import { getState, setState } from "windmill-client@1";

type Bitbucket = {

  username: string;

  password: string;

};

export async function main(

  bitbucket: Bitbucket,

  workspace: string,

  repo: string,

  branch: string

) {

  const lastChecked: number = (await getState()) || 0;

  const response = await fetch(

    `https://api.bitbucket.org/2.0/repositories/${workspace}/${repo}/commits?pagelen=100&include=${branch}`,

    {

      headers: {

        Authorization:

          "Basic " +

          Buffer.from(bitbucket.username + ":" + bitbucket.password).toString(

            "base64"

          ),

      },

    }

  );

  const data = await response.json();

  if (!response.ok) {

    throw new Error(data.error.message);

  }

  const newCommits = [];

  for (const commit of data?.values || []) {

    if (new Date(commit.date).getTime() > lastChecked) {

      newCommits.push(commit);

    } else {

      break;

    }

  }

  if (newCommits.length > 0) {

    await setState(new Date(newCommits[0].date).getTime());

  }

  return newCommits;

}