chore(deps): update dependency vue to v3.5.41

Signed-off-by: Sebastian Krupinski <krupinski01@gmail.com>

.github/workflows/build-test.yml

@@ -0,0 +1,42 @@
+name: Build Test
+
+on:
+  pull_request:
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Retrieve Server Install Action
+        uses: actions/checkout@v6.0.2
+        with:
+          repository: Nodarx/action-server-install
+          ref: main
+          path: action-server-install
+          github-server-url: https://git.ktrix.dev
+
+      - name: Install Server
+        uses: ./action-server-install
+        with:
+          install-php: 'false'
+          install-node: 'true'
+          php-version: '8.5'
+          node-version: '24'
+          server-path: './server'
+
+      - name: Checkout Pull Request
+        uses: actions/checkout@v6.0.2
+        with:
+          repository: ${{ github.repository }}
+          ref: ${{ github.event.pull_request.head.sha }}
+          path: server/modules/documents_manager
+          github-server-url: https://git.ktrix.dev
+
+      - name: Install dependencies
+        run: npm ci
+        working-directory: server/modules/documents_manager
+
+      - name: Build
+        run: npm run build
+        working-directory: server/modules/documents_manager

.github/workflows/js-unit-tests.yml

@@ -0,0 +1,42 @@
+name: JS Unit Tests
+
+on:
+  pull_request:
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Retrieve Server Install Action
+        uses: actions/checkout@v6.0.2
+        with:
+          repository: Nodarx/action-server-install
+          ref: main
+          path: action-server-install
+          github-server-url: https://git.ktrix.dev
+
+      - name: Install Server
+        uses: ./action-server-install
+        with:
+          install-php: 'false'
+          install-node: 'true'
+          php-version: '8.5'
+          node-version: '24'
+          server-path: './server'
+
+      - name: Checkout Pull Request
+        uses: actions/checkout@v6.0.2
+        with:
+          repository: ${{ github.repository }}
+          ref: ${{ github.event.pull_request.head.sha }}
+          path: server/modules/documents_manager
+          github-server-url: https://git.ktrix.dev
+
+      - name: Install dependencies
+        run: npm ci
+        working-directory: server/modules/documents_manager
+
+      - name: Run tests
+        run: npm run test:unit
+        working-directory: server/modules/documents_manager

.github/workflows/php-integration-tests.yml

@@ -0,0 +1,59 @@
+name: PHP Integration Tests
+
+on:
+  pull_request:
+  workflow_dispatch:
+
+jobs:
+  test:
+    name: Integration Tests
+    runs-on: ubuntu-latest
+    services:
+      mongo:
+        image: mongo:8
+        options: >-
+          --health-cmd "mongosh --quiet --eval \"db.adminCommand('ping')\""
+          --health-interval 5s
+          --health-timeout 5s
+          --health-retries 12
+
+    steps:
+      - name: Retrieve Server Install Action
+        uses: actions/checkout@v6.0.2
+        with:
+          repository: Nodarx/action-server-install
+          ref: main
+          path: action-server-install
+          github-server-url: https://git.ktrix.dev
+
+      - name: Install server
+        uses: ./action-server-install
+        with:
+          install-php: 'true'
+          php-version: '8.5'
+          server-path: './server'
+          database-uri: 'mongodb://mongo:27017/?tls=false'
+          database-name: 'ktrix_ci'
+          app-environment: 'test'
+
+      - name: Checkout module under test
+        uses: actions/checkout@v6.0.2
+        with:
+          repository: ${{ github.repository }}
+          ref: ${{ github.event.pull_request.head.sha || github.sha }}
+          path: server/modules/documents_manager
+          github-server-url: https://git.ktrix.dev
+
+      - name: Install module dependencies
+        run: composer install --prefer-dist --no-progress
+        working-directory: server/modules/documents_manager
+
+      - name: Install and enable module
+        working-directory: server
+        run: |
+          php bin/console module:install documents_manager
+          php bin/console module:enable documents_manager
+
+      - name: Run integration tests
+        working-directory: server/modules/documents_manager
+        run: composer test:integration

.github/workflows/php-unit-tests.yml

@@ -0,0 +1,42 @@
+name: PHP Unit Tests
+
+on:
+  pull_request:
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Retrieve Server Install Action
+        uses: actions/checkout@v6.0.2
+        with:
+          repository: Nodarx/action-server-install
+          ref: main
+          path: action-server-install
+          github-server-url: https://git.ktrix.dev
+
+      - name: Install Server
+        uses: ./action-server-install
+        with:
+          install-php: 'true'
+          install-node: 'false'
+          php-version: '8.5'
+          node-version: '24'
+          server-path: './server'
+
+      - name: Checkout Pull Request
+        uses: actions/checkout@v6.0.2
+        with:
+          repository: ${{ github.repository }}
+          ref: ${{ github.event.pull_request.head.sha }}
+          path: server/modules/documents_manager
+          github-server-url: https://git.ktrix.dev
+
+      - name: Install dependencies
+        run: composer install --prefer-dist --no-progress
+        working-directory: server/modules/documents_manager
+
+      - name: Run tests
+        run: composer test:unit
+        working-directory: server/modules/documents_manager

.github/workflows/renovate.yml

@@ -25,11 +25,17 @@ jobs:
           tools: composer:v2
 
       - name: Install Renovate
-        run: npm install -g renovate
+        run: |
+          npm install --global --no-audit --fund=false \
+            --prefix "${{ runner.temp }}/renovate-npm" \
+            --cache "${{ runner.temp }}/renovate-npm-cache" \
+            renovate
+          "${{ runner.temp }}/renovate-npm/bin/renovate" --version
 
       - name: Run Renovate
         env:
           RENOVATE_TOKEN: ${{ secrets.RENOVATE_TOKEN }}
           RENOVATE_PLATFORM: gitea
           RENOVATE_ENDPOINT: https://git.ktrix.dev/api/v1
-        run: renovate ${{ gitea.repository }}
+        run: |
+          "${{ runner.temp }}/renovate-npm/bin/renovate" ${{ gitea.repository }}

.gitignore

@@ -12,12 +12,10 @@ node_modules/
 /static/
 
 # Backend development
+/vendor/
 /lib/vendor/
 coverage/
-phpunit.xml.cache
+*.cache
-.phpunit.result.cache
-.php-cs-fixer.cache
-.phpstan.cache
 .phpactor/
 
 # Editors

composer.json

@@ -10,17 +10,29 @@
   "config": {
     "optimize-autoloader": true,
     "platform": {
-      "php": "8.2"
+      "php": "8.3"
     },
     "autoloader-suffix": "DocumentsManager",
     "vendor-dir": "lib/vendor"
   },
   "require": {
-    "php": ">=8.2 <=8.5"
+    "php": ">=8.3 <=8.5"
+  },
+  "require-dev": {
+    "phpunit/phpunit": "^12.0"
   },
   "autoload": {
     "psr-4": {
       "KTXM\\DocumentsManager\\": "lib/"
     }
+  },
+  "autoload-dev": {
+    "psr-4": {
+      "KTXT\\DocumentsManager\\Tests\\": "tests/php/"
+    }
+  },
+  "scripts": {
+    "test:unit": "phpunit --configuration tests/php/phpunit.xml --testsuite \"Unit Tests\" --colors=always --testdox",
+    "test:integration": "phpunit --configuration tests/php/phpunit.xml --testsuite \"Integration Tests\" --colors=always --testdox"
   }
 }

lib/Controllers/TransferController.php

@@ -12,9 +12,14 @@ namespace KTXM\DocumentsManager\Controllers;
 use KTXC\Http\Response\JsonResponse;
 use KTXC\Http\Response\Response;
 use KTXC\Http\Response\StreamedResponse;
-use KTXC\SessionIdentity;
+use KTXC\Context\IdentityContextInterface;
-use KTXC\SessionTenant;
+use KTXC\Context\TenantContextInterface;
 use KTXF\Controller\ControllerAbstract;
+use KTXF\Documents\Collection\CollectionBaseInterface;
+use KTXF\Documents\Entity\EntityBaseInterface;
+use KTXF\Resource\Identifier\CollectionIdentifier;
+use KTXF\Resource\Identifier\EntityIdentifier;
+use KTXF\Resource\Identifier\ResourceIdentifiers;
 use KTXF\Routing\Attributes\AuthenticatedRoute;
 use KTXM\DocumentsManager\Manager;
 use KTXM\DocumentsManager\Transfer\StreamingZip;
