<?php
/**
 * Orange Management
 *
 * PHP Version 7.0
 *
 * @category   TBD
 * @package    TBD
 * @author     OMS Development Team <dev@oms.com>
 * @author     Dennis Eichhorn <d.eichhorn@oms.com>
 * @copyright  2013 Dennis Eichhorn
 * @license    OMS License 1.0
 * @version    1.0.0
 * @link       http://orange-management.com
 */
namespace phpOMS\Utils\Git;

/**
 * Repository class
 *
 * @category   Framework
 * @package    phpOMS\Asset
 * @author     OMS Development Team <dev@oms.com>
 * @author     Dennis Eichhorn <d.eichhorn@oms.com>
 * @license    OMS License 1.0
 * @link       http://orange-management.com
 * @since      1.0.0
 */
class Repository
{
    /**
     * Repository path.
     *
     * @var string
     * @since 1.0.0
     */
    private $path = '';

    /**
     * Bare repository.
     *
     * @var bool
     * @since 1.0.0
     */
    private $bare = false;

    /**
     * Env variables.
     *
     * @var array
     * @since 1.0.0
     */
    private $envOptions = [];

    /**
     * Constructor
     *
     * @param string $path Repository path
     *
     * @since  1.0.0
     * @author Dennis Eichhorn <d.eichhorn@oms.com>
     */
    public function __construct(string $path)
    {
        $this->setPath($path);
    }

    /**
     * Create repository
     *
     * @param string $source Create repository from source (optional, can be remote)
     * @param bool $bare Bare repository
     *
     * @since  1.0.0
     * @author Dennis Eichhorn <d.eichhorn@oms.com>
     */
    public function create(string $source = null, bool $bare = false)
    {
        if (!is_dir($this->path) || file_exists($this->path . '/.git')) {
            throw new \Exception('Already repository');
        }

        if (isset($source)) {
            $this->clone($source);
        } else {
            $this->init($bare);
        }
    }

    /**
     * Set repository path.
     *
     * @param string $path Path to repository
     *
     * @since  1.0.0
     * @author Dennis Eichhorn <d.eichhorn@oms.com>
     */
    private function setPath(string $path)
    {
        if (!is_dir($path)) {
            throw new \PathException($path);
        }

        $this->path = realpath($path);

        if (file_exists($this->path . '/.git') && is_dir($this->path . '/.git')) {
            $this->bare = false;
            // Is this a bare repo?
        } elseif (is_file($this->path . '/config')) {
            $parse_ini = parse_ini_file($this->path . '/config');

            if ($parse_ini['bare']) {
                $this->bare = true;
            }
        }
    }

    /**
     * Run git command.
     *
     * @param string $cmd Command to run
     *
     * @since  1.0.0
     * @author Dennis Eichhorn <d.eichhorn@oms.com>
     */
    private function run(string $cmd) : string 
    {
        $cmd   = Git::getBin() . ' ' . $cmd;
        $pipes = [];
        $desc  = [
            1 => ['pipe', 'w'],
            2 => ['pipe', 'w'],
        ];

        if (count($_ENV) === 0) {
            $env = null;
            foreach ($this->envOptions as $key => $value) {
                putenv(sprintf("%s=%s", $key, $value));
            }
        } else {
            $env = array_merge($_ENV, $this->envOptions);
        }

        $resource = proc_open($cmd, $desc, $pipes, $this->path, $env);
        $stdout   = stream_get_contents($pipes[1]);
        $stderr   = stream_get_contents($pipes[2]);

        foreach ($pipes as $pipe) {
            fclose($pipe);
        }

        $status = trim(proc_close($resource));

        if ($status) {
            throw new Exception($stderr);
        }

        return $stdout;
    }

    /**
     * Get directory path.
     *
     * @return string
     *
     * @since  1.0.0
     * @author Dennis Eichhorn <d.eichhorn@oms.com>
     */
    public function getDirectoryPath() : string
    {
        return $this->bare ? $this->path : $this->path . '/.git';
    }

    /**
     * Get status.
     *
     * @return string
     *
     * @since  1.0.0
     * @author Dennis Eichhorn <d.eichhorn@oms.com>
     */
    public function status() : string
    {
        return $this->run('status');
    }

    public function add($files = '*')
    {
        if (is_array($files)) {
            $files = '"' . implode('" "', $files) . '"';
        } elseif (!is_string($files)) {
            throw new \Exception('Wrong type');
        }

        return $this->run('add ' . $files . ' -v');
    }

    public function rm($files = '*', bool $cached = false) : string
    {
        if (is_array($files)) {
            $files = '"' . implode('" "', $files) . '"';
        } elseif (!is_string($files)) {
            throw new \Exception('Wrong type');
        }

        return $this->run('rm ' . ($cached ? '--cached ' : '') . $files);
    }

    public function commit($msg = '', $all = true) : string
    {
        return $this->run('commit ' . ($all ? '-av' : '-v') . ' -m' . escapeshellarg($msg));
    }

