rename almost all exceptions

requires prooph/event-store#355
prooph · Jan 2, 2019 · 1fb9d87 · 1fb9d87
1 parent d086c3d
commit 1fb9d87
Show file tree

Hide file tree

Showing 51 changed files with 191 additions and 191 deletions.
diff --git a/src/ClientOperations/AbstractOperation.php b/src/ClientOperations/AbstractOperation.php
@@ -16,9 +16,9 @@
 use Amp\Deferred;
 use Amp\Promise;
 use Prooph\EventStore\EndPoint;
-use Prooph\EventStore\Exception\NotAuthenticatedException;
+use Prooph\EventStore\Exception\NotAuthenticated;
 use Prooph\EventStore\Exception\ServerError;
-use Prooph\EventStore\Exception\UnexpectedCommandException;
+use Prooph\EventStore\Exception\UnexpectedCommand;
 use Prooph\EventStore\UserCredentials;
 use Prooph\EventStoreClient\Messages\ClientMessages\NotHandled;
 use Prooph\EventStoreClient\Messages\ClientMessages\NotHandled_MasterInfo as MasterInfo;
@@ -138,7 +138,7 @@ public function fail(Throwable $exception): void
 
     private function inspectNotAuthenticated(TcpPackage $package): InspectionResult
     {
-        $this->fail(new NotAuthenticatedException());
+        $this->fail(new NotAuthenticated());
 
         return new InspectionResult(InspectionDecision::endOperation(), 'Not authenticated');
     }
