Switch to cascading deletes (#8266)

* Switch to cascading deletes

* Fix test and add changelog

* formats

Author: joehan

CHANGELOG.md

@@ -2,6 +2,7 @@
 - Added initial delay when loading python functions (#8239)
 - Enforced webframeworks enablement only on webframeworks sites (#8168)
 - Fixed issue where `apps:init` throws an error upon app creation.
+- Reenabled prompts for unused service deletion in `deploy --only`.
 - Update Firebase Data Connect local toolkit to v1.8.3, which includes the following changes: (#8263)
   - Adds a `_metadata.distance` field to vector similarity search results
   - Fixes `auth` and `request.auth` when the request is unauthenticated

scripts/dataconnect-test/tests.ts

@@ -32,9 +32,7 @@ function expected(
 }
 
 async function cleanUpService(projectId: string, serviceId: string, databaseId: string) {
-  await client.deleteServiceAndChildResources(
-    `projects/${projectId}/locations/us-central1/services/${serviceId}`,
-  );
+  await client.deleteService(`projects/${projectId}/locations/us-central1/services/${serviceId}`);
   await deleteDatabase(projectId, "dataconnect-test", databaseId);
 }
 

src/dataconnect/client.spec.ts

@@ -61,9 +61,11 @@ export async function createService(
   return pollRes;
 }
 
-async function deleteService(serviceName: string): Promise<types.Service> {
-  // NOTE(fredzqm): Don't force delete yet. Backend would leave orphaned resources.
-  const op = await dataconnectClient().delete<types.Service>(serviceName);
+export async function deleteService(serviceName: string): Promise<types.Service> {
+  // Note that we need to force delete in order to delete child resources too.
+  const op = await dataconnectClient().delete<types.Service>(serviceName, {
+    queryParams: { force: "true" },
+  });
   const pollRes = await operationPoller.pollOperation<types.Service>({
     apiOrigin: dataconnectOrigin(),
     apiVersion: DATACONNECT_API_VERSION,
@@ -72,19 +74,6 @@ async function deleteService(serviceName: string): Promise<types.Service> {
   return pollRes;
 }
 
-export async function deleteServiceAndChildResources(serviceName: string): Promise<void> {
-  const connectors = await listConnectors(serviceName);
-  await Promise.all(connectors.map(async (c) => deleteConnector(c.name)));
-  try {
-    await deleteSchema(serviceName);
-  } catch (err: any) {
-    if (err.status !== 404) {
-      throw err;
-    }
-  }
-  await deleteService(serviceName);
-}
-
 /** Schema methods */
 
 export async function getSchema(serviceName: string): Promise<types.Schema | undefined> {

src/dataconnect/client.ts

@@ -487,7 +487,7 @@ async function promptForInvalidConnectorError(
     !options.nonInteractive &&
     (await confirm({
       ...options,
-      message: `Would you like to delete and recreate these connectors? This will cause ${clc.red(`downtime.`)}.`,
+      message: `Would you like to delete and recreate these connectors? This will cause ${clc.red(`downtime`)}.`,
     }))
   ) {
     return true;

src/dataconnect/schemaMigration.ts

@@ -9,6 +9,7 @@ import { ResourceFilter } from "../../dataconnect/filters";
 import { vertexAIOrigin } from "../../api";
 import * as ensureApiEnabled from "../../ensureApiEnabled";
 import { join } from "node:path";
+import { confirm } from "../../prompt";
 
 /**
  * Checks for and creates a Firebase DataConnect service, if needed.
@@ -56,28 +57,22 @@ export default async function (
   );
 
   if (servicesToDelete.length) {
-    const warning = `The following services exist on ${projectId} but are not listed in your 'firebase.json'\n${servicesToDelete
-      .map((s) => s.name)
-      .join("\n")}\nConsider deleting these via the Firebase console if they are no longer needed.`;
-    utils.logLabeledWarning("dataconnect", warning);
-    // TODO: Switch this back to prompting for deletion.
-    // if (
-    //   await confirm({
-    //     force: options.force,
-    //     nonInteractive: options.nonInteractive,
-    //     message: `The following services exist on ${projectId} but are not listed in your 'firebase.json'\n${servicesToDelete
-    //       .map((s) => s.name)
-    //       .join("\n")}\nWould you like to delete these services?`,
-    //   })
-    // ) {
-    //   await Promise.all(
-    //     servicesToDelete.map(async (s) => {
-    //       const { projectId, locationId, serviceId } = splitName(s.name);
-    //       await client.deleteService(projectId, locationId, serviceId);
-    //       utils.logLabeledSuccess("dataconnect", `Deleted service ${s.name}`);
-    //     }),
-    //   );
-    // }
+    if (
+      await confirm({
+        force: options.force,
+        nonInteractive: options.nonInteractive,
+        message: `The following services exist on ${projectId} but are not listed in your 'firebase.json'\n${servicesToDelete
+          .map((s) => s.name)
+          .join("\n")}\nWould you like to delete these services?`,
+      })
+    ) {
+      await Promise.all(
+        servicesToDelete.map(async (s) => {
+          await client.deleteService(s.name);
+          utils.logLabeledSuccess("dataconnect", `Deleted service ${s.name}`);
+        }),
+      );
+    }
   }
 
   // Provision CloudSQL resources