Merge pull request #8 from barryosull/feature/player_versioning

Feature/player versioning

src/Contracts/Player/Player.php

@@ -17,5 +17,5 @@ public function snapshot();
     /**
      * @return int
      */
-    public function version();
+    public static function version();
 }

src/Contracts/Player/Snapshot/Snapshot.php

@@ -24,7 +24,7 @@ public function last_id();
     /**
      * @return Integer_
      */
-    public function updateCount();
+    public function playerVersion();
 
     /**
      * Returns a new Snapshot after resetting it back to its default state.

src/Player/AbstractPlayer.php

@@ -41,8 +41,8 @@ public function reset()
 
     public function play($limit = 1000)
     {
-        if ($this->snapshot()->version()->value() != $this->version()) {
-            throw new \Exception("The snapshot and projector have different versions, playing would cause potential data corruption. This exception only occurs if the players are used incorrectly.");
+        if ($this->snapshot()->playerVersion()->value() != static::version()) {
+            throw new \Exception("The snapshot (".$this->snapshot()->version()->value().") and projector (".$this->version().") for '".get_called_class()."' have different versions, playing would cause potential data corruption. This exception only occurs if the players are used incorrectly.");
         }
 
         $snapshot_stream = $this->log
@@ -83,7 +83,7 @@ public function snapshot()
     /**
      * @return int
      */
-    public function version()
+    public static function version()
     {
         $player_class = get_called_class();
 

src/Player/Collection/Player.php

@@ -40,7 +40,7 @@ public function snapshot()
         throw new \Exception("Collection Player Snapshots are not supported.");
     }
 
-    public function version()
+    public static function version()
     {
         throw new \Exception("Collection Player versions are not supported.");
     }

src/Player/Repository.php

@@ -43,11 +43,11 @@ public function hasVersionChanged(ClassName $class_name)
 
         $active_version = new Integer_(1);
         if ($snapshot) {
-            $active_version = $snapshot->version();
+            $active_version = $snapshot->playerVersion();
         }
 
-        $player = $this->player_factory->make($class_name);
+        $player_class = $class_name->value();
 
-        return $active_version->value() != $player->version();
+        return $active_version->value() != $player_class::version();
     }
 }

src/Player/Snapshot/Factory.php

@@ -23,7 +23,7 @@ public function make(array $snapshot)
         return new Snapshot(
             new ClassName($snapshot['class_name']),
             new Integer($snapshot['version']),
-            new Integer($snapshot['update_count']),
+            new Integer($snapshot['player_version']),
             $this->datetime_generator->string($snapshot['occurred_at']),
             $this->identifier_generator->string($snapshot['last_id'])
         );

src/Player/Snapshot/Snapshot.php

@@ -11,19 +11,19 @@ class Snapshot extends AbstractSnapshot implements \BoundedContext\Contracts\Pla
 {
     public $last_id;
     protected $class_name;
-    protected $update_count;
+    protected $player_version;
 
     public function __construct(
         ClassName $class_name,
         Integer_ $version,
-        Integer_ $update_count,
+        Integer_ $player_version,
         DateTime $occurred_at,
         Identifier $last_id
     )
     {
         parent::__construct($version, $occurred_at);
         $this->class_name = $class_name;
-        $this->update_count = $update_count;
+        $this->player_version = $player_version;
         $this->last_id = $last_id;
     }
 
@@ -35,13 +35,13 @@ public function last_id()
     public function reset(
         IdentifierGenerator $identifier_generator,
         DateTimeGenerator $datetime_generator,
-        Integer_ $version
+        Integer_ $player_version
     )
     {
         return new Snapshot(
             $this->class_name,
-            $version,
-            $this->update_count->reset(),
+            $this->version->reset(),
+            $player_version,
             $datetime_generator->now(),
             $identifier_generator->null()
         );
@@ -55,7 +55,7 @@ public function skip(
         return new Snapshot(
             $this->class_name,
             $this->version,
-            $this->update_count,
+            $this->player_version,
             $datetime_generator->now(),
             $next_id
         );
@@ -68,8 +68,8 @@ public function take(
     {
         return new Snapshot(
             $this->class_name,
-            $this->version,
-            $this->update_count->increment(),
+            $this->version->increment(),
+            $this->player_version,
             $datetime_generator->now(),
             $next_id
         );
@@ -95,8 +95,8 @@ public static function make(
         );
     }
 
-    public function updateCount()
+    public function playerVersion()
     {
-        return $this->update_count;
+        return $this->player_version;
     }
 }