update realtime reference to posts

Author: fenix-hub

main/scn/home/home.gd

@@ -24,6 +24,8 @@ var fr_posts : FirestoreCollection = Firebase.Firestore.collection("posts")
 
 var friend_posts : Array = []
 
+var posts_db_reference : FirebaseDatabaseReference 
+
 func _connect_signals():
     $ShareSomethingContainer.connect("share_post", self, "add_shared_post")
     users_list_section.connect("show_user_profile", self, "_on_show_user_profile")
@@ -40,7 +42,6 @@ func _ready():
     load_user()
     animate_Home(true)
     load_posts()
-#    suggested_users.suggest_user("fenix-hub")
     friend_list.load_friend_list()
 
 func load_user():
@@ -58,7 +59,7 @@ func animate_Home(display : bool):
     $Tween.start()
 
 func sort_posts(post_a : FirestoreDocument, post_b : FirestoreDocument):
-    if post_a.doc_fields.timestamp < post_b.doc_fields.timestamp:
+    if post_a.doc_fields.timestamp > post_b.doc_fields.timestamp:
         return true
     return false
 
@@ -69,29 +70,52 @@ func load_posts():
         for post in posts:
             if post.has("fields"):
                 if (post.fields.user_id.stringValue in UserData.friend_list) \
-                or (post.fields.user_id.stringValue == UserData.user_id):
+                or (post.fields.user_id.stringValue == UserData.user_id) \
+                and not post in friend_posts:
                     friend_posts.append(FirestoreDocument.new(post))
 
         friend_posts.sort_custom(self, "sort_posts")
 
         if friend_posts.empty():
             pass
         else:
-            for post in friend_posts.slice(0, 10):
-                if PostsManager.has_post(post.doc_name):
-                    if PostsManager.has_post_container(post.doc_name):
-                        var post_container : PostContainer = PostsManager.get_post_container_by_id(post.doc_name)
+            for post_idx in range(0, friend_posts.size()):#.slice(0, 10):
+                var post_container : PostContainer
+                if PostsManager.has_post(friend_posts[post_idx].doc_name):
+                    if PostsManager.has_post_container(friend_posts[post_idx].doc_name):
+                        post_container = PostsManager.get_post_container_by_id(friend_posts[post_idx].doc_name)
+                        add_post(post_container)
+                    else:
+                        post_container = Activities.post_container_scene.instance()
                         add_post(post_container)
+                        post_container.load_post(PostsManager.get_post_by_id(friend_posts[post_idx].doc_name))
                 else:
-                    var post_container : PostContainer = Activities.post_container_scene.instance()
-                    var post_obj : PostsManager.Post = PostsManager.add_post_from_doc(post.doc_name, post)
-                    post_container.load_post(post_obj)
+                    post_container = Activities.post_container_scene.instance()
+                    var post_obj : PostsManager.Post = PostsManager.add_post_from_doc(friend_posts[post_idx].doc_name, friend_posts[post_idx])
                     add_post(post_container)
+                    post_container.load_post(post_obj)
+                post_box.move_child(post_container, post_idx)
     else:
         for post in post_box.get_children():
             if post is PostContainer: post.queue_free()
         posts_section.get_node("NoFriends").show()
+    
+    if posts_db_reference == null:
+        posts_db_reference = Firebase.Database.get_database_reference("sociadot/posts")
+        posts_db_reference.connect("new_data_update", self, "_on_new_post")
+    
+    
 
+func _on_new_post(post : FirebaseResource):
+    if post.data.user == UserData.user_id:
+        return
+    if PostsManager.has_post(post.key):
+        return
+    var post_container : PostContainer = Activities.post_container_scene.instance()
+    var post_doc : FirestoreDocument = yield(Utilities.get_post_doc(post.key), "get_document")
+    var post_obj : PostsManager.Post = PostsManager.add_post_from_doc(post.key, post_doc)
+    add_post(post_container)
+    post_container.load_post(post_obj)  
 
 func add_post(post : PostContainer):
     posts_section.get_node("NoFriends").hide()

