api.restapi.php 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949
  1. <?php
  2. /**
  3. * REST API v1 implementation
  4. */
  5. class RestAPI {
  6. /**
  7. * Contains available objects and their methods callbacks as object=>callback=>methodName
  8. *
  9. * @var array
  10. */
  11. protected $objects = array();
  12. /**
  13. * Some predefined stuff
  14. */
  15. const PROUTE_DATA = 'data';
  16. /**
  17. * Oo
  18. */
  19. public function __construct() {
  20. $this->setAvailableObjects();
  21. }
  22. /**
  23. * Sets available objects and their methods
  24. *
  25. * @return void
  26. */
  27. protected function setAvailableObjects() {
  28. $this->objects = array(
  29. 'models' => array(
  30. 'getall' => 'modelsGetAll'
  31. ),
  32. 'storages' => array(
  33. 'getall' => 'storagesGetAll',
  34. 'getstates' => 'storagesGetStates'
  35. ),
  36. 'cameras' => array(
  37. 'getall' => 'camerasGetAll',
  38. 'create' => 'camerasCreate',
  39. 'activate' => 'camerasActivate',
  40. 'deactivate' => 'camerasDeactivate',
  41. 'setdescription' => 'camerasSetDescription',
  42. 'delete' => 'camerasDelete',
  43. 'isregistered' => 'camerasIsRegistered'
  44. ),
  45. 'users' => array(
  46. 'getall' => 'usersGetAll',
  47. 'create' => 'usersCreate',
  48. 'delete' => 'usersDelete',
  49. 'changepassword' => 'usersChangePassword',
  50. 'isregistered' => 'usersIsRegistered',
  51. 'checkauth' => 'usersCheckAuth'
  52. ),
  53. 'acls' => array(
  54. 'getall' => 'aclsGetAll',
  55. 'getallchannels' => 'aclsGetAllChannels',
  56. 'getallcameras' => 'aclsGetAllCameras',
  57. 'getchannels' => 'aclsGetChannels',
  58. 'getcameras' => 'aclsGetCameras',
  59. 'assignchannel' => 'aclsAssignChannel',
  60. 'assigncamera' => 'aclsAssignCamera',
  61. 'deassignchannel' => 'aclsDeassignChannel',
  62. 'deassigncamera' => 'aclsDeassignCamera',
  63. ),
  64. 'channels' => array(
  65. 'getall' => 'channelsGetAll',
  66. 'getscreenshotsall' => 'channelsGetScreenshotsAll',
  67. 'getscreenshot' => 'channelsGetScreenshot',
  68. 'getlivestream' => 'channelsGetLiveStream',
  69. ),
  70. 'recorders' => array(
  71. 'getall' => 'recordersGetAll',
  72. 'isrunning' => 'recordersIsRunning'
  73. ),
  74. 'system' => array(
  75. 'gethealth' => 'systemGetHealth',
  76. 'checkconnection' => 'systemCheckConnection'
  77. ),
  78. );
  79. }
  80. /**
  81. * Performs check for availability of request fields
  82. *
  83. * @param array $required
  84. * @param array $data
  85. *
  86. * @return bool
  87. */
  88. protected function checkRequestFields($required, $data) {
  89. $result = true;
  90. if (!empty($required)) {
  91. if (!empty($data)) {
  92. foreach ($required as $io => $eachRequired) {
  93. if (!isset($data[$eachRequired])) {
  94. $result = false;
  95. }
  96. }
  97. } else {
  98. $result = false;
  99. }
  100. }
  101. return($result);
  102. }
  103. /**
  104. * Catches some object method callback
  105. *
  106. * @return void
  107. */
  108. public function catchRequest() {
  109. $result = array(
  110. 'error' => 1,
  111. 'message' => __('No object specified')
  112. );
  113. if (!empty($this->objects)) {
  114. foreach ($this->objects as $eachObject => $objectMethods) {
  115. //object call
  116. if (ubRouting::checkGet($eachObject)) {
  117. $methodCallback = ubRouting::get($eachObject);
  118. if (isset($objectMethods[$methodCallback])) {
  119. $methodName = $objectMethods[$methodCallback];
  120. if (method_exists($this, $methodName)) {
  121. $inputData = array();
  122. if (ubRouting::checkPost(self::PROUTE_DATA)) {
  123. $unpackData = json_decode(ubRouting::post(self::PROUTE_DATA), true);
  124. if (is_array($unpackData)) {
  125. $inputData = $unpackData;
  126. }
  127. }
  128. $result = $this->$methodName($inputData);
  129. } else {
  130. $result = array(
  131. 'error' => 2,
  132. 'message' => __('Method not exists')
  133. );
  134. }
  135. } else {
  136. $result = array(
  137. 'error' => 2,
  138. 'message' => __('Method not exists')
  139. );
  140. }
  141. }
  142. }
  143. }
  144. $this->renderReply($result);
  145. }
  146. /**
  147. * Returns request reply as JSON
  148. *
  149. * @return void
  150. */
  151. protected function renderReply($data) {
  152. header('Content-Type: application/json; charset=UTF-8');
  153. $data = json_encode($data);
  154. die($data);
  155. }
  156. ///////////////////////////
  157. // Camera models methods //
  158. ///////////////////////////
  159. /**
  160. * Returns available camera models list
  161. *
  162. * @return array
  163. */
  164. protected function modelsGetAll() {
  165. $models = new Models();
  166. $result = $models->getAllModelData();
  167. return($result);
  168. }
  169. //////////////////////
  170. // Storages methods //
  171. //////////////////////
  172. /**
  173. * Returns available storages list
  174. *
  175. * @return array
  176. */
  177. protected function storagesGetAll() {
  178. $storages = new Storages();
  179. $result = $storages->getAllStoragesData();
  180. return($result);
  181. }
  182. /**
  183. * Returns available storages states
  184. *
  185. * @return array
  186. */
  187. protected function storagesGetStates() {
  188. $result = array();
  189. $storages = new Storages();
  190. $allStorages = $storages->getAllStoragesData();
  191. if (!empty($allStorages)) {
  192. foreach ($allStorages as $io => $each) {
  193. $storageState = ($storages->checkPath($each['path'])) ? 1 : 0;
  194. $storageTotal = @disk_total_space($each['path']);
  195. $storageFree = @disk_free_space($each['path']);
  196. $storageUsed = $storageTotal - $storageFree;
  197. $result[$each['id']]['state'] = $storageState;
  198. $result[$each['id']]['total'] = $storageTotal;
  199. $result[$each['id']]['used'] = $storageUsed;
  200. $result[$each['id']]['free'] = $storageFree;
  201. }
  202. }
  203. return($result);
  204. }
  205. /////////////////////
  206. // Cameras methods //
  207. /////////////////////
  208. /**
  209. * Returns full available cameras data
  210. *
  211. * @return array
  212. */
  213. protected function camerasGetAll() {
  214. $cameras = new Cameras();
  215. $result = $cameras->getAllCamerasFullData();
  216. return($result);
  217. }
  218. /**
  219. * Returns list of cameras accessible by
  220. *
  221. * @param array $request
  222. *
  223. * @return array
  224. */
  225. protected function camerasCreate($request) {
  226. $result = array();
  227. $requiredFields = array('modelid', 'ip', 'login', 'password', 'active', 'storageid', 'description');
  228. if ($this->checkRequestFields($requiredFields, $request)) {
  229. $cameras = new Cameras();
  230. $modelId = $request['modelid'];
  231. $ip = $request['ip'];
  232. $login = $request['login'];
  233. $password = $request['password'];
  234. $active = $request['active'];
  235. $storageId = $request['storageid'];
  236. $comment = $request['description'];
  237. $creationResult = $cameras->create($modelId, $ip, $login, $password, $active, $storageId, $comment);
  238. if (!empty($creationResult)) {
  239. $result = array('error' => 7, 'message' => $creationResult);
  240. } else {
  241. $result = array('error' => 0, 'message' => __('Success'));
  242. }
  243. } else {
  244. $result = array('error' => 3, 'message' => __('Wrong request data'));
  245. }
  246. return($result);
  247. }
  248. /**
  249. * Activates existing camera
  250. *
  251. * @param array $request
  252. *
  253. * @return array
  254. */
  255. protected function camerasActivate($request) {
  256. $result = array();
  257. $requiredFields = array('cameraid');
  258. if ($this->checkRequestFields($requiredFields, $request)) {
  259. $cameras = new Cameras();
  260. $actResult = $cameras->activate($request['cameraid']);
  261. if (!empty($actResult)) {
  262. $result = array('error' => 7, 'message' => $actResult);
  263. } else {
  264. $result = array('error' => 0, 'message' => __('Success'));
  265. }
  266. } else {
  267. $result = array('error' => 3, 'message' => __('Wrong request data'));
  268. }
  269. return($result);
  270. }
  271. /**
  272. * Deactivates existing camera
  273. *
  274. * @param array $request
  275. *
  276. * @return array
  277. */
  278. protected function camerasDeactivate($request) {
  279. $result = array();
  280. $requiredFields = array('cameraid');
  281. if ($this->checkRequestFields($requiredFields, $request)) {
  282. $cameras = new Cameras();
  283. $deactResult = $cameras->deactivate($request['cameraid']);
  284. if (!empty($deactResult)) {
  285. $result = array('error' => 7, 'message' => $deactResult);
  286. } else {
  287. $result = array('error' => 0, 'message' => __('Success'));
  288. }
  289. } else {
  290. $result = array('error' => 3, 'message' => __('Wrong request data'));
  291. }
  292. return($result);
  293. }
  294. /**
  295. * Sets camera description
  296. *
  297. * @param array $request
  298. *
  299. * @return array
  300. */
  301. protected function camerasSetDescription($request) {
  302. $result = array();
  303. $requiredFields = array('cameraid', 'description');
  304. if ($this->checkRequestFields($requiredFields, $request)) {
  305. $cameras = new Cameras();
  306. $renameResult = $cameras->saveComment($request['cameraid'], $request['description']);
  307. if (empty($renameResult)) {
  308. $result = array('error' => 0, 'message' => __('Success'));
  309. } else {
  310. $result = array('error' => 7, 'message' => $renameResult);
  311. }
  312. } else {
  313. $result = array('error' => 3, 'message' => __('Wrong request data'));
  314. }
  315. return($result);
  316. }
  317. /**
  318. * Deletes existing camera
  319. *
  320. * @param array $request
  321. *
  322. * @return array
  323. */
  324. protected function camerasDelete($request) {
  325. $result = array();
  326. $requiredFields = array('cameraid');
  327. if ($this->checkRequestFields($requiredFields, $request)) {
  328. $cameras = new Cameras();
  329. $delResult = $cameras->delete($request['cameraid']);
  330. if (!empty($delResult)) {
  331. $result = array('error' => 7, 'message' => $delResult);
  332. } else {
  333. $result = array('error' => 0, 'message' => __('Success'));
  334. }
  335. } else {
  336. $result = array('error' => 3, 'message' => __('Wrong request data'));
  337. }
  338. return($result);
  339. }
  340. /**
  341. * Checks is camera registered or not by its IP
  342. *
  343. * @param array $request
  344. *
  345. * @return array
  346. */
  347. protected function camerasIsRegistered($request) {
  348. $result = array();
  349. $requiredFields = array('ip');
  350. if ($this->checkRequestFields($requiredFields, $request)) {
  351. $cameras = new Cameras();
  352. $registerId = $cameras->isRegisteredIp($request['ip']);
  353. $registerState = ($registerId) ? 1 : 0;
  354. $result = array('error' => 0, 'registered' => $registerState, 'id' => $registerId);
  355. } else {
  356. $result = array('error' => 3, 'message' => __('Wrong request data'));
  357. }
  358. return($result);
  359. }
  360. ///////////////////////////
  361. // System object methods //
  362. ///////////////////////////
  363. /**
  364. * Just dummy callback to check API connection
  365. *
  366. * @return array
  367. */
  368. protected function systemCheckConnection() {
  369. $result = array('error' => 0, 'connection' => 1, 'message' => __('Success'));
  370. return($result);
  371. }
  372. /**
  373. * Returns system health info
  374. *
  375. * @return array
  376. */
  377. protected function systemGetHealth() {
  378. global $ubillingConfig;
  379. $hwInfo=new SystemHwInfo();
  380. $result = array(
  381. 'storages' => 1,
  382. 'network' => 1,
  383. 'database' => 1,
  384. 'channels_total' => 0,
  385. 'channels_online' => 0,
  386. 'uptime' => 0,
  387. 'loadavg' => 0,
  388. 'cpuload' => 0,
  389. 'os' => '',
  390. );
  391. //storages diag
  392. $storagesStates = $this->storagesGetStates();
  393. if (!empty($storagesStates)) {
  394. foreach ($storagesStates as $io => $eachStorageState) {
  395. if (!$eachStorageState['state']) {
  396. $result['storages'] = 0;
  397. }
  398. }
  399. } else {
  400. $result['storages'] = 0;
  401. }
  402. //network diag
  403. if (!zb_PingICMP('wolfrecorder.com')) {
  404. $result['network'] = 0;
  405. }
  406. //cameras stats
  407. $allCamerasData = $this->camerasGetAll();
  408. $result['channels_total'] = sizeof($allCamerasData);
  409. if (!empty($allCamerasData)) {
  410. $recorder = new Recorder();
  411. $runningRecorders = $recorder->getRunningRecorders();
  412. $result['channels_online'] = sizeof($runningRecorders);
  413. }
  414. //system uptime
  415. $uptime = $hwInfo->getUptime();
  416. $result['uptime'] = $uptime;
  417. //system load averaga
  418. $loadAvg = $hwInfo->getLa1();
  419. $result['loadavg'] = $loadAvg;
  420. //system load
  421. $cpuLoad=$hwInfo->getsystemLoadPercent();
  422. $result['cpuload'] = $cpuLoad;
  423. //system name
  424. $osName=$hwInfo->getOs();
  425. $osRelease=$hwInfo->getOsRelease();
  426. $phpVer=$hwInfo->getPhpVersion();
  427. $result['os'] = 'OS: ' . $osName.' '.$osRelease . ' PHP: ' . $phpVer;
  428. return($result);
  429. }
  430. ///////////////////////////
  431. // Users object methods //
  432. ///////////////////////////
  433. /**
  434. * Returns list of all available user data
  435. *
  436. * @return array
  437. */
  438. protected function usersGetAll() {
  439. $userManager = new UserManager();
  440. return($userManager->getAllUsersData());
  441. }
  442. /**
  443. * Creates new limited user
  444. *
  445. * @param array $request
  446. *
  447. * @return array
  448. */
  449. protected function usersCreate($request) {
  450. $result = array();
  451. $requiredFields = array('login', 'password');
  452. if ($this->checkRequestFields($requiredFields, $request)) {
  453. $userManager = new UserManager();
  454. $login = $request['login'];
  455. $password = $request['password'];
  456. $role = 'LIMITED';
  457. $userRegResult = $userManager->createUser($login, $password, $password, $role);
  458. if (!empty($userRegResult)) {
  459. $result = array('error' => 7, 'message' => $userRegResult);
  460. } else {
  461. $result = array('error' => 0, 'message' => __('Success'));
  462. }
  463. } else {
  464. $result = array('error' => 3, 'message' => __('Wrong request data'));
  465. }
  466. return($result);
  467. }
  468. /**
  469. * Changes some existing user password to new one
  470. *
  471. * @param array $request
  472. *
  473. * @return array
  474. */
  475. protected function usersChangePassword($request) {
  476. $result = array();
  477. $requiredFields = array('login', 'password');
  478. if ($this->checkRequestFields($requiredFields, $request)) {
  479. $userManager = new UserManager();
  480. $login = $request['login'];
  481. $password = $request['password'];
  482. $userSaveResult = $userManager->saveUser($login, $password, $password);
  483. if (!empty($userSaveResult)) {
  484. $result = array('error' => 7, 'message' => $userSaveResult);
  485. } else {
  486. $result = array('error' => 0, 'message' => __('Success'));
  487. }
  488. } else {
  489. $result = array('error' => 3, 'message' => __('Wrong request data'));
  490. }
  491. return($result);
  492. }
  493. /**
  494. * Checks is user registered or not?
  495. *
  496. * @param array $request
  497. *
  498. * @return array
  499. */
  500. protected function usersIsRegistered($request) {
  501. $result = array();
  502. $requiredFields = array('login');
  503. if ($this->checkRequestFields($requiredFields, $request)) {
  504. $userManager = new UserManager();
  505. $login = $request['login'];
  506. $userCheckResult = ($userManager->isUserRegistered($login)) ? 1 : 0;
  507. $result = array('error' => 0, 'registered' => $userCheckResult);
  508. } else {
  509. $result = array('error' => 3, 'message' => __('Wrong request data'));
  510. }
  511. return($result);
  512. }
  513. /**
  514. * Deletes an existing user
  515. *
  516. * @param array $request
  517. *
  518. * @return array
  519. */
  520. protected function usersDelete($request) {
  521. $result = array();
  522. $requiredFields = array('login');
  523. if ($this->checkRequestFields($requiredFields, $request)) {
  524. $userManager = new UserManager();
  525. $login = $request['login'];
  526. if ($userManager->isUserRegistered($login)) {
  527. $userManager->deleteUser($login);
  528. $result = array('error' => 0, 'message' => __('Success'));
  529. } else {
  530. $result = array('error' => 7, 'message' => __('User') . ' ' . __('not exists'));
  531. }
  532. } else {
  533. $result = array('error' => 3, 'message' => __('Wrong request data'));
  534. }
  535. return($result);
  536. }
  537. /**
  538. * Checks can user be athorized with some login and password or not
  539. *
  540. * @param array $request
  541. *
  542. * @return array
  543. */
  544. protected function usersCheckAuth($request) {
  545. $result = array();
  546. $requiredFields = array('login', 'password');
  547. if ($this->checkRequestFields($requiredFields, $request)) {
  548. $login = $request['login'];
  549. $password = $request['password'];
  550. if (!empty($login) AND !empty($password)) {
  551. $userManager = new UserManager();
  552. $allUsersData = $userManager->getAllUsersData();
  553. if (isset($allUsersData[$login])) {
  554. $userData = $allUsersData[$login];
  555. if (!empty($userData)) {
  556. $passwordHash = md5($password);
  557. if ($passwordHash == $userData['password']) {
  558. $result = array('error' => 0, 'auth' => 1, 'message' => __('Success'));
  559. } else {
  560. $result = array('error' => 6, 'auth' => 0, 'message' => __('Wrong credentials'));
  561. }
  562. } else {
  563. $result = array('error' => 7, 'message' => __('Error reading user profile'));
  564. }
  565. } else {
  566. $result = array('error' => 6, 'auth' => 0, 'message' => __('Wrong credentials'));
  567. }
  568. } else {
  569. $result = array('error' => 7, 'message' => __('Login') . ' ' . __('or') . ' ' . __('password') . ' ' . __('is empty'));
  570. }
  571. } else {
  572. $result = array('error' => 3, 'message' => __('Wrong request data'));
  573. }
  574. return($result);
  575. }
  576. ///////////////////
  577. // ACLs methods //
  578. ///////////////////
  579. /**
  580. * Returns array of all available ACLs
  581. *
  582. * @return array
  583. */
  584. protected function aclsGetAll() {
  585. $result = array();
  586. $acl = new ACL();
  587. $result = $acl->getAllAclsData();
  588. return($result);
  589. }
  590. /**
  591. * Returns array of all available user to cameras ACLs
  592. *
  593. * @return array
  594. */
  595. protected function aclsGetAllCameras() {
  596. $result = array();
  597. $acl = new ACL();
  598. $result = $acl->getAllCameraAclsData();
  599. return($result);
  600. }
  601. /**
  602. * Returns array of all available user to channels ACLs
  603. *
  604. * @return array
  605. */
  606. protected function aclsGetAllChannels() {
  607. $result = array();
  608. $acl = new ACL();
  609. $result = $acl->getAllChannelAclsData();
  610. return($result);
  611. }
  612. /**
  613. * Returns all channels assigned to some user as channelId=>cameraId
  614. *
  615. * @param array $request
  616. *
  617. * @return array
  618. */
  619. protected function aclsGetChannels($request) {
  620. $result = array();
  621. $requiredFields = array('login');
  622. if ($this->checkRequestFields($requiredFields, $request)) {
  623. $login = $request['login'];
  624. $acl = new ACL();
  625. $allChannelAcls = $acl->getAllChannelAclsData();
  626. if (isset($allChannelAcls[$login])) {
  627. $result = $allChannelAcls[$login];
  628. }
  629. } else {
  630. $result = array('error' => 3, 'message' => __('Wrong request data'));
  631. }
  632. return($result);
  633. }
  634. /**
  635. * Returns all camearas assigned to some user as cameraId=>channelId
  636. *
  637. * @param array $request
  638. *
  639. * @return array
  640. */
  641. protected function aclsGetCameras($request) {
  642. $result = array();
  643. $requiredFields = array('login');
  644. if ($this->checkRequestFields($requiredFields, $request)) {
  645. $login = $request['login'];
  646. $acl = new ACL();
  647. $allCameraAcls = $acl->getAllCameraAclsData();
  648. if (isset($allCameraAcls[$login])) {
  649. $result = $allCameraAcls[$login];
  650. }
  651. } else {
  652. $result = array('error' => 3, 'message' => __('Wrong request data'));
  653. }
  654. return($result);
  655. }
  656. /**
  657. * Creates ACL for some user by cameraId
  658. *
  659. * @param array $request
  660. *
  661. * @return array
  662. */
  663. protected function aclsAssignCamera($request) {
  664. $result = array();
  665. $requiredFields = array('login', 'cameraid');
  666. if ($this->checkRequestFields($requiredFields, $request)) {
  667. $login = $request['login'];
  668. $cameraId = $request['cameraid'];
  669. $acl = new ACL(true);
  670. $aclCreationResult = $acl->create($login, $cameraId);
  671. if (empty($aclCreationResult)) {
  672. $result = array('error' => 0, 'message' => __('Success'));
  673. } else {
  674. $result = array('error' => 7, 'message' => $aclCreationResult);
  675. }
  676. } else {
  677. $result = array('error' => 3, 'message' => __('Wrong request data'));
  678. }
  679. return($result);
  680. }
  681. /**
  682. * Creates ACL for some user by channelId
  683. *
  684. * @param array $request
  685. *
  686. * @return array
  687. */
  688. protected function aclsAssignChannel($request) {
  689. $result = array();
  690. $requiredFields = array('login', 'channelid');
  691. if ($this->checkRequestFields($requiredFields, $request)) {
  692. $login = $request['login'];
  693. $channelId = $request['channelid'];
  694. $acl = new ACL(true);
  695. $aclCreationResult = $acl->assignChannel($login, $channelId);
  696. if (empty($aclCreationResult)) {
  697. $result = array('error' => 0, 'message' => __('Success'));
  698. } else {
  699. $result = array('error' => 7, 'message' => $aclCreationResult);
  700. }
  701. } else {
  702. $result = array('error' => 3, 'message' => __('Wrong request data'));
  703. }
  704. return($result);
  705. }
  706. /**
  707. * Deletes ACL for some user by cameraId
  708. *
  709. * @param array $request
  710. *
  711. * @return array
  712. */
  713. protected function aclsDeassignCamera($request) {
  714. $result = array();
  715. $requiredFields = array('login', 'cameraid');
  716. if ($this->checkRequestFields($requiredFields, $request)) {
  717. $login = $request['login'];
  718. $cameraId = $request['cameraid'];
  719. $aclDeletionId = 0;
  720. $acl = new ACL();
  721. $allAcls = $acl->getAllAclsData();
  722. if (!empty($allAcls)) {
  723. foreach ($allAcls as $io => $each) {
  724. if ($each['user'] == $login AND $each['cameraid'] == $cameraId) {
  725. $aclDeletionId = $each['id'];
  726. }
  727. }
  728. }
  729. if ($aclDeletionId) {
  730. $aclDeletionResult = $acl->delete($aclDeletionId);
  731. if (empty($aclDeletionResult)) {
  732. $result = array('error' => 0, 'message' => __('Success'));
  733. } else {
  734. $result = array('error' => 7, 'message' => $aclDeletionResult);
  735. }
  736. } else {
  737. $result = array('error' => 0, 'message' => __('ACL') . ' ' . __('not exists'));
  738. }
  739. } else {
  740. $result = array('error' => 3, 'message' => __('Wrong request data'));
  741. }
  742. return($result);
  743. }
  744. /**
  745. * Deletes ACL for some user by channelId
  746. *
  747. * @param array $request
  748. *
  749. * @return array
  750. */
  751. protected function aclsDeassignChannel($request) {
  752. $result = array();
  753. $requiredFields = array('login', 'channelid');
  754. if ($this->checkRequestFields($requiredFields, $request)) {
  755. $login = $request['login'];
  756. $channelId = $request['channelid'];
  757. $aclDeletionId = 0;
  758. $acl = new ACL();
  759. $allAcls = $acl->getAllAclsData();
  760. if (!empty($allAcls)) {
  761. foreach ($allAcls as $io => $each) {
  762. if ($each['user'] == $login AND $each['channel'] == $channelId) {
  763. $aclDeletionId = $each['id'];
  764. }
  765. }
  766. }
  767. if ($aclDeletionId) {
  768. $aclDeletionResult = $acl->delete($aclDeletionId);
  769. if (empty($aclDeletionResult)) {
  770. $result = array('error' => 0, 'message' => __('Success'));
  771. } else {
  772. $result = array('error' => 7, 'message' => $aclDeletionResult);
  773. }
  774. } else {
  775. $result = array('error' => 0, 'message' => __('ACL') . ' ' . __('not exists'));
  776. }
  777. } else {
  778. $result = array('error' => 3, 'message' => __('Wrong request data'));
  779. }
  780. return($result);
  781. }
  782. ///////////////////////
  783. // Channels methods //
  784. ///////////////////////
  785. /**
  786. * Returns all available channels as channelId=>cameraId
  787. *
  788. * @return array
  789. */
  790. protected function channelsGetAll() {
  791. $result = array();
  792. $cameras = new Cameras();
  793. $result = $cameras->getAllCamerasChannels();
  794. return($result);
  795. }
  796. /**
  797. * Returns latest channel screenshot
  798. *
  799. * @param array $request
  800. *
  801. * @return array
  802. */
  803. protected function channelsGetScreenshot($request) {
  804. $result = array();
  805. $requiredFields = array('channelid');
  806. if ($this->checkRequestFields($requiredFields, $request)) {
  807. $channelId = $request['channelid'];
  808. $chanshots = new ChanShots();
  809. $screenshotRaw = $chanshots->getChannelScreenShot($channelId);
  810. $result = array('error' => 0, 'screenshot' => $screenshotRaw);
  811. } else {
  812. $result = array('error' => 3, 'message' => __('Wrong request data'));
  813. }
  814. return($result);
  815. }
  816. /**
  817. * Returns latest all channels screenshot as channelId=>screenshotUrl
  818. *
  819. * @return array
  820. */
  821. protected function channelsGetScreenshotsAll() {
  822. $result = array();
  823. $cameras = new Cameras();
  824. $allCamerasChannels = $cameras->getAllCamerasChannels();
  825. if (!empty($allCamerasChannels)) {
  826. $chanshots = new ChanShots();
  827. foreach ($allCamerasChannels as $eachChannelId => $eachCameraId) {
  828. $eachScreenShotUrl = $chanshots->getChannelScreenShot($eachChannelId);
  829. if (!empty($eachScreenShotUrl)) {
  830. $result[$eachChannelId] = $eachScreenShotUrl;
  831. }
  832. }
  833. }
  834. return($result);
  835. }
  836. /**
  837. * Returns channel live pseudo stream HLS URL
  838. *
  839. * @param array $request
  840. *
  841. * @return array
  842. */
  843. protected function channelsGetLiveStream($request) {
  844. $result = array();
  845. $requiredFields = array('channelid');
  846. if ($this->checkRequestFields($requiredFields, $request)) {
  847. $channelId = $request['channelid'];
  848. $url = LiveCams::URL_PSEUDOSTREAM . '&' . LiveCams::ROUTE_PSEUDOLIVE . '=' . $channelId;
  849. $result = array('error' => 0, 'livestream' => $url);
  850. } else {
  851. $result = array('error' => 3, 'message' => __('Wrong request data'));
  852. }
  853. return($result);
  854. }
  855. ///////////////////////
  856. // Recorders methods //
  857. ///////////////////////
  858. /**
  859. * Returns all running recorders as cameraId=>PID
  860. *
  861. * @return array
  862. */
  863. protected function recordersGetAll() {
  864. $result = array();
  865. $recorders = new Recorder();
  866. $result = $recorders->getRunningRecorders();
  867. return($result);
  868. }
  869. /**
  870. * Returns state of running recorder for some camera
  871. *
  872. * @param array $request
  873. *
  874. * @return array
  875. */
  876. protected function recordersIsRunning($request) {
  877. $requiredFields = array('cameraid');
  878. if ($this->checkRequestFields($requiredFields, $request)) {
  879. $cameraId = $request['cameraid'];
  880. $recorders = new Recorder();
  881. $allRunning = $recorders->getRunningRecorders();
  882. $runningState = (isset($allRunning[$cameraId])) ? 1 : 0;
  883. $result = array('error' => 0, 'running' => $runningState);
  884. } else {
  885. $result = array('error' => 3, 'message' => __('Wrong request data'));
  886. }
  887. return($result);
  888. }
  889. }