[{"_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.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.ts","extension","id","5c134c07-262f-4e76-8826-2990e21cb817","fileId","a3562b8a-a9c2-11f1-b9fd-1607ee4eb77e","parentId","branchId","3345cb6c-eeb2-4b61-ab03-8e0abc2dcd73","branchVersion",342,"latest",true,"createdAt",["D",1789312015279],"version",8,"fileType","script","content","/**\n * ============================================================================\n * VIBE SOCIAL PLATFORM — BOOKS / VIBE PRÉFÉRÉES (vibe-books.ts)\n * Collections de Vibe (max 5 Livres possédés par compte), avec icône lucide +\n * titre. Les Livres sont COLLABORATIFS : on les rejoint par lien/code, tous\n * les membres peuvent inviter et enrichir, seul le créateur renomme/supprime.\n * ============================================================================\n */\n\nimport type { Hono } from \"npm:hono@4\";\nimport { extractToken, getDb, verifyToken } from \"./config.ts\";\nimport type { RegisterMultiFn } from \"./vibe-common.ts\";\nimport {\n attachBookRefs,\n attachQuotedPosts,\n stripHtmlTags,\n} from \"./vibe-posts-core.ts\";\nimport { pushRealtimeEvent } from \"./realtime.ts\";\nimport { pushToUsers } from \"./vibe-dms-core.ts\";\nimport {\n backfillBookConversations,\n deleteBookConversation,\n ensureBookConversation,\n getBookConversationId,\n removeBookConversationMember,\n renameBookConversation,\n transferBookConversationOwnership,\n} from \"./vibe-books-conversations.ts\";\n\n/** Limite de Livres possédés par compte (les Livres rejoints ne comptent pas). */\nexport const MAX_BOOKS_PER_USER = 5;\n\n/** Alphabet sans caractères ambigus (pas de I, L, O, 0, 1). */\nexport const BOOK_CODE_ALPHABET = \"ABCDEFGHJKMNPQRSTUVWXYZ23456789\";\nexport const BOOK_CODE_LENGTH = 8;\n\nexport function makeBookCode(): string {\n const bytes = new Uint8Array(BOOK_CODE_LENGTH);\n crypto.getRandomValues(bytes);\n let code = \"\";\n for (let i = 0; i < BOOK_CODE_LENGTH; i++) {\n code += BOOK_CODE_ALPHABET[bytes[i] % BOOK_CODE_ALPHABET.length];\n }\n return code;\n}\n\n/** Normalise un code brut ou une URL de partage (« .../books/join/CODE »). */\nexport function normalizeBookCode(raw: unknown): string {\n const text = String(raw ?? \"\").trim();\n if (!text) return \"\";\n const segment = text.includes(\"/\")\n ? text.split(/[/?#]/).filter(Boolean).pop() || \"\"\n : text;\n return segment.toUpperCase().replace(/[^A-Z0-9]/g, \"\").slice(0, 12);\n}\n\nlet booksSchemaReady = false;\nexport async function ensureBooksTables(sql: any) {\n if (booksSchemaReady) return;\n try {\n await sql`\n CREATE TABLE IF NOT EXISTS vibe_books (\n id UUID PRIMARY KEY DEFAULT gen_random_uuid(),\n user_id INTEGER NOT NULL,\n title VARCHAR(60) NOT NULL,\n icon VARCHAR(40) NOT NULL DEFAULT 'BookHeart',\n created_at TIMESTAMPTZ DEFAULT NOW()\n )\n `;\n await sql`\n CREATE TABLE IF NOT EXISTS vibe_book_items (\n book_id UUID NOT NULL REFERENCES vibe_books(id) ON DELETE CASCADE,\n post_id UUID NOT NULL REFERENCES posts(id) ON DELETE CASCADE,\n added_at TIMESTAMPTZ DEFAULT NOW(),\n PRIMARY KEY (book_id, post_id)\n )\n `;\n // Collaboration : code de partage + attribution des Vibe ajoutées\n await sql`ALTER TABLE vibe_books ADD COLUMN IF NOT EXISTS join_code VARCHAR(12)`;\n await sql`ALTER TABLE vibe_books ADD COLUMN IF NOT EXISTS updated_at TIMESTAMPTZ DEFAULT NOW()`;\n await sql`CREATE UNIQUE INDEX IF NOT EXISTS idx_vibe_books_join_code ON vibe_books(join_code) WHERE join_code IS NOT NULL`;\n // Livres publics (lecture seule par tous) + références de livres dans les posts\n await sql`ALTER TABLE vibe_books ADD COLUMN IF NOT EXISTS is_public BOOLEAN DEFAULT FALSE`;\n await sql`\n CREATE TABLE IF NOT EXISTS post_book_refs (\n post_id UUID NOT NULL REFERENCES posts(id) ON DELETE CASCADE,\n book_id UUID NOT NULL REFERENCES vibe_books(id) ON DELETE CASCADE,\n created_at TIMESTAMPTZ DEFAULT NOW(),\n PRIMARY KEY (post_id, book_id)\n )\n `.catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_post_book_refs_book ON post_book_refs(book_id)`\n .catch(() => {});\n await sql`\n CREATE TABLE IF NOT EXISTS vibe_book_members (\n id UUID PRIMARY KEY DEFAULT gen_random_uuid(),\n book_id UUID NOT NULL REFERENCES vibe_books(id) ON DELETE CASCADE,\n user_id BIGINT NOT NULL REFERENCES users(id) ON DELETE CASCADE,\n role VARCHAR(20) DEFAULT 'member',\n joined_at TIMESTAMPTZ DEFAULT NOW(),\n UNIQUE (book_id, user_id)\n )\n `;\n await sql`CREATE INDEX IF NOT EXISTS idx_book_members_book ON vibe_book_members(book_id)`;\n await sql`CREATE INDEX IF NOT EXISTS idx_book_members_user ON vibe_book_members(user_id)`;\n await sql`ALTER TABLE vibe_book_items ADD COLUMN IF NOT EXISTS added_by BIGINT`;\n // Épingles de contenu (max 3 par Livre) + discussion du Livre\n await sql`ALTER TABLE vibe_book_items ADD COLUMN IF NOT EXISTS is_pinned BOOLEAN DEFAULT FALSE`\n .catch(() => {});\n await sql`ALTER TABLE vibe_book_items ADD COLUMN IF NOT EXISTS pinned_at TIMESTAMPTZ`\n .catch(() => {});\n await sql`ALTER TABLE vibe_book_items ADD COLUMN IF NOT EXISTS pinned_by BIGINT`\n .catch(() => {});\n await sql`\n CREATE TABLE IF NOT EXISTS vibe_book_comments (\n id UUID PRIMARY KEY DEFAULT gen_random_uuid(),\n book_id UUID NOT NULL REFERENCES vibe_books(id) ON DELETE CASCADE,\n user_id BIGINT NOT NULL REFERENCES users(id) ON DELETE CASCADE,\n content TEXT NOT NULL,\n created_at TIMESTAMPTZ DEFAULT NOW()\n )\n `.catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_book_comments_book ON vibe_book_comments(book_id, created_at DESC)`\n .catch(() => {});\n // Discussion : réponses citées + réactions emoji (migration 024)\n await sql`ALTER TABLE vibe_book_comments ADD COLUMN IF NOT EXISTS reply_to_id UUID REFERENCES vibe_book_comments(id) ON DELETE SET NULL`\n .catch(() => {});\n await sql`\n CREATE TABLE IF NOT EXISTS vibe_book_comment_reactions (\n id UUID PRIMARY KEY DEFAULT gen_random_uuid(),\n comment_id UUID NOT NULL REFERENCES vibe_book_comments(id) ON DELETE CASCADE,\n user_id BIGINT NOT NULL,\n emoji TEXT NOT NULL,\n created_at TIMESTAMPTZ DEFAULT NOW(),\n UNIQUE (comment_id, user_id, emoji)\n )\n `.catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_book_comment_reactions_comment ON vibe_book_comment_reactions(comment_id)`\n .catch(() => {});\n // Rétro-compat : inscrire les créateurs existants comme membres propriétaires\n await sql`\n INSERT INTO vibe_book_members (book_id, user_id, role)\n SELECT b.id, b.user_id, 'owner' FROM vibe_books b\n WHERE NOT EXISTS (SELECT 1 FROM vibe_book_members m WHERE m.book_id = b.id AND m.user_id = b.user_id)\n `.catch(() => {});\n // Rétro-compat : doter les Livres existants d'un code de partage\n const missing =\n await sql`SELECT id FROM vibe_books WHERE join_code IS NULL LIMIT 500`\n .catch(() => []);\n for (const row of missing) {\n for (let attempt = 0; attempt < 5; attempt++) {\n try {\n await sql`UPDATE vibe_books SET join_code = ${makeBookCode()} WHERE id = ${row.id}::uuid AND join_code IS NULL`;\n break;\n } catch {\n // collision de code : nouvelle tentative\n }\n }\n }\n // Conversation Messages de chaque Livre (création + rattachement des membres)\n await backfillBookConversations(sql).catch(() => {});\n booksSchemaReady = true;\n } catch (err) {\n console.error(\"[vibe-books] ensure tables error:\", err);\n }\n}\n\nasync function getAuthUserId(c: any): Promise {\n try {\n const token = extractToken(c.req.raw);\n if (!token) return null;\n const payload = await verifyToken(token);\n const userId = Number(\n payload.sub || (payload as any).id || (payload as any).userId,\n );\n return userId && !isNaN(userId) ? userId : null;\n } catch {\n return null;\n }\n}\n\n/** Clause d'appartenance : propriétaire OU membre inscrit. */\nconst bookAccessClause = (sql: any, userId: number) =>\n sql`\n (b.user_id = ${userId} OR EXISTS (SELECT 1 FROM vibe_book_members m WHERE m.book_id = b.id AND m.user_id = ${userId}))\n`;\n\nasync function fetchBookMembers(sql: any, bookId: string) {\n return await sql`\n SELECT m.user_id, m.role, m.joined_at, u.username, pr.display_name, pr.avatar_url\n FROM vibe_book_members m\n JOIN users u ON u.id = m.user_id\n LEFT JOIN profiles pr ON pr.user_id = m.user_id\n WHERE m.book_id = ${bookId}::uuid\n ORDER BY (m.role = 'owner') DESC, m.joined_at ASC\n LIMIT 100\n `;\n}\n\nexport function registerVibeBooksRoutes(\n app: Hono,\n registerMulti: RegisterMultiFn,\n) {\n // 1. LISTE DES LIVRES ACCESSIBLES (possédés + rejoints)\n const handleListBooks = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const sql = getDb();\n await ensureBooksTables(sql);\n\n const postId = c.req.query(\"post_id\") || \"\";\n const rows = await sql`\n SELECT b.id, b.title, b.icon, b.created_at, b.join_code, b.user_id, COALESCE(b.is_public, FALSE) AS is_public,\n (b.user_id = ${userId}) AS is_owner,\n COALESCE(\n (SELECT m.role FROM vibe_book_members m WHERE m.book_id = b.id AND m.user_id = ${userId} LIMIT 1),\n CASE WHEN b.user_id = ${userId} THEN 'owner' ELSE 'member' END\n ) AS role,\n (SELECT COUNT(*) FROM vibe_book_items bi WHERE bi.book_id = b.id) AS items_count,\n (SELECT COUNT(*) FROM vibe_book_members bm WHERE bm.book_id = b.id) AS members_count,\n (SELECT dm.id FROM dm_conversations dm WHERE dm.book_id = b.id LIMIT 1) AS conversation_id,\n ${\n postId\n ? sql`EXISTS (SELECT 1 FROM vibe_book_items bi2 WHERE bi2.book_id = b.id AND bi2.post_id = ${postId}::uuid)`\n : sql`FALSE`\n } AS contains_post\n FROM vibe_books b\n WHERE ${bookAccessClause(sql, userId)}\n ORDER BY (b.user_id = ${userId}) DESC, b.created_at ASC\n `;\n\n const ownedRows =\n await sql`SELECT COUNT(*) AS n FROM vibe_books WHERE user_id = ${userId}`;\n\n return c.json({\n success: true,\n books: rows,\n maxBooks: MAX_BOOKS_PER_USER,\n ownedCount: Number(ownedRows[0]?.n || 0),\n });\n } catch (err: any) {\n console.error(\"[vibe-books] List error:\", err);\n return c.json(\n { error: \"Erreur lors de la récupération des Livres.\" },\n 500,\n );\n }\n };\n registerMulti(\n \"get\",\n [\"/api/vibe/books\", \"/vibe/books\", \"/v1/books\"],\n handleListBooks,\n );\n\n // 2. CRÉATION D'UN LIVRE (max 5 possédés par compte, code de partage inclus)\n const handleCreateBook = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const body = await c.req.json().catch(() => ({}));\n const title = String(body?.title || \"\").trim();\n const icon = String(body?.icon || \"BookHeart\").trim().slice(0, 40);\n const isPublic = Boolean(body?.is_public);\n\n if (!title) {\n return c.json(\n { error: \"Veuillez donner un titre à votre Livre.\" },\n 400,\n );\n }\n if (title.length > 60) {\n return c.json({ error: \"Le titre est limité à 60 caractères.\" }, 400);\n }\n\n const sql = getDb();\n await ensureBooksTables(sql);\n const countRows =\n await sql`SELECT COUNT(*) AS n FROM vibe_books WHERE user_id = ${userId}`;\n if (Number(countRows[0]?.n || 0) >= MAX_BOOKS_PER_USER) {\n return c.json({\n error:\n `Vous avez atteint la limite de ${MAX_BOOKS_PER_USER} Livres par compte.`,\n }, 403);\n }\n\n let inserted: any[] = [];\n for (let attempt = 0; attempt < 5 && inserted.length === 0; attempt++) {\n const code = makeBookCode();\n try {\n inserted = await sql`\n INSERT INTO vibe_books (user_id, title, icon, join_code, is_public)\n VALUES (${userId}, ${title}, ${icon}, ${code}, ${isPublic})\n RETURNING id, title, icon, created_at, join_code, is_public\n `;\n } catch (err: any) {\n const msg = String(err?.message || \"\").toLowerCase();\n if (!msg.includes(\"duplicate\") && !msg.includes(\"unique\")) throw err;\n }\n }\n if (inserted.length === 0) {\n return c.json(\n { error: \"Impossible de créer le Livre. Réessayez.\" },\n 500,\n );\n }\n\n await sql`\n INSERT INTO vibe_book_members (book_id, user_id, role)\n VALUES (${inserted[0].id}::uuid, ${userId}, 'owner')\n ON CONFLICT (book_id, user_id) DO NOTHING\n `.catch(() => {});\n\n // Conversation Messages du Livre : créée immédiatement pour le propriétaire\n const conversationId = await ensureBookConversation(sql, {\n id: String(inserted[0].id),\n user_id: userId,\n title: String(inserted[0].title || title),\n }).catch(() => null);\n if (conversationId) {\n await pushRealtimeEvent(userId, \"group_updated\", {\n conversation_id: conversationId,\n action: \"created\",\n book_id: String(inserted[0].id),\n }).catch(() => {});\n }\n\n return c.json({\n success: true,\n book: {\n ...inserted[0],\n items_count: 0,\n contains_post: false,\n is_owner: true,\n role: \"owner\",\n members_count: 1,\n conversation_id: conversationId || null,\n },\n }, 201);\n } catch (err: any) {\n console.error(\"[vibe-books] Create error:\", err);\n return c.json({ error: \"Erreur lors de la création du Livre.\" }, 500);\n }\n };\n registerMulti(\n \"post\",\n [\"/api/vibe/books\", \"/vibe/books\", \"/v1/books\"],\n handleCreateBook,\n );\n\n // 3. MISE À JOUR D'UN LIVRE (titre / icône — créateur uniquement)\n const handleUpdateBook = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const bookId = c.req.param(\"bookId\");\n const body = await c.req.json().catch(() => ({}));\n const title = body?.title !== undefined\n ? String(body.title).trim()\n : null;\n const icon = body?.icon !== undefined\n ? String(body.icon).trim().slice(0, 40)\n : null;\n const isPublic = body?.is_public !== undefined\n ? Boolean(body.is_public)\n : null;\n\n if (title !== null && !title) {\n return c.json({ error: \"Le titre ne peut pas être vide.\" }, 400);\n }\n\n const sql = getDb();\n await ensureBooksTables(sql);\n const updated = await sql`\n UPDATE vibe_books SET\n title = ${title ?? sql`title`},\n icon = ${icon ?? sql`icon`},\n is_public = ${isPublic ?? sql`is_public`},\n updated_at = NOW()\n WHERE id = ${bookId}::uuid AND user_id = ${userId}\n RETURNING id, title, icon, created_at, join_code, is_public\n `;\n if (updated.length === 0) {\n return c.json({ error: \"Livre introuvable.\" }, 404);\n }\n\n // Synchro du titre de la conversation Messages du Livre\n if (title) {\n await renameBookConversation(sql, bookId, title).catch(() => {});\n }\n\n return c.json({\n success: true,\n book: {\n ...updated[0],\n is_owner: true,\n role: \"owner\",\n conversation_id: await getBookConversationId(sql, bookId),\n },\n });\n } catch (err: any) {\n console.error(\"[vibe-books] Update error:\", err);\n return c.json({ error: \"Erreur lors de la mise à jour du Livre.\" }, 500);\n }\n };\n registerMulti(\"post\", [\n \"/api/vibe/books/:bookId/update\",\n \"/vibe/books/:bookId/update\",\n \"/v1/books/:bookId/update\",\n ], handleUpdateBook);\n\n // 4. SUPPRESSION D'UN LIVRE (créateur uniquement, les Vibe ne sont pas supprimées)\n const handleDeleteBook = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const bookId = c.req.param(\"bookId\");\n const sql = getDb();\n await ensureBooksTables(sql);\n const deleted = await sql`\n DELETE FROM vibe_books WHERE id = ${bookId}::uuid AND user_id = ${userId} RETURNING id\n `;\n if (deleted.length === 0) {\n return c.json({ error: \"Livre introuvable.\" }, 404);\n }\n await deleteBookConversation(sql, bookId).catch(() => {});\n return c.json({ success: true });\n } catch (err: any) {\n console.error(\"[vibe-books] Delete error:\", err);\n return c.json({ error: \"Erreur lors de la suppression du Livre.\" }, 500);\n }\n };\n registerMulti(\"delete\", [\n \"/api/vibe/books/:bookId\",\n \"/vibe/books/:bookId\",\n \"/v1/books/:bookId\",\n ], handleDeleteBook);\n\n // 5. REJOINDRE UN LIVRE PAR CODE / LIEN (adhésion immédiate)\n const handleJoinBook = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const body = await c.req.json().catch(() => ({}));\n const code = normalizeBookCode(body?.code);\n if (code.length < 4) {\n return c.json(\n { success: false, error: \"Code d'invitation invalide.\" },\n 400,\n );\n }\n\n const sql = getDb();\n await ensureBooksTables(sql);\n const rows = await sql`\n SELECT id, user_id, title, icon, join_code FROM vibe_books WHERE join_code = ${code} LIMIT 1\n `;\n if (rows.length === 0) {\n return c.json({\n success: false,\n error: \"Aucun Livre ne correspond à ce code.\",\n }, 404);\n }\n\n const book = rows[0];\n const isOwner = Number(book.user_id) === userId;\n let alreadyMember = isOwner;\n if (!isOwner) {\n const inserted = await sql`\n INSERT INTO vibe_book_members (book_id, user_id, role)\n VALUES (${book.id}::uuid, ${userId}, 'member')\n ON CONFLICT (book_id, user_id) DO NOTHING\n RETURNING id\n `;\n alreadyMember = inserted.length === 0;\n if (!alreadyMember) {\n await sql`UPDATE vibe_books SET updated_at = NOW() WHERE id = ${book.id}::uuid`\n .catch(() => {});\n try {\n await sql`\n INSERT INTO notifications (recipient_id, actor_id, type, message)\n VALUES (${book.user_id}, ${userId}, 'book_join', ${`a rejoint votre Livre « ${book.title} »`})\n `;\n await pushRealtimeEvent(Number(book.user_id), \"notification\", {\n type: \"book_join\",\n book_id: book.id,\n actor_id: userId,\n });\n } catch {\n // notification best-effort\n }\n }\n }\n\n const countRows =\n await sql`SELECT COUNT(*) AS n FROM vibe_book_members WHERE book_id = ${book.id}::uuid`;\n\n // Conversation Messages du Livre : garantie + membres synchronisés\n const conversationId = await ensureBookConversation(sql, {\n id: String(book.id),\n user_id: Number(book.user_id),\n title: String(book.title),\n }).catch(() => null);\n if (conversationId && !alreadyMember) {\n const memberRows = await sql`\n SELECT user_id FROM dm_group_members WHERE conversation_id = ${conversationId}::uuid\n `.catch(() => []);\n const memberIds = (memberRows as any[]).map((r) => Number(r.user_id));\n await pushToUsers(\n memberIds.length > 0 ? memberIds : [userId],\n \"group_updated\",\n {\n conversation_id: conversationId,\n action: \"added\",\n book_id: String(book.id),\n },\n ).catch(() => {});\n }\n\n return c.json({\n success: true,\n already_member: alreadyMember,\n book: {\n id: book.id,\n title: book.title,\n icon: book.icon,\n join_code: book.join_code,\n user_id: book.user_id,\n is_owner: isOwner,\n role: isOwner ? \"owner\" : \"member\",\n members_count: Number(countRows[0]?.n || 0),\n conversation_id: conversationId || null,\n },\n });\n } catch (err: any) {\n console.error(\"[vibe-books] Join error:\", err);\n return c.json({ error: \"Erreur lors de la jointure du Livre.\" }, 500);\n }\n };\n registerMulti(\"post\", [\n \"/api/vibe/books/join\",\n \"/vibe/books/join\",\n \"/v1/books/join\",\n ], handleJoinBook);\n\n // 6. MEMBRES D'UN LIVRE (qui a rejoint)\n const handleGetBookMembers = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const bookId = c.req.param(\"bookId\");\n const sql = getDb();\n await ensureBooksTables(sql);\n\n const access = await sql`\n SELECT b.id FROM vibe_books b WHERE b.id = ${bookId}::uuid AND ${\n bookAccessClause(sql, userId)\n } LIMIT 1\n `;\n if (access.length === 0) {\n return c.json({ error: \"Livre introuvable.\" }, 404);\n }\n\n const members = await fetchBookMembers(sql, bookId);\n return c.json({ success: true, members });\n } catch (err: any) {\n console.error(\"[vibe-books] Members error:\", err);\n return c.json(\n { error: \"Erreur lors de la récupération des membres.\" },\n 500,\n );\n }\n };\n registerMulti(\"get\", [\n \"/api/vibe/books/:bookId/members\",\n \"/vibe/books/:bookId/members\",\n \"/v1/books/:bookId/members\",\n ], handleGetBookMembers);\n\n // 7. QUITTER UN LIVRE (membres non propriétaires)\n const handleLeaveBook = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const bookId = c.req.param(\"bookId\");\n const sql = getDb();\n await ensureBooksTables(sql);\n\n const rows =\n await sql`SELECT id, user_id FROM vibe_books WHERE id = ${bookId}::uuid LIMIT 1`;\n if (rows.length === 0) {\n return c.json({ error: \"Livre introuvable.\" }, 404);\n }\n if (Number(rows[0].user_id) === userId) {\n return c.json({\n success: false,\n error:\n \"Le créateur ne peut pas quitter son Livre. Supprimez-le à la place.\",\n code: \"OWNER_CANNOT_LEAVE\",\n }, 403);\n }\n\n const deleted = await sql`\n DELETE FROM vibe_book_members\n WHERE book_id = ${bookId}::uuid AND user_id = ${userId}\n RETURNING id\n `;\n if (deleted.length === 0) {\n return c.json({ error: \"Livre introuvable.\" }, 404);\n }\n\n await removeBookConversationMember(sql, bookId, userId).catch(() => {});\n return c.json({ success: true });\n } catch (err: any) {\n console.error(\"[vibe-books] Leave error:\", err);\n return c.json({ error: \"Erreur lors de la sortie du Livre.\" }, 500);\n }\n };\n registerMulti(\"post\", [\n \"/api/vibe/books/:bookId/leave\",\n \"/vibe/books/:bookId/leave\",\n \"/v1/books/:bookId/leave\",\n ], handleLeaveBook);\n\n // 8. RÉGÉNÉRER LE CODE DE PARTAGE (créateur uniquement, invalide l'ancien lien)\n const handleRegenerateCode = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const bookId = c.req.param(\"bookId\");\n const sql = getDb();\n await ensureBooksTables(sql);\n\n const rows = await sql`\n SELECT id FROM vibe_books WHERE id = ${bookId}::uuid AND user_id = ${userId} LIMIT 1\n `;\n if (rows.length === 0) {\n return c.json({ error: \"Livre introuvable.\" }, 404);\n }\n\n for (let attempt = 0; attempt < 5; attempt++) {\n const code = makeBookCode();\n try {\n const updated = await sql`\n UPDATE vibe_books SET join_code = ${code}, updated_at = NOW()\n WHERE id = ${bookId}::uuid\n RETURNING join_code\n `;\n return c.json({\n success: true,\n join_code: updated[0]?.join_code || code,\n });\n } catch {\n // collision de code : nouvelle tentative\n }\n }\n return c.json({ error: \"Impossible de générer un nouveau code.\" }, 500);\n } catch (err: any) {\n console.error(\"[vibe-books] Regenerate error:\", err);\n return c.json({ error: \"Erreur lors de la régénération du code.\" }, 500);\n }\n };\n registerMulti(\"post\", [\n \"/api/vibe/books/:bookId/regenerate-code\",\n \"/vibe/books/:bookId/regenerate-code\",\n \"/v1/books/:bookId/regenerate-code\",\n ], handleRegenerateCode);\n\n // 9. ENREGISTRER / RETIRER UNE VIBE D'UN LIVRE (toggle, tout membre)\n const handleToggleBookItem = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const bookId = c.req.param(\"bookId\");\n const postId = c.req.param(\"postId\");\n const sql = getDb();\n await ensureBooksTables(sql);\n\n const access = await sql`\n SELECT b.id FROM vibe_books b WHERE b.id = ${bookId}::uuid AND ${\n bookAccessClause(sql, userId)\n } LIMIT 1\n `;\n if (access.length === 0) {\n return c.json({ error: \"Livre introuvable.\" }, 404);\n }\n\n const exists =\n await sql`SELECT 1 FROM posts WHERE id = ${postId}::uuid LIMIT 1`;\n if (exists.length === 0) {\n return c.json({ error: \"Publication introuvable.\" }, 404);\n }\n\n const already = await sql`\n SELECT 1 FROM vibe_book_items WHERE book_id = ${bookId}::uuid AND post_id = ${postId}::uuid\n `;\n if (already.length > 0) {\n await sql`DELETE FROM vibe_book_items WHERE book_id = ${bookId}::uuid AND post_id = ${postId}::uuid`;\n return c.json({ success: true, saved: false });\n } else {\n await sql`\n INSERT INTO vibe_book_items (book_id, post_id, added_by)\n VALUES (${bookId}::uuid, ${postId}::uuid, ${userId})\n ON CONFLICT DO NOTHING\n `;\n return c.json({ success: true, saved: true });\n }\n } catch (err: any) {\n console.error(\"[vibe-books] Toggle item error:\", err);\n return c.json(\n { error: \"Erreur lors de l'enregistrement dans le Livre.\" },\n 500,\n );\n }\n };\n registerMulti(\"post\", [\n \"/api/vibe/books/:bookId/posts/:postId\",\n \"/vibe/books/:bookId/posts/:postId\",\n \"/v1/books/:bookId/posts/:postId\",\n ], handleToggleBookItem);\n\n // 10. CONTENU D'UN LIVRE (Vibe partagées + membres, même forme que le fil)\n const handleGetBookPosts = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const bookId = c.req.param(\"bookId\");\n const sql = getDb();\n await ensureBooksTables(sql);\n\n const bookRows = await sql`\n SELECT b.id, b.title, b.icon, b.created_at, b.join_code, b.user_id, COALESCE(b.is_public, FALSE) AS is_public,\n (b.user_id = ${userId}) AS is_owner,\n (b.user_id = ${userId} OR EXISTS (SELECT 1 FROM vibe_book_members m2 WHERE m2.book_id = b.id AND m2.user_id = ${userId})) AS is_member,\n COALESCE(\n (SELECT m.role FROM vibe_book_members m WHERE m.book_id = b.id AND m.user_id = ${userId} LIMIT 1),\n CASE WHEN b.user_id = ${userId} THEN 'owner' ELSE 'member' END\n ) AS role,\n (SELECT COUNT(*) FROM vibe_book_members bm WHERE bm.book_id = b.id) AS members_count,\n (SELECT dm.id FROM dm_conversations dm WHERE dm.book_id = b.id LIMIT 1) AS conversation_id\n FROM vibe_books b\n WHERE b.id = ${bookId}::uuid AND (${\n bookAccessClause(sql, userId)\n } OR COALESCE(b.is_public, FALSE) = TRUE)\n LIMIT 1\n `;\n if (bookRows.length === 0) {\n return c.json({ error: \"Livre introuvable.\" }, 404);\n }\n\n // Un simple lecteur d'un Livre public ne doit jamais voir le code d'invitation\n const book: any = { ...bookRows[0] };\n if (!book.is_member) {\n delete book.join_code;\n }\n\n const rows = await sql`\n SELECT p.*, pr.display_name, pr.avatar_url, u.username,\n (SELECT COUNT(*) FROM post_interactions WHERE post_id = p.id AND user_id = ${userId} AND interaction_type = 'like') > 0 as has_liked,\n (SELECT COUNT(*) FROM post_interactions WHERE post_id = p.id AND user_id = ${userId} AND interaction_type = 'repost') > 0 as has_reposted,\n (SELECT COUNT(*) FROM bookmarks WHERE post_id = p.id AND user_id = ${userId}) > 0 as has_bookmarked,\n (SELECT pi.interaction_type FROM post_interactions pi WHERE pi.post_id = p.id AND pi.user_id = ${userId} AND pi.interaction_type IN ('interest_more', 'interest_less') LIMIT 1) as my_feedback,\n bi.added_at as saved_at,\n bi.added_by,\n COALESCE(bi.is_pinned, FALSE) AS is_pinned,\n bi.pinned_at,\n au.username AS added_by_username,\n ap.display_name AS added_by_display_name,\n ap.avatar_url AS added_by_avatar_url\n FROM vibe_book_items bi\n JOIN posts p ON p.id = bi.post_id\n JOIN users u ON u.id = p.author_id\n LEFT JOIN profiles pr ON pr.user_id = u.id\n LEFT JOIN users au ON au.id = bi.added_by\n LEFT JOIN profiles ap ON ap.user_id = bi.added_by\n WHERE bi.book_id = ${bookId}::uuid\n AND (COALESCE(p.status, 'published') <> 'scheduled' OR p.author_id = ${userId})\n ORDER BY COALESCE(bi.is_pinned, FALSE) DESC, bi.pinned_at DESC NULLS LAST, bi.added_at DESC\n LIMIT 200\n `;\n\n const ids = rows.map((r: any) => String(r.id));\n const media = ids.length\n ? await sql`SELECT post_id, url, media_type, alt_text FROM media_assets WHERE post_id = ANY(${ids}::uuid[])`\n : [];\n const byPost: Record = {};\n for (const m of media) {\n (byPost[String(m.post_id)] ||= []).push(m);\n }\n const posts = rows.map((r: any) => ({\n ...r,\n media_assets: byPost[String(r.id)] || [],\n }));\n await attachQuotedPosts(posts);\n await attachBookRefs(posts, userId).catch(() => {});\n\n // Membres visibles uniquement pour les membres/propriétaires du Livre\n const members = book.is_member ? await fetchBookMembers(sql, bookId) : [];\n\n return c.json({ success: true, book, members, posts });\n } catch (err: any) {\n console.error(\"[vibe-books] Book posts error:\", err);\n return c.json({ error: \"Erreur lors de la récupération du Livre.\" }, 500);\n }\n };\n registerMulti(\"get\", [\n \"/api/vibe/books/:bookId/posts\",\n \"/vibe/books/:bookId/posts\",\n \"/v1/books/:bookId/posts\",\n ], handleGetBookPosts);\n\n // 11. LIVRES CONTENANT UNE VIBE DONNÉE (badge du PostCard)\n const handleBooksForPost = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const postId = c.req.param(\"postId\");\n const sql = getDb();\n await ensureBooksTables(sql);\n\n const rows = await sql`\n SELECT bi.book_id FROM vibe_book_items bi\n JOIN vibe_books b ON b.id = bi.book_id\n WHERE bi.post_id = ${postId}::uuid AND ${bookAccessClause(sql, userId)}\n `;\n\n return c.json({\n success: true,\n book_ids: rows.map((r: any) => String(r.book_id)),\n });\n } catch (err: any) {\n console.error(\"[vibe-books] Books for post error:\", err);\n return c.json(\n { error: \"Erreur lors de la vérification des Livres.\" },\n 500,\n );\n }\n };\n registerMulti(\"get\", [\n \"/api/vibe/books/for-post/:postId\",\n \"/vibe/books/for-post/:postId\",\n \"/v1/books/for-post/:postId\",\n ], handleBooksForPost);\n\n // 12. ÉPINGLER UNE VIBE DANS UN LIVRE (max 3 par Livre, membres autorisés)\n const handlePinBookPost = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const bookId = c.req.param(\"bookId\");\n const postId = c.req.param(\"postId\");\n const body = await c.req.json().catch(() => ({}));\n const pinned = body?.pinned !== false;\n\n const sql = getDb();\n await ensureBooksTables(sql);\n\n const access = await sql`\n SELECT b.id FROM vibe_books b\n WHERE b.id = ${bookId}::uuid AND ${bookAccessClause(sql, userId)}\n LIMIT 1\n `;\n if (access.length === 0) {\n return c.json({ error: \"Livre introuvable.\" }, 404);\n }\n\n const item = await sql`\n SELECT 1 FROM vibe_book_items WHERE book_id = ${bookId}::uuid AND post_id = ${postId}::uuid LIMIT 1\n `;\n if (item.length === 0) {\n return c.json({ error: \"Cette Vibe n'est pas dans ce Livre.\" }, 404);\n }\n\n if (pinned) {\n const countRows = await sql`\n SELECT COUNT(*) AS n FROM vibe_book_items\n WHERE book_id = ${bookId}::uuid AND COALESCE(is_pinned, FALSE) = TRUE AND post_id <> ${postId}::uuid\n `;\n if (Number(countRows[0]?.n || 0) >= 3) {\n return c.json({\n error: \"Maximum 3 Vibes épinglées par Livre.\",\n code: \"PIN_LIMIT\",\n }, 403);\n }\n await sql`\n UPDATE vibe_book_items SET is_pinned = TRUE, pinned_at = NOW(), pinned_by = ${userId}\n WHERE book_id = ${bookId}::uuid AND post_id = ${postId}::uuid\n `;\n } else {\n await sql`\n UPDATE vibe_book_items SET is_pinned = FALSE, pinned_at = NULL, pinned_by = NULL\n WHERE book_id = ${bookId}::uuid AND post_id = ${postId}::uuid\n `;\n }\n await sql`UPDATE vibe_books SET updated_at = NOW() WHERE id = ${bookId}::uuid`\n .catch(() => {});\n return c.json({ success: true, pinned });\n } catch (err: any) {\n console.error(\"[vibe-books] Pin error:\", err);\n return c.json({ error: \"Erreur lors de l'épinglage.\" }, 500);\n }\n };\n registerMulti(\"post\", [\n \"/api/vibe/books/:bookId/posts/:postId/pin\",\n \"/vibe/books/:bookId/posts/:postId/pin\",\n \"/v1/books/:bookId/posts/:postId/pin\",\n ], handlePinBookPost);\n\n // 13. EXCLURE UN MEMBRE DU LIVRE (créateur uniquement)\n const handleKickBookMember = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const bookId = c.req.param(\"bookId\");\n const targetId = Number(c.req.param(\"userId\"));\n if (!targetId) return c.json({ error: \"Membre invalide.\" }, 400);\n\n const sql = getDb();\n await ensureBooksTables(sql);\n const bookRows =\n await sql`SELECT user_id, title FROM vibe_books WHERE id = ${bookId}::uuid LIMIT 1`;\n if (bookRows.length === 0) {\n return c.json({ error: \"Livre introuvable.\" }, 404);\n }\n if (Number(bookRows[0].user_id) !== userId) {\n return c.json({\n error: \"Seul le créateur du Livre peut exclure un membre.\",\n }, 403);\n }\n if (targetId === userId) {\n return c.json({\n error: \"Le créateur ne peut pas s'exclure de son propre Livre.\",\n }, 400);\n }\n\n const del = await sql`\n DELETE FROM vibe_book_members WHERE book_id = ${bookId}::uuid AND user_id = ${targetId} RETURNING 1\n `;\n if (del.length === 0) {\n return c.json({ error: \"Ce membre ne fait pas partie du Livre.\" }, 404);\n }\n\n await removeBookConversationMember(sql, bookId, targetId).catch(() => {});\n\n try {\n await sql`\n INSERT INTO notifications (recipient_id, actor_id, type, message)\n VALUES (${targetId}, ${userId}, 'book_join', ${`vous a retiré du Livre « ${\n bookRows[0].title\n } »`})\n `;\n await pushRealtimeEvent(targetId, \"notification\", {\n type: \"book_join\",\n book_id: bookId,\n actor_id: userId,\n });\n } catch {}\n await sql`UPDATE vibe_books SET updated_at = NOW() WHERE id = ${bookId}::uuid`\n .catch(() => {});\n return c.json({ success: true, removed: targetId });\n } catch (err: any) {\n console.error(\"[vibe-books] Kick error:\", err);\n return c.json({ error: \"Erreur lors de l'exclusion du membre.\" }, 500);\n }\n };\n registerMulti(\"delete\", [\n \"/api/vibe/books/:bookId/members/:userId\",\n \"/vibe/books/:bookId/members/:userId\",\n \"/v1/books/:bookId/members/:userId\",\n ], handleKickBookMember);\n\n // 14. TRANSFÉRER LA PROPRIÉTÉ DU LIVRE (créateur → membre)\n const handleTransferBookOwnership = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const bookId = c.req.param(\"bookId\");\n const targetId = Number(c.req.param(\"userId\"));\n if (!targetId || targetId === userId) {\n return c.json({ error: \"Cible invalide.\" }, 400);\n }\n\n const sql = getDb();\n await ensureBooksTables(sql);\n const bookRows =\n await sql`SELECT user_id, title FROM vibe_books WHERE id = ${bookId}::uuid LIMIT 1`;\n if (bookRows.length === 0) {\n return c.json({ error: \"Livre introuvable.\" }, 404);\n }\n if (Number(bookRows[0].user_id) !== userId) {\n return c.json({\n error: \"Seul le créateur du Livre peut transférer la propriété.\",\n }, 403);\n }\n const targetMember = await sql`\n SELECT 1 FROM vibe_book_members WHERE book_id = ${bookId}::uuid AND user_id = ${targetId} LIMIT 1\n `;\n if (targetMember.length === 0) {\n return c.json({ error: \"Ce membre ne fait pas partie du Livre.\" }, 404);\n }\n\n const updated = await sql`\n UPDATE vibe_books SET user_id = ${targetId}, updated_at = NOW()\n WHERE id = ${bookId}::uuid AND user_id = ${userId}\n RETURNING id\n `;\n if (updated.length === 0) {\n return c.json({ error: \"Transfert impossible.\" }, 409);\n }\n\n await sql`UPDATE vibe_book_members SET role = 'member' WHERE book_id = ${bookId}::uuid AND user_id = ${userId}`;\n await sql`UPDATE vibe_book_members SET role = 'owner' WHERE book_id = ${bookId}::uuid AND user_id = ${targetId}`;\n\n await transferBookConversationOwnership(sql, bookId, userId, targetId)\n .catch(() => {});\n\n try {\n await sql`\n INSERT INTO notifications (recipient_id, actor_id, type, message)\n VALUES (${targetId}, ${userId}, 'book_join', ${`vous a transféré la propriété du Livre « ${\n bookRows[0].title\n } »`})\n `;\n await pushRealtimeEvent(targetId, \"notification\", {\n type: \"book_join\",\n book_id: bookId,\n actor_id: userId,\n });\n } catch {}\n return c.json({ success: true, new_owner: targetId });\n } catch (err: any) {\n console.error(\"[vibe-books] Transfer error:\", err);\n return c.json({ error: \"Erreur lors du transfert de propriété.\" }, 500);\n }\n };\n registerMulti(\"post\", [\n \"/api/vibe/books/:bookId/members/:userId/transfer-ownership\",\n \"/vibe/books/:bookId/members/:userId/transfer-ownership\",\n \"/v1/books/:bookId/members/:userId/transfer-ownership\",\n ], handleTransferBookOwnership);\n\n // 15. DISCUSSION DU LIVRE (commentaires au niveau du Livre)\n const handleGetBookComments = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const bookId = c.req.param(\"bookId\");\n const limit = Math.min(\n 100,\n Math.max(1, Number(c.req.query(\"limit\") || 50)),\n );\n const offset = Math.max(0, Number(c.req.query(\"offset\") || 0));\n\n const sql = getDb();\n await ensureBooksTables(sql);\n const access = await sql`\n SELECT b.id FROM vibe_books b\n WHERE b.id = ${bookId}::uuid AND ${bookAccessClause(sql, userId)}\n LIMIT 1\n `;\n if (access.length === 0) {\n return c.json({ error: \"Livre introuvable.\" }, 404);\n }\n\n const comments = await sql`\n SELECT bc.id, bc.content, bc.created_at, bc.user_id,\n u.username, pr.display_name, pr.avatar_url,\n bc.reply_to_id,\n rc.content AS reply_content, ru.username AS reply_username\n FROM vibe_book_comments bc\n JOIN users u ON u.id = bc.user_id\n LEFT JOIN profiles pr ON pr.user_id = bc.user_id\n LEFT JOIN vibe_book_comments rc ON rc.id = bc.reply_to_id\n LEFT JOIN users ru ON ru.id = rc.user_id\n WHERE bc.book_id = ${bookId}::uuid\n ORDER BY bc.created_at DESC\n LIMIT ${limit} OFFSET ${offset}\n `;\n\n // Réactions emoji agrégées { emoji, count, mine } (modèle DMs)\n try {\n const ids = (comments as any[]).map((cmt) => cmt.id);\n if (ids.length > 0) {\n const reactions = await sql`\n SELECT comment_id, emoji, user_id FROM vibe_book_comment_reactions\n WHERE comment_id = ANY(${ids}::uuid[])\n `;\n const byComment = new Map<\n string,\n { emoji: string; user_id: number }[]\n >();\n for (const r of reactions) {\n const key = String(r.comment_id);\n if (!byComment.has(key)) byComment.set(key, []);\n byComment.get(key)!.push({\n emoji: r.emoji,\n user_id: Number(r.user_id),\n });\n }\n for (const cmt of comments as any[]) {\n const list = byComment.get(String(cmt.id)) || [];\n const grouped: { emoji: string; count: number; mine: boolean }[] =\n [];\n for (const r of list) {\n const g = grouped.find((x) => x.emoji === r.emoji);\n if (g) {\n g.count += 1;\n g.mine = g.mine || r.user_id === userId;\n } else {\n grouped.push({\n emoji: r.emoji,\n count: 1,\n mine: r.user_id === userId,\n });\n }\n }\n cmt.reactions = grouped;\n }\n }\n } catch {}\n for (const cmt of comments as any[]) {\n if (!cmt.reactions) cmt.reactions = [];\n }\n\n return c.json({ success: true, comments });\n } catch (err: any) {\n console.error(\"[vibe-books] Comments list error:\", err);\n return c.json({\n error: \"Erreur lors de la récupération de la discussion.\",\n }, 500);\n }\n };\n registerMulti(\"get\", [\n \"/api/vibe/books/:bookId/comments\",\n \"/vibe/books/:bookId/comments\",\n \"/v1/books/:bookId/comments\",\n ], handleGetBookComments);\n\n const handleAddBookComment = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const bookId = c.req.param(\"bookId\");\n const body = await c.req.json().catch(() => ({}));\n const plain = stripHtmlTags(String(body?.content || \"\")).trim();\n if (!plain) {\n return c.json(\n { error: \"Le message de la discussion est requis.\" },\n 400,\n );\n }\n if (plain.length > 2000) {\n return c.json(\n { error: \"Message trop long (max 2000 caractères).\" },\n 400,\n );\n }\n\n // Réponse citée : le commentaire ciblé doit appartenir au même Livre\n const rawReplyTo = typeof body?.reply_to_id === \"string\"\n ? body.reply_to_id\n : \"\";\n const replyToId =\n /^[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}$/i.test(\n rawReplyTo,\n )\n ? rawReplyTo\n : null;\n\n const sql = getDb();\n await ensureBooksTables(sql);\n const access = await sql`\n SELECT b.id, b.user_id AS owner_id, b.title FROM vibe_books b\n WHERE b.id = ${bookId}::uuid AND ${bookAccessClause(sql, userId)}\n LIMIT 1\n `;\n if (access.length === 0) {\n return c.json({ error: \"Livre introuvable.\" }, 404);\n }\n\n let validReplyTo: string | null = null;\n if (replyToId) {\n const replyRows = await sql`\n SELECT 1 FROM vibe_book_comments\n WHERE id = ${replyToId}::uuid AND book_id = ${bookId}::uuid\n LIMIT 1\n `;\n if (replyRows.length === 0) {\n return c.json({\n error: \"Le message auquel vous répondez est introuvable.\",\n }, 400);\n }\n validReplyTo = replyToId;\n }\n\n const inserted = await sql`\n INSERT INTO vibe_book_comments (book_id, user_id, content, reply_to_id)\n VALUES (${bookId}::uuid, ${userId}, ${plain}, ${validReplyTo})\n RETURNING id, content, created_at, user_id\n `;\n await sql`UPDATE vibe_books SET updated_at = NOW() WHERE id = ${bookId}::uuid`\n .catch(() => {});\n\n // Notification légère au créateur (best-effort, hors auto-commentaire)\n const ownerId = Number(access[0].owner_id);\n if (ownerId !== userId) {\n try {\n await sql`\n INSERT INTO notifications (recipient_id, actor_id, type, message)\n VALUES (${ownerId}, ${userId}, 'book_join', ${`a commenté la discussion du Livre « ${\n access[0].title\n } »`})\n `;\n await pushRealtimeEvent(ownerId, \"notification\", {\n type: \"book_join\",\n book_id: bookId,\n actor_id: userId,\n });\n } catch {}\n }\n\n const enriched = await sql`\n SELECT bc.id, bc.content, bc.created_at, bc.user_id,\n u.username, pr.display_name, pr.avatar_url,\n bc.reply_to_id,\n rc.content AS reply_content, ru.username AS reply_username\n FROM vibe_book_comments bc\n JOIN users u ON u.id = bc.user_id\n LEFT JOIN profiles pr ON pr.user_id = bc.user_id\n LEFT JOIN vibe_book_comments rc ON rc.id = bc.reply_to_id\n LEFT JOIN users ru ON ru.id = rc.user_id\n WHERE bc.id = ${inserted[0].id}::uuid\n LIMIT 1\n `;\n const comment = enriched[0] || inserted[0];\n if (comment && !comment.reactions) comment.reactions = [];\n return c.json({ success: true, comment }, 201);\n } catch (err: any) {\n console.error(\"[vibe-books] Add comment error:\", err);\n return c.json({ error: \"Erreur lors de l'ajout du commentaire.\" }, 500);\n }\n };\n registerMulti(\"post\", [\n \"/api/vibe/books/:bookId/comments\",\n \"/vibe/books/:bookId/comments\",\n \"/v1/books/:bookId/comments\",\n ], handleAddBookComment);\n\n const handleDeleteBookComment = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const bookId = c.req.param(\"bookId\");\n const commentId = c.req.param(\"commentId\");\n\n const sql = getDb();\n await ensureBooksTables(sql);\n const rows = await sql`\n SELECT bc.user_id AS author_id, b.user_id AS owner_id\n FROM vibe_book_comments bc\n JOIN vibe_books b ON b.id = bc.book_id\n WHERE bc.id = ${commentId}::uuid AND bc.book_id = ${bookId}::uuid\n LIMIT 1\n `;\n if (rows.length === 0) {\n return c.json({ error: \"Commentaire introuvable.\" }, 404);\n }\n if (\n Number(rows[0].author_id) !== userId &&\n Number(rows[0].owner_id) !== userId\n ) {\n return c.json({\n error:\n \"Seuls l'auteur du commentaire ou le créateur du Livre peuvent le supprimer.\",\n }, 403);\n }\n await sql`DELETE FROM vibe_book_comments WHERE id = ${commentId}::uuid`;\n return c.json({ success: true });\n } catch (err: any) {\n console.error(\"[vibe-books] Delete comment error:\", err);\n return c.json(\n { error: \"Erreur lors de la suppression du commentaire.\" },\n 500,\n );\n }\n };\n registerMulti(\"delete\", [\n \"/api/vibe/books/:bookId/comments/:commentId\",\n \"/vibe/books/:bookId/comments/:commentId\",\n \"/v1/books/:bookId/comments/:commentId\",\n ], handleDeleteBookComment);\n\n // Réaction emoji sur un message de la discussion (toggle, membres du Livre)\n const handleReactBookComment = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const bookId = c.req.param(\"bookId\");\n const commentId = c.req.param(\"commentId\");\n const body = await c.req.json().catch(() => ({}));\n const emoji = String(body?.emoji || \"\");\n if (!emoji || emoji.length > 16) {\n return c.json({ error: \"Emoji requis.\" }, 400);\n }\n\n const sql = getDb();\n await ensureBooksTables(sql);\n const access = await sql`\n SELECT bc.id FROM vibe_book_comments bc\n JOIN vibe_books b ON b.id = bc.book_id\n WHERE bc.id = ${commentId}::uuid AND bc.book_id = ${bookId}::uuid\n AND ${bookAccessClause(sql, userId)}\n LIMIT 1\n `;\n if (access.length === 0) {\n return c.json({ error: \"Commentaire introuvable.\" }, 404);\n }\n\n const existing = await sql`\n SELECT id FROM vibe_book_comment_reactions\n WHERE comment_id = ${commentId}::uuid AND user_id = ${userId} AND emoji = ${emoji}\n LIMIT 1\n `;\n let reacted = false;\n if (existing.length > 0) {\n await sql`DELETE FROM vibe_book_comment_reactions WHERE id = ${\n existing[0].id\n }`;\n } else {\n await sql`\n INSERT INTO vibe_book_comment_reactions (comment_id, user_id, emoji)\n VALUES (${commentId}::uuid, ${userId}, ${emoji})\n ON CONFLICT (comment_id, user_id, emoji) DO NOTHING\n `;\n reacted = true;\n }\n\n const all = await sql`\n SELECT emoji, user_id FROM vibe_book_comment_reactions WHERE comment_id = ${commentId}::uuid\n `;\n const grouped: { emoji: string; count: number; mine: boolean }[] = [];\n for (const r of all as any[]) {\n const g = grouped.find((x) => x.emoji === r.emoji);\n if (g) {\n g.count += 1;\n g.mine = g.mine || Number(r.user_id) === userId;\n } else {\n grouped.push({\n emoji: r.emoji,\n count: 1,\n mine: Number(r.user_id) === userId,\n });\n }\n }\n return c.json({ success: true, reacted, reactions: grouped });\n } catch (err: any) {\n console.error(\"[vibe-books] React comment error:\", err);\n return c.json({ error: \"Erreur lors de la réaction.\" }, 500);\n }\n };\n registerMulti(\"post\", [\n \"/api/vibe/books/:bookId/comments/:commentId/react\",\n \"/vibe/books/:bookId/comments/:commentId/react\",\n \"/v1/books/:bookId/comments/:commentId/react\",\n ], handleReactBookComment);\n\n // 16. RECHERCHE DE LIVRES PUBLICS (mention @livre / attachement dans un post)\n const handleSearchPublicBooks = async (c: any) => {\n try {\n const userId = await getAuthUserId(c);\n if (!userId) return c.json({ error: \"Non authentifié.\" }, 401);\n const q = String(c.req.query(\"q\") || \"\").trim().slice(0, 50);\n if (!q) return c.json({ success: true, books: [] });\n\n const sql = getDb();\n await ensureBooksTables(sql);\n\n const rows = await sql`\n SELECT b.id, b.title, b.icon, TRUE AS is_public,\n u.username AS owner_username,\n pr.display_name AS owner_display_name,\n (SELECT COUNT(*) FROM vibe_book_members bm WHERE bm.book_id = b.id) AS members_count,\n (SELECT COUNT(*) FROM vibe_book_items bi WHERE bi.book_id = b.id) AS items_count\n FROM vibe_books b\n JOIN users u ON u.id = b.user_id\n LEFT JOIN profiles pr ON pr.user_id = u.id\n WHERE COALESCE(b.is_public, FALSE) = TRUE AND b.title ILIKE ${\n \"%\" + q + \"%\"\n }\n ORDER BY items_count DESC, b.updated_at DESC NULLS LAST\n LIMIT 20\n `;\n return c.json({ success: true, books: rows });\n } catch (err: any) {\n console.error(\"[vibe-books] Public search error:\", err);\n return c.json({ error: \"Erreur lors de la recherche de Livres.\" }, 500);\n }\n };\n registerMulti(\"get\", [\n \"/api/vibe/books/public\",\n \"/vibe/books/public\",\n \"/v1/books/public\",\n ], handleSearchPublicBooks);\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=1789534799&sig=d0e9bd008a19d21a4278d66ba8a82f38d1cd4969f07f21769dd2a06ad26857ad","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=1789534799&sig=35a45bbea9f7c308b27b7036fc6bf7e06c021ee516b5deb1d8a1b8e08015b411","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"]