手機感測器儀表板

# 邊緣運算 / PC 端 Python 接收器範例
# 支援 WebSocket (需要 pip install websockets) 與 HTTP POST

import asyncio
import json
from http.server import HTTPServer, BaseHTTPRequestHandler
import sys

# === 選擇 1：WebSocket 伺服器 (預設運行在 8080 Port) ===
async def ws_handler(websocket, path=None):
    print(f"[WS] 裝置已連線: {websocket.remote_address}")
    try:
        async for message in websocket:
            data = json.loads(message)
            # 讀取感測器數值
            accel = data.get("accel", {})
            orient = data.get("orient", {})
            gforce = data.get("gforce", "N/A")
            print(f"[WS] G-Force: {gforce} G | Accel X/Y/Z: {accel.get('x'):.2f}, {accel.get('y'):.2f}, {accel.get('z'):.2f} | Orient A/B/G: {orient.get('alpha'):.1f}°, {orient.get('beta'):.1f}°, {orient.get('gamma'):.1f}°")
    except Exception as e:
        print(f"[WS] 連線中斷: {e}")

async def start_ws():
    import websockets
    server = await websockets.serve(ws_handler, "0.0.0.0", 8080)
    print("🚀 WebSocket 伺服器已啟動，聆聽位址 ws://0.0.0.0:8080")
    await server.wait_closed()

# === 選擇 2：HTTP POST 伺服器 (預設運行在 8080 Port) ===
class HTTPRequestHandler(BaseHTTPRequestHandler):
    def do_OPTIONS(self):
        # 處理 CORS 預檢請求
        self.send_response(200)
        self.send_header("Access-Control-Allow-Origin", "*")
        self.send_header("Access-Control-Allow-Methods", "POST, GET, OPTIONS")
        self.send_header("Access-Control-Allow-Headers", "Content-Type")
        self.end_headers()

    def do_POST(self):
        content_length = int(self.headers['Content-Length'])
        post_data = self.rfile.read(content_length)
        
        # 跨域 Header
        self.send_response(200)
        self.send_header("Access-Control-Allow-Origin", "*")
        self.send_header("Content-Type", "application/json")
        self.end_headers()
        self.wfile.write(b'{"status":"ok"}')

        try:
            data = json.loads(post_data.decode('utf-8'))
            accel = data.get("accel", {})
            gforce = data.get("gforce", "N/A")
            print(f"[HTTP] G-Force: {gforce} G | Accel X/Y/Z: {accel.get('x'):.2f}, {accel.get('y'):.2f}, {accel.get('z'):.2f}")
        except Exception as e:
            print(f"[HTTP] 解析資料失敗: {e}")

def start_http():
    server_address = ('0.0.0.0', 8080)
    httpd = HTTPServer(server_address, HTTPRequestHandler)
    print("🚀 HTTP POST 伺服器已啟動，聆聽位址 http://0.0.0.0:8080")
    try:
        httpd.serve_forever()
    except KeyboardInterrupt:
        pass
    print("HTTP 伺服器已關閉。")

if __name__ == "__main__":
    if len(sys.argv) > 1 and sys.argv[1] == "http":
        start_http()
    else:
        try:
            asyncio.run(start_ws())
        except ImportError:
            print("⚠️ 未安裝 websockets 套件。請執行 'pip install websockets' 安裝，或改用 HTTP 伺服器：'python server.py http'")