Merge pull request #1134 from rocket-admin/backend_saved_filters

Backend saved filters

Author: Artuomka

backend/src/app.module.ts

@@ -33,6 +33,7 @@ import { EmailModule } from './entities/email/email/email.module.js';
 import { CompanyLogoModule } from './entities/company-logo/company-logo.module.js';
 import { CompanyFaviconModule } from './entities/company-favicon/company-favicon.module.js';
 import { CompanyTabTitleModule } from './entities/company-tab-title/company-tab-title.module.js';
+import { TableFiltersModule } from './entities/table-filters/table-filters.module.js';
 
 @Module({
   imports: [
@@ -62,6 +63,7 @@ import { CompanyTabTitleModule } from './entities/company-tab-title/company-tab-
     CompanyLogoModule,
     CompanyFaviconModule,
     CompanyTabTitleModule,
+    TableFiltersModule,
   ],
   controllers: [AppController],
   providers: [

backend/src/common/application/global-database-context.interface.ts

@@ -43,6 +43,8 @@ import { AiUserFileEntity } from '../../entities/ai/ai-data-entities/ai-user-fil
 import { CompanyLogoEntity } from '../../entities/company-logo/company-logo.entity.js';
 import { CompanyFaviconEntity } from '../../entities/company-favicon/company-favicon.entity.js';
 import { CompanyTabTitleEntity } from '../../entities/company-tab-title/company-tab-title.entity.js';
+import { TableFiltersEntity } from '../../entities/table-filters/table-filters.entity.js';
+import { ITableFiltersCustomRepository } from '../../entities/table-filters/repository/table-filters-custom-repository.interface.js';
 
 export interface IGlobalDatabaseContext extends IDatabaseContext {
   userRepository: Repository<UserEntity> & IUserRepository;
@@ -77,4 +79,5 @@ export interface IGlobalDatabaseContext extends IDatabaseContext {
   companyLogoRepository: Repository<CompanyLogoEntity>;
   companyFaviconRepository: Repository<CompanyFaviconEntity>;
   companyTabTitleRepository: Repository<CompanyTabTitleEntity>;
+  tableFiltersRepository: Repository<TableFiltersEntity> & ITableFiltersCustomRepository;
 }

backend/src/common/application/global-database-context.ts

@@ -87,6 +87,9 @@ import { aiUserFileRepositoryExtension } from '../../entities/ai/ai-data-entitie
 import { CompanyLogoEntity } from '../../entities/company-logo/company-logo.entity.js';
 import { CompanyFaviconEntity } from '../../entities/company-favicon/company-favicon.entity.js';
 import { CompanyTabTitleEntity } from '../../entities/company-tab-title/company-tab-title.entity.js';
+import { TableFiltersEntity } from '../../entities/table-filters/table-filters.entity.js';
+import { ITableFiltersCustomRepository } from '../../entities/table-filters/repository/table-filters-custom-repository.interface.js';
+import { tableFiltersCustomRepositoryExtension } from '../../entities/table-filters/repository/table-filters-custom-repository-extension.js';
 
 @Injectable({ scope: Scope.REQUEST })
 export class GlobalDatabaseContext implements IGlobalDatabaseContext {
@@ -124,6 +127,7 @@ export class GlobalDatabaseContext implements IGlobalDatabaseContext {
   private _companyLogoRepository: Repository<CompanyLogoEntity>;
   private _companyFaviconRepository: Repository<CompanyFaviconEntity>;
   private _companyTabTitleRepository: Repository<CompanyTabTitleEntity>;
+  private _tableFiltersRepository: Repository<TableFiltersEntity> & ITableFiltersCustomRepository;
 
   public constructor(
     @Inject(BaseType.DATA_SOURCE)
@@ -209,6 +213,9 @@ export class GlobalDatabaseContext implements IGlobalDatabaseContext {
     this._companyLogoRepository = this.appDataSource.getRepository(CompanyLogoEntity);
     this._companyFaviconRepository = this.appDataSource.getRepository(CompanyFaviconEntity);
     this._companyTabTitleRepository = this.appDataSource.getRepository(CompanyTabTitleEntity);
+    this._tableFiltersRepository = this.appDataSource
+      .getRepository(TableFiltersEntity)
+      .extend(tableFiltersCustomRepositoryExtension);
   }
 
   public get userRepository(): Repository<UserEntity> & IUserRepository {
@@ -339,6 +346,10 @@ export class GlobalDatabaseContext implements IGlobalDatabaseContext {
     return this._companyTabTitleRepository;
   }
 
+  public get tableFiltersRepository(): Repository<TableFiltersEntity> & ITableFiltersCustomRepository {
+    return this._tableFiltersRepository;
+  }
+
   public startTransaction(): Promise<void> {
     this._queryRunner = this.appDataSource.createQueryRunner();
     this._queryRunner.startTransaction();

backend/src/common/data-injection.tokens.ts

@@ -185,4 +185,8 @@ export enum UseCaseType {
   GET_ALL_USER_THREADS_WITH_AI_ASSISTANT = 'GET_ALL_USER_THREADS_WITH_AI_ASSISTANT',
   GET_ALL_THREAD_MESSAGES = 'GET_ALL_THREAD_MESSAGES',
   DELETE_THREAD_WITH_AI_ASSISTANT = 'DELETE_THREAD_WITH_AI_ASSISTANT',
+
+  CREATE_TABLE_FILTERS = 'CREATE_TABLE_FILTERS',
+  FIND_TABLE_FILTERS = 'FIND_TABLE_FILTERS',
+  DELETE_TABLE_FILTERS = 'DELETE_TABLE_FILTERS',
 }

backend/src/entities/connection/connection.entity.ts

@@ -25,6 +25,7 @@ import { CompanyInfoEntity } from '../company-info/company-info.entity.js';
 import { ActionRulesEntity } from '../table-actions/table-action-rules-module/action-rules.entity.js';
 import { nanoid } from 'nanoid';
 import { Constants } from '../../helpers/constants/constants.js';
+import { TableFiltersEntity } from '../table-filters/table-filters.entity.js';
 
 @Entity('connection')
 export class ConnectionEntity {
@@ -234,4 +235,7 @@ export class ConnectionEntity {
   @ManyToOne((_) => CompanyInfoEntity, (company) => company.connections)
   @JoinTable()
   company: Relation<CompanyInfoEntity>;
+
+  @OneToMany((_) => TableFiltersEntity, (table_filters) => table_filters.connection)
+  table_filters: Relation<TableFiltersEntity>[];
 }

backend/src/entities/table-filters/application/data-structures/create-table-filters.ds.ts

@@ -0,0 +1,6 @@
+export class CreateTableFiltersDto {
+  table_name: string;
+  connection_id: string;
+  filters: Record<string, any>;
+  masterPwd: string;
+}

backend/src/entities/table-filters/application/data-structures/find-table-filters.ds.ts

@@ -0,0 +1,4 @@
+export class FindTableFiltersDs {
+  table_name: string;
+  connection_id: string;
+}

backend/src/entities/table-filters/application/response-objects/created-table-filters.ro.ts

@@ -0,0 +1,15 @@
+import { ApiProperty } from '@nestjs/swagger';
+
+export class CreatedTableFiltersRO {
+  @ApiProperty()
+  id: string;
+
+  @ApiProperty()
+  tableName: string;
+
+  @ApiProperty()
+  connectionId: string;
+
+  @ApiProperty({ type: Object })
+  filters: Record<string, any>;
+}

backend/src/entities/table-filters/repository/table-filters-custom-repository-extension.ts

@@ -0,0 +1,12 @@
+import { TableFiltersEntity } from '../table-filters.entity.js';
+import { ITableFiltersCustomRepository } from './table-filters-custom-repository.interface.js';
+
+export const tableFiltersCustomRepositoryExtension: ITableFiltersCustomRepository = {
+  async findTableFiltersForTableInConnection(tableName: string, connectionId: string): Promise<TableFiltersEntity> {
+    const qb = this.createQueryBuilder('table_filters')
+      .leftJoin('table_filters.connection', 'connection')
+      .where('table_filters.table_name = :tableName', { tableName: tableName })
+      .andWhere('connection.id = :connectionId', { connectionId: connectionId });
+    return await qb.getOne();
+  },
+};

backend/src/entities/table-filters/repository/table-filters-custom-repository.interface.ts

@@ -0,0 +1,5 @@
+import { TableFiltersEntity } from '../table-filters.entity.js';
+
+export interface ITableFiltersCustomRepository {
+  findTableFiltersForTableInConnection(tableName: string, connectionId: string): Promise<TableFiltersEntity>;
+}