chitanka / chitanka

src/Command/GitCommitContentCommand.php

<?php namespace App\Command;

use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

class GitCommitContentCommand extends Command {

	private $output;

	public function getName() {
		return 'git:commit-content';
	}

	public function getDescription() {
		return 'Commit content changes from last X minutes';
	}

	public function getHelp() {
		return 'The <info>%command.name%</info> command commits all recent content changes.';
	}

	protected function getRequiredArguments() {
		return [
			'desc' => 'Brief description of changes',
		];
	}

	protected function getOptionalOptions() {
		return [
			'from' => ['Number of last minutes to check for changes', 30],
		];
	}

	/** {@inheritdoc} */
	protected function execute(InputInterface $input, OutputInterface $output): int {
		$this->output = $output;

		$description = $input->getArgument('desc');
		$lastMinutes = $input->getOption('from');
		$fromTime = date('Y-m-d H:i:s', strtotime("-$lastMinutes minutes"));
		$this->commitChanges($this->webDir('content'), $this->createMessageFile($description, $fromTime));

		$output->writeln('Done.');
		return self::SUCCESS;
	}

	/**
	 * @param string $contentDir
	 * @param string $messageFile
	 */
	private function commitChanges($contentDir, $messageFile) {
		if ( ! file_exists($messageFile)) {
			throw new \Exception("Message file '$messageFile' does not exist.");
		}
		$finder = new \Symfony\Component\Finder\Finder;
		foreach ($finder->directories()->in($contentDir)->depth(0) as $directory) {
			$this->gitCommitAndPush($directory, $messageFile);
		}
	}

	/**
	 * @param string $directory
	 * @param string $messageFile
	 */
	private function gitCommitAndPush($directory, $messageFile) {
		$this->output->writeln('');
		$this->output->writeln('===> Entering ' . basename($directory));
		chdir($directory);
		if (strpos(shell_exec('LC_ALL=C git status'), 'nothing to commit') !== false) {
			$this->output->writeln('Nothing to commit');
			return;
		}
		$this->output->writeln('Pulling eventual changes');
		shell_exec('git pull');
		$this->output->writeln('Staging current changes');
		shell_exec('git add .; git add -u .');
		$this->output->writeln('Commiting current changes');
		shell_exec("git commit --file='$messageFile'");
		$this->output->writeln('Pushing commit to remote server');
		shell_exec('git push');
	}

	/**
	 * @param string $description
	 * @param string $fromTime
	 */
	private function createMessageFile($description, $fromTime) {
		$filename = sys_get_temp_dir().'/chitanka-commit-content-'.time();
		file_put_contents($filename, $this->createMessageFileContents($description, $fromTime));
		return $filename;
	}

	/**
	 * @param string $description
	 * @param string $fromTime
	 */
	private function createMessageFileContents($description, $fromTime) {
		$messageId = date('#Ymd.His');
		$booksChanges = $this->getChangedBooksDescriptions($fromTime);
		$booksMessage = '';
		if (count($booksChanges) > 0) {
			$booksMessage .= count($booksChanges) == 1 ? 'Book:' : 'Books:';
			$booksMessage .= "\n" . implode("\n", $booksChanges);
		}

		$textsChanges = $this->getChangedTextsDescriptions($fromTime);
		$textsMessage = '';
		if (count($textsChanges) > 0) {
			$textsMessage .= count($textsChanges) == 1 ? 'Text:' : 'Texts:';
			$textsMessage .= "\n" . implode("\n", $textsChanges);
		}

		return <<<MSG
$description [$messageId]

$booksMessage

$textsMessage

MSG;
	}

	/**
	 * @RawSql
	 * @param string $fromTime
	 */
	private function getChangedBooksDescriptions($fromTime) {
		$sql = "SELECT CONCAT(b.id, ' / ', br.comment, ' / ', IFNULL(b.title_author, ''), ' — ', b.title, ' / ', b.type)
FROM `book_revision` br
LEFT JOIN book b on br.book_id = b.id
WHERE br.date >= '$fromTime'
LIMIT 1000";
		return $this->em->getConnection()->executeQuery($sql)->fetchAll(\PDO::FETCH_COLUMN);

The function Doctrine\DBAL\ForwardCompatibility\Result::fetchAll() has been deprecated: Use fetchAllNumeric(), fetchAllAssociative() or fetchFirstColumn() instead.

	}

	/**
	 * @RawSql
	 * @param string $fromTime
	 */
	private function getChangedTextsDescriptions($fromTime) {
		$sql = "SELECT CONCAT(t.id, ' / ', tr.comment, ' / ', GROUP_CONCAT(p.name SEPARATOR ', '), ' — ', t.title, ' / ', t.type)
FROM `text_revision` tr
LEFT JOIN `text` t ON tr.text_id = t.id
LEFT JOIN text_author ta ON ta.text_id = t.id
LEFT JOIN person p ON p.id = ta.person_id
WHERE tr.date >= '$fromTime'
GROUP BY tr.id
LIMIT 1000";
		return $this->em->getConnection()->executeQuery($sql)->fetchAll(\PDO::FETCH_COLUMN);

The function Doctrine\DBAL\ForwardCompatibility\Result::fetchAll() has been deprecated: Use fetchAllNumeric(), fetchAllAssociative() or fetchFirstColumn() instead.

	}
}