android: fork AndrOBD (submodule), thin client (Kotlin), raw-obd endpoint

web/app.py

@@ -6,6 +6,7 @@
 """
 
 import sys
+import logging
 from pathlib import Path
 
 # Добавляем корень проекта в PYTHONPATH
@@ -18,9 +19,13 @@ from elmer.db import Database
 from elmer.diagnose import Diagnoser
 from elmer.elm import ELM327
 from elmer.prompts import SYSTEM_PROMPT, build_user_prompt
+from web.raw_endpoint import register as register_raw_endpoint
+
+logging.basicConfig(level=logging.INFO, format="%(asctime)s [%(name)s] %(message)s")
 
 app = Flask(__name__)
 config = load()
+register_raw_endpoint(app)
 
 
 @app.route("/")

web/raw_endpoint.py

@@ -0,0 +1,52 @@
+"""Эндпоинт /api/v1/raw-obd — приём сырых OBD-ответов от тонкого клиента.
+
+Формат входящих данных:
+    {"raw": "41 05 5A", "timestamp": 1716652800000}
+
+Сервер логирует, складывает в очередь, и по готовности парсит + отправляет в LLM.
+"""
+
+import json
+import logging
+import threading
+from collections import deque
+from datetime import datetime, timezone
+
+logger = logging.getLogger("elmer.raw")
+
+# Буфер сырых сообщений на сессию (в production — Redis очередь)
+raw_buffer: deque[dict] = deque()
+buffer_lock = threading.Lock()
+
+
+def register(app):
+    """Регистрирует эндпоинт на Flask-приложении."""
+
+    @app.route("/api/v1/raw-obd", methods=["POST"])
+    def raw_obd():
+        from flask import request, jsonify
+
+        data = request.get_json(silent=True)
+        if not data or "raw" not in data:
+            return jsonify({"error": "missing 'raw' field"}), 400
+
+        raw = data["raw"].strip()
+        ts = data.get("timestamp", int(datetime.now(timezone.utc).timestamp() * 1000))
+
+        # Логируем в консоль
+        logger.info(f"[RAW] {raw}")
+
+        # Складываем в буфер
+        with buffer_lock:
+            raw_buffer.append({
+                "raw": raw,
+                "timestamp": ts,
+            })
+
+        return jsonify({
+            "status": "ok",
+            "received": raw,
+            "buffer_size": len(raw_buffer),
+        })
+
+    return app