shellphone.app/app/api/queue/fetch-messages.ts

39 lines
1.0 KiB
TypeScript
Raw Normal View History

import { Queue } from "quirrel/blitz";
import twilio from "twilio";
2021-07-31 14:33:18 +00:00
import db from "../../../db";
import insertMessagesQueue from "./insert-messages";
2021-07-31 14:33:18 +00:00
type Payload = {
customerId: string;
};
2021-07-31 14:33:18 +00:00
const fetchMessagesQueue = Queue<Payload>("api/queue/fetch-messages", async ({ customerId }) => {
const customer = await db.customer.findFirst({ where: { id: customerId } });
const phoneNumber = await db.phoneNumber.findFirst({ where: { customerId } });
2021-07-31 14:33:18 +00:00
const [messagesSent, messagesReceived] = await Promise.all([
twilio(customer!.accountSid!, customer!.authToken!).messages.list({
from: phoneNumber!.phoneNumber,
}),
twilio(customer!.accountSid!, customer!.authToken!).messages.list({
to: phoneNumber!.phoneNumber,
}),
]);
2021-07-31 14:33:18 +00:00
const messages = [...messagesSent, ...messagesReceived].sort(
(a, b) => a.dateSent.getTime() - b.dateSent.getTime()
);
2021-07-31 14:33:18 +00:00
await insertMessagesQueue.enqueue(
{
customerId,
messages,
},
{
id: `insert-messages-${customerId}`,
}
);
});
2021-07-31 14:33:18 +00:00
export default fetchMessagesQueue;