<?php

declare(strict_types=1);

namespace Abovault\Model;

defined('ABSPATH') || exit;

// Data-access on the plugin's own custom tables (internal identifiers only; values are
// prepared). Direct queries + no object cache are inherent to live subscription state.
// phpcs:disable WordPress.DB.DirectDatabaseQuery.DirectQuery, WordPress.DB.DirectDatabaseQuery.NoCaching, WordPress.DB.PreparedSQL.NotPrepared, WordPress.DB.PreparedSQL.InterpolatedNotPrepared, WordPress.DB.DirectDatabaseQuery.SchemaChange, PluginCheck.Security.DirectDB.UnescapedDBParameter, WordPress.NamingConventions.PrefixAllGlobals.NonPrefixedVariableFound

/**
 * Subscription entity + lightweight repository.
 *
 * STANDALONE data model (own table) — a real WCS replacement, not an add-on.
 * Status machine ported from famos.fans processSubscriptionRenewals.ts:
 *   trialing → active → past_due → canceled | expired
 *
 * Data lives in the site's own WP database (wp_abovault_subscriptions) — never an
 * external cloud. That is the DSGVO/sovereignty wedge, enforced at the architecture layer.
 */
final class Subscription
{
    // --- Status machine (mirrors the famos.fans lifecycle) ---
    public const STATUS_TRIALING = 'trialing';
    public const STATUS_ACTIVE   = 'active';
    public const STATUS_PAST_DUE = 'past_due';   // payment failed, in retry/grace window
    public const STATUS_CANCELED = 'canceled';   // ended (user or dunning-exhausted)
    public const STATUS_EXPIRED  = 'expired';    // trial lapsed without conversion

    /** Grace window before a past_due subscription is hard-canceled (days). Configurable. */
    public const DEFAULT_GRACE_DAYS = 7;

    public static function table(): string
    {
        global $wpdb;
        return $wpdb->prefix . 'abovault_subscriptions';
    }

    /**
     * DDL for activation. HPOS-friendly (own table, integer FKs to WC customer/order ids).
     */
    public static function schema(): string
    {
        global $wpdb;
        $table   = self::table();
        $collate = $wpdb->get_charset_collate();

        return "CREATE TABLE {$table} (
            id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
            customer_id BIGINT UNSIGNED NOT NULL,
            order_id BIGINT UNSIGNED NOT NULL DEFAULT 0,
            product_id BIGINT UNSIGNED NOT NULL,
            status VARCHAR(20) NOT NULL DEFAULT 'active',
            gateway VARCHAR(50) NOT NULL DEFAULT '',
            gateway_ref VARCHAR(191) NOT NULL DEFAULT '',
            amount DECIMAL(12,2) NOT NULL DEFAULT 0,
            currency CHAR(3) NOT NULL DEFAULT 'EUR',
            interval_unit VARCHAR(10) NOT NULL DEFAULT 'month',
            interval_count SMALLINT UNSIGNED NOT NULL DEFAULT 1,
            trial_end DATETIME NULL,
            current_period_start DATETIME NULL,
            current_period_end DATETIME NULL,
            cancel_at_period_end TINYINT(1) NOT NULL DEFAULT 0,
            retry_count SMALLINT UNSIGNED NOT NULL DEFAULT 0,
            pending_charge_ref VARCHAR(191) NOT NULL DEFAULT '',
            last_payment_failed_at DATETIME NULL,
            canceled_at DATETIME NULL,
            created_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
            updated_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
            PRIMARY KEY (id),
            KEY idx_status (status),
            KEY idx_customer (customer_id),
            KEY idx_order (order_id),
            KEY idx_period_end (current_period_end),
            KEY idx_gateway_ref (gateway_ref)
        ) {$collate};";
    }

    /**
     * Transition a subscription's status and stamp the relevant timestamp.
     * Central choke-point so retention triggers can hook every transition.
     *
     * @return bool True if a row was updated.
     */
    public static function transition(int $id, string $to, array $extra = []): bool
    {
        global $wpdb;
        $data = array_merge(['status' => $to], $extra);
        if ($to === self::STATUS_CANCELED && !isset($data['canceled_at'])) {
            $data['canceled_at'] = current_time('mysql', true);
        }
        $updated = $wpdb->update(self::table(), $data, ['id' => $id]);

        /**
         * Fires after every status transition. The retention engine listens here.
         *
         * @param int    $id
         * @param string $to   New status.
         * @param array  $extra
         */
        do_action('abovault_subscription_transitioned', $id, $to, $extra);

        return (bool) $updated;
    }
}