Function handleInbound

packages/integration-email/src/inbound.ts:43–122

(reqBody: any)

}

async function handleInbound(reqBody: any) {
  const spam = reqBody.headerLines.find(
    (h: any) => h.key === 'x-ses-spam-verdict'
  );
  if (spam && spam.line.indexOf('FAIL') > -1) {
    // skip spam
    return;
  }
  const virus = reqBody.headerLines.find(
    (h: any) => h.key === 'x-ses-virus-verdict'
  );
  if (virus && virus.line.indexOf('FAIL') > -1) {
    // skip virus
    return;
  }

  const forwarded = reqBody.headerLines.find(
    (h: any) => h.key === 'x-forwarded-to'
  );

  const destination: string[] = [];
  if (forwarded && forwarded.line) {
    const emails = extractEmail(forwarded.line);
    if (emails) {
      destination.push(...emails);
    }
  }
  const externalId = reqBody.messageId;
  const to = extractEmail(reqBody.to.text);
  if (to) {
    destination.push(...to);
  }
  const from = reqBody.from.text;
  const body = cleanUpQuotedEmail(reqBody.text || reqBody.html); // TODO: parse html to text
  const title = reqBody.subject;

  // "to" must match a channel integration
  const channel = await findChannel(destination);
  if (!channel) {
    console.warn('channel not found');
    return;
  }

  // "from" must find or create a new user
  const user = await linenSdk.findOrCreateUser({
    accountsId: channel.accountId,
    displayName: from,
    externalUserId: from,
  });

  // "inReplyTo" must find or create a thread
  const message =
    !!reqBody.inReplyTo &&
    (await linenSdk.findMessage({
      externalMessageId: reqBody.inReplyTo,
      channelId: channel.id,
    }));
  // if message exists, we create a new message