Module.php

<?php
namespace DemoData;

use Laminas\ServiceManager\ServiceLocatorInterface;
use Omeka\Api\Exception\NotFoundException;
use Omeka\Module\AbstractModule;

class Module extends AbstractModule
{
    private const VOCAB_NS_URI = 'https://omeka.org/s/vocabs/demo-data#';

    public function getConfig()
    {
        return include sprintf('%s/config/module.config.php', __DIR__);
    }

    public function install(ServiceLocatorInterface $services)
    {
        $api = $services->get('Omeka\ApiManager');
        $existing = $api->search('vocabularies', [
            'namespace_uri' => self::VOCAB_NS_URI,
            'limit' => 0,
        ]);
        if (0 === $existing->getTotalResults()) {
            $services->get('Omeka\RdfImporter')->import(
                'file',
                [
                    'o:namespace_uri' => self::VOCAB_NS_URI,
                    'o:prefix' => 'demo-data',
                    'o:label' => 'Demo Data',
                    'o:comment' => 'Shared vocabulary for the Demo Data module.',
                ],
                [
                    'file' => $this->vocabFile(),
                    'format' => 'turtle',
                ]
            );
        } else {
            $this->syncVocab($services);
        }
    }

    public function upgrade($oldVersion, $newVersion, ServiceLocatorInterface $services)
    {
        // syncVocab is safe to run on every upgrade: it adds new terms from the
        // N3 file but never deletes existing ones, so it cannot break items
        // that already use the vocabulary.
        $this->syncVocab($services);
    }

    public function uninstall(ServiceLocatorInterface $services)
    {
        $api = $services->get('Omeka\ApiManager');
        $settings = $services->get('Omeka\Settings');
        $config = $services->get('Config');
        $jobDispatcher = $services->get('Omeka\JobDispatcher');
        // Without cleanup, imported resources become orphaned on reinstall and
        // block re-import without manual deletion.
        $allItemIds = [];
        $allItemSetIds = [];
        $allTemplateIds = [];

        foreach (array_keys($config['demo_data']['datasets']) as $dataset) {
            $tracking = $settings->get("demo_data_imported_{$dataset}");
            if ($tracking) {
                $allItemIds = array_merge($allItemIds, $tracking['items'] ?? []);
                $allItemSetIds = array_merge($allItemSetIds, array_values($tracking['item_sets'] ?? []));
                if (!empty($tracking['resource_template'])) {
                    $allTemplateIds[] = $tracking['resource_template'];
                }
            }
        }

        if ($allItemIds) {
            $jobDispatcher->dispatch(\Omeka\Job\BatchDelete::class, [
                'resource' => 'items',
                'query' => ['id' => $allItemIds],
            ]);
        }
        if ($allItemSetIds) {
            $jobDispatcher->dispatch(\Omeka\Job\BatchDelete::class, [
                'resource' => 'item_sets',
                'query' => ['id' => $allItemSetIds],
            ]);
        }
        foreach ($allTemplateIds as $templateId) {
            try {
                $api->delete('resource_templates', $templateId);
            } catch (NotFoundException $e) {
                // Already gone.
            }
        }

        $vocabs = $api->search('vocabularies', [
            'namespace_uri' => self::VOCAB_NS_URI,
            'limit' => 1,
        ])->getContent();
        if ($vocabs) {
            $api->delete('vocabularies', $vocabs[0]->id());
        }

        foreach (array_keys($config['demo_data']['datasets']) as $dataset) {
            $settings->delete("demo_data_imported_{$dataset}");
            $settings->delete("demo_data_job_{$dataset}");
        }
    }

    private function syncVocab(ServiceLocatorInterface $services): void
    {
        $rdfImporter = $services->get('Omeka\RdfImporter');
        $vocabs = $services->get('Omeka\ApiManager')->search('vocabularies', [
            'namespace_uri' => self::VOCAB_NS_URI,
            'limit' => 1,
        ])->getContent();
        if (!$vocabs) {
            return;
        }
        $diff = $rdfImporter->getDiff('file', self::VOCAB_NS_URI, [
            'file' => $this->vocabFile(),
            'format' => 'turtle',
        ]);
        $rdfImporter->update($vocabs[0]->id(), $diff);
    }

    private function vocabFile(): string
    {
        return sprintf('%s/vocabs/demo-data.n3', __DIR__);
    }
}