mirror of
https://github.com/hanzo-apps/dataroom.git
synced 2026-11-02 22:04:20 +00:00
zeekayandHanzo Dev
6b68c9299e
The client was already @hanzo/kv; only the vocabulary was still Redis. Every module, symbol and comment now says what it connects to: lib/redis.ts -> lib/kv.ts (exports kv, lockKv) lib/redis-job-store.ts -> lib/kv-job-store.ts (KvJobStore) lib/redis-download-job-store.ts -> lib/kv-download-job-store.ts lib/files/tus-redis-locker.ts -> lib/files/tus-kv-locker.ts (KvLocker, KvLock) lib/api/domains/redis.ts -> lib/api/domains/kv.ts (getKey) lib/redis/ -> lib/kv-queue/ KV_URL is now the only endpoint variable — the REDIS_URL fallback and the redis://localhost default are gone, and the default scheme is kv://, which @hanzo/kv parses natively (utils/index.js). .env.example gained the KV_URL it never documented, and lost UPSTASH_REDIS_REST_LOCKER_URL/TOKEN: nothing has read those since the client changed — the locker opens a second connection to the same KV, so there is no second endpoint to configure. The second connection is `lockKv`, not `locker`: both tus routes already have a local `const locker = new KvLocker(...)`, so naming the client `locker` made the lock take itself as its own client. Verified against the repo's own gate (npx tsc --noEmit): 100 errors before and after, 0 introduced, compared set-wise by file:line:code. Behaviour is untouched — this is naming, one connection string, and dead config. Co-authored-by: Hanzo Dev <[email protected]>
71 lines
2.0 KiB
TypeScript
71 lines
2.0 KiB
TypeScript
import { NextApiRequest, NextApiResponse } from "next";
|
|
|
|
import { getDataroomSessionByLinkIdInPagesRouter } from "@/lib/auth/dataroom-auth";
|
|
import prisma from "@/lib/prisma";
|
|
import { downloadJobStore } from "@/lib/kv-download-job-store";
|
|
|
|
export default async function handler(
|
|
req: NextApiRequest,
|
|
res: NextApiResponse,
|
|
) {
|
|
if (req.method !== "GET") {
|
|
res.setHeader("Allow", ["GET"]);
|
|
return res.status(405).end(`Method ${req.method} Not Allowed`);
|
|
}
|
|
|
|
const linkId = req.query.linkId as string;
|
|
if (!linkId) {
|
|
return res.status(400).json({ error: "linkId is required" });
|
|
}
|
|
|
|
const session = await getDataroomSessionByLinkIdInPagesRouter(req, linkId);
|
|
if (!session) {
|
|
return res.status(401).json({ error: "Session required" });
|
|
}
|
|
|
|
const view = await prisma.view.findUnique({
|
|
where: { id: session.viewId },
|
|
select: { viewerEmail: true },
|
|
});
|
|
if (!view?.viewerEmail) {
|
|
return res.status(200).json([]);
|
|
}
|
|
|
|
const jobs = await downloadJobStore.getViewerJobs(
|
|
linkId,
|
|
view.viewerEmail,
|
|
20,
|
|
);
|
|
|
|
// Replace raw S3 presigned URLs with relative proxy URLs so the browser
|
|
// routes through the current origin (where the session cookie lives).
|
|
const sanitisedJobs = jobs.map((job) => {
|
|
const partCount = job.downloadUrls?.length ?? 0;
|
|
const proxyUrls =
|
|
job.status === "COMPLETED" && partCount > 0
|
|
? Array.from(
|
|
{ length: partCount },
|
|
(_, i) =>
|
|
`/api/links/download/file/${job.id}/${i}?linkId=${encodeURIComponent(linkId)}`,
|
|
)
|
|
: undefined;
|
|
|
|
return {
|
|
id: job.id,
|
|
status: job.status,
|
|
progress: job.progress,
|
|
totalFiles: job.totalFiles,
|
|
processedFiles: job.processedFiles,
|
|
downloadUrls: proxyUrls,
|
|
error: job.status === "FAILED" ? job.error : undefined,
|
|
dataroomName: job.dataroomName,
|
|
type: job.type,
|
|
folderName: job.folderName,
|
|
createdAt: job.createdAt,
|
|
expiresAt: job.expiresAt,
|
|
};
|
|
});
|
|
|
|
return res.status(200).json(sanitisedJobs);
|
|
}
|