feat: route packages_worker Temporal alerts to dedicated Akrites Slack channel (#4409)

Signed-off-by: Joana Maia <jmaia@contractor.linuxfoundation.org>
Co-authored-by: Claude Opus 4.7 <noreply@anthropic.com>

Author: joanagmaia

services/apps/packages_worker/src/activities.ts

@@ -61,3 +61,4 @@ export {
   blastRadiusReachability,
   blastRadiusReport,
 } from './blast-radius/activities'
+export { slackNotify } from './activities/index'

services/apps/packages_worker/src/activities/index.ts

@@ -0,0 +1,16 @@
+import { getServiceChildLogger } from '@crowd/logging'
+import { SlackChannel, SlackPersona, sendSlackNotificationAsync } from '@crowd/slack'
+
+const log = getServiceChildLogger('activity-interceptor')
+
+async function slackNotify(message: string, persona: SlackPersona | string) {
+  await sendSlackNotificationAsync(
+    SlackChannel.CDP_AKRITES_ALERTS,
+    persona as SlackPersona,
+    'Temporal Alert',
+    message,
+  )
+  log.info('Slack notification sent from Temporal activity')
+}
+
+export { slackNotify }

services/apps/packages_worker/src/service.ts

@@ -1,5 +1,6 @@
 import { Config } from '@crowd/archetype-standard'
 import { Options, ServiceWorker } from '@crowd/archetype-worker'
+import { SlackChannel } from '@crowd/slack'
 
 const config: Config = {
   envvars: [],
@@ -10,6 +11,7 @@ const config: Config = {
 
 const options: Options = {
   postgres: { enabled: false }, // packages-db is managed via getPackagesDb()
+  alertChannel: SlackChannel.CDP_AKRITES_ALERTS,
 }
 
 export const svc = new ServiceWorker(config, options)

services/archetypes/worker/src/activities/activityInterceptor.ts

@@ -6,7 +6,10 @@ import { SlackChannel, SlackPersona, sendSlackNotificationAsync } from '@crowd/s
 import telemetry from '@crowd/telemetry'
 
 export class ActivityMonitoringInterceptor implements ActivityInboundCallsInterceptor {
-  public constructor(private readonly ctx: Context) {}
+  public constructor(
+    private readonly ctx: Context,
+    private readonly alertChannel: SlackChannel = SlackChannel.CDP_ALERTS,
+  ) {}
   async execute(
     input: ActivityExecuteInput,
     next: Next<ActivityInboundCallsInterceptor, 'execute'>,
@@ -34,7 +37,7 @@ export class ActivityMonitoringInterceptor implements ActivityInboundCallsInterc
 
       // Fire and forget - don't await to avoid blocking the activity
       sendSlackNotificationAsync(
-        SlackChannel.CDP_ALERTS,
+        this.alertChannel,
         SlackPersona.WARNING_PROPAGATOR,
         'High Activity Retry Count',
         message,

services/archetypes/worker/src/worker.ts

@@ -14,6 +14,7 @@ import { DbStore, getDbConnection } from '@crowd/database'
 import { getServiceChildLogger } from '@crowd/logging'
 import { OpenSearchService, getOpensearchClient } from '@crowd/opensearch'
 import { IQueue, QueueFactory } from '@crowd/queue'
+import { SlackChannel } from '@crowd/slack'
 import { getDataConverter } from '@crowd/temporal'
 
 import * as metricActivities from './activities'
@@ -51,6 +52,7 @@ Options is used to configure the worker service.
 export interface Options {
   maxTaskQueueActivitiesPerSecond?: number
   maxConcurrentActivityTaskExecutions?: number
+  alertChannel?: SlackChannel
   postgres?: {
     enabled: boolean
   }
@@ -288,7 +290,7 @@ export class ServiceWorker extends Service {
             activity: [
               (ctx) => {
                 return {
-                  inbound: new ActivityMonitoringInterceptor(ctx),
+                  inbound: new ActivityMonitoringInterceptor(ctx, this.options.alertChannel),
                 }
               },
             ],

services/libs/slack/src/channels.ts

@@ -13,6 +13,7 @@ const CHANNEL_WEBHOOK_URLS: Record<SlackChannel, string | undefined> = {
   [SlackChannel.INSIGHTS_ALERTS]: process.env.INSIGHTS_ALERTS_SLACK_WEBHOOK_URL,
   [SlackChannel.INSIGHTS_CRITICAL_ALERTS]: process.env.INSIGHTS_CRITICAL_ALERTS_SLACK_WEBHOOK_URL,
   [SlackChannel.CDP_LFX_SELF_SERVE_ALERTS]: process.env.CDP_LFX_SELF_SERVE_ALERTS_SLACK_WEBHOOK_URL,
+  [SlackChannel.CDP_AKRITES_ALERTS]: process.env.CDP_AKRITES_ALERTS_SLACK_WEBHOOK_URL,
 }
 
 // Check for missing webhook URLs on initialization

services/libs/slack/src/types.ts

@@ -7,6 +7,7 @@ export enum SlackChannel {
   INSIGHTS_ALERTS = 'INSIGHTS_ALERTS',
   INSIGHTS_CRITICAL_ALERTS = 'INSIGHTS_CRITICAL_ALERTS',
   CDP_LFX_SELF_SERVE_ALERTS = 'CDP_LFX_SELF_SERVE_ALERTS',
+  CDP_AKRITES_ALERTS = 'CDP_AKRITES_ALERTS',
 }
 
 export enum SlackPersona {