# Edge 디바이스에서 서버로 데이터 push
import socketio

sio = socketio.Client()
sio.connect('http://SERVER_IP:8010')

# 플랫폼별 채널에 emit
sio.emit('edge_drone_state', payload_dict)   # DRONE
sio.emit('edge_ugv_state',   payload_dict)   # UGV
sio.emit('edge_usv_state',   payload_dict)   # USV
sio.emit('edge_uuv_state',   payload_dict)   # UUV
sio.emit('edge_mcm_state',   payload_dict)   # MCM

{
  "platform":    "DRONE",          // REQUIRED — DRONE | UGV | USV | UUV | MCM
  "unit_id":     "UGV-01",         // REQUIRED — 유닛 식별자
  "timestamp":   1712900000.123,   // REQUIRED — Unix epoch (초, 소수점 ms)
  "tick":        1042,             // REQUIRED — 단조 증가 프레임 카운터
  "fw_version":  "1.0.0",          // OPTIONAL — Edge 펌웨어 버전
  "health": {                       // OPTIONAL — Edge 자기진단
    "cpu_pct":    42.5,
    "ram_pct":    61.0,
    "temp_c":     58.2,
    "uptime_s":   3600
  },
  // ... 플랫폼별 페이로드 (아래 각 섹션 참조)
}

{
  /* ── 공통 헤더 ── */
  "platform":   "DRONE",
  "unit_id":    "UAV-01",
  "timestamp":  1712900000.0,
  "tick":       1042,

  /* ── 비행 상태 ── */
  "lat":        37.123456,        // 위도 (°)
  "lon":        127.123456,       // 경도 (°)
  "alt":        85.3,             // 고도 MSL (m)
  "alt_rel":    82.1,             // 지면 기준 상대 고도 (m)
  "heading":    275.4,            // 기수 방위 (°, 0~360)
  "speed":      12.5,             // 지면 속도 (m/s)
  "vspeed":     -0.3,             // 수직 속도 (m/s, 하강 음수)
  "pitch":      -2.1,             // 피치 (°)
  "roll":       5.8,              // 롤 (°)
  "flight_mode": "GUIDED",         // 비행 모드
  "armed":      true,             // 시동 여부

  /* ── 배터리 ── */
  "battery_pct": 78.5,            // 배터리 잔량 (%)
  "voltage_v":   22.1,            // 셀 전압 (V)

  /* ── AI 탐지 결과 (YOLO 온디바이스) ── */
  "detections": [
    {
      "id":         "TGT-001",
      "class":      "vehicle",       // 탐지 클래스
      "confidence": 0.92,
      "bbox":       [120, 80, 200, 160],  // [x1,y1,x2,y2] px
      "distance_m": 340.0,          // 추정 거리 (m)
      "bearing":    280.5           // 방위각 (°)
    }
  ],

  /* ── FPV 영상 ── */
  "video_url":  "rtsp://192.168.1.10:8554/fpv"  // RTSP 스트림 URL
}

{
  "platform":    "UGV",
  "unit_id":     "UGV-01",
  "timestamp":   1712900000.0,
  "tick":        512,

  /* ── 위치·이동 ── */
  "lat":         37.123456,
  "lon":         127.123456,
  "heading":     90.0,             // 진행 방위 (°)
  "speed_ms":    3.2,              // 이동 속도 (m/s)
  "mode":        "PATROL",         // PATROL | INVESTIGATE | EVADE | STANDBY

  /* ── 센서 융합 ── */
  "sensors": {
    "eoir":    { "active": true,  "confidence": 0.88 },  // EO/IR 카메라
    "lidar":   { "active": true,  "confidence": 0.92 },  // LiDAR
    "audio":   { "active": false, "confidence": 0.10 },  // 음향 탐지
    "rf":      { "active": false, "confidence": 0.05 }   // RF 신호 탐지
  },
  "fused_confidence": 0.84,        // 가중 융합 신뢰도
  "threat_class":     "Personnel",  // 위협 분류
  "threat_level":     "HIGH",       // NONE|LOW|MEDIUM|HIGH|CRITICAL
  "threat_distance_m":45.0,
  "threat_bearing":   120.0,

  /* ── 시스템 ── */
  "battery_pct":  68.0,
  "motor_temp_c": 52.3,
  "lidar_range_m":0.5             // LiDAR 최근접 장애물 거리
}

