chore: rm old implementation

Author: J0sueTM

src/com/moclojer/components/consumer.clj

@@ -11,10 +11,10 @@
 (defn execute!
   [commands]
   (flow "makes database execution"
-        [database (state-flow.api/get-state :database)]
-        (-> database
-            (database/execute commands)
-            state-flow.api/return)))
+    [database (state-flow.api/get-state :database)]
+    (-> database
+        (database/execute commands {})
+        state-flow.api/return)))
 
 (defn- create-and-start-system
   []
@@ -29,10 +29,10 @@
    :fail-fast? true}
 
   (flow "creates a table and insert a row and retreive"
-        (execute! ["CREATE TABLE test (id SERIAL PRIMARY KEY, name VARCHAR(255))"])
+    (execute! ["CREATE TABLE test (id SERIAL PRIMARY KEY, name VARCHAR(255))"])
 
-        (execute! ["INSERT INTO test (name) VALUES ('test')"])
+    (execute! ["INSERT INTO test (name) VALUES ('test')"])
 
-        (match? [#:test {:name "test"
-                         :id 1}]
-                (execute! ["SELECT * FROM test"]))))
+    (match? [#:test {:name "test"
+                     :id 1}]
+            (execute! ["SELECT * FROM test"]))))

src/com/moclojer/components/publisher.clj

@@ -21,17 +21,17 @@
    :cleanup utils/stop-system!
    :fail-fast? true}
   (flow
-   "should create a file on storage and read it back"
-   [storage (get-state :storage)]
-   (state/invoke #(storage/create-bucket! storage "test"))
-   (state/invoke #(do
+    "should create a file on storage and read it back"
+    [storage (get-state :storage)]
+    (state/invoke #(storage/create-bucket! storage "test"))
+    (state/invoke #(do
                     ;; wait for bucket creation
-                    (Thread/sleep 1000)
-                    (storage/upload! storage "test" "test.txt" "hello world!")))
-   (match? "hello world!"
-           (state/return
-            (utils/exec-with-timeout
-             #(some-> (storage/get-file storage "test" "test.txt")
-                      io/reader
-                      slurp)
-             10000 500)))))
+                     (Thread/sleep 1000)
+                     (storage/upload! storage "test" "test.txt" "hello world!" {})))
+    (match? "hello world!"
+            (state/return
+             (utils/exec-with-timeout
+              #(some-> (storage/get-file storage "test" "test.txt")
+                       io/reader
+                       slurp)
+              10000 500)))))