1:   2:   3:   4:   5:   6:   7:   8:   9:  10:  11:  12:  13:  14:  15:  16:  17:  18:  19:  20:  21:  22:  23:  24:  25:  26:  27:  28:  29:  30:  31:  32:  33:  34:  35:  36:  37:  38:  39:  40:  41:  42:  43:  44:  45:  46:  47:  48:  49:  50:  51:  52:  53:  54:  55:  56:  57:  58:  59:  60:  61:  62:  63:  64:  65:  66:  67:  68:  69:  70:  71:  72:  73:  74:  75:  76:  77:  78:  79:  80:  81:  82:  83:  84:  85:  86:  87:  88:  89:  90:  91:  92:  93:  94:  95:  96:  97:  98:  99: 100: 101: 102: 103: 104: 105: 106: 107: 108: 109: 110: 111: 112: 113: 114: 115: 116: 117: 118: 119: 120: 121: 122: 123: 124: 125: 126: 127: 128: 129: 130: 131: 132: 133: 134: 135: 136: 137: 138: 139: 140: 141: 142: 143: 144: 145: 146: 147: 148: 149: 150: 151: 152: 153: 154: 155: 156: 157: 158: 159: 160: 161: 162: 163: 164: 165: 166: 167: 168: 169: 170: 171: 172: 173: 174: 175: 176: 177: 178: 179: 180: 181: 182: 183: 184: 185: 186: 187: 188: 189: 190: 191: 192: 193: 194: 195: 196: 197: 198: 199: 200: 201: 202: 203: 204: 205: 206: 207: 208: 209: 210: 211: 212: 213: 214: 215: 216: 217: 218: 219: 220: 221: 222: 223: 224: 225: 226: 227: 228: 229: 230: 231: 232: 233: 234: 235: 236: 237: 238: 239: 240: 241: 242: 243: 244: 245: 246: 247: 248: 249: 250: 251: 252: 253: 254: 255: 256: 257: 258: 259: 260: 261: 262: 263: 264: 265: 266: 267: 268: 269: 270: 271: 272: 273: 274: 275: 276: 277: 278: 279: 280: 281: 282: 283: 284: 285: 286: 287: 288: 289: 290: 291: 292: 293: 294: 295: 296: 297: 298: 299: 300: 301: 302: 303: 304: 305: 306: 307: 308: 309: 310: 311: 312: 313: 314: 315: 316: 317: 318: 319: 320: 321: 322: 323: 324: 325: 326: 327: 328: 329: 330: 331: 332: 333: 334: 335: 336: 337: 338: 339: 340: 341: 342: 343: 344: 345: 346: 347: 348: 349: 350: 351: 352: 353: 354: 355: 356: 357: 358: 359: 360: 361: 362: 363: 364: 365: 366: 367: 368: 369: 370: 371: 372: 373: 374: 375: 376: 377: 378: 379: 380: 381: 382: 383: 384: 385: 386: 387: 388: 389: 390: 391: 392: 393: 394: 395: 396: 397: 398: 399: 400: 401: 402: 403: 404: 405: 406: 407: 408: 409: 410: 411: 412: 413: 414: 415: 416: 417: 418: 419: 420: 421: 422: 423: 424: 425: 426: 427: 428: 429: 430: 431: 432: 

<?php

/**
 * Class loads miscellaneous WordPress AJAX listeners related to email component
 * @package Mailer
 * @subpackage Management
 */

class Inbound_Mailer_Ajax_Listeners {
    static $needle;

    /**
     *  Initializes class
     */
    public function __construct() {
        self::load_hooks();
    }

    /**
     *  Loads hooks and filters
     */
    public static function load_hooks() {


        /* Adds listener to save email data */
        add_action( 'wp_ajax_save_inbound_email', array( __CLASS__ , 'save_email' ) );

        /* Adds listener for email variation send statistics */
        add_action( 'wp_ajax_inbound_load_email_row_stats' , array( __CLASS__ , 'get_email_row_statistics' ) );

        /* Adds listener to send test email */
        add_action( 'wp_ajax_inbound_send_test_email' , array( __CLASS__ , 'send_test_email' ) );

        /* Adds listener to schedule email */
        add_action( 'wp_ajax_inbound_schedule_email' , array( __CLASS__ , 'schedule_email' ) );

        /* Adds listener to schedule email */
        add_action( 'wp_ajax_inbound_unschedule_email' , array( __CLASS__ , 'unschedule_email' ) );

        /* Adds listener to set scheduled email to sent */
        add_action( 'wp_ajax_inbound_mark_sent' , array( __CLASS__ , 'mark_sent' ) );

        /* Adds listener to schedule email */
        add_action( 'wp_ajax_inbound_prepare_batch_email' , array( __CLASS__ , 'prepare_batch_email' ) );

        /* Adds listener to clear email stats */
        add_action( 'wp_ajax_clear_email_stats' , array( __CLASS__ , 'clear_stats' ) );

        /* Adds listener to update range email */
        add_action( 'wp_ajax_inbound_email_update_range' , array( __CLASS__ , 'update_range' ) );

        /* Adds listener to update job id memory */
        add_action( 'wp_ajax_inbound_email_update_job_id' , array( __CLASS__ , 'update_job_id' ) );
    }

