271 lines
8.9 KiB
PHP
271 lines
8.9 KiB
PHP
<?php
|
|
class EndpointsApi extends ApiController
|
|
{
|
|
public function default()
|
|
{
|
|
// $this->requireAuth();
|
|
$obj = $this->input;
|
|
|
|
//variables Definition
|
|
$command = "null";
|
|
|
|
//Log
|
|
$logManager = new LogManager('../logs/api/' . date("Y-m-d") . '.log');
|
|
$logManager->setLevel(LOGLEVEL);
|
|
|
|
//Token Checks
|
|
if ($obj['token'] == null || !isset($obj['token'])) {
|
|
$this->response([
|
|
'state' => 'unsuccess',
|
|
'errorMSG' => "Missing Value Token in JSON payload",
|
|
], 401);
|
|
die();
|
|
}
|
|
|
|
//Vstupní Checky
|
|
if (!DeviceManager::registeret($obj['token'])) {
|
|
//Notification data setup
|
|
$notificationMng = new NotificationManager;
|
|
$notificationData = [
|
|
'title' => 'Info',
|
|
'body' => 'New device Detected Found',
|
|
'icon' => BASEDIR . '/app/templates/images/icon-192x192.png',
|
|
];
|
|
|
|
//Subdevice Registration
|
|
$device = DeviceManager::create($obj['token'], $obj['token']);
|
|
foreach ($obj['values'] as $key => $value) {
|
|
if (!SubDeviceManager::getSubDeviceByMaster($device['device_id'], $key)) {
|
|
SubDeviceManager::create($device['device_id'], $key, UNITS[$key]);
|
|
}
|
|
}
|
|
|
|
//Notification for newly added Device
|
|
if ($notificationData != []) {
|
|
$subscribers = $notificationMng::getSubscription();
|
|
foreach ($subscribers as $key => $subscriber) {
|
|
$logManager->write("[NOTIFICATION] SENDING TO" . $subscriber['id'] . " ", LogRecordTypes::INFO);
|
|
$notificationMng::sendSimpleNotification(SERVERKEY, $subscriber['token'], $notificationData);
|
|
}
|
|
}
|
|
|
|
$logManager->write("[API] Registering Device", LogRecordTypes::INFO);
|
|
$this->response([
|
|
'state' => 'unsuccess',
|
|
'errorMSG' => "Device not registeret",
|
|
], 401);
|
|
}
|
|
|
|
if (!DeviceManager::approved($obj['token'])) {
|
|
$this->response([
|
|
'state' => 'unsuccess',
|
|
'errorMSG' => "Unaproved Device",
|
|
], 401);
|
|
}
|
|
|
|
$device = DeviceManager::getDeviceByToken($obj['token']);
|
|
DeviceManager::setHeartbeat($device['device_id']);
|
|
|
|
//Diagnostic
|
|
if (isset($obj['settings'])) {
|
|
$data = ['mac' => $obj['settings']["network"]["mac"], 'ip_address' => $obj['settings']["network"]["ip"]];
|
|
if (array_key_exists("firmware_hash", $obj['settings'])) {
|
|
$data['firmware_hash'] = $obj['settings']["firmware_hash"];
|
|
}
|
|
DeviceManager::editByToken($obj['token'], $data);
|
|
}
|
|
|
|
//Log Data Save
|
|
if (isset($obj['logs'])) {
|
|
foreach ($obj['logs'] as $log) {
|
|
$deviceLogManager = new LogManager('../logs/devices/' . date("Y-m-d") . '.log');
|
|
$deviceLogManager->setLevel(LOGLEVEL);
|
|
if ($log != 'HTTP_UPDATE_FAILD code-102 messageFile Not Found (404)') {
|
|
$deviceLogManager->write("[Device Log Msg] Device_ID " . $device['device_id'] . "->" . $log, LogRecordTypes::ERROR);
|
|
}
|
|
unset($deviceLogManager);
|
|
}
|
|
$this->response([
|
|
'state' => 'succes',
|
|
'command' => $command,
|
|
], 200);
|
|
die();
|
|
}
|
|
|
|
// Issuing command
|
|
if ($command == "null") {
|
|
$deviceCommand = $device["command"];
|
|
if ($deviceCommand != '' && $deviceCommand != null && $deviceCommand != "null") {
|
|
$command = $deviceCommand;
|
|
$data = [
|
|
'command' => 'null'
|
|
];
|
|
DeviceManager::editByToken($obj['token'], $data);
|
|
$logManager->write("[API] Device_ID " . $device['device_id'] . " executing command " . $command, LogRecordTypes::INFO);
|
|
}
|
|
}
|
|
|
|
$jsonAnswer = [];
|
|
$subDeviceLastReordValue = [];
|
|
|
|
if (isset($obj['values'])) {
|
|
//ZAPIS
|
|
foreach ($obj['values'] as $key => $value) {
|
|
if (!SubDeviceManager::getSubDeviceByMaster($device['device_id'], $key)) {
|
|
SubDeviceManager::create($device['device_id'], $key, UNITS[$key]);
|
|
}
|
|
|
|
$subDeviceLastReordValue[$key] = $value['value'];
|
|
RecordManager::create($device['device_id'], $key, round($value['value'], 3), 'device');
|
|
$logManager->write("[API] Device_ID " . $device['device_id'] . " writed value " . $key . ' ' . $value['value'], LogRecordTypes::INFO);
|
|
|
|
//notification
|
|
if ($key == 'door' || $key == 'water') {
|
|
$notificationMng = new NotificationManager;
|
|
$notificationData = [];
|
|
|
|
switch ($key) {
|
|
case 'door':
|
|
$notificationData = [
|
|
'title' => 'Info',
|
|
'body' => 'Someone just open up ' . $device['name'],
|
|
'icon' => BASEDIR . '/app/templates/images/icon-192x192.png',
|
|
];
|
|
|
|
break;
|
|
case 'water':
|
|
$notificationData = [
|
|
'title' => 'Alert',
|
|
'body' => 'Wather leak detected by ' . $device['name'],
|
|
'icon' => BASEDIR . '/app/templates/images/icon-192x192.png',
|
|
];
|
|
break;
|
|
}
|
|
if (DEBUGMOD) $notificationData['body'] .= ' value=' . $value['value'];
|
|
if ($notificationData != []) {
|
|
$subscribers = $notificationMng::getSubscription();
|
|
foreach ($subscribers as $key => $subscriber) {
|
|
$logManager->write("[NOTIFICATION] SENDING TO" . $subscriber['id'] . " ", LogRecordTypes::INFO);
|
|
$notificationMng::sendSimpleNotification(SERVERKEY, $subscriber['token'], $notificationData);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
//upravit format na setings-> netvork etc
|
|
|
|
$subDevicesTypeList = SubDeviceManager::getSubDeviceSTypeForMater($device['device_id']);
|
|
if (!in_array($subDevicesTypeList, ['on/off', 'door', 'water'])) {
|
|
$jsonAnswer['device']['sleepTime'] = $device['sleep_time'];
|
|
}
|
|
} else {
|
|
if (count(SubDeviceManager::getAllSubDevices($device['device_id'])) == 0) {
|
|
//SubDeviceManager::create($device['device_id'], 'on/off', UNITS[$key]);
|
|
//RecordManager::create($device['device_id'], 'on/off', 0);
|
|
}
|
|
|
|
$subDevicesData = SubDeviceManager::getAllSubDevices($device['device_id']);
|
|
|
|
foreach ($subDevicesData as $key => $subDeviceData) {
|
|
$subDeviceId = $subDeviceData['subdevice_id'];
|
|
$subDeviceLastReord = RecordManager::getLastRecord($subDeviceId);
|
|
if (!empty($subDeviceLastReord)) {
|
|
$subDeviceLastReordValue[$subDeviceData['type']] = $subDeviceLastReord['value'];
|
|
if ($subDeviceLastReord['execuded'] == 0) {
|
|
$logManager->write("[API] subDevice_ID " . $subDeviceId . " executed comand with value " . json_encode($subDeviceLastReordValue) . " executed " . $subDeviceLastReord['execuded'], LogRecordTypes::INFO);
|
|
RecordManager::setExecuted($subDeviceLastReord['record_id']);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
$hostname = "";
|
|
$hostname = strtolower($device['name']);
|
|
$hostname = str_replace(' ', '_', $hostname);
|
|
|
|
$jsonAnswer['device']['hostname'] = $hostname;
|
|
$jsonAnswer['state'] = 'succes';
|
|
$jsonAnswer['values'] = $subDeviceLastReordValue;
|
|
$jsonAnswer['command'] = $command;
|
|
|
|
$this->response($jsonAnswer);
|
|
// this method returns response as json
|
|
//unset($logManager); //TODO: Opravit
|
|
die();
|
|
}
|
|
|
|
protected function requireAuth()
|
|
{
|
|
if (isset($_SERVER['HTTP_AUTHORIZATION'])) {
|
|
// TODO: call appropriate class/method
|
|
$deviceManager = new DeviceManager();
|
|
list($type, $hash) = explode(' ', $_SERVER['HTTP_AUTHORIZATION']);
|
|
$this->authenticated = $deviceManager->approved($hash);
|
|
return $hash;
|
|
if (!$this->authenticated) {
|
|
throw new Exception("Authorization required", 401);
|
|
}
|
|
} else {
|
|
throw new Exception("Authorization required", 401);
|
|
}
|
|
}
|
|
|
|
public function default_v2()
|
|
{
|
|
$token = $this->requireAuth();
|
|
$obj = $this->input;
|
|
$response = [];
|
|
|
|
$device = DeviceManager::getDeviceByToken($token);
|
|
DeviceManager::setHeartbeat($device['device_id']);
|
|
|
|
// Issue command
|
|
$deviceCommand = $device["command"];
|
|
if ($deviceCommand != '' && $deviceCommand != null && $deviceCommand != "null") {
|
|
$response['command'] = $deviceCommand;
|
|
DeviceManager::editByToken($obj['token'], ['command' => 'null']);
|
|
}
|
|
|
|
$subDevicesData = SubDeviceManager::getAllSubDevices($device['device_id']);
|
|
if (count($subDevicesData) > 0) {
|
|
foreach ($subDevicesData as $key => $subDeviceData) {
|
|
$subDeviceId = $subDeviceData['subdevice_id'];
|
|
$subDeviceLastReord = RecordManager::getLastRecord($subDeviceId);
|
|
if (!empty($subDeviceLastReord)) {
|
|
$response['values'][$subDeviceData['type']] = $subDeviceLastReord['value'];
|
|
if ($subDeviceLastReord['execuded'] == 0) {
|
|
RecordManager::setExecuted($subDeviceLastReord['record_id']);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
$this->response($response, 200);
|
|
}
|
|
|
|
public function cofiguration_v2()
|
|
{
|
|
$token = $this->requireAuth();
|
|
$response = [];
|
|
|
|
$device = DeviceManager::getDeviceByToken($token);
|
|
DeviceManager::setHeartbeat($device['device_id']);
|
|
|
|
if (!empty($device["name"]) && isset($device["name"])) $response["nettwork"]['hostname'] = $this->nameToHostname($device["name"]);
|
|
if (!empty($device["ip_address"]) && isset($device["ip_address"])) $response["nettwork"]['ip'] = $device["ip_address"];
|
|
if (!empty($device["gateway"]) && isset($device["gateway"])) $response["nettwork"]['gateway'] = $device["gateway"];
|
|
if (!empty($device["dns"]) && isset($device["dns"])) $response["nettwork"]['dns'] = $device["dns"];
|
|
if (!empty($device["sleep_time"]) && isset($device["sleep_time"])) $response["sleep"] = $device["sleep_time"];
|
|
|
|
$this->response($response, 200);
|
|
}
|
|
|
|
private function nameToHostname(string $name = null)
|
|
{
|
|
$hostname = "";
|
|
$hostname = strtolower($name);
|
|
return str_replace(' ', '_', $hostname);
|
|
}
|
|
}
|