Créer pour OpenClone

import httpx, time, uuid

client = httpx.Client(
    base_url="http://localhost:8000",
    headers={"X-API-Key": "your-api-key"}
)

def ingest(text: str, app_name: str = "") -> dict:
    payload = {
        "source_type": "audio_system",
        "platform": "macos",
        "device_id": "my-device-uuid",
        "plugin_id": "my-audio-plugin",
        "plugin_version": "1.0.0",
        "timestamp": time.time(),
        "events": [{"timestamp": time.time(),
            "data": {"text": text, "app_name": app_name, "duration": 60},
            "raw_ref": str(uuid.uuid4())}]
    }
    resp = client.post("/api/v1/ingest", json=payload)
    resp.raise_for_status()
    return resp.json()

result = ingest("We shipped the feature today.", app_name="Zoom")
print(result)  # {"stored": 1, "skipped": 0, "file": "Audio/2026-02-26.md"}

const BASE = 'http://localhost:8000';
const KEY  = 'your-api-key';

async function ingest(text, appName = '') {
  const payload = {
    source_type: 'audio_system', platform: 'macos',
    device_id: 'my-device-uuid', plugin_id: 'my-audio-plugin',
    plugin_version: '1.0.0', timestamp: Date.now() / 1000,
    events: [{
      timestamp: Date.now() / 1000,
      data: { text, app_name: appName, duration: 60, confidence: 0.95 },
      raw_ref: crypto.randomUUID(),
    }],
  };
  const res = await fetch(BASE + '/api/v1/ingest', {
    method: 'POST',
    headers: { 'Content-Type': 'application/json', 'X-API-Key': KEY },
    body: JSON.stringify(payload),
  });
  if (!res.ok) throw new Error('Ingest failed: ' + res.status);
  return res.json();
}

const result = await ingest('We shipped the feature today.', 'Zoom');
console.log(result); // { stored: 1, file: 'Audio/2026-02-26.md' }

import Foundation

struct IngestEvent: Codable {
    let timestamp: Double
    let data: [String: String]
    let raw_ref: String
}
struct IngestPayload: Codable {
    let source_type, platform, device_id, plugin_id, plugin_version: String
    let timestamp: Double; let events: [IngestEvent]
}

func ingest(text: String, appName: String) async throws {
    guard let url = URL(string: "http://localhost:8000/api/v1/ingest") else { return }
    var request = URLRequest(url: url)
    request.httpMethod = "POST"
    request.setValue("application/json", forHTTPHeaderField: "Content-Type")
    request.setValue("your-api-key", forHTTPHeaderField: "X-API-Key")
    let payload = IngestPayload(
        source_type: "audio_system", platform: "macos",
        device_id: "my-uuid", plugin_id: "my-plugin", plugin_version: "1.0.0",
        timestamp: Date().timeIntervalSince1970,
        events: [IngestEvent(
            timestamp: Date().timeIntervalSince1970,
            data: ["text": text, "app_name": appName],
            raw_ref: UUID().uuidString
        )]
    )
    request.httpBody = try JSONEncoder().encode(payload)
    let (data, _) = try await URLSession.shared.data(for: request)
    print(String(data: data, encoding: .utf8) ?? "")
}