고감도 센서 연동 API

curl -X POST \
  https://your-domain.com/api/sensor/event \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "sensorId": "sensor-001",
    "eventType": "enter",
    "count": 1
  }'

import requests
import time

API_KEY = "sk_live_your_api_key_here"
BASE_URL = "https://your-domain.com/api/sensor"
HEADERS = {
    "Authorization": f"Bearer {API_KEY}",
    "Content-Type": "application/json"
}

# 단건 이벤트 전송
def send_event(sensor_id, event_type, count=None):
    payload = {
        "sensorId": sensor_id,
        "eventType": event_type,
        "eventAt": int(time.time() * 1000)
    }
    if count is not None:
        payload["count"] = count
    
    response = requests.post(
        f"{BASE_URL}/event",
        json=payload,
        headers=HEADERS
    )
    return response.json()

# 배치 이벤트 전송
def send_batch_events(events):
    response = requests.post(
        f"{BASE_URL}/events/batch",
        json={"events": events},
        headers=HEADERS
    )
    return response.json()

# 하트비트 전송
def send_heartbeat(sensor_id, battery=None):
    payload = {"sensorId": sensor_id, "status": "online"}
    if battery is not None:
        payload["battery"] = battery
    
    response = requests.post(
        f"{BASE_URL}/heartbeat",
        json=payload,
        headers=HEADERS
    )
    return response.json()

# 사용 예시
result = send_event("sensor-001", "enter", count=1)
print(result)  # {"success": true, "message": "Event recorded"}

#include <WiFi.h>
#include <HTTPClient.h>
#include <ArduinoJson.h>

const char* API_KEY = "sk_live_your_api_key_here";
const char* BASE_URL = "https://your-domain.com/api/sensor";
const char* SENSOR_ID = "sensor-esp32-001";

void sendOccupancyEvent(const char* eventType, int count) {
  HTTPClient http;
  String url = String(BASE_URL) + "/event";
  
  http.begin(url);
  http.addHeader("Authorization", String("Bearer ") + API_KEY);
  http.addHeader("Content-Type", "application/json");
  
  StaticJsonDocument<256> doc;
  doc["sensorId"] = SENSOR_ID;
  doc["eventType"] = eventType;
  doc["count"] = count;
  doc["eventAt"] = millis();  // 실제로는 NTP 시각 사용 권장
  
  String payload;
  serializeJson(doc, payload);
  
  int httpCode = http.POST(payload);
  if (httpCode == 200) {
    Serial.println("Event sent successfully");
  } else {
    Serial.printf("Error: %d\n", httpCode);
  }
  http.end();
}

void sendHeartbeat(int battery, int rssi) {
  HTTPClient http;
  String url = String(BASE_URL) + "/heartbeat";
  
  http.begin(url);
  http.addHeader("Authorization", String("Bearer ") + API_KEY);
  http.addHeader("Content-Type", "application/json");
  
  StaticJsonDocument<256> doc;
  doc["sensorId"] = SENSOR_ID;
  doc["status"] = "online";
  doc["battery"] = battery;
  doc["rssi"] = rssi;
  doc["firmware"] = "v1.0.0";
  
  String payload;
  serializeJson(doc, payload);
  http.POST(payload);
  http.end();
}

void setup() {
  Serial.begin(115200);
  // WiFi 연결 코드...
}

void loop() {
  // PIR 센서 감지 시 이벤트 전송
  if (digitalRead(PIR_PIN) == HIGH) {
    sendOccupancyEvent("enter", 1);
    delay(5000);  // 디바운스
  }
  
  // 10분마다 하트비트 전송
  static unsigned long lastHeartbeat = 0;
  if (millis() - lastHeartbeat > 600000) {
    sendHeartbeat(analogRead(BATTERY_PIN), WiFi.RSSI());
    lastHeartbeat = millis();
  }
}

const API_KEY = process.env.SENSOR_API_KEY;
const BASE_URL = "https://your-domain.com/api/sensor";

async function sendEvent(sensorId, eventType, count) {
  const response = await fetch(`${BASE_URL}/event`, {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${API_KEY}`,
      "Content-Type": "application/json"
    },
    body: JSON.stringify({
      sensorId,
      eventType,
      count,
      eventAt: Date.now()
    })
  });
  return response.json();
}

async function sendBatchEvents(events) {
  const response = await fetch(`${BASE_URL}/events/batch`, {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${API_KEY}`,
      "Content-Type": "application/json"
    },
    body: JSON.stringify({ events })
  });
  return response.json();
}

// 사용 예시
const result = await sendEvent("sensor-001", "enter", 1);
console.log(result);