link-stack/apps/bridge-worker/tasks/signal/receive-signal-message.ts

import { db, getWorkerUtils } from "@link-stack/bridge-common";

interface ReceiveSignalMessageTaskOptions {
  token: string;
  sender: string;
  message: string;
}

const receiveSignalMessageTask = async ({
  token,
  sender,
  message,
}: ReceiveSignalMessageTaskOptions): Promise<void> => {
  console.log({ token, sender, message });
  const worker = await getWorkerUtils();
  const row = await db
    .selectFrom("SignalBot")
    .selectAll()
    .where("id", "=", token)
    .executeTakeFirstOrThrow();

  console.log(row);

  const backendId = row.id;
  const payload = {
    message,
    recipient: sender,
  };

  await worker.addJob("common/notify-webhooks", { backendId, payload });
};

export default receiveSignalMessageTask;