main

<?php

​

if (!defined('ABSPATH')) {

    exit;

}

​

if (!class_exists('CWG_Instock_Upgrade')) {

​

    class CWG_Instock_Upgrade {

​

        public $upgrade_version = '1.0';

​

        public function __construct() {

            add_action('upgrader_process_complete', array($this, 'trigger_upgrade_instock'), 10, 2);

            add_action('cwg_instock_upgrade', array($this, 'register_schedule'));

            add_action('cwg_sync_instock_data', array($this, 'perform_upgrade'), 99, 1);

            register_activation_hook(CWGINSTOCK_FILE, array($this, 'register_schedule'));

        }

​

        public function trigger_upgrade_instock($upgrader_object, $options) {

            $our_plugin = CWGSTOCKPLUGINBASENAME;

            if ($options['action'] == 'update' && $options['type'] == 'plugin' && isset($options['plugins'])) {

                foreach ($options['plugins'] as $plugin) {

                    if ($plugin == $our_plugin) {

                        //trigger update functionality here

                        do_action('cwg_instock_upgrade');

                    }

                }

            }

        }

​

        public function register_schedule() {

            //upon update to the plugin perform some actions

            $api = new CWG_Instock_API();

            $get_meta_values = $api->get_meta_values('cwginstock_product_id', 'cwginstocknotifier');

            if ($get_meta_values) {

                $chunk_data = array_chunk($get_meta_values, 5);

                foreach ($chunk_data as $each_array) {

                    as_schedule_single_action(time(), 'cwg_sync_instock_data', array('pid' => $each_array));

                }

            }

        }

​

        public function perform_upgrade($ids) {

            global $wpdb;

            if (is_array($ids) && !empty($ids)) {

                $this->delete_duplicate_metas();

                $obj = new CWG_Instock_API();

                foreach ($ids as $each_id) {

                    $get_count = $obj->get_subscribers_count($each_id, 'cwg_subscribed');

                    update_post_meta($each_id, 'cwg_total_subscribers', $get_count);

                }

            }

        }

​

        public function delete_duplicate_metas() {

            global $wpdb;

            $get_option = get_option('cwg_data_upgraded', 0);

            if ($get_option == 0 || $get_option == '0') {

                //do upgrade process here

                $key = 'cwg_total_subscribers';

                $results = $wpdb->get_results($wpdb->prepare("SELECT count(pm.post_id) as cpid FROM {$wpdb->postmeta} pm WHERE pm.meta_key = %s", $key));

                if ($results) {