Create app.py

app.py

@@ -0,0 +1,55 @@
+import asyncio
+import threading
+import uuid
+from fastapi import FastAPI, BackgroundTasks
+from fastapi.responses import JSONResponse
+import uvicorn
+
+# Istihbarat modülünü içe aktar
+# !!! DİKKAT: Bu dosya 'Istihbarat.py' ile aynı klasörde olmalı !!!
+import Istihbarat
+
+app = FastAPI()
+
+# Çalışan işlemleri takip etmek için basit bir sözlük
+tasks_status = {}
+
+def run_istihbarat(task_id: str):
+    """Istihbarat modülünü arka planda çalıştırır."""
+    try:
+        # Istihbarat modülünün ana fonksiyonunu çağır
+        # Bu fonksiyon genelde sonsuz döngüye girer, bu yüzden bir thread'de çalıştırılır.
+        Istihbarat.istihbarat_modulu()
+        tasks_status[task_id] = "Tamamlandı"
+    except Exception as e:
+        tasks_status[task_id] = f"Hata: {str(e)}"
+
+@app.get("/")
+async def root():
+    """Ana sayfa, sunucunun çalıştığını gösterir."""
+    return {"message": "Dexo API Sunucusu Çalışıyor!", "status": "online"}
+
+@app.post("/start")
+async def start_istihbarat(background_tasks: BackgroundTasks):
+    """Istihbarat modülünü başlatmak için endpoint."""
+    task_id = str(uuid.uuid4())
+    tasks_status[task_id] = "Başlatılıyor..."
+
+    # Arka planda çalıştır
+    background_tasks.add_task(run_istihbarat, task_id)
+
+    return JSONResponse(content={
+        "message": "Istihbarat modülü başlatılıyor...",
+        "task_id": task_id,
+        "status_url": f"/status/{task_id}"
+    })
+
+@app.get("/status/{task_id}")
+async def get_status(task_id: str):
+    """İşlemin durumunu sorgulamak için endpoint."""
+    status = tasks_status.get(task_id, "Bilinmeyen işlem ID'si")
+    return {"task_id": task_id, "status": status}
+
+# Sunucuyu başlatmak için (Docker'da CMD ile çağrılacak)
+if __name__ == "__main__":
+    uvicorn.run(app, host="0.0.0.0", port=7860)