feat(apollo): auto-sync sequence replies to leads via cron

apps/backend/src/app/integrations/apollo/apollo-sync.service.ts

@@ -0,0 +1,48 @@
+import { Injectable, Logger } from '@nestjs/common';
+import { Cron, CronExpression } from '@nestjs/schedule';
+import { PrismaService } from '../../../prisma/prisma.service';
+import { ApolloProspectsService } from './prospects/apollo-prospects.service';
+
+@Injectable()
+export class ApolloSyncService {
+  private readonly logger = new Logger(ApolloSyncService.name);
+
+  constructor(
+    private readonly prisma: PrismaService,
+    private readonly apolloProspectsService: ApolloProspectsService,
+  ) {}
+
+  @Cron(CronExpression.EVERY_10_MINUTES)
+  async syncAllCampaignReplies() {
+    const campaigns = await this.prisma.campaign.findMany({
+      where: {
+        providerSequenceId: { not: null },
+        icpProfileId: { not: null },
+      },
+    });
+
+    if (!campaigns.length) return;
+
+    this.logger.log(`Syncing replies for ${campaigns.length} campaigns`);
+
+    for (const campaign of campaigns) {
+      try {
+        const result = await this.apolloProspectsService.syncRepliesToLeads(
+          campaign.organizationId,
+          campaign.providerSequenceId!,
+          campaign.icpProfileId!,
+          campaign.id,
+        );
+        if (result.created > 0) {
+          this.logger.log(
+            `Campaign ${campaign.id}: created ${result.created} leads, skipped ${result.skipped}`,
+          );
+        }
+      } catch (err) {
+        this.logger.error(
+          `Campaign ${campaign.id} sync failed: ${String(err)}`,
+        );
+      }
+    }
+  }
+}

apps/backend/src/app/integrations/integrations.module.ts

@@ -10,7 +10,7 @@ import { ApolloSequencesController } from './apollo/sequences/apollo-sequences.c
 import { ApolloCampaignsController } from './apollo/sequences/apollo-campaigns.controller';
 import { ApolloProspectsService } from './apollo/prospects/apollo-prospects.service';
 import { ApolloProspectsController } from './apollo/prospects/apollo-prospects.controller';
-import { ApolloWebhookController } from './apollo/apollo-webhook.controller';
+import { ApolloSyncService } from './apollo/apollo-sync.service';
 import {
   CampaignsRepository,
   ContactsRepository,
@@ -26,10 +26,10 @@ import { PrismaService } from '../../prisma/prisma.service';
     ApolloSequencesController,
     ApolloCampaignsController,
     ApolloProspectsController,
-    ApolloWebhookController,
   ],
   providers: [
     OrganizationGuard,
+    ApolloSyncService,
     ApolloIntegrationRepository,
     ApolloIntegrationService,
     ApolloMcpService,