Function updateImportStatus

packages/db/src/services/import.service.ts:657–730

(
  jobLogger: ILogger,
  job: {
    updateProgress: (progress: Record<string, any>) => void;
  },
  importId: string,
  options: UpdateImportStatusOptions
)

export type ImportSteps = UpdateImportStatusOptions['step'];

export async function updateImportStatus(
  jobLogger: ILogger,
  job: {
    updateProgress: (progress: Record<string, any>) => void;
  },
  importId: string,
  options: UpdateImportStatusOptions
): Promise<void> {
  const data: Prisma.ImportUpdateInput = {};
  switch (options.step) {
    case 'loading':
      data.status = 'processing';
      data.currentStep = 'loading';
      data.currentBatch = options.batch;
      data.statusMessage = options.batch
        ? `Importing events from ${options.batch}`
        : 'Initializing...';
      data.totalEvents = options.totalEvents;
      data.processedEvents = options.processedEvents;
      break;
    case 'loading_profiles':
      data.currentStep = 'loading_profiles';
      data.statusMessage =
        options.processedProfiles != null && options.totalProfiles != null
          ? `Importing user profiles (${options.processedProfiles} / ${options.totalProfiles})`
          : 'Importing user profiles...';
      break;
    case 'creating_sessions':
      data.currentStep = 'creating_sessions';
      data.currentBatch = options.batch;
      data.statusMessage = options.batch
        ? `Creating sessions (${options.batch})`
        : 'Creating sessions...';
      break;
    case 'generating_sessions':
      data.currentStep = 'generating_sessions';
      data.statusMessage = 'Generating session IDs...';
      break;
    case 'moving':
      data.currentStep = 'moving';
      data.currentBatch = options.batch;
      data.statusMessage = `Moving events to production (${options.batch})`;
      break;
    case 'backfilling_sessions':
      data.currentStep = 'backfilling_sessions';
      data.currentBatch = options.batch;
      data.statusMessage = options.batch
        ? `Aggregating sessions (${options.batch})`
        : 'Aggregating sessions...';
      break;
    case 'completed':
      data.status = 'completed';
      data.currentStep = 'completed';
      data.statusMessage = 'Import completed';
      data.completedAt = new Date();
      break;
    case 'failed':
      data.status = 'failed';