add controllers callbacks

api/registry/types.ts

@@ -1,2 +1,16 @@
 export type {DLSConstructor} from '../../src/registry/common/components/dls/types';
+export type {
+    OnCreateCollectionError,
+    OnCreateCollectionSuccess,
+    OnMoveCollectionError,
+    OnMoveCollectionSuccess,
+    OnMoveCollectionsListError,
+    OnMoveCollectionsListSuccess,
+    OnUpdateCollectionError,
+    OnUpdateCollectionSuccess,
+    OnDeleteCollectionError,
+    OnDeleteCollectionSuccess,
+    OnDeleteCollectionsListError,
+    OnDeleteCollectionsListSuccess,
+} from '../../src/registry/common/utils/controllers-callbacks/collections';
 export type {GatewayApi} from '../../src/registry';

src/components/validation-schema-compiler.ts

@@ -12,7 +12,6 @@ import {
 import US_ERRORS from '../const/us-error-constants';
 
 const ajv = new Ajv({
-    allErrors: true,
     verbose: true,
 });
 

src/controllers/collections/create.ts

@@ -0,0 +1,67 @@
+import {Request, Response} from '@gravity-ui/expresskit';
+
+import {prepareResponseAsync} from '../../components/response-presenter';
+import {makeSchemaValidator} from '../../components/validation-schema-compiler';
+import {createCollection} from '../../services/new/collection';
+import {formatCollectionWithOperation} from '../../services/new/collection/formatters';
+
+export type CreateCollectionReqBody = {
+    title: string;
+    description?: string;
+    parentId: Nullable<string>;
+};
+
+const validateBody = makeSchemaValidator({
+    type: 'object',
+    required: ['title', 'parentId'],
+    properties: {
+        title: {
+            type: 'string',
+        },
+        description: {
+            type: 'string',
+        },
+        parentId: {
+            type: ['string', 'null'],
+        },
+    },
+});
+
+export const createCollectionController = async (req: Request, res: Response) => {
+    const body = validateBody<CreateCollectionReqBody>(req.body);
+
+    const registry = req.ctx.get('registry');
+    const {
+        controllersCallbacks: {onCreateCollectionError, onCreateCollectionSuccess},
+    } = registry.common.functions.get();
+
+    try {
+        const result = await createCollection(
+            {ctx: req.ctx},
+            {
+                title: body.title,
+                description: body.description,
+                parentId: body.parentId,
+            },
+        );
+
+        onCreateCollectionSuccess({
+            ctx: req.ctx,
+            reqBody: body,
+            collection: result.collection.model,
+        });
+
+        const formattedResponse = formatCollectionWithOperation(
+            result.collection,
+            result.operation,
+        );
+
+        const {code, response} = await prepareResponseAsync({data: formattedResponse});
+
+        res.status(code).send(response);
+    } catch (error) {
+        onCreateCollectionError({ctx: req.ctx, reqBody: body, error});
+
+        throw error;
+    }
+};

src/controllers/collections/delete.ts

@@ -0,0 +1,54 @@
+import {Request, Response} from 'express';
+
+import {prepareResponseAsync} from '../../components/response-presenter';
+import {makeSchemaValidator} from '../../components/validation-schema-compiler';
+import {deleteCollections} from '../../services/new/collection';
+import {formatCollectionModelsList} from '../../services/new/collection/formatters';
+
+export type DeleteCollectionReqParams = {
+    collectionId: string;
+};
+
+const validateParams = makeSchemaValidator({
+    type: 'object',
+    required: ['collectionId'],
+    properties: {
+        collectionId: {
+            type: 'string',
+        },
+    },
+});
+
+export const deleteCollectionController = async (req: Request, res: Response) => {
+    const params = validateParams(req.params) as DeleteCollectionReqParams;
+
+    const registry = req.ctx.get('registry');
+    const {
+        controllersCallbacks: {onDeleteCollectionError, onDeleteCollectionSuccess},
+    } = registry.common.functions.get();
+
+    try {
+        const result = await deleteCollections(
+            {ctx: req.ctx},
+            {
+                collectionIds: [params.collectionId],
+            },
+        );
+
+        onDeleteCollectionSuccess({
+            ctx: req.ctx,
+            reqParams: params,
+            collections: result.collections,
+        });
+
+        const formattedResponse = formatCollectionModelsList(result);
+
+        const {code, response} = await prepareResponseAsync({data: formattedResponse});
+
+        res.status(code).send(response);
+    } catch (error) {
+        onDeleteCollectionError({ctx: req.ctx, reqParams: params, error});
+
+        throw error;
+    }
+};