diff options
Diffstat (limited to 'plugins/TestRunner/Aws/Instance.php')
| -rw-r--r-- | plugins/TestRunner/Aws/Instance.php | 191 |
1 files changed, 0 insertions, 191 deletions
diff --git a/plugins/TestRunner/Aws/Instance.php b/plugins/TestRunner/Aws/Instance.php deleted file mode 100644 index db706e36e0..0000000000 --- a/plugins/TestRunner/Aws/Instance.php +++ /dev/null @@ -1,191 +0,0 @@ -<?php -/** - * Matomo - free/libre analytics platform - * - * @link https://matomo.org - * @license http://www.gnu.org/licenses/gpl-3.0.html GPL v3 or later - * - */ - -namespace Piwik\Plugins\TestRunner\Aws; - -use Symfony\Component\Console\Input\InputArgument; -use Symfony\Component\Console\Input\InputInterface; -use Symfony\Component\Console\Input\InputOption; -use Symfony\Component\Console\Output\OutputInterface; -use Aws\Ec2\Ec2Client; - -class Instance -{ - - /** - * @var Config - */ - private $config; - - /** - * @var Ec2Client - */ - private $client; - - private $testSuite; - - private $useOneInstancePerTestSuite = false; - - public function __construct(Config $config, $testSuite) - { - $this->config = $config; - $this->testSuite = $testSuite; - $this->client = $this->createEc2Client(); - } - - public function enableUseOneInstancePerTestSuite() - { - $this->useOneInstancePerTestSuite = true; - } - - public function findExisting() - { - $filters = array( - array('Name' => 'image-id', 'Values' => array($this->config->getAmi())), - array('Name' => 'key-name', 'Values' => array($this->config->getKeyName())), - array('Name' => 'instance-state-name', 'Values' => array('running')), - ); - - if (!empty($this->testSuite) && $this->useOneInstancePerTestSuite) { - $filters[] = array('Name' => 'tag:TestSuite', 'Values' => array($this->testSuite)); - } - - $instances = $this->client->describeInstances(array('Filters' => $filters)); - - $reservations = $instances->getPath('Reservations'); - - if (!empty($reservations)) { - $host = $this->getHostFromDescribedInstances($instances); - - $instanceIds = $instances->getPath('Reservations/*/Instances/*/InstanceId'); - $this->verifySetup($instanceIds); - - return $host; - } - } - - public function terminate($instanceIds) - { - $this->client->terminateInstances(array( - 'InstanceIds' => $instanceIds - )); - - $this->client->waitUntilInstanceTerminated(array( - 'InstanceIds' => $instanceIds - )); - } - - public function launch() - { - // user data is executed when instance launches, it is important that this file starts with "#!" - $userData = file_get_contents(PIWIK_INCLUDE_PATH . '/plugins/TestRunner/scripts/on_instance_launch.sh'); - - $result = $this->client->runInstances(array( - 'ImageId' => $this->config->getAmi(), - 'MinCount' => 1, - 'MaxCount' => 1, - 'InstanceType' => $this->config->getInstanceType(), - 'KeyName' => $this->config->getKeyName(), - 'SecurityGroups' => $this->config->getSecurityGroups(), - 'InstanceInitiatedShutdownBehavior' => 'terminate', - 'UserData' => base64_encode($userData) - )); - - $instanceIds = $result->getPath('Instances/*/InstanceId'); - - $this->client->waitUntilInstanceRunning(array( - 'InstanceIds' => $instanceIds, - )); - - return $instanceIds; - } - - public function setup($instanceIds) - { - $awsCloudWatch = new CloudWatch($this->config); - $awsCloudWatch->terminateInstanceIfIdleForTooLong($instanceIds); - - $awsTags = new Tags($this->client); - $awsTags->assignTagsToInstances($instanceIds, $this->testSuite); - - $instances = $this->client->describeInstances(array( - 'InstanceIds' => $instanceIds, - )); - - $host = $this->getHostFromDescribedInstances($instances); - - return $host; - } - - public function verifySetup($instanceIds) - { - $awsCloudWatch = new CloudWatch($this->config); - $hasAlarms = $awsCloudWatch->hasAssignedAlarms($instanceIds); - - if (!$hasAlarms) { - $this->setup($instanceIds); // try setup again - - $hasAlarms = $awsCloudWatch->hasAssignedAlarms($instanceIds); - - if (!$hasAlarms) { // declare it as failed if it still does not work - throw new \Exception('Failed to assign alarms for InstanceIds: ' . implode(', ' , $instanceIds)); - } - } - } - - /** - * @param \Guzzle\Service\Resource\Model $resources - * @return mixed - */ - private function getHostFromDescribedInstances($resources) - { - $instances = $resources->getPath('Reservations/*/Instances'); - - if (empty($instances)) { - return; - } - - $instanceToUse = null; - - foreach ($instances as $index => $instance) { - if (!empty($instance['Tags'])) { - foreach ($instance['Tags'] as $tag) { - if (!empty($this->testSuite) - && $tag['Key'] === 'TestSuite' - && $tag['Value'] === $this->testSuite) { - - $instanceToUse = $instance; - } - } - } - } - - if (empty($instanceToUse)) { - $instanceToUse = array_shift($instances); - } - - $host = $instanceToUse['PublicDnsName']; - - return $host; - } - - private function createEc2Client() - { - return Ec2Client::factory($this->getConnectionOptions()); - } - - private function getConnectionOptions() - { - return array( - 'key' => $this->config->getAccessKey(), - 'secret' => $this->config->getSecretKey(), - 'region' => $this->config->getRegion() - ); - } -}
\ No newline at end of file |