Отправка событий с устройства.

Shell — subrose emit

Самый простой способ. Работает везде, где установлен пакет subrose. Флаг --data принимает JSON-объект; без него поле data остаётся пустым.

# Простое событие без данных
subrose emit --name door_open

# Событие с данными
subrose emit --name wifi_connected --data '{"ssid":"HomeNet","rssi":-55}'

# В скрипте init.d / cron (например, при смене DNS)
/opt/subrose/subrose emit --name dns_changed --data "{\"server\":\"$DNS\"}"

Shell — прямая запись в сокет (socat / nc)

Если subrose emit недоступен, событие пишут в сокет напрямую. Подходит для скриптов init.d на Keenetic/OpenWrt, где нет пути к бинарю.

# socat (широко доступен в OpenWrt/opkg)
echo '{"name":"reboot","data":{}}' | socat - UNIX-CONNECT:/var/run/subrose/subrose.sock

# nc с поддержкой unix-сокетов (BusyBox nc не поддерживает -U, там нужен socat)
# На Linux с полноценным nc:
echo '{"name":"reboot","data":{}}' | nc -U /var/run/subrose/subrose.sock

Python 3

Встроенный модуль socket — дополнительных зависимостей нет. Работает на Linux, macOS и Raspberry Pi.

import socket, json

SOCK_PATH = "/var/run/subrose/subrose.sock"  # или из конфига

def emit(name: str, data: dict = None):
    payload = json.dumps({"name": name, "data": data or {}}) + "\n"
    with socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) as s:
        s.connect(SOCK_PATH)
        s.sendall(payload.encode())

# Пример использования
emit("temperature", {"celsius": 42.5, "sensor": "cpu"})
emit("disk_full",  {"path": "/data", "used_pct": 97})

C (POSIX)

Минимальный фрагмент для встраивания в системный демон или init-скрипт на OpenWrt / Keenetic. Зависимостей нет, только POSIX-сокеты.

#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <unistd.h>

#define SOCK_PATH "/var/run/subrose/subrose.sock"

int subrose_emit(const char *name, const char *data_json) {
    int fd = socket(AF_UNIX, SOCK_STREAM, 0);
    if (fd < 0) return -1;

    struct sockaddr_un addr = {0};
    addr.sun_family = AF_UNIX;
    strncpy(addr.sun_path, SOCK_PATH, sizeof(addr.sun_path) - 1);

    if (connect(fd, (struct sockaddr *)&addr, sizeof(addr)) < 0) {
        close(fd); return -1;
    }

    char buf[4096];
    int n = snprintf(buf, sizeof(buf),
        "{\"name\":\"%s\",\"data\":%s}\n", name, data_json ? data_json : "{}");
    write(fd, buf, n);
    close(fd);
    return 0;
}

/* Пример: */
int main(void) {
    subrose_emit("sensor_alert", "{\"type\":\"overheat\",\"temp\":85}");
    return 0;
}

Windows — named pipe (на подходе)

Рецепт заработает вместе со сборкой агента для Windows, она на подходе (см. «Пакеты»). Агент будет слушать именованный канал \\.\pipe\subrose. Удобнее всего будет вызывать subrose emit, а в C/C++ подойдут CreateFile и WriteFile.

# PowerShell
$pipe = [System.IO.File]::Open('\\.\pipe\subrose',
    [System.IO.FileMode]::Open, [System.IO.FileAccess]::Write,
    [System.IO.FileShare]::None)
$bytes = [System.Text.Encoding]::UTF8.GetBytes(
    '{"name":"vpn_up","data":{"peer":"10.0.0.1"}}' + "`n")
$pipe.Write($bytes, 0, $bytes.Length)
$pipe.Close()

# Структура по умолчанию:
# <stateDir>/collectors/
#   cpu_temp.sh
#   disk_usage.sh
#   wan_status.sh

# Пример: cpu_temp.sh (должен быть chmod +x)
#!/bin/sh
TEMP=$(cat /sys/class/thermal/thermal_zone0/temp 2>/dev/null || echo 0)
# Агент ожидает валидный JSON-объект на stdout.
# Если stdout — не JSON, агент оборачивает: {"output":"..."}
printf '{"celsius":%d}' "$((TEMP / 1000))"

Имя события = имя файла скрипта (например, cpu_temp.sh). Пример расписания для запуска каждые 5 минут: */5 * * * *. Каждые 2 часа по будням: 0 */2 * * 1-5.