--- /dev/null
+<?php
+namespace callnotifier;
+
+class Logger_Echo implements Logger
+{
+ public function __construct()
+ {
+ $cc = new \Console_Color2();
+ $this->begin = $cc->convert('%y');
+ $this->end = $cc->convert('%n');
+ $this->blue = $cc->convert('%b');
+ }
+
+ public function log($type, $arData)
+ {
+ if ($type == 'msgData') {
+ echo $this->begin . $arData['type'] . $this->end
+ . ': ' . $arData['details'] . "\n";
+ } else {
+ echo $this->blue . $type . $this->end . ': '
+ . var_export($arData, true) . "\n";
+ }
+ }
+
+}
+
+?>
{
protected $dumpHdl;
+ /**
+ * Array of logger object arrays.
+ * Key is the notification type, value is an array of logger objects
+ * that want to get notified about the type.
+ *
+ * @var array
+ */
+ protected $logger = array(
+ 'msgData' => array(),
+ 'incomingCall' => array()
+ );
+
public function __construct($config)
{
$this->prepareDump();
}
+ /**
+ * Add a logger
+ *
+ * @param Logger $logger Logger object to register
+ * @param array|string $types Single notification type or array of such
+ * types. "*" means "register for all types".
+ *
+ * @return self
+ */
+ public function addLogger(Logger $logger, $types)
+ {
+ if ($types == '*') {
+ $types = array_keys($this->logger);
+ }
+ $types = (array)$types;
+
+ foreach ($types as $type) {
+ if (!isset($this->logger[$type])) {
+ throw new \Exception('Unknown log type: ' . $type);
+ }
+ $this->logger[$type][] = $logger;
+ }
+ }
+
public function handle($msg)
{
if ($this->config->dumpFile !== null) {
return false;
}
list(, $type, $someid, $details) = $matches;
+ $this->log(
+ 'msgData',
+ array(
+ 'type' => $type,
+ 'id' => $someid,
+ 'details' => $details
+ )
+ );
if ($type != 'Info') {
//we only want info messages
- var_dump($type . ': ' . $details);
return;
}
//Vegw/Ets-Cref:[0xffef]/[0x64] - VEGW_SETUP from upper layer to internal destination: CGPN[**22]->CDPN[41],
- var_dump($details);
$regex = '#CGPN\\[([^\\]]+)\\]->CDPN\\[([^\\]]+)\\]#';
if (preg_match($regex, $details, $matches)) {
- var_dump('a call!', $matches);
+ list(, $from, $to) = $matches;
+ $this->log('incomingCall', array('from' => $from, 'to' => $to));
+ }
+ }
+
+ protected function log($type, $arData)
+ {
+ if (!isset($this->logger[$type])) {
+ throw new \Exception('Unknown log type: ' . $type);
+ }
+
+ if (count($this->logger[$type])) {
+ foreach ($this->logger[$type] as $logger) {
+ $logger->log($type, $arData);
+ }
}
}
{
$file = $this->config->replayFile;
if (!file_exists($file)) {
- throw new Exception('Replay file does not exist');
+ throw new \Exception('Replay file does not exist');
}
$handle = fopen($file, 'r');
if (!$handle) {
- throw new Exception('Cannot open replay file for reading');
+ throw new \Exception('Cannot open replay file for reading');
}
while (($line = fgets($handle, 4096)) !== false) {
$this->handler->handle($line);
}
if (!feof($handle)) {
- throw new Exception('unexpected fgets() fail');
+ throw new \Exception('unexpected fgets() fail');
}
fclose($handle);
}