Function processNewMessage

packages/integration-discord/src/outbound.ts:180–219

({
  token,
  externalThreadId,
  externalChannelId,
  body,
  author,
  title,
  setThreadExternalId,
  setMessageExternalId,
}: {
  setThreadExternalId: (externalId: string) => Promise<void>;
  setMessageExternalId: (externalId: string) => Promise<void>;
  token: string;
  externalThreadId: string;
  externalChannelId: string;
  body: string;
  author?: string;
  title: string;
})

}

async function processNewMessage({
  token,
  externalThreadId,
  externalChannelId,
  body,
  author,
  title,
  setThreadExternalId,
  setMessageExternalId,
}: {
  setThreadExternalId: (externalId: string) => Promise<void>;
  setMessageExternalId: (externalId: string) => Promise<void>;
  token: string;
  externalThreadId: string;
  externalChannelId: string;
  body: string;
  author?: string;
  title: string;
}) {
  const client = await getClient(token);

  const thread: any = await client
    .post(Routes.threads(externalChannelId, externalThreadId), {
      body: { name: title, nonce },
    })
    .catch(() => null);

  if (thread) {
    await setThreadExternalId(thread.id);
  }

  const message: any = await client.post(
    Routes.channelMessages(thread ? thread.id : externalThreadId),
    {
      body: { content: `${author}: ${body}`, nonce },
    }
  );
  await setMessageExternalId(message.id);
  return;
}