Vigil Platform API v1

from mnemos_client import MnemosClient

client = MnemosClient.login(base_url="https://yourdomain.com",
                             email="you@example.com", password="secret")
token_raw = client.tokens.create(hardware_id="SIM-001", name="Dev Token")

client.ingest(token_raw=token_raw, hardware_id="SIM-001", measurements=[
    {"binding_id": "<uuid>", "value": 22.5},
    {"binding_id": "<uuid2>", "value": 1013.2},
])

await fetch("/api/v1/ingest/", {
  method: "POST",
  headers: {
    "Content-Type": "application/json",
    "Authorization": "Bearer gw_<gateway-token>"
  },
  body: JSON.stringify({
    hardware_id: "SIM-001",
    measurements: [
      { binding_id: "<uuid>",  value: 22.5 },
      { binding_id: "<uuid2>", value: 1013.2 },
    ]
  })
});

raw_token = client.tokens.create(hardware_id="SIM-001", name="Dev Token")
# raw_token == "gw_Kx9..." — store this securely

import requests
r = requests.get("https://yourdomain.com/api/v1/devices/",
    headers={"Authorization": "Bearer <token>"})
devices = r.json()["results"]

const r = await fetch("/api/v1/devices/", {
  headers: { "Authorization": "Bearer <token>" }
});
const { results: devices } = await r.json();

r = requests.get(f"https://yourdomain.com/api/v1/devices/{device_id}/",
    headers={"Authorization": "Bearer <token>"})
device = r.json()

const device = await (await fetch(`/api/v1/devices/${deviceId}/`,
  { headers: { "Authorization": "Bearer <token>" } })).json();

r = requests.get(f"https://yourdomain.com/api/v1/devices/{device_id}/latest/",
    headers={"Authorization": "Bearer <token>"})
latest = r.json()["readings"]

const { readings } = await (await fetch(`/api/v1/devices/${deviceId}/latest/`,
  { headers: { "Authorization": "Bearer <token>" } })).json();

device = client.devices.create(hardware_id="SIM-001", display_name="My Sensor")
print(device["id"])  # UUID to use in binding calls

bindings = client.devices.bindings(device_id="<uuid>")
for b in bindings:
    print(b["id"], b["quantity"]["slug"])

binding = client.devices.create_binding(
    device_id="<uuid>",
    channel=0,
    quantity_slug="temperature.celsius",
)
print(binding["id"])  # use this as binding_id in ingest calls

r = requests.get("https://yourdomain.com/api/v1/sites/",
    headers={"Authorization": "Bearer <token>"})
sites = r.json()["results"]

const { results: sites } = await (await fetch("/api/v1/sites/",
  { headers: { "Authorization": "Bearer <token>" } })).json();

r = requests.get(f"https://yourdomain.com/api/v1/sites/{site_id}/",
    headers={"Authorization": "Bearer <token>"})
site = r.json()

import requests
r = requests.get(
    "https://yourdomain.com/api/v1/explorer/query/",
    headers={"Authorization": "Bearer <token>"},
    params={
        "binding_ids": "<uuid1>,<uuid2>",
        "start": "-1h",
        "max_points": 500,
    }
)
data = r.json()
timestamps = data["timestamps"]
for series in data["series"]:
    print(series["label"], series["values"])

const params = new URLSearchParams({
  binding_ids: "<uuid1>,<uuid2>",
  start: "-1h",
  max_points: "500",
});
const r = await fetch(`/api/v1/explorer/query/?${params}`, {
  headers: { "Authorization": "Bearer <token>" }
});
const { timestamps, series } = await r.json();

# List all mechanical quantities
results = client.quantities.list(domain="mechanical")
for q in results["results"]:
    print(q["slug"], q["base_unit_symbol"])

qty = client.quantities.get("temperature.celsius")
print(qty["si_unit"])

r = requests.get("https://yourdomain.com/api/v1/alerts/",
    headers={"Authorization": "Bearer <token>"},
    params={"status": "active", "severity": "critical"})
events = r.json()["events"]

const r = await fetch("/api/v1/alerts/?status=active&severity=critical",
  { headers: { "Authorization": "Bearer <token>" } });
const { events } = await r.json();

r = requests.get(f"https://yourdomain.com/api/v1/alerts/{event_id}/",
    headers={"Authorization": "Bearer <token>"})
alert = r.json()

