[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_108":109,"_110":111},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mdevslabs","name","mai","path","vibe-books-conversations.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":55,"_56":57,"_58":59,"_60":32,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":72,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":84,"_85":86,"_87":88,"_89":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/mdevslabs/mai/code/vibe-books-conversations.ts","extension","id","4680835f-4a27-4872-bf07-3d942aee562c","fileId","b6035d2c-af88-11f1-8e18-1607ee4eb77e","parentId","branchId","3345cb6c-eeb2-4b61-ab03-8e0abc2dcd73","branchVersion",361,"latest",true,"createdAt",["D",1789313726383],"version",2,"fileType","script","content","/**\n * ============================================================================\n * VIBE SOCIAL PLATFORM — CONVERSATIONS DES LIVRES (vibe-books-conversations.ts)\n * Chaque Livre possède une conversation de groupe dans Messages\n * (dm_conversations.book_id, partner_id = \"group:\") : les mécanismes de\n * groupe existants (envoi, réactions, épingles, recherche, non-lus, SSE)\n * fonctionnent sans modification. Ce module synchronise membres et métadonnées\n * à chaque mutation du Livre + backfill idempotent des Livres existants.\n * ============================================================================\n */\n\nimport { ensureDMTables, pushToUsers } from \"./vibe-dms-core.ts\";\n\nlet bookConvTablesReady = false;\n\n/** Colonnes/index propres aux conversations de Livre (idempotent, 1×/isolate). */\nexport async function ensureBookConversationTables(sql: any): Promise {\n if (bookConvTablesReady) return;\n try {\n await ensureDMTables().catch(() => {});\n await sql`ALTER TABLE dm_conversations ADD COLUMN IF NOT EXISTS book_id UUID`\n .catch(() => {});\n await sql`CREATE UNIQUE INDEX IF NOT EXISTS idx_dm_conversations_book ON dm_conversations(book_id) WHERE book_id IS NOT NULL`\n .catch(() => {});\n await sql`ALTER TABLE direct_messages ADD COLUMN IF NOT EXISTS attached_post_id UUID`\n .catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_dm_attached_post ON direct_messages(attached_post_id) WHERE attached_post_id IS NOT NULL`\n .catch(() => {});\n bookConvTablesReady = true;\n } catch (err) {\n console.warn(\n \"[vibe-books-conversations] ensure tables skipped:\",\n (err as any)?.message,\n );\n }\n}\n\n/** Id de la conversation Messages d'un Livre (null si absente). */\nexport async function getBookConversationId(\n sql: any,\n bookId: string,\n): Promise {\n try {\n const rows =\n await sql`SELECT id FROM dm_conversations WHERE book_id = ${bookId}::uuid LIMIT 1`;\n return rows[0] ? String(rows[0].id) : null;\n } catch {\n return null;\n }\n}\n\n/** Membres de la conversation d'un Livre (depuis dm_group_members). */\nasync function fetchConversationMemberIds(\n sql: any,\n conversationId: string,\n): Promise {\n try {\n const rows =\n await sql`SELECT user_id FROM dm_group_members WHERE conversation_id = ${conversationId}::uuid`;\n return (rows as any[]).map((r) => Number(r.user_id)).filter((n) =>\n Number.isFinite(n)\n );\n } catch {\n return [];\n }\n}\n\n/**\n * Aligne dm_group_members sur vibe_book_members (upsert des rôles + purge des\n * partis). Retourne l'id de conversation et les membres synchronisés.\n */\nexport async function syncBookConversationMembers(\n sql: any,\n bookId: string,\n): Promise<{ conversationId: string | null; memberIds: number[] }> {\n const conversationId = await getBookConversationId(sql, bookId);\n if (!conversationId) return { conversationId: null, memberIds: [] };\n try {\n await sql`\n INSERT INTO dm_group_members (conversation_id, user_id, role, added_by)\n SELECT ${conversationId}::uuid, m.user_id,\n CASE WHEN m.role = 'owner' THEN 'admin' ELSE 'member' END,\n (SELECT user_id FROM vibe_books WHERE id = ${bookId}::uuid)\n FROM vibe_book_members m\n WHERE m.book_id = ${bookId}::uuid\n ON CONFLICT (conversation_id, user_id) DO UPDATE SET role = EXCLUDED.role\n `.catch(() => {});\n await sql`\n DELETE FROM dm_group_members\n WHERE conversation_id = ${conversationId}::uuid\n AND NOT EXISTS (\n SELECT 1 FROM vibe_book_members m\n WHERE m.book_id = ${bookId}::uuid AND m.user_id = dm_group_members.user_id\n )\n `.catch(() => {});\n } catch (err) {\n console.warn(\n \"[vibe-books-conversations] sync members failed:\",\n (err as any)?.message,\n );\n }\n const memberIds = await fetchConversationMemberIds(sql, conversationId);\n return { conversationId, memberIds };\n}\n\n/**\n * Garantit l'existence de la conversation du Livre + synchronise ses membres.\n * Retourne l'id de conversation (ou null en cas d'échec non bloquant).\n */\nexport async function ensureBookConversation(\n sql: any,\n book: { id: string; user_id: number; title: string },\n): Promise {\n try {\n await ensureBookConversationTables(sql);\n let conversationId = await getBookConversationId(sql, book.id);\n if (!conversationId) {\n try {\n const created = await sql`\n INSERT INTO dm_conversations\n (participant_one_id, participant_two_id, is_group, group_name, created_by, book_id,\n last_message_preview, last_message_at)\n VALUES (${book.user_id}, NULL, TRUE, ${book.title}, ${book.user_id}, ${book.id}::uuid,\n 'Conversation du Livre', NOW())\n RETURNING id\n `;\n conversationId = created[0]?.id ? String(created[0].id) : null;\n } catch {\n // course possible avec un autre isolate : la ligne existe peut-être déjà\n conversationId = await getBookConversationId(sql, book.id);\n }\n }\n if (!conversationId) return null;\n await syncBookConversationMembers(sql, book.id);\n return conversationId;\n } catch (err) {\n console.warn(\n \"[vibe-books-conversations] ensure failed:\",\n (err as any)?.message,\n );\n return null;\n }\n}\n\n/** Retire un membre (leave/kick) et prévient le membre retiré + les restants. */\nexport async function removeBookConversationMember(\n sql: any,\n bookId: string,\n userId: number,\n): Promise {\n try {\n const conversationId = await getBookConversationId(sql, bookId);\n if (!conversationId) return;\n await sql`\n DELETE FROM dm_group_members WHERE conversation_id = ${conversationId}::uuid AND user_id = ${userId}\n `.catch(() => {});\n const memberIds = await fetchConversationMemberIds(sql, conversationId);\n await pushToUsers([userId], \"group_updated\", {\n conversation_id: conversationId,\n action: \"removed\",\n book_id: bookId,\n });\n await pushToUsers(memberIds, \"group_updated\", {\n conversation_id: conversationId,\n action: \"updated\",\n book_id: bookId,\n });\n } catch (err) {\n console.warn(\n \"[vibe-books-conversations] remove member failed:\",\n (err as any)?.message,\n );\n }\n}\n\n/** Renomme la conversation (synchro du titre du Livre). */\nexport async function renameBookConversation(\n sql: any,\n bookId: string,\n title: string,\n): Promise {\n try {\n const conversationId = await getBookConversationId(sql, bookId);\n if (!conversationId) return;\n await sql`\n UPDATE dm_conversations SET group_name = ${\n title.slice(0, 100)\n } WHERE id = ${conversationId}::uuid\n `.catch(() => {});\n const memberIds = await fetchConversationMemberIds(sql, conversationId);\n await pushToUsers(memberIds, \"group_updated\", {\n conversation_id: conversationId,\n action: \"renamed\",\n book_id: bookId,\n });\n } catch (err) {\n console.warn(\n \"[vibe-books-conversations] rename failed:\",\n (err as any)?.message,\n );\n }\n}\n\n/** Transfère la propriété : created_by + rôles dm_group_members. */\nexport async function transferBookConversationOwnership(\n sql: any,\n bookId: string,\n fromUserId: number,\n toUserId: number,\n): Promise {\n try {\n const conversationId = await getBookConversationId(sql, bookId);\n if (!conversationId) return;\n await sql`\n UPDATE dm_conversations SET created_by = ${toUserId} WHERE id = ${conversationId}::uuid\n `.catch(() => {});\n await sql`\n UPDATE dm_group_members SET role = 'admin'\n WHERE conversation_id = ${conversationId}::uuid AND user_id = ${toUserId}\n `.catch(() => {});\n await sql`\n UPDATE dm_group_members SET role = 'member'\n WHERE conversation_id = ${conversationId}::uuid AND user_id = ${fromUserId}\n `.catch(() => {});\n const memberIds = await fetchConversationMemberIds(sql, conversationId);\n await pushToUsers(memberIds, \"group_updated\", {\n conversation_id: conversationId,\n action: \"admin_transferred\",\n book_id: bookId,\n });\n } catch (err) {\n console.warn(\n \"[vibe-books-conversations] transfer failed:\",\n (err as any)?.message,\n );\n }\n}\n\n/** Supprime la conversation, ses messages et prévient les membres. */\nexport async function deleteBookConversation(\n sql: any,\n bookId: string,\n): Promise {\n try {\n const conversationId = await getBookConversationId(sql, bookId);\n if (!conversationId) return;\n const memberIds = await fetchConversationMemberIds(sql, conversationId);\n // dm_reactions n'a pas de FK sur direct_messages : purge explicite (comme les groupes)\n await sql`DELETE FROM dm_reactions WHERE message_id IN (SELECT id FROM direct_messages WHERE conversation_id = ${conversationId}::uuid)`\n .catch(() => {});\n await sql`DELETE FROM direct_messages WHERE conversation_id = ${conversationId}::uuid`\n .catch(() => {});\n await sql`DELETE FROM dm_conversations WHERE id = ${conversationId}::uuid`\n .catch(() => {});\n await pushToUsers(memberIds, \"group_updated\", {\n conversation_id: conversationId,\n action: \"deleted\",\n book_id: bookId,\n });\n } catch (err) {\n console.warn(\n \"[vibe-books-conversations] delete failed:\",\n (err as any)?.message,\n );\n }\n}\n\n/** Backfill idempotent : conversation + membres pour chaque Livre qui n'en a pas. */\nexport async function backfillBookConversations(sql: any): Promise {\n try {\n await ensureBookConversationTables(sql);\n await sql`\n INSERT INTO dm_conversations\n (participant_one_id, participant_two_id, is_group, group_name, created_by, book_id,\n last_message_preview, last_message_at)\n SELECT b.user_id, NULL, TRUE, b.title, b.user_id, b.id, 'Conversation du Livre', COALESCE(b.updated_at, NOW())\n FROM vibe_books b\n WHERE NOT EXISTS (SELECT 1 FROM dm_conversations dm WHERE dm.book_id = b.id)\n `.catch(() => {});\n await sql`\n INSERT INTO dm_group_members (conversation_id, user_id, role, added_by)\n SELECT dm.id, m.user_id, CASE WHEN m.role = 'owner' THEN 'admin' ELSE 'member' END, b.user_id\n FROM dm_conversations dm\n JOIN vibe_books b ON b.id = dm.book_id\n JOIN vibe_book_members m ON m.book_id = dm.book_id\n WHERE dm.book_id IS NOT NULL\n ON CONFLICT (conversation_id, user_id) DO NOTHING\n `.catch(() => {});\n await sql`\n UPDATE dm_group_members gm SET role = 'admin'\n WHERE gm.role <> 'admin'\n AND EXISTS (\n SELECT 1 FROM dm_conversations dm\n JOIN vibe_books b ON b.id = dm.book_id\n WHERE dm.id = gm.conversation_id AND b.user_id = gm.user_id\n )\n `.catch(() => {});\n } catch (err) {\n console.warn(\n \"[vibe-books-conversations] backfill failed:\",\n (err as any)?.message,\n );\n }\n}","deleted",false,"label",[14],"200f8efb-f4ef-4117-ae26-ee737dbffb76",["D",1785339526786],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Avec l'API d'mAI, récupérez des données sur les projets !","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/cdf5d0c3-f220-4dec-712e-87455a037c00/square512?exp=1789559999&sig=44d65b20aca1395c040b27dce3cf5970992d3b5971734091c27b34722b3f854e","userId","7ed13655-83c2-4934-a981-01578302df33","pinnedFileId","968028a2-8b63-11f1-b718-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f99eb-d944-7332-99f8-2fbb8b1e7011","tursoName","200f8efbf4ef4117ae26ee737dbffb76","tursoHostname","200f8efbf4ef4117ae26ee737dbffb76-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789474235934],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_107":103},"org",{"_9":10,"_100":101,"_102":103,"_56":57,"_104":105,"_106":42},"branch",{"_35":90,"_11":91,"_22":28,"_92":45,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":12,"_99":10},"isOwned",364,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","mProjects","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/ec72623f-c02d-461a-9b1c-c2f416214400/square512?exp=1789559999&sig=bcfd1f5ab77bb912afaf0a89c6d083b06e2fc9d16c57c458e9715d7dd7ff5ca4","tier","free","canRestrictVals","profileImageUrl","ctx",{"_83":-5,"_141":142,"_143":144,"_145":146,"_147":42,"_148":42,"_149":42,"_150":32,"_151":-5,"_152":-7,"_153":-7,"_154":64,"_155":42,"_156":42,"_157":-5,"_158":42,"_159":42,"_160":42,"_161":-5},"ENV",{"_112":113,"_114":115,"_116":91,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138,"_139":140},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]