Upload folder using huggingface_hub

app/xero_client.py

@@ -1,10 +1,12 @@
 import logging
-import os
+# os is no longer needed for token persistence
 import json
 import time
 import requests
 from functools import wraps
 from flask import current_app, redirect, url_for, session, request
+# Import the mongo instance from your extensions file
+from .extensions import mongo
 
 logger = logging.getLogger(__name__)
 
@@ -80,7 +82,7 @@ def initialize_zoho_sdk(grant_token=None, accounts_server_url=None):
             config = current_app.config
             
             # Use the dynamically provided accounts_server_url or default to .in
-            base_accounts_url = accounts_server_url if accounts_server_url else 'https://accounts.zoho.in'
+            base_accounts_url = accounts_server_url if accounts_server_url else 'https://accounts.zohocloud.ca'
             token_url = f'{base_accounts_url}/oauth/v2/token'
             logger.info(f"Using token exchange URL: {token_url}")
 
@@ -119,21 +121,28 @@ def initialize_zoho_sdk(grant_token=None, accounts_server_url=None):
         logger.debug("initialize_zoho_sdk called without grant token. No action taken.")
 
 def _get_stored_token():
-    """Reads token data from the persistence file."""
-    token_path = current_app.config['ZOHO_TOKEN_PERSISTENCE_PATH']
-    if not os.path.exists(token_path):
-        return None
+    """Reads token data from MongoDB."""
     try:
-        with open(token_path, 'r') as f:
-            return json.load(f)
-    except (json.JSONDecodeError, FileNotFoundError):
+        # Use a consistent identifier for the single token document
+        token_doc = mongo.db.zoho_tokens.find_one({'_id': 'zoho_oauth_token'})
+        if token_doc:
+            # The _id is not part of the token data itself, remove it
+            token_doc.pop('_id', None)
+        return token_doc
+    except Exception as e:
+        logger.error(f"Error reading Zoho token from MongoDB: {e}", exc_info=True)
         return None
 
 def _save_token(token_data):
-    """Saves token data to the persistence file."""
-    token_path = current_app.config['ZOHO_TOKEN_PERSISTENCE_PATH']
-    with open(token_path, 'w') as f:
-        json.dump(token_data, f)
+    """Saves token data to MongoDB."""
+    try:
+        mongo.db.zoho_tokens.update_one(
+            {'_id': 'zoho_oauth_token'},
+            {'$set': token_data},
+            upsert=True
+        )
+    except Exception as e:
+        logger.error(f"Error saving Zoho token to MongoDB: {e}", exc_info=True)
 
 def _refresh_access_token():
     """Uses the refresh token to get a new access token from the correct data center."""
@@ -147,7 +156,7 @@ def _refresh_access_token():
         config = current_app.config
         
         # Use the stored accounts_server or default for backward compatibility
-        base_accounts_url = stored_token.get('accounts_server', 'https://accounts.zoho.in')
+        base_accounts_url = stored_token.get('accounts_server', 'https://accounts.zohocloud.ca')
         token_url = f'{base_accounts_url}/oauth/v2/token'
         logger.info(f"Using token refresh URL: {token_url}")
 
@@ -189,19 +198,21 @@ def get_access_token():
     return token.get('access_token')
 
 def is_zoho_token_available():
-    """Checks if a refresh token has been persisted in the file store."""
+    """Checks if a refresh token has been persisted in MongoDB."""
     token = _get_stored_token()
     return token is not None and 'refresh_token' in token
 
 def clear_zoho_token():
-    """Removes the persisted token file to effectively log out."""
-    token_path = current_app.config['ZOHO_TOKEN_PERSISTENCE_PATH']
-    if os.path.exists(token_path):
-        try:
-            os.remove(token_path)
-            logger.info("Zoho token file removed successfully.")
-        except OSError as e:
-            logger.error(f"Error removing Zoho token file: {e}")
+    """Removes the persisted token from MongoDB to effectively log out."""
+    try:
+        result = mongo.db.zoho_tokens.delete_one({'_id': 'zoho_oauth_token'})
+        if result.deleted_count > 0:
+            logger.info("Zoho token removed from MongoDB successfully.")
+        else:
+            logger.warning("Attempted to clear Zoho token, but none was found in MongoDB.")
+    except Exception as e:
+        logger.error(f"Error removing Zoho token from MongoDB: {e}", exc_info=True)
+
 
 def zoho_token_required(function):
     """
@@ -213,5 +224,4 @@ def zoho_token_required(function):
             session['next_url'] = request.url
             return redirect(url_for("zoho.login"))
         return function(*args, **kwargs)
-    return decorator
-    
+    return decorator

app/xero_routes.py

@@ -63,7 +63,7 @@ def login():
         'access_type': 'offline',
         'redirect_uri': config['ZOHO_REDIRECT_URL']
     }
-    accounts_url = 'https://accounts.zoho.in/oauth/v2/auth'
+    accounts_url = 'https://accounts.zohocloud.ca/oauth/v2/auth'
     auth_url = f"{accounts_url}?{urllib.parse.urlencode(params)}"
     return redirect(auth_url)
 
@@ -95,14 +95,14 @@ def logout():
 
 
 @zoho_bp.route("/api/inventory")
-@zoho_token_required
+# @zoho_token_required
 def inventory_sync_page():
     """Renders the page that will display the sync progress bar."""
     return render_template("inventory_sync.html", title="Inventory Sync")
 
 
 @zoho_bp.route("/api/inventory/stream")
-@zoho_token_required
+# @zoho_token_required
 def fetch_inventory_stream():
     """
     Performs the inventory sync and streams progress updates to the client.

run.py

@@ -4,4 +4,4 @@ os.environ['OAUTHLIB_INSECURE_TRANSPORT'] = '1'
 app = create_app()
 
 if __name__ == '__main__':
-    app.run(host="0.0.0.0",debug=True, port=7860)
+    app.run(host="0.0.0.0",debug=False, port=7860)