const alert = await (await fetch(`/api/v1/alerts/${eventId}/`,
  { headers: { "Authorization": "Bearer <token>" } })).json();

import sseclient, requests, json

resp = requests.get("https://yourdomain.com/api/v1/alerts/stream/",
    headers={"Authorization": "Bearer <token>"}, stream=True)

for event in sseclient.SSEClient(resp):
    if event.event == "alert":
        alert = json.loads(event.data)
        print(f"ALERT: {alert['device']} — {alert['severity']}")

r = requests.get("https://yourdomain.com/api/v1/alerts/rules/",
    headers={"Authorization": "Bearer <token>"})
rules = r.json()["rules"]

const { rules } = await (await fetch("/api/v1/alerts/rules/",
  { headers: { "Authorization": "Bearer <token>" } })).json();

r = requests.get("https://yourdomain.com/api/v1/canvas/",
    headers={"Authorization": "Bearer <token>"})
dashboards = r.json()["dashboards"]

const { dashboards } = await (await fetch("/api/v1/canvas/",
  { headers: { "Authorization": "Bearer <token>" } })).json();

<!-- Embed in an iframe -->
<iframe
  src="https://yourdomain.com/api/v1/canvas/public/<token>/"
  width="100%" height="600"
  frameborder="0"
  allowfullscreen>
</iframe>

const r = await fetch(`/api/v1/canvas/public/${token}/query/`, {
  method: "POST",
  headers: { "Content-Type": "application/json" },
  body: JSON.stringify({
    binding_ids: ["<uuid>"],
    start: new Date(Date.now() - 3600_000).toISOString(),
    end:   new Date().toISOString(),
  })
});
const { series } = await r.json();

r = requests.post("https://yourdomain.com/api/v1/ai/nlq/",
    headers={"Authorization": "Bearer <token>"},
    json={"question": "What was the peak vibration on Pump 1 this month?"})
result = r.json()
print(result["answer"])   # plain-English answer
print(result["sql"])      # generated SQL

const r = await fetch("/api/v1/ai/nlq/", {
  method: "POST",
  headers: { "Content-Type": "application/json", "Authorization": "Bearer <token>" },
  body: JSON.stringify({ question: "Show CO2 trends for floor 2 this week" })
});
const { answer, sql, chart_data } = await r.json();

import json, requests

resp = requests.post(
    "https://yourdomain.com/api/v1/ai/argus/message/",
    headers={"Authorization": "Bearer <token>"},
    json={"message": "What is the current vibration level on Pump 1?"},
    stream=True,
)
for line in resp.iter_lines():
    if not line or not line.startswith(b"data: "):
        continue
    ev = json.loads(line[6:])
    if ev["event"] == "token":
        print(ev["text"], end="", flush=True)
    elif ev["event"] == "done":
        print(f"\n[conversation: {ev['conversation_id']}]")
        break

r = requests.get("https://yourdomain.com/api/v1/ai/argus/conversations/",
    headers={"Authorization": "Bearer <token>"})
conversations = r.json()["conversations"]

# Search
r = requests.get("https://yourdomain.com/api/v1/ai/argus/memory/",
    headers={"Authorization": "Bearer <token>"},
    params={"q": "bearing failure"})
memories = r.json()["memories"]

# Create
r = requests.post("https://yourdomain.com/api/v1/ai/argus/memory/",
    headers={"Authorization": "Bearer <token>"},
    json={"content": "CO2 sensor on Floor 2 prone to drift",
          "memory_type": "observation", "salience": 0.7})

r = requests.get("https://yourdomain.com/api/v1/ai/argus/investigations/",
    headers={"Authorization": "Bearer <token>"})
invs = [i for i in r.json()["investigations"] if i["status"] == "complete"]

r = requests.get("https://yourdomain.com/api/v1/prism/fields/",
    headers={"Authorization": "Bearer <token>"})
fields = r.json()["fields"]

r = requests.get(f"https://yourdomain.com/api/v1/prism/{field_id}/data/",
    headers={"Authorization": "Bearer <token>"},
    params={"start": "2026-04-13T00:00:00Z"})
data = r.json()

import requests
r = requests.get("https://yourdomain.com/api/v1/pdp/types/",
    headers={"Authorization": "Bearer <token>"},
    params={"peripheral_class": "thermal", "contribution_status": "official"})
types = r.json()["results"]