Update main.py

main.py

@@ -772,6 +772,9 @@ def get_admin_dashboard_stats():
         all_users_docs = list(db.collection('users').stream())
         all_orgs_docs = list(db.collection('organizations').stream())
         
+        # Log initial data collection
+        logging.info(f"Admin Dashboard: Retrieved {len(all_users_docs)} users and {len(all_orgs_docs)} organizations")
+        
         # Data structures for aggregation
         user_sales_data = {}
         global_item_revenue = {}    # Will now be nested: {item: {currency: total}}
@@ -800,6 +803,9 @@ def get_admin_dashboard_stats():
         user_stats = {'total': len(all_users_docs), 'admins': admin_count, 'approvedForBot': approved_users, 'pendingApproval': pending_approvals}
         org_stats = {'total': len(all_orgs_docs)}
 
+        # Log user processing results
+        logging.info(f"Admin Dashboard: User stats - Total: {user_stats['total']}, Admins: {user_stats['admins']}, Approved: {user_stats['approvedForBot']}, Pending: {user_stats['pendingApproval']}")
+
         # --- Second Pass: Aggregate all financial data ---
         sales_count = 0
         for phone in approved_phone_numbers:
@@ -809,6 +815,9 @@ def get_admin_dashboard_stats():
                 user_sales_data[phone] = {'total_revenue_by_currency': {}, 'item_sales': {}}
                 last_seen_currency_code = normalize_currency_code(phone_to_user_map.get(phone, {}).get('defaultCurrency'), 'USD')
 
+                user_sales_count = 0
+                user_expenses_count = 0
+                
                 for sale_doc in bot_user_ref.collection('sales').stream():
                     details = sale_doc.to_dict().get('details', {})
                     currency_code = normalize_currency_code(details.get('currency'), last_seen_currency_code)
@@ -820,6 +829,7 @@ def get_admin_dashboard_stats():
                     global_sales_rev_by_curr[currency_code] = global_sales_rev_by_curr.get(currency_code, 0) + sale_revenue
                     global_cogs_by_curr[currency_code] = global_cogs_by_curr.get(currency_code, 0) + (cost * quantity)
                     sales_count += 1
+                    user_sales_count += 1
                     
                     user_sales_data[phone]['total_revenue_by_currency'][currency_code] = user_sales_data[phone]['total_revenue_by_currency'].get(currency_code, 0) + sale_revenue
                     
@@ -836,10 +846,21 @@ def get_admin_dashboard_stats():
                     global_expenses_by_curr[currency_code] = global_expenses_by_curr.get(currency_code, 0) + amount
                     if category not in global_expense_totals: global_expense_totals[category] = {}
                     global_expense_totals[category][currency_code] = global_expense_totals[category].get(currency_code, 0) + amount
+                    user_expenses_count += 1
+                
+                # Log per-user processing results
+                if user_sales_count > 0 or user_expenses_count > 0:
+                    logging.info(f"Admin Dashboard: User {phone} - Sales: {user_sales_count}, Expenses: {user_expenses_count}")
+                    
             except Exception as e:
                 logging.error(f"Admin stats: Could not process data for phone {phone}. Error: {e}")
                 continue
         
+        # Log financial aggregation results
+        logging.info(f"Admin Dashboard: Financial aggregation - Total sales: {sales_count}, Currencies found: {list(set(global_sales_rev_by_curr.keys()) | set(global_expenses_by_curr.keys()))}")
+        logging.info(f"Admin Dashboard: Revenue by currency: {global_sales_rev_by_curr}")
+        logging.info(f"Admin Dashboard: Expenses by currency: {global_expenses_by_curr}")
+        
         # --- Post-Processing: Generate Leaderboards For Each Currency ---
         all_currencies = set(global_sales_rev_by_curr.keys()) | set(global_expenses_by_curr.keys())
         
@@ -869,6 +890,10 @@ def get_admin_dashboard_stats():
             sorted_expenses = sorted(expenses_in_curr, key=lambda item: item[1], reverse=True)
             leaderboards['topExpenses'][currency] = [{'category': name, 'totalAmount': round(amount, 2)} for name, amount in sorted_expenses[:5]]
 
+        # Log leaderboard generation results
+        for currency in all_currencies:
+            logging.info(f"Admin Dashboard: Leaderboard for {currency} - Top users: {len(leaderboards['topUsersByRevenue'][currency])}, Top items: {len(leaderboards['topSellingItems'][currency])}, Top expenses: {len(leaderboards['topExpenses'][currency])}")
+
         # --- Final Assembly ---
         global_net_profit_by_curr = {}
         for curr in all_currencies:
@@ -885,17 +910,30 @@ def get_admin_dashboard_stats():
             'totalSalesCount': sales_count,
         }
 
-        return jsonify({
-            'userStats': user_stats, 'organizationStats': org_stats, 
-            'systemStats': system_stats, 'leaderboards': leaderboards
-        }), 200
+        # Log final response data structure
+        response_data = {
+            'userStats': user_stats, 
+            'organizationStats': org_stats, 
+            'systemStats': system_stats, 
+            'leaderboards': leaderboards
+        }
+        
+        logging.info(f"Admin Dashboard: Final response structure - userStats keys: {list(user_stats.keys())}, systemStats keys: {list(system_stats.keys())}, leaderboards keys: {list(leaderboards.keys())}")
+        logging.info(f"Admin Dashboard: System stats summary - Total currencies: {len(all_currencies)}, Net profit by currency: {global_net_profit_by_curr}")
+        
+        # Log response data size for debugging
+        import json
+        response_size = len(json.dumps(response_data))
+        logging.info(f"Admin Dashboard: Response data size: {response_size} bytes")
+
+        return jsonify(response_data), 200
 
     except PermissionError as e:
+        logging.error(f"Admin Dashboard: Permission denied - {e}")
         return jsonify({'error': str(e)}), 403
     except Exception as e:
         logging.error(f"Admin failed to fetch dashboard stats: {e}", exc_info=True)
         return jsonify({'error': 'An internal error occurred while fetching stats'}), 500
-
 # -----------------------------------------------------------------------------
 # 8. SERVER EXECUTION
 # -----------------------------------------------------------------------------