From cf87c0daa7e5743ec2c5ce2fe81ed995635e9cdf Mon Sep 17 00:00:00 2001
From: Vasilii Mikhailovskii <ti.webdev@ya.ru>
Date: Fri, 6 Dec 2024 23:00:31 +0200
Subject: [PATCH] create chat document

---
 apps/frontend/src/api/dbs.ts                  |  2 +
 .../src/components/read/ReadMessageSender.vue | 45 +++++++++++++++----
 apps/frontend/src/constants/dbNames.ts        |  1 +
 .../types/src/DBDocuments/ChatDocument.ts     | 23 ++++++++++
 packages/types/src/DBDocuments/index.ts       |  1 +
 .../migrations/1732483677017-dbs.js           |  4 ++
 6 files changed, 67 insertions(+), 9 deletions(-)
 create mode 100644 packages/types/src/DBDocuments/ChatDocument.ts

diff --git a/apps/frontend/src/api/dbs.ts b/apps/frontend/src/api/dbs.ts
index 2c88edb..e4e9ebb 100644
--- a/apps/frontend/src/api/dbs.ts
+++ b/apps/frontend/src/api/dbs.ts
@@ -3,6 +3,7 @@ import PouchDB from '@/api/PouchDB'
 import type {
   BaseDocument,
   QRCodeDocument,
+  ChatDocument,
   MessageDocument,
   WebPushSubscriptionDocument,
   PublicSettingsDocument,
@@ -18,6 +19,7 @@ export const getLocalDb = <T extends BaseDocument>(dbName: DB_NAMES) => new Pouc
 export const qrCodeDbRemote = getRemoteDb<QRCodeDocument>(DB_NAMES.QR)
 export const qrCodeDbLocal = getLocalDb<QRCodeDocument>(DB_NAMES.QR)
 export const messagesDbLocal = getLocalDb<MessageDocument>(DB_NAMES.MESSAGES)
+export const chatsDbRemote = getRemoteDb<ChatDocument>(DB_NAMES.CHATS)
 export const webPushSubscriptionsDbRemote = getRemoteDb<
   WebPushSubscriptionDocument<PushSubscriptionJSON>
 >(DB_NAMES.WEB_PUSH_SUBSCRIPTIONS)
diff --git a/apps/frontend/src/components/read/ReadMessageSender.vue b/apps/frontend/src/components/read/ReadMessageSender.vue
index 7d1fe48..4bbb14e 100644
--- a/apps/frontend/src/components/read/ReadMessageSender.vue
+++ b/apps/frontend/src/components/read/ReadMessageSender.vue
@@ -44,8 +44,8 @@
 <script setup lang="ts">
 import { ref } from 'vue'
 import { useRouter } from 'vue-router'
-import { messagesDbLocal as db } from '@/api/dbs'
-import type { MessageDocument, QRCodeDocument } from '@hereconnect/types'
+import { chatsDbRemote, messagesDbLocal as db } from '@/api/dbs'
+import type { ChatDocument, MessageDocument, QRCodeDocument } from '@hereconnect/types'
 import { ROUTE_NAMES } from '@/constants/routes'
 import { getUserUuid } from '@/utils/getUserUuid'
 import { getBrowserUuid } from '@/utils/getBrowserUuid'
@@ -69,22 +69,49 @@ async function sendMessage(content: string) {
   try {
     loading.value = true
 
-    const chat = (new Date().getTime() - new Date(doc.created_at).getTime()).toString(36)
+    const date = new Date()
+    const created_at = date.toISOString()
+    const chat = (date.getTime() - new Date(doc.created_at).getTime()).toString(36)
+    const user_uuid = getUserUuid()
+    const browser_uuid = getBrowserUuid()
+
+    const chatGuestDoc: ChatDocument = {
+      _id: `chat:${user_uuid}:guest:${doc.uri}:${chat}`,
+      type: 'chat',
+      qr_code_uri: doc.uri,
+      role: 'guest',
+      chat,
+      created_at,
+      user_uuid,
+    }
+
+    const chatOwnerDoc: ChatDocument = {
+      _id: `chat:${doc.user_uuid}:owner:${doc.uri}:${chat}`,
+      type: 'chat',
+      qr_code_uri: doc.uri,
+      role: 'owner',
+      chat,
+      created_at,
+      user_uuid: doc.user_uuid,
+    }
 
     const message: MessageDocument = {
-      _id: `message:${doc.uri}:${chat}:${new Date().toISOString()}`,
+      _id: `message:${doc.uri}:${chat}:${created_at}`,
       type: 'message',
       qr_code_uri: doc.uri,
       chat,
-      created_at: new Date().toISOString(),
+      created_at,
       from: 'guest',
-      user_uuid: getUserUuid(),
-      browser_uuid: getBrowserUuid(),
+      user_uuid,
+      browser_uuid,
       body: content.trim(),
     }
 
-    // Сохраняем сообщение в локальную базу данных
-    await db.put(message)
+    await Promise.all([
+      chatsDbRemote.bulkDocs([chatGuestDoc, chatOwnerDoc]),
+      // Сохраняем сообщение в локальную базу данных
+      db.put(message),
+    ])
 
     success.value = true
     error.value = null
diff --git a/apps/frontend/src/constants/dbNames.ts b/apps/frontend/src/constants/dbNames.ts
index bd31b68..31ed1b6 100644
--- a/apps/frontend/src/constants/dbNames.ts
+++ b/apps/frontend/src/constants/dbNames.ts
@@ -1,5 +1,6 @@
 export enum DB_NAMES {
   QR = 'qr',
+  CHATS = 'chats',
   MESSAGES = 'messages',
   WEB_PUSH_SUBSCRIPTIONS = 'web_push_subscriptions',
   PUBLIC_SETTINGS = 'public_settings',
diff --git a/packages/types/src/DBDocuments/ChatDocument.ts b/packages/types/src/DBDocuments/ChatDocument.ts
new file mode 100644
index 0000000..96026fd
--- /dev/null
+++ b/packages/types/src/DBDocuments/ChatDocument.ts
@@ -0,0 +1,23 @@
+import { type BaseDocument } from "./BaseDocument";
+import type { Role } from "./Role";
+
+/**
+ * Интерфейс для документа чата.
+ * Используется для хранения чатов, отправленных через QR‑код.
+ */
+export interface ChatDocument extends BaseDocument {
+  /** Тип документа, всегда 'chat' */
+  type: "chat";
+
+  /** Идентификатор QR‑кода, к которому относится чат */
+  qr_code_uri: string;
+
+  /** Идентификатор чата */
+  chat: string;
+
+  /** Роль пользователя в чате */
+  role: Role;
+
+  /** Идентификатор пользователя, которому принадлежит чат */
+  user_uuid: string;
+}
diff --git a/packages/types/src/DBDocuments/index.ts b/packages/types/src/DBDocuments/index.ts
index 1707caa..fc85697 100644
--- a/packages/types/src/DBDocuments/index.ts
+++ b/packages/types/src/DBDocuments/index.ts
@@ -1,5 +1,6 @@
 export * from "./Role";
 export * from "./BaseDocument";
+export * from "./ChatDocument";
 export * from "./MessageDocument";
 export * from "./PublicSettingsDocument";
 export * from "./QRCodeDocument";
diff --git a/services/db-migrations/migrations/1732483677017-dbs.js b/services/db-migrations/migrations/1732483677017-dbs.js
index 6d0f07e..cbb9ae5 100644
--- a/services/db-migrations/migrations/1732483677017-dbs.js
+++ b/services/db-migrations/migrations/1732483677017-dbs.js
@@ -17,6 +17,10 @@ const dbsSecurity = {
     admins: { roles: ["_admin"] },
     members: { roles: [] },
   },
+  chats: {
+    admins: { roles: ["_admin"] },
+    members: { roles: [] },
+  },
   qr: {
     admins: { roles: ["_admin"] },
     members: { roles: [] },