Merge pull request #19 from AHTu21/feature/chat

feat: мессенджер Retrogen (чаты, вложения, группы)

Author: nesson64

CHANGELOG.md

@@ -8,7 +8,18 @@
 
 ## [Unreleased]
 
-_Черновик до следующего релиза; в окне «О программе» не показывается._
+### Сообщения (`/messages`)
+
+- **Раздел «Сообщения»** в меню приложения: личные чаты, **группы**, системные каналы (**Новости** — только чтение, **Поддержка** — диалог с командой и **быстрыми командами**).
+- **Левая колонка:** иконка **профиля** (аватар, ФИО, «Создать группу», переход в **Избранное**), поиск пользователя для нового диалога, список чатов с непрочитанными; при открытом профиле список **приглушается**.
+- **Переписка:** отправка текста и **вложений** (скрепка, Enter и иконка отправки без обязательного текста), **эмодзи** в поле ввода; превью и **скачивание** файлов (иконка загрузки).
+- **Сообщения (ПКМ):** ответ, редактирование своих, **удалить у всех** / **только у меня**, пересылка в **Избранное**; скрытие «у себя» с запасом в `localStorage`, если миграция БД ещё не применена.
+- **Избранное:** личный канал для заметок и пересланных сообщений.
+- **Группы:** в шапке чата — **Настройки** (фото группы как у профиля — только «Загрузить фото», увеличение по клику), список участников, **добавление** по поиску, **Покинуть группу**, **Удалить группу** (только создатель); лента при открытых настройках приглушается.
+
+### Интерфейс
+
+- Пункт **«Сообщения»** в overflow-меню шапки (рядом с профилем и комнатами).
 
 <!-- changelog:user -->
 
@@ -195,6 +206,7 @@ _Черновик до следующего релиза; в окне «О пр
 
 ### API и сервер (история по релизам)
 
+- **Unreleased / мессенджер:** Prisma `Chat`, `ChatMember`, `Message`, `MessageAttachment`, `MessageHidden`; модуль `server/src/chat/`; REST `/api/chats`, вложения `/api/chat/attachments/:id`, группа (`PATCH …/group/avatar`, `POST …/group/members`, `POST …/leave`, `DELETE …/:chatId`); Socket.IO `chat:join`, `chat:message.created|updated|hidden`, `chat:list.updated`, `chat:typing`. Файлы вложений — `server/data/chat-attachments/` (в `.gitignore`). Миграции `20260525180000_messenger`, `20260525200000_message_hidden`; после pull — `npm run db:deploy`.
 - **0.10.0:** только клиент — `retrogen_profile_v1` в `localStorage`, событие `retrogen-profile`; модули `pages/profile/*`, `profileAccent`, `profileRoomColors`; миграция legacy (аватар ≠ обои доски).
 - **0.9.0:** миграция `Card.textDoc` (JSONB); сокет `stickerCollab:*` (Yjs relay in-memory).
 - **0.9.0 / ранее:** комната `listedInLobby`, `joinPasswordHash`, `POST /unlock`, `PATCH /access`; сокет **`planeLive`** → `plane.preview`; прокси Vite к Socket.IO в dev.

README.md

@@ -10,6 +10,20 @@
 3. **Миграции:** из корня репозитория `npm run db:deploy` (или `npm run db:migrate` для интерактивной разработки).
 4. **Запуск:** `npm run dev` — клиент http://localhost:5173, API и WebSocket http://localhost:3000.
 
