<?php
/**
 * @package AdvocateLoop\Core
 */

namespace AdvocateLoop\Core;

if (!defined('ABSPATH')) {
    exit;
}

class Presence {

    /** Daily heartbeat cron hook. */
    const HOOK = 'advocate_loop_presence';
    const PATH = '/api/v1/integrations/presence';
    const CONNECTOR = 'wordpress';
    const CONNECTION_OPTIONS = ['advocate_loop_api_key', 'advocate_loop_brand_id', 'advocate_loop_ss'];

    /**
     * Register hooks. Called once from the main plugin file on every load.
     */
    public static function register() {
        add_action(self::HOOK, [__CLASS__, 'heartbeat']);
        add_action('init', [__CLASS__, 'ensure_scheduled']);


        add_action('add_option_advocate_loop_ss', [__CLASS__, 'connected_now']);
        add_action('update_option_advocate_loop_ss', [__CLASS__, 'connected_now']);
        foreach (['advocate_loop_api_key', 'advocate_loop_brand_id'] as $option) {
            add_action('add_option_' . $option, [__CLASS__, 'check_in_soon']);
            add_action('update_option_' . $option, [__CLASS__, 'check_in_soon']);
        }


        add_action('delete_option', [__CLASS__, 'before_delete'], 10, 1);
        add_filter('pre_update_option_advocate_loop_brand_id', [__CLASS__, 'before_brand_change'], 10, 2);
    }


    public static function ensure_scheduled() {
        if (!wp_next_scheduled(self::HOOK)) {
            wp_schedule_event(time() + 5 * MINUTE_IN_SECONDS, 'daily', self::HOOK);
        }
    }

    public static function check_in_soon() {
        if (!wp_next_scheduled(self::HOOK, ['once'])) {
            wp_schedule_single_event(time() + MINUTE_IN_SECONDS, self::HOOK, ['once']);
        }
    }

    /**
     * @param string $option Option about to be deleted.
     */
    public static function before_delete($option) {
        if (in_array($option, self::CONNECTION_OPTIONS, true)) {
            self::send_once('deactivated');
        }
    }

    /**
     * @param mixed $new New brand ID.
     * @param mixed $old Current brand ID.
     * @return mixed The new value, unchanged.
     */
    public static function before_brand_change($new, $old) {
        if (!empty($old) && (string) $new !== (string) $old) {
            self::send_once('deactivated');
        }
        return $new;
    }

    public static function connected_now() {
        self::send_once('activated');
    }

    public static function heartbeat() {
        self::send('heartbeat');
    }

    public static function on_activation() {
        self::ensure_scheduled();
        self::send('activated');
    }

    public static function on_deactivation() {
        wp_clear_scheduled_hook(self::HOOK);
        wp_clear_scheduled_hook(self::HOOK, ['once']);
        self::send('deactivated');
    }

    private static function send_once($event) {
        static $sent = [];
        if (!empty($sent[$event])) {
            return;
        }
        $sent[$event] = true;
        self::send($event);
    }

    /**
     * @param string $event activated | heartbeat | deactivated
     */
    public static function send($event) {
        if (!get_option('advocate_loop_api_key') || !get_option('advocate_loop_brand_id') || !get_option('advocate_loop_ss')) {
            return;
        }

        $host = wp_parse_url(home_url(), PHP_URL_HOST);

        Signing::post(self::PATH, [
            'connector' => self::CONNECTOR,
            'event'     => $event,
            'enabled'   => true,
            'site'      => is_string($host) ? $host : '',
            'version'   => defined('ADVOCATE_LOOP_VERSION') ? ADVOCATE_LOOP_VERSION : '',
        ], [
            'timeout' => 5,
        ]);
    }
}