9555551525

Committed 17 Jun 2024 10:16PM UTC coverage: 70.262% (-1.1%) from 71.395%

Build # 9555551525

Build Type

push

github

Committed by

prolic

Commit Message

update coveralls repo token

Run Details

3466 of 4933 relevant lines covered (70.26%)

67.7 hits per line

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

85.19

/src/ClientOperations/UpdatePersistentSubscriptionOperation.php

<?php

/**
 * This file is part of `prooph/event-store-client`.
 * (c) 2018-2024 Alexander Miertsch <kontakt@codeliner.ws>
 * (c) 2018-2024 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\EventStoreClient\ClientOperations;

use Amp\DeferredFuture;
use Google\Protobuf\Internal\Message;
use Prooph\EventStore\Common\SystemConsumerStrategy;
use Prooph\EventStore\Exception\AccessDenied;
use Prooph\EventStore\Exception\InvalidOperationException;
use Prooph\EventStore\Exception\UnexpectedOperationResult;
use Prooph\EventStore\PersistentSubscriptionSettings;
use Prooph\EventStore\PersistentSubscriptionUpdateResult;
use Prooph\EventStore\PersistentSubscriptionUpdateStatus;
use Prooph\EventStore\UserCredentials;
use Prooph\EventStoreClient\Messages\ClientMessages\UpdatePersistentSubscription;
use Prooph\EventStoreClient\Messages\ClientMessages\UpdatePersistentSubscriptionCompleted;
use Prooph\EventStoreClient\Messages\ClientMessages\UpdatePersistentSubscriptionCompleted\UpdatePersistentSubscriptionResult;
use Prooph\EventStoreClient\SystemData\InspectionDecision;
use Prooph\EventStoreClient\SystemData\InspectionResult;
use Prooph\EventStoreClient\SystemData\TcpCommand;
use Psr\Log\LoggerInterface as Logger;

/**
 * @internal
 * @extends AbstractOperation<UpdatePersistentSubscriptionCompleted, PersistentSubscriptionUpdateResult>
 */
class UpdatePersistentSubscriptionOperation extends AbstractOperation
{
    public function __construct(
        Logger $logger,
        DeferredFuture $deferred,
        private readonly string $stream,
        private readonly string $groupName,
        private readonly PersistentSubscriptionSettings $settings,
        ?UserCredentials $userCredentials
    ) {
        parent::__construct(
            $logger,
            $deferred,
            $userCredentials,
            TcpCommand::UpdatePersistentSubscription,
            TcpCommand::UpdatePersistentSubscriptionCompleted,
            UpdatePersistentSubscriptionCompleted::class
        );
    }

    protected function createRequestDto(): Message
    {
        $message = new UpdatePersistentSubscription();
        $message->setSubscriptionGroupName($this->groupName);
        $message->setEventStreamId($this->stream);
        $message->setResolveLinkTos($this->settings->resolveLinkTos());
        $message->setStartFrom($this->settings->startFrom());
        $message->setMessageTimeoutMilliseconds($this->settings->messageTimeoutMilliseconds());
        $message->setRecordStatistics($this->settings->extraStatistics());
        $message->setLiveBufferSize($this->settings->liveBufferSize());
        $message->setReadBatchSize($this->settings->readBatchSize());
        $message->setBufferSize($this->settings->bufferSize());
        $message->setMaxRetryCount($this->settings->maxRetryCount());
        $message->setPreferRoundRobin($this->settings->namedConsumerStrategy() === SystemConsumerStrategy::RoundRobin);
        $message->setCheckpointAfterTime($this->settings->checkPointAfterMilliseconds());
        $message->setCheckpointMaxCount($this->settings->maxCheckPointCount());
        $message->setCheckpointMinCount($this->settings->minCheckPointCount());
        $message->setSubscriberMaxCount($this->settings->maxSubscriberCount());
        $message->setNamedConsumerStrategy($this->settings->namedConsumerStrategy()->name);

        return $message;
    }

