chore: Update to types@4.0.0, workflow-support@4.0.0

Author: tomasol

activity-sleepy/wit/ext/tutorial_activity-obelisk-ext/activity-obelisk-ext.wit

@@ -1,8 +1,10 @@
-// Generated by Obelisk 0.26.2
+// Generated by Obelisk 0.29.0
 package tutorial:activity-obelisk-ext;
 
 interface activity-sleepy {
-  use obelisk:types/execution@3.0.0.{execution-id, join-set, await-next-extension-error, get-extension-error, invoke-extension-error};
+  use obelisk:types/execution@4.0.0.{execution-id};
+  use obelisk:types/join-set@4.0.0.{join-set};
+  use obelisk:types/execution@4.0.0.{await-next-extension-error, get-extension-error, invoke-extension-error};
 
   step-submit: func(join-set: borrow<join-set>, idx: u64, sleep-millis: u64) -> execution-id;
 

activity-sleepy/wit/ext/tutorial_activity-obelisk-schedule/activity-obelisk-schedule.wit

@@ -1,9 +1,9 @@
-// Generated by Obelisk 0.26.2
+// Generated by Obelisk 0.29.0
 package tutorial:activity-obelisk-schedule;
 
 interface activity-sleepy {
-  use obelisk:types/execution@3.0.0.{execution-id};
-  use obelisk:types/time@3.0.0.{schedule-at};
+  use obelisk:types/execution@4.0.0.{execution-id};
+  use obelisk:types/time@4.0.0.{schedule-at};
 
   step-schedule: func(schedule-at: schedule-at, idx: u64, sleep-millis: u64) -> execution-id;
 }

workflow-tutorial/src/lib.rs

@@ -2,7 +2,7 @@ use exports::tutorial::workflow::workflow::Guest;
 use obelisk::{
     log::log,
     types::time::{Duration, ScheduleAt},
-    workflow::workflow_support::{self, ClosingStrategy, new_join_set_generated},
+    workflow::workflow_support,
 };
 use tutorial::{
     activity::activity_sleepy::step,
@@ -20,7 +20,7 @@ impl Guest for Component {
         let mut acc = 0;
         for i in 0..10 {
             log::info("Persistent sleep started");
-            workflow_support::sleep(ScheduleAt::In(Duration::Seconds(1)));
+            workflow_support::sleep(ScheduleAt::In(Duration::Seconds(1)))?;
             log::info("Persistent sleep finished");
             let result = step(i, i * 200).inspect_err(|_| log::error("step timed out"))?;
             acc += result;
@@ -35,7 +35,7 @@ impl Guest for Component {
         let max_iterations = 10;
         let mut handles = Vec::new();
         for i in 0..max_iterations {
-            let join_set = new_join_set_generated(ClosingStrategy::Complete);
+            let join_set = workflow_support::join_set_create();
             step_submit(&join_set, i, i * 200);
             handles.push((i, join_set));
         }
@@ -47,7 +47,7 @@ impl Guest for Component {
             let result = result.inspect_err(|_| log::error("step timed out"))?;
             acc = 10 * acc + result; // order-sensitive
             log::info(&format!("step({i})={result}, acc={acc}"));
-            workflow_support::sleep(ScheduleAt::In(Duration::Milliseconds(300)));
+            workflow_support::sleep(ScheduleAt::In(Duration::Milliseconds(300)))?;
         }
         log::info(&format!("parallel completed: {acc}"));
         Ok(acc)

workflow-tutorial/wit/deps/obelisk_types@3.0.0/types.wit

@@ -1,4 +1,4 @@
-package obelisk:types@3.0.0;
+package obelisk:types@4.0.0;
 
 @since(version = 3.0.0)
 interface time {
@@ -28,16 +28,9 @@ interface time {
     }
 }
 
-@since(version = 3.0.0)
+@since(version = 4.0.0)
 interface execution {
 
-    /// Join set resouce.
-    @since(version = 3.0.0)
-    resource join-set {
-        @since(version = 3.0.0)
-        id: func() -> string;
-    }
-
     @since(version = 3.0.0)
     record execution-id {
         id: string,
@@ -106,3 +99,41 @@ interface execution {
         conflict,
     }
 }
+
+
+@since(version = 4.0.0)
+interface join-set {
+    use time.{schedule-at};
+    use execution.{delay-id, response-id};
+
+    /// Join set resouce.
+    @since(version = 4.0.0)
+    resource join-set {
+
+        /// Get the join set identifier in the form of:
+        /// * `o:NAME` in case of a one-off join set, where `NAME` is generally an auto-incremented index optionally followed by underscode and a supplied name,
+        /// * `g:NAME` in case of a generated join set where `NAME` is generally an auto-incremented index,
+        /// * `n:NAME` in case of a named join set
+        @since(version = 4.0.0)
+        id: func() -> string;
+
+        /// Submit a delay request to the join set. The delay can be later polled using `join-next`.
+        @since(version = 4.0.0)
+        submit-delay: func(timeout: schedule-at) -> delay-id;
+
+        /// Block the workflow execution until next response associated with the join set arrives.
+        /// The response is marked as processed.
+        /// Child execution result can be obtained using `-get` extension function using the
+        /// returned execution ID.
+        /// Return `join-next-error::all-processed` if the join set has all requests matched with responses.
+        @since(version = 4.0.0)
+        join-next: func() -> result<tuple<response-id, result>, join-next-error>;
+    }
+
+    /// Error variants that may occur when calling `join-next` function.
+    @since(version = 4.0.0)
+    variant join-next-error {
+        /// All submitted requests and their responses were already processed.
+        all-processed,
+    }
+}

…l/wit/deps/obelisk_types@3.0.0/types.wit …l/wit/deps/obelisk_types@4.0.0/types.witwebhook-tutorial/wit/deps/obelisk_types@3.0.0/types.wit renamed to workflow-tutorial/wit/deps/obelisk_types@4.0.0/types.wit webhook-tutorial/wit/deps/obelisk_types@3.0.0/types.wit renamed to workflow-tutorial/wit/deps/obelisk_types@4.0.0/types.wit

@@ -0,0 +1,51 @@
+package obelisk:workflow@4.0.0;
+
+@since(version = 4.0.0)
+interface workflow-support {
+    use obelisk:types/time@4.0.0.{schedule-at, datetime};
+    use obelisk:types/execution@4.0.0.{delay-id, execution-id, response-id};
+    use obelisk:types/join-set@4.0.0.{join-set};
+
+    /// Error variants that may occur on named join set creation.
+    @since(version = 3.0.0)
+    variant join-set-create-error {
+        conflict,
+        invalid-name(string),
+    }
+
+    /// Returns a random u64 in the range [min, max).
+    @since(version = 3.0.0)
+    random-u64: func(min: u64, max-exclusive: u64) -> u64;
+    /// Returns a random u64 in the range [min, max].
+    @since(version = 3.0.0)
+    random-u64-inclusive: func(min: u64, max-inclusive: u64) -> u64;
+
+    /// Returns a random string with a length in the range [min_length, max_length).
+    /// The string consists only of alphanumeric characters (lowercase and uppercase letters, digits).
+    @since(version = 3.0.0)
+    random-string: func(min-length: u16, max-length-exclusive: u16) -> string;
+
+    /// Block execution for given time, return the time when the durable sleep expires.
+    /// Returns error if the delay is cancelled.
+    @since(version = 4.0.0)
+    sleep: func(schedule-at: schedule-at) -> result<datetime>;
+
+    /// Create a new join set with a generated name.
+    @since(version = 4.0.0)
+    join-set-create: func() -> join-set;
+
+    /// Create a new join set with the specified name.
+    /// The name may only contain alphanumeric characters and the following extra characters:
+    /// * underscore `_`
+    /// * dash `-`
+    /// * forward slash `/`
+    @since(version = 4.0.0)
+    join-set-create-named: func(name: string) -> result<join-set, join-set-create-error>;
+
+    /// Explicitly close join set. Unawaited delay requests are ignored,
+    /// unawaited activities are cancelled, unawaited child workflows block
+    /// until finish, as mandated by structured concurrency pattern.
+    /// Extension function `-get` can be later used to lookup the execution result.
+    @since(version = 4.0.0)
+    join-set-close: func(self: join-set);
+}

workflow-tutorial/wit/deps/obelisk_workflow@3.0.0/workflow-support.wit

@@ -7,7 +7,7 @@ world any {
     // Generated extensions for `parallel` workflow.
     import tutorial:activity-obelisk-ext/activity-sleepy;
     // Obelisk SDK
-    import obelisk:types/execution@3.0.0;
-    import obelisk:workflow/workflow-support@3.0.0;
+    import obelisk:types/execution@4.0.0;
+    import obelisk:workflow/workflow-support@4.0.0;
     import obelisk:log/log@1.0.0;
 }