123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899
import { ok } from "./util.ts";import * as T from "./types.ts";
/**  * This utility simplifies the volume backup process. * ```ts * export const { createBackup, restoreBackup } = Backups.volumes("main").build(); * ```*/export class Backups {  static BACKUP = "BACKUP" as const;  public backupSet = [] as {    srcPath: string;    srcVolume: string;    dstPath: string;    dstVolume: string;  }[];  constructor() {  }  static volumes(...volumeNames: string[]) {    return new Backups().addSets(...volumeNames.map((srcVolume) => ({      srcVolume,      srcPath: "./",      dstPath: `./${srcVolume}/`,      dstVolume: Backups.BACKUP,    })));  }  static addSets(    ...options: {      srcPath: string;      srcVolume: string;      dstPath: string;      dstVolume: string;    }[]  ) {    return new Backups().addSets(...options);  }  addSets(    ...options: {      srcPath: string;      srcVolume: string;      dstPath: string;      dstVolume: string;    }[]  ) {    options.forEach((x) => this.backupSet.push(x));    return this;  }  build() {    const createBackup: T.ExpectedExports.createBackup = async (effects) => {      for (const item of this.backupSet) {        if (notEmptyPath(item.dstPath)) {          await effects.createDir({            volumeId: item.dstVolume,            path: item.dstPath,          });        }        await effects.runRsync({          ...item,          options: {            delete: true,            force: true,            ignoreExisting: false,            exclude: [],          },        }).wait();      }      return ok;    };    const restoreBackup: T.ExpectedExports.restoreBackup = async (effects) => {      for (const item of this.backupSet) {        if (notEmptyPath(item.srcPath)) {          await effects.createDir({            volumeId: item.srcVolume,            path: item.srcPath,          });        }        await effects.runRsync({          options: {            delete: true,            force: true,            ignoreExisting: false,            exclude: [],          },          srcVolume: item.dstVolume,          dstVolume: item.srcVolume,          srcPath: item.dstPath,          dstPath: item.srcPath,        }).wait();      }      return ok;    };    return { createBackup, restoreBackup };  }}function notEmptyPath(file: string) {  return ["", ".", "./"].indexOf(file) === -1;}