Class AnalyticsMigrator

lib/UserMigration/AnalyticsMigrator.php:24–452

use Symfony\Component\Console\Output\OutputInterface;

class AnalyticsMigrator implements IMigrator {
	private const EXPORT_FILE = 'analytics/user-data.json';
	private const VERSION = 1;

	public function __construct(
		private IDBConnection $db,
		private IL10N $l10n,
	) {
	}

	public function export(IUser $user, IExportDestination $exportDestination, OutputInterface $output): void {
		$uid = $user->getUID();
		$output->writeln('<info>Exporting Analytics data</info>');

		$datasets = $this->fetchAllByUser('analytics_dataset', $uid);
		$datasetIds = array_map(static fn (array $row): int => (int)$row['id'], $datasets);

		$reports = $this->fetchAllByUser('analytics_report', $uid);
		$reportIds = array_map(static fn (array $row): int => (int)$row['id'], $reports);

		$payload = [
			'datasets' => $datasets,
			'reports' => $reports,
			'dataloads' => $this->fetchAllByIds('analytics_dataload', 'dataset', $datasetIds),
			'facts' => $this->fetchAllByIds('analytics_facts', 'dataset', $datasetIds),
			'thresholds' => $this->fetchAllByIds('analytics_threshold', 'report', $reportIds),
			'panoramas' => $this->fetchAllByUser('analytics_panorama', $uid),
		];

		$encoded = json_encode($payload, JSON_THROW_ON_ERROR);
		$exportDestination->addFileContents(self::EXPORT_FILE, $encoded);
	}

	public function import(IUser $user, IImportSource $importSource, OutputInterface $output): void {
		if (!$importSource->pathExists(self::EXPORT_FILE)) {
			$output->writeln('<comment>No Analytics data found in archive</comment>');
			return;
		}

		$raw = $importSource->getFileContents(self::EXPORT_FILE);
		$payload = json_decode($raw, true, 512, JSON_THROW_ON_ERROR);
		if (!is_array($payload)) {
			throw new UserMigrationException('Invalid Analytics migration payload');
		}

		$uid = $user->getUID();
		$datasetMap = [];
		$reportMap = [];

		$this->db->beginTransaction();
		try {
			$datasetMap = $this->importDatasets($uid, $payload['datasets'] ?? []);
			$reportMap = $this->importReports($uid, $payload['reports'] ?? [], $datasetMap);
			$this->importDataloads($uid, $payload['dataloads'] ?? [], $datasetMap);
			$this->importFacts($uid, $payload['facts'] ?? [], $datasetMap);
			$this->importThresholds($uid, $payload['thresholds'] ?? [], $reportMap);
			$this->importPanoramas($uid, $payload['panoramas'] ?? [], $reportMap);
			$this->db->commit();