Hive Gateway Driver for NestJS

Author: ardatan

.changeset/sixty-camels-design.md

@@ -0,0 +1,7 @@
+---
+'@graphql-hive/nestjs': patch
+---
+
+Hive Gateway Driver for NestJS;
+
+[Learn more in the docs](https://the-guild.dev/graphql/hive/docs/gateway/deployment/node-frameworks/nestjs)

e2e/nestjs/nestjs.e2e.ts

@@ -0,0 +1,26 @@
+import { createExampleSetup, createTenv } from '@internal/e2e';
+import { getLocalhost } from '@internal/testing';
+import { fetch } from '@whatwg-node/fetch';
+import { expect, it } from 'vitest';
+
+const { service } = createTenv(__dirname);
+const { supergraph, query, result } = createExampleSetup(__dirname);
+
+it('executes the query', async () => {
+  const supergraphPath = await supergraph();
+  const { port } = await service('nestjs', {
+    args: [`--supergraph=${supergraphPath}`],
+  });
+  const hostname = await getLocalhost(port);
+  const response = await fetch(`${hostname}:${port}/graphql`, {
+    method: 'POST',
+    headers: {
+      'Content-Type': 'application/json',
+    },
+    body: JSON.stringify({
+      query,
+    }),
+  });
+  const received = await response.json();
+  expect(received).toEqual(result);
+});

e2e/nestjs/package.json

@@ -0,0 +1,15 @@
+{
+  "name": "@e2e/nestjs",
+  "version": "0.0.1",
+  "private": true,
+  "dependencies": {
+    "@graphql-hive/nestjs": "workspace:^",
+    "@nestjs/common": "^11.0.1",
+    "@nestjs/core": "^11.0.9",
+    "@nestjs/graphql": "^13.0.2",
+    "@nestjs/platform-express": "^11.0.9",
+    "graphql": "^16.10.0",
+    "reflect-metadata": "^0.2.2",
+    "rxjs": "^7.8.1"
+  }
+}

e2e/nestjs/services/nestjs.ts

@@ -0,0 +1,33 @@
+import {
+  HiveGatewayDriver,
+  HiveGatewayDriverConfig,
+} from '@graphql-hive/nestjs';
+import { Opts } from '@internal/testing';
+import { Module } from '@nestjs/common';
+import { NestFactory } from '@nestjs/core';
+import { GraphQLModule } from '@nestjs/graphql';
+
+const opts = Opts(process.argv);
+const supergraph = opts.get('supergraph', true);
+
+@Module({
+  imports: [
+    GraphQLModule.forRoot<HiveGatewayDriverConfig>({
+      driver: HiveGatewayDriver,
+      supergraph,
+    }),
+  ],
+})
+class AppModule {}
+
+const port = opts.getServicePort('nestjs', true);
+
+async function main() {
+  const app = await NestFactory.create(AppModule);
+  await app.listen(port);
+}
+
+main().catch((err) => {
+  console.error(err);
+  process.exit(1);
+});

internal/e2e/src/tenv.ts

@@ -691,6 +691,7 @@ export function createTenv(cwd: string): Tenv {
         pipeLogs = isDebug(),
         args = [],
         protocol = 'http',
+        env,
       } = {},
     ) {
       port ||= await getAvailablePort();
@@ -702,6 +703,7 @@ export function createTenv(cwd: string): Tenv {
           signal: ctrl.signal,
           stack: leftoverStack,
           replaceStderr: (str) => str.replaceAll(__project, ''),
+          env,
         },
         'node',
         '--import',