Ensured smoudth message arrival to all clints

Author: offiicialkamal

API/DATABASE/__pycache__/connect.cpython-312.pyc

@@ -22,7 +22,9 @@ def connect_messages():
                 if not os.path.exists('DB'):
                         os.makedirs('DB')
                 return sqlite3.connect(path)
-                
+
+        
+        @staticmethod        
         def connect_chat_lists_db():
                 path = "DB/chats_lists.db"
                 if not os.path.exists("DB"):

API/DATABASE/__pycache__/createDatabase.cpython-312.pyc

@@ -1,11 +1,11 @@
-import sqlite3
-import os
+# import sqlite3
+# import os
 from .connect import database
 
+
 class create_database():
     def __init__(self):
         pass
-    
     @staticmethod
     def create_users_database():
         CREDENTIAL_DATABASE_CONNECTED = database.connect_users_db()
@@ -34,8 +34,8 @@ def create_users_database():
                 cursor.close()
                 return True
             except Exception as e:
-                print("error on create_users_database():",e)
-                return False
+                print("error on create_users_database():", e)
+                return None
             finally:
                 if CREDENTIAL_DATABASE_CONNECTED:
                     CREDENTIAL_DATABASE_CONNECTED.close()
@@ -49,7 +49,8 @@ def create_chats_table_for_this_new_user(RAW_UID):
         if CHATS_DATABASE_CONNECTED:
             try:
                 cursor = CHATS_DATABASE_CONNECTED.cursor()
