From b4211ea1d4402cd1fe1bb37800195e101158afc5 Mon Sep 17 00:00:00 2001
From: dholms <dtholmgren@gmail.com>
Date: Wed, 6 Mar 2024 18:21:44 -0600
Subject: [PATCH] fix pipethrough of headers

---
 packages/pds/src/pipethrough.ts | 17 +++++++++++++----
 1 file changed, 13 insertions(+), 4 deletions(-)

diff --git a/packages/pds/src/pipethrough.ts b/packages/pds/src/pipethrough.ts
index faf4fe36aa3..0d9c00737b5 100644
--- a/packages/pds/src/pipethrough.ts
+++ b/packages/pds/src/pipethrough.ts
@@ -95,6 +95,12 @@ export const parseProxyHeader = async (
   return { did, serviceUrl }
 }
 
+const HEADERS_TO_FORWARD = [
+  'accept-language',
+  'content-type',
+  'atproto-labelers',
+]
+
 export const createUrlAndHeaders = async (
   ctx: AppContext,
   req: express.Request,
@@ -115,10 +121,13 @@ export const createUrlAndHeaders = async (
   const headers = requester
     ? (await ctx.serviceAuthHeaders(requester, aud)).headers
     : {}
-  // forward accept-language header to upstream services
-  headers['accept-language'] = req.headers['accept-language']
-  headers['content-type'] = req.headers['content-type']
-  headers['atproto-labelers'] = req.headers['atproto-labelers']
+  // forward select headers to upstream services
+  for (const header of HEADERS_TO_FORWARD) {
+    const val = req.headers[header]
+    if (val) {
+      headers[header] = val
+    }
+  }
   return { url, headers }
 }