<?php
declare(strict_types=1);

namespace Operanse\Agent\Telemetry;

defined( 'ABSPATH' ) || exit;

use Operanse\Agent\Telemetry\Spool\SpoolInterface;

/**
 * The only way events enter the system. Cheap: builds an array, JSON-encodes, appends one line.
 * Never throws, never touches the network.
 */
final class Recorder {
	/**
	 * @param (\Closure(): bool)|null $enabled Whether events may be written at all: false before pairing (ADR-072
	 *                                       §8 Q1). Read on every record, from autoloaded settings already in
	 *                                       memory. Null = always (tests, WP-CLI tools).
	 */
	public function __construct( private SpoolInterface $spool, private ?\Closure $enabled = null ) {}

	/**
	 * @param array<string,mixed> $attributes
	 * @param array<string,float|int> $metrics
	 */
	public function record( string $type, string $source, string $priority, array $attributes = array(), array $metrics = array(), ?string $correlation_id = null ): void {
		try {
			if ( $this->enabled !== null && ! ( $this->enabled )() ) {
				return;
			}
			$event = Event::make( $type, $source, $priority, $attributes, $metrics, $correlation_id );
			$line  = wp_json_encode( $event );
			if ( is_string( $line ) ) {
				$this->spool->append( $line, $priority );
			}
		} catch ( \Throwable ) {
			// Fail open: telemetry loss is acceptable, site impact is not.
		}
	}

	public function spool(): SpoolInterface {
		return $this->spool;
	}
}