@@ -200,7 +200,7 @@ private function inspectUnexpectedCommand(TcpPackage $package, TcpCommand $expec
         $this->log->error('TcpPackage Data Dump:');
         $this->log->error($package->data());
 
-        $exception = UnexpectedCommandException::with($expectedCommand->name(), $package->command()->name());
+        $exception = UnexpectedCommand::with($expectedCommand->name(), $package->command()->name());
         $this->fail($exception);
 
         return new InspectionResult(InspectionDecision::endOperation(), $exception->getMessage());

diff --git a/src/ClientOperations/AbstractSubscriptionOperation.php b/src/ClientOperations/AbstractSubscriptionOperation.php
@@ -20,12 +20,12 @@
 use Generator;
 use Prooph\EventStore\EndPoint;
 use Prooph\EventStore\EventStoreSubscription;
-use Prooph\EventStore\Exception\AccessDeniedException;
-use Prooph\EventStore\Exception\ConnectionClosedException;
-use Prooph\EventStore\Exception\NotAuthenticatedException;
+use Prooph\EventStore\Exception\AccessDenied;
+use Prooph\EventStore\Exception\ConnectionClosed;
+use Prooph\EventStore\Exception\NotAuthenticated;
 use Prooph\EventStore\Exception\RuntimeException;
 use Prooph\EventStore\Exception\ServerError;
-use Prooph\EventStore\Exception\UnexpectedCommandException;
+use Prooph\EventStore\Exception\UnexpectedCommand;
 use Prooph\EventStore\Internal\ResolvedEvent;
 use Prooph\EventStore\SubscriptionDropReason;
 use Prooph\EventStore\UserCredentials;
@@ -155,7 +155,7 @@ public function inspectPackage(TcpPackage $package): InspectionResult
                             $this->dropSubscription(SubscriptionDropReason::userInitiated(), null);
                             break;
                         case SubscriptionDropReasonMessage::AccessDenied:
-                            $this->dropSubscription(SubscriptionDropReason::accessDenied(), new AccessDeniedException(\sprintf(
+                            $this->dropSubscription(SubscriptionDropReason::accessDenied(), new AccessDenied(\sprintf(
                                 'Subscription to \'%s\' failed due to access denied',
                                 $this->streamId
                             )));
@@ -173,15 +173,15 @@ public function inspectPackage(TcpPackage $package): InspectionResult
                                         $message->getReason()
                                 ));
                             }
-                            $this->dropSubscription(SubscriptionDropReason::unknown(), new UnexpectedCommandException(
+                            $this->dropSubscription(SubscriptionDropReason::unknown(), new UnexpectedCommand(
                                 'Unsubscribe reason: ' . $message->getReason()
                             ));
                             break;
                     }
 
                     return new InspectionResult(InspectionDecision::endOperation(), 'SubscriptionDropped: ' . $message->getReason());
                 case TcpCommand::NOT_AUTHENTICATED_EXCEPTION:
-                    $this->dropSubscription(SubscriptionDropReason::notAuthenticated(), new NotAuthenticatedException());
+                    $this->dropSubscription(SubscriptionDropReason::notAuthenticated(), new NotAuthenticated());
 
                     return new InspectionResult(InspectionDecision::endOperation(), 'NotAuthenticated');
                 case TcpCommand::BAD_REQUEST:
@@ -230,7 +230,7 @@ public function inspectPackage(TcpPackage $package): InspectionResult
                 default:
                     $this->dropSubscription(
                         SubscriptionDropReason::serverError(),
-                        UnexpectedCommandException::withName($package->command()->name())
+                        UnexpectedCommand::withName($package->command()->name())
                     );
 
                     return new InspectionResult(InspectionDecision::endOperation(), $package->command()->name());
@@ -247,7 +247,7 @@ public function connectionClosed(): void
     {
         $this->dropSubscription(
             SubscriptionDropReason::connectionClosed(),
-            new ConnectionClosedException('Connection was closed')
+            new ConnectionClosed('Connection was closed')
         );
     }
 

diff --git a/src/ClientOperations/AppendToStreamOperation.php b/src/ClientOperations/AppendToStreamOperation.php
@@ -15,11 +15,11 @@
 
 use Amp\Deferred;
 use Prooph\EventStore\EventData;
-use Prooph\EventStore\Exception\AccessDeniedException;
-use Prooph\EventStore\Exception\InvalidTransactionException;
-use Prooph\EventStore\Exception\StreamDeletedException;
+use Prooph\EventStore\Exception\AccessDenied;
+use Prooph\EventStore\Exception\InvalidTransaction;
+use Prooph\EventStore\Exception\StreamDeleted;
 use Prooph\EventStore\Exception\UnexpectedOperationResult;
-use Prooph\EventStore\Exception\WrongExpectedVersionException;
+use Prooph\EventStore\Exception\WrongExpectedVersion;
 use Prooph\EventStore\Position;
 use Prooph\EventStore\UserCredentials;
 use Prooph\EventStore\WriteResult;
@@ -105,25 +105,25 @@ protected function inspectResponse(ProtobufMessage $response): InspectionResult
             case OperationResult::CommitTimeout:
                 return new InspectionResult(InspectionDecision::retry(), 'CommitTimeout');
             case OperationResult::WrongExpectedVersion:
-                $this->fail(WrongExpectedVersionException::with(
+                $this->fail(WrongExpectedVersion::with(
                     $this->stream,
                     $this->expectedVersion,
                     $response->getCurrentVersion()
                 ));
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'WrongExpectedVersion');
             case OperationResult::StreamDeleted:
-                $exception = StreamDeletedException::with($this->stream);
+                $exception = StreamDeleted::with($this->stream);
                 $this->fail($exception);
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'StreamDeleted');
             case OperationResult::InvalidTransaction:
-                $exception = new InvalidTransactionException();
+                $exception = new InvalidTransaction();
                 $this->fail($exception);
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'InvalidTransaction');
             case OperationResult::AccessDenied:
-                $exception = AccessDeniedException::toStream($this->stream);
+                $exception = AccessDenied::toStream($this->stream);
                 $this->fail($exception);
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'AccessDenied');

diff --git a/src/ClientOperations/CommitTransactionOperation.php b/src/ClientOperations/CommitTransactionOperation.php
@@ -14,11 +14,11 @@
 namespace Prooph\EventStoreClient\ClientOperations;
 
 use Amp\Deferred;
-use Prooph\EventStore\Exception\AccessDeniedException;
-use Prooph\EventStore\Exception\InvalidTransactionException;
-use Prooph\EventStore\Exception\StreamDeletedException;
+use Prooph\EventStore\Exception\AccessDenied;
+use Prooph\EventStore\Exception\InvalidTransaction;
+use Prooph\EventStore\Exception\StreamDeleted;
 use Prooph\EventStore\Exception\UnexpectedOperationResult;