{
  "platform":    "USV",
  "unit_id":     "USV-01",
  "timestamp":   1712900000.0,
  "tick":        210,

  /* ── 항법 ── */
  "lat":         36.5000,
  "lon":         126.5000,
  "heading":     045.0,
  "speed_kts":   8.5,              // 노트
  "depth_m":     0.0,              // 수상 = 0
  "mode":        "PATROL",

  /* ── 해상 센서 ── */
  "sensors": {
    "radar":    { "active": true,  "confidence": 0.90, "range_m": 5000 },
    "ais":      { "active": true,  "contacts": 3 },
    "eoir":     { "active": true,  "confidence": 0.75 },
    "sonar":    { "active": false, "confidence": 0.0 }   // 수상에서는 미사용
  },
  "fused_confidence": 0.80,
  "threat_class":     "Surface_Vessel",
  "threat_level":     "MEDIUM",
  "threat_distance_m":1200.0,
  "threat_bearing":   280.0,

  /* ── 환경 ── */
  "wave_height_m":   0.8,
  "wind_speed_ms":   5.2,
  "sea_state":       2,              // Beaufort 해상 상태 (0~12)
  "battery_pct":     85.0
}

{
  "platform":    "UUV",
  "unit_id":     "UUV-01",
  "timestamp":   1712900000.0,
  "tick":        88,

  /* ── 항법 (GPS 없음 → INS+DVL) ── */
  "depth_m":     55.0,             // 수압계 측정 수심
  "heading":     045.0,
  "speed_kts":   4.0,
  "pitch_deg":   -1.5,
  "roll_deg":    2.3,
  "wp_idx":      3,                // 현재 웨이포인트 인덱스

  /* ── 수중 센서 4종 ── */
  "sensors": {
    "sonar":    { "active": true,  "confidence": 0.84 },  // 음파
    "hydro":    { "active": true,  "confidence": 0.78 },  // 음파 (수동청음)
    "dvl":      { "active": true,  "confidence": 0.95 },  // 음파 (속도계)
    "optical":  { "active": false, "confidence": 0.10 }   // 레이저 광학
  },
  "fused_confidence": 0.72,
  "threat_class":     "Enemy_Sub",
  "threat_level":     "HIGH",
  "threat_distance_m":2400.0,
  "threat_bearing":   280.0,
  "threat_elev_m":    -120.0,       // 위협 고도 (수심, 음수=수중)

  /* ── 환경 (CTD) ── */
  "water_temp_c":   12.5,
  "salinity_ppt":   34.5,          // 염도 → 음속 보정
  "battery_pct":    87.0,

  /* ── 광섬유 테더 ── */
  "tether": {
    "connected":  true,
    "length_m":   68.75,           // 전개 길이 (depth × 1.25)
    "tension_n":  42.0,            // 케이블 장력 (N)
    "data_gbps":  1.0,
    "latency_ms": 4.8,
    "winch":      "HOLDING"        // STANDBY|DEPLOYING|HOLDING|REELING
  }
}

