Implement weekly financial report schedule

workers/main/src/configs/schedules.ts

@@ -0,0 +1,71 @@
+import { Client } from '@temporalio/client';
+
+import { logger } from '../logger';
+import { weeklyFinancialReportsWorkflow } from '../workflows';
+import { workerConfig } from './worker';
+
+const SCHEDULE_ID = 'weekly-financial-report-schedule';
+
+/**
+ * Sets up the weekly financial report schedule
+ * Schedule runs every Tuesday at 1 PM America/New_York time (EST/EDT)
+ * @param client - Temporal client instance
+ */
+export async function setupWeeklyReportSchedule(client: Client): Promise<void> {
+  try {
+    const scheduleHandle = client.schedule.getHandle(SCHEDULE_ID);
+
+    // Check if schedule already exists
+    try {
+      await scheduleHandle.describe();
+      logger.info(`Schedule ${SCHEDULE_ID} already exists, skipping creation`);
+
+      return;
+    } catch (error) {
+      const errorMessage =
+        error instanceof Error ? error.message : String(error);
+
+      // Schedule doesn't exist, create it
+      logger.info(
+        `Schedule ${SCHEDULE_ID} not found, creating schedule. Reason: ${errorMessage}`,
+      );
+    }
+
+    await client.schedule.create({
+      scheduleId: SCHEDULE_ID,
+      spec: {
+        cronExpressions: ['0 13 * * 2'], // Every Tuesday at 1 PM
+        timezone: 'America/New_York', // Automatically handles EST/EDT transitions
+      },
+      action: {
+        type: 'startWorkflow',
+        workflowType: weeklyFinancialReportsWorkflow,
+        taskQueue: workerConfig.taskQueue,
+        workflowId: `weekly-financial-report-scheduled`,
+      },
+      policies: {
+        overlap: 'SKIP', // Skip if previous run is still in progress
+        catchupWindow: '1 day', // Catch up missed runs within 1 day
+      },
+    });
+
+    logger.info(
+      `Successfully created schedule ${SCHEDULE_ID} for weekly financial reports`,
+    );
+  } catch (error) {
+    logger.error(
+      `Failed to setup schedule ${SCHEDULE_ID}: ${error instanceof Error ? error.message : String(error)}`,
+    );
+    throw error;
+  }
+}
+
+/**
+ * Schedule configuration exported for documentation and testing
+ */
+export const scheduleConfig = {
+  scheduleId: SCHEDULE_ID,
+  cronExpression: '0 13 * * 2',
+  timezone: 'America/New_York',
+  description: 'Runs every Tuesday at 1 PM EST/EDT',
+} as const;

workers/main/src/configs/temporal.ts

@@ -3,10 +3,26 @@ import { z } from 'zod';
 
 const DEFAULT_TEMPORAL_ADDRESS = 'temporal:7233';
 
+/**
+ * Temporal connection configuration
+ * Used by both workers and clients to connect to Temporal server
+ */
 export const temporalConfig: NativeConnectionOptions = {
   address: process.env.TEMPORAL_ADDRESS || DEFAULT_TEMPORAL_ADDRESS,
 };
 
 export const temporalSchema = z.object({
   TEMPORAL_ADDRESS: z.string().default(DEFAULT_TEMPORAL_ADDRESS),
 });
+
+/**
+ * Schedule Configuration Documentation
+ *
+ * Weekly Financial Report Schedule:
+ * The schedule is automatically created/verified when the worker starts.
+ *
+ * For schedule configuration details (schedule ID, cron expression, timezone, etc.),
+ * see the exported `scheduleConfig` object in ./schedules.ts
+ *
+ * Implementation: ./schedules.ts
+ */

workers/main/src/index.test.ts

@@ -1,6 +1,7 @@
 import { afterEach, beforeEach, describe, expect, it, vi } from 'vitest';
 
-import { handleRunError, logger } from './index';
+import { handleRunError } from './index';
+import { logger } from './logger';
 
 describe('handleRunError', () => {
   let processExitSpy: ReturnType<typeof vi.spyOn>;

workers/main/src/index.ts

@@ -1,11 +1,14 @@
-import { DefaultLogger, NativeConnection, Worker } from '@temporalio/worker';
+import { Client, Connection } from '@temporalio/client';
+import { NativeConnection, Worker } from '@temporalio/worker';
 
 import * as activities from './activities';
 import { validateEnv } from './common/utils';
+import { setupWeeklyReportSchedule } from './configs/schedules';
 import { temporalConfig } from './configs/temporal';
 import { workerConfig } from './configs/worker';
+import { logger } from './logger';
 
-export const logger = new DefaultLogger('ERROR');
+export { logger };
 
 validateEnv();
 
@@ -25,6 +28,22 @@
 }
 
 export async function run(): Promise<void> {
+  // Setup weekly report schedule before starting worker
+  const clientConnection = await Connection.connect(temporalConfig);
+
+  try {
+    const client = new Client({ connection: clientConnection });
+
+    await setupWeeklyReportSchedule(client);
+  } catch (err) {
+    logger.error(
+      `Failed to setup schedule: ${err instanceof Error ? err.message : String(err)}`,
+    );
+  } finally {
+    await clientConnection.close();
+  }
+
+  // Create and run worker
   const connection = await createConnection();
 
   try {

workers/main/src/logger.ts

@@ -0,0 +1,7 @@
+import { DefaultLogger } from '@temporalio/worker';
+
+/**
+ * Shared logger instance for the worker
+ * Using ERROR level to reduce noise in production
+ */
+export const logger = new DefaultLogger('ERROR');