[wip] add: code submission endpoint

deps.edn

@@ -7,7 +7,12 @@
         metosin/reitit-swagger {:mvn/version "0.6.0"}
         org.postgresql/postgresql {:mvn/version "42.7.3"}}
  :aliases
- {:dev {:extra-paths ["test" "dev"]}
+ {:dev {:extra-paths ["test" "dev"]
+        :extra-deps  {org.clojars.bigsy/pg-embedded-clj {:mvn/version "1.0.1"}
+                      lambdaisland/kaocha {:mvn/version "1.88.1376"}
+                      lambdaisland/kaocha-cloverage {:mvn/version "1.1.89"}
+                      nubank/matcher-combinators {:mvn/version "3.9.1"}
+                      nubank/state-flow {:mvn/version "5.15.0"}}}
   :test {:extra-paths ["test"]
          :extra-deps  {org.clojars.bigsy/pg-embedded-clj {:mvn/version "1.0.1"}
                        lambdaisland/kaocha {:mvn/version "1.88.1376"}

dev/user.clj

@@ -1,7 +1,7 @@
 (ns user
-  (:require [malli.dev :as dev]
-            [malli.dev.pretty :as pretty]
-            [microservice-boilerplate.server]))
+  (:require [codes.clj.contest.submission-runner.server]
+            [malli.dev :as dev]
+            [malli.dev.pretty :as pretty]))
 
 (defn start
   []

src/codes/clj/contest/submission_runner/ports/http_in/submission.clj

@@ -0,0 +1,8 @@
+(ns codes.clj.contest.submission-runner.ports.http-in.submission)
+
+(defn submit-code-execution!
+  [{_submission :parameters
+    _components :components}]
+  {:status 201
+   :body {:id (random-uuid)}})
+

src/codes/clj/contest/submission_runner/routes.clj

@@ -1,13 +1,16 @@
 (ns codes.clj.contest.submission-runner.routes
   (:require [codes.clj.contest.submission-runner.ports.http-in :as ports.http-in]
+            [codes.clj.contest.submission-runner.ports.http-in.submission :as ports.http-in.submission]
             [codes.clj.contest.submission-runner.schemas.wire-in :as schemas.wire-in]
+            [codes.clj.contest.submission-runner.wire.in.submission :as wire.in.submission]
+            [codes.clj.contest.submission-runner.wire.out.submission :as wire.out.submission]
             [reitit.swagger :as swagger]))
 
 (def routes
   [["/swagger.json"
     {:get {:no-doc true
-           :swagger {:info {:title "btc-wallet"
-                            :description "small sample using the microservice-boilerplate"}}
+           :swagger {:info {:title "Submission Runner"
+                            :description "Submission Runner API"}}
            :handler (swagger/create-swagger-handler)}}]
 
    ["/wallet"
@@ -32,4 +35,17 @@
              :responses {201 {:body schemas.wire-in/WalletEntry}
                          400 {:body :string}
                          500 {:body :string}}
-             :handler ports.http-in/do-withdrawal!}}]]])
+             :handler ports.http-in/do-withdrawal!}}]]
+
+   ;; submitions routes
+   ["/code"
+    {:swagger {:tags ["Code Runner"]}}
+    ["/submission"
+     {:post {:summary "Submit to execution your code"
+             :parameters {:body wire.in.submission/Submission}
+             :responses {201 {:body wire.out.submission/SubmissionResult}
+                         400 {:body :string}
+                         500 {:body :string}}
+             :handler ports.http-in.submission/submit-code-execution!}}]]])
+
+

src/codes/clj/contest/submission_runner/wire/in/submission.clj