{
  "platform":    "MCM",
  "unit_id":     "MCM-01",
  "timestamp":   1712900000.0,
  "tick":        44,

  /* ── MCM 항법 ── */
  "depth_m":     25.0,
  "heading":     090.0,
  "speed_kts":   2.0,             // MCM은 저속 탐색 (1~3 kts)
  "mode":        "Search",        // Search|Classify|Investigate|Neutralize|Mark
  "scan_coverage_pct": 34.5,      // 누적 탐색 커버리지

  /* ── MCM 4종 센서 ── */
  "sensors": {
    "sss":     { "active": true,  "confidence": 0.88, "range_m": 200 },  // 음파
    "fls":     { "active": true,  "confidence": 0.82, "range_m": 80  },  // 음파
    "optical": { "active": false, "confidence": 0.10 },               // 레이저 광학
    "mag":     { "active": false, "confidence": 0.05 }                // 자기장
  },
  "fused_confidence":  0.0,        // 탐지 없음
  "mine_type":         "None",     // None|Moored|Bottom|Limpet|Influence|Drift
  "threat_level":      "NONE",

  /* ── 탐지된 기뢰 목록 ── */
  "mines": [
    {
      "mine_id":         "MINE-001",
      "mine_type":       "Moored",
      "status":          "CONFIRMED",   // POSSIBLE|PROBABLE|CONFIRMED|NEUTRALIZED
      "confidence":      0.94,
      "distance_m":      140.0,
      "bearing":         45.0,
      "depth_m":         18.0,
      "neutralize_method": "와이어 절단기"
    }
  ],
  "mines_detected":    1,
  "mines_confirmed":   1,
  "mines_neutralized": 0,

  /* ── 지휘관 승인 루프 ── */
  "need_commander":    false,
  "action_text":       "저속 래스터 탐색 중 (SSS 전개)",

  /* ── 광섬유 테더 ── */
  "tether": {
    "connected":  true,
    "length_m":   31.25,
    "tension_n":  18.0,
    "data_gbps":  1.0,
    "latency_ms": 4.1,
    "winch":      "DEPLOYING"
  },

  /* ── 환경 ── */
  "water_temp_c":  14.2,
  "salinity_ppt":  34.5,
  "battery_pct":   94.0
}

{
  "target":    "UGV-01",         // 대상 유닛 ID
  "cmd":       "SET_MODE",       // 명령 종류
  "params": {
    "mode":    "PATROL"
  },
  "issued_by": "OPERATOR-1",
  "timestamp": 1712900000.0
}

# 계류기뢰 탐지 시나리오 주입
curl -X POST https://fpv.exko.kr/api/mcm/inject \
  -H "Content-Type: application/json" \
  -d '{"scenario":"moored_mine"}'

# 현재 MCM 상태 조회
curl https://fpv.exko.kr/api/mcm/state | python3 -m json.tool

모함 (서버)
    │
    │  광섬유 케이블 (≤500m, 1Gbps)
    │  + 전력선 (DC 48V, 선택)
    │
윈치 / 슬립링
    │
내압 관통 커넥터
    │
광전 변환기 (Media Converter)
  SFP → RJ45 Ethernet
    │
Edge 디바이스 (Jetson TX2)
  eth0: 1 Gbps
    │
소나 인터페이스 보드
카메라 / MAG 센서

# Jetson / RPi Edge 디바이스에서
pip install python-socketio[client] requests

"""
fpv_edge_agent.py — 최소 Edge 에이전트
플랫폼에 맞는 채널명과 페이로드로 수정하여 사용
"""
import socketio, time, json

SERVER = "http://192.168.1.100:8010"   # 서버 IP 수정
UNIT   = "MCM-01"
CHAN   = "edge_mcm_state"              # 플랫폼별 채널

sio = socketio.Client()

@sio.event
def connect():
    print("✅ 서버 연결됨")

@sio.on("cmd")           # 서버 → Edge 명령 수신
def on_cmd(data):
    print(f"CMD: {data}")
    # 명령 처리 로직 구현

sio.connect(SERVER)
tick = 0

while True:
    payload = {
        "platform":  "MCM",
        "unit_id":   UNIT,
        "timestamp": time.time(),
        "tick":      tick,
        # ─── 실제 센서 데이터로 교체 ───
        "depth_m":   25.0,
        "heading":   90.0,
        "speed_kts": 2.0,
        "tether": { "connected": True, "length_m": 31.2 }
    }
    sio.emit(CHAN, payload)
    tick += 1
    time.sleep(1.0)   # 1 Hz

# backend/main.py에 추가
@sio.on("edge_mcm_state")
async def edge_mcm(sid, data):
    """Edge → 서버 수신 후 HUD로 브로드캐스트"""
    await sio.emit("mcm_state", data)   # HUD 채널로 전달
    # 선택: mcm_pipeline.apply_edge_data(data)  시뮬 엔진 교체