moved insertStatement and createStatement and init up to PDOListener

Author: marcelog

conf/support/event-handlers/dial-pdo-mysql-statements.xml

@@ -34,7 +34,7 @@ UPDATE `${mysql.table.call}` SET `cause`=:cause,`cause_txt`=:causeTxt WHERE `uni
     </value></constructor-arg>
   </bean>
 
-  <bean id="startCallStatement" class="PDOStatement" scope="prototype"
+  <bean id="insertStatement" class="PDOStatement" scope="prototype"
     factory-bean="pdoMysql" factory-method="prepare">
     <constructor-arg><value>
 INSERT INTO `${mysql.table.call}` (

conf/support/event-handlers/dial.xml

@@ -7,7 +7,7 @@
     <property name="hangupStatement"><ref bean="hangupCallStatement"/></property>
     <property name="dialedTimeStatement"><ref bean="dialedTimeStatement"/></property>
     <property name="answeredTimeStatement"><ref bean="answeredTimeStatement"/></property>
-    <property name="startCallStatement"><ref bean="startCallStatement"/></property>
+    <property name="insertStatement"><ref bean="insertStatement"/></property>
     <property name="endCallStatement"><ref bean="endCallStatement"/></property>
   </bean>
 </beans>

src/mg/AsterTrace/EventHandlers/DialListener.php

@@ -31,11 +31,6 @@
 
 class DialListener extends PDOListener
 {
-    /**
-     * @var \PDOStatement
-     */
-    private $_startCallStatement;
-
     /**
      * @var \PDOStatement
      */
@@ -56,16 +51,6 @@ class DialListener extends PDOListener
      */
     private $_answeredTimeStatement;
 
-    /**
-     * @var \PDOStatement
-     */
-    private $_createStatement;
-
-    public function setCreateStatement($statement)
-    {
-        $this->_createStatement = $statement;
-    }
-
     public function setHangupStatement($statement)
     {
         $this->_hangupStatement = $statement;
@@ -81,11 +66,6 @@ public function setAnsweredTimeStatement($statement)
         $this->_answeredTimeStatement = $statement;
     }
 
-    public function setStartCallStatement($statement)
-    {
-        $this->_startCallStatement = $statement;
-    }
-
     public function setEndCallStatement($statement)
     {
         $this->_endCallStatement = $statement;
@@ -130,7 +110,7 @@ public function onDialEnd($event)
 
     public function onDialBegin($event)
     {
-        $this->executeStatement($this->_startCallStatement, array(
+        $this->executeStatement($this->insertStatement, array(
             'uniqueidSrc' => $event->getUniqueId(),
             'uniqueidDst' => $event->getDestUniqueID(),
             'eventStart' => serialize($event),
@@ -141,11 +121,6 @@ public function onDialBegin($event)
             'clidNum' => $event->getCallerIDNum()
         ));
     }
-
-    public function init()
-    {
-        $this->executeStatement($this->_createStatement, array());
-    }
 }
 
 

src/mg/AsterTrace/EventHandlers/DtmfListener.php

@@ -31,41 +31,16 @@
 
 class DtmfListener extends PDOListener
 {
-    /**
-     * @var \PDOStatement
-     */
-    private $_insertStatement;
-
-    /**
-     * @var \PDOStatement
-     */
-    private $_createStatement;
-
-    public function setCreateStatement($statement)
-    {
-        $this->_createStatement = $statement;
-    }
-
-    public function setInsertStatement($statement)
-    {
-        $this->_insertStatement = $statement;
-    }
-
     public function onDTMF($event)
     {
         if ($event->getEnd() == 'Yes') {
-            $this->executeStatement($this->_insertStatement, array(
+            $this->executeStatement($this->insertStatement, array(
                 'uniqueid' => $event->getUniqueId(),
                 'dtmf' => $event->getDigit(),
                 'channel' => $event->getChannel()
             ));
         }
     }
-
-    public function init()
-    {
-        $this->executeStatement($this->_createStatement, array());
-    }
 }
 
 

src/mg/AsterTrace/EventHandlers/EventListener.php

@@ -1,6 +1,6 @@
 <?php
 /**
- * Listenes for all events. Will log all events to the
+ * Listens for all events. Will log all events to the
  * database by serializing the PAMI\Event\EventMessage class.
  *
  * PHP Version 5
@@ -31,29 +31,9 @@
 
 class EventListener extends PDOListener
 {
-    /**
-     * @var \PDOStatement
-     */
-    private $_insertStatement;
-
-    /**
-     * @var \PDOStatement
-     */
-    private $_createStatement;
-
-    public function setCreateStatement($statement)
-    {
-        $this->_createStatement = $statement;
-    }
-
-    public function setInsertStatement($statement)
-    {
-        $this->_insertStatement = $statement;
-    }
-
     public function onAnyEvent($event)
     {
-        $this->executeStatement($this->_insertStatement, array(
+        $this->executeStatement($this->insertStatement, array(
             'name' => $event->getName(),
             'channel' => method_exists($event, 'getChannel') ? $event->getChannel() : '',
             'uniqueId' => method_exists($event, 'getUniqueId') ? $event->getUniqueId() : '',
@@ -63,10 +43,6 @@ public function onAnyEvent($event)
         ));
     }
 
-    public function init()
-    {
-        $this->executeStatement($this->_createStatement, array());
-    }
 }
 
 

src/mg/AsterTrace/EventHandlers/PDOListener.php

@@ -30,6 +30,16 @@
 
 abstract class PDOListener implements \Ding\Logger\ILoggerAware
 {
+    /**
+     * @var \PDOStatement
+     */
+    protected $insertStatement;
+
+    /**
+     * @var \PDOStatement
+     */
+    protected $createStatement;
+
     /**
      * @var \Logger
      */
@@ -58,6 +68,36 @@ protected function executeStatement(\PDOStatement $statement, array $args)
             );
         }
     }
+    /**
+     * This will be called by the container. Will execute the create
+     * stable statement.
+     *
+     * @return void
+     */
+    public function init()
+    {
+        $this->executeStatement($this->createStatement, array());
+    }
+
+    /**
+     * Called by the container.
+     *
+     * @return void
+     */
+    public function setCreateStatement($statement)
+    {
+        $this->createStatement = $statement;
+    }
+
+    /**
+     * Called by the container.
+     *
+     * @return void
+     */
+    public function setInsertStatement($statement)
+    {
+        $this->insertStatement = $statement;
+    }
 }
 
 

src/mg/AsterTrace/EventHandlers/VarSetListener.php

@@ -31,40 +31,13 @@
 
 class VarSetListener extends PDOListener
 {
-    /**
-     * @var \PDOStatement
-     */
-    private $_insertStatement;
-
-    /**
-     * @var \PDOStatement
-     */
-    private $_createStatement;
-
-    public function setCreateStatement($statement)
-    {
-        $this->_createStatement = $statement;
-    }
-
-    public function setInsertStatement($statement)
-    {
-        $this->_insertStatement = $statement;
-    }
-
     public function onVarSet($event)
     {
-        $this->executeStatement($this->_insertStatement, array(
+        $this->executeStatement($this->insertStatement, array(
             'value' => $event->getValue(),
             'uniqueid' => $event->getUniqueId(),
             'channel' => $event->getChannel(),
             'name' => $event->getVariableName()
         ));
     }
-
-    public function init()
-    {
-        $this->executeStatement($this->_createStatement, array());
-    }
 }
-
-