Merge f659307 into f586d0f

chan-sccp · Nov 22, 2018 · 1190995 · 1190995
2 parents f586d0f + f659307
commit 1190995
Show file tree

Hide file tree

Showing 3 changed files with 88 additions and 3 deletions.
diff --git a/src/PAMI/Message/Action/MonitorAction.php b/src/PAMI/Message/Action/MonitorAction.php
@@ -56,15 +56,17 @@ class MonitorAction extends ActionMessage
      *
      * @param string $channel  Channel to monitor.
      * @param string $filename Absolute path to target filename.
+     * @param string $format Recording format, default 'wav'.
+     * @param string $mix Mix channels, default 'true'.
      *
      * @return void
      */
-    public function __construct($channel, $filename)
+    public function __construct($channel, $filename, $format = 'wav', $mix = 'true')
     {
         parent::__construct('Monitor');
         $this->setKey('Channel', $channel);
-        $this->setKey('Mix', 'true');
-        $this->setKey('Format', 'wav');
+        $this->setKey('Mix', $mix);
+        $this->setKey('Format', $format);
         $this->setKey('File', $filename);
     }
 }
diff --git a/src/PAMI/Message/Action/StatusAction.php b/src/PAMI/Message/Action/StatusAction.php
@@ -57,4 +57,18 @@ public function __construct($channel = false)
             $this->setKey('Channel', $channel);
         }
     }
+
+    /**
+     * Sets Variables key.
+     *
+     * @param array $variables Variables to use.
+     *
+     * @return void
+     */
+    public function setVariables($variables = array())
+    {
+        if (!empty($variables)) {
+          $this->setKey('Variables', implode(',', $variables));
+        }
+    }
 }
diff --git a/src/PAMI/Message/IncomingMessage.php b/src/PAMI/Message/IncomingMessage.php
@@ -53,6 +53,12 @@ abstract class IncomingMessage extends Message
      */
     protected $channelVariables;
 
+    /**
+     * Metadata. Specific channel variables.
+     * @var string[]
+     */
+    protected $statusVariables;
+
     /**
      * Serialize function.
      *
@@ -125,6 +131,45 @@ public function getChannelVariables($channel = null)
         }
     }
 
+    /**
+     * Returns the channel variables for all reported channels.
+     * https://github.com/marcelog/PAMI/issues/85
+     *
+     * The channel names will be lowercased.
+     *
+     * @return array
+     */
+    public function getAllStatusVariables()
+    {
+        return $this->statusVariables;
+    }
+
+    /**
+     * Returns the channel variables for the given channel.
+     * https://github.com/marcelog/PAMI/issues/85
+     *
+     * @param string $channel Channel name. If not given, will return variables
+     * for the "current" channel.
+     *
+     * @return array
+     */
+    public function getStatusVariables($channel = null)
+    {
+        if (is_null($channel)) {
+            if (!isset($this->keys['channel'])) {
+                return $this->getStatusVariables('default');
+            } else {
+                return $this->getStatusVariables($this->keys['channel']);
+            }
+        } else {
+            $channel = strtolower($channel);
+            if (!isset($this->statusVariables[$channel])) {
+                return null;
+            }
+            return $this->statusVariables[$channel];
+        }
+    }
+
     /**
      * Constructor.
      *
@@ -136,6 +181,7 @@ public function __construct($rawContent)
     {
         parent::__construct();
         $this->channelVariables = array('default' => array());
+        $this->statusVariables = array('default' => array());
         $this->rawContent = $rawContent;
         $lines = explode(Message::EOL, $rawContent);
         foreach ($lines as $line) {
@@ -155,13 +201,26 @@ public function __construct($rawContent)
                 unset($content[0]);
                 $value = isset($content[1]) ? trim(implode(':', $content)) : '';
                 $this->channelVariables[$chanName][$name] = $value;
+            } else if (!strncmp($name, 'variable', 8)) {
+                // https://github.com/marcelog/PAMI/issues/85
+                $matches = preg_match("/\(([^\)]*)\)/", $name, $captures);
+                $chanName = 'default';
+                if ($matches > 0) {
+                    $chanName = $captures[1];
+                }
+                $content = explode('=', $value);
+                $name = strtolower(trim($content[0]));
+                unset($content[0]);
+                $value = isset($content[1]) ? trim(implode(':', $content)) : '';
+                $this->statusVariables[$chanName][$name] = $value;
             } else {
                 $this->setKey($name, $value);
             }
         }
         // https://github.com/marcelog/PAMI/issues/85
         if (isset($this->keys['channel'])) {
             $channel = strtolower($this->keys['channel']);
+
             if (isset($this->channelVariables[$channel])) {
                 $this->channelVariables[$channel] = array_merge(
                     $this->channelVariables[$channel],
@@ -171,6 +230,16 @@ public function __construct($rawContent)
                 $this->channelVariables[$channel] = $this->channelVariables['default'];
             }
             unset($this->channelVariables['default']);
+
+            if (isset($this->statusVariables[$channel])) {
+                $this->statusVariables[$channel] = array_merge(
+                    $this->statusVariables[$channel],
+                    $this->statusVariables['default']
+                );
+            } else {
+                $this->statusVariables[$channel] = $this->statusVariables['default'];
+            }
+            unset($this->statusVariables['default']);
         }
     }
 }