How to Use Firebase Cloud Functions with FlutterFlow

1// functions/index.js — onCall function example
2const functions = require('firebase-functions');
3const admin = require('firebase-admin');
4admin.initializeApp();
5
6// Called from FlutterFlow Custom Action
7exports.processUserAction = functions.https.onCall(
8  async (data, context) => {
9    // 1. Verify authentication
10    if (!context.auth) {
11      throw new functions.https.HttpsError(
12        'unauthenticated',
13        'You must be logged in to perform this action'
14      );
15    }
16    // 2. Validate input parameters
17    const { actionType, targetId } = data;
18    if (!actionType || !targetId) {
19      throw new functions.https.HttpsError(
20        'invalid-argument',
21        'actionType and targetId are required'
22      );
23    }
24    // 3. Perform server-side logic
25    const db = admin.firestore();
26    const userId = context.auth.uid;
27    await db.collection('userActions').add({
28      userId,
29      actionType,
30      targetId,
31      createdAt: admin.firestore.FieldValue.serverTimestamp(),
32    });
33    // 4. Return result
34    return { success: true, message: 'Action recorded' };
35  }
36);

1// Firestore trigger: runs when a new 'orders' document is created
2exports.onOrderCreated = functions.firestore
3  .document('orders/{orderId}')
4  .onCreate(async (snap, context) => {
5    const order = snap.data();
6    const messaging = admin.messaging();
7    // Get user's FCM token
8    const userDoc = await admin.firestore()
9      .collection('users')
10      .doc(order.userId)
11      .get();
12    const fcmToken = userDoc.data()?.fcmToken;
13    if (fcmToken) {
14      await messaging.send({
15        token: fcmToken,
16        notification: {
17          title: 'Order confirmed!',
18          body: `Order #${context.params.orderId} received`,
19        },
20      });
21    }
22  });
23
24// Scheduled: runs every day at 9am UTC
25exports.dailyCleanup = functions.pubsub
26  .schedule('0 9 * * *')
27  .timeZone('UTC')
28  .onRun(async (_context) => {
29    const cutoff = new Date(Date.now() - 30 * 24 * 60 * 60 * 1000);
30    const db = admin.firestore();
31    const old = await db
32      .collection('tempData')
33      .where('createdAt', '<', cutoff)
34      .get();
35    const batch = db.batch();
36    old.forEach((doc) => batch.delete(doc.ref));
37    await batch.commit();
38    console.log(`Cleaned up ${old.size} old records`);
39  });

1// FlutterFlow Custom Action: callProcessUserAction
2import 'package:cloud_functions/cloud_functions.dart';
3
4Future<bool> callProcessUserAction(
5  String actionType,
6  String targetId,
7) async {
8  try {
9    final functions = FirebaseFunctions.instance;
10    final callable = functions.httpsCallable(
11      'processUserAction',
12      options: HttpsCallableOptions(
13        timeout: const Duration(seconds: 30),
14      ),
15    );
16    final result = await callable.call({
17      'actionType': actionType,
18      'targetId': targetId,
19    });
20    // result.data is the Map returned by your Cloud Function
21    return result.data['success'] == true;
22  } on FirebaseFunctionsException catch (e) {
23    // e.code contains the HttpsError code you threw
24    // e.message contains the human-readable message
25    print('Cloud Function error: ${e.code} - ${e.message}');
26    return false;
27  }
28}

1// Using Secret Manager with 2nd gen functions
2const { onCall } = require('firebase-functions/v2/https');
3const { defineSecret } = require('firebase-functions/params');
4
5const sendgridKey = defineSecret('SENDGRID_API_KEY');
6
7exports.sendWelcomeEmail = onCall(
8  { secrets: [sendgridKey] },
9  async (request) => {
10    if (!request.auth) {
11      throw new HttpsError('unauthenticated', 'Login required');
12    }
13    // Access secret value
14    const apiKey = sendgridKey.value();
15    // Use apiKey with SendGrid SDK...
16    return { sent: true };
17  }
18);