Update main.py

main.py

@@ -621,6 +621,52 @@ def respond_to_deal(deal_id):
     except firebase_exceptions.FirebaseError as fe: logger.error(f"Firebase error in respond_to_deal: {fe}"); return jsonify({'error': f'Firebase error: {str(fe)}'}), 500
     except Exception as e: logger.error(f"Respond to Deal Error: {e}"); return jsonify({'error': f'Failed to respond: {str(e)}'}), 500
 
+# --- NEW: /api/deals/my Endpoint ---
+@app.route('/api/deals/my', methods=['GET'])
+def get_my_deals():
+    auth_header = request.headers.get('Authorization')
+    uid = None # Initialize uid for error context
+    try:
+        # Ensure Firebase is initialized before proceeding
+        if not FIREBASE_INITIALIZED:
+            logger.error("get_my_deals: Firebase not initialized.")
+            return jsonify({'error': 'Server configuration error: Firebase not ready.'}), 503
+        
+        uid = verify_token(auth_header) # This can raise exceptions handled below
+        # verify_token now returns None on auth failure or raises specific exceptions
+        # The handle_route_auth_errors will catch PermissionError or ValueError from verify_token
+
+        all_deals_ref = db.reference('deals', app=db_app)
+        all_deals = all_deals_ref.get() # This can return None if 'deals' node doesn't exist
+        
+        my_deals = {}
+        if all_deals: # Important to check if all_deals is not None
+            for deal_id, deal_data in all_deals.items():
+                # Ensure deal_data is a dictionary before trying to access keys
+                if isinstance(deal_data, dict) and \
+                   (deal_data.get('buyer_id') == uid or deal_data.get('farmer_id') == uid):
+                    my_deals[deal_id] = deal_data
+        
+        # You can optionally sort them here if needed by the frontend, e.g., by created_at
+        # sorted_my_deals_list = sorted(my_deals.items(), key=lambda item: item[1].get('created_at', ''), reverse=True)
+        # return jsonify(dict(sorted_my_deals_list)), 200
+        
+        return jsonify(my_deals), 200
+
+    except Exception as e_auth_related: # Catches exceptions from verify_token or other auth logic
+        return handle_route_auth_errors(e_auth_related) # Use your existing handler
+    # The handle_route_auth_errors should ideally catch firebase_exceptions.FirebaseError too,
+    # or you can add a specific catch here if needed for DB operations within this route.
+    # For now, assuming handle_route_auth_errors is comprehensive enough or
+    # that FirebaseErrors from db.reference().get() would be caught by a generic Exception.
+    # To be more robust for DB specific errors within this route:
+    except firebase_exceptions.FirebaseError as fe:
+        logger.error(f"Firebase error in get_my_deals for UID {uid or 'unknown'}: {fe}\n{traceback.format_exc()}")
+        return jsonify({'error': f'Database operation failed: {str(fe)}', 'type': 'FirebaseSDKError'}), 500
+    except Exception as e: # Generic catch-all for any other unexpected error
+        logger.error(f"Get My Deals Error for UID {uid or 'unknown'}: {e}\n{traceback.format_exc()}")
+        return jsonify({'error': f'An unexpected error occurred: {str(e)}', 'type': 'GenericError'}), 500
+
 @app.route('/api/admin/deals/pending', methods=['GET'])
 def admin_get_pending_deals():
     auth_header = request.headers.get('Authorization')