changes

app/gmail_auth.py

@@ -3,48 +3,45 @@ from pathlib import Path
 from app.core.config import settings
 
 # CREATE TEMP DIRECTORY
-
 AUTH_DIR = Path("/tmp/google_auth")
 AUTH_DIR.mkdir(parents=True, exist_ok=True)
 
 # FULL FILE PATHS
-
 CREDENTIALS_PATH = AUTH_DIR / "credentials.json"
 TOKEN_PATH = AUTH_DIR / "token.json"
 
-# CREATE FILES FROM HF SECRETS
-
-if not CREDENTIALS_PATH.exists():
+# FORCE CREATE/VERIFY FILES AT RUNTIME
+# (Removed 'if not exists' check to ensure they always write correctly from HF Secrets)
+if "GOOGLE_CREDENTIALS" in os.environ:
     CREDENTIALS_PATH.write_text(os.environ["GOOGLE_CREDENTIALS"])
+else:
+    raise ValueError("GOOGLE_CREDENTIALS secret is missing from environment variables!")
 
-if not TOKEN_PATH.exists():
+if "GOOGLE_TOKEN" in os.environ:
     TOKEN_PATH.write_text(os.environ["GOOGLE_TOKEN"])
+else:
+    raise ValueError("GOOGLE_TOKEN secret is missing from environment variables!")
 
 # GMAIL IMPORTS
-
 from langchain_google_community.gmail.utils import (
     build_resource_service,
     get_gmail_credentials,
 )
-
 from langchain_google_community import GmailToolkit
 
-# LOAD CREDENTIALS
-
+# LOAD CREDENTIALS - Fixed parameter name to 'client_secrets_file'
 credentials = get_gmail_credentials(
-    token_file=str(TOKEN_PATH),
+    token_file=str(TOKEN_PATH.resolve()),
     scopes=["https://mail.google.com/"],
-    client_sercret_file=str(CREDENTIALS_PATH),
+    client_sercrets_file=str(CREDENTIALS_PATH.resolve()),  # <-- Fixed typo here
 )
 
 # BUILD API RESOURCE
-
 api_resource = build_resource_service(
     credentials=credentials
 )
 
 # TOOLKIT
-
 gmail_toolkit = GmailToolkit(
     api_resource=api_resource
-)
+)

app/nodes/check_email_exist_node.py

@@ -1,11 +1,11 @@
 
 from app.state.state import EmailAgentState
 from langchain_google_community import GmailToolkit
+from app.gmail_auth import gmail_toolkit ,api_resource
 
 def check_previous_email_exist_node(state: EmailAgentState):
     # Search for previous interactions with this sender
-    toolkit = GmailToolkit()
-    search_tool = [t for t in toolkit.get_tools() if t.name == "search_gmail"][0]
+    search_tool = [t for t in gmail_toolkit.get_tools() if t.name == "search_gmail"][0]
     results = search_tool.invoke(f"from:{state['sender_email_id']}")
 
     if len(results) == 0:

authenticate_gmail.py

@@ -1,29 +1,29 @@
-import os
-from google_auth_oauthlib.flow import InstalledAppFlow
+# import os
+# from google_auth_oauthlib.flow import InstalledAppFlow
 
-# Gmail API scope
-SCOPES = [
-    "https://mail.google.com/"
-]
+# # Gmail API scope
+# SCOPES = [
+#     "https://mail.google.com/"
+# ]
 
-def run_authentication():
-    print("Starting Google OAuth Authentication Flow...")
+# def run_authentication():
+#     print("Starting Google OAuth Authentication Flow...")
 
-    if not os.path.exists("credentials.json"):
-        print("ERROR: Please place your 'credentials.json' file in this folder first!")
-        return
+#     if not os.path.exists("credentials.json"):
+#         print("ERROR: Please place your 'credentials.json' file in this folder first!")
+#         return
 
-    flow = InstalledAppFlow.from_client_secrets_file(
-        "credentials.json",
-        SCOPES
-    )
+#     flow = InstalledAppFlow.from_client_secrets_file(
+#         "credentials.json",
+#         SCOPES
+#     )
 
-    creds = flow.run_local_server(port=8080)
+#     creds = flow.run_local_server(port=8080)
 
-    with open("token.json", "w") as token_file:
-        token_file.write(creds.to_json())
+#     with open("token.json", "w") as token_file:
+#         token_file.write(creds.to_json())
 
-    print("\nSUCCESS: 'token.json' has been created successfully!")
+#     print("\nSUCCESS: 'token.json' has been created successfully!")
 
-if __name__ == "__main__":
-    run_authentication()
+# if __name__ == "__main__":
+#     run_authentication()