Function processNewMessage

packages/integration-email/src/outbound.ts:38–88

(
  messageId: string,
  integration: any, // TODO: add types
  event: any // TODO: add types
)

}

async function processNewMessage(
  messageId: string,
  integration: any, // TODO: add types
  event: any // TODO: add types
) {
  const message = await linenSdk.getMessage({ messageId });

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

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

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

  const lastReply = await linenSdk.findMessage({
    threadId: message.threadId,
    channelId: message.channelId,
    mustHave: ['externalMessageId'],
    orderBy: 'desc',
    sortBy: 'sentAt',
  });

  const data = {
    from: message.author?.displayName,
    to: thread.messages.find(Boolean)?.author?.displayName,
    body: message.body,
    title: thread.title,
    channelInbox: integration.externalId,
    ...(lastReply?.externalMessageId && {
      lastExternalMessageId: lastReply.externalMessageId,
    }),
  };

  const externalId = await sendMail({ event, data });
  return await linenSdk.updateMessage({
    messageId,
    externalMessageId: externalId,
  });
}

async function sendMail({
  event,