-use Prooph\EventStore\Exception\WrongExpectedVersionException;
+use Prooph\EventStore\Exception\WrongExpectedVersion;
 use Prooph\EventStore\Position;
 use Prooph\EventStore\UserCredentials;
 use Prooph\EventStore\WriteResult;
@@ -84,22 +84,22 @@ protected function inspectResponse(ProtobufMessage $response): InspectionResult
             case OperationResult::CommitTimeout:
                 return new InspectionResult(InspectionDecision::retry(), 'CommitTimeout');
             case OperationResult::WrongExpectedVersion:
-                $this->fail(new WrongExpectedVersionException(\sprintf(
+                $this->fail(new WrongExpectedVersion(\sprintf(
                     'Commit transaction failed due to WrongExpectedVersion. Transaction id: \'%s\'',
                     $this->transactionId
                 )));
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'WrongExpectedVersion');
             case OperationResult::StreamDeleted:
-                $this->fail(new StreamDeletedException());
+                $this->fail(new StreamDeleted());
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'StreamDeleted');
             case OperationResult::InvalidTransaction:
-                $this->fail(new InvalidTransactionException());
+                $this->fail(new InvalidTransaction());
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'InvalidTransaction');
             case OperationResult::AccessDenied:
-                $exception = new AccessDeniedException('Write access denied');
+                $exception = new AccessDenied('Write access denied');
                 $this->fail($exception);
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'AccessDenied');

diff --git a/src/ClientOperations/ConditionalAppendToStreamOperation.php b/src/ClientOperations/ConditionalAppendToStreamOperation.php
@@ -17,8 +17,8 @@
 use Prooph\EventStore\ConditionalWriteResult;
 use Prooph\EventStore\ConditionalWriteStatus;
 use Prooph\EventStore\EventData;
-use Prooph\EventStore\Exception\AccessDeniedException;
-use Prooph\EventStore\Exception\InvalidTransactionException;
+use Prooph\EventStore\Exception\AccessDenied;
+use Prooph\EventStore\Exception\InvalidTransaction;
 use Prooph\EventStore\Exception\UnexpectedOperationResult;
 use Prooph\EventStore\Position;
 use Prooph\EventStore\UserCredentials;
@@ -106,12 +106,12 @@ protected function inspectResponse(ProtobufMessage $response): InspectionResult
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'StreamDeleted');
             case OperationResult::InvalidTransaction:
-                $exception = new InvalidTransactionException();
+                $exception = new InvalidTransaction();
                 $this->fail($exception);
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'InvalidTransaction');
             case OperationResult::AccessDenied:
-                $exception = AccessDeniedException::toStream($this->stream);
+                $exception = AccessDenied::toStream($this->stream);
                 $this->fail($exception);
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'AccessDenied');

diff --git a/src/ClientOperations/ConnectToPersistentSubscriptionOperation.php b/src/ClientOperations/ConnectToPersistentSubscriptionOperation.php
@@ -16,10 +16,10 @@
 use Amp\Deferred;
 use Prooph\EventStore\EventId;
 use Prooph\EventStore\EventStoreSubscription;
-use Prooph\EventStore\Exception\AccessDeniedException;
+use Prooph\EventStore\Exception\AccessDenied;
 use Prooph\EventStore\Exception\InvalidArgumentException;
-use Prooph\EventStore\Exception\MaximumSubscribersReachedException;
-use Prooph\EventStore\Exception\PersistentSubscriptionDeletedException;
+use Prooph\EventStore\Exception\MaximumSubscribersReached;
+use Prooph\EventStore\Exception\PersistentSubscriptionDeleted;
 use Prooph\EventStore\Internal\ConnectToPersistentSubscriptions;
 use Prooph\EventStore\Internal\PersistentEventStoreSubscription;
 use Prooph\EventStore\PersistentSubscriptionNakEventAction;
