fix : fixed the client simulator

README.md

@@ -17,13 +17,13 @@ license: mit
 
 # Federated Learning for Privacy-Preserving Financial Data Generation with RAG Integration
 
-This project implements a **complete federated learning framework** with a Retrieval-Augmented Generation (RAG) system for privacy-preserving synthetic financial data generation. The system includes a working server, multiple clients, and an interactive web application.
+This project implements a complete federated learning framework with a Retrieval-Augmented Generation (RAG) system for privacy-preserving synthetic financial data generation. The system includes a working server, multiple clients, and an interactive web application.
 
-## 🚀 Live Demo
+## Live Demo
 
 **Try it now**: [Hugging Face Spaces](https://huggingface.co/spaces/ArchCoder/federated-credit-scoring)
 
-## ✨ Features
+## Features
 
 - **Complete Federated Learning System**: Working server, clients, and web interface
 - **Real-time Predictions**: Get credit score predictions from the federated model
@@ -33,9 +33,9 @@ This project implements a **complete federated learning framework** with a Retri
 - **Educational**: Learn about federated learning concepts
 - **Production Ready**: Docker and Kubernetes deployment support
 
-## 🎯 Quick Start
+## Quick Start
 
-### Option 1: Try the Demo (No Setup Required)
+### Option 1: Try the Demo
 1. Visit the [Live Demo](https://huggingface.co/spaces/ArchCoder/federated-credit-scoring)
 2. Enter customer features and get predictions
 3. Learn about federated learning
@@ -72,7 +72,7 @@ streamlit run webapp/streamlit_app.py
 python test_complete_system.py
 ```
 
-## 🎮 How to Use
+## How to Use
 
 ### Web Application Features:
 - **Demo Mode**: Works without server (perfect for HF Spaces)
@@ -91,7 +91,7 @@ python test_complete_system.py
 6. **Global Model**: Updated model is distributed to all clients
 7. **Prediction**: Users can get predictions from the global model
 
-## 🏗️ System Architecture
+## System Architecture
 
 ```
 ┌─────────────────┐    ┌─────────────────┐    ┌─────────────────┐
@@ -107,7 +107,7 @@ python test_complete_system.py
                        └─────────────────┘
 ```
 
-## 📁 Project Structure
+## Project Structure
 
 ```
 FinFedRAG-Financial-Federated-RAG/
@@ -129,7 +129,7 @@ FinFedRAG-Financial-Federated-RAG/
 └── test_complete_system.py # End-to-end system test
 ```
 
-## 🔧 Configuration
+## Configuration
 
 ### Server Configuration (`config/server_config.yaml`)
 ```yaml
@@ -159,7 +159,7 @@ client:
     input_dim: 32
 ```
 
-## 🧪 Testing
+## Testing
 
 Run the complete system test:
 ```bash
@@ -167,12 +167,12 @@ python test_complete_system.py
 ```
 
 This will test:
-- ✅ Server health
-- ✅ Client registration
-- ✅ Training status
-- ✅ Prediction functionality
+- Server health
+- Client registration
+- Training status
+- Prediction functionality
 
-## 🚀 Deployment
+## Deployment
 
 ### Hugging Face Spaces (Recommended)
 1. Fork this repository
@@ -196,14 +196,14 @@ streamlit run webapp/streamlit_app.py
 docker-compose up
 ```
 
-## 📊 Performance
+## Performance
 
 - **Model Accuracy**: 85%+ across federated rounds
 - **Response Time**: <1 second for predictions
 - **Scalability**: Supports 10+ concurrent clients
 - **Privacy**: Zero raw data sharing
 
-## 🤝 Contributing
+## Contributing
 
 1. Fork the repository
 2. Create a feature branch
@@ -211,11 +211,11 @@ docker-compose up
 4. Add tests
 5. Submit a pull request
 
-## 📄 License
+## License
 
 MIT License - see LICENSE file for details.
 
-## 🙏 Acknowledgments
+## Acknowledgments
 
 - TensorFlow for the ML framework
 - Streamlit for the web interface

app.py

@@ -6,6 +6,73 @@ import threading
 import json
 from datetime import datetime
 
+# Client Simulator Class (moved to top)
+class ClientSimulator:
+    def __init__(self, server_url):
+        self.server_url = server_url
+        self.client_id = f"web_client_{int(time.time())}"
+        self.is_running = False
+        self.thread = None
+        self.last_update = "Never"
+        
+    def start(self):
+        self.is_running = True
+        self.thread = threading.Thread(target=self._run_client, daemon=True)
+        self.thread.start()
+        
+    def stop(self):
+        self.is_running = False
+        
+    def _run_client(self):
+        try:
+            # Register with server
+            client_info = {
+                'dataset_size': 100,
+                'model_params': 10000,
+                'capabilities': ['training', 'inference']
+            }
+            
+            resp = requests.post(f"{self.server_url}/register", 
+                               json={'client_id': self.client_id, 'client_info': client_info})
+            
+            if resp.status_code == 200:
+                st.session_state.training_history.append({
+                    'round': 0,
+                    'active_clients': 1,
+                    'clients_ready': 0,
+                    'timestamp': datetime.now()
+                })
+                
+                # Simulate client participation
+                while self.is_running:
+                    try:
+                        # Get training status
+                        status = requests.get(f"{self.server_url}/training_status")
+                        if status.status_code == 200:
+                            data = status.json()
+                            
+                            # Update training history
+                            st.session_state.training_history.append({
+                                'round': data.get('current_round', 0),
+                                'active_clients': data.get('active_clients', 0),
+                                'clients_ready': data.get('clients_ready', 0),
+                                'timestamp': datetime.now()
+                            })
+                            
+                            # Keep only last 50 entries
+                            if len(st.session_state.training_history) > 50:
+                                st.session_state.training_history = st.session_state.training_history[-50:]
+                        
+                        time.sleep(5)  # Check every 5 seconds
+                        
+                    except Exception as e:
+                        print(f"Client simulator error: {e}")
+                        time.sleep(10)
+                        
+        except Exception as e:
+            print(f"Failed to start client simulator: {e}")
+            self.is_running = False
+
 st.set_page_config(page_title="Federated Credit Scoring Demo", layout="centered")
 st.title("Federated Credit Scoring Demo (Federated Learning)")
 
@@ -172,71 +239,4 @@ if st.session_state.client_simulator and not DEMO_MODE:
 st.markdown("---")
 st.markdown("""
 *This is a demonstration of federated learning concepts. For full functionality, run the federated server and clients locally.*
-""")
-
-# Client Simulator Class
-class ClientSimulator:
-    def __init__(self, server_url):
-        self.server_url = server_url
-        self.client_id = f"web_client_{int(time.time())}"
-        self.is_running = False
-        self.thread = None
-        self.last_update = "Never"
-        
-    def start(self):
-        self.is_running = True
-        self.thread = threading.Thread(target=self._run_client, daemon=True)
-        self.thread.start()
-        
-    def stop(self):
-        self.is_running = False
-        
-    def _run_client(self):
-        try:
-            # Register with server
-            client_info = {
-                'dataset_size': 100,
-                'model_params': 10000,
-                'capabilities': ['training', 'inference']
-            }
-            
-            resp = requests.post(f"{self.server_url}/register", 
-                               json={'client_id': self.client_id, 'client_info': client_info})
-            
-            if resp.status_code == 200:
-                st.session_state.training_history.append({
-                    'round': 0,
-                    'active_clients': 1,
-                    'clients_ready': 0,
-                    'timestamp': datetime.now()
-                })
-                
-                # Simulate client participation
-                while self.is_running:
-                    try:
-                        # Get training status
-                        status = requests.get(f"{self.server_url}/training_status")
-                        if status.status_code == 200:
-                            data = status.json()
-                            
-                            # Update training history
-                            st.session_state.training_history.append({
-                                'round': data.get('current_round', 0),
-                                'active_clients': data.get('active_clients', 0),
-                                'clients_ready': data.get('clients_ready', 0),
-                                'timestamp': datetime.now()
-                            })
-                            
-                            # Keep only last 50 entries
-                            if len(st.session_state.training_history) > 50:
-                                st.session_state.training_history = st.session_state.training_history[-50:]
-                        
-                        time.sleep(5)  # Check every 5 seconds
-                        
-                    except Exception as e:
-                        print(f"Client simulator error: {e}")
-                        time.sleep(10)
-                        
-        except Exception as e:
-            print(f"Failed to start client simulator: {e}")
-            self.is_running = False 
+""") 

webapp/streamlit_app.py

@@ -6,6 +6,73 @@ import threading
 import json
 from datetime import datetime
 
+# Client Simulator Class (moved to top)
+class ClientSimulator:
+    def __init__(self, server_url):
+        self.server_url = server_url
+        self.client_id = f"web_client_{int(time.time())}"
+        self.is_running = False
+        self.thread = None
+        self.last_update = "Never"
+        
+    def start(self):
+        self.is_running = True
+        self.thread = threading.Thread(target=self._run_client, daemon=True)
+        self.thread.start()
+        
+    def stop(self):
+        self.is_running = False
+        
+    def _run_client(self):
+        try:
+            # Register with server
+            client_info = {
+                'dataset_size': 100,
+                'model_params': 10000,
+                'capabilities': ['training', 'inference']
+            }
+            
+            resp = requests.post(f"{self.server_url}/register", 
+                               json={'client_id': self.client_id, 'client_info': client_info})
+            
+            if resp.status_code == 200:
+                st.session_state.training_history.append({
+                    'round': 0,
+                    'active_clients': 1,
+                    'clients_ready': 0,
+                    'timestamp': datetime.now()
+                })
+                
+                # Simulate client participation
+                while self.is_running:
+                    try:
+                        # Get training status
+                        status = requests.get(f"{self.server_url}/training_status")
+                        if status.status_code == 200:
+                            data = status.json()
+                            
+                            # Update training history
+                            st.session_state.training_history.append({
+                                'round': data.get('current_round', 0),
+                                'active_clients': data.get('active_clients', 0),
+                                'clients_ready': data.get('clients_ready', 0),
+                                'timestamp': datetime.now()
+                            })
+                            
+                            # Keep only last 50 entries
+                            if len(st.session_state.training_history) > 50:
+                                st.session_state.training_history = st.session_state.training_history[-50:]
+                        
+                        time.sleep(5)  # Check every 5 seconds
+                        
+                    except Exception as e:
+                        print(f"Client simulator error: {e}")
+                        time.sleep(10)
+                        
+        except Exception as e:
+            print(f"Failed to start client simulator: {e}")
+            self.is_running = False
+
 st.set_page_config(page_title="Federated Credit Scoring Demo", layout="centered")
 st.title("Federated Credit Scoring Demo (Federated Learning)")
 
@@ -172,71 +239,4 @@ if st.session_state.client_simulator and not DEMO_MODE:
 st.markdown("---")
 st.markdown("""
 *This is a demonstration of federated learning concepts. For full functionality, run the federated server and clients locally.*
-""")
-
-# Client Simulator Class
-class ClientSimulator:
-    def __init__(self, server_url):
-        self.server_url = server_url
-        self.client_id = f"web_client_{int(time.time())}"
-        self.is_running = False
-        self.thread = None
-        self.last_update = "Never"
-        
-    def start(self):
-        self.is_running = True
-        self.thread = threading.Thread(target=self._run_client, daemon=True)
-        self.thread.start()
-        
-    def stop(self):
-        self.is_running = False
-        
-    def _run_client(self):
-        try:
-            # Register with server
-            client_info = {
-                'dataset_size': 100,
-                'model_params': 10000,
-                'capabilities': ['training', 'inference']
-            }
-            
-            resp = requests.post(f"{self.server_url}/register", 
-                               json={'client_id': self.client_id, 'client_info': client_info})
-            
-            if resp.status_code == 200:
-                st.session_state.training_history.append({
-                    'round': 0,
-                    'active_clients': 1,
-                    'clients_ready': 0,
-                    'timestamp': datetime.now()
-                })
-                
-                # Simulate client participation
-                while self.is_running:
-                    try:
-                        # Get training status
-                        status = requests.get(f"{self.server_url}/training_status")
-                        if status.status_code == 200:
-                            data = status.json()
-                            
-                            # Update training history
-                            st.session_state.training_history.append({
-                                'round': data.get('current_round', 0),
-                                'active_clients': data.get('active_clients', 0),
-                                'clients_ready': data.get('clients_ready', 0),
-                                'timestamp': datetime.now()
-                            })
-                            
-                            # Keep only last 50 entries
-                            if len(st.session_state.training_history) > 50:
-                                st.session_state.training_history = st.session_state.training_history[-50:]
-                        
-                        time.sleep(5)  # Check every 5 seconds
-                        
-                    except Exception as e:
-                        print(f"Client simulator error: {e}")
-                        time.sleep(10)
-                        
-        except Exception as e:
-            print(f"Failed to start client simulator: {e}")
-            self.is_running = False 
+""")