FIX: Ref Catalogo new functions models

src/modules/catalog/catalog.controller.ts

@@ -1,15 +1,15 @@
 import {
   Body,
   Controller,
-  Delete,
-  ForbiddenException,
   Get,
+  Headers,
   HttpException,
   Inject,
   Param,
   Post,
   Put,
   Query,
+  UnsupportedMediaTypeException,
 } from '@nestjs/common';
 import { ApiTags } from '@nestjs/swagger';
 import {
@@ -21,6 +21,7 @@ import { CatalogService } from './catalog.service';
 import { DadosferaLogger } from '@dadosfera/dadosfera-logs';
 import { PackTheMetadata } from 'src/utils/ PackTheMetadata';
 import { RequestUser, User } from 'src/authentication/user.decorator';
+import { ICatalogAllResponse } from './dtos';
 
 @ApiTags('Catalog')
 @Controller('catalog')
@@ -56,54 +57,15 @@ export class CatalogController {
     this.logger = dadosferaLogger.logger;
   }
 
-  @Put('manage_permissions/:id')
-  async manageDataAssetPermissions(
-    @Param('id') id: string,
+  @Get()
+  async catalogAll(
     @User() user: RequestUser,
-    @Body() body,
-  ) {
-    const { customer_id, customer_name, user_id, username } = user;
-    const metadata = PackTheMetadata({
-      customer_id,
-      customer_name,
-      user_id,
-      username,
-    });
-    const response = await this.catalogService.managePermissions(
-      { ...body, id },
-      metadata,
-    );
-
-    return { data_asset: JSON.parse(response.data_asset) };
-  }
-
-  @Put('revoke_permissions/:id')
-  async revokeDataAssetPermissions(
-    @Param('id') id: string,
-    @User() user: RequestUser,
-    @Body() body,
-  ) {
-    const { customer_id, customer_name, user_id, username } = user;
-    const metadata = PackTheMetadata({
-      customer_id,
-      customer_name,
-      user_id,
-      username,
-    });
-    const response = await this.catalogService.revokePermissions(
-      { ...body, id },
-      metadata,
-    );
-
-    return { message: response.message };
-  }
-
-  @Get('all')
-  async catalogAll(@User() user: RequestUser, @Body() body, @Query() params) {
+    @Query() query,
+  ): Promise<ICatalogAllResponse> {
     const { user_id, customer_name, customer_id, username, permissions } = user;
-    this.logger.info(`/catalog - ON CATALOG ALL ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
+    this.logger.info(`/catalog - Catalog all data assets`, {
+      user_id,
+      customer_name,
     });
 
     const is_data_manager = permissions.includes(
@@ -122,337 +84,12 @@ export class CatalogController {
     });
 
     const res = await this.catalogService.getAllOpenSearchDataAssets(
-      params,
+      query,
       metadata,
       customer_id,
     );
 
-    return res.data_assets;
-  }
-
-  @Get('data_apps')
-  async dataAppsAll(@Body() body) {
-    this.logger.info(`/catalog - ON FIND ALL DATA APPS ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-
-    const res = await this.catalogService.dataAppsAll(body);
-
-    return res;
-  }
-
-  @Delete('data_apps/:id')
-  async dataAppsOne(@Param() params, @Body() body) {
-    this.logger.info(`/catalog - ON FIND ONE DATA APP ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-    const { id } = params;
-
-    const res = await this.catalogService.dataAppsOne(id, body);
-
-    return res;
-  }
-
-  @Get('dashboard-metabase/:id')
-  async getOneDashboardMetabase(
-    @Body() body,
-    @Param() params,
-    @User() user: RequestUser,
-  ) {
-    const { id } = params;
-    this.logger.info(`/catalog - ON GET ONE DASHBOARD METABASE ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-
-    const { username, user_id, customer_id, customer_name, permissions } = user;
-    const is_data_manager = permissions.includes(
-      PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER.seqid,
-    );
-    let has_permission = false;
-    const metadata = PackTheMetadata({
-      username,
-      user_id,
-      customer_id,
-      customer_name,
-    });
-
-    const user_roles = await this.catalogService.getUserRolesIds(user_id);
-
-    const res = await this.catalogService.getOneDashboardMetabase(
-      id,
-      body,
-      metadata,
-      customer_id,
-    );
-
-    const dashboard = res.dashboard;
-
-    if (dashboard.owner === username) has_permission = true;
-
-    for (const role of user_roles) {
-      if (dashboard.p_roles.includes(role)) has_permission = true;
-    }
-
-    if (dashboard.p_users.includes(user_id)) has_permission = true;
-
-    if (is_data_manager || has_permission) {
-      delete dashboard.p_roles;
-      delete dashboard.p_users;
-      return res;
-    }
-
-    throw new HttpException(
-      'You do not have permission to access this data asset.',
-      403,
-    );
-  }
-
-  @Get('table-metadata')
-  async getAllTableMetadata(
-    @Body() body,
-    @Query() query,
-    @User() user: RequestUser,
-  ) {
-    this.logger.info(`/catalog - ON GET ALL TABLES METADATA ROUTE`, {
-      user: user.user_id,
-      customer: user.customer_name,
-    });
-    const { user_id, customer_name, customer_id, permissions, username } = user;
-    const is_data_manager = permissions.includes(
-      PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER.seqid,
-    );
-    let has_permission = false;
-    const metadata = PackTheMetadata({
-      user_id,
-      customer_id,
-      customer_name,
-    });
-
-    if (!query) {
-      const res = await this.catalogService.getAllTableMetadata(body);
-      return res;
-    } else {
-      const user_roles = await this.catalogService.getUserRolesIds(user_id);
-      const res = await this.catalogService.getOneTableMetadata(
-        body,
-        query,
-        metadata,
-        customer_id,
-      );
-      const table = res[0];
-
-      if (table.owner === username) has_permission = true;
-
-      for (const role of user_roles) {
-        if (table.p_roles.includes(role)) has_permission = true;
-      }
-
-      if (table.p_users.includes(user_id)) has_permission = true;
-
-      if (is_data_manager || has_permission) {
-        delete table.p_roles;
-        delete table.p_users;
-        return res;
-      }
-
-      throw new ForbiddenException(
-        'You do not have permission to access this data asset.',
-      );
-    }
-  }
-
-  @Delete('table-metadata/:id')
-  async deleteOneTableMetadata(@Param() params, @Body() body) {
-    const { id } = params;
-    this.logger.info(`/catalog - ON DELETE ONE TABLE METADATA ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-
-    const res = await this.catalogService.deleteOneTableMetadata(id, body);
-
-    return res;
-  }
-
-  @Get('column-metadata')
-  async getOneColumnMetadata(@Body() body, @Query() params) {
-    this.logger.info(`/catalog - ON GET ONE COLUMN METADATA ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-
-    const res = await this.catalogService.getOneColumnMetadata(body, params);
-
-    return res;
-  }
-
-  @Delete('column-metadata/:id')
-  async deleteOneColumnMetadata(@Param() params, @Body() body) {
-    this.logger.info(`/catalog - ON DELETE ONE COLUMN METADATA ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-    const { id } = params;
-
-    const res = await this.catalogService.deleteOneColumnMetadata(id, body);
-
-    return res;
-  }
-
-  @Get('data-preview')
-  async getOneDataPreview(@Body() body, @Query() params) {
-    this.logger.info(`/catalog - ON GET ONE DATAPREVIEW ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-
-    const res = await this.catalogService.getOneDataPreview(body, params);
-
-    return res;
-  }
-
-  @Get('data-status')
-  async getDataStatus(@Body() body) {
-    this.logger.info(`/catalog - ON GET DATA STATUS ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-
-    const res = await this.catalogService.getDataStatus(body);
-
-    return res;
-  }
-
-  @Get('data-status')
-  async createDataStatus(@Body() body) {
-    this.logger.info(`/catalog - ON CREATE DATA STATUS ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-
-    const res = await this.catalogService.createDataStatus(body);
-
-    return res;
-  }
-
-  @Get('data-docs')
-  async getDataDocs(@Body() body) {
-    this.logger.info(`/catalog - ON GET DATA DOCS ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-
-    const res = await this.catalogService.getDataDocs(body);
-
-    return res;
-  }
-
-  @Post('data-docs')
-  async createDataDocs(@Body() body) {
-    this.logger.info(`/catalog - ON CREATE DATA DOCS ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-
-    const res = await this.catalogService.createDataDocs(body);
-
-    return res;
-  }
-
-  @Get('data-rating')
-  async getDataRating(@Body() body) {
-    this.logger.info(`/catalog - ON GET DATA RATING ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-
-    const res = await this.catalogService.getDataRating(body);
-
-    return res;
-  }
-
-  @Post('data-rating')
-  async createDataRating(@Body() body) {
-    this.logger.info(`/catalog - ON GET DATA RATING ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-
-    const res = await this.catalogService.createDataRating(body);
-
-    return res;
-  }
-
-  @Get('summary-rating/:id')
-  async getSummaryRating() {
-    this.logger.info(`/catalog - ON GET SUMMARY RATING ROUTE`);
-    //const { id } = params;
-
-    //
-
-    //const res = await this.catalogService.getSummaryRating(id, body);
-
-    return {
-      avg_rating: 0,
-      rating_count: 0,
-    };
-  }
-
-  @Get('data-comment')
-  async getDataComment(@Body() body) {
-    this.logger.info(`/catalog - ON GET DATA COMMENT ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-
-    const res = await this.catalogService.getDataComment(body);
-
-    return res;
-  }
-
-  @Post('data-comment')
-  async createDataComment(@Body() body) {
-    this.logger.info(`/catalog - ON GET DATA COMMENT ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-
-    const res = await this.catalogService.createDataComment(body);
-
-    return res;
-  }
-
-  @Get('data-review')
-  async getDataReview(@Body() body, @Query() params) {
-    this.logger.info(`/catalog - ON GET DATA REVIEW ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
-    });
-
-    const res = await this.catalogService.getDataReview(body, params);
-
-    return res;
-  }
-
-  @Post('tags')
-  async createTags(@Body() body, @User() user: RequestUser) {
-    this.logger.info(`/catalog - ON CREATE TAG ROUTE`, {
-      user: user.user_id,
-      customer: user.customer_name,
-    });
-    const { user_id, customer_name, customer_id } = user;
-    const metadata = PackTheMetadata({
-      user_id,
-      customer_id,
-      customer_name,
-    });
-
-    const res = await this.catalogService.createTags(body, metadata);
-
-    return res.data_assets;
+    return { ...res };
   }
 
   @Get('tags')
@@ -474,28 +111,251 @@ export class CatalogController {
     return res;
   }
 
-  @Get('table-rules')
-  async getTableRules(@Body() body) {
-    this.logger.info(`/catalog - ON GET TABLE RULES ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
+  @Get('data-asset/:id')
+  async getDataAsset(
+    @User() user: RequestUser,
+    @Headers() headers,
+    @Param('id') id,
+  ) {
+    const { username, user_id, customer_id, customer_name, permissions } = user;
+    const [data_asset_type, data_asset_id] = id.split('-');
+
+    this.logger.info(`/catalog - ON GET ONE DASHBOARD METABASE ROUTE`, {
+      username,
+      customer_name,
     });
 
-    const res = await this.catalogService.getTableRules(body);
+    const is_data_manager = permissions.includes(
+      PERMISSIONS_GROUPS.CATALOG.permissions.DATA_MANAGER.seqid,
+    );
+    let has_permission = false;
+    const metadata = PackTheMetadata({
+      username,
+      user_id,
+      customer_id,
+      customer_name,
+    });
+
+    const user_roles = await this.catalogService.getUserRolesIds(user_id);
+
+    const { data_asset } = await this.catalogService.getOneDataAsset({
+      customer_id,
+      data_asset_id,
+      data_asset_type,
+      metadata,
+    });
+
+    if (data_asset?.owner === username) has_permission = true;
+
+    for (const role of user_roles) {
+      if (data_asset.p_roles.includes(role)) has_permission = true;
+    }
+
+    if (data_asset.p_users.includes(user_id)) has_permission = true;
+
+    if (is_data_manager || has_permission) {
+      delete data_asset.p_roles;
+      delete data_asset.p_users;
+      return { data_asset };
+    }
+
+    throw new HttpException(
+      'You do not have permission to access this data asset.',
+      403,
+    );
+  }
+
+  @Get('data-asset/:id/columns-metadata')
+  async getDataAssetColumnsMetadata(
+    @User() user: RequestUser,
+    @Headers('Dadosfera-Lang') language,
+    @Param('id') id,
+  ) {
+    const { customer_name, customer_id, user_id, username } = user;
+    const data_asset_type = id.split('-')[0];
+
+    const supported_data_assets = ['dataset'];
+
+    if (!supported_data_assets.includes(data_asset_type)) {
+      throw new UnsupportedMediaTypeException(
+        `${data_asset_type} does not have a preview function for the time being.`,
+      );
+    }
+
+    this.logger.info(`/catalog - ON GET DATA DOCS ROUTE`, {
+      user_id,
+      customer_name,
+    });
+
+    const metadata = PackTheMetadata({
+      customer_name,
+      customer_id,
+      user_id,
+      username,
+      language,
+    });
+
+    const columns_metadata =
+      await this.catalogService.getDatasetColumnsMetadata(id, metadata);
+
+    return { columns_metadata };
+  }
+
+  @Get('data-asset/:id/preview')
+  async getDataAssetPreview(
+    @User() user: RequestUser,
+    @Headers('Dadosfera-lang') language,
+    @Param('id') id,
+  ) {
+    const { customer_name, customer_id, user_id, username } = user;
+    const data_asset_type = id.split('-')[0];
+
+    const supported_data_assets = ['dataset'];
+
+    if (!supported_data_assets.includes(data_asset_type)) {
+      throw new UnsupportedMediaTypeException(
+        `${data_asset_type} does not have a preview function for the time being.`,
+      );
+    }
+
+    this.logger.info(`/catalog - ON GET DATA DOCS ROUTE`, {
+      user_id,
+      customer_name,
+    });
+
+    const metadata = PackTheMetadata({
+      customer_name,
+      customer_id,
+      user_id,
+      username,
+      language,
+    });
+
+    const preview = await this.catalogService.getDatasetPreview(id, metadata);
+
+    return { preview };
+  }
+
+  @Get('data-asset/:id/docs')
+  async getDataAssetDocs(
+    @User() user: RequestUser,
+    @Headers('Dadosfera-Lang') language,
+    @Param('id') id,
+  ) {
+    const { customer_name, customer_id, user_id, username } = user;
+    const data_asset_type = id.split('-')[0];
+
+    const supported_data_assets = ['dataset'];
+
+    if (!supported_data_assets.includes(data_asset_type)) {
+      throw new UnsupportedMediaTypeException(
+        `${data_asset_type} does not have a documentation function for the time being.`,
+      );
+    }
+
+    this.logger.info(`/catalog - ON GET DATA DOCS ROUTE`, {
+      user_id,
+      customer_name,
+    });
+
+    const metadata = PackTheMetadata({
+      customer_name,
+      customer_id,
+      user_id,
+      username,
+      language,
+    });
+
+    const docs = await this.catalogService.getDataDocs(id, metadata);
+
+    return { docs };
+  }
+
+  @Put('data-asset/:id')
+  async updateDataAsset(
+    @User() user: RequestUser,
+    @Headers() headers,
+    @Param('id') id,
+  ) {
+    console.log(user, headers);
+    return { data_asset_id: id, message: 'Under development' };
+  }
+
+  @Post('data-asset/:id/docs')
+  async manageDataAssetDocs(
+    @User() user: RequestUser,
+    @Headers() headers,
+    @Param('id') data_asset_id,
+    @Body('docs') docs: string,
+  ) {
+    const { user_id, customer_name } = user;
+    const [data_asset_type, id] = data_asset_id.split('-');
+
+    this.logger.info(`/catalog - ON GET DATA DOCS ROUTE`, {
+      user_id,
+      customer_name,
+    });
+
+    const res = await this.catalogService.createDataDocs({
+      table_id: id,
+      docs,
+      info: {
+        customer: customer_name,
+      },
+    });
 
     return res;
   }
 
-  @Delete('table-rules/:id')
-  async deleteTableRules(@Param() params, @Body() body) {
-    this.logger.info(`/catalog - ON DELETE TABLE RULES ROUTE`, {
-      user: body.info.user_id,
-      customer: body.info.customer,
+  @Post('data-asset/:id/comment')
+  async makeAComment(
+    @User() user: RequestUser,
+    @Headers() headers,
+    @Param('id') id,
+  ) {
+    console.log(user, headers);
+    return { data_asset_id: id, message: 'Under development' };
+  }
+
+  @Put('data-asset/:id/manage-permissions')
+  async manageDataAssetPermissions(
+    @Param('id') id: string,
+    @User() user: RequestUser,
+    @Body() body,
+  ) {
+    const { customer_id, customer_name, user_id, username } = user;
+    const metadata = PackTheMetadata({
+      customer_id,
+      customer_name,
+      user_id,
+      username,
     });
-    const { id } = params;
+    const response = await this.catalogService.managePermissions(
+      { ...body, id },
+      metadata,
+    );
 
-    const res = await this.catalogService.deleteTableRules(id, body);
+    return { data_asset: JSON.parse(response.data_asset) };
+  }
 
-    return res;
+  @Put('data-asset/:id/revoke-permissions')
+  async revokeDataAssetPermissions(
+    @Param('id') id: string,
+    @User() user: RequestUser,
+    @Body() body,
+  ) {
+    const { customer_id, customer_name, user_id, username } = user;
+    const metadata = PackTheMetadata({
+      customer_id,
+      customer_name,
+      user_id,
+      username,
+    });
+    const response = await this.catalogService.revokePermissions(
+      { ...body, id },
+      metadata,
+    );
+
+    return { message: response.message };
   }
 }