@@ -204,9 +218,14 @@ export function SpaceSidebar() {
interface SpaceMenuProps {
spaceId: string;
+ canManagePages: boolean;
onSpaceSettings: () => void;
}
-function SpaceMenu({ spaceId, onSpaceSettings }: SpaceMenuProps) {
+function SpaceMenu({
+ spaceId,
+ canManagePages,
+ onSpaceSettings,
+}: SpaceMenuProps) {
const { t } = useTranslation();
const { spaceSlug } = useParams();
const [importOpened, { open: openImportModal, close: closeImportModal }] =
@@ -214,15 +233,24 @@ function SpaceMenu({ spaceId, onSpaceSettings }: SpaceMenuProps) {
const [exportOpened, { open: openExportModal, close: closeExportModal }] =
useDisclosure(false);
+ const { data: watchStatus } = useSpaceWatchStatusQuery(spaceId);
+ const watchMutation = useWatchSpaceMutation();
+ const unwatchMutation = useUnwatchSpaceMutation();
+ const isWatching = watchStatus?.watching ?? false;
+
+ const handleToggleWatch = () => {
+ if (isWatching) {
+ unwatchMutation.mutate(spaceId);
+ } else {
+ watchMutation.mutate(spaceId);
+ }
+ };
+
return (
<>
-
+ {canManagePages && (
+ <>
+
-
+
+
+ )}
);
}
diff --git a/apps/client/src/features/space/queries/space-watcher-query.ts b/apps/client/src/features/space/queries/space-watcher-query.ts
new file mode 100644
index 00000000..ae4d5696
--- /dev/null
+++ b/apps/client/src/features/space/queries/space-watcher-query.ts
@@ -0,0 +1,49 @@
+import { useMutation, useQuery, useQueryClient } from "@tanstack/react-query";
+import {
+ watchSpace,
+ unwatchSpace,
+ getSpaceWatchStatus,
+} from "@/features/space/services/space-watcher-service";
+import { notifications } from "@mantine/notifications";
+import { useTranslation } from "react-i18next";
+
+const SPACE_WATCHER_KEY = "space-watcher";
+
+export function useSpaceWatchStatusQuery(spaceId: string) {
+ return useQuery({
+ queryKey: [SPACE_WATCHER_KEY, spaceId],
+ queryFn: () => getSpaceWatchStatus(spaceId),
+ enabled: !!spaceId,
+ staleTime: 60_000,
+ });
+}
+
+export function useWatchSpaceMutation() {
+ const queryClient = useQueryClient();
+ const { t } = useTranslation();
+ return useMutation({
+ mutationFn: (spaceId: string) => watchSpace(spaceId),
+ onSuccess: (_data, spaceId) => {
+ queryClient.setQueryData([SPACE_WATCHER_KEY, spaceId], {
+ watching: true,
+ });
+ notifications.show({ message: t("You are now watching this space") });
+ },
+ });
+}
+
+export function useUnwatchSpaceMutation() {
+ const queryClient = useQueryClient();
+ const { t } = useTranslation();
+ return useMutation({
+ mutationFn: (spaceId: string) => unwatchSpace(spaceId),
+ onSuccess: (_data, spaceId) => {
+ queryClient.setQueryData([SPACE_WATCHER_KEY, spaceId], {
+ watching: false,
+ });
+ notifications.show({
+ message: t("You are no longer watching this space"),
+ });
+ },
+ });
+}
diff --git a/apps/client/src/features/space/services/space-watcher-service.ts b/apps/client/src/features/space/services/space-watcher-service.ts
new file mode 100644
index 00000000..bcbeccc9
--- /dev/null
+++ b/apps/client/src/features/space/services/space-watcher-service.ts
@@ -0,0 +1,28 @@
+import api from "@/lib/api-client";
+
+export async function watchSpace(
+ spaceId: string,
+): Promise<{ watching: boolean }> {
+ const req = await api.post<{ watching: boolean }>("/spaces/watch", {
+ spaceId,
+ });
+ return req.data;
+}
+
+export async function unwatchSpace(
+ spaceId: string,
+): Promise<{ watching: boolean }> {
+ const req = await api.post<{ watching: boolean }>("/spaces/unwatch", {
+ spaceId,
+ });
+ return req.data;
+}
+
+export async function getSpaceWatchStatus(
+ spaceId: string,
+): Promise<{ watching: boolean }> {
+ const req = await api.post<{ watching: boolean }>("/spaces/watch-status", {
+ spaceId,
+ });
+ return req.data;
+}
diff --git a/apps/server/src/core/notification/services/page.notification.ts b/apps/server/src/core/notification/services/page.notification.ts
index 9e5c75dd..77ab967a 100644
--- a/apps/server/src/core/notification/services/page.notification.ts
+++ b/apps/server/src/core/notification/services/page.notification.ts
@@ -179,7 +179,11 @@ export class PageNotificationService {
async processPageUpdate(data: IPageUpdateNotificationJob, appUrl: string) {
const { pageId, spaceId, workspaceId, actorIds } = data;
- const watcherIds = await this.watcherRepo.getPageWatcherIds(pageId);
+ const watcherIds = await this.watcherRepo.getPageUpdateRecipientIds(
+ pageId,
+ spaceId,
+ );
+
if (watcherIds.length === 0) return;
const actorSet = new Set(actorIds);
@@ -219,7 +223,7 @@ export class PageNotificationService {
const context = await this.getPageContext(actorId, pageId, spaceId, appUrl);
if (!context) return;
- const { actor, pageTitle, basePageUrl } = context;
+ const { actor, pageTitle, basePageUrl, spaceName } = context;
for (const userId of recipientIds) {
const notification = await this.notificationService.create({
@@ -243,6 +247,7 @@ export class PageNotificationService {
actorName: actor.name,
pageTitle,
pageUrl: basePageUrl,
+ spaceName,
}),
NotificationType.PAGE_UPDATED,
);
@@ -421,7 +426,7 @@ export class PageNotificationService {
.executeTakeFirst(),
this.db
.selectFrom('spaces')
- .select(['id', 'slug'])
+ .select(['id', 'slug', 'name'])
.where('id', '=', spaceId)
.executeTakeFirst(),
]);
@@ -432,6 +437,11 @@ export class PageNotificationService {
const basePageUrl = `${appUrl}/s/${space.slug}/p/${page.slugId}`;
- return { actor, pageTitle: getPageTitle(page.title), basePageUrl };
+ return {
+ actor,
+ pageTitle: getPageTitle(page.title),
+ basePageUrl,
+ spaceName: space.name,
+ };
}
}
diff --git a/apps/server/src/core/watcher/dto/space-watcher.dto.ts b/apps/server/src/core/watcher/dto/space-watcher.dto.ts
new file mode 100644
index 00000000..1df06010
--- /dev/null
+++ b/apps/server/src/core/watcher/dto/space-watcher.dto.ts
@@ -0,0 +1,7 @@
+import { IsString, IsNotEmpty } from 'class-validator';
+
+export class SpaceWatcherDto {
+ @IsString()
+ @IsNotEmpty()
+ spaceId: string;
+}
diff --git a/apps/server/src/core/watcher/space-watcher.controller.ts b/apps/server/src/core/watcher/space-watcher.controller.ts
new file mode 100644
index 00000000..455c7d0d
--- /dev/null
+++ b/apps/server/src/core/watcher/space-watcher.controller.ts
@@ -0,0 +1,95 @@
+import {
+ Body,
+ Controller,
+ ForbiddenException,
+ HttpCode,
+ HttpStatus,
+ NotFoundException,
+ Post,
+ UseGuards,
+} from '@nestjs/common';
+import { WatcherService } from './watcher.service';
+import { AuthUser } from '../../common/decorators/auth-user.decorator';
+import { AuthWorkspace } from '../../common/decorators/auth-workspace.decorator';
+import { JwtAuthGuard } from '../../common/guards/jwt-auth.guard';
+import { User, Workspace } from '@docmost/db/types/entity.types';
+import { SpaceWatcherDto } from './dto/space-watcher.dto';
+import { SpaceRepo } from '@docmost/db/repos/space/space.repo';
+import SpaceAbilityFactory from '../casl/abilities/space-ability.factory';
+import {
+ SpaceCaslAction,
+ SpaceCaslSubject,
+} from '../casl/interfaces/space-ability.type';
+
+@UseGuards(JwtAuthGuard)
+@Controller('spaces')
+export class SpaceWatcherController {
+ constructor(
+ private readonly watcherService: WatcherService,
+ private readonly spaceRepo: SpaceRepo,
+ private readonly spaceAbility: SpaceAbilityFactory,
+ ) {}
+
+ private async loadSpaceAndAuthorize(
+ spaceId: string,
+ user: User,
+ workspace: Workspace,
+ ) {
+ const space = await this.spaceRepo.findById(spaceId, workspace.id);
+ if (!space) {
+ throw new NotFoundException('Space not found');
+ }
+
+ const ability = await this.spaceAbility.createForUser(user, space.id);
+ if (ability.cannot(SpaceCaslAction.Read, SpaceCaslSubject.Settings)) {
+ throw new ForbiddenException();
+ }
+
+ return space;
+ }
+
+ @HttpCode(HttpStatus.OK)
+ @Post('watch')
+ async watchSpace(
+ @Body() dto: SpaceWatcherDto,
+ @AuthUser() user: User,
+ @AuthWorkspace() workspace: Workspace,
+ ) {
+ const space = await this.loadSpaceAndAuthorize(dto.spaceId, user, workspace);
+
+ await this.watcherService.watchSpace(user.id, space.id, workspace.id);
+
+ return { watching: true };
+ }
+
+ @HttpCode(HttpStatus.OK)
+ @Post('unwatch')
+ async unwatchSpace(
+ @Body() dto: SpaceWatcherDto,
+ @AuthUser() user: User,
+ @AuthWorkspace() workspace: Workspace,
+ ) {
+ const space = await this.loadSpaceAndAuthorize(dto.spaceId, user, workspace);
+
+ await this.watcherService.unwatchSpace(user.id, space.id);
+
+ return { watching: false };
+ }
+
+ @HttpCode(HttpStatus.OK)
+ @Post('watch-status')
+ async getWatchStatus(
+ @Body() dto: SpaceWatcherDto,
+ @AuthUser() user: User,
+ @AuthWorkspace() workspace: Workspace,
+ ) {
+ const space = await this.loadSpaceAndAuthorize(dto.spaceId, user, workspace);
+
+ const watching = await this.watcherService.isWatchingSpace(
+ user.id,
+ space.id,
+ );
+
+ return { watching };
+ }
+}
diff --git a/apps/server/src/core/watcher/watcher.controller.ts b/apps/server/src/core/watcher/watcher.controller.ts
index cd10fa37..24c317f6 100644
--- a/apps/server/src/core/watcher/watcher.controller.ts
+++ b/apps/server/src/core/watcher/watcher.controller.ts
@@ -59,7 +59,12 @@ export class WatcherController {
await this.pageAccessService.validateCanView(page, user);
- await this.watcherService.unwatchPage(user.id, page.id);
+ await this.watcherService.unwatchPage(
+ user.id,
+ page.id,
+ page.spaceId,
+ page.workspaceId,
+ );
return { watching: false };
}
diff --git a/apps/server/src/core/watcher/watcher.module.ts b/apps/server/src/core/watcher/watcher.module.ts
index 76267b5a..357b8352 100644
--- a/apps/server/src/core/watcher/watcher.module.ts
+++ b/apps/server/src/core/watcher/watcher.module.ts
@@ -1,11 +1,12 @@
import { Module } from '@nestjs/common';
import { WatcherService } from './watcher.service';
import { WatcherController } from './watcher.controller';
+import { SpaceWatcherController } from './space-watcher.controller';
import { PageAccessModule } from '../page/page-access/page-access.module';
@Module({
imports: [PageAccessModule],
- controllers: [WatcherController],
+ controllers: [WatcherController, SpaceWatcherController],
providers: [WatcherService],
exports: [WatcherService],
})
diff --git a/apps/server/src/core/watcher/watcher.service.ts b/apps/server/src/core/watcher/watcher.service.ts
index 384a0787..3c5fe621 100644
--- a/apps/server/src/core/watcher/watcher.service.ts
+++ b/apps/server/src/core/watcher/watcher.service.ts
@@ -50,14 +50,44 @@ export class WatcherService {
return this.watcherRepo.insertMany(watchers, trx);
}
- async unwatchPage(userId: string, pageId: string) {
- return this.watcherRepo.mute(userId, pageId);
+ async unwatchPage(
+ userId: string,
+ pageId: string,
+ spaceId: string,
+ workspaceId: string,
+ ) {
+ return this.watcherRepo.mute(userId, pageId, spaceId, workspaceId);
}
async isWatchingPage(userId: string, pageId: string): Promise
{
return this.watcherRepo.isWatching(userId, pageId);
}
+ async watchSpace(
+ userId: string,
+ spaceId: string,
+ workspaceId: string,
+ trx?: KyselyTransaction,
+ ) {
+ const watcher: InsertableWatcher = {
+ userId,
+ pageId: null,
+ spaceId,
+ workspaceId,
+ type: WatcherType.SPACE,
+ addedById: userId,
+ };
+ return this.watcherRepo.upsertSpace(watcher, trx);
+ }
+
+ async unwatchSpace(userId: string, spaceId: string) {
+ return this.watcherRepo.deleteSpaceWatch(userId, spaceId);
+ }
+
+ async isWatchingSpace(userId: string, spaceId: string): Promise {
+ return this.watcherRepo.isWatchingSpace(userId, spaceId);
+ }
+
async getPageWatchers(pageId: string, pagination: PaginationOptions) {
return this.watcherRepo.findPageWatchers(pageId, pagination);
}
diff --git a/apps/server/src/database/repos/watcher/watcher.repo.ts b/apps/server/src/database/repos/watcher/watcher.repo.ts
index 9739b4de..f1506ff9 100644
--- a/apps/server/src/database/repos/watcher/watcher.repo.ts
+++ b/apps/server/src/database/repos/watcher/watcher.repo.ts
@@ -20,18 +20,6 @@ export type WatcherType = (typeof WatcherType)[keyof typeof WatcherType];
export class WatcherRepo {
constructor(@InjectKysely() private readonly db: KyselyDB) {}
- async findByUserAndPage(
- userId: string,
- pageId: string,
- ): Promise {
- return this.db
- .selectFrom('watchers')
- .selectAll()
- .where('userId', '=', userId)
- .where('pageId', '=', pageId)
- .executeTakeFirst();
- }
-
async findPageWatchers(pageId: string, pagination: PaginationOptions) {
const query = this.db
.selectFrom('watchers')
@@ -66,6 +54,53 @@ export class WatcherRepo {
return watchers.map((w) => w.userId);
}
+ /**
+ * Recipients for a `page.updated` notification, combining:
+ * - Active page watchers on this page, AND
+ * - Active space watchers on this space, EXCLUDING any user who has a
+ * muted page watcher row for this page (per-page mute always wins).
+ *
+ * Deduplicated at the SQL level — a user watching both the page and the
+ * containing space appears once.
+ */
+ async getPageUpdateRecipientIds(
+ pageId: string,
+ spaceId: string,
+ trx?: KyselyTransaction,
+ ): Promise {
+ const db = dbOrTx(this.db, trx);
+
+ const pageWatchers = db
+ .selectFrom('watchers')
+ .select('userId')
+ .where('pageId', '=', pageId)
+ .where('type', '=', WatcherType.PAGE)
+ .where('mutedAt', 'is', null);
+
+ const spaceWatchers = db
+ .selectFrom('watchers as sw')
+ .select('sw.userId')
+ .where('sw.spaceId', '=', spaceId)
+ .where('sw.pageId', 'is', null)
+ .where('sw.type', '=', WatcherType.SPACE)
+ .where((eb) =>
+ eb.not(
+ eb.exists(
+ eb
+ .selectFrom('watchers as pw')
+ .select('pw.id')
+ .whereRef('pw.userId', '=', 'sw.userId')
+ .where('pw.pageId', '=', pageId)
+ .where('pw.type', '=', WatcherType.PAGE)
+ .where('pw.mutedAt', 'is not', null),
+ ),
+ ),
+ );
+
+ const rows = await pageWatchers.union(spaceWatchers).execute();
+ return [...new Set(rows.map((r) => r.userId))];
+ }
+
async insert(
watcher: InsertableWatcher,
trx?: KyselyTransaction,
@@ -110,20 +145,81 @@ export class WatcherRepo {
.executeTakeFirst();
}
+ async upsertSpace(
+ watcher: InsertableWatcher,
+ trx?: KyselyTransaction,
+ ): Promise {
+ const db = dbOrTx(this.db, trx);
+ return db
+ .insertInto('watchers')
+ .values(watcher)
+ .onConflict((oc) =>
+ oc
+ .columns(['userId', 'spaceId'])
+ .where('pageId', 'is', null)
+ .doNothing(),
+ )
+ .returningAll()
+ .executeTakeFirst();
+ }
+
async mute(
userId: string,
pageId: string,
+ spaceId: string,
+ workspaceId: string,
+ trx?: KyselyTransaction,
+ ): Promise {
+ const db = dbOrTx(this.db, trx);
+ const mutedAt = new Date();
+ await db
+ .insertInto('watchers')
+ .values({
+ userId,
+ pageId,
+ spaceId,
+ workspaceId,
+ type: WatcherType.PAGE,
+ addedById: userId,
+ mutedAt,
+ })
+ .onConflict((oc) =>
+ oc
+ .columns(['userId', 'pageId'])
+ .where('pageId', 'is not', null)
+ .doUpdateSet({ mutedAt }),
+ )
+ .execute();
+ }
+
+ async deleteSpaceWatch(
+ userId: string,
+ spaceId: string,
trx?: KyselyTransaction,
): Promise {
const db = dbOrTx(this.db, trx);
await db
- .updateTable('watchers')
- .set({ mutedAt: new Date() })
+ .deleteFrom('watchers')
.where('userId', '=', userId)
- .where('pageId', '=', pageId)
+ .where('spaceId', '=', spaceId)
+ .where('pageId', 'is', null)
+ .where('type', '=', WatcherType.SPACE)
.execute();
}
+ async isWatchingSpace(userId: string, spaceId: string): Promise {
+ const watcher = await this.db
+ .selectFrom('watchers')
+ .select('id')
+ .where('userId', '=', userId)
+ .where('spaceId', '=', spaceId)
+ .where('pageId', 'is', null)
+ .where('type', '=', WatcherType.SPACE)
+ .executeTakeFirst();
+
+ return !!watcher;
+ }
+
async isWatching(userId: string, pageId: string): Promise {
const watcher = await this.db
.selectFrom('watchers')
@@ -164,14 +260,14 @@ export class WatcherRepo {
.where('spaceId', '=', spaceId)
.where('userId', 'is not', null)
.union(
- this.db
+ db
.selectFrom('spaceMembers')
.innerJoin('groupUsers', 'groupUsers.groupId', 'spaceMembers.groupId')
.select('groupUsers.userId')
.where('spaceMembers.spaceId', '=', spaceId),
);
- await this.db
+ await db
.deleteFrom('watchers')
.where('userId', 'in', userIds)
.where('spaceId', '=', spaceId)
diff --git a/apps/server/src/integrations/transactional/emails/page-update-email.tsx b/apps/server/src/integrations/transactional/emails/page-update-email.tsx
index 188d8a34..c4c85769 100644
--- a/apps/server/src/integrations/transactional/emails/page-update-email.tsx
+++ b/apps/server/src/integrations/transactional/emails/page-update-email.tsx
@@ -8,6 +8,7 @@ interface Props {
actorName: string;
pageTitle: string;
pageUrl: string;
+ spaceName: string;
}
export const PageUpdateEmail = ({
@@ -15,6 +16,7 @@ export const PageUpdateEmail = ({
actorName,
pageTitle,
pageUrl,
+ spaceName,
}: Props) => {
return (
@@ -24,8 +26,8 @@ export const PageUpdateEmail = ({
{actorName} updated{' '}
{pageTitle}
-
- .
+ {' '}
+ in {spaceName}.
View page
From 57efb91bd3ad626bcbc360f344be796018c10572 Mon Sep 17 00:00:00 2001
From: Philip Okugbe <16838612+Philipinho@users.noreply.github.com>
Date: Fri, 10 Apr 2026 19:23:47 +0100
Subject: [PATCH 60/60] feat(ee): ai chat (#2098)
* feat: ai chat
* feat: ai chat
* sync
* cleanup
* view space button
---
.../public/locales/en-US/translation.json | 30 +-
apps/client/src/App.tsx | 3 +
apps/client/src/components/common/copy.tsx | 7 +-
.../layouts/global/app-header.module.css | 16 +
.../components/layouts/global/app-header.tsx | 94 +++-
.../src/components/layouts/global/aside.tsx | 17 +-
.../layouts/global/global-app-shell.tsx | 5 +-
.../components/ui/card-carousel.module.css | 68 +++
.../src/components/ui/card-carousel.tsx | 77 ++++
.../ee/ai-chat/components/ai-chat-layout.tsx | 106 +++++
.../components/ai-chat-sidebar-item.tsx | 166 +++++++
.../ee/ai-chat/components/ai-chat-sidebar.tsx | 224 ++++++++++
.../ai-chat/components/aside-chat-history.tsx | 67 +++
.../ai-chat/components/aside-chat-panel.tsx | 258 +++++++++++
.../ai-chat/components/chat-empty-state.tsx | 91 ++++
.../src/ee/ai-chat/components/chat-input.tsx | 409 ++++++++++++++++++
.../ai-chat/components/chat-message-list.tsx | 174 ++++++++
.../ee/ai-chat/components/chat-message.tsx | 139 ++++++
.../ee/ai-chat/components/chat-tool-group.tsx | 56 +++
.../ai-chat/components/chat-tool-result.tsx | 49 +++
.../ee/ai-chat/components/enable-ai-chat.tsx | 67 +++
.../src/ee/ai-chat/hooks/use-chat-stream.ts | 227 ++++++++++
apps/client/src/ee/ai-chat/pages/ai-chat.tsx | 39 ++
.../src/ee/ai-chat/queries/ai-chat-query.ts | 61 +++
.../ee/ai-chat/services/ai-chat-service.ts | 144 ++++++
.../src/ee/ai-chat/styles/ai-chat.module.css | 169 ++++++++
.../styles/aside-chat-panel.module.css | 139 ++++++
.../ee/ai-chat/styles/chat-input.module.css | 242 +++++++++++
.../ee/ai-chat/styles/chat-message.module.css | 286 ++++++++++++
.../ee/ai-chat/styles/chat-sidebar.module.css | 138 ++++++
.../src/ee/ai-chat/types/ai-chat.types.ts | 49 +++
apps/client/src/ee/ai/pages/ai-settings.tsx | 2 +
.../components/mention/mention-list.tsx | 2 +-
.../components/mention/mention-suggestion.ts | 4 +-
.../home/components/home-ai-prompt.module.css | 28 ++
.../home/components/home-ai-prompt.tsx | 60 +++
.../components/search-control.module.css | 2 +
.../components/space-carousel.module.css | 22 +
.../space/components/space-carousel.tsx | 77 ++++
.../workspace/types/workspace.types.ts | 1 +
apps/client/src/pages/dashboard/home.tsx | 9 +-
apps/server/package.json | 2 +
.../core/attachment/attachment.constants.ts | 1 +
.../core/attachment/attachment.controller.ts | 30 +-
.../src/core/attachment/attachment.utils.ts | 2 +
.../processors/attachment.processor.ts | 5 +
.../attachment/services/attachment.service.ts | 25 ++
apps/server/src/core/auth/auth.controller.ts | 11 +-
.../workspace/dto/update-workspace.dto.ts | 4 +
.../workspace/services/workspace.service.ts | 17 +-
.../migrations/20260409T132415-ai-chat.ts | 118 +++++
.../repos/attachment/attachment.repo.ts | 51 +++
apps/server/src/database/types/db.d.ts | 28 ++
.../server/src/database/types/entity.types.ts | 17 +
apps/server/src/ee | 2 +-
.../environment/environment.service.ts | 7 +
.../src/integrations/export/export.service.ts | 2 +-
.../queue/constants/queue.constants.ts | 1 +
.../integrations/throttle/throttle.module.ts | 6 +-
.../integrations/throttle/throttler-names.ts | 2 +
.../throttle/user-throttler.guard.ts | 13 +
.../src/lib/markdown/utils/marked.utils.ts | 7 +-
pnpm-lock.yaml | 22 +
63 files changed, 4149 insertions(+), 48 deletions(-)
create mode 100644 apps/client/src/components/ui/card-carousel.module.css
create mode 100644 apps/client/src/components/ui/card-carousel.tsx
create mode 100644 apps/client/src/ee/ai-chat/components/ai-chat-layout.tsx
create mode 100644 apps/client/src/ee/ai-chat/components/ai-chat-sidebar-item.tsx
create mode 100644 apps/client/src/ee/ai-chat/components/ai-chat-sidebar.tsx
create mode 100644 apps/client/src/ee/ai-chat/components/aside-chat-history.tsx
create mode 100644 apps/client/src/ee/ai-chat/components/aside-chat-panel.tsx
create mode 100644 apps/client/src/ee/ai-chat/components/chat-empty-state.tsx
create mode 100644 apps/client/src/ee/ai-chat/components/chat-input.tsx
create mode 100644 apps/client/src/ee/ai-chat/components/chat-message-list.tsx
create mode 100644 apps/client/src/ee/ai-chat/components/chat-message.tsx
create mode 100644 apps/client/src/ee/ai-chat/components/chat-tool-group.tsx
create mode 100644 apps/client/src/ee/ai-chat/components/chat-tool-result.tsx
create mode 100644 apps/client/src/ee/ai-chat/components/enable-ai-chat.tsx
create mode 100644 apps/client/src/ee/ai-chat/hooks/use-chat-stream.ts
create mode 100644 apps/client/src/ee/ai-chat/pages/ai-chat.tsx
create mode 100644 apps/client/src/ee/ai-chat/queries/ai-chat-query.ts
create mode 100644 apps/client/src/ee/ai-chat/services/ai-chat-service.ts
create mode 100644 apps/client/src/ee/ai-chat/styles/ai-chat.module.css
create mode 100644 apps/client/src/ee/ai-chat/styles/aside-chat-panel.module.css
create mode 100644 apps/client/src/ee/ai-chat/styles/chat-input.module.css
create mode 100644 apps/client/src/ee/ai-chat/styles/chat-message.module.css
create mode 100644 apps/client/src/ee/ai-chat/styles/chat-sidebar.module.css
create mode 100644 apps/client/src/ee/ai-chat/types/ai-chat.types.ts
create mode 100644 apps/client/src/features/home/components/home-ai-prompt.module.css
create mode 100644 apps/client/src/features/home/components/home-ai-prompt.tsx
create mode 100644 apps/client/src/features/space/components/space-carousel.module.css
create mode 100644 apps/client/src/features/space/components/space-carousel.tsx
create mode 100644 apps/server/src/database/migrations/20260409T132415-ai-chat.ts
create mode 100644 apps/server/src/integrations/throttle/throttler-names.ts
create mode 100644 apps/server/src/integrations/throttle/user-throttler.guard.ts
diff --git a/apps/client/public/locales/en-US/translation.json b/apps/client/public/locales/en-US/translation.json
index 5db91598..b83b3548 100644
--- a/apps/client/public/locales/en-US/translation.json
+++ b/apps/client/public/locales/en-US/translation.json
@@ -627,6 +627,7 @@
"AI Answer": "AI Answer",
"Ask AI": "Ask AI",
"AI is thinking...": "AI is thinking...",
+ "Thinking": "Thinking",
"Ask a question...": "Ask a question...",
"AI Answers": "AI Answers",
"AI-powered search (AI Answers)": "AI-powered search (AI Answers)",
@@ -755,5 +756,32 @@
"Publish": "Publish",
"Security": "Security",
"Enforce SSO": "Enforce SSO",
- "Once enforced, members will not be able to login with email and password.": "Once enforced, members will not be able to login with email and password."
+ "Once enforced, members will not be able to login with email and password.": "Once enforced, members will not be able to login with email and password.",
+ "AI-generated content may not be accurate.": "AI-generated content may not be accurate.",
+ "AI Chat": "AI Chat",
+ "Analyze for insights": "Analyze for insights",
+ "Ask anything...": "Ask anything...",
+ "Chat history": "Chat history",
+ "Chat name": "Chat name",
+ "Close": "Close",
+ "Docmost AI": "Docmost AI",
+ "Failed to load chat. An error occurred.": "Failed to load chat. An error occurred.",
+ "Failed to render this message.": "Failed to render this message.",
+ "How can I help you today?": "How can I help you today?",
+ "New chat": "New chat",
+ "No chat history": "No chat history",
+ "No chats found": "No chats found",
+ "No conversations yet": "No conversations yet",
+ "Open full page": "Open full page",
+ "Previous 7 days": "Previous 7 days",
+ "Previous 30 days": "Previous 30 days",
+ "Search chats...": "Search chats...",
+ "Start a new chat to see it here.": "Start a new chat to see it here.",
+ "Summarize this page": "Summarize this page",
+ "Toggle AI Chat": "Toggle AI Chat",
+ "Translate this page": "Translate this page",
+ "Try a different search term.": "Try a different search term.",
+ "Try again": "Try again",
+ "Untitled chat": "Untitled chat",
+ "What can I help you with?": "What can I help you with?"
}
diff --git a/apps/client/src/App.tsx b/apps/client/src/App.tsx
index b99e63b3..382660c7 100644
--- a/apps/client/src/App.tsx
+++ b/apps/client/src/App.tsx
@@ -38,6 +38,7 @@ import UserApiKeys from "@/ee/api-key/pages/user-api-keys";
import WorkspaceApiKeys from "@/ee/api-key/pages/workspace-api-keys";
import AiSettings from "@/ee/ai/pages/ai-settings.tsx";
import AuditLogs from "@/ee/audit/pages/audit-logs.tsx";
+import AiChat from "@/ee/ai-chat/pages/ai-chat.tsx";
import VerifyEmail from "@/ee/pages/verify-email.tsx";
export default function App() {
@@ -81,6 +82,8 @@ export default function App() {
}>
} />
+ } />
+ } />
} />
} />
} />
diff --git a/apps/client/src/components/common/copy.tsx b/apps/client/src/components/common/copy.tsx
index 81a70771..745fc4ba 100644
--- a/apps/client/src/components/common/copy.tsx
+++ b/apps/client/src/components/common/copy.tsx
@@ -1,4 +1,4 @@
-import { ActionIcon, Tooltip } from "@mantine/core";
+import { ActionIcon, MantineColor, MantineSize, Tooltip } from "@mantine/core";
import { CopyButton } from "@/components/common/copy-button";
import { IconCheck, IconCopy } from "@tabler/icons-react";
import React from "react";
@@ -6,8 +6,10 @@ import { useTranslation } from "react-i18next";
interface CopyProps {
text: string;
+ size?: MantineSize;
+ color?: MantineColor;
}
-export default function CopyTextButton({ text }: CopyProps) {
+export default function CopyTextButton({ text, size }: CopyProps) {
const { t } = useTranslation();
return (
@@ -22,6 +24,7 @@ export default function CopyTextButton({ text }: CopyProps) {
color={copied ? "teal" : "gray"}
variant="subtle"
onClick={copy}
+ size={size}
>
{copied ? : }
diff --git a/apps/client/src/components/layouts/global/app-header.module.css b/apps/client/src/components/layouts/global/app-header.module.css
index b2298f13..a70b57e7 100644
--- a/apps/client/src/components/layouts/global/app-header.module.css
+++ b/apps/client/src/components/layouts/global/app-header.module.css
@@ -7,6 +7,19 @@
padding-right: var(--mantine-spacing-md);
}
+.brand {
+ display: flex;
+ align-items: center;
+ text-decoration: none;
+ color: inherit;
+ cursor: pointer;
+}
+
+.brandIcon {
+ display: flex;
+ align-items: center;
+}
+
.link {
display: block;
line-height: 1;
@@ -16,6 +29,9 @@
color: light-dark(var(--mantine-color-gray-7), var(--mantine-color-dark-0));
font-size: var(--mantine-font-size-sm);
font-weight: 500;
+ user-select: none;
+ white-space: nowrap;
+ flex-shrink: 0;
@mixin hover {
background-color: light-dark(var(--mantine-color-gray-0), var(--mantine-color-dark-6));
diff --git a/apps/client/src/components/layouts/global/app-header.tsx b/apps/client/src/components/layouts/global/app-header.tsx
index 58b76b71..9add5d7a 100644
--- a/apps/client/src/components/layouts/global/app-header.tsx
+++ b/apps/client/src/components/layouts/global/app-header.tsx
@@ -1,8 +1,18 @@
-import { Badge, Group, Text, Tooltip } from "@mantine/core";
+import {
+ ActionIcon,
+ Badge,
+ Box,
+ Group,
+ Text,
+ Tooltip,
+ UnstyledButton,
+} from "@mantine/core";
import classes from "./app-header.module.css";
import React from "react";
import TopMenu from "@/components/layouts/global/top-menu.tsx";
-import { Link } from "react-router-dom";
+import { Link, useLocation } from "react-router-dom";
+import { IconSparkles } from "@tabler/icons-react";
+import useToggleAside from "@/hooks/use-toggle-aside.tsx";
import APP_ROUTE from "@/lib/app-route.ts";
import { useAtom } from "jotai";
import {
@@ -23,8 +33,11 @@ import {
shareSearchSpotlight,
} from "@/features/search/constants.ts";
import { NotificationPopover } from "@/features/notification/components/notification-popover.tsx";
+import { workspaceAtom } from "@/features/user/atoms/current-user-atom.ts";
-const links = [{ link: APP_ROUTE.HOME, label: "Home" }];
+const links = [
+ { link: APP_ROUTE.HOME, label: "Home" },
+];
export function AppHeader() {
const { t } = useTranslation();
@@ -34,9 +47,14 @@ export function AppHeader() {
const [desktopOpened] = useAtom(desktopSidebarAtom);
const toggleDesktop = useToggleSidebar(desktopSidebarAtom);
const { isTrial, trialDaysLeft } = useTrial();
+ const location = useLocation();
+ const toggleAside = useToggleAside();
+ const [workspace] = useAtom(workspaceAtom);
+ const aiChatEnabled = workspace?.settings?.ai?.chat === true;
const isHomeRoute = location.pathname.startsWith("/home");
const isSpacesRoute = location.pathname === "/spaces";
+ const isPageRoute = location.pathname.includes("/p/");
const hideSidebar = isHomeRoute || isSpacesRoute;
const items = links.map((link) => (
@@ -73,15 +91,24 @@ export function AppHeader() {
)}
-
- Docmost
-
+
+
+ 
+
+
+ Docmost
+
+
{items}
@@ -98,6 +125,49 @@ export function AppHeader() {