os = new OperatingSystemOption($this);
$this->arch = new ArchitectureOption($this);
$this->version = new VersionFilterOption($this);
$this->location = new InstallationLocationOption($this);
$this->stability = new StabilityOption($this);
}
public function getDescription(): string
{
return 'Install or update RoadRunner binary';
}
/**
*
* @throws \Throwable
*/
public function execute(InputInterface $input, OutputInterface $output): int
{
$io = $this->io($input, $output);
$target = $this->location->get($input, $io);
$repository = $this->getRepository();
$output->writeln('');
$output->writeln(' Environment:');
$output->writeln(\sprintf(' - Version: %s', $this->version->get($input, $io)));
$output->writeln(\sprintf(' - Stability: %s', $this->stability->get($input, $io)));
$output->writeln(\sprintf(' - Operating System: %s', $this->os->get($input, $io)));
$output->writeln(\sprintf(' - Architecture: %s', $this->arch->get($input, $io)));
$output->writeln('');
// List of all available releases
$releases = $this->version->find($input, $io, $repository);
/**
* @var AssetInterface $asset
* @var ReleaseInterface $release
*/
[$asset, $release] = $this->findAsset($repository, $releases, $input, $io);
// Installation
$output->writeln(
\sprintf(" - %s", $release->getRepositoryName()) .
\sprintf(' (%s):', $release->getVersion()) .
' Downloading...',
);
if ($output->isVerbose()) {
$output->writeln(\sprintf(" -- %s", $asset->getName()));
}
// Install rr binary
$file = $this->installBinary($target, $release, $asset, $io, $output);
$this->installConfig($target, $input, $io);
// Success
if ($file === null) {
$io->warning('RoadRunner has not been installed');
return 1;
}
$io->success('Your project is now ready in ' . $file->getPath());
$io->title('Whats Next?');
$io->listing([
// 1)
'For more detailed documentation, see the ' .
'https://roadrunner.dev',
// 2)
'To run the application, use the following command: ' .
'$ ' . $file->getFilename() . ' serve',
]);
return 0;
}
protected function configure(): void
{
$this->addOption(
'plugin',
'p',
InputOption::VALUE_OPTIONAL | InputOption::VALUE_IS_ARRAY,
'Generate configuration with selected plugins.',
);
$this->addOption(
'preset',
null,
InputOption::VALUE_OPTIONAL,
'Generate configuration with plugins in a selected preset.',
);
$this->addOption(
'no-config',
null,
InputOption::VALUE_NONE,
'Do not generate configuration at all.',
);
}
/**
* @throws \Throwable
*/
private function installBinary(
string $target,
ReleaseInterface $release,
AssetInterface $asset,
StyleInterface $io,
OutputInterface $out,
): ?\SplFileInfo {
$extractor = $this->assetToArchive($asset, $out)
->extract([
'rr.exe' => $target . '/rr.exe',
'rr' => $target . '/rr',
])
;
$file = null;
while ($extractor->valid()) {
$file = $extractor->current();
if (! $this->checkExisting($file, $io)) {
$extractor->send(false);
continue;
}
// Success
$path = $file->getRealPath() ?: $file->getPathname();
$message = 'RoadRunner (%s) has been installed into %s';
$message = \sprintf($message, $release->getVersion(), $path);
$out->writeln($message);
$extractor->next();
if (! $file->isExecutable()) {
@\chmod($file->getRealPath(), 0755);
}
}
return $file;
}
private function installConfig(string $to, InputInterface $in, StyleInterface $io): bool
{
$to .= '/.rr.yaml';
if (\is_file($to) || \is_file(\getcwd() . '/.rr.yaml')) {
return false;
}
if ($in->getOption('no-config') || ! $io->confirm('Do you want create default ".rr.yaml" configuration file?', true)) {
return false;
}
$generator = new Generator();
$plugins = $in->getOption('preset') ?
Plugins::fromPreset($in->getOption('preset')) :
Plugins::fromPlugins($in->getOption('plugin'));
try {
$config = $generator->generate($plugins);
} catch (\Throwable $e) {
$io->error($e->getMessage());
}
\file_put_contents($to, $config);
return true;
}
private function checkExisting(\SplFileInfo $bin, StyleInterface $io): bool
{
if (\is_file($bin->getPathname())) {
$io->warning('RoadRunner binary file already exists!');
if (! $io->confirm('Do you want overwrite it?', false)) {
$io->note('Skipping RoadRunner installation...');
return false;
}
}
return true;
}
/**
* @return array{0: AssetInterface, 1: ReleaseInterface}
*/
private function findAsset(
RepositoryInterface $repo,
ReleasesCollection $releases,
InputInterface $in,
StyleInterface $io,
): array {
$osOption = $this->os->get($in, $io);
$archOption = $this->arch->get($in, $io);
$stabilityOption = $this->stability->get($in, $io);
/** @var ReleaseInterface[] $filtered */
$filtered = $releases
->minimumStability($stabilityOption)
->withAssets()
;
foreach ($filtered as $release) {
$asset = $release->getAssets()
->onlyRoadrunner()
->exceptDebPackages()
->whereArchitecture($archOption)
->whereOperatingSystem($osOption)
->first()
;
if ($asset === null) {
$io->warning(\vsprintf('%s %s does not contain available assembly (further search in progress)', [
$repo->getName(),
$release->getVersion(),
]));
continue;
}
return [$asset, $release];
}
$message = \vsprintf(self::ERROR_ENVIRONMENT, [
$this->os->getName(),
$osOption,
$this->arch->getName(),
$archOption,
$this->stability->getName(),
$stabilityOption,
$this->version->choices($releases),
]);
throw new \UnexpectedValueException($message);
}
/**
* @throws \Throwable
*/
private function assetToArchive(AssetInterface $asset, OutputInterface $out, ?string $temp = null): ArchiveInterface
{
$factory = new Factory();
$progress = new ProgressBar($out);
$progress->setFormat(' [%bar%] %percent:3s%% (%size%Kb/%total%Kb)');
$progress->setMessage('0.00', 'size');
$progress->setMessage('?.??', 'total');
$progress->display();
try {
return $factory->fromAsset($asset, static function (int $size, int $total) use ($progress): void {
if ($progress->getMaxSteps() !== $total) {
$progress->setMaxSteps($total);
}
if ($progress->getStartTime() === 0) {
$progress->start();
}
$progress->setMessage(\number_format($size / 1000, 2), 'size');
$progress->setMessage(\number_format($total / 1000, 2), 'total');
$progress->setProgress($size);
}, $temp);
} finally {
$progress->clear();
}
}
}