Public Chat Groups Now Live!!

Author: CodingBlood

ChangeStream.py renamed to GlobalChat.py

@@ -0,0 +1,58 @@
+from KThread import *
+
+
+def main(username, x):
+    import pymongo
+    import os
+    myclient = pymongo.MongoClient(
+        "mongodb+srv://CodingBlood:[email protected]/myFirstDatabase?retryWrites=true&w=majority")
+    os.system('cls' if os.name == 'nt' else 'clear')
+    mydb = myclient["Chatbox"]
+    mycol = mydb["PublicChatGroups"]
+    for iterate in mycol.find():
+        if iterate["GName"] == x:
+            print(iterate["GName"] + " : " + iterate["Desc"])
+            print(iterate["Owner"] + " --- Origin : " + iterate["Origin"])
+            admins = ""
+            for i in iterate["Admins"]["username"]:
+                admins += i
+            print("Our Esteemed Admins >> " + admins)
+            members = ""
+            for i in iterate["Members"]["username"]:
+                members += i
+            print("Our Esteemed Members >> " + members)
+            print()
+            print()
+            for chats in iterate["Chats"]:
+                print(chats["username"] + " : " + chats["Message"])
+
+    def task1():
+        mydb = myclient["Chatbox"]
+        mycol = mydb["PublicChatGroups"]
+
+        for change in mycol.watch(full_document='updateLookup'):
+            print(change["fullDocument"]["Chats"][-1]["username"] + " : " + change["fullDocument"]["Chats"][-1]["Message"])
+
+    def task2():
+        while True:
+            p = str(input())
+            if p != "$_":
+                mydict = {"username": username, "Message": p}
+                PChat = mydb["PublicChatGroups"]
+                document = dict(PChat.find_one({'GName': x}))
+                document['Chats'].append(mydict)
+                PChat.update({'GName': x}, document)
+            else:
+                break
+        return 0
+
+    t1 = KThread(target=task1)
+    t1.start()
+    # print("here")
+    task2()
+    # print("here1")
+    # print("here")
+    t1.kill()
+    # t2.start()
+    # t2.join()
+    # print(t1.is_alive())

PublicChats.py

@@ -66,11 +66,11 @@ def Write_Message(iterate):
 
 
 def GlobalChat(username, ChangeStreamVaraible):
-    import ChangeStream
-    ChangeStream.main(username)
+    import GlobalChat
+    GlobalChat.main(username)
     # import os
     # os.system("exec ChangeStream")
-    # subprocess.call(['python', 'ChangeStream.py'])
+    # subprocess.call(['python', 'GlobalChat.py'])
     KahesiModeOnn(username)
 
 def PuGrp(username):
@@ -93,6 +93,9 @@ def PuGrp(username):
     print("Enter 1 To Join a new Group")
     print("Enter Group Name To Chat")
     x = input()
+    import PublicChats
+    PublicChats.main(username, x)
+
     KahesiModeOnn(username)
 
 
@@ -199,9 +202,12 @@ def NPuGrp(username):
               "Members": {
                   "username": [username]
               },
-              "Chats": {
-                  username: "Booyahh! Welcome To My Own Public Group"
-              }
+              "Chats": [
+                  {
+                      "username": username,
+                      "Message": "Booyahh! Welcome To My Own Public Group"
+                  }
+              ]
               }
     x = mycol.insert_one(mydict)
     print("New Group Has Been Created Successfully")