php-api-clients / github

src/Resource/Async/Repository.php

<?php declare(strict_types=1);

namespace ApiClients\Client\Github\Resource\Async;

use ApiClients\Client\Github\CommandBus\Command\RefreshCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\AddLabelCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\AddWebHookCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\AppVeyorCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\BlobCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\BranchesCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\CommitCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\CommitsCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\CommunityHealthCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\CompareCommitsCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\Contents\FileUploadCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\ContentsCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\DetailedCommitCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\LabelsCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\LanguagesCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\MilestonesCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\PullRequestsCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\RefCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\RefsCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\ReleasesCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\ReplaceTopicsCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\ScrutinizerCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\SubscribeCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\TagsCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\TravisCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\TreeCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\UnSubscribeCommand;
use ApiClients\Client\Github\CommandBus\Command\Repository\UpdateSettingsCommand;
use ApiClients\Client\Github\CommandBus\Command\WebHooksCommand;
use ApiClients\Client\Github\Resource\Git\CommitInterface;
use ApiClients\Client\Github\Resource\Git\RefInterface;
use ApiClients\Client\Github\Resource\Git\TreeInterface;
use ApiClients\Client\Github\Resource\Repository as BaseRepository;
use ApiClients\Client\Github\VO\NamedBlob;
use function ApiClients\Tools\Rx\unwrapObservableFromPromise;
use React\Promise\PromiseInterface;
use React\Stream\ReadableStreamInterface;
use Rx\Observable;
use Rx\ObservableInterface;

class Repository extends BaseRepository
{
    public function refresh(): PromiseInterface
    {
        return $this->handleCommand(
            new RefreshCommand($this)
        );
    }

    public function branches(): ObservableInterface
    {
        return unwrapObservableFromPromise($this->handleCommand(
            new BranchesCommand($this->fullName())
        ));
    }

    public function commits(): ObservableInterface
    {
        return unwrapObservableFromPromise($this->handleCommand(
            new CommitsCommand($this->fullName())
        ));
    }

    public function specificCommit(string $sha): PromiseInterface
    {
        return $this->handleCommand(
            new DetailedCommitCommand(
                $this->fullName(),
                $sha
            )
        );
    }

    public function labels(): ObservableInterface
    {
        return unwrapObservableFromPromise($this->handleCommand(
            new LabelsCommand($this->fullName())
        ));
    }

    public function addLabel(string $name, string $colour): PromiseInterface
    {
        return $this->handleCommand(
            new AddLabelCommand($this->fullName(), $name, $colour)
        );
    }

    public function contents(string $path = '/'): Observable
    {
        return unwrapObservableFromPromise(
            $this->handleCommand(
                new ContentsCommand($this->fullName(), $path)
            )
        );
    }

    public function communityHealth(): PromiseInterface
    {
        return $this->handleCommand(
            new CommunityHealthCommand($this->fullName())
        );
    }

    public function tags(): ObservableInterface
    {
        return unwrapObservableFromPromise($this->handleCommand(
            new TagsCommand($this->fullName())
        ));
    }

    public function releases(): ObservableInterface
    {
        return unwrapObservableFromPromise($this->handleCommand(
            new ReleasesCommand($this->fullName())
        ));
    }

    public function languages(): PromiseInterface
    {
        return $this->handleCommand(
            new LanguagesCommand($this->fullName())
        );
    }

    public function webHooks(): ObservableInterface
    {
        return unwrapObservableFromPromise($this->handleCommand(
            new WebHooksCommand($this->fullName(), 'repos')
        ));
    }

    public function milestones(): ObservableInterface
    {
        return unwrapObservableFromPromise($this->handleCommand(
            new MilestonesCommand($this->fullName())
        ));
    }

    public function pullRequests(): ObservableInterface
    {
        return unwrapObservableFromPromise($this->handleCommand(
            new PullRequestsCommand($this->fullName())
        ));
    }

    public function compareCommits(string $base, string $head): PromiseInterface
    {
        return $this->handleCommand(new CompareCommitsCommand($this, $base, $head));
    }

    public function addWebHook(
        string $name,
        array $config,
        array $events,
        bool $active
    ): PromiseInterface {
        return $this->handleCommand(
            new AddWebHookCommand(
                $this->fullName(),
                $name,
                $config,
                $events,
                $active
            )
        );
    }

    public function addFile(
        string $filename,
        ReadableStreamInterface $stream,
        string $commitMessage = '',
        string $branch = ''
    ): PromiseInterface {
        if ($commitMessage === '') {
            $commitMessage = 'Update ' . $this->name;
        }

        return $this->handleCommand(new FileUploadCommand(
            $this->full_name,
            $commitMessage,
            '/repos/' . $this->full_name . '/contents/' . $filename,
            '',
            $branch,
            $stream
        ));
    }

    public function subscribe(bool $subscribed = true, bool $ignored = false): PromiseInterface
    {
        return $this->handleCommand(
            new SubscribeCommand($this->fullName(), $subscribed, $ignored)
        );
    }

    public function unSubscribe(): PromiseInterface
    {
        return $this->handleCommand(
            new UnSubscribeCommand($this->fullName())
        );
    }

    public function replaceTopics(string ...$topics): PromiseInterface
    {
        return $this->handleCommand(
            new ReplaceTopicsCommand($this->fullName(), ...$topics)
        );
    }

    public function travisRepository(): PromiseInterface
    {
        return $this->handleCommand(new TravisCommand($this->fullName()));
    }

    public function appVeyorRepository(): PromiseInterface
    {
        return $this->handleCommand(new AppVeyorCommand($this->fullName()));
    }

    public function scrutinizerRepository(): PromiseInterface
    {
        return $this->handleCommand(new ScrutinizerCommand(...\explode('/', $this->fullName())));

The call to ScrutinizerCommand::__construct() misses a required argument $name.

\explode('/', $this->fullName()) is of type array, but the function expects a string.

    }

    public function updateSettings(array $settings): PromiseInterface
    {
        if (!isset($settings['name'])) {
            $settings['name'] = $this->name();
        }

        return $this->handleCommand(new UpdateSettingsCommand($this->fullName(), $settings));
    }

    public function blob(ReadableStreamInterface $contents): PromiseInterface
    {
        return $this->handleCommand(new BlobCommand($this->fullName(), $contents));
    }

    public function tree(?string $baseTree, NamedBlob ...$blobs): PromiseInterface
    {
        return $this->handleCommand(new TreeCommand($this->fullName(), $baseTree, ...$blobs));
    }

    public function commit(string $message, TreeInterface $tree, ?string ...$baseCommits): PromiseInterface
    {
        return $this->handleCommand(new CommitCommand($this->fullName(), $message, $tree->sha(), ...$baseCommits));
    }

    public function refs(?string $namespace = null): ObservableInterface
    {
        return unwrapObservableFromPromise($this->handleCommand(
            new RefsCommand($this->fullName(), $namespace)
        ));
    }

    public function ref(RefInterface $ref, CommitInterface $tree): PromiseInterface
    {
        return $this->handleCommand(new RefCommand($this->fullName(), $ref->ref(), $tree->sha()));
    }
}