feat(storage-resize-images): Add onStartResize event and trigger for onStart event (#2562)

* fix(storage-resize-images): add missing recordStartEvent call

* feat(storage-resize-images): add onStorageResize event

* docs(storage-resize-images): update changelog

* chore(storage-resize-images): add onStartResize

* chore(storage-resize-images): add onStartResize event

---------

Co-authored-by: Tadej <tadej.dev@gmail.com>

Author: HassanBahati

storage-resize-images/CHANGELOG.md

@@ -1,3 +1,8 @@
+## Version 0.3.1
+
+fix - add missing recordStartEvent call (#2546)
+feat - add new onStartResize event
+
 ## Version 0.3.0
 
 fix! - remove backfill, due to architectural flaws.

storage-resize-images/extension.yaml

@@ -13,7 +13,7 @@
 # limitations under the License.
 
 name: storage-resize-images
-version: 0.3.0
+version: 0.3.1
 specVersion: v1beta
 
 displayName: Resize Images
@@ -426,6 +426,12 @@ events:
     description:
       Occurs when the function is settled. Provides no customized data other
       than the context.
+
+  - type: firebase.extensions.storage-resize-images.v1.onStartResize
+    description:
+      Occurs when an image resize operation completes successfully. This event
+      is only triggered when shouldResize returns true and the resize operation
+      succeeds.
 # Lifecycle events disabled - backfill feature commented out
 # lifecycleEvents:
 #   onInstall:

storage-resize-images/functions/src/events.ts

@@ -60,3 +60,19 @@ export const recordCompletionEvent = async (data: string | object) => {
     data,
   });
 };
+
+export const recordStartResizeEvent = async ({
+  subject,
+  data,
+}: {
+  subject: string;
+  data: string | object;
+}) => {
+  if (!eventChannel) return;
+
+  return eventChannel.publish({
+    type: getEventType("onStartResize"),
+    subject,
+    data,
+  });
+};

storage-resize-images/functions/src/index.ts

@@ -59,6 +59,11 @@ const generateResizedImageHandler = async (
     return;
   }
 
+  await events.recordStartResizeEvent({
+    subject: object.name,
+    data: { input: object },
+  });
+
   const bucket = admin.storage().bucket(object.bucket);
   const filePath = object.name; // File path in the bucket.
   const parsedPath = path.parse(filePath);
@@ -149,6 +154,7 @@ const generateResizedImageHandler = async (
 export const generateResizedImage = functions.storage
   .object()
   .onFinalize(async (object, context) => {
+    await events.recordStartEvent(object);
     await generateResizedImageHandler(object);
     await events.recordCompletionEvent({ context });
   });