Net Fetch in Electron

.eslintrc.json

@@ -3,13 +3,35 @@
   "ignorePatterns": ["**/*"],
   "plugins": ["@nrwl/nx"],
   "overrides": [
+    {
+      "files": ["*.ts", "*.tsx"],
+      "extends": ["plugin:@nrwl/nx/typescript"],
+      "rules": {}
+    },
+    {
+      "files": ["*.js", "*.jsx"],
+      "extends": ["plugin:@nrwl/nx/javascript"],
+      "rules": {}
+    },
+    {
+      "files": ["*.spec.ts", "*.spec.tsx", "*.spec.js", "*.spec.jsx"],
+      "env": {
+        "jest": true
+      },
+      "rules": {}
+    },
     {
       "files": ["*.ts", "*.tsx", "*.js", "*.jsx"],
       "rules": {
-        "@typescript-eslint/no-unused-vars": ["error", {
-          "varsIgnorePattern": "^_",
-          "argsIgnorePattern": "^_"
-        }],
+        "@typescript-eslint/no-unused-vars": [
+          "error",
+          {
+            "varsIgnorePattern": "^_",
+            "argsIgnorePattern": "^_"
+          }
+        ],
+        "@typescript-eslint/no-explicit-any": ["off", {}],
+        "@typescript-eslint/ban-ts-comment": ["off", {}],
         "@nrwl/nx/enforce-module-boundaries": [
           "error",
           {
@@ -24,23 +46,6 @@
           }
         ]
       }
-    },
-    {
-      "files": ["*.ts", "*.tsx"],
-      "extends": ["plugin:@nrwl/nx/typescript"],
-      "rules": {}
-    },
-    {
-      "files": ["*.js", "*.jsx"],
-      "extends": ["plugin:@nrwl/nx/javascript"],
-      "rules": {}
-    },
-    {
-      "files": ["*.spec.ts", "*.spec.tsx", "*.spec.js", "*.spec.jsx"],
-      "env": {
-        "jest": true
-      },
-      "rules": {}
     }
   ]
 }

apps/zui/src/core/electron-zed-client.ts

@@ -0,0 +1,7 @@
+import {Client} from "@brimdata/zed-node"
+import {net} from "electron"
+
+export class ElectronZedClient extends Client {
+  fetch =
+    process.env.JEST_WORKER_ID === undefined ? net.fetch : globalThis.fetch
+}

apps/zui/src/core/electron-zed-lake.ts

@@ -0,0 +1,7 @@
+import {Lake} from "@brimdata/zed-node"
+import {net} from "electron"
+
+export class ElectronZedLake extends Lake {
+  fetch =
+    process.env.JEST_WORKER_ID === undefined ? net.fetch : globalThis.fetch
+}

apps/zui/src/core/main/main-object.ts

@@ -2,7 +2,6 @@ import {app} from "electron"
 import keytar from "keytar"
 import {EventEmitter} from "events"
 import os from "os"
-import {Client, Lake} from "@brimdata/zed-node"
 import {Store as ReduxStore} from "redux"
 import url from "url"
 import {
@@ -30,6 +29,8 @@ import {getAuthToken} from "../../js/api/core/get-zealot"
 import {Abortables} from "src/app/core/models/abortables"
 import * as zui from "src/zui"
 import log from "electron-log"
+import {ElectronZedClient} from "../electron-zed-client"
+import {ElectronZedLake} from "../electron-zed-lake"
 
 export class MainObject {
   public isQuitting = false
@@ -43,7 +44,7 @@ export class MainObject {
     const windows = new WindowManager(data)
     const store = createMainStore(data?.globalState)
     const appMeta = await getAppMeta()
-    const lake = new Lake({
+    const lake = new ElectronZedLake({
       root: args.lakeRoot,
       port: args.lakePort,
       logs: args.lakeLogs,
@@ -55,7 +56,7 @@ export class MainObject {
 
   // Only call this from boot
   constructor(
-    readonly lake: Lake,
+    readonly lake: ElectronZedLake,
     readonly windows: WindowManager,
     readonly store: ReduxStore<State, any>,
     readonly session: Session,
@@ -135,7 +136,7 @@ export class MainObject {
     const lakeData = Lakes.id(lakeId)(this.store.getState())
     const lake = createLake(lakeData)
     const auth = await this.dispatch(getAuthToken(lake))
-    return new Client(lake.getAddress(), {auth})
+    return new ElectronZedClient(lake.getAddress(), {auth})
   }
 
   async createDefaultClient() {

packages/zed-node/package.json

@@ -9,7 +9,8 @@
   },
   "dependencies": {
     "@brimdata/zed-js": "workspace:*",
-    "fs-extra": "^11.1.1"
+    "fs-extra": "^11.1.1",
+    "node-fetch": "^2.6.2"
   },
   "peerDependencies": {
     "zed": "*"

packages/zed-node/src/client.ts

@@ -5,9 +5,11 @@ import {
   getLoadContentType,
   jsonHeader,
 } from '@brimdata/zed-js';
+// @ts-ignore
+import nodeFetch from 'node-fetch';
 
 export class Client extends BaseClient {
-  public fetch = globalThis.fetch;
+  public fetch = (...args: any[]) => nodeFetch(...args);
 
   async load(
     data: string | NodeJS.ReadableStream,

packages/zed-node/src/lake.ts

@@ -11,6 +11,7 @@ type ConstructorOpts = {
   corsOrigins?: string[];
 };
 export class Lake {
+  fetch = globalThis.fetch;
   lake?: ChildProcess;
   root: string;
   port: number;
@@ -82,7 +83,7 @@ export class Lake {
 
   async isUp() {
     try {
-      const response = await globalThis.fetch(`http://${this.addr()}/status`);
+      const response = await this.fetch(`http://${this.addr()}/status`);
       const text = await response.text();
       return text === 'ok';
     } catch (e) {

yarn.lock

@@ -1922,6 +1922,7 @@ __metadata:
     "@brimdata/zed-js": "workspace:*"
     "@types/fs-extra": ^11.0.1
     fs-extra: ^11.1.1
+    node-fetch: ^2.6.2
     zed: "github:brimdata/zed#main"
   peerDependencies:
     zed: "*"
@@ -14347,6 +14348,20 @@ __metadata:
   languageName: node
   linkType: hard
 
+"node-fetch@npm:^2.6.2":
+  version: 2.7.0
+  resolution: "node-fetch@npm:2.7.0"
+  dependencies:
+    whatwg-url: ^5.0.0
+  peerDependencies:
+    encoding: ^0.1.0
+  peerDependenciesMeta:
+    encoding:
+      optional: true
+  checksum: d76d2f5edb451a3f05b15115ec89fc6be39de37c6089f1b6368df03b91e1633fd379a7e01b7ab05089a25034b2023d959b47e59759cb38d88341b2459e89d6e5
+  languageName: node
+  linkType: hard
+
 "node-gyp-build@npm:^4.3.0":
   version: 4.6.0
   resolution: "node-gyp-build@npm:4.6.0"