রিয়েলটাইম ডেটাবেস ট্রিগার (1ম প্রজন্ম)

Cloud Functions ব্যবহার করে, আপনি ক্লায়েন্ট কোড আপডেট করার প্রয়োজন ছাড়াই Firebase Realtime Database ইভেন্টগুলো পরিচালনা করতে পারেন। Cloud Functions আপনাকে সম্পূর্ণ প্রশাসনিক অধিকারসহ Realtime Database অপারেশন চালানোর সুযোগ দেয় এবং এটি নিশ্চিত করে যে Realtime Database প্রতিটি পরিবর্তন স্বতন্ত্রভাবে প্রক্রিয়া করা হয়। আপনি DataSnapshot অথবা অ্যাডমিন এসডিকে-এর মাধ্যমে Firebase Realtime Database পরিবর্তন আনতে পারেন।

In a typical lifecycle, a Firebase Realtime Database function does the following:

1. Waits for changes to a particular Realtime Database location.
2. Triggers when an event occurs and performs its tasks (see What can I do with Cloud Functions ? for examples of use cases).
3. Receives a data object that contains a snapshot of the data stored in the specified document.

একটি Realtime Database ফাংশন ট্রিগার করুন

functions.database ব্যবহার করে Realtime Database ইভেন্টের জন্য নতুন ফাংশন তৈরি করুন। ফাংশনটি কখন ট্রিগার হবে তা নিয়ন্ত্রণ করতে, ইভেন্ট হ্যান্ডলারগুলোর মধ্যে একটি নির্দিষ্ট করুন এবং Realtime Database সেই পাথটি উল্লেখ করুন যেখানে এটি ইভেন্টের জন্য অপেক্ষা করবে।

ইভেন্ট হ্যান্ডলার সেট করুন

ফাংশন আপনাকে Realtime Database ইভেন্টগুলিকে দুটি নির্দিষ্ট স্তরে পরিচালনা করার সুযোগ দেয়; আপনি বিশেষভাবে শুধুমাত্র তৈরি, আপডেট বা মুছে ফেলার ইভেন্টগুলির জন্য শুনতে পারেন, অথবা আপনি একটি পাথের যেকোনো ধরনের পরিবর্তনের জন্য শুনতে পারেন। Cloud Functions Realtime Database জন্য এই ইভেন্ট হ্যান্ডলারগুলিকে সমর্থন করে:

• onWrite() , which triggers when data is created, updated, or deleted in Realtime Database .
• onCreate() , which triggers when new data is created in Realtime Database .
• onUpdate() , which triggers when data is updated in Realtime Database .
• onDelete() , which triggers when data is deleted from Realtime Database .

ইনস্ট্যান্স এবং পাথ নির্দিষ্ট করুন।

আপনার ফাংশনটি কখন এবং কোথায় ট্রিগার হবে তা নিয়ন্ত্রণ করতে, একটি পাথ নির্দিষ্ট করার জন্য ref(path) কল করুন, এবং ঐচ্ছিকভাবে instance('INSTANCE_NAME') দিয়ে একটি Realtime Database ইনস্ট্যান্স নির্দিষ্ট করুন। আপনি যদি কোনো ইনস্ট্যান্স নির্দিষ্ট না করেন, তাহলে ফাংশনটি ফায়ারবেস প্রজেক্টের ডিফল্ট Realtime Database ইনস্ট্যান্সে ডেপ্লয় হবে। উদাহরণস্বরূপ:

• Default Realtime Database instance: functions.database.ref('/foo/bar')
• Instance named "my-app-db-2": functions.database.instance('my-app-db-2').ref('/foo/bar')

এই পদ্ধতিগুলো আপনার ফাংশনকে Realtime Database ইনস্ট্যান্সের মধ্যে একটি নির্দিষ্ট পাথে রাইট অপারেশন পরিচালনা করার নির্দেশ দেয়। পাথ স্পেসিফিকেশন সেই পাথে সংঘটিত সমস্ত রাইট অপারেশনের সাথে মিলে যায়, যার মধ্যে এর নিচের যেকোনো স্থানে সংঘটিত রাইটও অন্তর্ভুক্ত। যদি আপনি আপনার ফাংশনের জন্য পাথটি /foo/bar হিসেবে সেট করেন, তবে এটি এই উভয় স্থানের ইভেন্টগুলোর সাথেই মিলে যাবে:

 /foo/bar
 /foo/bar/baz/really/deep/path

উভয় ক্ষেত্রেই, Firebase ধরে নেয় যে ইভেন্টটি /foo/bar এ ঘটেছে, এবং ইভেন্টের ডেটাতে /foo/bar এর পুরোনো ও নতুন ডেটা অন্তর্ভুক্ত থাকে। যদি ইভেন্টের ডেটার পরিমাণ বেশি হওয়ার সম্ভাবনা থাকে, তবে আপনার ডাটাবেসের রুটের কাছাকাছি একটিমাত্র ফাংশন ব্যবহার না করে, আরও গভীর পাথে একাধিক ফাংশন ব্যবহার করার কথা বিবেচনা করুন। সর্বোত্তম পারফরম্যান্সের জন্য, কেবলমাত্র সম্ভাব্য গভীরতম স্তর থেকেই ডেটার জন্য অনুরোধ করুন।

আপনি কোনো পাথ কম্পোনেন্টকে কার্লি ব্র্যাকেটের মধ্যে রেখে ওয়াইল্ডকার্ড হিসেবে নির্দিষ্ট করতে পারেন; ref('foo/{bar}') /foo এর যেকোনো চাইল্ডকে ম্যাচ করে। এই ওয়াইল্ডকার্ড পাথ কম্পোনেন্টগুলোর ভ্যালু আপনার ফাংশনের EventContext.params অবজেক্টের মধ্যে পাওয়া যায়। এই উদাহরণে, ভ্যালুটি context.params.bar হিসেবে পাওয়া যাচ্ছে।

