<?php

/**
 * Plugin Name: Broker Settings
 * Plugin URI:
 * Author URI:
 * Description: Add / Import brokers
 * Author: Tenzing Communicatiions Inc.
 * Version: 0.1
 */

// Exit if accessed directly
if (!defined('ABSPATH')) {
    exit;
}

register_activation_hook(__FILE__, 'activate_broker_settings_plugin');
register_deactivation_hook(__FILE__, 'deactivate_broker_settings_plugin');

// Run the init function when it's time to load the plugin
add_action('plugins_loaded', ['BrokerSettings', 'init']);

if (!class_exists('BrokerSettings')) {
    class BrokerSettings
    {
        // Instance of the class
        protected static $instance;

        // This function is called when loading our plugin
        public static function init()
        {
            // Check to see if an instance already exists
            if (is_null(self::$instance)) {
                // Create a new instance
                self::$instance = new self;
            }

            // Return the instance
            return self::$instance;
        }

        /**
         * Constructor will create the menu item
         */
        public function __construct()
        {
            // This plugin is for the backend only
            if (!is_admin()) {
                return;
            }

            // Detect line endings
            ini_set("auto_detect_line_endings", true);

            // Set max execution time
            set_time_limit(0);
            ini_set('max_execution_time', 259200);

            add_action('admin_menu', [$this, 'add_menu_broker_settings_page']);

            $this->enqueue_assets();
            $this->add_ajax_functions();
            $this->add_broker_custom_column();
        }

        /**
         * Initialize actions
         */
        protected function add_ajax_functions()
        {
            add_action('wp_ajax_get_broker_list', [$this, 'get_broker_list']);
            add_action('wp_ajax_import_bulk', [$this, 'import_bulk']);
            add_action('wp_ajax_create_broker', [$this, 'create_broker']);
            add_action('wp_ajax_get_broker_info', [$this, 'get_broker_info']);
            add_action('wp_ajax_update_broker_info', [$this, 'update_broker_info']);
            add_action('wp_ajax_delete_broker_info', [$this, 'delete_broker_info']);

            add_action('wp_ajax_upload_broker', [$this, 'upload_broker']);
            add_action('wp_ajax_upload_user_with_broker_info', [$this, 'upload_user_with_broker_info']);

            add_action('wp_ajax_get_broker_import_status', [$this, 'get_broker_import_status']);
        }

        /**
         * Add admin menus
         */
        public function add_menu_broker_settings_page()
        {
            add_menu_page(
                'Broker Settings',
                'Broker Settings',
                'manage_options',
                'broker_settings',
                [$this, 'display_broker_settings_page'],
                '',
                4
            );

            add_submenu_page(
                'broker_settings',
                'Import Broker Organizations',
                'Import Broker Organizations',
                'manage_options',
                'import_broker_organizations',
                [$this, 'display_import_broker_organizations_page']
            );

//            add_submenu_page(
//                'broker_settings',
//                'Import broker_id for users',
//                'Import broker_id for users',
//                'manage_options',
//                'import_broker_id_for_users',
//                [$this, 'display_import_broker_id_for_users_page']
//            );
        }

        /**
         * Enqueue assets
         */
        public function enqueue_assets()
        {
            $pluginDir = plugin_dir_url(__FILE__) . '';
            $pageParam = $_GET['page'];

            if ($pageParam == 'broker_settings') {
                wp_enqueue_style('angular-materialize', $pluginDir . 'css/angular-material.min.css');

                wp_enqueue_style('fonts', "https://fonts.googleapis.com/icon?family=Material+Icons");
                wp_enqueue_style('app', $pluginDir . 'css/app.css');

                wp_enqueue_script('angularjs', $pluginDir . 'js/angular.min.js', [], '1.6', true);
                wp_enqueue_script('angular-animate', $pluginDir . 'js/angular-animate.min.js', [], '1.5.5', true);
                wp_enqueue_script('angular-aria', $pluginDir . 'js/angular-aria.min.js', [], '1.5.5', true);
                wp_enqueue_script('angular-messages', $pluginDir . 'js/angular-messages.min.js', [], '1.5.5', true);

                wp_enqueue_script('angular-materialize', $pluginDir . 'js/angular-material.min.js', [], '1.1.1', true);

                wp_enqueue_script('app', $pluginDir . 'js/app.js', [], '0.1', true);
                wp_enqueue_script('broker-controller', $pluginDir . 'brokers/brokers.controller.js', [], '0.1', true);

                wp_enqueue_script('broker-factory', $pluginDir . 'brokers/brokers.factory.js', [], '0.1', true);
            } else {
                if ($pageParam == 'import_broker_organizations') {
                    wp_enqueue_style(
                        'progressbar',
                        $pluginDir . 'css/jquery-ui.min.css'
                    );

                    wp_enqueue_style(
                        'style',
                        $pluginDir . 'css/style.css'
                    );

                    wp_enqueue_script(
                        'jquery-ui-progressbar'
                    );

                    wp_enqueue_script(
                        'fileuploader',
                        $pluginDir . 'js/plupload.full.min.js',
                        '',
                        '1',
                        true
                    );

                    wp_enqueue_script(
                        'uploadUsers',
                        $pluginDir . 'js/import.js',
                        '',
                        '1',
                        true
                    );
                } else {
                    if ($pageParam == 'import_broker_id_for_users') {
                        wp_enqueue_style(
                            'progressbar',
                            $pluginDir . 'css/jquery-ui.min.css'
                        );
                        
                        wp_enqueue_style(
                            'style',
                            $pluginDir . 'css/style.css'
                        );

                        wp_enqueue_script(
                            'jquery-ui-progressbar'
                        );

                        wp_enqueue_script(
                            'fileuploader',
                            $pluginDir . 'js/plupload.full.min.js',
                            '',
                            '1',
                            true
                        );

                        wp_enqueue_script(
                            'uploadUsers',
                            $pluginDir . 'js/import2.js',
                            '',
                            '1',
                            true
                        );
                    }
                }
            }

        }

        /**
         *
         */
        public function add_broker_custom_column() {
            add_filter( 'manage_users_columns', function($column) {
                $column['broker_id'] = 'Broker ID';
                return $column;
            } );

            add_filter( 'manage_users_custom_column', function($val, $column_name, $user_id) {
                switch ($column_name) {
                    case 'broker_id' :
                        return get_the_author_meta( 'brokerage', $user_id );
                        break;
                    default:
                }
                return $val;
            }, 10, 3 );
        }

        /**
         * Ajax function for upload broker
         */
        public function upload_broker()
        {
            // if the form is submitted
            $isFileEmpty       = empty($_FILES['file']['tmp_name']);
            $csvFile           = $_FILES['file']['tmp_name'];
            $returnData        = [
                'success'         => [],
                'empty_broker_id' => [],
                'empty_brokerage' => [],
                'existing_broker' => []
            ];
            $importBrokerIDs   = [];
            $currentBrokerList = get_option('broker_list') ? unserialize(get_option('broker_list')) : [];

            $brokerArray  = $this->convertFileToArray($csvFile);
            $arr_rows     = $brokerArray[0];
            $check_string = $brokerArray[1];

            $total_rows = count($arr_rows);
            update_option('parsed_rows', 0);
            update_option('total_rows', $total_rows);

            // Check file/data type
            // must be utf-8
            if ($this->isUTF8($check_string) === false) {
                wp_send_json(['file_format' => 'Please check your CSV file format.']);
            }

            $necessaryColumns = [];

            $row_count = 1;

            if (!$isFileEmpty) {
                // loop around
                if (is_array($arr_rows)) {

                    $first   = true;
                    $headers = [];
                    foreach ($arr_rows as $row) {
                        $row = implode('","', $row);
                        // If a row is empty, just skip it
                        if (empty($row)) {
                            if ($first) {
                                break;
                            } else {
                                continue;
                            }
                        }

                        // If we are on the first line, the columns are the headers
                        if ($first === true) {
                            //replace " by null
                            //$calumn_names = str_replace('"', '', $row);
                            // split into values
                            //$headers = explode(",", $calumn_names);
                            $headers = str_getcsv($row, ',', '"');

                            // Filter or detect necessary columns from the header
                            foreach ($headers as $index => $header) {
                                $header = trim($header);
                                if (in_array($header, ['broker_id', 'brokerage', 'organization'])) {
                                    $necessaryColumns[$index] = $header;
                                }
                            }

                            $first = false;
                            continue;
                        }

                        // Increase row count
                        update_option('parsed_rows', ++$row_count);

                        $broker_data = [];

                        // split into values
                        //$arr_values = str_replace('"', '', $row);
                        //$arr_values = explode(",", $arr_values);
                        $arr_values = str_getcsv($row, ",", '"');

                        foreach ($arr_values as $ckey => $cvalue) {
                            // Check if the column value is in the necessary columns array
                            if (!array_key_exists($ckey, $necessaryColumns)) {
                                continue;
                            }

                            // Column Title
                            $column_name = strtolower(str_replace(' ', '', trim($headers[$ckey])));

                            // Sanitize the value
                            // Input data validation - prevent breaking something
                            // - correct data type ( remove any HTML tag, scripts )
                            $cvalue = sanitize_text_field($cvalue);

                            if ($column_name == 'brokerage' || $column_name == 'organization') {
                                $broker_data['brokerage'] = $cvalue;
                            } else {
                                $broker_data[$column_name] = $cvalue;
                            }

                        }

                        if (in_array($broker_data['broker_id'], $importBrokerIDs)) {
                            continue;
                        }

                        // If 'broker_id' is empty
                        // Error message > Skip > add to a result
                        if ($broker_data['broker_id'] == '') {
                            array_push(
                                $returnData['empty_broker_id'],
                                'Row: ' . $row_count . ' - CSV is missing the require field value (broker_id). Please check your csv file. The broker was not imported.'
                            );
                            continue;
                        }

                        // If 'brokerage' / 'organization' is empty
                        // Error message > Skip > add to a result
                        if (empty($broker_data['brokerage']) && empty($broker_data['organization'])) {
                            array_push(
                                $returnData['empty_brokerage'],
                                'Row: ' . $row_count . ' - CSV is missing the require field value (brokerage). Please check your csv file. The broker was not imported.'
                            );
                            continue;
                        }


                        // Check if the broker_id exists.
                        $brokerExisting = false;
                        foreach ($currentBrokerList as $broker) {
                            if ($broker['broker_id'] == $broker_data['broker_id']) {
                                $brokerExisting = true;
                            }
                        }

                        if ($brokerExisting) {
                            array_push(
                                $returnData['existing_broker'],
                                'Row: ' . $row_count . ' - The broker ( ' . $broker_data['broker_id'] . ' ) is already in our system. Please check your csv file. The broker was not imported.'
                            );
                            continue;
                        }

                        // Everything is good?
                        if (!isset($_POST['dry_run'])) {
                            array_push(
                                $currentBrokerList,
                                [
                                    'id'        => uniqid(),
                                    'broker_id' => $broker_data['broker_id'],
                                    'brokerage' => $broker_data['brokerage']
                                ]
                            );

                            update_option('broker_list', serialize($currentBrokerList));
                        }

                        array_push(
                            $returnData['success'],
                            'Row: ' . $row_count . ' - A broker ( ' . $broker_data['broker_id'] . ' ) have been imported successfully.'
                        );

                        array_push($importBrokerIDs, $broker_data['broker_id']);
                    }

                    // Save last import date

                    wp_send_json($returnData);
                }
            }
        }

        /**
         * Ajax function for upload user with broker info
         */
        public function upload_user_with_broker_info()
        {
            // if the form is submitted
            $isFileEmpty       = empty($_FILES['file']['tmp_name']);
            $csvFile           = $_FILES['file']['tmp_name'];
            $returnData        = [
                'success'          => [],
                'empty_user_email' => [],
                'empty_broker_id'  => [],
                'new_user'          => [],
                'no_existing_broker' => []
            ];
            $currentBrokerList = get_option('broker_list') ? unserialize(get_option('broker_list')) : [];

            $userArray    = $this->convertFileToArray($csvFile);
            $arr_rows     = $userArray[0];
            $check_string = $userArray[1];

            $total_rows = count($arr_rows);
            update_option('parsed_rows', 0);
            update_option('total_rows', $total_rows);

            // Check file/data type
            // must be utf-8
            if ($this->isUTF8($check_string) === false) {
                wp_send_json(['file_format' => 'Please check your CSV file format.']);
            }

            global $userAccessManager;
            $aUserGroups = null;

            $oUamAccessHandler = $userAccessManager->getAccessHandler();
            $aUamUserGroups = $oUamAccessHandler->getUserGroups();

            $uamGroup = false;
            $uamGroupBroker = false;
            foreach ($aUamUserGroups as $oUamUserGroup) {
                $groupName = $oUamUserGroup->getGroupName();
                if($groupName == 'rating.thecommonwell.ca/auth/authenticate') {
                    $uamGroup = $oUamUserGroup;
                }

                if($groupName == 'Broker') {
                    $uamGroupBroker = $oUamUserGroup;
                }
            }

            $necessaryColumns = [];

            $row_count = 1;

            if (!$isFileEmpty) {
                // loop around
                if (is_array($arr_rows)) {

                    $first   = true;
                    $headers = [];
                    foreach ($arr_rows as $row) {
                        $row = implode('","', $row);
                        // If a row is empty, just skip it
                        if (empty($row)) {
                            if ($first) {
                                break;
                            } else {
                                continue;
                            }
                        }

                        // If we are on the first line, the columns are the headers
                        if ($first === true) {
                            //replace " by null
                            //$calumn_names = str_replace('"', '', $row);
                            // split into values
                            //$headers = explode(",", $calumn_names);
                            $headers = str_getcsv($row, ',', '"');

                            // Filter or detect necessary columns from the header
                            foreach ($headers as $index => $header) {
                                $header = trim($header);
                                if (in_array($header, ['user_email', 'broker_id', 'first_name', 'last_name'])) {
                                    $necessaryColumns[$index] = $header;
                                }
                            }

                            $first = false;
                            continue;
                        }

                        // Increase row count
                        update_option('parsed_rows', ++$row_count);

                        $user_data = [];

                        // split into values
                        //$arr_values = str_replace('"', '', $row);
                        //$arr_values = explode(",", $arr_values);
                        $arr_values = str_getcsv($row, ",", '"');

                        foreach ($arr_values as $ckey => $cvalue) {
                            // Check if the column value is in the necessary columns array
                            if (!array_key_exists($ckey, $necessaryColumns)) {
                                continue;
                            }

                            // Column Title
                            $column_name = strtolower(str_replace(' ', '', trim($headers[$ckey])));

                            // Sanitize the value
                            // Input data validation - prevent breaking something
                            // - correct data type ( remove any HTML tag, scripts )
                            $cvalue = sanitize_text_field($cvalue);

                            if ($column_name == 'brokerage' || $column_name == 'organization') {
                                $user_data['brokerage'] = $cvalue;
                            } else {
                                $user_data[$column_name] = $cvalue;
                            }
                        }

                        // If 'user_email' is empty
                        // Error message > Skip > add to a result
                        if ($user_data['user_email'] == '') {
                            array_push(
                                $returnData['empty_user_email'],
                                'Row: ' . $row_count . ' - CSV is missing the require field value (user_email). Please check your csv file. The user was not imported.'
                            );
                            continue;
                        }

                        // If 'broker_id' is empty
                        // Error message > Skip > add to a result
                        if ($user_data['broker_id'] == '') {
                            array_push(
                                $returnData['empty_broker_id'],
                                'Row: ' . $row_count . ' - CSV is missing the require field value (broker_id). Please check your csv file. The user was not imported.'
                            );
                            continue;
                        }

                        // Check if the broker_id exists.
                        $brokerExisting = false;
                        foreach ($currentBrokerList as $broker) {
                            if ($broker['broker_id'] == $user_data['broker_id']) {
                                $brokerExisting = true;
                            }
                        }

                        if (!$brokerExisting) {
                            array_push(
                                $returnData['no_existing_broker'],
                                'Row: ' . $row_count . ' - The broker ( ' . $user_data['broker_id'] . ' ) is not in our system. Please check your csv file. The user was not imported.'
                            );
                            continue;
                        }

                        // Disable sending email
                        add_filter( 'send_email_change_email', '__return_false' );
                        add_filter( 'send_password_change_email', '__return_false' );

                        // Check if existing user
                        $userID = null;
                        // Create a new user
                        if (!email_exists($user_data['user_email'])) {
                            // Add new user

                            if (!isset($_POST['dry_run'])) {
                                $user_data['user_login'] = $user_data['user_email'];

                                $userID = wp_insert_user($user_data);
                                if (!is_wp_error($userID)) {
                                    array_push(
                                        $returnData['new_user'],
                                        'Row: ' . $row_count . ' - A new user is created ('.$userID.'). '
                                    );
                                }
                            } else {
                                array_push(
                                    $returnData['new_user'],
                                    'Row: ' . $row_count . ' - A new user is created ('.$user_data['user_email'].'). '
                                );
                            }


                        } else {
                            $userID = email_exists($user_data['user_email']);
                        }

                        $userID = intval($userID);

                        // Everything is good?
                        // Update Info
                        if (!isset($_POST['dry_run'])) {
                            update_user_meta($userID, 'broker_id', $user_data['broker_id']);

                            $user_meta=get_userdata($userID);
                            $user_roles=$user_meta->roles;

                            // If the user role is administrator
                            // Do not update role
                            // Otherwise, update the role to broker (subscriber)
                            if (in_array("administrator", $user_roles)){
                                // Update user info
                                wp_update_user([
                                    'ID' => $userID,
                                    'first_name' => $user_data['first_name'],
                                    'last_name' => $user_data['last_name']
                                ]);
                            } else {
                                // Update user info
                                wp_update_user([
                                    'ID' => $userID,
                                    'first_name' => $user_data['first_name'],
                                    'last_name' => $user_data['last_name'],
                                    'role' => 'subscriber'
                                ]);
                            }

                            if($uamGroupBroker) {
                                $uamGroupBroker->addObject('user', $userID);
                                $uamGroupBroker->save(false);
                            }

                            $brokerage = false;
                            foreach($currentBrokerList as $broker) {
                                if($user_data['broker_id'] == $broker['broker_id']) {
                                    $brokerage = $broker['brokerage'];
                                }
                            }

                            if($brokerage) {
                                update_user_meta($userID, 'brokerage', $brokerage);
                            }
                        }

                        if(isset($_POST['add_uam']) && $_POST['add_uam'] == '1') {
                            $uamGroup->addObject('user', $userID);
                            $uamGroup->save(false);
                        }

                        array_push(
                            $returnData['success'],
                            'Row: ' . $row_count . ' - A user ( ' . $user_data['user_email'] . ' ) have been imported/updated successfully.'
                        );
                    }

                    // Save last import date

                    wp_send_json($returnData);
                }
            }
        }

        /**
         * Import broker display
         */
        public function display_import_broker_organizations_page()
        {
            if (!current_user_can('manage_options')) {
                wp_die(__('You do not have sufficient permissions to access this page.'));
            }
            ?>
            <div class="wrap">
                <div id="html-message"></div>
                <h1>Import Broker Organizations Tool</h1>
                <div id="progressbar" class="progressbar">
                    <div class="progress-label">Loading...</div>
                </div>
                <div id="status"></div>
                <div class="error empty-file notice"><p>Please choose a file.</p></div>
                <h4>Detectable Column Titles: </h4>
                <ul>
                    <li>broker_id</li>
                    <li>brokerage</li>
                    <li>organization</li>
                </ul>
                <form id="broker-import-form" class="broker-import-form" action="" enctype="multipart/form-data"
                      method="post">
                    <input type="hidden" name="MAX_FILE_SIZE" value="50000000" />
                    <input id="dry-run" type="checkbox" name="dry-run" value="1" /><label for="dry-run">Dry
                                                                                                        run</label>
                    <br /><br />
                    <a id="csv_file" class="button" href="javascript:;">Select file</a>
                    <div id="filelist"></div>
                    <input id="submit" class="button" type="submit" value="Import" />
                    <div class="ajax-loader">
                        <img src="/wp-admin/images/spinner-2x.gif" alt="loader icon" class=""/> Importing...
                    </div>
                </form>
                <p style="color: red">Please make sure to have back up your database before proceeding!</p>
            </div>
        <?php }

        /**
         * Import broker id for users page
         */
        public function display_import_broker_id_for_users_page()
        {
            if (!current_user_can('manage_options')) {
                wp_die(__('You do not have sufficient permissions to access this page.'));
            }
            ?>
            <div class="wrap">
                <div id="html-message"></div>
                <h1>Import broker_id for users tool</h1>
                <div id="progressbar" class="progressbar">
                    <div class="progress-label">Loading...</div>
                </div>
                <div id="status"></div>
                <div class="error empty-file notice"><p>Please choose a file.</p></div>
                <h4>Detectable Column Titles: </h4>
                <ul>
                    <li>user_email</li>
                    <li>broker_id</li>
                    <li>first_name</li>
                    <li>last_name</li>
                </ul>
                <form id="user-with-broker-info-import-form" class="broker-import-form" action=""
                      enctype="multipart/form-data"
                      method="post">
                    <input type="hidden" name="MAX_FILE_SIZE" value="50000000" />
                    <input id="dry-run" type="checkbox" name="dry-run" value="1" /><label for="dry-run">Dry
                                                                                                        run</label>
                    &nbsp;&nbsp;
                    <input id="add-uam" type="checkbox" name="add-uam" value="1" /><label for="add-uam">Add to "rating.thecommonwell.ca/auth/authenticate" group</label>
                    <br /><br />
                    <a id="csv_file" class="button" href="javascript:;">Select file</a>
                    <div id="filelist"></div>
                    <input id="submit" class="button" type="submit" value="Import" />
                    <div class="ajax-loader">
                        <img src="/wp-admin/images/spinner-2x.gif" alt="loader icon" class=""/> Importing...
                    </div>
                </form>
                <p style="color: red">Please make sure to have back up your database before proceeding!</p>
            </div>
        <?php }

        /**
         * Get all brokers
         */
        public function get_broker_list()
        {
            $brokerList = get_option('broker_list') ? unserialize(get_option('broker_list')) : [];

            if (!empty($brokerList)) {
                wp_send_json($brokerList);
            }
        }

        /**
         * Get specific broker info
         */
        public function get_broker_info()
        {
            // Get current list
            $brokerList = get_option('broker_list') ? unserialize(get_option('broker_list')) : [];
            $ID   = $_GET['id'];

            if (!empty($brokerList)) {
                foreach ($brokerList as $brokerObj) {
                    if ($brokerObj['id'] == $ID) {
                        wp_send_json($brokerObj);
                    }
                }
            }
        }

        /**
         * Delete broker info
         */
        public function delete_broker_info()
        {
            // Get current list
            $brokerList = get_option('broker_list') ? unserialize(get_option('broker_list')) : [];
            $ID         = $_POST['id'];

            if (!empty($brokerList)) {
                foreach ($brokerList as $index => $brokerObj) {
                    if ($brokerObj['id'] == $ID) {
                        unset($brokerList[$index]);
                    }
                }

                $result = update_option('broker_list', serialize($brokerList));

                if ($result) {
                    echo json_encode(
                        [
                            'message' => 'Broker deleted.'
                        ]
                    );
                    wp_die();
                } else {
                    echo false;
                    wp_die();
                }
            }
        }

        /**
         * Update broker info
         */
        public function update_broker_info()
        {
            // Get current list
            $brokerList = get_option('broker_list') ? unserialize(get_option('broker_list')) : [];
            $ID         = $_POST['id'];
            $brokerID   = $_POST['broker_id'];
            $brokerage  = $_POST['brokerage'];

            if (!empty($brokerList)) {
                // Check if the broker_id exists.
                // Exit.
//                foreach ($brokerList as $brokerObj) {
//                    if ($brokerObj['broker_id'] == $brokerID) {
//                        echo json_encode(
//                            [
//                                'message' => 'Broker ID already exists.'
//                            ]
//                        );
//                        wp_die();
//                    }
//                }

                foreach ($brokerList as $index => $broker) {
                    if ($broker['id'] == $ID) {
                        $brokerList[$index]['broker_id'] = $brokerID;
                        $brokerList[$index]['brokerage'] = $brokerage;
                    }
                }

                $result = update_option('broker_list', serialize($brokerList));

                if ($result) {
                    echo json_encode(
                        [
                            'message' => 'Broker updated.'
                        ]
                    );
                    wp_die();
                } else {
                    echo false;
                    wp_die();
                }
            }
        }

        /**
         * Create a new broker
         */
        public function create_broker()
        {
            // Get current list
            $brokerList = get_option('broker_list') ? unserialize(get_option('broker_list')) : [];
            $brokerID   = $_POST['broker_id'];
            $brokerage  = $_POST['brokerage'];

            foreach ($brokerList as $brokerObj) {
                // Check if broker id already exists

                if ($brokerObj['broker_id'] == $brokerID) {
                    echo json_encode(
                        [
                            'message' => 'Broker ID already exists.'
                        ]
                    );

                    wp_die();
                }

            }

            array_push(
                $brokerList,
                [
                    'id'        => count($brokerList),
                    'broker_id' => $brokerID,
                    'brokerage' => $brokerage
                ]
            );

            $result = update_option('broker_list', serialize($brokerList));

            if ($result) {
                echo json_encode(
                    [
                        'message' => 'Broker created.'
                    ]
                );
                wp_die();
            } else {
                echo false;
                wp_die();
            }
        }

        /**
         * Broker settings page
         */
        public function display_broker_settings_page()
        { ?>
            <div class="container" ng-app="myApp">
                <ng-include src="'/wp-content/plugins/broker-settings/read_brokers.template.html'"></ng-include>
            </div>
            <?php
        }

        /**
         * Get a progress status
         * Deprecated
         */
        public function get_broker_import_status()
        {
            if (false !== get_option('parsed_rows')) {

                $parsed_rows = floatval(get_option('parsed_rows'));
                $total_rows  = floatval(get_option('total_rows'));

                $progress = $parsed_rows / $total_rows;

                if ($progress == 0) {
                    echo 100;
                    wp_die();
                }
                echo $progress * 100;
                wp_die();

            } else {
                wp_die();
            }
        }


        /**
         * @param $str
         *
         * @return bool|mixed|string
         */
        public function isUTF8($str)
        {
            //return wp_check_invalid_utf8($str);
            return mb_detect_encoding($str, 'UTF-8', true); // 'UTF-8'
        }

        /**
         * @param $csvFile
         *
         * @return array
         */
        public function convertFileToArray($csvFile)
        {
            $arr_rows     = [];
            $check_string = '';
            if (($handle = fopen($csvFile, "r")) !== false) {
                while (($data = fgetcsv($handle)) !== false) {
                    // If it's empty row, skip it
                    if (implode('', $data) == '') {
                        continue;
                    }

                    $check_string .= implode('","', $data);
                    array_push($arr_rows, $data);
                }
                fclose($handle);
            }

            return [
                $arr_rows,
                $check_string
            ];
        }


    }
}