feat: add service info cli (#187)

sam-goodwin · Jan 3, 2023 · f613910 · f613910
1 parent 82d5d37
commit f613910
Show file tree

Hide file tree

Showing 5 changed files with 53 additions and 7 deletions.
diff --git a/packages/@eventual/aws-cdk/src/service.ts b/packages/@eventual/aws-cdk/src/service.ts
@@ -204,6 +204,7 @@ export class Service extends Construct implements IGrantable {
       parameterName: `/eventual/services/${this.serviceName}`,
       stringValue: JSON.stringify({
         apiEndpoint: this.api.gateway.apiEndpoint,
+        eventBusArn: this.events.bus.eventBusArn,
         functions: {
           orchestrator: this.workflows.orchestrator.functionName,
           activityWorker: this.activities.worker.functionName,

diff --git a/packages/@eventual/cli/src/cli.ts b/packages/@eventual/cli/src/cli.ts
@@ -12,6 +12,7 @@ import { sendSignal } from "./commands/send-signal.js";
 import { execution } from "./commands/execution.js";
 import { publishEvents } from "./commands/publish-events.js";
 import { configure } from "./commands/configure.js";
+import { serviceInfo } from "./commands/service-info.js";
 
 const argv = hideBin(process.argv);
 const cli = yargs(argv).scriptName("eventual").strict();
@@ -24,6 +25,7 @@ const cli = yargs(argv).scriptName("eventual").strict();
   publishEvents,
   replay,
   sendSignal,
+  serviceInfo,
   services,
   start,
   timeline,

diff --git a/packages/@eventual/cli/src/commands/service-info.ts b/packages/@eventual/cli/src/commands/service-info.ts
@@ -0,0 +1,30 @@
+import { Argv } from "yargs";
+import { serviceAction, setServiceOptions } from "../service-action.js";
+
+export const serviceInfo = (yargs: Argv) =>
+  yargs.command(
+    "info",
+    "Get data about your service",
+    (yargs) => setServiceOptions(yargs, true),
+    serviceAction(
+      async (spinner, _service, _, serviceData) => {
+        spinner.start("Getting executions");
+        spinner.stop();
+        process.stdout.write(
+          [
+            `API Gateway: ${serviceData.apiEndpoint}`,
+            `Event Bus Arn: ${serviceData.eventBusArn}`,
+          ].join("\n")
+        );
+        process.stdout.write("\n");
+      },
+      async (_service, _, serviceData) => {
+        process.stdout.write(
+          JSON.stringify({
+            apiEndpoint: serviceData.apiEndpoint,
+            eventBusArn: serviceData.eventBusArn,
+          }) + "\n"
+        );
+      }
+    )
+  );
diff --git a/packages/@eventual/cli/src/service-action.ts b/packages/@eventual/cli/src/service-action.ts
@@ -8,18 +8,21 @@ import { assumeCliRole } from "./role.js";
 import {
   getServiceData,
   resolveRegion,
+  ServiceData,
   tryResolveDefaultService,
 } from "./service-data.js";
 
 export type ServiceAction<T> = (
   spinner: Ora,
   serviceClient: EventualServiceClient,
-  args: Arguments<T & { service: string }>
+  args: Arguments<T & { service: string }>,
+  serviceData: ServiceData
 ) => Promise<void>;
 
 export type ServiceJsonAction<T> = (
   serviceClient: EventualServiceClient,
-  args: Arguments<T & { service: string }>
+  args: Arguments<T & { service: string }>,
+  serviceData: ServiceData
 ) => Promise<void>;
 
 /**
@@ -52,12 +55,21 @@ export const serviceAction =
         if (!jsonAction) {
           throw new Error("Operation does not support --json.");
         }
-        return jsonAction(serviceClient, { ...args, service: serviceName });
+        return jsonAction(
+          serviceClient,
+          { ...args, service: serviceName },
+          serviceData
+        );
       }
-      return await action(spinner, serviceClient, {
-        ...args,
-        service: serviceName,
-      });
+      return await action(
+        spinner,
+        serviceClient,
+        {
+          ...args,
+          service: serviceName,
+        },
+        serviceData
+      );
     } catch (e: any) {
       if (args.debug) {
         styledConsole.error(util.inspect(e));

diff --git a/packages/@eventual/cli/src/service-data.ts b/packages/@eventual/cli/src/service-data.ts
@@ -14,6 +14,7 @@ import { styledConsole } from "./styled-console.js";
  */
 export interface ServiceData {
   apiEndpoint: string;
+  eventBusArn: string;
   functions: {
     orchestrator: string;
     activityWorker: string;