main/scn/post/post.gd

@@ -37,7 +37,8 @@ func load_post(post) -> void:
     set_user_id(post.user_id)
     set_description(post.description)
     set_timestamp(post.timestamp)
-    set_image(post.image)
+    if post.image_name == "":
+        set_image(null)
     PostsManager.add_post_scene(self)
 
 func set_post_id(p : String):
@@ -99,9 +100,15 @@ func set_description(d : String):
 
 
 func set_image(img : ImageTexture):
+    if not post_image:
+        return
     image = img
     if img == null:
+        post_image.material = null
+        post_image.hide()
         return
+    else:
+        post_image.show()
     post_image.set_texture(img)
     if img.get_size().y < 100:
         post_image.stretch_mode = TextureRect.STRETCH_KEEP_ASPECT_CENTERED

main/scn/share/share.gd

@@ -6,7 +6,7 @@ onready var post_image : TextureRect = $ShareSomething/Container/Image
 onready var post_description : TextEdit = $ShareSomething/Container/Description
 
 var image_path : String
-var image : ImageTexture
+var image : ImageTexture = null
 
 var y_limit : int = 400
 var x_limit : int = 500
@@ -48,8 +48,9 @@ func _on_ShareBtn_pressed():
     Activities.loading(true)
     var share_task : FirestoreTask = Utilities.add_post_doc(post_description.get_text().c_escape(), image_path)
     var post_doc : FirestoreDocument = yield(share_task, "task_finished")
-    var image_task : StorageTask = Utilities.add_post_image(post_doc.doc_name, image_path, image.get_data().save_png_to_buffer())
-    yield(image_task, "task_finished")
+    if image != null:
+        var image_task : StorageTask = Utilities.add_post_image(post_doc.doc_name, image_path, image.get_data().save_png_to_buffer())
+        yield(image_task, "task_finished")
     emit_signal("share_post", post_doc.doc_name, post_doc, image)
     hide()
     clear()
@@ -87,6 +88,7 @@ func _on_ShareSomethingContainer_gui_input(event):
             hide()
 
 func clear():
+    image = null
     post_image.set_texture(null)
     post_image.hide()
     post_description.set_text("")

main/scn/signin/signin.gd

@@ -18,7 +18,7 @@ func _ready():
     $UpdateProfile.hide()
     animate_SignContainer(true)
     yield(get_tree(), "idle_frame")
-    return
+#    return
     Firebase.Auth.load_auth()
     if not Firebase.Auth.auth.empty():
         Activities.loading( true)

main/scripts/posts_manager.gd

@@ -20,31 +20,32 @@ class Post:
     signal update_post(post)
 
     func _init(id : String, doc_task : FirestoreTask = null, img_task : StorageTask = null):
-            self.id = id
-            if doc_task != null:
-                document_task = doc_task
-                document_task.connect("get_document", self, "_on_get_document")
-            if img_task != null:
-                image_task = img_task
-                image_task.connect("task_finished", self, "_on_image_received")
-
+        self.id = id
+        if doc_task != null:
+            document_task = doc_task
+            document_task.connect("get_document", self, "_on_get_document")
+        if img_task != null:
+            image_task = img_task
+            image_task.connect("task_finished", self, "_on_image_received")
+            
     func _on_get_document(doc : FirestoreDocument):
         emit_signal("update_document", doc)
         document = doc
         user = doc.doc_fields.user
         user_id = doc.doc_fields.user_id
         description = doc.doc_fields.description
         timestamp = doc.doc_fields.timestamp
-#        likes = doc.doc_fields.likes
-#        comments = doc.doc_fields.comments
         image_name = doc.doc_fields.image
         emit_signal("update_post", self)
 
     func _on_image_received():
         if typeof(image_task.data) == TYPE_RAW_ARRAY:
             image = Utilities.byte2image(image_task.data)
             emit_signal("update_image", image)
