feat: add approve command

cli/src/commands/proposal/commands/update-status.ts

@@ -0,0 +1,59 @@
+import { EnumStatusCode } from '@wundergraph/cosmo-connect/dist/common/common_pb';
+import { Command, InvalidArgumentError } from 'commander';
+import pc from 'picocolors';
+import { getBaseHeaders } from '../../../core/config.js';
+import { BaseCommandOptions } from '../../../core/types/types.js';
+
+const proposalStatuses = ['APPROVED', 'CLOSED'] as const;
+type ProposalStatus = (typeof proposalStatuses)[number];
+
+const parseProposalStatus = (value: string): ProposalStatus => {
+  const status = value.toUpperCase();
+  if (!proposalStatuses.includes(status as ProposalStatus)) {
+    throw new InvalidArgumentError('Allowed values are approved and closed.');
+  }
+  return status as ProposalStatus;
+};
+
+export default (opts: BaseCommandOptions) => {
+  const command = new Command('update-status');
+  command.description('Updates the status of an existing proposal for a federated graph.');
+  command.argument('<name>', 'The name of the proposal to update.');
+  command.requiredOption(
+    '-f, --federation-graph <federatedGraphName>',
+    'The name of the federated graph this proposal is for.',
+  );
+  command.requiredOption(
+    '-s, --status <status>',
+    'The status to set. Allowed values: approved, closed.',
+    parseProposalStatus,
+  );
+  command.option('-n, --namespace [string]', 'The namespace of the federated graph.', 'default');
+
+  command.action(async (name, options) => {
+    const resp = await opts.client.platform.updateProposal(
+      {
+        proposalName: name,
+        federatedGraphName: options.federationGraph,
+        namespace: options.namespace,
+        updateAction: {
+          case: 'state',
+          value: options.status,
+        },
+      },
+      {
+        headers: getBaseHeaders(),
+      },
+    );
+
+    if (resp.response?.code === EnumStatusCode.OK) {
+      console.log(pc.green(`Proposal '${name}' status was updated to ${options.status} successfully.`));
+      return;
+    }
+
+    console.error(pc.red(resp.response?.details || `Failed to update status for proposal '${name}'.`));
+    process.exitCode = 1;
+  });
+
+  return command;
+};

cli/src/commands/proposal/index.ts

@@ -2,13 +2,15 @@ import { Command } from 'commander';
 import { BaseCommandOptions } from '../../core/types/types.js';
 import { checkAuth } from '../auth/utils.js';
 import CreateProposalCommand from './commands/create.js';