@@ -34,8 +39,8 @@ use Throwable;
 class TransferController extends ControllerAbstract
 {
     public function __construct(
-        private readonly SessionTenant $tenantIdentity,
+        private readonly TenantContextInterface $tenantContext,
-        private readonly SessionIdentity $userIdentity,
+        private readonly IdentityContextInterface $identityContext,
         private readonly Manager $manager,
         private readonly LoggerInterface $logger
     ) {}
@@ -51,19 +56,15 @@ class TransferController extends ControllerAbstract
         methods: ['GET']
     )]
     public function downloadEntity(string $provider, string $service, string $collection, string $identifier): Response {
-        $tenantId = $this->tenantIdentity->identifier();
+        $tenantId = $this->tenantContext->identifier();
-        $userId = $this->userIdentity->identifier();
+        $userId = $this->identityContext->identifier();
 
         try {
+            $target = new EntityIdentifier($provider, $service, $collection, $identifier);
+
             // Fetch entity metadata
-            $entities = $this->manager->entityFetch(
+            /** @var EntityBaseInterface[] $entities */
-                $tenantId,
+            $entities = $this->manager->entityFetchBulk($tenantId, $userId, $target);
-                $userId,
-                $provider,
-                $service,
-                $collection,
-                [$identifier]
-            );
 
             if (empty($entities) || !isset($entities[$identifier])) {
                 return new JsonResponse([
@@ -75,14 +76,7 @@ class TransferController extends ControllerAbstract
             $entity = $entities[$identifier];
 
             // Get the stream
-            $stream = $this->manager->entityReadStream(
+            $stream = $this->manager->entityReadStream($tenantId, $userId, $target);
-                $tenantId,
-                $userId,
-                $provider,
-                $service,
-                $collection,
-                $identifier
-            );
 
             if ($stream === null) {
                 return new JsonResponse([
@@ -141,8 +135,8 @@ class TransferController extends ControllerAbstract
         methods: ['GET']
     )]
     public function downloadArchive(string $provider, string $service, array $ids = [], ?string $collection = null, string $name = 'download'): Response {
-        $tenantId = $this->tenantIdentity->identifier();
+        $tenantId = $this->tenantContext->identifier();
-        $userId = $this->userIdentity->identifier();
+        $userId = $this->identityContext->identifier();
 
         if (empty($ids)) {
             return new JsonResponse([
@@ -179,10 +173,7 @@ class TransferController extends ControllerAbstract
                     $stream = $this->manager->entityReadStream(
                         $tenantId,
                         $userId,
-                        $provider,
+                        new EntityIdentifier($provider, $service, (string)$file['collection'], (string)$file['id'])
-                        $service,
-                        $file['collection'],
-                        $file['id']
                     );
 
                     if ($stream !== null) {
@@ -230,8 +221,8 @@ class TransferController extends ControllerAbstract
         methods: ['GET']
     )]
     public function downloadCollection(string $provider, string $service, string $identifier): Response {
-        $tenantId = $this->tenantIdentity->identifier();
+        $tenantId = $this->tenantContext->identifier();
-        $userId = $this->userIdentity->identifier();
+        $userId = $this->identityContext->identifier();
 
         try {
             // Fetch collection metadata
@@ -239,9 +230,7 @@ class TransferController extends ControllerAbstract
             $collection = $this->manager->collectionFetch(
                 $tenantId,
                 $userId,
-                $provider,
+                new CollectionIdentifier($provider, $service, $identifier)
-                $service,
-                $identifier
             );
 
             if ($collection === null) {
@@ -251,7 +240,7 @@ class TransferController extends ControllerAbstract
                 ], Response::HTTP_NOT_FOUND);
             }
 
-            $folderName = $collection->getLabel() ?? 'folder';
+            $folderName = $collection->getProperties()->getLabel() ?? 'folder';
             $archiveName = $this->sanitizeFilename($folderName) . '.zip';
 
             // Build recursive file list
@@ -275,10 +264,7 @@ class TransferController extends ControllerAbstract
                         $stream = $this->manager->entityReadStream(
                             $tenantId,
                             $userId,
-                            $provider,
+                            new EntityIdentifier($provider, $service, (string)$file['collection'], (string)$file['id'])
-                            $service,
-                            $file['collection'],
-                            $file['id']
                         );
 
                         if ($stream !== null) {
@@ -325,13 +311,10 @@ class TransferController extends ControllerAbstract
             // Try as entity first
             if ($collection !== null) {
                 /** @var EntityBaseInterface[] $entities */
-                $entities = $this->manager->entityFetch(
+                $entities = $this->manager->entityFetchBulk(
                     $tenantId,
                     $userId,
-                    $provider,
+                    new EntityIdentifier($provider, $service, $collection, (string)$id)
-                    $service,
-                    $collection,
-                    [$id]
                 );
 
                 if (!empty($entities) && isset($entities[$id])) {
@@ -340,8 +323,8 @@ class TransferController extends ControllerAbstract
                         'type' => 'file',
                         'id' => $id,
                         'collection' => $collection,
-                        'path' => $entity->getLabel() ?? $id,
+                        'path' => $entity->getProperties()->getLabel() ?? $id,
-                        'modTime' => $entity->modifiedOn()?->getTimestamp(),
+                        'modTime' => $entity->modified()?->getTimestamp(),
                     ];
                     continue;
                 }
@@ -352,19 +335,17 @@ class TransferController extends ControllerAbstract
             $collectionNode = $this->manager->collectionFetch(
                 $tenantId,
                 $userId,
-                $provider,
+                new CollectionIdentifier($provider, $service, (string)$id)
-                $service,
-                $id
             );
 
             if ($collectionNode !== null) {
-                $folderName = $collectionNode->getLabel() ?? $id;
+                $folderName = $collectionNode->getProperties()->getLabel() ?? $id;
                 $subFiles = $this->resolveCollectionContents(
                     $tenantId,
                     $userId,
                     $provider,
                     $service,
-                    $id,
+                    (string)$id,
                     $folderName
                 );
                 $files = array_merge($files, $subFiles);
@@ -407,17 +388,13 @@ class TransferController extends ControllerAbstract
             ];
         }
 
-        // Get all nodes in this collection using nodeList with recursive=false
+        // List immediate child collections and entities of this collection;
-        // We handle recursion ourselves to build proper paths
+        // recursion is handled here to build proper archive paths
+        $sources = new ResourceIdentifiers();
+        $sources->add(new CollectionIdentifier($provider, $service, $collectionId));
         try {
-            $nodes = $this->manager->nodeList(
+            $collections = $this->manager->collectionList($tenantId, $userId, $sources)[$provider][$service] ?? [];
-                $tenantId,
+            $entities = $this->manager->entityListBulk($tenantId, $userId, $sources)[$provider][$service][$collectionId] ?? [];
-                $userId,
-                $provider,
-                $service,
-                $collectionId,
-                false // Not recursive - we handle it ourselves
-            );
         } catch (Throwable $e) {
             $this->logger->warning('Failed to list collection contents', [
                 'collection' => $collectionId,
@@ -426,34 +403,35 @@ class TransferController extends ControllerAbstract
             return $files;
         }
 
-        foreach ($nodes as $node) {
+        /** @var CollectionBaseInterface $node */
-            $nodeName = $node->getLabel() ?? (string) $node->id();
+        foreach ($collections as $node) {
+            $nodeName = $node->getProperties()->getLabel() ?? (string) $node->identifier();
             $nodePath = $basePath !== '' ? $basePath . '/' . $nodeName : $nodeName;
+            // Recursively get contents of sub-collection
+            $subFiles = $this->resolveCollectionContents(
+                $tenantId,
+                $userId,
+                $provider,
+                $service,
+                (string) $node->identifier(),
+                $nodePath,
+                $depth + 1,
+                $maxDepth
+            );
+            $files = array_merge($files, $subFiles);
+        }
 
-            if ($node->isCollection()) {
+        /** @var EntityBaseInterface $node */
-                // Recursively get contents of sub-collection
+        foreach ($entities as $node) {
-                $subFiles = $this->resolveCollectionContents(
+            $nodeName = $node->getProperties()->getLabel() ?? (string) $node->identifier();
-                    $tenantId,
+            $nodePath = $basePath !== '' ? $basePath . '/' . $nodeName : $nodeName;
-                    $userId,
+            $files[] = [
-                    $provider,
+                'type' => 'file',
-                    $service,
+                'id' => (string) $node->identifier(),
-                    (string) $node->id(),
+                'collection' => $collectionId,
-                    $nodePath,
+                'path' => $nodePath,
-                    $depth + 1,
+                'modTime' => $node->modified()?->getTimestamp(),
-                    $maxDepth
+            ];
-                );
-                $files = array_merge($files, $subFiles);
-            } else {
-                // It's an entity (file)
-                /** @var INodeEntityBase $node */
-                $files[] = [
-                    'type' => 'file',
-                    'id' => (string) $node->id(),
-                    'collection' => $collectionId,
-                    'path' => $nodePath,
-                    'modTime' => $node->modifiedOn()?->getTimestamp(),
-                ];
-            }
         }
 
         return $files;

lib/Stream/ExpectedTotal.php

@@ -0,0 +1,20 @@
+<?php
+
+declare(strict_types=1);
+
+/**
+ * SPDX-FileCopyrightText: Sebastian Krupinski <krupinski01@gmail.com>
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+
+namespace KTXM\DocumentsManager\Stream;
+
+/**
+ * Implemented by a stream event that declares, up front, how many data frames
+ * are expected to follow. When such an event leads a stream generator, the
+ * envelope writer folds its value into the `control:start` frame's `total`
+ * (the progress denominator) instead of emitting it as a `data` frame.
+ */
+interface ExpectedTotal {
+    public function expectedTotal(): int;
+}

package.json

@@ -7,17 +7,24 @@
     "build": "vite build --mode production --config vite.config.ts",
     "dev": "vite build --mode development --config vite.config.ts",
     "watch": "vite build --mode development --watch --config vite.config.ts",
-    "typecheck": "vue-tsc --noEmit"
+    "typecheck": "vue-tsc --noEmit",
+    "test": "vitest run --config tests/js/vitest.config.ts",
+    "test:unit": "vitest run --config tests/js/vitest.config.ts",
+    "test:watch": "vitest watch --config tests/js/vitest.config.ts",
+    "test:coverage": "vitest run --coverage --config tests/js/vitest.config.ts"
   },
   "dependencies": {
-    "pinia": "^3.0.0",
+    "pinia": "^4.0.0",
     "vue": "^3.5.13"
   },
   "devDependencies": {
     "@tsconfig/node24": "^24.0.0",
     "@types/node": "^24.0.0",
     "@vue/tsconfig": "^0.9.0",
-    "typescript": "~5.7.2",
+    "typescript": "~6.0.0",
-    "vite": "^8.0.0"
+    "vite": "^8.0.0",
+    "@vitest/coverage-v8": "^4.1.6",
+    "jsdom": "^29.1.1",
+    "vitest": "^4.1.6"
   }
 }

src/models/collection.ts

@@ -4,6 +4,19 @@
 
 import type { CollectionContentTypes, CollectionInterface, CollectionModelInterface, CollectionPropertiesInterface } from "@/types/collection";
 
+/**
+ * Reduce a serialized resource identifier ("provider:service:collection")
+ * to its own (last) segment; plain values pass through unchanged
+ */
+function plainIdentifier(value: string | number | null | undefined): string | number | null {
+    if (value === null || value === undefined || value === '') {
+        return value ?? null;
+    }
+    const text = String(value);
+    const index = text.lastIndexOf(':');
+    return index >= 0 ? text.slice(index + 1) : value;
+}
+
 export class CollectionObject implements CollectionModelInterface {
 
     _data!: CollectionInterface;
@@ -24,7 +37,14 @@ export class CollectionObject implements CollectionModelInterface {
     }
 
     fromJson(data: CollectionInterface): CollectionObject {
-        this._data = data;
+        // the wire format carries full resource identifiers (provider:service:collection);
+        // reduce them to plain ids, which is what the stores and UI operate on
+        this._data = {
+            ...data,
+            service: plainIdentifier(data.service) ?? '',
+            collection: plainIdentifier(data.collection),
+            identifier: plainIdentifier(data.identifier) ?? '',
+        };
         if (data.properties) {
             this._data.properties = new CollectionPropertiesObject().fromJson(data.properties as CollectionPropertiesInterface);
         }

src/models/entity.ts

@@ -5,6 +5,19 @@ import type { EntityInterface, EntityModelInterface } from "@/types/entity";
 import type { DocumentInterface, DocumentModelInterface } from "@/types/document";
 import { DocumentObject } from "./document";
 
+/**
+ * Reduce a serialized resource identifier ("provider:service:collection:entity")
+ * to its own (last) segment; plain values pass through unchanged
+ */
+function plainIdentifier(value: string | number | null | undefined): string | number | null {
+    if (value === null || value === undefined || value === '') {
+        return value ?? null;
+    }
+    const text = String(value);
+    const index = text.lastIndexOf(':');
+    return index >= 0 ? text.slice(index + 1) : value;
+}
+
 export class EntityObject implements EntityModelInterface {
 
     _data!: EntityInterface<DocumentInterface|DocumentModelInterface>;
@@ -25,7 +38,14 @@ export class EntityObject implements EntityModelInterface {
     }
 
     fromJson(data: EntityInterface): EntityObject {
-        this._data = data
+        // the wire format carries full resource identifiers (provider:service:collection:entity);
+        // reduce them to plain ids, which is what the stores and UI operate on
+        this._data = {
+            ...data,
+            service: String(plainIdentifier(data.service) ?? ''),
+            collection: plainIdentifier(data.collection) ?? '',
+            identifier: plainIdentifier(data.identifier) ?? '',
+        }
         if (data.properties) {
             this._data.properties = new DocumentObject().fromJson(data.properties as DocumentInterface);
         }

src/services/collectionService.ts

@@ -16,6 +16,10 @@ import type {
   CollectionUpdateRequest,
   CollectionDeleteResponse,
   CollectionDeleteRequest,
+  CollectionCopyRequest,
+  CollectionCopyResponse,
+  CollectionMoveRequest,
+  CollectionMoveResponse,
   CollectionInterface,
 } from '../types/collection';
 import { useIntegrationStore } from '@KTXC/stores/integrationStore';
@@ -150,6 +154,30 @@ export const collectionService = {
     return await transceivePost<CollectionDeleteRequest, CollectionDeleteResponse>('collection.delete', request);
   },
 
+  /**
+   * Copy a collection to a new parent
+   *
+   * @param request - copy request parameters
+   *
+   * @returns Promise with copied collection object
+   */
+  async copy(request: CollectionCopyRequest): Promise<CollectionObject> {
+    const response = await transceivePost<CollectionCopyRequest, CollectionCopyResponse>('collection.copy', request);
+    return createCollectionObject(response);
+  },
+
+  /**
+   * Move a collection to a new parent
+   *
+   * @param request - move request parameters
+   *
+   * @returns Promise with moved collection object
+   */
+  async move(request: CollectionMoveRequest): Promise<CollectionObject> {
+    const response = await transceivePost<CollectionMoveRequest, CollectionMoveResponse>('collection.move', request);
+    return createCollectionObject(response);
+  },
+
 };
 
 export default collectionService;

src/services/entityService.ts

@@ -2,7 +2,7 @@
  * Entity management service
  */
 
-import { transceivePost } from './transceive';
+import { transceivePost, transceiveStream } from './transceive';
 import type {
   EntityListRequest,
   EntityListResponse,
@@ -18,6 +18,10 @@ import type {
   EntityDeleteResponse,
   EntityDeltaRequest,
   EntityDeltaResponse,
+  EntityCopyRequest,
+  EntityCopyResponse,
+  EntityMoveRequest,
+  EntityMoveResponse,
   EntityReadRequest,
   EntityReadResponse,
   EntityWriteRequest,
@@ -43,14 +47,14 @@ function createEntityObject(data: EntityInterface): EntityObject {
 export const entityService = {
 
   /**
-   * Retrieve list of entities, optionally filtered by source selector
+   * Retrieve list of entities, optionally filtered by source identifiers
    *
    * @param request - list request parameters
    *
    * @returns Promise with entity object list grouped by provider, service, collection, and entity identifier
    */
-  async list(request: EntityListRequest = {}): Promise<Record<string, Record<string, Record<string, Record<string, EntityObject>>>>> {
+  async listBulk(request: EntityListRequest = {}): Promise<Record<string, Record<string, Record<string, Record<string, EntityObject>>>>> {
-    const response = await transceivePost<EntityListRequest, EntityListResponse>('entity.list', request);
+    const response = await transceivePost<EntityListRequest, EntityListResponse>('entity.listBulk', request);
     
     // Convert nested response to EntityObject instances
     const providerList: Record<string, Record<string, Record<string, Record<string, EntityObject>>>> = {};
@@ -73,6 +77,20 @@ export const entityService = {
     return providerList;
   },
 
+  /**
+   * Stream entities one by one, invoking the callback for each entity
+   *
+   * @param request - list request parameters
+   * @param onEntity - callback invoked for each streamed entity
+   *
+   * @returns Promise with the total number of streamed entities
+   */
+  async listStream(request: EntityListRequest, onEntity: (entity: EntityObject) => void): Promise<{ total: number }> {
+    return await transceiveStream<EntityListRequest, EntityInterface>('entity.listStream', request, (entityData) => {
+      onEntity(createEntityObject(entityData));
+    });
+  },
+
   /**
    * Retrieve a specific entity by provider and identifier
    *
@@ -128,16 +146,38 @@ export const entityService = {
   },
 
   /**
-   * Delete an entity
+   * Delete entities
    *
    * @param request - delete request parameters
    *
-   * @returns Promise with deletion result
+   * @returns Promise with per-entity disposition results
    */
   async delete(request: EntityDeleteRequest): Promise<EntityDeleteResponse> {
     return await transceivePost<EntityDeleteRequest, EntityDeleteResponse>('entity.delete', request);
   },
 
+  /**
+   * Copy entities to another collection
+   *
+   * @param request - copy request parameters
+   *
+   * @returns Promise with per-entity disposition results
+   */
+  async copy(request: EntityCopyRequest): Promise<EntityCopyResponse> {
+    return await transceivePost<EntityCopyRequest, EntityCopyResponse>('entity.copy', request);
+  },
+
+  /**
+   * Move entities to another collection
+   *
+   * @param request - move request parameters
+   *
+   * @returns Promise with per-entity disposition results
+   */
+  async move(request: EntityMoveRequest): Promise<EntityMoveResponse> {
+    return await transceivePost<EntityMoveRequest, EntityMoveResponse>('entity.move', request);
+  },
+
   /**
    * Retrieve delta changes for entities
    * 

src/services/index.ts

@@ -6,4 +6,3 @@ export { providerService } from './providerService';
 export { serviceService } from './serviceService';
 export { collectionService } from './collectionService';
 export { entityService } from './entityService';
-export { nodeService } from './nodeService';

src/services/nodeService.ts

@@ -1,68 +0,0 @@
-/**
- * Node (unified collection/entity) management service
- */
-
-import { transceivePost } from './transceive'
-import type { ListFilter, ListSort, ListRange } from '../types/common'
-import type { CollectionInterface } from '../types/collection'
-import type { EntityInterface } from '../types/entity'
-
-export type NodeItem = CollectionInterface | EntityInterface
-
-export interface NodeListRequest {
-  provider: string
-  service: string | number
-  location?: string | number | null
-  recursive?: boolean
-  filter?: ListFilter | null
-  sort?: ListSort | null
-  range?: ListRange | null
-}
-
-export type NodeListResponse = Record<string, NodeItem>
-
-export interface NodeDeltaRequest {
-  provider: string
-  service: string | number
-  location?: string | number | null
-  signature: string
-  recursive?: boolean
-  detail?: 'ids' | 'full'
-}
-
-export interface NodeDeltaResult {
-  added: Array<string | number | NodeItem>
-  modified: Array<string | number | NodeItem>
-  removed: Array<string | number>
-  signature: string
-}
-
-export const nodeService = {
-
-  async list(request: NodeListRequest): Promise<NodeItem[]> {
-    const response = await transceivePost<NodeListRequest, NodeListResponse>('node.list', {
-      provider: request.provider,
-      service: request.service,
-      location: request.location ?? null,
-      recursive: request.recursive ?? false,
-      filter: request.filter ?? null,
-      sort: request.sort ?? null,
-      range: request.range ?? null,
-    })
-
-    return Object.values(response)
-  },
-
-  async delta(request: NodeDeltaRequest): Promise<NodeDeltaResult> {
-    return await transceivePost<NodeDeltaRequest, NodeDeltaResult>('node.delta', {
-      provider: request.provider,
-      service: request.service,
-      location: request.location ?? null,
-      signature: request.signature,
-      recursive: request.recursive ?? false,
-      detail: request.detail ?? 'ids',
-    })
-  },
-}
-
-export default nodeService

src/services/transceive.ts

@@ -4,7 +4,7 @@
  */
 
 import { createFetchWrapper } from '@KTXC';
-import type { ApiRequest, ApiResponse } from '../types/common';
+import type { ApiRequest, ApiResponse, ApiStreamResponse } from '../types/common';
 
 const fetchWrapper = createFetchWrapper();
 const API_URL = '/m/documents_manager/v1';
@@ -48,3 +48,82 @@ export async function transceivePost<TRequest, TResponse>(
 
   return response.data;
 }
+
+/**
+ * Stream an NDJSON API response, unwrapping data frames for the caller.
+ *
+ * @param operation - Operation name, e.g. 'entity.listStream'
+ * @param data      - Operation-specific request data
+ * @param onData    - Synchronous callback invoked for every unwrapped data payload.
+ * @param options   - Optional `user` override and an `onStart` hook.
+ * @returns Promise resolving to the final stream total from the control/end frame
+ */
+export async function transceiveStream<TRequest, TData>(
+  operation: string,
+  data: TRequest,
+  onData: (data: TData) => void,
+  options?: { user?: string; onStart?: (expected?: number) => void }
+): Promise<{ total: number }> {
+  const request: ApiRequest<TRequest> = {
+    version: API_VERSION,
+    transaction: generateTransactionId(),
+    operation,
+    data,
+    user: options?.user,
+  };
+
+  let total = 0;
+
+  const dispatch = (line: string): void => {
+    const message = JSON.parse(line) as ApiStreamResponse<TData>;
+
+    if (message.type === 'control') {
+      if (message.status === 'start') {
+        options?.onStart?.(message.total);
+      } else if (message.status === 'end') {
+        total = message.total;
+      }
+      return;
+    }
+
+    if (message.type === 'error') {
+      throw new Error(`[${operation}] ${message.message}`);
+    }
+
+    onData(message.data);
+  };
+
+  await fetchWrapper.post(API_URL, request, {
+    headers: { 'Accept': 'application/json' },
+    onStream: async (response: Response) => {
+      if (!response.body) {
+        throw new Error(`[${operation}] Response body is not readable`);
+      }
+
+      const reader = response.body.getReader();
+      const decoder = new TextDecoder();
+      let buffer = '';
+
+      try {
+        while (true) {
+          const { done, value } = await reader.read();
+          if (done) break;
+
+          buffer += decoder.decode(value, { stream: true });
+          const lines = buffer.split('\n');
+          buffer = lines.pop()!;
+
+          for (const line of lines) {
+            if (line.trim()) dispatch(line);
+          }
+        }
+
+        if (buffer.trim()) dispatch(buffer);
+      } finally {
+        reader.releaseLock();
+      }
+    },
+  });
+
+  return { total };
+}

src/stores/collectionsStore.ts

@@ -6,11 +6,11 @@ import { ref, computed, readonly } from 'vue'
 import { defineStore } from 'pinia'
 import { collectionService } from '../services/collectionService'
 import type {
-  SourceSelector,
+  CollectionIdentifier,
+  ServiceIdentifier,
   ListFilter,
   ListSort,
   CollectionMutableProperties,
-  CollectionDeleteResponse,
 } from '../types'
 import { CollectionObject } from '../models/collection'
 
@@ -71,7 +71,7 @@ export const useCollectionsStore = defineStore('documentsCollectionsStore', () =
   }
 
   // Actions
-  async function list(sources?: SourceSelector, filter?: ListFilter, sort?: ListSort): Promise<Record<string, CollectionObject>> {
+  async function list(sources?: (ServiceIdentifier | CollectionIdentifier)[], filter?: ListFilter, sort?: ListSort): Promise<Record<string, CollectionObject>> {
     transceiving.value = true
     try {
       const response = await collectionService.list({ sources, filter, sort })
@@ -101,7 +101,7 @@ export const useCollectionsStore = defineStore('documentsCollectionsStore', () =
   async function fetch(provider: string, service: string | number, identifier: string | number): Promise<CollectionObject> {
     transceiving.value = true
     try {
-      const response = await collectionService.fetch({ provider, service, collection: identifier })
+      const response = await collectionService.fetch({ targets: [`${provider}:${service}:${identifier}`] })
       const key = identifierKey(response.provider, response.service, response.identifier)
       _collections.value[key] = response
 
@@ -115,10 +115,10 @@ export const useCollectionsStore = defineStore('documentsCollectionsStore', () =
     }
   }
 
-  async function extant(sources: SourceSelector) {
+  async function extant(targets: CollectionIdentifier[]) {
     transceiving.value = true
     try {
-      const response = await collectionService.extant({ sources })
+      const response = await collectionService.extant({ targets })
       console.debug('[Documents Manager][Store] - Successfully checked collection availability')
       return response
     } catch (error: any) {
@@ -137,7 +137,10 @@ export const useCollectionsStore = defineStore('documentsCollectionsStore', () =
   ): Promise<CollectionObject> {
     transceiving.value = true
     try {
-      const response = await collectionService.create({ provider, service, collection, properties })
+      const target: CollectionIdentifier | undefined = collection !== null && collection !== undefined && collection !== ''
+        ? `${provider}:${service}:${collection}`
+        : undefined
+      const response = await collectionService.create({ provider, service: String(service), target, properties })
       const key = identifierKey(response.provider, response.service, response.identifier)
       _collections.value[key] = response
 
@@ -159,7 +162,7 @@ export const useCollectionsStore = defineStore('documentsCollectionsStore', () =
   ): Promise<CollectionObject> {
     transceiving.value = true
     try {
-      const response = await collectionService.update({ provider, service, identifier, properties })
+      const response = await collectionService.update({ target: `${provider}:${service}:${identifier}`, properties })
       const key = identifierKey(response.provider, response.service, response.identifier)
       _collections.value[key] = response
 
@@ -173,17 +176,18 @@ export const useCollectionsStore = defineStore('documentsCollectionsStore', () =
     }
   }
 
-  async function remove(provider: string, service: string | number, identifier: string | number): Promise<CollectionDeleteResponse> {
+  async function remove(provider: string, service: string | number, identifier: string | number): Promise<{ success: boolean }> {
     transceiving.value = true
     try {
-      const response = await collectionService.delete({ provider, service, identifier })
+      const response = await collectionService.delete({ target: `${provider}:${service}:${identifier}` })
-      if (response.success) {
+      const success = response.disposition === 'deleted' || response.disposition === 'moved'
+      if (success) {
         const key = identifierKey(provider, service, identifier)
         delete _collections.value[key]
       }
 
       console.debug('[Documents Manager][Store] - Successfully deleted collection:', `${provider}:${service}:${identifier}`)
-      return response
+      return { success }
     } catch (error: any) {
       console.error('[Documents Manager][Store] - Failed to delete collection:', error)
       throw error

src/stores/entitiesStore.ts

@@ -7,12 +7,13 @@ import { defineStore } from 'pinia'
 import { entityService } from '../services/entityService'
 import { EntityObject } from '../models'
 import type {
-  SourceSelector,
+  CollectionIdentifier,
+  EntityIdentifier,
+  ServiceIdentifier,
   ListFilter,
   ListSort,
   ListRange,
   DocumentInterface,
-  EntityDeleteResponse,
   EntityDeltaResponse,
 } from '../types'
 
@@ -100,10 +101,10 @@ export const useEntitiesStore = defineStore('documentsEntitiesStore', () => {
   }
 
   // Actions
-  async function list(sources?: SourceSelector, filter?: ListFilter, sort?: ListSort, range?: ListRange): Promise<Record<string, EntityObject>> {
+  async function list(sources?: (ServiceIdentifier | CollectionIdentifier)[], filter?: ListFilter, sort?: ListSort, range?: ListRange): Promise<Record<string, EntityObject>> {
     transceiving.value = true
     try {
-      const response = await entityService.list({ sources, filter, sort, range })
+      const response = await entityService.listBulk({ sources, filter, sort, range })
 
       const hydrated: Record<string, EntityObject> = {}
       Object.entries(response).forEach(([providerId, providerServices]) => {
@@ -137,7 +138,8 @@ export const useEntitiesStore = defineStore('documentsEntitiesStore', () => {
   ): Promise<Record<string, EntityObject>> {
     transceiving.value = true
     try {
-      const response = await entityService.fetch({ provider, service, collection, identifiers })
+      const targets: EntityIdentifier[] = identifiers.map((identifier) => `${provider}:${service}:${collection}:${identifier}` as EntityIdentifier)
+      const response = await entityService.fetch({ targets })
 
       const hydrated: Record<string, EntityObject> = {}
       Object.entries(response).forEach(([identifier, entityObj]) => {
@@ -156,10 +158,10 @@ export const useEntitiesStore = defineStore('documentsEntitiesStore', () => {
     }
   }
 
-  async function extant(sources: SourceSelector) {
+  async function extant(targets: (CollectionIdentifier | EntityIdentifier)[]) {
     transceiving.value = true
     try {
-      const response = await entityService.extant({ sources })
+      const response = await entityService.extant({ targets })
       console.debug('[Documents Manager][Store] - Successfully checked entity availability')
       return response
     } catch (error: any) {
@@ -179,7 +181,7 @@ export const useEntitiesStore = defineStore('documentsEntitiesStore', () => {
   ): Promise<EntityObject> {
     transceiving.value = true
     try {
-      const response = await entityService.create({ provider, service, collection, properties, options })
+      const response = await entityService.create({ target: `${provider}:${service}:${collection}`, properties, options })
       const key = identifierKey(response.provider, response.service, response.collection, response.identifier)
       _entities.value[key] = response
 
@@ -202,7 +204,7 @@ export const useEntitiesStore = defineStore('documentsEntitiesStore', () => {
   ): Promise<EntityObject> {
     transceiving.value = true
     try {
-      const response = await entityService.update({ provider, service, collection, identifier, properties })
+      const response = await entityService.update({ target: `${provider}:${service}:${collection}:${identifier}`, properties })
       const key = identifierKey(response.provider, response.service, response.collection, response.identifier)
       _entities.value[key] = response
 
@@ -221,17 +223,19 @@ export const useEntitiesStore = defineStore('documentsEntitiesStore', () => {
     service: string | number,
     collection: string | number,
     identifier: string | number,
-  ): Promise<EntityDeleteResponse> {
+  ): Promise<{ success: boolean }> {
     transceiving.value = true
     try {
-      const response = await entityService.delete({ provider, service, collection, identifier })
+      const target: EntityIdentifier = `${provider}:${service}:${collection}:${identifier}`
-      if (response.success) {
+      const response = await entityService.delete({ targets: [target] })
+      const success = response[target]?.disposition === 'deleted'
+      if (success) {
         const key = identifierKey(provider, service, collection, identifier)
         delete _entities.value[key]
       }
 
-      console.debug('[Documents Manager][Store] - Successfully deleted entity:', `${provider}:${service}:${collection}:${identifier}`)
+      console.debug('[Documents Manager][Store] - Successfully deleted entity:', target)
-      return response
+      return { success }
     } catch (error: any) {
       console.error('[Documents Manager][Store] - Failed to delete entity:', error)
       throw error
@@ -240,10 +244,10 @@ export const useEntitiesStore = defineStore('documentsEntitiesStore', () => {
     }
   }
 
-  async function delta(sources: SourceSelector): Promise<EntityDeltaResponse> {
+  async function delta(targets: (CollectionIdentifier | EntityIdentifier)[]): Promise<EntityDeltaResponse> {
     transceiving.value = true
     try {
-      const response = await entityService.delta({ sources })
+      const response = await entityService.delta({ targets })
 
       Object.entries(response).forEach(([provider, providerData]) => {
         if (providerData === false) return
@@ -280,7 +284,7 @@ export const useEntitiesStore = defineStore('documentsEntitiesStore', () => {
   ): Promise<string | null> {
     transceiving.value = true
     try {
-      const response = await entityService.read({ provider, service, collection, identifier })
+      const response = await entityService.read({ target: `${provider}:${service}:${collection}:${identifier}` })
       return response.content
     } catch (error: any) {
       console.error('[Documents Manager][Store] - Failed to read entity:', error)
@@ -299,7 +303,7 @@ export const useEntitiesStore = defineStore('documentsEntitiesStore', () => {
   ): Promise<number> {
     transceiving.value = true
     try {
-      const response = await entityService.write({ provider, service, collection, identifier, content, encoding: 'base64' })
+      const response = await entityService.write({ target: `${provider}:${service}:${collection}:${identifier}`, content, encoding: 'base64' })
       return response.bytesWritten
     } catch (error: any) {
       console.error('[Documents Manager][Store] - Failed to write entity:', error)

src/stores/nodesStore.ts

@@ -5,7 +5,8 @@
 import { computed, ref, readonly } from 'vue'
 import { defineStore } from 'pinia'
 import type {
-  SourceSelector,
+  CollectionIdentifier,
+  ServiceIdentifier,
   ListFilter,
   ListSort,
   ListRange,
@@ -112,13 +113,9 @@ export const useNodesStore = defineStore('documentsNodesStore', () => {
   ): Promise<CollectionObject[]> {
     error.value = null
     try {
-      const sources: SourceSelector = {
+      const sources: (ServiceIdentifier | CollectionIdentifier)[] = collectionId === null
-        [providerId]: {
+        ? [`${providerId}:${serviceId}`]
-          [String(serviceId)]: collectionId === null
+        : [`${providerId}:${serviceId}:${collectionId}`]
-            ? true
-            : { [String(collectionId)]: true },
-        },
-      }
 
       await collectionsStore.list(sources, filter, sort)
       return collectionsStore.collectionsForService(providerId, serviceId)
@@ -138,13 +135,9 @@ export const useNodesStore = defineStore('documentsNodesStore', () => {
   ): Promise<EntityObject[]> {
     error.value = null
     try {
-      const sources: SourceSelector = {
+      const sources: (ServiceIdentifier | CollectionIdentifier)[] = collectionId === null
-        [providerId]: {
+        ? [`${providerId}:${serviceId}`]
-          [String(serviceId)]: collectionId === null
+        : [`${providerId}:${serviceId}:${collectionId}`]
-            ? true
-            : { [String(collectionId)]: true },
-        },
-      }
 
       await entitiesStore.list(sources, filter, sort, range)
       return entitiesStore.entitiesForCollection(providerId, serviceId, collectionId)

src/stores/providersStore.ts

@@ -6,7 +6,7 @@ import { ref, computed, readonly } from 'vue'
 import { defineStore } from 'pinia'
 import { providerService } from '../services'
 import { ProviderObject } from '../models/provider'
-import type { SourceSelector } from '../types'
+import type { ProviderIdentifier } from '../types'
 
 export const useProvidersStore = defineStore('documentsProvidersStore', () => {
   // State
@@ -54,10 +54,10 @@ export const useProvidersStore = defineStore('documentsProvidersStore', () => {
    * 
    * @returns Promise with provider object list keyed by provider identifier
    */
-  async function list(sources?: SourceSelector): Promise<Record<string, ProviderObject>> {
+  async function list(targets?: ProviderIdentifier[]): Promise<Record<string, ProviderObject>> {
     transceiving.value = true
     try {
-      const providers = await providerService.list({ sources })
+      const providers = await providerService.list({ targets })
 
       // Merge retrieved providers into state
       _providers.value = { ..._providers.value, ...providers }
@@ -82,7 +82,7 @@ export const useProvidersStore = defineStore('documentsProvidersStore', () => {
   async function fetch(identifier: string): Promise<ProviderObject> {
     transceiving.value = true
     try {
-      const provider = await providerService.fetch({ identifier })
+      const provider = await providerService.fetch({ target: identifier })
 
       // Merge fetched provider into state
       _providers.value[provider.identifier] = provider
@@ -100,14 +100,14 @@ export const useProvidersStore = defineStore('documentsProvidersStore', () => {
   /**
    * Retrieve provider availability status for a given source selector
    * 
-   * @param sources - source selector to check availability for
+   * @param targets - provider identifiers to check availability for
    * 
    * @returns Promise with provider availability status
    */
-  async function extant(sources: SourceSelector) {
+  async function extant(targets: ProviderIdentifier[]) {
     transceiving.value = true
     try {
-      const response = await providerService.extant({ sources })
+      const response = await providerService.extant({ targets })
 
       Object.entries(response).forEach(([providerId, providerStatus]) => {
         if (providerStatus === false) {
@@ -115,7 +115,7 @@ export const useProvidersStore = defineStore('documentsProvidersStore', () => {
         }
       })
 
-      console.debug('[Documents Manager][Store] - Successfully checked', sources ? Object.keys(sources).length : 0, 'providers')
+      console.debug('[Documents Manager][Store] - Successfully checked', targets ? targets.length : 0, 'providers')
       return response
     } catch (error: any) {
       console.error('[Documents Manager][Store] - Failed to check providers:', error)

src/stores/servicesStore.ts

@@ -7,7 +7,7 @@ import { defineStore } from 'pinia'
 import { serviceService } from '../services'
 import { ServiceObject } from '../models/service'
 import type {
-  SourceSelector,
+  ServiceIdentifier,
   ServiceInterface,
 } from '../types'
 
@@ -76,14 +76,14 @@ export const useServicesStore = defineStore('documentsServicesStore', () => {
   /**
    * Retrieve all or specific services, optionally filtered by source selector
    * 
-   * @param sources - optional source selector
+   * @param targets - optional service identifiers
    * 
    * @returns Promise with service object list keyed by provider and service identifier
    */
-  async function list(sources?: SourceSelector): Promise<Record<string, ServiceObject>> {
+  async function list(targets?: ServiceIdentifier[]): Promise<Record<string, ServiceObject>> {
     transceiving.value = true
     try {
-      const response = await serviceService.list({ sources })
+      const response = await serviceService.list({ targets })
 
       // Flatten nested structure: provider-id: { service-id: object } -> "provider-id:service-id": object
       const services: Record<string, ServiceObject> = {}
@@ -137,16 +137,16 @@ export const useServicesStore = defineStore('documentsServicesStore', () => {
   /**
    * Retrieve service availability status for a given source selector
    * 
-   * @param sources - source selector to check availability for
+   * @param targets - service identifiers to check availability for
    * 
    * @returns Promise with service availability status
    */
-  async function extant(sources: SourceSelector) {
+  async function extant(targets: ServiceIdentifier[]) {
     transceiving.value = true
     try {
-      const response = await serviceService.extant({ sources })
+      const response = await serviceService.extant({ targets })
       
-      console.debug('[Documents Manager][Store] - Successfully checked', sources ? Object.keys(sources).length : 0, 'services')
+      console.debug('[Documents Manager][Store] - Successfully checked', targets ? targets.length : 0, 'services')
       return response
     } catch (error: any) {
       console.error('[Documents Manager][Store] - Failed to check services:', error)

src/types/collection.ts

@@ -1,7 +1,7 @@
 /**
  * Collection type definitions
  */
-import type { ListFilter, ListSort, SourceSelector } from './common';
+import type { CollectionIdentifier, ListFilter, ListSort, ServiceIdentifier } from './common';
 
 
 export interface CollectionModelInterface extends Omit<CollectionInterface, '@type' | 'created' | 'modified'> {
@@ -46,7 +46,7 @@ export interface CollectionPropertiesInterface extends CollectionMutableProperti
  * Collection list
  */
 export interface CollectionListRequest {
-  sources?: SourceSelector;
+  sources?: (ServiceIdentifier | CollectionIdentifier)[];
   filter?: ListFilter;
   sort?: ListSort;
 }
@@ -63,9 +63,7 @@ export interface CollectionListResponse {
  * Collection fetch
  */
 export interface CollectionFetchRequest {
-  provider: string;
+  targets: CollectionIdentifier[];
-  service: string | number;
-  collection: string | number;
 }
 
 export interface CollectionFetchResponse extends CollectionInterface {}
@@ -74,7 +72,7 @@ export interface CollectionFetchResponse extends CollectionInterface {}
  * Collection extant
  */
 export interface CollectionExtantRequest {
-  sources: SourceSelector;
+  targets: CollectionIdentifier[];
 }
 
 export interface CollectionExtantResponse {
@@ -91,8 +89,9 @@ export interface CollectionExtantResponse {
 export interface CollectionCreateRequest {
   provider: string;
   service: string | number;
-  collection?: string | number | null; // Parent Collection Identifier
+  target?: CollectionIdentifier | null; // Parent collection identifier (absent for root)
   properties: CollectionMutableProperties;
+  options?: Record<string, unknown>;
 }
 
 export interface CollectionCreateResponse extends CollectionInterface {}
@@ -101,9 +100,7 @@ export interface CollectionCreateResponse extends CollectionInterface {}
  * Collection modify
  */
 export interface CollectionUpdateRequest {
-  provider: string;
+  target: CollectionIdentifier;
-  service: string | number;
-  identifier: string | number;
   properties: CollectionMutableProperties;
 }
 
@@ -113,26 +110,23 @@ export interface CollectionUpdateResponse extends CollectionInterface {}
  * Collection delete
  */
 export interface CollectionDeleteRequest {
-  provider: string;
+  target: CollectionIdentifier;
-  service: string | number;
-  identifier: string | number;
   options?: {
     force?: boolean; // Whether to force delete even if collection is not empty
   };
 }
 
 export interface CollectionDeleteResponse {
-  success: boolean;
+  disposition: 'deleted' | 'moved';
+  mutation?: CollectionInterface;
 }
 
 /**
  * Collection copy
  */
 export interface CollectionCopyRequest {
-  provider: string;
+  source: CollectionIdentifier;
-  service: string;
+  target?: CollectionIdentifier | null; // Destination parent (absent for root)
-  identifier: string;
-  location?: string | null;
 }
 
 export interface CollectionCopyResponse extends CollectionInterface {}
@@ -141,10 +135,8 @@ export interface CollectionCopyResponse extends CollectionInterface {}
  * Collection move
  */
 export interface CollectionMoveRequest {
-  provider: string;
+  source: CollectionIdentifier;
-  service: string;
+  target?: CollectionIdentifier | null; // Destination parent (absent for root)
-  identifier: string;
-  location?: string | null;
 }
 
 export interface CollectionMoveResponse extends CollectionInterface {}

src/types/common.ts

@@ -44,33 +44,57 @@ export interface ApiErrorResponse {
 export type ApiResponse<T = any> = ApiSuccessResponse<T> | ApiErrorResponse;
 
 /**
- * Selector for targeting specific providers, services, collections, or entities in list or extant operations.
+ * Stream control start line.
- * 
- * Example usage:
- * {
- *   "provider1": true, // Select all services/collections/entities under provider1
- *   "provider2": {
- *     "serviceA": true, // Select all collections/entities under serviceA of provider2
- *     "serviceB": {
- *       "collectionX": true, // Select all entities under collectionX of serviceB of provider2
- *       "collectionY": [1, 2, 3] // Select entities with identifiers 1, 2, and 3 under collectionY of serviceB of provider2
- *     }
- *   }
- * }
  */
-export type SourceSelector = {
+export interface ApiStreamStartResponse {
-  [provider: string]: boolean | ServiceSelector;
+  type: 'control';
-};
+  status: 'start';
+  version: number;
+  transaction: string;
+  total?: number;
+}
 
-export type ServiceSelector = {
+/**
-  [service: string]: boolean | CollectionSelector;
+ * Stream control end line
-};
+ */
+export interface ApiStreamEndResponse {
+  type: 'control';
+  status: 'end';
+  total: number;
+}
 
-export type CollectionSelector = {
+/**
-  [collection: string | number]: boolean | EntitySelector;
+ * Stream error line
-};
+ */
+export interface ApiStreamErrorResponse {
+  type: 'error';
+  message: string;
+}
 
-export type EntitySelector = (string | number)[];
+export interface ApiStreamDataResponse<T = any> {
+  type: 'data';
+  data: T;
+}
+
+/**
+ * Shared stream control lines
+ */
+export type ApiStreamResponse<T = any> =
+  | ApiStreamStartResponse
+  | ApiStreamEndResponse
+  | ApiStreamErrorResponse
+  | ApiStreamDataResponse<T>;
+
+/**
+ * Identifiers for targeting specific providers, services, collections, or entities in list or extant operations.
+ *
+ * Operations accept flat arrays of colon-separated identifier strings, e.g.
+ * ["default:personal:00000000-0000-0000-0000-000000000000", "default:personal:folder1:file1"].
+ */
+export type ProviderIdentifier = `${string}`;
+export type ServiceIdentifier = `${string}:${string}`;
+export type CollectionIdentifier = `${string}:${string}:${string | number}`;
+export type EntityIdentifier = `${string}:${string}:${string}:${string | number}`;
 
 
 /**

src/types/entity.ts

@@ -1,7 +1,7 @@
 /**
  * Entity type definitions
  */
-import type { ListFilter, ListRange, ListSort, SourceSelector } from './common';
+import type { CollectionIdentifier, EntityIdentifier, ListFilter, ListRange, ListSort, ServiceIdentifier } from './common';
 import type { DocumentInterface, DocumentModelInterface } from './document';
 
 /**
@@ -25,11 +25,21 @@ export interface EntityInterface<T = DocumentInterface> {
   properties: T;
 }
 
+/**
+ * Entity mutation result (delete/move/copy operations)
+ */
+export interface EntityMutationResult {
+  disposition: 'deleted' | 'moved' | 'copied' | 'error';
+  destination?: CollectionIdentifier | null;
+  mutation?: EntityIdentifier;
+  error?: string;
+}
+
 /**
  * Entity list
  */
 export interface EntityListRequest {
-  sources?: SourceSelector;
+  sources?: (ServiceIdentifier | CollectionIdentifier)[];
   filter?: ListFilter;
   sort?: ListSort;
   range?: ListRange;
@@ -49,10 +59,7 @@ export interface EntityListResponse {
  * Entity fetch
  */
 export interface EntityFetchRequest {
-  provider: string;
+  targets: EntityIdentifier[];
-  service: string | number;
-  collection: string | number;
-  identifiers: (string | number)[];
 }
 
 export interface EntityFetchResponse {
@@ -63,7 +70,7 @@ export interface EntityFetchResponse {
  * Entity extant
  */
 export interface EntityExtantRequest {
-  sources: SourceSelector;
+  targets: (CollectionIdentifier | EntityIdentifier)[];
 }
 
 export interface EntityExtantResponse {
@@ -80,9 +87,7 @@ export interface EntityExtantResponse {
  * Entity create
  */
 export interface EntityCreateRequest<T = DocumentInterface> {
-  provider: string;
+  target: CollectionIdentifier;
-  service: string | number;
-  collection: string | number;
   properties: T;
   options?: Record<string, unknown>;
 }
@@ -93,10 +98,7 @@ export interface EntityCreateResponse<T = DocumentInterface> extends EntityInter
  * Entity update
  */
 export interface EntityUpdateRequest<T = DocumentInterface> {
-  provider: string;
+  target: EntityIdentifier;
-  service: string | number;
-  collection: string | number;
-  identifier: string | number;
   properties: T;
 }
 
@@ -106,21 +108,18 @@ export interface EntityUpdateResponse<T = DocumentInterface> extends EntityInter
  * Entity delete
  */
 export interface EntityDeleteRequest {
-  provider: string;
+  targets: EntityIdentifier[];
-  service: string | number;
-  collection: string | number;
-  identifier: string | number;
 }
 
 export interface EntityDeleteResponse {
-  success: boolean;
+  [identifier: string]: EntityMutationResult;
 }
 
 /**
  * Entity delta
  */
 export interface EntityDeltaRequest {
-  sources: SourceSelector;
+  targets: (CollectionIdentifier | EntityIdentifier)[];
 }
 
 export interface EntityDeltaResponse {
@@ -140,36 +139,31 @@ export interface EntityDeltaResponse {
  * Entity copy
  */
 export interface EntityCopyRequest {
-  provider: string;
+  target: CollectionIdentifier;
-  service: string | number;
+  sources: EntityIdentifier[];
-  collection: string | number;
-  identifier: string | number;
-  destination?: string | null;
 }
 
-export interface EntityCopyResponse<T = DocumentInterface> extends EntityInterface<T> {}
+export interface EntityCopyResponse {
+  [identifier: string]: EntityMutationResult;
+}
 
 /**
  * Entity move
  */
 export interface EntityMoveRequest {
-  provider: string;
+  target: CollectionIdentifier;
-  service: string | number;
+  sources: EntityIdentifier[];
-  collection: string | number;
-  identifier: string | number;
-  destination?: string | null;
 }
 
-export interface EntityMoveResponse<T = DocumentInterface> extends EntityInterface<T> {}
+export interface EntityMoveResponse {
+  [identifier: string]: EntityMutationResult;
+}
 
 /**
  * Entity read content
  */
 export interface EntityReadRequest {
-  provider: string;
+  target: EntityIdentifier;
-  service: string | number;
-  collection: string | number;
-  identifier: string | number;
 }
 
 export interface EntityReadResult {
@@ -183,10 +177,7 @@ export type EntityReadResponse = EntityReadResult;
  * Entity write content
  */
 export interface EntityWriteRequest {
-  provider: string;
+  target: EntityIdentifier;
-  service: string | number;
-  collection: string | number;
-  identifier: string | number;
   content: string;
   encoding?: 'base64';
 }

src/types/index.ts

@@ -4,4 +4,3 @@ export type * from './service';
 export type * from './collection';
 export type * from './entity';
 export type * from './document';
-export type * from './node';

src/types/node.ts

@@ -1,37 +0,0 @@
-/**
- * Node types for combined operations
- */
-
-import type { CollectionInterface } from "./collection";
-import type { ApiResponse, ListFilterCondition, ListRange, ListSort } from "./common";
-import type { EntityInterface } from "./entity";
-
-export interface NodeListRequest {
-  provider: string;
-  service: string;
-  location?: string | null;
-  recursive?: boolean;
-  filter?: ListFilterCondition | null;
-  sort?: ListSort | null;
-  range?: ListRange | null;
-}
-
-export type NodeListResponse = ApiResponse<CollectionInterface | EntityInterface>;
-
-export interface NodeDeltaRequest {
-  provider: string;
-  service: string;
-  location?: string | null;
-  signature: string;
-  recursive?: boolean;
-  detail?: 'ids' | 'full';
-}
-
-export interface NodeDeltaResult {
-  added: string[];
-  modified: string[];
-  removed: string[];
-  signature: string;
-}
-
-export type NodeDeltaResponse = ApiResponse<NodeDeltaResult>;

src/types/provider.ts

@@ -1,7 +1,7 @@
 /**
  * Provider type definitions
  */
-import type { SourceSelector } from "./common";
+import type { ProviderIdentifier } from "./common";
 
 /**
  * Provider capabilities
@@ -32,7 +32,7 @@ export interface ProviderInterface {
  * Provider list
  */
 export interface ProviderListRequest {
-  sources?: SourceSelector;
+  targets?: ProviderIdentifier[];
 }
 
 export interface ProviderListResponse {
@@ -43,7 +43,7 @@ export interface ProviderListResponse {
  * Provider fetch
  */
 export interface ProviderFetchRequest {
-  identifier: string;
+  target: ProviderIdentifier;
 }
 
 export interface ProviderFetchResponse extends ProviderInterface {}
@@ -52,7 +52,7 @@ export interface ProviderFetchResponse extends ProviderInterface {}
  * Provider extant
  */
 export interface ProviderExtantRequest {
-  sources: SourceSelector;
+  targets: ProviderIdentifier[];
 }
 
 export interface ProviderExtantResponse {

src/types/service.ts

@@ -1,7 +1,7 @@
 /**
  * Service type definitions
  */
-import type { SourceSelector, ListFilterComparisonOperator } from './common';
+import type { ServiceIdentifier as ServiceIdentifierString, ListFilterComparisonOperator } from './common';
 
 /**
  * Service capabilities
@@ -66,7 +66,7 @@ export interface ServiceInterface {
  * Service list
  */
 export interface ServiceListRequest {
-  sources?: SourceSelector;
+  targets?: ServiceIdentifierString[];
 }
 
 export interface ServiceListResponse {
@@ -89,7 +89,7 @@ export interface ServiceFetchResponse extends ServiceInterface {}
  * Service extant
  */
 export interface ServiceExtantRequest {
-  sources: SourceSelector;
+  targets: ServiceIdentifierString[];
 }
 
 export interface ServiceExtantResponse {

tests/js/unit/base.test.ts

@@ -0,0 +1,30 @@
+import { describe, it, expect } from 'vitest'
+
+describe('Basic Tests', () => {
+  it('should perform basic assertion', () => {
+    expect(true).toBe(true)
+  })
+
+  it('should test array operations', () => {
+    const array = ['foo', 'bar', 'baz']
+
+    expect(array).toHaveLength(3)
+    expect(array).toContain('bar')
+    expect(array[0]).toBe('foo')
+  })
+
+  it('should test string operations', () => {
+    const string = 'Hello, World!'
+
+    expect(string).toContain('World')
+    expect(string.length).toBe(13)
+  })
+
+  it('should test object operations', () => {
+    const obj = { foo: 'bar', count: 42 }
+
+    expect(obj).toHaveProperty('foo')
+    expect(obj.foo).toBe('bar')
+    expect(obj.count).toBeGreaterThan(40)
+  })
+})

tests/js/vitest.config.ts

@@ -0,0 +1,31 @@
+import { fileURLToPath } from 'node:url'
+import { defineConfig, configDefaults } from 'vitest/config'
+import path from 'path'
+
+const __filename = fileURLToPath(import.meta.url)
+const __dirname = path.dirname(__filename)
+
+export default defineConfig({
+  resolve: {
+    alias: {
+      '@': path.resolve(__dirname, '../../src'),
+      '@KTXC': path.resolve(__dirname, '../../../../core/src'),
+    },
+  },
+  test: {
+    environment: 'jsdom',
+    exclude: [...configDefaults.exclude, 'e2e/**'],
+    root: fileURLToPath(new URL('../../', import.meta.url)),
+    coverage: {
+      provider: 'v8',
+      reporter: ['text', 'json', 'html'],
+      exclude: [
+        'node_modules/',
+        'tests/',
+        '**/*.d.ts',
+        '**/*.config.*',
+        '**/dist/**',
+      ],
+    },
+  },
+})

tests/php/Integration/BaseTest.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace KTXT\DocumentsManager\Tests\Integration;
+
+use PHPUnit\Framework\TestCase;
+
+class BaseTest extends TestCase
+{
+    public function testBasicAssertion(): void
+    {
+        $this->assertTrue(true);
+    }
+
+    public function testArrayOperations(): void
+    {
+        $array = ['foo' => 'bar'];
+
+        $this->assertArrayHasKey('foo', $array);
+        $this->assertEquals('bar', $array['foo']);
+    }
+
+    public function testStringOperations(): void
+    {
+        $string = 'Hello, World!';
+
+        $this->assertStringContainsString('World', $string);
+        $this->assertEquals(13, strlen($string));
+    }
+}

tests/php/Unit/BaseTest.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace KTXT\DocumentsManager\Tests\Unit;
+
+use PHPUnit\Framework\TestCase;
+
+class BaseTest extends TestCase
+{
+    public function testBasicAssertion(): void
+    {
+        $this->assertTrue(true);
+    }
+
+    public function testArrayOperations(): void
+    {
+        $array = ['foo' => 'bar'];
+
+        $this->assertArrayHasKey('foo', $array);
+        $this->assertEquals('bar', $array['foo']);
+    }
+
+    public function testStringOperations(): void
+    {
+        $string = 'Hello, World!';
+
+        $this->assertStringContainsString('World', $string);
+        $this->assertEquals(13, strlen($string));
+    }
+}

tests/php/bootstrap.php

@@ -0,0 +1,17 @@
+<?php
+
+require dirname(__DIR__, 2).'/lib/vendor/autoload.php';
+
+// When this module is checked out inside a full server (server/modules/<handle>,
+// as it is in CI and in this monorepo checkout), also load the server's own
+// core/shared autoloader so tests can reference framework (KTXC/KTXF) types.
+// Standalone module checkouts without a server alongside them skip this.
+define('SERVER_ROOT', dirname(__DIR__, 4));
+$serverAutoload = SERVER_ROOT . '/vendor/autoload.php';
+if (is_file($serverAutoload)) {
+    require $serverAutoload;
+}
+
+if (isset($_SERVER['APP_DEBUG']) && $_SERVER['APP_DEBUG']) {
+    umask(0000);
+}

tests/php/phpunit.xml

@@ -0,0 +1,41 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<!-- https://phpunit.readthedocs.io/en/latest/configuration.html -->
+<phpunit xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:noNamespaceSchemaLocation="../../lib/vendor/phpunit/phpunit/phpunit.xsd"
+         colors="true"
+         failOnDeprecation="true"
+         failOnNotice="true"
+         failOnWarning="true"
+         bootstrap="bootstrap.php"
+         cacheDirectory="../../.phpunit.cache"
+>
+    <php>
+        <ini name="display_errors" value="1" />
+        <ini name="error_reporting" value="-1" />
+        <server name="APP_ENV" value="test" force="true" />
+        <server name="SHELL_VERBOSITY" value="-1" />
+    </php>
+
+    <testsuites>
+        <testsuite name="Unit Tests">
+            <directory>Unit</directory>
+        </testsuite>
+        <testsuite name="Integration Tests">
+            <directory>Integration</directory>
+        </testsuite>
+    </testsuites>
+
+    <source ignoreSuppressionOfDeprecations="true"
+            ignoreIndirectDeprecations="true"
+            restrictNotices="true"
+            restrictWarnings="true"
+    >
+        <include>
+            <directory>../../lib</directory>
+        </include>
+    </source>
+
+    <extensions>
+    </extensions>
+</phpunit>