mirror of
https://github.com/hanzoai/dataroom.git
synced 2026-10-30 18:41:07 +00:00
87 lines
2.1 KiB
TypeScript
87 lines
2.1 KiB
TypeScript
import crypto from "crypto";
|
|
import { z } from "zod";
|
|
|
|
import { redis } from "@/lib/redis";
|
|
|
|
export const PREVIEW_EXPIRATION_TIME = 20 * 60 * 1000; // 20 minutes
|
|
|
|
const ZPreviewSessionSchema = z.object({
|
|
userId: z.string(),
|
|
linkId: z.string(),
|
|
expiresAt: z.number(),
|
|
});
|
|
|
|
type PreviewSession = z.infer<typeof ZPreviewSessionSchema>;
|
|
|
|
async function createPreviewSession(
|
|
linkId: string,
|
|
userId: string,
|
|
): Promise<{ token: string; expiresAt: number }> {
|
|
const sessionToken = crypto.randomBytes(32).toString("hex");
|
|
const expiresAt = Date.now() + PREVIEW_EXPIRATION_TIME;
|
|
|
|
const sessionData: PreviewSession = {
|
|
linkId,
|
|
userId,
|
|
expiresAt,
|
|
};
|
|
|
|
// Validate session data before storing
|
|
ZPreviewSessionSchema.parse(sessionData);
|
|
|
|
// Store session in Redis
|
|
await redis.set(
|
|
`preview_session:${sessionToken}`,
|
|
JSON.stringify(sessionData),
|
|
{ pxat: expiresAt },
|
|
);
|
|
|
|
return {
|
|
token: sessionToken,
|
|
expiresAt,
|
|
};
|
|
}
|
|
|
|
async function verifyPreviewSession(
|
|
previewToken: string,
|
|
userId: string,
|
|
linkId: string,
|
|
): Promise<PreviewSession | null> {
|
|
const sessionToken = previewToken;
|
|
if (!sessionToken) return null;
|
|
|
|
const session = await redis.get(`preview_session:${sessionToken}`);
|
|
if (!session) return null;
|
|
|
|
try {
|
|
const sessionData = ZPreviewSessionSchema.parse(session);
|
|
|
|
// Check if the session is for the correct user
|
|
if (sessionData.userId !== userId) {
|
|
await redis.del(`preview_session:${sessionToken}`);
|
|
return null;
|
|
}
|
|
|
|
// Check if session is expired
|
|
if (sessionData.expiresAt < Date.now()) {
|
|
await redis.del(`preview_session:${sessionToken}`);
|
|
return null;
|
|
}
|
|
|
|
// Check if the session is for the correct link and dataroom
|
|
if (sessionData.linkId !== linkId) {
|
|
await redis.del(`preview_session:${sessionToken}`);
|
|
return null;
|
|
}
|
|
|
|
return sessionData;
|
|
} catch (error) {
|
|
console.error("Preview session verification error:", error);
|
|
await redis.del(`preview_session:${sessionToken}`);
|
|
return null;
|
|
}
|
|
}
|
|
|
|
export { createPreviewSession, verifyPreviewSession };
|
|
export type { PreviewSession };
|