import { IntegrationTaskKey } from "@trigger.dev/sdk";

import { Octokit } from "octokit";

import { GitHubReturnType, GitHubRunTask, onError } from "./index";

import { Issues } from "./issues";

import { ReactionContent, Reactions } from "./reactions";

export class Compound {

runTask: GitHubRunTask;

issues: Issues;

reactions: Reactions;

constructor(runTask: GitHubRunTask, issues: Issues, reactions: Reactions) {

this.runTask = runTask;

this.issues = issues;

this.reactions = reactions;

}

createIssueCommentWithReaction(

key: IntegrationTaskKey,

params: {

body: string;

owner: string;

repo: string;

issueNumber: number;

reaction: ReactionContent;

}

): GitHubReturnType<Octokit["rest"]["issues"]["createComment"]> {

return this.runTask(

key,

async () => {

const comment = await this.issues.createComment(

`Comment on Issue #${params.issueNumber}`,

params

);

const reaction = await this.reactions.createForIssueComment(

`React with ${params.reaction}`,

{

owner: params.owner,

repo: params.repo,

commentId: comment.id,

content: params.reaction,

}

);

return comment;

},

{

name: "Create Issue Comment",

params,

properties: [

{

label: "Repo",

text: params.repo,

},

{

label: "Issue",

text: `#${params.issueNumber}`,

},

],

},

onError

);

}

}