Innmind\LabStation\Agent\WatchCurrentGitBranch

Complexity

Total Complexity

3

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__invoke()	0	24	2
A	__construct()	0	12	1

<?php
declare(strict_types = 1);

namespace Innmind\LabStation\Agent;

use Innmind\LabStation\{
    Agent,
    Protocol,
    Activity,
    Activity\Type,
};
use Innmind\FileWatch\Watch;
use Innmind\IPC\{
    IPC,
    Process\Name,
};
use Innmind\Url\{
    PathInterface,
    Path,
};
use Innmind\Git\Git;

final class WatchCurrentGitBranch implements Agent
{
    private $git;
    private $protocol;
    private $watch;
    private $ipc;
    private $monitor;

    public function __construct(
        Git $git,
        Protocol $protocol,
        Watch $watch,
        IPC $ipc,
        Name $monitor
    ) {
        $this->git = $git;
        $this->protocol = $protocol;
        $this->watch = $watch;
        $this->ipc = $ipc;
        $this->monitor = $monitor;
    }

    public function __invoke(PathInterface $project): void
    {
        $git = new Path($project.'/.git');
        $repository = $this->git->repository($project);
        $previousBranch = $repository->head();

        ($this->watch)($git)(function() use (&$previousBranch, $repository) {
            $currentBranch = $repository->head();

            if ((string) $currentBranch === (string) $previousBranch) {
                return;
            }

            $previousBranch = $currentBranch;
            $monitor = $this->ipc->get($this->monitor);
            $monitor->send(
                $this->protocol->encode(
                    new Activity(
                        Type::gitBranchChanged(),
                        ['branch' => (string) $currentBranch]
                    )
                )
            );
            $monitor->close();
        });
    }
}