Function createDeltaProcessor

packages/cli/src/cli/utils/delta.ts:36–139

(fileKey: string)

};

export function createDeltaProcessor(fileKey: string) {
  const lockfilePath = path.join(process.cwd(), "i18n.lock");
  return {
    async checkIfLockExists() {
      return checkIfFileExists(lockfilePath);
    },
    async calculateDelta(params: {
      sourceData: Record<string, any>;
      targetData: Record<string, any>;
      checksums: Record<string, string>;
    }): Promise<Delta> {
      let added = _.difference(
        Object.keys(params.sourceData),
        Object.keys(params.targetData),
      );
      let removed = _.difference(
        Object.keys(params.targetData),
        Object.keys(params.sourceData),
      );
      const updated = Object.keys(params.sourceData).filter(
        (key) =>
          md5(params.sourceData[key]) !== params.checksums[key] &&
          params.checksums[key],
      );

      const renamed: [string, string][] = [];
      for (const addedKey of added) {
        const addedHash = md5(params.sourceData[addedKey]);
        for (const removedKey of removed) {
          if (params.checksums[removedKey] === addedHash) {
            renamed.push([removedKey, addedKey]);
            break;
          }
        }
      }
      added = added.filter(
        (key) => !renamed.some(([oldKey, newKey]) => newKey === key),
      );
      removed = removed.filter(
        (key) => !renamed.some(([oldKey, newKey]) => oldKey === key),
      );

      const hasChanges = [
        added.length > 0,
        removed.length > 0,
        updated.length > 0,
        renamed.length > 0,
      ].some((v) => v);

      return {
        added,
        removed,
        updated,
        renamed,
        hasChanges,
      };
    },
    async loadLock() {