From bd24282d2bd23d11a63b156bd32db61bd2d79e00 Mon Sep 17 00:00:00 2001
From: Nevo David <me@nevos.io>
Date: Wed, 7 Jan 2026 15:40:31 +0700
Subject: [PATCH] fix: don't wait for workflow start, for faster creation

---
 .../database/prisma/posts/posts.service.ts    | 154 +++++++-----------
 1 file changed, 61 insertions(+), 93 deletions(-)

diff --git a/libraries/nestjs-libraries/src/database/prisma/posts/posts.service.ts b/libraries/nestjs-libraries/src/database/prisma/posts/posts.service.ts
index c019bfd8..d8dfd75d 100644
--- a/libraries/nestjs-libraries/src/database/prisma/posts/posts.service.ts
+++ b/libraries/nestjs-libraries/src/database/prisma/posts/posts.service.ts
@@ -414,6 +414,57 @@ export class PostsService {
   getPostByForWebhookId(id: string) {
     return this._postRepository.getPostByForWebhookId(id);
   }
+
+  async startWorkflow(taskQueue: string, postId: string, orgId: string) {
+    try {
+      const workflows = this._temporalService.client
+        .getRawClient()
+        ?.workflow.list({
+          query: `postId="${postId}" AND ExecutionStatus="Running"`,
+        });
+
+      for await (const executionInfo of workflows) {
+        try {
+          const workflow = await this._temporalService.client.getWorkflowHandle(
+            executionInfo.workflowId
+          );
+          if (
+            workflow &&
+            (await workflow.describe()).status.name !== 'TERMINATED'
+          ) {
+            await workflow.terminate();
+          }
+        } catch (err) {}
+      }
+    } catch (err) {}
+
+    try {
+      await this._temporalService.client
+        .getRawClient()
+        ?.workflow.start('postWorkflowV101', {
+          workflowId: `post_${postId}`,
+          taskQueue: 'main',
+          args: [
+            {
+              taskQueue: taskQueue,
+              postId: postId,
+              organizationId: orgId,
+            },
+          ],
+          typedSearchAttributes: new TypedSearchAttributes([
+            {
+              key: postIdSearchParam,
+              value: postId,
+            },
+            {
+              key: organizationId,
+              value: orgId,
+            },
+          ]),
+        });
+    } catch (err) {}
+  }
+
   async createPost(orgId: string, body: CreatePostDto): Promise<any[]> {
     const postList = [];
     for (const post of body.posts) {
@@ -440,54 +491,11 @@ export class PostsService {
         return [] as any[];
       }
 
-      new Promise(async () => {
-        try {
-          const workflows = this._temporalService.client
-            .getRawClient()
-            ?.workflow.list({
-              query: `postId="${posts[0].id}" AND ExecutionStatus="Running"`,
-            });
-
-          for await (const executionInfo of workflows) {
-            try {
-              const workflow =
-                await this._temporalService.client.getWorkflowHandle(
-                  executionInfo.workflowId
-                );
-              if (
-                workflow &&
-                (await workflow.describe()).status.name !== 'TERMINATED'
-              ) {
-                await workflow.terminate();
-              }
-            } catch (err) {}
-          }
-        } catch (err) {}
-
-        await this._temporalService.client
-          .getRawClient()
-          ?.workflow.start('postWorkflowV101', {
-            workflowId: `post_${posts[0].id}`,
-            taskQueue: 'main',
-            args: [
-              {
-                taskQueue: post.settings.__type.split('-')[0].toLowerCase(),
-                postId: posts[0].id,
-                organizationId: orgId,
-              },
-            ],
-            typedSearchAttributes: new TypedSearchAttributes([
-              {
-                key: postIdSearchParam,
-                value: posts[0].id,
-              },
-              {
-                key: organizationId,
-                value: orgId,
-              },
-            ]),
-          });
-      }).catch((err) => {});
+      this.startWorkflow(
+        post.settings.__type.split('-')[0].toLowerCase(),
+        posts[0].id,
+        orgId
+      ).catch((err) => {});
 
       Sentry.metrics.count('post_created', 1);
       postList.push({
@@ -512,53 +520,13 @@ export class PostsService {
     const newDate = await this._postRepository.changeDate(orgId, id, date);
 
     try {
-      const workflows = this._temporalService.client
-        .getRawClient()
-        ?.workflow.list({
-          query: `postId="${getPostById.id}" AND ExecutionStatus="Running"`,
-        });
-
-      for await (const executionInfo of workflows) {
-        try {
-          const workflow = await this._temporalService.client.getWorkflowHandle(
-            executionInfo.workflowId
-          );
-          if (
-            workflow &&
-            (await workflow.describe()).status.name !== 'TERMINATED'
-          ) {
-            await workflow.terminate();
-          }
-        } catch (err) {}
-      }
+      await this.startWorkflow(
+        getPostById.integration.providerIdentifier.split('-')[0].toLowerCase(),
+        getPostById.id,
+        orgId
+      );
     } catch (err) {}
 
-    await this._temporalService.client
-      .getRawClient()
-      ?.workflow.start('postWorkflowV101', {
-        workflowId: `post_${getPostById.id}`,
-        taskQueue: 'main',
-        args: [
-          {
-            taskQueue: getPostById.integration.providerIdentifier
-              .split('-')[0]
-              .toLowerCase(),
-            postId: getPostById.id,
-            organizationId: orgId,
-          },
-        ],
-        typedSearchAttributes: new TypedSearchAttributes([
-          {
-            key: postIdSearchParam,
-            value: getPostById.id,
-          },
-          {
-            key: organizationId,
-            value: orgId,
-          },
-        ]),
-      });
-
     return newDate;
   }