index.js

/**
 * Reference Node.js implementation matching the Dart example.
 * This is used for snapshot testing to ensure the Dart builder
 * generates compatible functions.yaml output.
 */

const { onRequest } = require("firebase-functions/v2/https");
const { onMessagePublished } = require("firebase-functions/v2/pubsub");
const { onDocumentCreated, onDocumentUpdated, onDocumentDeleted, onDocumentWritten } = require("firebase-functions/v2/firestore");
const { onValueCreated, onValueUpdated, onValueDeleted, onValueWritten } = require("firebase-functions/v2/database");
const { defineString, defineInt, defineBoolean } = require("firebase-functions/params");

// =============================================================================
// Parameterized Configuration Examples
// =============================================================================

// Define parameters - these are read from environment variables at runtime
// and can be configured at deploy time via .env files or CLI prompts.
const welcomeMessage = defineString("WELCOME_MESSAGE", {
  default: "Hello from Dart Functions!",
  label: "Welcome Message",
  description: "The greeting message returned by the helloWorld function",
});

const minInstances = defineInt("MIN_INSTANCES", {
  default: 0,
  label: "Minimum Instances",
  description: "Minimum number of instances to keep warm",
});

const isProduction = defineBoolean("IS_PRODUCTION", {
  default: false,
  description: "Whether this is a production deployment",
});

// HTTPS onRequest example - using parameterized configuration
exports.helloWorld = onRequest(
  {
    // Use parameters in options - evaluated at deploy time
    minInstances: minInstances,
  },
  (request, response) => {
    // Access parameter value at runtime
    response.send(welcomeMessage.value());
  }
);

// Conditional configuration based on boolean parameter
exports.configuredEndpoint = onRequest(
  {
    // Use thenElse for conditional configuration at deploy time
    // isProduction.thenElse(trueValue, falseValue) returns an expression
    memory: isProduction.thenElse(2048, 512),
  },
  (request, response) => {
    // Access parameter value at runtime
    const env = isProduction.value() ? "production" : "development";
    response.send(`Running in ${env} mode`);
  }
);

// Pub/Sub trigger example
exports.onMessagePublished_mytopic = onMessagePublished(
  "my-topic",
  (event) => {
    const message = event.data.message;
    console.log("Received Pub/Sub message:");
    console.log("  ID:", message.messageId);
    console.log("  Published:", message.publishTime);
    console.log("  Data:", message.data ? Buffer.from(message.data, "base64").toString() : "");
    console.log("  Attributes:", message.attributes);
  }
);

// =============================================================================
// Firestore trigger examples
// =============================================================================

exports.onDocumentCreated_users_userId = onDocumentCreated(
  "users/{userId}",
  (event) => {
    const data = event.data?.data();
    console.log("Document created: users/" + event.params.userId);
    console.log("  Name:", data?.name);
    console.log("  Email:", data?.email);
  }
);

exports.onDocumentUpdated_users_userId = onDocumentUpdated(
  "users/{userId}",
  (event) => {
    const before = event.data?.before?.data();
    const after = event.data?.after?.data();
    console.log("Document updated: users/" + event.params.userId);
    console.log("  Before:", before);
    console.log("  After:", after);
  }
);

exports.onDocumentDeleted_users_userId = onDocumentDeleted(
  "users/{userId}",
  (event) => {
    const data = event.data?.data();
    console.log("Document deleted: users/" + event.params.userId);
    console.log("  Final data:", data);
  }
);

exports.onDocumentWritten_users_userId = onDocumentWritten(
  "users/{userId}",
  (event) => {
    const before = event.data?.before?.data();
    const after = event.data?.after?.data();
    console.log("Document written: users/" + event.params.userId);
    if (!before && after) {
      console.log("  Operation: CREATE");
    } else if (before && after) {
      console.log("  Operation: UPDATE");
    } else if (before && !after) {
      console.log("  Operation: DELETE");
    }
  }
);

exports.onDocumentCreated_posts_postId_comments_commentId = onDocumentCreated(
  "posts/{postId}/comments/{commentId}",
  (event) => {
    const data = event.data?.data();
    console.log("Comment created: posts/" + event.params.postId + "/comments/" + event.params.commentId);
    console.log("  Text:", data?.text);
    console.log("  Author:", data?.author);
  }
);

// =============================================================================
// Realtime Database trigger examples
// =============================================================================

exports.onValueCreated_messages_messageId = onValueCreated(
  "/messages/{messageId}",
  (event) => {
    const data = event.data?.val();
    console.log("Database value created: messages/" + event.params.messageId);
    console.log("  Data:", data);
    console.log("  Instance:", event.instance);
    console.log("  Ref:", event.ref);
  }
);

exports.onValueUpdated_messages_messageId = onValueUpdated(
  "/messages/{messageId}",
  (event) => {
    const before = event.data?.before?.val();
    const after = event.data?.after?.val();
    console.log("Database value updated: messages/" + event.params.messageId);
    console.log("  Before:", before);
    console.log("  After:", after);
  }
);

exports.onValueDeleted_messages_messageId = onValueDeleted(
  "/messages/{messageId}",
  (event) => {
    const data = event.data?.val();
    console.log("Database value deleted: messages/" + event.params.messageId);
    console.log("  Final data:", data);
  }
);

exports.onValueWritten_messages_messageId = onValueWritten(
  "/messages/{messageId}",
  (event) => {
    const before = event.data?.before;
    const after = event.data?.after;
    console.log("Database value written: messages/" + event.params.messageId);
    if (!before?.exists() && after?.exists()) {
      console.log("  Operation: CREATE");
      console.log("  New data:", after.val());
    } else if (before?.exists() && !after?.exists()) {
      console.log("  Operation: DELETE");
      console.log("  Deleted data:", before.val());
    } else {
      console.log("  Operation: UPDATE");
      console.log("  Before:", before?.val());
      console.log("  After:", after?.val());
    }
  }
);

exports.onValueWritten_users_userId_status = onValueWritten(
  "/users/{userId}/status",
  (event) => {
    const after = event.data?.after?.val();
    console.log("User status changed:", event.params.userId);
    console.log("  New status:", after);
  }
);