    /**
     *  Saves meta pair values give cta ID, meta key, and meta value
     */
    public static function save_email() {
        global $wpdb;

        if ( !isset($_POST) ) {
            return;
        }

        /* error_log( print_r( $_POST , true ) ); */

        /* update post type */
        wp_update_post( array(
            'ID' => $_POST['post_ID'],
            'post_status' => isset($_POST['post_status']) ? $_POST['post_status'] : $_POST['hidden_post_status'],
            'post_title' => $_POST['post_title'],
        ));

        /* get current email settings */
        $email_settings = Inbound_Email_Meta::get_settings( $_POST['post_ID'] );

        /* Set the call to action variation into a session variable */
        $_SESSION[ $_POST['post_ID'] . '-variation-id'] = (isset($_POST[ 'inbvid'])) ? $_POST[ 'inbvid'] : '0';

        /* save all post vars as meta */
        foreach ($_POST as $key => $value) {

            switch($key) {
                case 'subject':
                    $value = str_replace('&quot;' , '"' , $value);
                    break;
            }

            if ( substr( $key , 0 , 8 ) == 'inbound_' ){
                $key = str_replace( 'inbound_' , '' , $key );
                $email_settings[ $key ] = $value;
            } else {
                if (self::check_whitelist( $key )) {
                    $email_settings['variations'][ $_POST[ 'inbvid'] ][ $key ] = $value;
                }
            }
        }

        /* Update Settings */
        Inbound_Email_Meta::update_settings( $_POST['post_ID'] , $email_settings );

        /* Update Tags */
        if ( isset( $_POST['tax_input'] ) ) {
            foreach ( $_POST['tax_input']  as $tax => $terms ) {
                wp_set_post_terms( $_POST['post_ID'], $terms, $tax, false );
            }
        }

        header('HTTP/1.1 200 OK');
        exit;
    }

    /**
     *  Checks meta key for variation setting qualification
     *  @returns BOOLEAN $key false for skip true for save
     */
    public static function check_whitelist( $key ) {
        /* do not save post_ related keys */
        if ( substr( $key , 0 , 5 ) == 'post_' ) {
            return false;
        }

        /* do not save hidden custom fields */
        if ( substr( $key , 0 , 1 ) == '_' ) {
            return false;
        }

        /* do not save hidden custom fields */
        if ( substr( $key , 0 , 7 ) == 'hidden_' ) {
            return false;
        }

        /* do not save hidden custom fields */
        if ( substr( $key , 0 , 4 ) == 'cur_' ) {
            return false;
        }

        /* do not save hidden custom fields */
        if ( strstr( $key , 'nonce' ) ) {
            return false;
        }

        /* do not save hidden custom fields */
        if ( in_array( $key , array('inbvid', 'email_action' , 'originalaction','action','original_publish','publish','original_post_status', 'referredby', 'meta-box-order-nonce', 'comment_status','ping_status','post_mime_type','newtag','tax_input','post_password' ,'visibility','wp-preview' ) ) ) {
            return false;
        }

        return true;
    }

    /**
     *  Gets JSON object containing email send statistics return cached data if cached
     */
    public static function get_email_row_statistics() {
        global $inbound_settings;


        $post_status = (isset($_GET['post_status'])) ? $_GET['post_status'] : '';
        $page = (isset($_GET['paged'])) ? $_GET['paged'] : 1;
        $tkey =  'inbound-email-stats-cache'.$post_status.$page;

        $stats = get_transient($tkey);

        if (!is_array($stats)) {
            $stats = array();
        }

        /* get email id */
        $email_id = intval($_REQUEST['email_id']);

        /* get job id if applicable */
        $job_id = get_user_option(
            'inbound_mailer_screen_option_automated_email_report',
            get_current_user_id()
        );

        /* if job id is set to 'last_send' then source the last job id */
        $job_id = ($job_id == 'last_send' ) ? Inbound_Mailer_Post_Type::get_last_job_id($email_id) : $job_id;

        if (isset($stats[$email_id])) {
            echo json_encode($stats[$email_id]);
            header('HTTP/1.1 200 OK');
            exit;
        }

        switch ($inbound_settings['mailer']['mail-service']) {
            case "sparkpost":
                $stats[$email_id] = Inbound_SparkPost_Stats::get_sparkpost_inbound_events( $email_id , $vid = null , $job_id );
                break;
        }

        set_transient( $tkey , $stats , 60* 5);

        echo json_encode($stats[$email_id]);
        header('HTTP/1.1 200 OK');
        exit;
    }

    /**
     *  Sends test email
     */
    public static function send_test_email() {

        /* see if there is a lead associated with the test email */
        $lead_id = LeadStorage::lookup_lead_by_email($_REQUEST['email_address']);

        $response = Inbound_Mail_Daemon::send_solo_email( array(
            'email_address' => sanitize_text_field($_REQUEST['email_address']) ,
            'email_id' => intval($_REQUEST['email_id']) ,
            'vid' => intval($_REQUEST['variation_id']),
            'from_name' => 'test@inboundnow.com',
            'lead_id' => ( $lead_id ) ? intval($lead_id) : 0,
            'is_test' => true
        ));

        _e( 'Here are your send results:' , 'inbound-pro' );

        echo "\r\n";

        print_r($response);

        exit;
    }


