@@ 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 |