feat: colleciton delete #15

Merged
Sebastian merged 1 commits from feat/collection-delete into main 2026-05-06 02:33:22 +00:00
6 changed files with 74 additions and 11 deletions

View File

@@ -549,7 +549,7 @@ class DefaultController extends ControllerAbstract {
throw new InvalidArgumentException(self::ERR_INVALID_IDENTIFIER);
}
return $this->mailManager->collectionDelete(
$result = $this->mailManager->collectionDelete(
$tenantId,
$userId,
$data['provider'],
@@ -557,6 +557,48 @@ class DefaultController extends ControllerAbstract {
$data['identifier'],
$data['options'] ?? []
);
if (is_bool($result)) {
return [
'outcome' => 'deleted'
];
}
if ($result instanceof JsonSerializable) {
return [
'outcome' => 'moved',
'data' => $result
];
}
return $result;
}
private function collectionMove(string $tenantId, string $userId, array $data): mixed {
if (!isset($data['target'])) {
throw new InvalidArgumentException(self::ERR_MISSING_TARGET);
}
if (!is_string($data['target'])) {
throw new InvalidArgumentException(self::ERR_INVALID_TARGET);
}
if (!isset($data['sources'])) {
throw new InvalidArgumentException(self::ERR_MISSING_SOURCES);
}
if (!is_array($data['sources'])) {
throw new InvalidArgumentException(self::ERR_INVALID_SOURCES);
}
$target = ResourceIdentifier::fromString($data['target']);
if (!$target instanceof CollectionIdentifier) {
throw new InvalidArgumentException('Invalid parameter: target must be provider:service:collection');
}
$source = ResourceIdentifier::fromArray($data['source']);
if (!$source instanceof CollectionIdentifier) {
throw new InvalidArgumentException('Invalid parameter: sources must contain provider:service:collection identifiers');
}
return $this->mailManager->collectionMove($tenantId, $userId, $target, $source);
}
// ==================== Entity Operations ====================

View File

@@ -653,7 +653,7 @@ class Manager {
*
* @return CollectionBaseInterface|null
*/
public function collectionDelete(string $tenantId, ?string $userId, string $providerId, string|int $serviceId, string|int $collectionId, array $options = []): bool {
public function collectionDelete(string $tenantId, ?string $userId, string $providerId, string|int $serviceId, string|int $collectionId, array $options = []): CollectionBaseInterface | bool {
// retrieve service
$service = $this->serviceFetch($tenantId, $userId, $providerId, $serviceId);
@@ -666,10 +666,9 @@ class Manager {
}
$force = $options['force'] ?? false;
$recursive = $options['recursive'] ?? false;
// delete collection
return $service->collectionDelete($collectionId, $force, $recursive);
return $service->collectionDelete($collectionId, $force);
}
// ==================== Message Operations ====================

View File

@@ -123,8 +123,14 @@ export const collectionService = {
*
* @returns Promise with deletion result
*/
async delete(request: CollectionDeleteRequest): Promise<CollectionDeleteResponse> {
return await transceivePost<CollectionDeleteRequest, CollectionDeleteResponse>('collection.delete', request);
async delete(request: CollectionDeleteRequest): Promise<boolean | CollectionObject> {
const response = await transceivePost<CollectionDeleteRequest, CollectionDeleteResponse>('collection.delete', request);
if (response.outcome === 'moved' && response.data) {
return createCollectionObject(response.data);
}
return true;
},
};

View File

@@ -26,7 +26,6 @@ import type {
EntityStreamRequest,
EntityStreamResponse,
} from '../types/entity';
import type { EntityIdentifier } from '../types/common';
import { useIntegrationStore } from '@KTXC/stores/integrationStore';
import { EntityObject } from '../models';

View File

@@ -385,12 +385,16 @@ export const useCollectionsStore = defineStore('mailCollectionsStore', () => {
*
* @returns Promise with deletion result
*/
async function remove(provider: string, service: string | number, identifier: string | number): Promise<any> {
async function remove(provider: string, service: string | number, identifier: string | number): Promise<CollectionObject | boolean> {
transceiving.value = true
try {
await collectionService.delete({ provider, service, identifier })
const response = await collectionService.delete({ provider, service, identifier })
// Remove deleted collection from state
if (response !== true && !(response instanceof CollectionObject)) {
console.warn('[Mail Manager][Store] - Delete failed. Received unexpected response from delete operation:', response)
return false
}
const key = identifierKey(provider, service, identifier)
const previousCollection = _collections.value[key]
@@ -400,7 +404,19 @@ export const useCollectionsStore = defineStore('mailCollectionsStore', () => {
delete _collections.value[key]
if (response instanceof CollectionObject) {
const movedCollection = response
const movedKey = identifierKey(movedCollection.provider, movedCollection.service, movedCollection.identifier)
_collections.value[movedKey] = movedCollection
indexCollection(movedCollection)
console.debug('[Mail Manager][Store] - Successfully moved collection to trash', key, '->', movedKey)
return response
}
console.debug('[Mail Manager][Store] - Successfully deleted collection:', key)
return response
} catch (error: any) {
console.error('[Mail Manager][Store] - Failed to delete collection:', error)
throw error

View File

@@ -124,5 +124,6 @@ export interface CollectionDeleteRequest {
}
export interface CollectionDeleteResponse {
success: boolean;
outcome: 'deleted' | 'moved';
data?: CollectionInterface | null; // If moved, the new location of the collection
}