mirror of
https://github.com/docmost/docmost.git
synced 2026-08-23 04:21:05 +08:00
Compare commits
14
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
0d5f7bf4d4 | ||
|
|
ab43031375 | ||
|
|
8c2c49ea6d | ||
|
|
8913d20aa0 | ||
|
|
232beda471 | ||
|
|
911c1057d6 | ||
|
|
d136864ef1 | ||
|
|
c093c18bf3 | ||
|
|
ea59912c7e | ||
|
|
db3ff54da1 | ||
|
|
9414a38215 | ||
|
|
089286f6cf | ||
|
|
737cd67965 | ||
|
|
a0b2ac6ae3 |
+1
-1
@@ -42,7 +42,7 @@ RUN chown -R node:node /app
|
|||||||
|
|
||||||
USER node
|
USER node
|
||||||
|
|
||||||
RUN pnpm install --frozen-lockfile --prod
|
RUN pnpm install --frozen-lockfile --prod && rm -rf /home/node/.cache/pnpm
|
||||||
|
|
||||||
RUN mkdir -p /app/data/storage
|
RUN mkdir -p /app/data/storage
|
||||||
|
|
||||||
|
|||||||
@@ -4,7 +4,7 @@
|
|||||||
"version": "0.95.0",
|
"version": "0.95.0",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"dev": "vite",
|
"dev": "vite",
|
||||||
"build": "tsc && vite build",
|
"build": "tsc && vite build && node scripts/compress-dist.mjs",
|
||||||
"lint": "eslint .",
|
"lint": "eslint .",
|
||||||
"preview": "vite preview",
|
"preview": "vite preview",
|
||||||
"format": "prettier --write \"src/**/*.tsx\" \"src/**/*.ts\"",
|
"format": "prettier --write \"src/**/*.tsx\" \"src/**/*.ts\"",
|
||||||
@@ -52,7 +52,7 @@
|
|||||||
"mantine-form-zod-resolver": "1.3.0",
|
"mantine-form-zod-resolver": "1.3.0",
|
||||||
"mermaid": "11.16.1",
|
"mermaid": "11.16.1",
|
||||||
"mitt": "3.0.1",
|
"mitt": "3.0.1",
|
||||||
"nanoid": "3.3.17",
|
"nanoid": "3.3.18",
|
||||||
"posthog-js": "1.391.2",
|
"posthog-js": "1.391.2",
|
||||||
"react": "19.2.7",
|
"react": "19.2.7",
|
||||||
"react-clear-modal": "^2.0.18",
|
"react-clear-modal": "^2.0.18",
|
||||||
|
|||||||
@@ -387,6 +387,8 @@
|
|||||||
"Insert horizontal rule divider": "Insert horizontal rule divider",
|
"Insert horizontal rule divider": "Insert horizontal rule divider",
|
||||||
"Page break": "Page break",
|
"Page break": "Page break",
|
||||||
"Insert a page break for printing.": "Insert a page break for printing.",
|
"Insert a page break for printing.": "Insert a page break for printing.",
|
||||||
|
"Footnote": "Footnote",
|
||||||
|
"Insert a footnote reference.": "Insert a footnote reference.",
|
||||||
"Upload any image from your device.": "Upload any image from your device.",
|
"Upload any image from your device.": "Upload any image from your device.",
|
||||||
"Upload any video from your device.": "Upload any video from your device.",
|
"Upload any video from your device.": "Upload any video from your device.",
|
||||||
"Upload any audio from your device.": "Upload any audio from your device.",
|
"Upload any audio from your device.": "Upload any audio from your device.",
|
||||||
@@ -508,11 +510,6 @@
|
|||||||
"Allow viewers to comment": "Allow viewers to comment",
|
"Allow viewers to comment": "Allow viewers to comment",
|
||||||
"Allow viewers to add comments on pages in this space.": "Allow viewers to add comments on pages in this space.",
|
"Allow viewers to add comments on pages in this space.": "Allow viewers to add comments on pages in this space.",
|
||||||
"Toggle viewer comments": "Toggle viewer comments",
|
"Toggle viewer comments": "Toggle viewer comments",
|
||||||
"Hide comments from viewers": "Hide comments from viewers",
|
|
||||||
"Viewers cannot see or add comments on pages in this space.": "Viewers cannot see or add comments on pages in this space.",
|
|
||||||
"Toggle hide comments from viewers": "Toggle hide comments from viewers",
|
|
||||||
"Turn off 'Allow viewers to comment' first": "Turn off 'Allow viewers to comment' first",
|
|
||||||
"Turn off 'Hide comments from viewers' first": "Turn off 'Hide comments from viewers' first",
|
|
||||||
"Public sharing is disabled at the workspace level": "Public sharing is disabled at the workspace level",
|
"Public sharing is disabled at the workspace level": "Public sharing is disabled at the workspace level",
|
||||||
"Prevent pages in this space from being shared publicly.": "Prevent pages in this space from being shared publicly.",
|
"Prevent pages in this space from being shared publicly.": "Prevent pages in this space from being shared publicly.",
|
||||||
"Page permissions": "Page permissions",
|
"Page permissions": "Page permissions",
|
||||||
@@ -1294,5 +1291,16 @@
|
|||||||
"{{count}} rows deleted_one": "1 row deleted",
|
"{{count}} rows deleted_one": "1 row deleted",
|
||||||
"{{count}} rows deleted_other": "{{count}} rows deleted",
|
"{{count}} rows deleted_other": "{{count}} rows deleted",
|
||||||
"{{count}} selected_one": "1 selected",
|
"{{count}} selected_one": "1 selected",
|
||||||
"{{count}} selected_other": "{{count}} selected"
|
"{{count}} selected_other": "{{count}} selected",
|
||||||
|
"Compare": "Compare",
|
||||||
|
"Compare versions": "Compare versions",
|
||||||
|
"Select version from {{date}}": "Select version from {{date}}",
|
||||||
|
"Version actions for {{date}}": "Version actions for {{date}}",
|
||||||
|
"Comparing {{newer}} and {{older}}": "Comparing {{newer}} and {{older}}",
|
||||||
|
"Exit compare": "Exit compare",
|
||||||
|
"Search attachments...": "Search attachments...",
|
||||||
|
"Error loading attachments.": "Error loading attachments.",
|
||||||
|
"No attachments on this page yet.": "No attachments on this page yet.",
|
||||||
|
"Uploaded by {{name}}": "Uploaded by {{name}}",
|
||||||
|
"Download {{name}}": "Download {{name}}"
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,48 @@
|
|||||||
|
import { promises as fs } from "node:fs";
|
||||||
|
import { join, extname } from "node:path";
|
||||||
|
import { promisify } from "node:util";
|
||||||
|
import zlib from "node:zlib";
|
||||||
|
|
||||||
|
const gzip = promisify(zlib.gzip);
|
||||||
|
const brotli = promisify(zlib.brotliCompress);
|
||||||
|
|
||||||
|
const DIST = new URL("../dist", import.meta.url).pathname;
|
||||||
|
// index.html is rewritten by the server at boot, so html must not be precompressed
|
||||||
|
const COMPRESSIBLE = new Set([".js", ".css", ".svg", ".json", ".txt", ".map"]);
|
||||||
|
const MIN_SIZE = 1024;
|
||||||
|
|
||||||
|
async function* walk(dir) {
|
||||||
|
for (const entry of await fs.readdir(dir, { withFileTypes: true })) {
|
||||||
|
const path = join(dir, entry.name);
|
||||||
|
if (entry.isDirectory()) yield* walk(path);
|
||||||
|
else yield path;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
const files = [];
|
||||||
|
for await (const file of walk(DIST)) {
|
||||||
|
if (!COMPRESSIBLE.has(extname(file))) continue;
|
||||||
|
const { size } = await fs.stat(file);
|
||||||
|
if (size >= MIN_SIZE) files.push(file);
|
||||||
|
}
|
||||||
|
|
||||||
|
await Promise.all(
|
||||||
|
files.map(async (file) => {
|
||||||
|
const content = await fs.readFile(file);
|
||||||
|
const [gz, br] = await Promise.all([
|
||||||
|
gzip(content, { level: 9 }),
|
||||||
|
brotli(content, {
|
||||||
|
params: {
|
||||||
|
[zlib.constants.BROTLI_PARAM_QUALITY]: 11,
|
||||||
|
[zlib.constants.BROTLI_PARAM_SIZE_HINT]: content.length,
|
||||||
|
},
|
||||||
|
}),
|
||||||
|
]);
|
||||||
|
await Promise.all([
|
||||||
|
fs.writeFile(`${file}.gz`, gz),
|
||||||
|
fs.writeFile(`${file}.br`, br),
|
||||||
|
]);
|
||||||
|
}),
|
||||||
|
);
|
||||||
|
|
||||||
|
console.log(`precompressed ${files.length} assets (.gz/.br)`);
|
||||||
+77
-45
@@ -1,60 +1,92 @@
|
|||||||
|
import { lazy, Suspense, useEffect } from "react";
|
||||||
import { Navigate, Route, Routes } from "react-router-dom";
|
import { Navigate, Route, Routes } from "react-router-dom";
|
||||||
import SetupWorkspace from "@/pages/auth/setup-workspace.tsx";
|
|
||||||
import LoginPage from "@/pages/auth/login";
|
|
||||||
import Home from "@/pages/dashboard/home";
|
|
||||||
import Page from "@/pages/page/page";
|
|
||||||
import AccountSettings from "@/pages/settings/account/account-settings";
|
|
||||||
import WorkspaceMembers from "@/pages/settings/workspace/workspace-members";
|
|
||||||
import WorkspaceSettings from "@/pages/settings/workspace/workspace-settings";
|
|
||||||
import Groups from "@/pages/settings/group/groups";
|
|
||||||
import GroupInfo from "./pages/settings/group/group-info";
|
|
||||||
import Spaces from "@/pages/settings/space/spaces.tsx";
|
|
||||||
import { Error404 } from "@/components/ui/error-404.tsx";
|
|
||||||
import AccountPreferences from "@/pages/settings/account/account-preferences.tsx";
|
|
||||||
import SpaceHome from "@/pages/space/space-home.tsx";
|
|
||||||
import PageRedirect from "@/pages/page/page-redirect.tsx";
|
|
||||||
import Layout from "@/components/layouts/global/layout.tsx";
|
import Layout from "@/components/layouts/global/layout.tsx";
|
||||||
import InviteSignup from "@/pages/auth/invite-signup.tsx";
|
import { Error404 } from "@/components/ui/error-404.tsx";
|
||||||
import ForgotPassword from "@/pages/auth/forgot-password.tsx";
|
|
||||||
import PasswordReset from "./pages/auth/password-reset";
|
|
||||||
import Billing from "@/ee/billing/pages/billing.tsx";
|
|
||||||
import CloudLogin from "@/ee/pages/cloud-login.tsx";
|
|
||||||
import CreateWorkspace from "@/ee/pages/create-workspace.tsx";
|
|
||||||
import { isCloud } from "@/lib/config.ts";
|
import { isCloud } from "@/lib/config.ts";
|
||||||
import { useTranslation } from "react-i18next";
|
import { useTranslation } from "react-i18next";
|
||||||
import Security from "@/ee/security/pages/security.tsx";
|
|
||||||
import License from "@/ee/licence/pages/license.tsx";
|
|
||||||
import { useRedirectToCloudSelect } from "@/ee/hooks/use-redirect-to-cloud-select.tsx";
|
import { useRedirectToCloudSelect } from "@/ee/hooks/use-redirect-to-cloud-select.tsx";
|
||||||
import SharedPage from "@/pages/share/shared-page.tsx";
|
|
||||||
import PdfRenderPage from "@/ee/pdf-export/pdf-render-page.tsx";
|
|
||||||
import Shares from "@/pages/settings/shares/shares.tsx";
|
|
||||||
import ShareLayout from "@/features/share/components/share-layout.tsx";
|
|
||||||
import ShareRedirect from "@/pages/share/share-redirect.tsx";
|
|
||||||
import { useTrackOrigin } from "@/hooks/use-track-origin";
|
import { useTrackOrigin } from "@/hooks/use-track-origin";
|
||||||
import SpacesPage from "@/pages/spaces/spaces.tsx";
|
|
||||||
import { MfaChallengePage } from "@/ee/mfa/pages/mfa-challenge-page";
|
const SetupWorkspace = lazy(() => import("@/pages/auth/setup-workspace.tsx"));
|
||||||
import { MfaSetupRequiredPage } from "@/ee/mfa/pages/mfa-setup-required-page";
|
const LoginPage = lazy(() => import("@/pages/auth/login"));
|
||||||
import SpaceTrash from "@/pages/space/space-trash.tsx";
|
const Home = lazy(() => import("@/pages/dashboard/home"));
|
||||||
import UserApiKeys from "@/ee/api-key/pages/user-api-keys";
|
const Page = lazy(() => import("@/pages/page/page"));
|
||||||
import WorkspaceApiKeys from "@/ee/api-key/pages/workspace-api-keys";
|
const AccountSettings = lazy(
|
||||||
import AiSettings from "@/ee/ai/pages/ai-settings.tsx";
|
() => import("@/pages/settings/account/account-settings"),
|
||||||
import BasePage from "@/ee/base/pages/base-page.tsx";
|
);
|
||||||
import AuditLogs from "@/ee/audit/pages/audit-logs.tsx";
|
const WorkspaceMembers = lazy(
|
||||||
import VerifiedPages from "@/ee/page-verification/pages/verified-pages.tsx";
|
() => import("@/pages/settings/workspace/workspace-members"),
|
||||||
import TemplateList from "@/ee/template/pages/template-list";
|
);
|
||||||
import TemplateEditor from "@/ee/template/pages/template-editor";
|
const WorkspaceSettings = lazy(
|
||||||
import FavoritesPage from "@/pages/favorites/favorites-page";
|
() => import("@/pages/settings/workspace/workspace-settings"),
|
||||||
import AiChat from "@/ee/ai-chat/pages/ai-chat.tsx";
|
);
|
||||||
import VerifyEmail from "@/ee/pages/verify-email.tsx";
|
const Groups = lazy(() => import("@/pages/settings/group/groups"));
|
||||||
import LabelPage from "@/pages/label/label-page";
|
const GroupInfo = lazy(() => import("./pages/settings/group/group-info"));
|
||||||
|
const Spaces = lazy(() => import("@/pages/settings/space/spaces.tsx"));
|
||||||
|
const AccountPreferences = lazy(
|
||||||
|
() => import("@/pages/settings/account/account-preferences.tsx"),
|
||||||
|
);
|
||||||
|
const SpaceHome = lazy(() => import("@/pages/space/space-home.tsx"));
|
||||||
|
const PageRedirect = lazy(() => import("@/pages/page/page-redirect.tsx"));
|
||||||
|
const InviteSignup = lazy(() => import("@/pages/auth/invite-signup.tsx"));
|
||||||
|
const ForgotPassword = lazy(() => import("@/pages/auth/forgot-password.tsx"));
|
||||||
|
const PasswordReset = lazy(() => import("./pages/auth/password-reset"));
|
||||||
|
const Billing = lazy(() => import("@/ee/billing/pages/billing.tsx"));
|
||||||
|
const CloudLogin = lazy(() => import("@/ee/pages/cloud-login.tsx"));
|
||||||
|
const CreateWorkspace = lazy(() => import("@/ee/pages/create-workspace.tsx"));
|
||||||
|
const Security = lazy(() => import("@/ee/security/pages/security.tsx"));
|
||||||
|
const License = lazy(() => import("@/ee/licence/pages/license.tsx"));
|
||||||
|
const SharedPage = lazy(() => import("@/pages/share/shared-page.tsx"));
|
||||||
|
const PdfRenderPage = lazy(() => import("@/ee/pdf-export/pdf-render-page.tsx"));
|
||||||
|
const Shares = lazy(() => import("@/pages/settings/shares/shares.tsx"));
|
||||||
|
const ShareLayout = lazy(
|
||||||
|
() => import("@/features/share/components/share-layout.tsx"),
|
||||||
|
);
|
||||||
|
const ShareRedirect = lazy(() => import("@/pages/share/share-redirect.tsx"));
|
||||||
|
const SpacesPage = lazy(() => import("@/pages/spaces/spaces.tsx"));
|
||||||
|
const MfaChallengePage = lazy(() =>
|
||||||
|
import("@/ee/mfa/pages/mfa-challenge-page").then((m) => ({
|
||||||
|
default: m.MfaChallengePage,
|
||||||
|
})),
|
||||||
|
);
|
||||||
|
const MfaSetupRequiredPage = lazy(() =>
|
||||||
|
import("@/ee/mfa/pages/mfa-setup-required-page").then((m) => ({
|
||||||
|
default: m.MfaSetupRequiredPage,
|
||||||
|
})),
|
||||||
|
);
|
||||||
|
const SpaceTrash = lazy(() => import("@/pages/space/space-trash.tsx"));
|
||||||
|
const UserApiKeys = lazy(() => import("@/ee/api-key/pages/user-api-keys"));
|
||||||
|
const WorkspaceApiKeys = lazy(
|
||||||
|
() => import("@/ee/api-key/pages/workspace-api-keys"),
|
||||||
|
);
|
||||||
|
const AiSettings = lazy(() => import("@/ee/ai/pages/ai-settings.tsx"));
|
||||||
|
const BasePage = lazy(() => import("@/ee/base/pages/base-page.tsx"));
|
||||||
|
const AuditLogs = lazy(() => import("@/ee/audit/pages/audit-logs.tsx"));
|
||||||
|
const VerifiedPages = lazy(
|
||||||
|
() => import("@/ee/page-verification/pages/verified-pages.tsx"),
|
||||||
|
);
|
||||||
|
const TemplateList = lazy(() => import("@/ee/template/pages/template-list"));
|
||||||
|
const TemplateEditor = lazy(
|
||||||
|
() => import("@/ee/template/pages/template-editor"),
|
||||||
|
);
|
||||||
|
const FavoritesPage = lazy(() => import("@/pages/favorites/favorites-page"));
|
||||||
|
const AiChat = lazy(() => import("@/ee/ai-chat/pages/ai-chat.tsx"));
|
||||||
|
const VerifyEmail = lazy(() => import("@/ee/pages/verify-email.tsx"));
|
||||||
|
const LabelPage = lazy(() => import("@/pages/label/label-page"));
|
||||||
|
|
||||||
export default function App() {
|
export default function App() {
|
||||||
const { t } = useTranslation();
|
const { t } = useTranslation();
|
||||||
useRedirectToCloudSelect();
|
useRedirectToCloudSelect();
|
||||||
useTrackOrigin();
|
useTrackOrigin();
|
||||||
|
|
||||||
|
useEffect(() => {
|
||||||
|
// warm the editor chunk so opening a page doesn't wait on the network
|
||||||
|
const timer = setTimeout(() => import("@/pages/page/page"), 3000);
|
||||||
|
return () => clearTimeout(timer);
|
||||||
|
}, []);
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<>
|
<Suspense fallback={null}>
|
||||||
<Routes>
|
<Routes>
|
||||||
<Route index element={<Navigate to="/home" />} />
|
<Route index element={<Navigate to="/home" />} />
|
||||||
<Route path={"/login"} element={<LoginPage />} />
|
<Route path={"/login"} element={<LoginPage />} />
|
||||||
@@ -135,6 +167,6 @@ export default function App() {
|
|||||||
|
|
||||||
<Route path="*" element={<Error404 />} />
|
<Route path="*" element={<Error404 />} />
|
||||||
</Routes>
|
</Routes>
|
||||||
</>
|
</Suspense>
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,23 +1,34 @@
|
|||||||
import { ActionIcon, Box, Group, ScrollArea, Title, Tooltip } from "@mantine/core";
|
import { ActionIcon, Box, Group, ScrollArea, Title, Tooltip } from "@mantine/core";
|
||||||
import { IconX } from "@tabler/icons-react";
|
import { IconX } from "@tabler/icons-react";
|
||||||
import CommentListWithTabs from "@/features/comment/components/comment-list-with-tabs.tsx";
|
|
||||||
import { useAtom } from "jotai";
|
import { useAtom } from "jotai";
|
||||||
import { asideStateAtom } from "@/components/layouts/global/hooks/atoms/sidebar-atom.ts";
|
import { asideStateAtom } from "@/components/layouts/global/hooks/atoms/sidebar-atom.ts";
|
||||||
import React, { ReactNode, useEffect } from "react";
|
import React, { lazy, ReactNode, Suspense, useEffect } from "react";
|
||||||
import { useTranslation } from "react-i18next";
|
import { useTranslation } from "react-i18next";
|
||||||
import { TableOfContents } from "@/features/editor/components/table-of-contents/table-of-contents.tsx";
|
|
||||||
import { useAtomValue } from "jotai";
|
import { useAtomValue } from "jotai";
|
||||||
import { pageEditorAtom } from "@/features/editor/atoms/editor-atoms.ts";
|
import { pageEditorAtom } from "@/features/editor/atoms/editor-atoms.ts";
|
||||||
import AsideChatPanel from "@/ee/ai-chat/components/aside-chat-panel";
|
|
||||||
import { PageDetailsAside } from "@/features/page-details/components/page-details-aside.tsx";
|
|
||||||
import { ASIDE_PANEL_ID } from "@/hooks/use-toggle-aside.tsx";
|
import { ASIDE_PANEL_ID } from "@/hooks/use-toggle-aside.tsx";
|
||||||
import { useCanViewComments } from "@/features/comment/hooks/use-can-view-comments.ts";
|
|
||||||
|
const CommentListWithTabs = lazy(
|
||||||
|
() => import("@/features/comment/components/comment-list-with-tabs.tsx"),
|
||||||
|
);
|
||||||
|
const TableOfContents = lazy(() =>
|
||||||
|
import(
|
||||||
|
"@/features/editor/components/table-of-contents/table-of-contents.tsx"
|
||||||
|
).then((m) => ({ default: m.TableOfContents })),
|
||||||
|
);
|
||||||
|
const AsideChatPanel = lazy(
|
||||||
|
() => import("@/ee/ai-chat/components/aside-chat-panel"),
|
||||||
|
);
|
||||||
|
const PageDetailsAside = lazy(() =>
|
||||||
|
import("@/features/page-details/components/page-details-aside.tsx").then(
|
||||||
|
(m) => ({ default: m.PageDetailsAside }),
|
||||||
|
),
|
||||||
|
);
|
||||||
|
|
||||||
export default function Aside() {
|
export default function Aside() {
|
||||||
const [{ tab, isAsideOpen }, setAsideState] = useAtom(asideStateAtom);
|
const [{ tab, isAsideOpen }, setAsideState] = useAtom(asideStateAtom);
|
||||||
const { t } = useTranslation();
|
const { t } = useTranslation();
|
||||||
const pageEditor = useAtomValue(pageEditorAtom);
|
const pageEditor = useAtomValue(pageEditorAtom);
|
||||||
const canViewComments = useCanViewComments();
|
|
||||||
const closeAside = () => setAsideState((s) => ({ ...s, isAsideOpen: false }));
|
const closeAside = () => setAsideState((s) => ({ ...s, isAsideOpen: false }));
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
@@ -25,18 +36,12 @@ export default function Aside() {
|
|||||||
document.getElementById(ASIDE_PANEL_ID)?.focus();
|
document.getElementById(ASIDE_PANEL_ID)?.focus();
|
||||||
}, [isAsideOpen, tab]);
|
}, [isAsideOpen, tab]);
|
||||||
|
|
||||||
useEffect(() => {
|
|
||||||
if (isAsideOpen && tab === "comments" && !canViewComments) {
|
|
||||||
setAsideState({ tab: "", isAsideOpen: false });
|
|
||||||
}
|
|
||||||
}, [isAsideOpen, tab, canViewComments, setAsideState]);
|
|
||||||
|
|
||||||
let title: string;
|
let title: string;
|
||||||
let component: ReactNode;
|
let component: ReactNode;
|
||||||
|
|
||||||
switch (tab) {
|
switch (tab) {
|
||||||
case "comments":
|
case "comments":
|
||||||
component = canViewComments ? <CommentListWithTabs /> : null;
|
component = <CommentListWithTabs />;
|
||||||
title = "Comments";
|
title = "Comments";
|
||||||
break;
|
break;
|
||||||
case "toc":
|
case "toc":
|
||||||
@@ -76,17 +81,19 @@ export default function Aside() {
|
|||||||
</Group>
|
</Group>
|
||||||
)}
|
)}
|
||||||
|
|
||||||
{tab === "comments" || tab === "chat" ? (
|
<Suspense fallback={null}>
|
||||||
component
|
{tab === "comments" || tab === "chat" ? (
|
||||||
) : (
|
component
|
||||||
<ScrollArea
|
) : (
|
||||||
style={{ height: "85vh" }}
|
<ScrollArea
|
||||||
scrollbarSize={5}
|
style={{ height: "85vh" }}
|
||||||
type="scroll"
|
scrollbarSize={5}
|
||||||
>
|
type="scroll"
|
||||||
<div style={{ paddingBottom: "200px" }}>{component}</div>
|
>
|
||||||
</ScrollArea>
|
<div style={{ paddingBottom: "200px" }}>{component}</div>
|
||||||
)}
|
</ScrollArea>
|
||||||
|
)}
|
||||||
|
</Suspense>
|
||||||
</>
|
</>
|
||||||
)}
|
)}
|
||||||
</Box>
|
</Box>
|
||||||
|
|||||||
@@ -11,7 +11,10 @@ import {
|
|||||||
sidebarWidthAtom,
|
sidebarWidthAtom,
|
||||||
} from "@/components/layouts/global/hooks/atoms/sidebar-atom.ts";
|
} from "@/components/layouts/global/hooks/atoms/sidebar-atom.ts";
|
||||||
import { SpaceSidebar } from "@/features/space/components/sidebar/space-sidebar.tsx";
|
import { SpaceSidebar } from "@/features/space/components/sidebar/space-sidebar.tsx";
|
||||||
import AiChatSidebar from "@/ee/ai-chat/components/ai-chat-sidebar.tsx";
|
|
||||||
|
const AiChatSidebar = React.lazy(
|
||||||
|
() => import("@/ee/ai-chat/components/ai-chat-sidebar.tsx"),
|
||||||
|
);
|
||||||
import { AppHeader } from "@/components/layouts/global/app-header.tsx";
|
import { AppHeader } from "@/components/layouts/global/app-header.tsx";
|
||||||
import Aside from "@/components/layouts/global/aside.tsx";
|
import Aside from "@/components/layouts/global/aside.tsx";
|
||||||
import classes from "./app-shell.module.css";
|
import classes from "./app-shell.module.css";
|
||||||
@@ -126,7 +129,11 @@ export default function GlobalAppShell({
|
|||||||
)}
|
)}
|
||||||
{isSpaceRoute && <SpaceSidebar />}
|
{isSpaceRoute && <SpaceSidebar />}
|
||||||
{isSettingsRoute && <SettingsSidebar />}
|
{isSettingsRoute && <SettingsSidebar />}
|
||||||
{isAiRoute && <AiChatSidebar />}
|
{isAiRoute && (
|
||||||
|
<React.Suspense fallback={null}>
|
||||||
|
<AiChatSidebar />
|
||||||
|
</React.Suspense>
|
||||||
|
)}
|
||||||
{showGlobalSidebar && <GlobalSidebar />}
|
{showGlobalSidebar && <GlobalSidebar />}
|
||||||
</AppShell.Navbar>
|
</AppShell.Navbar>
|
||||||
<AppShell.Main id={MAIN_CONTENT_ID} tabIndex={-1}>
|
<AppShell.Main id={MAIN_CONTENT_ID} tabIndex={-1}>
|
||||||
|
|||||||
@@ -255,6 +255,7 @@ export default function ChatInput({
|
|||||||
},
|
},
|
||||||
content: "",
|
content: "",
|
||||||
editable: true,
|
editable: true,
|
||||||
|
textDirection: "auto",
|
||||||
immediatelyRender: true,
|
immediatelyRender: true,
|
||||||
shouldRerenderOnTransaction: false,
|
shouldRerenderOnTransaction: false,
|
||||||
autofocus: autofocus ? "end" : false,
|
autofocus: autofocus ? "end" : false,
|
||||||
|
|||||||
@@ -15,6 +15,14 @@ export interface IAiSearchResponse {
|
|||||||
}>;
|
}>;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export async function hintVectorCache(): Promise<void> {
|
||||||
|
try {
|
||||||
|
await api.post("/ai/vector-cache-hint");
|
||||||
|
} catch {
|
||||||
|
// best-effort cache hint
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
export async function aiAnswers(
|
export async function aiAnswers(
|
||||||
params: IPageSearchParams,
|
params: IPageSearchParams,
|
||||||
onChunk?: (chunk: { content?: string; sources?: any[] }) => void,
|
onChunk?: (chunk: { content?: string; sources?: any[] }) => void,
|
||||||
|
|||||||
@@ -19,7 +19,6 @@ export const Feature = {
|
|||||||
SHARING_CONTROLS: 'sharing:controls',
|
SHARING_CONTROLS: 'sharing:controls',
|
||||||
TEMPLATES: 'templates',
|
TEMPLATES: 'templates',
|
||||||
VIEWER_COMMENTS: 'comment:viewer',
|
VIEWER_COMMENTS: 'comment:viewer',
|
||||||
HIDE_COMMENTS: 'comment:hide',
|
|
||||||
PERSONAL_SPACES: 'spaces:personal',
|
PERSONAL_SPACES: 'spaces:personal',
|
||||||
DOCX_EXPORT: 'export:docx',
|
DOCX_EXPORT: 'export:docx',
|
||||||
BASES: 'bases',
|
BASES: 'bases',
|
||||||
|
|||||||
@@ -1,62 +0,0 @@
|
|||||||
import { Group, Text, Switch, Tooltip } from "@mantine/core";
|
|
||||||
import React, { useState } from "react";
|
|
||||||
import { useTranslation } from "react-i18next";
|
|
||||||
import { ISpace } from "@/features/space/types/space.types.ts";
|
|
||||||
import { useUpdateSpaceMutation } from "@/features/space/queries/space-query.ts";
|
|
||||||
import { useHasFeature } from "@/ee/hooks/use-feature.ts";
|
|
||||||
import { Feature } from "@/ee/features.ts";
|
|
||||||
import { useUpgradeLabel } from "@/ee/hooks/use-upgrade-label.ts";
|
|
||||||
|
|
||||||
type SpaceHideCommentsToggleProps = {
|
|
||||||
space: ISpace;
|
|
||||||
};
|
|
||||||
|
|
||||||
export default function SpaceHideCommentsToggle({
|
|
||||||
space,
|
|
||||||
}: SpaceHideCommentsToggleProps) {
|
|
||||||
const { t } = useTranslation();
|
|
||||||
const hasHideComments = useHasFeature(Feature.HIDE_COMMENTS);
|
|
||||||
const upgradeLabel = useUpgradeLabel();
|
|
||||||
const allowViewerCommentsEnabled =
|
|
||||||
space.settings?.comments?.allowViewerComments === true;
|
|
||||||
const isDisabled = !hasHideComments || allowViewerCommentsEnabled;
|
|
||||||
const tooltipLabel = !hasHideComments
|
|
||||||
? upgradeLabel
|
|
||||||
: t("Turn off 'Allow viewers to comment' first");
|
|
||||||
const [checked, setChecked] = useState(
|
|
||||||
space.settings?.comments?.hideCommentsFromViewers === true,
|
|
||||||
);
|
|
||||||
const updateSpaceMutation = useUpdateSpaceMutation();
|
|
||||||
|
|
||||||
const handleChange = async (event: React.ChangeEvent<HTMLInputElement>) => {
|
|
||||||
const value = event.currentTarget.checked;
|
|
||||||
try {
|
|
||||||
await updateSpaceMutation.mutateAsync({
|
|
||||||
spaceId: space.id,
|
|
||||||
hideCommentsFromViewers: value,
|
|
||||||
});
|
|
||||||
setChecked(value);
|
|
||||||
} catch {
|
|
||||||
// error handled by mutation
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
return (
|
|
||||||
<Group justify="space-between" wrap="nowrap" gap="xl">
|
|
||||||
<div>
|
|
||||||
<Text size="md">{t("Hide comments from viewers")}</Text>
|
|
||||||
<Text size="sm" c="dimmed">
|
|
||||||
{t("Viewers cannot see or add comments on pages in this space.")}
|
|
||||||
</Text>
|
|
||||||
</div>
|
|
||||||
<Tooltip label={tooltipLabel} disabled={!isDisabled} refProp="rootRef">
|
|
||||||
<Switch
|
|
||||||
checked={checked}
|
|
||||||
onChange={handleChange}
|
|
||||||
disabled={isDisabled}
|
|
||||||
aria-label={t("Toggle hide comments from viewers")}
|
|
||||||
/>
|
|
||||||
</Tooltip>
|
|
||||||
</Group>
|
|
||||||
);
|
|
||||||
}
|
|
||||||
@@ -17,12 +17,7 @@ export default function SpaceViewerCommentsToggle({
|
|||||||
const { t } = useTranslation();
|
const { t } = useTranslation();
|
||||||
const hasViewerComments = useHasFeature(Feature.VIEWER_COMMENTS);
|
const hasViewerComments = useHasFeature(Feature.VIEWER_COMMENTS);
|
||||||
const upgradeLabel = useUpgradeLabel();
|
const upgradeLabel = useUpgradeLabel();
|
||||||
const hideCommentsEnabled =
|
const isDisabled = !hasViewerComments;
|
||||||
space.settings?.comments?.hideCommentsFromViewers === true;
|
|
||||||
const isDisabled = !hasViewerComments || hideCommentsEnabled;
|
|
||||||
const tooltipLabel = !hasViewerComments
|
|
||||||
? upgradeLabel
|
|
||||||
: t("Turn off 'Hide comments from viewers' first");
|
|
||||||
const [checked, setChecked] = useState(
|
const [checked, setChecked] = useState(
|
||||||
space.settings?.comments?.allowViewerComments === true,
|
space.settings?.comments?.allowViewerComments === true,
|
||||||
);
|
);
|
||||||
@@ -50,7 +45,7 @@ export default function SpaceViewerCommentsToggle({
|
|||||||
</Text>
|
</Text>
|
||||||
</div>
|
</div>
|
||||||
<Tooltip
|
<Tooltip
|
||||||
label={tooltipLabel}
|
label={upgradeLabel}
|
||||||
disabled={!isDisabled}
|
disabled={!isDisabled}
|
||||||
refProp="rootRef"
|
refProp="rootRef"
|
||||||
>
|
>
|
||||||
|
|||||||
@@ -41,6 +41,7 @@ export default function ReadonlyTemplateEditor({
|
|||||||
<EditorProvider
|
<EditorProvider
|
||||||
editable={false}
|
editable={false}
|
||||||
immediatelyRender={true}
|
immediatelyRender={true}
|
||||||
|
textDirection="auto"
|
||||||
extensions={extensions}
|
extensions={extensions}
|
||||||
content={template.content}
|
content={template.content}
|
||||||
/>
|
/>
|
||||||
|
|||||||
@@ -87,6 +87,7 @@ export default function TemplateEditor() {
|
|||||||
const editor = useEditor({
|
const editor = useEditor({
|
||||||
extensions: templateExtensions,
|
extensions: templateExtensions,
|
||||||
content: "",
|
content: "",
|
||||||
|
textDirection: "auto",
|
||||||
editorProps: {
|
editorProps: {
|
||||||
scrollThreshold: 80,
|
scrollThreshold: 80,
|
||||||
scrollMargin: 80,
|
scrollMargin: 80,
|
||||||
|
|||||||
@@ -0,0 +1,59 @@
|
|||||||
|
import { ThemeIcon } from "@mantine/core";
|
||||||
|
import {
|
||||||
|
IconFile,
|
||||||
|
IconFileTypeCsv,
|
||||||
|
IconFileTypeDocx,
|
||||||
|
IconFileTypePdf,
|
||||||
|
IconFileTypePpt,
|
||||||
|
IconFileTypeXls,
|
||||||
|
IconFileZip,
|
||||||
|
IconMovie,
|
||||||
|
IconMusic,
|
||||||
|
IconPhoto,
|
||||||
|
type Icon,
|
||||||
|
} from "@tabler/icons-react";
|
||||||
|
|
||||||
|
const EXT_ICONS: Record<string, { icon: Icon; color: string }> = {
|
||||||
|
".pdf": { icon: IconFileTypePdf, color: "red" },
|
||||||
|
".doc": { icon: IconFileTypeDocx, color: "blue" },
|
||||||
|
".docx": { icon: IconFileTypeDocx, color: "blue" },
|
||||||
|
".xls": { icon: IconFileTypeXls, color: "teal" },
|
||||||
|
".xlsx": { icon: IconFileTypeXls, color: "teal" },
|
||||||
|
".csv": { icon: IconFileTypeCsv, color: "teal" },
|
||||||
|
".ppt": { icon: IconFileTypePpt, color: "orange" },
|
||||||
|
".pptx": { icon: IconFileTypePpt, color: "orange" },
|
||||||
|
".zip": { icon: IconFileZip, color: "gray" },
|
||||||
|
".rar": { icon: IconFileZip, color: "gray" },
|
||||||
|
".7z": { icon: IconFileZip, color: "gray" },
|
||||||
|
".tar": { icon: IconFileZip, color: "gray" },
|
||||||
|
".gz": { icon: IconFileZip, color: "gray" },
|
||||||
|
};
|
||||||
|
|
||||||
|
const MIME_ICONS: Array<{ prefix: string; icon: Icon; color: string }> = [
|
||||||
|
{ prefix: "image/", icon: IconPhoto, color: "grape" },
|
||||||
|
{ prefix: "video/", icon: IconMovie, color: "violet" },
|
||||||
|
{ prefix: "audio/", icon: IconMusic, color: "pink" },
|
||||||
|
];
|
||||||
|
|
||||||
|
interface AttachmentFileIconProps {
|
||||||
|
fileExt?: string;
|
||||||
|
mimeType?: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
export function AttachmentFileIcon({
|
||||||
|
fileExt,
|
||||||
|
mimeType,
|
||||||
|
}: AttachmentFileIconProps) {
|
||||||
|
const byExt = fileExt ? EXT_ICONS[fileExt.toLowerCase()] : undefined;
|
||||||
|
const byMime = mimeType
|
||||||
|
? MIME_ICONS.find((entry) => mimeType.startsWith(entry.prefix))
|
||||||
|
: undefined;
|
||||||
|
const { icon: FileIcon, color } = byExt ??
|
||||||
|
byMime ?? { icon: IconFile, color: "gray" };
|
||||||
|
|
||||||
|
return (
|
||||||
|
<ThemeIcon variant="light" color={color} size={40} radius="md">
|
||||||
|
<FileIcon size={22} stroke={1.5} />
|
||||||
|
</ThemeIcon>
|
||||||
|
);
|
||||||
|
}
|
||||||
@@ -0,0 +1,191 @@
|
|||||||
|
import { useCallback, useEffect, useMemo, useRef, useState } from "react";
|
||||||
|
import {
|
||||||
|
ActionIcon,
|
||||||
|
Anchor,
|
||||||
|
Center,
|
||||||
|
Group,
|
||||||
|
Loader,
|
||||||
|
Modal,
|
||||||
|
ScrollArea,
|
||||||
|
Text,
|
||||||
|
Tooltip,
|
||||||
|
} from "@mantine/core";
|
||||||
|
import { IconDownload } from "@tabler/icons-react";
|
||||||
|
import { useTranslation } from "react-i18next";
|
||||||
|
import { SearchInput } from "@/components/common/search-input.tsx";
|
||||||
|
import { CustomAvatar } from "@/components/ui/custom-avatar.tsx";
|
||||||
|
import { usePageAttachmentsQuery } from "@/features/attachments/queries/attachment-query.ts";
|
||||||
|
import { IPageAttachment } from "@/features/attachments/types/attachment.types.ts";
|
||||||
|
import { AttachmentFileIcon } from "@/features/attachments/components/attachment-file-icon.tsx";
|
||||||
|
import { formatBytes } from "@/lib";
|
||||||
|
import { getFileUrl } from "@/lib/config.ts";
|
||||||
|
import { formattedDate } from "@/lib/time.ts";
|
||||||
|
|
||||||
|
interface PageAttachmentsModalProps {
|
||||||
|
pageId: string;
|
||||||
|
open: boolean;
|
||||||
|
onClose: () => void;
|
||||||
|
}
|
||||||
|
|
||||||
|
export default function PageAttachmentsModal({
|
||||||
|
pageId,
|
||||||
|
open,
|
||||||
|
onClose,
|
||||||
|
}: PageAttachmentsModalProps) {
|
||||||
|
const { t } = useTranslation();
|
||||||
|
|
||||||
|
return (
|
||||||
|
<Modal
|
||||||
|
opened={open}
|
||||||
|
onClose={onClose}
|
||||||
|
title={t("Attachments")}
|
||||||
|
size={800}
|
||||||
|
closeButtonProps={{ "aria-label": t("Close") }}
|
||||||
|
>
|
||||||
|
<PageAttachmentsList pageId={pageId} />
|
||||||
|
</Modal>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
function PageAttachmentsList({ pageId }: { pageId: string }) {
|
||||||
|
const { t } = useTranslation();
|
||||||
|
const [search, setSearch] = useState("");
|
||||||
|
const {
|
||||||
|
data,
|
||||||
|
isLoading,
|
||||||
|
isError,
|
||||||
|
isFetching,
|
||||||
|
fetchNextPage,
|
||||||
|
hasNextPage,
|
||||||
|
isFetchingNextPage,
|
||||||
|
} = usePageAttachmentsQuery(pageId, search);
|
||||||
|
|
||||||
|
const attachments = useMemo(
|
||||||
|
() => data?.pages.flatMap((page) => page.items) ?? [],
|
||||||
|
[data],
|
||||||
|
);
|
||||||
|
|
||||||
|
const loadMoreRef = useRef<HTMLDivElement>(null);
|
||||||
|
|
||||||
|
useEffect(() => {
|
||||||
|
const sentinel = loadMoreRef.current;
|
||||||
|
if (!sentinel || !hasNextPage) return;
|
||||||
|
|
||||||
|
const observer = new IntersectionObserver(
|
||||||
|
(entries) => {
|
||||||
|
if (entries[0].isIntersecting && !isFetching) {
|
||||||
|
fetchNextPage();
|
||||||
|
}
|
||||||
|
},
|
||||||
|
{ threshold: 0.1 },
|
||||||
|
);
|
||||||
|
|
||||||
|
observer.observe(sentinel);
|
||||||
|
return () => observer.disconnect();
|
||||||
|
}, [fetchNextPage, hasNextPage, isFetching]);
|
||||||
|
|
||||||
|
const handleSearch = useCallback((value: string) => setSearch(value), []);
|
||||||
|
|
||||||
|
return (
|
||||||
|
<>
|
||||||
|
<SearchInput
|
||||||
|
onSearch={handleSearch}
|
||||||
|
placeholder={t("Search attachments...")}
|
||||||
|
/>
|
||||||
|
|
||||||
|
{isLoading ? (
|
||||||
|
<Center py="xl">
|
||||||
|
<Loader size="sm" />
|
||||||
|
</Center>
|
||||||
|
) : isError ? (
|
||||||
|
<Center py="xl">
|
||||||
|
<Text size="sm" c="dimmed">
|
||||||
|
{t("Error loading attachments.")}
|
||||||
|
</Text>
|
||||||
|
</Center>
|
||||||
|
) : attachments.length === 0 ? (
|
||||||
|
<Center py="xl">
|
||||||
|
<Text size="sm" c="dimmed">
|
||||||
|
{search
|
||||||
|
? t("No results found")
|
||||||
|
: t("No attachments on this page yet.")}
|
||||||
|
</Text>
|
||||||
|
</Center>
|
||||||
|
) : (
|
||||||
|
<ScrollArea.Autosize mah={480} type="scroll" scrollbarSize={5}>
|
||||||
|
{attachments.map((attachment) => (
|
||||||
|
<AttachmentRow key={attachment.id} attachment={attachment} />
|
||||||
|
))}
|
||||||
|
{hasNextPage && <div ref={loadMoreRef} style={{ height: 1 }} />}
|
||||||
|
{isFetchingNextPage && (
|
||||||
|
<Center py="sm">
|
||||||
|
<Loader size="sm" />
|
||||||
|
</Center>
|
||||||
|
)}
|
||||||
|
</ScrollArea.Autosize>
|
||||||
|
)}
|
||||||
|
</>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
function AttachmentRow({ attachment }: { attachment: IPageAttachment }) {
|
||||||
|
const { t } = useTranslation();
|
||||||
|
const fileUrl = getFileUrl(attachment.url);
|
||||||
|
|
||||||
|
return (
|
||||||
|
<Group wrap="nowrap" gap="md" py="sm" pr="xs">
|
||||||
|
<AttachmentFileIcon
|
||||||
|
fileExt={attachment.fileExt}
|
||||||
|
mimeType={attachment.mimeType}
|
||||||
|
/>
|
||||||
|
|
||||||
|
<div style={{ flex: 1, minWidth: 0 }}>
|
||||||
|
<Anchor
|
||||||
|
href={fileUrl}
|
||||||
|
target="_blank"
|
||||||
|
rel="noopener noreferrer"
|
||||||
|
size="sm"
|
||||||
|
fw={500}
|
||||||
|
c="inherit"
|
||||||
|
truncate="end"
|
||||||
|
style={{ display: "block" }}
|
||||||
|
>
|
||||||
|
{attachment.fileName}
|
||||||
|
</Anchor>
|
||||||
|
<Text size="xs" c="dimmed" mt={2} truncate="end">
|
||||||
|
{formatBytes(Number(attachment.fileSize))}
|
||||||
|
{" · "}
|
||||||
|
{formattedDate(new Date(attachment.createdAt))}
|
||||||
|
</Text>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
{attachment.creator && (
|
||||||
|
<Tooltip
|
||||||
|
label={t("Uploaded by {{name}}", { name: attachment.creator.name })}
|
||||||
|
withArrow
|
||||||
|
>
|
||||||
|
<CustomAvatar
|
||||||
|
avatarUrl={attachment.creator.avatarUrl}
|
||||||
|
name={attachment.creator.name}
|
||||||
|
size="sm"
|
||||||
|
/>
|
||||||
|
</Tooltip>
|
||||||
|
)}
|
||||||
|
|
||||||
|
<Tooltip label={t("Download attachment")} withArrow>
|
||||||
|
<ActionIcon
|
||||||
|
component="a"
|
||||||
|
href={fileUrl}
|
||||||
|
download={attachment.fileName}
|
||||||
|
target="_blank"
|
||||||
|
rel="noopener noreferrer"
|
||||||
|
variant="subtle"
|
||||||
|
color="gray"
|
||||||
|
aria-label={t("Download {{name}}", { name: attachment.fileName })}
|
||||||
|
>
|
||||||
|
<IconDownload size={18} />
|
||||||
|
</ActionIcon>
|
||||||
|
</Tooltip>
|
||||||
|
</Group>
|
||||||
|
);
|
||||||
|
}
|
||||||
@@ -0,0 +1,25 @@
|
|||||||
|
import {
|
||||||
|
InfiniteData,
|
||||||
|
keepPreviousData,
|
||||||
|
useInfiniteQuery,
|
||||||
|
UseInfiniteQueryResult,
|
||||||
|
} from "@tanstack/react-query";
|
||||||
|
import { getPageAttachments } from "@/features/attachments/services/attachment-service.ts";
|
||||||
|
import { IPageAttachment } from "@/features/attachments/types/attachment.types.ts";
|
||||||
|
import { IPagination } from "@/lib/types.ts";
|
||||||
|
|
||||||
|
export function usePageAttachmentsQuery(
|
||||||
|
pageId: string,
|
||||||
|
search?: string,
|
||||||
|
): UseInfiniteQueryResult<InfiniteData<IPagination<IPageAttachment>, unknown>> {
|
||||||
|
return useInfiniteQuery({
|
||||||
|
queryKey: ["page-attachments", pageId, search],
|
||||||
|
queryFn: ({ pageParam }) =>
|
||||||
|
getPageAttachments(pageId, { cursor: pageParam, query: search }),
|
||||||
|
enabled: !!pageId,
|
||||||
|
gcTime: 0,
|
||||||
|
placeholderData: keepPreviousData,
|
||||||
|
initialPageParam: undefined,
|
||||||
|
getNextPageParam: (lastPage) => lastPage.meta?.nextCursor ?? undefined,
|
||||||
|
});
|
||||||
|
}
|
||||||
@@ -3,7 +3,17 @@ import loadImage from "blueimp-load-image";
|
|||||||
import {
|
import {
|
||||||
AvatarIconType,
|
AvatarIconType,
|
||||||
IAttachment,
|
IAttachment,
|
||||||
|
IPageAttachment,
|
||||||
} from "@/features/attachments/types/attachment.types.ts";
|
} from "@/features/attachments/types/attachment.types.ts";
|
||||||
|
import { IPagination, QueryParams } from "@/lib/types.ts";
|
||||||
|
|
||||||
|
export async function getPageAttachments(
|
||||||
|
pageId: string,
|
||||||
|
params?: QueryParams,
|
||||||
|
): Promise<IPagination<IPageAttachment>> {
|
||||||
|
const req = await api.post("/pages/attachments", { pageId, ...params });
|
||||||
|
return req.data;
|
||||||
|
}
|
||||||
|
|
||||||
async function compressAndResizeIcon(
|
async function compressAndResizeIcon(
|
||||||
file: File,
|
file: File,
|
||||||
|
|||||||
@@ -1,4 +1,5 @@
|
|||||||
export {
|
export {
|
||||||
|
getPageAttachments,
|
||||||
uploadIcon,
|
uploadIcon,
|
||||||
uploadUserAvatar,
|
uploadUserAvatar,
|
||||||
uploadSpaceIcon,
|
uploadSpaceIcon,
|
||||||
|
|||||||
@@ -15,6 +15,15 @@ export interface IAttachment {
|
|||||||
deletedAt: string | null;
|
deletedAt: string | null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export interface IPageAttachment extends IAttachment {
|
||||||
|
url: string;
|
||||||
|
creator: {
|
||||||
|
id: string;
|
||||||
|
name: string;
|
||||||
|
avatarUrl: string | null;
|
||||||
|
} | null;
|
||||||
|
}
|
||||||
|
|
||||||
export enum AvatarIconType {
|
export enum AvatarIconType {
|
||||||
AVATAR = "avatar",
|
AVATAR = "avatar",
|
||||||
SPACE_ICON = "space-icon",
|
SPACE_ICON = "space-icon",
|
||||||
|
|||||||
@@ -103,6 +103,7 @@ const CommentEditor = forwardRef(
|
|||||||
},
|
},
|
||||||
content: defaultContent,
|
content: defaultContent,
|
||||||
editable,
|
editable,
|
||||||
|
textDirection: "auto",
|
||||||
immediatelyRender: true,
|
immediatelyRender: true,
|
||||||
shouldRerenderOnTransaction: false,
|
shouldRerenderOnTransaction: false,
|
||||||
autofocus: (autofocus && "end") || false,
|
autofocus: (autofocus && "end") || false,
|
||||||
|
|||||||
@@ -1,15 +0,0 @@
|
|||||||
import { useParams } from "react-router-dom";
|
|
||||||
import { usePageQuery } from "@/features/page/queries/page-query.ts";
|
|
||||||
import { useGetSpaceBySlugQuery } from "@/features/space/queries/space-query.ts";
|
|
||||||
import { extractPageSlugId } from "@/lib";
|
|
||||||
|
|
||||||
export function useCanViewComments(): boolean {
|
|
||||||
const { pageSlug } = useParams();
|
|
||||||
const { data: page } = usePageQuery({ pageId: extractPageSlugId(pageSlug) });
|
|
||||||
const { data: space } = useGetSpaceBySlugQuery(page?.space?.slug);
|
|
||||||
|
|
||||||
const canEdit = !page?.deletedAt && (page?.permissions?.canEdit ?? false);
|
|
||||||
return (
|
|
||||||
canEdit || space?.settings?.comments?.hideCommentsFromViewers !== true
|
|
||||||
);
|
|
||||||
}
|
|
||||||
@@ -12,6 +12,7 @@ import {
|
|||||||
IconMathFunction,
|
IconMathFunction,
|
||||||
IconRotate2,
|
IconRotate2,
|
||||||
IconSitemap,
|
IconSitemap,
|
||||||
|
IconSuperscript,
|
||||||
IconTable,
|
IconTable,
|
||||||
IconTag,
|
IconTag,
|
||||||
} from "@tabler/icons-react";
|
} from "@tabler/icons-react";
|
||||||
@@ -270,6 +271,12 @@ export const MoreInsertsGroup: FC<Props> = ({ editor, templateMode }) => {
|
|||||||
>
|
>
|
||||||
{t("Math block")}
|
{t("Math block")}
|
||||||
</Menu.Item>
|
</Menu.Item>
|
||||||
|
<Menu.Item
|
||||||
|
leftSection={<IconSuperscript size={16} />}
|
||||||
|
onClick={() => editor.chain().focus().addFootnote().run()}
|
||||||
|
>
|
||||||
|
{t("Footnote")}
|
||||||
|
</Menu.Item>
|
||||||
</Menu.Dropdown>
|
</Menu.Dropdown>
|
||||||
</Menu>
|
</Menu>
|
||||||
);
|
);
|
||||||
|
|||||||
@@ -30,6 +30,7 @@ import {
|
|||||||
IconTag,
|
IconTag,
|
||||||
IconMoodSmile,
|
IconMoodSmile,
|
||||||
IconRotate2,
|
IconRotate2,
|
||||||
|
IconSuperscript,
|
||||||
} from "@tabler/icons-react";
|
} from "@tabler/icons-react";
|
||||||
import {
|
import {
|
||||||
CommandProps,
|
CommandProps,
|
||||||
@@ -177,6 +178,16 @@ const CommandGroups: SlashMenuGroupedItemsType = {
|
|||||||
command: ({ editor, range }: CommandProps) =>
|
command: ({ editor, range }: CommandProps) =>
|
||||||
editor.chain().focus().deleteRange(range).setPageBreak().run(),
|
editor.chain().focus().deleteRange(range).setPageBreak().run(),
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
title: "Footnote",
|
||||||
|
description: "Insert a footnote reference.",
|
||||||
|
searchTerms: ["footnote", "reference", "citation", "note"],
|
||||||
|
icon: IconSuperscript,
|
||||||
|
command: ({ editor, range }: CommandProps) => {
|
||||||
|
editor.chain().focus().deleteRange(range).run();
|
||||||
|
editor.commands.addFootnote();
|
||||||
|
},
|
||||||
|
},
|
||||||
{
|
{
|
||||||
title: "Image",
|
title: "Image",
|
||||||
description: "Upload any image from your device.",
|
description: "Upload any image from your device.",
|
||||||
|
|||||||
@@ -40,6 +40,7 @@ export default function TransclusionContent({ content }: Props) {
|
|||||||
<EditorProvider
|
<EditorProvider
|
||||||
editable={false}
|
editable={false}
|
||||||
immediatelyRender={true}
|
immediatelyRender={true}
|
||||||
|
textDirection="auto"
|
||||||
extensions={extensions}
|
extensions={extensions}
|
||||||
content={content as any}
|
content={content as any}
|
||||||
/>
|
/>
|
||||||
|
|||||||
@@ -1,5 +1,6 @@
|
|||||||
import { markInputRule } from "@tiptap/core";
|
import { markInputRule } from "@tiptap/core";
|
||||||
import { StarterKit } from "@tiptap/starter-kit";
|
import { StarterKit } from "@tiptap/starter-kit";
|
||||||
|
import { Document } from "@tiptap/extension-document";
|
||||||
import { Code } from "@tiptap/extension-code";
|
import { Code } from "@tiptap/extension-code";
|
||||||
import { TextAlign } from "@tiptap/extension-text-align";
|
import { TextAlign } from "@tiptap/extension-text-align";
|
||||||
import { TaskList, TaskItem } from "@tiptap/extension-list";
|
import { TaskList, TaskItem } from "@tiptap/extension-list";
|
||||||
@@ -63,6 +64,9 @@ import {
|
|||||||
TransclusionReference,
|
TransclusionReference,
|
||||||
TableView,
|
TableView,
|
||||||
BaseEmbed as BaseEmbedNode,
|
BaseEmbed as BaseEmbedNode,
|
||||||
|
Footnotes,
|
||||||
|
Footnote,
|
||||||
|
FootnoteReference,
|
||||||
} from "@docmost/editor-ext";
|
} from "@docmost/editor-ext";
|
||||||
import {
|
import {
|
||||||
randomElement,
|
randomElement,
|
||||||
@@ -132,6 +136,7 @@ lowlight.register("scala", scala);
|
|||||||
// @ts-ignore
|
// @ts-ignore
|
||||||
export const mainExtensions = [
|
export const mainExtensions = [
|
||||||
StarterKit.configure({
|
StarterKit.configure({
|
||||||
|
document: false,
|
||||||
heading: false,
|
heading: false,
|
||||||
undoRedo: false,
|
undoRedo: false,
|
||||||
link: false,
|
link: false,
|
||||||
@@ -143,6 +148,9 @@ export const mainExtensions = [
|
|||||||
codeBlock: false,
|
codeBlock: false,
|
||||||
code: false,
|
code: false,
|
||||||
}),
|
}),
|
||||||
|
Document.extend({
|
||||||
|
content: "block+ footnotes?",
|
||||||
|
}),
|
||||||
// Override TipTap's Code extension to fix the inline code input rule.
|
// Override TipTap's Code extension to fix the inline code input rule.
|
||||||
// The upstream regex /(^|[^`])`([^`]+)`(?!`)$/ captures the character
|
// The upstream regex /(^|[^`])`([^`]+)`(?!`)$/ captures the character
|
||||||
// before the opening backtick as part of the match, causing markInputRule
|
// before the opening backtick as part of the match, causing markInputRule
|
||||||
@@ -203,7 +211,8 @@ export const mainExtensions = [
|
|||||||
parentName === "tableCell" ||
|
parentName === "tableCell" ||
|
||||||
parentName === "tableHeader" ||
|
parentName === "tableHeader" ||
|
||||||
parentName === "callout" ||
|
parentName === "callout" ||
|
||||||
parentName === "blockquote"
|
parentName === "blockquote" ||
|
||||||
|
parentName === "footnote"
|
||||||
) {
|
) {
|
||||||
return i18n.t("Write...");
|
return i18n.t("Write...");
|
||||||
}
|
}
|
||||||
@@ -417,6 +426,9 @@ export const mainExtensions = [
|
|||||||
}).configure(),
|
}).configure(),
|
||||||
Columns,
|
Columns,
|
||||||
Column,
|
Column,
|
||||||
|
Footnotes,
|
||||||
|
Footnote,
|
||||||
|
FootnoteReference,
|
||||||
AutoJoiner.configure({
|
AutoJoiner.configure({
|
||||||
elementsToJoin: [],
|
elementsToJoin: [],
|
||||||
}),
|
}),
|
||||||
|
|||||||
@@ -82,8 +82,6 @@ import {
|
|||||||
getCollabSocket,
|
getCollabSocket,
|
||||||
releaseCollabSocket,
|
releaseCollabSocket,
|
||||||
} from "@/features/editor/collab-socket";
|
} from "@/features/editor/collab-socket";
|
||||||
import clsx from "clsx";
|
|
||||||
import { useCanViewComments } from "@/features/comment/hooks/use-can-view-comments.ts";
|
|
||||||
|
|
||||||
interface PageEditorProps {
|
interface PageEditorProps {
|
||||||
pageId: string;
|
pageId: string;
|
||||||
@@ -198,7 +196,6 @@ function CollabPageEditor({
|
|||||||
const { pageSlug } = useParams();
|
const { pageSlug } = useParams();
|
||||||
const slugId = extractPageSlugId(pageSlug);
|
const slugId = extractPageSlugId(pageSlug);
|
||||||
const currentPageEditMode = useAtomValue(currentPageEditModeAtom);
|
const currentPageEditMode = useAtomValue(currentPageEditModeAtom);
|
||||||
const canViewComments = useCanViewComments();
|
|
||||||
const canScroll = useCallback(
|
const canScroll = useCallback(
|
||||||
() => Boolean(isComponentMounted.current && editorRef.current),
|
() => Boolean(isComponentMounted.current && editorRef.current),
|
||||||
[isComponentMounted],
|
[isComponentMounted],
|
||||||
@@ -252,6 +249,7 @@ function CollabPageEditor({
|
|||||||
{
|
{
|
||||||
extensions,
|
extensions,
|
||||||
editable,
|
editable,
|
||||||
|
textDirection: "auto",
|
||||||
immediatelyRender: true,
|
immediatelyRender: true,
|
||||||
shouldRerenderOnTransaction: false,
|
shouldRerenderOnTransaction: false,
|
||||||
editorProps: {
|
editorProps: {
|
||||||
@@ -375,7 +373,6 @@ function CollabPageEditor({
|
|||||||
};
|
};
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
if (!canViewComments) return;
|
|
||||||
document.addEventListener("ACTIVE_COMMENT_EVENT", handleActiveCommentEvent);
|
document.addEventListener("ACTIVE_COMMENT_EVENT", handleActiveCommentEvent);
|
||||||
return () => {
|
return () => {
|
||||||
document.removeEventListener(
|
document.removeEventListener(
|
||||||
@@ -383,7 +380,7 @@ function CollabPageEditor({
|
|||||||
handleActiveCommentEvent,
|
handleActiveCommentEvent,
|
||||||
);
|
);
|
||||||
};
|
};
|
||||||
}, [canViewComments]);
|
}, []);
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
setActiveCommentId(null);
|
setActiveCommentId(null);
|
||||||
@@ -434,13 +431,7 @@ function CollabPageEditor({
|
|||||||
}
|
}
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<div
|
<div className="editor-container" style={{ position: "relative" }}>
|
||||||
className={clsx(
|
|
||||||
"editor-container",
|
|
||||||
!canViewComments && "comments-hidden",
|
|
||||||
)}
|
|
||||||
style={{ position: "relative" }}
|
|
||||||
>
|
|
||||||
<div ref={menuContainerRef}>
|
<div ref={menuContainerRef}>
|
||||||
<EditorContent editor={editor} />
|
<EditorContent editor={editor} />
|
||||||
|
|
||||||
@@ -490,21 +481,18 @@ function StaticPageEditor({
|
|||||||
content: any;
|
content: any;
|
||||||
ariaLabel: string;
|
ariaLabel: string;
|
||||||
}) {
|
}) {
|
||||||
const canViewComments = useCanViewComments();
|
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<div className={clsx(!canViewComments && "comments-hidden")}>
|
<EditorProvider
|
||||||
<EditorProvider
|
editable={false}
|
||||||
editable={false}
|
immediatelyRender={true}
|
||||||
immediatelyRender={true}
|
textDirection="auto"
|
||||||
extensions={mainExtensions}
|
extensions={mainExtensions}
|
||||||
content={content}
|
content={content}
|
||||||
editorProps={{
|
editorProps={{
|
||||||
attributes: {
|
attributes: {
|
||||||
"aria-label": ariaLabel,
|
"aria-label": ariaLabel,
|
||||||
},
|
},
|
||||||
}}
|
}}
|
||||||
/>
|
/>
|
||||||
</div>
|
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -85,6 +85,7 @@ export default function ReadonlyPageEditor({
|
|||||||
<EditorProvider
|
<EditorProvider
|
||||||
editable={false}
|
editable={false}
|
||||||
immediatelyRender={true}
|
immediatelyRender={true}
|
||||||
|
textDirection="auto"
|
||||||
extensions={titleExtensions}
|
extensions={titleExtensions}
|
||||||
content={title}
|
content={title}
|
||||||
></EditorProvider>
|
></EditorProvider>
|
||||||
@@ -93,6 +94,7 @@ export default function ReadonlyPageEditor({
|
|||||||
<EditorProvider
|
<EditorProvider
|
||||||
editable={false}
|
editable={false}
|
||||||
immediatelyRender={true}
|
immediatelyRender={true}
|
||||||
|
textDirection="auto"
|
||||||
extensions={extensions}
|
extensions={extensions}
|
||||||
content={content}
|
content={content}
|
||||||
onCreate={({ editor }) => {
|
onCreate={({ editor }) => {
|
||||||
|
|||||||
@@ -315,8 +315,3 @@
|
|||||||
height: 100%;
|
height: 100%;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
.comments-hidden .ProseMirror .comment-mark {
|
|
||||||
background: none;
|
|
||||||
border-bottom: none;
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -0,0 +1,26 @@
|
|||||||
|
.ProseMirror sup a.footnote-ref {
|
||||||
|
color: var(--mantine-primary-color-filled);
|
||||||
|
text-decoration: none;
|
||||||
|
cursor: pointer;
|
||||||
|
font-weight: 600;
|
||||||
|
}
|
||||||
|
|
||||||
|
.ProseMirror sup:has(a.footnote-ref) {
|
||||||
|
padding: 0 1px;
|
||||||
|
}
|
||||||
|
|
||||||
|
.ProseMirror ol.footnotes {
|
||||||
|
margin-top: 2rem;
|
||||||
|
padding-top: 0.75rem;
|
||||||
|
font-size: 0.875rem;
|
||||||
|
color: var(--mantine-color-dimmed);
|
||||||
|
list-style-type: decimal;
|
||||||
|
}
|
||||||
|
|
||||||
|
.ProseMirror ol.footnotes:has(li) {
|
||||||
|
border-top: 1px solid var(--mantine-color-default-border);
|
||||||
|
}
|
||||||
|
|
||||||
|
.ProseMirror ol.footnotes li p {
|
||||||
|
margin: 0.15rem 0;
|
||||||
|
}
|
||||||
@@ -18,3 +18,4 @@
|
|||||||
@import "./columns.css";
|
@import "./columns.css";
|
||||||
@import "./status.css";
|
@import "./status.css";
|
||||||
@import "./base-embed.css";
|
@import "./base-embed.css";
|
||||||
|
@import "./footnotes.css";
|
||||||
|
|||||||
@@ -54,7 +54,7 @@
|
|||||||
var(--mantine-color-dark-5)
|
var(--mantine-color-dark-5)
|
||||||
);
|
);
|
||||||
font-weight: bold;
|
font-weight: bold;
|
||||||
text-align: left;
|
text-align: start;
|
||||||
}
|
}
|
||||||
|
|
||||||
.column-resize-handle {
|
.column-resize-handle {
|
||||||
|
|||||||
@@ -86,6 +86,7 @@ export function TitleEditor({
|
|||||||
},
|
},
|
||||||
editable: editable,
|
editable: editable,
|
||||||
content: title,
|
content: title,
|
||||||
|
textDirection: "auto",
|
||||||
immediatelyRender: true,
|
immediatelyRender: true,
|
||||||
shouldRerenderOnTransaction: false,
|
shouldRerenderOnTransaction: false,
|
||||||
editorProps: {
|
editorProps: {
|
||||||
|
|||||||
@@ -6,4 +6,13 @@ export const activeHistoryPrevIdAtom = atom<string>("");
|
|||||||
export const highlightChangesAtom = atom<boolean>(true);
|
export const highlightChangesAtom = atom<boolean>(true);
|
||||||
|
|
||||||
export type DiffCounts = { added: number; deleted: number; total: number };
|
export type DiffCounts = { added: number; deleted: number; total: number };
|
||||||
export const diffCountsAtom = atom<DiffCounts | null>(null);
|
export const diffCountsAtom = atom<DiffCounts | null>(
|
||||||
|
null as DiffCounts | null,
|
||||||
|
);
|
||||||
|
|
||||||
|
export type ComparePair = { newerId: string; olderId: string };
|
||||||
|
export const compareModeAtom = atom<boolean>(false);
|
||||||
|
export const compareSelectionAtom = atom<string[]>([]);
|
||||||
|
export const comparePairAtom = atom<ComparePair | null>(
|
||||||
|
null as ComparePair | null,
|
||||||
|
);
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
.history {
|
.history {
|
||||||
display: block;
|
display: flex;
|
||||||
|
align-items: center;
|
||||||
width: 100%;
|
width: 100%;
|
||||||
padding: var(--mantine-spacing-md);
|
|
||||||
color: light-dark(var(--mantine-color-black), var(--mantine-color-dark-0));
|
color: light-dark(var(--mantine-color-black), var(--mantine-color-dark-0));
|
||||||
|
|
||||||
@mixin hover {
|
@mixin hover {
|
||||||
@@ -12,6 +12,28 @@
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
.historyButton {
|
||||||
|
flex: 1;
|
||||||
|
min-width: 0;
|
||||||
|
color: inherit;
|
||||||
|
}
|
||||||
|
|
||||||
|
.compareCheckbox {
|
||||||
|
padding-left: var(--mantine-spacing-xs);
|
||||||
|
}
|
||||||
|
|
||||||
|
.itemMenu {
|
||||||
|
opacity: 0;
|
||||||
|
margin-right: var(--mantine-spacing-xs);
|
||||||
|
}
|
||||||
|
|
||||||
|
.history:hover .itemMenu,
|
||||||
|
.history:focus-within .itemMenu,
|
||||||
|
.history.active .itemMenu,
|
||||||
|
.itemMenu[aria-expanded="true"] {
|
||||||
|
opacity: 1;
|
||||||
|
}
|
||||||
|
|
||||||
.historyEditor {
|
.historyEditor {
|
||||||
:global(.ProseMirror) {
|
:global(.ProseMirror) {
|
||||||
padding: 0 !important;
|
padding: 0 !important;
|
||||||
@@ -77,3 +99,8 @@
|
|||||||
flex: 1;
|
flex: 1;
|
||||||
padding: rem(16px) rem(40px);
|
padding: rem(16px) rem(40px);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
.compareBanner {
|
||||||
|
border-bottom: rem(1px) solid
|
||||||
|
light-dark(var(--mantine-color-gray-3), var(--mantine-color-dark-4));
|
||||||
|
}
|
||||||
|
|||||||
@@ -31,6 +31,7 @@ export function HistoryEditor({
|
|||||||
const editor = useEditor({
|
const editor = useEditor({
|
||||||
extensions: mainExtensions,
|
extensions: mainExtensions,
|
||||||
editable: false,
|
editable: false,
|
||||||
|
textDirection: "auto",
|
||||||
});
|
});
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
@@ -170,7 +171,6 @@ export function HistoryEditor({
|
|||||||
}
|
}
|
||||||
|
|
||||||
const total = addedCount + deletedCount;
|
const total = addedCount + deletedCount;
|
||||||
// @ts-ignore
|
|
||||||
setDiffCounts({ added: addedCount, deleted: deletedCount, total });
|
setDiffCounts({ added: addedCount, deleted: deletedCount, total });
|
||||||
|
|
||||||
editor.setOptions({
|
editor.setOptions({
|
||||||
|
|||||||
@@ -1,10 +1,21 @@
|
|||||||
import { Text, Group, UnstyledButton, Avatar, Tooltip } from "@mantine/core";
|
import {
|
||||||
|
Text,
|
||||||
|
Group,
|
||||||
|
UnstyledButton,
|
||||||
|
Avatar,
|
||||||
|
Tooltip,
|
||||||
|
ActionIcon,
|
||||||
|
Checkbox,
|
||||||
|
Menu,
|
||||||
|
} from "@mantine/core";
|
||||||
|
import { IconDots } from "@tabler/icons-react";
|
||||||
import { CustomAvatar } from "@/components/ui/custom-avatar.tsx";
|
import { CustomAvatar } from "@/components/ui/custom-avatar.tsx";
|
||||||
import { formattedDate } from "@/lib/time";
|
import { formattedDate } from "@/lib/time";
|
||||||
import classes from "./css/history.module.css";
|
import classes from "./css/history.module.css";
|
||||||
import clsx from "clsx";
|
import clsx from "clsx";
|
||||||
import { IPageHistory } from "@/features/page-history/types/page.types";
|
import { IPageHistory } from "@/features/page-history/types/page.types";
|
||||||
import { memo, useCallback } from "react";
|
import { memo, useCallback } from "react";
|
||||||
|
import { useTranslation } from "react-i18next";
|
||||||
|
|
||||||
const MAX_VISIBLE_AVATARS = 5;
|
const MAX_VISIBLE_AVATARS = 5;
|
||||||
|
|
||||||
@@ -15,6 +26,13 @@ interface HistoryItemProps {
|
|||||||
onHover?: (id: string, index: number) => void;
|
onHover?: (id: string, index: number) => void;
|
||||||
onHoverEnd?: () => void;
|
onHoverEnd?: () => void;
|
||||||
isActive: boolean;
|
isActive: boolean;
|
||||||
|
compareMode: boolean;
|
||||||
|
isChecked: boolean;
|
||||||
|
isCheckboxDisabled: boolean;
|
||||||
|
canCompare: boolean;
|
||||||
|
onToggleCompare: (id: string) => void;
|
||||||
|
onStartCompare: (id: string) => void;
|
||||||
|
onRestore?: (id: string, index: number) => void;
|
||||||
}
|
}
|
||||||
|
|
||||||
const HistoryItem = memo(function HistoryItem({
|
const HistoryItem = memo(function HistoryItem({
|
||||||
@@ -24,10 +42,24 @@ const HistoryItem = memo(function HistoryItem({
|
|||||||
onHover,
|
onHover,
|
||||||
onHoverEnd,
|
onHoverEnd,
|
||||||
isActive,
|
isActive,
|
||||||
|
compareMode,
|
||||||
|
isChecked,
|
||||||
|
isCheckboxDisabled,
|
||||||
|
canCompare,
|
||||||
|
onToggleCompare,
|
||||||
|
onStartCompare,
|
||||||
|
onRestore,
|
||||||
}: HistoryItemProps) {
|
}: HistoryItemProps) {
|
||||||
|
const { t } = useTranslation();
|
||||||
|
const date = formattedDate(new Date(historyItem.createdAt));
|
||||||
|
|
||||||
const handleClick = useCallback(() => {
|
const handleClick = useCallback(() => {
|
||||||
onSelect(historyItem.id, index);
|
if (compareMode) {
|
||||||
}, [onSelect, historyItem.id, index]);
|
onToggleCompare(historyItem.id);
|
||||||
|
} else {
|
||||||
|
onSelect(historyItem.id, index);
|
||||||
|
}
|
||||||
|
}, [compareMode, onToggleCompare, onSelect, historyItem.id, index]);
|
||||||
|
|
||||||
const handleMouseEnter = useCallback(() => {
|
const handleMouseEnter = useCallback(() => {
|
||||||
onHover?.(historyItem.id, index);
|
onHover?.(historyItem.id, index);
|
||||||
@@ -37,63 +69,115 @@ const HistoryItem = memo(function HistoryItem({
|
|||||||
const hasContributors = contributors && contributors.length > 0;
|
const hasContributors = contributors && contributors.length > 0;
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<UnstyledButton
|
<div
|
||||||
p="xs"
|
className={clsx(classes.history, { [classes.active]: isActive })}
|
||||||
onClick={handleClick}
|
|
||||||
onMouseEnter={handleMouseEnter}
|
onMouseEnter={handleMouseEnter}
|
||||||
onMouseLeave={onHoverEnd}
|
onMouseLeave={onHoverEnd}
|
||||||
className={clsx(classes.history, { [classes.active]: isActive })}
|
|
||||||
>
|
>
|
||||||
<Text size="sm">{formattedDate(new Date(historyItem.createdAt))}</Text>
|
{compareMode && (
|
||||||
|
<Checkbox
|
||||||
|
size="xs"
|
||||||
|
className={classes.compareCheckbox}
|
||||||
|
checked={isChecked}
|
||||||
|
disabled={isCheckboxDisabled}
|
||||||
|
onChange={() => onToggleCompare(historyItem.id)}
|
||||||
|
aria-label={t("Select version from {{date}}", { date })}
|
||||||
|
/>
|
||||||
|
)}
|
||||||
|
|
||||||
<Group gap={6} wrap="nowrap" mt={4}>
|
<UnstyledButton
|
||||||
{hasContributors ? (
|
p="xs"
|
||||||
<>
|
onClick={handleClick}
|
||||||
<Tooltip.Group openDelay={300} closeDelay={100}>
|
className={classes.historyButton}
|
||||||
<Avatar.Group spacing={8}>
|
>
|
||||||
{contributors.slice(0, MAX_VISIBLE_AVATARS).map((contributor) => (
|
<Text size="sm">{date}</Text>
|
||||||
<Tooltip key={contributor.id} label={contributor.name} withArrow>
|
|
||||||
<CustomAvatar
|
<Group gap={6} wrap="nowrap" mt={4}>
|
||||||
size="sm"
|
{hasContributors ? (
|
||||||
avatarUrl={contributor.avatarUrl}
|
<>
|
||||||
name={contributor.name}
|
<Tooltip.Group openDelay={300} closeDelay={100}>
|
||||||
/>
|
<Avatar.Group spacing={8}>
|
||||||
</Tooltip>
|
{contributors
|
||||||
))}
|
.slice(0, MAX_VISIBLE_AVATARS)
|
||||||
{contributors.length > MAX_VISIBLE_AVATARS && (
|
.map((contributor) => (
|
||||||
<Tooltip
|
<Tooltip
|
||||||
withArrow
|
key={contributor.id}
|
||||||
label={contributors.slice(MAX_VISIBLE_AVATARS).map((c) => (
|
label={contributor.name}
|
||||||
<div key={c.id}>{c.name}</div>
|
withArrow
|
||||||
|
>
|
||||||
|
<CustomAvatar
|
||||||
|
size="sm"
|
||||||
|
avatarUrl={contributor.avatarUrl}
|
||||||
|
name={contributor.name}
|
||||||
|
/>
|
||||||
|
</Tooltip>
|
||||||
))}
|
))}
|
||||||
>
|
{contributors.length > MAX_VISIBLE_AVATARS && (
|
||||||
<Avatar size="sm" color="gray">
|
<Tooltip
|
||||||
+{contributors.length - MAX_VISIBLE_AVATARS}
|
withArrow
|
||||||
</Avatar>
|
label={contributors
|
||||||
</Tooltip>
|
.slice(MAX_VISIBLE_AVATARS)
|
||||||
)}
|
.map((c) => (
|
||||||
</Avatar.Group>
|
<div key={c.id}>{c.name}</div>
|
||||||
</Tooltip.Group>
|
))}
|
||||||
{contributors.length === 1 && (
|
>
|
||||||
|
<Avatar size="sm" color="gray">
|
||||||
|
+{contributors.length - MAX_VISIBLE_AVATARS}
|
||||||
|
</Avatar>
|
||||||
|
</Tooltip>
|
||||||
|
)}
|
||||||
|
</Avatar.Group>
|
||||||
|
</Tooltip.Group>
|
||||||
|
{contributors.length === 1 && (
|
||||||
|
<Text size="sm" c="dimmed" lineClamp={1}>
|
||||||
|
{contributors[0].name}
|
||||||
|
</Text>
|
||||||
|
)}
|
||||||
|
</>
|
||||||
|
) : (
|
||||||
|
<>
|
||||||
|
<CustomAvatar
|
||||||
|
size="sm"
|
||||||
|
avatarUrl={historyItem.lastUpdatedBy?.avatarUrl}
|
||||||
|
name={historyItem.lastUpdatedBy?.name}
|
||||||
|
/>
|
||||||
<Text size="sm" c="dimmed" lineClamp={1}>
|
<Text size="sm" c="dimmed" lineClamp={1}>
|
||||||
{contributors[0].name}
|
{historyItem.lastUpdatedBy?.name}
|
||||||
</Text>
|
</Text>
|
||||||
|
</>
|
||||||
|
)}
|
||||||
|
</Group>
|
||||||
|
</UnstyledButton>
|
||||||
|
|
||||||
|
{!compareMode && (
|
||||||
|
<Menu shadow="md" width={180} position="bottom-end">
|
||||||
|
<Menu.Target>
|
||||||
|
<ActionIcon
|
||||||
|
variant="subtle"
|
||||||
|
color="gray"
|
||||||
|
className={classes.itemMenu}
|
||||||
|
aria-label={t("Version actions for {{date}}", { date })}
|
||||||
|
onClick={(e) => e.stopPropagation()}
|
||||||
|
>
|
||||||
|
<IconDots size={18} />
|
||||||
|
</ActionIcon>
|
||||||
|
</Menu.Target>
|
||||||
|
<Menu.Dropdown>
|
||||||
|
<Menu.Item
|
||||||
|
disabled={!canCompare}
|
||||||
|
onClick={() => onStartCompare(historyItem.id)}
|
||||||
|
>
|
||||||
|
{t("Compare")}
|
||||||
|
</Menu.Item>
|
||||||
|
{onRestore && (
|
||||||
|
<Menu.Item onClick={() => onRestore(historyItem.id, index)}>
|
||||||
|
{t("Restore")}
|
||||||
|
</Menu.Item>
|
||||||
)}
|
)}
|
||||||
</>
|
</Menu.Dropdown>
|
||||||
) : (
|
</Menu>
|
||||||
<>
|
)}
|
||||||
<CustomAvatar
|
</div>
|
||||||
size="sm"
|
|
||||||
avatarUrl={historyItem.lastUpdatedBy?.avatarUrl}
|
|
||||||
name={historyItem.lastUpdatedBy?.name}
|
|
||||||
/>
|
|
||||||
<Text size="sm" c="dimmed" lineClamp={1}>
|
|
||||||
{historyItem.lastUpdatedBy?.name}
|
|
||||||
</Text>
|
|
||||||
</>
|
|
||||||
)}
|
|
||||||
</Group>
|
|
||||||
</UnstyledButton>
|
|
||||||
);
|
);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|||||||
@@ -6,8 +6,12 @@ import HistoryItem from "@/features/page-history/components/history-item";
|
|||||||
import {
|
import {
|
||||||
activeHistoryIdAtom,
|
activeHistoryIdAtom,
|
||||||
activeHistoryPrevIdAtom,
|
activeHistoryPrevIdAtom,
|
||||||
|
compareModeAtom,
|
||||||
|
comparePairAtom,
|
||||||
|
compareSelectionAtom,
|
||||||
historyAtoms,
|
historyAtoms,
|
||||||
} from "@/features/page-history/atoms/history-atoms";
|
} from "@/features/page-history/atoms/history-atoms";
|
||||||
|
import { resolveComparePair } from "@/features/page-history/utils/resolve-compare-pair";
|
||||||
import { useAtom, useSetAtom } from "jotai";
|
import { useAtom, useSetAtom } from "jotai";
|
||||||
import { useCallback, useEffect, useMemo, useRef } from "react";
|
import { useCallback, useEffect, useMemo, useRef } from "react";
|
||||||
import {
|
import {
|
||||||
@@ -32,6 +36,9 @@ function HistoryList({ pageId }: Props) {
|
|||||||
const [activeHistoryId, setActiveHistoryId] = useAtom(activeHistoryIdAtom);
|
const [activeHistoryId, setActiveHistoryId] = useAtom(activeHistoryIdAtom);
|
||||||
const setActiveHistoryPrevId = useSetAtom(activeHistoryPrevIdAtom);
|
const setActiveHistoryPrevId = useSetAtom(activeHistoryPrevIdAtom);
|
||||||
const setHistoryModalOpen = useSetAtom(historyAtoms);
|
const setHistoryModalOpen = useSetAtom(historyAtoms);
|
||||||
|
const [compareMode, setCompareMode] = useAtom(compareModeAtom);
|
||||||
|
const [compareSelection, setCompareSelection] = useAtom(compareSelectionAtom);
|
||||||
|
const setComparePair = useSetAtom(comparePairAtom);
|
||||||
|
|
||||||
const {
|
const {
|
||||||
data: pageHistoryData,
|
data: pageHistoryData,
|
||||||
@@ -79,10 +86,58 @@ function HistoryList({ pageId }: Props) {
|
|||||||
|
|
||||||
const handleSelect = useCallback(
|
const handleSelect = useCallback(
|
||||||
(id: string, index: number) => {
|
(id: string, index: number) => {
|
||||||
|
setComparePair(null);
|
||||||
setActiveHistoryId(id);
|
setActiveHistoryId(id);
|
||||||
setActiveHistoryPrevId(historyItems[index + 1]?.id ?? "");
|
setActiveHistoryPrevId(historyItems[index + 1]?.id ?? "");
|
||||||
},
|
},
|
||||||
[historyItems, setActiveHistoryId, setActiveHistoryPrevId],
|
[historyItems, setActiveHistoryId, setActiveHistoryPrevId, setComparePair],
|
||||||
|
);
|
||||||
|
|
||||||
|
const handleToggleCompare = useCallback(
|
||||||
|
(id: string) => {
|
||||||
|
setCompareSelection((prev) => {
|
||||||
|
if (prev.includes(id)) return prev.filter((item) => item !== id);
|
||||||
|
if (prev.length >= 2) return prev;
|
||||||
|
return [...prev, id];
|
||||||
|
});
|
||||||
|
},
|
||||||
|
[setCompareSelection],
|
||||||
|
);
|
||||||
|
|
||||||
|
const handleStartCompare = useCallback(
|
||||||
|
(id: string) => {
|
||||||
|
setComparePair(null);
|
||||||
|
setCompareMode(true);
|
||||||
|
setCompareSelection([id]);
|
||||||
|
},
|
||||||
|
[setComparePair, setCompareMode, setCompareSelection],
|
||||||
|
);
|
||||||
|
|
||||||
|
const handleCancelCompare = useCallback(() => {
|
||||||
|
setCompareMode(false);
|
||||||
|
setCompareSelection([]);
|
||||||
|
}, [setCompareMode, setCompareSelection]);
|
||||||
|
|
||||||
|
const handleConfirmCompare = useCallback(() => {
|
||||||
|
const pair = resolveComparePair(historyItems, compareSelection);
|
||||||
|
if (!pair) return;
|
||||||
|
setComparePair(pair);
|
||||||
|
setCompareMode(false);
|
||||||
|
setCompareSelection([]);
|
||||||
|
}, [
|
||||||
|
historyItems,
|
||||||
|
compareSelection,
|
||||||
|
setComparePair,
|
||||||
|
setCompareMode,
|
||||||
|
setCompareSelection,
|
||||||
|
]);
|
||||||
|
|
||||||
|
const handleRestoreItem = useCallback(
|
||||||
|
(id: string, index: number) => {
|
||||||
|
handleSelect(id, index);
|
||||||
|
confirmRestore(id);
|
||||||
|
},
|
||||||
|
[handleSelect, confirmRestore],
|
||||||
);
|
);
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
@@ -138,6 +193,16 @@ function HistoryList({ pageId }: Props) {
|
|||||||
onHover={handleHover}
|
onHover={handleHover}
|
||||||
onHoverEnd={clearPrefetchTimeout}
|
onHoverEnd={clearPrefetchTimeout}
|
||||||
isActive={historyItem.id === activeHistoryId}
|
isActive={historyItem.id === activeHistoryId}
|
||||||
|
compareMode={compareMode}
|
||||||
|
isChecked={compareSelection.includes(historyItem.id)}
|
||||||
|
isCheckboxDisabled={
|
||||||
|
!compareSelection.includes(historyItem.id) &&
|
||||||
|
compareSelection.length >= 2
|
||||||
|
}
|
||||||
|
canCompare={historyItems.length >= 2}
|
||||||
|
onToggleCompare={handleToggleCompare}
|
||||||
|
onStartCompare={handleStartCompare}
|
||||||
|
onRestore={canRestore ? handleRestoreItem : undefined}
|
||||||
/>
|
/>
|
||||||
))}
|
))}
|
||||||
{hasNextPage && <div ref={loadMoreRef} style={{ height: 1 }} />}
|
{hasNextPage && <div ref={loadMoreRef} style={{ height: 1 }} />}
|
||||||
@@ -148,22 +213,44 @@ function HistoryList({ pageId }: Props) {
|
|||||||
)}
|
)}
|
||||||
</ScrollArea>
|
</ScrollArea>
|
||||||
|
|
||||||
{canRestore && (
|
{compareMode ? (
|
||||||
<>
|
<>
|
||||||
<Divider />
|
<Divider />
|
||||||
<Group p="xs" wrap="nowrap">
|
<Group p="xs" wrap="nowrap">
|
||||||
<Button
|
<Button
|
||||||
variant="default"
|
variant="default"
|
||||||
size="compact-md"
|
size="compact-md"
|
||||||
onClick={() => setHistoryModalOpen(false)}
|
onClick={handleCancelCompare}
|
||||||
>
|
>
|
||||||
{t("Cancel")}
|
{t("Cancel")}
|
||||||
</Button>
|
</Button>
|
||||||
<Button size="compact-md" onClick={confirmRestore}>
|
<Button
|
||||||
{t("Restore")}
|
size="compact-md"
|
||||||
|
disabled={compareSelection.length !== 2}
|
||||||
|
onClick={handleConfirmCompare}
|
||||||
|
>
|
||||||
|
{t("Compare")}
|
||||||
</Button>
|
</Button>
|
||||||
</Group>
|
</Group>
|
||||||
</>
|
</>
|
||||||
|
) : (
|
||||||
|
canRestore && (
|
||||||
|
<>
|
||||||
|
<Divider />
|
||||||
|
<Group p="xs" wrap="nowrap">
|
||||||
|
<Button
|
||||||
|
variant="default"
|
||||||
|
size="compact-md"
|
||||||
|
onClick={() => setHistoryModalOpen(false)}
|
||||||
|
>
|
||||||
|
{t("Cancel")}
|
||||||
|
</Button>
|
||||||
|
<Button size="compact-md" onClick={() => confirmRestore()}>
|
||||||
|
{t("Restore")}
|
||||||
|
</Button>
|
||||||
|
</Group>
|
||||||
|
</>
|
||||||
|
)
|
||||||
)}
|
)}
|
||||||
</div>
|
</div>
|
||||||
);
|
);
|
||||||
|
|||||||
@@ -1,5 +1,6 @@
|
|||||||
import {
|
import {
|
||||||
ActionIcon,
|
ActionIcon,
|
||||||
|
CloseButton,
|
||||||
Group,
|
Group,
|
||||||
Paper,
|
Paper,
|
||||||
ScrollArea,
|
ScrollArea,
|
||||||
@@ -12,17 +13,20 @@ import { useAtom, useAtomValue } from "jotai";
|
|||||||
import {
|
import {
|
||||||
activeHistoryIdAtom,
|
activeHistoryIdAtom,
|
||||||
activeHistoryPrevIdAtom,
|
activeHistoryPrevIdAtom,
|
||||||
|
comparePairAtom,
|
||||||
diffCountsAtom,
|
diffCountsAtom,
|
||||||
highlightChangesAtom,
|
highlightChangesAtom,
|
||||||
} from "@/features/page-history/atoms/history-atoms";
|
} from "@/features/page-history/atoms/history-atoms";
|
||||||
import HistoryView from "@/features/page-history/components/history-view";
|
import HistoryView from "@/features/page-history/components/history-view";
|
||||||
import { useRef } from "react";
|
import { useMemo, useRef } from "react";
|
||||||
import { IconChevronUp, IconChevronDown } from "@tabler/icons-react";
|
import { IconChevronUp, IconChevronDown } from "@tabler/icons-react";
|
||||||
import { useTranslation } from "react-i18next";
|
import { useTranslation } from "react-i18next";
|
||||||
import {
|
import {
|
||||||
useDiffNavigation,
|
useDiffNavigation,
|
||||||
useHistoryReset,
|
useHistoryReset,
|
||||||
} from "@/features/page-history/hooks";
|
} from "@/features/page-history/hooks";
|
||||||
|
import { usePageHistoryListQuery } from "@/features/page-history/queries/page-history-query";
|
||||||
|
import { formattedDate } from "@/lib/time";
|
||||||
|
|
||||||
interface Props {
|
interface Props {
|
||||||
pageId: string;
|
pageId: string;
|
||||||
@@ -36,6 +40,28 @@ export default function HistoryModalBody({ pageId }: Props) {
|
|||||||
const activeHistoryPrevId = useAtomValue(activeHistoryPrevIdAtom);
|
const activeHistoryPrevId = useAtomValue(activeHistoryPrevIdAtom);
|
||||||
const [highlightChanges, setHighlightChanges] = useAtom(highlightChangesAtom);
|
const [highlightChanges, setHighlightChanges] = useAtom(highlightChangesAtom);
|
||||||
const diffCounts = useAtomValue(diffCountsAtom);
|
const diffCounts = useAtomValue(diffCountsAtom);
|
||||||
|
const [comparePair, setComparePair] = useAtom(comparePairAtom);
|
||||||
|
|
||||||
|
const { data: pageHistoryData } = usePageHistoryListQuery(pageId);
|
||||||
|
const historyItems = useMemo(
|
||||||
|
() => pageHistoryData?.pages.flatMap((page) => page.items) ?? [],
|
||||||
|
[pageHistoryData],
|
||||||
|
);
|
||||||
|
|
||||||
|
const compareLabel = useMemo(() => {
|
||||||
|
if (!comparePair) return null;
|
||||||
|
const newerItem = historyItems.find(
|
||||||
|
(item) => item.id === comparePair.newerId,
|
||||||
|
);
|
||||||
|
const olderItem = historyItems.find(
|
||||||
|
(item) => item.id === comparePair.olderId,
|
||||||
|
);
|
||||||
|
if (!newerItem || !olderItem) return null;
|
||||||
|
return t("Comparing {{newer}} and {{older}}", {
|
||||||
|
newer: formattedDate(new Date(newerItem.createdAt)),
|
||||||
|
older: formattedDate(new Date(olderItem.createdAt)),
|
||||||
|
});
|
||||||
|
}, [comparePair, historyItems, t]);
|
||||||
|
|
||||||
useHistoryReset(pageId);
|
useHistoryReset(pageId);
|
||||||
const { currentChangeIndex, handlePrevChange, handleNextChange } =
|
const { currentChangeIndex, handlePrevChange, handleNextChange } =
|
||||||
@@ -50,6 +76,25 @@ export default function HistoryModalBody({ pageId }: Props) {
|
|||||||
</nav>
|
</nav>
|
||||||
|
|
||||||
<div style={{ position: "relative", flex: 1 }}>
|
<div style={{ position: "relative", flex: 1 }}>
|
||||||
|
{comparePair && (
|
||||||
|
<Group
|
||||||
|
justify="space-between"
|
||||||
|
wrap="nowrap"
|
||||||
|
px="md"
|
||||||
|
py={4}
|
||||||
|
className={classes.compareBanner}
|
||||||
|
>
|
||||||
|
<Text size="sm" fw={500} lineClamp={1}>
|
||||||
|
{compareLabel ?? t("Compare versions")}
|
||||||
|
</Text>
|
||||||
|
<CloseButton
|
||||||
|
size="sm"
|
||||||
|
aria-label={t("Exit compare")}
|
||||||
|
onClick={() => setComparePair(null)}
|
||||||
|
/>
|
||||||
|
</Group>
|
||||||
|
)}
|
||||||
|
|
||||||
<ScrollArea
|
<ScrollArea
|
||||||
h={650}
|
h={650}
|
||||||
w="100%"
|
w="100%"
|
||||||
@@ -57,11 +102,18 @@ export default function HistoryModalBody({ pageId }: Props) {
|
|||||||
viewportRef={scrollViewportRef}
|
viewportRef={scrollViewportRef}
|
||||||
>
|
>
|
||||||
<div className={classes.sidebarRightSection}>
|
<div className={classes.sidebarRightSection}>
|
||||||
{activeHistoryId && <HistoryView />}
|
{comparePair ? (
|
||||||
|
<HistoryView
|
||||||
|
historyId={comparePair.newerId}
|
||||||
|
prevHistoryId={comparePair.olderId}
|
||||||
|
/>
|
||||||
|
) : (
|
||||||
|
activeHistoryId && <HistoryView />
|
||||||
|
)}
|
||||||
</div>
|
</div>
|
||||||
</ScrollArea>
|
</ScrollArea>
|
||||||
|
|
||||||
{activeHistoryId && activeHistoryPrevId && (
|
{(comparePair || (activeHistoryId && activeHistoryPrevId)) && (
|
||||||
<Paper
|
<Paper
|
||||||
shadow="md"
|
shadow="md"
|
||||||
radius="xl"
|
radius="xl"
|
||||||
|
|||||||
@@ -166,7 +166,7 @@ export default function HistoryModalMobile({ pageId, pageTitle }: Props) {
|
|||||||
<Button variant="default" onClick={() => setHistoryModalOpen(false)}>
|
<Button variant="default" onClick={() => setHistoryModalOpen(false)}>
|
||||||
{t("Cancel")}
|
{t("Cancel")}
|
||||||
</Button>
|
</Button>
|
||||||
<Button onClick={confirmRestore}>{t("Restore")}</Button>
|
<Button onClick={() => confirmRestore()}>{t("Restore")}</Button>
|
||||||
</Group>
|
</Group>
|
||||||
)}
|
)}
|
||||||
|
|
||||||
|
|||||||
@@ -7,21 +7,29 @@ import {
|
|||||||
activeHistoryPrevIdAtom,
|
activeHistoryPrevIdAtom,
|
||||||
} from "@/features/page-history/atoms/history-atoms";
|
} from "@/features/page-history/atoms/history-atoms";
|
||||||
|
|
||||||
function HistoryView() {
|
interface Props {
|
||||||
|
historyId?: string;
|
||||||
|
prevHistoryId?: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
function HistoryView({ historyId, prevHistoryId }: Props) {
|
||||||
const { t } = useTranslation();
|
const { t } = useTranslation();
|
||||||
const historyId = useAtomValue(activeHistoryIdAtom);
|
const activeId = useAtomValue(activeHistoryIdAtom);
|
||||||
const prevHistoryId = useAtomValue(activeHistoryPrevIdAtom);
|
const activePrevId = useAtomValue(activeHistoryPrevIdAtom);
|
||||||
|
|
||||||
|
const resolvedId = historyId ?? activeId;
|
||||||
|
const resolvedPrevId = prevHistoryId ?? activePrevId;
|
||||||
|
|
||||||
const {
|
const {
|
||||||
data,
|
data,
|
||||||
isLoading: isLoadingCurrent,
|
isLoading: isLoadingCurrent,
|
||||||
isError: isErrorCurrent,
|
isError: isErrorCurrent,
|
||||||
} = usePageHistoryQuery(historyId);
|
} = usePageHistoryQuery(resolvedId);
|
||||||
const {
|
const {
|
||||||
data: prevData,
|
data: prevData,
|
||||||
isLoading: isLoadingPrev,
|
isLoading: isLoadingPrev,
|
||||||
isError: isErrorPrev,
|
isError: isErrorPrev,
|
||||||
} = usePageHistoryQuery(prevHistoryId);
|
} = usePageHistoryQuery(resolvedPrevId);
|
||||||
|
|
||||||
if (isLoadingCurrent || isLoadingPrev) {
|
if (isLoadingCurrent || isLoadingPrev) {
|
||||||
return <></>;
|
return <></>;
|
||||||
|
|||||||
@@ -3,22 +3,45 @@ import { useEffect } from "react";
|
|||||||
import {
|
import {
|
||||||
activeHistoryIdAtom,
|
activeHistoryIdAtom,
|
||||||
activeHistoryPrevIdAtom,
|
activeHistoryPrevIdAtom,
|
||||||
|
compareModeAtom,
|
||||||
|
comparePairAtom,
|
||||||
|
compareSelectionAtom,
|
||||||
diffCountsAtom,
|
diffCountsAtom,
|
||||||
} from "@/features/page-history/atoms/history-atoms";
|
} from "@/features/page-history/atoms/history-atoms";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Resets history state when pageId changes.
|
* Resets history state when pageId changes.
|
||||||
* Clears active selection and diff counts.
|
* Clears active selection, diff counts, and compare state.
|
||||||
|
* Compare state also resets on unmount so reopening the modal starts clean.
|
||||||
*/
|
*/
|
||||||
export function useHistoryReset(pageId: string) {
|
export function useHistoryReset(pageId: string) {
|
||||||
const [, setActiveHistoryId] = useAtom(activeHistoryIdAtom);
|
const [, setActiveHistoryId] = useAtom(activeHistoryIdAtom);
|
||||||
const [, setActiveHistoryPrevId] = useAtom(activeHistoryPrevIdAtom);
|
const [, setActiveHistoryPrevId] = useAtom(activeHistoryPrevIdAtom);
|
||||||
const [, setDiffCounts] = useAtom(diffCountsAtom);
|
const [, setDiffCounts] = useAtom(diffCountsAtom);
|
||||||
|
const [, setCompareMode] = useAtom(compareModeAtom);
|
||||||
|
const [, setCompareSelection] = useAtom(compareSelectionAtom);
|
||||||
|
const [, setComparePair] = useAtom(comparePairAtom);
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
|
const resetCompare = () => {
|
||||||
|
setCompareMode(false);
|
||||||
|
setCompareSelection([]);
|
||||||
|
setComparePair(null);
|
||||||
|
};
|
||||||
|
|
||||||
setActiveHistoryId("");
|
setActiveHistoryId("");
|
||||||
setActiveHistoryPrevId("");
|
setActiveHistoryPrevId("");
|
||||||
// @ts-ignore
|
|
||||||
setDiffCounts(null);
|
setDiffCounts(null);
|
||||||
}, [pageId, setActiveHistoryId, setActiveHistoryPrevId, setDiffCounts]);
|
resetCompare();
|
||||||
|
|
||||||
|
return resetCompare;
|
||||||
|
}, [
|
||||||
|
pageId,
|
||||||
|
setActiveHistoryId,
|
||||||
|
setActiveHistoryPrevId,
|
||||||
|
setDiffCounts,
|
||||||
|
setCompareMode,
|
||||||
|
setCompareSelection,
|
||||||
|
setComparePair,
|
||||||
|
]);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
import { useAtom, useAtomValue, useSetAtom } from "jotai";
|
import { useAtomValue, useSetAtom } from "jotai";
|
||||||
import { useCallback } from "react";
|
import { useCallback } from "react";
|
||||||
import { useTranslation } from "react-i18next";
|
import { useTranslation } from "react-i18next";
|
||||||
import { Text } from "@mantine/core";
|
import { Text } from "@mantine/core";
|
||||||
@@ -9,7 +9,8 @@ import {
|
|||||||
activeHistoryIdAtom,
|
activeHistoryIdAtom,
|
||||||
historyAtoms,
|
historyAtoms,
|
||||||
} from "@/features/page-history/atoms/history-atoms";
|
} from "@/features/page-history/atoms/history-atoms";
|
||||||
import { usePageHistoryQuery } from "@/features/page-history/queries/page-history-query";
|
import { fetchPageHistory } from "@/features/page-history/queries/page-history-query";
|
||||||
|
import { IPageHistory } from "@/features/page-history/types/page.types";
|
||||||
import {
|
import {
|
||||||
pageEditorAtom,
|
pageEditorAtom,
|
||||||
titleEditorAtom,
|
titleEditorAtom,
|
||||||
@@ -25,8 +26,6 @@ export function useHistoryRestore() {
|
|||||||
const { t } = useTranslation();
|
const { t } = useTranslation();
|
||||||
|
|
||||||
const activeHistoryId = useAtomValue(activeHistoryIdAtom);
|
const activeHistoryId = useAtomValue(activeHistoryIdAtom);
|
||||||
const { data: activeHistoryData } = usePageHistoryQuery(activeHistoryId);
|
|
||||||
|
|
||||||
const mainEditor = useAtomValue(pageEditorAtom);
|
const mainEditor = useAtomValue(pageEditorAtom);
|
||||||
const mainEditorTitle = useAtomValue(titleEditorAtom);
|
const mainEditorTitle = useAtomValue(titleEditorAtom);
|
||||||
const setHistoryModalOpen = useSetAtom(historyAtoms);
|
const setHistoryModalOpen = useSetAtom(historyAtoms);
|
||||||
@@ -40,47 +39,66 @@ export function useHistoryRestore() {
|
|||||||
SpaceCaslSubject.Page,
|
SpaceCaslSubject.Page,
|
||||||
);
|
);
|
||||||
|
|
||||||
const handleRestore = useCallback(() => {
|
const handleRestore = useCallback(
|
||||||
if (!activeHistoryData) return;
|
async (historyId: string) => {
|
||||||
if (
|
let historyData: IPageHistory;
|
||||||
!mainEditor ||
|
try {
|
||||||
mainEditor.isDestroyed ||
|
historyData = await fetchPageHistory(historyId);
|
||||||
!mainEditorTitle ||
|
} catch {
|
||||||
mainEditorTitle.isDestroyed
|
notifications.show({
|
||||||
) {
|
message: t("Error fetching page data."),
|
||||||
return;
|
color: "red",
|
||||||
}
|
});
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
mainEditorTitle
|
if (
|
||||||
.chain()
|
!mainEditor ||
|
||||||
.clearContent()
|
mainEditor.isDestroyed ||
|
||||||
.setContent(activeHistoryData.title, { emitUpdate: true })
|
!mainEditorTitle ||
|
||||||
.run();
|
mainEditorTitle.isDestroyed
|
||||||
|
) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
mainEditor
|
mainEditorTitle
|
||||||
.chain()
|
.chain()
|
||||||
.clearContent()
|
.clearContent()
|
||||||
.setContent(activeHistoryData.content)
|
.setContent(historyData.title, { emitUpdate: true })
|
||||||
.run();
|
.run();
|
||||||
|
|
||||||
setHistoryModalOpen(false);
|
mainEditor
|
||||||
notifications.show({ message: t("Successfully restored") });
|
.chain()
|
||||||
}, [activeHistoryData, mainEditor, mainEditorTitle, setHistoryModalOpen, t]);
|
.clearContent()
|
||||||
|
.setContent(historyData.content)
|
||||||
|
.run();
|
||||||
|
|
||||||
const confirmRestore = useCallback(() => {
|
setHistoryModalOpen(false);
|
||||||
modals.openConfirmModal({
|
notifications.show({ message: t("Successfully restored") });
|
||||||
title: t("Please confirm your action"),
|
},
|
||||||
children: (
|
[mainEditor, mainEditorTitle, setHistoryModalOpen, t],
|
||||||
<Text size="sm">
|
);
|
||||||
{t(
|
|
||||||
"Are you sure you want to restore this version? Any changes not versioned will be lost.",
|
const confirmRestore = useCallback(
|
||||||
)}
|
(historyId?: string) => {
|
||||||
</Text>
|
const targetId = historyId ?? activeHistoryId;
|
||||||
),
|
if (!targetId) return;
|
||||||
labels: { confirm: t("Confirm"), cancel: t("Cancel") },
|
|
||||||
onConfirm: handleRestore,
|
modals.openConfirmModal({
|
||||||
});
|
title: t("Please confirm your action"),
|
||||||
}, [t, handleRestore]);
|
children: (
|
||||||
|
<Text size="sm">
|
||||||
|
{t(
|
||||||
|
"Are you sure you want to restore this version? Any changes not versioned will be lost.",
|
||||||
|
)}
|
||||||
|
</Text>
|
||||||
|
),
|
||||||
|
labels: { confirm: t("Confirm"), cancel: t("Cancel") },
|
||||||
|
onConfirm: () => handleRestore(targetId),
|
||||||
|
});
|
||||||
|
},
|
||||||
|
[t, handleRestore, activeHistoryId],
|
||||||
|
);
|
||||||
|
|
||||||
return { canRestore, confirmRestore };
|
return { canRestore, confirmRestore };
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -23,6 +23,14 @@ export function prefetchPageHistory(historyId: string) {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export function fetchPageHistory(historyId: string): Promise<IPageHistory> {
|
||||||
|
return queryClient.fetchQuery({
|
||||||
|
queryKey: ["page-history", historyId],
|
||||||
|
queryFn: () => getPageHistoryById(historyId),
|
||||||
|
staleTime: HISTORY_STALE_TIME,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
export function usePageHistoryListQuery(
|
export function usePageHistoryListQuery(
|
||||||
pageId: string,
|
pageId: string,
|
||||||
): UseInfiniteQueryResult<InfiniteData<IPagination<IPageHistory>, unknown>> {
|
): UseInfiniteQueryResult<InfiniteData<IPagination<IPageHistory>, unknown>> {
|
||||||
|
|||||||
@@ -0,0 +1,32 @@
|
|||||||
|
import { describe, expect, it } from "vitest";
|
||||||
|
import { resolveComparePair } from "./resolve-compare-pair";
|
||||||
|
|
||||||
|
// list is newest-first, matching usePageHistoryListQuery order
|
||||||
|
const items = [{ id: "v3" }, { id: "v2" }, { id: "v1" }];
|
||||||
|
|
||||||
|
describe("resolveComparePair", () => {
|
||||||
|
it("orders newer before older regardless of selection order", () => {
|
||||||
|
expect(resolveComparePair(items, ["v1", "v3"])).toEqual({
|
||||||
|
newerId: "v3",
|
||||||
|
olderId: "v1",
|
||||||
|
});
|
||||||
|
expect(resolveComparePair(items, ["v3", "v1"])).toEqual({
|
||||||
|
newerId: "v3",
|
||||||
|
olderId: "v1",
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
it("returns null unless exactly two versions are selected", () => {
|
||||||
|
expect(resolveComparePair(items, [])).toBeNull();
|
||||||
|
expect(resolveComparePair(items, ["v1"])).toBeNull();
|
||||||
|
expect(resolveComparePair(items, ["v1", "v2", "v3"])).toBeNull();
|
||||||
|
});
|
||||||
|
|
||||||
|
it("returns null when a selected id is not in the list", () => {
|
||||||
|
expect(resolveComparePair(items, ["v1", "missing"])).toBeNull();
|
||||||
|
});
|
||||||
|
|
||||||
|
it("returns null when the same id is selected twice", () => {
|
||||||
|
expect(resolveComparePair(items, ["v2", "v2"])).toBeNull();
|
||||||
|
});
|
||||||
|
});
|
||||||
@@ -0,0 +1,18 @@
|
|||||||
|
import { ComparePair } from "@/features/page-history/atoms/history-atoms";
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Resolves which of the two selected versions is newer using their position
|
||||||
|
* in the history list (list is newest-first: lower index = newer).
|
||||||
|
*/
|
||||||
|
export function resolveComparePair(
|
||||||
|
historyItems: { id: string }[],
|
||||||
|
selection: string[],
|
||||||
|
): ComparePair | null {
|
||||||
|
if (selection.length !== 2) return null;
|
||||||
|
const indexA = historyItems.findIndex((item) => item.id === selection[0]);
|
||||||
|
const indexB = historyItems.findIndex((item) => item.id === selection[1]);
|
||||||
|
if (indexA === -1 || indexB === -1 || indexA === indexB) return null;
|
||||||
|
return indexA < indexB
|
||||||
|
? { newerId: selection[0], olderId: selection[1] }
|
||||||
|
: { newerId: selection[1], olderId: selection[0] };
|
||||||
|
}
|
||||||
@@ -11,6 +11,7 @@ import {
|
|||||||
IconList,
|
IconList,
|
||||||
IconMarkdown,
|
IconMarkdown,
|
||||||
IconMessage,
|
IconMessage,
|
||||||
|
IconPaperclip,
|
||||||
IconPrinter,
|
IconPrinter,
|
||||||
IconStar,
|
IconStar,
|
||||||
IconStarFilled,
|
IconStarFilled,
|
||||||
@@ -42,6 +43,7 @@ import {
|
|||||||
import { formattedDate } from "@/lib/time.ts";
|
import { formattedDate } from "@/lib/time.ts";
|
||||||
import { PageEditModeToggle } from "@/features/user/components/page-state-pref.tsx";
|
import { PageEditModeToggle } from "@/features/user/components/page-state-pref.tsx";
|
||||||
import MovePageModal from "@/features/page/components/move-page-modal.tsx";
|
import MovePageModal from "@/features/page/components/move-page-modal.tsx";
|
||||||
|
import PageAttachmentsModal from "@/features/attachments/components/page-attachments-modal.tsx";
|
||||||
import { useTimeAgo } from "@/hooks/use-time-ago.tsx";
|
import { useTimeAgo } from "@/hooks/use-time-ago.tsx";
|
||||||
import { PageShareModal } from "@/ee/page-permission";
|
import { PageShareModal } from "@/ee/page-permission";
|
||||||
import {
|
import {
|
||||||
@@ -58,7 +60,6 @@ import {
|
|||||||
useWatchPageMutation,
|
useWatchPageMutation,
|
||||||
useUnwatchPageMutation,
|
useUnwatchPageMutation,
|
||||||
} from "@/features/page/queries/watcher-query";
|
} from "@/features/page/queries/watcher-query";
|
||||||
import { useCanViewComments } from "@/features/comment/hooks/use-can-view-comments.ts";
|
|
||||||
|
|
||||||
interface PageHeaderMenuProps {
|
interface PageHeaderMenuProps {
|
||||||
readOnly?: boolean;
|
readOnly?: boolean;
|
||||||
@@ -66,7 +67,6 @@ interface PageHeaderMenuProps {
|
|||||||
export default function PageHeaderMenu({ readOnly }: PageHeaderMenuProps) {
|
export default function PageHeaderMenu({ readOnly }: PageHeaderMenuProps) {
|
||||||
const { t } = useTranslation();
|
const { t } = useTranslation();
|
||||||
const commentsTriggerProps = useAsideTriggerProps("comments");
|
const commentsTriggerProps = useAsideTriggerProps("comments");
|
||||||
const canViewComments = useCanViewComments();
|
|
||||||
const tocTriggerProps = useAsideTriggerProps("toc");
|
const tocTriggerProps = useAsideTriggerProps("toc");
|
||||||
const { pageSlug } = useParams();
|
const { pageSlug } = useParams();
|
||||||
const { data: page } = usePageQuery({
|
const { data: page } = usePageQuery({
|
||||||
@@ -107,18 +107,16 @@ export default function PageHeaderMenu({ readOnly }: PageHeaderMenuProps) {
|
|||||||
|
|
||||||
<PageShareModal readOnly={readOnly} />
|
<PageShareModal readOnly={readOnly} />
|
||||||
|
|
||||||
{canViewComments && (
|
<Tooltip label={t("Comments")} openDelay={250} withArrow>
|
||||||
<Tooltip label={t("Comments")} openDelay={250} withArrow>
|
<ActionIcon
|
||||||
<ActionIcon
|
variant="subtle"
|
||||||
variant="subtle"
|
color="dark"
|
||||||
color="dark"
|
aria-label={t("Comments")}
|
||||||
aria-label={t("Comments")}
|
{...commentsTriggerProps}
|
||||||
{...commentsTriggerProps}
|
>
|
||||||
>
|
<IconMessage size={20} stroke={2} />
|
||||||
<IconMessage size={20} stroke={2} />
|
</ActionIcon>
|
||||||
</ActionIcon>
|
</Tooltip>
|
||||||
</Tooltip>
|
|
||||||
)}
|
|
||||||
|
|
||||||
{!page?.isBase && (
|
{!page?.isBase && (
|
||||||
<Tooltip label={t("Table of contents")} openDelay={250} withArrow>
|
<Tooltip label={t("Table of contents")} openDelay={250} withArrow>
|
||||||
@@ -161,6 +159,10 @@ function PageActionMenu({ readOnly }: PageActionMenuProps) {
|
|||||||
verificationOpened,
|
verificationOpened,
|
||||||
{ open: openVerificationModal, close: closeVerificationModal },
|
{ open: openVerificationModal, close: closeVerificationModal },
|
||||||
] = useDisclosure(false);
|
] = useDisclosure(false);
|
||||||
|
const [
|
||||||
|
attachmentsOpened,
|
||||||
|
{ open: openAttachmentsModal, close: closeAttachmentsModal },
|
||||||
|
] = useDisclosure(false);
|
||||||
const [pageEditor] = useAtom(pageEditorAtom);
|
const [pageEditor] = useAtom(pageEditorAtom);
|
||||||
const pageUpdatedAt = useTimeAgo(page?.updatedAt);
|
const pageUpdatedAt = useTimeAgo(page?.updatedAt);
|
||||||
const favoriteIds = useFavoriteIds("page", page?.spaceId);
|
const favoriteIds = useFavoriteIds("page", page?.spaceId);
|
||||||
@@ -297,6 +299,15 @@ function PageActionMenu({ readOnly }: PageActionMenuProps) {
|
|||||||
</Menu.Item>
|
</Menu.Item>
|
||||||
)}
|
)}
|
||||||
|
|
||||||
|
{!page?.isBase && (
|
||||||
|
<Menu.Item
|
||||||
|
leftSection={<IconPaperclip size={16} />}
|
||||||
|
onClick={openAttachmentsModal}
|
||||||
|
>
|
||||||
|
{t("Attachments")}
|
||||||
|
</Menu.Item>
|
||||||
|
)}
|
||||||
|
|
||||||
{!readOnly && !page?.isBase && (
|
{!readOnly && !page?.isBase && (
|
||||||
<PageVerificationMenuItem
|
<PageVerificationMenuItem
|
||||||
pageId={page?.id}
|
pageId={page?.id}
|
||||||
@@ -399,6 +410,12 @@ function PageActionMenu({ readOnly }: PageActionMenuProps) {
|
|||||||
opened={verificationOpened}
|
opened={verificationOpened}
|
||||||
onClose={closeVerificationModal}
|
onClose={closeVerificationModal}
|
||||||
/>
|
/>
|
||||||
|
|
||||||
|
<PageAttachmentsModal
|
||||||
|
pageId={page.id}
|
||||||
|
open={attachmentsOpened}
|
||||||
|
onClose={closeAttachmentsModal}
|
||||||
|
/>
|
||||||
</>
|
</>
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -13,11 +13,16 @@ import { SearchResultItem } from "./search-result-item.tsx";
|
|||||||
import { AiSearchResult } from "../../../ee/ai/components/ai-search-result.tsx";
|
import { AiSearchResult } from "../../../ee/ai/components/ai-search-result.tsx";
|
||||||
import { useHasFeature } from "@/ee/hooks/use-feature";
|
import { useHasFeature } from "@/ee/hooks/use-feature";
|
||||||
import { Feature } from "@/ee/features";
|
import { Feature } from "@/ee/features";
|
||||||
|
import { useAtomValue } from "jotai";
|
||||||
|
import { workspaceAtom } from "@/features/user/atoms/current-user-atom.ts";
|
||||||
|
import { hintVectorCache } from "@/ee/ai/services/ai-search-service.ts";
|
||||||
|
import { getAiVectorDriver } from "@/lib/config.ts";
|
||||||
|
|
||||||
interface SearchSpotlightProps {
|
interface SearchSpotlightProps {
|
||||||
spaceId?: string;
|
spaceId?: string;
|
||||||
}
|
}
|
||||||
export function SearchSpotlight({ spaceId }: SearchSpotlightProps) {
|
export function SearchSpotlight({ spaceId }: SearchSpotlightProps) {
|
||||||
|
const workspace = useAtomValue(workspaceAtom);
|
||||||
const { t } = useTranslation();
|
const { t } = useTranslation();
|
||||||
const hasAiFeature = useHasFeature(Feature.AI);
|
const hasAiFeature = useHasFeature(Feature.AI);
|
||||||
const hasAttachmentIndexing = useHasFeature(Feature.ATTACHMENT_INDEXING);
|
const hasAttachmentIndexing = useHasFeature(Feature.ATTACHMENT_INDEXING);
|
||||||
@@ -96,6 +101,15 @@ export function SearchSpotlight({ spaceId }: SearchSpotlightProps) {
|
|||||||
/>
|
/>
|
||||||
));
|
));
|
||||||
|
|
||||||
|
const handleSpotlightOpen = () => {
|
||||||
|
if (
|
||||||
|
workspace?.settings?.ai?.search === true &&
|
||||||
|
getAiVectorDriver() === "turbopuffer"
|
||||||
|
) {
|
||||||
|
hintVectorCache();
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
const handleFiltersChange = (newFilters: any) => {
|
const handleFiltersChange = (newFilters: any) => {
|
||||||
setFilters(newFilters);
|
setFilters(newFilters);
|
||||||
};
|
};
|
||||||
@@ -115,6 +129,7 @@ export function SearchSpotlight({ spaceId }: SearchSpotlightProps) {
|
|||||||
<Spotlight.Root
|
<Spotlight.Root
|
||||||
size="xl"
|
size="xl"
|
||||||
maxHeight={600}
|
maxHeight={600}
|
||||||
|
onSpotlightOpen={handleSpotlightOpen}
|
||||||
store={searchSpotlightStore}
|
store={searchSpotlightStore}
|
||||||
query={query}
|
query={query}
|
||||||
onQueryChange={setQuery}
|
onQueryChange={setQuery}
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
import React, { useEffect, useState } from "react";
|
import React, { useEffect, useRef, useState } from "react";
|
||||||
import { useDebouncedValue } from "@mantine/hooks";
|
import { useDebouncedValue } from "@mantine/hooks";
|
||||||
import { Group, Select, SelectProps, Text } from "@mantine/core";
|
import { Group, Select, SelectProps, Text } from "@mantine/core";
|
||||||
import { useGetSpacesQuery } from "@/features/space/queries/space-query.ts";
|
import { useGetSpacesQuery } from "@/features/space/queries/space-query.ts";
|
||||||
@@ -14,6 +14,7 @@ interface SpaceSelectProps {
|
|||||||
width?: number;
|
width?: number;
|
||||||
opened?: boolean;
|
opened?: boolean;
|
||||||
clearable?: boolean;
|
clearable?: boolean;
|
||||||
|
withinPortal?: boolean;
|
||||||
}
|
}
|
||||||
|
|
||||||
const renderSelectOption: SelectProps["renderOption"] = ({ option }) => (
|
const renderSelectOption: SelectProps["renderOption"] = ({ option }) => (
|
||||||
@@ -41,6 +42,7 @@ export function SpaceSelect({
|
|||||||
width,
|
width,
|
||||||
opened,
|
opened,
|
||||||
clearable,
|
clearable,
|
||||||
|
withinPortal = true,
|
||||||
}: SpaceSelectProps) {
|
}: SpaceSelectProps) {
|
||||||
const { t } = useTranslation();
|
const { t } = useTranslation();
|
||||||
const [searchValue, setSearchValue] = useState("");
|
const [searchValue, setSearchValue] = useState("");
|
||||||
@@ -50,9 +52,13 @@ export function SpaceSelect({
|
|||||||
limit: 50,
|
limit: 50,
|
||||||
});
|
});
|
||||||
const [data, setData] = useState([]);
|
const [data, setData] = useState([]);
|
||||||
|
const fetchedSpaces = useRef(new Map<string, ISpace>());
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
if (spaces) {
|
if (spaces) {
|
||||||
|
spaces.items.forEach((space: ISpace) =>
|
||||||
|
fetchedSpaces.current.set(space.slug, space),
|
||||||
|
);
|
||||||
const spaceData = spaces?.items
|
const spaceData = spaces?.items
|
||||||
.filter((space: ISpace) => space.slug !== value)
|
.filter((space: ISpace) => space.slug !== value)
|
||||||
.map((space: ISpace) => {
|
.map((space: ISpace) => {
|
||||||
@@ -83,14 +89,19 @@ export function SpaceSelect({
|
|||||||
onSearchChange={setSearchValue}
|
onSearchChange={setSearchValue}
|
||||||
clearable={clearable}
|
clearable={clearable}
|
||||||
variant="filled"
|
variant="filled"
|
||||||
onChange={(slug) =>
|
onChange={(slug) => {
|
||||||
onChange(spaces.items?.find((item) => item.slug === slug))
|
// options accumulate across fetches; resolve against everything
|
||||||
}
|
// fetched, not just the latest query result
|
||||||
|
const space = slug && fetchedSpaces.current.get(slug);
|
||||||
|
if (space) {
|
||||||
|
onChange(space);
|
||||||
|
}
|
||||||
|
}}
|
||||||
onClick={(e) => e.stopPropagation()}
|
onClick={(e) => e.stopPropagation()}
|
||||||
nothingFoundMessage={t("No space found")}
|
nothingFoundMessage={t("No space found")}
|
||||||
limit={50}
|
limit={50}
|
||||||
checkIconPosition="right"
|
checkIconPosition="right"
|
||||||
comboboxProps={{ width, withinPortal: true, position: "bottom", keepMounted: false, dropdownPadding: 0 }}
|
comboboxProps={{ width, withinPortal, position: "bottom", keepMounted: false, dropdownPadding: 0 }}
|
||||||
dropdownOpened={opened}
|
dropdownOpened={opened}
|
||||||
/>
|
/>
|
||||||
);
|
);
|
||||||
|
|||||||
@@ -54,7 +54,9 @@ import {
|
|||||||
import { mobileSidebarAtom } from "@/components/layouts/global/hooks/atoms/sidebar-atom.ts";
|
import { mobileSidebarAtom } from "@/components/layouts/global/hooks/atoms/sidebar-atom.ts";
|
||||||
import { useToggleSidebar } from "@/components/layouts/global/hooks/hooks/use-toggle-sidebar.ts";
|
import { useToggleSidebar } from "@/components/layouts/global/hooks/hooks/use-toggle-sidebar.ts";
|
||||||
import { searchSpotlight } from "@/features/search/constants";
|
import { searchSpotlight } from "@/features/search/constants";
|
||||||
import TemplatePickerModal from "@/ee/template/components/template-picker-modal";
|
const TemplatePickerModal = React.lazy(
|
||||||
|
() => import("@/ee/template/components/template-picker-modal"),
|
||||||
|
);
|
||||||
import { useHasFeature } from "@/ee/hooks/use-feature";
|
import { useHasFeature } from "@/ee/hooks/use-feature";
|
||||||
import { useUpgradeLabel } from "@/ee/hooks/use-upgrade-label";
|
import { useUpgradeLabel } from "@/ee/hooks/use-upgrade-label";
|
||||||
import { Feature } from "@/ee/features";
|
import { Feature } from "@/ee/features";
|
||||||
@@ -406,11 +408,13 @@ function SpaceMenu({
|
|||||||
|
|
||||||
{hasTemplates && templatePickerOpened && (
|
{hasTemplates && templatePickerOpened && (
|
||||||
<ErrorBoundary fallbackRender={() => null}>
|
<ErrorBoundary fallbackRender={() => null}>
|
||||||
<TemplatePickerModal
|
<React.Suspense fallback={null}>
|
||||||
opened={templatePickerOpened}
|
<TemplatePickerModal
|
||||||
onClose={closeTemplatePicker}
|
opened={templatePickerOpened}
|
||||||
initialSpaceId={spaceId}
|
onClose={closeTemplatePicker}
|
||||||
/>
|
initialSpaceId={spaceId}
|
||||||
|
/>
|
||||||
|
</React.Suspense>
|
||||||
</ErrorBoundary>
|
</ErrorBoundary>
|
||||||
)}
|
)}
|
||||||
</>
|
</>
|
||||||
|
|||||||
@@ -70,6 +70,7 @@ export function SwitchSpace({
|
|||||||
onChange={(space) => handleSelect(space.slug)}
|
onChange={(space) => handleSelect(space.slug)}
|
||||||
width={300}
|
width={300}
|
||||||
opened={true}
|
opened={true}
|
||||||
|
withinPortal={false}
|
||||||
/>
|
/>
|
||||||
</Popover.Dropdown>
|
</Popover.Dropdown>
|
||||||
</Popover>
|
</Popover>
|
||||||
|
|||||||
@@ -4,7 +4,6 @@ import { useTranslation } from "react-i18next";
|
|||||||
import { ISpace } from "@/features/space/types/space.types.ts";
|
import { ISpace } from "@/features/space/types/space.types.ts";
|
||||||
import SpacePublicSharingToggle from "@/ee/security/components/space-public-sharing-toggle.tsx";
|
import SpacePublicSharingToggle from "@/ee/security/components/space-public-sharing-toggle.tsx";
|
||||||
import SpaceViewerCommentsToggle from "@/ee/security/components/space-viewer-comments-toggle.tsx";
|
import SpaceViewerCommentsToggle from "@/ee/security/components/space-viewer-comments-toggle.tsx";
|
||||||
import SpaceHideCommentsToggle from "@/ee/security/components/space-hide-comments-toggle.tsx";
|
|
||||||
|
|
||||||
type SpaceSecuritySettingsProps = {
|
type SpaceSecuritySettingsProps = {
|
||||||
space: ISpace;
|
space: ISpace;
|
||||||
@@ -30,10 +29,6 @@ export default function SpaceSecuritySettings({
|
|||||||
<Divider my="lg" />
|
<Divider my="lg" />
|
||||||
|
|
||||||
<SpaceViewerCommentsToggle space={space} />
|
<SpaceViewerCommentsToggle space={space} />
|
||||||
|
|
||||||
<Divider my="lg" />
|
|
||||||
|
|
||||||
<SpaceHideCommentsToggle space={space} />
|
|
||||||
</div>
|
</div>
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -11,7 +11,6 @@ export interface ISpaceSharingSettings {
|
|||||||
|
|
||||||
export interface ISpaceCommentsSettings {
|
export interface ISpaceCommentsSettings {
|
||||||
allowViewerComments?: boolean;
|
allowViewerComments?: boolean;
|
||||||
hideCommentsFromViewers?: boolean;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface ISpaceSettings {
|
export interface ISpaceSettings {
|
||||||
@@ -37,7 +36,6 @@ export interface ISpace {
|
|||||||
// for updates
|
// for updates
|
||||||
disablePublicSharing?: boolean;
|
disablePublicSharing?: boolean;
|
||||||
allowViewerComments?: boolean;
|
allowViewerComments?: boolean;
|
||||||
hideCommentsFromViewers?: boolean;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
interface IMembership {
|
interface IMembership {
|
||||||
|
|||||||
@@ -43,6 +43,10 @@ export function isCloud(): boolean {
|
|||||||
return castToBoolean(getConfigValue("CLOUD"));
|
return castToBoolean(getConfigValue("CLOUD"));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export function getAiVectorDriver(): string {
|
||||||
|
return getConfigValue("AI_VECTOR_DRIVER");
|
||||||
|
}
|
||||||
|
|
||||||
export function getAvatarUrl(
|
export function getAvatarUrl(
|
||||||
avatarUrl: string,
|
avatarUrl: string,
|
||||||
type: AvatarIconType = AvatarIconType.AVATAR,
|
type: AvatarIconType = AvatarIconType.AVATAR,
|
||||||
|
|||||||
@@ -16,6 +16,7 @@ export default defineConfig(({ mode }) => {
|
|||||||
BILLING_TRIAL_DAYS,
|
BILLING_TRIAL_DAYS,
|
||||||
POSTHOG_HOST,
|
POSTHOG_HOST,
|
||||||
POSTHOG_KEY,
|
POSTHOG_KEY,
|
||||||
|
AI_VECTOR_DRIVER,
|
||||||
} = loadEnv(mode, envPath, "");
|
} = loadEnv(mode, envPath, "");
|
||||||
|
|
||||||
return {
|
return {
|
||||||
@@ -31,6 +32,7 @@ export default defineConfig(({ mode }) => {
|
|||||||
BILLING_TRIAL_DAYS,
|
BILLING_TRIAL_DAYS,
|
||||||
POSTHOG_HOST,
|
POSTHOG_HOST,
|
||||||
POSTHOG_KEY,
|
POSTHOG_KEY,
|
||||||
|
AI_VECTOR_DRIVER,
|
||||||
},
|
},
|
||||||
APP_VERSION: JSON.stringify(process.env.npm_package_version),
|
APP_VERSION: JSON.stringify(process.env.npm_package_version),
|
||||||
},
|
},
|
||||||
|
|||||||
+11
-10
@@ -40,32 +40,33 @@
|
|||||||
"@clickhouse/client": "1.18.2",
|
"@clickhouse/client": "1.18.2",
|
||||||
"@docmost/base-formula": "workspace:*",
|
"@docmost/base-formula": "workspace:*",
|
||||||
"@docmost/pdf-inspector": "1.9.6",
|
"@docmost/pdf-inspector": "1.9.6",
|
||||||
"@fastify/cookie": "11.0.2",
|
"@fastify/cookie": "11.1.2",
|
||||||
"@fastify/multipart": "10.0.0",
|
"@fastify/multipart": "10.1.1",
|
||||||
"@fastify/static": "10.1.2",
|
"@fastify/static": "10.1.3",
|
||||||
"@keyv/redis": "5.1.6",
|
"@keyv/redis": "5.1.6",
|
||||||
"@langchain/core": "1.1.46",
|
"@langchain/core": "1.1.46",
|
||||||
"@langchain/textsplitters": "1.0.1",
|
"@langchain/textsplitters": "1.0.1",
|
||||||
"@modelcontextprotocol/sdk": "1.30.0",
|
"@modelcontextprotocol/sdk": "1.30.0",
|
||||||
"@nest-lab/throttler-storage-redis": "1.2.0",
|
"@nest-lab/throttler-storage-redis": "1.2.0",
|
||||||
"@nestjs-labs/nestjs-ioredis": "11.0.4",
|
"@nestjs-labs/nestjs-ioredis": "11.0.4",
|
||||||
"@nestjs/bullmq": "11.0.4",
|
"@nestjs/bullmq": "11.0.5",
|
||||||
"@nestjs/cache-manager": "3.1.3",
|
"@nestjs/cache-manager": "3.1.3",
|
||||||
"@nestjs/common": "11.1.28",
|
"@nestjs/common": "11.2.1",
|
||||||
"@nestjs/config": "4.0.4",
|
"@nestjs/config": "4.0.4",
|
||||||
"@nestjs/core": "11.1.27",
|
"@nestjs/core": "11.2.1",
|
||||||
"@nestjs/event-emitter": "3.1.0",
|
"@nestjs/event-emitter": "3.1.0",
|
||||||
"@nestjs/jwt": "11.0.2",
|
"@nestjs/jwt": "11.0.2",
|
||||||
"@nestjs/mapped-types": "2.1.1",
|
"@nestjs/mapped-types": "2.1.1",
|
||||||
"@nestjs/passport": "11.0.5",
|
"@nestjs/passport": "11.0.5",
|
||||||
"@nestjs/platform-fastify": "11.1.28",
|
"@nestjs/platform-fastify": "11.2.1",
|
||||||
"@nestjs/platform-socket.io": "11.1.28",
|
"@nestjs/platform-socket.io": "11.2.1",
|
||||||
"@nestjs/schedule": "6.1.3",
|
"@nestjs/schedule": "6.1.3",
|
||||||
"@nestjs/terminus": "11.1.1",
|
"@nestjs/terminus": "11.1.1",
|
||||||
"@nestjs/throttler": "6.5.0",
|
"@nestjs/throttler": "6.5.0",
|
||||||
"@nestjs/websockets": "11.1.28",
|
"@nestjs/websockets": "11.2.1",
|
||||||
"@node-saml/passport-saml": "5.1.0",
|
"@node-saml/passport-saml": "5.1.0",
|
||||||
"@socket.io/redis-adapter": "8.3.0",
|
"@socket.io/redis-adapter": "8.3.0",
|
||||||
|
"@turbopuffer/turbopuffer": "^2.8.0",
|
||||||
"ai": "6.0.134",
|
"ai": "6.0.134",
|
||||||
"ai-sdk-ollama": "3.8.1",
|
"ai-sdk-ollama": "3.8.1",
|
||||||
"bcrypt": "6.0.0",
|
"bcrypt": "6.0.0",
|
||||||
@@ -119,7 +120,7 @@
|
|||||||
"tmp-promise": "3.0.3",
|
"tmp-promise": "3.0.3",
|
||||||
"typesense": "3.0.5",
|
"typesense": "3.0.5",
|
||||||
"undici": "7.29.0",
|
"undici": "7.29.0",
|
||||||
"ws": "8.21.0",
|
"ws": "8.21.3",
|
||||||
"yauzl": "3.4.0",
|
"yauzl": "3.4.0",
|
||||||
"zod": "4.3.6"
|
"zod": "4.3.6"
|
||||||
},
|
},
|
||||||
|
|||||||
@@ -22,11 +22,13 @@ import { TelemetryModule } from './integrations/telemetry/telemetry.module';
|
|||||||
import { RedisModule } from '@nestjs-labs/nestjs-ioredis';
|
import { RedisModule } from '@nestjs-labs/nestjs-ioredis';
|
||||||
import { RedisConfigService } from './integrations/redis/redis-config.service';
|
import { RedisConfigService } from './integrations/redis/redis-config.service';
|
||||||
import { CacheModule } from '@nestjs/cache-manager';
|
import { CacheModule } from '@nestjs/cache-manager';
|
||||||
import KeyvRedis from '@keyv/redis';
|
import KeyvRedis, { defaultReconnectStrategy } from '@keyv/redis';
|
||||||
|
import { parseRedisUrl } from './common/helpers';
|
||||||
import { LoggerModule } from './common/logger/logger.module';
|
import { LoggerModule } from './common/logger/logger.module';
|
||||||
import { ClsModule } from 'nestjs-cls';
|
import { ClsModule } from 'nestjs-cls';
|
||||||
import { NoopAuditModule } from './integrations/audit/audit.module';
|
import { NoopAuditModule } from './integrations/audit/audit.module';
|
||||||
import { ThrottleModule } from './integrations/throttle/throttle.module';
|
import { ThrottleModule } from './integrations/throttle/throttle.module';
|
||||||
|
import { EncryptionModule } from './integrations/encryption/encryption.module';
|
||||||
|
|
||||||
const enterpriseModules = [];
|
const enterpriseModules = [];
|
||||||
try {
|
try {
|
||||||
@@ -53,6 +55,7 @@ try {
|
|||||||
CoreModule,
|
CoreModule,
|
||||||
DatabaseModule,
|
DatabaseModule,
|
||||||
EnvironmentModule,
|
EnvironmentModule,
|
||||||
|
EncryptionModule,
|
||||||
RedisModule.forRootAsync({
|
RedisModule.forRootAsync({
|
||||||
useClass: RedisConfigService,
|
useClass: RedisConfigService,
|
||||||
}),
|
}),
|
||||||
@@ -60,10 +63,20 @@ try {
|
|||||||
isGlobal: true,
|
isGlobal: true,
|
||||||
useFactory: async (environmentService: EnvironmentService) => {
|
useFactory: async (environmentService: EnvironmentService) => {
|
||||||
const redisUrl = environmentService.getRedisUrl();
|
const redisUrl = environmentService.getRedisUrl();
|
||||||
|
const { family, tls } = parseRedisUrl(redisUrl);
|
||||||
|
|
||||||
return {
|
return {
|
||||||
ttl: 5 * 1000,
|
ttl: 5 * 1000,
|
||||||
stores: [new KeyvRedis(redisUrl)],
|
stores: [
|
||||||
|
new KeyvRedis({
|
||||||
|
url: redisUrl,
|
||||||
|
socket: {
|
||||||
|
family,
|
||||||
|
reconnectStrategy: defaultReconnectStrategy,
|
||||||
|
...tls,
|
||||||
|
},
|
||||||
|
}),
|
||||||
|
],
|
||||||
};
|
};
|
||||||
},
|
},
|
||||||
inject: [EnvironmentService],
|
inject: [EnvironmentService],
|
||||||
|
|||||||
@@ -66,6 +66,7 @@ export class CollaborationGateway {
|
|||||||
password: this.redisConfig.password,
|
password: this.redisConfig.password,
|
||||||
db: this.redisConfig.db,
|
db: this.redisConfig.db,
|
||||||
family: this.redisConfig.family,
|
family: this.redisConfig.family,
|
||||||
|
tls: this.redisConfig.tls,
|
||||||
retryStrategy: createRetryStrategy(),
|
retryStrategy: createRetryStrategy(),
|
||||||
}),
|
}),
|
||||||
serverId: `collab-${os?.hostname()}-${nanoid(10)}`,
|
serverId: `collab-${os?.hostname()}-${nanoid(10)}`,
|
||||||
|
|||||||
@@ -1,4 +1,5 @@
|
|||||||
import { StarterKit } from '@tiptap/starter-kit';
|
import { StarterKit } from '@tiptap/starter-kit';
|
||||||
|
import { Document } from '@tiptap/extension-document';
|
||||||
import { TextAlign } from '@tiptap/extension-text-align';
|
import { TextAlign } from '@tiptap/extension-text-align';
|
||||||
import { Superscript } from '@tiptap/extension-superscript';
|
import { Superscript } from '@tiptap/extension-superscript';
|
||||||
import SubScript from '@tiptap/extension-subscript';
|
import SubScript from '@tiptap/extension-subscript';
|
||||||
@@ -45,9 +46,18 @@ import {
|
|||||||
TransclusionSource,
|
TransclusionSource,
|
||||||
TransclusionReference,
|
TransclusionReference,
|
||||||
BaseEmbed,
|
BaseEmbed,
|
||||||
|
Footnotes,
|
||||||
|
Footnote,
|
||||||
|
FootnoteReference,
|
||||||
} from '@docmost/editor-ext';
|
} from '@docmost/editor-ext';
|
||||||
import { generateText, getSchema, JSONContent } from '@tiptap/core';
|
import {
|
||||||
|
extensions as coreExtensions,
|
||||||
|
generateText,
|
||||||
|
getSchema,
|
||||||
|
JSONContent,
|
||||||
|
} from '@tiptap/core';
|
||||||
import { generateHTML, generateJSON } from '../common/helpers/prosemirror/html';
|
import { generateHTML, generateJSON } from '../common/helpers/prosemirror/html';
|
||||||
|
import { collapseBlankLines } from '../common/helpers';
|
||||||
// @tiptap/html library works best for generating prosemirror json state but not HTML
|
// @tiptap/html library works best for generating prosemirror json state but not HTML
|
||||||
// see: https://github.com/ueberdosis/tiptap/issues/5352
|
// see: https://github.com/ueberdosis/tiptap/issues/5352
|
||||||
// see:https://github.com/ueberdosis/tiptap/issues/4089
|
// see:https://github.com/ueberdosis/tiptap/issues/4089
|
||||||
@@ -57,12 +67,17 @@ import * as Y from 'yjs';
|
|||||||
import { Logger } from '@nestjs/common';
|
import { Logger } from '@nestjs/common';
|
||||||
|
|
||||||
export const tiptapExtensions = [
|
export const tiptapExtensions = [
|
||||||
|
coreExtensions.TextDirection.configure({ direction: 'auto' }),
|
||||||
StarterKit.configure({
|
StarterKit.configure({
|
||||||
|
document: false,
|
||||||
codeBlock: false,
|
codeBlock: false,
|
||||||
link: false,
|
link: false,
|
||||||
trailingNode: false,
|
trailingNode: false,
|
||||||
heading: false,
|
heading: false,
|
||||||
}),
|
}),
|
||||||
|
Document.extend({
|
||||||
|
content: 'block+ footnotes?',
|
||||||
|
}),
|
||||||
Heading,
|
Heading,
|
||||||
UniqueID.configure({
|
UniqueID.configure({
|
||||||
types: ['heading', 'paragraph', 'transclusionSource'],
|
types: ['heading', 'paragraph', 'transclusionSource'],
|
||||||
@@ -110,7 +125,10 @@ export const tiptapExtensions = [
|
|||||||
Status,
|
Status,
|
||||||
TransclusionSource,
|
TransclusionSource,
|
||||||
TransclusionReference,
|
TransclusionReference,
|
||||||
BaseEmbed
|
BaseEmbed,
|
||||||
|
Footnotes,
|
||||||
|
Footnote,
|
||||||
|
FootnoteReference,
|
||||||
] as any;
|
] as any;
|
||||||
|
|
||||||
export function jsonToHtml(tiptapJson: any) {
|
export function jsonToHtml(tiptapJson: any) {
|
||||||
@@ -129,7 +147,7 @@ export function htmlToJson(html: string) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export function jsonToText(tiptapJson: JSONContent) {
|
export function jsonToText(tiptapJson: JSONContent) {
|
||||||
return generateText(tiptapJson, tiptapExtensions);
|
return collapseBlankLines(generateText(tiptapJson, tiptapExtensions));
|
||||||
}
|
}
|
||||||
|
|
||||||
export function jsonToNode(tiptapJson: JSONContent) {
|
export function jsonToNode(tiptapJson: JSONContent) {
|
||||||
|
|||||||
@@ -18,7 +18,6 @@ export const Feature = {
|
|||||||
RETENTION: 'retention',
|
RETENTION: 'retention',
|
||||||
SHARING_CONTROLS: 'sharing:controls',
|
SHARING_CONTROLS: 'sharing:controls',
|
||||||
VIEWER_COMMENTS: 'comment:viewer',
|
VIEWER_COMMENTS: 'comment:viewer',
|
||||||
HIDE_COMMENTS: 'comment:hide',
|
|
||||||
TEMPLATES: 'templates',
|
TEMPLATES: 'templates',
|
||||||
PDF_EXPORT: 'export:pdf',
|
PDF_EXPORT: 'export:pdf',
|
||||||
PERSONAL_SPACES: 'spaces:personal',
|
PERSONAL_SPACES: 'spaces:personal',
|
||||||
|
|||||||
@@ -1,4 +1,5 @@
|
|||||||
export * from './utils';
|
export * from './utils';
|
||||||
|
export * from './text.utils';
|
||||||
export * from './nanoid.utils';
|
export * from './nanoid.utils';
|
||||||
export * from './file.helper';
|
export * from './file.helper';
|
||||||
export * from './constants';
|
export * from './constants';
|
||||||
|
|||||||
@@ -0,0 +1,14 @@
|
|||||||
|
import { collapseBlankLines } from './text.utils';
|
||||||
|
|
||||||
|
describe('collapseBlankLines', () => {
|
||||||
|
it.each([
|
||||||
|
['a\n\n\n\nb', 'a\n\nb'],
|
||||||
|
['a\n\nb', 'a\n\nb'],
|
||||||
|
['a\nb', 'a\nb'],
|
||||||
|
['\n\n\n\na\n\n\n', '\n\na\n\n'],
|
||||||
|
['no newlines', 'no newlines'],
|
||||||
|
['', ''],
|
||||||
|
])('collapses %j to %j', (input, expected) => {
|
||||||
|
expect(collapseBlankLines(input)).toBe(expected);
|
||||||
|
});
|
||||||
|
});
|
||||||
@@ -0,0 +1,3 @@
|
|||||||
|
export function collapseBlankLines(text: string): string {
|
||||||
|
return text.replace(/\n{2,}/g, '\n\n');
|
||||||
|
}
|
||||||
@@ -30,13 +30,14 @@ export type RedisConfig = {
|
|||||||
db: number;
|
db: number;
|
||||||
password?: string;
|
password?: string;
|
||||||
family?: number;
|
family?: number;
|
||||||
|
tls?: { rejectUnauthorized?: boolean };
|
||||||
};
|
};
|
||||||
|
|
||||||
export function parseRedisUrl(redisUrl: string): RedisConfig {
|
export function parseRedisUrl(redisUrl: string): RedisConfig {
|
||||||
// format - redis[s]://[[username][:password]@][host][:port][/db-number][?family=4|6]
|
// format - redis[s]://[[username][:password]@][host][:port][/db-number][?family=4|6][&rejectUnauthorized=false]
|
||||||
const url = new URL(redisUrl);
|
const url = new URL(redisUrl);
|
||||||
const { hostname, port, password, pathname, searchParams } = url;
|
const { hostname, port, password, pathname, protocol, searchParams } = url;
|
||||||
const portInt = parseInt(port, 10);
|
const portInt = port ? parseInt(port, 10) : 6379;
|
||||||
|
|
||||||
let db: number = 0;
|
let db: number = 0;
|
||||||
// extract db value if present
|
// extract db value if present
|
||||||
@@ -54,7 +55,14 @@ export function parseRedisUrl(redisUrl: string): RedisConfig {
|
|||||||
family = parseInt(familyParam, 10);
|
family = parseInt(familyParam, 10);
|
||||||
}
|
}
|
||||||
|
|
||||||
return { host: hostname, port: portInt, password, db, family };
|
const tls =
|
||||||
|
protocol === 'rediss:'
|
||||||
|
? searchParams.get('rejectUnauthorized') === 'false'
|
||||||
|
? { rejectUnauthorized: false }
|
||||||
|
: {}
|
||||||
|
: undefined;
|
||||||
|
|
||||||
|
return { host: hostname, port: portInt, password: password || undefined, db, family, tls };
|
||||||
}
|
}
|
||||||
|
|
||||||
export function createRetryStrategy() {
|
export function createRetryStrategy() {
|
||||||
|
|||||||
@@ -53,8 +53,14 @@ import { EnvironmentService } from '../../integrations/environment/environment.s
|
|||||||
import { TokenService } from '../auth/services/token.service';
|
import { TokenService } from '../auth/services/token.service';
|
||||||
import { JwtAttachmentPayload, JwtType } from '../auth/dto/jwt-payload';
|
import { JwtAttachmentPayload, JwtType } from '../auth/dto/jwt-payload';
|
||||||
import * as path from 'path';
|
import * as path from 'path';
|
||||||
import { AttachmentInfoDto, RemoveIconDto } from './dto/attachment.dto';
|
import {
|
||||||
|
AttachmentInfoDto,
|
||||||
|
PageIdDto,
|
||||||
|
RemoveIconDto,
|
||||||
|
} from './dto/attachment.dto';
|
||||||
|
import { PaginationOptions } from '@docmost/db/pagination/pagination-options';
|
||||||
import { PageAccessService } from '../page/page-access/page-access.service';
|
import { PageAccessService } from '../page/page-access/page-access.service';
|
||||||
|
import { DomainService } from '../../integrations/environment/domain.service';
|
||||||
import { AuditEvent, AuditResource } from '../../common/events/audit-events';
|
import { AuditEvent, AuditResource } from '../../common/events/audit-events';
|
||||||
import {
|
import {
|
||||||
AUDIT_SERVICE,
|
AUDIT_SERVICE,
|
||||||
@@ -75,6 +81,7 @@ export class AttachmentController {
|
|||||||
private readonly environmentService: EnvironmentService,
|
private readonly environmentService: EnvironmentService,
|
||||||
private readonly tokenService: TokenService,
|
private readonly tokenService: TokenService,
|
||||||
private readonly pageAccessService: PageAccessService,
|
private readonly pageAccessService: PageAccessService,
|
||||||
|
private readonly domainService: DomainService,
|
||||||
@Inject(AUDIT_SERVICE) private readonly auditService: IAuditService,
|
@Inject(AUDIT_SERVICE) private readonly auditService: IAuditService,
|
||||||
) {}
|
) {}
|
||||||
|
|
||||||
@@ -151,7 +158,10 @@ export class AttachmentController {
|
|||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
return res.send(fileResponse);
|
return res.send({
|
||||||
|
...fileResponse,
|
||||||
|
url: this.buildFileUrl(workspace, fileResponse),
|
||||||
|
});
|
||||||
} catch (err: any) {
|
} catch (err: any) {
|
||||||
if (err?.statusCode === 413) {
|
if (err?.statusCode === 413) {
|
||||||
const errMessage = `File too large. Exceeds the ${this.environmentService.getFileUploadSizeLimit()} limit`;
|
const errMessage = `File too large. Exceeds the ${this.environmentService.getFileUploadSizeLimit()} limit`;
|
||||||
@@ -411,7 +421,37 @@ export class AttachmentController {
|
|||||||
|
|
||||||
await this.pageAccessService.validateCanView(page, user);
|
await this.pageAccessService.validateCanView(page, user);
|
||||||
|
|
||||||
return attachment;
|
return { ...attachment, url: this.buildFileUrl(workspace, attachment) };
|
||||||
|
}
|
||||||
|
|
||||||
|
@UseGuards(JwtAuthGuard)
|
||||||
|
@HttpCode(HttpStatus.OK)
|
||||||
|
@Post('pages/attachments')
|
||||||
|
async getPageAttachments(
|
||||||
|
@Body() dto: PageIdDto,
|
||||||
|
@Body() pagination: PaginationOptions,
|
||||||
|
@AuthUser() user: User,
|
||||||
|
@AuthWorkspace() workspace: Workspace,
|
||||||
|
) {
|
||||||
|
const page = await this.pageRepo.findById(dto.pageId);
|
||||||
|
if (!page || page.workspaceId !== workspace.id) {
|
||||||
|
throw new NotFoundException('Page not found');
|
||||||
|
}
|
||||||
|
|
||||||
|
await this.pageAccessService.validateCanView(page, user);
|
||||||
|
|
||||||
|
const result = await this.attachmentRepo.findPageAttachments(
|
||||||
|
page.id,
|
||||||
|
pagination,
|
||||||
|
);
|
||||||
|
|
||||||
|
return {
|
||||||
|
...result,
|
||||||
|
items: result.items.map((attachment) => ({
|
||||||
|
...attachment,
|
||||||
|
url: this.buildFileUrl(workspace, attachment),
|
||||||
|
})),
|
||||||
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
@UseGuards(JwtAuthGuard)
|
@UseGuards(JwtAuthGuard)
|
||||||
@@ -465,6 +505,10 @@ export class AttachmentController {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private buildFileUrl(workspace: Workspace, attachment: Attachment): string {
|
||||||
|
return `${this.domainService.getUrl(workspace.hostname)}/api/files/${attachment.id}/${encodeURIComponent(attachment.fileName)}`;
|
||||||
|
}
|
||||||
|
|
||||||
private async sendFileResponse(
|
private async sendFileResponse(
|
||||||
req: FastifyRequest,
|
req: FastifyRequest,
|
||||||
res: FastifyReply,
|
res: FastifyReply,
|
||||||
|
|||||||
@@ -1,4 +1,11 @@
|
|||||||
import { IsEnum, IsIn, IsNotEmpty, IsOptional, IsUUID } from 'class-validator';
|
import {
|
||||||
|
IsEnum,
|
||||||
|
IsIn,
|
||||||
|
IsNotEmpty,
|
||||||
|
IsOptional,
|
||||||
|
IsString,
|
||||||
|
IsUUID,
|
||||||
|
} from 'class-validator';
|
||||||
import { AttachmentType } from '../attachment.constants';
|
import { AttachmentType } from '../attachment.constants';
|
||||||
|
|
||||||
export class AttachmentInfoDto {
|
export class AttachmentInfoDto {
|
||||||
@@ -7,6 +14,12 @@ export class AttachmentInfoDto {
|
|||||||
attachmentId: string;
|
attachmentId: string;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export class PageIdDto {
|
||||||
|
@IsString()
|
||||||
|
@IsNotEmpty()
|
||||||
|
pageId: string;
|
||||||
|
}
|
||||||
|
|
||||||
export class RemoveIconDto {
|
export class RemoveIconDto {
|
||||||
@IsEnum(AttachmentType)
|
@IsEnum(AttachmentType)
|
||||||
@IsIn([
|
@IsIn([
|
||||||
|
|||||||
@@ -89,29 +89,20 @@ export class CommentController {
|
|||||||
@Body()
|
@Body()
|
||||||
pagination: PaginationOptions,
|
pagination: PaginationOptions,
|
||||||
@AuthUser() user: User,
|
@AuthUser() user: User,
|
||||||
@AuthWorkspace() workspace: Workspace,
|
|
||||||
) {
|
) {
|
||||||
const page = await this.pageRepo.findById(input.pageId);
|
const page = await this.pageRepo.findById(input.pageId);
|
||||||
if (!page) {
|
if (!page) {
|
||||||
throw new NotFoundException('Page not found');
|
throw new NotFoundException('Page not found');
|
||||||
}
|
}
|
||||||
|
|
||||||
await this.pageAccessService.validateCanViewComments(
|
await this.pageAccessService.validateCanView(page, user);
|
||||||
page,
|
|
||||||
user,
|
|
||||||
workspace.id,
|
|
||||||
);
|
|
||||||
|
|
||||||
return this.commentService.findByPageId(page.id, pagination);
|
return this.commentService.findByPageId(page.id, pagination);
|
||||||
}
|
}
|
||||||
|
|
||||||
@HttpCode(HttpStatus.OK)
|
@HttpCode(HttpStatus.OK)
|
||||||
@Post('info')
|
@Post('info')
|
||||||
async findOne(
|
async findOne(@Body() input: CommentIdDto, @AuthUser() user: User) {
|
||||||
@Body() input: CommentIdDto,
|
|
||||||
@AuthUser() user: User,
|
|
||||||
@AuthWorkspace() workspace: Workspace,
|
|
||||||
) {
|
|
||||||
const comment = await this.commentRepo.findById(input.commentId);
|
const comment = await this.commentRepo.findById(input.commentId);
|
||||||
if (!comment) {
|
if (!comment) {
|
||||||
throw new NotFoundException('Comment not found');
|
throw new NotFoundException('Comment not found');
|
||||||
@@ -122,11 +113,7 @@ export class CommentController {
|
|||||||
throw new NotFoundException('Page not found');
|
throw new NotFoundException('Page not found');
|
||||||
}
|
}
|
||||||
|
|
||||||
await this.pageAccessService.validateCanViewComments(
|
await this.pageAccessService.validateCanView(page, user);
|
||||||
page,
|
|
||||||
user,
|
|
||||||
workspace.id,
|
|
||||||
);
|
|
||||||
|
|
||||||
return comment;
|
return comment;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -14,7 +14,6 @@ import { CommentMentionEmail } from '@docmost/transactional/emails/comment-menti
|
|||||||
import { CommentCreateEmail } from '@docmost/transactional/emails/comment-created-email';
|
import { CommentCreateEmail } from '@docmost/transactional/emails/comment-created-email';
|
||||||
import { CommentResolvedEmail } from '@docmost/transactional/emails/comment-resolved-email';
|
import { CommentResolvedEmail } from '@docmost/transactional/emails/comment-resolved-email';
|
||||||
import { getPageTitle } from '../../../common/helpers';
|
import { getPageTitle } from '../../../common/helpers';
|
||||||
import { PageAccessService } from '../../page/page-access/page-access.service';
|
|
||||||
|
|
||||||
@Injectable()
|
@Injectable()
|
||||||
export class CommentNotificationService {
|
export class CommentNotificationService {
|
||||||
@@ -26,7 +25,6 @@ export class CommentNotificationService {
|
|||||||
private readonly spaceMemberRepo: SpaceMemberRepo,
|
private readonly spaceMemberRepo: SpaceMemberRepo,
|
||||||
private readonly pagePermissionRepo: PagePermissionRepo,
|
private readonly pagePermissionRepo: PagePermissionRepo,
|
||||||
private readonly watcherRepo: WatcherRepo,
|
private readonly watcherRepo: WatcherRepo,
|
||||||
private readonly pageAccessService: PageAccessService,
|
|
||||||
) {}
|
) {}
|
||||||
|
|
||||||
async processComment(data: ICommentNotificationJob, appUrl: string) {
|
async processComment(data: ICommentNotificationJob, appUrl: string) {
|
||||||
@@ -50,7 +48,7 @@ export class CommentNotificationService {
|
|||||||
);
|
);
|
||||||
if (!context) return;
|
if (!context) return;
|
||||||
|
|
||||||
const { actor, pageTitle, pageUrl, spaceSettings } = context;
|
const { actor, pageTitle, pageUrl } = context;
|
||||||
const notifiedUserIds = new Set<string>();
|
const notifiedUserIds = new Set<string>();
|
||||||
notifiedUserIds.add(actorId);
|
notifiedUserIds.add(actorId);
|
||||||
|
|
||||||
@@ -74,16 +72,7 @@ export class CommentNotificationService {
|
|||||||
pageId,
|
pageId,
|
||||||
[...usersWithSpaceAccess],
|
[...usersWithSpaceAccess],
|
||||||
);
|
);
|
||||||
let accessibleUserIds = usersWithPageAccess;
|
const usersWithAccess = new Set(usersWithPageAccess);
|
||||||
if (spaceSettings?.comments?.hideCommentsFromViewers === true) {
|
|
||||||
accessibleUserIds =
|
|
||||||
await this.pageAccessService.filterUserIdsWithPageEditAccess(
|
|
||||||
spaceId,
|
|
||||||
pageId,
|
|
||||||
accessibleUserIds,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
const usersWithAccess = new Set(accessibleUserIds);
|
|
||||||
|
|
||||||
for (const userId of mentionedUserIds) {
|
for (const userId of mentionedUserIds) {
|
||||||
if (!usersWithAccess.has(userId)) continue;
|
if (!usersWithAccess.has(userId)) continue;
|
||||||
@@ -156,7 +145,7 @@ export class CommentNotificationService {
|
|||||||
);
|
);
|
||||||
if (!context) return;
|
if (!context) return;
|
||||||
|
|
||||||
const { actor, pageTitle, pageUrl, spaceSettings } = context;
|
const { actor, pageTitle, pageUrl } = context;
|
||||||
|
|
||||||
const roles = await this.spaceMemberRepo.getUserSpaceRoles(
|
const roles = await this.spaceMemberRepo.getUserSpaceRoles(
|
||||||
commentCreatorId,
|
commentCreatorId,
|
||||||
@@ -177,16 +166,6 @@ export class CommentNotificationService {
|
|||||||
);
|
);
|
||||||
if (hasPageAccess.length === 0) return;
|
if (hasPageAccess.length === 0) return;
|
||||||
|
|
||||||
if (spaceSettings?.comments?.hideCommentsFromViewers === true) {
|
|
||||||
const editCapable =
|
|
||||||
await this.pageAccessService.filterUserIdsWithPageEditAccess(
|
|
||||||
spaceId,
|
|
||||||
pageId,
|
|
||||||
[commentCreatorId],
|
|
||||||
);
|
|
||||||
if (editCapable.length === 0) return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const notification = await this.notificationService.create({
|
const notification = await this.notificationService.create({
|
||||||
userId: commentCreatorId,
|
userId: commentCreatorId,
|
||||||
workspaceId,
|
workspaceId,
|
||||||
@@ -246,7 +225,7 @@ export class CommentNotificationService {
|
|||||||
.executeTakeFirst(),
|
.executeTakeFirst(),
|
||||||
this.db
|
this.db
|
||||||
.selectFrom('spaces')
|
.selectFrom('spaces')
|
||||||
.select(['id', 'slug', 'settings'])
|
.select(['id', 'slug'])
|
||||||
.where('id', '=', spaceId)
|
.where('id', '=', spaceId)
|
||||||
.executeTakeFirst(),
|
.executeTakeFirst(),
|
||||||
]);
|
]);
|
||||||
@@ -257,11 +236,6 @@ export class CommentNotificationService {
|
|||||||
|
|
||||||
const pageUrl = `${appUrl}/s/${space.slug}/p/${page.slugId}`;
|
const pageUrl = `${appUrl}/s/${space.slug}/p/${page.slugId}`;
|
||||||
|
|
||||||
return {
|
return { actor, pageTitle: getPageTitle(page.title), pageUrl };
|
||||||
actor,
|
|
||||||
pageTitle: getPageTitle(page.title),
|
|
||||||
pageUrl,
|
|
||||||
spaceSettings: (space.settings ?? null) as Record<string, any> | null,
|
|
||||||
};
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -7,7 +7,6 @@ import {
|
|||||||
SpaceCaslSubject,
|
SpaceCaslSubject,
|
||||||
} from '../../casl/interfaces/space-ability.type';
|
} from '../../casl/interfaces/space-ability.type';
|
||||||
import { SpaceRepo } from '@docmost/db/repos/space/space.repo';
|
import { SpaceRepo } from '@docmost/db/repos/space/space.repo';
|
||||||
import { SpaceMemberRepo } from '@docmost/db/repos/space/space-member.repo';
|
|
||||||
|
|
||||||
@Injectable()
|
@Injectable()
|
||||||
export class PageAccessService {
|
export class PageAccessService {
|
||||||
@@ -15,7 +14,6 @@ export class PageAccessService {
|
|||||||
private readonly pagePermissionRepo: PagePermissionRepo,
|
private readonly pagePermissionRepo: PagePermissionRepo,
|
||||||
private readonly spaceAbility: SpaceAbilityFactory,
|
private readonly spaceAbility: SpaceAbilityFactory,
|
||||||
private readonly spaceRepo: SpaceRepo,
|
private readonly spaceRepo: SpaceRepo,
|
||||||
private readonly spaceMemberRepo: SpaceMemberRepo,
|
|
||||||
) {}
|
) {}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -120,68 +118,8 @@ export class PageAccessService {
|
|||||||
|
|
||||||
const space = await this.spaceRepo.findById(page.spaceId, workspaceId);
|
const space = await this.spaceRepo.findById(page.spaceId, workspaceId);
|
||||||
const settings = space?.settings as Record<string, any> | null;
|
const settings = space?.settings as Record<string, any> | null;
|
||||||
if (
|
if (!settings?.comments?.allowViewerComments) {
|
||||||
!settings?.comments?.allowViewerComments ||
|
|
||||||
settings?.comments?.hideCommentsFromViewers
|
|
||||||
) {
|
|
||||||
throw new ForbiddenException();
|
throw new ForbiddenException();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
async validateCanViewComments(
|
|
||||||
page: Page,
|
|
||||||
user: User,
|
|
||||||
workspaceId: string,
|
|
||||||
): Promise<void> {
|
|
||||||
const { canEdit } = await this.validateCanViewWithPermissions(page, user);
|
|
||||||
if (canEdit) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const space = await this.spaceRepo.findById(page.spaceId, workspaceId);
|
|
||||||
const settings = space?.settings as Record<string, any> | null;
|
|
||||||
if (settings?.comments?.hideCommentsFromViewers) {
|
|
||||||
throw new ForbiddenException();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Callers must pass userIds that already have space access (WS room members / pre-filtered notification recipients).
|
|
||||||
*/
|
|
||||||
async filterUserIdsWithPageEditAccess(
|
|
||||||
spaceId: string,
|
|
||||||
pageId: string,
|
|
||||||
userIds: string[],
|
|
||||||
): Promise<string[]> {
|
|
||||||
if (userIds.length === 0) {
|
|
||||||
return [];
|
|
||||||
}
|
|
||||||
|
|
||||||
const spaceHasRestrictedPages =
|
|
||||||
await this.pagePermissionRepo.hasRestrictedPagesInSpace(spaceId);
|
|
||||||
const hasRestriction =
|
|
||||||
spaceHasRestrictedPages &&
|
|
||||||
(await this.pagePermissionRepo.hasRestrictedAncestor(pageId));
|
|
||||||
|
|
||||||
if (!hasRestriction) {
|
|
||||||
const editCapableIds =
|
|
||||||
await this.spaceMemberRepo.getUserIdsWithSpaceEditAccess(
|
|
||||||
userIds,
|
|
||||||
spaceId,
|
|
||||||
);
|
|
||||||
return userIds.filter((id) => editCapableIds.has(id));
|
|
||||||
}
|
|
||||||
|
|
||||||
const results = await Promise.all(
|
|
||||||
userIds.map(async (userId) => {
|
|
||||||
const { canEdit } = await this.pagePermissionRepo.canUserEditPage(
|
|
||||||
userId,
|
|
||||||
pageId,
|
|
||||||
);
|
|
||||||
return canEdit ? userId : null;
|
|
||||||
}),
|
|
||||||
);
|
|
||||||
|
|
||||||
return results.filter((id): id is string => id !== null);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -496,10 +496,21 @@ export class PageService {
|
|||||||
},
|
},
|
||||||
);
|
);
|
||||||
|
|
||||||
await this.aiQueue.add(QueueJob.PAGE_MOVED_TO_SPACE, {
|
await this.aiQueue.add(
|
||||||
pageIds: pageIdsToMove,
|
QueueJob.PAGE_MOVED_TO_SPACE,
|
||||||
workspaceId: rootPage.workspaceId,
|
{
|
||||||
});
|
pageIds: pageIdsToMove,
|
||||||
|
spaceId,
|
||||||
|
workspaceId: rootPage.workspaceId,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
attempts: 2,
|
||||||
|
backoff: {
|
||||||
|
type: 'fixed',
|
||||||
|
delay: 2 * 60 * 1000,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
);
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|||||||
@@ -15,8 +15,4 @@ export class UpdateSpaceDto extends PartialType(CreateSpaceDto) {
|
|||||||
@IsOptional()
|
@IsOptional()
|
||||||
@IsBoolean()
|
@IsBoolean()
|
||||||
allowViewerComments: boolean;
|
allowViewerComments: boolean;
|
||||||
|
|
||||||
@IsOptional()
|
|
||||||
@IsBoolean()
|
|
||||||
hideCommentsFromViewers: boolean;
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -339,15 +339,25 @@ export class SpaceMemberService {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (spaceMember.role === SpaceRole.ADMIN) {
|
await executeTx(this.db, async (trx) => {
|
||||||
await this.validateLastAdmin(dto.spaceId);
|
await trx
|
||||||
}
|
.selectFrom('spaces')
|
||||||
|
.select('id')
|
||||||
|
.where('id', '=', dto.spaceId)
|
||||||
|
.forUpdate()
|
||||||
|
.executeTakeFirst();
|
||||||
|
|
||||||
await this.spaceMemberRepo.updateSpaceMember(
|
if (spaceMember.role === SpaceRole.ADMIN) {
|
||||||
{ role: dto.role },
|
await this.validateLastAdmin(dto.spaceId, trx);
|
||||||
spaceMember.id,
|
}
|
||||||
dto.spaceId,
|
|
||||||
);
|
await this.spaceMemberRepo.updateSpaceMember(
|
||||||
|
{ role: dto.role },
|
||||||
|
spaceMember.id,
|
||||||
|
dto.spaceId,
|
||||||
|
trx,
|
||||||
|
);
|
||||||
|
});
|
||||||
|
|
||||||
this.auditService.log({
|
this.auditService.log({
|
||||||
event: AuditEvent.SPACE_MEMBER_ROLE_CHANGED,
|
event: AuditEvent.SPACE_MEMBER_ROLE_CHANGED,
|
||||||
@@ -368,10 +378,14 @@ export class SpaceMemberService {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
async validateLastAdmin(spaceId: string): Promise<void> {
|
async validateLastAdmin(
|
||||||
|
spaceId: string,
|
||||||
|
trx?: KyselyTransaction,
|
||||||
|
): Promise<void> {
|
||||||
const spaceOwnerCount = await this.spaceMemberRepo.roleCountBySpaceId(
|
const spaceOwnerCount = await this.spaceMemberRepo.roleCountBySpaceId(
|
||||||
SpaceRole.ADMIN,
|
SpaceRole.ADMIN,
|
||||||
spaceId,
|
spaceId,
|
||||||
|
trx,
|
||||||
);
|
);
|
||||||
if (spaceOwnerCount === 1) {
|
if (spaceOwnerCount === 1) {
|
||||||
throw new BadRequestException(
|
throw new BadRequestException(
|
||||||
|
|||||||
@@ -30,35 +30,6 @@ import {
|
|||||||
IAuditService,
|
IAuditService,
|
||||||
} from '../../../integrations/audit/audit.service';
|
} from '../../../integrations/audit/audit.service';
|
||||||
|
|
||||||
export function validateExclusiveCommentSettings(
|
|
||||||
dto: Partial<
|
|
||||||
Pick<UpdateSpaceDto, 'allowViewerComments' | 'hideCommentsFromViewers'>
|
|
||||||
>,
|
|
||||||
settingsBefore: Record<string, any>,
|
|
||||||
): void {
|
|
||||||
if (
|
|
||||||
dto.allowViewerComments === undefined &&
|
|
||||||
dto.hideCommentsFromViewers === undefined
|
|
||||||
) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const allowViewerComments =
|
|
||||||
dto.allowViewerComments ??
|
|
||||||
settingsBefore.comments?.allowViewerComments ??
|
|
||||||
false;
|
|
||||||
const hideCommentsFromViewers =
|
|
||||||
dto.hideCommentsFromViewers ??
|
|
||||||
settingsBefore.comments?.hideCommentsFromViewers ??
|
|
||||||
false;
|
|
||||||
|
|
||||||
if (allowViewerComments && hideCommentsFromViewers) {
|
|
||||||
throw new BadRequestException(
|
|
||||||
"'Allow viewers to comment' and 'Hide comments from viewers' cannot both be enabled",
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Injectable()
|
@Injectable()
|
||||||
export class SpaceService {
|
export class SpaceService {
|
||||||
constructor(
|
constructor(
|
||||||
@@ -170,8 +141,7 @@ export class SpaceService {
|
|||||||
|
|
||||||
if (
|
if (
|
||||||
typeof updateSpaceDto.disablePublicSharing !== 'undefined' ||
|
typeof updateSpaceDto.disablePublicSharing !== 'undefined' ||
|
||||||
typeof updateSpaceDto.allowViewerComments !== 'undefined' ||
|
typeof updateSpaceDto.allowViewerComments !== 'undefined'
|
||||||
typeof updateSpaceDto.hideCommentsFromViewers !== 'undefined'
|
|
||||||
) {
|
) {
|
||||||
const workspace = await this.workspaceRepo.findById(workspaceId, {
|
const workspace = await this.workspaceRepo.findById(workspaceId, {
|
||||||
withLicenseKey: true,
|
withLicenseKey: true,
|
||||||
@@ -198,17 +168,6 @@ export class SpaceService {
|
|||||||
) {
|
) {
|
||||||
throw new ForbiddenException('This feature requires a valid license');
|
throw new ForbiddenException('This feature requires a valid license');
|
||||||
}
|
}
|
||||||
|
|
||||||
if (
|
|
||||||
updateSpaceDto.hideCommentsFromViewers === true &&
|
|
||||||
!this.licenseCheckService.hasFeature(
|
|
||||||
workspace.licenseKey,
|
|
||||||
Feature.HIDE_COMMENTS,
|
|
||||||
workspace.plan,
|
|
||||||
)
|
|
||||||
) {
|
|
||||||
throw new ForbiddenException('This feature requires a valid license');
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
const spaceBefore = await this.spaceRepo.findById(
|
const spaceBefore = await this.spaceRepo.findById(
|
||||||
@@ -217,8 +176,6 @@ export class SpaceService {
|
|||||||
);
|
);
|
||||||
const settingsBefore = (spaceBefore?.settings ?? {}) as Record<string, any>;
|
const settingsBefore = (spaceBefore?.settings ?? {}) as Record<string, any>;
|
||||||
|
|
||||||
validateExclusiveCommentSettings(updateSpaceDto, settingsBefore);
|
|
||||||
|
|
||||||
const before: Record<string, any> = {};
|
const before: Record<string, any> = {};
|
||||||
const after: Record<string, any> = {};
|
const after: Record<string, any> = {};
|
||||||
|
|
||||||
@@ -261,23 +218,6 @@ export class SpaceService {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (typeof updateSpaceDto.hideCommentsFromViewers !== 'undefined') {
|
|
||||||
const prev = settingsBefore?.comments?.hideCommentsFromViewers ?? false;
|
|
||||||
if (prev !== updateSpaceDto.hideCommentsFromViewers) {
|
|
||||||
before.hideCommentsFromViewers = prev;
|
|
||||||
after.hideCommentsFromViewers =
|
|
||||||
updateSpaceDto.hideCommentsFromViewers;
|
|
||||||
}
|
|
||||||
|
|
||||||
await this.spaceRepo.updateCommentSettings(
|
|
||||||
updateSpaceDto.spaceId,
|
|
||||||
workspaceId,
|
|
||||||
'hideCommentsFromViewers',
|
|
||||||
updateSpaceDto.hideCommentsFromViewers,
|
|
||||||
trx,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
updatedSpace = await this.spaceRepo.updateSpace(
|
updatedSpace = await this.spaceRepo.updateSpace(
|
||||||
{
|
{
|
||||||
name: updateSpaceDto.name,
|
name: updateSpaceDto.name,
|
||||||
|
|||||||
@@ -8,6 +8,7 @@ import { EnvironmentService } from '../../integrations/environment/environment.s
|
|||||||
|
|
||||||
export class SpaceEvent {
|
export class SpaceEvent {
|
||||||
spaceId: string;
|
spaceId: string;
|
||||||
|
workspaceId: string;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Injectable()
|
@Injectable()
|
||||||
@@ -22,12 +23,12 @@ export class SpaceListener {
|
|||||||
|
|
||||||
@OnEvent(EventName.SPACE_DELETED)
|
@OnEvent(EventName.SPACE_DELETED)
|
||||||
async handleSpaceDeleted(event: SpaceEvent) {
|
async handleSpaceDeleted(event: SpaceEvent) {
|
||||||
const { spaceId } = event;
|
const { spaceId, workspaceId } = event;
|
||||||
if (this.isTypesense()) {
|
if (this.isTypesense()) {
|
||||||
await this.searchQueue.add(QueueJob.SPACE_DELETED, { spaceId });
|
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 {
|
isTypesense(): boolean {
|
||||||
|
|||||||
@@ -1,5 +1,8 @@
|
|||||||
import { Injectable } from '@nestjs/common';
|
import { Injectable } from '@nestjs/common';
|
||||||
import { InjectKysely } from 'nestjs-kysely';
|
import { InjectKysely } from 'nestjs-kysely';
|
||||||
|
import { ExpressionBuilder, sql } from 'kysely';
|
||||||
|
import { jsonObjectFrom } from 'kysely/helpers/postgres';
|
||||||
|
import { DB } from '@docmost/db/types/db';
|
||||||
import { KyselyDB, KyselyTransaction } from '@docmost/db/types/kysely.types';
|
import { KyselyDB, KyselyTransaction } from '@docmost/db/types/kysely.types';
|
||||||
import { dbOrTx } from '@docmost/db/utils';
|
import { dbOrTx } from '@docmost/db/utils';
|
||||||
import {
|
import {
|
||||||
@@ -8,6 +11,8 @@ import {
|
|||||||
UpdatableAttachment,
|
UpdatableAttachment,
|
||||||
} from '@docmost/db/types/entity.types';
|
} from '@docmost/db/types/entity.types';
|
||||||
import { AttachmentType } from '../../../core/attachment/attachment.constants';
|
import { AttachmentType } from '../../../core/attachment/attachment.constants';
|
||||||
|
import { PaginationOptions } from '@docmost/db/pagination/pagination-options';
|
||||||
|
import { executeWithCursorPagination } from '@docmost/db/pagination/cursor-pagination';
|
||||||
|
|
||||||
@Injectable()
|
@Injectable()
|
||||||
export class AttachmentRepo {
|
export class AttachmentRepo {
|
||||||
@@ -89,6 +94,41 @@ export class AttachmentRepo {
|
|||||||
.execute();
|
.execute();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async findPageAttachments(pageId: string, pagination: PaginationOptions) {
|
||||||
|
let query = this.db
|
||||||
|
.selectFrom('attachments')
|
||||||
|
.select(this.baseFields)
|
||||||
|
.select((eb) => this.withCreator(eb))
|
||||||
|
.where('pageId', '=', pageId)
|
||||||
|
.where('type', '=', AttachmentType.File)
|
||||||
|
.where('deletedAt', 'is', null);
|
||||||
|
|
||||||
|
if (pagination.query) {
|
||||||
|
query = query.where(
|
||||||
|
sql`f_unaccent(file_name)`,
|
||||||
|
'ilike',
|
||||||
|
sql`f_unaccent(${'%' + pagination.query + '%'})`,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
return executeWithCursorPagination(query, {
|
||||||
|
perPage: pagination.limit,
|
||||||
|
cursor: pagination.cursor,
|
||||||
|
beforeCursor: pagination.beforeCursor,
|
||||||
|
fields: [{ expression: 'id', direction: 'desc' }],
|
||||||
|
parseCursor: (cursor) => ({ id: cursor.id }),
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
withCreator(eb: ExpressionBuilder<DB, 'attachments'>) {
|
||||||
|
return jsonObjectFrom(
|
||||||
|
eb
|
||||||
|
.selectFrom('users')
|
||||||
|
.select(['users.id', 'users.name', 'users.avatarUrl'])
|
||||||
|
.whereRef('users.id', '=', 'attachments.creatorId'),
|
||||||
|
).as('creator');
|
||||||
|
}
|
||||||
|
|
||||||
async findByIds(
|
async findByIds(
|
||||||
ids: string[],
|
ids: string[],
|
||||||
opts?: {
|
opts?: {
|
||||||
|
|||||||
@@ -20,7 +20,6 @@ import {
|
|||||||
CacheKey,
|
CacheKey,
|
||||||
PERMISSION_CACHE_TTL_MS,
|
PERMISSION_CACHE_TTL_MS,
|
||||||
} from '../../../common/helpers/cache-keys';
|
} from '../../../common/helpers/cache-keys';
|
||||||
import { SpaceRole } from '../../../common/helpers/types/permission';
|
|
||||||
|
|
||||||
@Injectable()
|
@Injectable()
|
||||||
export class SpaceMemberRepo {
|
export class SpaceMemberRepo {
|
||||||
@@ -47,8 +46,10 @@ export class SpaceMemberRepo {
|
|||||||
updatableSpaceMember: UpdatableSpaceMember,
|
updatableSpaceMember: UpdatableSpaceMember,
|
||||||
spaceMemberId: string,
|
spaceMemberId: string,
|
||||||
spaceId: string,
|
spaceId: string,
|
||||||
|
trx?: KyselyTransaction,
|
||||||
): Promise<void> {
|
): Promise<void> {
|
||||||
await this.db
|
const db = dbOrTx(this.db, trx);
|
||||||
|
await db
|
||||||
.updateTable('spaceMembers')
|
.updateTable('spaceMembers')
|
||||||
.set(updatableSpaceMember)
|
.set(updatableSpaceMember)
|
||||||
.where('id', '=', spaceMemberId)
|
.where('id', '=', spaceMemberId)
|
||||||
@@ -93,8 +94,13 @@ export class SpaceMemberRepo {
|
|||||||
.execute();
|
.execute();
|
||||||
}
|
}
|
||||||
|
|
||||||
async roleCountBySpaceId(role: string, spaceId: string): Promise<number> {
|
async roleCountBySpaceId(
|
||||||
const { count } = await this.db
|
role: string,
|
||||||
|
spaceId: string,
|
||||||
|
trx?: KyselyTransaction,
|
||||||
|
): Promise<number> {
|
||||||
|
const db = dbOrTx(this.db, trx);
|
||||||
|
const { count } = await db
|
||||||
.selectFrom('spaceMembers')
|
.selectFrom('spaceMembers')
|
||||||
.select((eb) => eb.fn.count('role').as('count'))
|
.select((eb) => eb.fn.count('role').as('count'))
|
||||||
.where('role', '=', role)
|
.where('role', '=', role)
|
||||||
@@ -279,32 +285,6 @@ export class SpaceMemberRepo {
|
|||||||
return new Set(rows.map((r) => r.userId));
|
return new Set(rows.map((r) => r.userId));
|
||||||
}
|
}
|
||||||
|
|
||||||
async getUserIdsWithSpaceEditAccess(
|
|
||||||
userIds: string[],
|
|
||||||
spaceId: string,
|
|
||||||
): Promise<Set<string>> {
|
|
||||||
if (userIds.length === 0) return new Set();
|
|
||||||
|
|
||||||
const rows = await this.db
|
|
||||||
.selectFrom('spaceMembers')
|
|
||||||
.select('userId')
|
|
||||||
.where('userId', 'in', userIds)
|
|
||||||
.where('spaceId', '=', spaceId)
|
|
||||||
.where('spaceMembers.role', 'in', [SpaceRole.ADMIN, SpaceRole.WRITER])
|
|
||||||
.unionAll(
|
|
||||||
this.db
|
|
||||||
.selectFrom('spaceMembers')
|
|
||||||
.innerJoin('groupUsers', 'groupUsers.groupId', 'spaceMembers.groupId')
|
|
||||||
.select('groupUsers.userId')
|
|
||||||
.where('groupUsers.userId', 'in', userIds)
|
|
||||||
.where('spaceMembers.spaceId', '=', spaceId)
|
|
||||||
.where('spaceMembers.role', 'in', [SpaceRole.ADMIN, SpaceRole.WRITER]),
|
|
||||||
)
|
|
||||||
.execute();
|
|
||||||
|
|
||||||
return new Set(rows.map((r) => r.userId));
|
|
||||||
}
|
|
||||||
|
|
||||||
async getSpaceIdsByGroupId(groupId: string): Promise<string[]> {
|
async getSpaceIdsByGroupId(groupId: string): Promise<string[]> {
|
||||||
const rows = await this.db
|
const rows = await this.db
|
||||||
.selectFrom('spaceMembers')
|
.selectFrom('spaceMembers')
|
||||||
|
|||||||
@@ -149,17 +149,6 @@ export class SpaceRepo {
|
|||||||
.executeTakeFirst();
|
.executeTakeFirst();
|
||||||
}
|
}
|
||||||
|
|
||||||
async getSpaceSettings(
|
|
||||||
spaceId: string,
|
|
||||||
): Promise<Record<string, any> | null> {
|
|
||||||
const row = await this.db
|
|
||||||
.selectFrom('spaces')
|
|
||||||
.select('settings')
|
|
||||||
.where('id', '=', spaceId)
|
|
||||||
.executeTakeFirst();
|
|
||||||
return (row?.settings as Record<string, any> | undefined) ?? null;
|
|
||||||
}
|
|
||||||
|
|
||||||
async insertSpace(
|
async insertSpace(
|
||||||
insertableSpace: InsertableSpace,
|
insertableSpace: InsertableSpace,
|
||||||
trx?: KyselyTransaction,
|
trx?: KyselyTransaction,
|
||||||
@@ -241,6 +230,7 @@ export class SpaceRepo {
|
|||||||
|
|
||||||
this.eventEmitter.emit(EventName.SPACE_DELETED, {
|
this.eventEmitter.emit(EventName.SPACE_DELETED, {
|
||||||
spaceId,
|
spaceId,
|
||||||
|
workspaceId,
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -211,6 +211,24 @@ export class WorkspaceRepo {
|
|||||||
.executeTakeFirst();
|
.executeTakeFirst();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async updateAiEmbeddingFingerprint(
|
||||||
|
workspaceId: string,
|
||||||
|
fingerprint: { driver: string; model: string; dimensions: number },
|
||||||
|
trx?: KyselyTransaction,
|
||||||
|
) {
|
||||||
|
const db = dbOrTx(this.db, trx);
|
||||||
|
return db
|
||||||
|
.updateTable('workspaces')
|
||||||
|
.set({
|
||||||
|
settings: sql`COALESCE(settings, '{}'::jsonb)
|
||||||
|
|| jsonb_build_object('ai', COALESCE(settings->'ai', '{}'::jsonb)
|
||||||
|
|| jsonb_build_object('embedding', ${JSON.stringify(fingerprint)}::text::jsonb))`,
|
||||||
|
updatedAt: new Date(),
|
||||||
|
})
|
||||||
|
.where('id', '=', workspaceId)
|
||||||
|
.execute();
|
||||||
|
}
|
||||||
|
|
||||||
async updateSharingSettings(
|
async updateSharingSettings(
|
||||||
workspaceId: string,
|
workspaceId: string,
|
||||||
prefKey: string,
|
prefKey: string,
|
||||||
|
|||||||
+1
-1
Submodule apps/server/src/ee updated: f396df9bc5...e13af0ce05
@@ -0,0 +1,13 @@
|
|||||||
|
export class UnableToInitialize extends Error {
|
||||||
|
constructor(message: string) {
|
||||||
|
super(`Unable to initialize the encryption service: ${message}`);
|
||||||
|
this.name = 'UnableToInitialize';
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
export class UnableToDecrypt extends Error {
|
||||||
|
constructor(reason: string) {
|
||||||
|
super(`Unable to decrypt the ciphertext: ${reason}`);
|
||||||
|
this.name = 'UnableToDecrypt';
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,9 @@
|
|||||||
|
import { Global, Module } from '@nestjs/common';
|
||||||
|
import { EncryptionService } from './encryption.service';
|
||||||
|
|
||||||
|
@Global()
|
||||||
|
@Module({
|
||||||
|
providers: [EncryptionService],
|
||||||
|
exports: [EncryptionService],
|
||||||
|
})
|
||||||
|
export class EncryptionModule {}
|
||||||
@@ -0,0 +1,184 @@
|
|||||||
|
import { Test, TestingModule } from '@nestjs/testing';
|
||||||
|
import { EncryptionService } from './encryption.service';
|
||||||
|
import { UnableToDecrypt, UnableToInitialize } from './encryption.errors';
|
||||||
|
import { EnvironmentService } from '../environment/environment.service';
|
||||||
|
|
||||||
|
const APP_SECRET = 'test-app-secret-with-plenty-of-entropy-1234567890';
|
||||||
|
|
||||||
|
const buildService = (appSecret: string | undefined) => {
|
||||||
|
const env = { getAppSecret: () => appSecret } as EnvironmentService;
|
||||||
|
return new EncryptionService(env);
|
||||||
|
};
|
||||||
|
|
||||||
|
const decodeEnvelope = (encrypted: string) =>
|
||||||
|
JSON.parse(Buffer.from(encrypted, 'base64').toString()) as {
|
||||||
|
iv: string;
|
||||||
|
authTag: string;
|
||||||
|
cipherText: string;
|
||||||
|
};
|
||||||
|
|
||||||
|
const encodeEnvelope = (envelope: {
|
||||||
|
iv: string;
|
||||||
|
authTag: string;
|
||||||
|
cipherText: string;
|
||||||
|
}) => Buffer.from(JSON.stringify(envelope)).toString('base64');
|
||||||
|
|
||||||
|
describe('EncryptionService', () => {
|
||||||
|
let service: EncryptionService;
|
||||||
|
|
||||||
|
beforeEach(async () => {
|
||||||
|
const module: TestingModule = await Test.createTestingModule({
|
||||||
|
providers: [
|
||||||
|
EncryptionService,
|
||||||
|
{
|
||||||
|
provide: EnvironmentService,
|
||||||
|
useValue: { getAppSecret: () => APP_SECRET },
|
||||||
|
},
|
||||||
|
],
|
||||||
|
}).compile();
|
||||||
|
|
||||||
|
service = module.get<EncryptionService>(EncryptionService);
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('initialization', () => {
|
||||||
|
it('compiles via Nest DI', () => {
|
||||||
|
expect(service).toBeDefined();
|
||||||
|
});
|
||||||
|
|
||||||
|
it('throws UnableToInitialize when APP_SECRET is missing', () => {
|
||||||
|
expect(() => buildService(undefined)).toThrow(UnableToInitialize);
|
||||||
|
expect(() => buildService('')).toThrow(UnableToInitialize);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('encrypt + decrypt round-trip', () => {
|
||||||
|
it('decrypts back to the original plaintext', () => {
|
||||||
|
const plaintext = 'hello world';
|
||||||
|
const encrypted = service.encrypt(plaintext);
|
||||||
|
expect(service.decrypt(encrypted)).toBe(plaintext);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('handles empty string', () => {
|
||||||
|
const encrypted = service.encrypt('');
|
||||||
|
expect(service.decrypt(encrypted)).toBe('');
|
||||||
|
});
|
||||||
|
|
||||||
|
it('handles unicode (multi-byte UTF-8)', () => {
|
||||||
|
const plaintext = 'héllo 🔐 世界';
|
||||||
|
const encrypted = service.encrypt(plaintext);
|
||||||
|
expect(service.decrypt(encrypted)).toBe(plaintext);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('handles long plaintext (>1 block)', () => {
|
||||||
|
const plaintext = 'a'.repeat(10_000);
|
||||||
|
const encrypted = service.encrypt(plaintext);
|
||||||
|
expect(service.decrypt(encrypted)).toBe(plaintext);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('produces distinct ciphertexts for the same plaintext (random IV)', () => {
|
||||||
|
const plaintext = 'same input';
|
||||||
|
const a = service.encrypt(plaintext);
|
||||||
|
const b = service.encrypt(plaintext);
|
||||||
|
expect(a).not.toBe(b);
|
||||||
|
expect(service.decrypt(a)).toBe(plaintext);
|
||||||
|
expect(service.decrypt(b)).toBe(plaintext);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('cross-key isolation', () => {
|
||||||
|
it('cannot decrypt ciphertext produced under a different APP_SECRET', () => {
|
||||||
|
const other = buildService('totally-different-secret-value-9876543210');
|
||||||
|
const encrypted = service.encrypt('secret');
|
||||||
|
expect(() => other.decrypt(encrypted)).toThrow(UnableToDecrypt);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('tamper detection', () => {
|
||||||
|
it('rejects modified ciphertext', () => {
|
||||||
|
const encrypted = service.encrypt('hello');
|
||||||
|
const env = decodeEnvelope(encrypted);
|
||||||
|
const tamperedCipher = Buffer.from(env.cipherText, 'base64');
|
||||||
|
tamperedCipher[0] ^= 0x01;
|
||||||
|
const tampered = encodeEnvelope({
|
||||||
|
...env,
|
||||||
|
cipherText: tamperedCipher.toString('base64'),
|
||||||
|
});
|
||||||
|
expect(() => service.decrypt(tampered)).toThrow(UnableToDecrypt);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('rejects modified auth tag', () => {
|
||||||
|
const encrypted = service.encrypt('hello');
|
||||||
|
const env = decodeEnvelope(encrypted);
|
||||||
|
const tamperedTag = Buffer.from(env.authTag, 'base64');
|
||||||
|
tamperedTag[0] ^= 0x01;
|
||||||
|
const tampered = encodeEnvelope({
|
||||||
|
...env,
|
||||||
|
authTag: tamperedTag.toString('base64'),
|
||||||
|
});
|
||||||
|
expect(() => service.decrypt(tampered)).toThrow(UnableToDecrypt);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('rejects modified IV', () => {
|
||||||
|
const encrypted = service.encrypt('hello');
|
||||||
|
const env = decodeEnvelope(encrypted);
|
||||||
|
const tamperedIV = Buffer.from(env.iv, 'base64');
|
||||||
|
tamperedIV[0] ^= 0x01;
|
||||||
|
const tampered = encodeEnvelope({
|
||||||
|
...env,
|
||||||
|
iv: tamperedIV.toString('base64'),
|
||||||
|
});
|
||||||
|
expect(() => service.decrypt(tampered)).toThrow(UnableToDecrypt);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('malformed payloads', () => {
|
||||||
|
it('rejects non-base64 garbage', () => {
|
||||||
|
expect(() => service.decrypt('!!!not-valid-base64!!!')).toThrow(
|
||||||
|
UnableToDecrypt,
|
||||||
|
);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('rejects base64 of non-JSON', () => {
|
||||||
|
const garbage = Buffer.from('not json at all').toString('base64');
|
||||||
|
expect(() => service.decrypt(garbage)).toThrow(UnableToDecrypt);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('rejects JSON missing required fields', () => {
|
||||||
|
const partial = encodeEnvelope({
|
||||||
|
iv: Buffer.alloc(12).toString('base64'),
|
||||||
|
authTag: Buffer.alloc(16).toString('base64'),
|
||||||
|
} as never);
|
||||||
|
expect(() => service.decrypt(partial)).toThrow(UnableToDecrypt);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('rejects wrong-length IV', () => {
|
||||||
|
const encrypted = service.encrypt('hello');
|
||||||
|
const env = decodeEnvelope(encrypted);
|
||||||
|
const bad = encodeEnvelope({
|
||||||
|
...env,
|
||||||
|
iv: Buffer.alloc(8).toString('base64'),
|
||||||
|
});
|
||||||
|
expect(() => service.decrypt(bad)).toThrow(UnableToDecrypt);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('rejects wrong-length auth tag', () => {
|
||||||
|
const encrypted = service.encrypt('hello');
|
||||||
|
const env = decodeEnvelope(encrypted);
|
||||||
|
const bad = encodeEnvelope({
|
||||||
|
...env,
|
||||||
|
authTag: Buffer.alloc(8).toString('base64'),
|
||||||
|
});
|
||||||
|
expect(() => service.decrypt(bad)).toThrow(UnableToDecrypt);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('envelope format', () => {
|
||||||
|
it('returns base64 of JSON envelope with iv (12B), authTag (16B), cipherText', () => {
|
||||||
|
const encrypted = service.encrypt('hello');
|
||||||
|
const env = decodeEnvelope(encrypted);
|
||||||
|
expect(Buffer.from(env.iv, 'base64')).toHaveLength(12);
|
||||||
|
expect(Buffer.from(env.authTag, 'base64')).toHaveLength(16);
|
||||||
|
expect(Buffer.from(env.cipherText, 'base64').length).toBeGreaterThan(0);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
});
|
||||||
@@ -0,0 +1,108 @@
|
|||||||
|
// https://github.com/nhedger/nestjs-encryption - MIT
|
||||||
|
import { Injectable } from '@nestjs/common';
|
||||||
|
import {
|
||||||
|
createCipheriv,
|
||||||
|
createDecipheriv,
|
||||||
|
createHash,
|
||||||
|
randomBytes,
|
||||||
|
} from 'node:crypto';
|
||||||
|
import { UnableToDecrypt, UnableToInitialize } from './encryption.errors';
|
||||||
|
import { EnvironmentService } from '../environment/environment.service';
|
||||||
|
|
||||||
|
const ALGORITHM = 'aes-256-gcm';
|
||||||
|
const KEY_DOMAIN = 'docmost:encryption:v1';
|
||||||
|
const IV_LENGTH = 12;
|
||||||
|
const AUTH_TAG_LENGTH = 16;
|
||||||
|
|
||||||
|
type AEADPayload<TFormat = string | Buffer> = {
|
||||||
|
iv: TFormat;
|
||||||
|
authTag: TFormat;
|
||||||
|
cipherText: TFormat;
|
||||||
|
};
|
||||||
|
|
||||||
|
@Injectable()
|
||||||
|
export class EncryptionService {
|
||||||
|
private readonly key: Buffer;
|
||||||
|
|
||||||
|
constructor(environmentService: EnvironmentService) {
|
||||||
|
const appSecret = environmentService.getAppSecret();
|
||||||
|
if (!appSecret) {
|
||||||
|
throw new UnableToInitialize('APP_SECRET is not set.');
|
||||||
|
}
|
||||||
|
this.key = createHash('sha256')
|
||||||
|
.update(KEY_DOMAIN)
|
||||||
|
.update(appSecret)
|
||||||
|
.digest();
|
||||||
|
}
|
||||||
|
|
||||||
|
public encrypt(plaintext: string): string {
|
||||||
|
const iv = randomBytes(IV_LENGTH);
|
||||||
|
const cipher = createCipheriv(ALGORITHM, this.key, iv);
|
||||||
|
const cipherText = Buffer.concat([
|
||||||
|
cipher.update(plaintext, 'utf8'),
|
||||||
|
cipher.final(),
|
||||||
|
]);
|
||||||
|
const authTag = cipher.getAuthTag();
|
||||||
|
|
||||||
|
const aead: AEADPayload<string> = {
|
||||||
|
iv: iv.toString('base64'),
|
||||||
|
authTag: authTag.toString('base64'),
|
||||||
|
cipherText: cipherText.toString('base64'),
|
||||||
|
};
|
||||||
|
|
||||||
|
return Buffer.from(JSON.stringify(aead)).toString('base64');
|
||||||
|
}
|
||||||
|
|
||||||
|
public decrypt(encrypted: string): string {
|
||||||
|
try {
|
||||||
|
const { iv, authTag, cipherText } = this.decodeAEADPayload(encrypted);
|
||||||
|
const decipher = createDecipheriv(ALGORITHM, this.key, iv);
|
||||||
|
decipher.setAuthTag(authTag);
|
||||||
|
const decrypted = Buffer.concat([
|
||||||
|
decipher.update(cipherText),
|
||||||
|
decipher.final(),
|
||||||
|
]);
|
||||||
|
return decrypted.toString('utf8');
|
||||||
|
} catch (e: unknown) {
|
||||||
|
throw new UnableToDecrypt((e as Error).message);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private decodeAEADPayload(encodedPayload: string): AEADPayload<Buffer> {
|
||||||
|
const payload = Buffer.from(encodedPayload, 'base64');
|
||||||
|
|
||||||
|
let deserializedPkg: Record<string, unknown>;
|
||||||
|
try {
|
||||||
|
deserializedPkg = JSON.parse(payload.toString());
|
||||||
|
} catch {
|
||||||
|
throw new Error('The decoded AEAD payload is not a valid JSON string.');
|
||||||
|
}
|
||||||
|
|
||||||
|
for (const field of ['iv', 'authTag', 'cipherText']) {
|
||||||
|
if (!Object.prototype.hasOwnProperty.call(deserializedPkg, field)) {
|
||||||
|
throw new Error(`The AEAD payload is missing the ${field} field.`);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
const iv = Buffer.from(deserializedPkg.iv as string, 'base64');
|
||||||
|
if (iv.length !== IV_LENGTH) {
|
||||||
|
throw new Error(
|
||||||
|
`The decoded IV is not the correct length. Expected ${IV_LENGTH} bytes, got ${iv.length} bytes.`,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
const authTag = Buffer.from(deserializedPkg.authTag as string, 'base64');
|
||||||
|
if (authTag.length !== AUTH_TAG_LENGTH) {
|
||||||
|
throw new Error(
|
||||||
|
`The decoded auth tag is not the correct length. Expected ${AUTH_TAG_LENGTH} bytes, got ${authTag.length} bytes.`,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
const cipherText = Buffer.from(
|
||||||
|
deserializedPkg.cipherText as string,
|
||||||
|
'base64',
|
||||||
|
);
|
||||||
|
|
||||||
|
return { iv, authTag, cipherText };
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -310,6 +310,31 @@ export class EnvironmentService {
|
|||||||
return val === 'true';
|
return val === 'true';
|
||||||
}
|
}
|
||||||
|
|
||||||
|
getAiVectorDriver(): string {
|
||||||
|
return this.configService
|
||||||
|
.get<string>('AI_VECTOR_DRIVER', 'pgvector')
|
||||||
|
.toLowerCase();
|
||||||
|
}
|
||||||
|
|
||||||
|
getTurbopufferApiKey(): string {
|
||||||
|
return this.configService.get<string>('TURBOPUFFER_API_KEY');
|
||||||
|
}
|
||||||
|
|
||||||
|
getTurbopufferRegion(): string {
|
||||||
|
return this.configService.get<string>('TURBOPUFFER_REGION');
|
||||||
|
}
|
||||||
|
|
||||||
|
getTurbopufferBaseUrl(): string {
|
||||||
|
return this.configService.get<string>('TURBOPUFFER_BASE_URL');
|
||||||
|
}
|
||||||
|
|
||||||
|
getTurbopufferNamespacePrefix(): string {
|
||||||
|
return this.configService.get<string>(
|
||||||
|
'TURBOPUFFER_NAMESPACE_PREFIX',
|
||||||
|
'docmost',
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
getOpenAiApiKey(): string {
|
getOpenAiApiKey(): string {
|
||||||
return this.configService.get<string>('OPENAI_API_KEY');
|
return this.configService.get<string>('OPENAI_API_KEY');
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import {
|
|||||||
IsOptional,
|
IsOptional,
|
||||||
IsString,
|
IsString,
|
||||||
IsUrl,
|
IsUrl,
|
||||||
|
Matches,
|
||||||
MinLength,
|
MinLength,
|
||||||
ValidateIf,
|
ValidateIf,
|
||||||
validateSync,
|
validateSync,
|
||||||
@@ -108,6 +109,41 @@ export class EnvironmentVariables {
|
|||||||
@IsString()
|
@IsString()
|
||||||
AI_DRIVER: string;
|
AI_DRIVER: string;
|
||||||
|
|
||||||
|
@IsOptional()
|
||||||
|
@ValidateIf((obj) => obj.AI_VECTOR_DRIVER)
|
||||||
|
@IsIn(['pgvector', 'turbopuffer'])
|
||||||
|
@IsString()
|
||||||
|
AI_VECTOR_DRIVER: string;
|
||||||
|
|
||||||
|
@ValidateIf((obj) => obj.AI_VECTOR_DRIVER === 'turbopuffer')
|
||||||
|
@IsNotEmpty()
|
||||||
|
@IsString()
|
||||||
|
TURBOPUFFER_API_KEY: string;
|
||||||
|
|
||||||
|
@ValidateIf(
|
||||||
|
(obj) =>
|
||||||
|
obj.AI_VECTOR_DRIVER === 'turbopuffer' && !obj.TURBOPUFFER_BASE_URL,
|
||||||
|
)
|
||||||
|
@IsNotEmpty({
|
||||||
|
message:
|
||||||
|
'TURBOPUFFER_REGION is required when AI_VECTOR_DRIVER is turbopuffer, unless TURBOPUFFER_BASE_URL is set',
|
||||||
|
})
|
||||||
|
@IsString()
|
||||||
|
TURBOPUFFER_REGION: string;
|
||||||
|
|
||||||
|
@IsOptional()
|
||||||
|
@ValidateIf((obj) => obj.TURBOPUFFER_BASE_URL != '' && obj.TURBOPUFFER_BASE_URL != null)
|
||||||
|
@IsUrl({ protocols: ['http', 'https'], require_tld: false })
|
||||||
|
TURBOPUFFER_BASE_URL: string;
|
||||||
|
|
||||||
|
@IsOptional()
|
||||||
|
@IsString()
|
||||||
|
@Matches(/^[A-Za-z0-9\-_.]{1,90}$/, {
|
||||||
|
message:
|
||||||
|
'TURBOPUFFER_NAMESPACE_PREFIX may only contain letters, digits, dot, dash, underscore (max 90 chars)',
|
||||||
|
})
|
||||||
|
TURBOPUFFER_NAMESPACE_PREFIX: string;
|
||||||
|
|
||||||
@IsOptional()
|
@IsOptional()
|
||||||
@IsString()
|
@IsString()
|
||||||
AI_EMBEDDING_MODEL: string;
|
AI_EMBEDDING_MODEL: string;
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import {
|
|||||||
import { Injectable, Logger } from '@nestjs/common';
|
import { Injectable, Logger } from '@nestjs/common';
|
||||||
import { EnvironmentService } from '../environment/environment.service';
|
import { EnvironmentService } from '../environment/environment.service';
|
||||||
import { Redis } from 'ioredis';
|
import { Redis } from 'ioredis';
|
||||||
|
import { parseRedisUrl } from '../../common/helpers';
|
||||||
|
|
||||||
@Injectable()
|
@Injectable()
|
||||||
export class RedisHealthIndicator {
|
export class RedisHealthIndicator {
|
||||||
@@ -19,8 +20,10 @@ export class RedisHealthIndicator {
|
|||||||
const indicator = this.healthIndicatorService.check(key);
|
const indicator = this.healthIndicatorService.check(key);
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const redis = new Redis(this.environmentService.getRedisUrl(), {
|
const redisUrl = this.environmentService.getRedisUrl();
|
||||||
|
const redis = new Redis(redisUrl, {
|
||||||
maxRetriesPerRequest: 15,
|
maxRetriesPerRequest: 15,
|
||||||
|
tls: parseRedisUrl(redisUrl).tls,
|
||||||
});
|
});
|
||||||
|
|
||||||
await redis.ping();
|
await redis.ping();
|
||||||
|
|||||||
@@ -61,6 +61,7 @@ export enum QueueJob {
|
|||||||
WORKSPACE_DELETED = 'workspace-deleted',
|
WORKSPACE_DELETED = 'workspace-deleted',
|
||||||
WORKSPACE_CREATE_EMBEDDINGS = 'workspace-create-embeddings',
|
WORKSPACE_CREATE_EMBEDDINGS = 'workspace-create-embeddings',
|
||||||
WORKSPACE_DELETE_EMBEDDINGS = 'workspace-delete-embeddings',
|
WORKSPACE_DELETE_EMBEDDINGS = 'workspace-delete-embeddings',
|
||||||
|
WORKSPACE_RESET_EMBEDDINGS = 'workspace-reset-embeddings',
|
||||||
|
|
||||||
GENERATE_PAGE_EMBEDDINGS = 'generate-page-embeddings',
|
GENERATE_PAGE_EMBEDDINGS = 'generate-page-embeddings',
|
||||||
DELETE_PAGE_EMBEDDINGS = 'delete-page-embeddings',
|
DELETE_PAGE_EMBEDDINGS = 'delete-page-embeddings',
|
||||||
|
|||||||
@@ -18,6 +18,7 @@ import { GeneralQueueProcessor } from './processors/general-queue.processor';
|
|||||||
password: redisConfig.password,
|
password: redisConfig.password,
|
||||||
db: redisConfig.db,
|
db: redisConfig.db,
|
||||||
family: redisConfig.family,
|
family: redisConfig.family,
|
||||||
|
tls: redisConfig.tls,
|
||||||
retryStrategy: createRetryStrategy(),
|
retryStrategy: createRetryStrategy(),
|
||||||
},
|
},
|
||||||
defaultJobOptions: {
|
defaultJobOptions: {
|
||||||
|
|||||||
@@ -19,6 +19,7 @@ export class RedisConfigService implements RedisOptionsFactory {
|
|||||||
password: redisConfig.password,
|
password: redisConfig.password,
|
||||||
db: redisConfig.db,
|
db: redisConfig.db,
|
||||||
family: redisConfig.family,
|
family: redisConfig.family,
|
||||||
|
tls: redisConfig.tls,
|
||||||
retryStrategy: createRetryStrategy(),
|
retryStrategy: createRetryStrategy(),
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -49,6 +49,10 @@ export class StaticModule implements OnModuleInit {
|
|||||||
: undefined,
|
: undefined,
|
||||||
POSTHOG_HOST: this.environmentService.getPostHogHost(),
|
POSTHOG_HOST: this.environmentService.getPostHogHost(),
|
||||||
POSTHOG_KEY: this.environmentService.getPostHogKey(),
|
POSTHOG_KEY: this.environmentService.getPostHogKey(),
|
||||||
|
AI_VECTOR_DRIVER:
|
||||||
|
this.environmentService.getAiVectorDriver() === 'turbopuffer'
|
||||||
|
? 'turbopuffer'
|
||||||
|
: undefined,
|
||||||
};
|
};
|
||||||
|
|
||||||
const windowScriptContent = `<script>window.CONFIG=${JSON.stringify(configString)};</script>`;
|
const windowScriptContent = `<script>window.CONFIG=${JSON.stringify(configString)};</script>`;
|
||||||
@@ -67,6 +71,16 @@ export class StaticModule implements OnModuleInit {
|
|||||||
await app.register(fastifyStatic, {
|
await app.register(fastifyStatic, {
|
||||||
root: clientDistPath,
|
root: clientDistPath,
|
||||||
wildcard: false,
|
wildcard: false,
|
||||||
|
preCompressed: true,
|
||||||
|
setHeaders: (reply: any, pathName: string) => {
|
||||||
|
// Vite content-hashes everything under /assets, so they can be cached forever
|
||||||
|
if (/[\\/]assets[\\/]/.test(pathName)) {
|
||||||
|
reply.header(
|
||||||
|
'Cache-Control',
|
||||||
|
'public, max-age=31536000, immutable',
|
||||||
|
);
|
||||||
|
}
|
||||||
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
app.get(RENDER_PATH, (req: any, res: any) => {
|
app.get(RENDER_PATH, (req: any, res: any) => {
|
||||||
|
|||||||
@@ -17,6 +17,7 @@ export class WsRedisIoAdapter extends IoAdapter {
|
|||||||
|
|
||||||
const options: RedisOptions = {
|
const options: RedisOptions = {
|
||||||
family: this.redisConfig.family,
|
family: this.redisConfig.family,
|
||||||
|
tls: this.redisConfig.tls,
|
||||||
retryStrategy: createRetryStrategy(),
|
retryStrategy: createRetryStrategy(),
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
@@ -3,8 +3,6 @@ import { CACHE_MANAGER } from '@nestjs/cache-manager';
|
|||||||
import { Cache } from 'cache-manager';
|
import { Cache } from 'cache-manager';
|
||||||
import { Server, Socket } from 'socket.io';
|
import { Server, Socket } from 'socket.io';
|
||||||
import { PagePermissionRepo } from '@docmost/db/repos/page/page-permission.repo';
|
import { PagePermissionRepo } from '@docmost/db/repos/page/page-permission.repo';
|
||||||
import { SpaceRepo } from '@docmost/db/repos/space/space.repo';
|
|
||||||
import { PageAccessService } from '../core/page/page-access/page-access.service';
|
|
||||||
import {
|
import {
|
||||||
TREE_EVENTS,
|
TREE_EVENTS,
|
||||||
WS_SPACE_RESTRICTION_CACHE_PREFIX,
|
WS_SPACE_RESTRICTION_CACHE_PREFIX,
|
||||||
@@ -19,8 +17,6 @@ export class WsService {
|
|||||||
|
|
||||||
constructor(
|
constructor(
|
||||||
private readonly pagePermissionRepo: PagePermissionRepo,
|
private readonly pagePermissionRepo: PagePermissionRepo,
|
||||||
private readonly spaceRepo: SpaceRepo,
|
|
||||||
private readonly pageAccessService: PageAccessService,
|
|
||||||
@Inject(CACHE_MANAGER) private readonly cacheManager: Cache,
|
@Inject(CACHE_MANAGER) private readonly cacheManager: Cache,
|
||||||
) {}
|
) {}
|
||||||
|
|
||||||
@@ -71,24 +67,9 @@ export class WsService {
|
|||||||
spaceId: string,
|
spaceId: string,
|
||||||
pageId: string,
|
pageId: string,
|
||||||
data: any,
|
data: any,
|
||||||
opts?: { bypassVisibilityCheck?: boolean },
|
|
||||||
): Promise<void> {
|
): Promise<void> {
|
||||||
const room = getSpaceRoomName(spaceId);
|
const room = getSpaceRoomName(spaceId);
|
||||||
|
|
||||||
if (
|
|
||||||
!opts?.bypassVisibilityCheck &&
|
|
||||||
(await this.spaceHidesCommentsFromViewers(spaceId))
|
|
||||||
) {
|
|
||||||
await this.broadcastToUsersMatching(room, null, data, (candidateIds) =>
|
|
||||||
this.pageAccessService.filterUserIdsWithPageEditAccess(
|
|
||||||
spaceId,
|
|
||||||
pageId,
|
|
||||||
candidateIds,
|
|
||||||
),
|
|
||||||
);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const hasRestrictions = await this.spaceHasRestrictions(spaceId);
|
const hasRestrictions = await this.spaceHasRestrictions(spaceId);
|
||||||
if (!hasRestrictions) {
|
if (!hasRestrictions) {
|
||||||
this.server.to(room).emit('message', data);
|
this.server.to(room).emit('message', data);
|
||||||
@@ -137,17 +118,6 @@ export class WsService {
|
|||||||
excludeSocketId: string | null,
|
excludeSocketId: string | null,
|
||||||
pageId: string,
|
pageId: string,
|
||||||
data: any,
|
data: any,
|
||||||
): Promise<void> {
|
|
||||||
await this.broadcastToUsersMatching(room, excludeSocketId, data, (ids) =>
|
|
||||||
this.pagePermissionRepo.getUserIdsWithPageAccess(pageId, ids),
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
private async broadcastToUsersMatching(
|
|
||||||
room: string,
|
|
||||||
excludeSocketId: string | null,
|
|
||||||
data: any,
|
|
||||||
filterUserIds: (candidateUserIds: string[]) => Promise<string[]>,
|
|
||||||
): Promise<void> {
|
): Promise<void> {
|
||||||
const sockets = await this.server.in(room).fetchSockets();
|
const sockets = await this.server.in(room).fetchSockets();
|
||||||
|
|
||||||
@@ -174,9 +144,15 @@ export class WsService {
|
|||||||
const candidateUserIds = Array.from(userSocketMap.keys());
|
const candidateUserIds = Array.from(userSocketMap.keys());
|
||||||
if (candidateUserIds.length === 0) return;
|
if (candidateUserIds.length === 0) return;
|
||||||
|
|
||||||
const allowedSet = new Set(await filterUserIds(candidateUserIds));
|
const authorizedUserIds =
|
||||||
|
await this.pagePermissionRepo.getUserIdsWithPageAccess(
|
||||||
|
pageId,
|
||||||
|
candidateUserIds,
|
||||||
|
);
|
||||||
|
|
||||||
|
const authorizedSet = new Set(authorizedUserIds);
|
||||||
for (const [userId, userSockets] of userSocketMap) {
|
for (const [userId, userSockets] of userSocketMap) {
|
||||||
if (allowedSet.has(userId)) {
|
if (authorizedSet.has(userId)) {
|
||||||
for (const socket of userSockets) {
|
for (const socket of userSockets) {
|
||||||
socket.emit('message', data);
|
socket.emit('message', data);
|
||||||
}
|
}
|
||||||
@@ -200,13 +176,6 @@ export class WsService {
|
|||||||
return hasRestrictions;
|
return hasRestrictions;
|
||||||
}
|
}
|
||||||
|
|
||||||
private async spaceHidesCommentsFromViewers(
|
|
||||||
spaceId: string,
|
|
||||||
): Promise<boolean> {
|
|
||||||
const settings = await this.spaceRepo.getSpaceSettings(spaceId);
|
|
||||||
return settings?.comments?.hideCommentsFromViewers === true;
|
|
||||||
}
|
|
||||||
|
|
||||||
private extractPageId(data: any): string | null {
|
private extractPageId(data: any): string | null {
|
||||||
switch (data.operation) {
|
switch (data.operation) {
|
||||||
case 'addTreeNode':
|
case 'addTreeNode':
|
||||||
|
|||||||
@@ -32,6 +32,7 @@ export * from "./lib/columns";
|
|||||||
export * from "./lib/status";
|
export * from "./lib/status";
|
||||||
export * from "./lib/pdf";
|
export * from "./lib/pdf";
|
||||||
export * from "./lib/page-break";
|
export * from "./lib/page-break";
|
||||||
|
export * from "./lib/footnotes";
|
||||||
export * from "./lib/resizable-nodeview";
|
export * from "./lib/resizable-nodeview";
|
||||||
export {
|
export {
|
||||||
pageNodeToDocxBuffer,
|
pageNodeToDocxBuffer,
|
||||||
|
|||||||
@@ -0,0 +1,189 @@
|
|||||||
|
//Source MIT - https://github.com/buttondown/tiptap-footnotes
|
||||||
|
import { mergeAttributes } from "@tiptap/core";
|
||||||
|
import ListItem, { ListItemOptions } from "@tiptap/extension-list-item";
|
||||||
|
|
||||||
|
declare module "@tiptap/core" {
|
||||||
|
interface Commands<ReturnType> {
|
||||||
|
footnote: {
|
||||||
|
/**
|
||||||
|
* scrolls to & sets the text selection at the end of the footnote with the given id
|
||||||
|
* @param id the id of the footote (i.e. the `data-id` attribute value of the footnote)
|
||||||
|
* @example editor.commands.focusFootnote("a43956c1-1ab8-462f-96e4-be3a4b27fd50")
|
||||||
|
*/
|
||||||
|
focusFootnote: (id: string) => ReturnType;
|
||||||
|
};
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface FootnoteOptions extends ListItemOptions {
|
||||||
|
/**
|
||||||
|
* Content expression for this node
|
||||||
|
* @default "paragraph+"
|
||||||
|
*/
|
||||||
|
content: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
const Footnote = ListItem.extend<FootnoteOptions>({
|
||||||
|
name: "footnote",
|
||||||
|
content() {
|
||||||
|
return this.options.content;
|
||||||
|
},
|
||||||
|
isolating: true,
|
||||||
|
defining: true,
|
||||||
|
draggable: false,
|
||||||
|
|
||||||
|
addOptions() {
|
||||||
|
return {
|
||||||
|
HTMLAttributes: {},
|
||||||
|
bulletListTypeName: 'bulletList',
|
||||||
|
orderedListTypeName: 'orderedList',
|
||||||
|
...this.parent?.(),
|
||||||
|
content: "paragraph+",
|
||||||
|
};
|
||||||
|
},
|
||||||
|
|
||||||
|
addAttributes() {
|
||||||
|
return {
|
||||||
|
id: {
|
||||||
|
isRequired: true,
|
||||||
|
},
|
||||||
|
// the data-id field should match the data-id field of a footnote reference.
|
||||||
|
// it's used to link footnotes and references together.
|
||||||
|
"data-id": {
|
||||||
|
isRequired: true,
|
||||||
|
},
|
||||||
|
};
|
||||||
|
},
|
||||||
|
parseHTML() {
|
||||||
|
return [
|
||||||
|
{
|
||||||
|
tag: "li",
|
||||||
|
getAttrs(node) {
|
||||||
|
const id = node.getAttribute("data-id");
|
||||||
|
if (id) {
|
||||||
|
return {
|
||||||
|
"data-id": node.getAttribute("data-id"),
|
||||||
|
};
|
||||||
|
}
|
||||||
|
return false;
|
||||||
|
},
|
||||||
|
priority: 1000,
|
||||||
|
},
|
||||||
|
];
|
||||||
|
},
|
||||||
|
renderHTML({ HTMLAttributes }) {
|
||||||
|
return [
|
||||||
|
"li",
|
||||||
|
mergeAttributes(this.options.HTMLAttributes, HTMLAttributes),
|
||||||
|
0,
|
||||||
|
];
|
||||||
|
},
|
||||||
|
|
||||||
|
addCommands() {
|
||||||
|
return {
|
||||||
|
focusFootnote:
|
||||||
|
(id: string) =>
|
||||||
|
({ editor, chain }) => {
|
||||||
|
const matchedFootnote = editor.$node("footnote", {
|
||||||
|
"data-id": id,
|
||||||
|
});
|
||||||
|
if (matchedFootnote) {
|
||||||
|
// sets the text selection to the end of the footnote definition and scroll to it.
|
||||||
|
chain()
|
||||||
|
.focus()
|
||||||
|
.setTextSelection(
|
||||||
|
matchedFootnote.from + matchedFootnote.content.size
|
||||||
|
)
|
||||||
|
.run();
|
||||||
|
|
||||||
|
matchedFootnote.element.scrollIntoView();
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
return false;
|
||||||
|
},
|
||||||
|
};
|
||||||
|
},
|
||||||
|
addKeyboardShortcuts() {
|
||||||
|
return {
|
||||||
|
// when inside a footnote, Mod-a should select only the footnote content
|
||||||
|
"Mod-a": ({ editor }) => {
|
||||||
|
try {
|
||||||
|
const { selection } = editor.state;
|
||||||
|
const { $from } = selection;
|
||||||
|
|
||||||
|
for (let depth = $from.depth; depth >= 0; depth--) {
|
||||||
|
const node = $from.node(depth);
|
||||||
|
if (node.type.name === "footnote") {
|
||||||
|
const start = $from.start(depth);
|
||||||
|
const end = $from.end(depth);
|
||||||
|
|
||||||
|
editor.commands.setTextSelection({
|
||||||
|
from: start + 1,
|
||||||
|
to: end - 1,
|
||||||
|
});
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return false;
|
||||||
|
} catch (e) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
},
|
||||||
|
// when the user presses tab, adjust the text selection to be at the end of the next footnote
|
||||||
|
Tab: ({ editor }) => {
|
||||||
|
try {
|
||||||
|
const { selection } = editor.state;
|
||||||
|
const pos = editor.$pos(selection.anchor);
|
||||||
|
if (!pos.after) return false;
|
||||||
|
// if the next node is "footnotes", place the text selection at the end of the first footnote
|
||||||
|
if (pos.after.node.type.name == "footnotes") {
|
||||||
|
const firstChild = pos.after.node.child(0);
|
||||||
|
editor
|
||||||
|
.chain()
|
||||||
|
.setTextSelection(pos.after.from + firstChild.content.size)
|
||||||
|
.scrollIntoView()
|
||||||
|
.run();
|
||||||
|
return true;
|
||||||
|
} else {
|
||||||
|
const startPos = selection.$from.start(2);
|
||||||
|
if (Number.isNaN(startPos)) return false;
|
||||||
|
const parent = editor.$pos(startPos);
|
||||||
|
if (parent.node.type.name != "footnote" || !parent.after) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
// if the next node is a footnote, place the text selection at the end of it
|
||||||
|
editor
|
||||||
|
.chain()
|
||||||
|
.setTextSelection(parent.after.to - 1)
|
||||||
|
.scrollIntoView()
|
||||||
|
.run();
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
} catch {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
},
|
||||||
|
// inverse of the tab command - place the text selection at the end of the previous footnote
|
||||||
|
"Shift-Tab": ({ editor }) => {
|
||||||
|
const { selection } = editor.state;
|
||||||
|
const startPos = selection.$from.start(2);
|
||||||
|
if (Number.isNaN(startPos)) return false;
|
||||||
|
const parent = editor.$pos(startPos);
|
||||||
|
if (parent.node.type.name != "footnote" || !parent.before) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
editor
|
||||||
|
.chain()
|
||||||
|
.setTextSelection(parent.before.to - 1)
|
||||||
|
.scrollIntoView()
|
||||||
|
.run();
|
||||||
|
return true;
|
||||||
|
},
|
||||||
|
};
|
||||||
|
},
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
export default Footnote;
|
||||||
@@ -0,0 +1,46 @@
|
|||||||
|
//Source MIT - https://github.com/buttondown/tiptap-footnotes
|
||||||
|
import OrderedList from "@tiptap/extension-ordered-list";
|
||||||
|
import FootnoteRules from "./rules";
|
||||||
|
|
||||||
|
const Footnotes = OrderedList.extend({
|
||||||
|
name: "footnotes",
|
||||||
|
group: "", // removed the default group of the ordered list extension
|
||||||
|
isolating: true,
|
||||||
|
defining: true,
|
||||||
|
draggable: false,
|
||||||
|
|
||||||
|
content() {
|
||||||
|
return "footnote*";
|
||||||
|
},
|
||||||
|
addAttributes() {
|
||||||
|
return {
|
||||||
|
class: {
|
||||||
|
default: "footnotes",
|
||||||
|
},
|
||||||
|
};
|
||||||
|
},
|
||||||
|
parseHTML() {
|
||||||
|
return [
|
||||||
|
{
|
||||||
|
tag: "ol.footnotes",
|
||||||
|
priority: 1000,
|
||||||
|
},
|
||||||
|
];
|
||||||
|
},
|
||||||
|
|
||||||
|
addKeyboardShortcuts() {
|
||||||
|
return {};
|
||||||
|
},
|
||||||
|
addCommands() {
|
||||||
|
return {};
|
||||||
|
},
|
||||||
|
addInputRules() {
|
||||||
|
return [];
|
||||||
|
},
|
||||||
|
|
||||||
|
addExtensions() {
|
||||||
|
return [FootnoteRules];
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
export default Footnotes;
|
||||||
@@ -0,0 +1,4 @@
|
|||||||
|
export { default as Footnotes } from "./footnotes";
|
||||||
|
export { default as Footnote } from "./footnote";
|
||||||
|
export type { FootnoteOptions } from "./footnote";
|
||||||
|
export { default as FootnoteReference } from "./reference";
|
||||||
@@ -0,0 +1,221 @@
|
|||||||
|
//Source MIT - https://github.com/buttondown/tiptap-footnotes
|
||||||
|
import { mergeAttributes, Node } from "@tiptap/core";
|
||||||
|
import {
|
||||||
|
Fragment as PMFragment,
|
||||||
|
Node as PMNode,
|
||||||
|
Slice,
|
||||||
|
} from "@tiptap/pm/model";
|
||||||
|
import { NodeSelection, Plugin, PluginKey } from "@tiptap/pm/state";
|
||||||
|
import { generateNodeId } from "../utils";
|
||||||
|
|
||||||
|
|
||||||
|
const REFNUM_ATTR = "data-reference-number";
|
||||||
|
const REF_CLASS = "footnote-ref";
|
||||||
|
|
||||||
|
declare module "@tiptap/core" {
|
||||||
|
interface Commands<ReturnType> {
|
||||||
|
footnoteReference: {
|
||||||
|
/**
|
||||||
|
* add a new footnote reference
|
||||||
|
* @example editor.commands.addFootnote()
|
||||||
|
*/
|
||||||
|
addFootnote: () => ReturnType;
|
||||||
|
};
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
const FootnoteReference = Node.create({
|
||||||
|
name: "footnoteReference",
|
||||||
|
inline: true,
|
||||||
|
content: "text*",
|
||||||
|
group: "inline",
|
||||||
|
atom: true,
|
||||||
|
draggable: true,
|
||||||
|
|
||||||
|
parseHTML() {
|
||||||
|
return [
|
||||||
|
{
|
||||||
|
tag: `sup`,
|
||||||
|
priority: 1000,
|
||||||
|
getAttrs(node) {
|
||||||
|
const anchor = node.querySelector<HTMLAnchorElement>(
|
||||||
|
`a.${REF_CLASS}:first-child`
|
||||||
|
);
|
||||||
|
|
||||||
|
if (!anchor) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
const id = anchor.getAttribute("data-id");
|
||||||
|
const ref = anchor.getAttribute(REFNUM_ATTR);
|
||||||
|
|
||||||
|
return {
|
||||||
|
"data-id": id ?? generateNodeId(),
|
||||||
|
referenceNumber: ref ?? anchor.innerText,
|
||||||
|
};
|
||||||
|
},
|
||||||
|
contentElement(node) {
|
||||||
|
return node.firstChild as HTMLElement;
|
||||||
|
},
|
||||||
|
},
|
||||||
|
];
|
||||||
|
},
|
||||||
|
|
||||||
|
addAttributes() {
|
||||||
|
return {
|
||||||
|
class: {
|
||||||
|
default: REF_CLASS,
|
||||||
|
},
|
||||||
|
"data-id": {
|
||||||
|
renderHTML(attributes) {
|
||||||
|
return {
|
||||||
|
"data-id": attributes["data-id"] || generateNodeId(),
|
||||||
|
};
|
||||||
|
},
|
||||||
|
},
|
||||||
|
referenceNumber: {},
|
||||||
|
|
||||||
|
href: {
|
||||||
|
renderHTML(attributes) {
|
||||||
|
return {
|
||||||
|
href: `#fn:${attributes["referenceNumber"]}`,
|
||||||
|
};
|
||||||
|
},
|
||||||
|
},
|
||||||
|
};
|
||||||
|
},
|
||||||
|
|
||||||
|
renderHTML({ HTMLAttributes }) {
|
||||||
|
const { referenceNumber, ...attributes } = HTMLAttributes;
|
||||||
|
const attrs = mergeAttributes(this.options.HTMLAttributes, attributes);
|
||||||
|
attrs[REFNUM_ATTR] = referenceNumber;
|
||||||
|
|
||||||
|
return [
|
||||||
|
"sup",
|
||||||
|
{ id: `fnref:${referenceNumber}` },
|
||||||
|
["a", attrs, HTMLAttributes.referenceNumber],
|
||||||
|
];
|
||||||
|
},
|
||||||
|
|
||||||
|
addProseMirrorPlugins() {
|
||||||
|
const { editor } = this;
|
||||||
|
|
||||||
|
// Ensures pasted footnote references get unique IDs.
|
||||||
|
const mapNode = (node: PMNode): PMNode => {
|
||||||
|
if (node.type.name === this.name) {
|
||||||
|
const newAttrs = { ...node.attrs, "data-id": generateNodeId() };
|
||||||
|
return node.type.create(newAttrs, node.content, node.marks);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (node.content && node.content.size > 0) {
|
||||||
|
const newChildren: PMNode[] = [];
|
||||||
|
let changed = false;
|
||||||
|
|
||||||
|
node.content.forEach((child) => {
|
||||||
|
const mapped = mapNode(child);
|
||||||
|
if (mapped !== child) {
|
||||||
|
changed = true;
|
||||||
|
}
|
||||||
|
|
||||||
|
newChildren.push(mapped);
|
||||||
|
});
|
||||||
|
|
||||||
|
if (changed) {
|
||||||
|
return node.copy(PMFragment.from(newChildren));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return node;
|
||||||
|
};
|
||||||
|
|
||||||
|
return [
|
||||||
|
new Plugin({
|
||||||
|
key: new PluginKey("footnotePasteHandler"),
|
||||||
|
props: {
|
||||||
|
transformPasted(slice) {
|
||||||
|
const mappedNodes: PMNode[] = [];
|
||||||
|
let changed = false;
|
||||||
|
|
||||||
|
slice.content.forEach((node) => {
|
||||||
|
const mapped = mapNode(node);
|
||||||
|
if (mapped !== node) {
|
||||||
|
changed = true;
|
||||||
|
}
|
||||||
|
mappedNodes.push(mapped);
|
||||||
|
});
|
||||||
|
|
||||||
|
if (!changed) {
|
||||||
|
return slice;
|
||||||
|
}
|
||||||
|
|
||||||
|
return new Slice(
|
||||||
|
PMFragment.from(mappedNodes),
|
||||||
|
slice.openStart,
|
||||||
|
slice.openEnd
|
||||||
|
);
|
||||||
|
},
|
||||||
|
},
|
||||||
|
}),
|
||||||
|
new Plugin({
|
||||||
|
key: new PluginKey("footnoteRefClick"),
|
||||||
|
|
||||||
|
props: {
|
||||||
|
// on double-click, focus on the footnote
|
||||||
|
handleDoubleClickOn(view, pos, node, nodePos, event) {
|
||||||
|
if (node.type.name != "footnoteReference") return false;
|
||||||
|
event.preventDefault();
|
||||||
|
const id = node.attrs["data-id"];
|
||||||
|
return editor.commands.focusFootnote(id);
|
||||||
|
},
|
||||||
|
// click the footnote reference once to get focus, click twice to scroll to the footnote
|
||||||
|
handleClickOn(view, pos, node, nodePos, event) {
|
||||||
|
if (node.type.name != "footnoteReference") return false;
|
||||||
|
event.preventDefault();
|
||||||
|
const { selection } = editor.state.tr;
|
||||||
|
if (selection instanceof NodeSelection && selection.node.eq(node)) {
|
||||||
|
const id = node.attrs["data-id"];
|
||||||
|
return editor.commands.focusFootnote(id);
|
||||||
|
} else {
|
||||||
|
editor.chain().setNodeSelection(nodePos).run();
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
},
|
||||||
|
},
|
||||||
|
}),
|
||||||
|
];
|
||||||
|
},
|
||||||
|
|
||||||
|
addCommands() {
|
||||||
|
return {
|
||||||
|
addFootnote:
|
||||||
|
() =>
|
||||||
|
({ state, tr }) => {
|
||||||
|
const node = this.type.create({
|
||||||
|
"data-id": generateNodeId(),
|
||||||
|
});
|
||||||
|
tr.insert(state.selection.anchor, node);
|
||||||
|
return true;
|
||||||
|
},
|
||||||
|
};
|
||||||
|
},
|
||||||
|
|
||||||
|
addInputRules() {
|
||||||
|
// when a user types [^text], add a new footnote
|
||||||
|
return [
|
||||||
|
{
|
||||||
|
find: /\[\^(.*?)\]/,
|
||||||
|
type: this.type,
|
||||||
|
undoable: true,
|
||||||
|
handler({ range, match, chain }) {
|
||||||
|
const start = range.from;
|
||||||
|
let end = range.to;
|
||||||
|
if (match[1]) {
|
||||||
|
chain().deleteRange({ from: start, to: end }).addFootnote().run();
|
||||||
|
}
|
||||||
|
},
|
||||||
|
},
|
||||||
|
];
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
export default FootnoteReference;
|
||||||
@@ -0,0 +1,90 @@
|
|||||||
|
//Source MIT - https://github.com/buttondown/tiptap-footnotes
|
||||||
|
import { Plugin, PluginKey } from "@tiptap/pm/state";
|
||||||
|
import { ReplaceStep } from "@tiptap/pm/transform";
|
||||||
|
import { Extension } from "@tiptap/core";
|
||||||
|
import { updateFootnotesList } from "./utils";
|
||||||
|
|
||||||
|
const FootnoteRules = Extension.create({
|
||||||
|
name: "footnoteRules",
|
||||||
|
priority: 1000,
|
||||||
|
addProseMirrorPlugins() {
|
||||||
|
return [
|
||||||
|
new Plugin({
|
||||||
|
key: new PluginKey("footnoteRules"),
|
||||||
|
filterTransaction(tr) {
|
||||||
|
const { from, to } = tr.selection;
|
||||||
|
|
||||||
|
// Allow full document selections (Mod-a/Ctrl-a)
|
||||||
|
if (from === 0 && to === tr.doc.content.size) return true;
|
||||||
|
|
||||||
|
let selectedFootnotes = false;
|
||||||
|
let selectedContent = false;
|
||||||
|
let footnoteCount = 0;
|
||||||
|
tr.doc.nodesBetween(from, to, (node, _, parent) => {
|
||||||
|
if (parent?.type.name == "doc" && node.type.name != "footnotes") {
|
||||||
|
selectedContent = true;
|
||||||
|
} else if (node.type.name == "footnote") {
|
||||||
|
footnoteCount += 1;
|
||||||
|
} else if (node.type.name == "footnotes") {
|
||||||
|
selectedFootnotes = true;
|
||||||
|
}
|
||||||
|
});
|
||||||
|
const overSelected = selectedContent && selectedFootnotes;
|
||||||
|
/*
|
||||||
|
* Here, we don't allow any transaction that spans between the "content" nodes and the "footnotes" node. This also rejects any transaction that spans between more than 1 footnote.
|
||||||
|
*/
|
||||||
|
return !overSelected && footnoteCount <= 1;
|
||||||
|
},
|
||||||
|
|
||||||
|
// if there are some to the footnote references (added/deleted/dragged), append a transaction that updates the footnotes list accordingly
|
||||||
|
appendTransaction(transactions, oldState, newState) {
|
||||||
|
let newTr = newState.tr;
|
||||||
|
let refsChanged = false; // true if the footnote references have been changed, false otherwise
|
||||||
|
for (let tr of transactions) {
|
||||||
|
if (!tr.docChanged) continue;
|
||||||
|
if (refsChanged) break;
|
||||||
|
|
||||||
|
for (let step of tr.steps) {
|
||||||
|
if (!(step instanceof ReplaceStep)) continue;
|
||||||
|
if (refsChanged) break;
|
||||||
|
|
||||||
|
const isDelete = step.from != step.to; // the user deleted items from the document (from != to & the step is a replace step)
|
||||||
|
const isInsert = step.slice.size > 0;
|
||||||
|
|
||||||
|
// check if any footnote references have been inserted
|
||||||
|
if (isInsert) {
|
||||||
|
step.slice.content.descendants((node) => {
|
||||||
|
if (node?.type.name == "footnoteReference") {
|
||||||
|
refsChanged = true;
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
if (isDelete && !refsChanged) {
|
||||||
|
// check if any footnote references have been deleted
|
||||||
|
tr.before.nodesBetween(
|
||||||
|
step.from,
|
||||||
|
Math.min(tr.before.content.size, step.to), // make sure to not go over the old document's limit
|
||||||
|
(node) => {
|
||||||
|
if (node.type.name == "footnoteReference") {
|
||||||
|
refsChanged = true;
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
},
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (refsChanged) {
|
||||||
|
updateFootnotesList(newTr, newState);
|
||||||
|
return newTr;
|
||||||
|
}
|
||||||
|
|
||||||
|
return null;
|
||||||
|
},
|
||||||
|
}),
|
||||||
|
];
|
||||||
|
},
|
||||||
|
});
|
||||||
|
export default FootnoteRules;
|
||||||
@@ -0,0 +1,123 @@
|
|||||||
|
//Source MIT - https://github.com/buttondown/tiptap-footnotes
|
||||||
|
import { EditorState, Transaction } from "@tiptap/pm/state";
|
||||||
|
import { Fragment, Node } from "@tiptap/pm/model";
|
||||||
|
|
||||||
|
// update the reference number of all the footnote references in the document
|
||||||
|
export function updateFootnoteReferences(tr: Transaction) {
|
||||||
|
let count = 1;
|
||||||
|
|
||||||
|
const nodes: any[] = [];
|
||||||
|
|
||||||
|
tr.doc.descendants((node, pos) => {
|
||||||
|
if (node.type.name == "footnoteReference") {
|
||||||
|
tr.setNodeAttribute(pos, "referenceNumber", `${count}`);
|
||||||
|
|
||||||
|
nodes.push(node);
|
||||||
|
count += 1;
|
||||||
|
}
|
||||||
|
});
|
||||||
|
// return the updated footnote references (in the order that they appear in the document)
|
||||||
|
return nodes;
|
||||||
|
}
|
||||||
|
|
||||||
|
function getFootnotes(tr: Transaction) {
|
||||||
|
let footnotesRange: { from: number; to: number } | undefined;
|
||||||
|
const footnotes: Node[] = [];
|
||||||
|
tr.doc.descendants((node, pos) => {
|
||||||
|
if (node.type.name == "footnote") {
|
||||||
|
footnotes.push(node);
|
||||||
|
} else if (node.type.name == "footnotes") {
|
||||||
|
footnotesRange = { from: pos, to: pos + node.nodeSize };
|
||||||
|
} else {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
});
|
||||||
|
return { footnotesRange, footnotes };
|
||||||
|
}
|
||||||
|
|
||||||
|
// update the "footnotes" ordered list based on the footnote references in the document
|
||||||
|
export function updateFootnotesList(tr: Transaction, state: EditorState) {
|
||||||
|
const footnoteReferences = updateFootnoteReferences(tr);
|
||||||
|
|
||||||
|
const footnoteType = state.schema.nodes.footnote;
|
||||||
|
const footnotesType = state.schema.nodes.footnotes;
|
||||||
|
|
||||||
|
const emptyParagraph = state.schema.nodeFromJSON({
|
||||||
|
type: "paragraph",
|
||||||
|
content: [],
|
||||||
|
});
|
||||||
|
|
||||||
|
const { footnotesRange, footnotes } = getFootnotes(tr);
|
||||||
|
|
||||||
|
// a mapping of footnote id -> footnote node
|
||||||
|
const footnoteIds: { [key: string]: Node } = footnotes.reduce(
|
||||||
|
(obj, footnote) => {
|
||||||
|
obj[footnote.attrs["data-id"]] = footnote;
|
||||||
|
return obj;
|
||||||
|
},
|
||||||
|
{} as any,
|
||||||
|
);
|
||||||
|
|
||||||
|
const newFootnotes: Node[] = [];
|
||||||
|
|
||||||
|
let footnoteRefIds = new Set(
|
||||||
|
footnoteReferences.map((ref) => ref.attrs["data-id"]),
|
||||||
|
);
|
||||||
|
const deleteFootnoteIds: Set<string> = new Set();
|
||||||
|
for (let footnote of footnotes) {
|
||||||
|
const id = footnote.attrs["data-id"];
|
||||||
|
if (!footnoteRefIds.has(id) || deleteFootnoteIds.has(id)) {
|
||||||
|
deleteFootnoteIds.add(id);
|
||||||
|
// we traverse through this footnote's content because it may contain footnote references.
|
||||||
|
// we want to delete the footnotes associated with these references, so we add them to the delete set.
|
||||||
|
footnote.content.descendants((node) => {
|
||||||
|
if (node.type.name == "footnoteReference")
|
||||||
|
deleteFootnoteIds.add(node.attrs["data-id"]);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
for (let i = 0; i < footnoteReferences.length; i++) {
|
||||||
|
let refId = footnoteReferences[i].attrs["data-id"];
|
||||||
|
|
||||||
|
if (deleteFootnoteIds.has(refId)) continue;
|
||||||
|
// if there is a footnote w/ the same id as this `ref`, we preserve its content and update its id attribute
|
||||||
|
if (refId in footnoteIds) {
|
||||||
|
let footnote = footnoteIds[refId];
|
||||||
|
newFootnotes.push(
|
||||||
|
footnoteType.create(
|
||||||
|
{ ...footnote.attrs, id: `fn:${i + 1}` },
|
||||||
|
footnote.content,
|
||||||
|
),
|
||||||
|
);
|
||||||
|
} else {
|
||||||
|
let newNode = footnoteType.create(
|
||||||
|
{
|
||||||
|
"data-id": refId,
|
||||||
|
id: `fn:${i + 1}`,
|
||||||
|
},
|
||||||
|
[emptyParagraph],
|
||||||
|
);
|
||||||
|
newFootnotes.push(newNode);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (newFootnotes.length == 0) {
|
||||||
|
// no footnotes in the doc, delete the "footnotes" node
|
||||||
|
if (footnotesRange) {
|
||||||
|
tr.delete(footnotesRange.from, footnotesRange.to);
|
||||||
|
}
|
||||||
|
} else if (!footnotesRange) {
|
||||||
|
// there is no footnotes node present in the doc, add it
|
||||||
|
tr.insert(
|
||||||
|
tr.doc.content.size,
|
||||||
|
footnotesType.create(undefined, Fragment.from(newFootnotes)),
|
||||||
|
);
|
||||||
|
} else {
|
||||||
|
tr.replaceWith(
|
||||||
|
footnotesRange!.from + 1, // add 1 to point at the position after the opening ol tag
|
||||||
|
footnotesRange!.to - 1, // substract 1 to point to the position before the closing ol tag
|
||||||
|
Fragment.from(newFootnotes),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,110 @@
|
|||||||
|
import { Token, marked } from 'marked';
|
||||||
|
import { generateNodeId } from '../../utils';
|
||||||
|
|
||||||
|
interface FootnoteRefToken {
|
||||||
|
type: 'footnoteRef';
|
||||||
|
label: string;
|
||||||
|
raw: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
interface FootnoteDefToken {
|
||||||
|
type: 'footnoteDef';
|
||||||
|
label: string;
|
||||||
|
text: string;
|
||||||
|
raw: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Parse-scoped state: markdownToHtml resets before the top-level parse and
|
||||||
|
// appends the collected list after it. Nested marked.parse calls (callout,
|
||||||
|
// footnote definitions) share this state, so hooks cannot be used here.
|
||||||
|
let footnoteRefs: { label: string; id: string; number: number }[] = [];
|
||||||
|
let footnoteDefs = new Map<string, string>();
|
||||||
|
|
||||||
|
export function resetFootnotes() {
|
||||||
|
footnoteRefs = [];
|
||||||
|
footnoteDefs = new Map();
|
||||||
|
}
|
||||||
|
|
||||||
|
export function renderFootnotesList(): string {
|
||||||
|
if (!footnoteRefs.length) return '';
|
||||||
|
const items = footnoteRefs.map(({ label, id, number }) => {
|
||||||
|
const body = footnoteDefs.get(label) || '<p></p>';
|
||||||
|
return `<li id="fn:${number}" data-id="${id}">${body}</li>`;
|
||||||
|
});
|
||||||
|
return `<ol class="footnotes">\n${items.join('\n')}\n</ol>\n`;
|
||||||
|
}
|
||||||
|
|
||||||
|
export const footnoteRefExtension = {
|
||||||
|
name: 'footnoteRef',
|
||||||
|
level: 'inline',
|
||||||
|
start(src: string) {
|
||||||
|
return src.indexOf('[^');
|
||||||
|
},
|
||||||
|
tokenizer(src: string): FootnoteRefToken | undefined {
|
||||||
|
const match = /^\[\^([^\]\s]+)\]/.exec(src);
|
||||||
|
if (match) {
|
||||||
|
return {
|
||||||
|
type: 'footnoteRef',
|
||||||
|
raw: match[0],
|
||||||
|
label: match[1].toLowerCase(),
|
||||||
|
};
|
||||||
|
}
|
||||||
|
},
|
||||||
|
renderer(token: Token) {
|
||||||
|
const refToken = token as FootnoteRefToken;
|
||||||
|
const number = footnoteRefs.length + 1;
|
||||||
|
const id = generateNodeId();
|
||||||
|
footnoteRefs.push({ label: refToken.label, id, number });
|
||||||
|
return `<sup id="fnref:${number}"><a class="footnote-ref" data-id="${id}" data-reference-number="${number}" href="#fn:${number}">${number}</a></sup>`;
|
||||||
|
},
|
||||||
|
};
|
||||||
|
|
||||||
|
export const footnoteDefExtension = {
|
||||||
|
name: 'footnoteDef',
|
||||||
|
level: 'block',
|
||||||
|
start(src: string) {
|
||||||
|
return src.match(/^\[\^[^\]\s]+\]:/m)?.index ?? -1;
|
||||||
|
},
|
||||||
|
tokenizer(src: string): FootnoteDefToken | undefined {
|
||||||
|
const firstLine = /^\[\^([^\]\s]+)\]:[ \t]*/.exec(src);
|
||||||
|
if (!firstLine) return undefined;
|
||||||
|
|
||||||
|
const lines = src.split('\n');
|
||||||
|
const contentLines = [lines[0].slice(firstLine[0].length)];
|
||||||
|
let consumed = 1;
|
||||||
|
while (consumed < lines.length) {
|
||||||
|
const line = lines[consumed];
|
||||||
|
if (/^[ \t]{2,}\S/.test(line)) {
|
||||||
|
contentLines.push(line.replace(/^[ \t]{1,4}/, ''));
|
||||||
|
consumed += 1;
|
||||||
|
} else if (
|
||||||
|
/^[ \t]*$/.test(line) &&
|
||||||
|
consumed + 1 < lines.length &&
|
||||||
|
/^[ \t]{2,}\S/.test(lines[consumed + 1])
|
||||||
|
) {
|
||||||
|
contentLines.push('');
|
||||||
|
consumed += 1;
|
||||||
|
} else {
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
const raw =
|
||||||
|
lines.slice(0, consumed).join('\n') +
|
||||||
|
(consumed < lines.length ? '\n' : '');
|
||||||
|
return {
|
||||||
|
type: 'footnoteDef',
|
||||||
|
raw,
|
||||||
|
label: firstLine[1].toLowerCase(),
|
||||||
|
text: contentLines.join('\n').trim(),
|
||||||
|
};
|
||||||
|
},
|
||||||
|
renderer(token: Token) {
|
||||||
|
const defToken = token as FootnoteDefToken;
|
||||||
|
const body = defToken.text
|
||||||
|
? marked.parse(defToken.text).toString()
|
||||||
|
: '<p></p>';
|
||||||
|
footnoteDefs.set(defToken.label, body);
|
||||||
|
return '';
|
||||||
|
},
|
||||||
|
};
|
||||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user