mirror of
https://github.com/hanzo-apps/dataroom.git
synced 2026-10-30 14:47:36 +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]>
56 lines
1.6 KiB
TypeScript
56 lines
1.6 KiB
TypeScript
import { NextRequest, NextResponse } from "next/server";
|
|
|
|
import { BLOCKED_PATHNAMES } from "@/lib/constants";
|
|
|
|
export default async function DomainMiddleware(req: NextRequest) {
|
|
const path = req.nextUrl.pathname;
|
|
const host = req.headers.get("host");
|
|
|
|
// If it's the root path, check for a configured redirect URL via API
|
|
// (KV can't be used directly in Edge Runtime — no TCP support)
|
|
if (path === "/") {
|
|
if (host) {
|
|
try {
|
|
const apiUrl = new URL("/api/internal/domain-redirect", req.url);
|
|
apiUrl.searchParams.set("host", host);
|
|
const res = await fetch(apiUrl.toString(), {
|
|
headers: { "x-middleware-internal": "1" },
|
|
});
|
|
if (res.ok) {
|
|
const data = await res.json();
|
|
if (data.redirectUrl) {
|
|
return NextResponse.redirect(new URL(data.redirectUrl, req.url), {
|
|
status: 302,
|
|
});
|
|
}
|
|
}
|
|
} catch {
|
|
// If API is unavailable, fall through
|
|
}
|
|
}
|
|
|
|
return NextResponse.redirect(
|
|
new URL("https://dataroom.hanzo.ai", req.url),
|
|
);
|
|
}
|
|
|
|
const url = req.nextUrl.clone();
|
|
|
|
// Check for blocked pathnames
|
|
if (BLOCKED_PATHNAMES.includes(path) || path.includes(".")) {
|
|
url.pathname = "/404";
|
|
return NextResponse.rewrite(url, { status: 404 });
|
|
}
|
|
|
|
// Rewrite the URL to the correct page component for custom domains
|
|
url.pathname = `/view/domains/${host}${path}`;
|
|
|
|
return NextResponse.rewrite(url, {
|
|
headers: {
|
|
"X-Robots-Tag": "noindex",
|
|
"X-Powered-By":
|
|
"Hanzo Dataroom - Secure Data Room Infrastructure",
|
|
},
|
|
});
|
|
}
|