Force json parsing

package.json

@@ -1,7 +1,7 @@
 {
   "name": "nodegate",
   "description": "API gateway made simple, fast and easy to configure.",
-  "version": "2.0.0",
+  "version": "2.0.1",
   "author": "Julien Martin <[email protected]>",
   "license": "MIT",
   "scripts": {

test/workers/aggregate.test.js

@@ -458,5 +458,42 @@ describe('workers/aggregate', () => {
       await aggregate('post', 'https://wiki.federation.com/armaments')(container);
       expect(container.body.phasers).toBe(16);
     });
+    it('forces text parsing as json when the container headers is application/json', async () => {
+      const container = {
+        ...getEmpty(),
+        headers: {
+          'content-type': 'application/json',
+        },
+      };
+      fetchMock.mockGlobal().postOnce('https://wiki.federation.com/armaments', {
+        status: 200,
+        body: '{ "phasers": 16 }',
+        headers: {
+          'Content-Type': 'text/plain;charset=UTF-8',
+        },
+      });
+      await aggregate('post', 'https://wiki.federation.com/armaments')(container);
+      expect(container.body.phasers).toBe(16);
+    });
+    it('should throw an error when the parsing failed', async () => {
+      const container = {
+        ...getEmpty(),
+        headers: {
+          'content-type': 'application/json',
+        },
+      };
+      fetchMock.mockGlobal().postOnce('https://wiki.federation.com/armaments', {
+        status: 200,
+        body: '{ "badJSON: true }',
+        headers: {
+          'Content-Type': 'text/plain;charset=UTF-8',
+        },
+      });
+      try {
+        await aggregate('post', 'https://wiki.federation.com/armaments')(container);
+      } catch (err) {
+        expect(err.message).toEqual('SyntaxError: Unterminated string in JSON at position 18');
+      }
+    });
   });
 });

workers/aggregate.js

@@ -44,7 +44,11 @@ module.exports = (method, url, options = {}) => {
       container.statusCode = response.status;
       if (response.headers.get('content-type') && !isJsonContentType(response.headers.get('content-type'))) {
         const text = await response.text();
-        setBodyToContainer(text, container, options);
+        setBodyToContainer(
+          container.headers['content-type'] === 'application/json' ? JSON.parse(text) : text,
+          container,
+          options,
+        );
         if (!response.ok) {
           throw new WorkflowError('Fetch error', { text, statusCode: response.status });
         }