fix: get base of space id

Author: nichenqin

packages/command-handlers/src/handlers/create-base.command-handler.ts

@@ -4,9 +4,11 @@ import {
   BaseNameShouldBeUnique,
   injectBaseRepository,
   WithBaseName,
+  WithBaseSpaceId,
   type IBaseRepository,
 } from "@undb/base"
 import { CreateBaseCommand } from "@undb/commands"
+import { mustGetCurrentSpaceId } from "@undb/context/server"
 import { commandHandler } from "@undb/cqrs"
 import { singleton } from "@undb/di"
 import { applyRules, type ICommandHandler } from "@undb/domain"
@@ -25,7 +27,7 @@ export class CreateBaseCommandHandler implements ICommandHandler<CreateBaseComma
   async execute(command: CreateBaseCommand): Promise<any> {
     this.logger.debug(command)
 
-    const nameSpec = new WithBaseName(BaseName.from(command.name))
+    const nameSpec = new WithBaseName(BaseName.from(command.name)).and(new WithBaseSpaceId(mustGetCurrentSpaceId()))
     const exists = (await this.repository.findOne(nameSpec)).into(null)
 
     applyRules(new BaseNameShouldBeUnique(!!exists))

packages/command-handlers/src/handlers/update-base.command-handler.ts

@@ -1,5 +1,13 @@
-import { BaseName, BaseNameShouldBeUnique, injectBaseRepository, WithBaseName, type IBaseRepository } from "@undb/base"
+import {
+  BaseName,
+  BaseNameShouldBeUnique,
+  injectBaseRepository,
+  WithBaseName,
+  WithBaseSpaceId,
+  type IBaseRepository,
+} from "@undb/base"
 import { UpdateBaseCommand } from "@undb/commands"
+import { mustGetCurrentSpaceId } from "@undb/context/server"
 import { commandHandler } from "@undb/cqrs"
 import { singleton } from "@undb/di"
 import { applyRules, type ICommandHandler } from "@undb/domain"
@@ -21,7 +29,7 @@ export class UpdateBaseCommandHandler implements ICommandHandler<UpdateBaseComma
     const base = (await this.repository.findOneById(command.id)).unwrap()
 
     if (command.name) {
-      const nameSpec = new WithBaseName(BaseName.from(command.name))
+      const nameSpec = new WithBaseName(BaseName.from(command.name)).and(new WithBaseSpaceId(mustGetCurrentSpaceId()))
       const exists = (await this.repository.findOne(nameSpec)).into(null)
 
       applyRules(new BaseNameShouldBeUnique(!!exists))

packages/persistence/src/base/base.filter-visitor.ts

@@ -1,16 +1,13 @@
 import type { Base, IBaseSpecVisitor, WithBaseId, WithBaseName, WithBaseQ, WithBaseSpaceId } from "@undb/base"
 import type { WithBaseOption } from "@undb/base/src/specifications/base-option.specification"
 import type { DuplicatedBaseSpecification } from "@undb/base/src/specifications/base.specification"
-import { mustGetCurrentSpaceId } from "@undb/context/server"
 import type { ExpressionBuilder } from "kysely"
 import { AbstractQBVisitor } from "../abstract-qb.visitor"
 import type { Database } from "../db"
 
 export class BaseFilterVisitor extends AbstractQBVisitor<Base> implements IBaseSpecVisitor {
   constructor(protected readonly eb: ExpressionBuilder<Database, "undb_base">) {
     super(eb)
-    const spaceId = mustGetCurrentSpaceId()
-    this.addCond(this.eb.eb("space_id", "=", spaceId))
   }
 
   withOption(v: WithBaseOption): void {

packages/persistence/src/base/base.repository.ts

@@ -1,12 +1,13 @@
 import {
   WithBaseId,
+  WithBaseSpaceId,
   injectBaseOutboxService,
   type Base,
   type IBaseOutboxService,
   type IBaseRepository,
   type IBaseSpecification,
 } from "@undb/base"
-import { executionContext } from "@undb/context/server"
+import { executionContext, mustGetCurrentSpaceId } from "@undb/context/server"
 import { inject, singleton } from "@undb/di"
 import { None, Some, type Option } from "@undb/domain"
 import { getCurrentTransaction } from "../ctx"
@@ -55,7 +56,7 @@ export class BaseRepository implements IBaseRepository {
     return base ? Some(this.mapper.toDo(base)) : None
   }
   async findOneById(id: string): Promise<Option<Base>> {
-    const spec = WithBaseId.fromString(id)
+    const spec = WithBaseId.fromString(id).and(new WithBaseSpaceId(mustGetCurrentSpaceId()))
 
     const base = await (getCurrentTransaction() ?? this.qb)
       .selectFrom("undb_base")

packages/query-handlers/src/handlers/get-bases.query-handler.ts

@@ -1,7 +1,8 @@
-import { injectBaseQueryRepository, type IBaseDTO, type IBaseQueryRepository } from "@undb/base"
+import { injectBaseQueryRepository, WithBaseSpaceId, type IBaseDTO, type IBaseQueryRepository } from "@undb/base"
+import { mustGetCurrentSpaceId } from "@undb/context/server"
 import { queryHandler } from "@undb/cqrs"
 import { singleton } from "@undb/di"
-import { None, type IQueryHandler } from "@undb/domain"
+import { Some, type IQueryHandler } from "@undb/domain"
 import { GetBasesQuery } from "@undb/queries"
 
 @queryHandler(GetBasesQuery)
@@ -13,6 +14,7 @@ export class GetBasesQueryHandler implements IQueryHandler<GetBasesQuery, any> {
   ) {}
 
   async execute(query: GetBasesQuery): Promise<IBaseDTO[]> {
-    return this.repo.find(None)
+    const spec = new WithBaseSpaceId(mustGetCurrentSpaceId())
+    return this.repo.find(Some(spec))
   }
 }