@@ -132,7 +132,7 @@ protected function preInspectPackage(TcpPackage $package): ?InspectionResult
             $message->parseFromString($package->data());
 
             if ($message->getReason() === SubscriptionDropReasonMessage::AccessDenied) {
-                $this->dropSubscription(SubscriptionDropReason::accessDenied(), new AccessDeniedException('You do not have access to the stream'));
+                $this->dropSubscription(SubscriptionDropReason::accessDenied(), new AccessDenied('You do not have access to the stream'));
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'SubscriptionDropped');
             }
@@ -144,13 +144,13 @@ protected function preInspectPackage(TcpPackage $package): ?InspectionResult
             }
 
             if ($message->getReason() === SubscriptionDropReasonMessage::PersistentSubscriptionDeleted) {
-                $this->dropSubscription(SubscriptionDropReason::persistentSubscriptionDeleted(), new PersistentSubscriptionDeletedException());
+                $this->dropSubscription(SubscriptionDropReason::persistentSubscriptionDeleted(), new PersistentSubscriptionDeleted());
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'SubscriptionDropped');
             }
 
             if ($message->getReason() === SubscriptionDropReasonMessage::SubscriberMaxCountReached) {
-                $this->dropSubscription(SubscriptionDropReason::maxSubscribersReached(), new MaximumSubscribersReachedException());
+                $this->dropSubscription(SubscriptionDropReason::maxSubscribersReached(), new MaximumSubscribersReached());
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'SubscriptionDropped');
             }

diff --git a/src/ClientOperations/CreatePersistentSubscriptionOperation.php b/src/ClientOperations/CreatePersistentSubscriptionOperation.php
@@ -15,7 +15,7 @@
 
 use Amp\Deferred;
 use Prooph\EventStore\Common\SystemConsumerStrategies;
-use Prooph\EventStore\Exception\AccessDeniedException;
+use Prooph\EventStore\Exception\AccessDenied;
 use Prooph\EventStore\Exception\InvalidOperationException;
 use Prooph\EventStore\Exception\UnexpectedOperationResult;
 use Prooph\EventStore\Internal\PersistentSubscriptionCreateResult;
@@ -105,7 +105,7 @@ protected function inspectResponse(ProtobufMessage $response): InspectionResult
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'Fail');
             case CreatePersistentSubscriptionResult::AccessDenied:
-                $this->fail(AccessDeniedException::toStream($this->stream));
+                $this->fail(AccessDenied::toStream($this->stream));
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'AccessDenied');
             case CreatePersistentSubscriptionResult::AlreadyExists:

diff --git a/src/ClientOperations/DeletePersistentSubscriptionOperation.php b/src/ClientOperations/DeletePersistentSubscriptionOperation.php
@@ -14,7 +14,7 @@
 namespace Prooph\EventStoreClient\ClientOperations;
 
 use Amp\Deferred;
-use Prooph\EventStore\Exception\AccessDeniedException;
+use Prooph\EventStore\Exception\AccessDenied;
 use Prooph\EventStore\Exception\InvalidOperationException;
 use Prooph\EventStore\Exception\UnexpectedOperationResult;
 use Prooph\EventStore\Internal\PersistentSubscriptionDeleteResult;
@@ -85,7 +85,7 @@ protected function inspectResponse(ProtobufMessage $response): InspectionResult
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'Fail');
             case DeletePersistentSubscriptionResult::AccessDenied:
-                $this->fail(AccessDeniedException::toStream($this->stream));
+                $this->fail(AccessDenied::toStream($this->stream));
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'AccessDenied');
             case DeletePersistentSubscriptionResult::DoesNotExist:

diff --git a/src/ClientOperations/DeleteStreamOperation.php b/src/ClientOperations/DeleteStreamOperation.php
@@ -15,11 +15,11 @@
 
 use Amp\Deferred;
 use Prooph\EventStore\DeleteResult;
-use Prooph\EventStore\Exception\AccessDeniedException;
-use Prooph\EventStore\Exception\InvalidTransactionException;
-use Prooph\EventStore\Exception\StreamDeletedException;
+use Prooph\EventStore\Exception\AccessDenied;
+use Prooph\EventStore\Exception\InvalidTransaction;
+use Prooph\EventStore\Exception\StreamDeleted;
 use Prooph\EventStore\Exception\UnexpectedOperationResult;
