Respect CLI arguments and configuration when both provided

.changeset/fuzzy-eels-obey.md

@@ -0,0 +1,7 @@
+---
+'@graphql-hive/gateway': patch
+---
+
+Respect both registry token from CLI arguments and the configuration in the \`gateway.config\`
+
+User can provide the token in the CLI arguments, and have some registry configuration in \`gateway.config\`

.changeset/sixty-rice-give.md

@@ -0,0 +1,5 @@
+---
+'@graphql-hive/gateway-runtime': patch
+---
+
+`token` doesn't need to be required for Hive reporting in the configuration because it can be provided by the arguments

e2e/self-hosting-hive/gateway.config.ts

@@ -0,0 +1,28 @@
+import { defineConfig } from '@graphql-hive/gateway';
+import { boolEnv, Opts } from '@internal/testing';
+
+const opts = Opts(process.argv);
+const selfHostingHost = String(process.env['E2E_GATEWAY_RUNNER']).includes(
+  'docker',
+)
+  ? boolEnv('CI')
+    ? '172.17.0.1'
+    : 'host.docker.internal'
+  : 'localhost';
+const selfHostingPort = opts.getServicePort('selfHostingHive');
+
+export const gatewayConfig = defineConfig({
+  reporting: {
+    type: 'hive',
+    agent: {
+      maxRetries: 1,
+      maxSize: 1,
+      timeout: 200,
+    },
+    selfHosting: {
+      applicationUrl: `http://${selfHostingHost}:${selfHostingPort}`,
+      graphqlEndpoint: `http://${selfHostingHost}:${selfHostingPort}/graphql`,
+      usageEndpoint: `http://${selfHostingHost}:${selfHostingPort}/usage`,
+    },
+  },
+});

e2e/self-hosting-hive/package.json

@@ -0,0 +1,8 @@
+{
+  "name": "@e2e/self-hosting-hive",
+  "private": true,
+  "dependencies": {
+    "@graphql-hive/gateway": "workspace:*",
+    "graphql": "16.9.0"
+  }
+}

e2e/self-hosting-hive/self-hosting-hive.e2e.ts

@@ -0,0 +1,27 @@
+import { setTimeout } from 'node:timers/promises';
+import { createExampleSetup, createTenv } from '@internal/e2e';
+import { describe, expect, it } from 'vitest';
+
+describe('Self Hosting Hive', () => {
+  const TEST_TOKEN = 'my-token';
+  const { gateway, service } = createTenv(__dirname);
+  const { supergraph, query, result } = createExampleSetup(__dirname);
+  it('usage', async () => {
+    const selfHostingHive = await service('selfHostingHive');
+    await using gw = await gateway({
+      supergraph: await supergraph(),
+      services: [selfHostingHive],
+      args: [`--hive-registry-token=${TEST_TOKEN}`],
+    });
+    await expect(
+      gw.execute({
+        query,
+      }),
+    ).resolves.toEqual(result);
+    await setTimeout(300);
+    const incomingData = selfHostingHive.getStd('out');
+    // Check if `/usage` endpoint receives the POST request
+    expect(incomingData).toContain('POST /usage');
+    expect(incomingData).toContain(`"authorization":"Bearer ${TEST_TOKEN}"`);
+  });
+});

e2e/self-hosting-hive/services/selfHostingHive.ts

@@ -0,0 +1,27 @@
+import { createServer } from 'http';
+import { Opts } from '@internal/testing';
+
+const opts = Opts(process.argv);
+const selfHostingPort = opts.getServicePort('selfHostingHive');
+
+// Echo server
+
+createServer((req, res) => {
+  function echo(msg: string) {
+    process.stdout.write(msg);
+    res.write(msg);
+  }
+  res.writeHead(200, req.headers);
+  echo(`${req.method} ${req.url}\n`);
+  echo(`headers: ${JSON.stringify(req.headers)}\n`);
+  req.on('data', (chunk) => {
+    echo(chunk.toString('utf8'));
+  });
+  req.once('end', () => {
+    res.end();
+  });
+}).listen(selfHostingPort, () => {
+  process.stderr.write(
+    `Echo server listening on http://localhost:${selfHostingPort}\n`,
+  );
+});