prooph / event-store-http-client / 106

pending completion

Build # 106

Build Type

Pull #51

travis-ci-com

Committed by

web-flow

Commit Message

<a href="https://github.com/prooph/event-store-http-client/commit/<a class=hub.com/prooph/event-store-http-client/commit/<a class="double-link" href="https://git"><a class=hub.com/prooph/event-store-http-client/commit/<a class="double-link" href="https://git"><a class=hub.com/prooph/event-store-http-client/commit/0fe5ec722d9cecfba3d950957b94ab90827fbcc4">0fe5ec722">&lt;a href=&quot;https://github.com/prooph/event-store-http-client/commit/</a><a class="double-link" href="https://github.com/prooph/event-store-http-client/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/prooph/event-store-http-client/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/prooph/event-store-http-client/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/prooph/event-store-http-client/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/prooph/event-store-http-client/commit/0fe5ec722d9cecfba3d950957b94ab90827fbcc4">0fe5ec722</a><a href="https://github.com/prooph/event-store-http-client/commit/0fe5ec722d9cecfba3d950957b94ab90827fbcc4">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/prooph/event-store-http-client/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/prooph/event-store-http-client/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/prooph/event-store-http-client/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/prooph/event-store-http-client/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/prooph/event-store-http-client/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/prooph/event-store-http-client/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/prooph/event-store-http-client/commit/0fe5ec722d9cecfba3d950957b94ab90827fbcc4&quot;&gt;0fe5ec722&lt;/a&gt;&lt;a h... (continued)

Pull Request Pull Request #51: update http client to new interfaces

Run Details

71 of 71 new or added lines in 4 files covered. (100.0%)

962 of 1625 relevant lines covered (59.2%)

12.31 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

56.87

/src/Projections/ProjectionsManager.php

<?php

