From 7ac99e8259347d3a71f98eb87963e4fc1fa5addf Mon Sep 17 00:00:00 2001
From: Nevo David <me@nevos.io>
Date: Tue, 6 Jan 2026 12:51:06 +0700
Subject: [PATCH] fix: digest send async

---
 apps/orchestrator/src/activities/email.activity.ts           | 5 +++++
 apps/orchestrator/src/workflows/digest.email.workflow.ts     | 4 ++--
 apps/orchestrator/src/workflows/send.email.workflow.ts       | 3 +--
 .../src/integrations/social/tiktok.provider.ts               | 1 -
 4 files changed, 8 insertions(+), 5 deletions(-)

diff --git a/apps/orchestrator/src/activities/email.activity.ts b/apps/orchestrator/src/activities/email.activity.ts
index 3430a871..edaff56c 100644
--- a/apps/orchestrator/src/activities/email.activity.ts
+++ b/apps/orchestrator/src/activities/email.activity.ts
@@ -16,6 +16,11 @@ export class EmailActivity {
     return this._emailService.sendEmailSync(to, subject, html, replyTo);
   }
 
+  @ActivityMethod()
+  async sendEmailAsync(to: string, subject: string, html: string, replyTo?: string) {
+    return this._emailService.sendEmail(to, subject, html, replyTo);
+  }
+
   @ActivityMethod()
   async getUserOrgs(id: string) {
     return this._organizationService.getTeam(id);
diff --git a/apps/orchestrator/src/workflows/digest.email.workflow.ts b/apps/orchestrator/src/workflows/digest.email.workflow.ts
index acfe9eb6..bc5bf4cb 100644
--- a/apps/orchestrator/src/workflows/digest.email.workflow.ts
+++ b/apps/orchestrator/src/workflows/digest.email.workflow.ts
@@ -8,7 +8,7 @@ import {
 import { Email, emailSignal } from '@gitroom/orchestrator/signals/email.signal';
 import { EmailActivity } from '@gitroom/orchestrator/activities/email.activity';
 
-const { sendEmail, getUserOrgs } = proxyActivities<EmailActivity>({
+const { getUserOrgs, sendEmailAsync } = proxyActivities<EmailActivity>({
   startToCloseTimeout: '10 minute',
   taskQueue: 'main',
   retry: {
@@ -52,7 +52,7 @@ export async function digestEmailWorkflow({
 
       if (toSend.length === 0) continue;
 
-      await sendEmail(
+      await sendEmailAsync(
         user.user.email,
         toSend.length === 1
           ? toSend[0].title
diff --git a/apps/orchestrator/src/workflows/send.email.workflow.ts b/apps/orchestrator/src/workflows/send.email.workflow.ts
index 71e552eb..932e5092 100644
--- a/apps/orchestrator/src/workflows/send.email.workflow.ts
+++ b/apps/orchestrator/src/workflows/send.email.workflow.ts
@@ -21,8 +21,7 @@ const { sendEmail } = proxyActivities<EmailActivity>({
   },
 });
 
-// Rate limit: 2 requests per second = 500ms between requests
-const RATE_LIMIT_MS = 500;
+const RATE_LIMIT_MS = 700;
 
 export async function sendEmailWorkflow({
   queue = [],
diff --git a/libraries/nestjs-libraries/src/integrations/social/tiktok.provider.ts b/libraries/nestjs-libraries/src/integrations/social/tiktok.provider.ts
index bf4f7264..d6b52960 100644
--- a/libraries/nestjs-libraries/src/integrations/social/tiktok.provider.ts
+++ b/libraries/nestjs-libraries/src/integrations/social/tiktok.provider.ts
@@ -444,7 +444,6 @@ export class TiktokProvider extends SocialAbstract implements SocialProvider {
     integration: Integration
   ): Promise<PostResponse[]> {
     const [firstPost] = postDetails;
-    console.log('hello');
     const isPhoto = (firstPost?.media?.[0]?.path?.indexOf('mp4') || -1) === -1;
     const {
       data: { publish_id },