101 lines
2.5 KiB
TypeScript
101 lines
2.5 KiB
TypeScript
import { type Session, type SessionIdStorageStrategy, createSessionStorage } from "@remix-run/node";
|
|
import type { TwilioAccount } from "@prisma/client";
|
|
|
|
import serverConfig from "~/config/config.server";
|
|
import db from "./db.server";
|
|
import logger from "./logger.server";
|
|
|
|
type SessionTwilioAccount = Pick<TwilioAccount, "accountSid" | "authToken">;
|
|
export type SessionData = {
|
|
twilio?: SessionTwilioAccount | null;
|
|
};
|
|
|
|
const SECOND = 1;
|
|
const MINUTE = 60 * SECOND;
|
|
const HOUR = 60 * MINUTE;
|
|
const DAY = 24 * HOUR;
|
|
|
|
const sessionStorage = createDatabaseSessionStorage<SessionData>({
|
|
cookie: {
|
|
name: "__session",
|
|
httpOnly: true,
|
|
path: "/",
|
|
sameSite: "lax",
|
|
secrets: [serverConfig.app.sessionSecret],
|
|
secure: process.env.NODE_ENV === "production" && process.env.CI !== "true",
|
|
maxAge: 30 * DAY,
|
|
},
|
|
});
|
|
|
|
export function getSession(request: Request): Promise<Session<SessionData>> {
|
|
return sessionStorage.getSession(request.headers.get("Cookie"));
|
|
}
|
|
|
|
export const { commitSession } = sessionStorage;
|
|
|
|
function createDatabaseSessionStorage<Data extends SessionData = SessionData>({
|
|
cookie,
|
|
}: Pick<SessionIdStorageStrategy, "cookie">) {
|
|
return createSessionStorage<Data>({
|
|
cookie,
|
|
async createData(sessionData, expiresAt) {
|
|
let twilioAccount;
|
|
if (sessionData.twilio) {
|
|
twilioAccount = { connect: { accountSid: sessionData.twilio.accountSid } };
|
|
}
|
|
const { id } = await db.session.create({
|
|
data: {
|
|
expiresAt,
|
|
twilioAccount,
|
|
data: JSON.stringify(sessionData),
|
|
},
|
|
});
|
|
return id;
|
|
},
|
|
async readData(id) {
|
|
const session = await db.session.findUnique({ where: { id } });
|
|
if (!session) {
|
|
return null;
|
|
}
|
|
|
|
const sessionHasExpired = session.expiresAt && session.expiresAt < new Date();
|
|
if (sessionHasExpired) {
|
|
await db.session.delete({ where: { id } });
|
|
return null;
|
|
}
|
|
|
|
return JSON.parse(session.data);
|
|
},
|
|
async updateData(id, sessionData, expiresAt) {
|
|
try {
|
|
await db.session.update({
|
|
where: { id },
|
|
data: {
|
|
data: JSON.stringify(sessionData),
|
|
expiresAt,
|
|
},
|
|
});
|
|
} catch (error: any) {
|
|
if (error.code === "P2025") {
|
|
logger.warn("Could not update session because it's not in the DB");
|
|
return;
|
|
}
|
|
|
|
throw error;
|
|
}
|
|
},
|
|
async deleteData(id) {
|
|
try {
|
|
await db.session.delete({ where: { id } });
|
|
} catch (error: any) {
|
|
if (error.code === "P2025") {
|
|
logger.warn("Could not delete session because it's not in the DB");
|
|
return;
|
|
}
|
|
|
|
throw error;
|
|
}
|
|
},
|
|
});
|
|
}
|