Function processNewMessage

packages/integration-linear/src/outbound.ts:33–75

({
  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';
  }

  // create comment
  await createMessage({
    accessToken: integration.data.access_token,
    body: message.body,
    createAsUser: message.author?.displayName || 'linen-user',
    issueId: thread.externalThreadId,
    displayIconUrl: message.author?.profileImageUrl || undefined,
  });

  return `issue commented`;
}

async function processNewThread({
  threadId,