Merge pull request #51 from seki-seki/feature/execute-404

Feature/execute 404

src/clj/job_streamer/control_bus/component/jobs.clj

@@ -659,6 +659,7 @@
                           (not (:job/exclusive? (:job ctx)))))
    :put-to-existing? (fn [ctx]
                        (#{:put :post} (get-in ctx [:request :request-method])))
+   :post-to-missing? (fn [ctx] (find-by-name jobs app-name job-name))
    :conflict? (fn [{job :job}]
                 (if-let [last-execution (some->> (:job/executions job)
                                                  (sort #(compare (:job-execution/create-time %2) (:job-execution/create-time %1)))

test/clj/job_streamer/control_bus/component/jobs_test.clj

@@ -417,10 +417,16 @@
                           :step-execution-id 11111111111111}]})
         (is (= "SUCCESS" (-> request handler :body read-string :job-execution/step-executions first :step-execution/exit-status)))))))
 
-
-
-
-
+(deftest executions-resource
+  (let [system (new-system config)]
+    ;; setup data
+    ((-> (jobs/list-resource (:jobs system) "default")) {:request-method :post
+              :content-type "application/edn"
+              :body (pr-str {:job/name "job1"})})
+    (testing "return 404 when job-name is not exist"
+      (let [handler (-> (jobs/executions-resource (:jobs system) "default" "job2"))
+            request {:request-method :post}]
+        (is (= 404 (-> request handler :status)))))))
 
 (deftest parse-query
   (testing "parse-query"