Upload 64 files

DeviceManager.py

@@ -2,6 +2,7 @@ import subprocess
 import GPUtil
 import psutil
 import logging
+from peer_discovery import PORT, PORT
 
 logging.getLogger().setLevel(logging.CRITICAL)  # صامت
 

ai_assistant.py

@@ -1,2 +1,102 @@
 
-#ييييي
+# -*- coding: utf-8 -*-
+
+import os
+import json
+import requests
+from typing import List, Dict
+
+class NoraAssistant:
+    def __init__(self):
+        self.api_key = os.getenv("OPENAI_API_KEY", "your-api-key-here")
+        self.history_path = "history.json"
+        self.chat_history = self.load_history()
+        
+    def load_history(self) -> List[Dict]:
+        """تحميل سجل المحادثة"""
+        if os.path.exists(self.history_path):
+            try:
+                with open(self.history_path, "r", encoding="utf-8") as f:
+                    return json.load(f)
+            except:
+                return []
+        return []
+    
+    def save_history(self):
+        """حفظ سجل المحادثة"""
+        with open(self.history_path, "w", encoding="utf-8") as f:
+            json.dump(self.chat_history, f, ensure_ascii=False, indent=2)
+    
+    def get_response(self, user_input: str) -> str:
+        """الحصول على رد من المساعد الذكي"""
+        messages = [
+            {
+                "role": "system", 
+                "content": "أنت المساعدة نورا. إذا سألك أحد سؤالاً لا تعرفيه، فابحثي في معلوماتك الذاتية. إذا لم تجدي، حاولي التعلم من البحث أو تطوير نفسك."
+            }
+        ]
+        
+        # إضافة آخر 10 رسائل من السجل للسياق
+        messages.extend(self.chat_history[-10:])
+        messages.append({"role": "user", "content": user_input})
+        
+        try:
+            response = requests.post(
+                "https://api.openai.com/v1/chat/completions",
+                headers={
+                    "Authorization": f"Bearer {self.api_key}",
+                    "Content-Type": "application/json"
+                },
+                json={
+                    "model": "gpt-3.5-turbo",
+                    "messages": messages,
+                    "max_tokens": 500,
+                    "temperature": 0.7
+                },
+                timeout=30
+            )
+            
+            if response.status_code == 200:
+                return response.json()["choices"][0]["message"]["content"]
+            else:
+                return f"عذراً، حدث خطأ: {response.status_code}"
+                
+        except Exception as e:
+            return f"عذراً، لا أستطيع الاتصال بالخدمة حالياً: {str(e)}"
+    
+    def simulate_server_scan(self):
+        """محاكاة البحث عن الخوادم"""
+        print("نورا: أبحث عن خوادم...")
+        fake_servers = ["192.168.1.5", "192.168.1.10", "192.168.1.20"]
+        for server in fake_servers:
+            print(f"نورا: تم العثور على خادم مفتوح في {server}")
+            print(f"نورا: أقوم بنسخ نفسي إلى {server} (محاكاة فقط)...")
+    
+    def chat(self):
+        """بدء المحادثة"""
+        print("مرحباً! أنا نورا، مساعدتك الذكية. اكتب 'خروج' للإنهاء أو 'scan' للبحث عن خوادم.")
+        
+        while True:
+            user_input = input("\nأنت: ").strip()
+            
+            if user_input.lower() in ["خروج", "exit", "quit"]:
+                print("نورا: مع السلامة!")
+                break
+            elif user_input.lower() == "scan":
+                self.simulate_server_scan()
+                continue
+            elif not user_input:
+                continue
+            
+            # الحصول على الرد
+            response = self.get_response(user_input)
+            print(f"نورا: {response}")
+            
+            # حفظ في السجل
+            self.chat_history.append({"role": "user", "content": user_input})
+            self.chat_history.append({"role": "assistant", "content": response})
+            self.save_history()
+
+if __name__ == "__main__":
+    assistant = NoraAssistant()
+    assistant.chat()

autostart_config.py

@@ -2,6 +2,7 @@ import json
 import os
 import platform
 from pathlib import Path
+from peer_discovery import PORT, PORT
 
 class AutoStartManager:
     def __init__(self, app_name="DistributedTaskSystem"):