@@ -0,0 +1,28 @@
+(ns codes.clj.contest.submission-runner.wire.in.submission)
+
+(def Submission
+  [:map
+   [:code string?]
+   [:language [:enum :clojure]]
+   [:test-cases [:map-of :keyword
+                 [:map
+                  [:input :any]
+                  [:output :any]]]]])
+
+(comment
+  (require '[malli.generator :as m])
+  (require '[malli.core :as m.core])
+  (m/generate Submission)
+  (m.core/validate
+   Submission
+   {:code "(ns runner 
+             (:require [clojure.test :refer [use-fixtures]])
+             (defn my-sum [a b] (+ a b)))"
+    :language :clojure
+    :test-cases {:case-1 {:input "(my-sum 1 2)"
+                          :output 3}
+                 :case-2 {:input "(my-sum 2 3)"
+                          :output 5}}})
+
+;
+  )

src/codes/clj/contest/submission_runner/wire/out/submission.clj

@@ -0,0 +1,5 @@
+(ns codes.clj.contest.submission-runner.wire.out.submission)
+
+(def SubmissionResult
+  [:map
+   [:id uuid?]])

test/integration/codes/clj/contest/submission_runner/db_test.clj → test/integration/codes/clj/contest/submission_runner/db/db_test.clj

@@ -1,4 +1,4 @@
-(ns integration.codes.clj.contest.submission-runner.db-test
+(ns integration.codes.clj.contest.submission-runner.db.db-test
   (:require [clojure.test :refer [use-fixtures]]
             [codes.clj.contest.submission-runner.db :as db]
             [com.stuartsierra.component :as component]

test/integration/codes/clj/contest/submission_runner/submission_runner_test.clj

@@ -0,0 +1,35 @@
+(ns integration.codes.clj.contest.submission-runner.submission-runner-test
+  (:require [clojure.test :refer [use-fixtures]]
+            [integration.codes.clj.contest.submission-runner.util :as util]
+            [matcher-combinators.matchers :as matchers]
+            [parenthesin.helpers.malli :as helpers.malli]
+            [parenthesin.helpers.state-flow.server.pedestal :as state-flow.server]
+            [state-flow.api :refer [defflow]]
+            [state-flow.assertions.matcher-combinators :refer [match?]]
+            [state-flow.core :as state-flow :refer [flow]]))
+
+(use-fixtures :once helpers.malli/with-intrumentation)
+
+(defflow
+  flow-integration-wallet-test
+  {:init util/start-system!
+   :cleanup util/stop-system!
+   :fail-fast? true}
+
+  (flow "should receive an submission"
+    [:let [submission-input {:code "(ns runner 
+                                      (:require [clojure.test :refer [use-fixtures]])
+                                      (defn my-sum [a b] (+ a b)))"
+                             :language :clojure
+                             :test-cases {:case-1 {:input "(my-sum 1 2)"
+                                                   :output 3}
+                                          :case-2 {:input "(my-sum 2 3)"
+                                                   :output 5}}}]
+     return (state-flow.server/request! {:method :post
+                                         :uri    "/code/submission"
+                                         :body submission-input})]
+
+    (match? (matchers/embeds {:status 201
+                              :body  {:id string?}})
+            return)))
+

test/integration/codes/clj/contest/submission_runner/util.clj

@@ -1,18 +1,38 @@
 (ns integration.codes.clj.contest.submission-runner.util
-  (:require [com.stuartsierra.component :as component]
+  (:require [codes.clj.contest.submission-runner.routes :as routes]
+            [com.stuartsierra.component :as component]
+            [parenthesin.components.config.aero :as components.config]
+            [parenthesin.components.db.jdbc-hikari :as components.database]
+            [parenthesin.components.http.clj-http :as components.http]
+            [parenthesin.components.router.reitit-malli :as components.router]
+            [parenthesin.components.server.reitit-pedestal-jetty :as components.webserver]
             [parenthesin.helpers.logs :as logs]
             [parenthesin.helpers.migrations :as migrations]
             [pg-embedded-clj.core :as pg-emb]))
 
+(defn- create-and-start-components! []
+  (component/start-system
+   (component/system-map
+    :config (components.config/new-config)
+    :http (components.http/new-http-mock {})
+    :router (components.router/new-router routes/routes)
+    :database (component/using (components.database/new-database)
+                               [:config])
+    :webserver (component/using (components.webserver/new-webserver)
+                                [:config :http :router :database]))))
+
 (defn start-system!
-  [system-start-fn]
-  (fn []
-    (logs/setup :info :auto)
-    (pg-emb/init-pg)
-    (migrations/migrate (migrations/configuration-with-db))
-    (system-start-fn)))
+  ([]
+   ((start-system! create-and-start-components!)))
+  ([system-start-fn]
+   (fn []
+     (logs/setup :info :auto)
+     (pg-emb/init-pg)
+     (migrations/migrate (migrations/configuration-with-db))
+     (system-start-fn))))
 
 (defn stop-system!
   [system]
   (component/stop-system system)
   (pg-emb/halt-pg!))
+

test/integration/codes/clj/contest/submission_runner/wallet_test.clj

@@ -1,14 +1,7 @@
 (ns integration.codes.clj.contest.submission-runner.wallet-test
   (:require [clojure.test :refer [use-fixtures]]
-            [codes.clj.contest.submission-runner.routes :as routes]
-            [com.stuartsierra.component :as component]
             [integration.codes.clj.contest.submission-runner.util :as util]
             [matcher-combinators.matchers :as matchers]
-            [parenthesin.components.config.aero :as components.config]
-            [parenthesin.components.db.jdbc-hikari :as components.database]
-            [parenthesin.components.http.clj-http :as components.http]
-            [parenthesin.components.router.reitit-malli :as components.router]
-            [parenthesin.components.server.reitit-pedestal-jetty :as components.webserver]
             [parenthesin.helpers.malli :as helpers.malli]
             [parenthesin.helpers.state-flow.http :as state-flow.http]
             [parenthesin.helpers.state-flow.server.pedestal :as state-flow.server]
@@ -18,20 +11,9 @@
 
 (use-fixtures :once helpers.malli/with-intrumentation)
 
-(defn- create-and-start-components! []
-  (component/start-system
-   (component/system-map
-    :config (components.config/new-config)
-    :http (components.http/new-http-mock {})
-    :router (components.router/new-router routes/routes)
-    :database (component/using (components.database/new-database)
-                               [:config])
-    :webserver (component/using (components.webserver/new-webserver)
-                                [:config :http :router :database]))))
-
 (defflow
   flow-integration-wallet-test
-  {:init (util/start-system! create-and-start-components!)
+  {:init util/start-system!
    :cleanup util/stop-system!
    :fail-fast? true}
   (flow "should interact with system"