setName('state:export')
->setDescription('Export watch state to servers.')
->addOption('redirect-logger', 'r', InputOption::VALUE_NONE, 'Redirect logger to stdout.')
->addOption('memory-usage', 'm', InputOption::VALUE_NONE, 'Show memory usage.')
->addOption('force-full', 'f', InputOption::VALUE_NONE, 'Force full export.')
->addOption(
'proxy',
null,
InputOption::VALUE_REQUIRED,
'By default the HTTP client uses your ENV: HTTP_PROXY.'
)
->addOption(
'no-proxy',
null,
InputOption::VALUE_REQUIRED,
'Disables the proxy for a comma-separated list of hosts that do not require it to get reached.'
)
->addOption(
'servers-filter',
's',
InputOption::VALUE_OPTIONAL,
'Sync selected servers, comma seperated. \'s1,s2\'.',
''
)
->addOption(
'ignore-date',
null,
InputOption::VALUE_NONE,
'Ignore date comparison, and update server watched state to match database.'
)
->addOption('use-config', null, InputOption::VALUE_REQUIRED, 'Use different servers.yaml.')
->addOption(
'mapper-class',
null,
InputOption::VALUE_OPTIONAL,
'Configured mapper.',
afterLast($this->mapper::class, '\\')
)
->addOption('mapper-preload', null, InputOption::VALUE_NONE, 'Preload Mapper database into memory.')
->addOption(
'storage-pdo-single-transaction',
null,
InputOption::VALUE_NONE,
'Set Single transaction mode for PDO driver.'
);
}
protected function runCommand(InputInterface $input, OutputInterface $output): int
{
// -- Use Custom servers.yaml file.
if (($newConfig = $input->getOption('use-config'))) {
if (!is_string($newConfig) || !is_file($newConfig) || !is_readable($newConfig)) {
throw new RuntimeException('Unable to read data given config.');
}
Config::save('servers', Yaml::parseFile($newConfig));
}
$list = [];
$serversFilter = (string)$input->getOption('servers-filter');
$selected = explode(',', $serversFilter);
$isCustom = !empty($serversFilter) && count($selected) >= 1;
$supported = Config::get('supported', []);
foreach (Config::get('servers', []) as $serverName => $server) {
$type = strtolower(ag($server, 'type', 'unknown'));
if ($isCustom && !in_array($serverName, $selected, true)) {
continue;
}
if (true !== ag($server, 'export.enabled')) {
$output->writeln(
sprintf('Ignoring \'%s\' as requested by \'servers.yaml\'.', $serverName),
OutputInterface::VERBOSITY_VERBOSE
);
continue;
}
if (!isset($supported[$type])) {
$output->writeln(
sprintf(
'Server \'%s\' Used Unsupported type. Expecting one of \'%s\' but got \'%s\' instead.',
$serverName,
implode(', ', array_keys($supported)),
$type
)
);
return self::FAILURE;
}
if (null === ag($server, 'url')) {
$output->writeln(sprintf('Server \'%s\' has no url.', $serverName));
return self::FAILURE;
}
$list[] = [
'name' => $serverName,
'kind' => $supported[$type],
'server' => $server,
];
}
if (empty($list)) {
throw new RuntimeException(
$isCustom ? '--servers-filter/-s did not return any server.' : 'No server were found.'
);
}
$logger = null;
if ($input->getOption('redirect-logger') || $input->getOption('memory-usage')) {
$logger = new CliLogger($output, (bool)$input->getOption('memory-usage'));
}
$requests = [];
if (null !== $logger) {
$this->logger = $logger;
$this->mapper->setLogger($logger);
}
if (count($list) >= 1 && $input->getOption('mapper-preload')) {
$this->logger->info('Preloading all mapper data.');
$this->mapper->loadData();
$this->logger->info('Finished preloading mapper data.');
}
if ($input->getOption('storage-pdo-single-transaction')) {
$this->storage->singleTransaction();
}
foreach ($list as $server) {
$name = ag($server, 'name');
Data::addBucket($name);
$class = Container::get(ag($server, 'kind'));
assert($class instanceof ServerInterface);
$opts = ag($server, 'server.options', []);
if ($input->getOption('ignore-date')) {
$opts[ServerInterface::OPT_EXPORT_IGNORE_DATE] = true;
}
if ($input->getOption('proxy')) {
$opts['proxy'] = $input->getOption('proxy');
}
if ($input->getOption('no-proxy')) {
$opts['no_proxy'] = $input->getOption('no-proxy');
}
$class = $class->setUp(
name: $name,
url: new Uri(ag($server, 'server.url')),
token: ag($server, 'server.token', null),
userId: ag($server, 'server.user', null),
options: $opts
);
if (null !== $logger) {
$class = $class->setLogger($logger);
}
$after = $input->getOption('force-full') ? null : ag($server, 'server.import.lastSync', null);
if (null === $after) {
$this->logger->notice(
sprintf('Importing \'%s\' play state changes since beginning.', $name)
);
} else {
$after = makeDate($after);
$this->logger->notice(
sprintf('Importing \'%s\' play state changes since \'%s\'.', $name, $after)
);
}
array_push($requests, ...$class->push($this->mapper, $after));
if (true === Data::get(sprintf('%s.no_export_update', $name))) {
$this->logger->notice(
sprintf('Not updating \'%s\' export date, as the server reported an error.', $name)
);
} else {
Config::save(sprintf('servers.%s.export.lastSync', $name), time());
}
}
$this->logger->notice(sprintf('Waiting on (%d) (Compare State) Requests.', count($requests)));
foreach ($requests as $response) {
$requestData = $response->getInfo('user_data');
try {
if (200 === $response->getStatusCode()) {
$requestData['ok']($response);
} else {
$requestData['error']($response);
}
} catch (ExceptionInterface $e) {
$requestData['error']($e);
}
}
$this->logger->notice(sprintf('Finished waiting on (%d) Requests.', count($requests)));
$changes = $this->mapper->getQueue();
if (empty($changes)) {
$this->logger->notice('No State change detected.');
return self::SUCCESS;
}
$this->logger->notice(sprintf('Waiting on (%d) (Stats Change) Requests.', count($changes)));
foreach ($changes as $response) {
$requestData = $response->getInfo('user_data');
try {
if (200 !== $response->getStatusCode()) {
throw new ServerException($response);
}
$this->logger->debug(
sprintf(
'Processed: State (%s) - %s',
ag($requestData, 'state', '??'),
ag($requestData, 'itemName', '??'),
)
);
} catch (ExceptionInterface $e) {
$this->logger->error($e->getMessage());
}
}
$this->logger->notice(sprintf('Finished waiting on (%d) Requests.', count($changes)));
// -- Update Server.yaml with new lastSync date.
file_put_contents(
$newConfig ?? Config::get('path') . '/config/servers.yaml',
Yaml::dump(Config::get('servers', []), 8, 2)
);
return self::SUCCESS;
}
}