file call logger
[auerswald-callnotifier.git] / src / callnotifier / MessageHandler.php
1 <?php
2 namespace callnotifier;
3
4 class MessageHandler
5 {
6     protected $dumpHdl;
7
8
9     public function __construct($config, $log, $callMonitor)
10     {
11         $this->config = $config;
12         $this->prepareDump();
13         $this->log = $log;
14         $this->callMonitor = $callMonitor;
15     }
16
17     public function handle($msg)
18     {
19         if ($this->config->dumpFile !== null) {
20             $this->dump($msg);
21         }
22         if (substr($msg, 0, 9) != '[DKANPROT') {
23             //unknown message type
24             return;
25         }
26         $regex = '#^\\[DKANPROT-([^ ]+) ([0-9]+)\\] (.*)$#';
27         if (!preg_match($regex, $msg, $matches)) {
28             //message should always be that way
29             return false;
30         }
31         list(, $type, $someid, $details) = $matches;
32         $this->log->log(
33             'msgData',
34             array(
35                 'type' => $type,
36                 'id' => $someid,
37                 'details' => $details
38             )
39         );
40
41         if ($type == 'Debug') {
42             $msg = $this->parseEDSS1($details);
43             if (is_object($msg)) {
44                 $this->log->log('edss1msg', array('msg' => $msg));
45                 $this->callMonitor->handle($msg);
46             }
47         }
48     }
49
50     /**
51      * Example string: "T02: 00 A3 06 0A 08 01 01 5A FF 0A"
52      *
53      * @param string $details Detail string of a debug message
54      *
55      * @return EDSS1_Message The retrieved message, NULL if none.
56      */
57     protected function parseEDSS1($details)
58     {
59         if ($details{0} != 'T' && $details{0} != 'N') {
60             //we only want byte data
61             return;
62         }
63         if (substr($details, 16, 4) != ' 08 ') {
64             //only E-DSS-1, no other packets
65             return;
66         }
67         
68         $bytestring = substr($details, 5);
69         $bytes = static::getBytesFromHexString($bytestring);
70
71         $mp = new EDSS1_Parser();
72         return $mp->parse($bytes);
73     }
74
75     public static function getBytesFromHexString($bytestring)
76     {
77         $bytes = '';
78         foreach (explode(' ', $bytestring) as $strbyte) {
79             $bytes .= chr(hexdec($strbyte));
80         }
81         return $bytes;
82     }
83
84     protected function prepareDump()
85     {
86         if ($this->config->dumpFile === null) {
87             return;
88         }
89         $this->dumpHdl = fopen($this->config->dumpFile, 'w');
90         if (!$this->dumpHdl) {
91             throw new \Exception('Cannot open dump file for writing');
92         }
93     }
94
95     protected function dump($msg)
96     {
97         fwrite($this->dumpHdl, $msg . "\n");
98     }
99 }
100
101 ?>