container = $container; } public function up(Schema $schema): void { $jobInstances = $this->getJobInstances(); foreach ($jobInstances as $jobInstance) { $rawParameters = unserialize($jobInstance['raw_parameters']); $migratedRawParameters = $this->migrateRawParameters($rawParameters); $this->updateJobInstance($jobInstance['id'], serialize($migratedRawParameters)); } } public function down(Schema $schema): void { $this->throwIrreversibleMigrationException(); } private function getJobInstances(): array { $connection = $this->container->get('database_connection'); $sql = <<executeQuery($sql); return $stmt->fetchAll(\PDO::FETCH_ASSOC); } private function migrateRawParameters(array $rawParameters): array { if (!array_key_exists('filePath', $rawParameters)) { return $rawParameters; } $rawParameters['storage']['type'] = $this->isSaaSVersion() ? 'none' : 'local'; $rawParameters['storage']['file_path'] = $rawParameters['filePath']; unset($rawParameters['filePath']); return $rawParameters; } private function updateJobInstance(string $jobInstanceId, string $serializedRawParameters) { $sql = <<addSql($sql, ['job_instance_id' => $jobInstanceId, 'raw_parameters' => $serializedRawParameters]); } private function isSaaSVersion(): bool { /** @var VersionProviderInterface $versionProvider */ $versionProvider = $this->container->get('pim_catalog.version_provider'); return $versionProvider->isSaaSVersion(); } }