AfterExtensionFilesHaveBeenImportedEvent::class,
'resultName' => 'renderExtensionFileImportResult',
],
[
'eventClass' => AfterExtensionStaticDatabaseContentHasBeenImportedEvent::class,
'resultName' => 'renderImportedStaticDataResult',
],
[
'eventClass' => AfterExtensionDatabaseContentHasBeenImportedEvent::class,
'resultName' => 'renderExtensionDataImportResult',
],
[
'eventClass' => DatabaseSchemaUpdateEvent::class,
'resultName' => 'renderSchemaResult',
],
];
public function __construct(ExtensionSetupEventDispatcher $eventDispatcher)
{
foreach (static::$eventsToRegister as $signalConfig) {
$eventDispatcher->addListener(
$signalConfig['eventClass'],
function ($event) use ($signalConfig) {
$this->results[$signalConfig['resultName']][] = $event;
}
);
}
}
/**
* Output schema result
* @param ConsoleOutput $output
*/
public function renderSchemaResult(ConsoleOutput $output, SchemaUpdateResultRenderer $schemaUpdateResultRenderer = null)
{
if (!isset($this->results['renderSchemaResult'])) {
return;
}
/** @var DatabaseSchemaUpdateEvent $event */
$event = reset($this->results['renderSchemaResult']);
if ($event->result->hasPerformedUpdates()) {
$schemaUpdateResultRenderer = $schemaUpdateResultRenderer ?: new SchemaUpdateResultRenderer();
$output->outputLine('The following database schema updates were performed:');
$schemaUpdateResultRenderer->render($event->result, $output, true);
} else {
$output->outputLine(
'No schema updates were performed for update types:%s',
[
PHP_EOL . '"' . implode('", "', SchemaUpdateType::expandSchemaUpdateTypes(['safe'])) . '"',
]
);
}
}
/**
* Output at cli context imported static database content.
*
* @param ConsoleOutput $output
*/
public function renderImportedStaticDataResult(ConsoleOutput $output)
{
if (!isset($this->results['renderImportedStaticDataResult'])) {
return;
}
/** @var AfterExtensionStaticDatabaseContentHasBeenImportedEvent $event */
foreach ($this->results['renderImportedStaticDataResult'] as $event) {
// Output content of $pathToStaticSqlFile at cli context
$pathToStaticSqlFile = $event->getSqlFileName();
$absolutePath = GeneralUtility::getFileAbsFileName($pathToStaticSqlFile);
if (file_exists($absolutePath)) {
$output->outputFormatted(
'Import content of file "%s" of extension "%s" into database.',
[
$pathToStaticSqlFile,
$event->getPackageKey(),
]
);
$output->outputFormatted(file_get_contents($absolutePath), [], 2);
}
}
}
/**
* Output at cli context initialized imported files to $destinationAbsolutePath
*
* @param ConsoleOutput $output
*/
public function renderExtensionFileImportResult(ConsoleOutput $output)
{
if (!isset($this->results['renderExtensionFileImportResult'])) {
return;
}
/** @var AfterExtensionFilesHaveBeenImportedEvent $event */
foreach ($this->results['renderExtensionFileImportResult'] as $event) {
$output->outputFormatted(
'Files from extension "%s" were imported to path "%s"',
[
$event->getPackageKey(),
PathUtility::stripPathSitePrefix($event->getDestinationAbsolutePath()),
]
);
}
}
/**
* Output at cli context initialized imported files to $destinationAbsolutePath
*
* @param ConsoleOutput $output
*/
public function renderExtensionDataImportResult(ConsoleOutput $output)
{
if (!isset($this->results['renderExtensionDataImportResult'])) {
return;
}
/** @var AfterExtensionDatabaseContentHasBeenImportedEvent $event */
foreach ($this->results['renderExtensionDataImportResult'] as $event) {
$output->outputFormatted(
'Data from from file "%s" of extension "%s" was imported',
[
$event->getImportFileName(),
$event->getPackageKey(),
]
);
}
}
}