-use Prooph\EventStore\Exception\WrongExpectedVersionException;
+use Prooph\EventStore\Exception\WrongExpectedVersion;
 use Prooph\EventStore\Position;
 use Prooph\EventStore\UserCredentials;
 use Prooph\EventStoreClient\Messages\ClientMessages\DeleteStream;
@@ -94,24 +94,24 @@ public function inspectResponse(ProtobufMessage $response): InspectionResult
             case OperationResult::ForwardTimeout:
                 return new InspectionResult(InspectionDecision::retry(), 'ForwardTimeout');
             case OperationResult::WrongExpectedVersion:
-                $this->fail(WrongExpectedVersionException::with(
+                $this->fail(WrongExpectedVersion::with(
                     $this->stream,
                     $this->expectedVersion
                 ));
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'WrongExpectedVersion');
             case OperationResult::StreamDeleted:
-                $exception = StreamDeletedException::with($this->stream);
+                $exception = StreamDeleted::with($this->stream);
                 $this->fail($exception);
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'StreamDeleted');
             case OperationResult::InvalidTransaction:
-                $exception = new InvalidTransactionException();
+                $exception = new InvalidTransaction();
                 $this->fail($exception);
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'InvalidTransaction');
             case OperationResult::AccessDenied:
-                $exception = AccessDeniedException::toStream($this->stream);
+                $exception = AccessDenied::toStream($this->stream);
                 $this->fail($exception);
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'AccessDenied');

diff --git a/src/ClientOperations/ReadAllEventsBackwardOperation.php b/src/ClientOperations/ReadAllEventsBackwardOperation.php
@@ -15,7 +15,7 @@
 
 use Amp\Deferred;
 use Prooph\EventStore\AllEventsSlice;
-use Prooph\EventStore\Exception\AccessDeniedException;
+use Prooph\EventStore\Exception\AccessDenied;
 use Prooph\EventStore\Exception\ServerError;
 use Prooph\EventStore\Position;
 use Prooph\EventStore\ReadDirection;
@@ -94,7 +94,7 @@ protected function inspectResponse(ProtobufMessage $response): InspectionResult
                 return new InspectionResult(InspectionDecision::endOperation(), 'Error');
             case
             ReadAllResult::AccessDenied:
-                $this->fail(AccessDeniedException::toAllStream());
+                $this->fail(AccessDenied::toAllStream());
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'AccessDenied');
             default:

diff --git a/src/ClientOperations/ReadAllEventsForwardOperation.php b/src/ClientOperations/ReadAllEventsForwardOperation.php
@@ -15,7 +15,7 @@
 
 use Amp\Deferred;
 use Prooph\EventStore\AllEventsSlice;
-use Prooph\EventStore\Exception\AccessDeniedException;
+use Prooph\EventStore\Exception\AccessDenied;
 use Prooph\EventStore\Exception\ServerError;
 use Prooph\EventStore\Position;
 use Prooph\EventStore\ReadDirection;
@@ -94,7 +94,7 @@ protected function inspectResponse(ProtobufMessage $response): InspectionResult
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'Error');
             case ReadAllResult::AccessDenied:
-                $this->fail(AccessDeniedException::toAllStream());
+                $this->fail(AccessDenied::toAllStream());
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'AccessDenied');
             default:

diff --git a/src/ClientOperations/ReadEventOperation.php b/src/ClientOperations/ReadEventOperation.php
@@ -16,7 +16,7 @@
 use Amp\Deferred;
 use Prooph\EventStore\EventReadResult;
 use Prooph\EventStore\EventReadStatus;
-use Prooph\EventStore\Exception\AccessDeniedException;
+use Prooph\EventStore\Exception\AccessDenied;
 use Prooph\EventStore\Exception\ServerError;
 use Prooph\EventStore\ResolvedEvent;
 use Prooph\EventStore\UserCredentials;
@@ -103,7 +103,7 @@ protected function inspectResponse(ProtobufMessage $response): InspectionResult
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'Error');
             case ReadEventResult::AccessDenied:
-                $this->fail(AccessDeniedException::toStream($this->stream));
+                $this->fail(AccessDenied::toStream($this->stream));
 
                 return new InspectionResult(InspectionDecision::endOperation(), 'AccessDenied');
             default: