119 lines
2.6 KiB
TypeScript
119 lines
2.6 KiB
TypeScript
import { db, getWorkerUtils } from "bridge-common";
|
|
|
|
interface ReceiveWhatsappMessageTaskOptions {
|
|
token;
|
|
message: any;
|
|
}
|
|
|
|
const receiveWhatsappMessageTask = async ({
|
|
token,
|
|
message,
|
|
}: ReceiveWhatsappMessageTaskOptions): Promise<void> => {
|
|
const bot = await db
|
|
.selectFrom("WhatsappBot")
|
|
.selectAll()
|
|
.where((eb) => eb.or([eb("token", "=", token), eb("id", "=", token)]))
|
|
.executeTakeFirstOrThrow();
|
|
|
|
console.log(bot);
|
|
};
|
|
|
|
export default receiveWhatsappMessageTask;
|
|
|
|
/* eslint-disable camelcase */
|
|
/*
|
|
import { withDb, AppDatabase } from "../../lib/db";
|
|
import workerUtils from "../../lib/utils";
|
|
|
|
interface WebhookPayload {
|
|
to: string;
|
|
from: string;
|
|
message_id: string;
|
|
sent_at: string;
|
|
message: string;
|
|
attachment: string;
|
|
filename: string;
|
|
mime_type: string;
|
|
}
|
|
|
|
interface WhatsappMessageTaskOptions {
|
|
waMessageId: string;
|
|
waMessage: string;
|
|
waTimestamp: string;
|
|
attachment: string;
|
|
filename: string;
|
|
mimetype: string;
|
|
botPhoneNumber: string;
|
|
whatsappBotId: string;
|
|
}
|
|
|
|
const formatPayload = (
|
|
messageInfo: WhatsappMessageTaskOptions,
|
|
): WebhookPayload => {
|
|
const {
|
|
waMessageId,
|
|
waMessage,
|
|
waTimestamp,
|
|
attachment,
|
|
filename,
|
|
mimetype,
|
|
botPhoneNumber,
|
|
} = messageInfo;
|
|
const parsedMessage = JSON.parse(waMessage);
|
|
const message =
|
|
parsedMessage.message?.conversation ??
|
|
parsedMessage.message?.extendedTextMessage?.text ??
|
|
parsedMessage.message?.imageMessage?.caption ??
|
|
parsedMessage.message?.videoMessage?.caption;
|
|
|
|
return {
|
|
to: botPhoneNumber,
|
|
from: parsedMessage.key.remoteJid,
|
|
message_id: waMessageId,
|
|
sent_at: waTimestamp,
|
|
message,
|
|
attachment,
|
|
filename,
|
|
mime_type: mimetype,
|
|
};
|
|
};
|
|
|
|
const notifyWebhooks = async (
|
|
db: AppDatabase,
|
|
messageInfo: WhatsappMessageTaskOptions,
|
|
) => {
|
|
const { waMessageId, whatsappBotId } = messageInfo;
|
|
const webhooks = await db.webhooks.findAllByBackendId(
|
|
"whatsapp",
|
|
whatsappBotId,
|
|
);
|
|
if (webhooks && webhooks.length === 0) return;
|
|
|
|
webhooks.forEach(({ id }) => {
|
|
const payload = formatPayload(messageInfo);
|
|
console.log({ payload });
|
|
workerUtils.addJob(
|
|
"notify-webhook",
|
|
{
|
|
payload,
|
|
webhookId: id,
|
|
},
|
|
{
|
|
// this de-deduplicates the job
|
|
jobKey: `webhook-${id}-message-${waMessageId}`,
|
|
},
|
|
);
|
|
});
|
|
};
|
|
|
|
const whatsappMessageTask = async (
|
|
options: WhatsappMessageTaskOptions,
|
|
): Promise<void> => {
|
|
console.log(options);
|
|
withDb(async (db: AppDatabase) => {
|
|
await notifyWebhooks(db, options);
|
|
});
|
|
};
|
|
|
|
export default whatsappMessageTask;
|
|
*/
|