<?php

namespace TruePlayer;

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

/**
 * Internal event bus — the single seam every server-side milestone flows
 * through. Watch-verification and quiz-grading call Events::emit(); the
 * add-ons (webhooks, analytics, CRM bridges) subscribe via the
 * `trueplayer/event/{name}` action.
 *
 * Known events: view.started, progress.milestone, view.completed,
 * checkpoint.passed, checkpoint.failed, quiz.passed, quiz.failed,
 * video.locked, video.unlocked.
 */
class Events {

	const KNOWN = [
		'view.started',
		'progress.milestone',
		'view.completed',
		'checkpoint.passed',
		'checkpoint.failed',
		'quiz.passed',
		'quiz.failed',
		'video.locked',
		'video.unlocked',
		'subscriber.added',
	];

	public static function init() {
		// Nothing to hook at boot — this is a passive dispatcher. Kept as an
		// init target so the bootstrap wiring stays uniform with other modules.
	}

	/**
	 * Fire an event. $payload is the normalized data structure documented in
	 * the webhook payload spec (event, video_id, subject, etc.).
	 *
	 * @param string $name    One of self::KNOWN.
	 * @param array  $payload Event payload.
	 */
	/**
	 * Build the canonical wire payload for an event.
	 *
	 * Split out of emit() so anything that sends a TruePlayer-shaped body
	 * WITHOUT firing the bus — notably the "Send test" delivery — produces the
	 * exact same structure. A test that doesn't match real traffic is worse
	 * than no test: it passes against a receiver that would reject the real
	 * thing, or fails against one that would accept it.
	 *
	 * @param string $name    Event name.
	 * @param array  $payload Event-specific data.
	 * @return array
	 */
	public static function shape( $name, array $payload = [] ) {
		$payload = array_merge(
			[
				'event'     => $name,
				'timestamp' => Helper::now_iso(),
				'site'      => wp_parse_url( home_url(), PHP_URL_HOST ),
			],
			$payload
		);

		/**
		 * Mirror the viewer's contact fields to the top level.
		 *
		 * `subject` stays exactly as it was (nothing here is removed), but most
		 * receivers — CRMs, Zapier, Make — map a flat `email` and reject a
		 * payload that only nests it. Promoting them here covers every emit
		 * site at once instead of each caller remembering to do it.
		 */
		foreach ( [ 'email', 'name' ] as $field ) {
			if ( ! isset( $payload[ $field ] ) && ! empty( $payload['subject'][ $field ] ) ) {
				$payload[ $field ] = $payload['subject'][ $field ];
			}
		}

		return $payload;
	}

	public static function emit( $name, array $payload = [] ) {
		$payload = self::shape( $name, $payload );

		/**
		 * Generic hook (all events) + specific hook (per event name).
		 */
		do_action( 'trueplayer/event', $name, $payload );
		do_action( "trueplayer/event/{$name}", $payload );
	}
}