servicesConfig = $servicesConfig;
$this->servicesClient = $servicesClient;
$this->config = $config;
$this->logger = $logger;
parent::__construct();
}
/**
* @inheritdoc
*/
protected function configure()
{
$options = [
new InputOption(
self::PROJECT_ID_OPTION,
'-p',
InputOption::VALUE_OPTIONAL,
'Project identifier'
),
new InputOption(
self::ENVIRONMENT_ID_OPTION,
'-e',
InputOption::VALUE_OPTIONAL,
'Environment identifier'
)
];
$this->setName(self::COMMAND_NAME);
$this->setDescription('Lists projects info for the merchant configured in the service connector');
$this->setDefinition($options);
parent::configure();
}
/**
* Request the list of projects from merchant registry service
*
* @inheritdoc
*
* @param InputInterface $input
* @param OutputInterface $output
* @return int
*/
protected function execute(InputInterface $input, OutputInterface $output): int
{
$environment = $this->config->getValue($this->servicesConfig::CONFIG_PATH_SERVICES_CONNECTOR_ENVIRONMENT);
if (empty($environment)) {
$output->writeln(sprintf(
'Saas environment [%s] not set',
$this->servicesConfig::CONFIG_PATH_SERVICES_CONNECTOR_ENVIRONMENT
));
return Cli::RETURN_FAILURE;
}
if (!$this->servicesConfig->isApiKeySet()) {
$output->writeln(sprintf(
'Saas Api key set not configured for %s environment',
$environment
));
return Cli::RETURN_FAILURE;
}
try {
$projectId = $input->getOption(self::PROJECT_ID_OPTION);
$environmentId = $input->getOption(self::ENVIRONMENT_ID_OPTION);
$response = $this->servicesClient->request('GET', $this->getUrl($projectId, $environmentId));
if ($response
&& !empty($response['status'])
&& $response['status'] != 200
) {
$this->logger->error('Projects list retrieval failed.', ['response' => $response]);
$errorMessage = !empty($response['message']) ? $response['message'] : $response['error'];
$output->writeln(sprintf('Projects list retrieval failed: %s ', $errorMessage));
$exitCode = Cli::RETURN_FAILURE;
} else {
$this->parseResponse($output, $response);
$exitCode = Cli::RETURN_SUCCESS;
}
} catch (\Exception $exception) {
$this->logger->error(
sprintf('Projects list retrieval failed: %s', $exception->getMessage()),
['error' => $exception]
);
$output->writeln('Projects list retrieval failed.');
$exitCode = Cli::RETURN_FAILURE;
}
return $exitCode;
}
/**
* Build registry API url based on the project and environment identifiers if provided
*
* @param string|null $projectId
* @param string|null $environmentId
* @return string
*/
private function getUrl(?string $projectId, ?string $environmentId): string
{
if (!empty($environmentId)) {
$path = sprintf('registry/environments/%s', $environmentId);
} elseif (!empty($projectId)) {
$path = sprintf('registry/projects/%s', $projectId);
} else {
$path = 'registry';
}
return $this->servicesConfig->getRegistryApiUrl($path);
}
/**
* Parse the response in a table from the merchant registry service
*
* @param OutputInterface $output
* @param array $response
* @return void
*/
private function parseResponse(OutputInterface $output, array $response): void
{
// The response can be a list of projects or a single project (when getByEnvironmentId requested)
$projectData = $response['results'] ?? [$response];
if (empty($projectData)) {
$output->writeln('No projects found');
return;
}
$output->writeln('Projects list:');
$table = new Table($output);
$table->setHeaders([
'Project Id',
'Project Name',
'Environment Id',
'Environment Name',
'Environment Type']);
foreach ($projectData as $project) {
$table->addRow([
$project['projectId'],
$project['projectName'],
$project['environmentId'],
$project['environmentName'],
$project['environmentType']
]);
}
$table->render();
}
}