Merge pull request #114 from resonatehq/main

Bump 0.5

lib/async.ts

@@ -352,6 +352,31 @@ export class Context {
     }));
   }
 
+  /**
+   * Sleep for the specified time.
+   *
+   * @param ms Amount of time to sleep in milliseconds.
+   * @returns A Promise that resolves after the specified time has elapsed.
+   */
+  async sleep(ms: number): Promise<void> {
+    // generate id
+    const id = `${this.invocation.id}.${this.invocation.counter++}`;
+
+    // create a promise that resolves when it times out
+    const promise = await this.resonate.promises.create(id, Date.now() + ms, {
+      tags: { "resonate:timeout": "true" },
+    });
+
+    // wait for the promise to resolve
+    // if wait time < 1, delay will be set to 1
+    if (promise.pending) {
+      await new Promise((resolve) => setTimeout(resolve, promise.timeout - Date.now()));
+    }
+
+    // tight loop in case the promise is not yet resolved
+    await promise.wait(Infinity, this.invocation.opts.poll);
+  }
+
   /**
    * Generate a deterministic random number.
    *

lib/core/execution.ts

@@ -220,7 +220,6 @@ export class DeferredExecution<T> extends Execution<T> {
           headers: this.invocation.headers,
           param: this.invocation.param,
           tags: this.invocation.opts.tags,
-          poll: this.invocation.opts.poll,
         },
       );
 
@@ -240,7 +239,7 @@ export class DeferredExecution<T> extends Execution<T> {
   protected async join(future: Future<T>) {
     if (this.durablePromise) {
       // poll the completion of the durable promise
-      await this.durablePromise.completed;
+      await this.durablePromise.sync(Infinity, this.invocation.opts.poll);
 
       if (this.durablePromise.resolved) {
         this.invocation.resolve(this.durablePromise.value());