Innmind / Compose

src/Definition/Service.php

<?php
declare(strict_types = 1);

namespace Innmind\Compose\Definition;

use Innmind\Compose\{
    Definition\Service\Constructor,
    Definition\Service\Argument,
    Definition\Service\Arguments,
    Services,
    Compilation,
    Exception\ServiceCannotDecorateMultipleServices,
    Exception\LogicException
};
use Innmind\Immutable\{
    StreamInterface,
    Stream,
    Sequence
};

final class Service
{
    private $name;
    private $construct;
    private $arguments;
    private $exposeName;
    private $decorates = false;

    public function __construct(
        Name $name,
        Constructor $constructor,
        Argument ...$arguments
    ) {
        $this->name = $name;
        $this->construct = $constructor;
        $this->arguments = Stream::of(Argument::class, ...$arguments);

        $decorates = $this->arguments->filter(static function(Argument $argument): bool {
            return $argument instanceof Argument\Decorate;
        });

        if ($decorates->size() > 0) {
            $this->decorates = true;
        }

        if ($decorates->size() > 1) {
            throw new ServiceCannotDecorateMultipleServices((string) $name);
        }
    }

    public function decorates(): bool
    {
        return $this->decorates;
    }

    public function exposeAs(Name $name): self
    {
        $self = clone $this;
        $self->exposeName = $name;

        return $self;
    }

    public function exposed(): bool
    {
        return $this->exposeName instanceof Name;
    }

    public function exposedAs(): Name
    {
        return $this->exposeName;
    }

    public function isExposedAs(Name $name): bool
    {
        return (string) $this->exposeName === (string) $name;
    }

    public function name(): Name
    {
        return $this->name;
    }

    public function constructor(): Constructor
    {
        return $this->construct;
    }

    /**
     * @return StreamInterface<Argument>
     */
    public function arguments(): StreamInterface
    {
        return $this->arguments;
    }

    public function build(Services $services): object
    {
        return ($this->construct)(...$this->arguments->reduce(
            Stream::of('mixed'),
            static function(Stream $arguments, Argument $argument) use ($services): Stream {
                return $argument->resolve($arguments, $services);

The expression return $argument->resolve($arguments, $services) returns the type Innmind\Immutable\StreamInterface which includes types incompatible with the type-hinted return Innmind\Immutable\Stream.

            }
        ));
    }

    public function decorate(Name $service, Name $newName = null): self
    {
        if (!$this->decorates) {
            throw new LogicException;
        }

        $self = clone $this;
        $self->name = $newName ?? new Name(
            $self->name.'.'.md5((string) $service)
        );
        $self->decorates = false;
        $self->arguments = $self->arguments->map(static function(Argument $argument) use ($service): Argument {
            if ($argument instanceof Argument\Decorate) {
                return new Argument\Reference($service);
            }

            return $argument;
        });

        return $self;
    }

    public function tunnel(
        Name $dependency,
        Name $decorated,
        Name $newName = null
    ): self {
        if (
            !$this->decorates() ||
            !$this->exposed()
        ) {
            throw new LogicException;
        }

        return new self(
            $newName ?? new Name('tunnel_'.md5($dependency.'.'.$this->exposeName)),
            $this->construct,
            ...$this->arguments->map(function(Argument $argument) use ($dependency, $decorated): Argument {
                if ($argument instanceof Argument\Decorate) {
                    return new Argument\Reference($decorated);
                }

                return new Argument\Tunnel(
                    $dependency->add($this->exposeName),
                    $argument
                );
            })
        );
    }

    public function compile(): Compilation\Service
    {
        return new Compilation\Service(
            $this,
            $this->construct->compile(
                ...$this->arguments->reduce(
                    new Sequence,
                    static function(Sequence $arguments, Argument $argument): Sequence {
                        return $arguments->add($argument->compile());
                    }
                )
            )
        );
    }
}