DataTransferJob

Complexity

Total Complexity

13

Size/Duplication

Total Lines	110
Duplicated Lines	29.09 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes	4
Bugs	1	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	4	1
B	perform()	22	63	7
A	updateStatus()	0	7	1
A	updateBackupStatus()	10	10	3
A	DNData()	0	3	1

<?php

/**
 * Starts a capistrano script for either retrieving data from an environment,
 * or pushing data into an environment. Initiated by {@link DNDataTransfer}.
 *
 * @package deploynaut
 * @subpackage jobs
 */
class DataTransferJob extends DeploynautJob {

	/**
	 * set by a resque worker
	 */
	public $args = array();

	public function setUp() {
		$this->updateStatus('Started');
		chdir(BASE_PATH);
	}

	public function perform() {
		echo "[-] DataTransferJob starting" . PHP_EOL;
		$log = new DeploynautLogFile($this->args['logfile']);
		$dataTransfer = DNDataTransfer::get()->byID($this->args['dataTransferID']);
		$environment = $dataTransfer->Environment();
		$backupDataTransfer = null;

		if(!empty($this->args['backupBeforePush']) && $dataTransfer->Direction == 'push') {

This code seems to be duplicated across your project.

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

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

		// This is a bit icky, but there is no easy way of capturing a failed run by using the PHP Resque
		try {
			// Disallow concurrent jobs (don't rely on queuing implementation to restrict this)
			// Only consider data transfers started in the last 30 minutes (older jobs probably got stuck)
			$runningTransfers = DNDataTransfer::get()
				->filter(array(
					'EnvironmentID' => $environment->ID,
					'Status' => array('Queued', 'Started'),
					'Created:GreaterThan' => strtotime('-30 minutes')
				))
				->exclude('ID', $dataTransfer->ID);

			if($runningTransfers->count()) {
				$runningTransfer = $runningTransfers->first();
				$message = sprintf(
					'Error: another transfer is in progress (started at %s by %s)',
					$runningTransfer->dbObject('Created')->Nice(),
					$runningTransfer->Author()->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()->dataTransfer($dataTransfer, $log);
		} catch(Exception $e) {
			echo "[-] DataTransferJob failed" . PHP_EOL;
			throw $e;
		}

		$this->updateStatus('Finished');
		echo "[-] DataTransferJob finished" . PHP_EOL;
	}

	/**
	 * @param string $status
	 * @global array $databaseConfig
	 */
	protected function updateStatus($status) {
		global $databaseConfig;
		DB::connect($databaseConfig);
		$transfer = DNDataTransfer::get()->byID($this->args['dataTransferID']);
		$transfer->Status = $status;
		$transfer->write();
	}

	/**
	 * @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();
	}
}