CodeCow/stack
1
0
Fork 0
mirror of https://github.com/stack-auth/stack.git synced 2026-06-04 21:04:37 +08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Initialize OIDC provider lazily

Browse Source
This commit is contained in:
Konstantin Wohlwend 2024-11-30 23:47:12 -08:00
parent d05ce2e3e2
commit 5c39d9e8be
1 changed files with 18 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
apps/backend/src/app/api/v1/integrations/neon/oauth/idp/[[...route]]/route.tsx
View File

@ -5,16 +5,24 @@ import { createNodeHttpServerDuplex } from "@stackframe/stack-shared/dist/utils/
import { NextRequest, NextResponse } from "next/server";
import { createOidcProvider } from "./idp";
const apiBaseUrl = new URL(getEnvVariable("STACK_BASE_URL"));
const pathPrefix = "/api/v1/integrations/neon/oauth/idp";
const idpBaseUrl = new URL(pathPrefix, apiBaseUrl);
const oidcCallbackPromise = (async () => {
const oidc = await createOidcProvider({
id: "stack-preconfigured-idp:integrations/neon",
baseUrl: idpBaseUrl.toString(),
});
return oidc.callback();
})();
// we want to initialize the OIDC provider lazily so it's not initiated at build time
let _oidcCallbackPromiseCache: Promise<any> | undefined;
function getOidcCallbackPromise() {
if (!_oidcCallbackPromiseCache) {
const apiBaseUrl = new URL(getEnvVariable("STACK_BASE_URL"));
const idpBaseUrl = new URL(pathPrefix, apiBaseUrl);
_oidcCallbackPromiseCache = (async () => {
const oidc = await createOidcProvider({
id: "stack-preconfigured-idp:integrations/neon",
baseUrl: idpBaseUrl.toString(),
});
return oidc.callback();
})();
}
return _oidcCallbackPromiseCache;
}
const handler = handleApiRequest(async (req: NextRequest) => {
const newUrl = req.url.replace(pathPrefix, "");
@ -23,7 +31,6 @@ const handler = handleApiRequest(async (req: NextRequest) => {
}
const newHeaders = new Headers(req.headers);
const incomingBody = new Uint8Array(await req.arrayBuffer());
console.log("BBBBBBBB", incomingBody, new TextDecoder().decode(incomingBody));
const [incomingMessage, serverResponse] = await createNodeHttpServerDuplex({
method: req.method,
originalUrl: new URL(req.url),
@ -32,7 +39,7 @@ const handler = handleApiRequest(async (req: NextRequest) => {
body: incomingBody,
});
await (await oidcCallbackPromise)(incomingMessage, serverResponse);
await (await getOidcCallbackPromise())(incomingMessage, serverResponse);
const body = new Uint8Array(serverResponse.bodyChunks.flatMap(chunk => [...chunk]));