    /**
     *  Schedule email
     */
    public static function schedule_email() {
        $response = Inbound_Mailer_Scheduling::schedule_email(intval($_POST['email_id']));
        echo $response;
        exit;
    }

    /**
     *  Unschedule email
     */
    public static function unschedule_email() {
        do_action('mailer/unschedule-email' , $_REQUEST['email_id'] );
        exit;
    }

    /**
     *  Mark Email Sent
     */
    public static function mark_sent() {
        $args = array(
            'ID' => intval($_REQUEST['email_id']),
            'post_status' => 'sent',
        );

        wp_update_post( $args );
        exit;
    }

    /**
     *
     */
    public static function prepare_batch_email() {


        $email_id = $_POST['email_id'];
        $post_id = $_POST['post_id'];

        if (!$email_id) {
            return;
        }

        $post = get_post($email_id);

        if (function_exists('wp_get_current_user')) {
            $new_post_author = wp_get_current_user();
            $author_id = $new_post_author->ID;
        } else {
            $author_id = get_current_user_id();
        }


        $new_post = array(
            'menu_order' => $post->menu_order,
            'comment_status' => $post->comment_status,
            'ping_status' => $post->ping_status,
            'post_author' => $author_id,
            'post_content' => $post->post_content,
            'post_excerpt' =>   $post->post_excerpt ,
            'post_mime_type' => $post->post_mime_type,
            'post_parent' => $new_post_parent = empty($parent_id)? $post->post_parent : $parent_id,
            'post_password' => $post->post_password,
            'post_status' => 'unsent',
            'post_title' => get_the_title($post_id),
            'post_type' => $post->post_type,
        );

        $new_post['post_date'] = $new_post_date =   $post->post_date ;
        $new_post['post_date_gmt'] = get_gmt_from_date($new_post_date);

        $new_email_id = wp_insert_post($new_post);

        $meta_data = get_post_meta($post->ID);

        /* destroy any past statistics */
        unset($meta_data['inbound_statistics']);


        /* replace id in meta fields */
        foreach ($meta_data as $key=>$value) {
            if ($key=='inbound_settings') {
                $value[0] = unserialize( $value[0] );
            }


            /* set email type to batch */
            if ($key == 'inbound_settings') {
                $value[0]['email_type'] = 'batch';
                $variations = $value[0]['variations'];

                foreach ($variations as $vid => $settings) {
                    $value[0]['variations'][$vid]['acf'] = self::replace_id($value[0]['variations'][$vid]['acf'], $post_id);
                }


            } else {
                /* replace shortcode ids */
                $value[0] = self::replace_id($value[0], $post_id);
            }



            update_post_meta($new_email_id , $key , $value[0]);
        }


        echo $new_email_id;
        exit;
    }

    /**
     *
     */
    public static function replace_id( $mixed , $post_id ) {

        if (is_array($mixed)) {

            foreach ($mixed as $k => $v ) {

                if (is_array($v)) {
                    $mixed[$k] = self::replace_id($v,$post_id);
                }else {
                    preg_match("/\sid=\d+/", $v , $output_array);
                    foreach ($output_array as $kk=>$match) {
                        $mixed[$k] = str_replace($match , ' id=' . $post_id , $v);
                    }
                }
            }


        } else {

            preg_match("/\sid=\d+/", $mixed , $output_array);
            foreach ($output_array as $k=>$match) {
                $mixed = str_replace($match , ' id=' . $post_id , $mixed);
            }
        }

        return $mixed;
    }

    /**
     *  Schedule email
     */
    public static function clear_stats() {
        global $wpdb;

        $email_id = intval($_REQUEST['email_id']);
        $table_name = $wpdb->prefix . "inbound_events";

        /* delete the meta stats object */
        delete_post_meta( $email_id , 'inbound_statistics' );


        /* delete enteries from inbound_events table */
        $where = array(
            'email_id' => $email_id
        );

        $wpdb->delete( $table_name, $where, $where_format = null );

        echo 1;
        exit;
    }

    /**
     *  Updates user preferred statistic reporting date range
     */
    public static function update_range() {
        if (!isset($_POST['range'])) {
            return;
        }

        $response = update_user_option(
            get_current_user_id(),
            'inbound_mailer_screen_option_range',
            intval($_POST['range'])
        );
        echo $response;
        exit;
    }


    /**
     *  Updates user preferred statistic reporting date range
     */
    public static function update_job_id() {
        if (!isset($_POST['job_id'])) {
            return;
        }

        $response = update_user_option(
            get_current_user_id(),
            'inbound_mailer_reporting_job_id_' . intval($_POST['email_id']),
            sanitize_text_field($_POST['job_id'])
        );

        echo sanitize_text_field($_POST['job_id']);
        exit;
    }
}

/* Loads Inbound_Mailer_Ajax_Listeners pre init */
new Inbound_Mailer_Ajax_Listeners();