Add side-effect/invoke and side-effect/now

Signed-off-by: Greg Haskins <[email protected]>

Author: ghaskins

src/temporal/side_effect.clj

@@ -2,9 +2,25 @@
 
 (ns temporal.side-effect
   "Methods for managing side-effects from within workflows"
-  (:import [io.temporal.workflow Workflow]))
+  (:require [taoensso.timbre :as log]
+            [taoensso.nippy :as nippy]
+            [temporal.internal.utils :refer [->Func] :as u])
+  (:import [io.temporal.workflow Workflow]
+           [java.time LocalTime]))
 
 (defn gen-uuid
   "A side-effect friendly random UUID generator"
   []
   (str (Workflow/randomUUID)))
+
+(defn invoke
+  "Invokes 'f' via a Temporal [SideEffect](https://docs.temporal.io/concepts/what-is-a-side-effect/)"
+  [f]
+  (nippy/thaw
+   (Workflow/sideEffect u/bytes-type
+                        (->Func (fn [] (nippy/freeze (f)))))))
+
+(defn now
+  "Returns the java.time.LocalTime as a SideEffect"
+  []
+  (invoke #(LocalTime/now)))

test/temporal/test/side_effect.clj

@@ -0,0 +1,23 @@
+;; Copyright © 2022 Manetu, Inc.  All rights reserved
+
+(ns temporal.test.side-effect
+  (:require [clojure.test :refer :all]
+            [taoensso.timbre :as log]
+            [temporal.client.core :as c]
+            [temporal.workflow :refer [defworkflow]]
+            [temporal.side-effect :as side-effect]
+            [temporal.test.utils :as t])
+  (:import [java.time LocalTime]))
+
+(use-fixtures :once t/wrap-service)
+
+(defworkflow side-effect-workflow
+  [ctx {:keys [args]}]
+  (log/info "workflow:" args)
+  (side-effect/now))
+
+(deftest the-test
+  (testing "Verifies that we can round-trip through start"
+    (let [workflow (t/create-workflow side-effect-workflow)]
+      (c/start workflow {})
+      (is (instance? LocalTime @(c/get-result workflow))))))