This repository has been archived by the owner on Aug 9, 2021. It is now read-only.
-
-
Notifications
You must be signed in to change notification settings - Fork 79
/
mqttlog.class.php
112 lines (94 loc) · 3.29 KB
/
mqttlog.class.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
<?php
/*
LICENSE
Copyright (C) 2016 Teclib'
Copyright (C) 2010-2016 by the FusionInventory Development Team.
This file is part of Flyve MDM Plugin for GLPI.
Flyve MDM Plugin for GLPi is a subproject of Flyve MDM. Flyve MDM is a mobile
device management software.
Flyve MDM Plugin for GLPI is free software: you can redistribute it and/or
modify it under the terms of the GNU Affero General Public License as published
by the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
Flyve MDM Plugin for GLPI is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License
along with Flyve MDM Plugin for GLPI. If not, see http://www.gnu.org/licenses/.
------------------------------------------------------------------------------
@author Thierry Bugier Pineau
@copyright Copyright (c) 2016 Flyve MDM plugin team
@license AGPLv3+ http://www.gnu.org/licenses/agpl.txt
@link https://github.com/flyve-mdm/flyve-mdm-glpi
@link http://www.glpi-project.org/
------------------------------------------------------------------------------
*/
if (!defined('GLPI_ROOT')) {
die("Sorry. You can't access this file directly");
}
/**
* @since 0.1.0
*/
class PluginFlyvemdmMqttlog extends CommonDBTM {
const MQTT_MAXIMUM_DURATION = 60;
/**
* @deprecated
* @var unknown $phpMqtt
*/
protected $phpMqtt;
/**
* @deprecated
* @var unknown $beginTimestamp
*/
protected $beginTimestamp;
public function __construct() {
parent::__construct();
$this->beginTimestamp = time();
}
/**
* Name of the type
* @param $nb integer number of item in the type (default 0)
*/
public static function getTypeName($nb=0) {
return _n('MQTT subscriber', 'MQTT subscribers', $nb, "flyvemdm");
}
/**
* Save in DB an incoming MQTT message
* @param String $topic topic
* @param String $msg Message
*/
public function saveIngoingMqttMessage($topic, $msg) {
$this->saveMqttMessage("I", $topic, $msg);
}
/**
* Save in the DB an outgoing MQTT message
* @param array $topicList array of topics. String allowed for a single topic
* @param String $msg Message
*/
public function saveOutgoingMqttMessage($topicList, $msg) {
$this->saveMqttMessage("O", $topicList, $msg);
}
/**
* Save MQTT messages sent or received
* @param String $direction I for input O for output
* @param array $topicList array of topics. String allowed for a single topic
* @param String $msg Message
*/
protected function saveMqttMessage($direction, $topicList, $msg) {
global $DB;
if (! is_array($topicList)) {
$topicList = array($topicList);
}
$msg = $DB->escape($msg);
foreach ($topicList as $topic) {
$topic = $DB->escape($topic);
$this->fields['date'] = date('Y-m-d H:i:s');
$this->fields['direction'] = $direction;
$this->fields['topic'] = $topic;
$this->fields['message'] = $msg;
unset($this->fields['id']);
$this->addToDB();
}
}
}