Make headers case insensitive

.changeset/angry-socks-tan.md

@@ -0,0 +1,5 @@
+---
+"inngest": patch
+---
+
+Fix header keys sometimes case sensitive

packages/inngest/src/digitalocean.ts

@@ -91,7 +91,13 @@ export const serve = (
 
       return {
         body: () => data || {},
-        headers: (key) => http?.headers?.[key],
+        headers: (key) => {
+          for (const [k, v] of Object.entries(http.headers)) {
+            if (k.toLowerCase() === key.toLowerCase()) {
+              return v;
+            }
+          }
+        },
         method: () => http.method,
         url: () => new URL(`${options.serveHost}${options.servePath || "/"}`),
         queryString: (key) => main[key] as string,

packages/inngest/src/express.ts

@@ -74,7 +74,14 @@ export const serve = (options: ServeHandlerOptions): any => {
         // eslint-disable-next-line @typescript-eslint/no-unsafe-return
         body: () => req.body,
         headers: (key) => {
-          const header = req.headers[key];
+          let header;
+          for (const [k, v] of Object.entries(req.headers)) {
+            if (k.toLowerCase() === key.toLowerCase()) {
+              header = v;
+              break;
+            }
+          }
+
           return Array.isArray(header) ? header[0] : header;
         },
         method: () => req.method || "GET",

packages/inngest/src/fastify.ts

@@ -122,7 +122,14 @@ export const serve = (
       return {
         body: () => req.body,
         headers: (key) => {
-          const header = req.headers[key];
+          let header;
+          for (const [k, v] of Object.entries(req.headers)) {
+            if (k.toLowerCase() === key.toLowerCase()) {
+              header = v;
+              break;
+            }
+          }
+
           return Array.isArray(header) ? header[0] : header;
         },
         method: () => req.method,

packages/inngest/src/koa.ts

@@ -73,7 +73,13 @@ export const serve = (
         body: () =>
           (ctx.request as unknown as { body: Record<string, unknown> }).body,
         headers: (key) => {
-          const header = ctx.headers[key];
+          let header;
+          for (const [k, v] of Object.entries(ctx.headers)) {
+            if (k.toLowerCase() === key.toLowerCase()) {
+              header = v;
+              break;
+            }
+          }
 
           if (Array.isArray(header)) {
             return header[0];

packages/inngest/src/lambda.ts

@@ -105,7 +105,13 @@ export const serve = (
               : "{}"
           );
         },
-        headers: (key) => event.headers[key],
+        headers: (key) => {
+          for (const [k, v] of Object.entries(event.headers)) {
+            if (k.toLowerCase() === key.toLowerCase()) {
+              return v;
+            }
+          }
+        },
         method: () => {
           return eventIsV2
             ? event.requestContext.http.method

packages/inngest/src/next.ts

@@ -76,10 +76,17 @@ export const serve = (
       const req = expectedReq as Either<NextApiRequest, NextRequest>;
 
       const getHeader = (key: string): string | null | undefined => {
-        const header =
-          typeof req.headers.get === "function"
-            ? req.headers.get(key)
-            : req.headers[key];
+        let header;
+        if (typeof req.headers.get === "function") {
+          header = req.headers.get(key);
+        } else {
+          for (const [k, v] of Object.entries(req.headers)) {
+            if (k.toLowerCase() === key.toLowerCase()) {
+              header = v;
+              break;
+            }
+          }
+        }
 
         return Array.isArray(header) ? header[0] : header;
       };

packages/inngest/src/redwood.ts

@@ -82,7 +82,13 @@ export const serve = (
               : "{}"
           );
         },
-        headers: (key) => event.headers[key],
+        headers: (key) => {
+          for (const [k, v] of Object.entries(event.headers)) {
+            if (k.toLowerCase() === key.toLowerCase()) {
+              return v;
+            }
+          }
+        },
         method: () => event.httpMethod,
         url: () => {
           const scheme =