<?php

/**
 * Workflow job entity (queue item).
 *
 * @package AfroIT_Messaging_WorkflowAutomations
 */

namespace AfroIT\Messaging\WorkflowAutomations\Workflows;

use AfroIT\Messaging\WorkflowAutomations\Logging\Log;

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

/**
 * Class WorkflowJob
 *
 * Represents a queued workflow job with id, context_json, execution_json, run_at, status, created_at.
 * Local WordPress workflow id (when applicable) is stored in context_json as `workflow_id`.
 */
final class WorkflowJob {

	/**
	 * @var int
	 */
	public int $id;

    /**
     * @var string
     */
    public string $remote_workflow_uuid;

	/**
	 * @var string
	 */
	public string $remote_execution_uuid;

	/**
	 * @var string
	 */
	public string $context_json;

	/**
	 * @var string JSON-encoded results of executed steps (step_index, type, executed_at, result, status).
	 */
	public string $execution_json;

	/**
	 * @var string
	 */
	public string $run_at;

	/**
	 * @var string
	 */
	public string $status;

	/**
	 * @var string
	 */
	public string $created_at;

	/**
	 * Constructor.
	 *
	 * @param int    $id             Job ID.
     * @param string $remote_workflow_uuid Remote workflow UUID.
	 * @param string $remote_execution_uuid Remote execution UUID.
	 * @param string $context_json   Context data as JSON.
	 * @param string $execution_json Executed steps results as JSON.
	 * @param string $run_at         Run at datetime.
	 * @param string $status         Job status.
	 * @param string $created_at     Created at datetime.
	 */
	public function __construct(
		int $id,
		string $remote_workflow_uuid,
		string $remote_execution_uuid,
		string $context_json,
		string $execution_json,
		string $run_at,
		string $status,
		string $created_at
	) {
		$this->id                     = $id;
		$this->remote_workflow_uuid   = $remote_workflow_uuid;
		$this->remote_execution_uuid  = $remote_execution_uuid;
		$this->context_json           = $context_json;
		$this->execution_json         = $execution_json;
		$this->run_at                 = $run_at;
		$this->status                 = $status;
		$this->created_at             = $created_at;
	}

	/**
	 * Create from database row.
	 *
	 * @param object $row Database row.
	 * @return self
	 */
	public static function fromRow( object $row ): self {
		return new self(
			(int) $row->id,
			(string) ( $row->remote_workflow_uuid ?? '' ),
			(string) ( $row->remote_execution_uuid ?? '' ),
			(string) ( $row->context_json ?? '' ),
			(string) ( $row->execution_json ?? '' ),
			(string) ( $row->run_at ?? '' ),
			(string) ( $row->status ?? 'pending' ),
			(string) ( $row->created_at ?? '' )
		);
	}

	/**
	 * Local WordPress workflow post ID from context (local queue jobs only).
	 *
	 * @return int
	 */
	public function getLocalWorkflowId(): int {
		$ctx = $this->getContext();

		return isset( $ctx['workflow_id'] ) ? absint( $ctx['workflow_id'] ) : 0;
	}

	/**
	 * Get the remote workflow UUID.
	 *
	 * @return string
	 */
	public function getRemoteWorkflowUuid(): string {
		return $this->remote_workflow_uuid;
	}

	/**
	 * Get the remote execution UUID.
	 *
	 * @return string
	 */
	public function getRemoteExecutionUuid(): string {
		return $this->remote_execution_uuid;
	}

	/**
	 * Get the run at datetime.
	 *
	 * @return string
	 */
	public function getRunAt(): string {
		return $this->run_at;
	}

	/**
	 * Get the status.
	 *
	 * @return string
	 */
	public function getStatus(): string {
		return $this->status;
	}

	/**
	 * Get decoded context as array.
	 *
	 * @return array<string, mixed>
	 */
	public function getContext(): array {
		$decoded = json_decode( $this->context_json, true );
		return is_array( $decoded ) ? $decoded : array();
	}

	/**
	 * Get the created at datetime.
	 *
	 * @return string
	 */
	public function getCreatedAt(): string {
		return $this->created_at;
	}

	/**
	 * Get decoded execution results as array.
	 *
	 * @param bool $indexed Whether to index the results by step_index and type.
	 * @return array<int|string, mixed>
	 */
	public function getExecutionResults($indexed = false): array {
		$decoded = json_decode( $this->execution_json, true );
		$results = is_array( $decoded ) ? $decoded : array();
        if ( false === $indexed ) {
            return $results;
        }
        $indexed_results = array();
        foreach ( $results as $i => $result ) {
            if (empty($result['step_index'])) {
                $result['step_index'] = -1 * ($i + 1);
            }
            $indexed_results["{$result['step_index']}_{$result['type']}"] = $result;
        }
        return $indexed_results;
	}

}