diff --git a/apps/server/src/common/events/event.contants.ts b/apps/server/src/common/events/event.contants.ts index 3a0ecba17..e4c43ae61 100644 --- a/apps/server/src/common/events/event.contants.ts +++ b/apps/server/src/common/events/event.contants.ts @@ -15,6 +15,7 @@ export enum EventName { WORKSPACE_CREATED = 'workspace.created', WORKSPACE_UPDATED = 'workspace.updated', WORKSPACE_DELETED = 'workspace.deleted', + USER_SESSION_STARTED = 'user.session.started', BASE_CREATED = 'base.created', BASE_UPDATED = 'base.updated', diff --git a/apps/server/src/core/page/services/page.service.ts b/apps/server/src/core/page/services/page.service.ts index 387abc5cc..3a2e34afc 100644 --- a/apps/server/src/core/page/services/page.service.ts +++ b/apps/server/src/core/page/services/page.service.ts @@ -498,6 +498,7 @@ export class PageService { await this.aiQueue.add(QueueJob.PAGE_MOVED_TO_SPACE, { pageIds: pageIdsToMove, + spaceId, workspaceId: rootPage.workspaceId, }); } diff --git a/apps/server/src/database/listeners/space.listener.ts b/apps/server/src/database/listeners/space.listener.ts index af6e3a222..3a766b6ef 100644 --- a/apps/server/src/database/listeners/space.listener.ts +++ b/apps/server/src/database/listeners/space.listener.ts @@ -8,6 +8,7 @@ import { EnvironmentService } from '../../integrations/environment/environment.s export class SpaceEvent { spaceId: string; + workspaceId: string; } @Injectable() @@ -22,12 +23,12 @@ export class SpaceListener { @OnEvent(EventName.SPACE_DELETED) async handleSpaceDeleted(event: SpaceEvent) { - const { spaceId } = event; + const { spaceId, workspaceId } = event; if (this.isTypesense()) { await this.searchQueue.add(QueueJob.SPACE_DELETED, { spaceId }); } - await this.aiQueue.add(QueueJob.SPACE_DELETED, { spaceId }); + await this.aiQueue.add(QueueJob.SPACE_DELETED, { spaceId, workspaceId }); } isTypesense(): boolean { diff --git a/apps/server/src/database/repos/space/space.repo.ts b/apps/server/src/database/repos/space/space.repo.ts index 905d2fac6..82fc170bd 100644 --- a/apps/server/src/database/repos/space/space.repo.ts +++ b/apps/server/src/database/repos/space/space.repo.ts @@ -230,6 +230,7 @@ export class SpaceRepo { this.eventEmitter.emit(EventName.SPACE_DELETED, { spaceId, + workspaceId, }); } } diff --git a/apps/server/src/integrations/queue/constants/queue.constants.ts b/apps/server/src/integrations/queue/constants/queue.constants.ts index 546553438..8b7c03a1f 100644 --- a/apps/server/src/integrations/queue/constants/queue.constants.ts +++ b/apps/server/src/integrations/queue/constants/queue.constants.ts @@ -61,6 +61,7 @@ export enum QueueJob { WORKSPACE_DELETED = 'workspace-deleted', WORKSPACE_CREATE_EMBEDDINGS = 'workspace-create-embeddings', WORKSPACE_DELETE_EMBEDDINGS = 'workspace-delete-embeddings', + WORKSPACE_RESET_EMBEDDINGS = 'workspace-reset-embeddings', GENERATE_PAGE_EMBEDDINGS = 'generate-page-embeddings', DELETE_PAGE_EMBEDDINGS = 'delete-page-embeddings',