-                cursor.execute(f"""CREATE TABLE IF NOT EXISTS CHATS_{str(UID)} (
+                cursor.execute(
+                    f"""CREATE TABLE IF NOT EXISTS CHATS_{str(UID)} (
                             GUID INTEGER PRIMARY KEY AUTOINCREMENT,
                             GNAME TEXT,
                             PROFILE_PIC,
@@ -59,8 +60,10 @@ def create_chats_table_for_this_new_user(RAW_UID):
                 cursor.close()
                 return True
             except Exception as e:
-                print("error on create_chats_table_for_this_new_user(RAW_UID):",e)
-                return False
+                print(
+                    "error on create_chats_table_for_this_new_user(RAW_UID):",
+                    e)
+                return None
             finally:
                 if CHATS_DATABASE_CONNECTED:
                     CHATS_DATABASE_CONNECTED.close()
@@ -69,12 +72,13 @@ def create_chats_table_for_this_new_user(RAW_UID):
 
     @staticmethod
     def create_chat_database_table(GROUP_ID):
-      #  TABLE_NAME = str(GUID)
+        #  TABLE_NAME = str(GUID)
         CHAT_DATABASE_CONNECTED = database.connect_messages()
         if CHAT_DATABASE_CONNECTED:
             try:
                 cursor = CHAT_DATABASE_CONNECTED.cursor()
-                cursor.execute(f"""CREATE TABLE IF NOT EXISTS G_{str(GROUP_ID)} (
+                cursor.execute(
+                    f"""CREATE TABLE IF NOT EXISTS G_{str(GROUP_ID)} (
                                     MESSAGE_ID INTEGER PRIMARY KEY AUTOINCREMENT,
                                     SENDER_ID INTEGER,
                                     SENDER_NAME TEXT,
@@ -87,18 +91,19 @@ def create_chat_database_table(GROUP_ID):
                 return True
             except Exception as e:
                 print("error on create_chat_database_table(GROUP_ID):", e)
-                return False
+                return None
             finally:
                 if CHAT_DATABASE_CONNECTED:
                     CHAT_DATABASE_CONNECTED.close()
         else:
             print(' unable to comunicate with chat tables database')
-    
+
     @staticmethod
     def create_message_list_database():
+        connection = None
         try:
             connection = database.connect_chat_lists_db()
-            if  connection:
+            if connection:
                 cursor = connection.cursor()
                 cursor.execute("""
                                 CREATE TABLE IF NOT EXISTS all_chats (
@@ -117,5 +122,3 @@ def create_message_list_database():
         finally:
             if connection:
                 connection.close()
-    
-        

API/DATABASE/__pycache__/get_data.cpython-312.pyc

@@ -1,8 +1,8 @@
 from .connect import database
 from .createDatabase import create_database
-from datetime import datetime
-import sys
-import json
+# from datetime import datetime
+# import sys
+# import json
 
 
 class get:
@@ -188,17 +188,14 @@ def uid_by_cookie(COOKIE):
         connection = None
         uid = None
         try:
-            
             connection = database.connect_users_db()
             if connection:
+                print("connection sucessfull")
                 cursor = connection.cursor()
-
-                cursor.execute(
-                    """
-                                SELECT UID FROM users WHERE COOKIE=?
-                                """, (COOKIE, ))
-
+                cursor.execute("""SELECT UID FROM users WHERE COOKIE=?""",
+                               (COOKIE, ))
                 row = cursor.fetchone()
+                print(row)
                 uid = row[0] if row else None
                 cursor.close()
             return uid
@@ -276,9 +273,10 @@ def profile_pic(*, UID=None, GUID=None):
         finally:
             if connection:
                 connection.close()
-                
+
     @staticmethod
     def first_name(RAW_UID: str):
+        connection = None
         UID = int(RAW_UID)
         try:
             connection = database.connect_users_db()
@@ -300,7 +298,9 @@ def first_name(RAW_UID: str):
             if connection:
                 connection.close()
 
+    @staticmethod
     def last_name(RAW_UID):
+        connection = None
         UID = int(RAW_UID)
         try:
             connection = database.connect_users_db()
@@ -317,8 +317,11 @@ def last_name(RAW_UID):
             if connection:
                 connection.close()
 
+    @staticmethod
     def all_chats_json(RAW_UID):
+        connection = None
         UID = int(RAW_UID)
+        chats_json = {}
         try:
             connection = database.connect_chat_lists_db()
             if connection:
@@ -337,15 +340,17 @@ def all_chats_json(RAW_UID):
                         "CREATION_DATE": chat[3]
                     }
                 cursor.close()
-                return chats_json
+                return chats_json if chats_json else {}
         except Exception as e:
             print(f"erro while getting the chats of {UID} ==>> {e}")
-            return False
+            return {}
         finally:
             if connection:
                 connection.close()
-
+    @staticmethod
     def all_messages_json(limit, guid):
+        connection = None
+        messages_of_this_group_in_json_dict = {}
         try:
             connection = database.connect_messages()
             if connection:
@@ -360,7 +365,7 @@ def all_messages_json(limit, guid):
                                 """)
                 messages_of_this_group_in_json_dict = {}
                 rows_list_type = cursor.fetchall()
-                print(rows_list_type)
+                # print(rows_list_type)
                 for row_tupple in rows_list_type:
                     messages_of_this_group_in_json_dict[str(row_tupple[0])] = {
                         "SENDER_ID": row_tupple[1],
@@ -373,12 +378,13 @@ def all_messages_json(limit, guid):
                 return messages_of_this_group_in_json_dict
         except Exception as e:
             print("err on all_messages_json", e)
-            return False
+            return {}
         finally:
             if connection:
                 connection.close()
-
+    @staticmethod
     def all_personal_data(UID):
+        connection = None
         try:
             connection = database.connect_users_db()
             if connection:
@@ -389,9 +395,9 @@ def all_personal_data(UID):
                  """, (UID, ))
 
                 fc = cursor.fetchall()
-                print('its fc data', fc)
+                # print('its fc data', fc)
                 raw_data = fc[0]
-                print('its raw data', raw_data)
+                # print('its raw data', raw_data)
                 data = {
                     'FIRST_NAME': raw_data[1],
                     'LAST_NAME': raw_data[2],
@@ -405,7 +411,7 @@ def all_personal_data(UID):
                 return data
         except Exception as e:
             print(e)
-            return None
+            return {}
         finally:
             if connection:
                 connection.close()

API/DATABASE/__pycache__/update_data.cpython-312.pyc

@@ -3,6 +3,7 @@
 #in future ill add some more metjods like passwod mail number dob changing
 class update:
     def otp(new_otp, UID, COOKIE):
+        connection = None
         try:
             connection = database.connect_users_db()
             if connection:

API/DATABASE/__pycache__/write_data.cpython-312.pyc

@@ -2,8 +2,11 @@
 from .createDatabase import create_database
 from datetime import datetime
 class write_in_database:
+    
+    @staticmethod
     def add_user(FIRST_NAME, LAST_NAME, EMAIL, IS_MAIL_OTP, DOB, PHONE_NO, IP, CITY,PASSWORD, TOKEN, COOKIE, PROFILE_PIC):
         create_database.create_users_database()
+        connection = None
         try:
             connection = database.connect_users_db()
             cursor = connection.cursor()
@@ -35,9 +38,11 @@ def add_user(FIRST_NAME, LAST_NAME, EMAIL, IS_MAIL_OTP, DOB, PHONE_NO, IP, CITY,
     # ill use it when a user creates a group
     # it will add new group to all chats database
     # and additionally return that new groups uid
+    @staticmethod
     def add_group(GNAME, GUID=None):
         #create table if not exists
         create_database.create_message_list_database()
+        connection = None
         try:
             # imsert new group 
             connection = database.connect_chat_lists_db()
@@ -71,9 +76,11 @@ def add_group(GNAME, GUID=None):
     # this will add grpup to users table
     # this table will named by each users UID
     # this table will be returned to show all chat list for user
+    @staticmethod
     def add_user_in_group(RAW_UID ,RAW_GUID, GNAME):
         UID = int(RAW_UID)
         GUID = int(RAW_GUID)
+        connection = None
         try:
             ## uid is hader or name of create_chats_table_for_this_new_user
             ## GUID is groups uniq id
@@ -100,6 +107,7 @@ def add_user_in_group(RAW_UID ,RAW_GUID, GNAME):
     # it will store messages
     # each group id represents that specific table
     # this table contains all messages 
+    @staticmethod
     def store_this_message(GROUP_ID, SENDER_ID, SENDER_NAME, MESSAGE, PROFILE_PIC):
         create_database.create_chat_database_table(GROUP_ID)
         connection = None
@@ -112,13 +120,13 @@ def store_this_message(GROUP_ID, SENDER_ID, SENDER_NAME, MESSAGE, PROFILE_PIC):
             """, (int(SENDER_ID), SENDER_NAME, MESSAGE, PROFILE_PIC))
             connection.commit()
             MESSAGE_ID = cursor.lastrowid
-            print(MESSAGE_ID)
+            # print(MESSAGE_ID)
             cursor.execute(f"""
                             SELECT TIME_STAMP, PROFILE_PIC FROM G_{str(GROUP_ID)} WHERE MESSAGE_ID = ?
                             """,(MESSAGE_ID,))
 
             result = cursor.fetchone()
-            print(result)
+            # print(result)
             return MESSAGE_ID, result[0], result [1]
         except Exception as e:
             print("error on store_this_message(GROUP_ID, SENDER_ID, SENDER_NAME, MESSAGE):", e)