OpenStackApiManager.php

<?php
/**
 * Copyright 2014 Openstack Foundation
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 * http://www.apache.org/licenses/LICENSE-2.0
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 **/

/**
 * Class OpenStackApiManager
 */
class OpenStackApiManager
{

    /**
     * @var ITransactionManager
     */
    private $tx_manager;

    /**
     * @var IOpenStackReleaseRepository
     */
    private $release_repository;
    /**
     * @var IOpenStackComponentRepository
     */
    private $component_repository;
    /**
     * @var IOpenStackApiVersionRepository
     */
    private $version_repository;


    /**
     * @param IOpenStackReleaseRepository $release_repository
     * @param IOpenStackComponentRepository $component_repository
     * @param IOpenStackApiVersionRepository $version_repository
     * @param ITransactionManager $tx_manager
     */
    public function __construct(
        IOpenStackReleaseRepository $release_repository,
        IOpenStackComponentRepository $component_repository,
        IOpenStackApiVersionRepository $version_repository,
        ITransactionManager $tx_manager
    ) {

        $this->release_repository = $release_repository;
        $this->component_repository = $component_repository;
        $this->version_repository = $version_repository;
        $this->tx_manager = $tx_manager;
    }


    /**
     * @param IOpenStackRelease $release
     * @return bool|int
     */
    public function registerRelease(IOpenStackRelease $release)
    {
        $res = false;
        $release_repository = $this->release_repository;
        $this->tx_manager->transaction(function () use (&$res, $release, $release_repository) {
            $old_one = $release_repository->getByName($release->getName());
            if ($old_one) {
                throw new EntityAlreadyExistsException('OpenStackRelease', sprintf('name %s', $release->getName()));
            }

            $old_one = $release_repository->getByReleaseNumber($release->getReleaseNumber());
            if ($old_one) {
                throw new EntityAlreadyExistsException('OpenStackRelease',
                    sprintf('release_number %s', $release->getReleaseNumber()));
            }

            $res = $release_repository->add($release);
        });

        return $res;
    }

    /**
     * @param IOpenStackComponent $component
     * @return bool|int
     */
    public function registerComponent(IOpenStackComponent $component)
    {
        $res = false;
        $component_repository = $this->component_repository;
        $this->tx_manager->transaction(function () use (&$res, $component, $component_repository) {
            $old_one = $component_repository->getByNameAndCodeName($component->getName(), $component->getCodeName());
            if ($old_one) {
                throw new EntityAlreadyExistsException('OpenStackComponent', sprintf('name %s and codename %s', $component->getName(), $component->getCodeName()));
            }
            $res = $component_repository->add($component);
        });

        return $res;
    }

    /**
     * @param IOpenStackApiVersion $version
     * @return bool|int
     */
    public function registerVersion(IOpenStackApiVersion $version)
    {
        $res = false;
        $component_repository = $this->component_repository;
        $version_repository = $this->version_repository;
        $this->tx_manager->transaction(function () use (&$res, $version, $component_repository, $version_repository) {

            $component_id = $version->getReleaseComponent()->getIdentifier();
            $component = $component_repository->getById($component_id);
            if (!$component) {
                throw new NotFoundEntityException('OpenStackComponent', sprintf('id %s', $component_id));
            }

            $old_one = $version_repository->getByVersionAndComponent($version->getVersion(), $component_id);
            if ($old_one) {
                throw new EntityAlreadyExistsException('OpenStackApiVersion',
                    sprintf('version %s', $version->getVersion()));
            }

            $res = $version_repository->add($version);
        });

        return $res;
    }

    public function registerComponentOnRelease($release_id, $component_id)
    {
        $release = $this->release_repository->getById($release_id);
        $component = $this->component_repository->getById($component_id);
        $release->addOpenStackComponent($component);
    }

    /**
     * @param int $release_id
     * @param int $component_id
     * @return IOpenStackApiVersion[]
     * @throws NotFoundEntityException
     * @throws InvalidAggregateRootException
     */
    public function getReleaseSupportedVersionsByComponent($release_id, $component_id)
    {

        $release = $this->release_repository->getById($release_id);
        if (!$release) {
            throw new NotFoundEntityException('OpenStackRelease', sprintf('id %s', $release_id));
        }
        $component = $this->component_repository->getById($component_id);
        if (!$component) {
            throw new NotFoundEntityException('OpenStackComponent', sprintf('id %s', $component));
        }

        if (!$release->supportsComponent($component->getCodeName())) {
            throw new InvalidAggregateRootException('OpenStackRelease', $release_id, 'OpenStackComponent',
                $component_id);
        }

        $res = array();
        foreach ($this->version_repository->getByReleaseAndComponent($release_id, $component_id) as $version) {
            if ($release->supportsApiVersion($version)) {
                array_push($res, $version);
            }
        }

        return $res;
    }
}