<?php

/**
 * Event queue table schema and constants.
 *
 * @package AfroIT_Messaging_WorkflowAutomations
 */

namespace AfroIT\Messaging\WorkflowAutomations\Async;


if ( ! defined( 'ABSPATH' ) ) {
	exit;
}

/**
 * Class QueueTable
 *
 * Defines the event queue table structure and SQL.
 */
final class QueueTable {

	public const TABLE_NAME = 'afromewo_event_queue';

	public const STATUS_PENDING = 'pending';
	public const STATUS_PROCESSING = 'processing';
	public const STATUS_PROCESSED = 'processed';
	public const STATUS_FAILED = 'failed';

	/**
	 * Get full table name with prefix.
	 *
	 * @param \wpdb|null $wpdb WordPress database instance.
	 * @return string
	 */
	public static function getTableName( ?\wpdb $wpdb = null ): string {
		$wpdb = $wpdb ?? $GLOBALS['wpdb'];
		return $wpdb->prefix . self::TABLE_NAME;
	}

	/**
	 * Get CREATE TABLE SQL.
	 *
	 * @param string $prefix          Table prefix.
	 * @param string $charset_collate Charset collation.
	 * @return string
	 */
	public static function getCreateTableSql( string $prefix, string $charset_collate ): string {
		$table = $prefix . self::TABLE_NAME;
		return "CREATE TABLE {$table} (
			id bigint(20) unsigned NOT NULL AUTO_INCREMENT,
			event_name varchar(100) NOT NULL,
			payload_json longtext NOT NULL,
			status varchar(20) NOT NULL DEFAULT 'pending',
			created_at datetime NOT NULL,
			processed_at datetime DEFAULT NULL,
			PRIMARY KEY (id),
			KEY status_created (status, created_at)
		) {$charset_collate};";
	}
}