Paths with wildcards can match multiple events from a single write. An insert of

{
  "foo": {
    "hello": "world",
    "firebase": "functions"
  }
}

matches the path "/foo/{bar}" twice: once with "hello": "world" and again with "firebase": "functions" .

ইভেন্ট ডেটা পরিচালনা করুন

একটি Realtime Database ইভেন্ট পরিচালনা করার সময়, যে ডেটা অবজেক্টটি ফেরত আসে তা হলো একটি DataSnapshot । onWrite বা onUpdate ইভেন্টের ক্ষেত্রে, প্রথম প্যারামিটারটি একটি Change অবজেক্ট, যাতে দুটি স্ন্যাপশট থাকে যা ট্রিগারিং ইভেন্টের আগে ও পরের ডেটার অবস্থা তুলে ধরে। onCreate এবং onDelete ইভেন্টের ক্ষেত্রে, যে ডেটা অবজেক্টটি ফেরত আসে তা হলো তৈরি বা মুছে ফেলা ডেটার একটি স্ন্যাপশট।

In this example, the function retrieves the snapshot for the specified path, converts the string at that location to uppercase, and writes that modified string to the database:

// Listens for new messages added to /messages/:pushId/original and creates an
// uppercase version of the message to /messages/:pushId/uppercase
exports.makeUppercase = functions.database.ref('/messages/{pushId}/original')
    .onCreate((snapshot, context) => {
      // Grab the current value of what was written to the Realtime Database.
      const original = snapshot.val();
      functions.logger.log('Uppercasing', context.params.pushId, original);
      const uppercase = original.toUpperCase();
      // You must return a Promise when performing asynchronous tasks inside a Functions such as
      // writing to the Firebase Realtime Database.
      // Setting an "uppercase" sibling in the Realtime Database returns a Promise.
      return snapshot.ref.parent.child('uppercase').set(uppercase);
    });
index.js

ব্যবহারকারীর প্রমাণীকরণ তথ্য অ্যাক্সেস করা

EventContext.auth এবং EventContext.authType থেকে, আপনি ফাংশনটি চালু করা ব্যবহারকারীর অনুমতিসহ অন্যান্য তথ্য জানতে পারেন। নিরাপত্তা বিধি প্রয়োগের জন্য এটি কার্যকর হতে পারে, যা ব্যবহারকারীর অনুমতির স্তরের উপর ভিত্তি করে আপনার ফাংশনকে বিভিন্ন কার্যক্রম সম্পন্ন করার সুযোগ দেয়।

const functions = require('firebase-functions/v1');
const admin = require('firebase-admin');

exports.simpleDbFunction = functions.database.ref('/path')
    .onCreate((snap, context) => {
      if (context.authType === 'ADMIN') {
        // do something
      } else if (context.authType === 'USER') {
        console.log(snap.val(), 'written by', context.auth.uid);
      }
    });

এছাড়াও, আপনি ব্যবহারকারীর প্রমাণীকরণ তথ্য ব্যবহার করে একজন ব্যবহারকারীর ছদ্মবেশ ধারণ করতে এবং তার পক্ষ থেকে লেখার কাজ সম্পাদন করতে পারেন। কনকারেন্সি সমস্যা এড়াতে, নিচে দেখানো পদ্ধতি অনুযায়ী অ্যাপ ইনস্ট্যান্সটি ডিলিট করে দিন:

exports.impersonateMakeUpperCase = functions.database.ref('/messages/{pushId}/original')
    .onCreate((snap, context) => {
      const appOptions = JSON.parse(process.env.FIREBASE_CONFIG);
      appOptions.databaseAuthVariableOverride = context.auth;
      const app = admin.initializeApp(appOptions, 'app');
      const uppercase = snap.val().toUpperCase();
      const ref = snap.ref.parent.child('uppercase');

      const deleteApp = () => app.delete().catch(() => null);

      return app.database().ref(ref).set(uppercase).then(res => {
        // Deleting the app is necessary for preventing concurrency leaks
        return deleteApp().then(() => res);
      }).catch(err => {
        return deleteApp().then(() => Promise.reject(err));
      });
    });

পূর্ববর্তী মান পড়া হচ্ছে

The Change object has a before property that lets you inspect what was saved to Realtime Database before the event. The before property returns a DataSnapshot where all methods (for example, val() and exists() ) refer to the previous value. You can read the new value again by either using the original DataSnapshot or reading the after property. This property on any Change is another DataSnapshot representing the state of the data after the event happened.

For example, the before property can be used to make sure the function only uppercases text when it is first created:

exports.makeUppercase = functions.database.ref('/messages/{pushId}/original')
    .onWrite((change, context) => {
      // Only edit data when it is first created.
      if (change.before.exists()) {
        return null;
      }
      // Exit when the data is deleted.
      if (!change.after.exists()) {
        return null;
      }
      // Grab the current value of what was written to the Realtime Database.
      const original = change.after.val();
      console.log('Uppercasing', context.params.pushId, original);
      const uppercase = original.toUpperCase();
      // You must return a Promise when performing asynchronous tasks inside a Functions such as
      // writing to the Firebase Realtime Database.
      // Setting an "uppercase" sibling in the Realtime Database returns a Promise.
      return change.after.ref.parent.child('uppercase').set(uppercase);
    });