DanielPieper\MergeReminder\Service\MergeRequestService

Complexity

Total Complexity

9

Size/Duplication

Total Lines	88
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	transform()	0	8	2
A	allByProject()	0	24	2
A	getByProject()	0	7	2
A	findByProject()	0	7	2

<?php declare(strict_types=1);

namespace DanielPieper\MergeReminder\Service;

use Carbon\Carbon;
use DanielPieper\MergeReminder\Exception\MergeRequestNotFoundException;
use DanielPieper\MergeReminder\ValueObject\MergeRequest;
use DanielPieper\MergeReminder\ValueObject\Project;
use DanielPieper\MergeReminder\ValueObject\User;
use Gitlab\Client;
use Gitlab\ResultPager;

class MergeRequestService
{
    /** @var Client */
    private $gitlabClient;

    /** @var ResultPager */
    private $resultPager;

    public function __construct(Client $gitlabClient, ResultPager $resultPager)
    {
        $this->gitlabClient = $gitlabClient;
        $this->resultPager = $resultPager;
    }

    /**
     * @param Project $project
     * @param int $id
     * @return MergeRequest|null
     */
    public function findByProject(Project $project, int $id): ?MergeRequest
    {
        $mergeRequest = $this->gitlabClient->mergeRequests()->show($project->getId(), $id);
        if (!is_array($mergeRequest)) {
            return null;
        }
        return $this->transform($project, $mergeRequest);
    }

    /**
     * @param Project $project
     * @param int $id
     * @return MergeRequest
     * @throws MergeRequestNotFoundException
     */
    public function getByProject(Project $project, int $id): MergeRequest
    {
        $mergeRequest = $this->findByProject($project, $id);
        if (!$mergeRequest) {
            throw new MergeRequestNotFoundException();
        }
        return $mergeRequest;
    }

    /**
     * @param Project $project
     * @param Carbon|null $createdAfter
     * @return MergeRequest[]
     * @throws \Exception
     */
    public function allByProject(Project $project, ?Carbon $createdAfter = null): array
    {
        if (!$createdAfter) {
            $createdAfter = new Carbon('1 month ago');
        }

        $parameters = [
            'page' => 1,
            'per_page' => 100,
            'state' => 'opened',
            'created_after' => $createdAfter,
        ];
        $mergeRequests = $this->resultPager->fetchAll(
            $this->gitlabClient->mergeRequests(),
            'all',
            [
                $project->getId(),
                $parameters,
            ]
        );

        return array_map(function ($mergeRequest) use ($project) {
            return $this->transform($project, $mergeRequest);
        }, $mergeRequests);
    }

    /**
     * @param Project $project
     * @param array $mergeRequest
     * @return MergeRequest
     */
    private function transform(Project $project, array $mergeRequest): MergeRequest
    {
        $mergeRequest['project'] = $project;
        $mergeRequest['author'] = User::fromArray($mergeRequest['author']);
        if ($mergeRequest['assignee']) {
            $mergeRequest['assignee'] = User::fromArray($mergeRequest['assignee']);
        }
        return MergeRequest::fromArray($mergeRequest);
    }
}