Function processNewThread

packages/integration-github/src/outbound.ts:131–192

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

}

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

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

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

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

  const ownerRepo = integration.data as any;

  const data: threadCreateType = {
    body: thread.messages[0].body,
    integrationId: Number(integration.externalId),
    owner: ownerRepo.owner,
    repo: ownerRepo.repo,
    channelId: integration.channelId,
    ...(thread.title && { title: thread.title }),
    ...(thread.messages[0].author?.displayName && {
      displayName: thread.messages[0].author?.displayName,
    }),
  };

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

  const newThread = await octokit.rest.issues.create({
    title: data.title || data.body,
    body: _buildMessage(data.body, data.displayName),
    owner: data.owner,
    repo: data.repo,
  });

  const externalId = Serializer.buildExternalId(
    data.channelId,
    data.owner,
    data.repo,
    newThread.data.number
  );

  await linenSdk.updateThread({
    externalThreadId: externalId,
    threadId,
    channelId: data.channelId,