Updates for F2Fs and edge cases

Dockerfile

@@ -23,4 +23,4 @@ ENV NODE_ENV production
 COPY --from=build /usr/src/app/dist ./dist
 COPY --from=deps /usr/src/app/node_modules ./node_modules
 EXPOSE 3000
-CMD ["node", "dist/main.js"]
+CMD ["node", "dist/src/main.js"]

eslint.config.mjs

@@ -6,7 +6,7 @@ import tseslint from 'typescript-eslint';
 
 export default tseslint.config(
   {
-    ignores: ['eslint.config.mjs'],
+    ignores: ['eslint.config.mjs', 'src/autopilot/generated/**/*'],
   },
   eslint.configs.recommended,
   ...tseslint.configs.recommendedTypeChecked,

package.json

@@ -20,7 +20,8 @@
     "test:e2e": "jest --config ./test/jest-e2e.json",
     "prisma:generate": "prisma generate --schema prisma/challenge.schema.prisma && prisma generate --schema prisma/autopilot.schema.prisma",
     "postinstall": "prisma generate --schema prisma/challenge.schema.prisma && prisma generate --schema prisma/autopilot.schema.prisma && patch-package",
-    "prisma:pushautopilot": "prisma db push --schema prisma/autopilot.schema.prisma"
+    "prisma:pushautopilot": "prisma db push --schema prisma/autopilot.schema.prisma",
+    "pull:logs": "ts-node scripts/fetch-autopilot-actions.ts"
   },
   "prisma": {
     "schema": "prisma/challenge.schema.prisma"

prisma/challenge.schema.prisma

@@ -10,10 +10,10 @@ generator client {
 
 // Enum for allowed challenge track values (matches app-constants)
 enum ChallengeTrackEnum {
-  DEVELOP
+  DEVELOPMENT
   DESIGN
   DATA_SCIENCE
-  QA
+  QUALITY_ASSURANCE
 }
 
 enum ReviewTypeEnum {

scripts/fetch-autopilot-actions.ts

@@ -0,0 +1,70 @@
+import { Prisma, PrismaClient } from '@prisma/client';
+
+interface AutopilotActionRecord {
+  id: string;
+  challengeId: string | null;
+  action: string;
+  status: string;
+  source: string | null;
+  details: Prisma.JsonValue | null;
+  createdAt: Date | string;
+}
+
+async function main(): Promise<void> {
+  const [, , challengeId] = process.argv;
+
+  if (!challengeId) {
+    console.error('Usage: ts-node scripts/fetch-autopilot-actions.ts <challengeId>');
+    process.exit(1);
+  }
+
+  const databaseUrl = process.env.AUTOPILOT_DB_URL;
+
+  if (!databaseUrl) {
+    console.error('AUTOPILOT_DB_URL environment variable is not set.');
+    process.exit(1);
+  }
+
+  const prisma = new PrismaClient({
+    datasources: {
+      db: {
+        url: databaseUrl,
+      },
+    },
+  });
+
+  try {
+    const rows = (await prisma.$queryRaw<AutopilotActionRecord[]>
+      (Prisma.sql`
+        SELECT
+          "id",
+          "challengeId",
+          "action",
+          "status",
+          "source",
+          "details",
+          "createdAt"
+        FROM "autopilot"."actions"
+        WHERE "challengeId" = ${challengeId}
+        ORDER BY "createdAt" ASC
+      `)) ?? [];
+
+    const normalizedRows = rows.map((row) => ({
+      ...row,
+      createdAt:
+        row.createdAt instanceof Date
+          ? row.createdAt.toISOString()
+          : row.createdAt,
+    }));
+
+    console.log(JSON.stringify(normalizedRows, null, 2));
+  } catch (error) {
+    const err = error as Error;
+    console.error(`Failed to fetch autopilot actions: ${err.message}`);
+    process.exitCode = 1;
+  } finally {
+    await prisma.$disconnect();
+  }
+}
+
+void main();

src/autopilot/autopilot.module.ts

@@ -9,6 +9,9 @@ import { ResourcesModule } from '../resources/resources.module';
 import { PhaseReviewService } from './services/phase-review.service';
 import { ReviewAssignmentService } from './services/review-assignment.service';
 import { ChallengeCompletionService } from './services/challenge-completion.service';
+import { PhaseScheduleManager } from './services/phase-schedule-manager.service';
+import { ResourceEventHandler } from './services/resource-event-handler.service';
+import { First2FinishService } from './services/first2finish.service';
 
 @Module({
   imports: [
@@ -23,6 +26,9 @@ import { ChallengeCompletionService } from './services/challenge-completion.serv
   providers: [
     AutopilotService,
     SchedulerService,
+    PhaseScheduleManager,
+    ResourceEventHandler,
+    First2FinishService,
     PhaseReviewService,
     ReviewAssignmentService,
     ChallengeCompletionService,

src/autopilot/constants/challenge.constants.ts

@@ -0,0 +1,26 @@
+export const FIRST2FINISH_TYPE = 'first2finish';
+export const TOPGEAR_TASK_TYPE = 'topgear task';
+
+export function normalizeChallengeType(type?: string): string {
+  return (type ?? '').toLowerCase();
+}
+
+export function isTopgearTaskChallenge(type?: string): boolean {
+  return normalizeChallengeType(type) === TOPGEAR_TASK_TYPE;
+}
+
+export function isFirst2FinishChallenge(type?: string): boolean {
+  const normalized = normalizeChallengeType(type);
+  return normalized === FIRST2FINISH_TYPE || normalized === TOPGEAR_TASK_TYPE;
+}
+
+export function describeChallengeType(type?: string): string {
+  const normalized = normalizeChallengeType(type);
+  if (normalized === TOPGEAR_TASK_TYPE) {
+    return 'Topgear Task';
+  }
+  if (normalized === FIRST2FINISH_TYPE) {
+    return 'First2Finish';
+  }
+  return type ?? 'Unknown';
+}

src/autopilot/constants/review.constants.ts

@@ -1,12 +1,37 @@
-export const REVIEW_PHASE_NAMES = new Set(['Review', 'Iterative Review']);
+export const REVIEW_PHASE_NAMES = new Set([
+  'Review',
+  'Iterative Review',
+  'Post-Mortem',
+]);
+
+export const ITERATIVE_REVIEW_PHASE_NAME = 'Iterative Review';
+export const POST_MORTEM_PHASE_NAME = 'Post-Mortem';
+export const REGISTRATION_PHASE_NAME = 'Registration';
+export const SUBMISSION_PHASE_NAME = 'Submission';
+export const TOPGEAR_SUBMISSION_PHASE_NAME = 'Topgear Submission';
+
+export const SUBMISSION_PHASE_NAMES = new Set<string>([
+  SUBMISSION_PHASE_NAME,
+  TOPGEAR_SUBMISSION_PHASE_NAME,
+]);
+
+export const DEFAULT_APPEALS_PHASE_NAMES = new Set(['Appeals']);
+export const DEFAULT_APPEALS_RESPONSE_PHASE_NAMES = new Set([
+  'Appeals Response',
+]);
 
 const DEFAULT_PHASE_ROLES = ['Reviewer', 'Iterative Reviewer'];
 
 export const PHASE_ROLE_MAP: Record<string, string[]> = {
   Review: ['Reviewer'],
   'Iterative Review': ['Iterative Reviewer'],
+  'Post-Mortem': ['Reviewer', 'Copilot'],
 };
 
 export function getRoleNamesForPhase(phaseName: string): string[] {
   return PHASE_ROLE_MAP[phaseName] ?? DEFAULT_PHASE_ROLES;
 }
+
+export function isSubmissionPhaseName(phaseName: string): boolean {
+  return SUBMISSION_PHASE_NAMES.has(phaseName);
+}

src/autopilot/interfaces/autopilot.interface.ts

@@ -86,3 +86,54 @@ export interface SubmissionAggregatePayload {
   originalTopic?: string;
   [key: string]: unknown;
 }
+
+export interface ResourceEventPayload {
+  id: string;
+  challengeId: string;
+  memberId: string;
+  memberHandle: string;
+  roleId: string;
+  created: string;
+  createdBy: string;
+}
+
+export interface ReviewCompletedPayload {
+  challengeId: string;
+  submissionId: string;
+  reviewId: string;
+  phaseId: string;
+  scorecardId: string;
+  reviewerResourceId: string;
+  reviewerHandle: string;
+  reviewerMemberId: string;
+  submitterHandle: string;
+  submitterMemberId: string;
+  completedAt: string;
+  initialScore: number;
+}
+
+export interface AppealRespondedPayload {
+  challengeId: string;
+  submissionId: string;
+  reviewId: string;
+  scorecardId: string;
+  appealId: string;
+  appealResponseId: string;
+  reviewerResourceId: string;
+  reviewerHandle: string;
+  reviewerMemberId: string;
+  submitterHandle: string;
+  submitterMemberId: string;
+  reviewCompletedAt: string;
+  finalScore: number;
+}
+
+export interface First2FinishSubmissionPayload {
+  challengeId: string;
+  submissionId: string;
+  memberId: string;
+  memberHandle: string;
+  submittedAt: string;
+}
+
+export type TopgearSubmissionPayload = First2FinishSubmissionPayload;