DeployJob

Complexity

Total Complexity

24

Size/Duplication

Total Lines	178
Duplicated Lines	17.98 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes	10
Bugs	1	Features	1

7 Methods

Rating	Name	Duplication	Size	Complexity
C	alarmHandler()	0	39	7
A	setUp()	0	17	4
C	perform()	22	70	7
A	onFailure()	0	3	1
A	updateStatus()	0	6	1
A	updateBackupStatus()	10	10	3
A	DNData()	0	3	1

<?php

/**
 * Runs a deployment via the most appropriate backend
 */
class DeployJob extends DeploynautJob {

	/**
	 * @var array
	 */
	public $args;

	/**
	 * Poll the sigFile looking for a signal to self-deliver.
	 * This is useful if we don't know the PID of the worker - we can easily deliver signals
	 * if we only know the ClassName and ID of the DataObject.
	 */
	public function alarmHandler() {
		$sigFile = $this->args['sigFile'];
		if (file_exists($sigFile) && is_readable($sigFile) && is_writable($sigFile)) {
			$signal = (int)file_get_contents($sigFile);
			if (is_int($signal) && in_array((int)$signal, [
				// The following signals are trapped by both Resque and Rainforest.
				SIGTERM,
				SIGINT,
				SIGQUIT,
				// The following are Resque only.
				SIGUSR1,
				SIGUSR2,
				SIGCONT
			])) {
				echo sprintf(
					'[-] Signal "%s" received, delivering to own process group, PID "%s".' . PHP_EOL,
					$signal,
					getmypid()
				);

				// Mark the signal as received.
				unlink($sigFile);

				// Dispatch to own process group.
				$pgid = posix_getpgid(getmypid());
				if ($pgid<=0) {
					echo sprintf(
						'[-] Unable to send signal to invalid PGID "%s".' . PHP_EOL,
						$pgid
					);
				} else {
					posix_kill(-$pgid, $signal);
				}
			}
		}

		// Wake up again soon.
		pcntl_alarm(1);
	}

	public function setUp() {
		// Make this process a session leader so we can send signals
		// to this job as a whole (including any subprocesses such as spawned by Symfony).
		posix_setsid();

		if(function_exists('pcntl_alarm') && function_exists('pcntl_signal')) {
			if (!empty($this->args['sigFile'])) {
				echo sprintf('[-] Signal file requested, polling "%s".' . PHP_EOL, $this->args['sigFile']);
				declare(ticks = 1);
				pcntl_signal(SIGALRM, [$this, 'alarmHandler']);
				pcntl_alarm(1);
			}
		}

		$this->updateStatus(DNDeployment::TR_DEPLOY);
		chdir(BASE_PATH);
	}

	public function perform() {
		echo "[-] DeployJob starting" . PHP_EOL;
		$log = new DeploynautLogFile($this->args['logfile']);

		$deployment = DNDeployment::get()->byID($this->args['deploymentID']);
		$environment = $deployment->Environment();
		$project = $environment->Project();
		$backupDataTransfer = null;
		$backupMode = !empty($this->args['backup_mode']) ? $this->args['backup_mode'] : 'db';

		// Perform pre-deploy backup here if required. Note that the backup is done here within
		// the deploy job, so that the order of backup is done before deployment, and so it
		// doesn't tie up another worker. It also puts the backup output into
		// the same log as the deployment so there is visibility on what is going on.
		if(!empty($this->args['predeploy_backup'])) {

This code seems to be duplicated across your project.

			$backupDataTransfer = DNDataTransfer::create();
			$backupDataTransfer->EnvironmentID = $environment->ID;
			$backupDataTransfer->Direction = 'get';
			$backupDataTransfer->Mode = $backupMode;
			$backupDataTransfer->ResqueToken = $deployment->ResqueToken;
			$backupDataTransfer->AuthorID = $deployment->DeployerID;
			$backupDataTransfer->write();

			$deployment->BackupDataTransferID = $backupDataTransfer->ID;
			$deployment->write();
		}

		// This is a bit icky, but there is no easy way of capturing a failed deploy by using the PHP Resque
		try {
			// Disallow concurrent deployments (don't rely on queuing implementation to restrict this)
			// Only consider deployments started in the last 30 minutes (older jobs probably got stuck)
			$runningDeployments = $environment->runningDeployments()->exclude('ID', $this->args['deploymentID']);
			if($runningDeployments->count()) {
				$runningDeployment = $runningDeployments->first();
				$message = sprintf(
					'Error: another deployment is in progress (started at %s by %s)',
					$runningDeployment->dbObject('Created')->Nice(),
					$runningDeployment->Deployer()->Title
				);
				$log->write($message);
				throw new \RuntimeException($message);
			}

			if($backupDataTransfer) {

This code seems to be duplicated across your project.

				$log->write('Backing up existing data');
				try {
					$environment->Backend()->dataTransfer($backupDataTransfer, $log);
					$this->updateBackupStatus('Finished');
				} catch(Exception $e) {
					$this->updateBackupStatus('Failed');
					throw $e;
				}
			}

			$environment->Backend()->deploy(
				$environment,
				$log,
				$project,
				// Pass all args to give the backend full visibility. These args also contain
				// all options from the DeploymentStrategy merged in, including sha.
				$this->args
			);
		} catch(Exception $e) {
			// DeploynautJob will automatically trigger onFailure.
			echo "[-] DeployJob failed" . PHP_EOL;
			throw $e;
		}
		$this->updateStatus(DNDeployment::TR_COMPLETE);
		echo "[-] DeployJob finished" . PHP_EOL;
	}

	public function onFailure(Exception $exception) {
		$this->updateStatus(DNDeployment::TR_FAIL);
	}

	/**
	 * @param string $status Transition
	 * @global array $databaseConfig
	 */
	protected function updateStatus($status) {
		global $databaseConfig;
		DB::connect($databaseConfig);
		$deployment = DNDeployment::get()->byID($this->args['deploymentID']);
		$deployment->getMachine()->apply($status);
	}

	/**
	 * @param string $status Status of DNDataTransfer
	 * @global array $databaseConfig
	 */
	protected function updateBackupStatus($status) {

This method seems to be duplicated in your project.

		global $databaseConfig;
		DB::connect($databaseConfig);
		$deployment = DNDeployment::get()->byID($this->args['deploymentID']);
		$backup = $deployment->BackupDataTransfer();
		if($backup && $backup->exists()) {
			$backup->Status = $status;
			$backup->write();
		}
	}

	/**
	 * @return DNData
	 */
	protected function DNData() {
		return DNData::inst();
	}
}