nextcloud-fix-encryption-conflicts/fix-conflicts.ts

(async () => {
  const dir = '/home/ben/Nextcloud';

  const DRY_RUN = false;
  const BATCH_SIZE = 16;
  const ENCRYPTED_CONTENT_STRING = 'HBEGIN:oc_encryption_module:OC_DEFAULT_MODULE:cipher';
  const CONFLICTED_COPY_REGEX = /.*( \(conflicted copy \d{4}-\d{2}-\d{2} \d+\))(\.[^\.]*)?/;

  const p = Deno.run({
    cmd: ['bash', '-c', `find ${dir} -type f | grep conflicted\\ copy`],
    stdout: 'piped',
  });

  const output = await p.output();
  p.close();

  const outputStr = (new TextDecoder()).decode(output);
  const fileNames = [...new Set(outputStr.split('\n').filter(s => !!s))];

  const totalFiles = fileNames.length;
  let filesSuccess = 0;
  let fileData = [];

  for (let i = 0; i < totalFiles; i += BATCH_SIZE) {
    fileData = [
      ...fileData,
      ...(await Promise.all(fileNames.slice(i, i + BATCH_SIZE).map(async (conflictedFileName, index) => {
        const conflictedNameMatch = conflictedFileName.match(CONFLICTED_COPY_REGEX);
        if (!conflictedNameMatch) {
          return `[${conflictedFileName}] encountered regex error`;
        }
        const conflictString = conflictedNameMatch[1]; 
        const nonConflictedFileName = conflictedFileName.replace(conflictString, '');

        const conflictedFile = await Deno.open(conflictedFileName, { read: true });
        const conflictedFileInfo = await Deno.fstat(conflictedFile.rid);
        const normalFile = await Deno.open(nonConflictedFileName, { read: true }).catch(() => null);
        if (!normalFile) {
          if (!DRY_RUN) {
            // Only the conflicted file exists, just move it to the non-conflict filename
            await Deno.rename(conflictedFileName, nonConflictedFileName);
          }
          return `[${conflictedFileName}] only conflicted exists. Move to non-conflict filename`;
        }
        const normalFileInfo = await Deno.fstat(normalFile.rid);
        conflictedFile.close();
        normalFile.close();

        const shaP = Deno.run({
          cmd: ['sha256sum', nonConflictedFileName, conflictedFileName],
          stdout: 'piped',
        });

        const shaOutputStr = (new TextDecoder()).decode(await shaP.output());
        const shaOutputs = shaOutputStr.split('\n');
        const normalSha = shaOutputs[0].split(' ')[0];
        const conflictedSha = shaOutputs[1].split(' ')[0];

        shaP.close();

        if (normalSha === conflictedSha) {
          if (!DRY_RUN) {
            // They're the same, remove the conflicted file
            await Deno.remove(conflictedFileName);
          }
          return `[${conflictedFileName}] conflict and non-conflict have the same contents, remove the conflict`;
        }

        const headP = Deno.run({
          cmd: ['head', '-c', '64', nonConflictedFileName, conflictedFileName],
          stdout: 'piped',
        });

        const headOutputStr = (new TextDecoder()).decode(await headP.output());
        const headOutputs = headOutputStr.split('\n');
        const normalHead = headOutputs[1].split(' ')[0];
        const conflictedHead = headOutputs[3].split(' ')[0];

        headP.close();

        const normalEncrypted = normalHead.startsWith(ENCRYPTED_CONTENT_STRING);
        const conflictedEncrypted = conflictedHead.startsWith(ENCRYPTED_CONTENT_STRING);

        if (normalEncrypted && conflictedEncrypted) {
          console.error("Both files encrypted differently!");
          console.error(nonConflictedFileName, conflictedFileName);
          if (!DRY_RUN) {
            // Whatever, deleted the conflicted one
            await Deno.remove(conflictedFileName);
          }
          return `[${conflictedFileName}] both are encrypted but with different contents. We'll remove the conflict`;
        }

        if (normalEncrypted) {
          if (!DRY_RUN) {
            // delete normal
            await Deno.remove(nonConflictedFileName);
            await Deno.rename(conflictedFileName, nonConflictedFileName);
          }
          return `[${conflictedFileName}] the non-conflict is encrypted. Remove it and move the conflicted file in its place`;
        }

        if (conflictedEncrypted) {
          if (!DRY_RUN) {
            // delete conflicted
            await Deno.remove(conflictedFileName);
          }
          return `[${conflictedFileName}] the conflict is encrypted. Remove it and keep the normal file`;
        }

        if (normalFileInfo.mtime > conflictedFileInfo.mtime) {
          if (!DRY_RUN) {
            // delete conflicted
            await Deno.remove(conflictedFileName);
          }
          return `[${conflictedFileName}] conflict is older than the non-conflict. Remove the conflict`;
        }

        if (!DRY_RUN) {
          // delete normal
          await Deno.remove(nonConflictedFileName);
          await Deno.rename(conflictedFileName, nonConflictedFileName);
        }
        return `[${conflictedFileName}] non-conflict is older than the conflict. Remove the non-conflict`;
      }).map(p => p.then((msg) => {
        filesSuccess++;
        console.log(`[${filesSuccess}/${totalFiles}] ${msg}`);
        return msg;
      })))),
    ];
  }

  // console.log(fileData);
})();