namespace App\Neuron\Workflow;

use NeuronAI\Workflow\Edge;
use NeuronAI\Workflow\Workflow;

class SimpleWorkflow extends Workflow {
    public function nodes(): array {
        return [
            new InitialNode(),
            new MiddleNode(),
            new FinishNode(),
        ];
    }

    public function edges(): array {
        return [
            new Edge(InitialNode::class, MiddleNode::class),
            new Edge(MiddleNode::class, FinishNode::class),
        ];
    }

    protected function start(): string {
        return InitialNode::class;
    }

    protected function end(): array {
        return [FinishNode::class];
    }
}

$persistence = new FilePersistence(__DIR__);
$workflow = new Workflow($persistence, 'test_workflow');

$workflow->addNodes([
    new BeforeInterruptNode(),
    new InterruptNode(),
    new AfterInterruptNode(),
])->addEdges([
    new Edge(BeforeInterruptNode::class, InterruptNode::class),
    new Edge(InterruptNode::class, AfterInterruptNode::class),
])
->setStart(BeforeInterruptNode::class)
->setEnd([AfterInterruptNode::class]);

try {
    $workflow->run(new WorkflowState(['value' => 8]));
} catch (WorkflowInterrupt $interrupt) {
    $savedInterrupt = $persistence->load('test_workflow');
    echo "Workflow interrupted at {$savedInterrupt->getCurrentNode()}.";
}

// Đưa phản hồi từ con người và tiếp tục workflow
$result = $workflow->resume(['approved' => true]);
echo $result->get('final_value');