workspace-job-migrator

import wmill from "windmill-cli";

export async function main(

  source_workspace_id: string,

  target_workspace_id: string

) {

  console.log("DEBUG: Migrate jobs...");

  await wmill_run(

    "workspace",

    "migrate",

    target_workspace_id,

    "--source-workspace",

    source_workspace_id,

    "--token",

    process.env["WM_TOKEN"] ?? "",

    "--remote",

    process.env["BASE_URL"] + "/",

  );

  console.log("DEBUG: Migrate jons completed");

}

async function wmill_run(

  ...cmd: string[]

) {

  cmd = cmd.filter((elt) => elt !== "");

  console.log(`DEBUG: Running CLI command: 'wmill ${cmd.slice().join(" ")} ...'`);

  // Capture CLI output to parse JSON response

  const originalLog = console.log;

  let cliOutput = "";

  console.log = (msg: string) => {

    cliOutput += msg + "\n";

    originalLog(msg);

  };

  try {

    await wmill.parse(cmd);

    console.log = originalLog;

    console.log("DEBUG: CLI command executed successfully");

  } catch (error) {

    console.log = originalLog;

    console.log("DEBUG: CLI command execution failed:", error);

    throw error;

  }

  // END capture log

  console.log("DEBUG: Captured CLI output length:", cliOutput.length);

  console.log("DEBUG: Raw CLI output:", cliOutput);

  try {

    console.log("DEBUG: Attempting to parse CLI output as JSON...");

    // Find the first occurrence of '{' which indicates the start of JSON

    const jsonStartIndex = cliOutput.indexOf('{');

    if (jsonStartIndex === -1) {

      console.log("DEBUG: No JSON found in CLI output");

      return {};

    }

    // Extract everything from the first '{' to the end

    const jsonString = cliOutput.substring(jsonStartIndex).trim();

    console.log("DEBUG: Extracted JSON string:", jsonString);

    const res = JSON.parse(jsonString);

    console.log("DEBUG: Successfully parsed JSON result:", res);

    return res;

  } catch (e) {

    console.log("DEBUG: Failed to parse CLI output as JSON:", e);

    console.log("DEBUG: Returning empty object");

    return {};

  }

}