Merge pull request #28 from prooph/factories

prolic · web-flow · commit bca639da6aa0 · 2019-01-26T21:56:52.000+08:00
refactor factories
diff --git a/src/EventStoreConnectionFactory.php b/src/EventStoreConnectionFactory.php
@@ -23,14 +23,14 @@
 class EventStoreConnectionFactory
 {
     public static function create(
+        ConnectionSettings $settings = null,
         ClientInterface $client = null,
-        RequestFactory $requestFactory = null,
-        ConnectionSettings $settings = null
+        RequestFactory $requestFactory = null
     ): EventStoreConnection {
         return new EventStoreHttpConnection(
+            $settings ?? ConnectionSettings::default(),
             $client ?? HttpClientDiscovery::find(),
-            $requestFactory ?? MessageFactoryDiscovery::find(),
-            $settings ?? ConnectionSettings::default()
+            $requestFactory ?? MessageFactoryDiscovery::find()
         );
     }
 }
diff --git a/src/Internal/EventStoreHttpConnection.php b/src/Internal/EventStoreHttpConnection.php
@@ -74,20 +74,20 @@
 /** @internal */
 class EventStoreHttpConnection implements EventStoreConnection
 {
-    /** @var HttpClient */
-    private $httpClient;
     /** @var ConnectionSettings */
     private $settings;
+    /** @var HttpClient */
+    private $httpClient;
     /** @var callable */
     private $onException;
     /** @var string */
     private $baseUri;
 
     /** @internal */
     public function __construct(
+        ConnectionSettings $settings,
         ClientInterface $httpClient,
-        RequestFactory $requestFactory,
-        ConnectionSettings $settings
+        RequestFactory $requestFactory
     ) {
         $this->baseUri = \sprintf(
             '%s://%s:%s',
diff --git a/src/PersistentSubscriptions/PersistentSubscriptionsManager.php b/src/PersistentSubscriptions/PersistentSubscriptionsManager.php
@@ -29,16 +29,16 @@
 
 class PersistentSubscriptionsManager implements SyncPersistentSubscriptionsManager
 {
-    /** @var HttpClient */
-    private $httpClient;
     /** @var ConnectionSettings */
     private $settings;
+    /** @var HttpClient */
+    private $httpClient;
 
     /** @internal */
     public function __construct(
+        ConnectionSettings $settings,
         ClientInterface $client,
-        RequestFactory $requestFactory,
-        ConnectionSettings $settings
+        RequestFactory $requestFactory
     ) {
         $this->settings = $settings;
 
diff --git a/src/PersistentSubscriptions/PersistentSubscriptionsManagerFactory.php b/src/PersistentSubscriptions/PersistentSubscriptionsManagerFactory.php
@@ -23,14 +23,14 @@
 class PersistentSubscriptionsManagerFactory
 {
     public static function create(
+        ConnectionSettings $settings = null,
         ClientInterface $client = null,
-        RequestFactory $requestFactory = null,
-        ConnectionSettings $settings = null
+        RequestFactory $requestFactory = null
     ): SyncPersistentSubscriptionsManager {
         return new PersistentSubscriptionsManager(
+            $settings ?? ConnectionSettings::default(),
             $client ?? HttpClientDiscovery::find(),
-            $requestFactory ?? MessageFactoryDiscovery::find(),
-            $settings ?? ConnectionSettings::default()
+            $requestFactory ?? MessageFactoryDiscovery::find()
         );
     }
 }
diff --git a/src/Projections/ProjectionsManager.php b/src/Projections/ProjectionsManager.php
@@ -31,16 +31,16 @@
 
 class ProjectionsManager implements SyncProjectionsManager
 {
-    /** @var HttpClient */
-    private $httpClient;
     /** @var ConnectionSettings */
     private $settings;
+    /** @var HttpClient */
+    private $httpClient;
 
     /** @internal */
     public function __construct(
+        ConnectionSettings $settings,
         ClientInterface $client,
-        RequestFactory $requestFactory,
-        ConnectionSettings $settings
+        RequestFactory $requestFactory
     ) {
         $this->settings = $settings;
 
diff --git a/src/Projections/ProjectionsManagerFactory.php b/src/Projections/ProjectionsManagerFactory.php
@@ -23,14 +23,14 @@
 class ProjectionsManagerFactory
 {
     public static function create(
+        ConnectionSettings $settings = null,
         ClientInterface $client = null,
-        RequestFactory $requestFactory = null,
-        ConnectionSettings $settings = null
+        RequestFactory $requestFactory = null
     ): SyncProjectionsManager {
         return new ProjectionsManager(
+            $settings ?? ConnectionSettings::default(),
             $client ?? HttpClientDiscovery::find(),
-            $requestFactory ?? MessageFactoryDiscovery::find(),
-            $settings ?? ConnectionSettings::default()
+            $requestFactory ?? MessageFactoryDiscovery::find()
         );
     }
 }
diff --git a/src/Projections/QueryManager.php b/src/Projections/QueryManager.php
@@ -32,14 +32,14 @@ class QueryManager implements SyncQueryManager
 
     /** @internal */
     public function __construct(
+        ConnectionSettings $settings,
         ClientInterface $client,
-        RequestFactory $requestFactory,
-        ConnectionSettings $settings
+        RequestFactory $requestFactory
     ) {
         $this->projectionsManager = new ProjectionsManager(
+            $settings,
             $client,
-            $requestFactory,
-            $settings
+            $requestFactory
         );
     }
 
diff --git a/src/Projections/QueryManagerFactory.php b/src/Projections/QueryManagerFactory.php
@@ -23,14 +23,14 @@
 class QueryManagerFactory
 {
     public static function create(
+        ConnectionSettings $settings = null,
         ClientInterface $client = null,
-        RequestFactory $requestFactory = null,
-        ConnectionSettings $settings = null
+        RequestFactory $requestFactory = null
     ): SyncQueryManager {
         return new QueryManager(
+            $settings ?? ConnectionSettings::default(),
             $client ?? HttpClientDiscovery::find(),
-            $requestFactory ?? MessageFactoryDiscovery::find(),
-            $settings ?? ConnectionSettings::default()
+            $requestFactory ?? MessageFactoryDiscovery::find()
         );
     }
 }
diff --git a/src/UserManagement/UsersManager.php b/src/UserManagement/UsersManager.php
@@ -35,16 +35,16 @@
 
 class UsersManager implements SyncUsersManager
 {
-    /** @var HttpClient */
-    private $httpClient;
     /** @var ConnectionSettings */
     private $settings;
+    /** @var HttpClient */
+    private $httpClient;
 
     /** @internal */
     public function __construct(
+        ConnectionSettings $settings,
         ClientInterface $client,
-        RequestFactory $requestFactory,
-        ConnectionSettings $settings
+        RequestFactory $requestFactory
     ) {
         $this->settings = $settings;
 
diff --git a/src/UserManagement/UsersManagerFactory.php b/src/UserManagement/UsersManagerFactory.php
@@ -23,14 +23,14 @@
 class UsersManagerFactory
 {
     public static function create(
+        ConnectionSettings $settings = null,
         ClientInterface $client = null,
-        RequestFactory $requestFactory = null,
-        ConnectionSettings $settings = null
+        RequestFactory $requestFactory = null
     ): SyncUsersManager {
         return new UsersManager(
+            $settings ?? ConnectionSettings::default(),
             $client ?? HttpClientDiscovery::find(),
-            $requestFactory ?? MessageFactoryDiscovery::find(),
-            $settings ?? ConnectionSettings::default()
+            $requestFactory ?? MessageFactoryDiscovery::find()
         );
     }
 }
diff --git a/tests/Helper/TestConnection.php b/tests/Helper/TestConnection.php
@@ -28,8 +28,6 @@ public static function create(?UserCredentials $userCredentials = null): EventSt
         self::checkRequiredEnvironmentSettings();
 
         return EventStoreConnectionFactory::create(
-            null,
-            null,
             self::settings($userCredentials)
         );
     }
diff --git a/tests/PersistentSubscriptionManagement/persistent_subscription_manager.php b/tests/PersistentSubscriptionManagement/persistent_subscription_manager.php
@@ -46,8 +46,6 @@ class persistent_subscription_manager extends TestCase
     protected function setUp(): void
     {
         $this->manager = PersistentSubscriptionsManagerFactory::create(
-            null,
-            null,
             TestConnection::settings()
         );
         $this->stream = Guid::generateAsHex();
diff --git a/tests/ProjectionSpecification.php b/tests/ProjectionSpecification.php
@@ -43,8 +43,6 @@ protected function execute(callable $test): void
         $this->connection = TestConnection::create();
 
         $this->projectionsManager = ProjectionsManagerFactory::create(
-            null,
-            null,
             TestConnection::settings()
         );
 
diff --git a/tests/UserManagement/TestWithNode.php b/tests/UserManagement/TestWithNode.php
@@ -26,8 +26,6 @@ abstract class TestWithNode extends TestCase
     protected function setUp(): void
     {
         $this->manager = UsersManagerFactory::create(
-            null,
-            null,
             TestConnection::settings()
         );
     }
diff --git a/tests/UserManagement/list_users.php b/tests/UserManagement/list_users.php
@@ -56,8 +56,6 @@ public function list_all_users_works(): void
     public function list_all_users_falls_back_to_default_credentials(): void
     {
         $manager = UsersManagerFactory::create(
-            null,
-            null,
             TestConnection::settings()
         );
 
diff --git a/tests/connection_factory_can.php b/tests/connection_factory_can.php
@@ -26,8 +26,6 @@ final class connection_factory_can extends TestCase
     public function create_from_settings_and_discover_client_and_request_factory(): void
     {
         $conn = Factory::create(
-            null,
-            null,
             ConnectionSettings::default()
         );
 
@@ -43,8 +41,6 @@ public function create_from_settings_and_discover_client_and_request_factory():
     public function create_from_connection_string(): void
     {
         $conn = Factory::create(
-            null,
-            null,
             ConnectionString::getConnectionSettings(
                 'endpoint=foo:21345'
             )

Original file line number	Diff line number	Diff line change
`@@ -23,14 +23,14 @@`
`23`	`23`	`class EventStoreConnectionFactory`
`24`	`24`	`{`
`25`	`25`	`public static function create(`
	`26`	`+ ConnectionSettings $settings = null,`
`26`	`27`	`ClientInterface $client = null,`
`27`		`- RequestFactory $requestFactory = null,`
`28`		`- ConnectionSettings $settings = null`
	`28`	`+ RequestFactory $requestFactory = null`
`29`	`29`	`): EventStoreConnection {`
`30`	`30`	`return new EventStoreHttpConnection(`
	`31`	`+ $settings ?? ConnectionSettings::default(),`
`31`	`32`	`$client ?? HttpClientDiscovery::find(),`
`32`		`- $requestFactory ?? MessageFactoryDiscovery::find(),`
`33`		`- $settings ?? ConnectionSettings::default()`
	`33`	`+ $requestFactory ?? MessageFactoryDiscovery::find()`
`34`	`34`	`);`
`35`	`35`	`}`
`36`	`36`	`}`
Original file line number	Diff line number	Diff line change
`@@ -28,8 +28,6 @@ public static function create(?UserCredentials $userCredentials = null): EventSt`
`28`	`28`	`self::checkRequiredEnvironmentSettings();`
`29`	`29`
`30`	`30`	`return EventStoreConnectionFactory::create(`
`31`		`- null,`
`32`		`- null,`
`33`	`31`	`self::settings($userCredentials)`
`34`	`32`	`);`
`35`	`33`	`}`
Original file line number	Diff line number	Diff line change
`@@ -46,8 +46,6 @@ class persistent_subscription_manager extends TestCase`
`46`	`46`	`protected function setUp(): void`
`47`	`47`	`{`
`48`	`48`	`$this->manager = PersistentSubscriptionsManagerFactory::create(`
`49`		`- null,`
`50`		`- null,`
`51`	`49`	`TestConnection::settings()`
`52`	`50`	`);`
`53`	`51`	`$this->stream = Guid::generateAsHex();`
Original file line number	Diff line number	Diff line change
`@@ -26,8 +26,6 @@ abstract class TestWithNode extends TestCase`
`26`	`26`	`protected function setUp(): void`
`27`	`27`	`{`
`28`	`28`	`$this->manager = UsersManagerFactory::create(`
`29`		`- null,`
`30`		`- null,`
`31`	`29`	`TestConnection::settings()`
`32`	`30`	`);`
`33`	`31`	`}`
Original file line number	Diff line number	Diff line change
`@@ -56,8 +56,6 @@ public function list_all_users_works(): void`
`56`	`56`	`public function list_all_users_falls_back_to_default_credentials(): void`
`57`	`57`	`{`
`58`	`58`	`$manager = UsersManagerFactory::create(`
`59`		`- null,`
`60`		`- null,`
`61`	`59`	`TestConnection::settings()`
`62`	`60`	`);`
`63`	`61`
Original file line number	Diff line number	Diff line change
`@@ -26,8 +26,6 @@ final class connection_factory_can extends TestCase`
`26`	`26`	`public function create_from_settings_and_discover_client_and_request_factory(): void`
`27`	`27`	`{`
`28`	`28`	`$conn = Factory::create(`
`29`		`- null,`
`30`		`- null,`
`31`	`29`	`ConnectionSettings::default()`
`32`	`30`	`);`
`33`	`31`
`@@ -43,8 +41,6 @@ public function create_from_settings_and_discover_client_and_request_factory():`
`43`	`41`	`public function create_from_connection_string(): void`
`44`	`42`	`{`
`45`	`43`	`$conn = Factory::create(`
`46`		`- null,`
`47`		`- null,`
`48`	`44`	`ConnectionString::getConnectionSettings(`
`49`	`45`	`'endpoint=foo:21345'`
`50`	`46`	`)`