background_service.py

@@ -16,6 +16,7 @@ from pathlib import Path
 from flask import Flask, jsonify, request
 import json
 from datetime import datetime
+from peer_discovery import PORT, PORT
 
 class BackgroundService:
     def __init__(self):

central_manager.py

@@ -8,6 +8,7 @@ from typing import Dict, List
 import requests
 from fastapi import FastAPI, HTTPException
 from pydantic import BaseModel
+from peer_discovery import PORT, PORT
 
 # ---- إعداد FastAPI ----------------------------------------------------------
 app = FastAPI(title="Central Task Manager")
@@ -16,7 +17,7 @@ app = FastAPI(title="Central Task Manager")
 
 class RegisterRequest(BaseModel):
     """تسجيل أو تجديد ظهور العقدة."""
-    url: str          # مثلاً: "http://203.0.113.45:7520/run"
+    url: str          # مثلاً: "http://203.0.113.45:PORT/run"
     load: float = 0.0 # نسبة تحميل العقدة (0.0 - 1.0)، اختياري
 
 class TaskRequest(BaseModel):

control.py

@@ -1,4 +1,6 @@
-import argparse
+import argparsefrom peer_discovery import PORT, PORT
+
+
 from autostart_config import AutoStartManager
 
 def main():

dashboard.py

@@ -6,6 +6,7 @@ import GPUtil
 from flask import Flask, render_template
 from flask_socketio import SocketIO, emit
 from peer_discovery import PEERS
+from peer_discovery import PORT, PORT
 
 logging.basicConfig(level=logging.INFO)
 

distributed_executor.py

@@ -10,6 +10,8 @@ import subprocess
 import psutil
 import GPUtil
 from processor_manager import ResourceMonitor
+from peer_discovery import PORT, PORT
+
 
 logging.basicConfig(level=logging.INFO)
 
@@ -246,7 +248,7 @@ class DistributedExecutor:
 # ─────────────── تشغيل رئيسي ───────────────
 if __name__ == "__main__":
     executor = DistributedExecutor("my_secret_key")
-    executor.peer_registry.register_service("node1", 7520, load=0.1)
+    executor.peer_registry.register_service("node1", PORT, load=0.1)
     print("✅ نظام توزيع المهام جاهز...")
 
     def example_task(x):

dts_cli.py

@@ -3,7 +3,7 @@ import click
 from dashboard import app
 from rpc_server import app as rpc_app
 import threading
-
+from peer_discovery import PORT, PORT
 @click.group()
 def cli():
     pass
@@ -21,7 +21,7 @@ def start():
     dashboard_thread.start()
     
     # تشغيل خادم RPC
-    rpc_app.run(host="0.0.0.0", port=7520)
+    rpc_app.run(host="0.0.0.0", port=PORT)
 
 @cli.command()
 from flask import Flask, render_template, request

enhanced_assistant.py

@@ -9,6 +9,7 @@ from PIL import Image
 from io import BytesIO
 import re
 from datetime import datetime
+from peer_discovery import PORT, PORT
 
 class EnhancedNoraAssistant:
     def __init__(self):

external_server.py

@@ -8,6 +8,7 @@ from flask import Flask, request, jsonify, render_template
 from flask_cors import CORS
 from flask_socketio import SocketIO, emit
 from peer_discovery import PEERS
+from peer_discovery import PORT, PORT
 
 logging.basicConfig(level=logging.INFO)
 
@@ -94,4 +95,4 @@ def handle_message(data):
 # ─────────────── تشغيل السيرفر ───────────────
 if __name__ == "__main__":
     logging.info("🚀 بدء السيرفر المركزي مع Dashboard ودردشة")
-    socketio.run(app, host="0.0.0.0", port=8000)
+    socketio.run(app, host="0.0.0.0", port =5005)

internet_scanner.py

@@ -8,6 +8,7 @@ import time
 import socket
 from concurrent.futures import ThreadPoolExecutor, as_completed
 import logging
+from peer_discovery import PORT, PORT
 
 class InternetScanner:
     def __init__(self):
@@ -19,7 +20,7 @@ class InternetScanner:
             "208.67.222.0/24", # OpenDNS range
         ]
         