    /**
     * @param UpdatePersistentSubscriptionCompleted $response
     * @return InspectionResult
     */
    protected function inspectResponse(Message $response): InspectionResult
    {
        switch ($response->getResult()) {
            case UpdatePersistentSubscriptionResult::Success:
                $this->succeed($response);

                return new InspectionResult(InspectionDecision::EndOperation, 'Success');
            case UpdatePersistentSubscriptionResult::Fail:
                $this->fail(new InvalidOperationException(\sprintf(
                    'Subscription group \'%s\' on stream \'%s\' failed \'%s\'',
                    $this->groupName,
                    $this->stream,
                    $response->getReason()
                )));

                return new InspectionResult(InspectionDecision::EndOperation, 'Fail');
            case UpdatePersistentSubscriptionResult::AccessDenied:
                $this->fail(AccessDenied::toStream($this->stream));

                return new InspectionResult(InspectionDecision::EndOperation, 'AccessDenied');
            case UpdatePersistentSubscriptionResult::DoesNotExist:
                $this->fail(new InvalidOperationException(\sprintf(
                    'Subscription group \'%s\' on stream \'%s\' does not exist',
                    $this->groupName,
                    $this->stream
                )));

                return new InspectionResult(InspectionDecision::EndOperation, 'DoesNotExist');
            default:
                throw new UnexpectedOperationResult();
        }
    }

    /**
     * @param UpdatePersistentSubscriptionCompleted $response
     * @return PersistentSubscriptionUpdateResult
     */
    protected function transformResponse(Message $response): PersistentSubscriptionUpdateResult
    {
        return new PersistentSubscriptionUpdateResult(
            PersistentSubscriptionUpdateStatus::Success
        );
    }

    public function name(): string
    {
        return 'UpdatePersistentSubscription';
    }

    public function __toString(): string
    {
        return \sprintf('Stream: %s, Group Name: %s', $this->stream, $this->groupName);
    }
}