    public function cloneTo(string $target) : string
    {
        if (!is_dir($target)) {
            throw new \Exception('Not a directory');
        }

        return $this->run('clone --local ' . $this->path . ' ' . $target);
    }

    public function cloneFrom(string $source) : string
    {
        if (!is_dir($source)) {
            throw new \Exception('Not a directory');
        }

        // todo: is valid git repository?

        return $this->run('clone --local ' . $source . ' ' . $this->path);
    }

    public function cloneRemote(string $source) : string
    {
        // todo: is valid remote git repository?

        return $this->run('clone ' . $source . ' ' . $this->path);
    }

    public function clean(bool $dirs = false, bool $force = false) : string
    {
        return $this->run('clean ' . ($force ? ' -f' : '') . ($dirs ? ' -d' : ''));
    }

    public function createBranch(string $branch, bool $force = false) : string
    {
        return $this->run('branch ' . ($force ? '-D' : '-d') . ' ' . $branch);
    }

    public function getBranches() : array
    {
        $branches = explode('\n', $this->run('branch'));

        foreach ($branches as $key => &$branch) {
            $branch = trim($branch);

            if ($branch === '') {
                unset($branches[$key]);
            }
        }

        return $branches;
    }

    public function getBranchesRemote() : array
    {
        $branches = explode("\n", $this->run('branch -r'));

        foreach ($branches as $key => &$branch) {
            $branch = trim($branch);

            if ($branch === '' || strpos($branch, 'HEAD -> ') !== false) {
                unset($branches[$key]);
            }
        }

        return $branches;
    }

    public function getActiveBranch() : string
    {
        $branches = $this->getBranches();
        $active   = preg_grep('/^\*/', $branches);
        reset($active);

        return current($active);
    }

    public function checkout($branch) : string
    {
        return $this->run('checkout ' . $branch);
    }

    public function merge($branch) : string
    {
        return $this->run('merge ' . $branch . ' --no-ff');
    }

    public function fetch() : string
    {
        return $this->run('fetch');
    }

    public function addTag(string $tag, string $message = null) : string
    {
        return $this->run('tag -a ' . $tag . ' -m ' . escapeshellarg($message ?? $tag));
    }

    public function getTags(string $pattern) : string
    {
        $tags = explode('\n', $this->run('tag -l ' . $pattern));

        foreach ($tags as $key => &$tag) {
            $tag = trim($tag);

            if ($tag === '') {
                unset($tags[$key]);
            }
        }

        return $tags;
    }

    public function push(string $remote, string $branch) : string
    {
        return $this->run('push --tags ' . $remote . ' ' . $branch);
    }

    public function pull(string $remote, string $branch) : string
    {
        return $this->run('pull ' . $remote . ' ' . $branch);
    }

    public function log(string $format = null) : string
    {
        return !isset($format) ? $this->run('log') : $this->run('log --pretty=format:"' . $format . '"');
    }

    public function setDescription(string $description)
    {
        file_put_contents($this->getDirectoryPath(), $description);
    }

    public function getDescription() : string
    {
        return file_get_contents($this->getDirectoryPath() . '/description');
    }

    public function setEnv(string $key, string $value)
    {
        $this->envOptions[$key] = $value;
    }

    public function getCommit(string $commit) : Commit
    {
        return $this->run('log --format=%B -n 1 ' . $commit);
    }

    /**
     * Count Commits.
     *
     * @return string
     *
     * @since  1.0.0
     * @author Dennis Eichhorn <d.eichhorn@oms.com>
     */
    public function getCommitsCount(\DateTime $start = null, \DateTime $end = null, Author $author = null) : int
    {
        $result = $this->normalizeResult($this->run('shortlog -s -n --all'));

        return [''];
    }

    private function normalizeResult(string $result) : string
    {
        str_replace('\t', '|', trim($result));
    }

    /**
     * Get commits by author.
     *
     * @param Author $author Commits by author
     * @param \DateTime $start Commits from
     * @param \DateTime $end Commits to
     *
     * @return string
     *
     * @since  1.0.0
     * @author Dennis Eichhorn <d.eichhorn@oms.com>
     */
    public function getCommitsBy(Author $author, \DateTime $start = null, \DateTime $end) : array
    {
        return $this->run('git log --before="' . $end->format('Y-m-d') . '" --after="' . $start->format('Y-m-d') . '" --author="' . $author->getName() . '" --reverse --pretty=format:"%cd  %h  %s" --date=short');
	}

    /**
     * Get remote.
     *
     * @return string
     *
     * @since  1.0.0
     * @author Dennis Eichhorn <d.eichhorn@oms.com>
     */
    public function getRemote() : string
    {
        return $this->run('config --get remote.origin.url');
    }

    /**
     * Get newest commit.
     *
     * @return Commit
     *
     * @since  1.0.0
     * @author Dennis Eichhorn <d.eichhorn@oms.com>
     */
    public function getNewest() : string
    {
        return $this->run('log --name-status HEAD^..HEAD');
	}
}