fix: use custom req headers in all server requests

apps/login/next-env-vars.d.ts

@@ -28,6 +28,6 @@ declare namespace NodeJS {
      * Optional: custom request headers to be added to every request
      * Split by comma, key value pairs separated by colon
      */
-    CUSTOM_REQUEST_HEADERS: string;
+    CUSTOM_REQUEST_HEADERS?: string;
   }
 }

apps/login/src/lib/self.ts

@@ -1,6 +1,6 @@
 "use server";
 
-import { createServerTransport } from "@zitadel/client/node";
+import { createServerTransport } from "./zitadel";
 import { createUserServiceClient } from "@zitadel/client/v2";
 import { headers } from "next/headers";
 import { getSessionCookieById } from "./cookies";

apps/login/src/lib/server/password.ts

@@ -17,7 +17,7 @@ import {
   setUserPassword,
 } from "@/lib/zitadel";
 import { ConnectError, create } from "@zitadel/client";
-import { createServerTransport } from "@zitadel/client/node";
+import { createServerTransport } from "../zitadel";
 import { createUserServiceClient } from "@zitadel/client/v2";
 import {
   Checks,

apps/login/src/lib/service.ts

@@ -1,5 +1,5 @@
 import { createClientFor } from "@zitadel/client";
-import { createServerTransport } from "@zitadel/client/node";
+import { createServerTransport } from "./zitadel";
 import { IdentityProviderService } from "@zitadel/proto/zitadel/idp/v2/idp_service_pb";
 import { OIDCService } from "@zitadel/proto/zitadel/oidc/v2/oidc_service_pb";
 import { OrganizationService } from "@zitadel/proto/zitadel/org/v2/org_service_pb";
@@ -50,7 +50,7 @@ export async function createServiceForHost<T extends ServiceClass>(
       : [
           (next) => {
             return (req) => {
-              process.env.CUSTOM_REQUEST_HEADERS.split(",").forEach(
+              process.env.CUSTOM_REQUEST_HEADERS!.split(",").forEach(
                 (header) => {
                   const kv = header.split(":");
                   req.header.set(kv[0], kv[1]);

apps/login/src/lib/zitadel.ts

@@ -52,6 +52,8 @@ import {
 import { unstable_cacheLife as cacheLife } from "next/cache";
 import { getUserAgent } from "./fingerprint";
 import { createServiceForHost } from "./service";
+import { createServerTransport as libCreateServerTransport } from "@zitadel/client/node";
+import { Transport } from '@connectrpc/connect';
 
 const useCache = process.env.DEBUG !== "true";
 
@@ -1497,3 +1499,24 @@ export async function listAuthenticationMethodTypes({
     userId,
   });
 }
+
+export function createServerTransport(token: string, baseUrl: string): Transport {
+  return libCreateServerTransport(token, {
+    baseUrl,
+    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);
+            };
+          },
+        ],
+  });
+}