Complete implementations, add test.

Author: taeold

spec/common/providers/https.spec.ts

@@ -802,6 +802,26 @@ describe("onCallHandler", () => {
       const data = [`data: {"error":{"message":"INTERNAL","status":"INTERNAL"}}`];
       expect(resp.body).to.equal([...data, ""].join("\n"));
     });
+
+    it("always returns error for v1 callables", async () => {
+      const mockReq = mockRequest(
+        { message: "hello streaming" },
+        "application/json",
+        {},
+        { accept: "text/event-stream" }
+      ) as any;
+      const fn = https.onCallHandler(
+        {
+          cors: { origin: true, methods: "POST" },
+        },
+        (req, resp) => {
+          return "hello world";
+        },
+        "gcfv1"
+      );
+      const resp = await runHandler(fn, mockReq);
+      expect(JSON.parse(resp.body)).to.deep.equal({ "error": { "status": "INVALID_ARGUMENT", "message": "Unsupported Accept header 'text/event-stream'" } });
+    });
   });
 });
 

src/common/providers/https.ts

@@ -788,7 +788,6 @@ function wrapOnCallHandler<Req = any, Res = any>(
         throw new HttpsError('invalid-argument', "Unsupported Accept header 'text/event-stream'")
       }
 
-
       const data: Req = decode(req.body.data);
       let result: Res;
       if (version === "gcfv1") {
@@ -839,11 +838,11 @@ function wrapOnCallHandler<Req = any, Res = any>(
 
       const { status } = httpErr.httpErrorCode;
       const body = { error: httpErr.toJSON() };
-      if (req.header("accept") === "text/event-stream") {
+      if (version === "gcfv2" && req.header("accept") === "text/event-stream") {
         res.send(encodeSSE(body));
       } else {
         res.status(status).send(body);
       }
     }
-  };
-}
+  }
+};