UGitRepository.php

Go to the documentation of this file.

<?php
 
namespace Ubiquity\utils\git;
 
use Cz\Git\GitRepository;
use Cz\Git\GitException;
use Ubiquity\utils\base\UString;
 
class UGitRepository extends GitRepository {
 
    protected function run($cmd/*, $options = NULL*/){
        $args = func_get_args ();
        $cmd = $this->_processCommand ( $args );
        exec ( $cmd . ' 2>&1', $output, $ret );
 
        if ($ret !== 0) {
            throw new GitException ( implode("<br>",$output), $ret );
        }
 
        return $this;
    }
    
    public static function init($directory, array $params = NULL){
        if(is_dir("$directory/.git")){
            throw new GitException("Repo already exists in $directory.");
        }
        
        if(!is_dir($directory) && !@mkdir($directory, 0777, TRUE)){
            throw new GitException("Unable to create directory '$directory'.");
        }
        
        $cwd = getcwd();
        chdir($directory);
        exec(self::processCommand(array(
                'git init',
                $params,
                $directory,
        )), $output, $returnCode);
        
        if($returnCode !== 0){
            throw new GitException(implode("<br>", $output));
        }
        
        $repo = getcwd();
        chdir($cwd);
        return new static($repo);
    }
 
    protected function _processCommand(array $args) {
        $cmd = array ();
 
        $programName = array_shift ( $args );
 
        foreach ( $args as $arg ) {
            if (is_array ( $arg )) {
                foreach ( $arg as $key => $value ) {
                    $_c = '';
 
                    if (is_string ( $key )) {
                        $_c = "$key ";
                    }
                    if (is_array ( $value )) {
                        foreach ( $value as $v ) {
                            $cmd [] = $_c . escapeshellarg ( $v );
                        }
                    } else {
                        $cmd [] = $_c . escapeshellarg ( $value );
                    }
                }
            } elseif (is_scalar ( $arg ) && ! is_bool ( $arg )) {
                $cmd [] = escapeshellarg ( $arg );
            }
        }
        return "$programName " . implode ( ' ', $cmd );
    }
 
    public function getUntrackedFiles() {
        return $this->extractFromCommand ( 'git ls-files --others --exclude-standard', function ($value) {
            return trim ( $value );
        } );
    }
 
    public function getModifiedFiles() {
        try {
            return $this->extractFromCommand ( 'git diff --name-status HEAD', function ($array) {
                $array = trim ( preg_replace ( '!\s+!', ' ', $array ) );
                return explode ( ' ', $array );
            } );
        } catch ( \Cz\Git\GitException $e ) {
            return [ ];
        }
    }
 
    public function getChangesInFile($filename) {
        try {
            $output = $this->extractFromCommand ( 'git diff ' . $filename );
            if (is_array ( $output ))
                return implode ( '\r\n', $output );
            return $output;
        } catch ( \Cz\Git\GitException $e ) {
            return "";
        }
    }
 
    public function getChangesInCommit($commitHash) {
        try {
            $output = $this->extractFromCommand ( "git show {$commitHash}" );
            if (is_array ( $output ))
                return implode ( '\r\n', $output );
            return $output;
        } catch ( \Cz\Git\GitException $e ) {
            return "";
        }
    }
 
    public function getRemoteUrl() {
        try {
            $values = $this->extractFromCommand ( 'git config --get remote.origin.url', function ($str) {
                return trim ( $str );
            } );
            if (isset ( $values )) {
                return implode ( " ", $values );
            }
        } catch ( \Cz\Git\GitException $e ) {
            return "";
        }
        return "";
    }
 
    public function ignoreFiles($files) {
        if (! is_array ( $files )) {
            $files = func_get_args ();
        }
        $this->begin ();
        $this->run ( 'git reset', NULL, [ "--" => $files ] );
        return $this->end ();
    }
 
    public function getCommits() {
        $remoteBranchsSize=\count($this->getRemoteBranchs());
        $nonPushed = $this->getNonPushedCommitHash ();
        try {
            return $this->extractFromCommand ( 'git log --pretty=format:"%h___%an___%ar___%s___%H"', function ($str) use ($nonPushed,$remoteBranchsSize) {
                $array = \explode ( "___", $str );
                $pushed = true;
                if($remoteBranchsSize==0){
                    $pushed=false;
                }else{
                    if (\is_array ( $nonPushed ))
                        $pushed = ! in_array ( $array [0], $nonPushed );
                }
                return new GitCommit ( $array [0], $array [1], $array [2], $array [3], $array [4], $pushed );
            } );
        } catch ( \Cz\Git\GitException $e ) {
            return [ ];
        }
        return [ ];
    }
 
    public function getNonPushedCommitHash($branch="master") {
        try {
            return $this->extractFromCommand ( 'git log origin/'.$branch.'..'.$branch.' --pretty=format:"%h"' );
        } catch ( \Cz\Git\GitException $e ) {
            return [ ];
        }
        return [ ];
    }
    
    public function setUpstream($branch="master"){
        $this->begin ();
        $this->run ( 'git branch -u origin/'.$branch);
        return $this->end ();
    }
    
    public function getRemoteBranchs(){
        $url=$this->getRemoteUrl();
        if(UString::isNotNull($url)){
            try{
                $result= $this->extractFromCommand('git ls-remote --heads '.$url);
                if(!is_array($result)){
                    $result=[];
                }
                return $result;
            } catch ( \Cz\Git\GitException $e ) {
                return [ ];
            }
        }
        return [];
    }
}