This commit is contained in:
Elio Bischof
2025-07-01 15:43:33 +02:00
parent 1cbe7afb87
commit 816795f949
3 changed files with 3 additions and 28 deletions

View File

@@ -7,14 +7,8 @@ import { getSessionCookieById } from "./cookies";
import { getServiceUrlFromHeaders } from "./service-url"; import { getServiceUrlFromHeaders } from "./service-url";
import { getSession } from "./zitadel"; import { getSession } from "./zitadel";
const transport = async (serviceUrl: string, token: string) => {
return createServerTransport(token, {
baseUrl: serviceUrl,
});
};
const myUserService = async (serviceUrl: string, sessionToken: string) => { const myUserService = async (serviceUrl: string, sessionToken: string) => {
const transportPromise = await transport(serviceUrl, sessionToken); const transportPromise = await createServerTransport(sessionToken, serviceUrl);
return createUserServiceClient(transportPromise); return createUserServiceClient(transportPromise);
}; };

View File

@@ -428,9 +428,7 @@ export async function checkSessionAndSetPassword({
}); });
} else { } else {
const transport = async (serviceUrl: string, token: string) => { const transport = async (serviceUrl: string, token: string) => {
return createServerTransport(token, { return createServerTransport(token, serviceUrl);
baseUrl: serviceUrl,
});
}; };
const myUserService = async (serviceUrl: string, sessionToken: string) => { const myUserService = async (serviceUrl: string, sessionToken: string) => {

View File

@@ -43,24 +43,7 @@ export async function createServiceForHost<T extends ServiceClass>(
throw new Error("No token found"); throw new Error("No token found");
} }
const transport = createServerTransport(token, { const transport = createServerTransport(token, serviceUrl);
baseUrl: serviceUrl,
interceptors: !process.env.CUSTOM_REQUEST_HEADERS
? undefined
: [
(next) => {
return (req) => {
process.env.CUSTOM_REQUEST_HEADERS!.split(",").forEach(
(header) => {
const kv = header.split(":");
req.header.set(kv[0], kv[1]);
},
);
return next(req);
};
},
],
});
return createClientFor<T>(service)(transport); return createClientFor<T>(service)(transport);
} }