Function createProvider

apps/worker/src/jobs/import.ts:380–395

(
  record: Prisma.ImportGetPayload<{ include: { project: true } }>,
  jobLogger: ILogger
)

}

function createProvider(
  record: Prisma.ImportGetPayload<{ include: { project: true } }>,
  jobLogger: ILogger
) {
  const config = record.config;
  switch (config.provider) {
    case 'umami':
      return new UmamiProvider(record.projectId, config, jobLogger);
    case 'mixpanel':
      return new MixpanelProvider(record.projectId, config, jobLogger);
    case 'amplitude':
      return new AmplitudeProvider(record.projectId, config, jobLogger);
    default:
      throw new Error(`Unknown provider: ${config.provider}`);
  }
}