@@ 15-51 (lines=37) @@ | ||
12 | use function React\Promise\resolve; |
|
13 | use function WyriHaximus\React\futureFunctionPromise; |
|
14 | ||
15 | final class MyOrganizationsHandler |
|
16 | { |
|
17 | /** |
|
18 | * @var IteratePagesService |
|
19 | */ |
|
20 | private $service; |
|
21 | ||
22 | /** |
|
23 | * @var Hydrator |
|
24 | */ |
|
25 | private $hydrator; |
|
26 | ||
27 | /** |
|
28 | * @param IteratePagesService $service |
|
29 | * @param Hydrator $hydrator |
|
30 | */ |
|
31 | public function __construct(IteratePagesService $service, Hydrator $hydrator) |
|
32 | { |
|
33 | $this->service = $service; |
|
34 | $this->hydrator = $hydrator; |
|
35 | } |
|
36 | ||
37 | /** |
|
38 | * @param MyOrganizationsCommand $command |
|
39 | * @return PromiseInterface |
|
40 | */ |
|
41 | public function handle(MyOrganizationsCommand $command): PromiseInterface |
|
42 | { |
|
43 | return resolve( |
|
44 | $this->service->iterate('user/orgs') |
|
45 | ->flatMap(function ($organizations) { |
|
46 | return Observable::fromArray($organizations); |
|
47 | })->map(function ($organization) { |
|
48 | return $this->hydrator->hydrate(OrganizationInterface::HYDRATE_CLASS, $organization); |
|
49 | }) |
|
50 | ); |
|
51 | } |
|
52 | } |
|
53 |
@@ 15-52 (lines=38) @@ | ||
12 | use function React\Promise\resolve; |
|
13 | use function WyriHaximus\React\futureFunctionPromise; |
|
14 | ||
15 | final class BranchesHandler |
|
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 BranchesCommand $command |
|
39 | * @return PromiseInterface |
|
40 | */ |
|
41 | public function handle(BranchesCommand $command): PromiseInterface |
|
42 | { |
|
43 | return resolve( |
|
44 | $this->iteratePagesService->iterate('repos/' . $command->getFullName() . '/branches') |
|
45 | ->flatMap(function ($labels) { |
|
46 | return Observable::fromArray($labels); |
|
47 | })->map(function ($label) { |
|
48 | return $this->hydrator->hydrate(BranchInterface::HYDRATE_CLASS, $label); |
|
49 | }) |
|
50 | ); |
|
51 | } |
|
52 | } |
|
53 |
@@ 15-52 (lines=38) @@ | ||
12 | use function React\Promise\resolve; |
|
13 | use function WyriHaximus\React\futureFunctionPromise; |
|
14 | ||
15 | final class StatusesHandler |
|
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 StatusesCommand $command |
|
39 | * @return PromiseInterface |
|
40 | */ |
|
41 | public function handle(StatusesCommand $command): PromiseInterface |
|
42 | { |
|
43 | return resolve( |
|
44 | $this->iteratePagesService->iterate($command->getCommit()->url() . '/statuses') |
|
45 | ->flatMap(function ($statuses) { |
|
46 | return Observable::fromArray($statuses); |
|
47 | })->map(function ($status) { |
|
48 | return $this->hydrator->hydrate(StatusInterface::HYDRATE_CLASS, $status); |
|
49 | }) |
|
50 | ); |
|
51 | } |
|
52 | } |
|
53 |
@@ 15-52 (lines=38) @@ | ||
12 | use function React\Promise\resolve; |
|
13 | use function WyriHaximus\React\futureFunctionPromise; |
|
14 | ||
15 | final class CommitsHandler |
|
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 CommitsCommand $command |
|
39 | * @return PromiseInterface |
|
40 | */ |
|
41 | public function handle(CommitsCommand $command): PromiseInterface |
|
42 | { |
|
43 | return resolve( |
|
44 | $this->iteratePagesService->iterate('repos/' . $command->getFullName() . '/commits') |
|
45 | ->flatMap(function ($commits) { |
|
46 | return Observable::fromArray($commits); |
|
47 | })->map(function ($commit) { |
|
48 | return $this->hydrator->hydrate(CommitInterface::HYDRATE_CLASS, $commit); |
|
49 | }) |
|
50 | ); |
|
51 | } |
|
52 | } |
|
53 |
@@ 15-52 (lines=38) @@ | ||
12 | use function React\Promise\resolve; |
|
13 | use function WyriHaximus\React\futureFunctionPromise; |
|
14 | ||
15 | final class LabelsHandler |
|
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 LabelsCommand $command |
|
39 | * @return PromiseInterface |
|
40 | */ |
|
41 | public function handle(LabelsCommand $command): PromiseInterface |
|
42 | { |
|
43 | return resolve( |
|
44 | $this->iteratePagesService->iterate('repos/' . $command->getFullName() . '/labels') |
|
45 | ->flatMap(function ($labels) { |
|
46 | return Observable::fromArray($labels); |
|
47 | })->map(function ($label) { |
|
48 | return $this->hydrator->hydrate(LabelInterface::HYDRATE_CLASS, $label); |
|
49 | }) |
|
50 | ); |
|
51 | } |
|
52 | } |
|
53 |
@@ 15-51 (lines=37) @@ | ||
12 | use function React\Promise\resolve; |
|
13 | use function WyriHaximus\React\futureFunctionPromise; |
|
14 | ||
15 | final class OrganizationsHandler |
|
16 | { |
|
17 | /** |
|
18 | * @var IteratePagesService |
|
19 | */ |
|
20 | private $service; |
|
21 | ||
22 | /** |
|
23 | * @var Hydrator |
|
24 | */ |
|
25 | private $hydrator; |
|
26 | ||
27 | /** |
|
28 | * @param IteratePagesService $service |
|
29 | * @param Hydrator $hydrator |
|
30 | */ |
|
31 | public function __construct(IteratePagesService $service, Hydrator $hydrator) |
|
32 | { |
|
33 | $this->service = $service; |
|
34 | $this->hydrator = $hydrator; |
|
35 | } |
|
36 | ||
37 | /** |
|
38 | * @param OrganizationsCommand $command |
|
39 | * @return PromiseInterface |
|
40 | */ |
|
41 | public function handle(OrganizationsCommand $command): PromiseInterface |
|
42 | { |
|
43 | return resolve( |
|
44 | $this->service->iterate('users/' . $command->getLogin() . '/orgs') |
|
45 | ->flatMap(function ($organizations) { |
|
46 | return Observable::fromArray($organizations); |
|
47 | })->map(function ($organization) { |
|
48 | return $this->hydrator->hydrate(OrganizationInterface::HYDRATE_CLASS, $organization); |
|
49 | }) |
|
50 | ); |
|
51 | } |
|
52 | } |
|
53 |
@@ 15-53 (lines=39) @@ | ||
12 | use function React\Promise\resolve; |
|
13 | use function WyriHaximus\React\futureFunctionPromise; |
|
14 | ||
15 | final class RepositoriesHandler |
|
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 | * Fetch the given repository and hydrate it |
|
39 | * |
|
40 | * @param RepositoriesCommand $command |
|
41 | * @return PromiseInterface |
|
42 | */ |
|
43 | public function handle(RepositoriesCommand $command): PromiseInterface |
|
44 | { |
|
45 | return resolve( |
|
46 | $this->iteratePagesService->iterate('users/' . $command->getLogin() . '/repos') |
|
47 | ->flatMap(function ($repositories) { |
|
48 | return Observable::fromArray($repositories); |
|
49 | })->map(function ($repository) { |
|
50 | return $this->hydrator->hydrate(RepositoryInterface::HYDRATE_CLASS, $repository); |
|
51 | }) |
|
52 | ); |
|
53 | } |
|
54 | } |
|
55 |