Edits history of script submission #13983 for ' GitLab: push changes to windmill (gitlab)'

• bun

  Ap­pro­ved version

  Edit in Windmill

  Embed

  import * as wmillclient from "windmill-client";
  import wmill from "windmill-cli";
  import { basename } from "node:path";
  const util = require("util");
  const exec = util.promisify(require("child_process").exec);
  import process from "process";
  
  export async function main(
    repository: any,
    ref: string,
    user_username: string,
    commits: any
  ) {
    const ws = process.env["WM_WORKSPACE"];
    const repo_name = repository.name;
    const message: string = commits.pop().message;
  
    console.log("Received git sync push request:");
    console.log(`Repo: ${repo_name}`);
    console.log(`Ref: ${ref}`);
    console.log(`Pusher: ${user_username}`);
    console.log(`Message: ${message}`);
  
    const ws_settings = await wmillclient.WorkspaceService.getSettings({
      workspace: ws,
    });
    const repos = ws_settings.git_sync?.repositories;
  
    if (message.startsWith("[WM]")) {
      return {
        success: true,
        message: "Commit coming from windmill, no need to cli push back!",
      };
    }
  
    if (repos && repos.length > 0) {
      for (const repo of repos) {
        const repo_resource = await wmillclient.getResource(
          repo.git_repo_resource_path.split("$res:").pop()
        );
        if (repo_resource.url?.toLowerCase().includes(repo_name.toLowerCase())) {
          console.log("Repo found...");
          const cwd = process.cwd();
          process.env["HOME"] = ".";
  
          await git_clone(cwd, repo_resource, true);
  
          await wmill_sync_push(ws, message);
          console.log("Finished syncing");
          process.chdir(`${cwd}`);
          return { success: true };
        }
      }
    }
  }
  
  async function git_clone(
    cwd: string,
    repo_resource: any,
    use_individual_branch: boolean
  ): Promise<string> {
    let repo_url = repo_resource.url;
    const subfolder = repo_resource.folder ?? "";
    const branch = repo_resource.branch ?? "";
    const repo_name = basename(repo_url, ".git");
    const azureMatch = repo_url.match(/AZURE_DEVOPS_TOKEN\((?<url>.+)\)/);
    if (azureMatch) {
      console.log(
        "Requires Azure DevOps service account access token, requesting..."
      );
      const azureResource = await wmillclient.getResource(azureMatch.groups.url);
      const response = await fetch(
        `https://login.microsoftonline.com/${azureResource.azureTenantId}/oauth2/token`,
        {
          method: "POST",
          body: new URLSearchParams({
            client_id: azureResource.azureClientId,
            client_secret: azureResource.azureClientSecret,
            grant_type: "client_credentials",
            resource: "499b84ac-1321-427f-aa17-267ca6975798/.default",
          }),
        }
      );
      const { access_token } = await response.json();
      repo_url = repo_url.replace(azureMatch[0], access_token);
    }
    const args = ["clone", "--quiet", "--depth", "1"];
    if (use_individual_branch) {
      args.push("--no-single-branch"); // needed in case the asset branch already exists in the repo
    }
    if (subfolder !== "") {
      args.push("--sparse");
    }
    if (branch !== "") {
      args.push("--branch");
      args.push(branch);
    }
    args.push(repo_url);
    args.push(repo_name);
    await sh_run(-1, "git", ...args);
    try {
      process.chdir(`${cwd}/${repo_name}`);
    } catch (err) {
      console.log(
        `Error changing directory to '${cwd}/${repo_name}'. Error was:\n${err}`
      );
      throw err;
    }
    process.chdir(`${cwd}/${repo_name}`);
    if (subfolder !== "") {
      await sh_run(undefined, "git", "sparse-checkout", "add", subfolder);
    }
    try {
      process.chdir(`${cwd}/${repo_name}/${subfolder}`);
    } catch (err) {
      console.log(
        `Error changing directory to '${cwd}/${repo_name}/${subfolder}'. Error was:\n${err}`
      );
      throw err;
    }
    return repo_name;
  }
  
  async function sh_run(
    secret_position: number | undefined,
    cmd: string,
    ...args: string[]
  ) {
    const nargs = secret_position != undefined ? args.slice() : args;
    if (secret_position && secret_position < 0) {
      secret_position = nargs.length - 1 + secret_position;
    }
    let secret: string | undefined = undefined;
    if (secret_position != undefined) {
      nargs[secret_position] = "***";
      secret = args[secret_position];
    }
  
    console.log(`Running '${cmd} ${nargs.join(" ")} ...'`);
    const command = exec(`${cmd} ${args.join(" ")}`);
    try {
      const { stdout, stderr } = await command;
      if (stdout.length > 0) {
        console.log(stdout);
      }
      if (stderr.length > 0) {
        console.log(stderr);
      }
      console.log("Command successfully executed");
      return stdout;
    } catch (error) {
      let errorString = error.toString();
      if (secret) {
        errorString = errorString.replace(secret, "***");
      }
      const err = `SH command '${cmd} ${nargs.join(
        " "
      )}' returned with error ${errorString}`;
      throw Error(err);
    }
  }
  
  async function wmill_sync_push(workspace_id: string, message: string) {
    console.log("Pushing workspace to windmill");
    await wmill_run(
      3,
      "sync",
      "push",
      "--token",
      process.env["WM_TOKEN"] ?? "",
      "--workspace",
      workspace_id,
      "--yes",
      "--base-url",
      process.env["BASE_URL"] + "/",
      message ? "--message" : "",
      message ? message : ""
    );
  }
  
  async function wmill_run(secret_position: number, ...cmd: string[]) {
    cmd = cmd.filter((elt) => elt !== "");
    const cmd2 = cmd.slice();
    cmd2[secret_position] = "***";
    console.log(`Running 'wmill ${cmd2.join(" ")} ...'`);
    await wmill.parse(cmd);
    console.log("Command successfully executed");
  }
  

  Submitted by hugo697 240 days ago

