refactor: sharedb work flow (#606)

* refactor: sharedb work flow

* chore: remove non-existent var

* chore: remove useless e2e test

* fix: uniform registration of global guard positions to ensure execution order

* fix: e2e set port

* fix: socket error

* chore: remove test code

apps/nestjs-backend/src/features/auth/auth.controller.ts

@@ -55,7 +55,7 @@ export class AuthController {
 
   @Get('/user/me')
   async me(@Req() request: Express.Request) {
-    return { ...request.user!, _session_ticket: request.sessionID };
+    return request.user;
   }
 
   @Patch('/change-password')

apps/nestjs-backend/src/features/auth/auth.module.ts

@@ -1,5 +1,4 @@
 import { Module } from '@nestjs/common';
-import { APP_GUARD } from '@nestjs/core';
 import { PassportModule } from '@nestjs/passport';
 import { AccessTokenModule } from '../access-token/access-token.module';
 import { UserModule } from '../user/user.module';
@@ -26,10 +25,6 @@ import { SessionStrategy } from './strategies/session.strategy';
     AuthService,
     LocalStrategy,
     SessionStrategy,
-    {
-      provide: APP_GUARD,
-      useClass: AuthGuard,
-    },
     AuthGuard,
     SessionSerializer,
     SessionStoreService,

apps/nestjs-backend/src/features/auth/permission.module.ts

@@ -1,18 +1,10 @@
 import { Global, Module } from '@nestjs/common';
-import { APP_GUARD } from '@nestjs/core';
 import { PermissionGuard } from './guard/permission.guard';
 import { PermissionService } from './permission.service';
 
 @Global()
 @Module({
-  providers: [
-    PermissionService,
-    PermissionGuard,
-    {
-      provide: APP_GUARD,
-      useClass: PermissionGuard,
-    },
-  ],
+  providers: [PermissionService, PermissionGuard],
   exports: [PermissionService, PermissionGuard],
 })
 export class PermissionModule {}

apps/nestjs-backend/src/features/field/field.service.ts

@@ -25,7 +25,6 @@ import type { IClsStore } from '../../types/cls';
 import { isNotHiddenField } from '../../utils/is-not-hidden-field';
 import { convertNameToValidCharacter } from '../../utils/name-conversion';
 import { BatchService } from '../calculation/batch.service';
-import { FieldPermissionService } from './field-permission.service';
 import type { IFieldInstance } from './model/factory';
 import { createFieldInstanceByVo, rawField2FieldObj } from './model/factory';
 import { dbType2knexFormat } from './util';
@@ -38,7 +37,6 @@ export class FieldService implements IReadonlyAdapterService {
     private readonly batchService: BatchService,
     private readonly prismaService: PrismaService,
     private readonly cls: ClsService<IClsStore>,
-    private readonly fieldPermissionService: FieldPermissionService,
     @InjectDbProvider() private readonly dbProvider: IDbProvider,
     @InjectModel('CUSTOM_KNEX') private readonly knex: Knex
   ) {}
@@ -494,12 +492,7 @@ export class FieldService implements IReadonlyAdapterService {
   }
 
   async getDocIdsByQuery(tableId: string, query: IGetFieldsQuery) {
-    const fieldsQuery = await this.fieldPermissionService.getFieldsQueryWithPermission(
-      tableId,
-      query
-    );
-    const result = await this.getFieldsByQuery(tableId, fieldsQuery);
-
+    const result = await this.getFieldsByQuery(tableId, query);
     return {
       ids: result.map((field) => field.id),
     };

apps/nestjs-backend/src/features/field/open-api/field-open-api.controller.ts

@@ -104,4 +104,19 @@ export class FieldOpenApiController {
   async deleteField(@Param('tableId') tableId: string, @Param('fieldId') fieldId: string) {
     await this.fieldOpenApiService.deleteField(tableId, fieldId);
   }
+
+  @Permissions('field|read')
+  @Get('/socket/snapshot-bulk')
+  async getSnapshotBulk(@Param('tableId') tableId: string, @Query('ids') ids: string[]) {
+    return this.fieldService.getSnapshotBulk(tableId, ids);
+  }
+
+  @Permissions('field|read')
+  @Get('/socket/doc-ids')
+  async getDocIds(
+    @Param('tableId') tableId: string,
+    @Query(new ZodValidationPipe(getFieldsQuerySchema)) query: IGetFieldsQuery
+  ) {
+    return this.fieldService.getDocIdsByQuery(tableId, query);
+  }
 }

apps/nestjs-backend/src/features/record/open-api/record-open-api.controller.ts

@@ -81,4 +81,23 @@ export class RecordOpenApiController {
   ): Promise<void> {
     return await this.recordOpenApiService.deleteRecords(tableId, query.recordIds);
   }
+
+  @Permissions('record|read')
+  @Get('/socket/snapshot-bulk')
+  async getSnapshotBulk(
+    @Param('tableId') tableId: string,
+    @Query('ids') ids: string[],
+    @Query('projection') projection?: { [fieldNameOrId: string]: boolean }
+  ) {
+    return this.recordService.getSnapshotBulk(tableId, ids, projection);
+  }
+
+  @Permissions('record|read')
+  @Get('/socket/doc-ids')
+  async getDocIds(
+    @Param('tableId') tableId: string,
+    @Query(new ZodValidationPipe(getRecordsRoSchema), TqlPipe) query: IGetRecordsRo
+  ) {
+    return this.recordService.getDocIdsByQuery(tableId, query);
+  }
 }