[AI Improvement] [Task] Remove dead EmulatedTrigger and waitForBody cluster from functionsEmulatorShared.ts

src/emulator/functionsEmulatorShared.ts

@@ -2,14 +2,10 @@
 import * as path from "path";
 import * as fs from "fs";
 import { randomBytes } from "crypto";
-import * as _ from "lodash";
-import * as express from "express";
-import { CloudFunction } from "firebase-functions";
-
 import * as backend from "../deploy/functions/backend";
 import * as build from "../deploy/functions/build";
 import { Constants } from "./constants";
-import { BackendInfo, EmulatableBackend, InvokeRuntimeOpts } from "./functionsEmulator";
+import { BackendInfo, EmulatableBackend } from "./functionsEmulator";
 import { ENV_DIRECTORY } from "../extensions/manifest";
 import { substituteParams } from "../extensions/extensionsHelper";
 import { ExtensionSpec, ExtensionVersion } from "../extensions/types";
@@ -68,12 +64,12 @@
   timeoutSeconds?: number;
   regions?: string[];
   availableMemoryMb?: backend.MemoryOptions;
   httpsTrigger?: any;
   eventTrigger?: EventTrigger;
   taskQueueTrigger?: backend.TaskQueueTrigger;
   schedule?: EventSchedule;
   blockingTrigger?: BlockingTrigger;
   labels?: { [key: string]: any };
   codebase?: string;
 }
 
@@ -103,17 +99,8 @@
   service?: string;
 }
 
-export interface EmulatedTriggerMap {
-  [name: string]: EmulatedTrigger;
-}
-
-export interface FunctionsRuntimeArgs {
-  frb: FunctionsRuntimeBundle;
-  opts?: InvokeRuntimeOpts;
-}
-
 export interface FunctionsRuntimeBundle {
   proto: any;
   disabled_features?: FunctionsRuntimeFeatures;
   // TODO(danielylee): To make debugging in Functions Emulator w/ --inspect-functions flag a good experience, we run
   // all functions in a single runtime process. This is drastically different to production environment where each
@@ -131,35 +118,6 @@
   timeout?: boolean;
 }
 
-export class EmulatedTrigger {
-  /*
-  Here we create a trigger from a single definition (data about what resources does this trigger on, etc) and
-  the actual module which contains multiple functions / definitions. We locate the one we need below using
-  definition.entryPoint
-   */
-  constructor(
-    public definition: EmulatedTriggerDefinition,
-    private module: any,
-  ) {}
-
-  get memoryLimitBytes(): number {
-    return (this.definition.availableMemoryMb || 128) * 1024 * 1024;
-  }
-
-  get timeoutMs(): number {
-    return (this.definition.timeoutSeconds || 60) * 1000;
-  }
-
-  getRawFunction(): CloudFunction<any> {
-    if (!this.module) {
-      throw new Error("EmulatedTrigger has not been provided a module.");
-    }
-
-    const func = _.get(this.module, this.definition.entryPoint);
-    return func.__emulator_func || func;
-  }
-}
-
 /**
  * Checks if the v2 event service has been implemented in the emulator
  */
@@ -170,17 +128,17 @@
 /**
  * Validates that triggers are correctly formed and fills in some defaults.
  */
 export function prepareEndpoints(endpoints: backend.Endpoint[]) {
   const bkend = backend.of(...endpoints);
   for (const ep of endpoints) {
     serviceForEndpoint(ep).validateTrigger(ep as any, bkend);
   }
   inferBlockingDetails(bkend);
 }
 
 /**
  * Creates a unique trigger definition from Endpoints.
  * @param Endpoints A list of all CloudFunctions in the deployment.
  * @return A list of all CloudFunctions in the deployment.
  */
 export function emulatedFunctionsFromEndpoints(
@@ -234,7 +192,7 @@
       if (endpoint.platform === "gcfv1") {
         def.eventTrigger = {
           eventType: eventTrigger.eventType,
           resource: eventTrigger.eventFilters!.resource,
         };
       } else {
         // v2 events implemented are pubsub, storage, rtdb, firestore, alerts, auth, and custom events
@@ -243,7 +201,7 @@
         }
 
         // We use resource for pubsub & storage
         const { resource, topic, bucket } = endpoint.eventTrigger.eventFilters as any;
         const eventResource = resource || topic || bucket;
 
         def.eventTrigger = {
@@ -319,25 +277,6 @@
   return regionDefinitions;
 }
 
-/**
- * Converts an array of EmulatedTriggerDefinitions to a map of EmulatedTriggers, which contain information on execution,
- * @param {EmulatedTriggerDefinition[]} definitions An array of regionalized, parsed trigger definitions
- * @param {object} module Actual module which contains multiple functions / definitions
- * @return a map of trigger ids to EmulatedTriggers
- */
-export function getEmulatedTriggersFromDefinitions(
-  definitions: EmulatedTriggerDefinition[],
-  module: any, // eslint-disable-line @typescript-eslint/explicit-module-boundary-types, @typescript-eslint/no-explicit-any
-): EmulatedTriggerMap {
-  return definitions.reduce(
-    (obj: { [triggerName: string]: EmulatedTrigger }, definition: EmulatedTriggerDefinition) => {
-      obj[definition.id] = new EmulatedTrigger(definition, module);
-      return obj;
-    },
-    {},
-  );
-}
-
 /**
  * Create a path that used to create a tempfile for IPC over socket files.
  */
@@ -429,22 +368,6 @@
   return "";
 }
 
-/**
- * Create a Promise which can be awaited to recieve request bodies as strings.
- */
-export function waitForBody(req: express.Request): Promise<string> {
-  let data = "";
-  return new Promise((resolve) => {
-    req.on("data", (chunk: any) => {
-      data += chunk;
-    });
-
-    req.on("end", () => {
-      resolve(data);
-    });
-  });
-}
-
 /**
  * Find the root directory housing a node module.
  */