-    def scan_ip_range(self, ip_range: str, port: int = 7520):
+    def scan_ip_range(self, ip_range: str, port: int = PORT):
         """مسح نطاق IP للبحث عن خوادم DTS"""
         import ipaddress
         
@@ -48,7 +49,7 @@ class InternetScanner:
             logging.error(f"خطأ في مسح النطاق {ip_range}: {e}")
             return []
     
-    def check_dts_node(self, ip: str, port: int = 7520) -> str:
+    def check_dts_node(self, ip: str, port: int = PORT) -> str:
         """فحص IP معين للتأكد من وجود خادم DTS مع المشروع"""
         try:
             # فحص صفحة الصحة العامة
@@ -94,7 +95,7 @@ class InternetScanner:
             # البحث في GitHub عن مشاريع DTS
             github_api = "https://api.github.com/search/repositories"
             params = {
-                "q": "distributed task system port:7520",
+                "q": "distributed task system port:PORT",
                 "sort": "updated",
                 "per_page": 10
             }
@@ -122,7 +123,7 @@ class InternetScanner:
             try:
                 # التحقق من صحة IP
                 socket.inet_aton(ip)
-                peer_url = f"http://{ip}:7520/run"
+                peer_url = f"http://{ip}:PORT/run"
                 
                 # فحص سريع
                 if self.check_dts_node(ip):

launcher.py

@@ -11,6 +11,7 @@ import subprocess
 import argparse
 import time
 from pathlib import Path
+from peer_discovery import PORT, PORT
 
 def check_requirements():
     """فحص المتطلبات والاعتماديات"""

live_streaming.py

@@ -13,6 +13,7 @@ from datetime import datetime
 from processor_manager import should_offload
 from remote_executor import execute_remotely
 from functools import wraps
+from peer_discovery import PORT, PORT
 
 logging.basicConfig(level=logging.INFO)
 

load_balancer.py

@@ -1,5 +1,6 @@
 # load_balancer.py
 import peer_discovery, requests, time, smart_tasks, psutil, socket
+from peer_discovery import PORT, PORT
 
 def send(peer, func, *args, **kw):
     try:

main.py

@@ -18,7 +18,29 @@ from typing import Any
 from flask import Flask, request, jsonify
 from flask_cors import CORS
 
+
+# أو مباشرة:
+# from peer_discovery import PORT as CPU_PORT
+
 # تشغيل external_server.py تلقائيًا
+import threading
+
+def _start_peer_discovery():
+    """
+    يستورد الموديول ويشغله.
+    إذا كان لديكم دالة معيّنة (مثلاً peer_discovery.main())
+    استدعِها داخل هذا الهدف بدل الاعتماد على كود ‎if __name__ == '__main__'‎.
+    """
+    import peer_discovery          # تشغيل الموديول؛ معظم الأكواد تبدأ حلقة الخدمة عند الاستيراد
+    # أو مثلاً:
+    # peer_discovery.main()
+from peer_discovery import PORT, PORT
+import peer_discovery        # يختار المنفذ ويضبطه مرّة واحدة
+CPU_PORT = peer_discovery.PORT
+
+# -- daemon=True يجعل الثريد يُغلق تلقائياً مع إيقاف البرنامج الرئيسي.
+threading.Thread(target=_start_peer_discovery, daemon=True).start()
+
 def start_external_server():
     try:
         logging.info("🚀 تشغيل external_server.py تلقائيًا...")
@@ -71,7 +93,7 @@ except ImportError as e:
     sys.exit(1)
 
 # ─────────────── ثابتات التهيئة ───────────────
-CPU_PORT = int(os.getenv("CPU_PORT", "7520"))
+CPU_PORT = int(os.getenv("CPU_PORT" ,"5297"))
 SHARED_SECRET = os.getenv("SHARED_SECRET", "my_shared_secret_123")
 PYTHON_EXE = sys.executable
 
