<?php
/*
* Trigger.inc.php
*
* This is the domain logic managing the fundamental behaviors and data of Triggers.
*
* @author   Quinn Comendant <quinn@strangecode.com>
* @version  1.0
* @since    20 Aug 2014 17:20:09
*/

require_once 'models/Model.inc.php';

class Trigger extends Model
{
    // The database fields used by this model.
    public static $fields = array(
        'account_id' => '',
        'trigger_id' => '',
        'virtual_number' => '',
        'keyword' => '',
        'action' => '',
        'action_options' => '',
        'added_datetime' => '',
        'added_by_user_id' => '',
        'modified_datetime' => '',
        'modified_by_user_id' => '',
    );

    /*
    *
    *
    * @access   public
    * @param
    * @return
    * @author   Quinn Comendant <quinn@strangecode.com>
    * @version  1.0
    * @since    16 Nov 2014 17:45:40
    */
    static public function insert($frm)
    {
        global $auth, $cache;
        $db =& DB::getInstance();
        $app =& App::getInstance();

        // Remove any stale cached list data.
        $cache->delete('trigger list');

        // Create the record under the user's account, unless an account_id was provided.
        $account_id = isset($frm['account_id']) && is_numeric($frm['account_id']) ? $frm['account_id'] : $auth->get('account_id');

        // Insert record data.
        $app->logMsg(sprintf('%s with data %s', __METHOD__, getDump($frm)), LOG_DEBUG, __FILE__, __LINE__);
        $db->query("
            INSERT INTO trigger_tbl (
                account_id,
                virtual_number,
                keyword,
                action,
                action_options,
                added_datetime,
                added_by_user_id,
                modified_datetime,
                modified_by_user_id
            ) VALUES (
                '" . $db->escapeString($account_id) . "',
                '" . $db->escapeString($frm['virtual_number']) . "',
                '" . $db->escapeString($frm['keyword']) . "',
                '" . $db->escapeString($frm['action']) . "',
                '" . $db->escapeString($frm['action_options']) . "',
                NOW(),
                '" . $db->escapeString($auth->get('user_id')) . "',
                NOW(),
                '" . $db->escapeString($auth->get('user_id')) . "'
            )
        ");
        $last_insert_id = mysql_insert_id($db->getDBH());

        // Create version.
        $version = Version::getInstance($auth);
        $version->create('trigger_tbl', 'trigger_id', $last_insert_id, $frm['keyword']);

        return $last_insert_id;
    }

    /*
    *
    *
    * @access   public
    * @param
    * @return
    * @author   Quinn Comendant <quinn@strangecode.com>
    * @version  1.0
    * @since    16 Nov 2014 17:45:40
    */
    static public function update($frm)
    {
        global $auth, $lock, $cache;
        $db =& DB::getInstance();
        $app =& App::getInstance();

        $lock->select('trigger_tbl', 'trigger_id', $frm['trigger_id']);
        if ($lock->isLocked() && !$lock->isMine()) {
            $lock->dieErrorPage();
        }

        // Remove any stale cached list data.
        $cache->delete('trigger list');

        // Create the record under the user's account, unless an account_id was provided.
        $account_id = isset($frm['account_id']) && is_numeric($frm['account_id']) ? $frm['account_id'] : $auth->get('account_id');

        // Update record data.
        $app->logMsg(sprintf('%s with data %s', __METHOD__, getDump($frm)), LOG_DEBUG, __FILE__, __LINE__);
        $db->query("
            UPDATE trigger_tbl SET
                account_id = '" . $db->escapeString($account_id) . "',
                virtual_number = '" . $db->escapeString($frm['virtual_number']) . "',
                keyword = '" . $db->escapeString($frm['keyword']) . "',
                action = '" . $db->escapeString($frm['action']) . "',
                action_options = '" . $db->escapeString($frm['action_options']) . "',
                modified_datetime = NOW(),
                modified_by_user_id = '" . $db->escapeString($auth->get('user_id')) . "'
            WHERE trigger_id = '" . $db->escapeString($frm['trigger_id']) . "'
        ");

        // Create version.
        $version = Version::getInstance($auth);
        $version->create('trigger_tbl', 'trigger_id', $frm['trigger_id'], $frm['keyword']);

        // Unlock record.
        $lock->remove();
    }

    /*
    *
    *
    * @access   public
    * @param
    * @return
    * @author   Quinn Comendant <quinn@strangecode.com>
    * @version  1.0
    * @since    16 Nov 2014 17:45:40
    */
    static public function delete($id)
    {
        global $lock, $cache, $locally_carried_queries;
        $db =& DB::getInstance();
        $app =& App::getInstance();

        $lock->select('trigger_tbl', 'trigger_id', $id);
        if ($lock->isLocked() && !$lock->isMine()) {
            $lock->dieErrorPage();
        }

        // Remove any stale cached list data.
        $cache->delete('trigger list');

        // Delete the record.
        $db->query("DELETE FROM trigger_tbl WHERE trigger_id = '" . $db->escapeString($id) . "'");

        // Unlock record.
        $lock->remove();
    }

    /*
    *
    *
    * @access   public
    * @param
    * @return
    * @author   Quinn Comendant <quinn@strangecode.com>
    * @version  1.0
    * @since    16 Nov 2014 17:45:40
    */
    static public function getPaginatedList($where_clause='')
    {
        global $page, $so, $cache;
        $db =& DB::getInstance();
        $app =& App::getInstance();

        // Build search query if available.
        if (getFormData('q', false)) {
            $qry_words = preg_split('/[^\w]/', getFormData('q'));
            for ($i=0; $i<sizeof($qry_words); $i++) {
                $where_clause .= (empty($where_clause) ? 'WHERE' : 'AND') . "
                    (
                        trigger_tbl.virtual_number LIKE '%" . $db->escapeString($qry_words[$i]) . "%'
                        OR trigger_tbl.keyword LIKE '%" . $db->escapeString($qry_words[$i]) . "%'
                    )
                ";
            }
        }

        if (getFormData('filter_action', false)) {
            // Limit by filter.
            $where_clause .= (empty($where_clause) ? 'WHERE' : ' AND') . " action = '" . $db->escapeString(getFormData('filter_action')) . "'";
        }

        // Count the total number of records so we can do something about the page numbers.
        $qid = $db->query("
            SELECT COUNT(*)
            FROM trigger_tbl
            $where_clause
        ");
        list($num_results) = mysql_fetch_row($qid);

        // Set page numbers now we know (needed for next step).
        $page->setTotalItems($num_results);
        $page->calculate();

        // Final SQL, with sort and page limiters.
        $sql = "
            SELECT
                trigger_tbl.*,
                a1.username AS added_by_username,
                a2.username AS modified_by_username
            FROM trigger_tbl
            LEFT JOIN user_tbl a1 ON (trigger_tbl.added_by_user_id = a1.user_id)
            LEFT JOIN user_tbl a2 ON (trigger_tbl.modified_by_user_id = a2.user_id)
            $where_clause
            " . $so->getSortOrderSQL() . "
            " . $page->getLimitSQL() . "
        ";

        // Use a cache hash to determine if the result-set has changed.
        // A unique key for this query, with the total_items in case db records
        // were added since the last cache. This identifies a unique set of
        // cached data, but we must refer to the list that is cached by a more
        // generic name. so that we can flush the cache (if records updated)
        // without knowing the hash.
        $cache_hash = md5($sql . '|' . $page->total_items);
        $tmp_prefs = new Prefs('session', array('storagetype' => 'session'));
        if ($tmp_prefs->get('cache_hash') != $cache_hash) {
            $cache->delete('trigger list');
            $tmp_prefs->set('cache_hash', $cache_hash);
        }

        // First try to return from the cache.
        if ($cache->exists('trigger list')) {
            return $cache->get('trigger list');
        }

        // The list was not cached, so issue the real query.
        $qid = $db->query($sql);
        $list = array();
        while ($row = mysql_fetch_assoc($qid)) {
            $list[] = $row;
        }

        // Save this list into the cache.
        if (isset($list) && !empty($list)) {
            $cache->set('trigger list', $list);
        }

        return $list;
    }
}