added findOrFail to the read model repository interface

src/ReadModel/DoctrineORM/DoctrineORMRepository.php

@@ -4,6 +4,7 @@
 
 use Broadway\ReadModel\ReadModelInterface;
 use Doctrine\ORM\EntityManagerInterface;
+use Milio\CQRS\Readmodel\Exception\NotFoundReadModelException;
 use Milio\CQRS\ReadModel\ReadModelRepositoryInterface;
 
 /**
@@ -14,6 +15,7 @@ class DoctrineORMRepository implements ReadModelRepositoryInterface
     private $entityManager;
     private $repository;
     private $identifierName;
+    private $class;
 
     /**
      * @param EntityManagerInterface $entityManager  An entity manager instance
@@ -22,6 +24,7 @@ class DoctrineORMRepository implements ReadModelRepositoryInterface
      */
     public function __construct(EntityManagerInterface $entityManager, $class, $identifierName)
     {
+        $this->class = $class;
         $this->entityManager = $entityManager;
         $this->repository = $entityManager->getRepository($class);
         $this->identifierName = $identifierName;
@@ -77,4 +80,15 @@ public function remove($id)
         $this->entityManager->remove($model);
         $this->entityManager->flush($model);
     }
+
+    public function findOrFail($id)
+    {
+        $result = $this->find($id);
+
+        if (null === $result) {
+            throw new NotFoundReadModelException('no result for id '.$id.' and class '.$this->class);
+        }
+
+        return $result;
+    }
 }

src/ReadModel/Exception/NotFoundReadModelException.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace Milio\CQRS\Readmodel\Exception;
+
+/**
+ * Exception that gets thrown when read model could not be found by it's identifier
+ */
+class NotFoundReadModelException extends \Exception
+{
+
+}

src/ReadModel/ReadModelRepositoryInterface.php

@@ -4,9 +4,18 @@
 
 use Broadway\ReadModel\ReadModelInterface;
 use Broadway\ReadModel\RepositoryInterface;
+use Milio\CQRS\Readmodel\Exception\NotFoundReadModelException;
 
 interface ReadModelRepositoryInterface extends RepositoryInterface
 {
+    /**
+     * @param $id
+     * @return ReadModelInterface
+     *
+     * @throws NotFoundReadModelException when read model was not found
+     */
+    public function findOrFail($id);
+
     /**
      * Finds a single read model by a set of criteria.
      *