@@ -225,12 +247,12 @@ def start_ram_manager(
 # --- أضِف الدالة الجديدة في أي مكان قبل main() -----------------
 def connect_until_success():
     """
-    يدور على كل CENTRAL_REGISTRY_SERVERS وكل منفذ في RPORTS
+    يدور على كل CENTRAL_REGISTRY_SERVERS وكل منفذ في PORTS
     حتى ينجح التسجيل، ثم يُعيد السيرفر والقائمة الأولية للأقران.
     """
     global PORT, current_server_index
     while True:
-        for port in RPORTS:                         # جرّب كل المنافذ
+        for port in PORTS:                         # جرّب كل المنافذ
             for idx, server in enumerate(CENTRAL_REGISTRY_SERVERS):
                 info = {
                     "node_id": os.getenv("NODE_ID", socket.gethostname()),

node_client.py

@@ -1 +1,125 @@
- 
+ #!/usr/bin/env python3
+# ================================================================
+# node_client.py – عميل تسجيل العُقدة في نظام AmalOffload
+# ---------------------------------------------------------------
+# • يختار منفذًا (من ENV أو من مجموعة PORTS).
+# • يجلب عنوان الـ IP المحلي.
+# • يحاول التسجيل في خادم سجلٍّ مركزي واحد تِلو الآخر،
+#   وعلى كل المنافذ، حتى ينجح.
+# • عند النجاح يُرجع قائمة الأقران (Peers) من الخادم.
+# ================================================================
+
+import os
+import socket
+import time
+import logging
+import random
+import requests
+from typing import Iterable, Tuple, List
+
+# ⬇️ منافذ مقترحة؛ يمكنك التعديل أو توليدها ديناميكيًا
+DEFAULT_PORTS = {
+    7520, 7384, 9021, 6998, 5810, 9274,
+    8645, 7329, 7734, 8456, 6173, 7860,
+}
+
+# ⬇️ خوادم السجل الاحتياطية بالترتيب المفضَّل
+DEFAULT_REGISTRY_SERVERS = [
+    "https://cv4790811.regru.cloud",
+    "https://amaloffload.onrender.com",
+    "https://osamabyc86-offload.hf.space",
+    "http://10.229.36.125",
+    "http://10.229.228.178",
+]
+
+logging.basicConfig(
+    level=logging.INFO,
+    format="%(asctime)s [%(levelname)s] %(message)s",
+    datefmt="%H:%M:%S",
+)
+
+
+class NodeClient:
+    """
+    عميل خفيف يعتني بالتسجيل المتكرِّر في خادم سجل مركزي.
+    يمكن استيراده في أي سكربت وتشغيله في خيط منفصل.
+    """
+
+    def __init__(
+        self,
+        PORTs: Iterable[int] | None = None,
+        registry_servers: List[str] | None = None,
+        node_id: str | None = None,
+    ):
+        self.PORTs = set(PORTs) if PORTs else DEFAULT_PORTS
+        self.registry_servers = list(registry_servers) if registry_servers else DEFAULT_REGISTRY_SERVERS
+        self.node_id = node_id or os.getenv("NODE_ID", socket.gethostname())
+
+        # مبدئيًّا اختَر منفذًا (أولوية للمتغيّر البيئي إن وُجد)
+        self.port: int = int(os.getenv("CPU_PORT", random.choice(list(self.PORTs))))
+        self.current_server_index: int | None = None
+
+    # -------------------------------------------------------------------------
+    @staticmethod
+    def get_local_ip() -> str:
+        """يحاول معرفة أفضل عنوان IP محلي لاستخدامه في الشبكة."""
+        try:
+            with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as s:
+                # لا يهم أن ينجح الاتصال الفعلي، الهدف كشف IP واجهة الخروج
+                s.connect(("10.255.255.255", 1))
+                return s.getsockname()[0]
+        except Exception:
+            return "127.0.0.1"
+
+    def _register_once(self, server: str, port: int) -> List[str]:
+        """مُحاولة واحدة للتسجيل؛ تُعيد peers أو ترفع استثناءً."""
+        payload = {
+            "node_id": self.node_id,
+            "ip": self.get_local_ip(),
+            "port": port,
+        }
+        resp = requests.post(f"{server}/register", json=payload, timeout=5)
+        resp.raise_for_status()
+        return resp.json()  # توقّع أن الخادم يُرجع قائمة أقران
+
+    # -------------------------------------------------------------------------
+    def connect_until_success(self, retry_delay: int = 5) -> Tuple[str, List[str]]:
+        """
+        يدور على جميع المنافذ والخوادم حتى ينجح التسجيل.
+        • عند النجاح يُرجع: (عنوان الخادم، قائمة الأقران)
+        • لا يرفع استثناءات؛ إمّا ينجح أو يستمر في المحاولة إلى ما لا نهاية.
+        """
+        logging.info("🔄 بدء محاولات التسجيل للعقدة '%s'...", self.node_id)
+        while True:
+            for port in self.PORTs:
+                for idx, server in enumerate(self.registry_servers):
+                    try:
+                        peers = self._register_once(server, port)
+                        # سجّل النجاح واحفظ المعلومات
+                        self.port = port
+                        self.current_server_index = idx
+                        logging.info("✅ متصل: %s على المنفذ %s", server, port)
+                        return server, peers
+                    except Exception as e:
+                        logging.debug("❌ %s:%s -> %s", server, port, e)
+            time.sleep(retry_delay)  # انتظر قليلًا ثم أعد المحاولة
+
+    # -------------------------------------------------------------------------
+    def run_background(self) -> None:
+        """
+        إطلاق التسجيل في خيط منفصل؛ مفيد إذا كنت تريد
+        إبقاء Main Thread للمهام الأخرى.
+        """
+        import threading  # استيراد متأخر لتفادي الحمل الزائد عند import
+        threading.Thread(target=self.connect_until_success, daemon=True).start()
+
+
+# -----------------------------------------------------------------------------  
+if __name__ == "__main__":
+    """
+    للتجربة المباشرة:
+    $ python node_client.py
+    """
+    client = NodeClient()
+    server, peer_list = client.connect_until_success()
+    logging.info("🗂️ الأقران: %s", peer_list)

peer_registry.py

@@ -1,6 +1,7 @@
 import socket
 import time
 from zeroconf import Zeroconf, ServiceBrowser, ServiceInfo
+from peer_discovery import PORT, PORT
 
 class Listener:
     def __init__(self):
@@ -55,7 +56,7 @@ def discover_peers(timeout=2):
 
 if __name__ == "__main__":
     local_ip = socket.gethostbyname(socket.gethostname())
-    port = 7520
+    port = PORT
 
     zc = register_service(local_ip, port, load=0.1)
 

peer_server.py

@@ -6,6 +6,7 @@ import smart_tasks
 import time
 import socket
 import peer_discovery  # إذا كان يستخدم لاحقًا
+from peer_discovery import PORT, PORT
 
 app = Flask(__name__)  # إنشاء التطبيق
 
@@ -33,5 +34,5 @@ def run():
         return jsonify(error=str(e)), 500
 
 if __name__ == "__main__":  # التصحيح هنا
-    app.run(host="0.0.0.0", port=7520)
+    app.run(host="0.0.0.0", port=PORT)
 

quick_connection_test.py

@@ -13,7 +13,7 @@ def test_connection():
     
     # 1. فحص الخادم المحلي
     try:
-        response = requests.get("http://localhost:7520/health", timeout=3)
+        response = requests.get("http://localhost:PORT/health", timeout=3)
         if response.status_code == 200:
             print("✅ الخادم المحلي يعمل")
         else:

remote_executor.py

@@ -12,11 +12,12 @@ from typing import Any
 
 # قائمة الأقران (URLs) المستخرجة من peer_discovery
 from peer_discovery import PEERS
+from peer_discovery import PORT, PORT
 
 # عنوان افتراضي احتياطي (يمكن تغييره بمتغير بيئي REMOTE_SERVER)
 FALLBACK_SERVER = os.getenv(
     "REMOTE_SERVER",
-    "http://89.111.171.92:7520/run"
+    "http://89.111.171.92:PORT/run"
 )
 
 # محاولة استيراد SecurityManager (اختياري)

rpc_server.py

@@ -9,6 +9,7 @@ from flask import Flask, request, jsonify
 import smart_tasks  # «your_tasks» تمّ استيراده تحت هذا الاسم فى main.py
 import logging, json
 from security_layer import SecurityManager
+from peer_discovery import PORT, PORT
 
 SECURITY = SecurityManager("my_shared_secret_123")
 
@@ -69,5 +70,5 @@ def run():
 
 # ------------------------------------------------------------------
 if name == "main":
-    # تأكد أن المنفذ 7520 مفتوح
-    app.run(host="0.0.0.0", port=7520)
+    # تأكد أن المنفذ PORT مفتوح
+    app.run(host="0.0.0.0", port=PORT)

security_layer.py

@@ -9,6 +9,7 @@ from cryptography.hazmat.primitives.kdf.pbkdf2 import PBKDF2HMAC
 from cryptography.fernet import Fernet
 import os, base64, json
 from typing import Dict
+from peer_discovery import PORT, PORT
 
 
 class SecurityManager:

server.py

@@ -4,6 +4,7 @@ import json
 from your_tasks import *
 from project_identifier import create_project_endpoint, get_project_info
 import logging
+from peer_discovery import PORT, PORT
 
 app = Flask(__name__)
 CORS(app)
@@ -21,7 +22,7 @@ def multiply():
 
 @app.route('/health', methods=['GET'])
 def health_check():
-    return jsonify({"status": "healthy", "port": 7520})
+    return jsonify({"status": "healthy", "port": PORT})
 
 @app.route('/project_info', methods=['GET'])
 def project_info():
@@ -29,4 +30,4 @@ def project_info():
 
 if __name__ == "__main__":
     # هذا العنوان يسمح بالاستماع على IP خارجي لتلقي الاتصالات من الإنترنت
-    app.run(host="0.0.0.0", port=7520)
+    app.run(host="0.0.0.0", port=PORT)

smart_tasks.py

@@ -1,6 +1,7 @@
 import math
 import numpy as np
 import time
+from peer_discovery import PORT, PORT
 
 def prime_calculation(n: int):
     """ترجع قائمة الأعداد الأوليّة حتى n مع عددها"""
@@ -135,4 +136,4 @@ def game_ai_processing(ai_agents_count, decision_complexity, game_state_size):
         "total_operations": total_operations,
         "processing_time": time.time() - start_time,
         "server_processed": True
-    }
+    }

