feat: handle resource deletion

src/schemas/core/index.ts

@@ -8,3 +8,4 @@ export * from './link.schema';
 export * from './file.schema';
 export * from './polygonParts.schema';
 export * from './tile.schema';
+export * from './storage.schema';

src/schemas/core/storage.schema.ts

@@ -0,0 +1,13 @@
+import { z } from 'zod';
+import { SourceType } from '../../constants/core/constants';
+
+export const fsStorageSchema = z.object({
+  storageProvider: z.literal(SourceType.FS),
+});
+
+export const s3StorageSchema = z.object({
+  storageProvider: z.literal(SourceType.S3),
+  bucket: z.string().min(1),
+});
+
+export const storageSchema = z.discriminatedUnion('storageProvider', [fsStorageSchema, s3StorageSchema]);

src/schemas/deletion/task.schema.ts

@@ -1,7 +1,5 @@
 import { z } from 'zod';
-import { SourceType } from '../../constants/core/constants';
-
-export const sourceProviderSchema = z.union([z.literal(SourceType.S3), z.literal(SourceType.FS)]);
+import { storageSchema } from '../core';
 
 export const deleteTaskParamsSchema = z
   .object({
@@ -12,19 +10,10 @@ export const deleteTaskParamsSchema = z
   })
   .describe('deleteTaskParamsSchema');
 
-export const deletionParamsBaseSchema = z.object({
-  sourceProvider: sourceProviderSchema,
-  bucket: z.string().optional(),
+export const deleteStoredResourcesParamsBaseSchema = z.object({
+  paths: z.array(z.string().min(1)).min(1),
 });
 
-export const layerTilesDeletionParamsSchema = deletionParamsBaseSchema
-  .extend({
-    catalogId: z.string().uuid(),
-  })
-  .describe('layerTilesDeletionParamsSchema');
-
-export const artifactsDeletionParamsSchema = deletionParamsBaseSchema
-  .extend({
-    paths: z.array(z.string().min(1)).min(1), // explicit thumbnail/legend object keys (s3) or file paths (fs)
-  })
-  .describe('artifactsDeletionParamsSchema');
+export const deleteStoredResourcesParamsSchema = deleteStoredResourcesParamsBaseSchema
+  .and(storageSchema)
+  .describe('deleteStoredResourcesParamsSchema');

src/types/core/index.ts

@@ -8,3 +8,4 @@ export * from './file.type';
 export * from './callback.type';
 export * from './polygonParts.type';
 export * from './tile.type';
+export * from './storage.type';

src/types/core/storage.type.ts

@@ -0,0 +1,6 @@
+import type { z } from 'zod';
+import type { fsStorageSchema, s3StorageSchema, storageSchema } from '../../schemas';
+
+export type FsStorage = z.infer<typeof fsStorageSchema>;
+export type S3Storage = z.infer<typeof s3StorageSchema>;
+export type Storage = z.infer<typeof storageSchema>;

src/types/deletion/task.type.ts

@@ -1,6 +1,5 @@
 import z from 'zod';
-import { deleteTaskParamsSchema, layerTilesDeletionParamsSchema, artifactsDeletionParamsSchema } from '../../schemas/deletion/task.schema';
+import { deleteTaskParamsSchema, deleteStoredResourcesParamsSchema } from '../../schemas/deletion/task.schema';
 
 export type DeleteTaskParams = z.infer<typeof deleteTaskParamsSchema>;
-export type LayerTilesDeletionParams = z.infer<typeof layerTilesDeletionParamsSchema>;
-export type ArtifactsDeletionParams = z.infer<typeof artifactsDeletionParamsSchema>;
+export type DeleteStoredResourcesParams = z.infer<typeof deleteStoredResourcesParamsSchema>;