/**
 * This file is part of `prooph/event-store-http-client`.
 * (c) 2018-2020 Alexander Miertsch <kontakt@codeliner.ws>
 * (c) 2018-2020 Sascha-Oliver Prolic <saschaprolic@googlemail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Prooph\EventStoreHttpClient\Projections;

use Http\Message\RequestFactory;
use Prooph\EventStore\Exception\EventStoreConnectionException;
use Prooph\EventStore\Exception\InvalidArgumentException;
use Prooph\EventStore\Projections\ProjectionDetails;
use Prooph\EventStore\Projections\ProjectionsManager as SyncProjectionsManager;
use Prooph\EventStore\Projections\ProjectionStatistics;
use Prooph\EventStore\Projections\Query;
use Prooph\EventStore\Projections\State;
use Prooph\EventStore\Transport\Http\HttpStatusCode;
use Prooph\EventStore\UserCredentials;
use Prooph\EventStore\Util\Json;
use Prooph\EventStoreHttpClient\ConnectionSettings;
use Prooph\EventStoreHttpClient\Exception\ProjectionCommandConflict;
use Prooph\EventStoreHttpClient\Exception\ProjectionCommandFailed;
use Prooph\EventStoreHttpClient\Http\HttpClient;
use Psr\Http\Client\ClientInterface;
use Psr\Http\Message\ResponseInterface;
use Throwable;

class ProjectionsManager implements SyncProjectionsManager
{
    private ConnectionSettings $settings;
    private HttpClient $httpClient;

    /** @internal */
    public function __construct(
        ConnectionSettings $settings,
        ClientInterface $client,
        RequestFactory $requestFactory
    ) {
        $this->settings = $settings;

        $this->httpClient = new HttpClient(
            $client,
            $requestFactory,
            $settings,
            \sprintf(
                '%s://%s:%s',
                $settings->schema(),
                $settings->endPoint()->host(),
                $settings->endPoint()->port()
            )
        );
    }

    /**
     * Enables a projection
     */
    public function enable(string $name, ?UserCredentials $userCredentials = null): void
    {
        if ('' === $name) {
            throw new InvalidArgumentException('Name is required');
        }

        $this->sendPost(
            \sprintf(
                '/projection/%s/command/enable',
                \urlencode($name)
            ),
            '',
            $userCredentials,
            HttpStatusCode::OK
        );
    }

    /**
     * Aborts and disables a projection without writing a checkpoint
     */
    public function disable(string $name, ?UserCredentials $userCredentials = null): void
    {
        if ('' === $name) {
            throw new InvalidArgumentException('Name is required');
        }

        $this->sendPost(
            \sprintf(
                '/projection/%s/command/disable',
                \urlencode($name)
            ),
            '',
            $userCredentials,
            HttpStatusCode::OK
        );
    }

    /**
     * Disables a projection
     */
    public function abort(string $name, ?UserCredentials $userCredentials = null): void
    {
        if ('' === $name) {
            throw new InvalidArgumentException('Name is required');
        }

        $this->sendPost(
            \sprintf(
                '/projection/%s/command/abort',
                \urlencode($name)
            ),
            '',
            $userCredentials,
            HttpStatusCode::OK
        );
    }

    /**
     * Creates a one-time query
     */
    public function createOneTime(
        string $query,
        string $type = 'JS',
        ?UserCredentials $userCredentials = null
    ): void {
        if ('' === $query) {
            throw new InvalidArgumentException('Query is required');
        }

        $this->sendPost(
            \sprintf(
                '/projections/onetime?type=%s',
                $type
            ),
            $query,
            $userCredentials,
            HttpStatusCode::CREATED
        );
    }

    /**
     * Creates a one-time query
     */
    public function createTransient(
        string $name,
        string $query,
        string $type = 'JS',
        ?UserCredentials $userCredentials = null
    ): void {
        if ('' === $name) {
            throw new InvalidArgumentException('Name is required');
        }

        if ('' === $query) {
            throw new InvalidArgumentException('Query is required');
        }

        $this->sendPost(
            \sprintf(
                '/projections/transient?name=%s&type=%s',
                \urlencode($name),
                $type
            ),
            $query,
            $userCredentials,
            HttpStatusCode::CREATED
        );
    }

    /**
     * Creates a continuous projection
     */
    public function createContinuous(
        string $name,
        string $query,
        bool $trackEmittedStreams = false,
        string $type = 'JS',
        ?UserCredentials $userCredentials = null
    ): void {
        if ('' === $name) {
            throw new InvalidArgumentException('Name is required');
        }

        if ('' === $query) {
            throw new InvalidArgumentException('Query is required');
        }

        $this->sendPost(
            \sprintf(
                '/projections/continuous?name=%s&type=%s&emit=1&trackemittedstreams=%d',
                \urlencode($name),
                $type,
                (int) $trackEmittedStreams
            ),
            $query,
            $userCredentials,
            HttpStatusCode::CREATED
        );
    }

    /**
     * Lists all projections
     *
     * @return ProjectionDetails[]
     */
    public function listAll(?UserCredentials $userCredentials = null): array
    {
        $response = $this->sendGet(
            '/projections/any',
            $userCredentials,
            HttpStatusCode::OK
        );

        $data = Json::decode($response->getBody()->getContents());

        $projectionDetails = [];

        if (null === $data['projections']) {
            return $projectionDetails;
        }

        foreach ($data['projections'] as $entry) {
            $projectionDetails[] = $this->buildProjectionDetails($entry);
        }

        return $projectionDetails;
    }

    /**
     * Lists all one-time projections
     *
     * @return ProjectionDetails[]
     */
    public function listOneTime(?UserCredentials $userCredentials = null): array
    {
        $response = $this->sendGet(
            '/projections/onetime',
            $userCredentials,
            HttpStatusCode::OK
        );

        $data = Json::decode($response->getBody()->getContents());

        $projectionDetails = [];

        if (null === $data['projections']) {
            return $projectionDetails;
        }

        foreach ($data['projections'] as $entry) {
            $projectionDetails[] = $this->buildProjectionDetails($entry);
        }

        return $projectionDetails;
    }

    /**
     * Lists this status of all continuous projections
     *
     * @return ProjectionDetails[]
     */
    public function listContinuous(?UserCredentials $userCredentials = null): array
    {
        $response = $this->sendGet(
            '/projections/continuous',
            $userCredentials,
            HttpStatusCode::OK
        );

        $data = Json::decode($response->getBody()->getContents());

        $projectionDetails = [];

        if (null === $data['projections']) {
            return $projectionDetails;
        }

        foreach ($data['projections'] as $entry) {
            $projectionDetails[] = $this->buildProjectionDetails($entry);
        }

        return $projectionDetails;
    }

    /**
     * Returns String of JSON containing projection status
     */
    public function getStatus(string $name, ?UserCredentials $userCredentials = null): ProjectionDetails
    {
        if ('' === $name) {
            throw new InvalidArgumentException('Name is required');
        }

        return $this->buildProjectionDetails(
            Json::decode(
                $this->sendGet(
                    \sprintf(
                        '/projection/%s',
                        \urlencode($name)
                    ),
                    $userCredentials,
                    HttpStatusCode::OK
                )->getBody()->getContents()
            )
        );
    }

    /**
     * Returns String of JSON containing projection state
     */
    public function getState(string $name, ?UserCredentials $userCredentials = null): State
    {
        if ('' === $name) {
            throw new InvalidArgumentException('Name is required');
        }

        return new State(
            $this->sendGet(
                \sprintf(
                    '/projection/%s/state',
                    \urlencode($name)
                ),
                $userCredentials,
                HttpStatusCode::OK
            )->getBody()->getContents()
        );
    }

    /**
     * Returns String of JSON containing projection state
     */
    public function getPartitionState(
        string $name,
        string $partition,
        ?UserCredentials $userCredentials = null
    ): State {
        if ('' === $name) {
            throw new InvalidArgumentException('Name is required');
        }

        if ('' === $partition) {
            throw new InvalidArgumentException('Partition is required');
        }

        return new State(
            $this->sendGet(
                \sprintf(
                    '/projection/%s/state?partition=%s',
                    \urlencode($name),
                    \urlencode($partition)
                ),
                $userCredentials,
                HttpStatusCode::OK
            )->getBody()->getContents()
        );
    }

    public function getResult(string $name, ?UserCredentials $userCredentials = null): State
    {
        if ('' === $name) {
            throw new InvalidArgumentException('Name is required');
        }

        return new State(
            $this->sendGet(
                \sprintf(
                    '/projection/%s/result',
                    \urlencode($name)
                ),
                $userCredentials,
                HttpStatusCode::OK
            )->getBody()->getContents()
        );
    }

    public function getPartitionResult(
        string $name,
        string $partition,
        ?UserCredentials $userCredentials = null
    ): State {
        if ('' === $name) {
            throw new InvalidArgumentException('Name is required');
        }

        if ('' === $partition) {
            throw new InvalidArgumentException('Partition is required');
        }

        return new State(
            $this->sendGet(
                \sprintf(
                    '/projection/%s/result?partition=%s',
                    \urlencode($name),
                    \urlencode($partition)
                ),
                $userCredentials,
                HttpStatusCode::OK
            )->getBody()->getContents()
        );
    }

    public function getStatistics(string $name, ?UserCredentials $userCredentials = null): ProjectionStatistics
    {
        if ('' === $name) {
            throw new InvalidArgumentException('Name is required');
        }

        return new ProjectionStatistics(
            \json_decode(
                $this->sendGet(
                    \sprintf(
                        '/projection/%s/statistics',
                        \urlencode($name)
                    ),
                    $userCredentials,
                    HttpStatusCode::OK
                )->getBody()->getContents()
            )
        );
    }

    public function getQuery(string $name, ?UserCredentials $userCredentials = null): Query
    {
        if ('' === $name) {
            throw new InvalidArgumentException('Name is required');
        }

        return new Query(
            $this->sendGet(
                \sprintf(
                    '/projection/%s/query',
                    \urlencode($name)
                ),
                $userCredentials,
                HttpStatusCode::OK
            )->getBody()->getContents()
        );
    }

    public function updateQuery(
        string $name,
        string $query,
        ?bool $emitEnabled = false,
        ?UserCredentials $userCredentials = null
    ): void {
        if ('' === $name) {
            throw new InvalidArgumentException('Name is required');
        }

        if ('' === $query) {
            throw new InvalidArgumentException('Query is required');
        }

        $emit = '';

        if (null !== $emitEnabled) {
            $emit = '?emit=' . (string) (int) $emitEnabled;
        }

        $this->sendPut(
            \sprintf(
                '/projection/%s/query' . $emit,
                \urlencode($name)
            ),
            $query,
            $userCredentials,
            HttpStatusCode::OK
        );
    }

    public function delete(
        string $name,
        bool $deleteEmittedStreams = false,
        ?UserCredentials $userCredentials = null
    ): void {
        if ('' === $name) {
            throw new InvalidArgumentException('Name is required');
        }

        $this->sendDelete(
            \sprintf(
                '/projection/%s?deleteEmittedStreams=%d',
                \urlencode($name),
                (int) $deleteEmittedStreams
            ),
            $userCredentials,
            HttpStatusCode::OK
        );
    }

    public function reset(string $name, ?UserCredentials $userCredentials = null): void
    {
        if ('' === $name) {
            throw new InvalidArgumentException('Name is required');
        }

        $this->sendPost(
            \sprintf(
                '/projection/%s/command/reset',
                \urlencode($name)
            ),
            '',
            $userCredentials,
            HttpStatusCode::OK
        );
    }

    private function buildProjectionDetails(array $entry): ProjectionDetails
    {
        return new ProjectionDetails(
            $entry['coreProcessingTime'],
            $entry['version'],
            $entry['epoch'],
            $entry['effectiveName'],
            $entry['writesInProgress'],
            $entry['readsInProgress'],
            $entry['partitionsCached'],
            $entry['status'],
            $entry['stateReason'] ?? '',
            $entry['name'],
            $entry['mode'],
            $entry['position'],
            $entry['progress'],
            $entry['lastCheckpoint'] ?? '',
            $entry['eventsProcessedAfterRestart'],
            $entry['statusUrl'],
            $entry['stateUrl'],
            $entry['resultUrl'],
            $entry['queryUrl'],
            $entry['enableCommandUrl'],
            $entry['disableCommandUrl'],
            $entry['checkpointStatus'] ?? '',
            $entry['bufferedEvents'],
            $entry['writePendingEventsBeforeCheckpoint'],
            $entry['writePendingEventsAfterCheckpoint']
        );
    }

    private function sendGet(
        string $uri,
        ?UserCredentials $userCredentials,
        int $expectedCode
    ): ResponseInterface {
        $response = $this->httpClient->get(
            $uri,
            [],
            $userCredentials,
            static function (Throwable $e) {
                throw new EventStoreConnectionException($e->getMessage());
            }
        );

        if ($response->getStatusCode() !== $expectedCode) {
            throw new ProjectionCommandFailed(
                $response->getStatusCode(),
                \sprintf(
                    'Server returned %d (%s) for GET on %s',
                    $response->getStatusCode(),
                    $response->getReasonPhrase(),
                    $uri
                )
            );
        }

        return $response;
    }

    private function sendDelete(
        string $uri,
        ?UserCredentials $userCredentials,
        int $expectedCode
    ): void {
        $response = $this->httpClient->delete(
            $uri,
            [],
            $userCredentials,
            static function (Throwable $e) {
                throw new EventStoreConnectionException($e->getMessage());
            }
        );

        if ($response->getStatusCode() !== $expectedCode) {
            throw new ProjectionCommandFailed(
                $response->getStatusCode(),
                \sprintf(
                    'Server returned %d (%s) for DELETE on %s',
                    $response->getStatusCode(),
                    $response->getReasonPhrase(),
                    $uri
                )
            );
        }
    }

    private function sendPut(
        string $uri,
        string $content,
        ?UserCredentials $userCredentials,
        int $expectedCode
    ): void {
        $response = $this->httpClient->put(
            $uri,
            ['Content-Type' => 'application/json'],
            $content,
            $userCredentials,
            static function (Throwable $e) {
                throw new EventStoreConnectionException($e->getMessage());
            }
        );

        if ($response->getStatusCode() !== $expectedCode) {
            throw new ProjectionCommandFailed(
                $response->getStatusCode(),
                \sprintf(
                    'Server returned %d (%s) for PUT on %s',
                    $response->getStatusCode(),
                    $response->getReasonPhrase(),
                    $uri
                )
            );
        }
    }

    private function sendPost(
        string $uri,
        string $content,
        ?UserCredentials $userCredentials,
        int $expectedCode
    ): void {
        $response = $this->httpClient->post(
            $uri,
            ['Content-Type' => 'application/json'],
            $content,
            $userCredentials,
            static function (Throwable $e) {
                throw new EventStoreConnectionException($e->getMessage());
            }
        );

        if ($response->getStatusCode() === HttpStatusCode::CONFLICT) {
            throw new ProjectionCommandConflict($response->getStatusCode(), $response->getReasonPhrase());
        }

        if ($response->getStatusCode() !== $expectedCode) {
            throw new ProjectionCommandFailed(
                $response->getStatusCode(),
                \sprintf(
                    'Server returned %d (%s) for POST on %s',
                    $response->getStatusCode(),
                    $response->getReasonPhrase(),
                    $uri
                )
            );
        }
    }
}

