testBackupsAndCronsExtended.js

import BosBase from "bosbase";

function createStubClient() {
  const pb = new BosBase("https://backups.test");
  const calls = [];

  pb.send = async (path, options = {}) => {
    calls.push({ path, options });

    if (path === "/api/backups" && options.method === "POST") {
      return {};
    }

    if (path === "/api/backups/upload" && options.method === "POST") {
      return {};
    }

    if (path.startsWith("/api/backups/") && path.endsWith("/restore")) {
      return {};
    }

    if (path.startsWith("/api/backups/") && options.method === "DELETE") {
      return {};
    }

    if (path.startsWith("/api/crons/") && options.method === "POST") {
      return {};
    }

    throw new Error(`Unexpected request: ${path} ${options.method || ""}`);
  };

  return { pb, calls };
}

async function main() {
  const { pb, calls } = createStubClient();

  try {
    console.log("[INFO] Testing BackupService create/upload/delete/restore helpers...");
    const created = await pb.backups.create("nightly");
    if (!created) {
      throw new Error("backups.create did not resolve to true");
    }

    const createCall = calls.find(
      (c) => c.path === "/api/backups" && c.options.method === "POST",
    );
    if (!createCall || createCall.options.body?.name !== "nightly") {
      throw new Error("backups.create did not send expected payload");
    }

    await pb.backups.upload({ file: "blob" });
    const uploadCall = calls.find((c) => c.path === "/api/backups/upload");
    if (!uploadCall || uploadCall.options.method !== "POST") {
      throw new Error("backups.upload did not hit /api/backups/upload");
    }

    await pb.backups.delete("nightly.bak");
    const deleteCall = calls.find(
      (c) => c.path.startsWith("/api/backups/") && c.options.method === "DELETE",
    );
    if (!deleteCall || !deleteCall.path.endsWith("nightly.bak")) {
      throw new Error("backups.delete did not encode key");
    }

    await pb.backups.restore("nightly.bak");
    const restoreCall = calls.find((c) => c.path.endsWith("/restore"));
    if (!restoreCall || restoreCall.options.method !== "POST") {
      throw new Error("backups.restore did not POST to restore endpoint");
    }

    const url = pb.backups.getDownloadURL("TOKEN123", "folder/backup.zip");
    const encodedKey = encodeURIComponent("folder/backup.zip");
    if (!url.includes("TOKEN123") || !url.includes(encodedKey)) {
      throw new Error("getDownloadURL did not build expected download url");
    }
    console.log("[SUCCESS] BackupService helpers verified with stubbed client");

    console.log("[INFO] Testing CronService run helper...");
    await pb.crons.run("job with spaces");
    const cronCall = calls.find((c) => c.path.startsWith("/api/crons/"));
    if (
      !cronCall ||
      !cronCall.path.endsWith("job%20with%20spaces") ||
      cronCall.options.method !== "POST"
    ) {
      throw new Error("crons.run did not POST to encoded cron path");
    }
    console.log("[SUCCESS] CronService run helper verified");

    console.log("\n========== Backup and Cron helper coverage completed ==========");
  } catch (error) {
    console.error("[ERROR] Backup/Cron helper coverage failed:");
    console.error(error?.stack || error);
    process.exit(1);
  }
}

main();