Function processNewMessage

packages/integration-github/src/outbound.ts:76–129

({
  messageId,
  integration,
}: {
  messageId: string;
  integration: channelsIntegration;
})

}

async function processNewMessage({
  messageId,
  integration,
}: {
  messageId: string;
  integration: channelsIntegration;
}) {
  const message = await linenSdk.getMessage({
    messageId,
  });

  if (!message) {
    return 'MessageNotFound';
  }

  if (!message.threadId) {
    return 'ThreadNotFound';
  }

  const thread = await linenSdk.getThread({
    channelId: message.channelId,
    threadId: message.threadId,
  });

  if (!thread || !thread.externalThreadId) {
    return 'thread not found';
  }

  if (message.externalMessageId) {
    return 'skip two-way sync due message is not from linen';
  }

  const data: messageCreateType = {
    displayName: message.author?.displayName || 'user',
    body: message.body,
    integrationId: Number(integration.externalId),
    externalThreadId: thread.externalThreadId,
  };

  const octokit = await githubApp.getInstallationOctokit(data.integrationId);

  const { issueNumber, owner, repo } = Serializer.extractDataFromExternalId(
    data.externalThreadId
  );

  const result = await octokit.rest.issues.createComment({
    body: _buildMessage(data.body, data.displayName),
    issue_number: issueNumber,
    owner,
    repo,
  });

  return `issue commented: ${result?.data?.id}`;
}

async function processNewThread({
  threadId,