apps/orchestrator/src/workflows/missing.post.workflow.ts

import { proxyActivities, sleep } from '@temporalio/workflow';
import { PostActivity } from '@gitroom/orchestrator/activities/post.activity';

const { searchForMissingThreeHoursPosts } = proxyActivities<PostActivity>({
  startToCloseTimeout: '10 minute',
  retry: {
    maximumAttempts: 3,
    backoffCoefficient: 1,
    initialInterval: '2 minutes',
  },
});

export async function missingPostWorkflow() {
  await searchForMissingThreeHoursPosts();
  while (true) {
    await sleep('1 hour');
    await searchForMissingThreeHoursPosts();
  }
}