87 lines
2.8 KiB
TypeScript
87 lines
2.8 KiB
TypeScript
import { type LoaderFunction, redirect } from "@remix-run/node";
|
|
import twilio from "twilio";
|
|
|
|
import { refreshSessionData, requireLoggedIn } from "~/utils/auth.server";
|
|
import { commitSession } from "~/utils/session.server";
|
|
import db from "~/utils/db.server";
|
|
import serverConfig from "~/config/config.server";
|
|
import getTwilioClient from "~/utils/twilio.server";
|
|
import fetchPhoneCallsQueue from "~/queues/fetch-phone-calls.server";
|
|
import fetchMessagesQueue from "~/queues/fetch-messages.server";
|
|
import { encrypt } from "~/utils/encryption";
|
|
|
|
export const loader: LoaderFunction = async ({ request }) => {
|
|
const { organization } = await requireLoggedIn(request);
|
|
const url = new URL(request.url);
|
|
const twilioSubAccountSid = url.searchParams.get("AccountSid");
|
|
if (!twilioSubAccountSid) {
|
|
throw new Error("unreachable");
|
|
}
|
|
|
|
let twilioClient = twilio(twilioSubAccountSid, serverConfig.twilio.authToken);
|
|
const twilioSubAccount = await twilioClient.api.accounts(twilioSubAccountSid).fetch();
|
|
const twilioMainAccountSid = twilioSubAccount.ownerAccountSid;
|
|
const twilioMainAccount = await twilioClient.api.accounts(twilioMainAccountSid).fetch();
|
|
console.log("twilioSubAccount", twilioSubAccount);
|
|
console.log("twilioAccount", twilioMainAccount);
|
|
const twilioAccount = await db.twilioAccount.upsert({
|
|
where: { organizationId: organization.id },
|
|
create: {
|
|
organization: {
|
|
connect: { id: organization.id },
|
|
},
|
|
subAccountSid: twilioSubAccount.sid,
|
|
subAccountAuthToken: encrypt(twilioSubAccount.authToken),
|
|
accountSid: twilioMainAccount.sid,
|
|
accountAuthToken: encrypt(twilioMainAccount.authToken),
|
|
},
|
|
update: {
|
|
subAccountSid: twilioSubAccount.sid,
|
|
subAccountAuthToken: encrypt(twilioSubAccount.authToken),
|
|
accountSid: twilioMainAccount.sid,
|
|
accountAuthToken: encrypt(twilioMainAccount.authToken),
|
|
},
|
|
});
|
|
|
|
twilioClient = getTwilioClient(twilioAccount);
|
|
const phoneNumbers = await twilioClient.incomingPhoneNumbers.list();
|
|
await Promise.all(
|
|
phoneNumbers.map(async (phoneNumber) => {
|
|
const phoneNumberId = phoneNumber.sid;
|
|
try {
|
|
await db.phoneNumber.create({
|
|
data: {
|
|
id: phoneNumberId,
|
|
organizationId: organization.id,
|
|
number: phoneNumber.phoneNumber,
|
|
isCurrent: false,
|
|
isFetchingCalls: true,
|
|
isFetchingMessages: true,
|
|
},
|
|
});
|
|
|
|
await Promise.all([
|
|
fetchPhoneCallsQueue.add(`fetch calls of id=${phoneNumberId}`, {
|
|
phoneNumberId,
|
|
}),
|
|
fetchMessagesQueue.add(`fetch messages of id=${phoneNumberId}`, {
|
|
phoneNumberId,
|
|
}),
|
|
]);
|
|
} catch (error: any) {
|
|
if (error.code !== "P2002") {
|
|
// if it's not a duplicate, it's a real error we need to handle
|
|
throw error;
|
|
}
|
|
}
|
|
}),
|
|
);
|
|
|
|
const { session } = await refreshSessionData(request);
|
|
return redirect("/settings/phone", {
|
|
headers: {
|
|
"Set-Cookie": await commitSession(session),
|
|
},
|
|
});
|
|
};
|