• bun

  Edit in Windmill

  Embed

  import * as wmillclient from "windmill-client";
  import wmill from "windmill-cli";
  import { basename } from "node:path"
  const util = require('util');
  const exec = util.promisify(require('child_process').exec);
  import process from "process";
  
  export async function main(
    repository: any,
    ref: string,
    user_username: string,
    commits: any
  ) {
    const ws = process.env["WM_WORKSPACE"]
    const repo_name = repository.name
    const message: string = commits.pop().message
  
    console.log("Received git sync push request:")
    console.log(`Repo: ${repository}`)
    console.log(`Ref: ${ref}`)
    console.log(`Pusher: ${user_username}`)
    console.log(`Message: ${message}`)
  
    const ws_settings = await wmillclient.WorkspaceService.getSettings({ workspace: ws });
    const repos = ws_settings.git_sync?.repositories
  
    if (message.startsWith("[WM]")){
      return { success: true, message: "Commit coming from windmill, no need to cli push back!"}
    }
  
    if (repos && repos.length > 0) {
      for (const repo of repos) {
        const repo_resource = await wmillclient.getResource(repo.git_repo_resource_path.split("$res:").pop());
        if (repo_resource.url?.includes(repo_name)) {
          console.log("Repo found...")
          const cwd = process.cwd();
          process.env["HOME"] = "."
  
          await git_clone(cwd, repo_resource, true);
  
          await wmill_sync_push(
            ws,
            message
          )
          console.log("Finished syncing");
          process.chdir(`${cwd}`);
          return { success: true }
        }
      }
    }
  }
  
  async function git_clone(
    cwd: string,
    repo_resource: any,
    use_individual_branch: boolean
  ): Promise<string> {
    let repo_url = repo_resource.url;
    const subfolder = repo_resource.folder ?? "";
    const branch = repo_resource.branch ?? "";
    const repo_name = basename(repo_url, ".git");
    const azureMatch = repo_url.match(/AZURE_DEVOPS_TOKEN\((?<url>.+)\)/);
    if (azureMatch) {
      console.log(
        "Requires Azure DevOps service account access token, requesting..."
      );
      const azureResource = await wmillclient.getResource(azureMatch.groups.url);
      const response = await fetch(
        `https://login.microsoftonline.com/${azureResource.azureTenantId}/oauth2/token`,
        {
          method: "POST",
          body: new URLSearchParams({
            client_id: azureResource.azureClientId,
            client_secret: azureResource.azureClientSecret,
            grant_type: "client_credentials",
            resource: "499b84ac-1321-427f-aa17-267ca6975798/.default",
          }),
        }
      );
      const { access_token } = await response.json();
      repo_url = repo_url.replace(azureMatch[0], access_token);
    }
    const args = ["clone", "--quiet", "--depth", "1"];
    if (use_individual_branch) {
      args.push("--no-single-branch"); // needed in case the asset branch already exists in the repo
    }
    if (subfolder !== "") {
      args.push("--sparse");
    }
    if (branch !== "") {
      args.push("--branch");
      args.push(branch);
    }
    args.push(repo_url);
    args.push(repo_name);
    await sh_run(-1, "git", ...args);
    try {
      process.chdir(`${cwd}/${repo_name}`);
    } catch (err) {
      console.log(
        `Error changing directory to '${cwd}/${repo_name}'. Error was:\n${err}`
      );
      throw err;
    }
    process.chdir(`${cwd}/${repo_name}`);
    if (subfolder !== "") {
      await sh_run(undefined, "git", "sparse-checkout", "add", subfolder);
    }
    try {
      process.chdir(`${cwd}/${repo_name}/${subfolder}`);
    } catch (err) {
      console.log(
        `Error changing directory to '${cwd}/${repo_name}/${subfolder}'. Error was:\n${err}`
      );
      throw err;
    }
    return repo_name;
  }
  
  async function sh_run(
    secret_position: number | undefined,
    cmd: string,
    ...args: string[]
  ) {
    const nargs = secret_position != undefined ? args.slice() : args;
    if (secret_position && secret_position < 0) {
      secret_position = nargs.length - 1 + secret_position;
    }
    let secret: string | undefined = undefined
    if (secret_position != undefined) {
      nargs[secret_position] = "***";
      secret = args[secret_position]
    }
  
    console.log(`Running '${cmd} ${nargs.join(" ")} ...'`);
    const command = exec(`${cmd} ${args.join(" ")}`)
    try {
      const { stdout, stderr } = await command
      if (stdout.length > 0) {
        console.log(stdout);
      }
      if (stderr.length > 0) {
        console.log(stderr);
      }
      console.log("Command successfully executed");
      return stdout;
  
    } catch (error) {
      let errorString = error.toString();
      if (secret) {
        errorString = errorString.replace(secret, "***");
      }
      const err = `SH command '${cmd} ${nargs.join(
        " "
      )}' returned with error ${errorString}`;
      throw Error(err);
    }
  }
  
  
  async function wmill_sync_push(
    workspace_id: string,
    message: string,
  ) {
    console.log("Pushing workspace to windmill");
    await wmill_run(
      3,
      "sync",
      "push",
      "--token",
      process.env["WM_TOKEN"] ?? "",
      "--workspace",
      workspace_id,
      "--yes",
      "--base-url",
      process.env["BASE_URL"] + "/",
      message ? "--message" : "",
      message ? message : "",
    );
  }
  
  async function wmill_run(secret_position: number, ...cmd: string[]) {
    cmd = cmd.filter((elt) => elt !== "");
    const cmd2 = cmd.slice();
    cmd2[secret_position] = "***";
    console.log(`Running 'wmill ${cmd2.join(" ")} ...'`);
    await wmill.parse(cmd);
    console.log("Command successfully executed");
  }

  Submitted by hugo697 266 days ago