Pass request headers to CallableContext

spec/providers/https.spec.ts

@@ -443,6 +443,27 @@ describe('callable.FunctionBuilder', () => {
         },
       });
     });
+
+    it('should handle headers', async () => {
+      const mockRequest = request(null, 'application/json', {});
+      await runTest({
+        httpRequest: mockRequest,
+        expectedData: null,
+        callableFunction: (data, context) => {
+          expect(context.auth).to.be.undefined;
+          expect(context.headers).to.not.be.undefined;
+          expect(context.headers).to.equal(mockRequest.headers);
+          expect(context.instanceIdToken).to.be.undefined;
+          return null;
+        },
+        expectedHttpResponse: {
+          status: 200,
+          headers: expectedResponseHeaders,
+          body: {result: null},
+        },
+      });
+    });
+
   });
 });
 

src/providers/https.ts

@@ -26,6 +26,7 @@ import * as firebase from 'firebase-admin';
 import { apps } from '../apps';
 import * as _ from 'lodash';
 import * as cors from 'cors';
+import {IncomingHttpHeaders} from 'http';
 
 export function onRequest(handler: (req: express.Request, resp: express.Response) => void): HttpsFunction {
   // lets us add __trigger without altering handler:
@@ -213,6 +214,11 @@ export interface CallableContext {
     token: firebase.auth.DecodedIdToken;
   };
 
+  /**
+   * Incoming headers.
+   */
+  headers: IncomingHttpHeaders;
+
   /**
    * An unverified token for a Firebase Instance ID.
    */
@@ -373,7 +379,7 @@ export function onCall(
         throw new HttpsError('invalid-argument', 'Bad Request');
       }
 
-      const context: CallableContext = {};
+      const context: CallableContext = { headers: req.headers };
 
       const authorization = req.header('Authorization');
       if (authorization) {