..

.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

@@ -7,7 +7,6 @@ const selfHostingPort = opts.getServicePort('selfHostingHive');
 export const gatewayConfig = defineConfig({
   reporting: {
     type: 'hive',
-    token: 'secret',
     agent: {
       maxRetries: 1,
       maxSize: 1,

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

@@ -3,13 +3,15 @@ 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({
@@ -20,5 +22,6 @@ describe('Self Hosting Hive', () => {
     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

@@ -7,13 +7,17 @@ const selfHostingPort = opts.getServicePort('selfHostingHive');
 // Echo server
 
 createServer((req, res) => {
-  process.stdout.write(`${req.method} ${req.url}\n`);
+  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) => {
-    process.stdout.write(chunk);
-    res.write(chunk);
+    echo(chunk.toString('utf8'));
   });
-  req.on('end', () => {
+  req.once('end', () => {
     res.end();
   });
 }).listen(selfHostingPort, () => {

packages/gateway/src/commands/supergraph.ts

@@ -158,6 +158,7 @@ export const addCommand: AddCommand = (ctx, cli) =>
         ctx.log.info(`Configuring Hive registry reporting`);
         registryConfig = {
           reporting: {
+            ...loadedConfig.reporting,
             type: 'hive',
             token: hiveRegistryToken,
           },

packages/runtime/src/types.ts

@@ -185,8 +185,6 @@ export interface GatewayHiveCDNOptions {
 export interface GatewayHiveReportingOptions
   extends Omit<YamlConfig.HivePlugin, 'experimental__persistedDocuments'> {
   type: 'hive';
-  /** GraphQL Hive registry access token. */
-  token: string;
 }
 
 export interface GatewayGraphOSOptions {