+### Если localhost:5173 отдаёт 404
+
+На Windows иногда на порту **5173** остаётся старый процесс Node (только IPv6 `[::1]`), а новый Vite слушает **127.0.0.1** — тогда `http://localhost:5173` не открывается, а `http://127.0.0.1:5173` работает.
+
+Завершите лишний процесс на 5173 (Диспетчер задач → Node.js) или в PowerShell:
+
+```powershell
+Get-NetTCPConnection -LocalPort 5173 -ErrorAction SilentlyContinue |
+  Select-Object -ExpandProperty OwningProcess -Unique |
+  ForEach-Object { Stop-Process -Id $_ -Force -ErrorAction SilentlyContinue }
+```
+
+Затем снова `npm run dev`. API через прокси Vite: `http://localhost:5173/api/...`.
+
 Переменные для сервера читаются из **`server/.env`** (подхватываются и Prisma CLI при запуске из каталога `server`, и самим приложением).
 
 Если `psql` не в `PATH`, добавьте `bin` установки PostgreSQL в переменную окружения или подключайтесь через pgAdmin — на работу приложения это не влияет, нужна только корректная строка `DATABASE_URL`.
@@ -27,6 +41,8 @@
 
 ## Git и совместная разработка
 
+Команда и приглашение в GitHub Collaborators: **[docs/CONTRIBUTORS.md](./docs/CONTRIBUTORS.md)**.
+
 1. Клонируйте репозиторий, в корне: `npm install`.
 2. Скопируйте **`server/.env.example` → `server/.env`**, при необходимости **`client/.env.example` → `client/.env`** (файлы `.env` в git не попадают).
 3. `npm run db:deploy`, затем `npm run dev`.

client/src/App.tsx

@@ -8,6 +8,7 @@ import { RoomTeamPage } from "./pages/RoomTeamPage";
 import { SummaryPage } from "./pages/SummaryPage";
 import { WelcomePage } from "./pages/WelcomePage";
 import { WorkshopPage } from "./pages/WorkshopPage";
