setName('register-crontab')
->setDescription('Init crontab for data aggregating')
;
}
protected function execute(InputInterface $input, OutputInterface $output)
{
$output->writeln('Defining crontab task...');
$output->writeln('Please enter the frequency of data aggregating (frequency must be equal "pinba_stats_history" of the pinba engine config).');
$dialog = $this->getHelperSet()->get('dialog');
$frequency = $dialog->askAndValidate(
$output,
'Frequency (in minutes, default "5"): ',
function ($answer) {
if (intval($answer) <= 0) {
throw new \RunTimeException(
'You must enter positive integer value'
);
}
return $answer;
},
false,
'15'
);
$process = new Process('crontab -l');
$process->setTimeout(20);
$process->run();
$crontabString = $process->isSuccessful() ? $process->getOutput() : '';
$command = '*/' . $frequency . ' * * * * ' . __DIR__ . '/../../../console aggregate';
if (strpos($crontabString, $command) === false) {
$crontabString .= "\n" . $command . "\n";
}
$file = tempnam(sys_get_temp_dir(), 'ipm');
file_put_contents($file, $crontabString);
$process = new Process('crontab ' . $file);
$process->setTimeout(20);
$process->run();
if (!$process->isSuccessful()) {
throw new \RuntimeException($process->getErrorOutput());
}
$output->writeln('Crontab task are defined successfully');
}
}