Add fetch API globals

Author: bobisjan

packages/ember-cli-fastboot/fastboot/instance-initializers/fetch.js

@@ -0,0 +1,9 @@
+function initialize(instance) {
+  let { request } = instance.lookup('service:fastboot');
+  fetch.__fastbootRequest = request;
+}
+
+export default {
+  name: 'fastboot:fetch', // `ember-fetch` addon registers as `fetch`
+  initialize,
+};

packages/ember-cli-fastboot/test/request-details-test.js

@@ -1,5 +1,6 @@
 'use strict';
 
+const path = require('path');
 const chai = require('chai');
 const expect = chai.expect;
 const RSVP = require('rsvp');
@@ -11,8 +12,8 @@ function injectMiddlewareAddon(app) {
     pkg.devDependencies['body-parser'] =
       process.env.npm_package_devDependencies_body_parser;
     pkg.dependencies = pkg.dependencies || {};
-    pkg.dependencies['fastboot-express-middleware'] =
-      process.env.npm_package_dependencies_fastboot_express_middleware;
+    pkg.dependencies['fastboot'] = `file:${path.resolve(__dirname, '../../fastboot')}`
+    pkg.dependencies['fastboot-express-middleware'] = `file:${path.resolve(__dirname, '../../fastboot-express-middleware')}`
     pkg['ember-addon'] = {
       paths: ['lib/post-middleware'],
     };

packages/fastboot/package.json

@@ -28,10 +28,12 @@
     "postversion": "git push origin master --tags"
   },
   "dependencies": {
+    "abortcontroller-polyfill": "^1.7.3",
     "chalk": "^4.1.2",
     "cookie": "^0.4.1",
     "debug": "^4.3.3",
     "jsdom": "^19.0.0",
+    "node-fetch": "^2.6.7",
     "resolve": "^1.22.0",
     "simple-dom": "^1.4.0",
     "source-map-support": "^0.5.21"
@@ -79,4 +81,4 @@
       "tokenRef": "GITHUB_AUTH"
     }
   }
-}
+}

packages/fastboot/src/sandbox.js

@@ -4,6 +4,9 @@ const chalk = require('chalk');
 const vm = require('vm');
 const sourceMapSupport = require('source-map-support');
 
+const httpRegex = /^https?:\/\//;
+const protocolRelativeRegex = /^\/\//;
+
 module.exports = class Sandbox {
   constructor(globals) {
     this.globals = globals;
@@ -14,6 +17,7 @@ module.exports = class Sandbox {
 
   buildSandbox() {
     let console = this.buildWrappedConsole();
+    let fetch = this.buildFetch();
     let URL = require('url');
     let globals = this.globals;
 
@@ -28,6 +32,7 @@ module.exports = class Sandbox {
         // Convince jQuery not to assume it's in a browser
         module: { exports: {} },
       },
+      fetch,
       globals
     );
 
@@ -53,6 +58,89 @@ module.exports = class Sandbox {
     return wrappedConsole;
   }
 
+  buildFetch() {
+    let globals;
+
+    if (globalThis.fetch) {
+      globals = {
+        fetch: globalThis.fetch,
+        Request: globalThis.Request,
+        Response: globalThis.Response,
+        Headers: globalThis.Headers,
+        AbortController: globalThis.AbortController,
+      };
+    } else {
+      let nodeFetch = require('node-fetch');
+      let {
+        AbortController,
+        abortableFetch,
+      } = require('abortcontroller-polyfill/dist/cjs-ponyfill');
+      let { fetch, Request } = abortableFetch({
+        fetch: nodeFetch,
+        Request: nodeFetch.Request,
+      });
+
+      globals = {
+        fetch,
+        Request,
+        Response: nodeFetch.Response,
+        Headers: nodeFetch.Headers,
+        AbortController,
+      };
+    }
+
+    let originalFetch = globals.fetch;
+    globals.fetch = function __fastbootFetch(input, init) {
+      input = globals.fetch.__fastbootBuildAbsoluteURL(input);
+      return originalFetch(input, init);
+    };
+
+    globals.fetch.__fastbootBuildAbsoluteURL = function __fastbootBuildAbsoluteURL(input) {
+      if (input && input.href) {
+        // WHATWG URL or Node.js Url Object
+        input = input.href;
+      }
+
+      if (typeof input !== 'string') {
+        return input;
+      }
+
+      if (protocolRelativeRegex.test(input)) {
+        let request = globals.fetch.__fastbootRequest;
+        let [protocol] = globals.fetch.__fastbootParseRequest(input, request);
+        input = `${protocol}//${input}`;
+      } else if (!httpRegex.test(input)) {
+        let request = globals.fetch.__fastbootRequest;
+        let [protocol, host] = globals.fetch.__fastbootParseRequest(input, request);
+        input = `${protocol}//${host}${input}`;
+      }
+
+      return input;
+    };
+
+    globals.fetch.__fastbootParseRequest = function __fastbootParseRequest(url, request) {
+      if (!request) {
+        throw new Error(
+          `Using fetch with relative URL ${url}, but application instance has not been initialized yet.`
+        );
+      }
+
+      // Old Prember version is not sending protocol
+      const protocol = request.protocol === 'undefined:' ? 'http:' : request.protocol;
+      return [protocol, request.host];
+    };
+
+    let OriginalRequest = globals.Request;
+    globals.Request = class __FastBootRequest extends OriginalRequest {
+      constructor(input, init) {
+        input = globals.fetch.__fastbootBuildAbsoluteURL(input);
+        super(input, init);
+      }
+    };
+
+    return globals;
+  }
+
   runScript(script) {
     script.runInContext(this.context);
   }

test-packages/basic-app/app/router.js

@@ -16,4 +16,5 @@ Router.map(function() {
   this.route('echo-request-headers');
   this.route('return-status-code-418');
   this.route('metadata');
+  this.route('fetch');
 });

test-packages/basic-app/app/routes/fetch.js

@@ -0,0 +1,27 @@
+import Route from '@ember/routing/route';
+import { assert } from '@ember/debug';
+
+export default class FetchRoute extends Route {
+  beforeModel() {
+    assert('fetch is available', fetch);
+    assert('Request is available', Request);
+    assert('Response is available', Response);
+    assert('Headers is available', Headers);
+    assert('AbortController is available', AbortController);
+  }
+
+  async model() {
+    let responses = await Promise.all([
+      fetch('http://localhost:45678/absolute-url.json'),
+      fetch(new Request('http://localhost:45678/absolute-request.json')),
+      fetch('//localhost:45678/protocol-relative-url.json'),
+      fetch(new Request('//localhost:45678/protocol-relative-request.json')),
+      fetch('/path-relative-url.json'),
+      fetch(new Request('/path-relative-request.json')),
+    ]);
+
+    responses = await Promise.all(responses.map((response) => response.json()));
+
+    return responses.map((response) => response.response).join('|');
+  }
+}

test-packages/basic-app/app/templates/fetch.hbs

@@ -0,0 +1 @@
+{{@model}}

test-packages/basic-app/public/absolute-request.json

@@ -0,0 +1,3 @@
+{
+    "response": "absolute-request"
+}

test-packages/basic-app/public/absolute-url.json

@@ -0,0 +1,3 @@
+{
+    "response": "absolute-url"
+}

test-packages/basic-app/public/path-relative-request.json

@@ -0,0 +1,3 @@
+{
+    "response": "path-relative-request"
+}