+import { MessagesPage } from "./pages/MessagesPage";
 
 export default function App() {
   return (
@@ -18,6 +19,8 @@ export default function App() {
       <Route path="/register" element={<RegisterPage />} />
       <Route path="/profile" element={<ProfilePage />} />
       <Route path="/workshop" element={<WorkshopPage />} />
+      <Route path="/messages" element={<MessagesPage />} />
+      <Route path="/messages/:chatId" element={<MessagesPage />} />
       <Route path="/r/:slug/summary" element={<SummaryPage />} />
       <Route path="/r/:slug/team" element={<RoomTeamPage />} />
       <Route path="/r/:slug" element={<RoomPage />} />

client/src/api.ts

@@ -1,10 +1,16 @@
 import type { LobbyRoomDto, RoomDto } from "./types";
+import type {
+  ChatListItemDto,
+  MessageDto,
+  MessengerUserSearchDto,
+  SupportQuickCommandDto,
+} from "./types/messenger";
 import { getAccessToken, setAccessToken } from "./lib/authToken";
 import { unlockHeadersForUrl } from "./lib/roomUnlockStorage";
 
 export type AuthUserDto = { id: string; email: string; displayName: string; globalRole: string };
 
-async function apiFetch(input: string, init?: RequestInit): Promise<Response> {
+export async function apiFetch(input: string, init?: RequestInit): Promise<Response> {
   const headers = new Headers(init?.headers);
   const t = getAccessToken();
   if (t) headers.set("Authorization", `Bearer ${t}`);
@@ -429,6 +435,35 @@ export async function loginAccount(body: {
   return data;
 }
 
+export async function updateAuthDisplayName(displayName: string): Promise<AuthUserDto> {
+  const res = await apiFetch("/api/auth/me", {
+    method: "PATCH",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify({ displayName }),
+  });
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  const data = (await res.json()) as { user: AuthUserDto };
+  return data.user;
+}
+
+export async function forwardMessageToSaved(
+  chatId: string,
+  messageId: string,
+): Promise<{ message: MessageDto; savedChatId: string }> {
+  const res = await apiFetch(
+    `/api/chats/${encodeURIComponent(chatId)}/messages/${encodeURIComponent(messageId)}/forward-to-saved`,
+    { method: "POST" },
+  );
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ message: MessageDto; savedChatId: string }>;
+}
+
 export async function fetchAuthMe(): Promise<AuthUserDto | null> {
   const res = await apiFetch("/api/auth/me");
   if (res.status === 401) return null;
@@ -440,3 +475,253 @@ export async function fetchAuthMe(): Promise<AuthUserDto | null> {
 export function logoutAccount(): void {
   setAccessToken(null);
 }
+
+export async function fetchChats(): Promise<{ chats: ChatListItemDto[] }> {
+  const res = await apiFetch("/api/chats");
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ chats: ChatListItemDto[] }>;
+}
+
+export async function searchMessengerUsers(q: string): Promise<{ users: MessengerUserSearchDto[] }> {
+  const sp = new URLSearchParams({ q });
+  const res = await apiFetch(`/api/chats/users/search?${sp}`);
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ users: MessengerUserSearchDto[] }>;
+}
+
+export async function createDirectChat(userId: string): Promise<{ chat: ChatListItemDto }> {
+  const res = await apiFetch("/api/chats/direct", {
+    method: "POST",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify({ userId }),
+  });
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ chat: ChatListItemDto }>;
+}
+
+export async function createGroupChat(title: string, memberIds: string[]): Promise<{ chat: ChatListItemDto }> {
+  const res = await apiFetch("/api/chats/group", {
+    method: "POST",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify({ title, memberIds }),
+  });
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ chat: ChatListItemDto }>;
+}
+
+export async function fetchChatDetail(chatId: string): Promise<{ chat: ChatListItemDto }> {
+  const res = await apiFetch(`/api/chats/${encodeURIComponent(chatId)}`);
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ chat: ChatListItemDto }>;
+}
+
+export async function updateGroupChatAvatar(
+  chatId: string,
+  avatarUrl: string | null,
+): Promise<{ chat: ChatListItemDto }> {
+  const res = await apiFetch(`/api/chats/${encodeURIComponent(chatId)}/group/avatar`, {
+    method: "PATCH",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify({ avatarUrl }),
+  });
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ chat: ChatListItemDto }>;
+}
+
+export async function addGroupChatMembers(
+  chatId: string,
+  memberIds: string[],
+): Promise<{ chat: ChatListItemDto }> {
+  const res = await apiFetch(`/api/chats/${encodeURIComponent(chatId)}/group/members`, {
+    method: "POST",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify({ memberIds }),
+  });
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ chat: ChatListItemDto }>;
+}
+
+export async function leaveGroupChat(chatId: string): Promise<{ removed: boolean; chatDeleted: boolean }> {
+  const res = await apiFetch(`/api/chats/${encodeURIComponent(chatId)}/leave`, { method: "POST" });
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ removed: boolean; chatDeleted: boolean }>;
+}
+
+export async function deleteGroupChat(chatId: string): Promise<{ removed: boolean }> {
+  const res = await apiFetch(`/api/chats/${encodeURIComponent(chatId)}`, { method: "DELETE" });
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ removed: boolean }>;
+}
+
+export async function fetchChatMessages(
+  chatId: string,
+  opts?: { cursor?: string; limit?: number },
+): Promise<{ messages: MessageDto[]; nextCursor: string | null }> {
+  const sp = new URLSearchParams();
+  if (opts?.cursor) sp.set("cursor", opts.cursor);
+  if (opts?.limit != null) sp.set("limit", String(opts.limit));
+  const qs = sp.toString();
+  const res = await apiFetch(`/api/chats/${encodeURIComponent(chatId)}/messages${qs ? `?${qs}` : ""}`);
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ messages: MessageDto[]; nextCursor: string | null }>;
+}
+
+export async function sendChatMessage(
+  chatId: string,
+  body: { text: string; replyToMessageId?: string | null; clientMessageId?: string | null },
+): Promise<{ message: MessageDto }> {
+  const res = await apiFetch(`/api/chats/${encodeURIComponent(chatId)}/messages`, {
+    method: "POST",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify(body),
+  });
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ message: MessageDto }>;
+}
+
+export async function sendChatMessageWithAttachments(
+  chatId: string,
+  body: {
+    text?: string;
+    clientMessageId?: string | null;
+    replyToMessageId?: string | null;
+    files: File[];
+  },
+): Promise<{ message: MessageDto }> {
+  if (body.files.length === 0) {
+    throw new Error("attachments_required");
+  }
+  const fd = new FormData();
+  const trimmed = body.text?.trim() ?? "";
+  if (trimmed) fd.set("text", trimmed);
+  if (body.clientMessageId) fd.set("clientMessageId", body.clientMessageId);
+  if (body.replyToMessageId) fd.set("replyToMessageId", body.replyToMessageId);
+  for (const f of body.files) {
+    fd.append("files", f, f.name);
+  }
+  const res = await apiFetch(
+    `/api/chats/${encodeURIComponent(chatId)}/messages/upload`,
+    { method: "POST", body: fd },
+  );
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ message: MessageDto }>;
+}
+
+export async function fetchSupportQuickCommands(): Promise<{ commands: SupportQuickCommandDto[] }> {
+  const res = await apiFetch("/api/chats/support/quick-commands");
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ commands: SupportQuickCommandDto[] }>;
+}
+
+export async function runSupportQuickCommand(
+  chatId: string,
+  commandId: string,
+): Promise<{ userMessage: MessageDto; replyMessage: MessageDto }> {
+  const res = await apiFetch(`/api/chats/${encodeURIComponent(chatId)}/quick-command`, {
+    method: "POST",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify({ commandId }),
+  });
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ userMessage: MessageDto; replyMessage: MessageDto }>;
+}
+
+export async function editChatMessage(
+  chatId: string,
+  messageId: string,
+  text: string,
+): Promise<{ message: MessageDto }> {
+  const res = await apiFetch(
+    `/api/chats/${encodeURIComponent(chatId)}/messages/${encodeURIComponent(messageId)}`,
+    {
+      method: "PATCH",
+      headers: { "Content-Type": "application/json" },
+      body: JSON.stringify({ text }),
+    },
+  );
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<{ message: MessageDto }>;
+}
+
+export async function deleteChatMessage(
+  chatId: string,
+  messageId: string,
+  scope: "everyone" | "me",
+): Promise<
+  | { scope: "everyone"; message: MessageDto }
+  | { scope: "me"; messageId: string }
+> {
+  const res = await apiFetch(
+    `/api/chats/${encodeURIComponent(chatId)}/messages/${encodeURIComponent(messageId)}/delete`,
+    {
+      method: "POST",
+      headers: { "Content-Type": "application/json" },
+      body: JSON.stringify({ scope }),
+    },
+  );
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+  return res.json() as Promise<
+    | { scope: "everyone"; message: MessageDto }
+    | { scope: "me"; messageId: string }
+  >;
+}
+
+export async function markChatRead(chatId: string, messageId: string): Promise<void> {
+  const res = await apiFetch(`/api/chats/${encodeURIComponent(chatId)}/read`, {
+    method: "POST",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify({ messageId }),
+  });
+  if (!res.ok) {
+    const err = await res.json().catch(() => ({}));
+    throw new Error((err as { error?: string }).error ?? res.statusText);
+  }
+}

client/src/components/RetrogenOverflowMenu.tsx

@@ -87,6 +87,9 @@ export function RetrogenOverflowMenu({
           <Link to="/workshop" role="menuitem" className={itemClass(isLight)} onClick={() => setOpen(false)}>
             Мастерская
           </Link>
+          <Link to="/messages" role="menuitem" className={itemClass(isLight)} onClick={() => setOpen(false)}>
+            Мессенджер
+          </Link>
           {teamRoomSlug ? (
             <Link
               to={`/r/${teamRoomSlug}/team`}