<?php
/**
 * Event_Humanizer — turn a raw `prweb_events` row into a friendly title +
 * detail + tone for the activity feed and the dashboard. Stateless static
 * helpers used by templates without instantiating Events_Store.
 */

declare(strict_types=1);

defined( 'ABSPATH' ) || exit;

class Prweb_Event_Humanizer {

    public static function humanize_event( string $kind, $payload, ?string $occurred_at = null ): array {
        $p = is_array( $payload ) ? $payload : [];

        $short = function ( $v, int $head = 6, int $tail = 4 ): string {
            $s = (string) $v;
            if ( strlen( $s ) <= $head + $tail + 1 ) {
                return $s;
            }
            return substr( $s, 0, $head ) . '…' . substr( $s, -$tail );
        };
        $slug = function ( $url ) {
            $url  = (string) $url;
            $path = wp_parse_url( $url, PHP_URL_PATH );
            if ( ! is_string( $path ) || $path === '' ) {
                return $url;
            }
            $parts = array_values( array_filter( explode( '/', trim( $path, '/' ) ), 'strlen' ) );
            return $parts ? end( $parts ) : $path;
        };

        $tone_for = function ( string $k ): string {
            if ( str_ends_with( $k, '.failed' ) || str_ends_with( $k, '_failed' ) || str_ends_with( $k, '.denied' ) ) {
                return 'error';
            }
            if ( str_ends_with( $k, '.start' ) || str_ends_with( $k, '_started' ) || str_ends_with( $k, '.requested' ) ) {
                return 'warn';
            }
            return 'ok';
        };

        $title  = $kind;
        $detail = '';

        switch ( $kind ) {
            case 'asset.requested':
                // Asset request — `bot_id` only present on validator-side
                // emits; plugin-side asset.requested is the publisher
                // registering an asset (no bot context). Render both.
                if ( isset( $p['bot_id'] ) ) {
                    $title  = sprintf( '%s requested %s', $p['bot_id'], $slug( $p['resource'] ?? '' ) );
                    $detail = isset( $p['txid'] ) ? 'txid ' . $short( $p['txid'] ) : '';
                } else {
                    $title  = sprintf( 'Registering %s…', isset( $p['resource'] ) ? $slug( $p['resource'] ) : ( 'post #' . (int) ( $p['post_id'] ?? 0 ) ) );
                    $detail = '';
                }
                break;
            case 'asset.delivered':
                // Validator-side delivery (bot_id present) vs plugin-side
                // registration success (post_id present, no bot).
                if ( isset( $p['bot_id'] ) ) {
                    $title  = sprintf( 'Delivered %s to %s', $slug( $p['resource'] ?? ( $p['asset_path'] ?? '' ) ), $p['bot_id'] );
                    $bits   = [];
                    if ( isset( $p['origin_status'] ) ) { $bits[] = 'status ' . (int) $p['origin_status']; }
                    if ( isset( $p['txid'] ) )           { $bits[] = 'txid ' . $short( $p['txid'] ); }
                    $detail = implode( ' · ', $bits );
                } else {
                    $title  = sprintf( 'Registered post #%d', (int) ( $p['post_id'] ?? 0 ) );
                    $bits   = [];
                    if ( isset( $p['dab_id'] ) )   { $bits[] = 'dab #' . (int) $p['dab_id']; }
                    if ( isset( $p['offer_id'] ) ) { $bits[] = 'offer #' . (int) $p['offer_id']; }
                    $detail = implode( ' · ', $bits );
                }
                break;
            case 'asset.denied':
                if ( isset( $p['bot_id'] ) ) {
                    $title  = sprintf( 'Denied %s to %s', $slug( $p['resource'] ?? '' ), $p['bot_id'] );
                } else {
                    $title  = sprintf( 'Registration failed for post #%d', (int) ( $p['post_id'] ?? 0 ) );
                }
                $detail = (string) ( $p['reason'] ?? $p['error'] ?? '' );
                break;
            // Canonical token.* family (post-2026-04-27 migration). Legacy
            // license.* arms below are kept for in-flight pre-migration rows
            // and the migration's slow rollout window — defense in depth.
            case 'token.requested':
                $intent = (string) ( $p['intent'] ?? 'access' );
                $title  = sprintf( '%s asked to %s %s', $p['bot_id'] ?? 'a bot', $intent, $slug( $p['resource'] ?? '' ) );
                break;
            case 'token.minted':
                $title  = sprintf( 'Licensed %s to %s', $slug( $p['resource'] ?? '' ), $p['bot_id'] ?? 'a bot' );
                $bits   = [];
                if ( isset( $p['dab_id'] ) )    { $bits[] = 'dab #' . (int) $p['dab_id']; }
                if ( isset( $p['seller_id'] ) ) { $bits[] = 'seller ' . $short( $p['seller_id'] ); }
                if ( isset( $p['txid'] ) )      { $bits[] = 'txid ' . $short( $p['txid'] ); }
                $detail = implode( ' · ', $bits );
                break;
            case 'token.denied':
                $title  = sprintf( 'Denied license to %s', $p['bot_id'] ?? 'a bot' );
                $bits   = [];
                if ( ! empty( $p['resource'] ) ) { $bits[] = 'for ' . $slug( $p['resource'] ); }
                if ( ! empty( $p['reason'] ) )   { $bits[] = (string) $p['reason']; }
                $detail = implode( ' · ', $bits );
                break;
            // Canonical oauth.* account family. Legacy pds.account.* arms
            // remain below for transitional row-rendering tolerance.
            case 'oauth.account_created':
                $reason = (string) ( $p['reason'] ?? '' );
                if ( str_contains( $reason, 'failed' ) ) {
                    $title  = 'Account creation failed';
                    $detail = $reason;
                } elseif ( $reason === 'started' || str_contains( $reason, 'site_license_bootstrap_start' ) ) {
                    $title  = 'Creating publisher account…';
                    $detail = '';
                } else {
                    $title  = 'Created publisher account';
                    $detail = isset( $p['user_id'] ) ? $short( $p['user_id'] ) : '';
                }
                break;
            case 'oauth.account_cleared':
                $reason = (string) ( $p['reason'] ?? '' );
                $title  = $reason === 'started' ? 'Clearing publisher account…' : 'Cleared publisher account';
                $detail = isset( $p['user_id'] ) ? $short( $p['user_id'] ) : '';
                break;
            case 'oauth.start_ok':
                $title = 'OAuth flow started';
                $detail = isset( $p['subject_user'] ) ? (string) $p['subject_user'] : '';
                break;
            case 'oauth.start_failed':
                $title  = 'OAuth start failed';
                $detail = (string) ( $p['reason'] ?? '' );
                break;
            case 'oauth.revoke_error':
                $title  = 'OAuth revoke error';
                $detail = (string) ( $p['reason'] ?? '' );
                break;
            case 'oauth.disconnect_ok':
                $title = 'Disconnected';
                $detail = '';
                break;
            case 'oauth.disconnect_partial':
                $title  = 'Disconnected (partial)';
                $bits   = [];
                if ( isset( $p['refresh'] ) ) { $bits[] = 'refresh=' . ( $p['refresh'] ? 'ok' : 'failed' ); }
                if ( isset( $p['access'] ) )  { $bits[] = 'access='  . ( $p['access']  ? 'ok' : 'failed' ); }
                $detail = implode( ' · ', $bits );
                break;
            case 'oauth.token_refreshed':
                $outcome = (string) ( $p['refresh_outcome'] ?? 'ok' );
                $title   = 'Token refresh: ' . $outcome;
                $detail  = (string) ( $p['reason'] ?? '' );
                break;
            case 'oauth.consent_granted':
                if ( isset( $p['stage'] ) ) {
                    $title  = 'Onboarding: ' . (string) $p['stage'];
                    $detail = '';
                } else {
                    $title  = 'Consent granted';
                    $detail = isset( $p['client_id'] ) ? (string) $p['client_id'] : '';
                }
                break;
            case 'oauth.reader_register_started':
                $title  = 'Registering reader…';
                $detail = ! empty( $p['email_provided'] ) ? 'email provided' : 'no email';
                break;
            case 'oauth.reader_registered':
                $title  = 'Registered reader';
                $bits   = [];
                if ( ! empty( $p['pds_user_id'] ) ) { $bits[] = $short( $p['pds_user_id'] ); }
                if ( ! empty( $p['license_id'] ) )  { $bits[] = 'license ' . (string) $p['license_id']; }
                $detail = implode( ' · ', $bits );
                break;
            case 'oauth.reader_register_failed':
                $title  = 'Reader registration failed';
                $detail = (string) ( $p['reason'] ?? $p['error'] ?? '' );
                break;
            // Canonical offer.* family for RSL document publish + offer
            // archive lifecycle.
            case 'offer.published':
                $offer_id = (string) ( $p['offer_id'] ?? '' );
                if ( $offer_id === 'rsl-document' ) {
                    $mode  = (string) ( $p['mode'] ?? '' );
                    $title = $mode !== '' ? 'Publishing rsl.xml…' : 'Published rsl.xml';
                    $detail = (string) ( $p['path'] ?? ( $mode !== '' ? 'mode ' . $mode : '' ) );
                } else {
                    $title  = 'Offer published';
                    $detail = $offer_id;
                }
                break;
            case 'offer.publish_failed':
                $offer_id = (string) ( $p['offer_id'] ?? '' );
                if ( $offer_id === 'rsl-document' ) {
                    $title = 'rsl.xml publish failed';
                } else {
                    $title = 'SELL offer failed for post #' . (int) ( $p['post_id'] ?? 0 );
                }
                $detail = (string) ( $p['reason'] ?? $p['error'] ?? '' );
                break;
            case 'offer.archived':
                $title  = sprintf( 'Archived offer for post #%d', (int) ( $p['post_id'] ?? 0 ) );
                $detail = (string) ( $p['offer_id'] ?? '' );
                break;
            case 'offer.priced':
                $title = 'Offer price updated';
                $bits  = [];
                if ( isset( $p['price_leos'] ) ) {
                    $bits[] = 'price ' . (int) $p['price_leos'] . ' Żetons';
                }
                if ( ! empty( $p['source'] ) ) {
                    $bits[] = 'source ' . (string) $p['source'];
                }
                if ( ! empty( $p['scope'] ) ) {
                    $bits[] = $slug( $p['scope'] );
                }
                $detail = implode( ' · ', $bits );
                break;
            case 'offer.terms_set':
                $title  = 'Offer terms updated';
                $fields = is_array( $p['changed_fields'] ?? null ) ? $p['changed_fields'] : [];
                $bits   = [];
                if ( ! empty( $fields ) ) {
                    $bits[] = implode( ', ', array_map( 'strval', $fields ) );
                }
                if ( ! empty( $p['source'] ) ) {
                    $bits[] = 'source ' . (string) $p['source'];
                }
                $detail = implode( ' · ', $bits );
                break;
            case 'buyer.status_changed':
                $title  = sprintf( 'Buyer marked %s', (string) ( $p['status'] ?? 'updated' ) );
                $detail = (string) ( $p['bot_id'] ?? '' );
                break;
            case 'bundle.created':
                $title  = 'Bundle created';
                $detail = (string) ( $p['scope'] ?? ( $p['bundle_id'] ?? '' ) );
                break;
            case 'bundle.updated':
                $title  = 'Bundle updated';
                $detail = (string) ( $p['scope'] ?? ( $p['bundle_id'] ?? '' ) );
                break;
            case 'bundle.deleted':
                $title  = 'Bundle deleted';
                $detail = (string) ( $p['scope'] ?? ( $p['bundle_id'] ?? '' ) );
                break;
            // Canonical payout.* family.
            case 'payout.policy_updated':
                $title  = 'Payout policy updated';
                $detail = (string) ( $p['schedule'] ?? '' );
                break;
            case 'payout.connect_started':
                $title  = 'Stripe onboarding started';
                $detail = (string) ( $p['stripe_account_id'] ?? '' );
                break;
            case 'payout.staged':
                $title  = 'Payout staged';
                $detail = isset( $p['amount_cents'] ) ? '$' . number_format( (int) $p['amount_cents'] / 100, 2 ) : '';
                break;
            case 'payout.settled':
                $title  = 'Payout settled';
                $detail = isset( $p['amount_cents'] ) ? '$' . number_format( abs( (int) $p['amount_cents'] ) / 100, 2 ) : '';
                break;
            case 'payout.reversed':
                $title  = 'Payout reversed';
                $detail = (string) ( $p['payout_id'] ?? '' );
                break;
            case 'wizard.step_started':
                $title  = 'Onboarding started: ' . str_replace( '_', ' ', (string) ( $p['step_id'] ?? '' ) );
                $detail = '';
                break;
            case 'wizard.step_completed':
                $title  = 'Onboarding completed: ' . str_replace( '_', ' ', (string) ( $p['step_id'] ?? '' ) );
                $detail = isset( $p['duration_ms'] ) ? round( (int) $p['duration_ms'] / 1000, 1 ) . 's' : '';
                break;
            case 'wizard.step_failed':
                $title  = 'Onboarding failed: ' . str_replace( '_', ' ', (string) ( $p['step_id'] ?? '' ) );
                $detail = (string) ( $p['reason'] ?? '' );
                break;
            case 'wizard.step_skipped':
                $title  = 'Onboarding skipped: ' . str_replace( '_', ' ', (string) ( $p['step_id'] ?? '' ) );
                $detail = (string) ( $p['reason'] ?? '' );
                break;
            case 'wizard.resumed':
                $title  = 'Onboarding resumed';
                $detail = str_replace( '_', ' ', (string) ( $p['step_id'] ?? '' ) );
                break;
            // ---- Legacy arms below — kept for backfilled / pre-migration
            // rows, per distributed-data-reviewer-2026-04-27-20 Part B § "Activity tab
            // field-name mapping". Defense in depth: the migration's Rule 4
            // rewrites in place, but the humanizer being tolerant means a
            // slow rollout doesn't break the tab mid-flight.
            case 'license.requested':
                $intent = (string) ( $p['intent'] ?? 'access' );
                $title  = sprintf( '%s asked to %s %s', $p['bot_id'] ?? 'a bot', $intent, $slug( $p['resource'] ?? '' ) );
                break;
            case 'license.minted':
                $title  = sprintf( 'Licensed %s to %s', $slug( $p['resource'] ?? '' ), $p['bot_id'] ?? 'a bot' );
                $bits   = [];
                if ( isset( $p['dab_id'] ) )    { $bits[] = 'dab #' . (int) $p['dab_id']; }
                if ( isset( $p['seller_id'] ) ) { $bits[] = 'seller ' . $short( $p['seller_id'] ); }
                if ( isset( $p['txid'] ) )      { $bits[] = 'txid ' . $short( $p['txid'] ); }
                $detail = implode( ' · ', $bits );
                break;
            case 'license.denied':
                $title  = sprintf( 'Denied license to %s', $p['bot_id'] ?? 'a bot' );
                $bits   = [];
                if ( ! empty( $p['resource'] ) ) { $bits[] = 'for ' . $slug( $p['resource'] ); }
                if ( ! empty( $p['reason'] ) )   { $bits[] = (string) $p['reason']; }
                $detail = implode( ' · ', $bits );
                break;
            case 'asset.register.start':
                $title  = sprintf( 'Registering %s…', isset( $p['url'] ) ? $slug( $p['url'] ) : 'post #' . (int) ( $p['post_id'] ?? 0 ) );
                break;
            case 'asset.register.ok':
                $title  = sprintf( 'Registered post #%d', (int) ( $p['post_id'] ?? 0 ) );
                $bits   = [];
                if ( isset( $p['dab_id'] ) )   { $bits[] = 'dab #' . (int) $p['dab_id']; }
                if ( isset( $p['offer_id'] ) ) { $bits[] = 'offer #' . (int) $p['offer_id']; }
                $detail = implode( ' · ', $bits );
                break;
            case 'asset.register.failed':
                $title  = sprintf( 'Registration failed for post #%d', (int) ( $p['post_id'] ?? 0 ) );
                $detail = (string) ( $p['error'] ?? '' );
                break;
            case 'offer.create.failed':
                $title  = sprintf( 'SELL offer failed for post #%d', (int) ( $p['post_id'] ?? 0 ) );
                $detail = (string) ( $p['error'] ?? '' );
                break;
            case 'offer.revoke.start':
                $title  = sprintf( 'Revoking offer for post #%d…', (int) ( $p['post_id'] ?? 0 ) );
                break;
            case 'offer.revoke.ok':
                $title  = sprintf( 'Revoked offer for post #%d', (int) ( $p['post_id'] ?? 0 ) );
                break;
            case 'offer.revoke.failed':
                $title  = sprintf( 'Couldn\'t revoke offer for post #%d', (int) ( $p['post_id'] ?? 0 ) );
                $detail = (string) ( $p['error'] ?? '' );
                break;
            case 'pds.account.create.start':
                $title = 'Creating publisher account…';
                break;
            case 'pds.account.create.ok':
                $title  = 'Created publisher account';
                $detail = isset( $p['user_id'] ) ? $short( $p['user_id'] ) : '';
                break;
            case 'pds.account.create.failed':
                $title  = 'Account creation failed';
                $detail = (string) ( $p['error'] ?? '' );
                break;
            case 'pds.account.clear.start':
                $title  = 'Clearing publisher account…';
                $detail = isset( $p['user_id'] ) ? $short( $p['user_id'] ) : '';
                break;
            case 'pds.account.clear.ok':
                $title  = 'Cleared publisher account';
                $detail = isset( $p['user_id'] ) ? $short( $p['user_id'] ) : '';
                break;
            case 'rsl.publish.start':
                $title  = 'Publishing rsl.xml…';
                $detail = isset( $p['mode'] ) ? 'mode ' . (string) $p['mode'] : '';
                break;
            case 'rsl.publish.ok':
                $title  = 'Published rsl.xml';
                $detail = (string) ( $p['path'] ?? '' );
                break;
            case 'rsl.publish.failed':
                $title  = 'rsl.xml publish failed';
                $detail = (string) ( $p['reason'] ?? $p['error'] ?? '' );
                break;
            case 'reader.register.start':
                $title  = 'Registering reader…';
                $detail = ! empty( $p['email_provided'] ) ? 'email provided' : 'no email';
                break;
            case 'reader.register.ok':
                $title  = 'Registered reader';
                $bits   = [];
                if ( ! empty( $p['pds_user_id'] ) ) { $bits[] = $short( $p['pds_user_id'] ); }
                if ( ! empty( $p['license_id'] ) )  { $bits[] = 'license ' . (string) $p['license_id']; }
                $detail = implode( ' · ', $bits );
                break;
            case 'reader.register.failed':
                $title  = 'Reader registration failed';
                $detail = (string) ( $p['error'] ?? '' );
                break;
            case 'site_license.bootstrap.start':
                $title = 'Bootstrapping site license…';
                break;
            case 'site_license.bootstrap.ok':
                $title  = 'Bootstrapped site license';
                $detail = isset( $p['offer_id'] ) ? 'offer #' . (int) $p['offer_id'] : '';
                break;
            case 'site_license.bootstrap.failed':
                $title  = 'Site license bootstrap failed';
                $detail = (string) ( $p['error'] ?? '' );
                break;
            default:
                $title  = $kind;
                $detail = $p ? wp_json_encode( $p ) : '';
        }

        return [
            'title'  => $title,
            'detail' => $detail,
            'tone'   => $tone_for( $kind ),
            'kind'   => $kind,
        ];
    }

    public static function relative_time( string $occurred_at ): string {
        $t = strtotime( $occurred_at . ' UTC' );
        if ( ! $t ) {
            return $occurred_at;
        }
        $diff = time() - $t;
        if ( $diff < 0 )      { return 'just now'; }
        if ( $diff < 45 )     { return $diff . 's ago'; }
        if ( $diff < 3600 )   { return (int) round( $diff / 60 ) . 'm ago'; }
        if ( $diff < 86400 )  { return (int) round( $diff / 3600 ) . 'h ago'; }
        if ( $diff < 604800 ) { return (int) round( $diff / 86400 ) . 'd ago'; }
        return gmdate( 'M j', $t );
    }
}