[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_109":110,"_111":112},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","efrenlin","name","x-trader-consensus","path","lib/dashboard.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":38,"_66":67,"_68":69,"_70":71,"_72":73,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":85,"_86":87,"_88":89,"_90":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/efrenlin/x-trader-consensus/code/lib/dashboard.ts","extension","id","10417439-1277-4df4-bdfd-6e48091b75b5","dashboard.ts","fileId","dbf3c70a-ac1e-11f1-b666-1607ee4eb77e","parentId","8dccd4ba-aa00-11f1-906c-1607ee4eb77e","branchId","012dced4-9569-4aa1-b4df-043c162f1aa5","branchVersion",85,"latest",true,"createdAt",["D",1788938396425],"version",0,"fileType","script","content","// lib/dashboard.ts — server-side assembly for the Market Discovery &\n// Consensus dashboard UI. Reads ONLY existing SQLite data. Never writes,\n// never calls Anthropic, never re-analyzes. Reuses the exact consensus\n// semantics from lib/consensus.ts (unique independent accounts, repost\n// exclusion, one-account-one-vote, High-confidence-semantic-only votes,\n// ticker-identity exclusions, \"Unclear ≠ Neutral\").\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { TRACKED_ACCOUNTS } from \"../config.ts\";\nimport { computeTickerConsensus } from \"./consensus.ts\";\nimport type { TickerConsensusResult } from \"./consensus.ts\";\nimport { getExcludedTickers } from \"./tickerIdentity.ts\";\n\nexport type Period = \"daily\" | \"weekly\" | \"monthly\";\n\nconst PERIOD_HOURS: Record = {\n daily: 24,\n weekly: 24 * 7,\n monthly: 24 * 28,\n};\n\nconst safeParseStrArray = (json: string | null | undefined): string[] => {\n if (!json) return [];\n try {\n const v = JSON.parse(json);\n return Array.isArray(v) ? v.filter((x) => typeof x === \"string\") : [];\n } catch {\n return [];\n }\n};\n\ninterface SemanticTicker {\n ticker: string;\n company_name: string;\n evidence: string;\n confidence: \"High\" | \"Medium\" | \"Low\";\n recognition_reason: string;\n}\nconst safeParseSemantic = (json: string | null | undefined): SemanticTicker[] => {\n if (!json) return [];\n try {\n const v = JSON.parse(json);\n return Array.isArray(v)\n ? v.filter((x) => x && typeof x === \"object\" && typeof x.ticker === \"string\" && typeof x.confidence === \"string\")\n : [];\n } catch {\n return [];\n }\n};\n\nexport function tickersForPost(row: {\n mentioned_tickers?: string | null;\n stance_tickers?: string | null;\n semantic_tickers?: string | null;\n}): string[] {\n const set = new Set();\n safeParseStrArray(row.mentioned_tickers).forEach((t) => set.add(t.toUpperCase()));\n safeParseStrArray(row.stance_tickers).forEach((t) => set.add(t.toUpperCase()));\n safeParseSemantic(row.semantic_tickers).forEach((s) => set.add(s.ticker.toUpperCase()));\n return [...set];\n}\n\nexport function postMentionsTicker(row: {\n mentioned_tickers?: string | null;\n stance_tickers?: string | null;\n semantic_tickers?: string | null;\n}, ticker: string): boolean {\n const t = ticker.toUpperCase();\n return safeParseStrArray(row.mentioned_tickers).some((x) => x.toUpperCase() === t) ||\n safeParseStrArray(row.stance_tickers).some((x) => x.toUpperCase() === t) ||\n safeParseSemantic(row.semantic_tickers).some((s) => s.ticker.toUpperCase() === t);\n}\n\nfunction cutoffIso(period: Period): string {\n const hours = PERIOD_HOURS[period] ?? 24;\n return new Date(Date.now() - hours * 3600 * 1000).toISOString();\n}\n\n// Full analyzed posts within a window (period-filtered on posted_at).\nasync function analyzedPostsInWindow(cutoff: string): Promise {\n const res = await sqlite.execute({\n sql: `SELECT post_id, username, post_type, posted_at, text,\n mentioned_tickers, stance_tickers, explicit_stance, semantic_tickers,\n evidence, thesis, catalyst, time_horizon, position_disclosure, original_url\n FROM posts\n WHERE analyzed_at IS NOT NULL AND posted_at >= ?\n ORDER BY posted_at ASC`,\n args: [cutoff],\n });\n return res.rows as unknown as any[];\n}\n\n// Recompute consensus for a set of analyzed posts using the EXISTING engine.\nasync function consensusFor(posts: any[]): Promise {\n const excluded = await getExcludedTickers();\n const rows = posts.map((p) => ({\n post_id: p.post_id,\n username: p.username,\n post_type: p.post_type,\n posted_at: p.posted_at,\n text: p.text,\n mentioned_tickers: p.mentioned_tickers ?? \"[]\",\n stance_tickers: p.stance_tickers ?? \"[]\",\n explicit_stance: p.explicit_stance,\n semantic_tickers: p.semantic_tickers ?? \"[]\",\n }));\n return computeTickerConsensus(rows, excluded);\n}\n\n// Attention proxy: split a ticker's mentions in the window into a recent\n// quarter vs the prior three quarters of time. Returns a % change and a\n// \"rising\" flag. null when there is insufficient data to form a trend.\nfunction attentionChange(posts: any[], ticker: string, cutoff: string): { changePct: number | null; rising: boolean; recent: number; prior: number } {\n const related = posts.filter((p) => postMentionsTicker(p, ticker));\n if (related.length < 2) return { changePct: null, rising: false, recent: related.length, prior: 0 };\n const nowMs = Date.now();\n const cutoffMs = new Date(cutoff).getTime();\n const midMs = cutoffMs + ((nowMs - cutoffMs) / 4);\n const recent = related.filter((p) => new Date(p.posted_at).getTime() >= midMs).length;\n const prior = related.length - recent;\n const changePct = prior > 0 ? Math.round(((recent - prior) / prior) * 100) : (recent > 0 ? 100 : 0);\n return { changePct, rising: recent > prior, recent, prior };\n}\n\n// Unique active traders (accounts) mentioning a ticker within the window.\nfunction uniqueAccounts(posts: any[], ticker: string): number {\n return new Set(posts.filter((p) => postMentionsTicker(p, ticker)).map((p) => p.username)).size;\n}\n\nfunction latestView(posts: any[], ticker: string): string | null {\n const related = posts.filter((p) => postMentionsTicker(p, ticker));\n if (related.length === 0) return null;\n related.sort((a, b) => (a.posted_at < b.posted_at ? 1 : -1));\n return related[0].posted_at;\n}\n\nexport async function buildDashboardApi(period: Period) {\n const cutoff = cutoffIso(period);\n const posts = await analyzedPostsInWindow(cutoff);\n const consensus = await consensusFor(posts);\n\n // Header meta (all-time, not period-filtered)\n let totalAnalyzedRes = await sqlite.execute(\"SELECT COUNT(*) AS n FROM posts WHERE analyzed_at IS NOT NULL\");\n const totalAnalyzed = Number((totalAnalyzedRes.rows[0] as any).n || 0);\n let latestRes = await sqlite.execute(\"SELECT MAX(posted_at) AS m FROM posts WHERE analyzed_at IS NOT NULL\");\n const lastUpdated = (latestRes.rows[0] as any)?.m ?? null;\n let acctRes = await sqlite.execute(\"SELECT COUNT(*) AS n FROM accounts\");\n const trackedAccounts = Math.max(Number((acctRes.rows[0] as any).n || 0), TRACKED_ACCOUNTS.length);\n\n // Overview cards\n const bullishTickers = consensus.filter((c) => c.consensus_direction === \"Bullish\");\n const bearishTickers = consensus.filter((c) => c.consensus_direction === \"Bearish\");\n const unclearTickers = consensus.filter((c) => c.consensus_direction === \"No directional consensus (all Unclear or mention-only)\");\n const agreementTickers = consensus.filter((c) => (c.consensus_direction === \"Bullish\" || c.consensus_direction === \"Bearish\") && (c.disagreement_level === \"None\" || c.disagreement_level === \"Low\"));\n const disagreementTickers = consensus.filter((c) => c.consensus_direction === \"Mixed / Disputed\" || c.disagreement_level === \"Moderate\" || c.disagreement_level === \"High\");\n const attentionRising = consensus.filter((c) => attentionChange(posts, c.ticker, cutoff).rising);\n\n // Top Consensus Stocks (sortable client-side; server default order)\n const topStocks = consensus.map((c) => {\n const attn = attentionChange(posts, c.ticker, cutoff);\n const dominant = c.bullish_accounts > c.bearish_accounts ? c.bullish_ratio : (c.bearish_accounts > c.bullish_accounts ? c.bearish_ratio : null);\n const strength = dominant === null || dominant === undefined ? null : Math.round(dominant * 100);\n return {\n ticker: c.ticker,\n mentions: c.mention_count,\n bullishAccounts: c.bullish_accounts,\n bearishAccounts: c.bearish_accounts,\n unclear: c.unclear_accounts,\n uniqueAccounts: c.unique_accounts_mentioning,\n direction: c.consensus_direction,\n disagreement: c.disagreement_level,\n disagreementScore: c.disagreement_score,\n strength,\n attentionChangePct: attn.changePct,\n attentionRising: attn.rising,\n attentionRecent: attn.recent,\n attentionPrior: attn.prior,\n latestView: latestView(posts, c.ticker),\n };\n });\n\n // Consensus / Disagreement sections\n const agreement = agreementTickers.map((c) => ({\n ticker: c.ticker, direction: c.consensus_direction, uniqueAccounts: c.unique_accounts_mentioning,\n bullish: c.bullish_accounts, bearish: c.bearish_accounts, unclear: c.unclear_accounts, latestView: latestView(posts, c.ticker),\n }));\n const disagreement = disagreementTickers.map((c) => ({\n ticker: c.ticker, direction: c.consensus_direction, level: c.disagreement_level, score: c.disagreement_score,\n bullish: c.bullish_accounts, bearish: c.bearish_accounts, unclear: c.unclear_accounts, uniqueAccounts: c.unique_accounts_mentioning, latestView: latestView(posts, c.ticker),\n }));\n\n // Trader Monitor\n const traders = [];\n for (const handle of TRACKED_ACCOUNTS) {\n const reposts = posts.filter((p) => p.username.toLowerCase() === handle.toLowerCase());\n const stocks = new Set();\n reposts.forEach((p) => tickersForPost(p).forEach((t) => stocks.add(t)));\n const stanceCounts = { Bullish: 0, Bearish: 0, Unclear: 0 };\n reposts.forEach((p) => {\n const s = p.explicit_stance as string;\n if (s === \"Bullish\" || s === \"Bearish\" || s === \"Unclear\") stanceCounts[s]++;\n });\n const thesisPosts = reposts.filter((p) => p.thesis).sort((a, b) => (a.posted_at < b.posted_at ? 1 : -1));\n const latest = [...reposts].sort((a, b) => (a.posted_at < b.posted_at ? 1 : -1))[0];\n traders.push({\n account: handle,\n latestActivity: latest?.posted_at ?? null,\n stocksDiscussed: [...stocks].sort(),\n counts: stanceCounts,\n latestThesis: thesisPosts[0] ? { thesis: thesisPosts[0].thesis, posted_at: thesisPosts[0].posted_at, url: thesisPosts[0].original_url } : null,\n });\n }\n\n // Attention & Emerging Ideas — rank by recent activity, independent accounts, acceleration\n const attention = consensus.map((c) => {\n const attn = attentionChange(posts, c.ticker, cutoff);\n return {\n ticker: c.ticker,\n recentMentions: attn.recent,\n uniqueAccounts: c.unique_accounts_mentioning,\n mentions: c.mention_count,\n latestView: latestView(posts, c.ticker),\n changePct: attn.changePct,\n direction: c.consensus_direction,\n };\n }).sort((a, b) => (b.recentMentions - a.recentMentions) || (b.uniqueAccounts - a.uniqueAccounts));\n\n // Recent Market Views feed (analyzed posts with a stance or tickers)\n const feedPosts = posts\n .filter((p) => p.explicit_stance || postMentionsTicker(p, \"___\")) // keep only analyzed-with-stance or ticker-bearing\n .filter((p) => p.explicit_stance !== null && (postMentionsTicker(p, \"PLACEHOLDER\") || !!p.thesis || p.explicit_stance === \"Bullish\" || p.explicit_stance === \"Bearish\" || p.explicit_stance === \"Unclear\"))\n .sort((a, b) => (a.posted_at < b.posted_at ? 1 : -1)).slice(0, 60);\n const recentViews = feedPosts.map((p) => ({\n account: p.username,\n postType: p.post_type,\n tickers: tickersForPost(p),\n stance: p.explicit_stance,\n evidence: p.evidence,\n thesis: p.thesis,\n postedAt: p.posted_at,\n url: p.original_url,\n }));\n\n return {\n period,\n cutoff,\n meta: { lastUpdated, trackedAccounts, totalAnalyzed, consensusTickers: consensus.length },\n overview: {\n bullishTickers: bullishTickers.length,\n bearishTickers: bearishTickers.length,\n unclearTickers: unclearTickers.length,\n consensus: agreementTickers.length,\n disagreement: disagreementTickers.length,\n attentionRising: attentionRising.length,\n },\n topStocks,\n agreement,\n disagreement,\n traders,\n attention,\n recentViews,\n };\n}\n\n// Stock drilldown: all analyzed posts for one ticker (not period-limited so\n// stance history and mention trend are complete and attributable).\nexport async function buildStockDrilldown(ticker: string): Promise {\n const t = ticker.toUpperCase();\n const all = await analyzedPostsInWindow(\"1970-01-01T00:00:00.000Z\"); // all-time analyzed\n const related = all.filter((p) => postMentionsTicker(p, t));\n const excluded = await getExcludedTickers();\n if (excluded.has(t)) {\n return { ticker: t, excluded: true, note: \"Ticker is excluded from consensus by the ticker-identity safeguard.\" };\n }\n\n const rows = related.map((p) => ({\n post_id: p.post_id, username: p.username, post_type: p.post_type, posted_at: p.posted_at, text: p.text,\n mentioned_tickers: p.mentioned_tickers ?? \"[]\", stance_tickers: p.stance_tickers ?? \"[]\",\n explicit_stance: p.explicit_stance, semantic_tickers: p.semantic_tickers ?? \"[]\",\n }));\n const c = computeTickerConsensus(rows, excluded).find((r) => r.ticker === t) ?? null;\n\n // Mention trend: bucket by time into up to 8 buckets (all-time span).\n const trend = (() => {\n if (related.length === 0) return [{ label: \"No data\", count: 0 }];\n const times = related.map((p) => new Date(p.posted_at).getTime()).sort((a, b) => a - b);\n const min = times[0], max = Math.max(Date.now(), times[times.length - 1]);\n const span = Math.max(max - min, 1);\n const buckets: { label: string; count: number }[] = [];\n const nBuckets = Math.min(8, Math.max(2, related.length));\n for (let i = 0; i < nBuckets; i++) {\n const start = min + (span / nBuckets) * i;\n const end = min + (span / nBuckets) * (i + 1);\n const count = related.filter((p) => {\n const tms = new Date(p.posted_at).getTime();\n return tms >= start && (i === nBuckets - 1 ? tms <= end : tms < end);\n }).length;\n buckets.push({ label: new Date(start).toISOString().slice(0, 10), count });\n }\n return buckets;\n })();\n\n const latestViews = related.sort((a, b) => (a.posted_at < b.posted_at ? 1 : -1)).slice(0, 25).map((p) => ({\n account: p.username, postType: p.post_type, stance: p.explicit_stance, evidence: p.evidence, thesis: p.thesis,\n catalyst: p.catalyst, timeHorizon: p.time_horizon, positionDisclosure: p.position_disclosure,\n postedAt: p.posted_at, url: p.original_url, text: p.text?.slice(0, 300) ?? null,\n }));\n\n const stanceHistory = related.sort((a, b) => (a.posted_at < b.posted_at ? 1 : -1)).slice(0, 30).map((p) => ({\n account: p.username, stance: p.explicit_stance, postedAt: p.posted_at, url: p.original_url, postType: p.post_type,\n }));\n\n // Latest distinct thesis / catalyst / horizon / position disclosure (only when explicitly present)\n const withThesis = related.filter((p) => p.thesis).sort((a, b) => (a.posted_at < b.posted_at ? 1 : -1));\n const withCat = related.filter((p) => p.catalyst).sort((a, b) => (a.posted_at < b.posted_at ? 1 : -1));\n const withHor = related.filter((p) => p.time_horizon).sort((a, b) => (a.posted_at < b.posted_at ? 1 : -1));\n const withPos = related.filter((p) => p.position_disclosure).sort((a, b) => (a.posted_at < b.posted_at ? 1 : -1));\n\n return {\n ticker: t,\n excluded: false,\n consensus: c,\n relatedPosts: related.length,\n uniqueAccounts: new Set(related.map((p) => p.username)).size,\n trend,\n latestViews,\n stanceHistory,\n detail: {\n thesis: withThesis[0]?.thesis ?? null,\n catalyst: withCat[0]?.catalyst ?? null,\n timeHorizon: withHor[0]?.time_horizon ?? null,\n positionDisclosure: withPos[0]?.position_disclosure ?? null, // only when explicitly stated\n },\n };\n}\n\n// Search by ticker or trader.\nexport async function searchMarket(q: string): Promise {\n const query = (q ?? \"\").trim().toLowerCase();\n if (!query) return { tickers: [], traders: [] };\n\n const all = await analyzedPostsInWindow(\"1970-01-01T00:00:00.000Z\");\n const consensus = await consensusFor(all);\n\n // Ticker matches\n const tickerMatches = new Set();\n for (const c of consensus) {\n if (c.ticker.toLowerCase().includes(query)) tickerMatches.add(c.ticker);\n }\n for (const p of all) {\n if (tickForPostHas(p, query)) tickerMatches.add(query.toUpperCase());\n }\n\n // Trader matches\n const traderMatches = TRACKED_ACCOUNTS.filter((h) => h.toLowerCase().includes(query)).map((h) => h);\n\n return {\n query,\n tickers: [...tickerMatches].sort(),\n traders: traderMatches,\n };\n}\n\nfunction tickForPostHas(p: any, q: string): boolean {\n return tickersForPost(p).some((t) => t.toLowerCase() === q);\n}\n","deleted",false,"label",[47,24],"lib","5c601043-49d8-4da3-8595-d21725bb7d55",["D",1788705462303],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","X account collector: normalized posts into SQLite","imageUrl","userId","8f36435b-4ee1-42d7-a52e-11508b5c71b0","pinnedFileId","b9b4c5ce-aa00-11f1-b6d1-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a07719-4bcc-778e-997b-14b67712b6b9","tursoName","5c60104349d84da38595d21725bb7d55","tursoHostname","5c60104349d84da38595d21725bb7d55-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789485645684],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_108":104},"org",{"_9":10,"_101":102,"_103":104,"_58":59,"_105":106,"_107":44},"branch",{"_37":91,"_11":92,"_22":30,"_93":48,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":12,"_100":10},"isOwned",146,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Efren Lin","avatar","https://lh3.googleusercontent.com/a/ACg8ocITAXmIR316-M-ReEEDUIUESLjIDNnYnCPqoEpOrKLJExkkkWU=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_84":-5,"_142":143,"_144":145,"_146":147,"_148":44,"_149":44,"_150":44,"_151":34,"_152":-5,"_153":-7,"_154":-7,"_155":38,"_156":44,"_157":44,"_158":-5,"_159":44,"_160":44,"_161":44,"_162":-5},"ENV",{"_113":114,"_115":116,"_117":92,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139,"_140":141},"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"]