1	<?php
2
3	/**
4	* This file is part of `prooph/event-store-http-client`.
5	* (c) 2018-2020 Alexander Miertsch <kontakt@codeliner.ws>
6	* (c) 2018-2020 Sascha-Oliver Prolic <saschaprolic@googlemail.com>
7	*
8	* For the full copyright and license information, please view the LICENSE
9	* file that was distributed with this source code.
10	*/
11
12	declare(strict_types=1);
13
14	namespace Prooph\EventStoreHttpClient\Projections;
15
16	use Http\Message\RequestFactory;
17	use Prooph\EventStore\Exception\EventStoreConnectionException;
18	use Prooph\EventStore\Exception\InvalidArgumentException;
19	use Prooph\EventStore\Projections\ProjectionDetails;
20	use Prooph\EventStore\Projections\ProjectionsManager as SyncProjectionsManager;
21	use Prooph\EventStore\Projections\ProjectionStatistics;
22	use Prooph\EventStore\Projections\Query;
23	use Prooph\EventStore\Projections\State;
24	use Prooph\EventStore\Transport\Http\HttpStatusCode;
25	use Prooph\EventStore\UserCredentials;
26	use Prooph\EventStore\Util\Json;
27	use Prooph\EventStoreHttpClient\ConnectionSettings;
28	use Prooph\EventStoreHttpClient\Exception\ProjectionCommandConflict;
29	use Prooph\EventStoreHttpClient\Exception\ProjectionCommandFailed;
30	use Prooph\EventStoreHttpClient\Http\HttpClient;
31	use Psr\Http\Client\ClientInterface;
32	use Psr\Http\Message\ResponseInterface;
33	use Throwable;
34
35	class ProjectionsManager implements SyncProjectionsManager
36	{
37	private ConnectionSettings $settings;
38	private HttpClient $httpClient;
39
40	/** @internal */
41	public function __construct(
42	ConnectionSettings $settings,
43	ClientInterface $client,
44	RequestFactory $requestFactory
45	) {
46	$this->settings = $settings;	13✔
47
48	$this->httpClient = new HttpClient(	13✔
49	$client,
50	$requestFactory,
51	$settings,
52	\sprintf(	13✔
53	'%s://%s:%s',
54	$settings->schema(),	13✔
55	$settings->endPoint()->host(),	13✔
56	$settings->endPoint()->port()	13✔
57	)
58	);
59	}	13✔
60
61	/**
62	* Enables a projection
63	*/
64	public function enable(string $name, ?UserCredentials $userCredentials = null): void
65	{
66	if ('' === $name) {	1✔
67	throw new InvalidArgumentException('Name is required');	×
68	}
69
70	$this->sendPost(	1✔
71	\sprintf(	1✔
72	'/projection/%s/command/enable',
73	\urlencode($name)	1✔
74	),
75	'',	1✔
76	$userCredentials,
77	HttpStatusCode::OK	1✔
78	);
79	}	1✔
80
81	/**
82	* Aborts and disables a projection without writing a checkpoint
83	*/
84	public function disable(string $name, ?UserCredentials $userCredentials = null): void
85	{
86	if ('' === $name) {	2✔
87	throw new InvalidArgumentException('Name is required');	×
88	}
89
90	$this->sendPost(	2✔
91	\sprintf(	2✔
92	'/projection/%s/command/disable',
93	\urlencode($name)	2✔
94	),
95	'',	2✔
96	$userCredentials,
97	HttpStatusCode::OK	2✔
98	);
99	}	2✔
100
101	/**
102	* Disables a projection
103	*/
104	public function abort(string $name, ?UserCredentials $userCredentials = null): void
105	{
106	if ('' === $name) {	×
107	throw new InvalidArgumentException('Name is required');	×
108	}
109
110	$this->sendPost(	×
111	\sprintf(	×
112	'/projection/%s/command/abort',
113	\urlencode($name)	×
114	),
115	'',	×
116	$userCredentials,
117	HttpStatusCode::OK	×
118	);
119	}	×
120
121	/**
122	* Creates a one-time query
123	*/
124	public function createOneTime(
125	string $query,
126	string $type = 'JS',
127	?UserCredentials $userCredentials = null
128	): void {
129	if ('' === $query) {	2✔
130	throw new InvalidArgumentException('Query is required');	×
131	}
132
133	$this->sendPost(	2✔
134	\sprintf(	2✔
135	'/projections/onetime?type=%s',
136	$type	2✔
137	),
138	$query,
139	$userCredentials,
140	HttpStatusCode::CREATED	2✔
141	);
142	}	2✔
143
144	/**
145	* Creates a one-time query
146	*/
147	public function createTransient(
148	string $name,
149	string $query,
150	string $type = 'JS',
151	?UserCredentials $userCredentials = null
152	): void {
153	if ('' === $name) {	1✔
154	throw new InvalidArgumentException('Name is required');	×
155	}
156
157	if ('' === $query) {	1✔
158	throw new InvalidArgumentException('Query is required');	×
159	}
160
161	$this->sendPost(	1✔
162	\sprintf(	1✔
163	'/projections/transient?name=%s&type=%s',
164	\urlencode($name),	1✔
165	$type	1✔
166	),
167	$query,
168	$userCredentials,
169	HttpStatusCode::CREATED	1✔
170	);
171	}	1✔
172
173	/**
174	* Creates a continuous projection
175	*/
176	public function createContinuous(
177	string $name,
178	string $query,
179	bool $trackEmittedStreams = false,
180	string $type = 'JS',
181	?UserCredentials $userCredentials = null
182	): void {
183	if ('' === $name) {	9✔
184	throw new InvalidArgumentException('Name is required');	×
185	}
186
187	if ('' === $query) {	9✔
188	throw new InvalidArgumentException('Query is required');	×
189	}
190
191	$this->sendPost(	9✔
192	\sprintf(	9✔
193	'/projections/continuous?name=%s&type=%s&emit=1&trackemittedstreams=%d',
194	\urlencode($name),	9✔
195	$type,	9✔
196	(int) $trackEmittedStreams	9✔
197	),
198	$query,
199	$userCredentials,
200	HttpStatusCode::CREATED	9✔
201	);
202	}	9✔
203
204	/**
205	* Lists all projections
206	*
207	* @return ProjectionDetails[]
208	*/
209	public function listAll(?UserCredentials $userCredentials = null): array
210	{
211	$response = $this->sendGet(	1✔
212	'/projections/any',	1✔
213	$userCredentials,
214	HttpStatusCode::OK	1✔
215	);
216
217	$data = Json::decode($response->getBody()->getContents());	1✔
218
219	$projectionDetails = [];	1✔
220
221	if (null === $data['projections']) {	1✔
222	return $projectionDetails;	×
223	}
224
225	foreach ($data['projections'] as $entry) {	1✔
226	$projectionDetails[] = $this->buildProjectionDetails($entry);	1✔
227	}
228
229	return $projectionDetails;	1✔
230	}
231
232	/**
233	* Lists all one-time projections
234	*
235	* @return ProjectionDetails[]
236	*/
237	public function listOneTime(?UserCredentials $userCredentials = null): array
238	{
239	$response = $this->sendGet(	2✔
240	'/projections/onetime',	2✔
241	$userCredentials,
242	HttpStatusCode::OK	2✔
243	);
244
245	$data = Json::decode($response->getBody()->getContents());	2✔
246
247	$projectionDetails = [];	2✔
248
249	if (null === $data['projections']) {	2✔
250	return $projectionDetails;	×
251	}
252
253	foreach ($data['projections'] as $entry) {	2✔
254	$projectionDetails[] = $this->buildProjectionDetails($entry);	2✔
255	}
256
257	return $projectionDetails;	2✔
258	}
259
260	/**
261	* Lists this status of all continuous projections
262	*
263	* @return ProjectionDetails[]
264	*/
265	public function listContinuous(?UserCredentials $userCredentials = null): array
266	{
267	$response = $this->sendGet(	3✔
268	'/projections/continuous',	3✔
269	$userCredentials,
270	HttpStatusCode::OK	3✔
271	);
272
273	$data = Json::decode($response->getBody()->getContents());	3✔
274
275	$projectionDetails = [];	3✔
276
277	if (null === $data['projections']) {	3✔
278	return $projectionDetails;	×
279	}
280
281	foreach ($data['projections'] as $entry) {	3✔
282	$projectionDetails[] = $this->buildProjectionDetails($entry);	3✔
283	}
284
285	return $projectionDetails;	3✔
286	}
287
288	/**
289	* Returns String of JSON containing projection status
290	*/
291	public function getStatus(string $name, ?UserCredentials $userCredentials = null): ProjectionDetails
292	{
293	if ('' === $name) {	4✔
294	throw new InvalidArgumentException('Name is required');	×
295	}
296
297	return $this->buildProjectionDetails(	4✔
298	Json::decode(	4✔
299	$this->sendGet(	4✔
300	\sprintf(	4✔
301	'/projection/%s',
302	\urlencode($name)	4✔
303	),
304	$userCredentials,
305	HttpStatusCode::OK	4✔
306	)->getBody()->getContents()	4✔
307	)
308	);
309	}
310
311	/**
312	* Returns String of JSON containing projection state
313	*/
314	public function getState(string $name, ?UserCredentials $userCredentials = null): State
315	{
316	if ('' === $name) {	×
317	throw new InvalidArgumentException('Name is required');	×
318	}
319
320	return new State(	×
321	$this->sendGet(	×
322	\sprintf(	×
323	'/projection/%s/state',
324	\urlencode($name)	×
325	),
326	$userCredentials,
327	HttpStatusCode::OK	×
328	)->getBody()->getContents()	×
329	);
330	}
331
332	/**
333	* Returns String of JSON containing projection state
334	*/
335	public function getPartitionState(
336	string $name,
337	string $partition,
338	?UserCredentials $userCredentials = null
339	): State {
340	if ('' === $name) {	×
341	throw new InvalidArgumentException('Name is required');	×
342	}
343
344	if ('' === $partition) {	×
345	throw new InvalidArgumentException('Partition is required');	×
346	}
347
348	return new State(	×
349	$this->sendGet(	×
350	\sprintf(	×
351	'/projection/%s/state?partition=%s',
352	\urlencode($name),	×
353	\urlencode($partition)	×
354	),
355	$userCredentials,
356	HttpStatusCode::OK	×
357	)->getBody()->getContents()	×
358	);
359	}
360
361	public function getResult(string $name, ?UserCredentials $userCredentials = null): State
362	{
363	if ('' === $name) {	×
364	throw new InvalidArgumentException('Name is required');	×
365	}
366
367	return new State(	×
368	$this->sendGet(	×
369	\sprintf(	×
370	'/projection/%s/result',
371	\urlencode($name)	×
372	),
373	$userCredentials,
374	HttpStatusCode::OK	×
375	)->getBody()->getContents()	×
376	);
377	}
378
379	public function getPartitionResult(
380	string $name,
381	string $partition,
382	?UserCredentials $userCredentials = null
383	): State {
384	if ('' === $name) {	×
385	throw new InvalidArgumentException('Name is required');	×
386	}
387
388	if ('' === $partition) {	×
389	throw new InvalidArgumentException('Partition is required');	×
390	}
391
392	return new State(	×
393	$this->sendGet(	×
394	\sprintf(	×
395	'/projection/%s/result?partition=%s',
396	\urlencode($name),	×
397	\urlencode($partition)	×
398	),
399	$userCredentials,
400	HttpStatusCode::OK	×
401	)->getBody()->getContents()	×
402	);
403	}
404
405	public function getStatistics(string $name, ?UserCredentials $userCredentials = null): ProjectionStatistics
406	{
407	if ('' === $name) {	×
408	throw new InvalidArgumentException('Name is required');	×
409	}
410
411	return new ProjectionStatistics(	×
412	\json_decode(	×
413	$this->sendGet(	×
414	\sprintf(	×
415	'/projection/%s/statistics',
416	\urlencode($name)	×
417	),
418	$userCredentials,
419	HttpStatusCode::OK	×
420	)->getBody()->getContents()	×
421	)
422	);
423	}
424
425	public function getQuery(string $name, ?UserCredentials $userCredentials = null): Query
426	{
427	if ('' === $name) {	1✔
428	throw new InvalidArgumentException('Name is required');	×
429	}
430
431	return new Query(	1✔
432	$this->sendGet(	1✔
433	\sprintf(	1✔
434	'/projection/%s/query',
435	\urlencode($name)	1✔
436	),
437	$userCredentials,
438	HttpStatusCode::OK	1✔
439	)->getBody()->getContents()	1✔
440	);
441	}
442
443	public function updateQuery(
444	string $name,
445	string $query,
446	?bool $emitEnabled = false,
447	?UserCredentials $userCredentials = null
448	): void {
449	if ('' === $name) {	1✔
450	throw new InvalidArgumentException('Name is required');	×
451	}
452
453	if ('' === $query) {	1✔
454	throw new InvalidArgumentException('Query is required');	×
455	}
456
457	$emit = '';	1✔
458
459	if (null !== $emitEnabled) {	1✔
460	$emit = '?emit=' . (string) (int) $emitEnabled;	1✔
461	}
462
463	$this->sendPut(	1✔
464	\sprintf(	1✔
465	'/projection/%s/query' . $emit,	1✔
466	\urlencode($name)	1✔
467	),
468	$query,
469	$userCredentials,
470	HttpStatusCode::OK	1✔
471	);
472	}	1✔
473
474	public function delete(
475	string $name,
476	bool $deleteEmittedStreams = false,
477	?UserCredentials $userCredentials = null
478	): void {
479	if ('' === $name) {	×
480	throw new InvalidArgumentException('Name is required');	×
481	}
482
483	$this->sendDelete(	×
484	\sprintf(	×
485	'/projection/%s?deleteEmittedStreams=%d',
486	\urlencode($name),	×
487	(int) $deleteEmittedStreams	×
488	),
489	$userCredentials,
490	HttpStatusCode::OK	×
491	);
492	}	×
493
494	public function reset(string $name, ?UserCredentials $userCredentials = null): void
495	{
496	if ('' === $name) {	1✔
497	throw new InvalidArgumentException('Name is required');	×
498	}
499
500	$this->sendPost(	1✔
501	\sprintf(	1✔
502	'/projection/%s/command/reset',
503	\urlencode($name)	1✔
504	),
505	'',	1✔
506	$userCredentials,
507	HttpStatusCode::OK	1✔
508	);
509	}	1✔
510
511	private function buildProjectionDetails(array $entry): ProjectionDetails
512	{
513	return new ProjectionDetails(	10✔
514	$entry['coreProcessingTime'],	10✔
515	$entry['version'],	10✔
516	$entry['epoch'],	10✔
517	$entry['effectiveName'],	10✔
518	$entry['writesInProgress'],	10✔
519	$entry['readsInProgress'],	10✔
520	$entry['partitionsCached'],	10✔
521	$entry['status'],	10✔
522	$entry['stateReason'] ?? '',	10✔
523	$entry['name'],	10✔
524	$entry['mode'],	10✔
525	$entry['position'],	10✔
526	$entry['progress'],	10✔
527	$entry['lastCheckpoint'] ?? '',	10✔
528	$entry['eventsProcessedAfterRestart'],	10✔
529	$entry['statusUrl'],	10✔
530	$entry['stateUrl'],	10✔
531	$entry['resultUrl'],	10✔
532	$entry['queryUrl'],	10✔
533	$entry['enableCommandUrl'],	10✔
534	$entry['disableCommandUrl'],	10✔
535	$entry['checkpointStatus'] ?? '',	10✔
536	$entry['bufferedEvents'],	10✔
537	$entry['writePendingEventsBeforeCheckpoint'],	10✔
538	$entry['writePendingEventsAfterCheckpoint']	10✔
539	);
540	}
541
542	private function sendGet(
543	string $uri,
544	?UserCredentials $userCredentials,
545	int $expectedCode
546	): ResponseInterface {
547	$response = $this->httpClient->get(	11✔
548	$uri,
549	[],	11✔
550	$userCredentials,
551	static function (Throwable $e) {	11✔
552	throw new EventStoreConnectionException($e->getMessage());	×
553	}	11✔
554	);
555
556	if ($response->getStatusCode() !== $expectedCode) {	11✔
557	throw new ProjectionCommandFailed(	×
558	$response->getStatusCode(),	×
559	\sprintf(	×
560	'Server returned %d (%s) for GET on %s',
561	$response->getStatusCode(),	×
562	$response->getReasonPhrase(),	×
563	$uri	×
564	)
565	);
566	}
567
568	return $response;	11✔
569	}
570
571	private function sendDelete(
572	string $uri,
573	?UserCredentials $userCredentials,
574	int $expectedCode
575	): void {
576	$response = $this->httpClient->delete(	×
577	$uri,
578	[],	×
579	$userCredentials,
580	static function (Throwable $e) {	×
581	throw new EventStoreConnectionException($e->getMessage());	×
582	}	×
583	);
584
585	if ($response->getStatusCode() !== $expectedCode) {	×
586	throw new ProjectionCommandFailed(	×
587	$response->getStatusCode(),	×
588	\sprintf(	×
589	'Server returned %d (%s) for DELETE on %s',
590	$response->getStatusCode(),	×
591	$response->getReasonPhrase(),	×
592	$uri	×
593	)
594	);
595	}
596	}	×
597
598	private function sendPut(
599	string $uri,
600	string $content,
601	?UserCredentials $userCredentials,
602	int $expectedCode
603	): void {
604	$response = $this->httpClient->put(	1✔
605	$uri,
606	['Content-Type' => 'application/json'],	1✔
607	$content,
608	$userCredentials,
609	static function (Throwable $e) {	1✔
610	throw new EventStoreConnectionException($e->getMessage());	×
611	}	1✔
612	);
613
614	if ($response->getStatusCode() !== $expectedCode) {	1✔
615	throw new ProjectionCommandFailed(	×
616	$response->getStatusCode(),	×
617	\sprintf(	×
618	'Server returned %d (%s) for PUT on %s',
619	$response->getStatusCode(),	×
620	$response->getReasonPhrase(),	×
621	$uri	×
622	)
623	);
624	}
625	}	1✔
626
627	private function sendPost(
628	string $uri,
629	string $content,
630	?UserCredentials $userCredentials,
631	int $expectedCode
632	): void {
633	$response = $this->httpClient->post(	12✔
634	$uri,
635	['Content-Type' => 'application/json'],	12✔
636	$content,
637	$userCredentials,
638	static function (Throwable $e) {	12✔
639	throw new EventStoreConnectionException($e->getMessage());	×
640	}	12✔
641	);
642
643	if ($response->getStatusCode() === HttpStatusCode::CONFLICT) {	12✔
644	throw new ProjectionCommandConflict($response->getStatusCode(), $response->getReasonPhrase());	×
645	}
646
647	if ($response->getStatusCode() !== $expectedCode) {	12✔
648	throw new ProjectionCommandFailed(	×
649	$response->getStatusCode(),	×
650	\sprintf(	×
651	'Server returned %d (%s) for POST on %s',
652	$response->getStatusCode(),	×
653	$response->getReasonPhrase(),	×
654	$uri	×
655	)
656	);
657	}
658	}	12✔
659	}

prooph / event-store-http-client / 106

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous