mirror of
https://github.com/hauke68/Magallanes.git
synced 2026-08-28 10:08:56 +02:00
Major overhauling and refactoring of Magallanes Command and Tasks modulairty and workflow.
ADVICE: there is no Backwards Compatibility with custom tasks, those using the _config instance will be broken or those using the getEnvironmentName().
This commit is contained in:
@@ -10,15 +10,15 @@ class Mage_Task_BuiltIn_Deployment_Releases
|
||||
|
||||
public function run()
|
||||
{
|
||||
if ($this->_config->release('enabled', false) == true) {
|
||||
$releasesDirectory = $this->_config->release('directory', 'releases');
|
||||
$symlink = $this->_config->release('symlink', 'current');
|
||||
if ($this->getConfig()->release('enabled', false) == true) {
|
||||
$releasesDirectory = $this->getConfig()->release('directory', 'releases');
|
||||
$symlink = $this->getConfig()->release('symlink', 'current');
|
||||
|
||||
if (substr($symlink, 0, 1) == '/') {
|
||||
$releasesDirectory = rtrim($this->_config->deployment('to'), '/') . '/' . $releasesDirectory;
|
||||
$releasesDirectory = rtrim($this->getConfig()->deployment('to'), '/') . '/' . $releasesDirectory;
|
||||
}
|
||||
|
||||
$currentCopy = $releasesDirectory . '/' . $this->_config->getReleaseId();
|
||||
$currentCopy = $releasesDirectory . '/' . $this->getConfig()->getReleaseId();
|
||||
|
||||
// Fetch the user and group from base directory
|
||||
$userGroup = '33:33';
|
||||
@@ -35,7 +35,7 @@ class Mage_Task_BuiltIn_Deployment_Releases
|
||||
$result = $this->_runRemoteCommand($command);
|
||||
|
||||
// Count Releases
|
||||
$maxReleases = $this->_config->release('max', false);
|
||||
$maxReleases = $this->getConfig()->release('max', false);
|
||||
if (($maxReleases !== false) && ($maxReleases > 0)) {
|
||||
$releasesList = '';
|
||||
$countReleasesFetch = $this->_runRemoteCommand('ls -1 ' . $releasesDirectory, $releasesList);
|
||||
@@ -44,7 +44,7 @@ class Mage_Task_BuiltIn_Deployment_Releases
|
||||
if ($releasesList != '') {
|
||||
$releasesList = explode(PHP_EOL, $releasesList);
|
||||
if (count($releasesList) > $maxReleases) {
|
||||
$releasesToDelete = array_diff($releasesList, array($this->_config->getReleaseId()));
|
||||
$releasesToDelete = array_diff($releasesList, array($this->getConfig()->getReleaseId()));
|
||||
sort($releasesToDelete);
|
||||
$releasesToDeleteCount = count($releasesToDelete) - $maxReleases;
|
||||
$releasesToDelete = array_slice($releasesToDelete, 0, $releasesToDeleteCount + 1);
|
||||
|
||||
@@ -5,11 +5,11 @@ class Mage_Task_BuiltIn_Deployment_Rsync
|
||||
{
|
||||
public function getName()
|
||||
{
|
||||
if ($this->_config->release('enabled', false) == true) {
|
||||
if ($this->getActionOption('overrideRelease', false) == true) {
|
||||
if ($this->getConfig()->release('enabled', false) == true) {
|
||||
if ($this->getConfig()->getParameter('overrideRelease', false) == true) {
|
||||
return 'Rsync (with Releases override) [built-in]';
|
||||
} else {
|
||||
return 'Rsync (with Releases) [built-in]';
|
||||
return 'Rsync (with Releases) [built-in]';
|
||||
}
|
||||
} else {
|
||||
return 'Rsync [built-in]';
|
||||
@@ -18,13 +18,13 @@ class Mage_Task_BuiltIn_Deployment_Rsync
|
||||
|
||||
public function run()
|
||||
{
|
||||
$overrideRelease = $this->getActionOption('overrideRelease', false);
|
||||
|
||||
$overrideRelease = $this->getConfig()->getParameter('overrideRelease', false);
|
||||
|
||||
if ($overrideRelease == true) {
|
||||
$releaseToOverride = false;
|
||||
$resultFetch = $this->_runRemoteCommand('ls -ld current | cut -d\"/\" -f2', $releaseToOverride);
|
||||
if (is_numeric($releaseToOverride)) {
|
||||
$this->_config->setReleaseId($releaseToOverride);
|
||||
$this->getConfig()->setReleaseId($releaseToOverride);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -34,39 +34,39 @@ class Mage_Task_BuiltIn_Deployment_Rsync
|
||||
'.mage',
|
||||
'.gitignore'
|
||||
);
|
||||
|
||||
// Look for User Excludes
|
||||
$userExcludes = $this->_config->deployment('excludes', array());
|
||||
|
||||
// If we are working with releases
|
||||
$deployToDirectory = $this->_config->deployment('to');
|
||||
if ($this->_config->release('enabled', false) == true) {
|
||||
$releasesDirectory = $this->_config->release('directory', 'releases');
|
||||
|
||||
$deployToDirectory = rtrim($this->_config->deployment('to'), '/')
|
||||
// Look for User Excludes
|
||||
$userExcludes = $this->getConfig()->deployment('excludes', array());
|
||||
|
||||
// If we are working with releases
|
||||
$deployToDirectory = $this->getConfig()->deployment('to');
|
||||
if ($this->getConfig()->release('enabled', false) == true) {
|
||||
$releasesDirectory = $this->getConfig()->release('directory', 'releases');
|
||||
|
||||
$deployToDirectory = rtrim($this->getConfig()->deployment('to'), '/')
|
||||
. '/' . $releasesDirectory
|
||||
. '/' . $this->_config->getReleaseId();
|
||||
$this->_runRemoteCommand('mkdir -p ' . $releasesDirectory . '/' . $this->_config->getReleaseId());
|
||||
. '/' . $this->getConfig()->getReleaseId();
|
||||
$this->_runRemoteCommand('mkdir -p ' . $releasesDirectory . '/' . $this->getConfig()->getReleaseId());
|
||||
}
|
||||
|
||||
$command = 'rsync -avz '
|
||||
. '--rsh="ssh -p' . $this->_config->getHostPort() . '" '
|
||||
. '--rsh="ssh -p' . $this->getConfig()->getHostPort() . '" '
|
||||
. $this->_excludes(array_merge($excludes, $userExcludes)) . ' '
|
||||
. $this->_config->deployment('from') . ' '
|
||||
. $this->_config->deployment('user') . '@' . $this->_config->getHostName() . ':' . $deployToDirectory;
|
||||
. $this->getConfig()->deployment('from') . ' '
|
||||
. $this->getConfig()->deployment('user') . '@' . $this->getConfig()->getHostName() . ':' . $deployToDirectory;
|
||||
|
||||
$result = $this->_runLocalCommand($command);
|
||||
|
||||
|
||||
return $result;
|
||||
}
|
||||
|
||||
|
||||
private function _excludes(Array $excludes)
|
||||
{
|
||||
$excludesRsync = '';
|
||||
foreach ($excludes as $exclude) {
|
||||
$excludesRsync .= ' --exclude ' . $exclude . ' ';
|
||||
}
|
||||
|
||||
|
||||
$excludesRsync = trim($excludesRsync);
|
||||
return $excludesRsync;
|
||||
}
|
||||
|
||||
@@ -10,16 +10,22 @@ class Mage_Task_BuiltIn_Releases_List
|
||||
|
||||
public function run()
|
||||
{
|
||||
if ($this->_config->release('enabled', false) == true) {
|
||||
$releasesDirectory = $this->_config->release('directory', 'releases');
|
||||
$symlink = $this->_config->release('symlink', 'current');
|
||||
if ($this->getConfig()->release('enabled', false) == true) {
|
||||
$releasesDirectory = $this->getConfig()->release('directory', 'releases');
|
||||
$symlink = $this->getConfig()->release('symlink', 'current');
|
||||
|
||||
Mage_Console::output('Releases available on <dark_gray>' . $this->_config->getHost() . '</dark_gray>');
|
||||
|
||||
Mage_Console::output('Releases available on <dark_gray>' . $this->getConfig()->getHost() . '</dark_gray>');
|
||||
|
||||
// Get Releases
|
||||
$output = '';
|
||||
$result = $this->_runRemoteCommand('ls -1 ' . $releasesDirectory, $output);
|
||||
$releases = ($output == '') ? array() : explode(PHP_EOL, $output);
|
||||
|
||||
|
||||
// Get Current
|
||||
$result = $this->_runRemoteCommand('ls -l ' . $symlink, $output);
|
||||
$currentRelease = explode('/', $output);
|
||||
$currentRelease = trim(array_pop($currentRelease));
|
||||
|
||||
if (count($releases) == 0) {
|
||||
Mage_Console::output('<dark_gray>No releases available</dark_gray> ... ', 2);
|
||||
} else {
|
||||
@@ -27,6 +33,7 @@ class Mage_Task_BuiltIn_Releases_List
|
||||
$releases = array_slice($releases, 0, 10);
|
||||
|
||||
foreach ($releases as $releaseIndex => $release) {
|
||||
$release = trim($release);
|
||||
$releaseIndex = str_pad($releaseIndex * -1, 2, ' ', STR_PAD_LEFT);
|
||||
$releaseDate = $release[0] . $release[1] . $release[2] .$release[3]
|
||||
. '-'
|
||||
@@ -39,11 +46,16 @@ class Mage_Task_BuiltIn_Releases_List
|
||||
. $release[10] . $release[11]
|
||||
. ':'
|
||||
. $release[12] . $release[13];
|
||||
|
||||
|
||||
$isCurrent = '';
|
||||
if ($currentRelease == $release) {
|
||||
$isCurrent = ' <- current';
|
||||
}
|
||||
|
||||
Mage_Console::output(
|
||||
'Release: <purple>' . $release . '</purple> '
|
||||
. '- Date: <dark_gray>' . $releaseDate . '</dark_gray> '
|
||||
. '- Index: <dark_gray>' . $releaseIndex . '</dark_gray>', 2);
|
||||
. '- Index: <dark_gray>' . $releaseIndex . '</dark_gray>' . $isCurrent, 2);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -4,7 +4,7 @@ class Mage_Task_BuiltIn_Releases_Rollback
|
||||
implements Mage_Task_Releases_BuiltIn
|
||||
{
|
||||
private $_release = null;
|
||||
|
||||
|
||||
public function getName()
|
||||
{
|
||||
return 'Rollback release [built-in]';
|
||||
@@ -15,31 +15,32 @@ class Mage_Task_BuiltIn_Releases_Rollback
|
||||
$this->_release = $releaseId;
|
||||
return $this;
|
||||
}
|
||||
|
||||
|
||||
public function getRelease()
|
||||
{
|
||||
return $this->_release;
|
||||
}
|
||||
|
||||
|
||||
public function run()
|
||||
{
|
||||
if ($this->_config->release('enabled', false) == true) {
|
||||
$releasesDirectory = $this->_config->release('directory', 'releases');
|
||||
$symlink = $this->_config->release('symlink', 'current');
|
||||
|
||||
if ($this->getConfig()->release('enabled', false) == true) {
|
||||
$releasesDirectory = $this->getConfig()->release('directory', 'releases');
|
||||
$symlink = $this->getConfig()->release('symlink', 'current');
|
||||
|
||||
$output = '';
|
||||
$result = $this->_runRemoteCommand('ls -1 ' . $releasesDirectory, $output);
|
||||
$releases = ($output == '') ? array() : explode(PHP_EOL, $output);
|
||||
|
||||
|
||||
if (count($releases) == 0) {
|
||||
Mage_Console::output('Release are not available for <dark_gray>' . $this->_config->getHost() . '</dark_gray> ... <red>FAIL</red>');
|
||||
Mage_Console::output('Release are not available for <dark_gray>' . $this->getConfig()->getHost() . '</dark_gray> ... <red>FAIL</red>');
|
||||
|
||||
} else {
|
||||
rsort($releases);
|
||||
|
||||
|
||||
$releaseIsAvailable = false;
|
||||
if ($this->getRelease() == '') {
|
||||
$releaseId = $releases[0];
|
||||
$releaseIsAvailable = true;
|
||||
|
||||
} else if ($this->getRelease() <= 0) {
|
||||
$index = $this->getRelease() * -1;
|
||||
@@ -53,34 +54,34 @@ class Mage_Task_BuiltIn_Releases_Rollback
|
||||
$releaseIsAvailable = true;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
if (!$releaseIsAvailable) {
|
||||
Mage_Console::output('Release <dark_gray>' . $this->getRelease() . '</dark_gray> is invalid or unavailable for <dark_gray>' . $this->_config->getHost() . '</dark_gray> ... <red>FAIL</red>');
|
||||
Mage_Console::output('Release <dark_gray>' . $this->getRelease() . '</dark_gray> is invalid or unavailable for <dark_gray>' . $this->getConfig()->getHost() . '</dark_gray> ... <red>FAIL</red>');
|
||||
|
||||
} else {
|
||||
Mage_Console::output('Rollback release on <dark_gray>' . $this->_config->getHost() . '</dark_gray>');
|
||||
Mage_Console::output('Rollback release on <dark_gray>' . $this->getConfig()->getHost() . '</dark_gray>');
|
||||
$rollbackTo = $releasesDirectory . '/' . $releaseId;
|
||||
|
||||
|
||||
// Tasks
|
||||
$tasks = 1;
|
||||
$completedTasks = 0;
|
||||
$tasksToRun = $this->_config->getTasks();
|
||||
$this->_config->setReleaseId($releaseId);
|
||||
|
||||
$tasksToRun = $this->getConfig()->getTasks();
|
||||
$this->getConfig()->setReleaseId($releaseId);
|
||||
|
||||
if (count($tasksToRun) == 0) {
|
||||
Mage_Console::output('<light_purple>Warning!</light_purple> <dark_gray>No </dark_gray><light_cyan>Deployment</light_cyan> <dark_gray>tasks defined.</dark_gray>', 2);
|
||||
Mage_Console::output('Deployment to <dark_gray>' . $this->_config->getHost() . '</dark_gray> skipped!', 1, 3);
|
||||
|
||||
Mage_Console::output('Deployment to <dark_gray>' . $this->getConfig()->getHost() . '</dark_gray> skipped!', 1, 3);
|
||||
|
||||
} else {
|
||||
foreach ($tasksToRun as $taskName) {
|
||||
$task = Mage_Task_Factory::get($taskName, $this->_config, true, 'deploy');
|
||||
$task = Mage_Task_Factory::get($taskName, $this->getConfig(), true, 'deploy');
|
||||
$task->init();
|
||||
Mage_Console::output('Running <purple>' . $task->getName() . '</purple> ... ', 2, false);
|
||||
|
||||
|
||||
if ($task instanceOf Mage_Task_Releases_RollbackAware) {
|
||||
$tasks++;
|
||||
$result = $task->run();
|
||||
|
||||
|
||||
if ($result == true) {
|
||||
Mage_Console::output('<green>OK</green>', 0);
|
||||
$completedTasks++;
|
||||
@@ -88,14 +89,14 @@ class Mage_Task_BuiltIn_Releases_Rollback
|
||||
Mage_Console::output('<red>FAIL</red>', 0);
|
||||
}
|
||||
} else {
|
||||
Mage_Console::output('<yellow>SKIPPED</yellow>', 0);
|
||||
Mage_Console::output('<yellow>SKIPPED</yellow>', 0);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
// Changing Release
|
||||
Mage_Console::output('Running <purple>Rollback Release [id=' . $releaseId . ']</purple> ... ', 2, false);
|
||||
|
||||
|
||||
$userGroup = '';
|
||||
$resultFetch = $this->_runRemoteCommand('ls -ld ' . $rollbackTo . ' | awk \'{print \$3\":\"\$4}\'', $userGroup);
|
||||
$command = 'rm -f ' . $symlink
|
||||
@@ -111,14 +112,14 @@ class Mage_Task_BuiltIn_Releases_Rollback
|
||||
} else {
|
||||
Mage_Console::output('<red>FAIL</red>', 0);
|
||||
}
|
||||
|
||||
|
||||
if ($completedTasks == $tasks) {
|
||||
$tasksColor = 'green';
|
||||
} else {
|
||||
$tasksColor = 'red';
|
||||
}
|
||||
|
||||
Mage_Console::output('Release rollback on <dark_gray>' . $this->_config->getHost() . '</dark_gray> compted: <' . $tasksColor . '>' . $completedTasks . '/' . $tasks . '</' . $tasksColor . '> tasks done.', 1, 3);
|
||||
|
||||
Mage_Console::output('Release rollback on <dark_gray>' . $this->getConfig()->getHost() . '</dark_gray> compted: <' . $tasksColor . '>' . $completedTasks . '/' . $tasks . '</' . $tasksColor . '> tasks done.', 1, 3);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -4,15 +4,15 @@ class Mage_Task_BuiltIn_Scm_Clone
|
||||
{
|
||||
private $_name = 'SCM Clone [built-in]';
|
||||
private $_source = null;
|
||||
|
||||
|
||||
public function getName()
|
||||
{
|
||||
return $this->_name;
|
||||
}
|
||||
|
||||
|
||||
public function init()
|
||||
{
|
||||
$this->_source = $this->_config->deployment('source');
|
||||
$this->_source = $this->getConfig()->deployment('source');
|
||||
switch ($this->_source['type']) {
|
||||
case 'git':
|
||||
$this->_name = 'SCM Clone (GIT) [built-in]';
|
||||
@@ -23,7 +23,7 @@ class Mage_Task_BuiltIn_Scm_Clone
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public function run()
|
||||
{
|
||||
$this->_runLocalCommand('mkdir -p ' . $this->_source['temporal']);
|
||||
@@ -39,14 +39,14 @@ class Mage_Task_BuiltIn_Scm_Clone
|
||||
. 'git checkout ' . $this->_source['from'];
|
||||
$result = $result && $this->_runLocalCommand($command);
|
||||
|
||||
$this->_config->setFrom($this->_source['temporal']);
|
||||
$this->getConfig()->setFrom($this->_source['temporal']);
|
||||
break;
|
||||
|
||||
case 'svn':
|
||||
return false;
|
||||
break;
|
||||
}
|
||||
|
||||
|
||||
return $result;
|
||||
}
|
||||
}
|
||||
@@ -4,17 +4,17 @@ class Mage_Task_BuiltIn_Scm_RemoveClone
|
||||
{
|
||||
private $_name = 'SCM Remove Clone [built-in]';
|
||||
private $_source = null;
|
||||
|
||||
|
||||
public function getName()
|
||||
{
|
||||
return $this->_name;
|
||||
}
|
||||
|
||||
public function init()
|
||||
public function init()
|
||||
{
|
||||
$this->_source = $this->_config->deployment('source');
|
||||
$this->_source = $this->getConfig()->deployment('source');
|
||||
}
|
||||
|
||||
|
||||
public function run()
|
||||
{
|
||||
return $this->_runLocalCommand('rm -rf ' . $this->_source['temporal']);
|
||||
|
||||
@@ -11,7 +11,7 @@ class Mage_Task_BuiltIn_Scm_Update
|
||||
|
||||
public function init()
|
||||
{
|
||||
switch ($this->_config->scm('type')) {
|
||||
switch ($this->getConfig()->scm('type')) {
|
||||
case 'git':
|
||||
$this->_name = 'SCM Update (GIT) [built-in]';
|
||||
break;
|
||||
@@ -24,7 +24,7 @@ class Mage_Task_BuiltIn_Scm_Update
|
||||
|
||||
public function run()
|
||||
{
|
||||
switch ($this->_config->scm('type')) {
|
||||
switch ($this->getConfig()->scm('type')) {
|
||||
case 'git':
|
||||
$command = 'git pull';
|
||||
break;
|
||||
@@ -32,10 +32,14 @@ class Mage_Task_BuiltIn_Scm_Update
|
||||
case 'svn':
|
||||
$command = 'svn update';
|
||||
break;
|
||||
|
||||
default:
|
||||
return false;
|
||||
break;
|
||||
}
|
||||
|
||||
$result = $this->_runLocalCommand($command);
|
||||
$this->_config->reloadConfig();
|
||||
$this->getConfig()->reload();
|
||||
|
||||
return $result;
|
||||
}
|
||||
|
||||
@@ -0,0 +1,4 @@
|
||||
<?php
|
||||
interface Mage_Task_Releases_SkipOnOverride
|
||||
{
|
||||
}
|
||||
+10
-15
@@ -4,47 +4,42 @@ abstract class Mage_Task_TaskAbstract
|
||||
protected $_config = null;
|
||||
protected $_inRollback = false;
|
||||
protected $_stage = null;
|
||||
|
||||
|
||||
public abstract function getName();
|
||||
|
||||
|
||||
public abstract function run();
|
||||
|
||||
|
||||
public final function __construct(Mage_Config $config, $inRollback = false, $stage = null)
|
||||
{
|
||||
$this->_config = $config;
|
||||
$this->_inRollback = $inRollback;
|
||||
$this->_stage = $stage;
|
||||
}
|
||||
|
||||
|
||||
public function inRollback()
|
||||
{
|
||||
return $this->_inRollback;
|
||||
}
|
||||
|
||||
|
||||
public function getStage()
|
||||
{
|
||||
return $this->_stage;
|
||||
}
|
||||
|
||||
|
||||
public function getConfig()
|
||||
{
|
||||
return $this->_config;
|
||||
}
|
||||
|
||||
public function getActionOption($name, $value = false)
|
||||
{
|
||||
return Mage_Console::getActionOption($name, $value);
|
||||
}
|
||||
|
||||
|
||||
public function init()
|
||||
{
|
||||
}
|
||||
|
||||
|
||||
protected final function _runLocalCommand($command, &$output = null)
|
||||
{
|
||||
return Mage_Console::executeCommand($command, $output);
|
||||
}
|
||||
|
||||
|
||||
protected final function _runRemoteCommand($command, &$output = null)
|
||||
{
|
||||
if ($this->_config->release('enabled', false) == true) {
|
||||
@@ -61,7 +56,7 @@ abstract class Mage_Task_TaskAbstract
|
||||
} else {
|
||||
$releasesDirectory = '';
|
||||
}
|
||||
|
||||
|
||||
$localCommand = 'ssh -p ' . $this->_config->getHostPort() . ' '
|
||||
. '-q -o UserKnownHostsFile=/dev/null -o StrictHostKeyChecking=no '
|
||||
. $this->_config->deployment('user') . '@' . $this->_config->getHostName() . ' '
|
||||
|
||||
Reference in New Issue
Block a user