Added support for calling Eventarc emulator (#1686)

apascal07 · web-flow · commit 2a76539fbcbd · 2022-05-04T12:39:00.000-07:00
diff --git a/src/eventarc/eventarc-client-internal.ts b/src/eventarc/eventarc-client-internal.ts
@@ -102,7 +102,7 @@ export class EventarcApiClient {
     }
     const request: HttpRequestConfig = {
       method: 'POST',
-      url: `${EVENTARC_API}/${channel}:publishEvents`,
+      url: `${this.getEventarcHost()}/${channel}:publishEvents`,
       data: JSON.stringify({ events }),
     };
     return this.sendRequest(request);
@@ -153,4 +153,8 @@ export class EventarcApiClient {
     const projectId = await this.getProjectId();
     return `projects/${projectId}/locations/${location}/channels/${channelId}`;
   }
+
+  private getEventarcHost(): string {
+    return process.env.CLOUD_EVENTARC_EMULATOR_HOST ?? EVENTARC_API;
+  }
 }

Original file line number	Diff line number	Diff line change
`@@ -102,7 +102,7 @@ export class EventarcApiClient {`
`102`	`102`	`}`
`103`	`103`	`const request: HttpRequestConfig = {`
`104`	`104`	`method: 'POST',`
`105`		- url: `${EVENTARC_API}/${channel}:publishEvents`,
	`105`	+ url: `${this.getEventarcHost()}/${channel}:publishEvents`,
`106`	`106`	`data: JSON.stringify({ events }),`
`107`	`107`	`};`
`108`	`108`	`return this.sendRequest(request);`
`@@ -153,4 +153,8 @@ export class EventarcApiClient {`
`153`	`153`	`const projectId = await this.getProjectId();`
`154`	`154`	return `projects/${projectId}/locations/${location}/channels/${channelId}`;
`155`	`155`	`}`
	`156`	`+`
	`157`	`+ private getEventarcHost(): string {`
	`158`	`+ return process.env.CLOUD_EVENTARC_EMULATOR_HOST ?? EVENTARC_API;`
	`159`	`+ }`
`156`	`160`	`}`