Handle website workflows

src/controllers/platform.controller.ts

@@ -6,14 +6,19 @@ import { DatabaseManager, PlatformNames } from '@togethercrew.dev/db';
 
 import config from '../config';
 import parentLogger from '../config/logger';
-import {
-    discord, generateCodeChallenge, generateCodeVerifier, generateState, google, twitter
-} from '../config/oAtuh2';
+import { discord, generateCodeChallenge, generateCodeVerifier, generateState, google, twitter } from '../config/oAtuh2';
 import { IAuthAndPlatform, ISessionRequest } from '../interfaces';
 import { IAuthRequest } from '../interfaces/Request.interface';
 import {
-    discordServices, discourseService, githubService, googleService, notionService, platformService,
-    tokenService, twitterService, userService
+  discordServices,
+  discourseService,
+  githubService,
+  googleService,
+  notionService,
+  platformService,
+  tokenService,
+  twitterService,
+  userService,
 } from '../services';
 import { catchAsync, pick } from '../utils';
 

src/services/module.service.ts

@@ -1,8 +1,6 @@
 import { FilterQuery, HydratedDocument, ObjectId, Types } from 'mongoose';
 
-import {
-    IModule, IModuleUpdateBody, Module, ModuleNames, PlatformNames
-} from '@togethercrew.dev/db';
+import { IModule, IModuleUpdateBody, Module, ModuleNames, PlatformNames } from '@togethercrew.dev/db';
 
 import platformService from './platform.service';
 import websiteService from './website';
@@ -65,14 +63,10 @@ const updateModule = async (
   module: HydratedDocument<IModule>,
   updateBody: Partial<IModuleUpdateBody>,
 ): Promise<HydratedDocument<IModule>> => {
-  console.log('S1', module.name, updateBody.options?.platforms);
-
   if (!updateBody.options?.platforms?.length) {
     return module.save();
   }
 
-  console.log('S2', module.options);
-
   if (!module.options) {
     module.options = { platforms: [] };
   } else if (!module.options.platforms) {
@@ -81,8 +75,6 @@ const updateModule = async (
 
   const platforms = updateBody.options.platforms;
 
-  console.log('S3', platforms[0].name);
-
   if (platforms[0].name === undefined) {
     const globalOption = module.options.platforms[0];
     if (globalOption) {
@@ -134,6 +126,7 @@ const handleHivemindWebsiteCase = async (platform: any) => {
   } else if (isActivated === false) {
     if (existingScheduleId) {
       await websiteService.coreService.deleteWebsiteSchedule(existingScheduleId);
+      await websiteService.coreService.terminateWebsiteWorkflow(platformDoc.community.toString());
       platformDoc.set('metadata.scheduleId', null);
 
       await platformDoc.save();

src/services/platform.service.ts

@@ -374,6 +374,7 @@ const handleWebsiteResourceChanges = async (
 
   if (platform.metadata.scheduleId) {
     await websiteService.coreService.deleteWebsiteSchedule(platform.metadata.scheduleId);
+    await websiteService.coreService.terminateWebsiteWorkflow(platform.community.toString());
     updateBody.metadata.scheduleId = null;
   }
 

src/services/temporal/website.service.ts

@@ -60,6 +60,12 @@ class TemporalWebsiteService extends TemporalCoreService {
     const handle = client.schedule.getHandle(scheduleId);
     await handle.delete();
   }
+
+  public async terminateWorkflow(workflowId: string): Promise<void> {
+    const client: Client = await this.getClient();
+    const handle = client.workflow.getHandle(workflowId);
+    await handle.terminate();
+  }
 }
 
 export default new TemporalWebsiteService();

src/services/website/core.service.ts

@@ -27,7 +27,17 @@ async function deleteWebsiteSchedule(scheduleId: string): Promise<void> {
   }
 }
 
+async function terminateWebsiteWorkflow(workflowId: string): Promise<void> {
+  try {
+    await temporalWebsite.terminateWorkflow(workflowId);
+  } catch (error) {
+    logger.error(error, 'Failed to terminate website workflow.');
+    throw new ApiError(590, 'Failed to terminate website workflow.');
+  }
+}
+
 export default {
   createWebsiteSchedule,
   deleteWebsiteSchedule,
+  terminateWebsiteWorkflow,
 };