Function executeTaskQueueHook

src/deploy/functions/release/lifecycle.ts:91–156

* Executes a taskQueue lifecycle hook by enqueuing a task in Cloud Tasks.

(
  taskHook: { function: string; body?: Record<string, unknown> },
  wantBackend: backend.Backend,
)

 * Executes a taskQueue lifecycle hook by enqueuing a task in Cloud Tasks.
 */
async function executeTaskQueueHook(
  taskHook: { function: string; body?: Record<string, unknown> },
  wantBackend: backend.Backend,
): Promise<void> {
  const targetEndpoint = findTargetEndpoint(wantBackend, taskHook.function);
  if (!targetEndpoint) {
    throw new FirebaseError(
      `Target endpoint "${taskHook.function}" not found in backend for lifecycle hook.`,
    );
  }

  if (!backend.isTaskQueueTriggered(targetEndpoint)) {
    throw new FirebaseError(`Target endpoint "${taskHook.function}" is not a task queue function.`);
  }

  const queueName = cloudtasks.queueNameForEndpoint(targetEndpoint);
  const bodyStr = taskHook.body ? JSON.stringify(taskHook.body) : "";
  const body = bodyStr ? Buffer.from(bodyStr).toString("base64") : undefined;

  const url = targetEndpoint.uri;
  if (!url) {
    throw new FirebaseError(`Target endpoint "${taskHook.function}" does not have a trigger URI.`);
  }

  const projectMetadata = await getProject(targetEndpoint.project);
  const projectNumber = projectMetadata.projectNumber;
  const sa =
    targetEndpoint.serviceAccount || (await computeEngine.getDefaultServiceAccount(projectNumber));

  const task: cloudtasks.Task = {
    httpRequest: {
      url,
      httpMethod: "POST",
      headers: {
        "Content-Type": "application/json",
      },
      oidcToken: {
        serviceAccountEmail: sa,
        audience: url,
      },
    },
  };
  if (body) {
    task.httpRequest.body = body;
  }

  try {
    await cloudtasks.enqueueTask(queueName, task);
    logLabeledSuccess(
      "functions",
      `Successfully queued task for lifecycle hook ${taskHook.function} in queue ${queueName}.`,
    );
    logLabeledBullet(
      "functions",
      `View logs for ${taskHook.function} at: ${getCloudConsoleLogUrl(targetEndpoint)}`,
    );
  } catch (err: unknown) {
    // We treat lifecycle hook failures as warnings. We don't want to fail