Initial commit

.gitignore

@@ -0,0 +1,24 @@
+/target
+/classes
+/checkouts
+profiles.clj
+pom.xml
+pom.xml.asc
+*.jar
+*.class
+/.lein-*
+/.nrepl-port
+/resources/public/js
+/out
+/.repl
+*.log
+/.env
+Procfile
+titanoboa.iml
+/.idea/**
+/resources/auth_privkey.pem
+fstab
+**/*.pem
+/test/*/
+!/test/shakes/
+figwheel_server.log

dev-resources/repo/demo/demo.001.edn

@@ -0,0 +1 @@
+{:name "demo", :revision 1, :type nil, :properties {}, :first-step "step", :steps [{:id "step", :type :custom, :supertype :tasklet, :next {3 "step3", 2 "step2"}, :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   (+ 1 1))"}, :properties {}} {:id "step2", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " (fn [j]\n      (+ 2 2))"}, :next {4 "step4", 5 "step5"}, :properties {}} {:id "step3", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " "}, :next {}, :properties {}} {:id "step4", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   \"Hello World!\")"}, :next {}, :properties {}} {:id "step5", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " "}, :next {}, :properties {}}]}

dev-resources/repo/demo/demo.002.edn

@@ -0,0 +1 @@
+{:name "demo", :revision 2, :type nil, :properties {}, :first-step "step", :steps [{:id "step", :type :custom, :supertype :tasklet, :next {3 "step3", 2 "step2"}, :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   (+ 1 1))"}, :properties {}} {:id "step2", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " (fn [j]\n      (+ 2 2))"}, :next {4 "step4", 5 "step5"}, :properties {}} {:id "step3", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " "}, :next {}, :properties {}} {:id "step4", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   \"Hello World!\")"}, :next {}, :properties {}} {:id "step5", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " "}, :next {}, :properties {}}]}

dev-resources/repo/demo/demo.003.edn

@@ -0,0 +1 @@
+{:first-step "step", :name "demo", :revision 3, :type nil, :properties {:name "Somebody"}, :steps [{:id "step", :type :custom, :supertype :tasklet, :next {3 "step3", 2 "step2"}, :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   (+ 1 1))"}, :properties {}} {:id "step2", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " (fn [j]\n      (+ 2 2))"}, :next {4 "step4", 5 "step5"}, :properties {}} {:id "step3", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "  (fn [j] \n   \"Hello World!\")"}, :next {}, :properties {}} {:id "step4", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   \"Hello World!\")"}, :next {}, :properties {}} {:id "step5", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "  (fn [j] \n   \"Hello World!\")"}, :next {}, :properties {}}]}

dev-resources/repo/demo/demo.004.edn

@@ -0,0 +1 @@
+{:first-step "step", :name "demo", :revision 4, :type nil, :properties {:name "Miroslavek"}, :steps [{:id "step", :type :custom, :supertype :tasklet, :next [[3 "step3"] [2 "step2"]], :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   (+ 1 1))"}, :properties {}} {:id "step2", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " (fn [j]\n      (+ 2 2))"}, :next [[4 "step4"] [5 "step5"]], :properties {}} {:id "step3", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "  (fn [j] \n   \"Hello World!\")"}, :next [], :properties {}} {:id "step4", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   \"Hello World!\")"}, :next [], :properties {}} {:id "step5", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "  (fn [j] \n   \"Hello World!\")"}, :next [], :properties {}}]}

dev-resources/repo/demo/demo.005.edn

@@ -0,0 +1 @@
+{:first-step "step", :name "demo", :revision 5, :type nil, :properties {:name "nobody"}, :steps [{:id "step", :type :custom, :supertype :tasklet, :next [[3 "step3"] [2 "step2"]], :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   (+ 1 1))"}, :properties {}} {:id "step2", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " (fn [j]\n      (+ 2 2))"}, :next [[4 "step4"] [5 "step5"]], :properties {}} {:id "step3", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "  (fn [j] \n   \"Hello World!\")"}, :next [], :properties {}} {:id "step4", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   \"Hello World!\")"}, :next [], :properties {}} {:id "step5", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "  (fn [j] \n   \"Hello World!\")"}, :next [], :properties {}}]}

dev-resources/repo/demo/demo.006.edn

@@ -0,0 +1 @@
+{:first-step "step", :name "demo", :revision 6, :type nil, :properties {:name "somebody"}, :steps [{:id "step", :type :custom, :supertype :tasklet, :next [[3 "step3"] [2 "step2"]], :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   (+ 1 1))"}, :properties {}} {:id "step2", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " (fn [j]\n      (+ 2 2))"}, :next [[4 "step4"] [5 "step5"]], :properties {}} {:id "step3", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "  (fn [j] \n   \"Hello World!\")"}, :next [], :properties {}} {:id "step4", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   \"Hello World!\")"}, :next [], :properties {}} {:id "step5", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "  (fn [j] \n   \"Hello World!\")"}, :next [], :properties {}}]}

dev-resources/repo/demo/demo.007.edn

@@ -0,0 +1 @@
+{:first-step "step", :name "demo", :revision 7, :type nil, :properties {:name "somebody to love"}, :steps [{:id "step", :type :custom, :supertype :tasklet, :next [[3 "step3"] [2 "step2"]], :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   (+ 1 1))"}, :properties {}} {:id "step2", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " (fn [j]\n      (+ 2 2))"}, :next [[4 "step4"] [5 "step5"]], :properties {}} {:id "step3", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "  (fn [j] \n   \"Hello World!\")"}, :next [], :properties {}} {:id "step4", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   \"Hello World!\")"}, :next [], :properties {}} {:id "step5", :type :custom, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "  (fn [j] \n   \"Hello World!\")"}, :next [], :properties {}}]}

dev-resources/repo/demo3/demo3.001.edn

@@ -0,0 +1 @@
+{:name "demo3", :revision 1, :type nil, :properties {}, :first-step "step", :steps [{:id "step", :type :http-client, :supertype :tasklet, :next {}, :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.httpclient/request"}, :properties {:request-method :get, :as :json, :response-property-name :rest-response, :body-only? true, :url #titanoboa.exp.Expression{:value "(mapv #(str \"https://jsonplaceholder.typicode.com/posts/\"  %) (range 1 10))"}}, :revision 1}]}

dev-resources/repo/demo3/demo3.002.edn

@@ -0,0 +1 @@
+{:name "demo3", :revision 2, :type nil, :properties {}, :first-step "stepasas", :steps [{:id "stepasas", :type :http-client, :supertype :tasklet, :next {}, :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.httpclient/request"}, :properties {:request-method :get, :as :json, :response-property-name :rest-response, :body-only? true, :url #titanoboa.exp.Expression{:value "(mapv #(str \"https://jsonplaceholder.typicode.com/posts/\"  %) (range 1 10))"}}, :revision 1}]}

dev-resources/repo/demo3/demo3.003.edn

@@ -0,0 +1 @@
+{:name "demo3", :revision 3, :type nil, :properties {}, :first-step "step", :steps [{:id "step", :type :http-client, :supertype :tasklet, :next {}, :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.httpclient/request"}, :properties {:request-method :get, :as :json, :response-property-name :rest-response, :body-only? true, :url #titanoboa.exp.Expression{:value "(mapv #(str \"https://jsonplaceholder.typicode.com/posts/\"  %) (range 1 10))"}}, :revision 1}]}

dev-resources/repo/http-test/http-test.001.edn

@@ -0,0 +1 @@
+{:name "http-test", :revision 1, :type nil, :properties {}, :first-step "step", :steps [{:id "step", :type :custom, :supertype :tasklet, :next {}, :workload-fn #titanoboa.exp.Expression{:value " "}, :properties {}}]}

dev-resources/repo/http-test/http-test.002.edn

@@ -0,0 +1 @@
+{:name "http-test", :revision 2, :type nil, :properties {}, :first-step "step", :steps [{:id "step", :type :custom, :supertype :tasklet, :next {}, :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   {(get-in j [:properties :response-property-name]) (clj-http.client/request (:properties j))})"}, :properties {:request-method :get, :url "https://jsonplaceholder.typicode.com/posts/1", :as :json, :response-property-name :response}}]}

dev-resources/repo/http-test/http-test.003.edn

@@ -0,0 +1 @@
+{:name "http-test", :revision 3, :type nil, :properties {}, :first-step "step", :steps [{:id "step", :type :custom, :supertype :tasklet, :next {}, :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n   {(get-in j [:properties :response-property-name]) (clj-http.client/request (:properties j))})"}, :properties {:request-method :get, :url "https://jsonplaceholder.typicode.com/posts/1", :as :json, :response-property-name :rest-response}}]}

dev-resources/repo/http-test/http-test.004.edn

@@ -0,0 +1 @@
+{:first-step "step", :name "http-test", :revision 4, :type nil, :properties {:lol ""}, :steps [{:id "step", :type :custom, :supertype :tasklet, :next {}, :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n  {:properties  \n   {(get-in j [:properties :response-property-name]) \n    (clj-http.client/request (:properties j))}})"}, :properties {:request-method :get, :url "https://jsonplaceholder.typicode.com/posts/1", :as :json, :response-property-name :rest-response}}]}

dev-resources/repo/http-test/http-test.005.edn

@@ -0,0 +1 @@
+{:first-step "http-client", :name "http-test", :revision 5, :type nil, :properties {:lol ""}, :steps [{:id "http-client", :type :custom, :supertype :tasklet, :next {}, :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n  {:properties  \n   {(get-in j [:properties :response-property-name]) \n    (clj-http.client/request (:properties j))}})"}, :properties {:request-method :get, :url "https://jsonplaceholder.typicode.com/posts/1", :as :json, :response-property-name :rest-response, :body-only? false}}]}

dev-resources/repo/http-test/http-test.006.edn

@@ -0,0 +1 @@
+{:first-step "http-client", :name "http-test", :revision 6, :type nil, :properties {:lol ""}, :steps [{:id "http-client", :type :http-client, :supertype :tasklet, :next {}, :workload-fn #titanoboa.exp.Expression{:value " (fn [j] \n  {:properties  \n   {(get-in j [:properties :response-property-name]) \n    (clj-http.client/request (:properties j))}})"}, :properties {:request-method :get, :url "https://jsonplaceholder.typicode.com/posts/1", :as :json, :response-property-name :rest-response, :body-only? false}, :revision 1}]}

dev-resources/repo/http-test/http-test.007.edn

@@ -0,0 +1 @@
+{:first-step "http-client", :name "http-test", :revision 7, :type nil, :properties {:lol ""}, :steps [{:id "http-client", :type :http-client, :supertype :tasklet, :next {}, :workload-fn #titanoboa.exp.Expression{:value " titanoboa.tasklet.http-client/request"}, :properties {:request-method :get, :as :json, :response-property-name :rest-response, :body-only? true, :connection-pool {:timeout 5, :threads 4, :insecure? false, :default-per-route 10}, :url #titanoboa.exp.Expression{:value "(mapv #(str \"https://jsonplaceholder.typicode.com/posts/\" %) (range 1 10))"}}, :revision 1}]}

dev-resources/repo/http-test/http-test.008.edn

@@ -0,0 +1 @@
+{:first-step "http-client", :name "http-test", :revision 8, :type nil, :properties {:lol ""}, :steps [{:id "http-client", :type :http-client, :supertype :tasklet, :next {"*" "load-data"}, :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.httpclient/request"}, :properties {:request-method :get, :as :json, :response-property-name :rest-response, :body-only? true, :connection-pool {:timeout 5, :threads 4, :insecure? false, :default-per-route 10}, :url #titanoboa.exp.Expression{:value "(mapv #(str \"https://jsonplaceholder.typicode.com/posts/\" %) (range 1 10))"}}, :revision 1} {:id "load-data", :type :jdbc, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.jdbc/query"}, :next {}, :properties {:response-property-name :db-data, :data-source-ks [:db :system :pool], :query {:select [:*], :from [:customers]}}, :revision 1}]}

dev-resources/repo/http-test/http-test.009.edn

@@ -0,0 +1 @@
+{:first-step "http-client", :name "http-test", :revision 9, :type nil, :properties {}, :steps [{:id "http-client", :type :http-client, :supertype :tasklet, :next {"*" "load-data"}, :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.httpclient/request"}, :properties {:request-method :get, :as :json, :response-property-name :rest-response, :body-only? true, :connection-pool {:timeout 5, :threads 4, :insecure? false, :default-per-route 10}, :url #titanoboa.exp.Expression{:value "(mapv #(str \"https://jsonplaceholder.typicode.com/posts/\" %) (range 1 10))"}}, :revision 1} {:id "load-data", :type :jdbc, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.jdbc/query"}, :next {}, :properties {:response-property-name :db-data, :data-source-ks [:db :system :pool], :query {:select [:id :name :address], :from [:customers], :where [:= :id 1]}}, :revision 1}]}

dev-resources/repo/http-test/http-test.010.edn

@@ -0,0 +1 @@
+{:first-step "http-client", :name "http-test", :revision 10, :type nil, :properties {}, :steps [{:id "http-client", :type :http-client, :supertype :tasklet, :next {"*" "load-data"}, :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.httpclient/request"}, :properties {:request-method :get, :as :json, :response-property-name :rest-response, :body-only? true, :connection-pool {:timeout 5, :threads 4, :insecure? false, :default-per-route 10}, :url #titanoboa.exp.Expression{:value "(mapv #(str \"https://jsonplaceholder.typicode.com/posts/\" %) (range 1 10))"}}, :revision 1} {:id "load-data", :type :jdbc, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.jdbc/query"}, :next {}, :properties {:response-property-name :db-data, :data-source-ks [:db :system :pool], :query {:select [:o.ordernumber :o.TotalAmount :c.FirstName :c.LastName :c.City :c.Country], :from [[:customers :c]], :left-join [[:orders :o] [:= :c.id :o.customerid]], :order-by [[:o.totalamount :desc :nulls-last]], :limit 10}}, :revision 1}]}

dev-resources/repo/http-test/http-test.011.edn

@@ -0,0 +1,16 @@
+{:first-step "http-client", :name "http-test", :revision 11, :type nil, :properties {},
+ :steps [{:id "http-client", :type :http-client, :supertype :tasklet, :next {"*" "load-data"},
+          :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.httpclient/request"},
+          :properties {:request-method :get, :as :json, :response-property-name :rest-response, :body-only? true,
+                       :connection-pool {:timeout 5, :threads 4, :insecure? false, :default-per-route 10},
+                       :url #titanoboa.exp.Expression{:value "(mapv #(str \"https://jsonplaceholder.typicode.com/posts/\" %) (range 1 10))"}}, :revision 1}
+         {:id "load-data", :type :jdbc, :supertype :tasklet,
+          :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.jdbc/query"}, :next {"*" "email"},
+          :properties {:response-property-name :db-data, :data-source-ks [:db :system :pool], :query {:select [:o.ordernumber :o.TotalAmount :c.FirstName :c.LastName :c.City :c.Country],
+                                                                                                      :from [[:customers :c]],
+                                                                                                      :left-join [[:orders :o] [:= :c.id :o.customerid]],
+                                                                                                      :order-by [[:o.totalamount :desc :nulls-last]],
+                                                                                                      :limit 10}}, :revision 1}
+         {:id "email", :type :smtp, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.smtp/send"}, :next {},
+          :dependencies [["com.draines/postal" "2.0.2"]],
+          :properties {:connection {:host "localhost", :port 2525}, :email {:from "miro@somedomain.net", :body "Tralalalala", :subject "hi there!", :to "joe@example.com"}}, :revision 1}]}

dev-resources/repo/http-test/http-test.012.edn

@@ -0,0 +1 @@
+{:first-step "http-client", :name "http-test", :revision 12, :type nil, :properties {}, :steps [{:id "http-client", :type :http-client, :supertype :tasklet, :next [["*" "load-data"]], :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.httpclient/request"}, :properties {:request-method :get, :as :json, :response-property-name :rest-response, :body-only? true, :connection-pool {:timeout 5, :threads 4, :insecure? false, :default-per-route 10}, :url #titanoboa.exp.Expression{:value "(mapv #(str \"https://jsonplaceholder.typicode.com/posts/\" %) (range 1 10))"}}, :revision 1} {:id "load-data", :type :jdbc, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.jdbc/query"}, :next [["*" "email"]], :properties {:response-property-name :db-data, :data-source-ks [:test-db :system :pool], :query {:select [:o.ordernumber :o.TotalAmount :c.FirstName :c.LastName :c.City :c.Country], :from [[:customers :c]], :left-join [[:orders :o] [:= :c.id :o.customerid]], :order-by [[:o.totalamount :desc :nulls-last]], :limit 10}}, :revision 1} {:properties {:connection {:host "localhost", :port 2525}, :email {:from "miro@somedomain.net", :body "Tralalalala", :subject "hi there!", :to "joe@example.com"}}, :revision 1, :type :smtp, :next [], :id "email", :supertype :tasklet, :dependencies [["com.draines/postal" "2.0.2"]], :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.smtp/send"}}]}

dev-resources/repo/http-test/http-test.013.edn

@@ -0,0 +1 @@
+{:first-step "http-client", :name "http-test", :revision 13, :type nil, :properties {}, :steps [{:id "http-client", :type :http-client, :supertype :tasklet, :next [["*" "load-data"]], :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.httpclient/request"}, :properties {:request-method :get, :as :json, :response-property-name :rest-response, :body-only? true, :connection-pool {:timeout 5, :threads 4, :insecure? false, :default-per-route 10}, :url #titanoboa.exp.Expression{:value "(mapv #(str \"https://jsonplaceholder.typicode.com/posts/\" %) (range 1 10))"}}, :revision 1} {:id "load-data", :type :jdbc, :supertype :tasklet, :workload-fn #titanoboa.exp.Expression{:value "titanoboa.tasklet.jdbc/query"}, :next [["*" "email"]], :properties {:response-property-name :db-data, :data-source-ks [:test-db :system :pool], :query {:select [:o.ordernumber :o.TotalAmount :c.FirstName :c.LastName :c.City :c.Country], :from [[:customers :c]], :left-join [[:orders :o] [:= :c.id :o.customerid]], :order-by [[:o.totalamount :desc :nulls-last]], :limit 10}}, :revision 1} {:properties {:connection {:host "localhost", :port 2525}, :email {:from "miro@somedomain.net", :body "Tralalalala", :subject "hi there!", :to "joe@example.com"}}, :revision 1, :type :smtp, :next [], :id "email", :supertype :tasklet, :dependencies [["com.draines/postal" "2.0.2"]], :workload-fn #titanoboa.exp.Expression{:value "(fn [{{:keys [connection email] :as properties} :properties :as job}]\n  (require 'postal.core)\n  (let [result-map (postal.core/send-message connection email)]\n    (if (= :SUCCESS (:error result-map))\n      {:exit (:code result-map)\n       :properties {:smtp-result result-map}}\n      result-map)))"}}]}