Merge pull request #6 from formapro/pvm-class-map

Intr schema, enchance object builder. fix doc.
formapro · Sep 28, 2017 · a6e6952 · a6e6952
2 parents 43bc303 + eda01f5
commit a6e6952
Show file tree

Hide file tree

Showing 16 changed files with 102 additions and 51 deletions.
diff --git a/docs/conditions-example.md b/docs/conditions-example.md
@@ -11,6 +11,9 @@ use Formapro\Pvm\CallbackBehavior;
 use Formapro\Pvm\ProcessEngine;
 use Formapro\Pvm\Process;
 use Formapro\Pvm\Token;
+use Formapro\Pvm\ObjectBuilderHook;
+
+(new ObjectBuilderHook())->register();
 
 $registry = new DefaultBehaviorRegistry();
 $registry->register('print_label', new CallbackBehavior(function(Token $token) {
@@ -20,7 +23,7 @@ $registry->register('condition', new CallbackBehavior(function(Token $token) {
     return ['first'];
 }));
 
-$process = new Process();
+$process = Process::create();
 $foo = $process->createNode();
 $foo->setLabel('foo');
 $foo->setBehavior('condition');

diff --git a/docs/cycle-example.md b/docs/cycle-example.md
@@ -13,6 +13,9 @@ use Formapro\Pvm\Process;
 use Formapro\Pvm\Token;
 use function Makasim\Values\get_value;
 use function Makasim\Values\set_value;
+use Formapro\Pvm\ObjectBuilderHook;
+
+(new ObjectBuilderHook())->register();
 
 $registry = new DefaultBehaviorRegistry();
 $registry->register('print_label', new CallbackBehavior(function(Token $token) {
@@ -27,7 +30,7 @@ $registry->register('go_back_first_three_times', new CallbackBehavior(function(T
     return $counter < 3 ? ['back'] : ['forth'];
 }));
 
-$process = new Process();
+$process = Process::create();
 $foo = $process->createNode();
 $foo->setLabel('foo');
 $foo->setBehavior('print_label');

diff --git a/docs/fork-example.md b/docs/fork-example.md
@@ -12,13 +12,16 @@ use Formapro\Pvm\CallbackBehavior;
 use Formapro\Pvm\ProcessEngine;
 use Formapro\Pvm\Process;
 use Formapro\Pvm\Token;
+use Formapro\Pvm\ObjectBuilderHook;
+
+(new ObjectBuilderHook())->register();
 
 $registry = new DefaultBehaviorRegistry();
 $registry->register('print_label', new CallbackBehavior(function(Token $token) {
     echo $token->getTransition()->getTo()->getLabel().' ';
 }));
 
-$process = new Process();
+$process = Process::create();
 $foo = $process->createNode();
 $foo->setLabel('foo');
 $foo->setBehavior('print_label');

diff --git a/docs/mongo-storage-example.md b/docs/mongo-storage-example.md
@@ -14,8 +14,11 @@ namespace Acme;
 
 use Formapro\Pvm\Process;
 use Formapro\Pvm\Yadm\MongoProcessStorage;
+use Formapro\Pvm\ObjectBuilderHook;
 
-$process = new Process();
+(new ObjectBuilderHook())->register();
+
+$process = Process::create();
 $fooNode = $process->createNode();
 $fooNode->setLabel('foo');
 $fooNode->setBehavior('print_label');

diff --git a/docs/parallel-execution-with-enqueue.md b/docs/parallel-execution-with-enqueue.md
@@ -25,6 +25,9 @@ use Formapro\Pvm\ProcessStorage;
 use Formapro\Pvm\Process;
 use Formapro\Pvm\Token;
 use Formapro\Pvm\Enqueue\AsyncTransition;
+use Formapro\Pvm\ObjectBuilderHook;
+
+(new ObjectBuilderHook())->register();
 
 $client = new SimpleClient('amqp://');
 $asyncTransition = new AsyncTransition($client->getProducer());
@@ -36,7 +39,7 @@ $registry->register('print_label', new CallbackBehavior(function(Token $token) {
     echo $token->getTransition()->getTo()->getLabel().' ';
 }));
 
-$process = new Process();
+$process = Process::create();
 $foo = $process->createNode();
 $foo->setLabel('foo');
 $foo->setBehavior('print_label');

diff --git a/docs/pause-and-continue-example.md b/docs/pause-and-continue-example.md
@@ -14,6 +14,9 @@ use Formapro\Pvm\Token;
 use Formapro\Pvm\Exception\WaitExecutionException;
 use function Makasim\Values\set_value;
 use function Makasim\Values\get_value;
+use Formapro\Pvm\ObjectBuilderHook;
+
+(new ObjectBuilderHook())->register();
 
 $registry = new DefaultBehaviorRegistry();
 $registry->register('pause_and_continue', new CallbackBehavior(function(Token $token) {
@@ -25,7 +28,7 @@ $registry->register('pause_and_continue', new CallbackBehavior(function(Token $t
     echo 'purchased. ';
 }));
 
-$process = new Process();
+$process = Process::create();
 $fooNode = $process->createNode();
 $fooNode->setLabel('foo');
 $fooNode->setBehavior('pause_and_continue');

diff --git a/docs/sequence-example.md b/docs/sequence-example.md
@@ -11,13 +11,16 @@ use Formapro\Pvm\CallbackBehavior;
 use Formapro\Pvm\ProcessEngine;
 use Formapro\Pvm\Process;
 use Formapro\Pvm\Token;
+use Formapro\Pvm\ObjectBuilderHook;
+
+(new ObjectBuilderHook())->register();
 
 $registry = new DefaultBehaviorRegistry();
 $registry->register('print_label', new CallbackBehavior(function(Token $token) {
     echo $token->getTransition()->getTo()->getLabel().' ';
 }));
 
-$process = new Process();
+$process = Process::create();
 $fooNode = $process->createNode();
 $fooNode->setLabel('foo');
 $fooNode->setBehavior('print_label');

diff --git a/docs/synchronization-example.md b/docs/synchronization-example.md
@@ -12,6 +12,9 @@ use Formapro\Pvm\CallbackBehavior;
 use Formapro\Pvm\ProcessEngine;
 use Formapro\Pvm\Process;
 use Formapro\Pvm\Token;
+use Formapro\Pvm\ObjectBuilderHook;
+
+(new ObjectBuilderHook())->register();
 
 $registry = new DefaultBehaviorRegistry();
 $registry->register('print_label', new CallbackBehavior(function(Token $token) {
@@ -38,7 +41,7 @@ $registry->register('join', new CallbackBehavior(function (Token $token) {
     throw new InterruptExecutionException();
 }));
 
-$process = new Process();
+$process = Process::create();
 
 $fork = $process->createNode();
 $fork->setLabel('fork');

diff --git a/src/Yadm/CreateTrait.php → src/CreateTrait.php b/src/Yadm/CreateTrait.php → src/CreateTrait.php
@@ -13,7 +13,7 @@ trait CreateTrait
     public static function create(array $data = [])
     {
         return build_object(null, array_replace([
-            'class' => static::class,
+            'schema' => static::SCHEMA,
         ], $data));
     }
 }
diff --git a/src/Node.php b/src/Node.php
@@ -7,6 +7,8 @@
 
 class Node
 {
+    const SCHEMA = 'http://pvm.forma-pro.com/schemas/Node.json';
+
     use ValuesTrait {
         setValue as public;
         getValue as public;

diff --git a/src/ObjectBuilderHook.php b/src/ObjectBuilderHook.php
@@ -0,0 +1,33 @@
+<?php
+namespace Formapro\Pvm;
+
+use function Makasim\Values\register_global_hook;
+
+class ObjectBuilderHook
+{
+    /**
+     * @var PvmClassMap
+     */
+    private $classMap;
+
+    /**
+     * @param string[] $classMap
+     */
+    public function __construct(array $classMap = [])
+    {
+        $this->classMap = new PvmClassMap($classMap);
+    }
+
+    public function register()
+    {
+        register_global_hook('get_object_class', function(array $values) {
+            if (isset($values['schema'])) {
+                if (false == array_key_exists($values['schema'], $this->classMap->get())) {
+                    throw new \LogicException(sprintf('An object has class set "%s" but there is no class for it', $values['class']));
+                }
+
+                return $this->classMap[$values['schema']];
+            }
+        });
+    }
+}
diff --git a/src/Process.php b/src/Process.php
@@ -7,6 +7,8 @@
 
 class Process
 {
+    const SCHEMA = 'http://pvm.forma-pro.com/schemas/Process.json';
+
     use ValuesTrait {
         getValue as public;
         setValue as public;

diff --git a/src/PvmClassMap.php b/src/PvmClassMap.php
@@ -0,0 +1,28 @@
+<?php
+namespace Formapro\Pvm;
+
+class PvmClassMap
+{
+    /**
+     * @var string[]
+     */
+    private $classMap;
+
+    /**
+     * @param string[] $classMap
+     */
+    public function __construct(array $classMap = [])
+    {
+        $this->classMap = array_replace([
+            Process::SCHEMA => Process::class,
+            Node::SCHEMA => Node::class,
+            Token::SCHEMA => Token::class,
+            Transition::SCHEMA => Transition::class,
+        ], $classMap);
+    }
+
+    public function get(): array
+    {
+        return $this->classMap;
+    }
+}
diff --git a/src/Token.php b/src/Token.php
@@ -6,6 +6,8 @@
 
 class Token
 {
+    const SCHEMA = 'http://pvm.forma-pro.com/schemas/Token.json';
+
     use ValuesTrait;
     use CreateTrait;
 

diff --git a/src/Transition.php b/src/Transition.php
@@ -6,6 +6,8 @@
 
 class Transition
 {
+    const SCHEMA = 'http://pvm.forma-pro.com/schemas/Transition.json';
+
     use ValuesTrait {
         setValue as public;
         getValue as public;

diff --git a/src/Yadm/ObjectBuilderHook.php b/src/Yadm/ObjectBuilderHook.php