Add delete alarm

Signed-off-by: Marcos Candeia <[email protected]>
deco-cx · Nov 3, 2023 · b71ce19 · b71ce19
1 parent d137270
commit b71ce19
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/workflow.ts b/src/workflow.ts
@@ -36,6 +36,9 @@ export const buildRoutes = (wkflow: Workflow): Routes => {
       "POST": async (req: Request) => {
         const body: WorkflowExecution = await req.json();
         const shouldRestart = new URL(req.url).searchParams.has("restart");
+        const deleteAlarmPromise = shouldRestart
+          ? wkflow.state.storage.deleteAlarm()
+          : Promise.resolve();
         const pendingAndHistory = shouldRestart
           ? Promise.all([
             wkflow.execution.pending.get(),
@@ -48,6 +51,7 @@ export const buildRoutes = (wkflow: Workflow): Routes => {
           wkflow.execution.pending.del(...pending),
           wkflow.execution.history.del(...history),
           createPromise,
+          deleteAlarmPromise,
         ]);
         wkflow.workflowExecution = body;
         return new Response(JSON.stringify(body), { status: 201 });