1	<?php
2
3	/**
4	* This file is part of `prooph/event-store-client`.
5	* (c) 2018-2024 Alexander Miertsch <kontakt@codeliner.ws>
6	* (c) 2018-2024 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\EventStoreClient\ClientOperations;
15
16	use Amp\DeferredFuture;
17	use Google\Protobuf\Internal\Message;
18	use Prooph\EventStore\Common\SystemConsumerStrategy;
19	use Prooph\EventStore\Exception\AccessDenied;
20	use Prooph\EventStore\Exception\InvalidOperationException;
21	use Prooph\EventStore\Exception\UnexpectedOperationResult;
22	use Prooph\EventStore\PersistentSubscriptionSettings;
23	use Prooph\EventStore\PersistentSubscriptionUpdateResult;
24	use Prooph\EventStore\PersistentSubscriptionUpdateStatus;
25	use Prooph\EventStore\UserCredentials;
26	use Prooph\EventStoreClient\Messages\ClientMessages\UpdatePersistentSubscription;
27	use Prooph\EventStoreClient\Messages\ClientMessages\UpdatePersistentSubscriptionCompleted;
28	use Prooph\EventStoreClient\Messages\ClientMessages\UpdatePersistentSubscriptionCompleted\UpdatePersistentSubscriptionResult;
29	use Prooph\EventStoreClient\SystemData\InspectionDecision;
30	use Prooph\EventStoreClient\SystemData\InspectionResult;
31	use Prooph\EventStoreClient\SystemData\TcpCommand;
32	use Psr\Log\LoggerInterface as Logger;
33
34	/**
35	* @internal
36	* @extends AbstractOperation<UpdatePersistentSubscriptionCompleted, PersistentSubscriptionUpdateResult>
37	*/
38	class UpdatePersistentSubscriptionOperation extends AbstractOperation
39	{
40	public function __construct(
41	Logger $logger,
42	DeferredFuture $deferred,
43	private readonly string $stream,
44	private readonly string $groupName,
45	private readonly PersistentSubscriptionSettings $settings,
46	?UserCredentials $userCredentials
47	) {
48	parent::__construct(	5✔
49	$logger,	5✔
50	$deferred,	5✔
51	$userCredentials,	5✔
52	TcpCommand::UpdatePersistentSubscription,	5✔
53	TcpCommand::UpdatePersistentSubscriptionCompleted,	5✔
54	UpdatePersistentSubscriptionCompleted::class	5✔
55	);	5✔
56	}
57
58	protected function createRequestDto(): Message
59	{
60	$message = new UpdatePersistentSubscription();	5✔
61	$message->setSubscriptionGroupName($this->groupName);	5✔
62	$message->setEventStreamId($this->stream);	5✔
63	$message->setResolveLinkTos($this->settings->resolveLinkTos());	5✔
64	$message->setStartFrom($this->settings->startFrom());	5✔
65	$message->setMessageTimeoutMilliseconds($this->settings->messageTimeoutMilliseconds());	5✔
66	$message->setRecordStatistics($this->settings->extraStatistics());	5✔
67	$message->setLiveBufferSize($this->settings->liveBufferSize());	5✔
68	$message->setReadBatchSize($this->settings->readBatchSize());	5✔
69	$message->setBufferSize($this->settings->bufferSize());	5✔
70	$message->setMaxRetryCount($this->settings->maxRetryCount());	5✔
71	$message->setPreferRoundRobin($this->settings->namedConsumerStrategy() === SystemConsumerStrategy::RoundRobin);	5✔
72	$message->setCheckpointAfterTime($this->settings->checkPointAfterMilliseconds());	5✔
73	$message->setCheckpointMaxCount($this->settings->maxCheckPointCount());	5✔
74	$message->setCheckpointMinCount($this->settings->minCheckPointCount());	5✔
75	$message->setSubscriberMaxCount($this->settings->maxSubscriberCount());	5✔
76	$message->setNamedConsumerStrategy($this->settings->namedConsumerStrategy()->name);	5✔
77
78	return $message;	5✔
79	}
80
81	/**
82	* @param UpdatePersistentSubscriptionCompleted $response
83	* @return InspectionResult
84	*/
85	protected function inspectResponse(Message $response): InspectionResult
86	{
87	switch ($response->getResult()) {	5✔
88	case UpdatePersistentSubscriptionResult::Success:	5✔
89	$this->succeed($response);	3✔
90
91	return new InspectionResult(InspectionDecision::EndOperation, 'Success');	3✔
92	case UpdatePersistentSubscriptionResult::Fail:	2✔
93	$this->fail(new InvalidOperationException(\sprintf(	×
94	'Subscription group \'%s\' on stream \'%s\' failed \'%s\'',	×
95	$this->groupName,	×
96	$this->stream,	×
97	$response->getReason()	×
98	)));	×
99
100	return new InspectionResult(InspectionDecision::EndOperation, 'Fail');	×
101	case UpdatePersistentSubscriptionResult::AccessDenied:	2✔
102	$this->fail(AccessDenied::toStream($this->stream));	1✔
103
104	return new InspectionResult(InspectionDecision::EndOperation, 'AccessDenied');	1✔
105	case UpdatePersistentSubscriptionResult::DoesNotExist:	1✔
106	$this->fail(new InvalidOperationException(\sprintf(	1✔
107	'Subscription group \'%s\' on stream \'%s\' does not exist',	1✔
108	$this->groupName,	1✔
109	$this->stream	1✔
110	)));	1✔
111
112	return new InspectionResult(InspectionDecision::EndOperation, 'DoesNotExist');	1✔
113	default:
114	throw new UnexpectedOperationResult();	×
115	}
116	}
117
118	/**
119	* @param UpdatePersistentSubscriptionCompleted $response
120	* @return PersistentSubscriptionUpdateResult
121	*/
122	protected function transformResponse(Message $response): PersistentSubscriptionUpdateResult
123	{
124	return new PersistentSubscriptionUpdateResult(	3✔
125	PersistentSubscriptionUpdateStatus::Success	3✔
126	);	3✔
127	}
128
129	public function name(): string
130	{
131	return 'UpdatePersistentSubscription';	5✔
132	}
133
134	public function __toString(): string
135	{
136	return \sprintf('Stream: %s, Group Name: %s', $this->stream, $this->groupName);	5✔
137	}
138	}

prooph / event-store-client / 9555551525

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