silverstripe / deploynaut

code/model/DNDataArchive.php

Indentation +540 added lines, -540 removed lines

@@ -50,544 +50,544 @@
 class DNDataArchive extends DataObject
 {
 
-    private static $db = array(
-        'UploadToken' => 'Varchar(8)',
-        'ArchiveFileHash' => 'Varchar(32)',
-        "Mode" => "Enum('all, assets, db', '')",
-        "IsBackup" => "Boolean",
-        "IsManualUpload" => "Boolean",
-    );
-
-    private static $has_one = array(
-        'Author' => 'Member',
-        'OriginalEnvironment' => 'DNEnvironment',
-        'Environment' => 'DNEnvironment',
-        'ArchiveFile' => 'File'
-    );
-
-    private static $has_many = array(
-        'DataTransfers' => 'DNDataTransfer',
-    );
-
-    private static $singular_name = 'Data Archive';
-
-    private static $plural_name = 'Data Archives';
-
-    private static $summary_fields = array(
-        'Created' => 'Created',
-        'Author.Title' => 'Author',
-        'Environment.Project.Name' => 'Project',
-        'OriginalEnvironment.Name' => 'Origin',
-        'Environment.Name' => 'Environment',
-        'ArchiveFile.Name' => 'File',
-    );
-
-    private static $searchable_fields = array(
-        'Environment.Project.Name' => array(
-            'title' => 'Project',
-        ),
-        'OriginalEnvironment.Name' => array(
-            'title' => 'Origin',
-        ),
-        'Environment.Name' => array(
-            'title' => 'Environment',
-        ),
-        'UploadToken' => array(
-            'title' => 'Upload Token',
-        ),
-        'Mode' => array(
-            'title' => 'Mode',
-        ),
-    );
-
-    private static $_cache_can_restore = array();
-
-    private static $_cache_can_download = array();
-
-    public static function get_mode_map()
-    {
-        return array(
-            'all' => 'Database and Assets',
-            'db' => 'Database only',
-            'assets' => 'Assets only',
-        );
-    }
-
-    /**
-     * Returns a unique token to correlate an offline item (posted DVD)
-     * with a specific archive placeholder.
-     *
-     * @return string
-     */
-    public static function generate_upload_token($chars = 8)
-    {
-        $generator = new RandomGenerator();
-        return strtoupper(substr($generator->randomToken(), 0, $chars));
-    }
-
-    public function onBeforeWrite()
-    {
-        if (!$this->AuthorID) {
-            $this->AuthorID = Member::currentUserID();
-        }
-
-        parent::onBeforeWrite();
-    }
-
-    public function onAfterDelete()
-    {
-        $this->ArchiveFile()->delete();
-    }
-
-    public function getCMSFields()
-    {
-        $fields = parent::getCMSFields();
-        $fields->removeByName('OriginalEnvironmentID');
-        $fields->removeByName('EnvironmentID');
-        $fields->removeByName('ArchiveFile');
-        $fields->addFieldsToTab(
-            'Root.Main',
-            array(
-                new ReadonlyField('ProjectName', 'Project', $this->Environment()->Project()->Name),
-                new ReadonlyField('OriginalEnvironmentName', 'OriginalEnvironment', $this->OriginalEnvironment()->Name),
-                new ReadonlyField('EnvironmentName', 'Environment', $this->Environment()->Name),
-                $linkField = new ReadonlyField(
-                    'DataArchive',
-                    'Archive File',
-                    sprintf(
-                        '<a href="%s">%s</a>',
-                        $this->ArchiveFile()->AbsoluteURL,
-                        $this->ArchiveFile()->Filename
-                    )
-                ),
-                new GridField(
-                    'DataTransfers',
-                    'Transfers',
-                    $this->DataTransfers()
-                ),
-            )
-        );
-        $linkField->dontEscape = true;
-        $fields = $fields->makeReadonly();
-
-        return $fields;
-    }
-
-    public function getDefaultSearchContext()
-    {
-        $context = parent::getDefaultSearchContext();
-        $context->getFields()->dataFieldByName('Mode')->setHasEmptyDefault(true);
-
-        return $context;
-    }
-
-    /**
-     * Calculates and returns a human-readable size of this archive file. If the file exists, it will determine
-     * whether to display the output in bytes, kilobytes, megabytes, or gigabytes.
-     *
-     * @return string The human-readable size of this archive file
-     */
-    public function FileSize()
-    {
-        if ($this->ArchiveFile()->exists()) {
-            return $this->ArchiveFile()->getSize();
-        } else {
-            return "N/A";
-        }
-    }
-
-    public function getModeNice()
-    {
-        if ($this->Mode == 'all') {
-            return 'database and assets';
-        } else {
-            return $this->Mode;
-        }
-    }
-
-    /**
-     * Some archives don't have files attached to them yet,
-     * because a file has been posted offline and is waiting to be uploaded
-     * against this "archive placeholder".
-     *
-     * @return boolean
-     */
-    public function isPending()
-    {
-        return !($this->ArchiveFileID);
-    }
-
-    /**
-     * Inferred from both restore and backup permissions.
-     *
-     * @param Member|null $member The {@link Member} object to test against.
-     */
-    public function canView($member = null)
-    {
-        return ($this->canRestore($member) || $this->canDownload($member));
-    }
-
-    /**
-     * Whether a {@link Member} can restore this archive to an environment.
-     * This only needs to be checked *once* per member and environment.
-     *
-     * @param Member|null $member The {@link Member} object to test against.
-     * @return true if $member (or the currently logged in member if null) can upload this archive
-     */
-    public function canRestore($member = null)
-    {
-        $memberID = $member ? $member->ID : Member::currentUserID();
-        if (!$memberID) {
-            return false;
-        }
-
-        $key = $memberID . '-' . $this->EnvironmentID;
-        if (!isset(self::$_cache_can_restore[$key])) {
-            self::$_cache_can_restore[$key] = $this->Environment()->canUploadArchive($member);
-        }
-
-        return self::$_cache_can_restore[$key];
-    }
-
-    /**
-     * Whether a {@link Member} can download this archive to their PC.
-     * This only needs to be checked *once* per member and environment.
-     *
-     * @param Member|null $member The {@link Member} object to test against.
-     * @return true if $member (or the currently logged in member if null) can download this archive
-     */
-    public function canDownload($member = null)
-    {
-        $memberID = $member ? $member->ID : Member::currentUserID();
-        if (!$memberID) {
-            return false;
-        }
-
-        $key = $memberID . '-' . $this->EnvironmentID;
-        if (!isset(self::$_cache_can_download[$key])) {
-            self::$_cache_can_download[$key] = $this->Environment()->canDownloadArchive($member);
-        }
-        return self::$_cache_can_download[$key];
-    }
-
-    /**
-     * Whether a {@link Member} can delete this archive from staging area.
-     *
-     * @param Member|null $member The {@link Member} object to test against.
-     * @return boolean if $member (or the currently logged in member if null) can delete this archive
-     */
-    public function canDelete($member = null)
-    {
-        return $this->Environment()->canDeleteArchive($member);
-    }
-
-    /**
-     * Check if this member can move archive into the environment.
-     *
-     * @param DNEnvironment $targetEnv Environment to check.
-     * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
-     *
-     * @return boolean true if $member can upload archives linked to this environment, false if they can't.
-     */
-    public function canMoveTo($targetEnv, $member = null)
-    {
-        if ($this->Environment()->Project()->ID != $targetEnv->Project()->ID) {
-            // We don't permit moving snapshots between projects at this stage.
-            return false;
-        }
-
-        if (!$member) {
-            $member = Member::currentUser();
-        }
-
-        // Must be logged in to check permissions
-        if (!$member) {
-            return false;
-        }
-
-        // Admin can always move.
-        if (Permission::checkMember($member, 'ADMIN')) {
-            return true;
-        }
-
-        // Checks if the user can actually access the archive.
-        if (!$this->canDownload($member)) {
-            return false;
-        }
-
-        // Hooks into ArchiveUploaders permission to prevent proliferation of permission checkboxes.
-        // Bypasses the quota check - we don't need to check for it as long as we move the snapshot within the project.
-        return $targetEnv->ArchiveUploaders()->byID($member->ID)
-            || $member->inGroups($targetEnv->ArchiveUploaderGroups());
-    }
-
-    /**
-     * Finds all environments within this project where the archive can be moved to.
-     * Excludes current environment automatically.
-     *
-     * @return ArrayList List of valid environments.
-     */
-    public function validTargetEnvironments()
-    {
-        $archive = $this;
-        $envs = $this->Environment()->Project()->DNEnvironmentList()
-            ->filterByCallback(function ($item) use ($archive) {
-                return $archive->EnvironmentID != $item->ID && $archive->canMoveTo($item);
-            });
-
-        return $envs;
-    }
-
-    /**
-     * Returns a unique filename, including project/environment/timestamp details.
-     * @return string
-     */
-    public function generateFilename(DNDataTransfer $dataTransfer)
-    {
-        $generator = new RandomGenerator();
-        $filter = FileNameFilter::create();
-
-        return sprintf(
-            '%s-%s-%s-%s-%s',
-            $filter->filter(strtolower($this->OriginalEnvironment()->Project()->Name)),
-            $filter->filter(strtolower($this->OriginalEnvironment()->Name)),
-            $dataTransfer->Mode,
-            date('Ymd'),
-            sha1($generator->generateEntropy())
-        );
-    }
-
-    /**
-     * Returns a path unique to a specific transfer, including project/environment details.
-     * Does not create the path on the filesystem. Can be used to store files related to this transfer.
-     *
-     * @param DNDataTransfer
-     * @return string Absolute file path
-     */
-    public function generateFilepath(DNDataTransfer $dataTransfer)
-    {
-        $data = DNData::inst();
-        $transferDir = $data->getDataTransferDir();
-        $filter = FileNameFilter::create();
-
-        return sprintf('%s/%s/%s/transfer-%s/',
-            $transferDir,
-            $filter->filter(strtolower($this->OriginalEnvironment()->Project()->Name)),
-            $filter->filter(strtolower($this->OriginalEnvironment()->Name)),
-            $dataTransfer->ID
-        );
-    }
-
-    /**
-     * Attach an sspak file path to this archive and associate the transfer.
-     * Does the job of creating a {@link File} record, and setting correct paths into the assets directory.
-     *
-     * @param string $sspakFilepath
-     * @param DNDataTransfer $dataTransfer
-     * @return bool
-     */
-    public function attachFile($sspakFilepath, DNDataTransfer $dataTransfer)
-    {
-        $sspakFilepath = ltrim(
-            str_replace(
-                array(ASSETS_PATH, realpath(ASSETS_PATH)),
-                '',
-                $sspakFilepath
-            ),
-            DIRECTORY_SEPARATOR
-        );
-
-        $folder = Folder::find_or_make(dirname($sspakFilepath));
-        $file = new File();
-        $file->Name = basename($sspakFilepath);
-        $file->Filename = $sspakFilepath;
-        $file->ParentID = $folder->ID;
-        $file->write();
-
-        // "Status" will be updated by the job execution
-        $dataTransfer->write();
-
-        // Get file hash to ensure consistency.
-        // Only do this when first associating the file since hashing large files is expensive.
-        // Note that with CapistranoDeploymentBackend the file won't be available yet, as it
-        // gets put in place immediately after this method gets called. In which case, it will
-        // be hashed in setArchiveFromFiles()
-        if (file_exists($file->FullPath)) {
-            $this->ArchiveFileHash = md5_file($file->FullPath);
-        }
-        $this->ArchiveFileID = $file->ID;
-        $this->DataTransfers()->add($dataTransfer);
-        $this->write();
-
-        return true;
-    }
-
-    /**
-     * Extract the current sspak contents into the given working directory.
-     * This also extracts the assets and database and puts them into
-     * <workingdir>/database.sql and <workingdir>/assets, respectively.
-     *
-     * @param string|null $workingDir The path to extract to
-     * @throws RuntimeException
-     * @return bool
-     */
-    public function extractArchive($workingDir = null)
-    {
-        if (!is_dir($workingDir)) {
-            mkdir($workingDir, 0700, true);
-        }
-
-        $cleanupFn = function () use ($workingDir) {
-            $process = new Process(sprintf('rm -rf %s', escapeshellarg($workingDir)));
-            $process->run();
-        };
-
-        // Extract *.sspak to a temporary location
-        $sspakFilename = $this->ArchiveFile()->FullPath;
-        $process = new Process(sprintf(
-            'sspak extract %s %s',
-            escapeshellarg($sspakFilename),
-            escapeshellarg($workingDir)
-        ));
-        $process->setTimeout(3600);
-        $process->run();
-        if (!$process->isSuccessful()) {
-            $cleanupFn();
-            throw new RuntimeException(sprintf('Could not extract the sspak file: %s', $process->getErrorOutput()));
-        }
-
-        // Extract database.sql.gz to <workingdir>/database.sql
-        if (file_exists($workingDir . DIRECTORY_SEPARATOR . 'database.sql.gz')) {
-            $process = new Process('gunzip database.sql.gz', $workingDir);
-            $process->setTimeout(3600);
-            $process->run();
-            if (!$process->isSuccessful()) {
-                $cleanupFn();
-                throw new RuntimeException(sprintf('Could not extract the db archive: %s', $process->getErrorOutput()));
-            }
-        }
-
-        // Extract assets.tar.gz to <workingdir>/assets/
-        if (file_exists($workingDir . DIRECTORY_SEPARATOR . 'assets.tar.gz')) {
-            $process = new Process('tar xzf assets.tar.gz', $workingDir);
-            $process->setTimeout(3600);
-            $process->run();
-            if (!$process->isSuccessful()) {
-                $cleanupFn();
-                throw new RuntimeException(sprintf('Could not extract the assets archive: %s', $process->getErrorOutput()));
-            }
-        }
-
-        return true;
-    }
-
-    /**
-     * Validate that an sspak contains the correct content.
-     *
-     * For example, if the user uploaded an sspak containing just the db, but declared in the form
-     * that it contained db+assets, then the archive is not valid.
-     *
-     * @param string|null $mode "db", "assets", or "all". This is the content we're checking for. Default to the archive setting
-     * @return ValidationResult
-     */
-    public function validateArchiveContents($mode = null)
-    {
-        $mode = $mode ?: $this->Mode;
-        $result = new ValidationResult();
-
-        $file = $this->ArchiveFile()->FullPath;
-
-        if (!is_readable($file)) {
-            $result->error(sprintf('SSPak file "%s" cannot be read.', $file));
-            return $result;
-        }
-
-        $process = new Process(sprintf('tar -tf %s', escapeshellarg($file)));
-        $process->setTimeout(120);
-        $process->run();
-        if (!$process->isSuccessful()) {
-            throw new RuntimeException(sprintf('Could not list files in archive: %s', $process->getErrorOutput()));
-        }
-
-        $output = explode(PHP_EOL, $process->getOutput());
-        $files = array_filter($output);
-
-        if (in_array($mode, array('all', 'db')) && !in_array('database.sql.gz', $files)) {
-            $result->error('The snapshot is missing the database.');
-            return $result;
-        }
-
-        if (in_array($mode, array('all', 'assets')) && !in_array('assets.tar.gz', $files)) {
-            $result->error('The snapshot is missing assets.');
-            return $result;
-        }
-
-        return $result;
-    }
-
-    /**
-     * Given a path that already exists and contains an extracted sspak, including
-     * the assets, fix all of the file permissions so they're in a state ready to
-     * be pushed to remote servers.
-     *
-     * Normally, command line tar will use permissions found in the archive, but will
-     * substract the user's umask from them. This has a potential to create unreadable
-     * files, e.g. cygwin on Windows will pack files with mode 000, hence why this fix
-     * is necessary.
-     *
-     * @param string|null $workingDir The path of where the sspak has been extracted to
-     * @throws RuntimeException
-     * @return bool
-     */
-    public function fixArchivePermissions($workingDir)
-    {
-        $fixCmds = array(
-            // The directories need to have permissions changed one by one (hence the ; instead of +),
-            // otherwise we might end up having no +x access to a directory deeper down.
-            sprintf('find %s -type d -exec chmod 755 {} \;', escapeshellarg($workingDir)),
-            sprintf('find %s -type f -exec chmod 644 {} +', escapeshellarg($workingDir))
-        );
-
-        foreach ($fixCmds as $cmd) {
-            $process = new Process($cmd);
-            $process->setTimeout(3600);
-            $process->run();
-            if (!$process->isSuccessful()) {
-                throw new RuntimeException($process->getErrorOutput());
-            }
-        }
-
-        return true;
-    }
-
-    /**
-     * Given extracted sspak contents, create an sspak from it
-     * and overwrite the current ArchiveFile with it's contents.
-     *
-     * @param string|null $workingDir The path of where the sspak has been extracted to
-     * @return bool
-     */
-    public function setArchiveFromFiles($workingDir)
-    {
-        $command = sprintf('sspak saveexisting %s 2>&1', $this->ArchiveFile()->FullPath);
-        if ($this->Mode == 'db') {
-            $command .= sprintf(' --db=%s/database.sql', $workingDir);
-        } elseif ($this->Mode == 'assets') {
-            $command .= sprintf(' --assets=%s/assets', $workingDir);
-        } else {
-            $command .= sprintf(' --db=%s/database.sql --assets=%s/assets', $workingDir, $workingDir);
-        }
-
-        $process = new Process($command, $workingDir);
-        $process->setTimeout(3600);
-        $process->run();
-        if (!$process->isSuccessful()) {
-            throw new RuntimeException($process->getErrorOutput());
-        }
-
-        $this->ArchiveFileHash = md5_file($this->ArchiveFile()->FullPath);
-        $this->write();
-
-        return true;
-    }
+	private static $db = array(
+		'UploadToken' => 'Varchar(8)',
+		'ArchiveFileHash' => 'Varchar(32)',
+		"Mode" => "Enum('all, assets, db', '')",
+		"IsBackup" => "Boolean",
+		"IsManualUpload" => "Boolean",
+	);
+
+	private static $has_one = array(
+		'Author' => 'Member',
+		'OriginalEnvironment' => 'DNEnvironment',
+		'Environment' => 'DNEnvironment',
+		'ArchiveFile' => 'File'
+	);
+
+	private static $has_many = array(
+		'DataTransfers' => 'DNDataTransfer',
+	);
+
+	private static $singular_name = 'Data Archive';
+
+	private static $plural_name = 'Data Archives';
+
+	private static $summary_fields = array(
+		'Created' => 'Created',
+		'Author.Title' => 'Author',
+		'Environment.Project.Name' => 'Project',
+		'OriginalEnvironment.Name' => 'Origin',
+		'Environment.Name' => 'Environment',
+		'ArchiveFile.Name' => 'File',
+	);
+
+	private static $searchable_fields = array(
+		'Environment.Project.Name' => array(
+			'title' => 'Project',
+		),
+		'OriginalEnvironment.Name' => array(
+			'title' => 'Origin',
+		),
+		'Environment.Name' => array(
+			'title' => 'Environment',
+		),
+		'UploadToken' => array(
+			'title' => 'Upload Token',
+		),
+		'Mode' => array(
+			'title' => 'Mode',
+		),
+	);
+
+	private static $_cache_can_restore = array();
+
+	private static $_cache_can_download = array();
+
+	public static function get_mode_map()
+	{
+		return array(
+			'all' => 'Database and Assets',
+			'db' => 'Database only',
+			'assets' => 'Assets only',
+		);
+	}
+
+	/**
+	 * Returns a unique token to correlate an offline item (posted DVD)
+	 * with a specific archive placeholder.
+	 *
+	 * @return string
+	 */
+	public static function generate_upload_token($chars = 8)
+	{
+		$generator = new RandomGenerator();
+		return strtoupper(substr($generator->randomToken(), 0, $chars));
+	}
+
+	public function onBeforeWrite()
+	{
+		if (!$this->AuthorID) {
+			$this->AuthorID = Member::currentUserID();
+		}
+
+		parent::onBeforeWrite();
+	}
+
+	public function onAfterDelete()
+	{
+		$this->ArchiveFile()->delete();
+	}
+
+	public function getCMSFields()
+	{
+		$fields = parent::getCMSFields();
+		$fields->removeByName('OriginalEnvironmentID');
+		$fields->removeByName('EnvironmentID');
+		$fields->removeByName('ArchiveFile');
+		$fields->addFieldsToTab(
+			'Root.Main',
+			array(
+				new ReadonlyField('ProjectName', 'Project', $this->Environment()->Project()->Name),
+				new ReadonlyField('OriginalEnvironmentName', 'OriginalEnvironment', $this->OriginalEnvironment()->Name),
+				new ReadonlyField('EnvironmentName', 'Environment', $this->Environment()->Name),
+				$linkField = new ReadonlyField(
+					'DataArchive',
+					'Archive File',
+					sprintf(
+						'<a href="%s">%s</a>',
+						$this->ArchiveFile()->AbsoluteURL,
+						$this->ArchiveFile()->Filename
+					)
+				),
+				new GridField(
+					'DataTransfers',
+					'Transfers',
+					$this->DataTransfers()
+				),
+			)
+		);
+		$linkField->dontEscape = true;
+		$fields = $fields->makeReadonly();
+
+		return $fields;
+	}
+
+	public function getDefaultSearchContext()
+	{
+		$context = parent::getDefaultSearchContext();
+		$context->getFields()->dataFieldByName('Mode')->setHasEmptyDefault(true);
+
+		return $context;
+	}
+
+	/**
+	 * Calculates and returns a human-readable size of this archive file. If the file exists, it will determine
+	 * whether to display the output in bytes, kilobytes, megabytes, or gigabytes.
+	 *
+	 * @return string The human-readable size of this archive file
+	 */
+	public function FileSize()
+	{
+		if ($this->ArchiveFile()->exists()) {
+			return $this->ArchiveFile()->getSize();
+		} else {
+			return "N/A";
+		}
+	}
+
+	public function getModeNice()
+	{
+		if ($this->Mode == 'all') {
+			return 'database and assets';
+		} else {
+			return $this->Mode;
+		}
+	}
+
+	/**
+	 * Some archives don't have files attached to them yet,
+	 * because a file has been posted offline and is waiting to be uploaded
+	 * against this "archive placeholder".
+	 *
+	 * @return boolean
+	 */
+	public function isPending()
+	{
+		return !($this->ArchiveFileID);
+	}
+
+	/**
+	 * Inferred from both restore and backup permissions.
+	 *
+	 * @param Member|null $member The {@link Member} object to test against.
+	 */
+	public function canView($member = null)
+	{
+		return ($this->canRestore($member) || $this->canDownload($member));
+	}
+
+	/**
+	 * Whether a {@link Member} can restore this archive to an environment.
+	 * This only needs to be checked *once* per member and environment.
+	 *
+	 * @param Member|null $member The {@link Member} object to test against.
+	 * @return true if $member (or the currently logged in member if null) can upload this archive
+	 */
+	public function canRestore($member = null)
+	{
+		$memberID = $member ? $member->ID : Member::currentUserID();
+		if (!$memberID) {
+			return false;
+		}
+
+		$key = $memberID . '-' . $this->EnvironmentID;
+		if (!isset(self::$_cache_can_restore[$key])) {
+			self::$_cache_can_restore[$key] = $this->Environment()->canUploadArchive($member);
+		}
+
+		return self::$_cache_can_restore[$key];
+	}
+
+	/**
+	 * Whether a {@link Member} can download this archive to their PC.
+	 * This only needs to be checked *once* per member and environment.
+	 *
+	 * @param Member|null $member The {@link Member} object to test against.
+	 * @return true if $member (or the currently logged in member if null) can download this archive
+	 */
+	public function canDownload($member = null)
+	{
+		$memberID = $member ? $member->ID : Member::currentUserID();
+		if (!$memberID) {
+			return false;
+		}
+
+		$key = $memberID . '-' . $this->EnvironmentID;
+		if (!isset(self::$_cache_can_download[$key])) {
+			self::$_cache_can_download[$key] = $this->Environment()->canDownloadArchive($member);
+		}
+		return self::$_cache_can_download[$key];
+	}
+
+	/**
+	 * Whether a {@link Member} can delete this archive from staging area.
+	 *
+	 * @param Member|null $member The {@link Member} object to test against.
+	 * @return boolean if $member (or the currently logged in member if null) can delete this archive
+	 */
+	public function canDelete($member = null)
+	{
+		return $this->Environment()->canDeleteArchive($member);
+	}
+
+	/**
+	 * Check if this member can move archive into the environment.
+	 *
+	 * @param DNEnvironment $targetEnv Environment to check.
+	 * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
+	 *
+	 * @return boolean true if $member can upload archives linked to this environment, false if they can't.
+	 */
+	public function canMoveTo($targetEnv, $member = null)
+	{
+		if ($this->Environment()->Project()->ID != $targetEnv->Project()->ID) {
+			// We don't permit moving snapshots between projects at this stage.
+			return false;
+		}
+
+		if (!$member) {
+			$member = Member::currentUser();
+		}
+
+		// Must be logged in to check permissions
+		if (!$member) {
+			return false;
+		}
+
+		// Admin can always move.
+		if (Permission::checkMember($member, 'ADMIN')) {
+			return true;
+		}
+
+		// Checks if the user can actually access the archive.
+		if (!$this->canDownload($member)) {
+			return false;
+		}
+
+		// Hooks into ArchiveUploaders permission to prevent proliferation of permission checkboxes.
+		// Bypasses the quota check - we don't need to check for it as long as we move the snapshot within the project.
+		return $targetEnv->ArchiveUploaders()->byID($member->ID)
+			|| $member->inGroups($targetEnv->ArchiveUploaderGroups());
+	}
+
+	/**
+	 * Finds all environments within this project where the archive can be moved to.
+	 * Excludes current environment automatically.
+	 *
+	 * @return ArrayList List of valid environments.
+	 */
+	public function validTargetEnvironments()
+	{
+		$archive = $this;
+		$envs = $this->Environment()->Project()->DNEnvironmentList()
+			->filterByCallback(function ($item) use ($archive) {
+				return $archive->EnvironmentID != $item->ID && $archive->canMoveTo($item);
+			});
+
+		return $envs;
+	}
+
+	/**
+	 * Returns a unique filename, including project/environment/timestamp details.
+	 * @return string
+	 */
+	public function generateFilename(DNDataTransfer $dataTransfer)
+	{
+		$generator = new RandomGenerator();
+		$filter = FileNameFilter::create();
+
+		return sprintf(
+			'%s-%s-%s-%s-%s',
+			$filter->filter(strtolower($this->OriginalEnvironment()->Project()->Name)),
+			$filter->filter(strtolower($this->OriginalEnvironment()->Name)),
+			$dataTransfer->Mode,
+			date('Ymd'),
+			sha1($generator->generateEntropy())
+		);
+	}
+
+	/**
+	 * Returns a path unique to a specific transfer, including project/environment details.
+	 * Does not create the path on the filesystem. Can be used to store files related to this transfer.
+	 *
+	 * @param DNDataTransfer
+	 * @return string Absolute file path
+	 */
+	public function generateFilepath(DNDataTransfer $dataTransfer)
+	{
+		$data = DNData::inst();
+		$transferDir = $data->getDataTransferDir();
+		$filter = FileNameFilter::create();
+
+		return sprintf('%s/%s/%s/transfer-%s/',
+			$transferDir,
+			$filter->filter(strtolower($this->OriginalEnvironment()->Project()->Name)),
+			$filter->filter(strtolower($this->OriginalEnvironment()->Name)),
+			$dataTransfer->ID
+		);
+	}
+
+	/**
+	 * Attach an sspak file path to this archive and associate the transfer.
+	 * Does the job of creating a {@link File} record, and setting correct paths into the assets directory.
+	 *
+	 * @param string $sspakFilepath
+	 * @param DNDataTransfer $dataTransfer
+	 * @return bool
+	 */
+	public function attachFile($sspakFilepath, DNDataTransfer $dataTransfer)
+	{
+		$sspakFilepath = ltrim(
+			str_replace(
+				array(ASSETS_PATH, realpath(ASSETS_PATH)),
+				'',
+				$sspakFilepath
+			),
+			DIRECTORY_SEPARATOR
+		);
+
+		$folder = Folder::find_or_make(dirname($sspakFilepath));
+		$file = new File();
+		$file->Name = basename($sspakFilepath);
+		$file->Filename = $sspakFilepath;
+		$file->ParentID = $folder->ID;
+		$file->write();
+
+		// "Status" will be updated by the job execution
+		$dataTransfer->write();
+
+		// Get file hash to ensure consistency.
+		// Only do this when first associating the file since hashing large files is expensive.
+		// Note that with CapistranoDeploymentBackend the file won't be available yet, as it
+		// gets put in place immediately after this method gets called. In which case, it will
+		// be hashed in setArchiveFromFiles()
+		if (file_exists($file->FullPath)) {
+			$this->ArchiveFileHash = md5_file($file->FullPath);
+		}
+		$this->ArchiveFileID = $file->ID;
+		$this->DataTransfers()->add($dataTransfer);
+		$this->write();
+
+		return true;
+	}
+
+	/**
+	 * Extract the current sspak contents into the given working directory.
+	 * This also extracts the assets and database and puts them into
+	 * <workingdir>/database.sql and <workingdir>/assets, respectively.
+	 *
+	 * @param string|null $workingDir The path to extract to
+	 * @throws RuntimeException
+	 * @return bool
+	 */
+	public function extractArchive($workingDir = null)
+	{
+		if (!is_dir($workingDir)) {
+			mkdir($workingDir, 0700, true);
+		}
+
+		$cleanupFn = function () use ($workingDir) {
+			$process = new Process(sprintf('rm -rf %s', escapeshellarg($workingDir)));
+			$process->run();
+		};
+
+		// Extract *.sspak to a temporary location
+		$sspakFilename = $this->ArchiveFile()->FullPath;
+		$process = new Process(sprintf(
+			'sspak extract %s %s',
+			escapeshellarg($sspakFilename),
+			escapeshellarg($workingDir)
+		));
+		$process->setTimeout(3600);
+		$process->run();
+		if (!$process->isSuccessful()) {
+			$cleanupFn();
+			throw new RuntimeException(sprintf('Could not extract the sspak file: %s', $process->getErrorOutput()));
+		}
+
+		// Extract database.sql.gz to <workingdir>/database.sql
+		if (file_exists($workingDir . DIRECTORY_SEPARATOR . 'database.sql.gz')) {
+			$process = new Process('gunzip database.sql.gz', $workingDir);
+			$process->setTimeout(3600);
+			$process->run();
+			if (!$process->isSuccessful()) {
+				$cleanupFn();
+				throw new RuntimeException(sprintf('Could not extract the db archive: %s', $process->getErrorOutput()));
+			}
+		}
+
+		// Extract assets.tar.gz to <workingdir>/assets/
+		if (file_exists($workingDir . DIRECTORY_SEPARATOR . 'assets.tar.gz')) {
+			$process = new Process('tar xzf assets.tar.gz', $workingDir);
+			$process->setTimeout(3600);
+			$process->run();
+			if (!$process->isSuccessful()) {
+				$cleanupFn();
+				throw new RuntimeException(sprintf('Could not extract the assets archive: %s', $process->getErrorOutput()));
+			}
+		}
+
+		return true;
+	}
+
+	/**
+	 * Validate that an sspak contains the correct content.
+	 *
+	 * For example, if the user uploaded an sspak containing just the db, but declared in the form
+	 * that it contained db+assets, then the archive is not valid.
+	 *
+	 * @param string|null $mode "db", "assets", or "all". This is the content we're checking for. Default to the archive setting
+	 * @return ValidationResult
+	 */
+	public function validateArchiveContents($mode = null)
+	{
+		$mode = $mode ?: $this->Mode;
+		$result = new ValidationResult();
+
+		$file = $this->ArchiveFile()->FullPath;
+
+		if (!is_readable($file)) {
+			$result->error(sprintf('SSPak file "%s" cannot be read.', $file));
+			return $result;
+		}
+
+		$process = new Process(sprintf('tar -tf %s', escapeshellarg($file)));
+		$process->setTimeout(120);
+		$process->run();
+		if (!$process->isSuccessful()) {
+			throw new RuntimeException(sprintf('Could not list files in archive: %s', $process->getErrorOutput()));
+		}
+
+		$output = explode(PHP_EOL, $process->getOutput());
+		$files = array_filter($output);
+
+		if (in_array($mode, array('all', 'db')) && !in_array('database.sql.gz', $files)) {
+			$result->error('The snapshot is missing the database.');
+			return $result;
+		}
+
+		if (in_array($mode, array('all', 'assets')) && !in_array('assets.tar.gz', $files)) {
+			$result->error('The snapshot is missing assets.');
+			return $result;
+		}
+
+		return $result;
+	}
+
+	/**
+	 * Given a path that already exists and contains an extracted sspak, including
+	 * the assets, fix all of the file permissions so they're in a state ready to
+	 * be pushed to remote servers.
+	 *
+	 * Normally, command line tar will use permissions found in the archive, but will
+	 * substract the user's umask from them. This has a potential to create unreadable
+	 * files, e.g. cygwin on Windows will pack files with mode 000, hence why this fix
+	 * is necessary.
+	 *
+	 * @param string|null $workingDir The path of where the sspak has been extracted to
+	 * @throws RuntimeException
+	 * @return bool
+	 */
+	public function fixArchivePermissions($workingDir)
+	{
+		$fixCmds = array(
+			// The directories need to have permissions changed one by one (hence the ; instead of +),
+			// otherwise we might end up having no +x access to a directory deeper down.
+			sprintf('find %s -type d -exec chmod 755 {} \;', escapeshellarg($workingDir)),
+			sprintf('find %s -type f -exec chmod 644 {} +', escapeshellarg($workingDir))
+		);
+
+		foreach ($fixCmds as $cmd) {
+			$process = new Process($cmd);
+			$process->setTimeout(3600);
+			$process->run();
+			if (!$process->isSuccessful()) {
+				throw new RuntimeException($process->getErrorOutput());
+			}
+		}
+
+		return true;
+	}
+
+	/**
+	 * Given extracted sspak contents, create an sspak from it
+	 * and overwrite the current ArchiveFile with it's contents.
+	 *
+	 * @param string|null $workingDir The path of where the sspak has been extracted to
+	 * @return bool
+	 */
+	public function setArchiveFromFiles($workingDir)
+	{
+		$command = sprintf('sspak saveexisting %s 2>&1', $this->ArchiveFile()->FullPath);
+		if ($this->Mode == 'db') {
+			$command .= sprintf(' --db=%s/database.sql', $workingDir);
+		} elseif ($this->Mode == 'assets') {
+			$command .= sprintf(' --assets=%s/assets', $workingDir);
+		} else {
+			$command .= sprintf(' --db=%s/database.sql --assets=%s/assets', $workingDir, $workingDir);
+		}
+
+		$process = new Process($command, $workingDir);
+		$process->setTimeout(3600);
+		$process->run();
+		if (!$process->isSuccessful()) {
+			throw new RuntimeException($process->getErrorOutput());
+		}
+
+		$this->ArchiveFileHash = md5_file($this->ArchiveFile()->FullPath);
+		$this->write();
+
+		return true;
+	}
 }

Spacing +30 added lines, -30 removed lines

