util.js

const axios = require("axios");

async function getUser(address) {
  const response = await axios.get(
    `${process.env.GITOPIA_API_URL}/user/${address}`
  );

  if (response.data) {
    return response.data.User;
  }

  return null;
}

async function getUsername(address) {
  const response = await axios.get(
    `${process.env.GITOPIA_API_URL}/user/${address}`
  );

  // Ensure the response data contains a username
  if (response.data && response.data.User.username) {
    if (response.data.User.username !== "") {
      return response.data.User.username;
    }
  }

  return address;
}

async function getDAOname(address) {
  const response = await axios.get(
    `${process.env.GITOPIA_API_URL}/dao/${address}`
  );

  // Ensure the response data contains a name
  if (response.data && response.data.dao.name) {
    return response.data.dao.name;
  } else {
    throw new Error("Unable to retrieve DAO name");
  }
}

const resolveAddress = async (address, type) => {
  if (type === "USER") {
    return await getUsername(address);
  }

  return await getDAOname(address);
};

const getRepoDetails = async (repositoryId) => {
  const response = await axios.get(
    `${process.env.GITOPIA_API_URL}/repository/${repositoryId}`
  );

  const repositoryOwnerId = response.data.Repository.owner.id;
  const repositoryOwnerType = response.data.Repository.owner.type;
  const repositoryName = response.data.Repository.name;

  const repoOwnerName = await resolveAddress(
    repositoryOwnerId,
    repositoryOwnerType
  );

  return { repoOwnerName, repositoryName };
};

const generateSectionBlock = (message) => {
  return {
    type: "section",
    text: {
      type: "mrkdwn",
      text: message,
    },
  };
};

const postToSlack = async (web, subscriptions, repoOwnerName, blocks) => {
  for (let channel in subscriptions) {
    if (
      subscriptions[channel].some(
        (item) =>
          item === "*" || item.toLowerCase() === repoOwnerName.toLowerCase()
      )
    ) {
      // Send the message to Slack
      if (blocks.length > 0) {
        try {
          await web.chat.postMessage({
            channel,
            blocks: blocks,
          });
        } catch (e) {
          console.error("Error sending message to Slack:", e);
        }
      }
    }
  }
};

module.exports = {
  getUser,
  getUsername,
  getDAOname,
  resolveAddress,
  getRepoDetails,
  generateSectionBlock,
  postToSlack,
};