+import UpdateProposalStatusCommand from './commands/update-status.js';
 import UpdateProposalCommand from './commands/update.js';
 
 export default (opts: BaseCommandOptions) => {
   const command = new Command('proposal');
   command.description('Provides commands for creating and maintaining proposals for a federated graph');
   command.addCommand(CreateProposalCommand(opts));
   command.addCommand(UpdateProposalCommand(opts));
+  command.addCommand(UpdateProposalStatusCommand(opts));
 
   command.hook('preAction', async (thisCmd) => {
     await checkAuth();

cli/test/update-proposal-status.test.ts

@@ -0,0 +1,128 @@
+import { type MessageInitShape } from '@bufbuild/protobuf';
+import { createClient, createRouterTransport } from '@connectrpc/connect';
+import { EnumStatusCode } from '@wundergraph/cosmo-connect/dist/common/common_pb';
+import {
+  PlatformService,
+  type UpdateProposalRequest,
+  UpdateProposalResponseSchema,
+} from '@wundergraph/cosmo-connect/dist/platform/v1/platform_pb';
+import { Command } from 'commander';
+import { afterEach, beforeEach, describe, expect, test, vi, type MockInstance } from 'vitest';
+import UpdateProposalStatusCommand from '../src/commands/proposal/commands/update-status.js';
+import { Client } from '../src/core/client/client.js';
+
+function createMockTransport(
+  response: MessageInitShape<typeof UpdateProposalResponseSchema>,
+  onUpdateProposal?: (req: UpdateProposalRequest) => void,
+) {
+  return createRouterTransport(({ service }) => {
+    service(PlatformService, {
+      updateProposal: (req) => {
+        onUpdateProposal?.(req);
+        return response;
+      },
+    });
+  });
+}
+
+async function runUpdateStatus(
+  response: MessageInitShape<typeof UpdateProposalResponseSchema>,
+  args: string[] = [],
+  onUpdateProposal?: (req: UpdateProposalRequest) => void,
+): Promise<void> {
+  const client: Client = {
+    platform: createClient(PlatformService, createMockTransport(response, onUpdateProposal)),
+  };
+  const program = new Command();
+  program.exitOverride();
+  const command = UpdateProposalStatusCommand({ client });
+  command.exitOverride();
+  program.addCommand(command);
+  await program.parseAsync(
+    ['update-status', 'my-proposal', '--federation-graph', 'my-graph', '--status', 'approved', ...args],
+    { from: 'user' },
+  );
+}
+
+describe('update proposal status', () => {
+  let logSpy: MockInstance<typeof console.log>;
+  let errorSpy: MockInstance<typeof console.error>;
+
+  beforeEach(() => {
+    logSpy = vi.spyOn(console, 'log').mockImplementation(() => {});
+    errorSpy = vi.spyOn(console, 'error').mockImplementation(() => {});
+  });
+
+  afterEach(() => {
+    process.exitCode = undefined;
+    vi.restoreAllMocks();
+  });
+
+  test('approves a proposal in the default namespace', async () => {
+    let request: UpdateProposalRequest | undefined;
+
+    await runUpdateStatus({ response: { code: EnumStatusCode.OK } }, [], (req) => {
+      request = req;
+    });
+
+    expect(request).toMatchObject({
+      proposalName: 'my-proposal',
+      federatedGraphName: 'my-graph',
+      namespace: 'default',
+      updateAction: {
+        case: 'state',
+        value: 'APPROVED',
+      },
+    });
+    expect(logSpy).toHaveBeenCalledWith(
+      expect.stringContaining("Proposal 'my-proposal' status was updated to APPROVED successfully."),
+    );
+    expect(errorSpy).not.toHaveBeenCalled();
+    expect(process.exitCode).toBeUndefined();
+  });
+
+  test('closes a proposal in an explicitly provided namespace', async () => {
+    let request: UpdateProposalRequest | undefined;
+
+    await runUpdateStatus(
+      { response: { code: EnumStatusCode.OK } },
+      ['--status', 'CLOSED', '--namespace', 'production'],
+      (req) => {
+        request = req;
+      },
+    );
+
+    expect(request).toMatchObject({
+      namespace: 'production',
+      updateAction: {
+        case: 'state',
+        value: 'CLOSED',
+      },
+    });
+  });
+
+  test('rejects statuses that cannot be set manually', async () => {
+    let updateCalled = false;
+
+    await expect(
+      runUpdateStatus({ response: { code: EnumStatusCode.OK } }, ['--status', 'published'], () => {
+        updateCalled = true;
+      }),
+    ).rejects.toThrow('Allowed values are approved and closed.');
+
+    expect(updateCalled).toBe(false);
+  });
+
+  test('prints the control-plane error and sets a non-zero exit code', async () => {
+    await runUpdateStatus({
+      response: {
+        code: EnumStatusCode.ERR_NOT_FOUND,
+        details: 'Proposal my-proposal not found',
+      },
+    });
+
+    expect(errorSpy).toHaveBeenCalledWith(expect.stringContaining('Proposal my-proposal not found'));
+    expect(logSpy).not.toHaveBeenCalled();
+    expect(process.exitCode).toBe(1);
+  });
+});

docs-website/cli/proposal.mdx

@@ -14,3 +14,7 @@ The `proposal` command and its subcommands provide functionality to manage propo
 <Card title="Update a proposal" href="/cli/proposal/update" icon="pencil">
   Update an existing proposal for a federated graph
 </Card>
+
+<Card title="Update a proposal status" href="/cli/proposal/update-status" icon="arrows-rotate">
+  Approve or close an existing proposal from a local or CI environment
+</Card>

docs-website/cli/proposal/update-status.mdx

@@ -0,0 +1,52 @@
+---
+title: "Update Status"
+description: "Updates the status of an existing proposal for a federated graph."
+icon: arrows-rotate
+---
+
+## Usage
+
+```bash
+npx wgc proposal update-status <name> --federation-graph <federated-graph-name> --status <status> [options]
+```
+
+## Description
+
+The `npx wgc proposal update-status` command updates an existing proposal's review status. The command is non-interactive, which makes it suitable for CI workflows.
+
+The API key used by the command must have write access to the federated graph.
+
+## **Parameters**
+
+- `[name]`: The name of the proposal to update.
+
+## **Options**
+
+- `-f, --federation-graph <federatedGraphName>` (required): The name of the federated graph this proposal is for.
+- `-s, --status <status>` (required): The status to set. Accepted values are `approved` and `closed`. Values are case-insensitive.
+- `-n, --namespace [namespace]`: The namespace of the federated graph (Default: `default`).
+
+## **CI examples**
+
+Configure an API key as a secret in your CI system and expose it as `COSMO_API_KEY` before running the command.
+
+Approve a proposal:
+
+```bash
+export COSMO_API_KEY=<API_KEY>
+npx wgc proposal update-status product-changes \
+  --federation-graph my-graph \
+  --namespace production \
+  --status approved
+```
+
+Close a proposal:
+
+```bash
+npx wgc proposal update-status product-changes \
+  --federation-graph my-graph \
+  --namespace production \
+  --status closed
+```
+
+The command exits with a non-zero status when the proposal status cannot be updated, allowing the CI job to fail immediately.

docs-website/concepts/proposals.mdx

@@ -72,6 +72,14 @@ npx wgc proposal update <name> --federation-graph <federated-graph-name> (--subg
 
 **Note**: When updating a proposal, any subgraphs you specify will completely replace the corresponding subgraphs in the existing proposal. The update is not incremental.
 
+### Updating a Proposal Status
+
+Use the [`wgc proposal update-status`](/cli/proposal/update-status) command to approve or close an existing proposal. The command is non-interactive and can be used in CI with a `COSMO_API_KEY` that has write access to the federated graph:
+
+```bash
+npx wgc proposal update-status <name> --federation-graph <federated-graph-name> --status <approved|closed> [--namespace <namespace>]
+```
+
 ## Configuring Proposals
 
 <Frame>

docs-website/docs.json

@@ -672,7 +672,7 @@
               {
                 "group": "Proposal",
                 "icon": "file-circle-plus",
-                "pages": ["cli/proposal", "cli/proposal/create", "cli/proposal/update"]
+                "pages": ["cli/proposal", "cli/proposal/create", "cli/proposal/update", "cli/proposal/update-status"]
               }
             ]
           }