fs_cdr.php

<?php

/**
 * @package FS_CURL
 * @license BSD
 * @author  Raymond Chandler (intralanman) <intralanman@gmail.com>
 * @version 0.1
 * Class for inserting xml CDR records
 * @return object
 */
class fs_cdr extends fs_curl
{
    /**
     * This object is the objectified representation of the XML CDR
     * @var SimpleXMLElement
     */
    public $xml_cdr;

    /**
     * This array will hold the db field and their corresponding value
     * @var array
     */
    public $values = [];

    /**
     * This is where we instantiate our parent and set up our CDR object
     */
    public function __construct()
    {
        parent::__construct();

        $cdr = stripslashes($this->request['cdr']);
        $this->xml_cdr = new SimpleXMLElement($cdr);
    }

    /**
     * This is where we run the bulk of our logic through other methods
     */
    public function main()
    {
        $this->set_record_values();
        $this->insert_cdr();
    }

    /**
     * This method will take the db fields and paths defined above and
     * set the values array to be used for the insert
     */
    public function set_record_values()
    {
        /**
         * @var stdClass $xml
         */
        $xml = $this->xml_cdr;
        $callflow = is_array($xml->callflow) ? $xml->callflow[0] : $xml->callflow;
        $caller_profile = $callflow->caller_profile;
        $variables = $xml->variables;
        $stats = $xml->{'call-stats'};
        $aLeg = substr($this->request['uuid'], 0, 2) == 'a_';

        // calc traffic
        $inbound_bytes = 0;
        $outbound_bytes = 0;
        if (isset($stats->audio)) {
            $inbound_bytes += (int)@$stats->audio->inbound->raw_bytes;
            $outbound_bytes += (int)@$stats->audio->outbound->raw_bytes;
        }
        if (isset($stats->video)) {
            $inbound_bytes += (int)@$stats->video->inbound->raw_bytes;
            $outbound_bytes += (int)@$stats->video->outbound->raw_bytes;
        }

        $this->values = [
            'is_aleg'              => $aLeg ? 1 : 0,
            'direction'            => (string)$variables->direction,
            'start_stamp'          => urldecode((string)$variables->start_stamp),
            'answer_stamp'         => urldecode((string)$variables->answer_stamp) ?: null,
            'end_stamp'            => urldecode((string)$variables->end_stamp),
            'duration'             => (int)$variables->duration,
            'billsec'              => (int)$variables->billsec,
            'hangup_cause'         => (string)$variables->hangup_cause_q850,
            'uuid'                 => (string)$variables->uuid,
            'accountcode'          => (string)$variables->accountcode ?: null,
            'read_codec'           => (string)$variables->read_codec ?: null,
            'write_codec'          => (string)$variables->write_codec ?: null,
            'endpoint_disposition' => urldecode((string)$variables->endpoint_disposition) ?: null,
            'dialstatus'           => urldecode((string)$variables->DIALSTATUS) ?: null,
            'inbound_bytes'        => $inbound_bytes,
            'outbound_bytes'       => $outbound_bytes,
            'sip_user_agent'       => mb_substr(urldecode((string)$variables->sip_user_agent), 0, 512),
            'originator_uuid'      => (string)$variables->originator ?: null,
            'last_bridge_role'     => (string)$variables->last_bridge_role ?: null,
            'call_record_id'       => (string)$variables->call_record_id ?: null,
            'caller_id_name'       => urldecode((string)$variables->effective_caller_id_name) ?: (string)$caller_profile->caller_id_name,
            'caller_id_number'     => urldecode((string)$variables->effective_caller_id_number) ?: (string)$caller_profile->caller_id_number,
            'context'              => (string)$caller_profile->context,
        ];

        if ($aLeg) {
            $values = [
                'username'           => (string)$caller_profile->username ?: null,
                'destination_number' => (string)$caller_profile->destination_number,
            ];
        } else {
            $values = [
                'username' => (string)$variables->dialed_user ?: ((string)$caller_profile->callee_id_number ?: null),
            ];
        }
        $this->values += $values;

        $this->debug($this->values);
    }

    /**
     * finally do the insert of the CDR
     */
    public function insert_cdr()
    {
        $keys = array_keys($this->values);

        $query = sprintf("INSERT INTO cdr (%s) VALUES (:%s)", implode(', ', $keys), implode(', :', $keys));
        $this->debug($query);

        $statement = $this->db->prepare($query);
        $statement->execute($this->values);
    }
}