Method processJob

server/utils/import-queue.ts:646–825

(job: QueueJob, workerId: number)

  }

  private async processJob(job: QueueJob, workerId: number): Promise<void> {
    try {
      let result: any;

      switch (job.type) {
        case "wakatime-api":
          if (!job.data.apiKey) {
            throw new Error("API key is required for WakaTime import");
          }

          let wakatimeJob = this.getOrCreateJob(
            job.id,
            job.userId,
            "wakatime-api",
            `WakaTime API Import ${new Date().toISOString()}`,
          );

          result = await handleWakatimeImport(
            job.data.apiKey,
            job.userId,
            wakatimeJob,
          );
          break;

        case "wakatime-file":
          if (!job.data.exportData || !job.data.jobId) {
            throw new Error(
              "Export data and job ID are required for WakaTime file import",
            );
          }

          const existingJob = activeJobs.get(job.id);
          if (existingJob) {
            const daysWithData =
              job.data.exportData.days?.filter(
                (day) => day.heartbeats && day.heartbeats.length > 0,
              ) || [];
            updateJob(existingJob, {
              status: ImportStatus.Processing,
              current: 0,
              total: daysWithData.length,
            });
            result = await handleWakatimeFileImport(
              job.data.exportData,
              job.userId,
              existingJob,
            );
          } else {
            const daysWithData =
              job.data.exportData.days?.filter(
                (day) => day.heartbeats && day.heartbeats.length > 0,
              ) || [];
            const fileJob = this.getOrCreateJob(
              job.id,
              job.userId,
              "wakatime-file",
              `WakaTime File Import ${new Date().toISOString()}`,
              daysWithData.length,