Method processDateRangeChunk

server/utils/import-queue.ts:505–553

(
    chunk: WorkChunk,
    job: ImportJob,
    workerId: number,
  )

  }

  private async processDateRangeChunk(
    chunk: WorkChunk,
    job: ImportJob,
    workerId: number,
  ): Promise<void> {
    const { days } = chunk.data;
    let processedInChunk = 0;
    let processedDaysWithData = 0;
    const totalInChunk = days?.length || 0;

    for (const day of days || []) {
      if (!day.heartbeats || day.heartbeats.length === 0) {
        processedInChunk++;

        if (processedInChunk % 5 === 0 || processedInChunk === totalInChunk) {
          chunk.progress = Math.round((processedInChunk / totalInChunk) * 100);
          this.updateJobProgress(job.id);
        }
        continue;
      }

      try {
        const userAgents = new Map();
        const processedHeartbeats = day.heartbeats.map((h: any) =>
          mapHeartbeat(
            h,
            userAgents,
            job.userId,
            chunk.data.originalJob.data.exportData?.user.last_plugin,
          ),
        );

        await processHeartbeatsByDate(job.userId, processedHeartbeats);
        processedInChunk++;
        processedDaysWithData++;
        chunk.data.processedDays = processedDaysWithData;

        if (processedInChunk % 5 === 0 || processedInChunk === totalInChunk) {
          chunk.progress = Math.round((processedInChunk / totalInChunk) * 100);
          this.updateJobProgress(job.id);
        }
      } catch (error) {
        handleLog(
          `[worker] Worker ${workerId} error processing day ${day.date}: ${error}`,
        );
        processedInChunk++;
      }
    }
  }

  private updateJobProgress(jobId: string): void {
    const job = activeJobs.get(jobId);