Revert "Fix issue with mixed v1 and v2 functions deployments (#6293)" (#6295)

blidd-google · web-flow · commit d2cd8e305d0a · 2023-08-24T11:27:52.000-07:00
This reverts commit d44e236.
diff --git a/src/deploy/functions/release/fabricator.ts b/src/deploy/functions/release/fabricator.ts
@@ -130,22 +130,17 @@ export class Fabricator {
     };
 
     const upserts: Array<Promise<void>> = [];
-    const scraperV1 = new SourceTokenScraper();
-    const scraperV2 = new SourceTokenScraper();
+    const scraper = new SourceTokenScraper();
     for (const endpoint of changes.endpointsToCreate) {
       this.logOpStart("creating", endpoint);
-      upserts.push(
-        handle("create", endpoint, () => this.createEndpoint(endpoint, scraperV1, scraperV2))
-      );
+      upserts.push(handle("create", endpoint, () => this.createEndpoint(endpoint, scraper)));
     }
     for (const endpoint of changes.endpointsToSkip) {
       utils.logSuccess(this.getLogSuccessMessage("skip", endpoint));
     }
     for (const update of changes.endpointsToUpdate) {
       this.logOpStart("updating", update.endpoint);
-      upserts.push(
-        handle("update", update.endpoint, () => this.updateEndpoint(update, scraperV1, scraperV2))
-      );
+      upserts.push(handle("update", update.endpoint, () => this.updateEndpoint(update, scraper)));
     }
     await utils.allSettled(upserts);
 
@@ -172,39 +167,31 @@ export class Fabricator {
     return deployResults;
   }
 
-  async createEndpoint(
-    endpoint: backend.Endpoint,
-    scraperV1: SourceTokenScraper,
-    scraperV2: SourceTokenScraper
-  ): Promise<void> {
+  async createEndpoint(endpoint: backend.Endpoint, scraper: SourceTokenScraper): Promise<void> {
     endpoint.labels = { ...endpoint.labels, ...deploymentTool.labels() };
     if (endpoint.platform === "gcfv1") {
-      await this.createV1Function(endpoint, scraperV1);
+      await this.createV1Function(endpoint, scraper);
     } else if (endpoint.platform === "gcfv2") {
-      await this.createV2Function(endpoint, scraperV2);
+      await this.createV2Function(endpoint, scraper);
     } else {
       assertExhaustive(endpoint.platform);
     }
 
     await this.setTrigger(endpoint);
   }
 
-  async updateEndpoint(
-    update: planner.EndpointUpdate,
-    scraperV1: SourceTokenScraper,
-    scraperV2: SourceTokenScraper
-  ): Promise<void> {
+  async updateEndpoint(update: planner.EndpointUpdate, scraper: SourceTokenScraper): Promise<void> {
     update.endpoint.labels = { ...update.endpoint.labels, ...deploymentTool.labels() };
     if (update.deleteAndRecreate) {
       await this.deleteEndpoint(update.deleteAndRecreate);
-      await this.createEndpoint(update.endpoint, scraperV1, scraperV2);
+      await this.createEndpoint(update.endpoint, scraper);
       return;
     }
 
     if (update.endpoint.platform === "gcfv1") {
-      await this.updateV1Function(update.endpoint, scraperV1);
+      await this.updateV1Function(update.endpoint, scraper);
     } else if (update.endpoint.platform === "gcfv2") {
-      await this.updateV2Function(update.endpoint, scraperV2);
+      await this.updateV2Function(update.endpoint, scraper);
     } else {
       assertExhaustive(update.endpoint.platform);
     }
diff --git a/src/test/deploy/functions/release/fabricator.spec.ts b/src/test/deploy/functions/release/fabricator.spec.ts
@@ -1216,11 +1216,7 @@ describe("Fabricator", () => {
       const createV1Function = sinon.stub(fab, "createV1Function");
       createV1Function.resolves();
 
-      await fab.createEndpoint(
-        ep,
-        new scraper.SourceTokenScraper(),
-        new scraper.SourceTokenScraper()
-      );
+      await fab.createEndpoint(ep, new scraper.SourceTokenScraper());
       expect(createV1Function).is.calledOnce;
       expect(setTrigger).is.calledOnce;
       expect(setTrigger).is.calledAfter(createV1Function);
@@ -1233,11 +1229,7 @@ describe("Fabricator", () => {
       const createV2Function = sinon.stub(fab, "createV2Function");
       createV2Function.resolves();
 
-      await fab.createEndpoint(
-        ep,
-        new scraper.SourceTokenScraper(),
-        new scraper.SourceTokenScraper()
-      );
+      await fab.createEndpoint(ep, new scraper.SourceTokenScraper());
       expect(createV2Function).is.calledOnce;
       expect(setTrigger).is.calledOnce;
       expect(setTrigger).is.calledAfter(createV2Function);
@@ -1249,9 +1241,10 @@ describe("Fabricator", () => {
       const createV1Function = sinon.stub(fab, "createV1Function");
       createV1Function.rejects(new reporter.DeploymentError(ep, "set invoker", undefined));
 
-      await expect(
-        fab.createEndpoint(ep, new scraper.SourceTokenScraper(), new scraper.SourceTokenScraper())
-      ).to.be.rejectedWith(reporter.DeploymentError, "set invoker");
+      await expect(fab.createEndpoint(ep, new scraper.SourceTokenScraper())).to.be.rejectedWith(
+        reporter.DeploymentError,
+        "set invoker"
+      );
       expect(createV1Function).is.calledOnce;
       expect(setTrigger).is.not.called;
     });
@@ -1265,11 +1258,7 @@ describe("Fabricator", () => {
       const updateV1Function = sinon.stub(fab, "updateV1Function");
       updateV1Function.resolves();
 
-      await fab.updateEndpoint(
-        { endpoint: ep },
-        new scraper.SourceTokenScraper(),
-        new scraper.SourceTokenScraper()
-      );
+      await fab.updateEndpoint({ endpoint: ep }, new scraper.SourceTokenScraper());
       expect(updateV1Function).is.calledOnce;
       expect(setTrigger).is.calledOnce;
       expect(setTrigger).is.calledAfter(updateV1Function);
@@ -1282,11 +1271,7 @@ describe("Fabricator", () => {
       const updateV2Function = sinon.stub(fab, "updateV2Function");
       updateV2Function.resolves();
 
-      await fab.updateEndpoint(
-        { endpoint: ep },
-        new scraper.SourceTokenScraper(),
-        new scraper.SourceTokenScraper()
-      );
+      await fab.updateEndpoint({ endpoint: ep }, new scraper.SourceTokenScraper());
       expect(updateV2Function).is.calledOnce;
       expect(setTrigger).is.calledOnce;
       expect(setTrigger).is.calledAfter(updateV2Function);
@@ -1299,11 +1284,7 @@ describe("Fabricator", () => {
       updateV1Function.rejects(new reporter.DeploymentError(ep, "set invoker", undefined));
 
       await expect(
-        fab.updateEndpoint(
-          { endpoint: ep },
-          new scraper.SourceTokenScraper(),
-          new scraper.SourceTokenScraper()
-        )
+        fab.updateEndpoint({ endpoint: ep }, new scraper.SourceTokenScraper())
       ).to.be.rejectedWith(reporter.DeploymentError, "set invoker");
       expect(updateV1Function).is.calledOnce;
       expect(setTrigger).is.not.called;
@@ -1332,11 +1313,7 @@ describe("Fabricator", () => {
       const createV2Function = sinon.stub(fab, "createV2Function");
       createV2Function.resolves();
 
-      await fab.updateEndpoint(
-        update,
-        new scraper.SourceTokenScraper(),
-        new scraper.SourceTokenScraper()
-      );
+      await fab.updateEndpoint(update, new scraper.SourceTokenScraper());
 
       expect(deleteTrigger).to.have.been.called;
       expect(deleteV1Function).to.have.been.calledImmediatelyAfter(deleteTrigger);
