| @@ 13-50 (lines=38) @@ | ||
| 10 | use React\Promise\PromiseInterface; |
|
| 11 | use function React\Promise\resolve; |
|
| 12 | ||
| 13 | final class BranchesHandler |
|
| 14 | { |
|
| 15 | /** |
|
| 16 | * @var IteratePagesService |
|
| 17 | */ |
|
| 18 | private $iteratePagesService; |
|
| 19 | ||
| 20 | /** |
|
| 21 | * @var Hydrator |
|
| 22 | */ |
|
| 23 | private $hydrator; |
|
| 24 | ||
| 25 | /** |
|
| 26 | * @param IteratePagesService $iteratePagesService |
|
| 27 | * @param Hydrator $hydrator |
|
| 28 | */ |
|
| 29 | public function __construct(IteratePagesService $iteratePagesService, Hydrator $hydrator) |
|
| 30 | { |
|
| 31 | $this->iteratePagesService = $iteratePagesService; |
|
| 32 | $this->hydrator = $hydrator; |
|
| 33 | } |
|
| 34 | ||
| 35 | /** |
|
| 36 | * @param BranchesCommand $command |
|
| 37 | * @return PromiseInterface |
|
| 38 | */ |
|
| 39 | public function handle(BranchesCommand $command): PromiseInterface |
|
| 40 | { |
|
| 41 | return resolve( |
|
| 42 | $this->iteratePagesService->iterate('repos/' . $command->getFullName() . '/branches') |
|
| 43 | ->flatMap(function ($labels) { |
|
| 44 | return observableFromArray($labels); |
|
| 45 | })->map(function ($label) { |
|
| 46 | return $this->hydrator->hydrate(BranchInterface::HYDRATE_CLASS, $label); |
|
| 47 | }) |
|
| 48 | ); |
|
| 49 | } |
|
| 50 | } |
|
| 51 | ||
| @@ 13-50 (lines=38) @@ | ||
| 10 | use React\Promise\PromiseInterface; |
|
| 11 | use function React\Promise\resolve; |
|
| 12 | ||
| 13 | final class StatusesHandler |
|
| 14 | { |
|
| 15 | /** |
|
| 16 | * @var IteratePagesService |
|
| 17 | */ |
|
| 18 | private $iteratePagesService; |
|
| 19 | ||
| 20 | /** |
|
| 21 | * @var Hydrator |
|
| 22 | */ |
|
| 23 | private $hydrator; |
|
| 24 | ||
| 25 | /** |
|
| 26 | * @param IteratePagesService $iteratePagesService |
|
| 27 | * @param Hydrator $hydrator |
|
| 28 | */ |
|
| 29 | public function __construct(IteratePagesService $iteratePagesService, Hydrator $hydrator) |
|
| 30 | { |
|
| 31 | $this->iteratePagesService = $iteratePagesService; |
|
| 32 | $this->hydrator = $hydrator; |
|
| 33 | } |
|
| 34 | ||
| 35 | /** |
|
| 36 | * @param StatusesCommand $command |
|
| 37 | * @return PromiseInterface |
|
| 38 | */ |
|
| 39 | public function handle(StatusesCommand $command): PromiseInterface |
|
| 40 | { |
|
| 41 | return resolve( |
|
| 42 | $this->iteratePagesService->iterate($command->getCommit()->url() . '/statuses') |
|
| 43 | ->flatMap(function ($statuses) { |
|
| 44 | return observableFromArray($statuses); |
|
| 45 | })->map(function ($status) { |
|
| 46 | return $this->hydrator->hydrate(StatusInterface::HYDRATE_CLASS, $status); |
|
| 47 | }) |
|
| 48 | ); |
|
| 49 | } |
|
| 50 | } |
|
| 51 | ||
| @@ 13-50 (lines=38) @@ | ||
| 10 | use React\Promise\PromiseInterface; |
|
| 11 | use function React\Promise\resolve; |
|
| 12 | ||
| 13 | final class CommitsHandler |
|
| 14 | { |
|
| 15 | /** |
|
| 16 | * @var IteratePagesService |
|
| 17 | */ |
|
| 18 | private $iteratePagesService; |
|
| 19 | ||
| 20 | /** |
|
| 21 | * @var Hydrator |
|
| 22 | */ |
|
| 23 | private $hydrator; |
|
| 24 | ||
| 25 | /** |
|
| 26 | * @param IteratePagesService $iteratePagesService |
|
| 27 | * @param Hydrator $hydrator |
|
| 28 | */ |
|
| 29 | public function __construct(IteratePagesService $iteratePagesService, Hydrator $hydrator) |
|
| 30 | { |
|
| 31 | $this->iteratePagesService = $iteratePagesService; |
|
| 32 | $this->hydrator = $hydrator; |
|
| 33 | } |
|
| 34 | ||
| 35 | /** |
|
| 36 | * @param CommitsCommand $command |
|
| 37 | * @return PromiseInterface |
|
| 38 | */ |
|
| 39 | public function handle(CommitsCommand $command): PromiseInterface |
|
| 40 | { |
|
| 41 | return resolve( |
|
| 42 | $this->iteratePagesService->iterate('repos/' . $command->getFullName() . '/commits') |
|
| 43 | ->flatMap(function ($commits) { |
|
| 44 | return observableFromArray($commits); |
|
| 45 | })->map(function ($commit) { |
|
| 46 | return $this->hydrator->hydrate(CommitInterface::HYDRATE_CLASS, $commit); |
|
| 47 | }) |
|
| 48 | ); |
|
| 49 | } |
|
| 50 | } |
|
| 51 | ||
| @@ 13-50 (lines=38) @@ | ||
| 10 | use React\Promise\PromiseInterface; |
|
| 11 | use function React\Promise\resolve; |
|
| 12 | ||
| 13 | final class LabelsHandler |
|
| 14 | { |
|
| 15 | /** |
|
| 16 | * @var IteratePagesService |
|
| 17 | */ |
|
| 18 | private $iteratePagesService; |
|
| 19 | ||
| 20 | /** |
|
| 21 | * @var Hydrator |
|
| 22 | */ |
|
| 23 | private $hydrator; |
|
| 24 | ||
| 25 | /** |
|
| 26 | * @param IteratePagesService $iteratePagesService |
|
| 27 | * @param Hydrator $hydrator |
|
| 28 | */ |
|
| 29 | public function __construct(IteratePagesService $iteratePagesService, Hydrator $hydrator) |
|
| 30 | { |
|
| 31 | $this->iteratePagesService = $iteratePagesService; |
|
| 32 | $this->hydrator = $hydrator; |
|
| 33 | } |
|
| 34 | ||
| 35 | /** |
|
| 36 | * @param LabelsCommand $command |
|
| 37 | * @return PromiseInterface |
|
| 38 | */ |
|
| 39 | public function handle(LabelsCommand $command): PromiseInterface |
|
| 40 | { |
|
| 41 | return resolve( |
|
| 42 | $this->iteratePagesService->iterate('repos/' . $command->getFullName() . '/labels') |
|
| 43 | ->flatMap(function ($labels) { |
|
| 44 | return observableFromArray($labels); |
|
| 45 | })->map(function ($label) { |
|
| 46 | return $this->hydrator->hydrate(LabelInterface::HYDRATE_CLASS, $label); |
|
| 47 | }) |
|
| 48 | ); |
|
| 49 | } |
|
| 50 | } |
|
| 51 | ||
| @@ 14-51 (lines=38) @@ | ||
| 11 | use React\Promise\PromiseInterface; |
|
| 12 | use function React\Promise\resolve; |
|
| 13 | ||
| 14 | final class ReleasesHandler |
|
| 15 | { |
|
| 16 | /** |
|
| 17 | * @var IteratePagesService |
|
| 18 | */ |
|
| 19 | private $iteratePagesService; |
|
| 20 | ||
| 21 | /** |
|
| 22 | * @var Hydrator |
|
| 23 | */ |
|
| 24 | private $hydrator; |
|
| 25 | ||
| 26 | /** |
|
| 27 | * @param IteratePagesService $iteratePagesService |
|
| 28 | * @param Hydrator $hydrator |
|
| 29 | */ |
|
| 30 | public function __construct(IteratePagesService $iteratePagesService, Hydrator $hydrator) |
|
| 31 | { |
|
| 32 | $this->iteratePagesService = $iteratePagesService; |
|
| 33 | $this->hydrator = $hydrator; |
|
| 34 | } |
|
| 35 | ||
| 36 | /** |
|
| 37 | * @param TagsCommand $command |
|
| 38 | * @return PromiseInterface |
|
| 39 | */ |
|
| 40 | public function handle(ReleasesCommand $command): PromiseInterface |
|
| 41 | { |
|
| 42 | return resolve( |
|
| 43 | $this->iteratePagesService->iterate('repos/' . $command->getFullName() . '/releases') |
|
| 44 | ->flatMap(function ($labels) { |
|
| 45 | return observableFromArray($labels); |
|
| 46 | })->map(function ($label) { |
|
| 47 | return $this->hydrator->hydrate(ReleaseInterface::HYDRATE_CLASS, $label); |
|
| 48 | }) |
|
| 49 | ); |
|
| 50 | } |
|
| 51 | } |
|
| 52 | ||
| @@ 13-50 (lines=38) @@ | ||
| 10 | use React\Promise\PromiseInterface; |
|
| 11 | use function React\Promise\resolve; |
|
| 12 | ||
| 13 | final class TagsHandler |
|
| 14 | { |
|
| 15 | /** |
|
| 16 | * @var IteratePagesService |
|
| 17 | */ |
|
| 18 | private $iteratePagesService; |
|
| 19 | ||
| 20 | /** |
|
| 21 | * @var Hydrator |
|
| 22 | */ |
|
| 23 | private $hydrator; |
|
| 24 | ||
| 25 | /** |
|
| 26 | * @param IteratePagesService $iteratePagesService |
|
| 27 | * @param Hydrator $hydrator |
|
| 28 | */ |
|
| 29 | public function __construct(IteratePagesService $iteratePagesService, Hydrator $hydrator) |
|
| 30 | { |
|
| 31 | $this->iteratePagesService = $iteratePagesService; |
|
| 32 | $this->hydrator = $hydrator; |
|
| 33 | } |
|
| 34 | ||
| 35 | /** |
|
| 36 | * @param TagsCommand $command |
|
| 37 | * @return PromiseInterface |
|
| 38 | */ |
|
| 39 | public function handle(TagsCommand $command): PromiseInterface |
|
| 40 | { |
|
| 41 | return resolve( |
|
| 42 | $this->iteratePagesService->iterate('repos/' . $command->getFullName() . '/tags') |
|
| 43 | ->flatMap(function ($labels) { |
|
| 44 | return observableFromArray($labels); |
|
| 45 | })->map(function ($label) { |
|
| 46 | return $this->hydrator->hydrate(TagInterface::HYDRATE_CLASS, $label); |
|
| 47 | }) |
|
| 48 | ); |
|
| 49 | } |
|
| 50 | } |
|
| 51 | ||
| @@ 13-50 (lines=38) @@ | ||
| 10 | use React\Promise\PromiseInterface; |
|
| 11 | use function React\Promise\resolve; |
|
| 12 | ||
| 13 | final class EventsHandler |
|
| 14 | { |
|
| 15 | /** |
|
| 16 | * @var IteratePagesService |
|
| 17 | */ |
|
| 18 | private $service; |
|
| 19 | ||
| 20 | /** |
|
| 21 | * @var Hydrator |
|
| 22 | */ |
|
| 23 | private $hydrator; |
|
| 24 | ||
| 25 | /** |
|
| 26 | * @param IteratePagesService $service |
|
| 27 | * @param Hydrator $hydrator |
|
| 28 | */ |
|
| 29 | public function __construct(IteratePagesService $service, Hydrator $hydrator) |
|
| 30 | { |
|
| 31 | $this->service = $service; |
|
| 32 | $this->hydrator = $hydrator; |
|
| 33 | } |
|
| 34 | ||
| 35 | /** |
|
| 36 | * @param EventsCommand $command |
|
| 37 | * @return PromiseInterface |
|
| 38 | */ |
|
| 39 | public function handle(EventsCommand $command): PromiseInterface |
|
| 40 | { |
|
| 41 | return resolve( |
|
| 42 | $this->service->iterate('users/' . $command->getLogin() . '/events') |
|
| 43 | ->flatMap(function ($events) { |
|
| 44 | return observableFromArray($events); |
|
| 45 | })->map(function ($event) { |
|
| 46 | return $this->hydrator->hydrate(EventInterface::HYDRATE_CLASS, $event); |
|
| 47 | }) |
|
| 48 | ); |
|
| 49 | } |
|
| 50 | } |
|
| 51 | ||
| @@ 13-50 (lines=38) @@ | ||
| 10 | use React\Promise\PromiseInterface; |
|
| 11 | use function React\Promise\resolve; |
|
| 12 | ||
| 13 | final class OrganizationsHandler |
|
| 14 | { |
|
| 15 | /** |
|
| 16 | * @var IteratePagesService |
|
| 17 | */ |
|
| 18 | private $service; |
|
| 19 | ||
| 20 | /** |
|
| 21 | * @var Hydrator |
|
| 22 | */ |
|
| 23 | private $hydrator; |
|
| 24 | ||
| 25 | /** |
|
| 26 | * @param IteratePagesService $service |
|
| 27 | * @param Hydrator $hydrator |
|
| 28 | */ |
|
| 29 | public function __construct(IteratePagesService $service, Hydrator $hydrator) |
|
| 30 | { |
|
| 31 | $this->service = $service; |
|
| 32 | $this->hydrator = $hydrator; |
|
| 33 | } |
|
| 34 | ||
| 35 | /** |
|
| 36 | * @param OrganizationsCommand $command |
|
| 37 | * @return PromiseInterface |
|
| 38 | */ |
|
| 39 | public function handle(OrganizationsCommand $command): PromiseInterface |
|
| 40 | { |
|
| 41 | return resolve( |
|
| 42 | $this->service->iterate('users/' . $command->getLogin() . '/orgs') |
|
| 43 | ->flatMap(function ($organizations) { |
|
| 44 | return observableFromArray($organizations); |
|
| 45 | })->map(function ($organization) { |
|
| 46 | return $this->hydrator->hydrate(OrganizationInterface::HYDRATE_CLASS, $organization); |
|
| 47 | }) |
|
| 48 | ); |
|
| 49 | } |
|
| 50 | } |
|
| 51 | ||
| @@ 13-52 (lines=40) @@ | ||
| 10 | use React\Promise\PromiseInterface; |
|
| 11 | use function React\Promise\resolve; |
|
| 12 | ||
| 13 | final class RepositoriesHandler |
|
| 14 | { |
|
| 15 | /** |
|
| 16 | * @var IteratePagesService |
|
| 17 | */ |
|
| 18 | private $iteratePagesService; |
|
| 19 | ||
| 20 | /** |
|
| 21 | * @var Hydrator |
|
| 22 | */ |
|
| 23 | private $hydrator; |
|
| 24 | ||
| 25 | /** |
|
| 26 | * @param IteratePagesService $iteratePagesService |
|
| 27 | * @param Hydrator $hydrator |
|
| 28 | */ |
|
| 29 | public function __construct(IteratePagesService $iteratePagesService, Hydrator $hydrator) |
|
| 30 | { |
|
| 31 | $this->iteratePagesService = $iteratePagesService; |
|
| 32 | $this->hydrator = $hydrator; |
|
| 33 | } |
|
| 34 | ||
| 35 | /** |
|
| 36 | * Fetch the given repository and hydrate it. |
|
| 37 | * |
|
| 38 | * @param RepositoriesCommand $command |
|
| 39 | * @return PromiseInterface |
|
| 40 | */ |
|
| 41 | public function handle(RepositoriesCommand $command): PromiseInterface |
|
| 42 | { |
|
| 43 | return resolve( |
|
| 44 | $this->iteratePagesService->iterate('users/' . $command->getLogin() . '/repos') |
|
| 45 | ->flatMap(function ($repositories) { |
|
| 46 | return observableFromArray($repositories); |
|
| 47 | })->map(function ($repository) { |
|
| 48 | return $this->hydrator->hydrate(RepositoryInterface::HYDRATE_CLASS, $repository); |
|
| 49 | }) |
|
| 50 | ); |
|
| 51 | } |
|
| 52 | } |
|
| 53 | ||
| @@ 13-50 (lines=38) @@ | ||
| 10 | use React\Promise\PromiseInterface; |
|
| 11 | use function React\Promise\resolve; |
|
| 12 | ||
| 13 | final class WebHooksHandler |
|
| 14 | { |
|
| 15 | /** |
|
| 16 | * @var IteratePagesService |
|
| 17 | */ |
|
| 18 | private $iteratePagesService; |
|
| 19 | ||
| 20 | /** |
|
| 21 | * @var Hydrator |
|
| 22 | */ |
|
| 23 | private $hydrator; |
|
| 24 | ||
| 25 | /** |
|
| 26 | * @param IteratePagesService $iteratePagesService |
|
| 27 | * @param Hydrator $hydrator |
|
| 28 | */ |
|
| 29 | public function __construct(IteratePagesService $iteratePagesService, Hydrator $hydrator) |
|
| 30 | { |
|
| 31 | $this->iteratePagesService = $iteratePagesService; |
|
| 32 | $this->hydrator = $hydrator; |
|
| 33 | } |
|
| 34 | ||
| 35 | /** |
|
| 36 | * @param WebHooksCommand $command |
|
| 37 | * @return PromiseInterface |
|
| 38 | */ |
|
| 39 | public function handle(WebHooksCommand $command): PromiseInterface |
|
| 40 | { |
|
| 41 | return resolve( |
|
| 42 | $this->iteratePagesService->iterate($command->getPrefix() . '/' . $command->getName() . '/hooks') |
|
| 43 | ->flatMap(function ($webHooks) { |
|
| 44 | return observableFromArray($webHooks); |
|
| 45 | })->map(function ($webHook) { |
|
| 46 | return $this->hydrator->hydrate(WebHookInterface::HYDRATE_CLASS, $webHook); |
|
| 47 | }) |
|
| 48 | ); |
|
| 49 | } |
|
| 50 | } |
|
| 51 | ||
| @@ 15-52 (lines=38) @@ | ||
| 12 | use React\Promise\PromiseInterface; |
|
| 13 | use function React\Promise\resolve; |
|
| 14 | ||
| 15 | final class MilestonesHandler |
|
| 16 | { |
|
| 17 | /** |
|
| 18 | * @var IteratePagesService |
|
| 19 | */ |
|
| 20 | private $iteratePagesService; |
|
| 21 | ||
| 22 | /** |
|
| 23 | * @var Hydrator |
|
| 24 | */ |
|
| 25 | private $hydrator; |
|
| 26 | ||
| 27 | /** |
|
| 28 | * @param IteratePagesService $iteratePagesService |
|
| 29 | * @param Hydrator $hydrator |
|
| 30 | */ |
|
| 31 | public function __construct(IteratePagesService $iteratePagesService, Hydrator $hydrator) |
|
| 32 | { |
|
| 33 | $this->iteratePagesService = $iteratePagesService; |
|
| 34 | $this->hydrator = $hydrator; |
|
| 35 | } |
|
| 36 | ||
| 37 | /** |
|
| 38 | * @param MilestonesCommand $command |
|
| 39 | * @return PromiseInterface |
|
| 40 | */ |
|
| 41 | public function handle(MilestonesCommand $command): PromiseInterface |
|
| 42 | { |
|
| 43 | return resolve( |
|
| 44 | $this->iteratePagesService->iterate('repos/' . $command->getFullName() . '/milestones') |
|
| 45 | ->flatMap(function ($milestones) { |
|
| 46 | return observableFromArray($milestones); |
|
| 47 | })->map(function ($milestone) { |
|
| 48 | return $this->hydrator->hydrate(MilestoneInterface::HYDRATE_CLASS, $milestone); |
|
| 49 | }) |
|
| 50 | ); |
|
| 51 | } |
|
| 52 | } |
|
| 53 | ||
| @@ 17-54 (lines=38) @@ | ||
| 14 | use React\Promise\PromiseInterface; |
|
| 15 | use function React\Promise\resolve; |
|
| 16 | ||
| 17 | final class PullRequestsHandler |
|
| 18 | { |
|
| 19 | /** |
|
| 20 | * @var IteratePagesService |
|
| 21 | */ |
|
| 22 | private $iteratePagesService; |
|
| 23 | ||
| 24 | /** |
|
| 25 | * @var Hydrator |
|
| 26 | */ |
|
| 27 | private $hydrator; |
|
| 28 | ||
| 29 | /** |
|
| 30 | * @param IteratePagesService $iteratePagesService |
|
| 31 | * @param Hydrator $hydrator |
|
| 32 | */ |
|
| 33 | public function __construct(IteratePagesService $iteratePagesService, Hydrator $hydrator) |
|
| 34 | { |
|
| 35 | $this->iteratePagesService = $iteratePagesService; |
|
| 36 | $this->hydrator = $hydrator; |
|
| 37 | } |
|
| 38 | ||
| 39 | /** |
|
| 40 | * @param PullRequestsCommand $command |
|
| 41 | * @return PromiseInterface |
|
| 42 | */ |
|
| 43 | public function handle(PullRequestsCommand $command): PromiseInterface |
|
| 44 | { |
|
| 45 | return resolve( |
|
| 46 | $this->iteratePagesService->iterate('repos/' . $command->getFullName() . '/pulls') |
|
| 47 | ->flatMap(function ($milestones) { |
|
| 48 | return observableFromArray($milestones); |
|
| 49 | })->map(function ($milestone) { |
|
| 50 | return $this->hydrator->hydrate(PullRequestInterface::HYDRATE_CLASS, $milestone); |
|
| 51 | }) |
|
| 52 | ); |
|
| 53 | } |
|
| 54 | } |
|
| 55 | ||