René's URL Explorer Experiment

Title: Adding stream listeners to sniff change in child by rizasif · Pull Request #50 · firebase/firebase-admin-python · GitHub

Open Graph Title: Adding stream listeners to sniff change in child by rizasif · Pull Request #50 · firebase/firebase-admin-python

X Title: Adding stream listeners to sniff change in child by rizasif · Pull Request #50 · firebase/firebase-admin-python

Description: Hello, I noticed that there (according to my best knowledge) hasn't been a stream listener implemented in the project. Which has a sole responsibility to fire up a callback function (https://firebase.google.com/docs/reference/rest/database/#callback) when any change to a firebase node is occurred. This is essential for developers who want to perform an action when a change to database is observed. The changes I proposed are inspired by PyRebase (https://github.com/thisbejim/Pyrebase). I have implemented a SSEClient which uses python request library to listen for changes. These changes have been tested using a simulation of 100 users, performing read and write operations. The results, so far, are promising with 0% failure rate. I have written a test code for you as well. The following adds a new child node to the already available parent "users". Now, if you visit the firebase console and delete this new child node, then the "call_function" will fire up. Similar, case can be observed by updating, adding or deleting in the child of "users" node through the console. import firebase_admin from firebase_admin import credentials from firebase_admin import db # Fetch the service account key JSON file contents cred = credentials.Certificate("PATH_TO_JSON_FILE") # Initialize the app with a service account, granting admin privileges firebase_admin.initialize_app(cred, {"databaseURL": "DATABASE_URL"}) root = db.reference() print(root.get()) new_user = root.child("users").push({"name": "lila Annen", "age": 19}) ref = root.child("users") print(ref.get()) def call_function(message): print( message["event"]) print(message["path"]) my_stream_question_requested = db.reference("users").stream(call_function, stream_id="new stream") Hope to hear from you soon, thanks!

Open Graph Description: Hello, I noticed that there (according to my best knowledge) hasn't been a stream listener implemented in the project. Which has a sole responsibility to fire up a callback function (https://fi...

X Description: Hello, I noticed that there (according to my best knowledge) hasn't been a stream listener implemented in the project. Which has a sole responsibility to fire up a callback function (https:...

Opengraph URL: https://github.com/firebase/firebase-admin-python/pull/50

X: @github

direct link

Domain: patch-diff.githubusercontent.com

Links:

Viewport: width=device-width