Function processThreadUpdate

packages/integration-github/src/outbound.ts:194–262

({
  threadId,
  integration,
  event,
}: {
  threadId: string;
  integration: channelsIntegration;
  event: TwoWaySyncEvent;
})

}

async function processThreadUpdate({
  threadId,
  integration,
  event,
}: {
  threadId: string;
  integration: channelsIntegration;
  event: TwoWaySyncEvent;
}) {
  const thread = await linenSdk.getThread({
    channelId: integration.channelId,
    threadId,
  });

  if (!thread) {
    return 'ThreadNotFound';
  }

  if (!thread.messages.length) {
    return 'ThreadNotFound';
  }

  if (!thread.externalThreadId) {
    return 'missing thread external id';
  }

  const data: threadUpdateSchema = {
    body: thread.messages[0].body,
    integrationId: Number(integration.externalId),
    externalThreadId: thread.externalThreadId,
    ...(!!thread.title && { title: thread.title }),
    ...(!!thread.messages[0].author?.displayName && {
      displayName: thread.messages[0].author?.displayName,
    }),
  };

  const octokit = await githubApp.getInstallationOctokit(data.integrationId);
  const { issueNumber, owner, repo } = Serializer.extractDataFromExternalId(
    data.externalThreadId
  );

  if (event === 'threadClosed') {
    await octokit.rest.issues.update({
      issue_number: issueNumber,
      state: 'closed',
      owner,
      repo,
    });
    return `issue closed: ${issueNumber}`;
  } else if (event === 'threadReopened') {
    await octokit.rest.issues.update({
      issue_number: issueNumber,
      state: 'open',
      owner,
      repo,
    });
    return `issue reopened: ${issueNumber}`;
  } else if (event === 'threadUpdated') {