Expose ActivityInfo in public API

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

Author: ghaskins

src/temporal/activity.clj

@@ -41,6 +41,11 @@ along with the Activity Task for the next retry attempt and can be extracted by
       (log/trace "get-heartbeat-details:" v)
       v)))
 
+(defn get-info
+  "Returns information about the Activity execution"
+  []
+  (a/get-info))
+
 (defn- complete-invoke
   [activity result]
   (log/trace activity "completed with" (count result) "bytes")

src/temporal/internal/activity.clj

@@ -58,9 +58,10 @@
      :activity-type  (.getActivityType d)}))
 
 (defn get-info []
-  (-> (Activity/getExecutionContext)
-      (.getInfo)
-      (d/datafy)))
+  (->> (Activity/getExecutionContext)
+       (.getInfo)
+       (d/datafy)
+       (into {})))
 
 (defn get-annotation
   ^String [x]

test/temporal/test/activity_info.clj

@@ -0,0 +1,26 @@
+;; Copyright © Manetu, Inc.  All rights reserved
+
+(ns temporal.test.activity-info
+  (:require [clojure.test :refer :all]
+            [temporal.client.core :as c]
+            [temporal.workflow :refer [defworkflow]]
+            [temporal.activity :refer [defactivity] :as a]
+            [temporal.test.utils :as t]))
+
+(use-fixtures :once t/wrap-service)
+
+(defactivity getinfo-activity
+  [ctx args]
+  (a/get-info))
+
+(defworkflow getinfo-workflow
+  [args]
+  @(a/invoke getinfo-activity args))
+
+(deftest the-test
+  (testing "Verifies that we can retrieve our activity-id"
+    (let [workflow (t/create-workflow getinfo-workflow)]
+      (c/start workflow {})
+      (let [{:keys [activity-id]} @(c/get-result workflow)]
+        (is (some? activity-id))))))
+