-
+        else:
+            if image_task.data.has("error") or image_name == "":
+                image = null
+                emit_signal("update_image", image)
 
 var posts : Array = []
 var post_containers : Array = []
@@ -58,9 +59,13 @@ func add_post(id : String, document_task : FirestoreTask = null, image_task : St
     return post
 
 func add_post_from_doc(id : String, doc : FirestoreDocument, image_task : StorageTask = null) -> Post:
+    var post : Post
     if image_task == null:
-        image_task = Utilities.get_post_image(doc.doc_fields.user_id, id, doc.doc_fields.image)
-    var post : Post = Post.new(id, null, image_task)
+        if doc.doc_fields.image != "":
+            image_task = Utilities.get_post_image(doc.doc_fields.user_id, id, doc.doc_fields.image)
+            post = Post.new(id, null, image_task)
+        else:
+            post = Post.new(id)
     post._on_get_document(doc)
     posts.append(post)
     return post

main/scripts/utilities.gd

@@ -67,21 +67,28 @@ func update_friend_list(friend_id : String) -> FirestoreTask:
         friend_list = UserData.friend_list
         })
 
-
+# Get a single post document by ID
+func get_post_doc(post_id : String) -> FirestoreTask:
+    return posts_collection.get(post_id)
 
 # Get a post's Image from Storage
 func get_post_image(user_id : String, post_id : String, post_image : String) -> StorageTask:
     return Firebase.Storage.ref("sociadot/posts/{user_id}/{post_id}/{post_image}".format({user_id = user_id, post_id = post_id, post_image = post_image})).get_data()
 
 # Add a new post Document
 func add_post_doc(description : String, image_path : String, timestamp : int = Utilities.get_time()) -> FirestoreTask:
-    return posts_collection.add("", {
+    var add_post_task : FirestoreTask = posts_collection.add("", {
         user = UserData.user_name,
         user_id = UserData.user_id,
         description = description,
         image = get_image_name(image_path),
         timestamp = timestamp
        })
+    add_post_task.connect("add_document", self, "_on_post_added")
+    return add_post_task
+
+func _on_post_added(post_doc : FirestoreDocument):
+    Firebase.Database.get_database_reference("sociadot/posts").update(post_doc.doc_name, { user = post_doc.doc_fields.user_id })
 
 # Add a post image to Storage
 func add_post_image(post_id : String, image_path : String, image : PoolByteArray) -> StorageTask:

project.godot

@@ -201,16 +201,17 @@ enabled=PoolStringArray( "godot-firebase" )
 
 [firebase]
 
-environment_variables/apiKey="AIzaSyBdarlkNQO0rqZnDgv8P914R_dkSfp3S1c"
-environment_variables/authDomain="instadot.firebaseapp.com"
-environment_variables/databaseURL="https://instadot-default-rtdb.firebaseio.com"
-environment_variables/projectId="instadot"
-environment_variables/storageBucket="instadot.appspot.com"
-environment_variables/messagingSenderId="283726603535"
-environment_variables/appId="1:283726603535:web:14132220da1c119f62ca7a"
+environment_variables/apiKey="AIzaSyCgrmTwdsjR0zY0hHR_WyuSX4cJri1wiBo"
+environment_variables/authDomain="roundtable-5c241.firebaseapp.com"
+environment_variables/databaseURL="https://roundtable-5c241.firebaseio.com"
+environment_variables/projectId="roundtable-5c241"
+environment_variables/storageBucket="roundtable-5c241.appspot.com"
+environment_variables/messagingSenderId="567850593967"
+environment_variables/appId="1:567850593967:web:5395b274d9da6a919f2e5a"
 environment_variables/measurementId=""
 environment_variables/clientId=""
 environment_variables/clientSecret=""
+environment_variables/domainUriPrefix=""
 
 [gui]