Merge branch 'main' of https://github.com/invertase/firebase_functions

Author: Lyokone

README.md

@@ -13,7 +13,7 @@ This package provides a complete Dart implementation of Firebase Cloud Functions
 |-------------|--------|-----------|
 | **HTTPS** | ✅ Complete | `onRequest`, `onCall`, `onCallWithData` |
 | **Pub/Sub** | ✅ Complete | `onMessagePublished` |
-| **Firestore** | ✅ Complete | `onDocumentCreated`, `onDocumentUpdated`, `onDocumentDeleted`, `onDocumentWritten` |
+| **Firestore** | ✅ Complete | `onDocumentCreated`, `onDocumentUpdated`, `onDocumentDeleted`, `onDocumentWritten`, `onDocumentCreatedWithAuthContext`, `onDocumentUpdatedWithAuthContext`, `onDocumentDeletedWithAuthContext`, `onDocumentWrittenWithAuthContext` |
 | **Realtime Database** | ✅ Complete | `onValueCreated`, `onValueUpdated`, `onValueDeleted`, `onValueWritten` |
 | **Firebase Alerts** | ✅ Complete | Crashlytics, Billing, Performance alerts |
 | **Identity Platform** | ✅ Complete | `beforeUserCreated`, `beforeUserSignedIn` (+ `beforeEmailSent`, `beforeSmsSent`*) |
@@ -216,6 +216,49 @@ firebase.firestore.onDocumentCreated(
     print('Comment: ${event.params['commentId']}');
   },
 );
+
+// With auth context (identifies the principal that triggered the write)
+firebase.firestore.onDocumentCreatedWithAuthContext(
+  document: 'orders/{orderId}',
+  (event) async {
+    print('Auth type: ${event.authType}');
+    print('Auth ID: ${event.authId}');
+    final data = event.data?.data();
+    print('Order: ${data?['product']}');
+  },
+);
+
+firebase.firestore.onDocumentUpdatedWithAuthContext(
+  document: 'orders/{orderId}',
+  (event) async {
+    print('Updated by: ${event.authType} (${event.authId})');
+    final before = event.data?.before?.data();
+    final after = event.data?.after?.data();
+    print('Before: $before');
+    print('After: $after');
+  },
+);
+
+firebase.firestore.onDocumentDeletedWithAuthContext(
+  document: 'orders/{orderId}',
+  (event) async {
+    print('Deleted by: ${event.authType} (${event.authId})');
+    final data = event.data?.data();
+    print('Deleted data: $data');
+  },
+);
+
+firebase.firestore.onDocumentWrittenWithAuthContext(
+  document: 'orders/{orderId}',
+  (event) async {
+    print('Written by: ${event.authType} (${event.authId})');
+    final before = event.data?.before;
+    final after = event.data?.after;
+    if (before == null || !before.exists) print('CREATE');
+    else if (after == null || !after.exists) print('DELETE');
+    else print('UPDATE');
+  },
+);
 ```
 
 ## Realtime Database Triggers

lib/firebase_functions.dart

@@ -54,7 +54,7 @@
 library;
 
 // Re-export Firestore types for convenience
-export 'package:googleapis_firestore/googleapis_firestore.dart'
+export 'package:google_cloud_firestore/google_cloud_firestore.dart'
     show DocumentData, DocumentSnapshot, QueryDocumentSnapshot;
 // Re-export Shelf types for convenience
 export 'package:shelf/shelf.dart' show Request, Response;

lib/src/firebase.dart

@@ -2,7 +2,7 @@ import 'dart:async';
 import 'dart:io';
 
 import 'package:dart_firebase_admin/dart_firebase_admin.dart';
-import 'package:googleapis_firestore/googleapis_firestore.dart' as gfs;
+import 'package:google_cloud_firestore/google_cloud_firestore.dart' as gfs;
 import 'package:shelf/shelf.dart';
 
 import 'alerts/alerts_namespace.dart';

lib/src/firestore/document_snapshot.dart

@@ -1,4 +1,4 @@
-import 'package:googleapis_firestore/googleapis_firestore.dart'
+import 'package:google_cloud_firestore/google_cloud_firestore.dart'
     show DocumentData;
 
 export '../common/change.dart';

lib/src/firestore/firestore_namespace.dart

@@ -453,7 +453,12 @@ class FirestoreNamespace extends FunctionsNamespace {
           final params = _extractParams(document, headers.documentPath);
 
           final parsed = await _parseBody(request);
-          final snapshot = parsed?['value'];
+          final snapshotKey =
+              (methodName == 'onDocumentDeleted' ||
+                  methodName == 'onDocumentDeletedWithAuthContext')
+              ? 'old_value'
+              : 'value';
+          final snapshot = parsed?[snapshotKey];
 
           try {
             if (withAuthContext) {

pubspec.yaml

@@ -31,11 +31,11 @@ dependencies:
       url: https://github.com/invertase/dart_firebase_admin.git
       ref: next
       path: packages/dart_firebase_admin
-  googleapis_firestore:
+  google_cloud_firestore:
     git:
       url: https://github.com/invertase/dart_firebase_admin.git
       ref: next
-      path: packages/googleapis_firestore
+      path: packages/google_cloud_firestore
   stack_trace: ^1.12.1
   protobuf: ^6.0.0
   http: ^1.6.0
@@ -57,11 +57,11 @@ dev_dependencies:
   yaml: ^3.1.3
 
 dependency_overrides:
-  googleapis_firestore:
+  google_cloud_firestore:
     git:
       url: https://github.com/invertase/dart_firebase_admin.git
       ref: next
-      path: packages/googleapis_firestore
+      path: packages/google_cloud_firestore
   googleapis_storage:
     git:
       url: https://github.com/invertase/dart_firebase_admin.git

test/e2e/tests/firestore_tests.dart

@@ -98,13 +98,26 @@ void runFirestoreTests(
       await client.deleteDocument('users/$testUserId');
       print('✓ Document deleted successfully');
 
-      // Wait for trigger
+      // Wait for trigger to fire
       await Future<void>.delayed(const Duration(seconds: 2));
 
       // Verify document no longer exists
       final doc = await client.getDocument('users/$testUserId');
       expect(doc, isNull, reason: 'Document should not exist after deletion');
       print('✓ Document deletion verified');
+
+      // Verify handler received the pre-deletion document data by checking
+      // the structured log line emitted by the handler.
+      final outputLogs = getEmulator().outputLines.join('\n');
+      expect(
+        outputLogs,
+        contains('[onDocumentDeleted] hasData=true'),
+        reason: 'event.data should be non-null for delete events',
+      );
+      expect(outputLogs, contains('name=To Be Deleted'));
+      expect(outputLogs, contains('email=delete@example.com'));
+      expect(outputLogs, contains('finalMessage=goodbye'));
+      print('✓ Handler received correct pre-deletion document data');
     });
 
     test('onDocumentWritten fires for all operations', () async {

test/fixtures/dart_reference/bin/server.dart

@@ -184,6 +184,12 @@ void main(List<String> args) async {
       final data = event.data?.data();
       print('Document deleted: users/${event.params['userId']}');
       print('  Final data: $data');
+      print(
+        '[onDocumentDeleted] hasData=${data != null}'
+        ' name=${data?['name']}'
+        ' email=${data?['email']}'
+        ' finalMessage=${data?['finalMessage']}',
+      );
     });
 
     firebase.firestore.onDocumentWritten(document: 'users/{userId}', (