<?php

/**
 * Registers referred visitors as leads when they create a customer account.
 */

namespace Afileasy\WooCommerce;

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

class Leads
{
    private const SEND_HOOK = 'afileasy_send_lead';
    public const USER_META_KEY = 'afileasy_event_id';
    private const COOKIE = 'afileasy_ref';

    public function register(): void
    {
        add_action('woocommerce_created_customer', [$this, 'onCustomerCreated'], 10, 1);

        add_action(self::SEND_HOOK, [$this, 'send'], 10, 1);
    }

    /**
     * Stamp the referral on the new account and queue its delivery.
     *
     * @param  int  $customer_id
     */
    public function onCustomerCreated($customer_id): void
    {
        $customer_id = (int) $customer_id;

        if (Connection::get() === null) {
            return;
        }

        /**
         * Filter whether new accounts are registered as leads. Returning false
         * disables lead capture only — order attribution and order events are
         * unaffected.
         *
         * @param  bool  $capture
         * @param  int  $customer_id
         */
        if (! apply_filters('afileasy_capture_leads', true, $customer_id)) {
            return;
        }
        
        if (get_user_meta($customer_id, self::USER_META_KEY, true)) {
            return;
        }

        $ref = isset($_COOKIE[self::COOKIE]) ? sanitize_text_field(wp_unslash($_COOKIE[self::COOKIE])) : '';

        if ($ref === '') {
            return;
        }

        update_user_meta($customer_id, self::USER_META_KEY, $ref);

        if (function_exists('as_enqueue_async_action')) {
            as_enqueue_async_action(self::SEND_HOOK, [$customer_id], 'afileasy');

            return;
        }

        $this->send($customer_id);
    }

    /**
     * Build the payload and POST it to Afileasy.
     *
     * @param  int  $customer_id
     */
    public function send($customer_id): void
    {
        $connection = Connection::get();
        if ($connection === null) {
            return;
        }

        $user = get_userdata((int) $customer_id);
        if (! $user || ! is_email($user->user_email)) {
            return;
        }

        $ref = get_user_meta($user->ID, self::USER_META_KEY, true);
        if (! is_string($ref) || $ref === '') {
            return;
        }

        $payload = [
            'public_key' => $connection['o'],
            'code' => $ref,
            'email' => $user->user_email,
            'name' => $this->name($user),
        ];

        wp_remote_post(Connection::leadUrl($connection), [
            'headers' => [
                'Content-Type' => 'application/json',
                'Accept' => 'application/json',
            ],
            'body' => wp_json_encode($payload),
            'timeout' => 20,
            'blocking' => true,
        ]);
    }

    private function name(\WP_User $user): ?string
    {
        $full = trim($user->first_name.' '.$user->last_name);

        if ($full !== '') {
            return $full;
        }

        return $user->display_name !== '' ? $user->display_name : null;
    }
}