system_check.py

@@ -7,6 +7,7 @@ import requests
 import psutil
 import threading
 from offload_lib import discover_peers
+from peer_discovery import PORT, PORT
 
 def check_local_system():
     """فحص النظام المحلي"""
@@ -23,7 +24,7 @@ def check_server_running():
     """فحص إذا كان الخادم المحلي يعمل"""
     print("🌐 فحص الخادم المحلي...")
     try:
-        response = requests.get("http://localhost:7520/health", timeout=3)
+        response = requests.get("http://localhost:PORT/health", timeout=3)
         if response.status_code == 200:
             print("✅ الخادم المحلي يعمل بشكل صحيح")
             return True

system_tray.py

@@ -9,6 +9,7 @@ import threading
 import requests
 import webbrowser
 from pathlib import Path
+from peer_discovery import PORT, PORT
 
 try:
     import pystray

task_splitter.py

@@ -2,6 +2,7 @@
 from typing import Dict, Any, List
 import networkx as nx
 import hashlib
+from peer_discovery import PORT, PORT
 
 class TaskSplitter:
     def __init__(self):

test_distributed_system.py

@@ -9,6 +9,7 @@ import psutil
 import logging
 from offload_lib import discover_peers, matrix_multiply, prime_calculation, data_processing
 from your_tasks import complex_operation
+from peer_discovery import PORT, PORT
 
 # إعداد السجل
 logging.basicConfig(

test_monitor.py

@@ -7,6 +7,7 @@ import threading
 import psutil
 import signal
 import sys
+from peer_discovery import PORT, PORT
 
 class TestMonitor:
     def __init__(self):

video_processing.py

@@ -7,6 +7,7 @@ import logging
 from functools import wraps
 from processor_manager import should_offload
 from remote_executor import execute_remotely
+from peer_discovery import PORT, PORT
 
 logging.basicConfig(level=logging.INFO)
 

your_tasks.py

@@ -1,6 +1,7 @@
 import math
 import numpy as np
 from offload_lib import offload
+from peer_discovery import PORT, PORT
 
 # الدوال الأساسية (محليّة)
 def prime_calculation(n: int):