fix(test/integration): fix broken integration test

scripts/dataconnect-test/templates/connector.yaml

@@ -1,2 +1,2 @@
-connectorId: "connectorId"
+connectorId: "1"
 authMode: "PUBLIC"

scripts/dataconnect-test/tests.ts

@@ -11,7 +11,7 @@
 const FIREBASE_PROJECT = process.env.FBTOOLS_TARGET_PROJECT || "";
 const FIREBASE_DEBUG = process.env.FIREBASE_DEBUG || "";
 
 function expected(
   serviceId: string,
   databaseId: string,
   schemaUpdateTime: string,
@@ -24,21 +24,21 @@
     schemaUpdateTime,
     connectors: [
       {
-        connectorId: "connectorId",
+        connectorId: "1",
         connectorLastUpdated,
       },
     ],
   };
 }
 
 async function cleanUpService(projectId: string, serviceId: string, databaseId: string) {
   await client.deleteServiceAndChildResources(
     `projects/${projectId}/locations/us-central1/services/${serviceId}`,
   );
   await deleteDatabase(projectId, "dataconnect-test", databaseId);
 }
 
 async function list() {
   return await cli.exec(
     "dataconnect:services:list",
     FIREBASE_PROJECT,
@@ -51,7 +51,7 @@
   );
 }
 
 async function migrate(force: boolean) {
   const args = force ? ["--force"] : [];
   if (FIREBASE_DEBUG) {
     args.push("--debug");
@@ -68,7 +68,7 @@
   );
 }
 
 async function deploy(force: boolean) {
   const args = ["--only", "dataconnect"];
   if (force) {
     args.push("--force");
@@ -81,7 +81,7 @@
   });
 }
 
 function toPath(p: string) {
   return path.join(__dirname, p);
 }
 
@@ -124,7 +124,7 @@
   return { serviceId, databaseId };
 }
 
 function prepareStep(step: Step) {
   fs.writeFileSync(toPath("fdc-test/schema/schema.gql"), step.schemaGQL, { mode: 420 /* 0o644 */ });
   fs.writeFileSync(toPath("fdc-test/connector/connector.gql"), step.connectorGQL, {
     mode: 420 /* 0o644 */,
@@ -145,7 +145,7 @@
   });
 
   afterEach(async function (this) {
-    this.timeout(10000);
+    this.timeout(100000); // Need to wait a long time for cleanup.
     fs.rmSync(fdcTest, { recursive: true, force: true });
     await cleanUpService(FIREBASE_PROJECT, serviceId, databaseId);
   });
@@ -158,8 +158,8 @@
           await deploy(false);
           await migrate(true);
           await deploy(true);
         } catch (err: any) {
           expect(err.expectErr, `Unexpected error: ${err.message}`).to.be.true;
         }
         expect(step.expectErr).to.be.false;
         const result = await list();