관리-도구

편집 파일: Plugin.php

<?php
class Plugin
{
    var $mysqli;
    var $dbpref;
    var $load;
    var $ip;
    var $base_dir;
    var $secure_key;
    var $secure;
    var $plugin_dir;
    var $plugin_table;

var $activation_callbacks = array();
    var $deactivation_callbacks = array();
    var $action_callbacks = array(
        'cf_head' => array(),
        'cf_footer' => array(),
        'init' => array(),
        'admin_menu' => array(),
        'admin_menues' => array(),
        'admin_submenues' => array(),
        'app_menu' => array(),
        'admin_init' => array(),
        'admin_head' => array(),
        'admin_footer' => array(),
        'cf_sale' => array(),
        'cf_funnel_create' => array(),
        'cf_funnel_delete' => array(),
        'cf_funnel_page_create' => array(),
        'cf_funnel_page_level_change' => array(),
        'cf_funnel_page_delete' => array(),
        'cf_funnel_page_setup_change' => array(),
        'cf_funnel_page_content_change' => array(),
        'cf_member_create' => array(),
        'cf_member_update' => array(),
        'cf_member_delete' => array(),
        'cf_product_create' => array(),
        'cf_product_update' => array(),
        'cf_product_delete' => array(),
    );
    var $autores_callbacks = array();
    var $payment_methods_callbacks = array();
    var $filter_callbacks = array(
        'the_content' => array(),
        'the_email_content' => array(),
        'the_email_subject' => array(),
        'the_email_subject' => array(),
        'the_checkout_data' => array(),
    );

var $temp_products = [];
    var $shortcodes = array();
    var $langs = array();

function __construct($arr)
    {
        $this->mysqli = $arr['mysqli'];
        $this->dbpref = $arr['dbpref'];
        if (isset($arr['load'])) {
            $this->load = $arr['load'];
            $this->secure = $this->load->secure();
        }
        $this->ip = $arr['ip'];

if (isset($arr['base_dir'])) {
            $this->base_dir = $arr['base_dir'];
        }
        $this->plugin_table = $this->dbpref . 'qfnl_plugins';
    }
    function getConfig($plugin, $folder)
    {
        $dbpref = $this->dbpref;
        $mysqli = $this->mysqli;
        $table = $this->plugin_table;
        $plugin = $mysqli->real_escape_string($plugin);
        $file = $folder . "/config.json";
        $base_url = rtrim(get_option('install_url'), "/");
        $base_url .= "/plugins/" . $plugin;

if (is_file($file) && filesize($file) > 0) {
            $fp = fopen($file, 'r');
            $data = fread($fp, filesize($file));
            fclose($fp);

$data = json_decode($data);
            if (isset($data->start)) {
                $data->active = false;
                $data->registered = false;

$data->start = self::filterAttr($data->start);
                $data->start = $folder . "/" . $data->start;
                $data->dir = $folder;
                $data->url = $base_url;

if (isset($data->logo)) {
                    $data->logo = trim($data->logo);
                    if (strlen($data->logo) > 0 && !filter_var($data->logo, FILTER_VALIDATE_URL)) {
                        $data->logo = self::filterAttr($data->logo);
                        $data->logo = $base_url . "/" . $data->logo;
                    }
                }

$qry = $mysqli->query("select `status` from `" . $table . "` where `base_dir`='" . $plugin . "'");
                if ($qry->num_rows > 0) {
                    $r = $qry->fetch_object();
                    $data->registered = true;
                    if ($r->status == '1') {
                        $data->active = true;
                    }
                }
                $data->temp_id = time();
                $data->temp_id .= $data->temp_id . mt_rand(0, 10000000000);
                $data->temp_id .= substr(str_shuffle('xcvbnmsdfghjkwertyuiop1234567890'), 0, 5);
                return $data;
            }
        }
        return false;
    }
    function filterAttr($attr)
    {
        $attr = trim($attr);
        $attr = trim($attr, ".");
        $attr = trim($attr, "/");
        $attr = trim($attr, "\\");
        $attr = str_replace("\\", "/", $attr);
        return $attr;
    }
    function getPlugins($type = "all")
    {
        $dir = $this->base_dir . "/plugins";
        $folders = scandir($dir);
        $plugins = array();
        for ($i = 0; $i < count($folders); $i++) {
            if (in_array($folders[$i], array('.', '..'))) {
                continue;
            }
            $folder = self::filterAttr($folders[$i], '/');
            $plugin_name = $folder;
            $folder = $dir . "/" . $folder;
            $config_file = $folder . "/config.json";
            $has_config = false;
            if (@is_file($config_file)) {
                $config = self::getConfig($plugin_name, $folder);
                if ($config) {
                    $config->temp_id .= $i;
                    $plugins[$plugin_name] = $config;
                }
            }
        }
        if ($type == "all") {
            return $plugins;
        }
        if (in_array($type, array('active', 'inactive'))) {
            foreach ($plugins as $index => $plugin) {
                if ((!$plugin->active && $type == 'active') || ($plugin->active && $type == "inactive")) {
                    unset($plugins[$index]);
                }
            }
            return $plugins;
        } else {
            return array();
        }
    }
    function processActivation($plugin, $doo = "activate")
    {
        try {
            if (!in_array($doo, array('activate', 'deactivate'))) {
                throw new Exception("Invalid Command");
            }
            $mysqli = $this->mysqli;
            $dbpref = $this->dbpref;
            $table = $this->plugin_table;

$plugin = $mysqli->real_escape_string($plugin);
            $base_dir = $this->base_dir;
            $pid = $plugin;
            $plugin = self::getConfig($plugin, $base_dir . "/plugins/" . $plugin);

$do_check_version = function () use (&$plugin) {
                if (isset($plugin->required_version) && ($plugin->required_version > (get_option('qfnl_current_version')))) {
                    throw new Exception('To activate this plugin you need minimum CourseFunnels version ' . $plugin->required_version . ', your current CourseFunnels version is ' . get_option('qfnl_current_version'));
                }
            };

if ($plugin) {
                $date = date('Y-m-d H:i:s');
                if ($plugin->registered) {
                    $stat = ($doo == 'activate') ? 1 : 0;

if ($stat) {
                        $do_check_version();
                    }

$qry = $mysqli->query("update `" . $table . "` set `status`='" . $stat . "', `activated_on`='" . $date . "' where `base_dir`='" . $pid . "'");
                } else if ($doo == 'activate') {
                    //qfnl_current_version

$do_check_version();

$plugin_version = '0';
                    if (isset($plugin->version)) {
                        $plugin_version = $mysqli->real_escape_string($plugin->version);
                    }

$qry = $mysqli->query("insert into `" . $table . "` (`base_dir`,`destin_version`,`status`,`activated_on`) values ('" . $pid . "','" . $plugin_version . "','1','" . $date . "')");
                }

if (!isset($qry) || !$qry) {
                    throw new Exception("Unable to process this request");
                } else {
                    require_once($plugin->start);
                    if ($doo == 'activate') {
                        foreach ($this->activation_callbacks as $cb) {
                            if (is_array($cb)) {
                                if (is_array($cb[0])) {
                                    $temp_func = $cb[0][1];
                                    $cb[0][0]->$temp_func($cb[1]);
                                } else {
                                    $cb[0]($cb[1]);
                                }
                            }
                        }
                    } else if ($doo == 'deactivate') {
                        foreach ($this->deactivation_callbacks as $cb) {
                            if (is_array($cb)) {
                                if (is_array($cb[0])) {
                                    $temp_func = $cb[0][1];
                                    $cb[0][0]->$temp_func($cb[1]);
                                } else {
                                    $cb[0]($cb[1]);
                                }
                            }
                        }
                    }
                    return 1;
                }
            } else {
                throw new Exception("Unable to detect as a plugin");
            }
        } catch (Exception $e) {
            return $e->getMessage();
        }
    }
    function checkForUpdate($plugin_id, $detailed)
    {
        $stat = array("error" => false, 'update' => false, 'file' => '', "version" => "0.0", "data" => "", "required_cf_version" => "0.0");
        $base_dir = $this->base_dir;
        $plugin = self::getConfig($plugin_id, $base_dir . "/plugins/" . $plugin_id);
        if ($plugin && isset($plugin->auto_update_callback_url) && isset($plugin->version)) {
            $url = $plugin->auto_update_callback_url;
            $ch = curl_init();
            curl_setopt($ch, CURLOPT_URL, $url);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
            curl_setopt($ch, CURLOPT_TIMEOUT, 10);
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
            $res = curl_exec($ch);
            if (curl_errno($ch)) {
                $err_msg = curl_error($ch);
                $stat["error"] = true;
                $stat["data"] = $err_msg;
            }
            curl_close($ch);

if (!$stat['error']) {
                $data = json_decode($res);
                if (isset($data->version) && ($data->version > $plugin->version) && isset($data->file) && filter_var($data->file, FILTER_VALIDATE_URL)) {
                    if ($data->version > $plugin->version) {
                        $stat['update'] = true;
                        $stat['version'] = $data->version;
                        if (isset($data->message)) {
                            $stat["data"] = $data->message;
                        }
                        if (isset($data->required_cf_version)) {
                            $stat['required_cf_version'] = $data->required_cf_version;
                        }
                        $stat['file'] = $data->file;
                    } elseif ($data->version === $plugin->version) {
                        $stat['version'] = $data->version;
                    }
                }
            }
        }
        return $stat;
    }
    function uploadPlugin($zip_file, $do_update = false)
    {
        $base_dir = $this->base_dir;
        $temp_dir = $base_dir . "/public-assets/temp_plugins";
        $plugins_dir = $base_dir . "/plugins";
        try {
            $file = $zip_file;
            $tmp_name = explode('.', basename($file));
            if (strtolower($tmp_name[count($tmp_name) - 1]) == 'zip') {
                $zip = new ZipArchive();
                $zip->open($file);

array_pop($tmp_name);
                $dir_name = implode(".", $tmp_name);
                $arr = array();
                for ($i = 0; $i < $zip->numFiles; $i++) {
                    $stat = $zip->statIndex($i);
                    $name = self::filterAttr($stat['name']);
                    array_push($arr, $name);
                }
                $has_config = false;
                if (in_array('config.json', $arr)) {
                    $has_config = true;
                    $dir = $plugins_dir . '/' . $dir_name;
                    if (!self::getConfig($dir_name, $dir) || $do_update) {
                        if (!$do_update) {
                            cf_rmdir($dir);
                        }
                        mkdir($dir);
                        $zip->extractTo($dir);
                        $zip->close();
                    } else {
                        $zip->close();
                        throw new Exception("There already a plugin exist with same directory name");
                    }
                } elseif (!strpos($arr[0], '/') && in_array($arr[0] . '/config.json', $arr)) {
                    $has_config = true;
                    $dir = $plugins_dir . "/" . $arr[0];
                    if (!self::getConfig($arr[0], $dir) || $do_update) {
                        if (!$do_update) {
                            cf_rmdir($dir);
                        }
                        $zip->extractTo($plugins_dir);
                        $zip->close();
                    } else {
                        $zip->close();
                        throw new Exception("There already a plugin exist with same directory name");
                    }
                } else {
                    throw new Exception('There no valid configuration file exists');
                }

if ($has_config) {
                    return 1;
                }
            } else {
                throw new Exception("Please upload a valid zip file.");
            }
        } catch (Exception $err) {
            return $err->getMessage();
        }
    }
    function remotePluginInstall($file, $do_update = false, $plugin_id = "")
    {
        try {
            if (!filter_var($file, FILTER_VALIDATE_URL)) {
                throw new Exception("Invalid file URL provided");
            }
            $ch = curl_init();
            curl_setopt($ch, CURLOPT_URL, $file);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
            curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
            curl_setopt($ch, CURLOPT_HTTPHEADER, array(
                "Host: cloudfunnels.in"
            ));
            $res = curl_exec($ch);
            if (curl_errno($ch)) {
                $err = curl_error($ch);
                curl_close($ch);
                throw new Exception($err);
            }
            curl_close($ch);

$temp_dir = $this->base_dir . "/public-assets/temp_plugins";
            if (cf_dir_exists($temp_dir)) {
                cf_rmdir($temp_dir);
            }
            mkdir($temp_dir);
            if ($do_update) {
                $plugin_id = trim($plugin_id);
                if (strlen($plugin_id) < 1) {
                    throw new Exception("Invalid plugin id provided");
                }
                $zip_file = $temp_dir . '/' . $plugin_id . '.zip';
            } else {
                $zip_file = basename($file);
                $zip_file = $temp_dir . '/' . $zip_file;
            }
            $fp = fopen($zip_file, 'w');
            fwrite($fp, $res);
            fclose($fp);
            if (!is_file($zip_file)) {
                cf_rmdir($temp_dir);
                throw new Exception("Unable to download plugin");
            }
            $stat_data = self::uploadPlugin($zip_file, $do_update);
            cf_rmdir($temp_dir);
            return $stat_data;
        } catch (Exception $err) {
            return $err->getMessage();
        }
    }
    function deletePlugin($plugin)
    {
        $mysqli = $this->mysqli;
        $plugin = $mysqli->real_escape_string($plugin);
        $dir = $this->base_dir . '/plugins/' . $plugin;
        cf_rmdir($dir);
        $mysqli->query("delete from `" . $this->plugin_table . "` where `base_dir`='" . $plugin . "'");
        return 1;
    }
    function playCallbacks($cbs, $settings = array())
    {
        foreach ($cbs as $cb) {
            if (is_array($cb)) {
                if (is_array($cb[0])) {
                    $temp_func = $cb[0][1];
                    $data = $cb[0][0]->$temp_func($settings, $cb[1]);
                } else {
                    $data = $cb[0]($settings, $cb[1]);
                }
            }
        }
    }
    function playCallbacksForFilter($cbs, $content, $settings = array())
    {
        foreach ($cbs as $cb) {
            if (is_array($cb)) {
                if (is_array($cb[0])) {
                    $temp_func = $cb[0][1];
                    $content = $cb[0][0]->$temp_func($content, $settings, $cb[1]);
                } else {
                    $content = $cb[0]($content, $settings, $cb[1]);
                }
            }
        }
        return $content;
    }
    function attachToContent($type, $settings)
    {
        //$type=header||footer
        //attaching header footer scripts with add action
        $data = "";
        ob_start();
        $arr = $this->action_callbacks[$type];
        $this->playCallbacks($arr, $settings);
        $data = ob_get_contents();
        ob_end_clean();
        return $data;
    }
    function processFilter($type, $content = "", $settings = array())
    {
        //filter hook
        $cbs = $this->filter_callbacks[$type];
        return self::playCallbacksForFilter($cbs, $content, $settings);
    }
    function processInit($type = 'init')
    {
        $cbs = $this->action_callbacks[$type];
        self::playCallbacks($cbs, array());
    }
    function processAdminMenu($page = false)
    {
        $this->action_callbacks['admin_menues'] = array();
        $this->action_callbacks['admin_submenues'] = array();
        $cbs = $this->action_callbacks['admin_menu'];
        self::playCallbacks($cbs, array());

if ($page !== false && is_string($page) && strlen($page) > 0) {
            if (isset($this->action_callbacks['admin_menues'][$page])) {
                return $this->action_callbacks['admin_menues'][$page];
            } else if (isset($this->action_callbacks['admin_submenues'][$page])) {
                if (isset($this->action_callbacks['admin_menues'][$this->action_callbacks['admin_submenues'][$page][0]['parent_slug']])) {
                    return $this->action_callbacks['admin_submenues'][$page];
                } else {
                    return false;
                }
            } else {
                return false;
            }
        } else {
            return $this->action_callbacks['admin_menues'];
        }
    }
    function doShortcode($scode, $str)
    {
        if (!$scode) {
            foreach ($this->shortcodes as $index => $cb) {
                $str = self::processShortcode($index, $str);
            }
        } else {
            $str = self::processShortcode($scode, $str);
        }
        return $str;
    }
    function processShortcode($scode, $str)
    {
        if (!isset($this->shortcodes[$scode])) {
            return $str;
        }
        $s_cb = $this->shortcodes[$scode];

$r_scode = preg_quote($scode);

$init_reg = "/(\[" . $r_scode . ")(.(?!\[))*(\])+/";
        $complete_reg = "/(\[" . $r_scode . ")(.(?!\[))*(\])+(.(?!\[\/" . $r_scode . "))*(.)?(\[\/" . $r_scode . "\])+/";

$play_scode = function ($code, $str = "") use ($scode, &$s_cb) {
            $reg = "/([a-zA-Z0-9_\-])+(=)+((\"(.(?!\"))*.\")|(\'(.(?!\'))*.\')|(\S+))/";
            $params = array();
            $code = trim(str_replace("[" . $scode, "", $code));
            $code = rtrim($code, "]");
            preg_match_all($reg, $code, $arr);
            if (isset($arr[0]) && is_array($arr[0])) {
                foreach ($arr[0] as $param) {
                    $param = preg_replace_callback("/=/", function ($matches) {
                        return "@-cf-scode-brk-@";
                    }, $param, 1);
                    $param = explode("@-cf-scode-brk-@", $param);
                    $params[$param[0]] = trim($param[1], "\"\'");
                }
            }
            if (is_array($s_cb) && count($s_cb) > 0) {
                if (is_array($s_cb[0])) {
                    $temp_s_cb = $s_cb[0][1];
                    $str = $s_cb[0][0]->$temp_s_cb($params, $str, $s_cb[1]);
                } else {
                    $str = $s_cb[0]($params, $str, $s_cb[1]);
                }
            }
            return $str;
        };

$cb_open_close = function ($matches) use ($complete_reg, $init_reg, $scode, $play_scode) {
            $data = $matches[0];
            preg_match($init_reg, $data, $arr);
            $code = $arr[0];

$data = rtrim($data, "[/" . $scode . "]");
            $data = preg_replace_callback($init_reg, function ($matches) {
                return "";
            }, $data, 1);
            $data = $play_scode($code, $data);
            return $data;
        };

$cb_open = function ($matches) use ($init_reg, $scode, $play_scode) {
            $data = $play_scode($matches[0]);
            return $data;
        };

$str = preg_replace_callback($complete_reg, $cb_open_close, $str);
        $str = preg_replace_callback($init_reg, $cb_open, $str);
        return $str;
    }
    function processAjax($action)
    {
        $user_ob = $this->load->loadUser();
        if (!$user_ob->isLoggedin() && isset($this->action_callbacks['cf_ajax_nopriv_' . $action])) {
            self::playCallbacks($this->action_callbacks['cf_ajax_nopriv_' . $action], array());
        }
        if ($user_ob->isLoggedin() && isset($this->action_callbacks['cf_ajax_' . $action])) {
            self::playCallbacks($this->action_callbacks['cf_ajax_' . $action], array());
        }
    }
    function processApi($action)
    {
        if (isset($this->action_callbacks['cf_api_' . $action])) {
            self::playCallbacks($this->action_callbacks['cf_api_' . $action], array());
        }
    }
    function processGetFunnels($type = "", $limit = 5)
    {
        $loader = $this->load;
        $funnel_ob = $loader->loadFunnel();
        if (is_numeric($limit) && $limit === -1) {
            $limit = $funnel_ob->getCountFunnelsInDB();
        }
        $funnel_data = $funnel_ob->getAllFunnelForView(0, $type, $limit);
        $rows = $funnel_data['rows'];
        $arr = array();
        while ($r = $rows->fetch_assoc()) {
            array_push($arr, $r);
        }
        return $arr;
    }
    function createMetaDataArg($data)
    {
        $accepted = array('funnel_id' => 0, 'page_level' => '0', 'page_type' => 'ab');
        if (is_array($data)) {
            if (!isset($data['funnel_id'])) {
                throw new Exception("Missing index `funnel_id` in first argument.");
            }
            foreach ($data as $index => $val) {
                if (!isset($accepted[$index])) {
                    throw new Exception("Unknown index \"" . $index . "\" in first argument");
                }
                $accepted[$index] = $val;
            }
            $data = $accepted;
        } else {
            $data = array('funnel_id' => $data, 'page_level' => '0', 'page_type' => 'ab');
        }
        return $data;
    }
    function addFunnelMeta($data, $key, $meta_value, $doo = "add")
    {
        $mysqli = $this->mysqli;
        $dbpref = $this->dbpref;
        $table = $dbpref . 'qfnl_funnel_meta';
        $key = $mysqli->real_escape_string($key);
        $meta_value = $mysqli->real_escape_string($meta_value);

$qry_str = "";
        $count = 0;
        $data = self::createMetaDataArg($data);

if ($doo == 'update') {
            foreach ($data as $index => $val) {
                ++$count;
                $val = $mysqli->real_escape_string($val);
                $qry_str .= "`" . $index . "`='" . $val . "'";
                if ($count <= 2) {
                    $qry_str .= " and ";
                }
            }
            $mysqli->query("update `" . $table . "` set `value`='" . $meta_value . "' where " . $qry_str . " and `key`='" . $key . "'");
        } else if ($doo == 'add') {
            if (self::getFunnelMeta($data, $key)) {
                return false;
            }

$attrs = "(";
            $vals = "(";
            foreach ($data as $index => $val) {
                $attrs .= "`" . $index . "`,";
                $vals .= "'" . $val . "',";
            }

$attrs .= "`key`,`value`)";
            $vals .= "'" . $key . "','" . $meta_value . "')";

$qry = $mysqli->query("insert into `" . $table . "` " . $attrs . " values " . $vals . "");
        } else {
            throw new Exception('Unknown command');
        }
        return true;
    }
    function getFunnelMeta($data, $key)
    {
        $mysqli = $this->mysqli;
        $dbpref = $this->dbpref;
        $table = $dbpref . 'qfnl_funnel_meta';
        $key = $mysqli->real_escape_string($key);

$qry_str = "";
        $count = 0;
        $data = self::createMetaDataArg($data);

foreach ($data as $index => $val) {
            ++$count;
            $val = $mysqli->real_escape_string($val);
            $qry_str .= "`" . $index . "`='" . $val . "'";
            if ($count <= 2) {
                $qry_str .= " and ";
            }
        }

$qry = $mysqli->query("select `value` from `" . $table . "` where " . $qry_str . " and `key`='" . $key . "'");

if ($qry->num_rows) {
            $r = $qry->fetch_object();
            return $r->value;
        } else {
            return false;
        }
    }
    function deleteFunnelMeta($data, $key)
    {
        $mysqli = $this->mysqli;
        $dbpref = $this->dbpref;
        $table = $dbpref . 'qfnl_funnel_meta';
        $key = $mysqli->real_escape_string($key);

$qry_str = "";
        $count = 0;
        $data = self::createMetaDataArg($data, $key);

foreach ($data as $index => $val) {
            ++$count;
            $val = $mysqli->real_escape_string($val);
            $qry_str .= "`" . $index . "`='" . $val . "'";
            if ($count <= 2) {
                $qry_str .= " and ";
            }
        }
        $qry = $mysqli->query("delete from `" . $table . "` where " . $qry_str . " and `key`='" . $key . "'");
        return true;
    }
    function processAutoResponders($id, $name, $email, $data = array())
    {
        if (!is_array($data)) {
            $data = array();
        }
        $data['name'] = $name;
        $data['email'] = $email;

if (isset($this->autores_callbacks[$id])) {
            $ap = $this->autores_callbacks[$id];
            self::playCallbacks(array(array($ap['cb'], $ap['args'])), $data);
        }
    }
    function processPaymentMethod($id, $product_detail, $description)
    {
        if (isset($this->payment_methods_callbacks[$id])) {
            $loader = $this->load;
            $sell_ob = $loader->loadSell();
            $method = $this->payment_methods_callbacks[$id];

if (is_array($product_detail)) {
                $product_detail['description'] = $description;
            }
            $cb = $method['cb'];
            $execution_url = rtrim(get_option('install_url'), '/');
            $execution_url .= "/index.php?page=do_payment_execute";
            if (is_array($cb)) {
                $func = $cb[1];
                $res = $cb[0]->$func($method['credentials'], $product_detail, $execution_url, $method['args']);
            } else {
                $res = $cb($method['credentials'], $product_detail, $execution_url, $method['args']);
            }
            return ($res) ? $res : 0;
        } else {
            return 0;
        }
    }
    function triggerSales($data, $status)
    {
        $payment_setup = array();
        if (isset($_SESSION['order_form_data' . get_option('site_token')])) {
            $payment_setup = $_SESSION['order_form_data' . get_option('site_token')];
        }

if (isset($payment_setup['membership'])) {
            $payment_setup['membership_registration_pages'] = explode(',', trim($payment_setup['membership'], ','));

unset($payment_setup['membership']);
        }

if (isset($payment_setup['optional_products'])) {
            $payment_setup['other_products'] = $payment_setup['optional_products'];
            unset($payment_setup['optional_products']);
        }

if (isset($payment_setup['lists'])) {
            $payment_setup['lists'] = explode('@', trim($payment_setup['lists'], '@'));
        }

$arr = array(
            'success' => ($status) ? true : false,
            'payment_data' => $data,
            'payment_setup' => $payment_setup
        );
        $cbs = $this->action_callbacks['cf_sale'];
        self::playCallbacks($cbs, $arr);
    }
    function processFunnelCreateDelete($funnel_id, $create = true)
    {
        $cbs = ($create) ? ($this->action_callbacks['cf_funnel_create']) : ($this->action_callbacks['cf_funnel_delete']);
        self::playCallbacks($cbs, $funnel_id);
    }
    function processPageCreateDelete($arr, $create = true)
    {
        $cbs = ($create) ? ($this->action_callbacks['cf_funnel_page_create']) : ($this->action_callbacks['cf_funnel_page_delete']);
        self::playCallbacks($cbs, $arr);
    }
    function processPageLevelChange($funnel_id, $changes)
    {
        $cbs = $this->action_callbacks['cf_funnel_page_level_change'];
        $arr = array('funnel_id' => $funnel_id, 'changes' => $changes);
        self::playCallbacks($cbs, $arr);
    }
    function processPageSetupChange($funnel_id, $level)
    {
        $cbs = $this->action_callbacks['cf_funnel_page_setup_change'];
        $arr = array(
            'funnel_id' => $funnel_id,
            'level' => $level
        );
        self::playCallbacks($cbs, $arr);
    }
    function processPageContentChange($funnel_id, $page_id, $level, $ab_type)
    {
        $cbs = $this->action_callbacks['cf_funnel_page_content_change'];
        $arr = array(
            'funnel_id' => $funnel_id,
            'page_id' => $page_id,
            'level' => $level,
            'ab_type' => $ab_type
        );
        self::playCallbacks($cbs, $arr);
    }
    function processGetSales($data)
    {
        $mysqli = $this->mysqli;
        $loader = $this->load;

$rplc_arr = array(
            'id' => 'id',
            'payment_id' => 'payment_id',
            'product_id' => 'productid',
            'payment_method_id' => 'paymentmethod',
            'membership_id' => 'membership',
            'funnel_id' => 'funnelid',
            'payer_email' => 'purchase_email'
        );

$rplc_arr_original = array();
        foreach ($rplc_arr as $index => $val) {
            $rplc_arr_original[$val] = $index;
        }

if (!is_array($data) && $data !== (-1)) {
            $data = array('payment_id' => $data);
        } elseif (is_array($data) && count($data) > 0) {
            $new_data = array();
            foreach ($data as $index => $val) {
                if (isset($rplc_arr[$index])) {
                    $new_data[$rplc_arr[$index]] = $val;
                } else {
                    throw new Exception("Unable to recognize index `" . $index . "`");
                }
            }
            $data = $new_data;
        } else {
            $data = array();
        }

$qry_str_arr = array();
        $qry_str = "";
        if (count($data) > 0) {
            foreach ($data as $index => $val) {
                $val = $mysqli->real_escape_string($val);
                array_push($qry_str_arr, "`" . $index . "`='" . $val . "'");
            }
            $qry_str = " where " . implode(' and ', $qry_str_arr);
        }

$sell_ob = $loader->loadSell();
        return $sell_ob->getSale('', $qry_str, $rplc_arr_original);
    }
    function processGetMembership($data)
    {
        $mysqli = $this->mysqli;
        $loader = $this->load;
        $membership_ob = $loader->loadMember();
        $qry_str_arr = array();
        $qry_str = "";

$allowed_fields = array('id', 'funnel_id', 'email', 'valid_only', 'verified_only', 'verify_code');

if (is_array($data) && count($data) > 0) {
            foreach ($data as $index => $val) {
                if (!in_array($index, $allowed_fields)) {
                    throw new Exception("Unknown field `" . $index . "`");
                }
                $val = $mysqli->real_escape_string($val);
                if ($index == 'funnel_id') {
                    $index = 'funnelid';
                } elseif ($index == 'verified_only') {
                    $index = 'verified';
                    $val = ($val) ? 1 : 0;
                } elseif ($index == 'valid_only') {
                    $index = 'valid';
                    $val = ($val) ? 1 : 0;
                } elseif ($index == 'verify_code') {
                    $index = 'verifycode';
                }
                array_push($qry_str_arr, "`" . $index . "`='" . $val . "'");
            }
        } elseif (is_numeric($data) && $data > 0) {
            array_push($qry_str_arr, "`id`='" . $data . "'");
        } elseif (filter_var($data, FILTER_VALIDATE_EMAIL)) {
            array_push($qry_str_arr, "`email`='" . $data . "'");
        }
        if (count($qry_str_arr) > 0) {
            $qry_str = " where ";
            $qry_str .= implode(' and ', $qry_str_arr);
        }

return $membership_ob->getMemberDetailForPlugins($qry_str);
    }
    function processMembership($data, $doo = 'add')
    {
        $cbs = array();
        if ($doo == 'add') {
            $cbs = $this->action_callbacks['cf_member_create'];
        } elseif ($doo == 'update') {
            $cbs = $this->action_callbacks['cf_member_update'];
        } elseif ($doo == 'delete') {
            $cbs = $this->action_callbacks['cf_member_delete'];
        } else {
            return false;
        }
        self::playCallbacks($cbs, $data);
    }
    function processProduct($data, $doo = 'add')
    {
        $cbs = array();
        if ($doo == 'add') {
            $cbs = $this->action_callbacks['cf_product_create'];
        } elseif ($doo == 'update') {
            $cbs = $this->action_callbacks['cf_product_update'];
        } elseif ($doo == 'delete') {
            $cbs = $this->action_callbacks['cf_product_delete'];
        }
        self::playCallBacks($cbs, $data);
    }
    function processGetProducts($data)
    {
        $loader = $this->load;
        $sell_ob = $loader->loadSell();
        $qry_str_arr = array();
        $qry_str = '';
        $accept_arr = array('id', 'product_id');
        if (is_array($data)) {
            foreach ($data as $index => $val) {
                if (!in_array($index, $accept_arr)) {
                    throw new Exception("Unknown field `" . $index . "`");
                }
                if ($index == 'product_id') {
                    $index = 'productid';
                }
                array_push($qry_str_arr, "`" . $index . "`='" . $val . "'");
            }
        } elseif (is_numeric($data) && $data >= 0) {
            array_push($qry_str_arr, "`id`='" . $data . "'");
        } else if ($data !== (-1)) {
            return array();
        }
        if (count($qry_str_arr) > 0) {
            $qry_str = " where " . implode(' and ', $qry_str_arr);
        }
        return $sell_ob->pluginGetProducts($qry_str);
    }
    function processGetSMTPs($data = -1)
    {
        $loader = $this->load;
        $smtp_ob = $loader->loadSMTP();
        $qry_str = "";
        if (($data != '-1') && is_numeric($data)) {
            $qry_str = " where `id`=" . $data;
        }
        return $smtp_ob->pluginGetSMTPs($qry_str);
    }
    function processGetLists($id, $show_subscribers = false)
    {
        $loader = $this->load;
        $qry_str = "";
        $lists_ob = $loader->createlist();
        $lists = false;
        if ($id === (-1)) {
            $lists = $lists_ob->getList($id, 1);
        } else {
            $lists = $lists_ob->getList($id);
        }
        $arr = array();
        $getLeadsFromList = function ($id) use (&$lists_ob) {
            $subs = $lists_ob->getLeadsFromLists($id);
            $arr = array();
            if ($subs) {
                while ($r = $subs->fetch_assoc()) {
                    $r['list_id'] = $r['listid'];
                    unset($r['listid']);
                    $r['additional_data'] = array();
                    $r['exf'] = json_decode($r['exf']);
                    if (is_object($r['exf'])) {
                        $r['additional_data'] = (array)$r['exf'];
                    }
                    unset($r['exf']);
                    $r['ip'] = $r['ipaddr'];
                    unset($r['ipaddr']);

array_push($arr, $r);
                }
            }
            return $arr;
        };
        if ($lists) {
            if ($id >= 0) {
                $r = (array)$lists;
                if ($show_subscribers) {
                    $r['subscribers'] = $getLeadsFromList($id);
                }
                array_push($arr, $r);
            } else {
                while ($r = $lists->fetch_assoc()) {
                    if ($show_subscribers) {
                        $r['subscribers'] = $getLeadsFromList($r['id']);
                    }
                    array_push($arr, $r);
                }
            }
        }
        return $arr;
    }
    function addUpDelSubscriberToList($id, $data = array(), $doo = 'add')
    {
        //$doo should be add, update, delete
        $loader = $this->load;
        $lists_ob = $loader->createlist();
        $valid_fields = array('name', 'email', 'additional_data');

if (in_array($doo, array('add', 'update'))) {
            if (!is_array($data)) {
                throw new Exception("Second parameter should be an array");
            }
            $in_arr = array(
                'name' => '',
                'email' => '',
                'additional_data' => array(),
                'process_sequence' => 0
            );
            $up_arr = array();
            foreach ($data as $index => $val) {
                if (!in_array($index, $valid_fields)) {
                    throw new Exception("Unknown index '" . $index . "'");
                }
                if ($index == 'email' && !filter_var($val, FILTER_VALIDATE_EMAIL)) {
                    return false;
                } elseif ($index == 'additional_data' && !is_array($val)) {
                    $in_arr['additional_data'] = array();
                }
                if ($doo == 'add') {
                    $in_arr[$index] = $val;
                } else {
                    if ($index == 'process_sequence') {
                        continue;
                    }
                    $up_arr[$index] = $val;
                }
            }
            if ($doo == 'add') {
                $in = $lists_ob->addToList($id, $in_arr['name'], $in_arr['email'], $in_arr['additional_data'], 0, $in_arr['process_sequence']);
                return $in;
            } else {
                if (isset($up_arr['additional_data'])) {
                    $up_arr['exf'] = $up_arr['additional_data'];
                    unset($up_arr['additional_data']);
                }
                $up = $lists_ob->pluginUpdateListUser($id, $up_arr);
                return $up;
            }
        } elseif ($doo = 'delete') {
            return $lists_ob->pluginDeleteSubscriber($id);
        } else {
            return false;
        }
    }
    function processGetSubscriber($id, $email = false)
    {
        $loader = $this->load;
        $lists_ob = $loader->createlist();
        return $lists_ob->pluginGetSubscriber($id, $email);
    }
    function processTheEmailContent($content)
    {
        //the_email_content
        $cbs = $this->filter_callbacks['the_email_content'];
        return self::playCallbacksForFilter($cbs, $content, array());
    }
    function processTheEmailSubject($content)
    {
        //the_email_subject
        $cbs = $this->filter_callbacks['the_email_subject'];
        return self::playCallbacksForFilter($cbs, $content, array());
    }
    function processGetUsers($arr = array())
    {
        $mysqli = $this->mysqli;
        $loader = $this->load;
        $permission_arr = array('id', 'email');
        $qry_args = array();
        $qry_str = "";
        foreach ($arr as $index => $val) {
            if (!in_array($index, $permission_arr)) {
                throw new Exception('Unknown index ' . $index);
            }
            $val = $mysqli->real_escape_string($val);
            $data = ($index == 'id') ? "`id`=" . $val . "" : "`" . $index . "`='" . $val . "'";
            array_push($qry_args, $data);
        }
        $user_ob = $loader->loadUser();
        if (count($qry_args) > 0) {
            $qry_str = " where ";
            $qry_str .= implode('and', $qry_args);
        }
        return $user_ob->pluginGetAllUsers($qry_str);
    }
}