import { nodes, root, state } from "membrane";

export async function endpoint({ path, body }) {
  switch (path) {
    case "/webhook":
      {
        const { action, workflow_job, repository } = JSON.parse(body);
        if (
          action === "completed" &&
          workflow_job.conclusion === "failure"
        ) {
          const message = 
           `The workflow "${workflow_job.workflow_name}" 
            in the repository "${repository.full_name}"
            was canceled due to a failure caused by 
            "${workflow_job.name}".`;

          await nodes.sms.send({ message });
        }
      }
      return JSON.stringify({ status: 200 });
    default:
      console.log("Unknown Endpoint:", path);
  }
}