P3X GitList

df43c987

<?php

7fe9182f

namespace GitList\Component\Git;

df43c987

7fe9182f

use GitList\Component\Git\Commit\Commit; use GitList\Component\Git\Model\Tree; use GitList\Component\Git\Model\Blob; use GitList\Component\Git\Model\Diff;

ffcf6081

use Symfony\Component\Filesystem\Filesystem;

df43c987

class Repository { protected $path; protected $client; public function __construct($path, Client $client) { $this->setPath($path); $this->setClient($client); } public function setClient(Client $client) { $this->client = $client; } public function getClient() { return $this->client; } public function create() { mkdir($this->getPath()); $this->getClient()->run($this, 'init'); return $this; } public function getConfig($key) { $key = $this->getClient()->run($this, 'config ' . $key);

b00f723a

df43c987

return trim($key); } public function setConfig($key, $value) { $this->getClient()->run($this, "config $key \"$value\""); return $this; }

b00f723a

df43c987

/** * Add untracked files

b00f723a

*

df43c987

* @access public * @param mixed $files Files to be added to the repository */ public function add($files = '.') {

b00f723a

if (is_array($files)) {

df43c987

$files = implode(' ', $files); }

b00f723a

df43c987

$this->getClient()->run($this, "add $files"); return $this; } /** * Add all untracked files

b00f723a

*

df43c987

* @access public */ public function addAll() { $this->getClient()->run($this, "add -A"); return $this; }

b00f723a

df43c987

/** * Commit changes to the repository

b00f723a

*

df43c987

* @access public * @param string $message Description of the changes made */ public function commit($message) { $this->getClient()->run($this, "commit -m '$message'"); return $this; }

b00f723a

df43c987

/** * Checkout a branch

b00f723a

*

df43c987

* @access public * @param string $branch Branch to be checked out */ public function checkout($branch) { $this->getClient()->run($this, "checkout $branch"); return $this; } /** * Pull repository changes

b00f723a

*

df43c987

* @access public */ public function pull() { $this->getClient()->run($this, "pull"); return $this; }

b00f723a

df43c987

/** * Update remote references

b00f723a

*

df43c987

* @access public * @param string $repository Repository to be pushed

b00f723a

* @param string $refspec Refspec for the push

df43c987

*/ public function push($repository = null, $refspec = null) { $command = "push";

b00f723a

if ($repository) {

df43c987

$command .= " $repository";

b00f723a

} if ($refspec) {

df43c987

$command .= " $refspec"; }

b00f723a

df43c987

$this->getClient()->run($this, $command); return $this; }

b00f723a

df43c987

/** * Show a list of the repository branches

b00f723a

*

df43c987

* @access public * @return array List of branches */ public function getBranches() { $branches = $this->getClient()->run($this, "branch"); $branches = explode("\n", $branches); $branches = array_filter(preg_replace('/[\*\s]/', '', $branches));

b00f723a

df43c987

return $branches; }

b00f723a

df43c987

/** * Show the current repository branch

b00f723a

*

df43c987

* @access public * @return string Current repository branch */ public function getCurrentBranch() { $branches = $this->getClient()->run($this, "branch"); $branches = explode("\n", $branches);

b00f723a

foreach ($branches as $branch) { if ($branch[0] == '*') {

df43c987

return substr($branch, 2); } } }

b00f723a

df43c987

/** * Check if a specified branch exists

b00f723a

*

df43c987

* @access public

b00f723a

* @param string $branch Branch to be checked

df43c987

* @return boolean True if the branch exists */ public function hasBranch($branch) { $branches = $this->getBranches(); $status = in_array($branch, $branches);

b00f723a

df43c987

return $status; } /** * Create a new repository branch

b00f723a

*

df43c987

* @access public * @param string $branch Branch name */ public function createBranch($branch) { $this->getClient()->run($this, "branch $branch"); }

b00f723a

df43c987

/** * Show a list of the repository tags

b00f723a

*

df43c987

* @access public * @return array List of tags */ public function getTags() { $tags = $this->getClient()->run($this, "tag"); $tags = explode("\n", $tags); if (empty($tags[0])) { return NULL; }

b00f723a

df43c987

return $tags; }

b5ba7959

/** * Show the amount of commits on the repository

b00f723a

*

b5ba7959

* @access public * @return integer Total number of commits */

9c4b5e9f

public function getTotalCommits($file = null)

b5ba7959

{

df8f74a9

$command = "rev-list --all";

b00f723a

9c4b5e9f

if ($file) { $command .= " $file"; }

df8f74a9

$command .= " | wc -l";

9c4b5e9f

$commits = $this->getClient()->run($this, $command);

b00f723a

b5ba7959

return $commits; }

b00f723a

df43c987

/** * Show the repository commit log

b00f723a

*

df43c987

* @access public * @return array Commit log */

3f3c25bc

public function getCommits($file = null, $page = 0)

df43c987

{

3f3c25bc

$page = 15 * $page; $pager = "--skip=$page --max-count=15"; $command = 'log ' . $pager . ' --pretty=format:\'"%h": {"hash": "%H", "short_hash": "%h", "tree": "%T", "parent": "%P", "author": "%an", "author_email": "%ae", "date": "%at", "commiter": "%cn", "commiter_email": "%ce", "commiter_date": "%ct", "message": "%f"}\'';

b00f723a

df43c987

if ($file) { $command .= " $file"; } $logs = $this->getClient()->run($this, $command);

3f3c25bc

if (empty($logs)) { throw new \RuntimeException('No commit log available'); }

df43c987

$logs = str_replace("\n", ',', $logs); $logs = json_decode("{ $logs }", true); foreach ($logs as $log) { $log['message'] = str_replace('-', ' ', $log['message']); $commit = new Commit; $commit->importData($log); $commits[] = $commit; } return $commits; } public function getRelatedCommits($hash) { $logs = $this->getClient()->run($this, 'log --pretty=format:\'"%h": {"hash": "%H", "short_hash": "%h", "tree": "%T", "parent": "%P", "author": "%an", "author_email": "%ae", "date": "%at", "commiter": "%cn", "commiter_email": "%ce", "commiter_date": "%ct", "message": "%f"}\'');

595bd91d

if (empty($logs)) { throw new \RuntimeException('No commit log available'); }

df43c987

$logs = str_replace("\n", ',', $logs); $logs = json_decode("{ $logs }", true); foreach ($logs as $log) { $log['message'] = str_replace('-', ' ', $log['message']); $logTree = $this->getClient()->run($this, 'diff-tree -t -r ' . $log['hash']); $lines = explode("\n", $logTree); array_shift($lines); $files = array(); foreach ($lines as $key => $line) { if (empty($line)) { unset($lines[$key]); continue; } $files[] = preg_split("/[\s]+/", $line); } // Now let's find the commits who have our hash within them foreach ($files as $file) { if ($file[1] == 'commit') { continue; } if ($file[3] == $hash) { $commit = new Commit; $commit->importData($log); $commits[] = $commit; break; } } } return $commits; }

4b028e62

public function getCommit($commitHash)

df43c987

{

4b028e62

$logs = $this->getClient()->run($this, 'show --pretty=format:\'{"hash": "%H", "short_hash": "%h", "tree": "%T", "parent": "%P", "author": "%an", "author_email": "%ae", "date": "%at", "commiter": "%cn", "commiter_email": "%ce", "commiter_date": "%ct", "message": "%f"}\' ' . $commitHash);

595bd91d

if (empty($logs)) { throw new \RuntimeException('No commit log available'); }

df43c987

$logs = explode("\n", $logs); // Read commit metadata $data = json_decode($logs[0], true); $data['message'] = str_replace('-', ' ', $data['message']); $commit = new Commit; $commit->importData($data); unset($logs[0]);

8092f9c3

if (empty($logs[1])) {

4b028e62

$logs = explode("\n", $this->getClient()->run($this, 'diff '.$commitHash.'~1..'.$commitHash));

8092f9c3

}

df43c987

// Read diff logs

2d6a31e7

$lineNumOld = 0; $lineNumNew = 0;

df43c987

foreach ($logs as $log) { if ('diff' === substr($log, 0, 4)) { if (isset($diff)) { $diffs[] = $diff; } $diff = new Diff;

484c7267

preg_match('/^diff --[\S]+ (a\/)?([\S]+)( b\/)?/', $log, $name); $diff->setFile($name[2]);

df43c987

continue; } if ('index' === substr($log, 0, 5)) { $diff->setIndex($log); continue; } if ('---' === substr($log, 0, 3)) { $diff->setOld($log); continue; } if ('+++' === substr($log, 0, 3)) { $diff->setNew($log); continue; }

da43306c

// Handle binary files properly. if ('Binary' === substr($log, 0, 6)) { $m = array(); if (preg_match('/Binary files (.+) and (.+) differ/', $log, $m)) { $diff->setOld($m[1]); $diff->setNew(" {$m[2]}"); } }

2d6a31e7

if (!empty($log)) { switch ($log[0]) { case "@": // Set the line numbers preg_match('/@@ -([0-9]+)/', $log, $matches); $lineNumOld = $matches[1] - 1; $lineNumNew = $matches[1] - 1; break; case "-": $lineNumOld++; break; case "+": $lineNumNew++; break; default: $lineNumOld++; $lineNumNew++; } } else { $lineNumOld++; $lineNumNew++; } $diff->addLine($log, $lineNumOld, $lineNumNew);

df43c987

} if (isset($diff)) { $diffs[] = $diff; } $commit->setDiffs($diffs); return $commit; } public function getAuthorStatistics() {

39d4a24b

$logs = $this->getClient()->run($this, 'log --pretty=format:\'%an||%ae\' ' . $this->getHead());

595bd91d

if (empty($logs)) { throw new \RuntimeException('No statistics available'); }

df43c987

$logs = explode("\n", $logs); $logs = array_count_values($logs); arsort($logs); foreach ($logs as $user => $count) { $user = explode('||', $user);

b00f723a

$data[] = array('name' => $user[0], 'email' => $user[1], 'commits' => $count);

df43c987

}

b00f723a

df43c987

return $data; }

19d80921

/** * Get the current HEAD. * * @return string the name of the HEAD branch. */ public function getHead() {

3308fe46

if (file_exists($this->getPath() . '/.git/HEAD')) { $file = @file_get_contents($this->getPath() . '/.git/HEAD');

b00f723a

} elseif (file_exists($this->getPath() . '/HEAD')) {

3308fe46

$file = @file_get_contents($this->getPath() . '/HEAD');

b00f723a

} else {

3308fe46

return 'master';

22a81468

}

48a267d5

// Find first existing branch

19d80921

foreach (explode("\n", $file) as $line) { $m = array(); if (preg_match('#ref:\srefs/heads/(.+)#', $line, $m)) {

48a267d5

if ($this->hasBranch($m[1])) { return $m[1]; }

19d80921

} } // Default to something sane if in a detached HEAD state.

48a267d5

$branches = $this->getBranches(); if (!empty($branches)) { return current($branches); }

b00f723a

19d80921

return 'master'; }

df43c987

public function getStatistics($branch) { // Calculate amount of files, extensions and file size $logs = $this->getClient()->run($this, 'ls-tree -r -l ' . $branch); $lines = explode("\n", $logs); $files = array(); $data['extensions'] = array(); $data['size'] = 0; $data['files'] = 0; foreach ($lines as $key => $line) { if (empty($line)) { unset($lines[$key]); continue; } $files[] = preg_split("/[\s]+/", $line); } foreach ($files as $file) { if ($file[1] == 'blob') { $data['files']++; } if (is_numeric($file[3])) { $data['size'] += $file[3]; } if (($pos = strrpos($file[4], '.')) !== FALSE) { $data['extensions'][] = substr($file[4], $pos); } } $data['extensions'] = array_count_values($data['extensions']); arsort($data['extensions']); return $data; }

a4cff9b8

/** * Extract the tree hash for a given branch or tree reference *

b00f723a

* @param string $branch

a4cff9b8

* @return string */ public function getBranchTree($branch) {

ffcf6081

$hash = $this->getClient()->run($this, "log --pretty='%T' --max-count=1 $branch");

a4cff9b8

$hash = trim($hash, "\r\n "); return $hash ? : false; } /** * Create a TAR or ZIP archive of a git tree * * @param string $tree Tree-ish reference * @param string $output Output File name * @param string $format Archive format */ public function createArchive($tree, $output, $format = 'zip') {

ffcf6081

$fs = new Filesystem; $fs->mkdir(dirname($output));

a4cff9b8

$this->getClient()->run($this, "archive --format=$format --output=$output $tree"); }

df43c987

/** * Get the Tree for the provided folder

b00f723a

* * @param string $tree Folder that will be parsed * @return Tree Instance of Tree for the provided folder

df43c987

*/ public function getTree($tree) { $tree = new Tree($tree, $this->getClient(), $this); $tree->parse();

b00f723a

df43c987

return $tree; } /** * Get the Blob for the provided file

b00f723a

* * @param string $blob File that will be parsed * @return Blob Instance of Blob for the provided file

df43c987

*/ public function getBlob($blob) { return new Blob($blob, $this->getClient(), $this); } /** * Blames the provided file and parses the output

b00f723a

* * @param string $file File that will be blamed * @return array Commits hashes containing the lines

df43c987

*/ public function getBlame($file) {

158150d6

$blame = array();

df43c987

$logs = $this->getClient()->run($this, "blame -s $file"); $logs = explode("\n", $logs);

158150d6

$i = 0; $previous_commit = '';

df43c987

foreach ($logs as $log) { if ($log == '') { continue; }

dca25b61

preg_match_all("/([a-zA-Z0-9^]{8})\s+.*?([0-9]+)\)(.+)/", $log, $match);

df43c987

158150d6

$current_commit = $match[1][0]; if ($current_commit != $previous_commit) { ++$i; $blame[$i] = array('line' => '', 'commit' => $current_commit);

df43c987

}

bda9cc5f

$blame[$i]['line'] .= PHP_EOL . $match[3][0];

158150d6

$previous_commit = $current_commit;

df43c987

} return $blame; } /** * Get the current Repository path

b00f723a

*

df43c987

* @return string Path where the repository is located */ public function getPath() { return $this->path; } /** * Set the current Repository path

b00f723a

*

df43c987

* @param string $path Path where the repository is located */ public function setPath($path) { $this->path = $path; } }