replace graphql datasource with apollo client (#160)

* replace graphql datasource with apollo client

* add network mocking capabilities

* add more mocks

* Prevent accidental creation of multiple output channels

* add test for "wrong token" scenario

* changeset

* fix js types

* get one piece of real data into the mocks

* avoid `this.client.client.query`

* split mock server into functions

.changeset/dull-singers-melt.md

@@ -0,0 +1,5 @@
+---
+"vscode-apollo": patch
+---
+
+Replace `graphql-datasource` usage with `@apollo/client`

.changeset/warm-mayflies-nail.md

@@ -0,0 +1,5 @@
+---
+"vscode-apollo": patch
+---
+
+Prevent accidental creation of multiple output channels

.vscode/launch.json

@@ -14,6 +14,7 @@
         "${workspaceFolder}/sampleWorkspace/sampleWorkspace.code-workspace"
       ],
       "sourceMaps": true,
+      "env": { "APOLLO_ENGINE_ENDPOINT": "http://localhost:7096/apollo" },
       "outFiles": ["${workspaceRoot}/lib/**/*.js"]
     },
     {
@@ -36,7 +37,8 @@
         "${workspaceFolder}/sampleWorkspace/sampleWorkspace.code-workspace"
       ],
       "outFiles": ["${workspaceFolder}/lib/**/*.js"],
-      "preLaunchTask": "BuildAndStartWorkspace"
+      "preLaunchTask": "BuildAndStartWorkspace",
+      "env": { "APOLLO_ENGINE_ENDPOINT": "http://localhost:7096/apollo" }
     },
     {
       "name": "Attach to Test Debugger",

package.json

@@ -18,7 +18,7 @@
     "build": "tsc --build tsconfig.build.json",
     "build:clean": "npm run build -- --clean",
     "watch": "npm run build -- --watch",
-    "sampleWorkspace:run": "node sampleWorkspace/httpSchemaServer/server.mjs",
+    "sampleWorkspace:run": "node src/__e2e__/mockServer.js",
     "changeset-version": "changeset version && npm i",
     "changeset-publish": "npm run build && changeset publish",
     "typecheck": "tsc --noEmit",
@@ -38,7 +38,6 @@
     "@types/lz-string": "^1.3.34",
     "@types/node-fetch": "2.6.11",
     "@wry/equality": "^0.5.7",
-    "apollo-datasource": "^0.8.0",
     "await-to-js": "^3.0.0",
     "cosmiconfig": "^9.0.0",
     "dotenv": "^16.0.0",
@@ -75,9 +74,11 @@
     "@typescript-eslint/parser": "6.9.1",
     "@vscode/test-cli": "^0.0.10",
     "@vscode/test-electron": "^2.4.1",
+    "@wry/trie": "^0.5.0",
     "eslint": "8.52.0",
     "eslint-config-prettier": "9.0.0",
     "eslint-plugin-prettier": "5.0.1",
+    "graphql-http": "^1.22.1",
     "jest": "29.7.0",
     "jest-environment-node": "29.7.0",
     "memfs": "3.2.2",

src/__e2e__/mockServer.js

@@ -0,0 +1,117 @@
+// @ts-check
+const http = require("http");
+const {
+  parseRequestParams,
+  createHandler,
+} = require("graphql-http/lib/use/http");
+const { buildSchema } = require("graphql");
+const { Trie } = require("@wry/trie");
+
+function runMockServer(
+  /** @type {number}  */ port,
+  onStart = (/** @type {number}  */ port) => {},
+) {
+  const mocks = new Trie(false);
+
+  const server = http.createServer(async (req, res) => {
+    if (req.url === "/apollo") {
+      if (req.method === "POST") {
+        await handleApolloPost(req, res);
+      } else if (req.method === "PUT") {
+        await handleApolloPut(req, res);
+      }
+    } else if (req.url === "/graphql") {
+      schemaHandler(req, res);
+    } else {
+      res.writeHead(404).end();
+    }
+  });
+
+  server.on("error", (err) => {
+    console.log("Failed to start server", err);
+  });
+
+  console.log("Starting server...");
+  server.listen(port);
+  onStart(port);
+  console.log(`Server ready at: http://localhost:${port}`);
+  return {
+    [Symbol.dispose]() {
+      console.log("Closing server...");
+      server.close();
+      console.log("Server closed");
+    },
+  };
+
+  /**
+   * Mock GraphQL Endpoint Handler
+   * @param {http.IncomingMessage} req
+   * @param {http.ServerResponse} res
+   */
+  async function handleApolloPost(req, res) {
+    const { operationName, variables } =
+      /** @type{import("graphql-http/lib/common").RequestParams} */ (
+        await parseRequestParams(req, res)
+      );
+
+    const mock = mocks.peek(operationName, JSON.stringify(variables));
+    if (mock) {
+      res.writeHead(200, { "Content-Type": "application/json" });
+      res.end(JSON.stringify(mock.response));
+    } else {
+      console.warn("No mock available for %o", {
+        operationName,
+        variables,
+      });
+      res.writeHead(200).end(
+        JSON.stringify({
+          data: null,
+          errors: [
+            {
+              message: "No mock found.",
+              extensions: { operationName, variables },
+            },
+          ],
+        }),
+      );
+    }
+  }
+
+  /**
+   * Handler to accept new GraphQL Mocks
+   * @param {http.IncomingMessage} req
+   * @param {http.ServerResponse} res
+   */
+  async function handleApolloPut(req, res) {
+    const body = await new Promise((resolve) => {
+      let body = "";
+      req.setEncoding("utf-8");
+      req.on("data", (chunk) => (body += chunk));
+      req.on("end", () => resolve(body));
+    });
+    const { operationName, variables, response } = JSON.parse(body);
+    mocks.lookup(operationName, JSON.stringify(variables)).response = response;
+    //console.info("mock loaded", { operationName, variables });
+    res.end();
+  }
+}
+
+const schema = buildSchema(`#graphql
+  type Book {
+    title: String
+    author: String
+  }
+
+  type Query {
+    books: [Book]
+  }
+`);
+const schemaHandler = createHandler({
+  schema,
+});
+
+if (require.main === module) {
+  runMockServer(7096, require("./mocks.js").loadDefaultMocks);
+}
+
+module.exports.runMockServer = runMockServer;