Function createWorkerTask

packages/cli/src/cli/cmd/run/execute.ts:149–325

(args: {
  ctx: CmdRunContext;
  assignedTasks: CmdRunTask[];
  ioLimiter: LimitFunction;
  i18nLimiter: LimitFunction;
  onDone: () => void;
  initialChecksumsMap: Map<string, Record<string, string>>;
  getFileIoLimiter: (bucketPathPattern: string) => LimitFunction;
})

}

function createWorkerTask(args: {
  ctx: CmdRunContext;
  assignedTasks: CmdRunTask[];
  ioLimiter: LimitFunction;
  i18nLimiter: LimitFunction;
  onDone: () => void;
  initialChecksumsMap: Map<string, Record<string, string>>;
  getFileIoLimiter: (bucketPathPattern: string) => LimitFunction;
}): ListrTask {
  return {
    title: "Initializing...",
    task: async (_subCtx: any, subTask: any) => {
      for (const assignedTask of args.assignedTasks) {
        subTask.title = createWorkerStatusMessage({
          assignedTask,
          percentage: 0,
        });
        const bucketLoader = createLoaderForTask(assignedTask);
        const deltaProcessor = createDeltaProcessor(
          assignedTask.bucketPathPattern,
        );

        // Get initial checksums from the preloaded map
        const initialChecksums =
          args.initialChecksumsMap.get(assignedTask.bucketPathPattern) || {};

        const taskResult = await args.i18nLimiter(async () => {
          try {
            // Pull operations must be serialized per-file for single-file formats
            // where multiple locales share the same file (e.g., xcode-xcstrings)
            const fileIoLimiter = args.getFileIoLimiter(
              assignedTask.bucketPathPattern,
            );
            const sourceData = await fileIoLimiter(async () =>
              bucketLoader.pull(assignedTask.sourceLocale),
            );
            const hints = await fileIoLimiter(async () =>
              bucketLoader.pullHints(),
            );
            const targetData = await fileIoLimiter(async () =>
              bucketLoader.pull(assignedTask.targetLocale),
            );
            const delta = await deltaProcessor.calculateDelta({
              sourceData,
              targetData,
              checksums: initialChecksums,
            });

            const processableData = computeProcessableData(
              sourceData,
              delta,
              args.ctx.flags.force,
              assignedTask.onlyKeys,
            );

            if (!Object.keys(processableData).length) {
              await fileIoLimiter(async () => {
                // re-push in case some of the unlocalizable / meta data changed