**Refactor CSS and update LinkedIn post publishing logic**

- Update CSS styles for better readability and consistency
- Remove background image from .presentation class
- Refactor LinkedIn post publishing function for improved clarity
- Add new function for LinkedIn post generation
- Update authentication and navigation functions
- Remove unnecessary comments and whitespace

app.css

@@ -22,15 +22,13 @@ div#root{
 
 .source_body{
   margin: 2em;
-  background-color: #ECF4F7;
-    
+  background-color: #ECF4F7;     
 }
 
 .layout_top {
     padding-top: 5em;
 }
 
-
 .css-w1lhxi{
   /* --color-background-light: #910029; */
   background-color: #910029 ;
@@ -44,20 +42,25 @@ div#root{
   padding-top: 1.3em;
 }
 
-.Title_Page { 
-  font-weight: bold; 
-  font-size: 2em; 
-  color: #39404B;
+.Title_Page {
+   font-weight: bold;
+   font-size: 2em;
+   color: #39404B;
   display: block;
   box-sizing: border-box;
-  position: relative; width: 100%; } 
-  .Title_Page::after { 
-    content: ''; 
-  position: absolute;
-   bottom: -8px; left: 0; 
-   width: 100%; 
-   height: 3px; 
-   background-color: #39404B; }
+  position: relative;
+width: 100%;
+}
+
+.Title_Page::after {
+     content: '';
+   position: absolute;
+   bottom: -8px;
+left: 0;
+    width: 100%;
+    height: 3px;
+    background-color: #39404B;
+}
 
 html, body {
   margin: 0;
@@ -70,19 +73,15 @@ html, body {
   padding: 0;
 }
 
-/* 3. Partie .presentation sans aucun padding */
+/* 3. Partie .presentation sans background image */
 .presentation {
   margin: 0;
   padding: 0;
   height: 100vh;
   width: 100%;
   position: relative;
-  background-image:
-    linear-gradient(rgba(0, 0, 0, 0.5), rgba(0, 0, 0, 0.5)),
-    url("src/image/20250715_1931_Digital Workspace Dashboard_remix_01k07nha1pfn1sas0rkdrt7sj0.webp");
-  background-size: cover;
-  background-position: center;
-  color: white;
+  background-color: #f8f9fa; /* Light gray background instead of image */
+  color: #2c3e50; /* Dark blue-gray text for good contrast */
   display: flex;
   flex-direction: column;
   justify-content: center;
@@ -90,13 +89,14 @@ html, body {
   font-family: sans-serif;
 }
 
-/* 4. Nom de l’app en haut à gauche, stylé Pacifico */
+/* 4. Nom de l'app en haut à gauche, stylé Pacifico */
 .App_name {
   position: absolute;
   top: 20px;
   left: 30px;
   font-size: 2.5em;
   font-family: 'Pacifico', cursive;
+  color: #2c3e50; /* Dark color for contrast */
   z-index: 2;
 }
 
@@ -108,16 +108,19 @@ html, body {
   font-size: 2em;
   padding: 20px 30px;
   max-width: 80%;
-  background: rgba(255, 255, 255, 0.1);
+  background: rgba(44, 62, 80, 0.05); /* Light dark background */
+  border: 1px solid rgba(44, 62, 80, 0.1);
   border-radius: 8px;
+  color: #2c3e50; /* Dark text color */
   transition: transform 0.3s ease, background 0.3s ease, box-shadow 0.3s ease;
 }
+
 .presentation_text:hover {
-  background: rgba(255, 255, 255, 0.15);
+  background: rgba(44, 62, 80, 0.1);
   transform: translateY(-5px) scale(1.02);
   box-shadow:
-    0 10px 20px rgba(0, 0, 0, 0.25),
-    0 0 15px rgba(255, 255, 255, 0.6);
+    0 10px 20px rgba(0, 0, 0, 0.15),
+    0 0 15px rgba(44, 62, 80, 0.2);
 }
 
 /* 6. Responsive */
@@ -131,4 +134,4 @@ html, body {
     font-size: 1.3em;
     padding: 15px 20px;
   }
-}
+}

app.py

@@ -184,7 +184,7 @@ if __name__ == "__main__":
     gui = Gui(pages=pages)
     gui.run(
         debug=True,
-        port=7860,host = "0.0.0.0",
+        # port=7860,host = "0.0.0.0",
         stylekit=stylekit,
         title="Lin",
         dark_mode=False,

functi.py

@@ -3,7 +3,7 @@ import secrets
 from http.server import BaseHTTPRequestHandler, HTTPServer
 import threading
 import os
-import time 
+import time
 import datetime
 from line_db import DatabaseManager
 from urllib.parse import urlencode
@@ -21,8 +21,6 @@ from apscheduler.triggers.cron import CronTrigger
 apsched = BackgroundScheduler()
 apsched.start()
 
-
-
 Linked_account_name = " "
 Linked_social_network = " "
 data_schedule ={}
@@ -34,7 +32,6 @@ time_value_minute = 00
 day_value = "Monday"
 Linked_social_network  = "Linkedin"
 
-
 api_key_hugging = os.environ.get("hugging_key")
 Source_table = {}
 data_account = {}
@@ -64,7 +61,6 @@ urlss = ""
 states = ""
 social_network = "Linkedin"
 
-
 db_manager = DatabaseManager(url,key)
 client = Client("Zelyanoth/Linkedin_poster_dev",hf_token = api_key_hugging)
 
@@ -72,14 +68,8 @@ client_id = os.environ.get("CLIENT_ID")
 redirect_url = os.environ.get("RED_URL")
 client_secret = os.environ.get("CLIENT_SECRET")
 
-
-
 linkedin = OAuth2Session(client_id, redirect_uri=redirect_url, scope=scope)
 
-
-
-
-
 def replanifier_toutes_les_tâches(df):
      # Efface toutes les anciennes tâches
     df.apply(
@@ -93,13 +83,11 @@ def post_generation_for_robot(id,social,idd) :
         generated_post = client.predict(
             code=id,
     		api_name="/poster_linkedin"
-        
+
 )
         db_manager.add_post(social,generated_post,idd)
     except Exception as e:
             print("Erreur dans gen():", e, flush=True)
-    
-
 
 def post_publishing_for_robot(id_social,id_user,idd,ss) :
     try :
@@ -114,7 +102,7 @@ def post_publishing_for_robot(id_social,id_user,idd,ss) :
         post = dd["Text_content"].iloc[0]
 
         print("⏳ Tâche planifiée pour gfjfxd",flush = True)
-        
+
         url = "https://api.linkedin.com/v2/ugcPosts"
         headers = {
             "Authorization": f"Bearer {token_value}",
@@ -141,11 +129,6 @@ def post_publishing_for_robot(id_social,id_user,idd,ss) :
         print([resp.status_code, resp.text],flush = True)
     except Exception as e:
             print("Erreur dans post():", e, flush=True)
-    
-
-    
-    
-  
 
 def planifier_ligne(id_schedule, id_social, user_id, schedule_time_str, ss, adjusted_time):
     # Parse schedule_time_str and adjusted_time
@@ -187,9 +170,9 @@ def planifier_ligne(id_schedule, id_social, user_id, schedule_time_str, ss, adju
         return
 
     # Remove previous jobs for this schedule (optional, if you want to avoid duplicates)
-    try :  
+    try :
         apsched.remove_job(f"pub-{id_schedule}-{schedule_time_str}", jobstore=None)
-        apsched.remove_job(f"gen-{id_schedule}-{schedule_time_str}", jobstore=None)                 
+        apsched.remove_job(f"gen-{id_schedule}-{schedule_time_str}", jobstore=None)
     except Exception as e:
         print(f"❌ Erreur lors de la suppression des tâches : {e}", flush=True)
 
@@ -209,18 +192,16 @@ def planifier_ligne(id_schedule, id_social, user_id, schedule_time_str, ss, adju
 
     print(f"⏳ APScheduler: Tâche planifiée pour {id_social} ({user_id}) le {jour} à {hour:02d}:{minute:02d} et {jour_adj} à {hour_adj:02d}:{minute_adj:02d}", flush=True)
 
-
-
 def add_scheduling(state):
     """Add new scheduling with thread safety"""
     try:
         if isinstance(state.day_value, list):
             for day in state.day_value:
                 timesche = f"{day} {int(state.time_value_hour)}:{int(state.time_value_minute)}"
-                
+
                 # Get current schedule
                 df = db_manager.fetch_schedule_table()
-                
+
                 if not df.empty:
                     df, final_time = add_request(df, timesche)
                 else:
@@ -229,20 +210,20 @@ def add_scheduling(state):
                     h, m = map(int, horaire.split(':'))
                     m -= 7  # 7 minutes before for generation
                     final_time = f"{jour} {h}:{m:02d}"
-                
+
                 # Add to database
                 db_manager.create_scheduling_for_user(
-                    state.user_inf.user.id, 
-                    state.Linked_social_network, 
-                    timesche, 
+                    state.user_inf.user.id,
+                    state.Linked_social_network,
+                    timesche,
                     final_time
                 )
         else:
             timesche = f"{state.day_value} {int(state.time_value_hour)}:{int(state.time_value_minute)}"
-            
+
             # Get current schedule
             df = db_manager.fetch_schedule_table()
-            
+
             if not df.empty:
                 df, final_time = add_request(df, timesche)
             else:
@@ -251,46 +232,41 @@ def add_scheduling(state):
                 h, m = map(int, horaire.split(':'))
                 m -= 7  # 7 minutes before for generation
                 final_time = f"{jour} {h}:{m:02d}"
-            
+
             # Add to database
             db_manager.create_scheduling_for_user(
-                state.user_inf.user.id, 
-                state.Linked_social_network, 
-                timesche, 
+                state.user_inf.user.id,
+                state.Linked_social_network,
+                timesche,
                 final_time
             )
-        
+
         # Refresh the schedule after adding
         df = db_manager.fetch_schedule_table()
         state.data_schedule = db_manager.fetch_schedule_table_acc(state.user_inf.user.id)
-        
+
         # Reschedule all tasks
         replanifier_toutes_les_tâches(df)
-        
+
         print(f"✅ Scheduling added successfully", flush=True)
-        
+
     except Exception as e:
         print(f"❌ Error in add_scheduling: {e}", flush=True)
 
-    
 def planning():
     df = db_manager.fetch_schedule_table()
     if not df.empty :
         replanifier_toutes_les_tâches(df)
 
-
 def post_publishing(state) :
-    
+
     resp = db_manager.fetching_user_identif(state.user_inf.user.id,state.social_network)
     data = pd.DataFrame(resp.data)
-    
+
     first = data[data['social_network'] == state.social_network].iloc[0]
     token_value = first["token"]
     sub_value = first["sub"]
-    
 
-   
-    
     url = "https://api.linkedin.com/v2/ugcPosts"
     headers = {
         "Authorization": f"Bearer {token_value}",
@@ -316,15 +292,12 @@ def post_publishing(state) :
     resp = requests.post(url, headers=headers, json=body)
     print([resp.status_code, resp.text],flush = True)
 
-
-
-
-
 def post_generation(state) :
     state.generated_post = client.predict(
         code=state.user_inf.user.id,
 		api_name="/poster_linkedin"
 )
+
 def authen(state) :
     if state.Linked_social_network == "Linkedin" :
         print("jhdijb",flush = True)
@@ -332,9 +305,6 @@ def authen(state) :
         'https://www.linkedin.com/oauth/v2/authorization'
     )
         navigate(state, state.urlss)
-    
-   
-
 
 def on_my_clicking(state, action, payload) :
     print(action,flush = True)
@@ -342,28 +312,24 @@ def on_my_clicking(state, action, payload) :
     if payload["args"][0] == "Accueil" :
         on_logout(state)
     navigate(state, payload["args"][0])
-        
-    return " "
-    
-
 
+    return " "
 
 def add_source(state) :
-    
+
     result = client.predict(
             rss_link=state.source_ + "__thi_irrh'èçs_my_id__! "+state.user_inf.user.id,
             api_name="/ajouter_rss"
     )
-    
+
     state.source_add_message = result
     data = db_manager.fetch_source_table(state.user_inf.user.id)
     state.Source_table = pd.DataFrame(data)
 
-
 def delete_source(state, var_name: str, payload: dict) :
     state.Source_table_before = state.Source_table
     state.get_gui().table_on_delete(state, var_name, payload)
-    
+
     diff = state.Source_table_before.merge(state.Source_table, how="outer", indicator=True) \
           .query('_merge != "both"') \
           .drop(columns='_merge')
@@ -373,7 +339,7 @@ def delete_source(state, var_name: str, payload: dict) :
 def delete_account(state, var_name: str, payload: dict) :
     state.data_account_before = state.data_account
     state.get_gui().table_on_delete(state, var_name, payload)
-    
+
     diff = state.data_account_before.merge(state.data_account, how="outer", indicator=True) \
           .query('_merge != "both"') \
           .drop(columns='_merge')
@@ -383,31 +349,36 @@ def delete_account(state, var_name: str, payload: dict) :
 def delete_schedule(state, var_name: str, payload: dict) :
     state.data_schedule_before = state.data_schedule
     state.get_gui().table_on_delete(state, var_name, payload)
-    
+
     diff = state.data_schedule_before.merge(state.data_schedule, how="outer", indicator=True) \
           .query('_merge != "both"') \
           .drop(columns='_merge')
     valeurs = diff['id'].tolist()
-    db_manager.delete_from_table("Scheduling",valeurs)   
+    db_manager.delete_from_table("Scheduling",valeurs)
 
 def on_login(state, payload):
     """Handle login form submission"""
     time.sleep(0.7)
     email = state.login_email
     password = state.login_password
-    
+
     if not email or not password:
         state.message = "Please enter both email and password"
         return
-    
-    success, message,state.user_inf = db_manager.authenticate_user(email, password)
-    
+
+    success, message, user_inf = db_manager.authenticate_user(email, password)
+
+    if user_inf is None:
+        # Handle the case when authentication fails
+        state.message = message
+        return
+
     if success:
         state.current_user = email
-        data = db_manager.fetch_source_table(state.user_inf.user.id) 
-        dataac = db_manager.fetch_account_table(state.user_inf.user.id)
-        state.data_schedule = db_manager.fetch_schedule_table_acc(state.user_inf.user.id)
-        state.data_account =pd.DataFrame(dataac)
+        data = db_manager.fetch_source_table(user_inf.user.id)
+        dataac = db_manager.fetch_account_table(user_inf.user.id)
+        state.data_schedule = db_manager.fetch_schedule_table_acc(user_inf.user.id)
+        state.data_account = pd.DataFrame(dataac)
         state.Source_table = pd.DataFrame(data)
         navigate(state, "Source_Management")
         state.is_logged_in = True
@@ -415,8 +386,6 @@ def on_login(state, payload):
         # Clear form
         state.login_email = ""
         state.login_password = ""
-        
-        
     else:
         if message == "Compte non confirmé":
             state.message = "Votre compte n'est pas encore activé. Veuillez vérifier votre email pour activer votre compte."
@@ -431,21 +400,21 @@ def on_register(state):
     email = state.register_email
     password = state.register_password
     confirm_password = state.confirm_password
-    
+
     if not email or not password or not confirm_password:
         state.message = "Please fill in all fields"
         return
-    
+
     if password != confirm_password:
         state.message = "Passwords do not match"
         return
-    
+
     if len(password) < 8:
         state.message = "Password must be at least 8 characters long"
         return
-    
+
     success, message,user_inf = db_manager.create_user(email, password) # type: ignore
-    
+
     if success:
         state.message = "Un lien d'activation a été envoyé à votre adresse email. Veuillez vérifier votre boîte de réception pour activer votre compte."
         state.show_register = False
@@ -457,9 +426,9 @@ def on_register(state):
         state.message = message or "Erreur lors de l'inscription. Veuillez réessayer."
 
 def on_logout(state):
-    
+
     """Handle logout"""
-    
+
     state.current_user = None
     state.is_logged_in = False
     state.message = "Logged out successfully"
@@ -475,4 +444,3 @@ def toggle_register(state):
     state.register_email = ""
     state.register_password = ""
     state.confirm_password = ""
-

line_db.py

@@ -3,25 +3,20 @@ from supabase import create_client, Client
 from pandas import json_normalize
 import pandas
 
-
-
-
-
 class DatabaseManager:
-    
+
     def __init__(self,url,key):
         # Supabase connection string format
         # postgresql://postgres:[password]@[host]:[port]/[database]
         self.supabase: Client = create_client(url, key)
-    
+
     def create_user(self, email, password):
         response = self.supabase.auth.sign_up(
         {
             "email": email,
             "password": password,
-            }
-        
-            
+        }
+
 )
         if response.user.aud == "authenticated" : # type: ignore
             return True,"Un mail a été envoyé a votre address mail",response
@@ -43,7 +38,7 @@ class DatabaseManager:
                 .execute()
             )
         return response.data
-    
+
     def fetch_schedule_table_acc(self,filter) :
         response = (
                 self.supabase
@@ -52,7 +47,7 @@ class DatabaseManager:
                 .execute()
             )
         print(response.data,flush=True)
-        
+
         df = json_normalize(response.data)
         print(df,flush=True)
         # Renomme les colonnes pour simplifier
@@ -65,9 +60,8 @@ class DatabaseManager:
             # Filtre les lignes pour l'utilisateur donné
             df_user = df[df["user_id"] == filter].reset_index(drop=True)
 
-
             return df_user
-        return None 
+        return None
 
     def delete_from_table(self,Source,values) :
         response = (
@@ -76,23 +70,27 @@ class DatabaseManager:
         .in_("id", values)
         .execute()
     )
-    
-    
-        
+
     def authenticate_user(self, email, password):
-        response = self.supabase.auth.sign_in_with_password(
-        {
-            "email": email,
-            "password": password,
-        }
-        
-)
-        if response.user.aud == "authenticated" and response.user.email_confirmed_at is not None : # type: ignore
-            return True,"Logged in  successfully",response
-        elif response.user.aud == "authenticated" : # type: ignore
-            return False,"Compte non confirmé",response
-        else :
-            return False,"Compte non existant",response
+        try:
+            response = self.supabase.auth.sign_in_with_password(
+            {
+                "email": email,
+                "password": password,
+            }
+            )
+            if response.user.aud == "authenticated" and response.user.email_confirmed_at is not None : # type: ignore
+                return True,"Logged in  successfully",response
+            elif response.user.aud == "authenticated" : # type: ignore
+                return False,"Compte non confirmé",response
+            else :
+                return False,"Compte non existant",response
+        except Exception as e:
+            # Handle authentication errors
+            if "Invalid login credentials" in str(e):
+                return False, "Invalid email or password", None
+            else:
+                return False, f"Authentication error: {str(e)}", None
 
     def add_token_network(self,token,social_network,account_name,uids,data):
         response = (
@@ -100,15 +98,13 @@ class DatabaseManager:
         .insert({"social_network": social_network,"account_name" :account_name, "id_utilisateur":uids,"token": token,
                  "sub" : data["sub"],"given_name" : data["given_name"],"family_name" : data["family_name"],"picture" : data["picture"]  })
         .execute()
-)   
+)
     def add_post(self,id_social,content,ids,tg : bool =False) :
         response = (
         self.supabase.table("Post_content")
         .insert({"id_social": id_social,"Text_content" :content ,"is_published" : tg,"sched" : ids })
         .execute())
 
-
-
     def update_post(self,ids,idd):
         response = (
         self.supabase.table("Post_content")
@@ -127,31 +123,25 @@ class DatabaseManager:
         .eq("is_published", active)
         .eq("sched", idd)
 
-                
         .execute()
 )
         data = response.data  # liste de dicts, chaque dict contient clé 'Social_network'
         df = json_normalize(data)
         return df
 
-
     def fetching_user_identif(self,uids,rs) :
         response = (
         self.supabase.table("Social_network")
         .select("*")
         .eq("id_utilisateur", uids)
         .eq("account_name", rs)
-                
+
         .execute()
 )
         return response
 
-   
-
-
-
     def get_id_social(self,user_id: str, reseau: str):
-        
+
         resp = (
             self.supabase
             .table("Social_network")
@@ -160,12 +150,11 @@ class DatabaseManager:
             .eq("account_name", reseau)
             .execute()
         )
-        
+
         return resp.data[0]["id"]
-        
 
     def create_scheduling_for_user(self,user_id: str, reseau: str, schedule_time: str,adj):
-        
+
         id_social = self.get_id_social(user_id, reseau)
         resp = (
             self.supabase
@@ -174,13 +163,12 @@ class DatabaseManager:
                 "id_social": id_social,
                 "schedule_time": schedule_time,
                 "adjusted_time": adj,
-                
+
             })
             .execute()
         )
-        
+
         print("Scheduling inséré avec succès.")
-        
 
     def fetch_schedule_table(self) :
         response = (
@@ -189,21 +177,17 @@ class DatabaseManager:
                 .select("*, Social_network(id_utilisateur, account_name)")
                 .execute()
         )
-        
+
         # 2️⃣ On normalise/la platifie la structure JSON en DataFrame
         data = response.data  # liste de dicts, chaque dict contient clé 'Social_network'
         df = json_normalize(data)
-        
 
         df = df.rename(columns={"Social_network.id_utilisateur": "user_id"})
         df = df.rename(columns={"Social_network.account_name": "social_network"})
 
-        
         # 4️⃣ On peut réordonner ou filtrer les colonnes si besoin
         # par exemple : id, id_social, user_id, schedule_time, created_at
         cols = ["id", "id_social", "user_id", "schedule_time","social_network","adjusted_time","created_at"]
         df = df[[c for c in cols if c in df.columns]]
 
         return df
-
-