ваше сообщение коммита

backend/app.js

@@ -11,6 +11,7 @@ const db = require('./db'); // Добавляем импорт db
 const aiAssistant = require('./services/ai-assistant'); // Добавляем импорт aiAssistant
 const fs = require('fs');
 const path = require('path');
+const messagesRoutes = require('./routes/messages');
 
 // Проверка и создание директорий для хранения данных контрактов
 const ensureDirectoriesExist = () => {
@@ -77,7 +78,7 @@ app.use(
       'http://127.0.0.1:5173', // Добавляем альтернативный origin
     ],
     credentials: true,
-    methods: ['GET', 'POST', 'PUT', 'DELETE', 'OPTIONS'],
+    methods: ['GET', 'POST', 'PUT', 'DELETE', 'PATCH', 'OPTIONS'],
     allowedHeaders: ['Content-Type', 'Authorization', 'Cookie'],
   })
 );
@@ -163,6 +164,7 @@ app.use('/api/isic', isicRoutes); // Добавленное использова
 app.use('/api/geocoding', geocodingRoutes); // Добавленное использование роута
 app.use('/api/dle', dleRoutes); // Добавляем маршрут DLE
 app.use('/api/settings', settingsRoutes); // Добавляем маршрут настроек
+app.use('/api/messages', messagesRoutes);
 
 const nonceStore = new Map(); // или любая другая реализация хранилища nonce
 

backend/db.js

@@ -97,10 +97,4 @@ async function saveGuestMessageToDatabase(message, language, guestId) {
 }
 
 // Экспортируем функции для работы с базой данных
-module.exports = {
-  getPool,
-  getQuery,
-  reinitPoolFromDbSettings,
-  saveGuestMessageToDatabase,
-  setPoolChangeCallback,
-};
+module.exports = { getQuery, pool, getPool, setPoolChangeCallback };

backend/db/migrations/026_add_preferred_language_to_users.sql

@@ -0,0 +1,2 @@
+-- Добавление поля preferred_language для хранения языков пользователя (множественный выбор)
+ALTER TABLE users ADD COLUMN preferred_language jsonb; 

backend/routes/messages.js

@@ -0,0 +1,23 @@
+const express = require('express');
+const router = express.Router();
+const db = require('../db');
+
+// GET /api/messages?userId=123
+router.get('/', async (req, res) => {
+  const userId = req.query.userId;
+  if (!userId) return res.status(400).json({ error: 'userId required' });
+  try {
+    const result = await db.getQuery()(
+      `SELECT id, user_id, sender_type, content, channel, role, direction, created_at, attachment_filename, attachment_mimetype, attachment_size, attachment_data, metadata
+       FROM messages
+       WHERE user_id = $1
+       ORDER BY created_at ASC`,
+      [userId]
+    );
+    res.json(result.rows);
+  } catch (e) {
+    res.status(500).json({ error: 'DB error', details: e.message });
+  }
+});
+
+module.exports = router; 

backend/routes/users.js

@@ -138,4 +138,54 @@ router.get('/', async (req, res) => {
 });
 */
 
+// PATCH /api/users/:id — обновить имя и язык
+router.patch('/:id', async (req, res) => {
+  const userId = req.params.id;
+  const { name, language } = req.body;
+  if (!name && !language) return res.status(400).json({ error: 'Nothing to update' });
+  try {
+    const fields = [];
+    const values = [];
+    let idx = 1;
+    if (name !== undefined) {
+      // Разделяем имя на first_name и last_name (по пробелу)
+      const [firstName, ...lastNameArr] = name.split(' ');
+      fields.push(`first_name = $${idx++}`);
+      values.push(firstName);
+      fields.push(`last_name = $${idx++}`);
+      values.push(lastNameArr.join(' ') || null);
+    }
+    if (language !== undefined) {
+      fields.push(`preferred_language = $${idx++}`);
+      values.push(Array.isArray(language) ? JSON.stringify(language) : language);
+    }
+    values.push(userId);
+    const sql = `UPDATE users SET ${fields.join(', ')} WHERE id = $${idx} RETURNING *`;
+    const result = await db.getQuery()(sql, values);
+    res.json(result.rows[0]);
+  } catch (e) {
+    res.status(500).json({ error: 'DB error', details: e.message });
+  }
+});
+
+// DELETE /api/users/:id — удалить контакт и все связанные данные
+router.delete('/:id', async (req, res) => {
+  const userId = req.params.id;
+  const client = await db.getPool().connect();
+  try {
+    await client.query('BEGIN');
+    await client.query('DELETE FROM user_identities WHERE user_id = $1', [userId]);
+    await client.query('DELETE FROM messages WHERE user_id = $1', [userId]);
+    // Добавьте другие связанные таблицы, если нужно
+    await client.query('DELETE FROM users WHERE id = $1', [userId]);
+    await client.query('COMMIT');
+    res.json({ success: true });
+  } catch (e) {
+    await client.query('ROLLBACK');
+    res.status(500).json({ error: 'DB error', details: e.message });
+  } finally {
+    client.release();
+  }
+});
+
 module.exports = router;