[{"_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-posts-core.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-posts-core.ts","extension","id","1dc88b4f-fa7c-41cc-ad43-9674a68921bb","fileId","d2a0d882-ae03-11f1-8af9-1607ee4eb77e","parentId","branchId","3345cb6c-eeb2-4b61-ab03-8e0abc2dcd73","branchVersion",306,"latest",true,"createdAt",["D",1789229573039],"version",4,"fileType","script","content","/**\n * ============================================================================\n * VIBE SOCIAL PLATFORM — POSTS CORE HELPERS (vibe-posts-core.ts)\n * Helpers partagés purs (sans dépendance Hono/app) : prédicats, requêtes\n * d'hydratation (citations, médias, sondages, collaborateurs), publication\n * paresseuse des vibes planifiées et migrations idempotentes des colonnes.\n * Importé par vibe-posts.ts, vibe-posts-crud.ts, vibe-posts-engage.ts,\n * vibe-feed.ts, vibe-users.ts et vibe-books.ts.\n * ============================================================================\n */\n\nimport { getDb } from \"./config.ts\";\n\nexport const isUuid = (v: any): boolean =>\n typeof v === \"string\" &&\n /^[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}$/i.test(v);\n\n/** Prédicat SQL : un post est lisible si public, sien, partagé aux abonnés\n * (et que le spectateur suit l'auteur) ou au cercle (et qu'il en est membre). */\nexport const visibilityFilter = (viewerId: number | null) => {\n const sql = getDb();\n if (!viewerId) return sql`AND p.visibility = 'public'`;\n return sql`AND (\n p.visibility = 'public'\n OR p.author_id = ${viewerId}\n OR (p.visibility = 'followers' AND EXISTS (SELECT 1 FROM follows f WHERE f.follower_id = ${viewerId} AND f.following_id = p.author_id))\n OR (p.visibility = 'circle' AND EXISTS (SELECT 1 FROM circle_members cm WHERE cm.user_id = p.author_id AND cm.member_user_id = ${viewerId}))\n )`;\n};\n\n/** Version texte brut d'un contenu riche (scan de sécurité, snippets, recherche). */\nexport function stripHtmlTags(text: string): string {\n if (!text || !text.includes(\"<\")) return text || \"\";\n return text\n .replace(//gi, \"\\n\")\n .replace(/<\\/(p|div|li|blockquote)>/gi, \"\\n\")\n .replace(/<[^>]*>/g, \" \")\n .replace(/[ \\t]+/g, \" \")\n .trim();\n}\n\n/**\n * Publication paresseuse des vibes planifiées dont la date est atteinte :\n * appelée au chargement des flux / profils (aucun cron nécessaire côté serveur).\n * Throttle 30 s pour éviter un scan de table à chaque requête.\n */\nlet lastPublishCheck = 0;\nexport async function publishDuePosts(): Promise {\n const now = Date.now();\n if (now - lastPublishCheck < 30_000) return;\n lastPublishCheck = now;\n try {\n await ensurePostColumns();\n const sql = getDb();\n const due = await sql`\n UPDATE posts\n SET status = 'published', published_at = NOW(), updated_at = NOW()\n WHERE status = 'scheduled' AND scheduled_at IS NOT NULL AND scheduled_at <= NOW()\n RETURNING id, author_id\n `;\n for (const p of due) {\n await sql`\n INSERT INTO notifications (recipient_id, actor_id, type, post_id, message)\n VALUES (${p.author_id}, ${p.author_id}, 'mai_system', ${p.id}::uuid, 'Votre vibe planifiée a été publiée.')\n `.catch(() => {});\n }\n } catch (err) {\n console.warn(\n \"[vibe-posts] publishDuePosts skipped:\",\n (err as any)?.message,\n );\n }\n}\n\n/**\n * Attache les publications citées (quote-posts) en une requête : champ\n * `quoted_post` {username, display_name, avatar_url, content, media_assets…}.\n * Exporté pour réutilisation (posts de profil dans vibe-users.ts).\n */\nexport async function attachQuotedPosts(posts: any[]) {\n if (!posts || posts.length === 0) return;\n for (const p of posts) p.quoted_post = null;\n const quoteIds = Array.from(\n new Set(posts.map((p) => p.quoted_post_id).filter(Boolean)),\n );\n if (quoteIds.length === 0) return;\n try {\n const sql = getDb();\n const rows = await sql`\n SELECT q.id, q.author_id, q.content, q.format, q.likes_count, q.replies_count, q.published_at, q.created_via, q.ai_generated,\n u.username, pr.display_name, pr.avatar_url,\n (COALESCE(u.is_verified, FALSE) OR LOWER(COALESCE(u.tier, '')) IN ('plus', 'pro', 'max')) as is_verified\n FROM posts q\n JOIN users u ON u.id = q.author_id\n LEFT JOIN profiles pr ON pr.user_id = u.id\n WHERE q.id = ANY(${quoteIds}::uuid[])\n `;\n const mediaRows = await sql`\n SELECT post_id, url, media_type, alt_text FROM media_assets WHERE post_id = ANY(${quoteIds}::uuid[])\n `;\n const mediaByPost: Record = {};\n for (const m of mediaRows) {\n (mediaByPost[String(m.post_id)] ||= []).push({\n url: m.url,\n media_type: m.media_type,\n alt_text: m.alt_text,\n });\n }\n const byId = new Map(\n rows.map((\n r: any,\n ) => [String(r.id), {\n ...r,\n media_assets: mediaByPost[String(r.id)] || [],\n }]),\n );\n for (const p of posts) {\n if (p.quoted_post_id) {\n p.quoted_post = byId.get(String(p.quoted_post_id)) || null;\n }\n }\n } catch (err) {\n console.warn(\"[vibe-posts] attachQuotedPosts:\", (err as any)?.message);\n }\n}\n\n/**\n * Hydrate `media_assets` pour une liste de posts en une seule requête.\n * Forme tagged-template uniquement : neon@1.1.0 interdit l'appel\n * fonction classique `sql(ids)` — utiliser `= ANY(${ids}::uuid[])`.\n * Exporté car utilisé par le feed ET la recherche.\n */\nexport async function fetchPostMedia(posts: any[]) {\n if (!posts || posts.length === 0) return;\n try {\n const sql = getDb();\n const ids = posts.map((p) => p.id);\n const media =\n await sql`SELECT post_id, url, media_type, alt_text FROM media_assets WHERE post_id = ANY(${ids}::uuid[]) ORDER BY position ASC, created_at ASC`;\n const byPost: Record = {};\n for (const m of media) {\n const key = String(m.post_id);\n (byPost[key] ||= []).push({\n url: m.url,\n media_type: m.media_type,\n alt_text: m.alt_text,\n });\n }\n for (const p of posts) p.media_assets = byPost[String(p.id)] || [];\n } catch (mediaErr) {\n console.warn(\"[Vibe API] Erreur fetchPostMedia:\", mediaErr);\n for (const p of posts) p.media_assets ||= [];\n }\n}\n\n/**\n * Hydrate `poll` {id, question, ends_at, total_votes, options[{id,label,votes_count,position}],\n * my_vote: option_id|null, expired} pour une liste de posts. Exporté (feed, recherche, profils).\n */\nexport async function attachPolls(posts: any[], currentUserId: number | null) {\n if (!posts || posts.length === 0) return;\n for (const p of posts) p.poll = null;\n try {\n const sql = getDb();\n const ids = posts.map((p) => p.id);\n const polls = await sql`\n SELECT id, post_id, question, ends_at, total_votes, created_at\n FROM post_polls WHERE post_id = ANY(${ids}::uuid[])\n `.catch(() => []);\n if (!polls || polls.length === 0) return;\n const pollIds = polls.map((pl: any) => pl.id);\n const options = await sql`\n SELECT id, poll_id, label, votes_count, position\n FROM post_poll_options WHERE poll_id = ANY(${pollIds}::uuid[])\n ORDER BY position ASC\n `.catch(() => []);\n const optsByPoll: Record = {};\n for (const o of options) (optsByPoll[String(o.poll_id)] ||= []).push(o);\n let votesByPoll: Record = {};\n if (currentUserId) {\n const votes = await sql`\n SELECT poll_id, option_id FROM post_poll_votes\n WHERE poll_id = ANY(${pollIds}::uuid[]) AND user_id = ${currentUserId}\n `.catch(() => []);\n for (const v of votes) {\n votesByPoll[String(v.poll_id)] = String(v.option_id);\n }\n }\n const pollByPost: Record = {};\n for (const pl of polls) {\n pollByPost[String(pl.post_id)] = {\n ...pl,\n options: optsByPoll[String(pl.id)] || [],\n my_vote: votesByPoll[String(pl.id)] || null,\n expired: new Date(pl.ends_at).getTime() <= Date.now(),\n };\n }\n for (const p of posts) p.poll = pollByPost[String(p.id)] || null;\n } catch (err) {\n console.warn(\"[vibe-posts] attachPolls skipped:\", (err as any)?.message);\n }\n}\n\n/**\n * Hydrate `collaborators` [{username, display_name, avatar_url, status}] pour une liste de posts.\n */\nexport async function attachCollaborators(posts: any[]) {\n if (!posts || posts.length === 0) return;\n for (const p of posts) p.collaborators = [];\n try {\n const sql = getDb();\n const ids = posts.map((p) => p.id);\n const rows = await sql`\n SELECT pc.post_id, pc.status, u.username, pr.display_name, pr.avatar_url\n FROM post_collaborators pc\n JOIN users u ON u.id = pc.user_id\n LEFT JOIN profiles pr ON pr.user_id = u.id\n WHERE pc.post_id = ANY(${ids}::uuid[])\n `.catch(() => []);\n const byPost: Record = {};\n for (const r of rows) {\n (byPost[String(r.post_id)] ||= []).push({\n username: r.username,\n display_name: r.display_name,\n avatar_url: r.avatar_url,\n status: r.status,\n });\n }\n for (const p of posts) p.collaborators = byPost[String(p.id)] || [];\n } catch (err) {\n console.warn(\n \"[vibe-posts] attachCollaborators skipped:\",\n (err as any)?.message,\n );\n }\n}\n\n/** Hydratation combinée sondages + collaborateurs (une seule import côté feed). */\nexport async function attachPollsAndCollabs(\n posts: any[],\n currentUserId: number | null,\n) {\n await attachPolls(posts, currentUserId).catch(() => {});\n await attachCollaborators(posts).catch(() => {});\n}\n\nlet postColumnsReady = false;\nexport const ensurePostColumns = async () => {\n if (postColumnsReady) return;\n try {\n const sql = getDb();\n await sql`ALTER TABLE posts ADD COLUMN IF NOT EXISTS ai_generated BOOLEAN DEFAULT FALSE`\n .catch(() => {});\n await sql`ALTER TABLE posts ADD COLUMN IF NOT EXISTS quoted_post_id UUID REFERENCES posts(id) ON DELETE SET NULL`\n .catch(() => {});\n // Planification de publication (réservée Plus/Pro/Max)\n await sql`ALTER TABLE posts ADD COLUMN IF NOT EXISTS status VARCHAR(20) DEFAULT 'published'`\n .catch(() => {});\n await sql`ALTER TABLE posts ADD COLUMN IF NOT EXISTS scheduled_at TIMESTAMPTZ`\n .catch(() => {});\n await sql`UPDATE posts SET status = 'published' WHERE status IS NULL`.catch(\n () => {},\n );\n await sql`CREATE INDEX IF NOT EXISTS idx_posts_status ON posts(status)`\n .catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_posts_scheduled_due ON posts(status, scheduled_at) WHERE status = 'scheduled'`\n .catch(() => {});\n // Médias joints aux commentaires\n await sql`ALTER TABLE media_assets ADD COLUMN IF NOT EXISTS comment_id UUID REFERENCES comments(id) ON DELETE CASCADE`\n .catch(() => {});\n // Table comments : rendre path optionnel et garantir les colonnes requises\n await sql`ALTER TABLE comments ALTER COLUMN path DROP NOT NULL`.catch(\n () => {},\n );\n await sql`ALTER TABLE comments ALTER COLUMN path SET DEFAULT ''`.catch(\n () => {},\n );\n await sql`ALTER TABLE comments ADD COLUMN IF NOT EXISTS parent_comment_id UUID REFERENCES comments(id) ON DELETE CASCADE`\n .catch(() => {});\n await sql`ALTER TABLE comments ADD COLUMN IF NOT EXISTS depth INTEGER DEFAULT 0`\n .catch(() => {});\n await sql`ALTER TABLE comments ADD COLUMN IF NOT EXISTS likes_count INTEGER DEFAULT 0`\n .catch(() => {});\n await sql`ALTER TABLE comments ADD COLUMN IF NOT EXISTS is_hidden BOOLEAN DEFAULT FALSE`\n .catch(() => {});\n // Table comment_likes pour persister les likes de commentaires\n await sql`\n CREATE TABLE IF NOT EXISTS comment_likes (\n id UUID PRIMARY KEY DEFAULT gen_random_uuid(),\n user_id BIGINT NOT NULL,\n comment_id UUID NOT NULL REFERENCES comments(id) ON DELETE CASCADE,\n created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(),\n UNIQUE (user_id, comment_id)\n )\n `.catch(() => {});\n // Sondages intégrés aux posts (2-4 options, vote unique modifiable)\n await sql`\n CREATE TABLE IF NOT EXISTS post_polls (\n id UUID PRIMARY KEY DEFAULT gen_random_uuid(),\n post_id UUID NOT NULL REFERENCES posts(id) ON DELETE CASCADE,\n question TEXT NOT NULL,\n ends_at TIMESTAMPTZ NOT NULL,\n total_votes INT DEFAULT 0,\n created_at TIMESTAMPTZ DEFAULT NOW()\n )\n `.catch(() => {});\n await sql`\n CREATE TABLE IF NOT EXISTS post_poll_options (\n id UUID PRIMARY KEY DEFAULT gen_random_uuid(),\n poll_id UUID NOT NULL REFERENCES post_polls(id) ON DELETE CASCADE,\n label TEXT NOT NULL,\n votes_count INT DEFAULT 0,\n position INT NOT NULL\n )\n `.catch(() => {});\n await sql`\n CREATE TABLE IF NOT EXISTS post_poll_votes (\n poll_id UUID NOT NULL,\n user_id BIGINT NOT NULL,\n option_id UUID NOT NULL,\n voted_at TIMESTAMPTZ DEFAULT NOW(),\n PRIMARY KEY (poll_id, user_id)\n )\n `.catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_polls_post ON post_polls(post_id)`\n .catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_poll_options_poll ON post_poll_options(poll_id)`\n .catch(() => {});\n // Posts collaboratifs (co-signature : pending | accepted | declined)\n await sql`\n CREATE TABLE IF NOT EXISTS post_collaborators (\n post_id UUID NOT NULL REFERENCES posts(id) ON DELETE CASCADE,\n user_id BIGINT NOT NULL,\n status VARCHAR(20) DEFAULT 'pending',\n invited_at TIMESTAMPTZ DEFAULT NOW(),\n accepted_at TIMESTAMPTZ,\n PRIMARY KEY (post_id, user_id)\n )\n `.catch(() => {});\n // Brouillons multi-appareils (synchronisation serveur, complément de draftCookie local)\n await sql`\n CREATE TABLE IF NOT EXISTS post_drafts (\n id UUID PRIMARY KEY DEFAULT gen_random_uuid(),\n user_id BIGINT NOT NULL,\n html TEXT NOT NULL,\n text TEXT NOT NULL,\n visibility VARCHAR(20) DEFAULT 'public',\n scheduled_at TIMESTAMPTZ,\n ai_generated BOOLEAN DEFAULT FALSE,\n media_assets JSONB DEFAULT '[]',\n updated_at TIMESTAMPTZ DEFAULT NOW(),\n created_at TIMESTAMPTZ DEFAULT NOW()\n )\n `.catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_drafts_user ON post_drafts(user_id, updated_at DESC)`\n .catch(() => {});\n // Ordre d'affichage des médias (carrousel + drag & drop)\n await sql`ALTER TABLE media_assets ADD COLUMN IF NOT EXISTS position INT DEFAULT 0`\n .catch(() => {});\n // Profil temporel utilisateur : vues détaillées + affinité topic implicite\n await sql`\n CREATE TABLE IF NOT EXISTS post_views (\n id UUID PRIMARY KEY DEFAULT gen_random_uuid(),\n user_id BIGINT,\n post_id UUID NOT NULL REFERENCES posts(id) ON DELETE CASCADE,\n duration_ms INT NOT NULL DEFAULT 1000,\n dwell_ms INT NOT NULL DEFAULT 1000,\n visible_ratio FLOAT DEFAULT 0.5,\n completed BOOLEAN DEFAULT FALSE,\n created_at TIMESTAMPTZ DEFAULT NOW()\n )\n `.catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_views_user ON post_views(user_id, created_at DESC)`\n .catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_views_post ON post_views(post_id)`\n .catch(() => {});\n // Migration 017 : source de trafic + index temporels pour les séries stats\n await sql`ALTER TABLE post_views ADD COLUMN IF NOT EXISTS source TEXT DEFAULT 'feed'`\n .catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_views_post_created ON post_views(post_id, created_at DESC)`\n .catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_views_created ON post_views(created_at DESC)`\n .catch(() => {});\n // Migration 017 : visites profil (distinct des vues posts)\n await sql`\n CREATE TABLE IF NOT EXISTS profile_views (\n id UUID PRIMARY KEY DEFAULT gen_random_uuid(),\n profile_user_id BIGINT NOT NULL REFERENCES users(id) ON DELETE CASCADE,\n viewer_id BIGINT REFERENCES users(id) ON DELETE SET NULL,\n source TEXT DEFAULT 'profile',\n created_at TIMESTAMPTZ DEFAULT NOW()\n )\n `.catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_profile_views_profile ON profile_views(profile_user_id, created_at DESC)`\n .catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_profile_views_viewer ON profile_views(viewer_id, created_at DESC)`\n .catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_profile_views_created ON profile_views(created_at DESC)`\n .catch(() => {});\n await sql`\n CREATE TABLE IF NOT EXISTS user_topic_affinity (\n user_id BIGINT NOT NULL,\n topic TEXT NOT NULL,\n total_time_ms BIGINT DEFAULT 0,\n views INT DEFAULT 0,\n likes INT DEFAULT 0,\n score FLOAT DEFAULT 0,\n updated_at TIMESTAMPTZ DEFAULT NOW(),\n PRIMARY KEY (user_id, topic)\n )\n `.catch(() => {});\n postColumnsReady = true;\n } catch (err) {\n console.warn(\n \"[vibe-posts] ensurePostColumns skipped:\",\n (err as any)?.message,\n );\n }\n};\n\n// Épinglage sur son profil de posts (y compris d'autres comptes), max 2 au total\nlet profilePinnedReady = false;\nexport const ensureProfilePinnedPostsTable = async () => {\n if (profilePinnedReady) return;\n try {\n const sql = getDb();\n await sql`\n CREATE TABLE IF NOT EXISTS profile_pinned_posts (\n user_id BIGINT NOT NULL REFERENCES users(id) ON DELETE CASCADE,\n post_id UUID NOT NULL REFERENCES posts(id) ON DELETE CASCADE,\n created_at TIMESTAMPTZ DEFAULT NOW(),\n PRIMARY KEY (user_id, post_id)\n )\n `.catch(() => {});\n await sql`CREATE INDEX IF NOT EXISTS idx_profile_pinned_user ON profile_pinned_posts(user_id, created_at DESC)`\n .catch(() => {});\n profilePinnedReady = true;\n } catch (err) {\n console.warn(\n \"[vibe-posts] ensureProfilePinnedPostsTable skipped:\",\n (err as any)?.message,\n );\n }\n};\n\n// ── Références de Livres dans les posts (attachement / mention @livre) ───────\nconst BOOK_REF_UUID_RE =\n /^[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}$/i;\n\n/** Extrait les identifiants de Livres référencés en HTML (), max 5. */\nexport function extractBookRefIds(html: string): string[] {\n if (!html) return [];\n const ids = new Set();\n const matches = String(html).matchAll(/]*data-book-id=\"([^\"]+)\"/gi);\n for (const match of matches) {\n const id = String(match[1] || \"\").trim();\n if (BOOK_REF_UUID_RE.test(id)) ids.add(id.toLowerCase());\n if (ids.size >= 5) break;\n }\n return Array.from(ids);\n}\n\n/** Remplace intégralement les références de Livres d'un post. */\nexport async function syncPostBookRefs(\n sql: any,\n postId: string,\n bookIds: string[],\n): Promise {\n try {\n await sql`DELETE FROM post_book_refs WHERE post_id = ${postId}::uuid`;\n for (const bookId of bookIds) {\n await sql`\n INSERT INTO post_book_refs (post_id, book_id)\n VALUES (${postId}::uuid, ${bookId}::uuid)\n ON CONFLICT DO NOTHING\n `.catch(() => {});\n }\n } catch (err) {\n console.warn(\n \"[vibe-posts] syncPostBookRefs skipped:\",\n (err as any)?.message,\n );\n }\n}\n\n/** Hydrate les posts avec leurs Livres référencés (carte livre). */\nexport async function attachBookRefs(\n posts: any[],\n viewerId: number | null = null,\n): Promise {\n if (!Array.isArray(posts) || posts.length === 0) return;\n try {\n const sql = getDb();\n const postIds = posts.map((p) => String(p.id));\n const refRows = await sql`\n SELECT post_id, book_id FROM post_book_refs WHERE post_id = ANY(${postIds}::uuid[])\n `;\n if (refRows.length === 0) {\n for (const p of posts) p.book_refs = [];\n return;\n }\n const bookIds = Array.from(\n new Set(refRows.map((r: any) => String(r.book_id))),\n );\n const books = await sql`\n SELECT b.id, b.title, b.icon, COALESCE(b.is_public, FALSE) AS is_public, b.user_id,\n u.username AS owner_username, 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 ${\n viewerId !== null\n ? sql`(b.user_id = ${viewerId} OR EXISTS (SELECT 1 FROM vibe_book_members bm2 WHERE bm2.book_id = b.id AND bm2.user_id = ${viewerId}))`\n : sql`FALSE`\n } AS viewer_is_member\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 b.id = ANY(${bookIds}::uuid[])\n `;\n const byId = new Map(books.map((b: any) => [String(b.id), b]));\n const byPost = new Map();\n for (const r of refRows) {\n const book = byId.get(String(r.book_id));\n if (!book) continue;\n const canView = Boolean(book.is_public) || Boolean(book.viewer_is_member);\n const entry = {\n id: String(book.id),\n title: book.title,\n icon: book.icon,\n owner_username: book.owner_username,\n owner_display_name: book.owner_display_name,\n members_count: Number(book.members_count || 0),\n items_count: Number(book.items_count || 0),\n can_view: canView,\n };\n const key = String(r.post_id);\n if (!byPost.has(key)) byPost.set(key, []);\n byPost.get(key)!.push(entry);\n }\n for (const p of posts) {\n p.book_refs = byPost.get(String(p.id)) || [];\n }\n } catch (err) {\n console.warn(\"[vibe-posts] attachBookRefs skipped:\", (err as any)?.message);\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=1789538399&sig=cd777e882462fce47bac2003be9a9fe1267d4472bdb46131ff02f8b27f89b2ac","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=1789538399&sig=b90c7895d89b2c8a9d976c298024ed06d954dd92e3be0b0905971776951516a4","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"]