+
{{ t('openregister', 'Active Filters') }}
@@ -495,7 +478,6 @@ export default {
enabledFacets: {}, // Which facets user has enabled
facetsLoading: false, // Stage 1 loading
facetDataLoading: false, // Stage 2 loading
- selectedSource: 'auto', // 'auto', 'database', 'index'
// View management
viewSearchQuery: '', // Search query for filtering views
showSaveForm: false, // Show inline save form
@@ -619,32 +601,6 @@ export default {
searchPlaceholder() {
return this.searchTerms.length > 0 ? 'Add more search terms...' : 'Type to search...'
},
- sourceOptions() {
- return [
- {
- value: 'auto',
- label: '🤖 Auto (Intelligent)',
- description: 'Automatically chooses the best data source',
- },
- {
- value: 'index',
- label: '🔍 SOLR Index',
- description: 'Fast search with advanced features, field weighting, and faceting',
- },
- {
- value: 'database',
- label: '💾 Database',
- description: 'Direct database queries (slower but always available)',
- },
- ]
- },
- selectedSourceValue() {
- const source = this.sourceOptions.find(option => option.value === this.selectedSource)
- return source || this.sourceOptions[0]
- },
- isDatabaseSource() {
- return this.selectedSource === 'database'
- },
hasEnabledFacets() {
return Object.values(this.enabledFacets).some(enabled => enabled)
},
@@ -816,9 +772,6 @@ export default {
if (this.searchTerms && this.searchTerms.length > 0) {
query.q = this.searchTerms.join(',')
}
- if (this.selectedSource && this.selectedSource !== 'auto') {
- query.source = this.selectedSource
- }
return query
},
// Compare two query objects for equality (shallow, keys/values as strings)
@@ -845,14 +798,10 @@ export default {
// Apply URL query params into component/store state
applyQueryParamsFromRoute() {
if (this.$route.path !== '/tables') return
- const { register, schema, q, source } = this.$route.query || {}
+ const { register, schema, q } = this.$route.query || {}
// Clear selection when params absent so table empties
if (!register) this.selectedRegisters = []
if (!schema) this.selectedSchemas = []
- // Source
- if (source) {
- this.selectedSource = String(source)
- }
// Search terms
if (typeof q === 'string') {
const terms = q.split(',').map(s => s.trim()).filter(Boolean)
@@ -943,11 +892,6 @@ export default {
// Only update URL; route watcher will trigger applyQueryParamsFromRoute -> performSearchWithFacets once
this.updateRouteQueryFromState()
},
- handleSourceChange(option) {
- this.selectedSource = option.value
- // Only update URL; route watcher triggers applyQueryParamsFromRoute -> performSearchWithFacets once
- this.updateRouteQueryFromState()
- },
/** Push sidebar state into objectStore.searchParams and refetch type 'search'. Sets register/schema context for dialogs and discoverFacets. */
syncSearchParamsAndRefetch() {
const registerId = this.selectedRegisters.length > 0 ? this.selectedRegisters[0] : null
@@ -971,7 +915,6 @@ export default {
schema: schemaId,
search,
filters,
- source: this.selectedSource || 'auto',
})
objectStore.refetchSearchCollection()
},
@@ -1074,7 +1017,7 @@ export default {
},
// Toggle individual facet on/off
- toggleFacet(fieldName, fieldInfo) {
+ toggleFacet(fieldName, _fieldInfo) {
// When toggling facet, clear any existing data for that field
if (this.enabledFacets[fieldName]) {
// Facet was enabled, now being disabled
@@ -1277,11 +1220,6 @@ export default {
this.selectedSchemas = config.schemas
}
- // Apply source (database/index/auto)
- if (config.source) {
- this.selectedSource = config.source
- }
-
// Apply search terms (default filters)
if (config.searchTerms && Array.isArray(config.searchTerms)) {
this.searchTerms = config.searchTerms
@@ -1320,7 +1258,6 @@ export default {
// Query parameters only
registers: this.selectedRegisters,
schemas: this.selectedSchemas,
- source: this.selectedSource,
searchTerms: this.searchTerms,
facetFilters: this.facetFilters,
enabledFacets: this.enabledFacets,
@@ -1374,7 +1311,6 @@ export default {
// Query parameters only
registers: this.selectedRegisters,
schemas: this.selectedSchemas,
- source: this.selectedSource,
searchTerms: this.searchTerms,
facetFilters: this.facetFilters,
enabledFacets: this.enabledFacets,
@@ -1547,7 +1483,6 @@ export default {
objectStore.updateSearchParams({
search: this.searchTerms.length > 0 ? this.searchTerms.join(' ') : '',
filters: activeFilters,
- source: this.selectedSource || 'auto',
})
},
diff --git a/src/views/Endpoint/EndpointDetails.vue b/src/views/Endpoint/EndpointDetails.vue
index 1460ac3cd..d5579160e 100644
--- a/src/views/Endpoint/EndpointDetails.vue
+++ b/src/views/Endpoint/EndpointDetails.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/Endpoint/EndpointsList.vue b/src/views/Endpoint/EndpointsList.vue
index eb7328004..4b96217e9 100644
--- a/src/views/Endpoint/EndpointsList.vue
+++ b/src/views/Endpoint/EndpointsList.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/agents/AgentsIndex.vue b/src/views/agents/AgentsIndex.vue
index 3d78f6345..53e374114 100644
--- a/src/views/agents/AgentsIndex.vue
+++ b/src/views/agents/AgentsIndex.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/application/ApplicationDetails.vue b/src/views/application/ApplicationDetails.vue
index 40daa7019..c1b24d319 100644
--- a/src/views/application/ApplicationDetails.vue
+++ b/src/views/application/ApplicationDetails.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/application/ApplicationsIndex.vue b/src/views/application/ApplicationsIndex.vue
index b4d16030f..1d7504940 100644
--- a/src/views/application/ApplicationsIndex.vue
+++ b/src/views/application/ApplicationsIndex.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/configuration/ConfigurationsIndex.vue b/src/views/configuration/ConfigurationsIndex.vue
index 6de22b00d..f31522f7c 100644
--- a/src/views/configuration/ConfigurationsIndex.vue
+++ b/src/views/configuration/ConfigurationsIndex.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/dashboard/DashboardIndex.vue b/src/views/dashboard/DashboardIndex.vue
index bb5797a66..550a12607 100644
--- a/src/views/dashboard/DashboardIndex.vue
+++ b/src/views/dashboard/DashboardIndex.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/deleted/DeletedIndex.vue b/src/views/deleted/DeletedIndex.vue
index 8be894e04..dd697da4e 100644
--- a/src/views/deleted/DeletedIndex.vue
+++ b/src/views/deleted/DeletedIndex.vue
@@ -1,4 +1,5 @@
@@ -521,7 +522,7 @@ export default {
* @param {object} options - Export options
* @return {void}
*/
- exportFilteredItems(options) {
+ exportFilteredItems(_options) {
// TODO: Implement export functionality for deleted items
},
/**
diff --git a/src/views/logs/AuditTrailIndex.vue b/src/views/logs/AuditTrailIndex.vue
index b40958f75..0717b3e76 100644
--- a/src/views/logs/AuditTrailIndex.vue
+++ b/src/views/logs/AuditTrailIndex.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/logs/SearchTrailIndex.vue b/src/views/logs/SearchTrailIndex.vue
index d70fa5d52..79db290e9 100644
--- a/src/views/logs/SearchTrailIndex.vue
+++ b/src/views/logs/SearchTrailIndex.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/object/ObjectDetails.vue b/src/views/object/ObjectDetails.vue
index d17092e2f..0f1a12b44 100644
--- a/src/views/object/ObjectDetails.vue
+++ b/src/views/object/ObjectDetails.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/object/ObjectsIndex.vue b/src/views/object/ObjectsIndex.vue
index 9446af935..4e21e696b 100644
--- a/src/views/object/ObjectsIndex.vue
+++ b/src/views/object/ObjectsIndex.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/object/ObjectsList.vue b/src/views/object/ObjectsList.vue
index 4eb151169..f262fd30a 100644
--- a/src/views/object/ObjectsList.vue
+++ b/src/views/object/ObjectsList.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/organisation/OrganisationDetails.vue b/src/views/organisation/OrganisationDetails.vue
index 309ffc5a2..ccfc83471 100644
--- a/src/views/organisation/OrganisationDetails.vue
+++ b/src/views/organisation/OrganisationDetails.vue
@@ -1,4 +1,5 @@
@@ -372,11 +373,11 @@ export default {
window.open(websiteUrl, '_blank')
}
},
- showSuccessMessage(message) {
+ showSuccessMessage(_message) {
// Implementation would depend on your notification system
// TODO: Integrate with Nextcloud notification system
},
- showErrorMessage(message) {
+ showErrorMessage(_message) {
// Implementation would depend on your notification system
// TODO: Integrate with Nextcloud notification system
},
diff --git a/src/views/organisation/OrganisationsIndex.vue b/src/views/organisation/OrganisationsIndex.vue
index 8f6749e6a..420a5e5c8 100644
--- a/src/views/organisation/OrganisationsIndex.vue
+++ b/src/views/organisation/OrganisationsIndex.vue
@@ -1,4 +1,5 @@
@@ -549,11 +550,11 @@ export default {
window.open(websiteUrl, '_blank')
}
},
- showSuccessMessage(message) {
+ showSuccessMessage(_message) {
// Implementation would depend on your notification system
// TODO: Integrate with Nextcloud notification system
},
- showErrorMessage(message) {
+ showErrorMessage(_message) {
// Implementation would depend on your notification system
// TODO: Integrate with Nextcloud notification system
},
diff --git a/src/views/register/RegisterDetail.vue b/src/views/register/RegisterDetail.vue
index ed2ef3cdc..90a8a849b 100644
--- a/src/views/register/RegisterDetail.vue
+++ b/src/views/register/RegisterDetail.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/register/RegistersIndex.vue b/src/views/register/RegistersIndex.vue
index b19a7f8fd..79f66cea8 100644
--- a/src/views/register/RegistersIndex.vue
+++ b/src/views/register/RegistersIndex.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/schema/SchemaDetails.vue b/src/views/schema/SchemaDetails.vue
index c2defd851..68f30ab11 100644
--- a/src/views/schema/SchemaDetails.vue
+++ b/src/views/schema/SchemaDetails.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/schema/SchemasIndex.vue b/src/views/schema/SchemasIndex.vue
index 57bfcef8e..fc6322fc9 100644
--- a/src/views/schema/SchemasIndex.vue
+++ b/src/views/schema/SchemasIndex.vue
@@ -1,4 +1,5 @@
diff --git a/src/views/search/SearchIndex.vue b/src/views/search/SearchIndex.vue
index e46151723..f4f25b7da 100644
--- a/src/views/search/SearchIndex.vue
+++ b/src/views/search/SearchIndex.vue
@@ -84,7 +84,7 @@ export default {
objectStore.setObjectItem({ '@self': row['@self'] || { id: row.id } })
}
},
- handleCopy({ id, newName }) {
+ handleCopy({ id, newName: _newName }) {
const row = this.normalizedObjects.find((r) => String(r.id) === String(id))
if (row) {
objectStore.setObjectItem(row)
diff --git a/src/views/settings/sections/SolrConfiguration.vue b/src/views/settings/sections/SolrConfiguration.vue
index e37cd9854..446e557f9 100644
--- a/src/views/settings/sections/SolrConfiguration.vue
+++ b/src/views/settings/sections/SolrConfiguration.vue
@@ -1724,7 +1724,7 @@ export default {
this.showDeleteCollectionDialog = false
},
- async handleCollectionDeleted(result) {
+ async handleCollectionDeleted(_result) {
// Close the modal
this.closeDeleteCollectionModal()
diff --git a/src/views/source/SourcesIndex.vue b/src/views/source/SourcesIndex.vue
index 09392826e..427f58c1f 100644
--- a/src/views/source/SourcesIndex.vue
+++ b/src/views/source/SourcesIndex.vue
@@ -1,4 +1,5 @@
@@ -330,7 +331,7 @@ export default {
this.pagination.page = 1
this.pagination.limit = pageSize
},
- getSourceRegisterCount(sourceId) {
+ getSourceRegisterCount(_sourceId) {
// This would need to be implemented based on how registers are linked to sources
// For now, return a placeholder
return '-'
diff --git a/src/views/templates/TemplatesIndex.vue b/src/views/templates/TemplatesIndex.vue
index bb247d302..5f42f3605 100644
--- a/src/views/templates/TemplatesIndex.vue
+++ b/src/views/templates/TemplatesIndex.vue
@@ -287,10 +287,10 @@ export default {
/**
* View template details
*
- * @param {object} template - Template object
+ * @param {object} _template - Template object
* @return {void}
*/
- viewTemplate(template) {
+ viewTemplate(_template) {
// TODO: Navigate to template details page when available
// console.log('View template:', template)
},
diff --git a/tests/Unit/Controller/BulkControllerTest.php b/tests/Unit/Controller/BulkControllerTest.php
index 2a3979d92..1bf769f9a 100644
--- a/tests/Unit/Controller/BulkControllerTest.php
+++ b/tests/Unit/Controller/BulkControllerTest.php
@@ -83,7 +83,11 @@ public function testDeleteUuidsNotArray(): void
public function testDeleteSuccess(): void
{
$this->setupResolveSuccess();
- $this->objectService->method('deleteObjects')->willReturn(['uuid1', 'uuid2']);
+ $this->objectService->method('deleteObjects')->willReturn([
+ 'deleted_uuids' => ['uuid1', 'uuid2'],
+ 'skipped_uuids' => ['uuid3'],
+ 'cascade_count' => 0,
+ ]);
$this->request->method('getParams')->willReturn([
'uuids' => ['uuid1', 'uuid2', 'uuid3'],
@@ -98,13 +102,20 @@ public function testDeleteSuccess(): void
$this->assertEquals(['uuid1', 'uuid2'], $data['deleted_uuids']);
$this->assertEquals(3, $data['requested_count']);
$this->assertEquals(1, $data['skipped_count']);
+ $this->assertEquals(['uuid3'], $data['skipped_uuids']);
+ $this->assertEquals(0, $data['cascade_count']);
+ $this->assertEquals(2, $data['total_affected']);
$this->assertEquals('Bulk delete operation completed successfully', $data['message']);
}
public function testDeleteAllSuccessful(): void
{
$this->setupResolveSuccess();
- $this->objectService->method('deleteObjects')->willReturn(['uuid1', 'uuid2']);
+ $this->objectService->method('deleteObjects')->willReturn([
+ 'deleted_uuids' => ['uuid1', 'uuid2'],
+ 'skipped_uuids' => [],
+ 'cascade_count' => 0,
+ ]);
$this->request->method('getParams')->willReturn([
'uuids' => ['uuid1', 'uuid2'],
@@ -168,423 +179,8 @@ public function testDeleteSchemaNotFound(): void
$this->assertStringContainsString('Schema not found', $data['error']);
}
- // ========================================================================
- // publish() tests
- // ========================================================================
-
- public function testPublishMissingUuids(): void
- {
- $this->request->method('getParams')->willReturn([]);
-
- $result = $this->controller->publish('1', '2');
-
- $this->assertEquals(Http::STATUS_BAD_REQUEST, $result->getStatus());
- }
-
- public function testPublishEmptyUuidsArray(): void
- {
- $this->request->method('getParams')->willReturn(['uuids' => []]);
-
- $result = $this->controller->publish('1', '2');
-
- $this->assertEquals(Http::STATUS_BAD_REQUEST, $result->getStatus());
- }
-
- public function testPublishUuidsNotArray(): void
- {
- $this->request->method('getParams')->willReturn(['uuids' => 'string-value']);
-
- $result = $this->controller->publish('1', '2');
-
- $this->assertEquals(Http::STATUS_BAD_REQUEST, $result->getStatus());
- }
-
- public function testPublishSuccess(): void
- {
- $this->objectService->method('setRegister')->willReturnSelf();
- $this->objectService->method('setSchema')->willReturnSelf();
- $this->objectService->method('publishObjects')->willReturn(['uuid1']);
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- ]);
-
- $result = $this->controller->publish('1', '2');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- $data = $result->getData();
- $this->assertTrue($data['success']);
- $this->assertEquals(1, $data['published_count']);
- $this->assertEquals(['uuid1'], $data['published_uuids']);
- $this->assertEquals(1, $data['requested_count']);
- $this->assertEquals(0, $data['skipped_count']);
- $this->assertEquals('Bulk publish operation completed successfully', $data['message']);
- }
-
- public function testPublishWithSkippedUuids(): void
- {
- $this->objectService->method('setRegister')->willReturnSelf();
- $this->objectService->method('setSchema')->willReturnSelf();
- $this->objectService->method('publishObjects')->willReturn(['uuid1']);
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1', 'uuid2', 'uuid3'],
- ]);
-
- $result = $this->controller->publish('1', '2');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- $data = $result->getData();
- $this->assertEquals(1, $data['published_count']);
- $this->assertEquals(3, $data['requested_count']);
- $this->assertEquals(2, $data['skipped_count']);
- }
-
- public function testPublishWithValidDatetime(): void
- {
- $this->objectService->method('setRegister')->willReturnSelf();
- $this->objectService->method('setSchema')->willReturnSelf();
- $this->objectService->method('publishObjects')->willReturn(['uuid1']);
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- 'datetime' => '2024-01-01T12:00:00Z',
- ]);
-
- $result = $this->controller->publish('1', '2');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- $data = $result->getData();
- $this->assertTrue($data['success']);
- // datetime_used should be formatted as Y-m-d H:i:s
- $this->assertEquals('2024-01-01 12:00:00', $data['datetime_used']);
- }
-
- public function testPublishWithDatetimeTrue(): void
- {
- $this->objectService->method('setRegister')->willReturnSelf();
- $this->objectService->method('setSchema')->willReturnSelf();
- $this->objectService->method('publishObjects')->willReturn(['uuid1']);
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- 'datetime' => true,
- ]);
-
- $result = $this->controller->publish('1', '2');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- $data = $result->getData();
- $this->assertTrue($data['datetime_used']);
- }
-
- public function testPublishWithDatetimeFalse(): void
- {
- $this->objectService->method('setRegister')->willReturnSelf();
- $this->objectService->method('setSchema')->willReturnSelf();
- $this->objectService->method('publishObjects')->willReturn(['uuid1']);
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- 'datetime' => false,
- ]);
-
- $result = $this->controller->publish('1', '2');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- $data = $result->getData();
- $this->assertFalse($data['datetime_used']);
- }
-
- public function testPublishWithDatetimeNull(): void
- {
- $this->objectService->method('setRegister')->willReturnSelf();
- $this->objectService->method('setSchema')->willReturnSelf();
- $this->objectService->method('publishObjects')->willReturn(['uuid1']);
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- 'datetime' => null,
- ]);
-
- $result = $this->controller->publish('1', '2');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- }
-
- public function testPublishInvalidDatetime(): void
- {
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- 'datetime' => 'not-a-date',
- ]);
-
- $result = $this->controller->publish('1', '2');
-
- $this->assertEquals(Http::STATUS_BAD_REQUEST, $result->getStatus());
- $data = $result->getData();
- $this->assertStringContainsString('Invalid datetime format', $data['error']);
- }
-
- public function testPublishException(): void
- {
- $this->objectService->method('setRegister')->willReturnSelf();
- $this->objectService->method('setSchema')->willReturnSelf();
- $this->objectService->method('publishObjects')
- ->willThrowException(new \Exception('Publish error'));
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- ]);
-
- $result = $this->controller->publish('1', '2');
-
- $this->assertEquals(Http::STATUS_INTERNAL_SERVER_ERROR, $result->getStatus());
- $data = $result->getData();
- $this->assertStringContainsString('Bulk publish operation failed', $data['error']);
- $this->assertStringContainsString('Publish error', $data['error']);
- }
-
- public function testPublishDefaultDatetimeWhenNotProvided(): void
- {
- $this->objectService->method('setRegister')->willReturnSelf();
- $this->objectService->method('setSchema')->willReturnSelf();
- $this->objectService->method('publishObjects')->willReturn(['uuid1']);
-
- // No datetime key in params at all - defaults to true
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- ]);
-
- $result = $this->controller->publish('1', '2');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- $data = $result->getData();
- $this->assertTrue($data['datetime_used']);
- }
-
- // ========================================================================
- // depublish() tests
- // ========================================================================
-
- public function testDepublishSuccess(): void
- {
- $this->setupResolveSuccess();
- $this->objectService->method('depublishObjects')->willReturn(['uuid1']);
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- ]);
-
- $result = $this->controller->depublish('1', '2');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- $data = $result->getData();
- $this->assertTrue($data['success']);
- $this->assertEquals(1, $data['depublished_count']);
- $this->assertEquals(['uuid1'], $data['depublished_uuids']);
- $this->assertEquals(1, $data['requested_count']);
- $this->assertEquals(0, $data['skipped_count']);
- $this->assertEquals('Bulk depublish operation completed successfully', $data['message']);
- }
-
- public function testDepublishWithSkippedUuids(): void
- {
- $this->setupResolveSuccess();
- $this->objectService->method('depublishObjects')->willReturn(['uuid1']);
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1', 'uuid2', 'uuid3'],
- ]);
-
- $result = $this->controller->depublish('1', '2');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- $data = $result->getData();
- $this->assertEquals(1, $data['depublished_count']);
- $this->assertEquals(3, $data['requested_count']);
- $this->assertEquals(2, $data['skipped_count']);
- }
-
- public function testDepublishMissingUuids(): void
- {
- $this->setupResolveSuccess();
- $this->request->method('getParams')->willReturn([]);
-
- $result = $this->controller->depublish('1', '2');
-
- $this->assertEquals(Http::STATUS_BAD_REQUEST, $result->getStatus());
- }
-
- public function testDepublishEmptyUuidsArray(): void
- {
- $this->setupResolveSuccess();
- $this->request->method('getParams')->willReturn(['uuids' => []]);
-
- $result = $this->controller->depublish('1', '2');
-
- $this->assertEquals(Http::STATUS_BAD_REQUEST, $result->getStatus());
- }
-
- public function testDepublishUuidsNotArray(): void
- {
- $this->setupResolveSuccess();
- $this->request->method('getParams')->willReturn(['uuids' => 'not-array']);
-
- $result = $this->controller->depublish('1', '2');
-
- $this->assertEquals(Http::STATUS_BAD_REQUEST, $result->getStatus());
- }
-
- public function testDepublishWithValidDatetime(): void
- {
- $this->setupResolveSuccess();
- $this->objectService->method('depublishObjects')->willReturn(['uuid1']);
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- 'datetime' => '2024-06-15T10:30:00Z',
- ]);
-
- $result = $this->controller->depublish('1', '2');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- $data = $result->getData();
- $this->assertTrue($data['success']);
- $this->assertEquals('2024-06-15 10:30:00', $data['datetime_used']);
- }
-
- public function testDepublishWithDatetimeTrue(): void
- {
- $this->setupResolveSuccess();
- $this->objectService->method('depublishObjects')->willReturn(['uuid1']);
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- 'datetime' => true,
- ]);
-
- $result = $this->controller->depublish('1', '2');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- $data = $result->getData();
- $this->assertTrue($data['datetime_used']);
- }
-
- public function testDepublishWithDatetimeFalse(): void
- {
- $this->setupResolveSuccess();
- $this->objectService->method('depublishObjects')->willReturn(['uuid1']);
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- 'datetime' => false,
- ]);
-
- $result = $this->controller->depublish('1', '2');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- $data = $result->getData();
- $this->assertFalse($data['datetime_used']);
- }
-
- public function testDepublishWithDatetimeNull(): void
- {
- $this->setupResolveSuccess();
- $this->objectService->method('depublishObjects')->willReturn(['uuid1']);
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- 'datetime' => null,
- ]);
-
- $result = $this->controller->depublish('1', '2');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- }
-
- public function testDepublishInvalidDatetime(): void
- {
- $this->setupResolveSuccess();
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- 'datetime' => 'invalid-date-string',
- ]);
-
- $result = $this->controller->depublish('1', '2');
-
- $this->assertEquals(Http::STATUS_BAD_REQUEST, $result->getStatus());
- $data = $result->getData();
- $this->assertStringContainsString('Invalid datetime format', $data['error']);
- }
-
- public function testDepublishDefaultDatetimeWhenNotProvided(): void
- {
- $this->setupResolveSuccess();
- $this->objectService->method('depublishObjects')->willReturn(['uuid1']);
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- ]);
-
- $result = $this->controller->depublish('1', '2');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- $data = $result->getData();
- $this->assertTrue($data['datetime_used']);
- }
-
- public function testDepublishRegisterNotFound(): void
- {
- $this->objectService->method('setRegister')
- ->willThrowException(new DoesNotExistException('not found'));
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- ]);
-
- $result = $this->controller->depublish('nonexistent', '2');
-
- $this->assertEquals(Http::STATUS_NOT_FOUND, $result->getStatus());
- $data = $result->getData();
- $this->assertStringContainsString('Register not found', $data['error']);
- }
-
- public function testDepublishSchemaNotFound(): void
- {
- $this->objectService->method('setRegister')->willReturnSelf();
- $this->objectService->method('setSchema')
- ->willThrowException(new DoesNotExistException('not found'));
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- ]);
-
- $result = $this->controller->depublish('1', 'nonexistent');
-
- $this->assertEquals(Http::STATUS_NOT_FOUND, $result->getStatus());
- $data = $result->getData();
- $this->assertStringContainsString('Schema not found', $data['error']);
- }
-
- public function testDepublishException(): void
- {
- $this->setupResolveSuccess();
- $this->objectService->method('depublishObjects')
- ->willThrowException(new \Exception('Depublish error'));
-
- $this->request->method('getParams')->willReturn([
- 'uuids' => ['uuid1'],
- ]);
-
- $result = $this->controller->depublish('1', '2');
- $this->assertEquals(Http::STATUS_INTERNAL_SERVER_ERROR, $result->getStatus());
- $data = $result->getData();
- $this->assertStringContainsString('Bulk depublish operation failed', $data['error']);
- $this->assertStringContainsString('Depublish error', $data['error']);
- }
+ // publish/depublish tests removed — endpoints deprecated per deprecate-published-metadata spec
// ========================================================================
// save() tests
@@ -784,78 +380,7 @@ public function testSaveWithEmptyStatistics(): void
$this->assertEquals(0, $data['saved_count']);
}
- // ========================================================================
- // publishSchema() tests
- // ========================================================================
-
- public function testPublishSchemaInvalidId(): void
- {
- $result = $this->controller->publishSchema('1', 'not-numeric');
-
- $this->assertEquals(Http::STATUS_BAD_REQUEST, $result->getStatus());
- $data = $result->getData();
- $this->assertStringContainsString('Invalid schema ID', $data['error']);
- }
-
- public function testPublishSchemaSuccess(): void
- {
- $this->objectService->method('setRegister')->willReturnSelf();
- $this->objectService->method('setSchema')->willReturnSelf();
- $this->objectService->method('publishObjectsBySchema')->willReturn([
- 'published_count' => 5,
- 'published_uuids' => ['u1', 'u2', 'u3', 'u4', 'u5'],
- 'schema_id' => 1,
- ]);
-
- $this->request->method('getParams')->willReturn([]);
-
- $result = $this->controller->publishSchema('1', '1');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- $data = $result->getData();
- $this->assertTrue($data['success']);
- $this->assertEquals(5, $data['published_count']);
- $this->assertEquals(['u1', 'u2', 'u3', 'u4', 'u5'], $data['published_uuids']);
- $this->assertEquals(1, $data['schema_id']);
- $this->assertFalse($data['publish_all']);
- $this->assertEquals('Schema objects publishing completed successfully', $data['message']);
- }
-
- public function testPublishSchemaWithPublishAllTrue(): void
- {
- $this->objectService->method('setRegister')->willReturnSelf();
- $this->objectService->method('setSchema')->willReturnSelf();
- $this->objectService->method('publishObjectsBySchema')->willReturn([
- 'published_count' => 10,
- 'published_uuids' => ['u1'],
- 'schema_id' => 2,
- ]);
-
- $this->request->method('getParams')->willReturn(['publishAll' => true]);
-
- $result = $this->controller->publishSchema('1', '2');
-
- $this->assertEquals(Http::STATUS_OK, $result->getStatus());
- $data = $result->getData();
- $this->assertTrue($data['publish_all']);
- }
-
- public function testPublishSchemaException(): void
- {
- $this->objectService->method('setRegister')->willReturnSelf();
- $this->objectService->method('setSchema')->willReturnSelf();
- $this->objectService->method('publishObjectsBySchema')
- ->willThrowException(new \Exception('Schema publish error'));
-
- $this->request->method('getParams')->willReturn([]);
-
- $result = $this->controller->publishSchema('1', '1');
-
- $this->assertEquals(Http::STATUS_INTERNAL_SERVER_ERROR, $result->getStatus());
- $data = $result->getData();
- $this->assertStringContainsString('Schema objects publishing failed', $data['error']);
- $this->assertStringContainsString('Schema publish error', $data['error']);
- }
+ // publishSchema() tests removed — deprecated per deprecate-published-metadata spec
// ========================================================================
// deleteSchema() tests
@@ -1122,25 +647,6 @@ public function testDeleteReturnsJsonResponse(): void
$this->assertInstanceOf(JSONResponse::class, $result);
}
- public function testPublishReturnsJsonResponse(): void
- {
- $this->request->method('getParams')->willReturn([]);
-
- $result = $this->controller->publish('1', '2');
-
- $this->assertInstanceOf(JSONResponse::class, $result);
- }
-
- public function testDepublishReturnsJsonResponse(): void
- {
- $this->setupResolveSuccess();
- $this->request->method('getParams')->willReturn([]);
-
- $result = $this->controller->depublish('1', '2');
-
- $this->assertInstanceOf(JSONResponse::class, $result);
- }
-
public function testSaveReturnsJsonResponse(): void
{
$this->setupResolveSuccess();
diff --git a/tests/Unit/Service/ObjectHandlers/SaveObjectTest.php b/tests/Unit/Service/ObjectHandlers/SaveObjectTest.php
index c5c5fcaa1..f65c22a2a 100644
--- a/tests/Unit/Service/ObjectHandlers/SaveObjectTest.php
+++ b/tests/Unit/Service/ObjectHandlers/SaveObjectTest.php
@@ -1108,35 +1108,6 @@ public function testInversedByWithArrayPropertyAddsToExistingArray(): void
$this->assertEquals($parentUuid, $result->getUuid());
}
- /**
- * Test scanForRelations detects no relations in simple data
- *
- * @return void
- */
- public function testScanForRelationsWithSimpleData(): void
- {
- // Configure schema mock.
- $this->mockSchema->method('getSchemaObject')->willReturn((object)['properties' => new \stdClass()]);
- $this->mockSchema->method('getProperties')->willReturn([
- 'name' => ['type' => 'string'],
- 'description' => ['type' => 'string']
- ]);
- $this->mockSchema->method('getConfiguration')->willReturn(null);
-
- $data = [
- 'name' => 'Test Object',
- 'description' => 'Test Description'
- ];
-
- $relations = $this->saveObject->scanForRelations(
- data: $data,
- prefix: '',
- schema: $this->mockSchema
- );
-
- $this->assertIsArray($relations, 'scanForRelations should return an array.');
- }
-
/**
* Test applyPropertyDefaults applies default values from schema
*
@@ -1174,4 +1145,34 @@ public function testApplyPropertyDefaultsAppliesDefaults(): void
$this->assertIsArray($result, 'applyPropertyDefaults should return an array.');
$this->assertEquals('Test Object Title', $result['title'], 'Existing values should be preserved.');
}
+
+ /**
+ * Test scanForRelations detects no relations in simple data
+ *
+ * @return void
+ */
+ public function testScanForRelationsWithSimpleData(): void
+ {
+ // Configure schema mock.
+ $this->mockSchema->method('getSchemaObject')->willReturn((object)['properties' => new \stdClass()]);
+ $this->mockSchema->method('getProperties')->willReturn([
+ 'name' => ['type' => 'string'],
+ 'description' => ['type' => 'string']
+ ]);
+ $this->mockSchema->method('getConfiguration')->willReturn(null);
+
+ $data = [
+ 'name' => 'Test Object',
+ 'description' => 'Test Description'
+ ];
+
+ $relations = $this->saveObject->scanForRelations(
+ data: $data,
+ prefix: '',
+ schema: $this->mockSchema
+ );
+
+ $this->assertIsArray($relations, 'scanForRelations should return an array.');
+ }
+
}
\ No newline at end of file
diff --git a/tests/federation/README.md b/tests/federation/README.md
new file mode 100644
index 000000000..bd0e93963
--- /dev/null
+++ b/tests/federation/README.md
@@ -0,0 +1,138 @@
+# OpenCatalogi Federation Integration Tests
+
+Automated tests for OpenCatalogi's federation features: directory sync, listing management, federated search, broadcast/anti-loop protection, and cross-catalog publication aggregation.
+
+## How It Works
+
+The test suite spins up **two isolated Nextcloud instances** (with a shared PostgreSQL database) in Docker, installs OpenRegister + OpenCatalogi on both, runs a comprehensive Newman test collection, then tears everything down. Nothing persists after the test — no leftover containers, volumes, or networks.
+
+## Quick Start
+
+```bash
+cd openregister
+bash tests/federation/run-federation-tests.sh
+```
+
+## Requirements
+
+- Docker + Docker Compose v2
+- Node.js / npm (for `npx newman`)
+- Ports 9081 and 9082 available (only used during the test run)
+
+## What Gets Tested
+
+### Phase 1: Health & Initialization
+- Both Nextcloud instances are healthy and responding
+- OpenRegister API is active on both instances
+- OpenCatalogi directory endpoint is active on both instances
+
+### Phase 2: Setup Catalogs & Publications
+- Get OpenCatalogi configuration from Instance 2
+- Create a catalog on Instance 2
+- Create a register + schema on Instance 2
+- Create two test publications on Instance 2
+- Verify Instance 2's directory shows its catalog
+
+### Phase 3: Directory Registration & Sync
+- Verify Instance 1 starts with no/minimal listings
+- Register Instance 2's directory URL on Instance 1
+- Verify listings appear after registration
+- Get individual listing details
+- Explicit directory sync
+- Verify directory includes Instance 2 entries
+
+### Phase 4: Listing CRUD
+- Create a manual listing
+- Update the listing
+- Read the updated listing
+- Delete the listing
+- Confirm deletion (404)
+
+### Phase 5: Federated Search & Publications
+- Aggregated federated publications list
+- Keyword search across federated catalogs
+- Pagination on federated search
+- Search endpoint (separate from federation)
+- Direct access to Instance 2's publications
+
+### Phase 6: Bidirectional Federation & Anti-Loop
+- Register Instance 1 as directory on Instance 2
+- Verify Instance 2 has listings from Instance 1
+- Bidirectional sync from Instance 1 (no infinite loop)
+- Bidirectional sync from Instance 2 (no infinite loop)
+- Federated search from Instance 2's perspective
+
+### Phase 7: Integration Level & Availability
+- Set listing integration level to `none`
+- Verify disabled listing is excluded from federated search
+- Re-enable listing integration level to `search`
+
+### Phase 8: Catalog CRUD
+- Create catalog on Instance 1
+- List catalogs
+- Get single catalog
+
+### Phase 9: Final State Verification
+- Final listing counts on both instances
+- Final directory state
+
+## Architecture
+
+```
+┌─────────────────────────────────────────────────────┐
+│ federation-test-network │
+│ │
+│ ┌──────────┐ ┌──────────┐ ┌──────────────┐ │
+│ │ nc-fed-1 │ │ nc-fed-2 │ │ federation-db│ │
+│ │ :9081 │◄──►│ :9082 │ │ PostgreSQL │ │
+│ │ │ │ │ │ nc1 + nc2 DBs│ │
+│ └────┬─────┘ └────┬─────┘ └──────┬───────┘ │
+│ │ │ │ │
+│ └───────────────┴────────────────┘ │
+└─────────────────────────────────────────────────────┘
+```
+
+- **nc-fed-1** (port 9081): The "home" catalog that discovers and searches others
+- **nc-fed-2** (port 9082): The "remote" catalog with test publications
+- **federation-db**: Shared PostgreSQL with two databases (`nc1`, `nc2`)
+- All on an isolated Docker network (`federation-test-network`)
+
+## Files
+
+| File | Purpose |
+|------|---------|
+| `docker-compose.federation.yml` | Two Nextcloud instances + shared DB |
+| `tests/federation/federation-tests.postman_collection.json` | Newman collection (9 phases, 30+ requests) |
+| `tests/federation/run-federation-tests.sh` | Orchestration: start, install, test, teardown |
+| `tests/federation/init-second-db.sql` | Creates the second PostgreSQL database |
+| `tests/federation/README.md` | This file |
+
+## Running Individual Phases
+
+You can run the Newman collection manually against already-running instances:
+
+```bash
+npx newman run tests/federation/federation-tests.postman_collection.json \
+ --env-var "nc1Url=http://localhost:9081" \
+ --env-var "nc2Url=http://localhost:9082" \
+ --env-var "nc2Internal=http://nc-fed-2" \
+ --folder "Phase 1: Health & Initialization"
+```
+
+## Troubleshooting
+
+### Containers fail to start
+- Check if ports 9081/9082 are in use: `ss -tlnp | grep 908`
+- Check Docker logs: `docker logs nc-fed-1` / `docker logs nc-fed-2`
+
+### Apps fail to enable
+- Check the Nextcloud log: `docker exec nc-fed-1 cat /var/www/html/data/nextcloud.log | tail -20`
+- Ensure the OpenRegister and OpenCatalogi source directories are present in the parent directory
+
+### Directory sync doesn't find remote instance
+- The `isLocalUrl()` filter in DirectoryService excludes localhost/private IPs, but Docker hostnames (`nc-fed-2`) pass through correctly
+- Check inter-container connectivity: `docker exec nc-fed-1 curl -s http://nc-fed-2/status.php`
+
+### Tests timeout
+- First run takes longer due to Nextcloud installation (can be 2-3 minutes per instance)
+- Increase `MAX_WAIT` in the shell script if needed
diff --git a/tests/federation/federation-tests.postman_collection.json b/tests/federation/federation-tests.postman_collection.json
new file mode 100644
index 000000000..b8d5c88ff
--- /dev/null
+++ b/tests/federation/federation-tests.postman_collection.json
@@ -0,0 +1,879 @@
+{
+ "info": {
+ "_postman_id": "opencatalogi-federation-tests",
+ "name": "OpenCatalogi - Federation Integration Tests",
+ "description": "Comprehensive federation tests for OpenCatalogi between two Nextcloud instances.\n\nPhases:\n1. Health & initialization (settings load, schema creation)\n2. Seed catalog + publications on Instance 2\n3. Directory registration & sync (+ seed listing if RBAC blocks sync)\n4. Listing CRUD\n5. Federated search & publications\n6. Bidirectional federation & anti-loop\n7. Integration level toggling\n8. Catalog operations on Instance 1\n9. Final state verification\n\nNote: The directory endpoint has a known RBAC issue where searchObjects returns 0 results in HTTP/PublicPage context. The tests work around this by seeding listing objects directly via the OpenRegister objects API when sync produces no results.",
+ "schema": "https://schema.getpostman.com/json/collection/v2.1.0/collection.json"
+ },
+ "auth": {
+ "type": "basic",
+ "basic": [
+ { "key": "username", "value": "admin", "type": "string" },
+ { "key": "password", "value": "admin", "type": "string" }
+ ]
+ },
+ "variable": [
+ { "key": "nc1Url", "value": "http://localhost:9081", "type": "string" },
+ { "key": "nc2Url", "value": "http://localhost:9082", "type": "string" },
+ { "key": "nc2Internal", "value": "http://nc-fed-2", "type": "string" },
+ { "key": "nc1CatalogRegisterId", "value": "", "type": "string" },
+ { "key": "nc1CatalogSchemaId", "value": "", "type": "string" },
+ { "key": "nc1ListingRegisterId", "value": "", "type": "string" },
+ { "key": "nc1ListingSchemaId", "value": "", "type": "string" },
+ { "key": "nc2CatalogRegisterId", "value": "", "type": "string" },
+ { "key": "nc2CatalogSchemaId", "value": "", "type": "string" },
+ { "key": "nc2ListingRegisterId", "value": "", "type": "string" },
+ { "key": "nc2ListingSchemaId", "value": "", "type": "string" },
+ { "key": "nc1CatalogId", "value": "", "type": "string" },
+ { "key": "nc2CatalogId", "value": "", "type": "string" },
+ { "key": "nc1ListingId", "value": "", "type": "string" },
+ { "key": "nc2ListingId", "value": "", "type": "string" },
+ { "key": "manualListingId", "value": "", "type": "string" },
+ { "key": "seededListingId", "value": "", "type": "string" },
+ { "key": "nc2PublicationSchemaId", "value": "", "type": "string" },
+ { "key": "nc2PublicationId1", "value": "", "type": "string" },
+ { "key": "nc2PublicationId2", "value": "", "type": "string" },
+ { "key": "nc2DefaultCatalogId", "value": "", "type": "string" },
+ { "key": "federatedResultCount", "value": "0", "type": "string" },
+ { "key": "nc1ListingCountBeforeSync", "value": "0", "type": "string" }
+ ],
+ "item": [
+ {
+ "name": "Phase 1: Health & Initialization",
+ "item": [
+ {
+ "name": "1.1 Health check — Instance 1",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Instance 1 is healthy', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.installed).to.be.true;",
+ " console.log('✅ Instance 1 ready — version: ' + json.versionstring);",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "auth": { "type": "noauth" }, "method": "GET", "url": { "raw": "{{nc1Url}}/status.php", "host": ["{{nc1Url}}"], "path": ["status.php"] } }
+ },
+ {
+ "name": "1.2 Health check — Instance 2",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Instance 2 is healthy', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.installed).to.be.true;",
+ " console.log('✅ Instance 2 ready — version: ' + json.versionstring);",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "auth": { "type": "noauth" }, "method": "GET", "url": { "raw": "{{nc2Url}}/status.php", "host": ["{{nc2Url}}"], "path": ["status.php"] } }
+ },
+ {
+ "name": "1.3 Get Instance 1 settings",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Got settings from Instance 1', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " var c = json.configuration || {};",
+ " pm.collectionVariables.set('nc1CatalogRegisterId', c.catalog_register || '');",
+ " pm.collectionVariables.set('nc1CatalogSchemaId', c.catalog_schema || '');",
+ " pm.collectionVariables.set('nc1ListingRegisterId', c.listing_register || '');",
+ " pm.collectionVariables.set('nc1ListingSchemaId', c.listing_schema || '');",
+ " pm.expect(c.catalog_register).to.not.be.empty;",
+ " pm.expect(c.listing_register).to.not.be.empty;",
+ " console.log('✅ NC1 catalog: register=' + c.catalog_register + ' schema=' + c.catalog_schema);",
+ " console.log('✅ NC1 listing: register=' + c.listing_register + ' schema=' + c.listing_schema);",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/settings", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "settings"] } }
+ },
+ {
+ "name": "1.4 Get Instance 2 settings",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Got settings from Instance 2', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " var c = json.configuration || {};",
+ " pm.collectionVariables.set('nc2CatalogRegisterId', c.catalog_register || '');",
+ " pm.collectionVariables.set('nc2CatalogSchemaId', c.catalog_schema || '');",
+ " pm.collectionVariables.set('nc2ListingRegisterId', c.listing_register || '');",
+ " pm.collectionVariables.set('nc2ListingSchemaId', c.listing_schema || '');",
+ " pm.expect(c.catalog_register).to.not.be.empty;",
+ " pm.expect(c.listing_register).to.not.be.empty;",
+ " console.log('✅ NC2 catalog: register=' + c.catalog_register + ' schema=' + c.catalog_schema);",
+ " console.log('✅ NC2 listing: register=' + c.listing_register + ' schema=' + c.listing_schema);",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc2Url}}/index.php/apps/opencatalogi/api/settings", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "settings"] } }
+ },
+ {
+ "name": "1.5 Verify directory endpoint on Instance 1",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Directory endpoint responds', function () {",
+ " pm.response.to.have.status(200);",
+ " console.log('✅ OpenCatalogi directory active on Instance 1');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/directory", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "directory"] } }
+ },
+ {
+ "name": "1.6 Verify directory endpoint on Instance 2",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Directory endpoint responds', function () {",
+ " pm.response.to.have.status(200);",
+ " console.log('✅ OpenCatalogi directory active on Instance 2');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc2Url}}/index.php/apps/opencatalogi/api/directory", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "directory"] } }
+ }
+ ]
+ },
+ {
+ "name": "Phase 2: Seed data on Instance 2",
+ "item": [
+ {
+ "name": "2.1 Find publication schema on Instance 2",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Found publication schema', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " var schemas = json.results || [];",
+ " var pubSchema = schemas.find(function(s) { return s.slug === 'publication'; });",
+ " pm.expect(pubSchema).to.not.be.undefined;",
+ " pm.collectionVariables.set('nc2PublicationSchemaId', pubSchema.id);",
+ " console.log('✅ Publication schema ID: ' + pubSchema.id + ' (slug: publication)');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc2Url}}/index.php/apps/openregister/api/schemas", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "openregister", "api", "schemas"] } }
+ },
+ {
+ "name": "2.2 Find default catalog on Instance 2",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Found default catalog', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " var catalogs = json.results || [];",
+ " pm.expect(catalogs.length).to.be.above(0);",
+ " var defCatalog = catalogs.find(function(c) { return c.slug === 'publications' || c.title === 'Publications'; });",
+ " pm.expect(defCatalog).to.not.be.undefined;",
+ " var id = (defCatalog['@self'] && defCatalog['@self'].id) || defCatalog.uuid || defCatalog.id;",
+ " pm.collectionVariables.set('nc2DefaultCatalogId', id);",
+ " console.log('✅ Default catalog ID: ' + id);",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc2Url}}/index.php/apps/opencatalogi/api/catalogi", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "catalogi"] } }
+ },
+ {
+ "name": "2.3 Update default catalog with publication register/schema references",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Catalog updated with register/schema references', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " console.log('✅ Default catalog updated — registers/schemas set');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": {
+ "method": "PUT",
+ "header": [{ "key": "Content-Type", "value": "application/json" }],
+ "body": { "mode": "raw", "raw": "{\n \"title\": \"Publications\",\n \"summary\": \"The main publications catalog\",\n \"listed\": true,\n \"status\": \"stable\",\n \"slug\": \"publications\",\n \"registers\": [\"{{nc2CatalogRegisterId}}\"],\n \"schemas\": [\"{{nc2PublicationSchemaId}}\"]\n}" },
+ "url": { "raw": "{{nc2Url}}/index.php/apps/openregister/api/objects/{{nc2CatalogRegisterId}}/{{nc2CatalogSchemaId}}/{{nc2DefaultCatalogId}}", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "openregister", "api", "objects", "{{nc2CatalogRegisterId}}", "{{nc2CatalogSchemaId}}", "{{nc2DefaultCatalogId}}"] }
+ }
+ },
+ {
+ "name": "2.4 Create publication 1 on Instance 2",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Publication 1 created', function () {",
+ " var status = pm.response.code;",
+ " pm.expect(status).to.be.oneOf([200, 201]);",
+ " var json = pm.response.json();",
+ " var id = json.uuid || json.id;",
+ " pm.expect(id).to.not.be.undefined;",
+ " pm.collectionVariables.set('nc2PublicationId1', id);",
+ " console.log('✅ Publication 1 created: ' + id + ' — \"Federation Alpha Document\"');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": {
+ "method": "POST",
+ "header": [{ "key": "Content-Type", "value": "application/json" }],
+ "body": { "mode": "raw", "raw": "{\n \"title\": \"Federation Alpha Document\",\n \"summary\": \"First test publication for cross-catalog federation search\",\n \"description\": \"This document is created on Instance 2 and should appear when Instance 1 performs a federated search.\"\n}" },
+ "url": { "raw": "{{nc2Url}}/index.php/apps/openregister/api/objects/{{nc2CatalogRegisterId}}/{{nc2PublicationSchemaId}}", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "openregister", "api", "objects", "{{nc2CatalogRegisterId}}", "{{nc2PublicationSchemaId}}"] }
+ }
+ },
+ {
+ "name": "2.5 Create publication 2 on Instance 2",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Publication 2 created', function () {",
+ " var status = pm.response.code;",
+ " pm.expect(status).to.be.oneOf([200, 201]);",
+ " var json = pm.response.json();",
+ " var id = json.uuid || json.id;",
+ " pm.expect(id).to.not.be.undefined;",
+ " pm.collectionVariables.set('nc2PublicationId2', id);",
+ " console.log('✅ Publication 2 created: ' + id + ' — \"Federation Beta Report\"');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": {
+ "method": "POST",
+ "header": [{ "key": "Content-Type", "value": "application/json" }],
+ "body": { "mode": "raw", "raw": "{\n \"title\": \"Federation Beta Report\",\n \"summary\": \"Second test publication for validating federated search pagination\",\n \"description\": \"Created on Instance 2. Used to verify that multiple publications are returned in federated search results.\"\n}" },
+ "url": { "raw": "{{nc2Url}}/index.php/apps/openregister/api/objects/{{nc2CatalogRegisterId}}/{{nc2PublicationSchemaId}}", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "openregister", "api", "objects", "{{nc2CatalogRegisterId}}", "{{nc2PublicationSchemaId}}"] }
+ }
+ },
+ {
+ "name": "2.6 Verify publications visible on Instance 2",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Instance 2 has local publications', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results).to.be.an('array');",
+ " pm.expect(json.results.length).to.be.at.least(2);",
+ " console.log('✅ Instance 2 has ' + json.results.length + ' publications in federation endpoint');",
+ " // Verify our publications are among them",
+ " var titles = json.results.map(function(r) { return r.title || (r.object && r.object.title); });",
+ " console.log(' Titles: ' + titles.join(', '));",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc2Url}}/index.php/apps/opencatalogi/api/federation/publications?_aggregate=false", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "federation", "publications"], "query": [{ "key": "_aggregate", "value": "false" }] } }
+ },
+ {
+ "name": "2.7 Create additional catalog on Instance 2",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Catalog created on Instance 2', function () {",
+ " var status = pm.response.code;",
+ " pm.expect(status).to.be.oneOf([200, 201]);",
+ " var json = pm.response.json();",
+ " var id = json.uuid || json.id;",
+ " pm.expect(id).to.not.be.undefined;",
+ " pm.collectionVariables.set('nc2CatalogId', id);",
+ " console.log('✅ Catalog created on Instance 2: ' + id);",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": {
+ "method": "POST",
+ "header": [{ "key": "Content-Type", "value": "application/json" }],
+ "body": { "mode": "raw", "raw": "{\n \"title\": \"Federation Remote Catalog\",\n \"summary\": \"Test catalog on Instance 2 for federation testing\",\n \"listed\": true,\n \"slug\": \"federation-remote\"\n}" },
+ "url": { "raw": "{{nc2Url}}/index.php/apps/openregister/api/objects/{{nc2CatalogRegisterId}}/{{nc2CatalogSchemaId}}", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "openregister", "api", "objects", "{{nc2CatalogRegisterId}}", "{{nc2CatalogSchemaId}}"] }
+ }
+ },
+ {
+ "name": "2.2 Verify catalog in catalogi list",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Catalog appears in list', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results).to.be.an('array');",
+ " pm.expect(json.results.length).to.be.above(0);",
+ " console.log('✅ Instance 2 has ' + json.results.length + ' catalogs');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc2Url}}/index.php/apps/opencatalogi/api/catalogi", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "catalogi"] } }
+ },
+ {
+ "name": "2.3 Check Instance 2 directory (documents RBAC issue)",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Directory shows catalogs publicly', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results).to.be.an('array');",
+ " pm.expect(json.results.length).to.be.above(0, 'Directory should show catalogs (RBAC read:public + multitenancy disabled)');",
+ " console.log('✅ Instance 2 directory has ' + json.results.length + ' entries');",
+ " json.results.forEach(function(r) {",
+ " console.log(' → ' + (r.title || r.name || 'untitled'));",
+ " });",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc2Url}}/index.php/apps/opencatalogi/api/directory", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "directory"] } }
+ }
+ ]
+ },
+ {
+ "name": "Phase 3: Directory sync + seed listing",
+ "item": [
+ {
+ "name": "3.1 Instance 1 listings initially empty",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Instance 1 starts empty', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results).to.be.an('array');",
+ " console.log('✅ Instance 1 starts with ' + json.results.length + ' listings');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings"] } }
+ },
+ {
+ "name": "3.2 Attempt directory sync (add NC2)",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Directory registration accepted', function () {",
+ " var status = pm.response.code;",
+ " pm.expect(status).to.be.oneOf([200, 201, 202]);",
+ " var json = pm.response.json();",
+ " var created = json.listings_created || 0;",
+ " if (created > 0) {",
+ " console.log('✅ Directory sync created ' + created + ' listings (RBAC issue resolved!)');",
+ " } else {",
+ " console.log('⚠️ Directory sync created 0 listings (expected — RBAC issue). Will seed listing directly.');",
+ " }",
+ " pm.collectionVariables.set('syncCreatedListings', created);",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": {
+ "method": "POST",
+ "header": [{ "key": "Content-Type", "value": "application/json" }],
+ "body": { "mode": "raw", "raw": "{\n \"url\": \"{{nc2Internal}}/index.php/apps/opencatalogi/api/directory\"\n}" },
+ "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings/add", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings", "add"] }
+ }
+ },
+ {
+ "name": "3.3 Seed listing on Instance 1 (pointing to Instance 2)",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Listing seeded on Instance 1', function () {",
+ " var status = pm.response.code;",
+ " pm.expect(status).to.be.oneOf([200, 201]);",
+ " var json = pm.response.json();",
+ " var id = json.uuid || json.id;",
+ " pm.expect(id).to.not.be.undefined;",
+ " pm.collectionVariables.set('seededListingId', id);",
+ " pm.collectionVariables.set('nc1ListingId', id);",
+ " console.log('✅ Seeded listing on Instance 1: ' + id);",
+ " console.log(' Points to NC2 publications + search endpoints');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": {
+ "method": "POST",
+ "header": [{ "key": "Content-Type", "value": "application/json" }],
+ "body": { "mode": "raw", "raw": "{\n \"catalogusId\": \"federation-remote-seed\",\n \"title\": \"Federation Remote (Seeded)\",\n \"summary\": \"Seeded listing pointing to Instance 2 — workaround for directory RBAC issue\",\n \"directory\": \"{{nc2Internal}}/index.php/apps/opencatalogi/api/directory\",\n \"search\": \"{{nc2Internal}}/index.php/apps/opencatalogi/api/search\",\n \"publications\": \"{{nc2Internal}}/index.php/apps/opencatalogi/api/federation/publications\",\n \"integrationLevel\": \"search\",\n \"default\": false,\n \"status\": \"stable\",\n \"statusCode\": 200\n}" },
+ "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings"] }
+ }
+ },
+ {
+ "name": "3.4 Verify listing exists on Instance 1",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Instance 1 has listing(s)', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results).to.be.an('array');",
+ " pm.expect(json.results.length).to.be.above(0);",
+ " console.log('✅ Instance 1 now has ' + json.results.length + ' listing(s)');",
+ " ",
+ " // Store listing ID from response — list items use @self.id, not top-level id",
+ " var listing = json.results[0];",
+ " var id = (listing['@self'] && listing['@self'].id) || listing.uuid || listing.id;",
+ " pm.collectionVariables.set('nc1ListingId', id);",
+ " var data = listing.object || listing;",
+ " console.log(' ID: ' + id);",
+ " console.log(' Title: ' + (data.title || 'N/A'));",
+ " console.log(' Integration: ' + (data.integrationLevel || 'N/A'));",
+ " console.log(' Publications: ' + (data.publications || 'N/A'));",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings"] } }
+ },
+ {
+ "name": "3.5 Get seeded listing details",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Listing details correct', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " var data = json.object || json;",
+ " pm.expect(data.title).to.not.be.undefined;",
+ " console.log('✅ Listing details:');",
+ " console.log(' Title: ' + (data.title || 'N/A'));",
+ " console.log(' Directory: ' + (data.directory || 'N/A'));",
+ " console.log(' Search: ' + (data.search || 'N/A'));",
+ " console.log(' Publications: ' + (data.publications || 'N/A'));",
+ " console.log(' IntegrationLevel: ' + (data.integrationLevel || 'N/A'));",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings/{{nc1ListingId}}", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings", "{{nc1ListingId}}"] } }
+ },
+ {
+ "name": "3.6 Sync directories explicitly",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Directory sync completed', function () {",
+ " var status = pm.response.code;",
+ " pm.expect(status).to.be.oneOf([200, 201, 202]);",
+ " console.log('✅ Directory sync executed');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": {
+ "method": "POST",
+ "header": [{ "key": "Content-Type", "value": "application/json" }],
+ "body": { "mode": "raw", "raw": "{}" },
+ "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings/sync", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings", "sync"] }
+ }
+ }
+ ]
+ },
+ {
+ "name": "Phase 4: Listing CRUD",
+ "item": [
+ {
+ "name": "4.1 Create a manual listing",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Manual listing created', function () {",
+ " var status = pm.response.code;",
+ " pm.expect(status).to.be.oneOf([200, 201]);",
+ " var json = pm.response.json();",
+ " var id = json.uuid || json.id;",
+ " pm.expect(id).to.not.be.undefined;",
+ " pm.collectionVariables.set('manualListingId', id);",
+ " console.log('✅ Manual listing created: ' + id);",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": {
+ "method": "POST",
+ "header": [{ "key": "Content-Type", "value": "application/json" }],
+ "body": { "mode": "raw", "raw": "{\n \"catalogusId\": \"manual-crud-test\",\n \"title\": \"Manual CRUD Listing\",\n \"summary\": \"Testing create/read/update/delete lifecycle\",\n \"directory\": \"https://example.com/api/directory\",\n \"default\": false\n}" },
+ "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings"] }
+ }
+ },
+ {
+ "name": "4.2 Update the manual listing",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Listing updated', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " var data = json.object || json;",
+ " console.log('✅ Listing updated — title: ' + (data.title || 'N/A'));",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": {
+ "method": "PUT",
+ "header": [{ "key": "Content-Type", "value": "application/json" }],
+ "body": { "mode": "raw", "raw": "{\n \"catalogusId\": \"manual-crud-test\",\n \"title\": \"Updated CRUD Listing\",\n \"summary\": \"Updated via PUT — verifying update works\"\n}" },
+ "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings/{{manualListingId}}", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings", "{{manualListingId}}"] }
+ }
+ },
+ {
+ "name": "4.3 Read updated listing",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Listing reflects update', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " var data = json.object || json;",
+ " pm.expect(data.title).to.eql('Updated CRUD Listing');",
+ " console.log('✅ Read back — title: ' + data.title);",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings/{{manualListingId}}", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings", "{{manualListingId}}"] } }
+ },
+ {
+ "name": "4.4 Delete the manual listing",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Listing deleted', function () {",
+ " var status = pm.response.code;",
+ " pm.expect(status).to.be.oneOf([200, 204]);",
+ " console.log('✅ Manual listing deleted');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "DELETE", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings/{{manualListingId}}", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings", "{{manualListingId}}"] } }
+ },
+ {
+ "name": "4.5 Confirm deletion",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Deleted listing is gone', function () {",
+ " var status = pm.response.code;",
+ " pm.expect(status).to.be.oneOf([404, 400, 500]);",
+ " console.log('✅ Listing confirmed gone (status: ' + status + ')');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings/{{manualListingId}}", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings", "{{manualListingId}}"] } }
+ },
+ {
+ "name": "4.6 Verify seeded listing still exists after CRUD",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Seeded listing survives CRUD on other listing', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " var data = json.object || json;",
+ " pm.expect(data.title).to.include('Federation Remote');",
+ " console.log('✅ Seeded listing intact: ' + data.title);",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings/{{seededListingId}}", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings", "{{seededListingId}}"] } }
+ }
+ ]
+ },
+ {
+ "name": "Phase 5: Federated search & publications",
+ "item": [
+ {
+ "name": "5.1 Federated publications (aggregated from Instance 2)",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Federated publications returns remote results', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results).to.be.an('array');",
+ " pm.expect(json.results.length).to.be.at.least(2, 'Expected at least 2 publications from Instance 2');",
+ " pm.collectionVariables.set('federatedResultCount', json.results.length.toString());",
+ " console.log('✅ Federated publications: ' + json.results.length + ' results');",
+ " if (json.total !== undefined) console.log(' Total: ' + json.total);",
+ " // Verify publications have titles",
+ " json.results.forEach(function(r, i) {",
+ " var title = r.title || (r.object && r.object.title) || 'untitled';",
+ " console.log(' [' + i + '] ' + title);",
+ " });",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/federation/publications?_aggregate=true", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "federation", "publications"], "query": [{ "key": "_aggregate", "value": "true" }] } }
+ },
+ {
+ "name": "5.2 Federated search with keyword 'Alpha'",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Keyword search returns matching results', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results).to.be.an('array');",
+ " console.log('✅ Search for \"Alpha\": ' + json.results.length + ' results');",
+ " // Log titles to verify relevance",
+ " json.results.forEach(function(r) {",
+ " var title = r.title || (r.object && r.object.title) || 'untitled';",
+ " console.log(' → ' + title);",
+ " });",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/federation/publications?_search=Alpha&_aggregate=true", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "federation", "publications"], "query": [{ "key": "_search", "value": "Alpha" }, { "key": "_aggregate", "value": "true" }] } }
+ },
+ {
+ "name": "5.3 Federated search with pagination (limit=1)",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Pagination limits results correctly', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results).to.be.an('array');",
+ " pm.expect(json.results.length).to.be.at.most(1, 'Pagination limit=1 should return max 1 result');",
+ " console.log('✅ Paginated: ' + json.results.length + ' result(s) with limit=1');",
+ " if (json.total !== undefined) {",
+ " pm.expect(json.total).to.be.at.least(2, 'Total should still reflect all available results');",
+ " console.log(' Total available: ' + json.total);",
+ " }",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/federation/publications?_limit=1&_page=1&_aggregate=true", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "federation", "publications"], "query": [{ "key": "_limit", "value": "1" }, { "key": "_page", "value": "1" }, { "key": "_aggregate", "value": "true" }] } }
+ },
+ {
+ "name": "5.4 Local search on Instance 2 (has publications)",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Local search finds publications on Instance 2', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results).to.be.an('array');",
+ " pm.expect(json.results.length).to.be.at.least(1, 'Instance 2 should find its local publications');",
+ " console.log('✅ Instance 2 local search: ' + json.results.length + ' results for \"Federation\"');",
+ " json.results.forEach(function(r) {",
+ " var title = r.title || (r.object && r.object.title) || 'untitled';",
+ " console.log(' → ' + title);",
+ " });",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc2Url}}/index.php/apps/opencatalogi/api/search?_search=Federation", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "search"], "query": [{ "key": "_search", "value": "Federation" }] } }
+ },
+ {
+ "name": "5.5 Local search on Instance 1 (no local publications)",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Instance 1 local search returns empty (no local publications)', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results).to.be.an('array');",
+ " console.log('✅ Instance 1 local search: ' + json.results.length + ' results (expected 0 — publications are on Instance 2)');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/search?_search=Federation", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "search"], "query": [{ "key": "_search", "value": "Federation" }] } }
+ }
+ ]
+ },
+ {
+ "name": "Phase 6: Bidirectional federation & anti-loop",
+ "item": [
+ {
+ "name": "6.1 Seed listing on Instance 2 (pointing to Instance 1)",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Reverse listing seeded on Instance 2', function () {",
+ " var status = pm.response.code;",
+ " pm.expect(status).to.be.oneOf([200, 201]);",
+ " var json = pm.response.json();",
+ " var id = json.uuid || json.id;",
+ " pm.expect(id).to.not.be.undefined;",
+ " pm.collectionVariables.set('nc2ListingId', id);",
+ " console.log('✅ Reverse listing on Instance 2: ' + id);",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": {
+ "method": "POST",
+ "header": [{ "key": "Content-Type", "value": "application/json" }],
+ "body": { "mode": "raw", "raw": "{\n \"catalogusId\": \"federation-home-seed\",\n \"title\": \"Federation Home (Seeded)\",\n \"summary\": \"Reverse listing pointing to Instance 1\",\n \"directory\": \"http://nc-fed-1/index.php/apps/opencatalogi/api/directory\",\n \"search\": \"http://nc-fed-1/index.php/apps/opencatalogi/api/search\",\n \"publications\": \"http://nc-fed-1/index.php/apps/opencatalogi/api/federation/publications\",\n \"integrationLevel\": \"search\",\n \"default\": false,\n \"status\": \"stable\",\n \"statusCode\": 200\n}" },
+ "url": { "raw": "{{nc2Url}}/index.php/apps/opencatalogi/api/listings", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings"] }
+ }
+ },
+ {
+ "name": "6.2 Verify Instance 2 has listings",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Instance 2 has listings', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results).to.be.an('array');",
+ " pm.expect(json.results.length).to.be.above(0);",
+ " console.log('✅ Instance 2 has ' + json.results.length + ' listing(s)');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc2Url}}/index.php/apps/opencatalogi/api/listings", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings"] } }
+ },
+ {
+ "name": "6.3 Count listings before bidirectional sync",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Baseline listing count captured', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.collectionVariables.set('nc1ListingCountBeforeSync', json.results.length.toString());",
+ " console.log('✅ Instance 1 has ' + json.results.length + ' listing(s) before bidirectional sync');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings"] } }
+ },
+ {
+ "name": "6.4 Bidirectional sync from Instance 1",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Bidirectional sync completes without loop', function () {",
+ " var status = pm.response.code;",
+ " pm.expect(status).to.be.oneOf([200, 201, 202]);",
+ " var json = pm.response.json();",
+ " console.log('✅ NC1 sync completed');",
+ " if (json.listings_created !== undefined) {",
+ " console.log(' Created: ' + json.listings_created + ', Updated: ' + json.listings_updated + ', Skipped: ' + json.listings_skipped);",
+ " }",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": {
+ "method": "POST",
+ "header": [{ "key": "Content-Type", "value": "application/json" }],
+ "body": { "mode": "raw", "raw": "{}" },
+ "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings/sync", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings", "sync"] }
+ }
+ },
+ {
+ "name": "6.5 Bidirectional sync from Instance 2",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Bidirectional sync from NC2 completes', function () {",
+ " var status = pm.response.code;",
+ " pm.expect(status).to.be.oneOf([200, 201, 202]);",
+ " var json = pm.response.json();",
+ " console.log('✅ NC2 sync completed');",
+ " if (json.listings_created !== undefined) {",
+ " console.log(' Created: ' + json.listings_created + ', Updated: ' + json.listings_updated + ', Skipped: ' + json.listings_skipped);",
+ " }",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": {
+ "method": "POST",
+ "header": [{ "key": "Content-Type", "value": "application/json" }],
+ "body": { "mode": "raw", "raw": "{}" },
+ "url": { "raw": "{{nc2Url}}/index.php/apps/opencatalogi/api/listings/sync", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings", "sync"] }
+ }
+ },
+ {
+ "name": "6.6 Verify no duplicate listings after sync",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('No duplicate listings created by sync', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " var beforeCount = parseInt(pm.collectionVariables.get('nc1ListingCountBeforeSync') || '0');",
+ " var afterCount = json.results.length;",
+ " pm.expect(afterCount).to.be.at.most(beforeCount + 1, 'Sync should not create excessive duplicate listings');",
+ " console.log('✅ Listing count: before=' + beforeCount + ', after=' + afterCount + ' (no duplicates)');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings"] } }
+ },
+ {
+ "name": "6.5 Federated search from Instance 2",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Instance 2 can search federation', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results).to.be.an('array');",
+ " console.log('✅ Instance 2 federated search: ' + json.results.length + ' results');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc2Url}}/index.php/apps/opencatalogi/api/federation/publications?_aggregate=true", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "federation", "publications"], "query": [{ "key": "_aggregate", "value": "true" }] } }
+ }
+ ]
+ },
+ {
+ "name": "Phase 7: Integration level toggling",
+ "item": [
+ {
+ "name": "7.1 Disable listing (set integrationLevel to none)",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Integration level set to none', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " var data = json.object || json;",
+ " pm.expect(data.integrationLevel).to.eql('none');",
+ " console.log('✅ Listing integration level set to none');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": {
+ "method": "PUT",
+ "header": [{ "key": "Content-Type", "value": "application/json" }],
+ "body": { "mode": "raw", "raw": "{\n \"catalogusId\": \"federation-remote-seed\",\n \"title\": \"Federation Remote (Seeded)\",\n \"summary\": \"Seeded listing — now DISABLED\",\n \"integrationLevel\": \"none\"\n}" },
+ "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings/{{nc1ListingId}}", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings", "{{nc1ListingId}}"] }
+ }
+ },
+ {
+ "name": "7.2 Verify listing shows as disabled",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Listing is disabled', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " var data = json.object || json;",
+ " pm.expect(data.integrationLevel).to.eql('none');",
+ " console.log('✅ Listing confirmed disabled — integrationLevel: ' + data.integrationLevel);",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings/{{nc1ListingId}}", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings", "{{nc1ListingId}}"] } }
+ },
+ {
+ "name": "7.3 Federated search excludes disabled listing",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Disabled listing excluded from federated search', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results).to.be.an('array');",
+ " var prevCount = parseInt(pm.collectionVariables.get('federatedResultCount') || '0');",
+ " if (prevCount > 0) {",
+ " pm.expect(json.results.length).to.be.below(prevCount, 'Results should decrease after disabling listing');",
+ " console.log('✅ Results decreased: ' + prevCount + ' → ' + json.results.length + ' (remote excluded)');",
+ " } else {",
+ " console.log('✅ Federated search with disabled listing: ' + json.results.length + ' results');",
+ " }",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/federation/publications?_aggregate=true", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "federation", "publications"], "query": [{ "key": "_aggregate", "value": "true" }] } }
+ },
+ {
+ "name": "7.4 Re-enable listing (set integrationLevel to search)",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Integration level restored to search', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " var data = json.object || json;",
+ " pm.expect(data.integrationLevel).to.eql('search');",
+ " console.log('✅ Listing integration level restored to search');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": {
+ "method": "PUT",
+ "header": [{ "key": "Content-Type", "value": "application/json" }],
+ "body": { "mode": "raw", "raw": "{\n \"catalogusId\": \"federation-remote-seed\",\n \"title\": \"Federation Remote (Seeded)\",\n \"summary\": \"Seeded listing — re-enabled\",\n \"integrationLevel\": \"search\"\n}" },
+ "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings/{{nc1ListingId}}", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings", "{{nc1ListingId}}"] }
+ }
+ },
+ {
+ "name": "7.5 Verify re-enabled listing",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Listing is re-enabled', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " var data = json.object || json;",
+ " pm.expect(data.integrationLevel).to.eql('search');",
+ " console.log('✅ Listing confirmed re-enabled — integrationLevel: ' + data.integrationLevel);",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings/{{nc1ListingId}}", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings", "{{nc1ListingId}}"] } }
+ }
+ ]
+ },
+ {
+ "name": "Phase 8: Catalog operations on Instance 1",
+ "item": [
+ {
+ "name": "8.1 Create catalog on Instance 1",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Catalog created on Instance 1', function () {",
+ " var status = pm.response.code;",
+ " pm.expect(status).to.be.oneOf([200, 201]);",
+ " var json = pm.response.json();",
+ " var id = json.uuid || json.id;",
+ " pm.expect(id).to.not.be.undefined;",
+ " pm.collectionVariables.set('nc1CatalogId', id);",
+ " console.log('✅ Catalog created: ' + id);",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": {
+ "method": "POST",
+ "header": [{ "key": "Content-Type", "value": "application/json" }],
+ "body": { "mode": "raw", "raw": "{\n \"title\": \"Federation Home Catalog\",\n \"summary\": \"Local catalog on Instance 1\",\n \"listed\": true,\n \"slug\": \"federation-home\"\n}" },
+ "url": { "raw": "{{nc1Url}}/index.php/apps/openregister/api/objects/{{nc1CatalogRegisterId}}/{{nc1CatalogSchemaId}}", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "openregister", "api", "objects", "{{nc1CatalogRegisterId}}", "{{nc1CatalogSchemaId}}"] }
+ }
+ },
+ {
+ "name": "8.2 List catalogs",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Catalogs listed', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results).to.be.an('array');",
+ " pm.expect(json.results.length).to.be.above(0);",
+ " console.log('✅ Instance 1 has ' + json.results.length + ' catalogs');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/catalogi", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "catalogi"] } }
+ },
+ {
+ "name": "8.3 Get single catalog (via OpenRegister)",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Catalog retrieved', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.title).to.eql('Federation Home Catalog');",
+ " console.log('✅ Catalog: ' + json.title);",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/openregister/api/objects/{{nc1CatalogRegisterId}}/{{nc1CatalogSchemaId}}/{{nc1CatalogId}}", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "openregister", "api", "objects", "{{nc1CatalogRegisterId}}", "{{nc1CatalogSchemaId}}", "{{nc1CatalogId}}"] } }
+ }
+ ]
+ },
+ {
+ "name": "Phase 9: Final state verification",
+ "item": [
+ {
+ "name": "9.1 Final listings on Instance 1",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Final state — Instance 1', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results.length).to.be.above(0);",
+ " console.log('✅ Final: Instance 1 has ' + json.results.length + ' listing(s)');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/listings", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings"] } }
+ },
+ {
+ "name": "9.2 Final listings on Instance 2",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Final state — Instance 2', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " pm.expect(json.results.length).to.be.above(0);",
+ " console.log('✅ Final: Instance 2 has ' + json.results.length + ' listing(s)');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc2Url}}/index.php/apps/opencatalogi/api/listings", "host": ["{{nc2Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "listings"] } }
+ },
+ {
+ "name": "9.3 Final directory state",
+ "event": [{ "listen": "test", "script": { "exec": [
+ "pm.test('Final directory state', function () {",
+ " pm.response.to.have.status(200);",
+ " var json = pm.response.json();",
+ " console.log('✅ Final: directory has ' + json.results.length + ' entries');",
+ " console.log('');",
+ " console.log('========================================');",
+ " console.log(' Federation test suite completed!');",
+ " console.log('========================================');",
+ "});"
+ ], "type": "text/javascript" }}],
+ "request": { "method": "GET", "url": { "raw": "{{nc1Url}}/index.php/apps/opencatalogi/api/directory", "host": ["{{nc1Url}}"], "path": ["index.php", "apps", "opencatalogi", "api", "directory"] } }
+ }
+ ]
+ }
+ ]
+}
diff --git a/tests/federation/init-databases.sql b/tests/federation/init-databases.sql
new file mode 100644
index 000000000..428d372cc
--- /dev/null
+++ b/tests/federation/init-databases.sql
@@ -0,0 +1,31 @@
+-- Federation test: initialize both databases with required extensions
+-- Runs on the default database (nc1) first, then creates and configures nc2
+
+-- Extensions for nc1 (default database)
+CREATE EXTENSION IF NOT EXISTS vector;
+CREATE EXTENSION IF NOT EXISTS pg_trgm;
+CREATE EXTENSION IF NOT EXISTS btree_gin;
+CREATE EXTENSION IF NOT EXISTS btree_gist;
+CREATE EXTENSION IF NOT EXISTS "uuid-ossp";
+
+ALTER DATABASE nc1 SET pg_trgm.similarity_threshold = 0.3;
+ALTER DATABASE nc1 SET maintenance_work_mem = '256MB';
+
+-- Create and configure nc2
+CREATE DATABASE nc2 OWNER nextcloud;
+
+\connect nc2;
+
+CREATE EXTENSION IF NOT EXISTS vector;
+CREATE EXTENSION IF NOT EXISTS pg_trgm;
+CREATE EXTENSION IF NOT EXISTS btree_gin;
+CREATE EXTENSION IF NOT EXISTS btree_gist;
+CREATE EXTENSION IF NOT EXISTS "uuid-ossp";
+
+ALTER DATABASE nc2 SET pg_trgm.similarity_threshold = 0.3;
+ALTER DATABASE nc2 SET maintenance_work_mem = '256MB';
+
+DO $$
+BEGIN
+ RAISE NOTICE 'Federation test databases initialized: nc1 + nc2';
+END $$;
diff --git a/tests/federation/init-second-db.sql b/tests/federation/init-second-db.sql
new file mode 100644
index 000000000..acd761214
--- /dev/null
+++ b/tests/federation/init-second-db.sql
@@ -0,0 +1,21 @@
+-- Create second database for federation testing
+-- This runs automatically via docker-entrypoint-initdb.d
+
+CREATE DATABASE nc2 OWNER nextcloud;
+
+-- Enable extensions on the second database
+\connect nc2;
+
+CREATE EXTENSION IF NOT EXISTS vector;
+CREATE EXTENSION IF NOT EXISTS pg_trgm;
+CREATE EXTENSION IF NOT EXISTS btree_gin;
+CREATE EXTENSION IF NOT EXISTS btree_gist;
+CREATE EXTENSION IF NOT EXISTS "uuid-ossp";
+
+ALTER DATABASE nc2 SET pg_trgm.similarity_threshold = 0.3;
+ALTER DATABASE nc2 SET maintenance_work_mem = '256MB';
+
+DO $$
+BEGIN
+ RAISE NOTICE 'Federation test: second database (nc2) initialized successfully';
+END $$;
diff --git a/tests/federation/run-federation-tests.sh b/tests/federation/run-federation-tests.sh
new file mode 100755
index 000000000..46b616cfb
--- /dev/null
+++ b/tests/federation/run-federation-tests.sh
@@ -0,0 +1,284 @@
+#!/bin/bash
+# =============================================================================
+# OpenCatalogi Federation Integration Tests
+# =============================================================================
+#
+# Spins up two isolated Nextcloud instances, installs OpenRegister + OpenCatalogi
+# on both, runs the Newman federation test collection, then tears everything down.
+#
+# Usage:
+# bash tests/federation/run-federation-tests.sh
+#
+# Requirements:
+# - Docker + Docker Compose v2
+# - npm (for npx newman)
+# - Ports 9081 and 9082 available
+#
+# =============================================================================
+
+set -euo pipefail
+
+# ---- Configuration ----------------------------------------------------------
+SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
+PROJECT_DIR="$(cd "$SCRIPT_DIR/../.." && pwd)"
+COMPOSE_FILE="$PROJECT_DIR/docker-compose.federation.yml"
+COMPOSE_CMD="docker compose -p federation-test -f $COMPOSE_FILE"
+COLLECTION="$SCRIPT_DIR/federation-tests.postman_collection.json"
+
+NC1_URL="http://localhost:9081"
+NC2_URL="http://localhost:9082"
+NC2_INTERNAL="http://nc-fed-2"
+
+NC1_CONTAINER="nc-fed-1"
+NC2_CONTAINER="nc-fed-2"
+DB_CONTAINER="federation-db"
+
+ADMIN_USER="admin"
+ADMIN_PASS="admin"
+
+MAX_WAIT=300 # Max seconds to wait for containers to be healthy
+INSTALL_WAIT=30 # Seconds to wait after app install for initialization
+
+# ---- Colors -----------------------------------------------------------------
+RED='\033[0;31m'
+GREEN='\033[0;32m'
+BLUE='\033[0;34m'
+YELLOW='\033[1;33m'
+NC='\033[0m'
+
+# ---- Helper functions -------------------------------------------------------
+log() { echo -e "${BLUE}[INFO]${NC} $1"; }
+success() { echo -e "${GREEN}[PASS]${NC} $1"; }
+warn() { echo -e "${YELLOW}[WARN]${NC} $1"; }
+error() { echo -e "${RED}[FAIL]${NC} $1"; }
+
+# ---- Cleanup (runs on exit) ------------------------------------------------
+cleanup() {
+ local exit_code=$?
+ echo ""
+ log "Tearing down federation test environment..."
+ cd "$PROJECT_DIR"
+ $COMPOSE_CMD down -v --remove-orphans 2>/dev/null || true
+
+ if [ $exit_code -eq 0 ]; then
+ success "Federation tests completed successfully!"
+ else
+ error "Federation tests failed (exit code: $exit_code)"
+ fi
+
+ exit $exit_code
+}
+trap cleanup EXIT
+
+# ---- Pre-flight checks -----------------------------------------------------
+log "Running pre-flight checks..."
+
+if ! command -v docker &>/dev/null; then
+ error "Docker is not installed"
+ exit 1
+fi
+
+if ! docker compose version &>/dev/null; then
+ error "Docker Compose v2 is not available"
+ exit 1
+fi
+
+if ! command -v npx &>/dev/null; then
+ error "npx is not available (install Node.js)"
+ exit 1
+fi
+
+if ! [ -f "$COMPOSE_FILE" ]; then
+ error "docker-compose.federation.yml not found at $COMPOSE_FILE"
+ exit 1
+fi
+
+if ! [ -f "$COLLECTION" ]; then
+ error "Newman collection not found at $COLLECTION"
+ exit 1
+fi
+
+# Check if ports are available
+for port in 9081 9082; do
+ if ss -tlnp 2>/dev/null | grep -q ":$port "; then
+ error "Port $port is already in use"
+ exit 1
+ fi
+done
+
+success "Pre-flight checks passed"
+
+# ---- Start containers -------------------------------------------------------
+echo ""
+echo "============================================"
+echo " OpenCatalogi Federation Test Suite"
+echo "============================================"
+echo ""
+
+log "Starting federation test environment..."
+cd "$PROJECT_DIR"
+
+# Clean up any previous run
+$COMPOSE_CMD down -v --remove-orphans 2>/dev/null || true
+
+# Start fresh
+$COMPOSE_CMD up -d
+
+# ---- Wait for database ------------------------------------------------------
+log "Waiting for database to be ready..."
+elapsed=0
+while ! docker exec "$DB_CONTAINER" pg_isready -U nextcloud -d nc1 &>/dev/null; do
+ sleep 2
+ elapsed=$((elapsed + 2))
+ if [ $elapsed -ge $MAX_WAIT ]; then
+ error "Database did not become ready within ${MAX_WAIT}s"
+ exit 1
+ fi
+done
+success "Database ready (${elapsed}s)"
+
+# ---- Wait for Nextcloud instances -------------------------------------------
+wait_for_nextcloud() {
+ local container=$1
+ local url=$2
+ local name=$3
+ local elapsed=0
+
+ log "Waiting for $name ($container) to be ready..."
+ while true; do
+ # Check if container is still running
+ if ! docker ps --format '{{.Names}}' | grep -q "^${container}$"; then
+ error "$name container is not running"
+ docker logs "$container" 2>&1 | tail -20
+ exit 1
+ fi
+
+ # Check HTTP status
+ if curl -sf "$url/status.php" 2>/dev/null | grep -q '"installed":true'; then
+ success "$name is ready (${elapsed}s)"
+ return 0
+ fi
+
+ sleep 5
+ elapsed=$((elapsed + 5))
+ if [ $elapsed -ge $MAX_WAIT ]; then
+ error "$name did not become ready within ${MAX_WAIT}s"
+ docker logs "$container" 2>&1 | tail -30
+ exit 1
+ fi
+
+ # Progress indicator every 30 seconds
+ if [ $((elapsed % 30)) -eq 0 ]; then
+ log " Still waiting for $name... (${elapsed}s)"
+ fi
+ done
+}
+
+wait_for_nextcloud "$NC1_CONTAINER" "$NC1_URL" "Instance 1"
+wait_for_nextcloud "$NC2_CONTAINER" "$NC2_URL" "Instance 2"
+
+# ---- Install apps on both instances -----------------------------------------
+install_apps() {
+ local container=$1
+ local name=$2
+
+ log "Installing apps on $name..."
+
+ # Enable OpenRegister
+ if docker exec -u www-data "$container" php occ app:enable openregister 2>&1; then
+ success " OpenRegister enabled on $name"
+ else
+ warn " OpenRegister may already be enabled on $name"
+ fi
+
+ # Enable OpenCatalogi
+ if docker exec -u www-data "$container" php occ app:enable opencatalogi 2>&1; then
+ success " OpenCatalogi enabled on $name"
+ else
+ warn " OpenCatalogi may already be enabled on $name"
+ fi
+
+ # Set trusted domain to allow cross-container requests
+ docker exec -u www-data "$container" php occ config:system:set trusted_domains 1 --value="$container" 2>&1
+ docker exec -u www-data "$container" php occ config:system:set trusted_domains 2 --value="nc-fed-1" 2>&1
+ docker exec -u www-data "$container" php occ config:system:set trusted_domains 3 --value="nc-fed-2" 2>&1
+
+ # Disable brute force protection for test environment
+ docker exec -u www-data "$container" php occ config:system:set auth.bruteforce.protection.enabled --type=boolean --value=false 2>&1
+
+ success " Apps installed on $name"
+}
+
+install_apps "$NC1_CONTAINER" "Instance 1"
+install_apps "$NC2_CONTAINER" "Instance 2"
+
+# Restart Apache to clear OPcache and pick up any code changes
+log "Restarting Apache on both instances..."
+docker exec "$NC1_CONTAINER" apache2ctl graceful 2>/dev/null || true
+docker exec "$NC2_CONTAINER" apache2ctl graceful 2>/dev/null || true
+
+# Wait briefly for repair steps to complete
+log "Waiting 10s for initial repair steps..."
+sleep 10
+
+# Trigger settings load to initialize schemas and registers
+log "Loading OpenCatalogi settings (initializing schemas)..."
+for url in "$NC1_URL" "$NC2_URL"; do
+ result=$(curl -sf -u "$ADMIN_USER:$ADMIN_PASS" "$url/index.php/apps/opencatalogi/api/settings/load" 2>/dev/null || echo '{}')
+ schemas=$(echo "$result" | python3 -c "import sys,json; d=json.load(sys.stdin); print(len(d.get('schemas',[])))" 2>/dev/null || echo "0")
+ if [ "$schemas" -gt 0 ]; then
+ success " Loaded $schemas schemas on $url"
+ else
+ warn " No schemas loaded on $url (may already exist)"
+ fi
+done
+
+# Wait for schema initialization to settle
+log "Waiting ${INSTALL_WAIT}s for app initialization..."
+sleep "$INSTALL_WAIT"
+
+# Verify apps are responding
+log "Verifying app endpoints..."
+verify_app() {
+ local url=$1
+ local label=$2
+ if curl -sf -u "$ADMIN_USER:$ADMIN_PASS" "$url/index.php/apps/opencatalogi/api/directory" >/dev/null 2>&1; then
+ success " OpenCatalogi responding on $label"
+ else
+ error " OpenCatalogi not responding on $label"
+ exit 1
+ fi
+}
+verify_app "$NC1_URL" "Instance 1"
+verify_app "$NC2_URL" "Instance 2"
+
+# ---- Run Newman tests -------------------------------------------------------
+echo ""
+echo "============================================"
+echo " Running Newman Federation Tests"
+echo "============================================"
+echo ""
+
+npx newman run "$COLLECTION" \
+ --env-var "nc1Url=$NC1_URL" \
+ --env-var "nc2Url=$NC2_URL" \
+ --env-var "nc2Internal=$NC2_INTERNAL" \
+ --reporters cli \
+ --color on \
+ --timeout-request 30000 \
+ --delay-request 500
+
+NEWMAN_EXIT=$?
+
+echo ""
+if [ $NEWMAN_EXIT -eq 0 ]; then
+ echo "============================================"
+ success "All federation tests passed!"
+ echo "============================================"
+else
+ echo "============================================"
+ error "Some federation tests failed"
+ echo "============================================"
+fi
+
+exit $NEWMAN_EXIT
diff --git a/webpack.config.js b/webpack.config.js
index e7bb3410b..d3f160eda 100644
--- a/webpack.config.js
+++ b/webpack.config.js
@@ -86,4 +86,8 @@ webpackConfig.entry = {
const otherPlugins = (webpackConfig.plugins || []).filter((p) => p.constructor.name !== 'VueLoaderPlugin')
webpackConfig.plugins = [new VueLoaderPlugin(), ...otherPlugins]
+// Force @nextcloud/dialogs to resolve from this app's node_modules,
+// preventing the nextcloud-vue submodule's nested deps (Vue 3) from leaking in.
+webpackConfig.resolve.alias['@nextcloud/dialogs'] = path.resolve(__dirname, 'node_modules/@nextcloud/dialogs')
+
module.exports = webpackConfig