cacto
3ade5c2512
device-control-service: HTTP/JSON API (internal/httpapi) рядом с gRPC —
POST /devices/{id}/turn-on|turn-off|set-level, тот же server.Server внутри,
без дублирования логики. Решение вместо gRPC-клиента на PHP: grpc/grpc
через PECL компилируется в Alpine 10-20+ минут и утяжеляет образ, а
диаграмма архитектуры в ТЗ и так допускала HTTP для Laravel→device-control.
Laravel: DeviceShadow (чтение Device Shadow из Redis, MGET одним запросом
для списка устройств), ClickHouseClient (HTTP-интерфейс ClickHouse,
параметризованные {name:Type}-запросы), DeviceControlClient (HTTP-вызовы
к новому Go-эндпоинту). Redis-клиент — predis (чистый PHP), а не phpredis,
по той же причине, что и решение по gRPC — не добавлять ещё одну
C-компиляцию в образ.
DeviceController::show — страница устройства: live-статус/last_seen/
desired-reported state из Redis, история показаний из ClickHouse (для
сенсоров), кнопки ручного управления (для актуаторов, только owner,
с проверкой capability устройства). В devices/index — бейдж online/
offline/unknown. Дашборд дополнен счётчиком онлайн-устройств.
Два реальных бага найдены и исправлены при сквозной проверке:
1. Пустой action_params сериализовался в JSON-массив "[]" (PHP не
различает пустой список и пустой объект), а Go ждёт объект —
rule-engine-service падал на unmarshal. Фикс — JsonObjectCast
(JSON_FORCE_OBJECT) на AutomationRule::action_params.
2. Redis-ключи device shadow — общее пространство имён с Go-сервisами
(сырые ключи без префикса), а Laravel по умолчанию добавляет ко всем
ключам префикс "app-name-database-" — Laravel никогда не видел
реальные данные. Фикс — REDIS_PREFIX="" в окружении контейнера
(важно: пустое значение в docker-compose YAML нужно задавать явно
через "", просто "KEY:" означает "взять из окружения хоста").
Проверено сквозным тестом через docker compose: полный цикл телеметрия →
правило → команда воспроизведён вживую с реальным исправлением на лету;
ручное управление (turn_on/turn_off/set_level) из Laravel UI подтверждено
через браузер — HTTP-вызов к device-control-service, обновление
desired_state (merge-patch), реальная MQTT-команда поймана мониторингом
топика. 38/38 тестов Laravel, все Go-тесты device-control-service зелёные.
64 lines
2.1 KiB
PHP
64 lines
2.1 KiB
PHP
<?php
|
|
|
|
namespace App\Services;
|
|
|
|
use Illuminate\Support\Facades\Http;
|
|
use Illuminate\Support\Facades\Log;
|
|
|
|
/**
|
|
* HTTP client for device-control-service's manual-command API (see that
|
|
* service's README for why HTTP instead of gRPC here). Mirrors the
|
|
* gRPC CommandResult contract: {success, error} in the body — always
|
|
* returned as an array here too, never an exception, so callers don't need
|
|
* to distinguish "device rejected it" from "service unreachable" to render
|
|
* a flash message.
|
|
*/
|
|
class DeviceControlClient
|
|
{
|
|
public function __construct(private readonly string $baseUrl) {}
|
|
|
|
/** @return array{success: bool, error: ?string} */
|
|
public function turnOn(string $externalId): array
|
|
{
|
|
return $this->post("/devices/{$externalId}/turn-on");
|
|
}
|
|
|
|
/** @return array{success: bool, error: ?string} */
|
|
public function turnOff(string $externalId): array
|
|
{
|
|
return $this->post("/devices/{$externalId}/turn-off");
|
|
}
|
|
|
|
/** @return array{success: bool, error: ?string} */
|
|
public function setLevel(string $externalId, float $level): array
|
|
{
|
|
return $this->post("/devices/{$externalId}/set-level", ['level' => $level]);
|
|
}
|
|
|
|
/**
|
|
* @param array<string, mixed> $body
|
|
* @return array{success: bool, error: ?string}
|
|
*/
|
|
private function post(string $path, array $body = []): array
|
|
{
|
|
try {
|
|
$response = Http::timeout(5)->post("{$this->baseUrl}{$path}", $body);
|
|
} catch (\Illuminate\Http\Client\ConnectionException $e) {
|
|
Log::error('device-control-service unreachable', ['path' => $path, 'error' => $e->getMessage()]);
|
|
|
|
return ['success' => false, 'error' => 'device-control-service недоступен'];
|
|
}
|
|
|
|
if ($response->failed()) {
|
|
Log::error('device-control-service returned an error status', ['path' => $path, 'status' => $response->status()]);
|
|
|
|
return ['success' => false, 'error' => 'device-control-service вернул ошибку'];
|
|
}
|
|
|
|
return [
|
|
'success' => (bool) $response->json('success'),
|
|
'error' => $response->json('error'),
|
|
];
|
|
}
|
|
}
|