@@ -127,7 +127,7 @@ 
 
     public function onBeforeWrite()
     {
-        if (!$this->AuthorID) {
+        if(!$this->AuthorID) {
             $this->AuthorID = Member::currentUserID();
         }
 
@@ -189,7 +189,7 @@ 
      */
     public function FileSize()
     {
-        if ($this->ArchiveFile()->exists()) {
+        if($this->ArchiveFile()->exists()) {
             return $this->ArchiveFile()->getSize();
         } else {
             return "N/A";
@@ -198,7 +198,7 @@ 
 
     public function getModeNice()
     {
-        if ($this->Mode == 'all') {
+        if($this->Mode == 'all') {
             return 'database and assets';
         } else {
             return $this->Mode;
@@ -237,12 +237,12 @@ 
     public function canRestore($member = null)
     {
         $memberID = $member ? $member->ID : Member::currentUserID();
-        if (!$memberID) {
+        if(!$memberID) {
             return false;
         }
 
         $key = $memberID . '-' . $this->EnvironmentID;
-        if (!isset(self::$_cache_can_restore[$key])) {
+        if(!isset(self::$_cache_can_restore[$key])) {
             self::$_cache_can_restore[$key] = $this->Environment()->canUploadArchive($member);
         }
 
@@ -259,12 +259,12 @@ 
     public function canDownload($member = null)
     {
         $memberID = $member ? $member->ID : Member::currentUserID();
-        if (!$memberID) {
+        if(!$memberID) {
             return false;
         }
 
         $key = $memberID . '-' . $this->EnvironmentID;
-        if (!isset(self::$_cache_can_download[$key])) {
+        if(!isset(self::$_cache_can_download[$key])) {
             self::$_cache_can_download[$key] = $this->Environment()->canDownloadArchive($member);
         }
         return self::$_cache_can_download[$key];
@@ -291,27 +291,27 @@ 
      */
     public function canMoveTo($targetEnv, $member = null)
     {
-        if ($this->Environment()->Project()->ID != $targetEnv->Project()->ID) {
+        if($this->Environment()->Project()->ID != $targetEnv->Project()->ID) {
             // We don't permit moving snapshots between projects at this stage.
             return false;
         }
 
-        if (!$member) {
+        if(!$member) {
             $member = Member::currentUser();
         }
 
         // Must be logged in to check permissions
-        if (!$member) {
+        if(!$member) {
             return false;
         }
 
         // Admin can always move.
-        if (Permission::checkMember($member, 'ADMIN')) {
+        if(Permission::checkMember($member, 'ADMIN')) {
             return true;
         }
 
         // Checks if the user can actually access the archive.
-        if (!$this->canDownload($member)) {
+        if(!$this->canDownload($member)) {
             return false;
         }
 
@@ -331,7 +331,7 @@ 
     {
         $archive = $this;
         $envs = $this->Environment()->Project()->DNEnvironmentList()
-            ->filterByCallback(function ($item) use ($archive) {
+            ->filterByCallback(function($item) use ($archive) {
                 return $archive->EnvironmentID != $item->ID && $archive->canMoveTo($item);
             });
 
@@ -412,7 +412,7 @@ 
         // Note that with CapistranoDeploymentBackend the file won't be available yet, as it
         // gets put in place immediately after this method gets called. In which case, it will
         // be hashed in setArchiveFromFiles()
-        if (file_exists($file->FullPath)) {
+        if(file_exists($file->FullPath)) {
             $this->ArchiveFileHash = md5_file($file->FullPath);
         }
         $this->ArchiveFileID = $file->ID;
@@ -433,11 +433,11 @@ 
      */
     public function extractArchive($workingDir = null)
     {
-        if (!is_dir($workingDir)) {
+        if(!is_dir($workingDir)) {
             mkdir($workingDir, 0700, true);
         }
 
-        $cleanupFn = function () use ($workingDir) {
+        $cleanupFn = function() use ($workingDir) {
             $process = new Process(sprintf('rm -rf %s', escapeshellarg($workingDir)));
             $process->run();
         };
@@ -451,28 +451,28 @@ 
         ));
         $process->setTimeout(3600);
         $process->run();
-        if (!$process->isSuccessful()) {
+        if(!$process->isSuccessful()) {
             $cleanupFn();
             throw new RuntimeException(sprintf('Could not extract the sspak file: %s', $process->getErrorOutput()));
         }
 
         // Extract database.sql.gz to <workingdir>/database.sql
-        if (file_exists($workingDir . DIRECTORY_SEPARATOR . 'database.sql.gz')) {
+        if(file_exists($workingDir . DIRECTORY_SEPARATOR . 'database.sql.gz')) {
             $process = new Process('gunzip database.sql.gz', $workingDir);
             $process->setTimeout(3600);
             $process->run();
-            if (!$process->isSuccessful()) {
+            if(!$process->isSuccessful()) {
                 $cleanupFn();
                 throw new RuntimeException(sprintf('Could not extract the db archive: %s', $process->getErrorOutput()));
             }
         }
 
         // Extract assets.tar.gz to <workingdir>/assets/
-        if (file_exists($workingDir . DIRECTORY_SEPARATOR . 'assets.tar.gz')) {
+        if(file_exists($workingDir . DIRECTORY_SEPARATOR . 'assets.tar.gz')) {
             $process = new Process('tar xzf assets.tar.gz', $workingDir);
             $process->setTimeout(3600);
             $process->run();
-            if (!$process->isSuccessful()) {
+            if(!$process->isSuccessful()) {
                 $cleanupFn();
                 throw new RuntimeException(sprintf('Could not extract the assets archive: %s', $process->getErrorOutput()));
             }
@@ -497,7 +497,7 @@ 
 
         $file = $this->ArchiveFile()->FullPath;
 
-        if (!is_readable($file)) {
+        if(!is_readable($file)) {
             $result->error(sprintf('SSPak file "%s" cannot be read.', $file));
             return $result;
         }
@@ -505,19 +505,19 @@ 
         $process = new Process(sprintf('tar -tf %s', escapeshellarg($file)));
         $process->setTimeout(120);
         $process->run();
-        if (!$process->isSuccessful()) {
+        if(!$process->isSuccessful()) {
             throw new RuntimeException(sprintf('Could not list files in archive: %s', $process->getErrorOutput()));
         }
 
         $output = explode(PHP_EOL, $process->getOutput());
         $files = array_filter($output);
 
-        if (in_array($mode, array('all', 'db')) && !in_array('database.sql.gz', $files)) {
+        if(in_array($mode, array('all', 'db')) && !in_array('database.sql.gz', $files)) {
             $result->error('The snapshot is missing the database.');
             return $result;
         }
 
-        if (in_array($mode, array('all', 'assets')) && !in_array('assets.tar.gz', $files)) {
+        if(in_array($mode, array('all', 'assets')) && !in_array('assets.tar.gz', $files)) {
             $result->error('The snapshot is missing assets.');
             return $result;
         }
@@ -548,11 +548,11 @@ 
             sprintf('find %s -type f -exec chmod 644 {} +', escapeshellarg($workingDir))
         );
 
-        foreach ($fixCmds as $cmd) {
+        foreach($fixCmds as $cmd) {
             $process = new Process($cmd);
             $process->setTimeout(3600);
             $process->run();
-            if (!$process->isSuccessful()) {
+            if(!$process->isSuccessful()) {
                 throw new RuntimeException($process->getErrorOutput());
             }
         }
@@ -570,9 +570,9 @@ 
     public function setArchiveFromFiles($workingDir)
     {
         $command = sprintf('sspak saveexisting %s 2>&1', $this->ArchiveFile()->FullPath);
-        if ($this->Mode == 'db') {
+        if($this->Mode == 'db') {
             $command .= sprintf(' --db=%s/database.sql', $workingDir);
-        } elseif ($this->Mode == 'assets') {
+        } elseif($this->Mode == 'assets') {
             $command .= sprintf(' --assets=%s/assets', $workingDir);
         } else {
             $command .= sprintf(' --db=%s/database.sql --assets=%s/assets', $workingDir, $workingDir);
@@ -581,7 +581,7 @@ 
         $process = new Process($command, $workingDir);
         $process->setTimeout(3600);
         $process->run();
-        if (!$process->isSuccessful()) {
+        if(!$process->isSuccessful()) {
             throw new RuntimeException($process->getErrorOutput());
         }
 

Braces +23 added lines, -46 removed lines

@@ -47,8 +47,7 @@ 
  * @method ManyManyList DataTransfers()
  *
  */
-class DNDataArchive extends DataObject
-{
+class DNDataArchive extends DataObject {
 
     private static $db = array(
         'UploadToken' => 'Varchar(8)',
@@ -104,8 +103,7 @@ 
 
     private static $_cache_can_download = array();
 
-    public static function get_mode_map()
-    {
+    public static function get_mode_map() {
         return array(
             'all' => 'Database and Assets',
             'db' => 'Database only',
@@ -119,14 +117,12 @@ 
      *
      * @return string
      */
-    public static function generate_upload_token($chars = 8)
-    {
+    public static function generate_upload_token($chars = 8) {
         $generator = new RandomGenerator();
         return strtoupper(substr($generator->randomToken(), 0, $chars));
     }
 
-    public function onBeforeWrite()
-    {
+    public function onBeforeWrite() {
         if (!$this->AuthorID) {
             $this->AuthorID = Member::currentUserID();
         }
@@ -134,13 +130,11 @@ 
         parent::onBeforeWrite();
     }
 
-    public function onAfterDelete()
-    {
+    public function onAfterDelete() {
         $this->ArchiveFile()->delete();
     }
 
-    public function getCMSFields()
-    {
+    public function getCMSFields() {
         $fields = parent::getCMSFields();
         $fields->removeByName('OriginalEnvironmentID');
         $fields->removeByName('EnvironmentID');
@@ -173,8 +167,7 @@ 
         return $fields;
     }
 
-    public function getDefaultSearchContext()
-    {
+    public function getDefaultSearchContext() {
         $context = parent::getDefaultSearchContext();
         $context->getFields()->dataFieldByName('Mode')->setHasEmptyDefault(true);
 
@@ -187,8 +180,7 @@ 
      *
      * @return string The human-readable size of this archive file
      */
-    public function FileSize()
-    {
+    public function FileSize() {
         if ($this->ArchiveFile()->exists()) {
             return $this->ArchiveFile()->getSize();
         } else {
@@ -196,8 +188,7 @@ 
         }
     }
 
-    public function getModeNice()
-    {
+    public function getModeNice() {
         if ($this->Mode == 'all') {
             return 'database and assets';
         } else {
@@ -212,8 +203,7 @@ 
      *
      * @return boolean
      */
-    public function isPending()
-    {
+    public function isPending() {
         return !($this->ArchiveFileID);
     }
 
@@ -222,8 +212,7 @@ 
      *
      * @param Member|null $member The {@link Member} object to test against.
      */
-    public function canView($member = null)
-    {
+    public function canView($member = null) {
         return ($this->canRestore($member) || $this->canDownload($member));
     }
 
@@ -234,8 +223,7 @@ 
      * @param Member|null $member The {@link Member} object to test against.
      * @return true if $member (or the currently logged in member if null) can upload this archive
      */
-    public function canRestore($member = null)
-    {
+    public function canRestore($member = null) {
         $memberID = $member ? $member->ID : Member::currentUserID();
         if (!$memberID) {
             return false;
@@ -256,8 +244,7 @@ 
      * @param Member|null $member The {@link Member} object to test against.
      * @return true if $member (or the currently logged in member if null) can download this archive
      */
-    public function canDownload($member = null)
-    {
+    public function canDownload($member = null) {
         $memberID = $member ? $member->ID : Member::currentUserID();
         if (!$memberID) {
             return false;
@@ -276,8 +263,7 @@ 
      * @param Member|null $member The {@link Member} object to test against.
      * @return boolean if $member (or the currently logged in member if null) can delete this archive
      */
-    public function canDelete($member = null)
-    {
+    public function canDelete($member = null) {
         return $this->Environment()->canDeleteArchive($member);
     }
 
@@ -289,8 +275,7 @@ 
      *
      * @return boolean true if $member can upload archives linked to this environment, false if they can't.
      */
-    public function canMoveTo($targetEnv, $member = null)
-    {
+    public function canMoveTo($targetEnv, $member = null) {
         if ($this->Environment()->Project()->ID != $targetEnv->Project()->ID) {
             // We don't permit moving snapshots between projects at this stage.
             return false;
@@ -327,8 +312,7 @@ 
      *
      * @return ArrayList List of valid environments.
      */
-    public function validTargetEnvironments()
-    {
+    public function validTargetEnvironments() {
         $archive = $this;
         $envs = $this->Environment()->Project()->DNEnvironmentList()
             ->filterByCallback(function ($item) use ($archive) {
@@ -342,8 +326,7 @@ 
      * Returns a unique filename, including project/environment/timestamp details.
      * @return string
      */
-    public function generateFilename(DNDataTransfer $dataTransfer)
-    {
+    public function generateFilename(DNDataTransfer $dataTransfer) {
         $generator = new RandomGenerator();
         $filter = FileNameFilter::create();
 
@@ -364,8 +347,7 @@ 
      * @param DNDataTransfer
      * @return string Absolute file path
      */
-    public function generateFilepath(DNDataTransfer $dataTransfer)
-    {
+    public function generateFilepath(DNDataTransfer $dataTransfer) {
         $data = DNData::inst();
         $transferDir = $data->getDataTransferDir();
         $filter = FileNameFilter::create();
@@ -386,8 +368,7 @@ 
      * @param DNDataTransfer $dataTransfer
      * @return bool
      */
-    public function attachFile($sspakFilepath, DNDataTransfer $dataTransfer)
-    {
+    public function attachFile($sspakFilepath, DNDataTransfer $dataTransfer) {
         $sspakFilepath = ltrim(
             str_replace(
                 array(ASSETS_PATH, realpath(ASSETS_PATH)),
@@ -431,8 +412,7 @@ 
      * @throws RuntimeException
      * @return bool
      */
-    public function extractArchive($workingDir = null)
-    {
+    public function extractArchive($workingDir = null) {
         if (!is_dir($workingDir)) {
             mkdir($workingDir, 0700, true);
         }
@@ -490,8 +470,7 @@ 
      * @param string|null $mode "db", "assets", or "all". This is the content we're checking for. Default to the archive setting
      * @return ValidationResult
      */
-    public function validateArchiveContents($mode = null)
-    {
+    public function validateArchiveContents($mode = null) {
         $mode = $mode ?: $this->Mode;
         $result = new ValidationResult();
 
@@ -539,8 +518,7 @@ 
      * @throws RuntimeException
      * @return bool
      */
-    public function fixArchivePermissions($workingDir)
-    {
+    public function fixArchivePermissions($workingDir) {
         $fixCmds = array(
             // The directories need to have permissions changed one by one (hence the ; instead of +),
             // otherwise we might end up having no +x access to a directory deeper down.
@@ -567,8 +545,7 @@ 
      * @param string|null $workingDir The path of where the sspak has been extracted to
      * @return bool
      */
-    public function setArchiveFromFiles($workingDir)
-    {
+    public function setArchiveFromFiles($workingDir) {
         $command = sprintf('sspak saveexisting %s 2>&1', $this->ArchiveFile()->FullPath);
         if ($this->Mode == 'db') {
             $command .= sprintf(' --db=%s/database.sql', $workingDir);

code/model/DNEnvironment.php

Indentation +1366 added lines, -1366 removed lines

@@ -42,1376 +42,1376 @@
 class DNEnvironment extends DataObject
 {
 
-    /**
-     * If this is set to a full pathfile, it will be used as template
-     * file when creating a new capistrano environment config file.
-     *
-     * If not set, the default 'environment.template' from the module
-     * root is used
-     *
-     * @config
-     * @var string
-     */
-    private static $template_file = '';
-
-    /**
-     * Set this to true to allow editing of the environment files via the web admin
-     *
-     * @var bool
-     */
-    private static $allow_web_editing = false;
-
-    /**
-     * @var array
-     */
-    private static $casting = array(
-        'DeployHistory' => 'Text'
-    );
-
-    /**
-     * Allowed backends. A map of Injector identifier to human-readable label.
-     *
-     * @config
-     * @var array
-     */
-    private static $allowed_backends = array();
-
-    /**
-     * @var array
-     */
-    public static $db = array(
-        "Filename" => "Varchar(255)",
-        "Name" => "Varchar(255)",
-        "URL" => "Varchar(255)",
-        "BackendIdentifier" => "Varchar(255)", // Injector identifier of the DeploymentBackend
-        "DryRunEnabled" => "Boolean", // True if the dry run button should be enabled on the frontend
-        "Usage" => "Enum('Production, UAT, Test, Unspecified', 'Unspecified')"
-    );
-
-    /**
-     * @var array
-     */
-    public static $has_one = array(
-        "Project" => "DNProject",
-        "CreateEnvironment" => "DNCreateEnvironment"
-    );
-
-    /**
-     * @var array
-     */
-    public static $has_many = array(
-        "Deployments" => "DNDeployment",
-        "DataArchives" => "DNDataArchive",
-        "Pipelines" => "Pipeline" // Only one Pipeline can be 'Running' at any one time. @see self::CurrentPipeline().
-    );
-
-    /**
-     * @var array
-     */
-    public static $many_many = array(
-        "Viewers"            => "Member", // Who can view this environment
-        "ViewerGroups"       => "Group",
-        "Deployers"          => "Member", // Who can deploy to this environment
-        "DeployerGroups" => "Group",
-        "CanRestoreMembers"  => "Member", // Who can restore archive files to this environment
-        "CanRestoreGroups"  => "Group",
-        "CanBackupMembers"   => "Member", // Who can backup archive files from this environment
-        "CanBackupGroups"   => "Group",
-        "ArchiveUploaders"   => "Member", // Who can upload archive files linked to this environment
-        "ArchiveUploaderGroups" => "Group",
-        "ArchiveDownloaders" => "Member", // Who can download archive files from this environment
-        "ArchiveDownloaderGroups" => "Group",
-        "ArchiveDeleters"    => "Member", // Who can delete archive files from this environment,
-        "ArchiveDeleterGroups" => "Group",
-        "PipelineApprovers"  => "Member", // Who can approve / reject pipelines from this environment
-        "PipelineApproverGroups" => "Group",
-        "PipelineCancellers"   => "Member", // Who can abort pipelines
-        "PipelineCancellerGroups" => "Group"
-    );
-
-    /**
-     * @var array
-     */
-    public static $summary_fields = array(
-        "Name" => "Environment Name",
-        "Usage" => "Usage",
-        "URL" => "URL",
-        "DeployersList" => "Can Deploy List",
-        "CanRestoreMembersList" => "Can Restore List",
-        "CanBackupMembersList" => "Can Backup List",
-        "ArchiveUploadersList" => "Can Upload List",
-        "ArchiveDownloadersList" => "Can Download List",
-        "ArchiveDeletersList"  => "Can Delete List",
-        "PipelineApproversList" => "Can Approve List",
-        "PipelineCancellersList" => "Can Cancel List"
-    );
-
-    private static $singular_name = 'Capistrano Environment';
-
-    private static $plural_name = 'Capistrano Environments';
-
-    /**
-     * @var array
-     */
-    public static $searchable_fields = array(
-        "Name",
-    );
-
-    /**
-     * @var string
-     */
-    private static $default_sort = 'Name';
-
-    /**
-     * Used by the sync task
-     *
-     * @param string $path
-     * @return \DNEnvironment
-     */
-    public static function create_from_path($path)
-    {
-        $e = DNEnvironment::create();
-        $e->Filename = $path;
-        $e->Name = basename($e->Filename, '.rb');
-
-        // add each administrator member as a deployer of the new environment
-        $adminGroup = Group::get()->filter('Code', 'administrators')->first();
-        $e->DeployerGroups()->add($adminGroup);
-        return $e;
-    }
-
-    /**
-     * Get the deployment backend used for this environment.
-     *
-     * Enforces compliance with the allowed_backends setting; if the DNEnvironment.BackendIdentifier value is
-     * illegal then that value is ignored.
-     *
-     * @return DeploymentBackend
-     */
-    public function Backend()
-    {
-        $backends = array_keys($this->config()->get('allowed_backends', Config::FIRST_SET));
-        switch (sizeof($backends)) {
-        // Nothing allowed, use the default value "DeploymentBackend"
-            case 0:
-                $backend = "DeploymentBackend";
-                break;
-
-            // Only 1 thing allowed, use that
-            case 1:
-                $backend = $backends[0];
-                break;
-
-            // Multiple choices, use our choice if it's legal, otherwise default to the first item on the list
-            default:
-                $backend = $this->BackendIdentifier;
-                if (!in_array($backend, $backends)) {
-                    $backend = $backends[0];
-                }
-        }
-
-        return Injector::inst()->get($backend);
-    }
-
-    public function Menu()
-    {
-        $list = new ArrayList();
-
-        $controller = Controller::curr();
-        $actionType = $controller->getField('CurrentActionType');
-
-        $list->push(new ArrayData(array(
-            'Link' => sprintf('naut/project/%s/environment/%s', $this->Project()->Name, $this->Name),
-            'Title' => 'Deployments',
-            'IsCurrent' => $this->isCurrent(),
-            'IsSection' => $this->isSection() && $actionType == DNRoot::ACTION_DEPLOY
-        )));
-
-        $this->extend('updateMenu', $list);
-
-        return $list;
-    }
-
-    /**
-     * Return the current object from $this->Menu()
-     * Good for making titles and things
-     */
-    public function CurrentMenu()
-    {
-        return $this->Menu()->filter('IsSection', true)->First();
-    }
-
-    /**
-     * Return a name for this environment.
-     *
-     * @param string $separator The string used when concatenating project with env name
-     * @return string
-     */
-    public function getFullName($separator = ':')
-    {
-        return sprintf('%s%s%s', $this->Project()->Name, $separator, $this->Name);
-    }
-
-    public function getBareURL()
-    {
-        $url = parse_url($this->URL);
-        if (isset($url['host'])) {
-            return strtolower($url['host']);
-        }
-    }
-
-    /**
-     * @return boolean true if there is a pipeline for the current environment.
-     */
-    public function HasPipelineSupport()
-    {
-        $config = $this->GenericPipelineConfig();
-        return $config instanceof ArrayData && isset($config->Steps);
-    }
-
-    /**
-     * Returns a {@link Pipeline} object that is linked to this environment, but isn't saved into the database. This
-     * shouldn't be saved into the database unless you plan on starting an actual pipeline.
-     *
-     * @return Pipeline
-     */
-    public function GenericPipeline()
-    {
-        $pipeline = Pipeline::create();
-        $pipeline->EnvironmentID = $this->ID;
-        return $pipeline;
-    }
-
-    /**
-     * Returns the parsed config, based on a {@link Pipeline} being created for this {@link DNEnvironment}.
-     *
-     * @return ArrayData
-     */
-    public function GenericPipelineConfig()
-    {
-        $config = $this->loadPipelineConfig();
-        if ($config) {
-            return self::array_to_viewabledata($config);
-        }
-    }
-
-    /**
-     * Extract pipeline configuration data from the source yml file
-     *
-     * @return array
-     */
-    public function loadPipelineConfig()
-    {
-        require_once 'thirdparty/spyc/spyc.php';
-
-        $path = $this->getPipelineFilename();
-        if (file_exists($path)) {
-            return Spyc::YAMLLoad($path);
-        }
-    }
-
-    /**
-     * Returns the {@link DNEnvironment} object relating to the pipeline config for this environment. The environment
-     * YAML file (e.g. project1-uat.yml; see docs/en/pipelines.md) contains two variable called `DependsOnProject` and
-     * `DependsOnEnvironment` - these are used together to find the {@link DNEnvironment} that this environment should
-     * rely on.
-     */
-    public function DependsOnEnvironment()
-    {
-        if ($this->HasPipelineSupport()) {
-            $pipeline = $this->GenericPipeline();
-            return $pipeline->getDependentEnvironment();
-        }
-
-        return null;
-    }
-
-    /**
-     * @return bool true if there is a currently running Pipeline, and false if there isn't
-     */
-    public function HasCurrentPipeline()
-    {
-        return $this->CurrentPipeline() && $this->CurrentPipeline()->isInDB();
-    }
-
-    /**
-     * This can be used to determine if there is a currently running pipeline (there can only be one running per
-     * {@link DNEnvironment} at once), as well as getting the current pipeline to be shown in templates.
-     *
-     * @return DataObject|null The currently running pipeline, or null if there isn't any.
-     */
-    public function CurrentPipeline()
-    {
-        return $this->Pipelines()->filter('Status', array('Running', 'Rollback'))->first();
-    }
-
-    /**
-     * @return bool true if the current user can cancel a running pipeline
-     */
-    public function CanCancelPipeline()
-    {
-        // do we have a current pipeline
-        if ($this->HasCurrentPipeline()) {
-            return $this->CurrentPipeline()->canAbort();
-        }
-        return false;
-    }
-
-    /**
-     * Environments are only viewable by people that can view the environment.
-     *
-     * @param Member|null $member
-     * @return boolean
-     */
-    public function canView($member = null)
-    {
-        if (!$member) {
-            $member = Member::currentUser();
-        }
-        if (!$member) {
-            return false;
-        }
-        // Must be logged in to check permissions
-
-        if (Permission::checkMember($member, 'ADMIN')) {
-            return true;
-        }
-
-        // if no Viewers or ViewerGroups defined, fallback to DNProject::canView permissions
-        if ($this->Viewers()->exists() || $this->ViewerGroups()->exists()) {
-            return $this->Viewers()->byID($member->ID)
-                || $member->inGroups($this->ViewerGroups());
-        }
-
-        return $this->Project()->canView($member);
-    }
-
-    /**
-     * Allow deploy only to some people.
-     *
-     * @param Member|null $member
-     * @return boolean
-     */
-    public function canDeploy($member = null)
-    {
-        if (!$member) {
-            $member = Member::currentUser();
-        }
-        if (!$member) {
-            return false;
-        }
-        // Must be logged in to check permissions
-
-        if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
-            if ($this->Project()->allowed(DNRoot::ALLOW_PROD_DEPLOYMENT, $member)) {
-                return true;
-            }
-        } else {
-            if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_DEPLOYMENT, $member)) {
-                return true;
-            }
-        }
-
-        return $this->Deployers()->byID($member->ID)
-            || $member->inGroups($this->DeployerGroups());
-    }
-
-    /**
-     * Allows only selected {@link Member} objects to restore {@link DNDataArchive} objects into this
-     * {@link DNEnvironment}.
-     *
-     * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
-     * @return boolean true if $member can restore, and false if they can't.
-     */
-    public function canRestore($member = null)
-    {
-        if (!$member) {
-            $member = Member::currentUser();
-        }
-        if (!$member) {
-            return false;
-        }
-        // Must be logged in to check permissions
-
-        if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
-            if ($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
-                return true;
-            }
-        } else {
-            if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
-                return true;
-            }
-        }
-
-        return $this->CanRestoreMembers()->byID($member->ID)
-            || $member->inGroups($this->CanRestoreGroups());
-    }
-
-    /**
-     * Allows only selected {@link Member} objects to backup this {@link DNEnvironment} to a {@link DNDataArchive}
-     * file.
-     *
-     * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
-     * @return boolean true if $member can backup, and false if they can't.
-     */
-    public function canBackup($member = null)
-    {
-        $project = $this->Project();
-        if ($project->HasDiskQuota() && $project->HasExceededDiskQuota()) {
-            return false;
-        }
-
-        if (!$member) {
-            $member = Member::currentUser();
-        }
-        // Must be logged in to check permissions
-        if (!$member) {
-            return false;
-        }
-
-        if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
-            if ($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
-                return true;
-            }
-        } else {
-            if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
-                return true;
-            }
-        }
-
-        return $this->CanBackupMembers()->byID($member->ID)
-            || $member->inGroups($this->CanBackupGroups());
-    }
-
-    /**
-     * Allows only selected {@link Member} objects to upload {@link DNDataArchive} objects linked to this
-     * {@link DNEnvironment}.
-     *
-     * Note: This is not uploading them to the actual environment itself (e.g. uploading to the live site) - it is the
-     * process of uploading a *.sspak file into Deploynaut for later 'restoring' to an environment. See
-     * {@link self::canRestore()}.
-     *
-     * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
-     * @return boolean true if $member can upload archives linked to this environment, false if they can't.
-     */
-    public function canUploadArchive($member = null)
-    {
-        $project = $this->Project();
-        if ($project->HasDiskQuota() && $project->HasExceededDiskQuota()) {
-            return false;
-        }
-
-        if (!$member) {
-            $member = Member::currentUser();
-        }
-        if (!$member) {
-            return false;
-        }
-        // Must be logged in to check permissions
-
-        if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
-            if ($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
-                return true;
-            }
-        } else {
-            if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
-                return true;
-            }
-        }
-
-        return $this->ArchiveUploaders()->byID($member->ID)
-            || $member->inGroups($this->ArchiveUploaderGroups());
-    }
-
-    /**
-     * Allows only selected {@link Member} objects to download {@link DNDataArchive} objects from this
-     * {@link DNEnvironment}.
-     *
-     * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
-     * @return boolean true if $member can download archives from this environment, false if they can't.
-     */
-    public function canDownloadArchive($member = null)
-    {
-        if (!$member) {
-            $member = Member::currentUser();
-        }
-        if (!$member) {
-            return false;
-        }
-        // Must be logged in to check permissions
-
-        if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
-            if ($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
-                return true;
-            }
-        } else {
-            if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
-                return true;
-            }
-        }
-
-        return $this->ArchiveDownloaders()->byID($member->ID)
-            || $member->inGroups($this->ArchiveDownloaderGroups());
-    }
-
-    /**
-     * Determine if the specified user can abort any pipelines
-     *
-     * @param Member|null $member
-     * @return boolean
-     */
-    public function canAbort($member = null)
-    {
-        if (!$member) {
-            $member = Member::currentUser();
-        }
-        if (!$member) {
-            return false;
-        }
-
-        if (Permission::checkMember($member, 'ADMIN')) {
-            return true;
-        }
-
-        return $this->PipelineCancellers()->byID($member->ID)
-            || $member->inGroups($this->PipelineCancellerGroups());
-    }
-
-    /**
-     * Determine if the specified user can approve any pipelines
-     *
-     * @param Member|null $member
-     * @return boolean
-     */
-    public function canApprove($member = null)
-    {
-        if (!$member) {
-            $member = Member::currentUser();
-        }
-        if (!$member) {
-            return false;
-        }
-
-        if (Permission::checkMember($member, 'ADMIN')) {
-            return true;
-        }
-        return $this->PipelineApprovers()->byID($member->ID)
-            || $member->inGroups($this->PipelineApproverGroups());
-    }
-
-    /**
-     * Allows only selected {@link Member} objects to delete {@link DNDataArchive} objects from this
-     * {@link DNEnvironment}.
-     *
-     * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
-     * @return boolean true if $member can delete archives from this environment, false if they can't.
-     */
-    public function canDeleteArchive($member = null)
-    {
-        if (!$member) {
-            $member = Member::currentUser();
-        }
-        if (!$member) {
-            return false;
-        }
-        // Must be logged in to check permissions
-
-        if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
-            if ($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
-                return true;
-            }
-        } else {
-            if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
-                return true;
-            }
-        }
-
-        return $this->ArchiveDeleters()->byID($member->ID)
-            || $member->inGroups($this->ArchiveDeleterGroups());
-    }
-    /**
-     * Get a string of groups/people that are allowed to deploy to this environment.
-     * Used in DNRoot_project.ss to list {@link Member}s who have permission to perform this action.
-     *
-     * @return string
-     */
-    public function getDeployersList()
-    {
-        return implode(
-            ", ",
-            array_merge(
-                $this->DeployerGroups()->column("Title"),
-                $this->Deployers()->column("FirstName")
-            )
-        );
-    }
-
-    /**
-     * Get a string of groups/people that are allowed to restore {@link DNDataArchive} objects into this environment.
-     *
-     * @return string
-     */
-    public function getCanRestoreMembersList()
-    {
-        return implode(
-            ", ",
-            array_merge(
-                $this->CanRestoreGroups()->column("Title"),
-                $this->CanRestoreMembers()->column("FirstName")
-            )
-        );
-    }
-
-    /**
-     * Get a string of groups/people that are allowed to backup {@link DNDataArchive} objects from this environment.
-     *
-     * @return string
-     */
-    public function getCanBackupMembersList()
-    {
-        return implode(
-            ", ",
-            array_merge(
-                $this->CanBackupGroups()->column("Title"),
-                $this->CanBackupMembers()->column("FirstName")
-            )
-        );
-    }
-
-    /**
-     * Get a string of groups/people that are allowed to upload {@link DNDataArchive}
-     *  objects linked to this environment.
-     *
-     * @return string
-     */
-    public function getArchiveUploadersList()
-    {
-        return implode(
-            ", ",
-            array_merge(
-                $this->ArchiveUploaderGroups()->column("Title"),
-                $this->ArchiveUploaders()->column("FirstName")
-            )
-        );
-    }
-
-    /**
-     * Get a string of groups/people that are allowed to download {@link DNDataArchive} objects from this environment.
-     *
-     * @return string
-     */
-    public function getArchiveDownloadersList()
-    {
-        return implode(
-            ", ",
-            array_merge(
-                $this->ArchiveDownloaderGroups()->column("Title"),
-                $this->ArchiveDownloaders()->column("FirstName")
-            )
-        );
-    }
-
-    /**
-     * Get a string of groups/people that are allowed to delete {@link DNDataArchive} objects from this environment.
-     *
-     * @return string
-     */
-    public function getArchiveDeletersList()
-    {
-        return implode(
-            ", ",
-            array_merge(
-                $this->ArchiveDeleterGroups()->column("Title"),
-                $this->ArchiveDeleters()->column("FirstName")
-            )
-        );
-    }
-
-    /**
-     * Get a string of groups/people that are allowed to approve pipelines
-     *
-     * @return string
-     */
-    public function getPipelineApproversList()
-    {
-        return implode(
-            ", ",
-            array_merge(
-                $this->PipelineApproverGroups()->column("Title"),
-                $this->PipelineApprovers()->column("FirstName")
-            )
-        );
-    }
-
-    /**
-     * Get a string of groups/people that are allowed to cancel pipelines
-     *
-     * @return string
-     */
-    public function getPipelineCancellersList()
-    {
-        return implode(
-            ", ",
-            array_merge(
-                $this->PipelineCancellerGroups()->column("Title"),
-                $this->PipelineCancellers()->column("FirstName")
-            )
-        );
-    }
-
-    /**
-     * @return DNData
-     */
-    public function DNData()
-    {
-        return DNData::inst();
-    }
-
-    /**
-     * Get the current deployed build for this environment
-     *
-     * Dear people of the future: If you are looking to optimize this, simply create a CurrentBuildSHA(), which can be
-     * a lot faster. I presume you came here because of the Project display template, which only needs a SHA.
-     *
-     * @return false|DNDeployment
-     */
-    public function CurrentBuild()
-    {
-        // The DeployHistory function is far too slow to use for this
-
-        /** @var DNDeployment $deploy */
-        $deploy = DNDeployment::get()->filter(array(
-            'EnvironmentID' => $this->ID,
-            'Status' => 'Finished'
-        ))->sort('LastEdited DESC')->first();
-
-        if (!$deploy || (!$deploy->SHA)) {
-            return false;
-        }
-
-        $repo = $this->Project()->getRepository();
-        if (!$repo) {
-            return $deploy;
-        }
-
-        try {
-            $commit = $repo->getCommit($deploy->SHA);
-            if ($commit) {
-                $deploy->Message = Convert::raw2xml($commit->getMessage());
-                $deploy->Committer = Convert::raw2xml($commit->getCommitterName());
-                $deploy->CommitDate = $commit->getCommitterDate()->Format('d/m/Y g:ia');
-                $deploy->Author = Convert::raw2xml($commit->getAuthorName());
-                $deploy->AuthorDate = $commit->getAuthorDate()->Format('d/m/Y g:ia');
-            }
-            // We can't find this SHA, so we ignore adding a commit message to the deployment
-        } catch (Exception $ex) {
-        }
-
-        return $deploy;
-    }
-
-    /**
-     * A history of all builds deployed to this environment
-     *
-     * @return ArrayList
-     */
-    public function DeployHistory()
-    {
-        return $this->Deployments()
-            ->where('SHA IS NOT NULL')
-            ->sort('LastEdited DESC');
-    }
-
-    /**
-     * @param string $sha
-     * @return array
-     */
-    protected function getCommitData($sha)
-    {
-        try {
-            $repo = $this->Project()->getRepository();
-            if ($repo !== false) {
-                $commit = new \Gitonomy\Git\Commit($repo, $sha);
-                return [
-                    'AuthorName' => (string)Convert::raw2xml($commit->getAuthorName()),
-                    'AuthorEmail' => (string)Convert::raw2xml($commit->getAuthorEmail()),
-                    'Message' => (string)Convert::raw2xml($commit->getMessage()),
-                    'ShortHash' => Convert::raw2xml($commit->getFixedShortHash(8)),
-                    'Hash' => Convert::raw2xml($commit->getHash())
-                ];
-            }
-        } catch (\Gitonomy\Git\Exception\ReferenceNotFoundException $exc) {
-            SS_Log::log($exc, SS_Log::WARN);
-        }
-        return array(
-            'AuthorName' => '(unknown)',
-            'AuthorEmail' => '(unknown)',
-            'Message' => '(unknown)',
-            'ShortHash' => $sha,
-            'Hash' => '(unknown)',
-        );
-    }
-
-    /**
-     * @return string
-     */
-    public function Link()
-    {
-        return $this->Project()->Link() . "/environment/" . $this->Name;
-    }
-
-    /**
-     * Is this environment currently at the root level of the controller that handles it?
-     * @return bool
-     */
-    public function isCurrent()
-    {
-        return $this->isSection() && Controller::curr()->getAction() == 'environment';
-    }
-
-    /**
-     * Is this environment currently in a controller that is handling it or performing a sub-task?
-     * @return bool
-     */
-    public function isSection()
-    {
-        $controller = Controller::curr();
-        $environment = $controller->getField('CurrentEnvironment');
-        return $environment && $environment->ID == $this->ID;
-    }
-
-
-    /**
-     * Build a set of multi-select fields for assigning permissions to a pair of group and member many_many relations
-     *
-     * @param string $groupField Group field name
-     * @param string $memberField Member field name
-     * @param array $groups List of groups
-     * @param array $members List of members
-     * @return FieldGroup
-     */
-    protected function buildPermissionField($groupField, $memberField, $groups, $members)
-    {
-        return FieldGroup::create(
-            ListboxField::create($groupField, false, $groups)
-                ->setMultiple(true)
-                ->setAttribute('data-placeholder', 'Groups')
-                ->setAttribute('placeholder', 'Groups')
-                ->setAttribute('style', 'width: 400px;'),
-
-            ListboxField::create($memberField, false, $members)
-                ->setMultiple(true)
-                ->setAttribute('data-placeholder', 'Members')
-                ->setAttribute('placeholder', 'Members')
-                ->setAttribute('style', 'width: 400px;')
-        );
-    }
-
-    /**
-     * @return FieldList
-     */
-    public function getCMSFields()
-    {
-        $fields = new FieldList(new TabSet('Root'));
-
-        $project = $this->Project();
-        if ($project && $project->exists()) {
-            $viewerGroups = $project->Viewers();
-            $groups = $viewerGroups->sort('Title')->map()->toArray();
-            $members = array();
-            foreach ($viewerGroups as $group) {
-                foreach ($group->Members()->map() as $k => $v) {
-                    $members[$k] = $v;
-                }
-            }
-            asort($members);
-        } else {
-            $groups = array();
-            $members = array();
-        }
-
-        // Main tab
-        $fields->addFieldsToTab('Root.Main', array(
-            // The Main.ProjectID
-            TextField::create('ProjectName', 'Project')
-                ->setValue(($project = $this->Project()) ? $project->Name : null)
-                ->performReadonlyTransformation(),
-
-            // The Main.Name
-            TextField::create('Name', 'Environment name')
-                ->setDescription('A descriptive name for this environment, e.g. staging, uat, production'),
-
-
-            $this->obj('Usage')->scaffoldFormField('Environment usage'),
-
-            // The Main.URL field
-            TextField::create('URL', 'Server URL')
-                ->setDescription('This url will be used to provide the front-end with a link to this environment'),
-
-            // The Main.Filename
-            TextField::create('Filename')
-                ->setDescription('The capistrano environment file name')
-                ->performReadonlyTransformation(),
-        ));
-
-        // Backend identifier - pick from a named list of configurations specified in YML config
-        $backends = $this->config()->get('allowed_backends', Config::FIRST_SET);
-        // If there's only 1 backend, then user selection isn't needed
-        if (sizeof($backends) > 1) {
-            $fields->addFieldToTab('Root.Main', DropdownField::create('BackendIdentifier', 'Deployment backend')
-                ->setSource($backends)
-                ->setDescription('What kind of deployment system should be used to deploy to this environment'));
-        }
-
-        $fields->addFieldsToTab('Root.UserPermissions', array(
-            // The viewers of the environment
-            $this
-                ->buildPermissionField('ViewerGroups', 'Viewers', $groups, $members)
-                ->setTitle('Who can view this environment?')
-                ->setDescription('Groups or Users who can view this environment'),
-
-            // The Main.Deployers
-            $this
-                ->buildPermissionField('DeployerGroups', 'Deployers', $groups, $members)
-                ->setTitle('Who can deploy?')
-                ->setDescription('Groups or Users who can deploy to this environment'),
-
-            // A box to select all snapshot options.
-            $this
-                ->buildPermissionField('TickAllSnapshotGroups', 'TickAllSnapshot', $groups, $members)
-                ->setTitle("<em>All snapshot permissions</em>")
-                ->addExtraClass('tickall')
-                ->setDescription('UI shortcut to select all snapshot-related options - not written to the database.'),
-
-            // The Main.CanRestoreMembers
-            $this
-                ->buildPermissionField('CanRestoreGroups', 'CanRestoreMembers', $groups, $members)
-                ->setTitle('Who can restore?')
-                ->setDescription('Groups or Users who can restore archives from Deploynaut into this environment'),
-
-            // The Main.CanBackupMembers
-            $this
-                ->buildPermissionField('CanBackupGroups', 'CanBackupMembers', $groups, $members)
-                ->setTitle('Who can backup?')
-                ->setDescription('Groups or Users who can backup archives from this environment into Deploynaut'),
-
-            // The Main.ArchiveDeleters
-            $this
-                ->buildPermissionField('ArchiveDeleterGroups', 'ArchiveDeleters', $groups, $members)
-                ->setTitle('Who can delete?')
-                ->setDescription("Groups or Users who can delete archives from this environment's staging area."),
-
-            // The Main.ArchiveUploaders
-            $this
-                ->buildPermissionField('ArchiveUploaderGroups', 'ArchiveUploaders', $groups, $members)
-                ->setTitle('Who can upload?')
-                ->setDescription(
-                    'Users who can upload archives linked to this environment into Deploynaut.<br />' .
-                    'Linking them to an environment allows limiting download permissions (see below).'
-                ),
-
-            // The Main.ArchiveDownloaders
-            $this
-                ->buildPermissionField('ArchiveDownloaderGroups', 'ArchiveDownloaders', $groups, $members)
-                ->setTitle('Who can download?')
-                ->setDescription(<<<PHP
+	/**
+	 * If this is set to a full pathfile, it will be used as template
+	 * file when creating a new capistrano environment config file.
+	 *
+	 * If not set, the default 'environment.template' from the module
+	 * root is used
+	 *
+	 * @config
+	 * @var string
+	 */
+	private static $template_file = '';
+
+	/**
+	 * Set this to true to allow editing of the environment files via the web admin
+	 *
+	 * @var bool
+	 */
+	private static $allow_web_editing = false;
+
+	/**
+	 * @var array
+	 */
+	private static $casting = array(
+		'DeployHistory' => 'Text'
+	);
+
+	/**
+	 * Allowed backends. A map of Injector identifier to human-readable label.
+	 *
+	 * @config
+	 * @var array
+	 */
+	private static $allowed_backends = array();
+
+	/**
+	 * @var array
+	 */
+	public static $db = array(
+		"Filename" => "Varchar(255)",
+		"Name" => "Varchar(255)",
+		"URL" => "Varchar(255)",
+		"BackendIdentifier" => "Varchar(255)", // Injector identifier of the DeploymentBackend
+		"DryRunEnabled" => "Boolean", // True if the dry run button should be enabled on the frontend
+		"Usage" => "Enum('Production, UAT, Test, Unspecified', 'Unspecified')"
+	);
+
+	/**
+	 * @var array
+	 */
+	public static $has_one = array(
+		"Project" => "DNProject",
+		"CreateEnvironment" => "DNCreateEnvironment"
+	);
+
+	/**
+	 * @var array
+	 */
+	public static $has_many = array(
+		"Deployments" => "DNDeployment",
+		"DataArchives" => "DNDataArchive",
+		"Pipelines" => "Pipeline" // Only one Pipeline can be 'Running' at any one time. @see self::CurrentPipeline().
+	);
+
+	/**
+	 * @var array
+	 */
+	public static $many_many = array(
+		"Viewers"            => "Member", // Who can view this environment
+		"ViewerGroups"       => "Group",
+		"Deployers"          => "Member", // Who can deploy to this environment
+		"DeployerGroups" => "Group",
+		"CanRestoreMembers"  => "Member", // Who can restore archive files to this environment
+		"CanRestoreGroups"  => "Group",
+		"CanBackupMembers"   => "Member", // Who can backup archive files from this environment
+		"CanBackupGroups"   => "Group",
+		"ArchiveUploaders"   => "Member", // Who can upload archive files linked to this environment
+		"ArchiveUploaderGroups" => "Group",
+		"ArchiveDownloaders" => "Member", // Who can download archive files from this environment
+		"ArchiveDownloaderGroups" => "Group",
+		"ArchiveDeleters"    => "Member", // Who can delete archive files from this environment,
+		"ArchiveDeleterGroups" => "Group",
+		"PipelineApprovers"  => "Member", // Who can approve / reject pipelines from this environment
+		"PipelineApproverGroups" => "Group",
+		"PipelineCancellers"   => "Member", // Who can abort pipelines
+		"PipelineCancellerGroups" => "Group"
+	);
+
+	/**
+	 * @var array
+	 */
+	public static $summary_fields = array(
+		"Name" => "Environment Name",
+		"Usage" => "Usage",
+		"URL" => "URL",
+		"DeployersList" => "Can Deploy List",
+		"CanRestoreMembersList" => "Can Restore List",
+		"CanBackupMembersList" => "Can Backup List",
+		"ArchiveUploadersList" => "Can Upload List",
+		"ArchiveDownloadersList" => "Can Download List",
+		"ArchiveDeletersList"  => "Can Delete List",
+		"PipelineApproversList" => "Can Approve List",
+		"PipelineCancellersList" => "Can Cancel List"
+	);
+
+	private static $singular_name = 'Capistrano Environment';
+
+	private static $plural_name = 'Capistrano Environments';
+
+	/**
+	 * @var array
+	 */
+	public static $searchable_fields = array(
+		"Name",
+	);
+
+	/**
+	 * @var string
+	 */
+	private static $default_sort = 'Name';
+
+	/**
+	 * Used by the sync task
+	 *
+	 * @param string $path
+	 * @return \DNEnvironment
+	 */
+	public static function create_from_path($path)
+	{
+		$e = DNEnvironment::create();
+		$e->Filename = $path;
+		$e->Name = basename($e->Filename, '.rb');
+
+		// add each administrator member as a deployer of the new environment
+		$adminGroup = Group::get()->filter('Code', 'administrators')->first();
+		$e->DeployerGroups()->add($adminGroup);
+		return $e;
+	}
+
+	/**
+	 * Get the deployment backend used for this environment.
+	 *
+	 * Enforces compliance with the allowed_backends setting; if the DNEnvironment.BackendIdentifier value is
+	 * illegal then that value is ignored.
+	 *
+	 * @return DeploymentBackend
+	 */
+	public function Backend()
+	{
+		$backends = array_keys($this->config()->get('allowed_backends', Config::FIRST_SET));
+		switch (sizeof($backends)) {
+		// Nothing allowed, use the default value "DeploymentBackend"
+			case 0:
+				$backend = "DeploymentBackend";
+				break;
+
+			// Only 1 thing allowed, use that
+			case 1:
+				$backend = $backends[0];
+				break;
+
+			// Multiple choices, use our choice if it's legal, otherwise default to the first item on the list
+			default:
+				$backend = $this->BackendIdentifier;
+				if (!in_array($backend, $backends)) {
+					$backend = $backends[0];
+				}
+		}
+
+		return Injector::inst()->get($backend);
+	}
+
+	public function Menu()
+	{
+		$list = new ArrayList();
+
+		$controller = Controller::curr();
+		$actionType = $controller->getField('CurrentActionType');
+
+		$list->push(new ArrayData(array(
+			'Link' => sprintf('naut/project/%s/environment/%s', $this->Project()->Name, $this->Name),
+			'Title' => 'Deployments',
+			'IsCurrent' => $this->isCurrent(),
+			'IsSection' => $this->isSection() && $actionType == DNRoot::ACTION_DEPLOY
+		)));
+
+		$this->extend('updateMenu', $list);
+
+		return $list;
+	}
+
+	/**
+	 * Return the current object from $this->Menu()
+	 * Good for making titles and things
+	 */
+	public function CurrentMenu()
+	{
+		return $this->Menu()->filter('IsSection', true)->First();
+	}
+
+	/**
+	 * Return a name for this environment.
+	 *
+	 * @param string $separator The string used when concatenating project with env name
+	 * @return string
+	 */
+	public function getFullName($separator = ':')
+	{
+		return sprintf('%s%s%s', $this->Project()->Name, $separator, $this->Name);
+	}
+
+	public function getBareURL()
+	{
+		$url = parse_url($this->URL);
+		if (isset($url['host'])) {
+			return strtolower($url['host']);
+		}
+	}
+
+	/**
+	 * @return boolean true if there is a pipeline for the current environment.
+	 */
+	public function HasPipelineSupport()
+	{
+		$config = $this->GenericPipelineConfig();
+		return $config instanceof ArrayData && isset($config->Steps);
+	}
+
+	/**
+	 * Returns a {@link Pipeline} object that is linked to this environment, but isn't saved into the database. This
+	 * shouldn't be saved into the database unless you plan on starting an actual pipeline.
+	 *
+	 * @return Pipeline
+	 */
+	public function GenericPipeline()
+	{
+		$pipeline = Pipeline::create();
+		$pipeline->EnvironmentID = $this->ID;
+		return $pipeline;
+	}
+
+	/**
+	 * Returns the parsed config, based on a {@link Pipeline} being created for this {@link DNEnvironment}.
+	 *
+	 * @return ArrayData
+	 */
+	public function GenericPipelineConfig()
+	{
+		$config = $this->loadPipelineConfig();
+		if ($config) {
+			return self::array_to_viewabledata($config);
+		}
+	}
+
+	/**
+	 * Extract pipeline configuration data from the source yml file
+	 *
+	 * @return array
+	 */
+	public function loadPipelineConfig()
+	{
+		require_once 'thirdparty/spyc/spyc.php';
+
+		$path = $this->getPipelineFilename();
+		if (file_exists($path)) {
+			return Spyc::YAMLLoad($path);
+		}
+	}
+
+	/**
+	 * Returns the {@link DNEnvironment} object relating to the pipeline config for this environment. The environment
+	 * YAML file (e.g. project1-uat.yml; see docs/en/pipelines.md) contains two variable called `DependsOnProject` and
+	 * `DependsOnEnvironment` - these are used together to find the {@link DNEnvironment} that this environment should
+	 * rely on.
+	 */
+	public function DependsOnEnvironment()
+	{
+		if ($this->HasPipelineSupport()) {
+			$pipeline = $this->GenericPipeline();
+			return $pipeline->getDependentEnvironment();
+		}
+
+		return null;
+	}
+
+	/**
+	 * @return bool true if there is a currently running Pipeline, and false if there isn't
+	 */
+	public function HasCurrentPipeline()
+	{
+		return $this->CurrentPipeline() && $this->CurrentPipeline()->isInDB();
+	}
+
+	/**
+	 * This can be used to determine if there is a currently running pipeline (there can only be one running per
+	 * {@link DNEnvironment} at once), as well as getting the current pipeline to be shown in templates.
+	 *
+	 * @return DataObject|null The currently running pipeline, or null if there isn't any.
+	 */
+	public function CurrentPipeline()
+	{
+		return $this->Pipelines()->filter('Status', array('Running', 'Rollback'))->first();
+	}
+
+	/**
+	 * @return bool true if the current user can cancel a running pipeline
+	 */
+	public function CanCancelPipeline()
+	{
+		// do we have a current pipeline
+		if ($this->HasCurrentPipeline()) {
+			return $this->CurrentPipeline()->canAbort();
+		}
+		return false;
+	}
+
+	/**
+	 * Environments are only viewable by people that can view the environment.
+	 *
+	 * @param Member|null $member
+	 * @return boolean
+	 */
+	public function canView($member = null)
+	{
+		if (!$member) {
+			$member = Member::currentUser();
+		}
+		if (!$member) {
+			return false;
+		}
+		// Must be logged in to check permissions
+
+		if (Permission::checkMember($member, 'ADMIN')) {
+			return true;
+		}
+
+		// if no Viewers or ViewerGroups defined, fallback to DNProject::canView permissions
+		if ($this->Viewers()->exists() || $this->ViewerGroups()->exists()) {
+			return $this->Viewers()->byID($member->ID)
+				|| $member->inGroups($this->ViewerGroups());
+		}
+
+		return $this->Project()->canView($member);
+	}
+
+	/**
+	 * Allow deploy only to some people.
+	 *
+	 * @param Member|null $member
+	 * @return boolean
+	 */
+	public function canDeploy($member = null)
+	{
+		if (!$member) {
+			$member = Member::currentUser();
+		}
+		if (!$member) {
+			return false;
+		}
+		// Must be logged in to check permissions
+
+		if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
+			if ($this->Project()->allowed(DNRoot::ALLOW_PROD_DEPLOYMENT, $member)) {
+				return true;
+			}
+		} else {
+			if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_DEPLOYMENT, $member)) {
+				return true;
+			}
+		}
+
+		return $this->Deployers()->byID($member->ID)
+			|| $member->inGroups($this->DeployerGroups());
+	}
+
+	/**
+	 * Allows only selected {@link Member} objects to restore {@link DNDataArchive} objects into this
+	 * {@link DNEnvironment}.
+	 *
+	 * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
+	 * @return boolean true if $member can restore, and false if they can't.
+	 */
+	public function canRestore($member = null)
+	{
+		if (!$member) {
+			$member = Member::currentUser();
+		}
+		if (!$member) {
+			return false;
+		}
+		// Must be logged in to check permissions
+
+		if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
+			if ($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
+				return true;
+			}
+		} else {
+			if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
+				return true;
+			}
+		}
+
+		return $this->CanRestoreMembers()->byID($member->ID)
+			|| $member->inGroups($this->CanRestoreGroups());
+	}
+
+	/**
+	 * Allows only selected {@link Member} objects to backup this {@link DNEnvironment} to a {@link DNDataArchive}
+	 * file.
+	 *
+	 * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
+	 * @return boolean true if $member can backup, and false if they can't.
+	 */
+	public function canBackup($member = null)
+	{
+		$project = $this->Project();
+		if ($project->HasDiskQuota() && $project->HasExceededDiskQuota()) {
+			return false;
+		}
+
+		if (!$member) {
+			$member = Member::currentUser();
+		}
+		// Must be logged in to check permissions
+		if (!$member) {
+			return false;
+		}
+
+		if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
+			if ($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
+				return true;
+			}
+		} else {
+			if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
+				return true;
+			}
+		}
+
+		return $this->CanBackupMembers()->byID($member->ID)
+			|| $member->inGroups($this->CanBackupGroups());
+	}
+
+	/**
+	 * Allows only selected {@link Member} objects to upload {@link DNDataArchive} objects linked to this
+	 * {@link DNEnvironment}.
+	 *
+	 * Note: This is not uploading them to the actual environment itself (e.g. uploading to the live site) - it is the
+	 * process of uploading a *.sspak file into Deploynaut for later 'restoring' to an environment. See
+	 * {@link self::canRestore()}.
+	 *
+	 * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
+	 * @return boolean true if $member can upload archives linked to this environment, false if they can't.
+	 */
+	public function canUploadArchive($member = null)
+	{
+		$project = $this->Project();
+		if ($project->HasDiskQuota() && $project->HasExceededDiskQuota()) {
+			return false;
+		}
+
+		if (!$member) {
+			$member = Member::currentUser();
+		}
+		if (!$member) {
+			return false;
+		}
+		// Must be logged in to check permissions
+
+		if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
+			if ($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
+				return true;
+			}
+		} else {
+			if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
+				return true;
+			}
+		}
+
+		return $this->ArchiveUploaders()->byID($member->ID)
+			|| $member->inGroups($this->ArchiveUploaderGroups());
+	}
+
+	/**
+	 * Allows only selected {@link Member} objects to download {@link DNDataArchive} objects from this
+	 * {@link DNEnvironment}.
+	 *
+	 * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
+	 * @return boolean true if $member can download archives from this environment, false if they can't.
+	 */
+	public function canDownloadArchive($member = null)
+	{
+		if (!$member) {
+			$member = Member::currentUser();
+		}
+		if (!$member) {
+			return false;
+		}
+		// Must be logged in to check permissions
+
+		if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
+			if ($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
+				return true;
+			}
+		} else {
+			if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
+				return true;
+			}
+		}
+
+		return $this->ArchiveDownloaders()->byID($member->ID)
+			|| $member->inGroups($this->ArchiveDownloaderGroups());
+	}
+
+	/**
+	 * Determine if the specified user can abort any pipelines
+	 *
+	 * @param Member|null $member
+	 * @return boolean
+	 */
+	public function canAbort($member = null)
+	{
+		if (!$member) {
+			$member = Member::currentUser();
+		}
+		if (!$member) {
+			return false;
+		}
+
+		if (Permission::checkMember($member, 'ADMIN')) {
+			return true;
+		}
+
+		return $this->PipelineCancellers()->byID($member->ID)
+			|| $member->inGroups($this->PipelineCancellerGroups());
+	}
+
+	/**
+	 * Determine if the specified user can approve any pipelines
+	 *
+	 * @param Member|null $member
+	 * @return boolean
+	 */
+	public function canApprove($member = null)
+	{
+		if (!$member) {
+			$member = Member::currentUser();
+		}
+		if (!$member) {
+			return false;
+		}
+
+		if (Permission::checkMember($member, 'ADMIN')) {
+			return true;
+		}
+		return $this->PipelineApprovers()->byID($member->ID)
+			|| $member->inGroups($this->PipelineApproverGroups());
+	}
+
+	/**
+	 * Allows only selected {@link Member} objects to delete {@link DNDataArchive} objects from this
+	 * {@link DNEnvironment}.
+	 *
+	 * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
+	 * @return boolean true if $member can delete archives from this environment, false if they can't.
+	 */
+	public function canDeleteArchive($member = null)
+	{
+		if (!$member) {
+			$member = Member::currentUser();
+		}
+		if (!$member) {
+			return false;
+		}
+		// Must be logged in to check permissions
+
+		if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
+			if ($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
+				return true;
+			}
+		} else {
+			if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
+				return true;
+			}
+		}
+
+		return $this->ArchiveDeleters()->byID($member->ID)
+			|| $member->inGroups($this->ArchiveDeleterGroups());
+	}
+	/**
+	 * Get a string of groups/people that are allowed to deploy to this environment.
+	 * Used in DNRoot_project.ss to list {@link Member}s who have permission to perform this action.
+	 *
+	 * @return string
+	 */
+	public function getDeployersList()
+	{
+		return implode(
+			", ",
+			array_merge(
+				$this->DeployerGroups()->column("Title"),
+				$this->Deployers()->column("FirstName")
+			)
+		);
+	}
+
+	/**
+	 * Get a string of groups/people that are allowed to restore {@link DNDataArchive} objects into this environment.
+	 *
+	 * @return string
+	 */
+	public function getCanRestoreMembersList()
+	{
+		return implode(
+			", ",
+			array_merge(
+				$this->CanRestoreGroups()->column("Title"),
+				$this->CanRestoreMembers()->column("FirstName")
+			)
+		);
+	}
+
+	/**
+	 * Get a string of groups/people that are allowed to backup {@link DNDataArchive} objects from this environment.
+	 *
+	 * @return string
+	 */
+	public function getCanBackupMembersList()
+	{
+		return implode(
+			", ",
+			array_merge(
+				$this->CanBackupGroups()->column("Title"),
+				$this->CanBackupMembers()->column("FirstName")
+			)
+		);
+	}
+
+	/**
+	 * Get a string of groups/people that are allowed to upload {@link DNDataArchive}
+	 *  objects linked to this environment.
+	 *
+	 * @return string
+	 */
+	public function getArchiveUploadersList()
+	{
+		return implode(
+			", ",
+			array_merge(
+				$this->ArchiveUploaderGroups()->column("Title"),
+				$this->ArchiveUploaders()->column("FirstName")
+			)
+		);
+	}
+
+	/**
+	 * Get a string of groups/people that are allowed to download {@link DNDataArchive} objects from this environment.
+	 *
+	 * @return string
+	 */
+	public function getArchiveDownloadersList()
+	{
+		return implode(
+			", ",
+			array_merge(
+				$this->ArchiveDownloaderGroups()->column("Title"),
+				$this->ArchiveDownloaders()->column("FirstName")
+			)
+		);
+	}
+
+	/**
+	 * Get a string of groups/people that are allowed to delete {@link DNDataArchive} objects from this environment.
+	 *
+	 * @return string
+	 */
+	public function getArchiveDeletersList()
+	{
+		return implode(
+			", ",
+			array_merge(
+				$this->ArchiveDeleterGroups()->column("Title"),
+				$this->ArchiveDeleters()->column("FirstName")
+			)
+		);
+	}
+
+	/**
+	 * Get a string of groups/people that are allowed to approve pipelines
+	 *
+	 * @return string
+	 */
+	public function getPipelineApproversList()
+	{
+		return implode(
+			", ",
+			array_merge(
+				$this->PipelineApproverGroups()->column("Title"),
+				$this->PipelineApprovers()->column("FirstName")
+			)
+		);
+	}
+
+	/**
+	 * Get a string of groups/people that are allowed to cancel pipelines
+	 *
+	 * @return string
+	 */
+	public function getPipelineCancellersList()
+	{
+		return implode(
+			", ",
+			array_merge(
+				$this->PipelineCancellerGroups()->column("Title"),
+				$this->PipelineCancellers()->column("FirstName")
+			)
+		);
+	}
+
+	/**
+	 * @return DNData
+	 */
+	public function DNData()
+	{
+		return DNData::inst();
+	}
+
+	/**
+	 * Get the current deployed build for this environment
+	 *
+	 * Dear people of the future: If you are looking to optimize this, simply create a CurrentBuildSHA(), which can be
+	 * a lot faster. I presume you came here because of the Project display template, which only needs a SHA.
+	 *
+	 * @return false|DNDeployment
+	 */
+	public function CurrentBuild()
+	{
+		// The DeployHistory function is far too slow to use for this
+
+		/** @var DNDeployment $deploy */
+		$deploy = DNDeployment::get()->filter(array(
+			'EnvironmentID' => $this->ID,
+			'Status' => 'Finished'
+		))->sort('LastEdited DESC')->first();
+
+		if (!$deploy || (!$deploy->SHA)) {
+			return false;
+		}
+
+		$repo = $this->Project()->getRepository();
+		if (!$repo) {
+			return $deploy;
+		}
+
+		try {
+			$commit = $repo->getCommit($deploy->SHA);
+			if ($commit) {
+				$deploy->Message = Convert::raw2xml($commit->getMessage());
+				$deploy->Committer = Convert::raw2xml($commit->getCommitterName());
+				$deploy->CommitDate = $commit->getCommitterDate()->Format('d/m/Y g:ia');
+				$deploy->Author = Convert::raw2xml($commit->getAuthorName());
+				$deploy->AuthorDate = $commit->getAuthorDate()->Format('d/m/Y g:ia');
+			}
+			// We can't find this SHA, so we ignore adding a commit message to the deployment
+		} catch (Exception $ex) {
+		}
+
+		return $deploy;
+	}
+
+	/**
+	 * A history of all builds deployed to this environment
+	 *
+	 * @return ArrayList
+	 */
+	public function DeployHistory()
+	{
+		return $this->Deployments()
+			->where('SHA IS NOT NULL')
+			->sort('LastEdited DESC');
+	}
+
+	/**
+	 * @param string $sha
+	 * @return array
+	 */
+	protected function getCommitData($sha)
+	{
+		try {
+			$repo = $this->Project()->getRepository();
+			if ($repo !== false) {
+				$commit = new \Gitonomy\Git\Commit($repo, $sha);
+				return [
+					'AuthorName' => (string)Convert::raw2xml($commit->getAuthorName()),
+					'AuthorEmail' => (string)Convert::raw2xml($commit->getAuthorEmail()),
+					'Message' => (string)Convert::raw2xml($commit->getMessage()),
+					'ShortHash' => Convert::raw2xml($commit->getFixedShortHash(8)),
+					'Hash' => Convert::raw2xml($commit->getHash())
+				];
+			}
+		} catch (\Gitonomy\Git\Exception\ReferenceNotFoundException $exc) {
+			SS_Log::log($exc, SS_Log::WARN);
+		}
+		return array(
+			'AuthorName' => '(unknown)',
+			'AuthorEmail' => '(unknown)',
+			'Message' => '(unknown)',
+			'ShortHash' => $sha,
+			'Hash' => '(unknown)',
+		);
+	}
+
+	/**
+	 * @return string
+	 */
+	public function Link()
+	{
+		return $this->Project()->Link() . "/environment/" . $this->Name;
+	}
+
+	/**
+	 * Is this environment currently at the root level of the controller that handles it?
+	 * @return bool
+	 */
+	public function isCurrent()
+	{
+		return $this->isSection() && Controller::curr()->getAction() == 'environment';
+	}
+
+	/**
+	 * Is this environment currently in a controller that is handling it or performing a sub-task?
+	 * @return bool
+	 */
+	public function isSection()
+	{
+		$controller = Controller::curr();
+		$environment = $controller->getField('CurrentEnvironment');
+		return $environment && $environment->ID == $this->ID;
+	}
+
+
+	/**
+	 * Build a set of multi-select fields for assigning permissions to a pair of group and member many_many relations
+	 *
+	 * @param string $groupField Group field name
+	 * @param string $memberField Member field name
+	 * @param array $groups List of groups
+	 * @param array $members List of members
+	 * @return FieldGroup
+	 */
+	protected function buildPermissionField($groupField, $memberField, $groups, $members)
+	{
+		return FieldGroup::create(
+			ListboxField::create($groupField, false, $groups)
+				->setMultiple(true)
+				->setAttribute('data-placeholder', 'Groups')
+				->setAttribute('placeholder', 'Groups')
+				->setAttribute('style', 'width: 400px;'),
+
+			ListboxField::create($memberField, false, $members)
+				->setMultiple(true)
+				->setAttribute('data-placeholder', 'Members')
+				->setAttribute('placeholder', 'Members')
+				->setAttribute('style', 'width: 400px;')
+		);
+	}
+
+	/**
+	 * @return FieldList
+	 */
+	public function getCMSFields()
+	{
+		$fields = new FieldList(new TabSet('Root'));
+
+		$project = $this->Project();
+		if ($project && $project->exists()) {
+			$viewerGroups = $project->Viewers();
+			$groups = $viewerGroups->sort('Title')->map()->toArray();
+			$members = array();
+			foreach ($viewerGroups as $group) {
+				foreach ($group->Members()->map() as $k => $v) {
+					$members[$k] = $v;
+				}
+			}
+			asort($members);
+		} else {
+			$groups = array();
+			$members = array();
+		}
+
+		// Main tab
+		$fields->addFieldsToTab('Root.Main', array(
+			// The Main.ProjectID
+			TextField::create('ProjectName', 'Project')
+				->setValue(($project = $this->Project()) ? $project->Name : null)
+				->performReadonlyTransformation(),
+
+			// The Main.Name
+			TextField::create('Name', 'Environment name')
+				->setDescription('A descriptive name for this environment, e.g. staging, uat, production'),
+
+
+			$this->obj('Usage')->scaffoldFormField('Environment usage'),
+
+			// The Main.URL field
+			TextField::create('URL', 'Server URL')
+				->setDescription('This url will be used to provide the front-end with a link to this environment'),
+
+			// The Main.Filename
+			TextField::create('Filename')
+				->setDescription('The capistrano environment file name')
+				->performReadonlyTransformation(),
+		));
+
+		// Backend identifier - pick from a named list of configurations specified in YML config
+		$backends = $this->config()->get('allowed_backends', Config::FIRST_SET);
+		// If there's only 1 backend, then user selection isn't needed
+		if (sizeof($backends) > 1) {
+			$fields->addFieldToTab('Root.Main', DropdownField::create('BackendIdentifier', 'Deployment backend')
+				->setSource($backends)
+				->setDescription('What kind of deployment system should be used to deploy to this environment'));
+		}
+
+		$fields->addFieldsToTab('Root.UserPermissions', array(
+			// The viewers of the environment
+			$this
+				->buildPermissionField('ViewerGroups', 'Viewers', $groups, $members)
+				->setTitle('Who can view this environment?')
+				->setDescription('Groups or Users who can view this environment'),
+
+			// The Main.Deployers
+			$this
+				->buildPermissionField('DeployerGroups', 'Deployers', $groups, $members)
+				->setTitle('Who can deploy?')
+				->setDescription('Groups or Users who can deploy to this environment'),
+
+			// A box to select all snapshot options.
+			$this
+				->buildPermissionField('TickAllSnapshotGroups', 'TickAllSnapshot', $groups, $members)
+				->setTitle("<em>All snapshot permissions</em>")
+				->addExtraClass('tickall')
+				->setDescription('UI shortcut to select all snapshot-related options - not written to the database.'),
+
+			// The Main.CanRestoreMembers
+			$this
+				->buildPermissionField('CanRestoreGroups', 'CanRestoreMembers', $groups, $members)
+				->setTitle('Who can restore?')
+				->setDescription('Groups or Users who can restore archives from Deploynaut into this environment'),
+
+			// The Main.CanBackupMembers
+			$this
+				->buildPermissionField('CanBackupGroups', 'CanBackupMembers', $groups, $members)
+				->setTitle('Who can backup?')
+				->setDescription('Groups or Users who can backup archives from this environment into Deploynaut'),
+
+			// The Main.ArchiveDeleters
+			$this
+				->buildPermissionField('ArchiveDeleterGroups', 'ArchiveDeleters', $groups, $members)
+				->setTitle('Who can delete?')
+				->setDescription("Groups or Users who can delete archives from this environment's staging area."),
+
+			// The Main.ArchiveUploaders
+			$this
+				->buildPermissionField('ArchiveUploaderGroups', 'ArchiveUploaders', $groups, $members)
+				->setTitle('Who can upload?')
+				->setDescription(
+					'Users who can upload archives linked to this environment into Deploynaut.<br />' .
+					'Linking them to an environment allows limiting download permissions (see below).'
+				),
+
+			// The Main.ArchiveDownloaders
+			$this
+				->buildPermissionField('ArchiveDownloaderGroups', 'ArchiveDownloaders', $groups, $members)
+				->setTitle('Who can download?')
+				->setDescription(<<<PHP
 Users who can download archives from this environment to their computer.<br />
 Since this implies access to the snapshot, it is also a prerequisite for restores
 to other environments, alongside the "Who can restore" permission.<br>
 Should include all users with upload permissions, otherwise they can't download
 their own uploads.
 PHP
-                ),
-
-            // The Main.PipelineApprovers
-            $this
-                ->buildPermissionField('PipelineApproverGroups', 'PipelineApprovers', $groups, $members)
-                ->setTitle('Who can approve pipelines?')
-                ->setDescription('Users who can approve waiting deployment pipelines.'),
-
-            // The Main.PipelineCancellers
-            $this
-                ->buildPermissionField('PipelineCancellerGroups', 'PipelineCancellers', $groups, $members)
-                ->setTitle('Who can cancel pipelines?')
-                ->setDescription('Users who can cancel in-progess deployment pipelines.')
-        ));
-
-        // The Main.DeployConfig
-        if ($this->Project()->exists()) {
-            $this->setDeployConfigurationFields($fields);
-        }
-
-        // The DataArchives
-        $dataArchiveConfig = GridFieldConfig_RecordViewer::create();
-        $dataArchiveConfig->removeComponentsByType('GridFieldAddNewButton');
-        if (class_exists('GridFieldBulkManager')) {
-            $dataArchiveConfig->addComponent(new GridFieldBulkManager());
-        }
-        $dataArchive = GridField::create('DataArchives', 'Data Archives', $this->DataArchives(), $dataArchiveConfig);
-        $fields->addFieldToTab('Root.DataArchive', $dataArchive);
-
-        // Pipeline templates
-        $this->setPipelineConfigurationFields($fields);
-
-        // Pipelines
-        if ($this->Pipelines()->Count()) {
-            $pipelinesConfig = GridFieldConfig_RecordEditor::create();
-            $pipelinesConfig->removeComponentsByType('GridFieldAddNewButton');
-            if (class_exists('GridFieldBulkManager')) {
-                $pipelinesConfig->addComponent(new GridFieldBulkManager());
-            }
-            $pipelines = GridField::create('Pipelines', 'Pipelines', $this->Pipelines(), $pipelinesConfig);
-            $fields->addFieldToTab('Root.Pipelines', $pipelines);
-        }
-
-        // Deployments
-        $deploymentsConfig = GridFieldConfig_RecordEditor::create();
-        $deploymentsConfig->removeComponentsByType('GridFieldAddNewButton');
-        if (class_exists('GridFieldBulkManager')) {
-            $deploymentsConfig->addComponent(new GridFieldBulkManager());
-        }
-        $deployments = GridField::create('Deployments', 'Deployments', $this->Deployments(), $deploymentsConfig);
-        $fields->addFieldToTab('Root.Deployments', $deployments);
-
-        Requirements::javascript('deploynaut/javascript/environment.js');
-
-        // Add actions
-        $action = new FormAction('check', 'Check Connection');
-        $action->setUseButtonTag(true);
-        $dataURL = Director::absoluteBaseURL() . 'naut/api/' . $this->Project()->Name . '/' . $this->Name . '/ping';
-        $action->setAttribute('data-url', $dataURL);
-        $fields->insertBefore($action, 'Name');
-
-        // Allow extensions
-        $this->extend('updateCMSFields', $fields);
-        return $fields;
-    }
-
-    /**
-     * @param FieldList $fields
-     */
-    protected function setDeployConfigurationFields(&$fields)
-    {
-        if (!$this->config()->get('allow_web_editing')) {
-            return;
-        }
-
-        if ($this->envFileExists()) {
-            $deployConfig = new TextareaField('DeployConfig', 'Deploy config', $this->getEnvironmentConfig());
-            $deployConfig->setRows(40);
-            $fields->insertAfter($deployConfig, 'Filename');
-            return;
-        }
-
-        $warning = 'Warning: This environment doesn\'t have deployment configuration.';
-        $noDeployConfig = new LabelField('noDeployConfig', $warning);
-        $noDeployConfig->addExtraClass('message warning');
-        $fields->insertAfter($noDeployConfig, 'Filename');
-        $createConfigField = new CheckboxField('CreateEnvConfig', 'Create Config');
-        $createConfigField->setDescription('Would you like to create the capistrano deploy configuration?');
-        $fields->insertAfter($createConfigField, 'noDeployConfig');
-    }
-
-    /**
-     * @param FieldList $fields
-     */
-    protected function setPipelineConfigurationFields($fields)
-    {
-        if (!$this->config()->get('allow_web_editing')) {
-            return;
-        }
-        $config = $this->pipelineFileExists()
-            ? file_get_contents($this->getPipelineFilename())
-            : '';
-        $deployConfig = new TextareaField('PipelineConfig', 'Pipeline config', $config);
-        $deployConfig->setRows(40);
-        if (!$this->pipelineFileExists()) {
-            $deployConfig->setDescription(
-                "No pipeline is configured for this environment. Saving content here will generate a new template."
-            );
-        }
-        $fields->addFieldsToTab('Root.PipelineSettings', array(
-            FieldGroup::create(
-                CheckboxField::create('DryRunEnabled', 'Enable dry-run?')
-            )
-                ->setTitle('Pipeline Options')
-                ->setDescription(
-                    "Allows admins to run simulated pipelines without triggering deployments or notifications."
-                ),
-            $deployConfig
-        ));
-    }
-
-    /**
-     */
-    public function onBeforeWrite()
-    {
-        parent::onBeforeWrite();
-        if ($this->Name && $this->Name . '.rb' != $this->Filename) {
-            $this->Filename = $this->Name . '.rb';
-        }
-        $this->checkEnvironmentPath();
-        $this->writeConfigFile();
-        $this->writePipelineFile();
-    }
-
-    public function onAfterWrite()
-    {
-        parent::onAfterWrite();
-
-        if ($this->Usage == 'Production' || $this->Usage == 'UAT') {
-            $conflicting = DNEnvironment::get()
-                ->filter('ProjectID', $this->ProjectID)
-                ->filter('Usage', $this->Usage)
-                ->exclude('ID', $this->ID);
-
-            foreach ($conflicting as $otherEnvironment) {
-                $otherEnvironment->Usage = 'Unspecified';
-                $otherEnvironment->write();
-            }
-        }
-    }
-
-
-    /**
-     * Ensure that environment paths are setup on the local filesystem
-     */
-    protected function checkEnvironmentPath()
-    {
-        // Create folder if it doesn't exist
-        $configDir = dirname($this->getConfigFilename());
-        if (!file_exists($configDir) && $configDir) {
-            mkdir($configDir, 0777, true);
-        }
-    }
-
-    /**
-     * Write the deployment config file to filesystem
-     */
-    protected function writeConfigFile()
-    {
-        if (!$this->config()->get('allow_web_editing')) {
-            return;
-        }
-
-        // Create a basic new environment config from a template
-        if (!$this->envFileExists()
-            && $this->Filename
-            && $this->CreateEnvConfig
-        ) {
-            $templateFile = $this->config()->template_file ?: BASE_PATH . '/deploynaut/environment.template';
-            file_put_contents($this->getConfigFilename(), file_get_contents($templateFile));
-        } elseif ($this->envFileExists() && $this->DeployConfig) {
-            file_put_contents($this->getConfigFilename(), $this->DeployConfig);
-        }
-    }
-
-    /**
-     * Write the pipeline config file to filesystem
-     */
-    protected function writePipelineFile()
-    {
-        if (!$this->config()->get('allow_web_editing')) {
-            return;
-        }
-        $path = $this->getPipelineFilename();
-        if ($this->PipelineConfig) {
-            // Update file
-            file_put_contents($path, $this->PipelineConfig);
-        } elseif ($this->isChanged('PipelineConfig') && file_exists($path)) {
-            // Remove file if deleted
-            unlink($path);
-        }
-    }
-
-    /**
-     * Delete any related config files
-     */
-    public function onAfterDelete()
-    {
-        parent::onAfterDelete();
-        // Create a basic new environment config from a template
-        if ($this->config()->get('allow_web_editing') && $this->envFileExists()) {
-            unlink($this->getConfigFilename());
-        }
-
-        $create = $this->CreateEnvironment();
-        if ($create && $create->exists()) {
-            $create->delete();
-        }
-    }
-
-    /**
-     * @return string
-     */
-    protected function getEnvironmentConfig()
-    {
-        if (!$this->envFileExists()) {
-            return '';
-        }
-        return file_get_contents($this->getConfigFilename());
-    }
-
-    /**
-     * @return boolean
-     */
-    protected function envFileExists()
-    {
-        if (!$this->getConfigFilename()) {
-            return false;
-        }
-        return file_exists($this->getConfigFilename());
-    }
-
-    /**
-     * Returns the path to the ruby config file
-     *
-     * @return string
-     */
-    public function getConfigFilename()
-    {
-        if (!$this->Project()->exists()) {
-            return '';
-        }
-        if (!$this->Filename) {
-            return '';
-        }
-        return $this->DNData()->getEnvironmentDir() . '/' . $this->Project()->Name . '/' . $this->Filename;
-    }
-
-    /**
-     * Returns the path to the {@link Pipeline} configuration for this environment.
-     * Uses the same path and filename as the capistrano config, but with .yml extension.
-     *
-     * @return string
-     */
-    public function getPipelineFilename()
-    {
-        $name = $this->getConfigFilename();
-        if (!$name) {
-            return null;
-        }
-        $path = pathinfo($name);
-        if ($path) {
-            return $path['dirname'] . '/' . $path['filename'] . '.yml';
-        }
-    }
-
-    /**
-     * Does this environment have a pipeline config file
-     *
-     * @return boolean
-     */
-    protected function pipelineFileExists()
-    {
-        $filename = $this->getPipelineFilename();
-        if (empty($filename)) {
-            return false;
-        }
-        return file_exists($filename);
-    }
-
-    /**
-     * Helper function to convert a multi-dimensional array (associative or indexed) to an {@link ArrayList} or
-     * {@link ArrayData} object structure, so that values can be used in templates.
-     *
-     * @param array $array The (single- or multi-dimensional) array to convert
-     * @return object Either an {@link ArrayList} or {@link ArrayData} object, or the original item ($array) if $array
-     * isn't an array.
-     */
-    public static function array_to_viewabledata($array)
-    {
-        // Don't transform non-arrays
-        if (!is_array($array)) {
-            return $array;
-        }
-
-        // Figure out whether this is indexed or associative
-        $keys = array_keys($array);
-        $assoc = ($keys != array_keys($keys));
-        if ($assoc) {
-            // Treat as viewable data
-            $data = new ArrayData(array());
-            foreach ($array as $key => $value) {
-                $data->setField($key, self::array_to_viewabledata($value));
-            }
-            return $data;
-        } else {
-            // Treat this as basic non-associative list
-            $list = new ArrayList();
-            foreach ($array as $value) {
-                $list->push(self::array_to_viewabledata($value));
-            }
-            return $list;
-        }
-    }
-
-
-
-    /**
-     * Helper function to retrieve filtered commits from an environment
-     * this environment depends on
-     *
-     * @return DataList
-     */
-    public function getDependentFilteredCommits()
-    {
-        // check if this environment depends on another environemnt
-        $dependsOnEnv = $this->DependsOnEnvironment();
-        if (empty($dependsOnEnv)) {
-            return null;
-        }
-
-        // Check if there is a filter
-        $config = $this->GenericPipelineConfig();
-        $filter = isset($config->PipelineConfig->FilteredCommits)
-            ? $config->PipelineConfig->FilteredCommits
-            : null;
-        if (empty($filter)) {
-            return null;
-        }
-
-        // Create and execute filter
-        if (!class_exists($filter)) {
-            throw new Exception(sprintf("Class %s does not exist", $filter));
-        }
-        $commitClass = $filter::create();
-        // setup the environment to check for commits
-        $commitClass->env = $dependsOnEnv;
-        return $commitClass->getCommits();
-    }
-
-    /**
-     * Enable the maintenance page
-     *
-     * @param DeploynautLogFile $log
-     */
-    public function enableMaintenace($log)
-    {
-        $this->Backend()
-            ->enableMaintenance($this, $log, $this->Project());
-    }
-
-    /**
-     * Disable maintenance page
-     *
-     * @param DeploynautLogFile $log
-     */
-    public function disableMaintenance($log)
-    {
-        $this->Backend()
-            ->disableMaintenance($this, $log, $this->Project());
-    }
-
-    protected function validate()
-    {
-        $result = parent::validate();
-        $backend = $this->Backend();
-
-        if (strcasecmp('test', $this->Name) === 0 && get_class($backend) == 'CapistranoDeploymentBackend') {
-            $result->error('"test" is not a valid environment name when using Capistrano backend.');
-        }
-
-        return $result;
-    }
+				),
+
+			// The Main.PipelineApprovers
+			$this
+				->buildPermissionField('PipelineApproverGroups', 'PipelineApprovers', $groups, $members)
+				->setTitle('Who can approve pipelines?')
+				->setDescription('Users who can approve waiting deployment pipelines.'),
+
+			// The Main.PipelineCancellers
+			$this
+				->buildPermissionField('PipelineCancellerGroups', 'PipelineCancellers', $groups, $members)
+				->setTitle('Who can cancel pipelines?')
+				->setDescription('Users who can cancel in-progess deployment pipelines.')
+		));
+
+		// The Main.DeployConfig
+		if ($this->Project()->exists()) {
+			$this->setDeployConfigurationFields($fields);
+		}
+
+		// The DataArchives
+		$dataArchiveConfig = GridFieldConfig_RecordViewer::create();
+		$dataArchiveConfig->removeComponentsByType('GridFieldAddNewButton');
+		if (class_exists('GridFieldBulkManager')) {
+			$dataArchiveConfig->addComponent(new GridFieldBulkManager());
+		}
+		$dataArchive = GridField::create('DataArchives', 'Data Archives', $this->DataArchives(), $dataArchiveConfig);
+		$fields->addFieldToTab('Root.DataArchive', $dataArchive);
+
+		// Pipeline templates
+		$this->setPipelineConfigurationFields($fields);
+
+		// Pipelines
+		if ($this->Pipelines()->Count()) {
+			$pipelinesConfig = GridFieldConfig_RecordEditor::create();
+			$pipelinesConfig->removeComponentsByType('GridFieldAddNewButton');
+			if (class_exists('GridFieldBulkManager')) {
+				$pipelinesConfig->addComponent(new GridFieldBulkManager());
+			}
+			$pipelines = GridField::create('Pipelines', 'Pipelines', $this->Pipelines(), $pipelinesConfig);
+			$fields->addFieldToTab('Root.Pipelines', $pipelines);
+		}
+
+		// Deployments
+		$deploymentsConfig = GridFieldConfig_RecordEditor::create();
+		$deploymentsConfig->removeComponentsByType('GridFieldAddNewButton');
+		if (class_exists('GridFieldBulkManager')) {
+			$deploymentsConfig->addComponent(new GridFieldBulkManager());
+		}
+		$deployments = GridField::create('Deployments', 'Deployments', $this->Deployments(), $deploymentsConfig);
+		$fields->addFieldToTab('Root.Deployments', $deployments);
+
+		Requirements::javascript('deploynaut/javascript/environment.js');
+
+		// Add actions
+		$action = new FormAction('check', 'Check Connection');
+		$action->setUseButtonTag(true);
+		$dataURL = Director::absoluteBaseURL() . 'naut/api/' . $this->Project()->Name . '/' . $this->Name . '/ping';
+		$action->setAttribute('data-url', $dataURL);
+		$fields->insertBefore($action, 'Name');
+
+		// Allow extensions
+		$this->extend('updateCMSFields', $fields);
+		return $fields;
+	}
+
+	/**
+	 * @param FieldList $fields
+	 */
+	protected function setDeployConfigurationFields(&$fields)
+	{
+		if (!$this->config()->get('allow_web_editing')) {
+			return;
+		}
+
+		if ($this->envFileExists()) {
+			$deployConfig = new TextareaField('DeployConfig', 'Deploy config', $this->getEnvironmentConfig());
+			$deployConfig->setRows(40);
+			$fields->insertAfter($deployConfig, 'Filename');
+			return;
+		}
+
+		$warning = 'Warning: This environment doesn\'t have deployment configuration.';
+		$noDeployConfig = new LabelField('noDeployConfig', $warning);
+		$noDeployConfig->addExtraClass('message warning');
+		$fields->insertAfter($noDeployConfig, 'Filename');
+		$createConfigField = new CheckboxField('CreateEnvConfig', 'Create Config');
+		$createConfigField->setDescription('Would you like to create the capistrano deploy configuration?');
+		$fields->insertAfter($createConfigField, 'noDeployConfig');
+	}
+
+	/**
+	 * @param FieldList $fields
+	 */
+	protected function setPipelineConfigurationFields($fields)
+	{
+		if (!$this->config()->get('allow_web_editing')) {
+			return;
+		}
+		$config = $this->pipelineFileExists()
+			? file_get_contents($this->getPipelineFilename())
+			: '';
+		$deployConfig = new TextareaField('PipelineConfig', 'Pipeline config', $config);
+		$deployConfig->setRows(40);
+		if (!$this->pipelineFileExists()) {
+			$deployConfig->setDescription(
+				"No pipeline is configured for this environment. Saving content here will generate a new template."
+			);
+		}
+		$fields->addFieldsToTab('Root.PipelineSettings', array(
+			FieldGroup::create(
+				CheckboxField::create('DryRunEnabled', 'Enable dry-run?')
+			)
+				->setTitle('Pipeline Options')
+				->setDescription(
+					"Allows admins to run simulated pipelines without triggering deployments or notifications."
+				),
+			$deployConfig
+		));
+	}
+
+	/**
+	 */
+	public function onBeforeWrite()
+	{
+		parent::onBeforeWrite();
+		if ($this->Name && $this->Name . '.rb' != $this->Filename) {
+			$this->Filename = $this->Name . '.rb';
+		}
+		$this->checkEnvironmentPath();
+		$this->writeConfigFile();
+		$this->writePipelineFile();
+	}
+
+	public function onAfterWrite()
+	{
+		parent::onAfterWrite();
+
+		if ($this->Usage == 'Production' || $this->Usage == 'UAT') {
+			$conflicting = DNEnvironment::get()
+				->filter('ProjectID', $this->ProjectID)
+				->filter('Usage', $this->Usage)
+				->exclude('ID', $this->ID);
+
+			foreach ($conflicting as $otherEnvironment) {
+				$otherEnvironment->Usage = 'Unspecified';
+				$otherEnvironment->write();
+			}
+		}
+	}
+
+
+	/**
+	 * Ensure that environment paths are setup on the local filesystem
+	 */
+	protected function checkEnvironmentPath()
+	{
+		// Create folder if it doesn't exist
+		$configDir = dirname($this->getConfigFilename());
+		if (!file_exists($configDir) && $configDir) {
+			mkdir($configDir, 0777, true);
+		}
+	}
+
+	/**
+	 * Write the deployment config file to filesystem
+	 */
+	protected function writeConfigFile()
+	{
+		if (!$this->config()->get('allow_web_editing')) {
+			return;
+		}
+
+		// Create a basic new environment config from a template
+		if (!$this->envFileExists()
+			&& $this->Filename
+			&& $this->CreateEnvConfig
+		) {
+			$templateFile = $this->config()->template_file ?: BASE_PATH . '/deploynaut/environment.template';
+			file_put_contents($this->getConfigFilename(), file_get_contents($templateFile));
+		} elseif ($this->envFileExists() && $this->DeployConfig) {
+			file_put_contents($this->getConfigFilename(), $this->DeployConfig);
+		}
+	}
+
+	/**
+	 * Write the pipeline config file to filesystem
+	 */
+	protected function writePipelineFile()
+	{
+		if (!$this->config()->get('allow_web_editing')) {
+			return;
+		}
+		$path = $this->getPipelineFilename();
+		if ($this->PipelineConfig) {
+			// Update file
+			file_put_contents($path, $this->PipelineConfig);
+		} elseif ($this->isChanged('PipelineConfig') && file_exists($path)) {
+			// Remove file if deleted
+			unlink($path);
+		}
+	}
+
+	/**
+	 * Delete any related config files
+	 */
+	public function onAfterDelete()
+	{
+		parent::onAfterDelete();
+		// Create a basic new environment config from a template
+		if ($this->config()->get('allow_web_editing') && $this->envFileExists()) {
+			unlink($this->getConfigFilename());
+		}
+
+		$create = $this->CreateEnvironment();
+		if ($create && $create->exists()) {
+			$create->delete();
+		}
+	}
+
+	/**
+	 * @return string
+	 */
+	protected function getEnvironmentConfig()
+	{
+		if (!$this->envFileExists()) {
+			return '';
+		}
+		return file_get_contents($this->getConfigFilename());
+	}
+
+	/**
+	 * @return boolean
+	 */
+	protected function envFileExists()
+	{
+		if (!$this->getConfigFilename()) {
+			return false;
+		}
+		return file_exists($this->getConfigFilename());
+	}
+
+	/**
+	 * Returns the path to the ruby config file
+	 *
+	 * @return string
+	 */
+	public function getConfigFilename()
+	{
+		if (!$this->Project()->exists()) {
+			return '';
+		}
+		if (!$this->Filename) {
+			return '';
+		}
+		return $this->DNData()->getEnvironmentDir() . '/' . $this->Project()->Name . '/' . $this->Filename;
+	}
+
+	/**
+	 * Returns the path to the {@link Pipeline} configuration for this environment.
+	 * Uses the same path and filename as the capistrano config, but with .yml extension.
+	 *
+	 * @return string
+	 */
+	public function getPipelineFilename()
+	{
+		$name = $this->getConfigFilename();
+		if (!$name) {
+			return null;
+		}
+		$path = pathinfo($name);
+		if ($path) {
+			return $path['dirname'] . '/' . $path['filename'] . '.yml';
+		}
+	}
+
+	/**
+	 * Does this environment have a pipeline config file
+	 *
+	 * @return boolean
+	 */
+	protected function pipelineFileExists()
+	{
+		$filename = $this->getPipelineFilename();
+		if (empty($filename)) {
+			return false;
+		}
+		return file_exists($filename);
+	}
+
+	/**
+	 * Helper function to convert a multi-dimensional array (associative or indexed) to an {@link ArrayList} or
+	 * {@link ArrayData} object structure, so that values can be used in templates.
+	 *
+	 * @param array $array The (single- or multi-dimensional) array to convert
+	 * @return object Either an {@link ArrayList} or {@link ArrayData} object, or the original item ($array) if $array
+	 * isn't an array.
+	 */
+	public static function array_to_viewabledata($array)
+	{
+		// Don't transform non-arrays
+		if (!is_array($array)) {
+			return $array;
+		}
+
+		// Figure out whether this is indexed or associative
+		$keys = array_keys($array);
+		$assoc = ($keys != array_keys($keys));
+		if ($assoc) {
+			// Treat as viewable data
+			$data = new ArrayData(array());
+			foreach ($array as $key => $value) {
+				$data->setField($key, self::array_to_viewabledata($value));
+			}
+			return $data;
+		} else {
+			// Treat this as basic non-associative list
+			$list = new ArrayList();
+			foreach ($array as $value) {
+				$list->push(self::array_to_viewabledata($value));
+			}
+			return $list;
+		}
+	}
+
+
+
+	/**
+	 * Helper function to retrieve filtered commits from an environment
+	 * this environment depends on
+	 *
+	 * @return DataList
+	 */
+	public function getDependentFilteredCommits()
+	{
+		// check if this environment depends on another environemnt
+		$dependsOnEnv = $this->DependsOnEnvironment();
+		if (empty($dependsOnEnv)) {
+			return null;
+		}
+
+		// Check if there is a filter
+		$config = $this->GenericPipelineConfig();
+		$filter = isset($config->PipelineConfig->FilteredCommits)
+			? $config->PipelineConfig->FilteredCommits
+			: null;
+		if (empty($filter)) {
+			return null;
+		}
+
+		// Create and execute filter
+		if (!class_exists($filter)) {
+			throw new Exception(sprintf("Class %s does not exist", $filter));
+		}
+		$commitClass = $filter::create();
+		// setup the environment to check for commits
+		$commitClass->env = $dependsOnEnv;
+		return $commitClass->getCommits();
+	}
+
+	/**
+	 * Enable the maintenance page
+	 *
+	 * @param DeploynautLogFile $log
+	 */
+	public function enableMaintenace($log)
+	{
+		$this->Backend()
+			->enableMaintenance($this, $log, $this->Project());
+	}
+
+	/**
+	 * Disable maintenance page
+	 *
+	 * @param DeploynautLogFile $log
+	 */
+	public function disableMaintenance($log)
+	{
+		$this->Backend()
+			->disableMaintenance($this, $log, $this->Project());
+	}
+
+	protected function validate()
+	{
+		$result = parent::validate();
+		$backend = $this->Backend();
+
+		if (strcasecmp('test', $this->Name) === 0 && get_class($backend) == 'CapistranoDeploymentBackend') {
+			$result->error('"test" is not a valid environment name when using Capistrano backend.');
+		}
+
+		return $result;
+	}
 }

Spacing +95 added lines, -95 removed lines

@@ -191,7 +191,7 @@ 
     public function Backend()
     {
         $backends = array_keys($this->config()->get('allowed_backends', Config::FIRST_SET));
-        switch (sizeof($backends)) {
+        switch(sizeof($backends)) {
         // Nothing allowed, use the default value "DeploymentBackend"
             case 0:
                 $backend = "DeploymentBackend";
@@ -205,7 +205,7 @@ 
             // Multiple choices, use our choice if it's legal, otherwise default to the first item on the list
             default:
                 $backend = $this->BackendIdentifier;
-                if (!in_array($backend, $backends)) {
+                if(!in_array($backend, $backends)) {
                     $backend = $backends[0];
                 }
         }
@@ -255,7 +255,7 @@ 
     public function getBareURL()
     {
         $url = parse_url($this->URL);
-        if (isset($url['host'])) {
+        if(isset($url['host'])) {
             return strtolower($url['host']);
         }
     }
@@ -290,7 +290,7 @@ 
     public function GenericPipelineConfig()
     {
         $config = $this->loadPipelineConfig();
-        if ($config) {
+        if($config) {
             return self::array_to_viewabledata($config);
         }
     }
@@ -305,7 +305,7 @@ 
         require_once 'thirdparty/spyc/spyc.php';
 
         $path = $this->getPipelineFilename();
-        if (file_exists($path)) {
+        if(file_exists($path)) {
             return Spyc::YAMLLoad($path);
         }
     }
@@ -318,7 +318,7 @@ 
      */
     public function DependsOnEnvironment()
     {
-        if ($this->HasPipelineSupport()) {
+        if($this->HasPipelineSupport()) {
             $pipeline = $this->GenericPipeline();
             return $pipeline->getDependentEnvironment();
         }
@@ -351,7 +351,7 @@ 
     public function CanCancelPipeline()
     {
         // do we have a current pipeline
-        if ($this->HasCurrentPipeline()) {
+        if($this->HasCurrentPipeline()) {
             return $this->CurrentPipeline()->canAbort();
         }
         return false;
@@ -365,20 +365,20 @@ 
      */
     public function canView($member = null)
     {
-        if (!$member) {
+        if(!$member) {
             $member = Member::currentUser();
         }
-        if (!$member) {
+        if(!$member) {
             return false;
         }
         // Must be logged in to check permissions
 
-        if (Permission::checkMember($member, 'ADMIN')) {
+        if(Permission::checkMember($member, 'ADMIN')) {
             return true;
         }
 
         // if no Viewers or ViewerGroups defined, fallback to DNProject::canView permissions
-        if ($this->Viewers()->exists() || $this->ViewerGroups()->exists()) {
+        if($this->Viewers()->exists() || $this->ViewerGroups()->exists()) {
             return $this->Viewers()->byID($member->ID)
                 || $member->inGroups($this->ViewerGroups());
         }
@@ -394,20 +394,20 @@ 
      */
     public function canDeploy($member = null)
     {
-        if (!$member) {
+        if(!$member) {
             $member = Member::currentUser();
         }
-        if (!$member) {
+        if(!$member) {
             return false;
         }
         // Must be logged in to check permissions
 
-        if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
-            if ($this->Project()->allowed(DNRoot::ALLOW_PROD_DEPLOYMENT, $member)) {
+        if($this->Usage === 'Production' || $this->Usage === 'Unspecified') {
+            if($this->Project()->allowed(DNRoot::ALLOW_PROD_DEPLOYMENT, $member)) {
                 return true;
             }
         } else {
-            if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_DEPLOYMENT, $member)) {
+            if($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_DEPLOYMENT, $member)) {
                 return true;
             }
         }
@@ -425,20 +425,20 @@ 
      */
     public function canRestore($member = null)
     {
-        if (!$member) {
+        if(!$member) {
             $member = Member::currentUser();
         }
-        if (!$member) {
+        if(!$member) {
             return false;
         }
         // Must be logged in to check permissions
 
-        if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
-            if ($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
+        if($this->Usage === 'Production' || $this->Usage === 'Unspecified') {
+            if($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
                 return true;
             }
         } else {
-            if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
+            if($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
                 return true;
             }
         }
@@ -457,24 +457,24 @@ 
     public function canBackup($member = null)
     {
         $project = $this->Project();
-        if ($project->HasDiskQuota() && $project->HasExceededDiskQuota()) {
+        if($project->HasDiskQuota() && $project->HasExceededDiskQuota()) {
             return false;
         }
 
-        if (!$member) {
+        if(!$member) {
             $member = Member::currentUser();
         }
         // Must be logged in to check permissions
-        if (!$member) {
+        if(!$member) {
             return false;
         }
 
-        if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
-            if ($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
+        if($this->Usage === 'Production' || $this->Usage === 'Unspecified') {
+            if($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
                 return true;
             }
         } else {
-            if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
+            if($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
                 return true;
             }
         }
@@ -497,24 +497,24 @@ 
     public function canUploadArchive($member = null)
     {
         $project = $this->Project();
-        if ($project->HasDiskQuota() && $project->HasExceededDiskQuota()) {
+        if($project->HasDiskQuota() && $project->HasExceededDiskQuota()) {
             return false;
         }
 
-        if (!$member) {
+        if(!$member) {
             $member = Member::currentUser();
         }
-        if (!$member) {
+        if(!$member) {
             return false;
         }
         // Must be logged in to check permissions
 
-        if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
-            if ($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
+        if($this->Usage === 'Production' || $this->Usage === 'Unspecified') {
+            if($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
                 return true;
             }
         } else {
-            if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
+            if($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
                 return true;
             }
         }
@@ -532,20 +532,20 @@ 
      */
     public function canDownloadArchive($member = null)
     {
-        if (!$member) {
+        if(!$member) {
             $member = Member::currentUser();
         }
-        if (!$member) {
+        if(!$member) {
             return false;
         }
         // Must be logged in to check permissions
 
-        if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
-            if ($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
+        if($this->Usage === 'Production' || $this->Usage === 'Unspecified') {
+            if($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
                 return true;
             }
         } else {
-            if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
+            if($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
                 return true;
             }
         }
@@ -562,14 +562,14 @@ 
      */
     public function canAbort($member = null)
     {
-        if (!$member) {
+        if(!$member) {
             $member = Member::currentUser();
         }
-        if (!$member) {
+        if(!$member) {
             return false;
         }
 
-        if (Permission::checkMember($member, 'ADMIN')) {
+        if(Permission::checkMember($member, 'ADMIN')) {
             return true;
         }
 
@@ -585,14 +585,14 @@ 
      */
     public function canApprove($member = null)
     {
-        if (!$member) {
+        if(!$member) {
             $member = Member::currentUser();
         }
-        if (!$member) {
+        if(!$member) {
             return false;
         }
 
-        if (Permission::checkMember($member, 'ADMIN')) {
+        if(Permission::checkMember($member, 'ADMIN')) {
             return true;
         }
         return $this->PipelineApprovers()->byID($member->ID)
@@ -608,20 +608,20 @@ 
      */
     public function canDeleteArchive($member = null)
     {
-        if (!$member) {
+        if(!$member) {
             $member = Member::currentUser();
         }
-        if (!$member) {
+        if(!$member) {
             return false;
         }
         // Must be logged in to check permissions
 
-        if ($this->Usage==='Production' || $this->Usage==='Unspecified') {
-            if ($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
+        if($this->Usage === 'Production' || $this->Usage === 'Unspecified') {
+            if($this->Project()->allowed(DNRoot::ALLOW_PROD_SNAPSHOT, $member)) {
                 return true;
             }
         } else {
-            if ($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
+            if($this->Project()->allowed(DNRoot::ALLOW_NON_PROD_SNAPSHOT, $member)) {
                 return true;
             }
         }
@@ -785,18 +785,18 @@ 
             'Status' => 'Finished'
         ))->sort('LastEdited DESC')->first();
 
-        if (!$deploy || (!$deploy->SHA)) {
+        if(!$deploy || (!$deploy->SHA)) {
             return false;
         }
 
         $repo = $this->Project()->getRepository();
-        if (!$repo) {
+        if(!$repo) {
             return $deploy;
         }
 
         try {
             $commit = $repo->getCommit($deploy->SHA);
-            if ($commit) {
+            if($commit) {
                 $deploy->Message = Convert::raw2xml($commit->getMessage());
                 $deploy->Committer = Convert::raw2xml($commit->getCommitterName());
                 $deploy->CommitDate = $commit->getCommitterDate()->Format('d/m/Y g:ia');
@@ -804,7 +804,7 @@ 
                 $deploy->AuthorDate = $commit->getAuthorDate()->Format('d/m/Y g:ia');
             }
             // We can't find this SHA, so we ignore adding a commit message to the deployment
-        } catch (Exception $ex) {
+        } catch(Exception $ex) {
         }
 
         return $deploy;
@@ -830,7 +830,7 @@ 
     {
         try {
             $repo = $this->Project()->getRepository();
-            if ($repo !== false) {
+            if($repo !== false) {
                 $commit = new \Gitonomy\Git\Commit($repo, $sha);
                 return [
                     'AuthorName' => (string)Convert::raw2xml($commit->getAuthorName()),
@@ -840,7 +840,7 @@ 
                     'Hash' => Convert::raw2xml($commit->getHash())
                 ];
             }
-        } catch (\Gitonomy\Git\Exception\ReferenceNotFoundException $exc) {
+        } catch(\Gitonomy\Git\Exception\ReferenceNotFoundException $exc) {
             SS_Log::log($exc, SS_Log::WARN);
         }
         return array(
@@ -915,12 +915,12 @@ 
         $fields = new FieldList(new TabSet('Root'));
 
         $project = $this->Project();
-        if ($project && $project->exists()) {
+        if($project && $project->exists()) {
             $viewerGroups = $project->Viewers();
             $groups = $viewerGroups->sort('Title')->map()->toArray();
             $members = array();
-            foreach ($viewerGroups as $group) {
-                foreach ($group->Members()->map() as $k => $v) {
+            foreach($viewerGroups as $group) {
+                foreach($group->Members()->map() as $k => $v) {
                     $members[$k] = $v;
                 }
             }
@@ -957,7 +957,7 @@ 
         // Backend identifier - pick from a named list of configurations specified in YML config
         $backends = $this->config()->get('allowed_backends', Config::FIRST_SET);
         // If there's only 1 backend, then user selection isn't needed
-        if (sizeof($backends) > 1) {
+        if(sizeof($backends) > 1) {
             $fields->addFieldToTab('Root.Main', DropdownField::create('BackendIdentifier', 'Deployment backend')
                 ->setSource($backends)
                 ->setDescription('What kind of deployment system should be used to deploy to this environment'));
@@ -1037,14 +1037,14 @@ 
         ));
 
         // The Main.DeployConfig
-        if ($this->Project()->exists()) {
+        if($this->Project()->exists()) {
             $this->setDeployConfigurationFields($fields);
         }
 
         // The DataArchives
         $dataArchiveConfig = GridFieldConfig_RecordViewer::create();
         $dataArchiveConfig->removeComponentsByType('GridFieldAddNewButton');
-        if (class_exists('GridFieldBulkManager')) {
+        if(class_exists('GridFieldBulkManager')) {
             $dataArchiveConfig->addComponent(new GridFieldBulkManager());
         }
         $dataArchive = GridField::create('DataArchives', 'Data Archives', $this->DataArchives(), $dataArchiveConfig);
@@ -1054,10 +1054,10 @@ 
         $this->setPipelineConfigurationFields($fields);
 
         // Pipelines
-        if ($this->Pipelines()->Count()) {
+        if($this->Pipelines()->Count()) {
             $pipelinesConfig = GridFieldConfig_RecordEditor::create();
             $pipelinesConfig->removeComponentsByType('GridFieldAddNewButton');
-            if (class_exists('GridFieldBulkManager')) {
+            if(class_exists('GridFieldBulkManager')) {
                 $pipelinesConfig->addComponent(new GridFieldBulkManager());
             }
             $pipelines = GridField::create('Pipelines', 'Pipelines', $this->Pipelines(), $pipelinesConfig);
@@ -1067,7 +1067,7 @@ 
         // Deployments
         $deploymentsConfig = GridFieldConfig_RecordEditor::create();
         $deploymentsConfig->removeComponentsByType('GridFieldAddNewButton');
-        if (class_exists('GridFieldBulkManager')) {
+        if(class_exists('GridFieldBulkManager')) {
             $deploymentsConfig->addComponent(new GridFieldBulkManager());
         }
         $deployments = GridField::create('Deployments', 'Deployments', $this->Deployments(), $deploymentsConfig);
@@ -1092,11 +1092,11 @@ 
      */
     protected function setDeployConfigurationFields(&$fields)
     {
-        if (!$this->config()->get('allow_web_editing')) {
+        if(!$this->config()->get('allow_web_editing')) {
             return;
         }
 
-        if ($this->envFileExists()) {
+        if($this->envFileExists()) {
             $deployConfig = new TextareaField('DeployConfig', 'Deploy config', $this->getEnvironmentConfig());
             $deployConfig->setRows(40);
             $fields->insertAfter($deployConfig, 'Filename');
@@ -1117,7 +1117,7 @@ 
      */
     protected function setPipelineConfigurationFields($fields)
     {
-        if (!$this->config()->get('allow_web_editing')) {
+        if(!$this->config()->get('allow_web_editing')) {
             return;
         }
         $config = $this->pipelineFileExists()
@@ -1125,7 +1125,7 @@ 
             : '';
         $deployConfig = new TextareaField('PipelineConfig', 'Pipeline config', $config);
         $deployConfig->setRows(40);
-        if (!$this->pipelineFileExists()) {
+        if(!$this->pipelineFileExists()) {
             $deployConfig->setDescription(
                 "No pipeline is configured for this environment. Saving content here will generate a new template."
             );
@@ -1147,7 +1147,7 @@ 
     public function onBeforeWrite()
     {
         parent::onBeforeWrite();
-        if ($this->Name && $this->Name . '.rb' != $this->Filename) {
+        if($this->Name && $this->Name . '.rb' != $this->Filename) {
             $this->Filename = $this->Name . '.rb';
         }
         $this->checkEnvironmentPath();
@@ -1159,13 +1159,13 @@ 
     {
         parent::onAfterWrite();
 
-        if ($this->Usage == 'Production' || $this->Usage == 'UAT') {
+        if($this->Usage == 'Production' || $this->Usage == 'UAT') {
             $conflicting = DNEnvironment::get()
                 ->filter('ProjectID', $this->ProjectID)
                 ->filter('Usage', $this->Usage)
                 ->exclude('ID', $this->ID);
 
-            foreach ($conflicting as $otherEnvironment) {
+            foreach($conflicting as $otherEnvironment) {
                 $otherEnvironment->Usage = 'Unspecified';
                 $otherEnvironment->write();
             }
@@ -1180,7 +1180,7 @@ 
     {
         // Create folder if it doesn't exist
         $configDir = dirname($this->getConfigFilename());
-        if (!file_exists($configDir) && $configDir) {
+        if(!file_exists($configDir) && $configDir) {
             mkdir($configDir, 0777, true);
         }
     }
@@ -1190,18 +1190,18 @@ 
      */
     protected function writeConfigFile()
     {
-        if (!$this->config()->get('allow_web_editing')) {
+        if(!$this->config()->get('allow_web_editing')) {
             return;
         }
 
         // Create a basic new environment config from a template
-        if (!$this->envFileExists()
+        if(!$this->envFileExists()
             && $this->Filename
             && $this->CreateEnvConfig
         ) {
             $templateFile = $this->config()->template_file ?: BASE_PATH . '/deploynaut/environment.template';
             file_put_contents($this->getConfigFilename(), file_get_contents($templateFile));
-        } elseif ($this->envFileExists() && $this->DeployConfig) {
+        } elseif($this->envFileExists() && $this->DeployConfig) {
             file_put_contents($this->getConfigFilename(), $this->DeployConfig);
         }
     }
@@ -1211,14 +1211,14 @@ 
      */
     protected function writePipelineFile()
     {
-        if (!$this->config()->get('allow_web_editing')) {
+        if(!$this->config()->get('allow_web_editing')) {
             return;
         }
         $path = $this->getPipelineFilename();
-        if ($this->PipelineConfig) {
+        if($this->PipelineConfig) {
             // Update file
             file_put_contents($path, $this->PipelineConfig);
-        } elseif ($this->isChanged('PipelineConfig') && file_exists($path)) {
+        } elseif($this->isChanged('PipelineConfig') && file_exists($path)) {
             // Remove file if deleted
             unlink($path);
         }
@@ -1231,12 +1231,12 @@ 
     {
         parent::onAfterDelete();
         // Create a basic new environment config from a template
-        if ($this->config()->get('allow_web_editing') && $this->envFileExists()) {
+        if($this->config()->get('allow_web_editing') && $this->envFileExists()) {
             unlink($this->getConfigFilename());
         }
 
         $create = $this->CreateEnvironment();
-        if ($create && $create->exists()) {
+        if($create && $create->exists()) {
             $create->delete();
         }
     }
@@ -1246,7 +1246,7 @@ 
      */
     protected function getEnvironmentConfig()
     {
-        if (!$this->envFileExists()) {
+        if(!$this->envFileExists()) {
             return '';
         }
         return file_get_contents($this->getConfigFilename());
@@ -1257,7 +1257,7 @@ 
      */
     protected function envFileExists()
     {
-        if (!$this->getConfigFilename()) {
+        if(!$this->getConfigFilename()) {
             return false;
         }
         return file_exists($this->getConfigFilename());
@@ -1270,10 +1270,10 @@ 
      */
     public function getConfigFilename()
     {
-        if (!$this->Project()->exists()) {
+        if(!$this->Project()->exists()) {
             return '';
         }
-        if (!$this->Filename) {
+        if(!$this->Filename) {
             return '';
         }
         return $this->DNData()->getEnvironmentDir() . '/' . $this->Project()->Name . '/' . $this->Filename;
@@ -1288,11 +1288,11 @@ 
     public function getPipelineFilename()
     {
         $name = $this->getConfigFilename();
-        if (!$name) {
+        if(!$name) {
             return null;
         }
         $path = pathinfo($name);
-        if ($path) {
+        if($path) {
             return $path['dirname'] . '/' . $path['filename'] . '.yml';
         }
     }
@@ -1305,7 +1305,7 @@ 
     protected function pipelineFileExists()
     {
         $filename = $this->getPipelineFilename();
-        if (empty($filename)) {
+        if(empty($filename)) {
             return false;
         }
         return file_exists($filename);
@@ -1322,24 +1322,24 @@ 
     public static function array_to_viewabledata($array)
     {
         // Don't transform non-arrays
-        if (!is_array($array)) {
+        if(!is_array($array)) {
             return $array;
         }
 
         // Figure out whether this is indexed or associative
         $keys = array_keys($array);
         $assoc = ($keys != array_keys($keys));
-        if ($assoc) {
+        if($assoc) {
             // Treat as viewable data
             $data = new ArrayData(array());
-            foreach ($array as $key => $value) {
+            foreach($array as $key => $value) {
                 $data->setField($key, self::array_to_viewabledata($value));
             }
             return $data;
         } else {
             // Treat this as basic non-associative list
             $list = new ArrayList();
-            foreach ($array as $value) {
+            foreach($array as $value) {
                 $list->push(self::array_to_viewabledata($value));
             }
             return $list;
@@ -1358,7 +1358,7 @@ 
     {
         // check if this environment depends on another environemnt
         $dependsOnEnv = $this->DependsOnEnvironment();
-        if (empty($dependsOnEnv)) {
+        if(empty($dependsOnEnv)) {
             return null;
         }
 
@@ -1367,12 +1367,12 @@ 
         $filter = isset($config->PipelineConfig->FilteredCommits)
             ? $config->PipelineConfig->FilteredCommits
             : null;
-        if (empty($filter)) {
+        if(empty($filter)) {
             return null;
         }
 
         // Create and execute filter
-        if (!class_exists($filter)) {
+        if(!class_exists($filter)) {
             throw new Exception(sprintf("Class %s does not exist", $filter));
         }
         $commitClass = $filter::create();
@@ -1408,7 +1408,7 @@ 
         $result = parent::validate();
         $backend = $this->Backend();
 
-        if (strcasecmp('test', $this->Name) === 0 && get_class($backend) == 'CapistranoDeploymentBackend') {
+        if(strcasecmp('test', $this->Name) === 0 && get_class($backend) == 'CapistranoDeploymentBackend') {
             $result->error('"test" is not a valid environment name when using Capistrano backend.');
         }
 

Braces +59 added lines, -118 removed lines

@@ -39,8 +39,7 @@ 
  * @method ManyManyList PipelineCancellers()
  * @method ManyManyList PipelineCancellerGroups()
  */
-class DNEnvironment extends DataObject
-{
+class DNEnvironment extends DataObject {
 
     /**
      * If this is set to a full pathfile, it will be used as template
@@ -168,8 +167,7 @@ 
      * @param string $path
      * @return \DNEnvironment
      */
-    public static function create_from_path($path)
-    {
+    public static function create_from_path($path) {
         $e = DNEnvironment::create();
         $e->Filename = $path;
         $e->Name = basename($e->Filename, '.rb');
@@ -188,8 +186,7 @@ 
      *
      * @return DeploymentBackend
      */
-    public function Backend()
-    {
+    public function Backend() {
         $backends = array_keys($this->config()->get('allowed_backends', Config::FIRST_SET));
         switch (sizeof($backends)) {
         // Nothing allowed, use the default value "DeploymentBackend"
@@ -213,8 +210,7 @@ 
         return Injector::inst()->get($backend);
     }
 
-    public function Menu()
-    {
+    public function Menu() {
         $list = new ArrayList();
 
         $controller = Controller::curr();
@@ -236,8 +232,7 @@ 
      * Return the current object from $this->Menu()
      * Good for making titles and things
      */
-    public function CurrentMenu()
-    {
+    public function CurrentMenu() {
         return $this->Menu()->filter('IsSection', true)->First();
     }
 
@@ -247,13 +242,11 @@ 
      * @param string $separator The string used when concatenating project with env name
      * @return string
      */
-    public function getFullName($separator = ':')
-    {
+    public function getFullName($separator = ':') {
         return sprintf('%s%s%s', $this->Project()->Name, $separator, $this->Name);
     }
 
-    public function getBareURL()
-    {
+    public function getBareURL() {
         $url = parse_url($this->URL);
         if (isset($url['host'])) {
             return strtolower($url['host']);
@@ -263,8 +256,7 @@ 
     /**
      * @return boolean true if there is a pipeline for the current environment.
      */
-    public function HasPipelineSupport()
-    {
+    public function HasPipelineSupport() {
         $config = $this->GenericPipelineConfig();
         return $config instanceof ArrayData && isset($config->Steps);
     }
@@ -275,8 +267,7 @@ 
      *
      * @return Pipeline
      */
-    public function GenericPipeline()
-    {
+    public function GenericPipeline() {
         $pipeline = Pipeline::create();
         $pipeline->EnvironmentID = $this->ID;
         return $pipeline;
@@ -287,8 +278,7 @@ 
      *
      * @return ArrayData
      */
-    public function GenericPipelineConfig()
-    {
+    public function GenericPipelineConfig() {
         $config = $this->loadPipelineConfig();
         if ($config) {
             return self::array_to_viewabledata($config);
@@ -300,8 +290,7 @@ 
      *
      * @return array
      */
-    public function loadPipelineConfig()
-    {
+    public function loadPipelineConfig() {
         require_once 'thirdparty/spyc/spyc.php';
 
         $path = $this->getPipelineFilename();
@@ -316,8 +305,7 @@ 
      * `DependsOnEnvironment` - these are used together to find the {@link DNEnvironment} that this environment should
      * rely on.
      */
-    public function DependsOnEnvironment()
-    {
+    public function DependsOnEnvironment() {
         if ($this->HasPipelineSupport()) {
             $pipeline = $this->GenericPipeline();
             return $pipeline->getDependentEnvironment();
@@ -329,8 +317,7 @@ 
     /**
      * @return bool true if there is a currently running Pipeline, and false if there isn't
      */
-    public function HasCurrentPipeline()
-    {
+    public function HasCurrentPipeline() {
         return $this->CurrentPipeline() && $this->CurrentPipeline()->isInDB();
     }
 
@@ -340,16 +327,14 @@ 
      *
      * @return DataObject|null The currently running pipeline, or null if there isn't any.
      */
-    public function CurrentPipeline()
-    {
+    public function CurrentPipeline() {
         return $this->Pipelines()->filter('Status', array('Running', 'Rollback'))->first();
     }
 
     /**
      * @return bool true if the current user can cancel a running pipeline
      */
-    public function CanCancelPipeline()
-    {
+    public function CanCancelPipeline() {
         // do we have a current pipeline
         if ($this->HasCurrentPipeline()) {
             return $this->CurrentPipeline()->canAbort();
@@ -363,8 +348,7 @@ 
      * @param Member|null $member
      * @return boolean
      */
-    public function canView($member = null)
-    {
+    public function canView($member = null) {
         if (!$member) {
             $member = Member::currentUser();
         }
@@ -392,8 +376,7 @@ 
      * @param Member|null $member
      * @return boolean
      */
-    public function canDeploy($member = null)
-    {
+    public function canDeploy($member = null) {
         if (!$member) {
             $member = Member::currentUser();
         }
@@ -423,8 +406,7 @@ 
      * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
      * @return boolean true if $member can restore, and false if they can't.
      */
-    public function canRestore($member = null)
-    {
+    public function canRestore($member = null) {
         if (!$member) {
             $member = Member::currentUser();
         }
@@ -454,8 +436,7 @@ 
      * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
      * @return boolean true if $member can backup, and false if they can't.
      */
-    public function canBackup($member = null)
-    {
+    public function canBackup($member = null) {
         $project = $this->Project();
         if ($project->HasDiskQuota() && $project->HasExceededDiskQuota()) {
             return false;
@@ -494,8 +475,7 @@ 
      * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
      * @return boolean true if $member can upload archives linked to this environment, false if they can't.
      */
-    public function canUploadArchive($member = null)
-    {
+    public function canUploadArchive($member = null) {
         $project = $this->Project();
         if ($project->HasDiskQuota() && $project->HasExceededDiskQuota()) {
             return false;
@@ -530,8 +510,7 @@ 
      * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
      * @return boolean true if $member can download archives from this environment, false if they can't.
      */
-    public function canDownloadArchive($member = null)
-    {
+    public function canDownloadArchive($member = null) {
         if (!$member) {
             $member = Member::currentUser();
         }
@@ -560,8 +539,7 @@ 
      * @param Member|null $member
      * @return boolean
      */
-    public function canAbort($member = null)
-    {
+    public function canAbort($member = null) {
         if (!$member) {
             $member = Member::currentUser();
         }
@@ -583,8 +561,7 @@ 
      * @param Member|null $member
      * @return boolean
      */
-    public function canApprove($member = null)
-    {
+    public function canApprove($member = null) {
         if (!$member) {
             $member = Member::currentUser();
         }
@@ -606,8 +583,7 @@ 
      * @param Member|null $member The {@link Member} object to test against. If null, uses Member::currentMember();
      * @return boolean true if $member can delete archives from this environment, false if they can't.
      */
-    public function canDeleteArchive($member = null)
-    {
+    public function canDeleteArchive($member = null) {
         if (!$member) {
             $member = Member::currentUser();
         }
@@ -635,8 +611,7 @@ 
      *
      * @return string
      */
-    public function getDeployersList()
-    {
+    public function getDeployersList() {
         return implode(
             ", ",
             array_merge(
@@ -651,8 +626,7 @@ 
      *
      * @return string
      */
-    public function getCanRestoreMembersList()
-    {
+    public function getCanRestoreMembersList() {
         return implode(
             ", ",
             array_merge(
@@ -667,8 +641,7 @@ 
      *
      * @return string
      */
-    public function getCanBackupMembersList()
-    {
+    public function getCanBackupMembersList() {
         return implode(
             ", ",
             array_merge(
@@ -684,8 +657,7 @@ 
      *
      * @return string
      */
-    public function getArchiveUploadersList()
-    {
+    public function getArchiveUploadersList() {
         return implode(
             ", ",
             array_merge(
@@ -700,8 +672,7 @@ 
      *
      * @return string
      */
-    public function getArchiveDownloadersList()
-    {
+    public function getArchiveDownloadersList() {
         return implode(
             ", ",
             array_merge(
@@ -716,8 +687,7 @@ 
      *
      * @return string
      */
-    public function getArchiveDeletersList()
-    {
+    public function getArchiveDeletersList() {
         return implode(
             ", ",
             array_merge(
@@ -732,8 +702,7 @@ 
      *
      * @return string
      */
-    public function getPipelineApproversList()
-    {
+    public function getPipelineApproversList() {
         return implode(
             ", ",
             array_merge(
@@ -748,8 +717,7 @@ 
      *
      * @return string
      */
-    public function getPipelineCancellersList()
-    {
+    public function getPipelineCancellersList() {
         return implode(
             ", ",
             array_merge(
@@ -762,8 +730,7 @@ 
     /**
      * @return DNData
      */
-    public function DNData()
-    {
+    public function DNData() {
         return DNData::inst();
     }
 
@@ -775,8 +742,7 @@ 
      *
      * @return false|DNDeployment
      */
-    public function CurrentBuild()
-    {
+    public function CurrentBuild() {
         // The DeployHistory function is far too slow to use for this
 
         /** @var DNDeployment $deploy */
@@ -815,8 +781,7 @@ 
      *
      * @return ArrayList
      */
-    public function DeployHistory()
-    {
+    public function DeployHistory() {
         return $this->Deployments()
             ->where('SHA IS NOT NULL')
             ->sort('LastEdited DESC');
@@ -826,8 +791,7 @@ 
      * @param string $sha
      * @return array
      */
-    protected function getCommitData($sha)
-    {
+    protected function getCommitData($sha) {
         try {
             $repo = $this->Project()->getRepository();
             if ($repo !== false) {
@@ -855,8 +819,7 @@ 
     /**
      * @return string
      */
-    public function Link()
-    {
+    public function Link() {
         return $this->Project()->Link() . "/environment/" . $this->Name;
     }
 
@@ -864,8 +827,7 @@ 
      * Is this environment currently at the root level of the controller that handles it?
      * @return bool
      */
-    public function isCurrent()
-    {
+    public function isCurrent() {
         return $this->isSection() && Controller::curr()->getAction() == 'environment';
     }
 
@@ -873,8 +835,7 @@ 
      * Is this environment currently in a controller that is handling it or performing a sub-task?
      * @return bool
      */
-    public function isSection()
-    {
+    public function isSection() {
         $controller = Controller::curr();
         $environment = $controller->getField('CurrentEnvironment');
         return $environment && $environment->ID == $this->ID;
@@ -890,8 +851,7 @@ 
      * @param array $members List of members
      * @return FieldGroup
      */
-    protected function buildPermissionField($groupField, $memberField, $groups, $members)
-    {
+    protected function buildPermissionField($groupField, $memberField, $groups, $members) {
         return FieldGroup::create(
             ListboxField::create($groupField, false, $groups)
                 ->setMultiple(true)
@@ -910,8 +870,7 @@ 
     /**
      * @return FieldList
      */
-    public function getCMSFields()
-    {
+    public function getCMSFields() {
         $fields = new FieldList(new TabSet('Root'));
 
         $project = $this->Project();
@@ -1090,8 +1049,7 @@ 
     /**
      * @param FieldList $fields
      */
-    protected function setDeployConfigurationFields(&$fields)
-    {
+    protected function setDeployConfigurationFields(&$fields) {
         if (!$this->config()->get('allow_web_editing')) {
             return;
         }
@@ -1115,8 +1073,7 @@ 
     /**
      * @param FieldList $fields
      */
-    protected function setPipelineConfigurationFields($fields)
-    {
+    protected function setPipelineConfigurationFields($fields) {
         if (!$this->config()->get('allow_web_editing')) {
             return;
         }
@@ -1144,8 +1101,7 @@ 
 
     /**
      */
-    public function onBeforeWrite()
-    {
+    public function onBeforeWrite() {
         parent::onBeforeWrite();
         if ($this->Name && $this->Name . '.rb' != $this->Filename) {
             $this->Filename = $this->Name . '.rb';
@@ -1155,8 +1111,7 @@ 
         $this->writePipelineFile();
     }
 
-    public function onAfterWrite()
-    {
+    public function onAfterWrite() {
         parent::onAfterWrite();
 
         if ($this->Usage == 'Production' || $this->Usage == 'UAT') {
@@ -1176,8 +1131,7 @@ 
     /**
      * Ensure that environment paths are setup on the local filesystem
      */
-    protected function checkEnvironmentPath()
-    {
+    protected function checkEnvironmentPath() {
         // Create folder if it doesn't exist
         $configDir = dirname($this->getConfigFilename());
         if (!file_exists($configDir) && $configDir) {
@@ -1188,8 +1142,7 @@ 
     /**
      * Write the deployment config file to filesystem
      */
-    protected function writeConfigFile()
-    {
+    protected function writeConfigFile() {
         if (!$this->config()->get('allow_web_editing')) {
             return;
         }
@@ -1209,8 +1162,7 @@ 
     /**
      * Write the pipeline config file to filesystem
      */
-    protected function writePipelineFile()
-    {
+    protected function writePipelineFile() {
         if (!$this->config()->get('allow_web_editing')) {
             return;
         }
@@ -1227,8 +1179,7 @@ 
     /**
      * Delete any related config files
      */
-    public function onAfterDelete()
-    {
+    public function onAfterDelete() {
         parent::onAfterDelete();
         // Create a basic new environment config from a template
         if ($this->config()->get('allow_web_editing') && $this->envFileExists()) {
@@ -1244,8 +1195,7 @@ 
     /**
      * @return string
      */
-    protected function getEnvironmentConfig()
-    {
+    protected function getEnvironmentConfig() {
         if (!$this->envFileExists()) {
             return '';
         }
@@ -1255,8 +1205,7 @@ 
     /**
      * @return boolean
      */
-    protected function envFileExists()
-    {
+    protected function envFileExists() {
         if (!$this->getConfigFilename()) {
             return false;
         }
@@ -1268,8 +1217,7 @@ 
      *
      * @return string
      */
-    public function getConfigFilename()
-    {
+    public function getConfigFilename() {
         if (!$this->Project()->exists()) {
             return '';
         }
@@ -1285,8 +1233,7 @@ 
      *
      * @return string
      */
-    public function getPipelineFilename()
-    {
+    public function getPipelineFilename() {
         $name = $this->getConfigFilename();
         if (!$name) {
             return null;
@@ -1302,8 +1249,7 @@ 
      *
      * @return boolean
      */
-    protected function pipelineFileExists()
-    {
+    protected function pipelineFileExists() {
         $filename = $this->getPipelineFilename();
         if (empty($filename)) {
             return false;
@@ -1319,8 +1265,7 @@ 
      * @return object Either an {@link ArrayList} or {@link ArrayData} object, or the original item ($array) if $array
      * isn't an array.
      */
-    public static function array_to_viewabledata($array)
-    {
+    public static function array_to_viewabledata($array) {
         // Don't transform non-arrays
         if (!is_array($array)) {
             return $array;
@@ -1354,8 +1299,7 @@ 
      *
      * @return DataList
      */
-    public function getDependentFilteredCommits()
-    {
+    public function getDependentFilteredCommits() {
         // check if this environment depends on another environemnt
         $dependsOnEnv = $this->DependsOnEnvironment();
         if (empty($dependsOnEnv)) {
@@ -1386,8 +1330,7 @@ 
      *
      * @param DeploynautLogFile $log
      */
-    public function enableMaintenace($log)
-    {
+    public function enableMaintenace($log) {
         $this->Backend()
             ->enableMaintenance($this, $log, $this->Project());
     }
@@ -1397,14 +1340,12 @@ 
      *
      * @param DeploynautLogFile $log
      */
-    public function disableMaintenance($log)
-    {
+    public function disableMaintenance($log) {
         $this->Backend()
             ->disableMaintenance($this, $log, $this->Project());
     }
 
-    protected function validate()
-    {
+    protected function validate() {
         $result = parent::validate();
         $backend = $this->Backend();
 

code/model/DNFailedCommits.php

Indentation +6 added lines, -6 removed lines

@@ -9,11 +9,11 @@
 class DNFailedCommits extends DNFilteredCommits
 {
 
-    private $description = 'Commits that have failed in the past';
+	private $description = 'Commits that have failed in the past';
 
-    public function __construct()
-    {
-        parent::__construct();
-        $this->setFilter('Failed');
-    }
+	public function __construct()
+	{
+		parent::__construct();
+		$this->setFilter('Failed');
+	}
 }

Braces +2 added lines, -4 removed lines

@@ -6,13 +6,11 @@
  *  Class to represent failed commits
  *
  */
-class DNFailedCommits extends DNFilteredCommits
-{
+class DNFailedCommits extends DNFilteredCommits {
 
     private $description = 'Commits that have failed in the past';
 
-    public function __construct()
-    {
+    public function __construct() {
         parent::__construct();
         $this->setFilter('Failed');
     }

code/model/DNFilteredCommits.php

Indentation +32 added lines, -32 removed lines

@@ -30,43 +30,43 @@
 class DNFilteredCommits extends Object
 {
 
-    public $env;
+	public $env;
 
-    private $filter;
+	private $filter;
 
-    private $environmentExceptionError = 'Environment has not been set';
+	private $environmentExceptionError = 'Environment has not been set';
 
-    // default sort to be by the latest commit
-    protected $sort = 'DESC';
+	// default sort to be by the latest commit
+	protected $sort = 'DESC';
 
-    public function setFilter($filter = 'Finished')
-    {
-        $this->filter = $filter;
-    }
+	public function setFilter($filter = 'Finished')
+	{
+		$this->filter = $filter;
+	}
 
-    public function getCommits()
-    {
-        if (!isset($this->env)) {
-            $this->environmentNotSetException();
-        }
-        $successfulCommits =
-            $this->env->DeployHistory()->filter(
-                array('Status' => $this->filter, 'EnvironmentID' => $this->env->ID)
-            )->sort('Created', $this->sort);
-        return $successfulCommits;
-    }
+	public function getCommits()
+	{
+		if (!isset($this->env)) {
+			$this->environmentNotSetException();
+		}
+		$successfulCommits =
+			$this->env->DeployHistory()->filter(
+				array('Status' => $this->filter, 'EnvironmentID' => $this->env->ID)
+			)->sort('Created', $this->sort);
+		return $successfulCommits;
+	}
 
-    public function getLatestCommit()
-    {
-        if (!isset($this->env)) {
-            $this->environmentNotSetException();
-        }
-        $commits = $this->getCommits();
-        return $commits->first();
-    }
+	public function getLatestCommit()
+	{
+		if (!isset($this->env)) {
+			$this->environmentNotSetException();
+		}
+		$commits = $this->getCommits();
+		return $commits->first();
+	}
 
-    private function environmentNotSetException()
-    {
-        throw new Exception($this->environmentExceptionError);
-    }
+	private function environmentNotSetException()
+	{
+		throw new Exception($this->environmentExceptionError);
+	}
 }

Spacing +2 added lines, -2 removed lines

@@ -46,7 +46,7 @@ 
 
     public function getCommits()
     {
-        if (!isset($this->env)) {
+        if(!isset($this->env)) {
             $this->environmentNotSetException();
         }
         $successfulCommits =
@@ -58,7 +58,7 @@ 
 
     public function getLatestCommit()
     {
-        if (!isset($this->env)) {
+        if(!isset($this->env)) {
             $this->environmentNotSetException();
         }
         $commits = $this->getCommits();

Braces +5 added lines, -10 removed lines

@@ -27,8 +27,7 @@ 
  *    PerformTestOn: 'ThisEnvironment'
  *
  */
-class DNFilteredCommits extends Object
-{
+class DNFilteredCommits extends Object {
 
     public $env;
 
@@ -39,13 +38,11 @@ 
     // default sort to be by the latest commit
     protected $sort = 'DESC';
 
-    public function setFilter($filter = 'Finished')
-    {
+    public function setFilter($filter = 'Finished') {
         $this->filter = $filter;
     }
 
-    public function getCommits()
-    {
+    public function getCommits() {
         if (!isset($this->env)) {
             $this->environmentNotSetException();
         }
@@ -56,8 +53,7 @@ 
         return $successfulCommits;
     }
 
-    public function getLatestCommit()
-    {
+    public function getLatestCommit() {
         if (!isset($this->env)) {
             $this->environmentNotSetException();
         }
@@ -65,8 +61,7 @@ 
         return $commits->first();
     }
 
-    private function environmentNotSetException()
-    {
+    private function environmentNotSetException() {
         throw new Exception($this->environmentExceptionError);
     }
 }

code/model/DNFinishedCommits.php

Indentation +9 added lines, -9 removed lines

@@ -8,14 +8,14 @@
  */
 class DNFinishedCommits extends DNFilteredCommits
 {
-    /**
-     * @var string
-     */
-    private $description = 'Commits successfully deployed in the past';
+	/**
+	 * @var string
+	 */
+	private $description = 'Commits successfully deployed in the past';
 
-    public function __construct()
-    {
-        parent::__construct();
-        $this->setFilter('Finished');
-    }
+	public function __construct()
+	{
+		parent::__construct();
+		$this->setFilter('Finished');
+	}
 }

Braces +2 added lines, -4 removed lines

@@ -6,15 +6,13 @@
  *  Class to represent finished commits
  *
  */
-class DNFinishedCommits extends DNFilteredCommits
-{
+class DNFinishedCommits extends DNFilteredCommits {
     /**
      * @var string
      */
     private $description = 'Commits successfully deployed in the past';
 
-    public function __construct()
-    {
+    public function __construct() {
         parent::__construct();
         $this->setFilter('Finished');
     }

code/model/DNProject.php

Indentation +1157 added lines, -1157 removed lines

@@ -15,887 +15,887 @@ 
 class DNProject extends DataObject
 {
 
-    /**
-     * @var array
-     */
-    public static $db = array(
-        "Name" => "Varchar",
-        "CVSPath" => "Varchar(255)",
-        "DiskQuotaMB" => "Int",
-        "AllowedEnvironmentType" => "Varchar(255)",
-    );
-
-    /**
-     * @var array
-     */
-    public static $has_many = array(
-        "Environments" => "DNEnvironment",
-        "CreateEnvironments" => "DNCreateEnvironment"
-    );
-
-    /**
-     * @var array
-     */
-    public static $many_many = array(
-        "Viewers" => "Group",
-        'StarredBy' => "Member"
-    );
-
-    /**
-     * @var array
-     */
-    public static $summary_fields = array(
-        "Name",
-        "ViewersList",
-    );
-
-    /**
-     * @var array
-     */
-    public static $searchable_fields = array(
-        "Name",
-    );
-
-    /**
-     * @var string
-     */
-    private static $singular_name = 'Project';
-
-    /**
-     * @var string
-     */
-    private static $plural_name = 'Projects';
-
-    /**
-     * @var string
-     */
-    private static $default_sort = 'Name';
-
-    /**
-     * Display the repository URL on the project page.
-     *
-     * @var bool
-     */
-    private static $show_repository_url = false;
-
-    /**
-     * In-memory cache for currentBuilds per environment since fetching them from
-     * disk is pretty resource hungry.
-     *
-     * @var array
-     */
-    protected static $relation_cache = array();
-
-    /**
-     * In-memory cache to determine whether clone repo was called.
-     * @var array
-     */
-    private static $has_cloned_cache = array();
-
-    /**
-     * @var bool|Member
-     */
-    protected static $_current_member_cache = null;
-
-    /**
-     * Used by the sync task
-     *
-     * @param string $path
-     * @return \DNProject
-     */
-    public static function create_from_path($path)
-    {
-        $project = DNProject::create();
-        $project->Name = $path;
-        $project->write();
-
-        // add the administrators group as the viewers of the new project
-        $adminGroup = Group::get()->filter('Code', 'administrators')->first();
-        if ($adminGroup && $adminGroup->exists()) {
-            $project->Viewers()->add($adminGroup);
-        }
-        return $project;
-    }
-
-    /**
-     * Return the used quota in MB.
-     *
-     * @param int $round Number of decimal places to round to
-     * @return double The used quota size in MB
-     */
-    public function getUsedQuotaMB($round = 2)
-    {
-        $size = 0;
-
-        foreach ($this->Environments() as $environment) {
-            foreach ($environment->DataArchives()->filter('IsBackup', 0) as $archive) {
-                $size += $archive->ArchiveFile()->getAbsoluteSize();
-            }
-        }
-
-        // convert bytes to megabytes and round
-        return round(($size / 1024) / 1024, $round);
-    }
-
-    /**
-     * Getter for DiskQuotaMB field to provide a default for existing
-     * records that have no quota field set, as it will need to default
-     * to a globally set size.
-     *
-     * @return string|int The quota size in MB
-     */
-    public function getDiskQuotaMB()
-    {
-        $size = $this->getField('DiskQuotaMB');
-
-        if (empty($size)) {
-            $defaults = $this->config()->get('defaults');
-            $size = (isset($defaults['DiskQuotaMB'])) ? $defaults['DiskQuotaMB'] : 0;
-        }
-
-        return $size;
-    }
-
-    /**
-     * Has the disk quota been exceeded?
-     *
-     * @return boolean
-     */
-    public function HasExceededDiskQuota()
-    {
-        return $this->getUsedQuotaMB(0) >= $this->getDiskQuotaMB();
-    }
-
-    /**
-     * Is there a disk quota set for this project?
-     *
-     * @return boolean
-     */
-    public function HasDiskQuota()
-    {
-        return $this->getDiskQuotaMB() > 0;
-    }
-
-    /**
-     * Returns the current disk quota usage as a percentage
-     *
-     * @return int
-     */
-    public function DiskQuotaUsagePercent()
-    {
-        $quota = $this->getDiskQuotaMB();
-        if ($quota > 0) {
-            return $this->getUsedQuotaMB() * 100 / $quota;
-        }
-        return 100;
-    }
-
-    /**
-     * Get the menu to be shown on projects
-     *
-     * @return ArrayList
-     */
-    public function Menu()
-    {
-        $list = new ArrayList();
-
-        $controller = Controller::curr();
-        $actionType = $controller->getField('CurrentActionType');
-
-        if (DNRoot::FlagSnapshotsEnabled() && $this->isProjectReady()) {
-            $list->push(new ArrayData(array(
-                'Link' => sprintf('naut/project/%s/snapshots', $this->Name),
-                'Title' => 'Snapshots',
-                'IsCurrent' => $this->isSection() && $controller->getAction() == 'snapshots',
-                'IsSection' => $this->isSection() && $actionType == DNRoot::ACTION_SNAPSHOT
-            )));
-        }
-
-        $this->extend('updateMenu', $list);
-
-        return $list;
-    }
-
-    /**
-     * Is this project currently at the root level of the controller that handles it?
-     *
-     * @return bool
-     */
-    public function isCurrent()
-    {
-        return $this->isSection() && Controller::curr()->getAction() == 'project';
-    }
-
-    /**
-     * Return the current object from $this->Menu()
-     * Good for making titles and things
-     *
-     * @return DataObject
-     */
-    public function CurrentMenu()
-    {
-        return $this->Menu()->filter('IsSection', true)->First();
-    }
-
-    /**
-     * Is this project currently in a controller that is handling it or performing a sub-task?
-     *
-     * @return bool
-     */
-    public function isSection()
-    {
-        $controller = Controller::curr();
-        $project = $controller->getField('CurrentProject');
-        return $project && $this->ID == $project->ID;
-    }
-
-    /**
-     * Restrict access to viewing this project
-     *
-     * @param Member|null $member
-     * @return boolean
-     */
-    public function canView($member = null)
-    {
-        if (!$member) {
-            $member = Member::currentUser();
-        }
-
-        if (Permission::checkMember($member, 'ADMIN')) {
-            return true;
-        }
-
-        return $member->inGroups($this->Viewers());
-    }
-
-    /**
-     * @param Member|null $member
-     *
-     * @return bool
-     */
-    public function canRestore($member = null)
-    {
-        if ($this->allowedAny(
-            array(
-                DNRoot::ALLOW_PROD_SNAPSHOT,
-                DNRoot::ALLOW_NON_PROD_SNAPSHOT
-            ),
-            $member
-        )) {
-            return true;
-        }
-
-        return (bool)$this->Environments()->filterByCallback(function ($env) use ($member) {
-            return $env->canRestore($member);
-        })->Count();
-    }
-
-    /**
-     * @param Member|null $member
-     * @return bool
-     */
-    public function canBackup($member = null)
-    {
-        if ($this->allowedAny(
-            array(
-                DNRoot::ALLOW_PROD_SNAPSHOT,
-                DNRoot::ALLOW_NON_PROD_SNAPSHOT
-            ),
-            $member
-        )) {
-            return true;
-        }
-
-        return (bool)$this->Environments()->filterByCallback(function ($env) use ($member) {
-            return $env->canBackup($member);
-        })->Count();
-    }
-
-    /**
-     * @param Member|null $member
-     * @return bool
-     */
-    public function canUploadArchive($member = null)
-    {
-        if ($this->allowedAny(
-            array(
-                DNRoot::ALLOW_PROD_SNAPSHOT,
-                DNRoot::ALLOW_NON_PROD_SNAPSHOT
-            ),
-            $member
-        )) {
-            return true;
-        }
-
-        return (bool)$this->Environments()->filterByCallback(function ($env) use ($member) {
-            return $env->canUploadArchive($member);
-        })->Count();
-    }
-
-    /**
-     * @param Member|null $member
-     * @return bool
-     */
-    public function canDownloadArchive($member = null)
-    {
-        if ($this->allowedAny(
-            array(
-                DNRoot::ALLOW_PROD_SNAPSHOT,
-                DNRoot::ALLOW_NON_PROD_SNAPSHOT
-            ),
-            $member
-        )) {
-            return true;
-        }
-
-        return (bool)$this->Environments()->filterByCallback(function ($env) use ($member) {
-            return $env->canDownloadArchive($member);
-        })->Count();
-    }
-
-    /**
-     * This is a permission check for the front-end only.
-     *
-     * Only admins can create environments for now. Also, we need to check the value
-     * of AllowedEnvironmentType which dictates which backend to use to render the form.
-     *
-     * @param Member|null $member
-     *
-     * @return bool
-     */
-    public function canCreateEnvironments($member = null)
-    {
-        $envType = $this->AllowedEnvironmentType;
-        if ($envType) {
-            $env = Injector::inst()->get($envType);
-            if ($env instanceof EnvironmentCreateBackend) {
-                return $this->allowed(DNRoot::ALLOW_CREATE_ENVIRONMENT, $member);
-            }
-        }
-        return false;
-    }
-
-    /**
-     * @return DataList
-     */
-    public function DataArchives()
-    {
-        $envIds = $this->Environments()->column('ID');
-        return DNDataArchive::get()->filter('EnvironmentID', $envIds);
-    }
-
-    /**
-     * Return all archives which are "manual upload requests",
-     * meaning they don't have a file attached to them (yet).
-     *
-     * @return DataList
-     */
-    public function PendingManualUploadDataArchives()
-    {
-        return $this->DataArchives()->filter('ArchiveFileID', null);
-    }
-
-    /**
-     * Build an environment variable array to be used with this project.
-     *
-     * This is relevant if every project needs to use an individual SSH pubkey.
-     *
-     * Include this with all Gitonomy\Git\Repository, and
-     * \Symfony\Component\Process\Processes.
-     *
-     * @return array
-     */
-    public function getProcessEnv()
-    {
-        if (file_exists($this->getPrivateKeyPath())) {
-            // Key-pair is available, use it.
-            $processEnv = array(
-                'IDENT_KEY' => $this->getPrivateKeyPath(),
-                'GIT_SSH' => BASE_PATH . "/deploynaut/git-deploy.sh"
-            );
-        } else {
-            $processEnv = array();
-        }
-        $this->extend('updateProcessEnv', $processEnv);
-
-        return $processEnv;
-    }
-
-    /**
-     * Get a string of people allowed to view this project
-     *
-     * @return string
-     */
-    public function getViewersList()
-    {
-        return implode(", ", $this->Viewers()->column("Title"));
-    }
-
-    /**
-     * @return DNData
-     */
-    public function DNData()
-    {
-        return DNData::inst();
-    }
-
-    /**
-     * Provides a DNBuildList of builds found in this project.
-     *
-     * @return DNReferenceList
-     */
-    public function DNBuildList()
-    {
-        return DNReferenceList::create($this, $this->DNData());
-    }
-
-    /**
-     * Provides a list of the branches in this project.
-     *
-     * @return DNBranchList
-     */
-    public function DNBranchList()
-    {
-        if ($this->CVSPath && !$this->repoExists()) {
-            $this->cloneRepo();
-        }
-        return DNBranchList::create($this, $this->DNData());
-    }
-
-    /**
-     * Provides a list of the tags in this project.
-     *
-     * @return DNReferenceList
-     */
-    public function DNTagList()
-    {
-        if ($this->CVSPath && !$this->repoExists()) {
-            $this->cloneRepo();
-        }
-        return DNReferenceList::create($this, $this->DNData(), null, null, true);
-    }
-
-    /**
-     * @return false|Gitonomy\Git\Repository
-     */
-    public function getRepository()
-    {
-        if (!$this->repoExists()) {
-            return false;
-        }
-
-        return new Gitonomy\Git\Repository($this->getLocalCVSPath());
-    }
-
-    /**
-     * Provides a list of environments found in this project.
-     * CAUTION: filterByCallback will change this into an ArrayList!
-     *
-     * @return ArrayList
-     */
-    public function DNEnvironmentList()
-    {
-        if (!self::$_current_member_cache) {
-            self::$_current_member_cache = Member::currentUser();
-        }
-
-        if (self::$_current_member_cache === false) {
-            return new ArrayList();
-        }
-
-        $currentMember = self::$_current_member_cache;
-        return $this->Environments()
-            ->filterByCallBack(function ($item) use ($currentMember) {
-                return $item->canView($currentMember);
-            });
-    }
-
-    /**
-     * @param string $usage
-     * @return ArrayList
-     */
-    public function EnvironmentsByUsage($usage)
-    {
-        return $this->DNEnvironmentList()->filter('Usage', $usage);
-    }
-
-    /**
-     * Returns a map of envrionment name to build name
-     *
-     * @return false|DNDeployment
-     */
-    public function currentBuilds()
-    {
-        if (!isset(self::$relation_cache['currentBuilds.'.$this->ID])) {
-            $currentBuilds = array();
-            foreach ($this->Environments() as $env) {
-                $currentBuilds[$env->Name] = $env->CurrentBuild();
-            }
-            self::$relation_cache['currentBuilds.'.$this->ID] = $currentBuilds;
-        }
-        return self::$relation_cache['currentBuilds.'.$this->ID];
-    }
-
-    /**
-     * @param string
-     * @return string
-     */
-    public function Link($action = '')
-    {
-        return Controller::join_links("naut", "project", $this->Name, $action);
-    }
-
-    /**
-     * @return string|null
-     */
-    public function CreateEnvironmentLink()
-    {
-        if ($this->canCreateEnvironments()) {
-            return $this->Link('createenv');
-        }
-        return null;
-    }
-
-    /**
-     * @return string
-     */
-    public function ToggleStarLink()
-    {
-        return $this->Link('/star');
-    }
-
-    /**
-     * @return bool
-     */
-    public function IsStarred()
-    {
-        $member = Member::currentUser();
-        if ($member === null) {
-            return false;
-        }
-        $favourited = $this->StarredBy()->filter('MemberID', $member->ID);
-        if ($favourited->count() == 0) {
-            return false;
-        }
-        return true;
-    }
-
-    /**
-     * @param string $action
-     * @return string
-     */
-    public function APILink($action)
-    {
-        return Controller::join_links("naut", "api", $this->Name, $action);
-    }
-
-    /**
-     * @return FieldList
-     */
-    public function getCMSFields()
-    {
-        $fields = parent::getCMSFields();
-
-        /** @var GridField $environments */
-        $environments = $fields->dataFieldByName("Environments");
-
-        $fields->fieldByName("Root")->removeByName("Viewers");
-        $fields->fieldByName("Root")->removeByName("Environments");
-        $fields->fieldByName("Root")->removeByName("LocalCVSPath");
-
-        $diskQuotaDesc = 'This is the maximum amount of disk space (in megabytes) that all environments within this '
-            . 'project can use for stored snapshots';
-        $fields->dataFieldByName('DiskQuotaMB')->setDescription($diskQuotaDesc);
-
-        $projectNameDesc = 'Changing the name will <strong>reset</strong> the deploy configuration and avoid using non'
-            . 'alphanumeric characters';
-        $fields->fieldByName('Root.Main.Name')
-            ->setTitle('Project name')
-            ->setDescription($projectNameDesc);
-
-        $fields->fieldByName('Root.Main.CVSPath')
-            ->setTitle('Git repository')
-            ->setDescription('E.g. git@github.com:silverstripe/silverstripe-installer.git');
-
-        $workspaceField = new ReadonlyField('LocalWorkspace', 'Git workspace', $this->getLocalCVSPath());
-        $workspaceField->setDescription('This is where the GIT repository are located on this server');
-        $fields->insertAfter($workspaceField, 'CVSPath');
-
-        $readAccessGroups = ListboxField::create('Viewers', 'Project viewers', Group::get()->map()->toArray())
-            ->setMultiple(true)
-            ->setDescription('These groups can view the project in the front-end.');
-        $fields->addFieldToTab("Root.Main", $readAccessGroups);
-
-        $this->setCreateProjectFolderField($fields);
-        $this->setEnvironmentFields($fields, $environments);
-
-        $environmentTypes = ClassInfo::implementorsOf('EnvironmentCreateBackend');
-        $types = array();
-        foreach ($environmentTypes as $type) {
-            $types[$type] = $type;
-        }
-
-        $fields->addFieldsToTab('Root.Main', array(
-            DropdownField::create(
-                'AllowedEnvironmentType',
-                'Allowed Environment Type',
-                $types
-            )->setDescription('This defined which form to show on the front end for '
-                . 'environment creation. This will not affect backend functionality.')
-            ->setEmptyString(' - None - '),
-        ));
-
-        return $fields;
-    }
-
-    /**
-     * If there isn't a capistrano env project folder, show options to create one
-     *
-     * @param FieldList $fields
-     */
-    public function setCreateProjectFolderField(&$fields)
-    {
-        // Check if the capistrano project folder exists
-        if (!$this->Name) {
-            return;
-        }
-
-        if ($this->projectFolderExists()) {
-            return;
-        }
-
-        $createFolderNotice = new LabelField('CreateEnvFolderNotice', 'Warning: No Capistrano project folder exists');
-        $createFolderNotice->addExtraClass('message warning');
-        $fields->insertBefore($createFolderNotice, 'Name');
-        $createFolderField = new CheckboxField('CreateEnvFolder', 'Create folder');
-        $createFolderField->setDescription('Would you like to create the capistrano project folder?');
-        $fields->insertAfter($createFolderField, 'CreateEnvFolderNotice');
-    }
-
-    /**
-     * @return boolean
-     */
-    public function projectFolderExists()
-    {
-        return file_exists($this->getProjectFolderPath());
-    }
-
-    /**
-     * @return bool
-     */
-    public function repoExists()
-    {
-        return file_exists(sprintf('%s/HEAD', $this->getLocalCVSPath()));
-    }
-
-    /**
-     * Setup a job to clone a git repository.
-     * @return string resque token
-     */
-    public function cloneRepo()
-    {
-        // Avoid this being called multiple times in the same request
-        if (!isset(self::$has_cloned_cache[$this->ID])) {
-            $fetch = DNGitFetch::create();
-            $fetch->ProjectID = $this->ID;
-            $fetch->write();
-
-            // passing true here tells DNGitFetch to force a git clone, otherwise
-            // it will just update the repo if it already exists. We want to ensure
-            // we're always cloning a new repo in this case, as the git URL may have changed.
-            $fetch->start(true);
-
-            self::$has_cloned_cache[$this->ID] = true;
-        }
-    }
-
-    /**
-     * @return string
-     */
-    public function getLocalCVSPath()
-    {
-        return sprintf('%s/%s', DEPLOYNAUT_LOCAL_VCS_PATH, $this->Name);
-    }
-
-    public function onBeforeWrite()
-    {
-        parent::onBeforeWrite();
-
-        if ($this->CreateEnvFolder && !file_exists($this->getProjectFolderPath())) {
-            mkdir($this->getProjectFolderPath());
-        }
-    }
-
-    public function onAfterWrite()
-    {
-        parent::onAfterWrite();
-
-        if (!$this->CVSPath) {
-            return;
-        }
-
-        $changedFields = $this->getChangedFields(true, 2);
-        if (isset($changedFields['CVSPath']) || isset($changedFields['Name'])) {
-            $this->cloneRepo();
-        }
-    }
-
-    /**
-     * Delete related environments and folders
-     */
-    public function onAfterDelete()
-    {
-        parent::onAfterDelete();
-
-        // Delete related environments
-        foreach ($this->Environments() as $env) {
-            $env->delete();
-        }
-
-        // Delete local repository
-        if (file_exists($this->getLocalCVSPath())) {
-            Filesystem::removeFolder($this->getLocalCVSPath());
-        }
-
-        // Delete project template
-        if (file_exists($this->getProjectFolderPath()) && Config::inst()->get('DNEnvironment', 'allow_web_editing')) {
-            Filesystem::removeFolder($this->getProjectFolderPath());
-        }
-
-        // Delete the deploy key
-        if (file_exists($this->getKeyDir())) {
-            Filesystem::removeFolder($this->getKeyDir());
-        }
-    }
-
-    /**
-     * Fetch the public key for this project.
-     *
-     * @return string|void
-     */
-    public function getPublicKey()
-    {
-        $key = $this->getPublicKeyPath();
-
-        if (file_exists($key)) {
-            return trim(file_get_contents($key));
-        }
-    }
-
-    /**
-     * This returns that path of the public key if a key directory is set. It doesn't check whether the file exists.
-     *
-     * @return string|null
-     */
-    public function getPublicKeyPath()
-    {
-        if ($privateKey = $this->getPrivateKeyPath()) {
-            return $privateKey . '.pub';
-        }
-        return null;
-    }
-
-    /**
-     * This returns that path of the private key if a key directory is set. It doesn't check whether the file exists.
-     *
-     * @return string|null
-     */
-    public function getPrivateKeyPath()
-    {
-        $keyDir = $this->getKeyDir();
-        if (!empty($keyDir)) {
-            $filter = FileNameFilter::create();
-            $name = $filter->filter($this->Name);
-            return $keyDir . '/' . $name;
-        }
-        return null;
-    }
-
-    /**
-     * Returns the location of the projects key dir if one exists.
-     *
-     * @return string|null
-     */
-    public function getKeyDir()
-    {
-        $keyDir = $this->DNData()->getKeyDir();
-        if (!$keyDir) {
-            return null;
-        }
-
-        $filter = FileNameFilter::create();
-        $name = $filter->filter($this->Name);
-
-        return $this->DNData()->getKeyDir() . '/' . $name;
-    }
-
-    /**
-     * Setup a gridfield for the environment configs
-     *
-     * @param FieldList $fields
-     * @param GridField $environments
-     */
-    protected function setEnvironmentFields(&$fields, $environments)
-    {
-        if (!$environments) {
-            return;
-        }
-
-        $environments->getConfig()->addComponent(new GridFieldAddNewMultiClass());
-        $environments->getConfig()->removeComponentsByType('GridFieldAddNewButton');
-        $environments->getConfig()->removeComponentsByType('GridFieldAddExistingAutocompleter');
-        $environments->getConfig()->removeComponentsByType('GridFieldDeleteAction');
-        $environments->getConfig()->removeComponentsByType('GridFieldPageCount');
-        if (Config::inst()->get('DNEnvironment', 'allow_web_editing')) {
-            $addNewRelease = new GridFieldAddNewButton('toolbar-header-right');
-            $addNewRelease->setButtonName('Add');
-            $environments->getConfig()->addComponent($addNewRelease);
-        }
-
-        $fields->addFieldToTab("Root.Main", $environments);
-    }
-
-    /**
-     * Provide current repository URL to the users.
-     *
-     * @return void|string
-     */
-    public function getRepositoryURL()
-    {
-        $showUrl = Config::inst()->get($this->class, 'show_repository_url');
-        if ($showUrl) {
-            return $this->CVSPath;
-        }
-    }
-
-    /**
-     * Whitelist configuration that describes how to convert a repository URL into a link
-     * to a web user interface for that URL
-     *
-     * Consists of a hash of "full.lower.case.domain" => {configuration} key/value pairs
-     *
-     * {configuration} can either be boolean true to auto-detect both the host and the
-     * name of the UI provider, or a nested array that overrides either one or both
-     * of the auto-detected valyes
-     *
-     * @var array
-     */
-    private static $repository_interfaces = array(
-        'github.com' => array(
-            'icon' => 'deploynaut/img/github.png',
-            'name' => 'Github.com',
-        ),
-        'bitbucket.org' => array(
-            'commit' => 'commits',
-            'name' => 'Bitbucket.org',
-        ),
-        'repo.or.cz' => array(
-            'scheme' => 'http',
-            'name' => 'repo.or.cz',
-            'regex' => array('^(.*)$' => '/w$1'),
-        ),
-
-        /* Example for adding your own gitlab repository and override all auto-detected values (with their defaults)
+	/**
+	 * @var array
+	 */
+	public static $db = array(
+		"Name" => "Varchar",
+		"CVSPath" => "Varchar(255)",
+		"DiskQuotaMB" => "Int",
+		"AllowedEnvironmentType" => "Varchar(255)",
+	);
+
+	/**
+	 * @var array
+	 */
+	public static $has_many = array(
+		"Environments" => "DNEnvironment",
+		"CreateEnvironments" => "DNCreateEnvironment"
+	);
+
+	/**
+	 * @var array
+	 */
+	public static $many_many = array(
+		"Viewers" => "Group",
+		'StarredBy' => "Member"
+	);
+
+	/**
+	 * @var array
+	 */
+	public static $summary_fields = array(
+		"Name",
+		"ViewersList",
+	);
+
+	/**
+	 * @var array
+	 */
+	public static $searchable_fields = array(
+		"Name",
+	);
+
+	/**
+	 * @var string
+	 */
+	private static $singular_name = 'Project';
+
+	/**
+	 * @var string
+	 */
+	private static $plural_name = 'Projects';
+
+	/**
+	 * @var string
+	 */
+	private static $default_sort = 'Name';
+
+	/**
+	 * Display the repository URL on the project page.
+	 *
+	 * @var bool
+	 */
+	private static $show_repository_url = false;
+
+	/**
+	 * In-memory cache for currentBuilds per environment since fetching them from
+	 * disk is pretty resource hungry.
+	 *
+	 * @var array
+	 */
+	protected static $relation_cache = array();
+
+	/**
+	 * In-memory cache to determine whether clone repo was called.
+	 * @var array
+	 */
+	private static $has_cloned_cache = array();
+
+	/**
+	 * @var bool|Member
+	 */
+	protected static $_current_member_cache = null;
+
+	/**
+	 * Used by the sync task
+	 *
+	 * @param string $path
+	 * @return \DNProject
+	 */
+	public static function create_from_path($path)
+	{
+		$project = DNProject::create();
+		$project->Name = $path;
+		$project->write();
+
+		// add the administrators group as the viewers of the new project
+		$adminGroup = Group::get()->filter('Code', 'administrators')->first();
+		if ($adminGroup && $adminGroup->exists()) {
+			$project->Viewers()->add($adminGroup);
+		}
+		return $project;
+	}
+
+	/**
+	 * Return the used quota in MB.
+	 *
+	 * @param int $round Number of decimal places to round to
+	 * @return double The used quota size in MB
+	 */
+	public function getUsedQuotaMB($round = 2)
+	{
+		$size = 0;
+
+		foreach ($this->Environments() as $environment) {
+			foreach ($environment->DataArchives()->filter('IsBackup', 0) as $archive) {
+				$size += $archive->ArchiveFile()->getAbsoluteSize();
+			}
+		}
+
+		// convert bytes to megabytes and round
+		return round(($size / 1024) / 1024, $round);
+	}
+
+	/**
+	 * Getter for DiskQuotaMB field to provide a default for existing
+	 * records that have no quota field set, as it will need to default
+	 * to a globally set size.
+	 *
+	 * @return string|int The quota size in MB
+	 */
+	public function getDiskQuotaMB()
+	{
+		$size = $this->getField('DiskQuotaMB');
+
+		if (empty($size)) {
+			$defaults = $this->config()->get('defaults');
+			$size = (isset($defaults['DiskQuotaMB'])) ? $defaults['DiskQuotaMB'] : 0;
+		}
+
+		return $size;
+	}
+
+	/**
+	 * Has the disk quota been exceeded?
+	 *
+	 * @return boolean
+	 */
+	public function HasExceededDiskQuota()
+	{
+		return $this->getUsedQuotaMB(0) >= $this->getDiskQuotaMB();
+	}
+
+	/**
+	 * Is there a disk quota set for this project?
+	 *
+	 * @return boolean
+	 */
+	public function HasDiskQuota()
+	{
+		return $this->getDiskQuotaMB() > 0;
+	}
+
+	/**
+	 * Returns the current disk quota usage as a percentage
+	 *
+	 * @return int
+	 */
+	public function DiskQuotaUsagePercent()
+	{
+		$quota = $this->getDiskQuotaMB();
+		if ($quota > 0) {
+			return $this->getUsedQuotaMB() * 100 / $quota;
+		}
+		return 100;
+	}
+
+	/**
+	 * Get the menu to be shown on projects
+	 *
+	 * @return ArrayList
+	 */
+	public function Menu()
+	{
+		$list = new ArrayList();
+
+		$controller = Controller::curr();
+		$actionType = $controller->getField('CurrentActionType');
+
+		if (DNRoot::FlagSnapshotsEnabled() && $this->isProjectReady()) {
+			$list->push(new ArrayData(array(
+				'Link' => sprintf('naut/project/%s/snapshots', $this->Name),
+				'Title' => 'Snapshots',
+				'IsCurrent' => $this->isSection() && $controller->getAction() == 'snapshots',
+				'IsSection' => $this->isSection() && $actionType == DNRoot::ACTION_SNAPSHOT
+			)));
+		}
+
+		$this->extend('updateMenu', $list);
+
+		return $list;
+	}
+
+	/**
+	 * Is this project currently at the root level of the controller that handles it?
+	 *
+	 * @return bool
+	 */
+	public function isCurrent()
+	{
+		return $this->isSection() && Controller::curr()->getAction() == 'project';
+	}
+
+	/**
+	 * Return the current object from $this->Menu()
+	 * Good for making titles and things
+	 *
+	 * @return DataObject
+	 */
+	public function CurrentMenu()
+	{
+		return $this->Menu()->filter('IsSection', true)->First();
+	}
+
+	/**
+	 * Is this project currently in a controller that is handling it or performing a sub-task?
+	 *
+	 * @return bool
+	 */
+	public function isSection()
+	{
+		$controller = Controller::curr();
+		$project = $controller->getField('CurrentProject');
+		return $project && $this->ID == $project->ID;
+	}
+
+	/**
+	 * Restrict access to viewing this project
+	 *
+	 * @param Member|null $member
+	 * @return boolean
+	 */
+	public function canView($member = null)
+	{
+		if (!$member) {
+			$member = Member::currentUser();
+		}
+
+		if (Permission::checkMember($member, 'ADMIN')) {
+			return true;
+		}
+
+		return $member->inGroups($this->Viewers());
+	}
+
+	/**
+	 * @param Member|null $member
+	 *
+	 * @return bool
+	 */
+	public function canRestore($member = null)
+	{
+		if ($this->allowedAny(
+			array(
+				DNRoot::ALLOW_PROD_SNAPSHOT,
+				DNRoot::ALLOW_NON_PROD_SNAPSHOT
+			),
+			$member
+		)) {
+			return true;
+		}
+
+		return (bool)$this->Environments()->filterByCallback(function ($env) use ($member) {
+			return $env->canRestore($member);
+		})->Count();
+	}
+
+	/**
+	 * @param Member|null $member
+	 * @return bool
+	 */
+	public function canBackup($member = null)
+	{
+		if ($this->allowedAny(
+			array(
+				DNRoot::ALLOW_PROD_SNAPSHOT,
+				DNRoot::ALLOW_NON_PROD_SNAPSHOT
+			),
+			$member
+		)) {
+			return true;
+		}
+
+		return (bool)$this->Environments()->filterByCallback(function ($env) use ($member) {
+			return $env->canBackup($member);
+		})->Count();
+	}
+
+	/**
+	 * @param Member|null $member
+	 * @return bool
+	 */
+	public function canUploadArchive($member = null)
+	{
+		if ($this->allowedAny(
+			array(
+				DNRoot::ALLOW_PROD_SNAPSHOT,
+				DNRoot::ALLOW_NON_PROD_SNAPSHOT
+			),
+			$member
+		)) {
+			return true;
+		}
+
+		return (bool)$this->Environments()->filterByCallback(function ($env) use ($member) {
+			return $env->canUploadArchive($member);
+		})->Count();
+	}
+
+	/**
+	 * @param Member|null $member
+	 * @return bool
+	 */
+	public function canDownloadArchive($member = null)
+	{
+		if ($this->allowedAny(
+			array(
+				DNRoot::ALLOW_PROD_SNAPSHOT,
+				DNRoot::ALLOW_NON_PROD_SNAPSHOT
+			),
+			$member
+		)) {
+			return true;
+		}
+
+		return (bool)$this->Environments()->filterByCallback(function ($env) use ($member) {
+			return $env->canDownloadArchive($member);
+		})->Count();
+	}
+
+	/**
+	 * This is a permission check for the front-end only.
+	 *
+	 * Only admins can create environments for now. Also, we need to check the value
+	 * of AllowedEnvironmentType which dictates which backend to use to render the form.
+	 *
+	 * @param Member|null $member
+	 *
+	 * @return bool
+	 */
+	public function canCreateEnvironments($member = null)
+	{
+		$envType = $this->AllowedEnvironmentType;
+		if ($envType) {
+			$env = Injector::inst()->get($envType);
+			if ($env instanceof EnvironmentCreateBackend) {
+				return $this->allowed(DNRoot::ALLOW_CREATE_ENVIRONMENT, $member);
+			}
+		}
+		return false;
+	}
+
+	/**
+	 * @return DataList
+	 */
+	public function DataArchives()
+	{
+		$envIds = $this->Environments()->column('ID');
+		return DNDataArchive::get()->filter('EnvironmentID', $envIds);
+	}
+
+	/**
+	 * Return all archives which are "manual upload requests",
+	 * meaning they don't have a file attached to them (yet).
+	 *
+	 * @return DataList
+	 */
+	public function PendingManualUploadDataArchives()
+	{
+		return $this->DataArchives()->filter('ArchiveFileID', null);
+	}
+
+	/**
+	 * Build an environment variable array to be used with this project.
+	 *
+	 * This is relevant if every project needs to use an individual SSH pubkey.
+	 *
+	 * Include this with all Gitonomy\Git\Repository, and
+	 * \Symfony\Component\Process\Processes.
+	 *
+	 * @return array
+	 */
+	public function getProcessEnv()
+	{
+		if (file_exists($this->getPrivateKeyPath())) {
+			// Key-pair is available, use it.
+			$processEnv = array(
+				'IDENT_KEY' => $this->getPrivateKeyPath(),
+				'GIT_SSH' => BASE_PATH . "/deploynaut/git-deploy.sh"
+			);
+		} else {
+			$processEnv = array();
+		}
+		$this->extend('updateProcessEnv', $processEnv);
+
+		return $processEnv;
+	}
+
+	/**
+	 * Get a string of people allowed to view this project
+	 *
+	 * @return string
+	 */
+	public function getViewersList()
+	{
+		return implode(", ", $this->Viewers()->column("Title"));
+	}
+
+	/**
+	 * @return DNData
+	 */
+	public function DNData()
+	{
+		return DNData::inst();
+	}
+
+	/**
+	 * Provides a DNBuildList of builds found in this project.
+	 *
+	 * @return DNReferenceList
+	 */
+	public function DNBuildList()
+	{
+		return DNReferenceList::create($this, $this->DNData());
+	}
+
+	/**
+	 * Provides a list of the branches in this project.
+	 *
+	 * @return DNBranchList
+	 */
+	public function DNBranchList()
+	{
+		if ($this->CVSPath && !$this->repoExists()) {
+			$this->cloneRepo();
+		}
+		return DNBranchList::create($this, $this->DNData());
+	}
+
+	/**
+	 * Provides a list of the tags in this project.
+	 *
+	 * @return DNReferenceList
+	 */
+	public function DNTagList()
+	{
+		if ($this->CVSPath && !$this->repoExists()) {
+			$this->cloneRepo();
+		}
+		return DNReferenceList::create($this, $this->DNData(), null, null, true);
+	}
+
+	/**
+	 * @return false|Gitonomy\Git\Repository
+	 */
+	public function getRepository()
+	{
+		if (!$this->repoExists()) {
+			return false;
+		}
+
+		return new Gitonomy\Git\Repository($this->getLocalCVSPath());
+	}
+
+	/**
+	 * Provides a list of environments found in this project.
+	 * CAUTION: filterByCallback will change this into an ArrayList!
+	 *
+	 * @return ArrayList
+	 */
+	public function DNEnvironmentList()
+	{
+		if (!self::$_current_member_cache) {
+			self::$_current_member_cache = Member::currentUser();
+		}
+
+		if (self::$_current_member_cache === false) {
+			return new ArrayList();
+		}
+
+		$currentMember = self::$_current_member_cache;
+		return $this->Environments()
+			->filterByCallBack(function ($item) use ($currentMember) {
+				return $item->canView($currentMember);
+			});
+	}
+
+	/**
+	 * @param string $usage
+	 * @return ArrayList
+	 */
+	public function EnvironmentsByUsage($usage)
+	{
+		return $this->DNEnvironmentList()->filter('Usage', $usage);
+	}
+
+	/**
+	 * Returns a map of envrionment name to build name
+	 *
+	 * @return false|DNDeployment
+	 */
+	public function currentBuilds()
+	{
+		if (!isset(self::$relation_cache['currentBuilds.'.$this->ID])) {
+			$currentBuilds = array();
+			foreach ($this->Environments() as $env) {
+				$currentBuilds[$env->Name] = $env->CurrentBuild();
+			}
+			self::$relation_cache['currentBuilds.'.$this->ID] = $currentBuilds;
+		}
+		return self::$relation_cache['currentBuilds.'.$this->ID];
+	}
+
+	/**
+	 * @param string
+	 * @return string
+	 */
+	public function Link($action = '')
+	{
+		return Controller::join_links("naut", "project", $this->Name, $action);
+	}
+
+	/**
+	 * @return string|null
+	 */
+	public function CreateEnvironmentLink()
+	{
+		if ($this->canCreateEnvironments()) {
+			return $this->Link('createenv');
+		}
+		return null;
+	}
+
+	/**
+	 * @return string
+	 */
+	public function ToggleStarLink()
+	{
+		return $this->Link('/star');
+	}
+
+	/**
+	 * @return bool
+	 */
+	public function IsStarred()
+	{
+		$member = Member::currentUser();
+		if ($member === null) {
+			return false;
+		}
+		$favourited = $this->StarredBy()->filter('MemberID', $member->ID);
+		if ($favourited->count() == 0) {
+			return false;
+		}
+		return true;
+	}
+
+	/**
+	 * @param string $action
+	 * @return string
+	 */
+	public function APILink($action)
+	{
+		return Controller::join_links("naut", "api", $this->Name, $action);
+	}
+
+	/**
+	 * @return FieldList
+	 */
+	public function getCMSFields()
+	{
+		$fields = parent::getCMSFields();
+
+		/** @var GridField $environments */
+		$environments = $fields->dataFieldByName("Environments");
+
+		$fields->fieldByName("Root")->removeByName("Viewers");
+		$fields->fieldByName("Root")->removeByName("Environments");
+		$fields->fieldByName("Root")->removeByName("LocalCVSPath");
+
+		$diskQuotaDesc = 'This is the maximum amount of disk space (in megabytes) that all environments within this '
+			. 'project can use for stored snapshots';
+		$fields->dataFieldByName('DiskQuotaMB')->setDescription($diskQuotaDesc);
+
+		$projectNameDesc = 'Changing the name will <strong>reset</strong> the deploy configuration and avoid using non'
+			. 'alphanumeric characters';
+		$fields->fieldByName('Root.Main.Name')
+			->setTitle('Project name')
+			->setDescription($projectNameDesc);
+
+		$fields->fieldByName('Root.Main.CVSPath')
+			->setTitle('Git repository')
+			->setDescription('E.g. git@github.com:silverstripe/silverstripe-installer.git');
+
+		$workspaceField = new ReadonlyField('LocalWorkspace', 'Git workspace', $this->getLocalCVSPath());
+		$workspaceField->setDescription('This is where the GIT repository are located on this server');
+		$fields->insertAfter($workspaceField, 'CVSPath');
+
+		$readAccessGroups = ListboxField::create('Viewers', 'Project viewers', Group::get()->map()->toArray())
+			->setMultiple(true)
+			->setDescription('These groups can view the project in the front-end.');
+		$fields->addFieldToTab("Root.Main", $readAccessGroups);
+
+		$this->setCreateProjectFolderField($fields);
+		$this->setEnvironmentFields($fields, $environments);
+
+		$environmentTypes = ClassInfo::implementorsOf('EnvironmentCreateBackend');
+		$types = array();
+		foreach ($environmentTypes as $type) {
+			$types[$type] = $type;
+		}
+
+		$fields->addFieldsToTab('Root.Main', array(
+			DropdownField::create(
+				'AllowedEnvironmentType',
+				'Allowed Environment Type',
+				$types
+			)->setDescription('This defined which form to show on the front end for '
+				. 'environment creation. This will not affect backend functionality.')
+			->setEmptyString(' - None - '),
+		));
+
+		return $fields;
+	}
+
+	/**
+	 * If there isn't a capistrano env project folder, show options to create one
+	 *
+	 * @param FieldList $fields
+	 */
+	public function setCreateProjectFolderField(&$fields)
+	{
+		// Check if the capistrano project folder exists
+		if (!$this->Name) {
+			return;
+		}
+
+		if ($this->projectFolderExists()) {
+			return;
+		}
+
+		$createFolderNotice = new LabelField('CreateEnvFolderNotice', 'Warning: No Capistrano project folder exists');
+		$createFolderNotice->addExtraClass('message warning');
+		$fields->insertBefore($createFolderNotice, 'Name');
+		$createFolderField = new CheckboxField('CreateEnvFolder', 'Create folder');
+		$createFolderField->setDescription('Would you like to create the capistrano project folder?');
+		$fields->insertAfter($createFolderField, 'CreateEnvFolderNotice');
+	}
+
+	/**
+	 * @return boolean
+	 */
+	public function projectFolderExists()
+	{
+		return file_exists($this->getProjectFolderPath());
+	}
+
+	/**
+	 * @return bool
+	 */
+	public function repoExists()
+	{
+		return file_exists(sprintf('%s/HEAD', $this->getLocalCVSPath()));
+	}
+
+	/**
+	 * Setup a job to clone a git repository.
+	 * @return string resque token
+	 */
+	public function cloneRepo()
+	{
+		// Avoid this being called multiple times in the same request
+		if (!isset(self::$has_cloned_cache[$this->ID])) {
+			$fetch = DNGitFetch::create();
+			$fetch->ProjectID = $this->ID;
+			$fetch->write();
+
+			// passing true here tells DNGitFetch to force a git clone, otherwise
+			// it will just update the repo if it already exists. We want to ensure
+			// we're always cloning a new repo in this case, as the git URL may have changed.
+			$fetch->start(true);
+
+			self::$has_cloned_cache[$this->ID] = true;
+		}
+	}
+
+	/**
+	 * @return string
+	 */
+	public function getLocalCVSPath()
+	{
+		return sprintf('%s/%s', DEPLOYNAUT_LOCAL_VCS_PATH, $this->Name);
+	}
+
+	public function onBeforeWrite()
+	{
+		parent::onBeforeWrite();
+
+		if ($this->CreateEnvFolder && !file_exists($this->getProjectFolderPath())) {
+			mkdir($this->getProjectFolderPath());
+		}
+	}
+
+	public function onAfterWrite()
+	{
+		parent::onAfterWrite();
+
+		if (!$this->CVSPath) {
+			return;
+		}
+
+		$changedFields = $this->getChangedFields(true, 2);
+		if (isset($changedFields['CVSPath']) || isset($changedFields['Name'])) {
+			$this->cloneRepo();
+		}
+	}
+
+	/**
+	 * Delete related environments and folders
+	 */
+	public function onAfterDelete()
+	{
+		parent::onAfterDelete();
+
+		// Delete related environments
+		foreach ($this->Environments() as $env) {
+			$env->delete();
+		}
+
+		// Delete local repository
+		if (file_exists($this->getLocalCVSPath())) {
+			Filesystem::removeFolder($this->getLocalCVSPath());
+		}
+
+		// Delete project template
+		if (file_exists($this->getProjectFolderPath()) && Config::inst()->get('DNEnvironment', 'allow_web_editing')) {
+			Filesystem::removeFolder($this->getProjectFolderPath());
+		}
+
+		// Delete the deploy key
+		if (file_exists($this->getKeyDir())) {
+			Filesystem::removeFolder($this->getKeyDir());
+		}
+	}
+
+	/**
+	 * Fetch the public key for this project.
+	 *
+	 * @return string|void
+	 */
+	public function getPublicKey()
+	{
+		$key = $this->getPublicKeyPath();
+
+		if (file_exists($key)) {
+			return trim(file_get_contents($key));
+		}
+	}
+
+	/**
+	 * This returns that path of the public key if a key directory is set. It doesn't check whether the file exists.
+	 *
+	 * @return string|null
+	 */
+	public function getPublicKeyPath()
+	{
+		if ($privateKey = $this->getPrivateKeyPath()) {
+			return $privateKey . '.pub';
+		}
+		return null;
+	}
+
+	/**
+	 * This returns that path of the private key if a key directory is set. It doesn't check whether the file exists.
+	 *
+	 * @return string|null
+	 */
+	public function getPrivateKeyPath()
+	{
+		$keyDir = $this->getKeyDir();
+		if (!empty($keyDir)) {
+			$filter = FileNameFilter::create();
+			$name = $filter->filter($this->Name);
+			return $keyDir . '/' . $name;
+		}
+		return null;
+	}
+
+	/**
+	 * Returns the location of the projects key dir if one exists.
+	 *
+	 * @return string|null
+	 */
+	public function getKeyDir()
+	{
+		$keyDir = $this->DNData()->getKeyDir();
+		if (!$keyDir) {
+			return null;
+		}
+
+		$filter = FileNameFilter::create();
+		$name = $filter->filter($this->Name);
+
+		return $this->DNData()->getKeyDir() . '/' . $name;
+	}
+
+	/**
+	 * Setup a gridfield for the environment configs
+	 *
+	 * @param FieldList $fields
+	 * @param GridField $environments
+	 */
+	protected function setEnvironmentFields(&$fields, $environments)
+	{
+		if (!$environments) {
+			return;
+		}
+
+		$environments->getConfig()->addComponent(new GridFieldAddNewMultiClass());
+		$environments->getConfig()->removeComponentsByType('GridFieldAddNewButton');
+		$environments->getConfig()->removeComponentsByType('GridFieldAddExistingAutocompleter');
+		$environments->getConfig()->removeComponentsByType('GridFieldDeleteAction');
+		$environments->getConfig()->removeComponentsByType('GridFieldPageCount');
+		if (Config::inst()->get('DNEnvironment', 'allow_web_editing')) {
+			$addNewRelease = new GridFieldAddNewButton('toolbar-header-right');
+			$addNewRelease->setButtonName('Add');
+			$environments->getConfig()->addComponent($addNewRelease);
+		}
+
+		$fields->addFieldToTab("Root.Main", $environments);
+	}
+
+	/**
+	 * Provide current repository URL to the users.
+	 *
+	 * @return void|string
+	 */
+	public function getRepositoryURL()
+	{
+		$showUrl = Config::inst()->get($this->class, 'show_repository_url');
+		if ($showUrl) {
+			return $this->CVSPath;
+		}
+	}
+
+	/**
+	 * Whitelist configuration that describes how to convert a repository URL into a link
+	 * to a web user interface for that URL
+	 *
+	 * Consists of a hash of "full.lower.case.domain" => {configuration} key/value pairs
+	 *
+	 * {configuration} can either be boolean true to auto-detect both the host and the
+	 * name of the UI provider, or a nested array that overrides either one or both
+	 * of the auto-detected valyes
+	 *
+	 * @var array
+	 */
+	private static $repository_interfaces = array(
+		'github.com' => array(
+			'icon' => 'deploynaut/img/github.png',
+			'name' => 'Github.com',
+		),
+		'bitbucket.org' => array(
+			'commit' => 'commits',
+			'name' => 'Bitbucket.org',
+		),
+		'repo.or.cz' => array(
+			'scheme' => 'http',
+			'name' => 'repo.or.cz',
+			'regex' => array('^(.*)$' => '/w$1'),
+		),
+
+		/* Example for adding your own gitlab repository and override all auto-detected values (with their defaults)
         'gitlab.mysite.com' => array(
             'icon' => 'deploynaut/img/git.png',
             'host' => 'gitlab.mysite.com',
@@ -904,280 +904,280 @@ 
             'commit' => "commit"
         ),
         */
-    );
-
-    /**
-     * Get a ViewableData structure describing the UI tool that lets the user view the repository code
-     *
-     * @return ArrayData
-     */
-    public function getRepositoryInterface()
-    {
-        $interfaces = $this->config()->repository_interfaces;
-
-        /* Look for each whitelisted hostname */
-        foreach ($interfaces as $host => $interface) {
-            /* See if the CVS Path is for this hostname, followed by some junk (maybe a port), then the path */
-            if (preg_match('{^[^.]*' . $host . '(.*?)([/a-zA-Z].+)}', $this->CVSPath, $match)) {
-                $path = $match[2];
-
-                $scheme = isset($interface['scheme']) ? $interface['scheme'] : 'https';
-                $host = isset($interface['host']) ? $interface['host'] : $host;
-                $regex = isset($interface['regex']) ? $interface['regex'] : array('\.git$' => '');
-
-                $components = explode('.', $host);
-
-                foreach ($regex as $pattern => $replacement) {
-                    $path = preg_replace('/' . $pattern . '/', $replacement, $path);
-                }
-
-                $uxurl = Controller::join_links($scheme . '://', $host, $path);
-
-                if (array_key_exists('commit', $interface) && $interface['commit'] == false) {
-                    $commiturl = false;
-                } else {
-                    $commiturl = Controller::join_links(
-                        $uxurl,
-                        isset($interface['commit']) ? $interface['commit'] : 'commit'
-                    );
-                }
-
-                return new ArrayData(array(
-                    'Name'      => isset($interface['name']) ? $interface['name'] : ucfirst($components[0]),
-                    'Icon'      => isset($interface['icon']) ? $interface['icon'] : 'deploynaut/img/git.png',
-                    'URL'       => $uxurl,
-                    'CommitURL' => $commiturl
-                ));
-            }
-        }
-    }
-
-    /**
-     * @return string
-     */
-    protected function getProjectFolderPath()
-    {
-        return sprintf('%s/%s', $this->DNData()->getEnvironmentDir(), $this->Name);
-    }
-
-    /**
-     * Convenience wrapper for a single permission code.
-     *
-     * @param string $code
-     * @return SS_List
-     */
-    public function whoIsAllowed($code)
-    {
-        return $this->whoIsAllowedAny(array($code));
-    }
-
-    /**
-     * List members who have $codes on this project.
-     * Does not support Permission::DENY_PERMISSION malarky, same as Permission::get_groups_by_permission anyway...
-     *
-     * @param array|string $codes
-     * @return SS_List
-     */
-    public function whoIsAllowedAny($codes)
-    {
-        if (!is_array($codes)) {
-            $codes = array($codes);
-        }
-
-        $SQLa_codes = Convert::raw2sql($codes);
-        $SQL_codes = join("','", $SQLa_codes);
-
-        return DataObject::get('Member')
-            ->where("\"PermissionRoleCode\".\"Code\" IN ('$SQL_codes') OR \"Permission\".\"Code\" IN ('$SQL_codes')")
-            ->filter("DNProject_Viewers.DNProjectID", $this->ID)
-            ->leftJoin('Group_Members', "\"Group_Members\".\"MemberID\" = \"Member\".\"ID\"")
-            ->leftJoin('Group', "\"Group_Members\".\"GroupID\" = \"Group\".\"ID\"")
-            ->leftJoin('DNProject_Viewers', "\"DNProject_Viewers\".\"GroupID\" = \"Group\".\"ID\"")
-            ->leftJoin('Permission', "\"Permission\".\"GroupID\" = \"Group\".\"ID\"")
-            ->leftJoin('Group_Roles', "\"Group_Roles\".\"GroupID\" = \"Group\".\"ID\"")
-            ->leftJoin('PermissionRole', "\"Group_Roles\".\"PermissionRoleID\" = \"PermissionRole\".\"ID\"")
-            ->leftJoin('PermissionRoleCode', "\"PermissionRoleCode\".\"RoleID\" = \"PermissionRole\".\"ID\"");
-    }
-
-    /**
-     * Convenience wrapper for a single permission code.
-     *
-     * @param string $code
-     * @param Member|null $member
-     *
-     * @return bool
-     */
-    public function allowed($code, $member = null)
-    {
-        return $this->allowedAny(array($code), $member);
-    }
-
-    /**
-     * Checks if a group is allowed to the project and the permission code
-     *
-     * @param string $permissionCode
-     * @param Group $group
-     *
-     * @return bool
-     */
-    public function groupAllowed($permissionCode, Group $group)
-    {
-        $viewers = $this->Viewers();
-        if (!$viewers->find('ID', $group->ID)) {
-            return false;
-        }
-        $groups = Permission::get_groups_by_permission($permissionCode);
-        if (!$groups->find('ID', $group->ID)) {
-            return false;
-        }
-        return true;
-    }
-
-    /**
-     * Check if member has a permission code in this project.
-     *
-     * @param array|string $codes
-     * @param Member|null $member
-     *
-     * @return bool
-     */
-    public function allowedAny($codes, $member = null)
-    {
-        if (!$member) {
-            $member = Member::currentUser();
-        }
-
-        if (Permission::checkMember($member, 'ADMIN')) {
-            return true;
-        }
-
-        $hits = $this->whoIsAllowedAny($codes)->filter('Member.ID', $member->ID)->count();
-        return ($hits>0 ? true : false);
-    }
-
-    /**
-     * Checks if the environment has been fully built.
-     *
-     * @return bool
-     */
-    public function isProjectReady()
-    {
-        if ($this->getRunningInitialEnvironmentCreations()->count() > 0) {
-            // We're still creating the initial environments for this project so we're
-            // not quite done
-            return false;
-        }
-
-        // Provide a hook for further checks. Logic stolen from
-        // {@see DataObject::extendedCan()}
-        $isDone = $this->extend('isProjectReady');
-        if ($isDone && is_array($isDone)) {
-            $isDone = array_filter($isDone, function ($val) {
-                return !is_null($val);
-            });
-
-            // If anything returns false then we're not ready.
-            if ($isDone) {
-                return min($isDone);
-            }
-        }
-
-        return true;
-    }
-
-    /**
-     * Returns a list of environments still being created.
-     *
-     * @return SS_List
-     */
-    public function getRunningEnvironmentCreations()
-    {
-        return $this->CreateEnvironments()
-            ->filter('Status', ['Queued', 'Started']);
-    }
-
-    /**
-     * Returns a list of initial environments created for this project.
-     *
-     * @return DataList
-     */
-    public function getInitialEnvironmentCreations()
-    {
-        return $this->CreateEnvironments()->filter('IsInitialEnvironment', true);
-    }
-
-    /**
-     * Only returns initial environments that are being created.
-     *
-     * @return DataList
-     */
-    public function getRunningInitialEnvironmentCreations()
-    {
-        return $this->getInitialEnvironmentCreations()
-            ->filter('Status', ['Queued', 'Started']);
-    }
-
-    /**
-     * Returns a list of completed initial environment creations. This includes failed tasks.
-     *
-     * @return DataList
-     */
-    public function getCompleteInitialEnvironmentCreations()
-    {
-        return $this->getInitialEnvironmentCreations()
-            ->exclude('Status', ['Queued', 'Started']);
-    }
-
-    /**
-     * @return ValidationResult
-     */
-    protected function validate()
-    {
-        $validation = parent::validate();
-        if ($validation->valid()) {
-            if (empty($this->Name)) {
-                return $validation->error('The stack must have a name.');
-            }
-
-            // The name is used to build filepaths so should be restricted
-            if (!preg_match('/^[a-zA-Z0-9][a-zA-Z0-9\-\_]+$/', $this->Name)) {
-                return $validation->error('Project name can only contain alphanumeric, hyphens and underscores.');
-            }
-
-            if (empty($this->CVSPath)) {
-                return $validation->error('You must provide a repository URL.');
-            }
-
-            $existing = DNProject::get()->filter('Name', $this->Name);
-            if ($this->ID) {
-                $existing = $existing->exclude('ID', $this->ID);
-            }
-            if ($existing->count() > 0) {
-                return $validation->error('A stack already exists with that name.');
-            }
-        }
-        return $validation;
-    }
-
-    /**
-     * @param Member $member
-     *
-     * @return bool
-     */
-    public function canCreate($member = null)
-    {
-        if (!$member) {
-            $member = Member::currentUser();
-        }
-        if (!$member) {
-            return false;
-        }
-
-        if (Permission::checkMember($member, 'ADMIN')) {
-            return true;
-        }
-
-        // This calls canCreate on extensions.
-        return parent::canCreate($member);
-    }
+	);
+
+	/**
+	 * Get a ViewableData structure describing the UI tool that lets the user view the repository code
+	 *
+	 * @return ArrayData
+	 */
+	public function getRepositoryInterface()
+	{
+		$interfaces = $this->config()->repository_interfaces;
+
+		/* Look for each whitelisted hostname */
+		foreach ($interfaces as $host => $interface) {
+			/* See if the CVS Path is for this hostname, followed by some junk (maybe a port), then the path */
+			if (preg_match('{^[^.]*' . $host . '(.*?)([/a-zA-Z].+)}', $this->CVSPath, $match)) {
+				$path = $match[2];
+
+				$scheme = isset($interface['scheme']) ? $interface['scheme'] : 'https';
+				$host = isset($interface['host']) ? $interface['host'] : $host;
+				$regex = isset($interface['regex']) ? $interface['regex'] : array('\.git$' => '');
+
+				$components = explode('.', $host);
+
+				foreach ($regex as $pattern => $replacement) {
+					$path = preg_replace('/' . $pattern . '/', $replacement, $path);
+				}
+
+				$uxurl = Controller::join_links($scheme . '://', $host, $path);
+
+				if (array_key_exists('commit', $interface) && $interface['commit'] == false) {
+					$commiturl = false;
+				} else {
+					$commiturl = Controller::join_links(
+						$uxurl,
+						isset($interface['commit']) ? $interface['commit'] : 'commit'
+					);
+				}
+
+				return new ArrayData(array(
+					'Name'      => isset($interface['name']) ? $interface['name'] : ucfirst($components[0]),
+					'Icon'      => isset($interface['icon']) ? $interface['icon'] : 'deploynaut/img/git.png',
+					'URL'       => $uxurl,
+					'CommitURL' => $commiturl
+				));
+			}
+		}
+	}
+
+	/**
+	 * @return string
+	 */
+	protected function getProjectFolderPath()
+	{
+		return sprintf('%s/%s', $this->DNData()->getEnvironmentDir(), $this->Name);
+	}
+
+	/**
+	 * Convenience wrapper for a single permission code.
+	 *
+	 * @param string $code
+	 * @return SS_List
+	 */
+	public function whoIsAllowed($code)
+	{
+		return $this->whoIsAllowedAny(array($code));
+	}
+
+	/**
+	 * List members who have $codes on this project.
+	 * Does not support Permission::DENY_PERMISSION malarky, same as Permission::get_groups_by_permission anyway...
+	 *
+	 * @param array|string $codes
+	 * @return SS_List
+	 */
+	public function whoIsAllowedAny($codes)
+	{
+		if (!is_array($codes)) {
+			$codes = array($codes);
+		}
+
+		$SQLa_codes = Convert::raw2sql($codes);
+		$SQL_codes = join("','", $SQLa_codes);
+
+		return DataObject::get('Member')
+			->where("\"PermissionRoleCode\".\"Code\" IN ('$SQL_codes') OR \"Permission\".\"Code\" IN ('$SQL_codes')")
+			->filter("DNProject_Viewers.DNProjectID", $this->ID)
+			->leftJoin('Group_Members', "\"Group_Members\".\"MemberID\" = \"Member\".\"ID\"")
+			->leftJoin('Group', "\"Group_Members\".\"GroupID\" = \"Group\".\"ID\"")
+			->leftJoin('DNProject_Viewers', "\"DNProject_Viewers\".\"GroupID\" = \"Group\".\"ID\"")
+			->leftJoin('Permission', "\"Permission\".\"GroupID\" = \"Group\".\"ID\"")
+			->leftJoin('Group_Roles', "\"Group_Roles\".\"GroupID\" = \"Group\".\"ID\"")
+			->leftJoin('PermissionRole', "\"Group_Roles\".\"PermissionRoleID\" = \"PermissionRole\".\"ID\"")
+			->leftJoin('PermissionRoleCode', "\"PermissionRoleCode\".\"RoleID\" = \"PermissionRole\".\"ID\"");
+	}
+
+	/**
+	 * Convenience wrapper for a single permission code.
+	 *
+	 * @param string $code
+	 * @param Member|null $member
+	 *
+	 * @return bool
+	 */
+	public function allowed($code, $member = null)
+	{
+		return $this->allowedAny(array($code), $member);
+	}
+
+	/**
+	 * Checks if a group is allowed to the project and the permission code
+	 *
+	 * @param string $permissionCode
+	 * @param Group $group
+	 *
+	 * @return bool
+	 */
+	public function groupAllowed($permissionCode, Group $group)
+	{
+		$viewers = $this->Viewers();
+		if (!$viewers->find('ID', $group->ID)) {
+			return false;
+		}
+		$groups = Permission::get_groups_by_permission($permissionCode);
+		if (!$groups->find('ID', $group->ID)) {
+			return false;
+		}
+		return true;
+	}
+
+	/**
+	 * Check if member has a permission code in this project.
+	 *
+	 * @param array|string $codes
+	 * @param Member|null $member
+	 *
+	 * @return bool
+	 */
+	public function allowedAny($codes, $member = null)
+	{
+		if (!$member) {
+			$member = Member::currentUser();
+		}
+
+		if (Permission::checkMember($member, 'ADMIN')) {
+			return true;
+		}
+
+		$hits = $this->whoIsAllowedAny($codes)->filter('Member.ID', $member->ID)->count();
+		return ($hits>0 ? true : false);
+	}
+
+	/**
+	 * Checks if the environment has been fully built.
+	 *
+	 * @return bool
+	 */
+	public function isProjectReady()
+	{
+		if ($this->getRunningInitialEnvironmentCreations()->count() > 0) {
+			// We're still creating the initial environments for this project so we're
+			// not quite done
+			return false;
+		}
+
+		// Provide a hook for further checks. Logic stolen from
+		// {@see DataObject::extendedCan()}
+		$isDone = $this->extend('isProjectReady');
+		if ($isDone && is_array($isDone)) {
+			$isDone = array_filter($isDone, function ($val) {
+				return !is_null($val);
+			});
+
+			// If anything returns false then we're not ready.
+			if ($isDone) {
+				return min($isDone);
+			}
+		}
+
+		return true;
+	}
+
+	/**
+	 * Returns a list of environments still being created.
+	 *
+	 * @return SS_List
+	 */
+	public function getRunningEnvironmentCreations()
+	{
+		return $this->CreateEnvironments()
+			->filter('Status', ['Queued', 'Started']);
+	}
+
+	/**
+	 * Returns a list of initial environments created for this project.
+	 *
+	 * @return DataList
+	 */
+	public function getInitialEnvironmentCreations()
+	{
+		return $this->CreateEnvironments()->filter('IsInitialEnvironment', true);
+	}
+
+	/**
+	 * Only returns initial environments that are being created.
+	 *
+	 * @return DataList
+	 */
+	public function getRunningInitialEnvironmentCreations()
+	{
+		return $this->getInitialEnvironmentCreations()
+			->filter('Status', ['Queued', 'Started']);
+	}
+
+	/**
+	 * Returns a list of completed initial environment creations. This includes failed tasks.
+	 *
+	 * @return DataList
+	 */
+	public function getCompleteInitialEnvironmentCreations()
+	{
+		return $this->getInitialEnvironmentCreations()
+			->exclude('Status', ['Queued', 'Started']);
+	}
+
+	/**
+	 * @return ValidationResult
+	 */
+	protected function validate()
+	{
+		$validation = parent::validate();
+		if ($validation->valid()) {
+			if (empty($this->Name)) {
+				return $validation->error('The stack must have a name.');
+			}
+
+			// The name is used to build filepaths so should be restricted
+			if (!preg_match('/^[a-zA-Z0-9][a-zA-Z0-9\-\_]+$/', $this->Name)) {
+				return $validation->error('Project name can only contain alphanumeric, hyphens and underscores.');
+			}
+
+			if (empty($this->CVSPath)) {
+				return $validation->error('You must provide a repository URL.');
+			}
+
+			$existing = DNProject::get()->filter('Name', $this->Name);
+			if ($this->ID) {
+				$existing = $existing->exclude('ID', $this->ID);
+			}
+			if ($existing->count() > 0) {
+				return $validation->error('A stack already exists with that name.');
+			}
+		}
+		return $validation;
+	}
+
+	/**
+	 * @param Member $member
+	 *
+	 * @return bool
+	 */
+	public function canCreate($member = null)
+	{
+		if (!$member) {
+			$member = Member::currentUser();
+		}
+		if (!$member) {
+			return false;
+		}
+
+		if (Permission::checkMember($member, 'ADMIN')) {
+			return true;
+		}
+
+		// This calls canCreate on extensions.
+		return parent::canCreate($member);
+	}
 }

Spacing +73 added lines, -73 removed lines

@@ -111,7 +111,7 @@ 
 
         // add the administrators group as the viewers of the new project
         $adminGroup = Group::get()->filter('Code', 'administrators')->first();
-        if ($adminGroup && $adminGroup->exists()) {
+        if($adminGroup && $adminGroup->exists()) {
             $project->Viewers()->add($adminGroup);
         }
         return $project;
@@ -127,8 +127,8 @@ 
     {
         $size = 0;
 
-        foreach ($this->Environments() as $environment) {
-            foreach ($environment->DataArchives()->filter('IsBackup', 0) as $archive) {
+        foreach($this->Environments() as $environment) {
+            foreach($environment->DataArchives()->filter('IsBackup', 0) as $archive) {
                 $size += $archive->ArchiveFile()->getAbsoluteSize();
             }
         }
@@ -148,7 +148,7 @@ 
     {
         $size = $this->getField('DiskQuotaMB');
 
-        if (empty($size)) {
+        if(empty($size)) {
             $defaults = $this->config()->get('defaults');
             $size = (isset($defaults['DiskQuotaMB'])) ? $defaults['DiskQuotaMB'] : 0;
         }
@@ -184,7 +184,7 @@ 
     public function DiskQuotaUsagePercent()
     {
         $quota = $this->getDiskQuotaMB();
-        if ($quota > 0) {
+        if($quota > 0) {
             return $this->getUsedQuotaMB() * 100 / $quota;
         }
         return 100;
@@ -202,7 +202,7 @@ 
         $controller = Controller::curr();
         $actionType = $controller->getField('CurrentActionType');
 
-        if (DNRoot::FlagSnapshotsEnabled() && $this->isProjectReady()) {
+        if(DNRoot::FlagSnapshotsEnabled() && $this->isProjectReady()) {
             $list->push(new ArrayData(array(
                 'Link' => sprintf('naut/project/%s/snapshots', $this->Name),
                 'Title' => 'Snapshots',
@@ -257,11 +257,11 @@ 
      */
     public function canView($member = null)
     {
-        if (!$member) {
+        if(!$member) {
             $member = Member::currentUser();
         }
 
-        if (Permission::checkMember($member, 'ADMIN')) {
+        if(Permission::checkMember($member, 'ADMIN')) {
             return true;
         }
 
@@ -275,7 +275,7 @@ 
      */
     public function canRestore($member = null)
     {
-        if ($this->allowedAny(
+        if($this->allowedAny(
             array(
                 DNRoot::ALLOW_PROD_SNAPSHOT,
                 DNRoot::ALLOW_NON_PROD_SNAPSHOT
@@ -285,7 +285,7 @@ 
             return true;
         }
 
-        return (bool)$this->Environments()->filterByCallback(function ($env) use ($member) {
+        return (bool)$this->Environments()->filterByCallback(function($env) use ($member) {
             return $env->canRestore($member);
         })->Count();
     }
@@ -296,7 +296,7 @@ 
      */
     public function canBackup($member = null)
     {
-        if ($this->allowedAny(
+        if($this->allowedAny(
             array(
                 DNRoot::ALLOW_PROD_SNAPSHOT,
                 DNRoot::ALLOW_NON_PROD_SNAPSHOT
@@ -306,7 +306,7 @@ 
             return true;
         }
 
-        return (bool)$this->Environments()->filterByCallback(function ($env) use ($member) {
+        return (bool)$this->Environments()->filterByCallback(function($env) use ($member) {
             return $env->canBackup($member);
         })->Count();
     }
@@ -317,7 +317,7 @@ 
      */
     public function canUploadArchive($member = null)
     {
-        if ($this->allowedAny(
+        if($this->allowedAny(
             array(
                 DNRoot::ALLOW_PROD_SNAPSHOT,
                 DNRoot::ALLOW_NON_PROD_SNAPSHOT
@@ -327,7 +327,7 @@ 
             return true;
         }
 
-        return (bool)$this->Environments()->filterByCallback(function ($env) use ($member) {
+        return (bool)$this->Environments()->filterByCallback(function($env) use ($member) {
             return $env->canUploadArchive($member);
         })->Count();
     }
@@ -338,7 +338,7 @@ 
      */
     public function canDownloadArchive($member = null)
     {
-        if ($this->allowedAny(
+        if($this->allowedAny(
             array(
                 DNRoot::ALLOW_PROD_SNAPSHOT,
                 DNRoot::ALLOW_NON_PROD_SNAPSHOT
@@ -348,7 +348,7 @@ 
             return true;
         }
 
-        return (bool)$this->Environments()->filterByCallback(function ($env) use ($member) {
+        return (bool)$this->Environments()->filterByCallback(function($env) use ($member) {
             return $env->canDownloadArchive($member);
         })->Count();
     }
@@ -366,9 +366,9 @@ 
     public function canCreateEnvironments($member = null)
     {
         $envType = $this->AllowedEnvironmentType;
-        if ($envType) {
+        if($envType) {
             $env = Injector::inst()->get($envType);
-            if ($env instanceof EnvironmentCreateBackend) {
+            if($env instanceof EnvironmentCreateBackend) {
                 return $this->allowed(DNRoot::ALLOW_CREATE_ENVIRONMENT, $member);
             }
         }
@@ -407,7 +407,7 @@ 
      */
     public function getProcessEnv()
     {
-        if (file_exists($this->getPrivateKeyPath())) {
+        if(file_exists($this->getPrivateKeyPath())) {
             // Key-pair is available, use it.
             $processEnv = array(
                 'IDENT_KEY' => $this->getPrivateKeyPath(),
@@ -456,7 +456,7 @@ 
      */
     public function DNBranchList()
     {
-        if ($this->CVSPath && !$this->repoExists()) {
+        if($this->CVSPath && !$this->repoExists()) {
             $this->cloneRepo();
         }
         return DNBranchList::create($this, $this->DNData());
@@ -469,7 +469,7 @@ 
      */
     public function DNTagList()
     {
-        if ($this->CVSPath && !$this->repoExists()) {
+        if($this->CVSPath && !$this->repoExists()) {
             $this->cloneRepo();
         }
         return DNReferenceList::create($this, $this->DNData(), null, null, true);
@@ -480,7 +480,7 @@ 
      */
     public function getRepository()
     {
-        if (!$this->repoExists()) {
+        if(!$this->repoExists()) {
             return false;
         }
 
@@ -495,17 +495,17 @@ 
      */
     public function DNEnvironmentList()
     {
-        if (!self::$_current_member_cache) {
+        if(!self::$_current_member_cache) {
             self::$_current_member_cache = Member::currentUser();
         }
 
-        if (self::$_current_member_cache === false) {
+        if(self::$_current_member_cache === false) {
             return new ArrayList();
         }
 
         $currentMember = self::$_current_member_cache;
         return $this->Environments()
-            ->filterByCallBack(function ($item) use ($currentMember) {
+            ->filterByCallBack(function($item) use ($currentMember) {
                 return $item->canView($currentMember);
             });
     }
@@ -526,14 +526,14 @@ 
      */
     public function currentBuilds()
     {
-        if (!isset(self::$relation_cache['currentBuilds.'.$this->ID])) {
+        if(!isset(self::$relation_cache['currentBuilds.' . $this->ID])) {
             $currentBuilds = array();
-            foreach ($this->Environments() as $env) {
+            foreach($this->Environments() as $env) {
                 $currentBuilds[$env->Name] = $env->CurrentBuild();
             }
-            self::$relation_cache['currentBuilds.'.$this->ID] = $currentBuilds;
+            self::$relation_cache['currentBuilds.' . $this->ID] = $currentBuilds;
         }
-        return self::$relation_cache['currentBuilds.'.$this->ID];
+        return self::$relation_cache['currentBuilds.' . $this->ID];
     }
 
     /**
@@ -550,7 +550,7 @@ 
      */
     public function CreateEnvironmentLink()
     {
-        if ($this->canCreateEnvironments()) {
+        if($this->canCreateEnvironments()) {
             return $this->Link('createenv');
         }
         return null;
@@ -570,11 +570,11 @@ 
     public function IsStarred()
     {
         $member = Member::currentUser();
-        if ($member === null) {
+        if($member === null) {
             return false;
         }
         $favourited = $this->StarredBy()->filter('MemberID', $member->ID);
-        if ($favourited->count() == 0) {
+        if($favourited->count() == 0) {
             return false;
         }
         return true;
@@ -631,7 +631,7 @@ 
 
         $environmentTypes = ClassInfo::implementorsOf('EnvironmentCreateBackend');
         $types = array();
-        foreach ($environmentTypes as $type) {
+        foreach($environmentTypes as $type) {
             $types[$type] = $type;
         }
 
@@ -656,11 +656,11 @@ 
     public function setCreateProjectFolderField(&$fields)
     {
         // Check if the capistrano project folder exists
-        if (!$this->Name) {
+        if(!$this->Name) {
             return;
         }
 
-        if ($this->projectFolderExists()) {
+        if($this->projectFolderExists()) {
             return;
         }
 
@@ -695,7 +695,7 @@ 
     public function cloneRepo()
     {
         // Avoid this being called multiple times in the same request
-        if (!isset(self::$has_cloned_cache[$this->ID])) {
+        if(!isset(self::$has_cloned_cache[$this->ID])) {
             $fetch = DNGitFetch::create();
             $fetch->ProjectID = $this->ID;
             $fetch->write();
@@ -721,7 +721,7 @@ 
     {
         parent::onBeforeWrite();
 
-        if ($this->CreateEnvFolder && !file_exists($this->getProjectFolderPath())) {
+        if($this->CreateEnvFolder && !file_exists($this->getProjectFolderPath())) {
             mkdir($this->getProjectFolderPath());
         }
     }
@@ -730,12 +730,12 @@ 
     {
         parent::onAfterWrite();
 
-        if (!$this->CVSPath) {
+        if(!$this->CVSPath) {
             return;
         }
 
         $changedFields = $this->getChangedFields(true, 2);
-        if (isset($changedFields['CVSPath']) || isset($changedFields['Name'])) {
+        if(isset($changedFields['CVSPath']) || isset($changedFields['Name'])) {
             $this->cloneRepo();
         }
     }
@@ -748,22 +748,22 @@ 
         parent::onAfterDelete();
 
         // Delete related environments
-        foreach ($this->Environments() as $env) {
+        foreach($this->Environments() as $env) {
             $env->delete();
         }
 
         // Delete local repository
-        if (file_exists($this->getLocalCVSPath())) {
+        if(file_exists($this->getLocalCVSPath())) {
             Filesystem::removeFolder($this->getLocalCVSPath());
         }
 
         // Delete project template
-        if (file_exists($this->getProjectFolderPath()) && Config::inst()->get('DNEnvironment', 'allow_web_editing')) {
+        if(file_exists($this->getProjectFolderPath()) && Config::inst()->get('DNEnvironment', 'allow_web_editing')) {
             Filesystem::removeFolder($this->getProjectFolderPath());
         }
 
         // Delete the deploy key
-        if (file_exists($this->getKeyDir())) {
+        if(file_exists($this->getKeyDir())) {
             Filesystem::removeFolder($this->getKeyDir());
         }
     }
@@ -777,7 +777,7 @@ 
     {
         $key = $this->getPublicKeyPath();
 
-        if (file_exists($key)) {
+        if(file_exists($key)) {
             return trim(file_get_contents($key));
         }
     }
@@ -789,7 +789,7 @@ 
      */
     public function getPublicKeyPath()
     {
-        if ($privateKey = $this->getPrivateKeyPath()) {
+        if($privateKey = $this->getPrivateKeyPath()) {
             return $privateKey . '.pub';
         }
         return null;
@@ -803,7 +803,7 @@ 
     public function getPrivateKeyPath()
     {
         $keyDir = $this->getKeyDir();
-        if (!empty($keyDir)) {
+        if(!empty($keyDir)) {
             $filter = FileNameFilter::create();
             $name = $filter->filter($this->Name);
             return $keyDir . '/' . $name;
@@ -819,7 +819,7 @@ 
     public function getKeyDir()
     {
         $keyDir = $this->DNData()->getKeyDir();
-        if (!$keyDir) {
+        if(!$keyDir) {
             return null;
         }
 
@@ -837,7 +837,7 @@ 
      */
     protected function setEnvironmentFields(&$fields, $environments)
     {
-        if (!$environments) {
+        if(!$environments) {
             return;
         }
 
@@ -846,7 +846,7 @@ 
         $environments->getConfig()->removeComponentsByType('GridFieldAddExistingAutocompleter');
         $environments->getConfig()->removeComponentsByType('GridFieldDeleteAction');
         $environments->getConfig()->removeComponentsByType('GridFieldPageCount');
-        if (Config::inst()->get('DNEnvironment', 'allow_web_editing')) {
+        if(Config::inst()->get('DNEnvironment', 'allow_web_editing')) {
             $addNewRelease = new GridFieldAddNewButton('toolbar-header-right');
             $addNewRelease->setButtonName('Add');
             $environments->getConfig()->addComponent($addNewRelease);
@@ -863,7 +863,7 @@ 
     public function getRepositoryURL()
     {
         $showUrl = Config::inst()->get($this->class, 'show_repository_url');
-        if ($showUrl) {
+        if($showUrl) {
             return $this->CVSPath;
         }
     }
@@ -916,9 +916,9 @@ 
         $interfaces = $this->config()->repository_interfaces;
 
         /* Look for each whitelisted hostname */
-        foreach ($interfaces as $host => $interface) {
+        foreach($interfaces as $host => $interface) {
             /* See if the CVS Path is for this hostname, followed by some junk (maybe a port), then the path */
-            if (preg_match('{^[^.]*' . $host . '(.*?)([/a-zA-Z].+)}', $this->CVSPath, $match)) {
+            if(preg_match('{^[^.]*' . $host . '(.*?)([/a-zA-Z].+)}', $this->CVSPath, $match)) {
                 $path = $match[2];
 
                 $scheme = isset($interface['scheme']) ? $interface['scheme'] : 'https';
@@ -927,13 +927,13 @@ 
 
                 $components = explode('.', $host);
 
-                foreach ($regex as $pattern => $replacement) {
+                foreach($regex as $pattern => $replacement) {
                     $path = preg_replace('/' . $pattern . '/', $replacement, $path);
                 }
 
                 $uxurl = Controller::join_links($scheme . '://', $host, $path);
 
-                if (array_key_exists('commit', $interface) && $interface['commit'] == false) {
+                if(array_key_exists('commit', $interface) && $interface['commit'] == false) {
                     $commiturl = false;
                 } else {
                     $commiturl = Controller::join_links(
@@ -980,7 +980,7 @@ 
      */
     public function whoIsAllowedAny($codes)
     {
-        if (!is_array($codes)) {
+        if(!is_array($codes)) {
             $codes = array($codes);
         }
 
@@ -1023,11 +1023,11 @@ 
     public function groupAllowed($permissionCode, Group $group)
     {
         $viewers = $this->Viewers();
-        if (!$viewers->find('ID', $group->ID)) {
+        if(!$viewers->find('ID', $group->ID)) {
             return false;
         }
         $groups = Permission::get_groups_by_permission($permissionCode);
-        if (!$groups->find('ID', $group->ID)) {
+        if(!$groups->find('ID', $group->ID)) {
             return false;
         }
         return true;
@@ -1043,16 +1043,16 @@ 
      */
     public function allowedAny($codes, $member = null)
     {
-        if (!$member) {
+        if(!$member) {
             $member = Member::currentUser();
         }
 
-        if (Permission::checkMember($member, 'ADMIN')) {
+        if(Permission::checkMember($member, 'ADMIN')) {
             return true;
         }
 
         $hits = $this->whoIsAllowedAny($codes)->filter('Member.ID', $member->ID)->count();
-        return ($hits>0 ? true : false);
+        return ($hits > 0 ? true : false);
     }
 
     /**
@@ -1062,7 +1062,7 @@ 
      */
     public function isProjectReady()
     {
-        if ($this->getRunningInitialEnvironmentCreations()->count() > 0) {
+        if($this->getRunningInitialEnvironmentCreations()->count() > 0) {
             // We're still creating the initial environments for this project so we're
             // not quite done
             return false;
@@ -1071,13 +1071,13 @@ 
         // Provide a hook for further checks. Logic stolen from
         // {@see DataObject::extendedCan()}
         $isDone = $this->extend('isProjectReady');
-        if ($isDone && is_array($isDone)) {
-            $isDone = array_filter($isDone, function ($val) {
+        if($isDone && is_array($isDone)) {
+            $isDone = array_filter($isDone, function($val) {
                 return !is_null($val);
             });
 
             // If anything returns false then we're not ready.
-            if ($isDone) {
+            if($isDone) {
                 return min($isDone);
             }
         }
@@ -1134,25 +1134,25 @@ 
     protected function validate()
     {
         $validation = parent::validate();
-        if ($validation->valid()) {
-            if (empty($this->Name)) {
+        if($validation->valid()) {
+            if(empty($this->Name)) {
                 return $validation->error('The stack must have a name.');
             }
 
             // The name is used to build filepaths so should be restricted
-            if (!preg_match('/^[a-zA-Z0-9][a-zA-Z0-9\-\_]+$/', $this->Name)) {
+            if(!preg_match('/^[a-zA-Z0-9][a-zA-Z0-9\-\_]+$/', $this->Name)) {
                 return $validation->error('Project name can only contain alphanumeric, hyphens and underscores.');
             }
 
-            if (empty($this->CVSPath)) {
+            if(empty($this->CVSPath)) {
                 return $validation->error('You must provide a repository URL.');
             }
 
             $existing = DNProject::get()->filter('Name', $this->Name);
-            if ($this->ID) {
+            if($this->ID) {
                 $existing = $existing->exclude('ID', $this->ID);
             }
-            if ($existing->count() > 0) {
+            if($existing->count() > 0) {
                 return $validation->error('A stack already exists with that name.');
             }
         }
@@ -1166,14 +1166,14 @@ 
      */
     public function canCreate($member = null)
     {
-        if (!$member) {
+        if(!$member) {
             $member = Member::currentUser();
         }
-        if (!$member) {
+        if(!$member) {
             return false;
         }
 
-        if (Permission::checkMember($member, 'ADMIN')) {
+        if(Permission::checkMember($member, 'ADMIN')) {
             return true;
         }
 

Braces +63 added lines, -126 removed lines

@@ -12,8 +12,7 @@ 
  * @method ManyManyList Viewers()
  * @method ManyManyList StarredBy()
  */
-class DNProject extends DataObject
-{
+class DNProject extends DataObject {
 
     /**
      * @var array
@@ -103,8 +102,7 @@ 
      * @param string $path
      * @return \DNProject
      */
-    public static function create_from_path($path)
-    {
+    public static function create_from_path($path) {
         $project = DNProject::create();
         $project->Name = $path;
         $project->write();
@@ -123,8 +121,7 @@ 
      * @param int $round Number of decimal places to round to
      * @return double The used quota size in MB
      */
-    public function getUsedQuotaMB($round = 2)
-    {
+    public function getUsedQuotaMB($round = 2) {
         $size = 0;
 
         foreach ($this->Environments() as $environment) {
@@ -144,8 +141,7 @@ 
      *
      * @return string|int The quota size in MB
      */
-    public function getDiskQuotaMB()
-    {
+    public function getDiskQuotaMB() {
         $size = $this->getField('DiskQuotaMB');
 
         if (empty($size)) {
@@ -161,8 +157,7 @@ 
      *
      * @return boolean
      */
-    public function HasExceededDiskQuota()
-    {
+    public function HasExceededDiskQuota() {
         return $this->getUsedQuotaMB(0) >= $this->getDiskQuotaMB();
     }
 
@@ -171,8 +166,7 @@ 
      *
      * @return boolean
      */
-    public function HasDiskQuota()
-    {
+    public function HasDiskQuota() {
         return $this->getDiskQuotaMB() > 0;
     }
 
@@ -181,8 +175,7 @@ 
      *
      * @return int
      */
-    public function DiskQuotaUsagePercent()
-    {
+    public function DiskQuotaUsagePercent() {
         $quota = $this->getDiskQuotaMB();
         if ($quota > 0) {
             return $this->getUsedQuotaMB() * 100 / $quota;
@@ -195,8 +188,7 @@ 
      *
      * @return ArrayList
      */
-    public function Menu()
-    {
+    public function Menu() {
         $list = new ArrayList();
 
         $controller = Controller::curr();
@@ -221,8 +213,7 @@ 
      *
      * @return bool
      */
-    public function isCurrent()
-    {
+    public function isCurrent() {
         return $this->isSection() && Controller::curr()->getAction() == 'project';
     }
 
@@ -232,8 +223,7 @@ 
      *
      * @return DataObject
      */
-    public function CurrentMenu()
-    {
+    public function CurrentMenu() {
         return $this->Menu()->filter('IsSection', true)->First();
     }
 
@@ -242,8 +232,7 @@ 
      *
      * @return bool
      */
-    public function isSection()
-    {
+    public function isSection() {
         $controller = Controller::curr();
         $project = $controller->getField('CurrentProject');
         return $project && $this->ID == $project->ID;
@@ -255,8 +244,7 @@ 
      * @param Member|null $member
      * @return boolean
      */
-    public function canView($member = null)
-    {
+    public function canView($member = null) {
         if (!$member) {
             $member = Member::currentUser();
         }
@@ -273,8 +261,7 @@ 
      *
      * @return bool
      */
-    public function canRestore($member = null)
-    {
+    public function canRestore($member = null) {
         if ($this->allowedAny(
             array(
                 DNRoot::ALLOW_PROD_SNAPSHOT,
@@ -294,8 +281,7 @@ 
      * @param Member|null $member
      * @return bool
      */
-    public function canBackup($member = null)
-    {
+    public function canBackup($member = null) {
         if ($this->allowedAny(
             array(
                 DNRoot::ALLOW_PROD_SNAPSHOT,
@@ -315,8 +301,7 @@ 
      * @param Member|null $member
      * @return bool
      */
-    public function canUploadArchive($member = null)
-    {
+    public function canUploadArchive($member = null) {
         if ($this->allowedAny(
             array(
                 DNRoot::ALLOW_PROD_SNAPSHOT,
@@ -336,8 +321,7 @@ 
      * @param Member|null $member
      * @return bool
      */
-    public function canDownloadArchive($member = null)
-    {
+    public function canDownloadArchive($member = null) {
         if ($this->allowedAny(
             array(
                 DNRoot::ALLOW_PROD_SNAPSHOT,
@@ -363,8 +347,7 @@ 
      *
      * @return bool
      */
-    public function canCreateEnvironments($member = null)
-    {
+    public function canCreateEnvironments($member = null) {
         $envType = $this->AllowedEnvironmentType;
         if ($envType) {
             $env = Injector::inst()->get($envType);
@@ -378,8 +361,7 @@ 
     /**
      * @return DataList
      */
-    public function DataArchives()
-    {
+    public function DataArchives() {
         $envIds = $this->Environments()->column('ID');
         return DNDataArchive::get()->filter('EnvironmentID', $envIds);
     }
@@ -390,8 +372,7 @@ 
      *
      * @return DataList
      */
-    public function PendingManualUploadDataArchives()
-    {
+    public function PendingManualUploadDataArchives() {
         return $this->DataArchives()->filter('ArchiveFileID', null);
     }
 
@@ -405,8 +386,7 @@ 
      *
      * @return array
      */
-    public function getProcessEnv()
-    {
+    public function getProcessEnv() {
         if (file_exists($this->getPrivateKeyPath())) {
             // Key-pair is available, use it.
             $processEnv = array(
@@ -426,16 +406,14 @@ 
      *
      * @return string
      */
-    public function getViewersList()
-    {
+    public function getViewersList() {
         return implode(", ", $this->Viewers()->column("Title"));
     }
 
     /**
      * @return DNData
      */
-    public function DNData()
-    {
+    public function DNData() {
         return DNData::inst();
     }
 
@@ -444,8 +422,7 @@ 
      *
      * @return DNReferenceList
      */
-    public function DNBuildList()
-    {
+    public function DNBuildList() {
         return DNReferenceList::create($this, $this->DNData());
     }
 
@@ -454,8 +431,7 @@ 
      *
      * @return DNBranchList
      */
-    public function DNBranchList()
-    {
+    public function DNBranchList() {
         if ($this->CVSPath && !$this->repoExists()) {
             $this->cloneRepo();
         }
@@ -467,8 +443,7 @@ 
      *
      * @return DNReferenceList
      */
-    public function DNTagList()
-    {
+    public function DNTagList() {
         if ($this->CVSPath && !$this->repoExists()) {
             $this->cloneRepo();
         }
@@ -478,8 +453,7 @@ 
     /**
      * @return false|Gitonomy\Git\Repository
      */
-    public function getRepository()
-    {
+    public function getRepository() {
         if (!$this->repoExists()) {
             return false;
         }
@@ -493,8 +467,7 @@ 
      *
      * @return ArrayList
      */
-    public function DNEnvironmentList()
-    {
+    public function DNEnvironmentList() {
         if (!self::$_current_member_cache) {
             self::$_current_member_cache = Member::currentUser();
         }
@@ -514,8 +487,7 @@ 
      * @param string $usage
      * @return ArrayList
      */
-    public function EnvironmentsByUsage($usage)
-    {
+    public function EnvironmentsByUsage($usage) {
         return $this->DNEnvironmentList()->filter('Usage', $usage);
     }
 
@@ -524,8 +496,7 @@ 
      *
      * @return false|DNDeployment
      */
-    public function currentBuilds()
-    {
+    public function currentBuilds() {
         if (!isset(self::$relation_cache['currentBuilds.'.$this->ID])) {
             $currentBuilds = array();
             foreach ($this->Environments() as $env) {
@@ -540,16 +511,14 @@ 
      * @param string
      * @return string
      */
-    public function Link($action = '')
-    {
+    public function Link($action = '') {
         return Controller::join_links("naut", "project", $this->Name, $action);
     }
 
     /**
      * @return string|null
      */
-    public function CreateEnvironmentLink()
-    {
+    public function CreateEnvironmentLink() {
         if ($this->canCreateEnvironments()) {
             return $this->Link('createenv');
         }
@@ -559,16 +528,14 @@ 
     /**
      * @return string
      */
-    public function ToggleStarLink()
-    {
+    public function ToggleStarLink() {
         return $this->Link('/star');
     }
 
     /**
      * @return bool
      */
-    public function IsStarred()
-    {
+    public function IsStarred() {
         $member = Member::currentUser();
         if ($member === null) {
             return false;
@@ -584,16 +551,14 @@ 
      * @param string $action
      * @return string
      */
-    public function APILink($action)
-    {
+    public function APILink($action) {
         return Controller::join_links("naut", "api", $this->Name, $action);
     }
 
     /**
      * @return FieldList
      */
-    public function getCMSFields()
-    {
+    public function getCMSFields() {
         $fields = parent::getCMSFields();
 
         /** @var GridField $environments */
@@ -653,8 +618,7 @@ 
      *
      * @param FieldList $fields
      */
-    public function setCreateProjectFolderField(&$fields)
-    {
+    public function setCreateProjectFolderField(&$fields) {
         // Check if the capistrano project folder exists
         if (!$this->Name) {
             return;
@@ -675,16 +639,14 @@ 
     /**
      * @return boolean
      */
-    public function projectFolderExists()
-    {
+    public function projectFolderExists() {
         return file_exists($this->getProjectFolderPath());
     }
 
     /**
      * @return bool
      */
-    public function repoExists()
-    {
+    public function repoExists() {
         return file_exists(sprintf('%s/HEAD', $this->getLocalCVSPath()));
     }
 
@@ -692,8 +654,7 @@ 
      * Setup a job to clone a git repository.
      * @return string resque token
      */
-    public function cloneRepo()
-    {
+    public function cloneRepo() {
         // Avoid this being called multiple times in the same request
         if (!isset(self::$has_cloned_cache[$this->ID])) {
             $fetch = DNGitFetch::create();
@@ -712,13 +673,11 @@ 
     /**
      * @return string
      */
-    public function getLocalCVSPath()
-    {
+    public function getLocalCVSPath() {
         return sprintf('%s/%s', DEPLOYNAUT_LOCAL_VCS_PATH, $this->Name);
     }
 
-    public function onBeforeWrite()
-    {
+    public function onBeforeWrite() {
         parent::onBeforeWrite();
 
         if ($this->CreateEnvFolder && !file_exists($this->getProjectFolderPath())) {
@@ -726,8 +685,7 @@ 
         }
     }
 
-    public function onAfterWrite()
-    {
+    public function onAfterWrite() {
         parent::onAfterWrite();
 
         if (!$this->CVSPath) {
@@ -743,8 +701,7 @@ 
     /**
      * Delete related environments and folders
      */
-    public function onAfterDelete()
-    {
+    public function onAfterDelete() {
         parent::onAfterDelete();
 
         // Delete related environments
@@ -773,8 +730,7 @@ 
      *
      * @return string|void
      */
-    public function getPublicKey()
-    {
+    public function getPublicKey() {
         $key = $this->getPublicKeyPath();
 
         if (file_exists($key)) {
@@ -787,8 +743,7 @@ 
      *
      * @return string|null
      */
-    public function getPublicKeyPath()
-    {
+    public function getPublicKeyPath() {
         if ($privateKey = $this->getPrivateKeyPath()) {
             return $privateKey . '.pub';
         }
@@ -800,8 +755,7 @@ 
      *
      * @return string|null
      */
-    public function getPrivateKeyPath()
-    {
+    public function getPrivateKeyPath() {
         $keyDir = $this->getKeyDir();
         if (!empty($keyDir)) {
             $filter = FileNameFilter::create();
@@ -816,8 +770,7 @@ 
      *
      * @return string|null
      */
-    public function getKeyDir()
-    {
+    public function getKeyDir() {
         $keyDir = $this->DNData()->getKeyDir();
         if (!$keyDir) {
             return null;
@@ -835,8 +788,7 @@ 
      * @param FieldList $fields
      * @param GridField $environments
      */
-    protected function setEnvironmentFields(&$fields, $environments)
-    {
+    protected function setEnvironmentFields(&$fields, $environments) {
         if (!$environments) {
             return;
         }
@@ -860,8 +812,7 @@ 
      *
      * @return void|string
      */
-    public function getRepositoryURL()
-    {
+    public function getRepositoryURL() {
         $showUrl = Config::inst()->get($this->class, 'show_repository_url');
         if ($showUrl) {
             return $this->CVSPath;
@@ -911,8 +862,7 @@ 
      *
      * @return ArrayData
      */
-    public function getRepositoryInterface()
-    {
+    public function getRepositoryInterface() {
         $interfaces = $this->config()->repository_interfaces;
 
         /* Look for each whitelisted hostname */
@@ -955,8 +905,7 @@ 
     /**
      * @return string
      */
-    protected function getProjectFolderPath()
-    {
+    protected function getProjectFolderPath() {
         return sprintf('%s/%s', $this->DNData()->getEnvironmentDir(), $this->Name);
     }
 
@@ -966,8 +915,7 @@ 
      * @param string $code
      * @return SS_List
      */
-    public function whoIsAllowed($code)
-    {
+    public function whoIsAllowed($code) {
         return $this->whoIsAllowedAny(array($code));
     }
 
@@ -978,8 +926,7 @@ 
      * @param array|string $codes
      * @return SS_List
      */
-    public function whoIsAllowedAny($codes)
-    {
+    public function whoIsAllowedAny($codes) {
         if (!is_array($codes)) {
             $codes = array($codes);
         }
@@ -1007,8 +954,7 @@ 
      *
      * @return bool
      */
-    public function allowed($code, $member = null)
-    {
+    public function allowed($code, $member = null) {
         return $this->allowedAny(array($code), $member);
     }
 
@@ -1020,8 +966,7 @@ 
      *
      * @return bool
      */
-    public function groupAllowed($permissionCode, Group $group)
-    {
+    public function groupAllowed($permissionCode, Group $group) {
         $viewers = $this->Viewers();
         if (!$viewers->find('ID', $group->ID)) {
             return false;
@@ -1041,8 +986,7 @@ 
      *
      * @return bool
      */
-    public function allowedAny($codes, $member = null)
-    {
+    public function allowedAny($codes, $member = null) {
         if (!$member) {
             $member = Member::currentUser();
         }
@@ -1060,8 +1004,7 @@ 
      *
      * @return bool
      */
-    public function isProjectReady()
-    {
+    public function isProjectReady() {
         if ($this->getRunningInitialEnvironmentCreations()->count() > 0) {
             // We're still creating the initial environments for this project so we're
             // not quite done
@@ -1090,8 +1033,7 @@ 
      *
      * @return SS_List
      */
-    public function getRunningEnvironmentCreations()
-    {
+    public function getRunningEnvironmentCreations() {
         return $this->CreateEnvironments()
             ->filter('Status', ['Queued', 'Started']);
     }
@@ -1101,8 +1043,7 @@ 
      *
      * @return DataList
      */
-    public function getInitialEnvironmentCreations()
-    {
+    public function getInitialEnvironmentCreations() {
         return $this->CreateEnvironments()->filter('IsInitialEnvironment', true);
     }
 
@@ -1111,8 +1052,7 @@ 
      *
      * @return DataList
      */
-    public function getRunningInitialEnvironmentCreations()
-    {
+    public function getRunningInitialEnvironmentCreations() {
         return $this->getInitialEnvironmentCreations()
             ->filter('Status', ['Queued', 'Started']);
     }
@@ -1122,8 +1062,7 @@ 
      *
      * @return DataList
      */
-    public function getCompleteInitialEnvironmentCreations()
-    {
+    public function getCompleteInitialEnvironmentCreations() {
         return $this->getInitialEnvironmentCreations()
             ->exclude('Status', ['Queued', 'Started']);
     }
@@ -1131,8 +1070,7 @@ 
     /**
      * @return ValidationResult
      */
-    protected function validate()
-    {
+    protected function validate() {
         $validation = parent::validate();
         if ($validation->valid()) {
             if (empty($this->Name)) {
@@ -1164,8 +1102,7 @@ 
      *
      * @return bool
      */
-    public function canCreate($member = null)
-    {
+    public function canCreate($member = null) {
         if (!$member) {
             $member = Member::currentUser();
         }

code/model/DNQueuedCommits.php

Indentation +6 added lines, -6 removed lines

@@ -9,11 +9,11 @@
 class DNQueuedCommits extends DNFilteredCommits
 {
 
-    private $description = 'Commits that are currently queued';
+	private $description = 'Commits that are currently queued';
 
-    public function __construct()
-    {
-        parent::__construct();
-        $this->setFilter('Queued');
-    }
+	public function __construct()
+	{
+		parent::__construct();
+		$this->setFilter('Queued');
+	}
 }

Braces +2 added lines, -4 removed lines

@@ -6,13 +6,11 @@
  *  Class to represent queued commits
  *
  */
-class DNQueuedCommits extends DNFilteredCommits
-{
+class DNQueuedCommits extends DNFilteredCommits {
 
     private $description = 'Commits that are currently queued';
 
-    public function __construct()
-    {
+    public function __construct() {
         parent::__construct();
         $this->setFilter('Queued');
     }

code/model/DNReference.php

Indentation +25 added lines, -25 removed lines

@@ -3,34 +3,34 @@
 class DNReference extends ViewableData
 {
 
-    /**
-     * @var Gitonomy\Git\Reference
-     */
-    protected $reference;
+	/**
+	 * @var Gitonomy\Git\Reference
+	 */
+	protected $reference;
 
-    private static $casting = array(
-        'Name' => 'Text',
-        'FullName' => 'Text',
-        'Filename' => 'Text'
-    );
+	private static $casting = array(
+		'Name' => 'Text',
+		'FullName' => 'Text',
+		'Filename' => 'Text'
+	);
 
-    public function __construct(Gitonomy\Git\Reference $reference)
-    {
-        $this->reference = $reference;
-    }
+	public function __construct(Gitonomy\Git\Reference $reference)
+	{
+		$this->reference = $reference;
+	}
 
-    public function Name()
-    {
-        return $this->reference->getName();
-    }
+	public function Name()
+	{
+		return $this->reference->getName();
+	}
 
-    public function FullName()
-    {
-        return $this->reference->getCommitHash();
-    }
+	public function FullName()
+	{
+		return $this->reference->getCommitHash();
+	}
 
-    public function Filename()
-    {
-        return $this->reference->getFullname();
-    }
+	public function Filename()
+	{
+		return $this->reference->getFullname();
+	}
 }

Braces +5 added lines, -10 removed lines

@@ -1,7 +1,6 @@ 
 <?php
 
-class DNReference extends ViewableData
-{
+class DNReference extends ViewableData {
 
     /**
      * @var Gitonomy\Git\Reference
@@ -14,23 +13,19 @@ 
         'Filename' => 'Text'
     );
 
-    public function __construct(Gitonomy\Git\Reference $reference)
-    {
+    public function __construct(Gitonomy\Git\Reference $reference) {
         $this->reference = $reference;
     }
 
-    public function Name()
-    {
+    public function Name() {
         return $this->reference->getName();
     }
 
-    public function FullName()
-    {
+    public function FullName() {
         return $this->reference->getCommitHash();
     }
 
-    public function Filename()
-    {
+    public function Filename() {
         return $this->reference->getFullname();
     }
 }

code/model/DNReferenceList.php

Indentation +206 added lines, -206 removed lines

@@ -5,210 +5,210 @@
 class DNReferenceList extends ArrayList
 {
 
-    /**
-     * @var string
-     */
-    protected static $refs_dir = '';
-
-    /**
-     * @var bool
-     */
-    protected $loaded = false;
-
-    /**
-     * @var Reference|null
-     */
-    protected $reference = null;
-
-    /**
-     * @var null|string
-     */
-    protected $blockBranch;
-
-    /**
-     * @var array
-     */
-    protected $builds = array();
-
-    /**
-     * @var int
-     */
-    protected $limit = 10;
-
-    /**
-     * @var bool
-     */
-    protected $getTags = false;
-
-    /**
-     * @var DNProject
-     */
-    protected $project;
-
-    /**
-     * @var DNData
-     */
-    protected $data;
-
-    /**
-     * @param $refsDir
-     */
-    public static function set_refs_dir($refsDir)
-    {
-        self::$refs_dir = $refsDir;
-    }
-
-    /**
-     * @return string
-     */
-    public static function get_refs_dir()
-    {
-        return self::$refs_dir;
-    }
-
-    /**
-     * @param DNProject $project
-     * @param DNData $data
-     * @param Reference|null $reference
-     * @param string|null $blockBranch
-     * @param bool $getTags
-     */
-    public function __construct(
-        DNProject $project,
-        DNData $data,
-        Reference $reference = null,
-        $blockBranch = null,
-        $getTags = false
-    ) {
-        $this->project = $project;
-        $this->data = $data;
-        $this->reference = $reference;
-        $this->blockBranch = $blockBranch;
-        $this->getTags = $getTags;
-        parent::__construct(array());
-    }
-
-    /**
-     * @param int $limit
-     * @return DNReferenceList
-     */
-    public function setLimit($limit)
-    {
-        $this->limit = $limit;
-        return $this;
-    }
-
-    /**
-     * @return array
-     */
-    protected function getReferences()
-    {
-        try {
-            $repository = new Gitonomy\Git\Repository($this->project->getLocalCVSPath());
-        } catch (Exception $e) {
-            return array();
-        }
-
-        if ($this->getTags) {
-            if ($this->reference) {
-                throw new LogicException("Can't have \$reference and \$getTags both set");
-            }
-            $log = $repository->getReferences()->getTags();
-        } elseif ($this->reference) {
-            $log = $this->reference->getLog();
-        } else {
-            $log = $repository->getLog();
-        }
-
-        if ($this->limit) {
-            if (is_array($log)) {
-                $limitedLog = array_slice($log, 0, $this->limit);
-            } else {
-                $limitedLog = $log->setLimit($this->limit);
-            }
-        } else {
-            $limitedLog = $log;
-        }
-
-        // cache them for look up in byName
-        $builds = array();
-        foreach ($limitedLog as $reference) {
-            if (!empty($this->blockBranch)) {
-                $branchesIncluding = GitonomyCache::getIncludingBranches($reference);
-                foreach ($branchesIncluding as $candidate) {
-                    if ($candidate->getName() == $this->blockBranch) {
-                        // Break out of the function
-                        return $builds;
-                    }
-                }
-            }
-
-            if ($this->getTags) {
-                $builds[] = DNTag::create($reference, $this->project, $this->data);
-            } else {
-                $name = $this->reference ? $this->reference->getName() : '';
-                $builds[] = DNCommit::create($reference, $this->project, $this->data, $name);
-            }
-        }
-
-        return $builds;
-    }
-
-    /**
-     * Find a build in this set by hash.
-     *
-     * @param string $hash
-     * @return DNCommit
-     */
-    public function byName($hash)
-    {
-        if ($this->loaded === false) {
-            $this->items = $this->getReferences();
-            $this->loaded = true;
-        }
-
-        // The item might not be in the list because of the limit, try to find
-        // in an older version and add it to the list.
-        $found = null;
-        foreach ($this->items as $item) {
-            if ($item->SHA() == $hash) {
-                $found = $item;
-                break;
-            }
-        }
-
-        if ($found === null) {
-            $repository = new Gitonomy\Git\Repository($this->project->getLocalCVSPath());
-            $commit = new Gitonomy\Git\Commit($repository, $hash);
-            $found = DNCommit::create($commit, $this->project, $this->data);
-        }
-
-        return $found;
-    }
-
-    public function Count()
-    {
-        $this->getIterator();
-        return parent::Count();
-    }
-
-    /**
-     * Returns an Iterator for this ArrayList.
-     * This function allows you to use ArrayList in foreach loops
-     *
-     * @return ArrayIterator
-     */
-    public function getIterator()
-    {
-        if ($this->loaded === false) {
-            $this->items = $this->getReferences();
-            $this->loaded = true;
-        }
-        foreach ($this->items as $item) {
-            if (is_array($item)) {
-                $this->items[] = new ArrayData($item);
-            }
-        }
-        return new ArrayIterator($this->items);
-    }
+	/**
+	 * @var string
+	 */
+	protected static $refs_dir = '';
+
+	/**
+	 * @var bool
+	 */
+	protected $loaded = false;
+
+	/**
+	 * @var Reference|null
+	 */
+	protected $reference = null;
+
+	/**
+	 * @var null|string
+	 */
+	protected $blockBranch;
+
+	/**
+	 * @var array
+	 */
+	protected $builds = array();
+
+	/**
+	 * @var int
+	 */
+	protected $limit = 10;
+
+	/**
+	 * @var bool
+	 */
+	protected $getTags = false;
+
+	/**
+	 * @var DNProject
+	 */
+	protected $project;
+
+	/**
+	 * @var DNData
+	 */
+	protected $data;
+
+	/**
+	 * @param $refsDir
+	 */
+	public static function set_refs_dir($refsDir)
+	{
+		self::$refs_dir = $refsDir;
+	}
+
+	/**
+	 * @return string
+	 */
+	public static function get_refs_dir()
+	{
+		return self::$refs_dir;
+	}
+
+	/**
+	 * @param DNProject $project
+	 * @param DNData $data
+	 * @param Reference|null $reference
+	 * @param string|null $blockBranch
+	 * @param bool $getTags
+	 */
+	public function __construct(
+		DNProject $project,
+		DNData $data,
+		Reference $reference = null,
+		$blockBranch = null,
+		$getTags = false
+	) {
+		$this->project = $project;
+		$this->data = $data;
+		$this->reference = $reference;
+		$this->blockBranch = $blockBranch;
+		$this->getTags = $getTags;
+		parent::__construct(array());
+	}
+
+	/**
+	 * @param int $limit
+	 * @return DNReferenceList
+	 */
+	public function setLimit($limit)
+	{
+		$this->limit = $limit;
+		return $this;
+	}
+
+	/**
+	 * @return array
+	 */
+	protected function getReferences()
+	{
+		try {
+			$repository = new Gitonomy\Git\Repository($this->project->getLocalCVSPath());
+		} catch (Exception $e) {
+			return array();
+		}
+
+		if ($this->getTags) {
+			if ($this->reference) {
+				throw new LogicException("Can't have \$reference and \$getTags both set");
+			}
+			$log = $repository->getReferences()->getTags();
+		} elseif ($this->reference) {
+			$log = $this->reference->getLog();
+		} else {
+			$log = $repository->getLog();
+		}
+
+		if ($this->limit) {
+			if (is_array($log)) {
+				$limitedLog = array_slice($log, 0, $this->limit);
+			} else {
+				$limitedLog = $log->setLimit($this->limit);
+			}
+		} else {
+			$limitedLog = $log;
+		}
+
+		// cache them for look up in byName
+		$builds = array();
+		foreach ($limitedLog as $reference) {
+			if (!empty($this->blockBranch)) {
+				$branchesIncluding = GitonomyCache::getIncludingBranches($reference);
+				foreach ($branchesIncluding as $candidate) {
+					if ($candidate->getName() == $this->blockBranch) {
+						// Break out of the function
+						return $builds;
+					}
+				}
+			}
+
+			if ($this->getTags) {
+				$builds[] = DNTag::create($reference, $this->project, $this->data);
+			} else {
+				$name = $this->reference ? $this->reference->getName() : '';
+				$builds[] = DNCommit::create($reference, $this->project, $this->data, $name);
+			}
+		}
+
+		return $builds;
+	}
+
+	/**
+	 * Find a build in this set by hash.
+	 *
+	 * @param string $hash
+	 * @return DNCommit
+	 */
+	public function byName($hash)
+	{
+		if ($this->loaded === false) {
+			$this->items = $this->getReferences();
+			$this->loaded = true;
+		}
+
+		// The item might not be in the list because of the limit, try to find
+		// in an older version and add it to the list.
+		$found = null;
+		foreach ($this->items as $item) {
+			if ($item->SHA() == $hash) {
+				$found = $item;
+				break;
+			}
+		}
+
+		if ($found === null) {
+			$repository = new Gitonomy\Git\Repository($this->project->getLocalCVSPath());
+			$commit = new Gitonomy\Git\Commit($repository, $hash);
+			$found = DNCommit::create($commit, $this->project, $this->data);
+		}
+
+		return $found;
+	}
+
+	public function Count()
+	{
+		$this->getIterator();
+		return parent::Count();
+	}
+
+	/**
+	 * Returns an Iterator for this ArrayList.
+	 * This function allows you to use ArrayList in foreach loops
+	 *
+	 * @return ArrayIterator
+	 */
+	public function getIterator()
+	{
+		if ($this->loaded === false) {
+			$this->items = $this->getReferences();
+			$this->loaded = true;
+		}
+		foreach ($this->items as $item) {
+			if (is_array($item)) {
+				$this->items[] = new ArrayData($item);
+			}
+		}
+		return new ArrayIterator($this->items);
+	}
 }

Spacing +18 added lines, -18 removed lines

@@ -105,23 +105,23 @@ 
     {
         try {
             $repository = new Gitonomy\Git\Repository($this->project->getLocalCVSPath());
-        } catch (Exception $e) {
+        } catch(Exception $e) {
             return array();
         }
 
-        if ($this->getTags) {
-            if ($this->reference) {
+        if($this->getTags) {
+            if($this->reference) {
                 throw new LogicException("Can't have \$reference and \$getTags both set");
             }
             $log = $repository->getReferences()->getTags();
-        } elseif ($this->reference) {
+        } elseif($this->reference) {
             $log = $this->reference->getLog();
         } else {
             $log = $repository->getLog();
         }
 
-        if ($this->limit) {
-            if (is_array($log)) {
+        if($this->limit) {
+            if(is_array($log)) {
                 $limitedLog = array_slice($log, 0, $this->limit);
             } else {
                 $limitedLog = $log->setLimit($this->limit);
@@ -132,18 +132,18 @@ 
 
         // cache them for look up in byName
         $builds = array();
-        foreach ($limitedLog as $reference) {
-            if (!empty($this->blockBranch)) {
+        foreach($limitedLog as $reference) {
+            if(!empty($this->blockBranch)) {
                 $branchesIncluding = GitonomyCache::getIncludingBranches($reference);
-                foreach ($branchesIncluding as $candidate) {
-                    if ($candidate->getName() == $this->blockBranch) {
+                foreach($branchesIncluding as $candidate) {
+                    if($candidate->getName() == $this->blockBranch) {
                         // Break out of the function
                         return $builds;
                     }
                 }
             }
 
-            if ($this->getTags) {
+            if($this->getTags) {
                 $builds[] = DNTag::create($reference, $this->project, $this->data);
             } else {
                 $name = $this->reference ? $this->reference->getName() : '';
@@ -162,7 +162,7 @@ 
      */
     public function byName($hash)
     {
-        if ($this->loaded === false) {
+        if($this->loaded === false) {
             $this->items = $this->getReferences();
             $this->loaded = true;
         }
@@ -170,14 +170,14 @@ 
         // The item might not be in the list because of the limit, try to find
         // in an older version and add it to the list.
         $found = null;
-        foreach ($this->items as $item) {
-            if ($item->SHA() == $hash) {
+        foreach($this->items as $item) {
+            if($item->SHA() == $hash) {
                 $found = $item;
                 break;
             }
         }
 
-        if ($found === null) {
+        if($found === null) {
             $repository = new Gitonomy\Git\Repository($this->project->getLocalCVSPath());
             $commit = new Gitonomy\Git\Commit($repository, $hash);
             $found = DNCommit::create($commit, $this->project, $this->data);
@@ -200,12 +200,12 @@ 
      */
     public function getIterator()
     {
-        if ($this->loaded === false) {
+        if($this->loaded === false) {
             $this->items = $this->getReferences();
             $this->loaded = true;
         }
-        foreach ($this->items as $item) {
-            if (is_array($item)) {
+        foreach($this->items as $item) {
+            if(is_array($item)) {
                 $this->items[] = new ArrayData($item);
             }
         }

Braces +8 added lines, -16 removed lines

@@ -2,8 +2,7 @@ 
 
 use Gitonomy\Git\Reference;
 
-class DNReferenceList extends ArrayList
-{
+class DNReferenceList extends ArrayList {
 
     /**
      * @var string
@@ -53,16 +52,14 @@ 
     /**
      * @param $refsDir
      */
-    public static function set_refs_dir($refsDir)
-    {
+    public static function set_refs_dir($refsDir) {
         self::$refs_dir = $refsDir;
     }
 
     /**
      * @return string
      */
-    public static function get_refs_dir()
-    {
+    public static function get_refs_dir() {
         return self::$refs_dir;
     }
 
@@ -92,8 +89,7 @@ 
      * @param int $limit
      * @return DNReferenceList
      */
-    public function setLimit($limit)
-    {
+    public function setLimit($limit) {
         $this->limit = $limit;
         return $this;
     }
@@ -101,8 +97,7 @@ 
     /**
      * @return array
      */
-    protected function getReferences()
-    {
+    protected function getReferences() {
         try {
             $repository = new Gitonomy\Git\Repository($this->project->getLocalCVSPath());
         } catch (Exception $e) {
@@ -160,8 +155,7 @@ 
      * @param string $hash
      * @return DNCommit
      */
-    public function byName($hash)
-    {
+    public function byName($hash) {
         if ($this->loaded === false) {
             $this->items = $this->getReferences();
             $this->loaded = true;
@@ -186,8 +180,7 @@ 
         return $found;
     }
 
-    public function Count()
-    {
+    public function Count() {
         $this->getIterator();
         return parent::Count();
     }
@@ -198,8 +191,7 @@ 
      *
      * @return ArrayIterator
      */
-    public function getIterator()
-    {
+    public function getIterator() {
         if ($this->loaded === false) {
             $this->items = $this->getReferences();
             $this->loaded = true;