Shiloh/lasthourcloud
Shiloh/lasthourcloud
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases 4 Wiki Activity

feat: add runRemoteCommandSync

Browse Source
This commit is contained in:
Andras Bacsai 2023-03-31 09:42:05 +02:00
parent 00ae88b6b6
commit 47d3ac3ef5
2 changed files with 19 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
app/Jobs/ContainerStatusJob.php
View File

@ -32,10 +32,7 @@ public function handle(): void
$not_found_applications = $applications; $not_found_applications = $applications;
$containers = collect(); $containers = collect();
foreach ($servers as $server) { foreach ($servers as $server) {
$private_key_location = savePrivateKey($server); $output = runRemoteCommandSync($server, ['docker ps -a -q --format \'{{json .}}\'']);
$ssh_command = generateSshCommand($private_key_location, $server->ip, $server->user, $server->port, 'docker ps -a -q --format \'{{json .}}\'');
$process = Process::run($ssh_command);
$output = trim($process->output());
$containers = $containers->concat(formatDockerCmdOutputToJson($output)); $containers = $containers->concat(formatDockerCmdOutputToJson($output));
} }
foreach ($containers as $container) { foreach ($containers as $container) {
@ -48,13 +45,13 @@ public function handle(): void
}); });
$found_application->status = $container['State']; $found_application->status = $container['State'];
$found_application->save(); $found_application->save();
Log::info('Found application: ' . $found_application->uuid . '.Set status to: ' . $found_application->status); Log::info('Found application: ' . $found_application->uuid . '. Set status to: ' . $found_application->status);
} }
} }
foreach ($not_found_applications as $not_found_application) { foreach ($not_found_applications as $not_found_application) {
$not_found_application->status = 'exited'; $not_found_application->status = 'exited';
$not_found_application->save(); $not_found_application->save();
Log::info('Not found application: ' . $not_found_application->uuid . '.Set status to: ' . $not_found_application->status); Log::info('Not found application: ' . $not_found_application->uuid . '. Set status to: ' . $not_found_application->status);
} }
} catch (\Exception $e) { } catch (\Exception $e) {
Log::error($e->getMessage()); Log::error($e->getMessage());

16
bootstrap/helpers.php
View File

@ -7,6 +7,7 @@
use Illuminate\Database\Eloquent\Model; use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Collection; use Illuminate\Support\Collection;
use Illuminate\Support\Facades\Log; use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Process;
use Illuminate\Support\Facades\Storage; use Illuminate\Support\Facades\Storage;
use Spatie\Activitylog\Contracts\Activity; use Spatie\Activitylog\Contracts\Activity;
@ -113,3 +114,18 @@ function formatDockerLabelsToJson($rawOutput): Collection
})[0]; })[0];
} }
} }
if (!function_exists('runRemoteCommandSync')) {
function runRemoteCommandSync($server, array $command) {
$command_string = implode("\n", $command);
$private_key_location = savePrivateKey($server);
$ssh_command = generateSshCommand($private_key_location, $server->ip, $server->user, $server->port, $command_string);
$process = Process::run($ssh_command);
$output = trim($process->output());
$exitCode = $process->exitCode();
if ($exitCode !== 0) {
Log::error($output);
throw new \RuntimeException('There was an error running the command.');
}
return $output;
}
}