${msg}

この画面は閉じてOKです。

`,\n { headers: { \"Content-Type\": \"text/html; charset=utf-8\" } },\n );\n}\nfunction composeForm(s, mode = \"post\") {\n const base = Deno.env.get(\"BOT_BASE_URL\");\n const c = cands(s);\n const action = mode === \"reserve\" ? \"/reserve\" : \"/submit\";\n const title = mode === \"reserve\" ? \"明日の朝の投稿を予約\" : \"投稿\";\n const btn = mode === \"reserve\" ? \"翌朝7:25に予約する\" : \"今すぐ投稿する\";\n const radios = c.slice(0, 3).map((name, i) =>\n `

${\n [\"①\", \"②\", \"③\"][i]\n }`\n ).join(\"\");\n return new Response(\n `

` +\n `

${title}

`,\n { headers: { \"Content-Type\": \"text/html; charset=utf-8\" } },\n );\n}\n// ---- スケジューラ ----\nexport async function runScheduler() {\n if (Deno.env.get(\"ENABLED\") === \"false\") {\n return;\n }\n const s = await getState();\n const today = jstDate();\n const m = jstMins();\n // 朝: 7:25〜11:00(cron遅延に強い広め窓)。前夜の予約があれば自動投稿、なければ生成してDiscord承認へ\n if (false && m >= 7 * 60 + 25 && m < 11 * 60 && s.morningSentDate !== today) { // 朝の自動投稿を停止(2026-07-20)\n if (s.reservedDate === today && s.reservedText) {\n try {\n const id = await postWithImage(s.reservedText, s.reservedImg);\n await sendDiscord({\n content:\n `✅ 予約していた朝の投稿を自動で出しました。\\nhttps://x.com/i/status/${id}`,\n });\n } catch (e) {\n await sendDiscord({\n content: \"⚠️ 予約した朝投稿の失敗: \" + String(e).slice(0, 150),\n });\n }\n s.morningSentDate = today;\n s.reservedText = \"\";\n s.reservedImg = \"\";\n s.reservedDate = \"\";\n await setState(s);\n } else {\n try {\n const g = await generateMorning();\n s.draftText = g.text;\n s.candImgs = g.candImgs;\n } catch (e) {\n s.draftText = \"(朝の学び投稿の自動生成に失敗。編集から書けます)\";\n s.candImgs = [\"morning_01.png\", \"morning_02.png\", \"morning_03.png\"];\n await sendDiscord({\n content: \"⚠️ 朝の自動生成エラー: \" + String(e).slice(0, 150),\n });\n }\n s.draftDate = today;\n s.token = crypto.randomUUID().slice(0, 8);\n s.status = \"pending\";\n s.morningSentDate = today;\n await setState(s);\n await sendDraftMessage(s);\n }\n }\n if (m >= 17 * 60 + 30 && m < 22 * 60 && s.sentDate !== today) {\n // Gemini 503/429 等の一時障害でその日の夕方ポストを丸ごと落とさないよう、\n // 当日 MAX_GEN_TRY 回までは sentDate を立てず次の実行(約15分後)で再挑戦する。\n const MAX_GEN_TRY = 3;\n if (s.genTryDate !== today) {\n s.genTryDate = today;\n s.genTryCount = 0;\n }\n let deferred = false;\n try {\n const g = await generateDraft();\n s.draftText = g.text;\n s.candImgs = g.candImgs; // 相場ムードに合う候補\n } catch (e) {\n s.genTryCount = (s.genTryCount || 0) + 1;\n const retryable = s.genTryCount < MAX_GEN_TRY;\n await sendDiscord({\n content: \"⚠️ 自動生成エラー(\" + s.genTryCount + \"/\" + MAX_GEN_TRY +\n \"): \" +\n String(e).slice(0, 150) +\n (retryable\n ? \" ／約15分後に自動で再挑戦します。\"\n : \" ／上限に達したので手動編集用の下書きを出します。\"),\n });\n if (retryable) {\n deferred = true;\n s.status = \"pending\";\n } else {\n s.draftText = \"(相場観の自動生成に失敗。編集から手動で書けます)\";\n s.candImgs = [\"mental_01.png\", \"mental_02.png\", \"mental_03.png\"];\n }\n }\n if (deferred) {\n await setState(s);\n } else {\n s.draftDate = today;\n s.token = crypto.randomUUID().slice(0, 8);\n s.status = \"pending\";\n s.sentDate = today;\n await setState(s);\n await sendDraftMessage(s);\n }\n }\n if (m >= 18 * 60 && m < 22 * 60 && s.status === \"scheduled\") {\n const err = checkText(s.draftText);\n if (!err && s.chosenImg) {\n try {\n const id = await postWithImage(s.draftText, s.chosenImg);\n s.status = \"posted\";\n s.postedDate = today;\n s.lastTweetId = id;\n s.token = \"\"; // 投稿済み下書きの古いリンクを失効（二重投稿防止）\n await setState(s);\n await sendDiscord({\n content:\n `✅ 18時の予約投稿を実行しました。\\nhttps://x.com/i/status/${id}`,\n });\n } catch (e) {\n await sendDiscord({ content: `⚠️ 予約投稿に失敗: ${String(e)}` });\n }\n } else {\n s.postedDate = today;\n await setState(s);\n await sendDiscord({\n content: `⚠️ 予約投稿を中止（${err || \"画像未選択\"}）`,\n });\n }\n }\n}\n// ===== クラウドAI:データ取得→インジ計算→Gemini執筆 =====\nasync function fetchTF(interval, size = 80) {\n const k = Deno.env.get(\"TWELVEDATA_API_KEY\");\n const r = await fetch(\n `https://api.twelvedata.com/time_series?symbol=USD/JPY&interval=${interval}&outputsize=${size}&apikey=${k}`,\n );\n const d = await r.json();\n if (!d.values) {\n throw new Error(`データ取得失敗(${interval}): ${JSON.stringify(d)}`);\n }\n return d.values; // newest first\n}\nfunction emaArr(vals, period) {\n const k = 2 / (period + 1);\n const out = [];\n let e = vals[0];\n for (let i = 0; i < vals.length; i++) {\n e = i === 0 ? vals[0] : vals[i] * k + e * (1 - k);\n out.push(e);\n }\n return out;\n}\nfunction bb(closes, period = 20, mult = 2) {\n const i = closes.length - 1;\n let s = 0;\n for (let j = i - period + 1; j <= i; j++) {\n s += closes[j];\n }\n const m = s / period;\n let sq = 0;\n for (let j = i - period + 1; j <= i; j++) {\n sq += (closes[j] - m) ** 2;\n }\n const sd = Math.sqrt(sq / period);\n return { mid: m, upper: m + mult * sd, lower: m - mult * sd };\n}\nfunction macd(closes) {\n const ef = emaArr(closes, 12), es = emaArr(closes, 26);\n const line = closes.map((_, i) => ef[i] - es[i]);\n const sig = emaArr(line, 9);\n const hist = line.map((v, i) => v - sig[i]);\n const n = hist.length;\n return { hist: hist[n - 1], histPrev: hist[n - 2] };\n}\nfunction rci(closes, period) {\n const w = closes.slice(closes.length - period);\n const n = period;\n const timeRank = w.map((_, t) => n - t); // 古い=n, 最新=1\n const sorted = w.map((v, idx) => ({ v, idx })).sort((a, b) => b.v - a.v);\n const priceRank = new Array(n);\n sorted.forEach((o, rank) => priceRank[o.idx] = rank + 1);\n let d2 = 0;\n for (let t = 0; t < n; t++) {\n const d = timeRank[t] - priceRank[t];\n d2 += d * d;\n }\n return Math.round((1 - 6 * d2 / (n * (n * n - 1))) * 100);\n}\nfunction heikin(values) {\n const out = [];\n for (let i = 0; i < values.length; i++) {\n const o = +values[i].open,\n h = +values[i].high,\n l = +values[i].low,\n c = +values[i].close;\n const hc = (o + h + l + c) / 4;\n const ho = i === 0 ? (o + c) / 2 : (out[i - 1].o + out[i - 1].c) / 2;\n out.push({ o: ho, c: hc, color: hc >= ho ? \"青\" : \"赤\" });\n }\n return out;\n}\nfunction analyzeTF(values) {\n const v = values.slice().reverse(); // 古い→新しい\n const closes = v.map((x) => +x.close);\n const last = closes[closes.length - 1];\n const e10 = emaArr(closes, 10);\n const e10last = e10[e10.length - 1];\n const e10prev = e10[Math.max(0, e10.length - 5)];\n const b = bb(closes, 20, 2);\n const m = macd(closes);\n const ha = heikin(v).slice(-4).map((x) => x.color).join(\"\");\n const trend = (last > e10last && e10last > e10prev)\n ? \"上昇\"\n : (last < e10last && e10last < e10prev)\n ? \"下降\"\n : \"横ばい\";\n const hi = Math.max(...v.slice(-20).map((x) => +x.high));\n const lo = Math.min(...v.slice(-20).map((x) => +x.low));\n const bbPos = last > b.upper\n ? \"±2σ上抜け\"\n : last < b.lower\n ? \"±2σ下抜け\"\n : last > b.mid\n ? \"ミドル上\"\n : \"ミドル下\";\n return {\n last: last.toFixed(3),\n trend,\n e10: e10last.toFixed(3),\n bbPos,\n bbUp: b.upper.toFixed(2),\n bbLo: b.lower.toFixed(2),\n macd: m.hist > 0 ? \"プラス\" : \"マイナス\",\n macdTurn: (m.hist > 0) !== (m.histPrev > 0) ? \"転換\" : \"継続\",\n rci9: rci(closes, 9),\n rci13: rci(closes, 13),\n rci27: rci(closes, 27),\n ha,\n hi: hi.toFixed(2),\n lo: lo.toFixed(2),\n };\n}\nasync function buildSummary() {\n const [h4, h1, m15, m5] = await Promise.all([\n fetchTF(\"4h\", 60),\n fetchTF(\"1h\", 80),\n fetchTF(\"15min\", 80),\n fetchTF(\"5min\", 80),\n ]);\n const a4 = analyzeTF(h4),\n a1 = analyzeTF(h1),\n a15 = analyzeTF(m15),\n a5 = analyzeTF(m5);\n const f = (t, a) =>\n `【${t}】現値${a.last} トレンド${a.trend} 10EMA${a.e10} BB位置${a.bbPos}(上${a.bbUp}/下${a.bbLo}) MACD${a.macd}(${a.macdTurn}) RCI(9/13/27)=${a.rci9}/${a.rci13}/${a.rci27} 平均足直近${a.ha} 直近高安${a.hi}-${a.lo}`;\n const mood = (a4.trend === \"上昇\" && a1.trend === \"上昇\")\n ? \"up\"\n : (a4.trend === \"下降\" && a1.trend === \"下降\")\n ? \"down\"\n : \"range\";\n return {\n text: `${f(\"4時間足\", a4)}\\n${f(\"1時間足\", a1)}\\n${f(\"15分足\", a15)}\\n${\n f(\"5分足\", a5)\n }`,\n mood,\n };\n}\n// 相場ムード(up/down/range)に合う画像候補を、Blobに実在するものから3枚選ぶ\nasync function pickCandidates(mood) {\n const items = await blob.list();\n const names = items.map((i) => i.key).filter((k) =>\n /\\.(png|jpg|jpeg)$/i.test(k)\n );\n const pref = {\n up: [\"up_\", \"win_\", \"morning_\", \"ouen_\"],\n down: [\"down_\", \"mental_\", \"loss_\", \"sonkiri_\"],\n range: [\"range_\", \"quiet_\", \"mental_\", \"shikin_\"],\n };\n const order = pref[mood] || pref.range;\n const picked = [];\n for (const pfx of order) {\n for (const n of names) {\n if (n.startsWith(pfx) && !picked.includes(n)) {\n picked.push(n);\n }\n if (picked.length >= 3) {\n break;\n }\n }\n if (picked.length >= 3) {\n break;\n }\n }\n for (const n of names) {\n if (picked.length >= 3) {\n break;\n }\n if (!picked.includes(n)) {\n picked.push(n);\n }\n }\n return picked.length\n ? picked.slice(0, 3)\n : [\"mental_01.png\", \"mental_02.png\", \"mental_03.png\"];\n}\n// 今夜のNY注目：USDの★3(High)指標＋要人発言(Speaks等)のみ、今から約16時間以内を抽出\nasync function fetchCalendar() {\n try {\n const r = await fetch(\n \"https://nfs.faireconomy.media/ff_calendar_thisweek.json\",\n );\n const all = await r.json();\n const now = Date.now();\n const end = now + 16 * 3600 * 1000;\n const isSpeech = (t) => /Speaks|Testimony|Testifies|Chair|Powell/i.test(t);\n const picked = all\n .filter((e) =>\n e.country === \"USD\" && (e.impact === \"High\" || isSpeech(e.title))\n )\n .map((e) => ({ e, t: new Date(e.date).getTime() }))\n .filter((x) => x.t >= now && x.t <= end)\n .sort((a, b) => a.t - b.t);\n if (!picked.length) {\n return \"特筆すべき★3指標・要人発言なし\";\n }\n return picked.map(({ e, t }) => {\n const j = new Date(t + 9 * 3600 * 1000);\n const hh = String(j.getUTCHours()).padStart(2, \"0\"),\n mm = String(j.getUTCMinutes()).padStart(2, \"0\");\n return `${hh}:${mm}JST ${e.title}${\n e.impact === \"High\" ? \"(★3)\" : \"(要人発言)\"\n }`;\n }).join(\" / \");\n } catch (_) {\n return \"（指標カレンダー取得失敗）\";\n }\n}\nasync function callGemini(prompt, maxTokens = 2048, thinkingBudget = 512) {\n const key = Deno.env.get(\"GEMINI_API_KEY\");\n const models = [\"gemini-2.5-flash\", \"gemini-2.5-flash-lite\"];\n const sleep = (ms) => new Promise((r) => setTimeout(r, ms));\n let lastErr = \"(不明)\";\n for (const model of models) {\n for (let attempt = 0; attempt < 3; attempt++) {\n const url =\n `https://generativelanguage.googleapis.com/v1beta/models/${model}:generateContent?key=${key}`;\n let res, d;\n try {\n res = await fetch(url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n contents: [{ parts: [{ text: prompt }] }],\n generationConfig: {\n maxOutputTokens: maxTokens,\n thinkingConfig: { thinkingBudget },\n },\n }),\n });\n d = await res.json();\n } catch (e) {\n lastErr = `${model} 通信: ${String(e).slice(0, 120)}`;\n if (attempt < 2) {\n await sleep(attempt === 0 ? 2000 : 6000);\n }\n continue;\n }\n if (res.ok) {\n const text = (d.candidates?.[0]?.content?.parts?.[0]?.text ?? \"\")\n .trim();\n if (text) {\n return text;\n }\n lastErr = `${model} 200だが本文が空: ${\n JSON.stringify(d).slice(0, 150)\n }`;\n break;\n }\n lastErr = `${model} ${res.status}: ${JSON.stringify(d).slice(0, 150)}`;\n const retryable = res.status === 429 || res.status === 500 ||\n res.status === 503;\n if (!retryable) {\n break;\n }\n if (attempt < 2) {\n await sleep(attempt === 0 ? 2000 : 6000);\n }\n }\n }\n throw new Error(\"Gemini失敗: \" + lastErr);\n}\nasync function generateDraft() {\n const { text: summary, mood } = await buildSummary();\n const ny = await fetchCalendar();\n const now = nowJST();\n const timeStr = `${\n now.getUTCMonth() + 1\n }月${now.getUTCDate()}日 ${now.getUTCHours()}時${now.getUTCMinutes()}分(JST)`;\n const prompt =\n `あなたはFXトレーダー「いしかわ」本人として、その日のドル円の相場観をXに投稿します。スキャトレふうた流のテクニカルで読みます。\n\n# 現在時刻: ${timeStr}\n- 東京時間=9〜15時、欧州(ロンドン)=16〜翌1時頃、NY=21〜翌6時頃。\n- すでに終わった/進行中のセッションは過去形〜現在形で、これから来るセッションだけ「今夜の注目」として書く(時制を間違えない)。\n\n# ふうた流の見方(コンフルエンス=複数根拠の一致で読む)\n- 環境認識：上位足(4時間足・1時間足)でトレンド方向を決める。10EMA・BBミドルの向き、ダウ理論の高値安値の切り上げ/切り下げ。\n- 平均足：青=買い優勢/赤=売り優勢、色の連続=トレンド継続、直近の色並びで勢いを見る。\n- ボリンジャーバンド：±2σ=反転/バンドウォーク=強トレンド、ミドル=押し目戻り目。\n- RCI(9/13/27)：±80で買われすぎ/売られすぎ。MACD：方向と転換。\n- 時間帯：東京(アジア)はレンジ寄り、ロンドン・NYはトレンドが出やすい。\n- 節目：キリの良い数字(ラウンドナンバー)やネックラインを意識。\n\n# 今日の実データ(ドル円・計算済み)\n${summary}\n\n# 今夜のNY注目(★3指標と要人発言のみ。ここに書かれた事以外は書かない。「なし」なら無理に触れない)\n${ny}\n\n# 書き方ルール\n- 【最重要】改行・記号・絵文字を含めて **必ず140字以内**（理想は120〜135字）。超過は絶対NG。全部を書こうとせず要点を絞る。\n- いしかわの声：です・ます調、丁寧で謙虚、絵文字1〜2個(☀👍👀📈💦😊🔆等)、適度な改行。\n- 東京・欧州の流れ→テクニカル所感→(あれば)今夜の注目→前向きな締め、を凝縮。\n- 断定・予想の言い切り・売買指示は禁止(「〜な印象」「〜な地合い」等)。データにない事実は作らない。\n- 出力はツイート本文のみ(説明や引用符は不要)。`;\n let text = (await callGemini(prompt)).replace(/^[\"「]|[\"」]$/g, \"\").trim();\n // 140字を超えたら意味を保って短縮（最大2回）\n let tries = 0;\n while (text.length > 140 && tries < 2) {\n text = (await callGemini(\n `次のFXツイートを、意味・口調・絵文字を保ったまま【125字以内】に短くしてください。出力は本文のみ:\\n\\n${text}`,\n )).replace(/^[\"「]|[\"」]$/g, \"\").trim();\n tries++;\n }\n const candImgs = await pickCandidates(mood);\n return { text, summary, candImgs };\n}\n// ===== ライブ配信用:詳細相場分析(Xには投稿しない・口頭解説用) =====\nasync function analyzeDetailed() {\n const { text: summary } = await buildSummary();\n const ny = await fetchCalendar();\n const prompt =\n `あなたはスキャトレふうた流のFXトレーダー「いしかわ」。ライブ配信で口頭解説するための「ドル円の詳細相場分析」を作ります(Xには投稿しない社内用・詳細版)。\n\n# 計算済みデータ(実データ)\n${summary}\n\n# 今夜のNY注目(★3＋要人発言)\n${ny}\n\n# 出力フォーマット(必ずこの見出しで、各項目を具体的に)\n【4時間足】トレンド/BBミドル・±2σ/10EMAとの位置/平均足の色・勢い/ダウの高安/意識される節目\n【1時間足】同上\n【15分足】同上\n【5分足】同上(エントリー執行の足)\n【現在の目線】ロング or ショート or 様子見を明記し、理由を一言\n【エントリーポイント】狙い方(押し目買い/戻り売り/ブレイク/±2σ反発等)と価格帯の目安\n【根拠(3つ)】1. … / 2. … / 3. …(ふうた流コンフルエンス:環境認識・平均足・BB・RCI9/13/27・MACD・ネックライン/ラウンドナンバー等から独立した3つ)\n\n# ルール\n- ふうた流のMTF(上位足で環境認識→下位足でタイミング)、スキャルピング視点。\n- 断定しすぎず「〜な根拠が揃っている/まだ揃わない」という表現。\n- 各足の解説は具体的に(2〜3文)。全体700〜1000字。見出しごとに改行して読みやすく。出力は本文のみ。`;\n return await callGemini(prompt, 5000, 1500);\n}\n// ===== 朝の学び投稿(ふうた流・時事なし・テーマ日替わり) =====\nconst MORNING_THEMES = [\n { theme: \"損切りの大切さ\", tag: \"sonkiri\" },\n { theme: \"資金管理・LOTの考え方\", tag: \"shikin\" },\n { theme: \"メンタル・待つこと(休むも相場)\", tag: \"mental\" },\n { theme: \"環境認識(上位足でトレンドを見る)\", tag: \"study\" },\n { theme: \"平均足の見方(色と勢い)\", tag: \"study\" },\n { theme: \"コツコツ継続する大切さ\", tag: \"keizoku\" },\n { theme: \"押し目買い・戻り売りの考え方\", tag: \"sonkiri\" },\n { theme: \"ダウ理論(高値安値の切り上げ/下げ)\", tag: \"study\" },\n { theme: \"ネックライン・節目の意識\", tag: \"study\" },\n { theme: \"焦らず自分のルールを守る\", tag: \"shikin\" },\n { theme: \"無理をしない・ケガをしない立ち回り\", tag: \"mental\" },\n { theme: \"前向きに一歩ずつ\", tag: \"ouen\" },\n];\nfunction dayOfYear(d) {\n return Math.floor(\n (d.getTime() - Date.UTC(d.getUTCFullYear(), 0, 0)) / 86400000,\n );\n}\nasync function pickByTag(tag) {\n const items = await blob.list();\n const names = items.map((i) => i.key).filter((k) =>\n /\\.(png|jpg|jpeg)$/i.test(k)\n );\n const picked = names.filter((n) => n.startsWith(tag + \"_\")).slice(0, 3);\n for (const n of names) {\n if (picked.length >= 3) {\n break;\n }\n if (!picked.includes(n)) {\n picked.push(n);\n }\n }\n return picked.length\n ? picked.slice(0, 3)\n : [\"morning_01.png\", \"morning_02.png\", \"morning_03.png\"];\n}\nasync function generateMorning() {\n const { theme, tag } =\n MORNING_THEMES[dayOfYear(nowJST()) % MORNING_THEMES.length];\n const prompt =\n `あなたはFXトレーダー「いしかわ」本人として、朝の「学び投稿」をXに書きます。時事や当日の相場には触れず、普遍的な学び・マインドを書きます。\n\n# 今日のテーマ: ${theme}\n# 背景(スキャトレふうた流の考え方)\n- コンフルエンス(複数根拠の一致)、環境認識(上位足でトレンド)、平均足の色・勢い、押し目買い/戻り売り、損切りの徹底、資金管理、休むも相場、コツコツ継続。\n\n# 書き方ルール\n- 【最重要】改行・絵文字含めて必ず140字以内(理想120〜135字)。\n- いしかわの声: 朝の挨拶(おはようございます☀等)で始め、です・ます、謙虚、絵文字1〜2個、適度な改行。\n- 断定・予想・売買指示は禁止。前向きな一言で締める。\n- 出力はツイート本文のみ。`;\n let text = (await callGemini(prompt)).replace(/^[\"「]|[\"」]$/g, \"\").trim();\n let tries = 0;\n while (text.length > 140 && tries < 2) {\n text = (await callGemini(\n `次のツイートを意味と口調を保ち125字以内に短くして。本文のみ:\\n\\n${text}`,\n )).replace(/^[\"「]|[\"」]$/g, \"\").trim();\n tries++;\n }\n return { text, candImgs: await pickByTag(tag) };\n}\n// ---- HTTP ----\nexport default async function (req) {\n const url = new URL(req.url);\n const p = url.pathname;\n const s = await getState();\n\n { // ★この { } で全体を囲ってあるのは、前回の「結果カード」ブロックと同じ名前の定義が\n // ぶつかって val 全体が動かなくなるのを防ぐため。囲いを外して貼らないこと。\n // ===== 朝のFXおみくじ: 結果カード配信＋シェア効果の計測 =====\n // 運勢の印 → 表示名。ページ側(おみくじ_テンプレート.html の UNSEI)と必ず一致させる。\n const OMIKUJI_UNSEI = {\n \"cho-daikichi\": \"超大吉\",\n \"daikichi\": \"大吉\",\n \"chukichi\": \"中吉\",\n \"shokichi\": \"小吉\",\n \"kichi\": \"吉\",\n \"suekichi\": \"末吉\",\n \"kyo\": \"凶\",\n \"daikyo\": \"大凶\",\n };\n\n // ---- 計測（日付ごとの合計だけ。個人を特定するものは保存しない）----\n const OMIKUJI_STATS_KEY = \"omikuji_stats_v1\";\n const OMIKUJI_KEEP_DAYS = 120; // これより古い日は捨てる（無限に太らせない）\n // Xやチャットアプリの「リンクの中身を見に来るロボット」は人数に数えない。\n // 数えると、1回シェアされただけで訪問者が増えたように見えて判断を誤る。\n const OMIKUJI_BOT =\n /bot|crawler|spider|slurp|preview|facebookexternalhit|discord|slack|line\\/|whatsapp|embedly|skype|telegram|pinterest|vkshare|curl|wget|python|okhttp|headless/i;\n async function omikujiBump(fields) {\n try {\n const all = (await blob.getJSON(OMIKUJI_STATS_KEY)) ?? {};\n const day = jstDate(); // JSTの日付で1行（bot本体と同じ数え方）\n const d = all[day] ??\n { v: 0, ref: 0, draw: 0, share: 0, fdraw: 0, fshare: 0, r: {} };\n for (const [k, n] of Object.entries(fields)) {\n if (k === \"r\") d.r[n] = (d.r[n] ?? 0) + 1;\n else d[k] = (d[k] ?? 0) + n;\n }\n all[day] = d;\n const keep = Object.keys(all).sort().slice(-OMIKUJI_KEEP_DAYS);\n const trimmed = {};\n for (const k of keep) trimmed[k] = all[k];\n await blob.setJSON(OMIKUJI_STATS_KEY, trimmed);\n } catch (_) { /* 計測の失敗でページを落とさない。数字より配信が大事。 */ }\n }\n\n // ページから送られてくる「引いた」「シェアを押した」の合図（本文は空・応答は204）\n if (p.endsWith(\"/omikuji-stat\")) {\n const e = url.searchParams.get(\"e\") ?? \"\";\n const fromShare = url.searchParams.get(\"f\") === \"1\"; // シェア経由で来た人か\n if (e === \"draw\" || e === \"share\") {\n const f = { [e]: 1 };\n if (fromShare) f[e === \"draw\" ? \"fdraw\" : \"fshare\"] = 1;\n await omikujiBump(f);\n }\n return new Response(null, {\n status: 204,\n headers: { \"Cache-Control\": \"no-store\" },\n });\n }\n\n // 貯まった数字を見る（社長用。python omikuji_stats.py がこれを読む）\n if (p.endsWith(\"/omikuji-stats\")) {\n if (url.searchParams.get(\"key\") !== Deno.env.get(\"ADMIN_KEY\")) {\n return new Response(\"認証エラー\", { status: 401 });\n }\n const all = (await blob.getJSON(OMIKUJI_STATS_KEY)) ?? {};\n return new Response(JSON.stringify(all), {\n headers: {\n \"Content-Type\": \"application/json; charset=utf-8\",\n \"Cache-Control\": \"no-store\",\n },\n });\n }\n\n // 運勢ごとのOGP画像（/omikuji-ogp-daikichi.png など。印なしは従来の /omikuji-ogp.png）\n {\n const m = p.match(/\\/omikuji-ogp(?:-([a-z-]+))?\\.png$/);\n if (m) {\n const blobName = m[1] ? `omikuji-ogp-${m[1]}.png` : \"omikuji-ogp.png\";\n try {\n return new Response(await getImageBytes(blobName), {\n headers: {\n \"Content-Type\": \"image/png\",\n \"Cache-Control\": \"public, max-age=86400\",\n },\n });\n } catch (_) {\n return new Response(\"not found\", { status: 404 });\n }\n }\n }\n\n // 公開ページ。?r= が付いているときだけ、カードの画像・見出しをその運勢に差し替える。\n // 差し替えないと、どの運勢をシェアしても同じ絵になり「何を引いたか」が伝わらない。\n if (p.endsWith(\"/omikuji\")) {\n let html;\n try {\n html = new TextDecoder().decode(await getImageBytes(\"omikuji.html\"));\n } catch (_) {\n return new Response(\n \"おみくじページが未アップロードです（publish_omikuji.py を実行してください）\",\n {\n status: 404,\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n },\n );\n }\n const r = url.searchParams.get(\"r\") ?? \"\";\n const name = OMIKUJI_UNSEI[r];\n\n // 来訪を数える（ロボットは除く）。?r= 付きなら「シェア経由」として別に数える。\n if (!OMIKUJI_BOT.test(req.headers.get(\"user-agent\") ?? \"\")) {\n await omikujiBump(name ? { v: 1, ref: 1, r } : { v: 1 });\n }\n\n if (name) {\n const base = url.origin + p; // 例) https://…/omikuji\n const setMeta = (h, attr, key, val) =>\n h.replace(\n new RegExp(`(\n h.replace(\n new RegExp(`(\n new Response(JSON.stringify(o), {\n status: st,\n headers: { \"Content-Type\": \"application/json; charset=utf-8\" },\n });\n const today = jstDate();\n const force = url.searchParams.get(\"force\") === \"1\";\n // 二重投稿の最終防衛線（サーバ側で日付を持つ＝両PCから叩かれても1日1回）\n if (!force && s.omikujiDate === today) {\n return jsonRes({\n ok: true,\n skipped: \"already_posted_today\",\n id: s.omikujiId ?? null,\n });\n }\n const ng = checkText(\n String(j.text ?? \"\").replace(/https?:\\/\\/\\S+/g, \"x\".repeat(23)),\n );\n if (ng) {\n return jsonRes({ ok: false, error: \"本文NG: \" + ng }, 400);\n }\n let id;\n try {\n id = await postWithVideo(\n String(j.text),\n String(j.video ?? \"omikuji.mp4\"),\n );\n } catch (e) {\n await sendDiscord({\n content: `⚠ 朝のFXおみくじの投稿に失敗しました（本ポスト）。\\n${\n String(e).slice(0, 400)\n }`,\n });\n return jsonRes({ ok: false, error: String(e) }, 500);\n }\n // 本ポストが出た時点で当日分を確定（この後で落ちても二重投稿しない）\n s.omikujiDate = today;\n s.omikujiId = id;\n await setState(s);\n let replyId = null, replyErr = null;\n if (j.reply) {\n try {\n replyId = await postTweetReply(String(j.reply), id);\n } catch (e) {\n replyErr = String(e).slice(0, 400);\n }\n }\n await sendDiscord({\n content:\n `⛩ 朝のFXおみくじを自動投稿しました。\\nhttps://x.com/i/status/${id}\\n` +\n (j.reply\n ? (replyId\n ? \"↳ リプ（おみくじURL）も投稿済み\"\n : `⚠ リプの投稿に失敗: ${replyErr}`)\n : \"\"),\n });\n return jsonRes({ ok: true, id, replyId, replyErr });\n }\n // 【ブロック②】ここまで ------------------------------------------------------\n // 【ブロック③】ここから ------------------------------------------------------\n // ブロック②のすぐ下（同じ場所）に続けて貼る。おみくじの「公開ページ」を配信する。\n // 中身はBlobに置いたHTMLを返すだけなので、ページを更新したいときは\n // PC側で publish_omikuji.py を実行するだけでよい（このコードは触らない）。\n // ===== 朝のFXおみくじ: 公開ページ =====\n if (p.endsWith(\"/omikuji\")) {\n try {\n const bytes = await getImageBytes(\"omikuji.html\");\n return new Response(bytes, {\n headers: {\n \"Content-Type\": \"text/html; charset=utf-8\",\n \"Cache-Control\": \"public, max-age=300\",\n },\n });\n } catch (_) {\n return new Response(\n \"おみくじページが未アップロードです（publish_omikuji.py を実行してください）\",\n {\n status: 404,\n headers: { \"Content-Type\": \"text/plain; charset=utf-8\" },\n },\n );\n }\n }\n // OGP画像（Xでリンクをカード表示させるため）\n if (p.endsWith(\"/omikuji-ogp.png\")) {\n try {\n const bytes = await getImageBytes(\"omikuji-ogp.png\");\n return new Response(bytes, {\n headers: {\n \"Content-Type\": \"image/png\",\n \"Cache-Control\": \"public, max-age=86400\",\n },\n });\n } catch (_) {\n return new Response(\"not found\", { status: 404 });\n }\n }\n // 【ブロック③】ここまで ------------------------------------------------------\n // 画像アップロード用フォーム（コード経由でBlobに保存 → コードから読める）\n if (p.endsWith(\"/upload\")) {\n if (url.searchParams.get(\"key\") !== Deno.env.get(\"ADMIN_KEY\")) {\n return new Response(\"認証エラー\", { status: 401 });\n }\n if (req.method === \"POST\") {\n const f = await req.formData();\n const files = f.getAll(\"files\");\n const names = [];\n for (const file of files) {\n if (file instanceof File && file.size > 0) {\n await blob.set(file.name, new Uint8Array(await file.arrayBuffer()));\n names.push(file.name);\n }\n }\n return new Response(\n \"アップロード完了: \" + names.length + \"件\\n\" + names.join(\"\\n\"),\n { headers: { \"Content-Type\": \"text/plain; charset=utf-8\" } },\n );\n }\n const key = url.searchParams.get(\"key\");\n return new Response(\n `

` +\n `

画像アップロード

x-auto-post/images/ の画像を選んでください（複数可）。

` +\n `

`,\n { headers: { \"Content-Type\": \"text/html; charset=utf-8\" } },\n );\n }\n // 画像管理ページ: 一覧表示＋削除ボタン\n if (p.endsWith(\"/manage\")) {\n if (url.searchParams.get(\"key\") !== Deno.env.get(\"ADMIN_KEY\")) {\n return new Response(\"認証エラー\", { status: 401 });\n }\n let msg = \"\";\n if (req.method === \"POST\") {\n const f = await req.formData();\n const name = String(f.get(\"del\") || \"\");\n if (name) {\n await blob.delete(name);\n msg = `🗑 ${name} を削除しました。`;\n }\n }\n const base = Deno.env.get(\"BOT_BASE_URL\");\n const items = await blob.list();\n const imgs = items.map((i) => i.key).filter((k) =>\n /\\.(png|jpg|jpeg)$/i.test(k)\n ).sort();\n const rows = imgs.map((n) =>\n `

` +\n `

${n}` +\n `

`\n ).join(\"\");\n return new Response(\n `

` +\n `

画像の管理

${\n msg ? `

${msg}

` : \"\"\n }

全${imgs.length}枚。削除は取り消せません。

${rows}

`,\n { headers: { \"Content-Type\": \"text/html; charset=utf-8\" } },\n );\n }\n // デバッグ: Blobの実キー一覧\n if (p.endsWith(\"/list\")) {\n const items = await blob.list();\n return new Response(JSON.stringify(items, null, 2), {\n headers: { \"Content-Type\": \"application/json; charset=utf-8\" },\n });\n }\n // デバッグ: 現在の状態(予約・送信済み日付・停止設定・現在時刻)を表示\n if (p.endsWith(\"/state\")) {\n if (url.searchParams.get(\"key\") !== Deno.env.get(\"ADMIN_KEY\")) {\n return new Response(\"認証エラー\", { status: 401 });\n }\n const info = {\n 今JST日付: jstDate(),\n 今の分: jstMins(),\n ENABLED_停止設定: Deno.env.get(\"ENABLED\") ?? \"(未設定=稼働)\",\n 予約_reservedDate: s.reservedDate || \"(なし)\",\n 予約_本文: s.reservedText || \"(なし)\",\n 予約_画像: s.reservedImg || \"(なし)\",\n 朝送信済み日付_morningSentDate: s.morningSentDate || \"(なし)\",\n 夜送信済み日付_sentDate: s.sentDate || \"(なし)\",\n 最終投稿日_postedDate: s.postedDate || \"(なし)\",\n status: s.status,\n 市場日報_marketDate: s.marketDate || \"(なし)\",\n 市場日報_本文: s.marketText || \"(なし)\",\n 市場日報_画像: (s.marketImgs && s.marketImgs.length)\n ? s.marketImgs.join(\",\")\n : \"(なし)\",\n 市場日報_動画: s.marketVideo || \"(なし)\",\n };\n return new Response(JSON.stringify(info, null, 2), {\n headers: { \"Content-Type\": \"application/json; charset=utf-8\" },\n });\n }\n if (p.endsWith(\"/img\")) {\n const name = url.searchParams.get(\"name\");\n try {\n const bytes = await getImageBytes(name);\n const ct = name.toLowerCase().endsWith(\".png\")\n ? \"image/png\"\n : \"image/jpeg\";\n return new Response(bytes, {\n headers: {\n \"Content-Type\": ct,\n \"Cache-Control\": \"public, max-age=3600\",\n },\n });\n } catch (e) {\n return new Response(\"画像取得エラー: \" + String(e), { status: 404 });\n }\n }\n if (p.endsWith(\"/ping\")) {\n await sendDiscord({ content: \"✅ 接続テスト成功\" });\n return new Response(\"OK\");\n }\n // 段階1テスト: Twelve Data からドル円データが取れるか\n if (p.endsWith(\"/testdata\")) {\n if (url.searchParams.get(\"key\") !== Deno.env.get(\"ADMIN_KEY\")) {\n return new Response(\"認証エラー\", { status: 401 });\n }\n const k = Deno.env.get(\"TWELVEDATA_API_KEY\");\n if (!k) {\n return new Response(\"TWELVEDATA_API_KEY が未設定です\", { status: 500 });\n }\n const r = await fetch(\n `https://api.twelvedata.com/time_series?symbol=USD/JPY&interval=1h&outputsize=5&apikey=${k}`,\n );\n const d = await r.json();\n return new Response(JSON.stringify(d, null, 2), {\n headers: { \"Content-Type\": \"application/json; charset=utf-8\" },\n });\n }\n // 段階2テスト: データ取得→インジ計算→Gemini執筆を実行して結果を表示\n if (p.endsWith(\"/generate\")) {\n if (url.searchParams.get(\"key\") !== Deno.env.get(\"ADMIN_KEY\")) {\n return new Response(\"認証エラー\", { status: 401 });\n }\n try {\n const { text, summary, candImgs } = await generateDraft();\n if (url.searchParams.get(\"send\") === \"1\") {\n s.draftText = text;\n s.candImgs = candImgs;\n s.draftDate = jstDate();\n s.token = crypto.randomUUID().slice(0, 8);\n s.status = \"pending\";\n s.sentDate = jstDate();\n await setState(s);\n await sendDraftMessage(s);\n return new Response(\n `Discordに送信しました(${text.length}字)。\\n\\n${text}`,\n { headers: { \"Content-Type\": \"text/plain; charset=utf-8\" } },\n );\n }\n return new Response(\n `【生成された相場観(${text.length}字)】\\n\\n${text}\\n\\n————— 計算データ —————\\n${summary}`,\n { headers: { \"Content-Type\": \"text/plain; charset=utf-8\" } },\n );\n } catch (e) {\n return new Response(\"生成エラー: \" + String(e), { status: 500 });\n }\n }\n // 管理: テスト送信\n if (p.endsWith(\"/send-now\")) {\n if (url.searchParams.get(\"key\") !== Deno.env.get(\"ADMIN_KEY\")) {\n return new Response(\"認証エラー\", { status: 401 });\n }\n s.token = crypto.randomUUID().slice(0, 8);\n s.status = \"pending\";\n await setState(s);\n await sendDraftMessage(s);\n return new Response(\"OK: Discordに下書き＋3候補を送信しました。\");\n }\n // 管理: 下書きセット（本文＋画像候補） body: {\"text\":\"...\",\"images\":[\"a.png\",\"b.png\",\"c.png\"]}\n if (p.endsWith(\"/set-draft\")) {\n if (url.searchParams.get(\"key\") !== Deno.env.get(\"ADMIN_KEY\")) {\n return new Response(\"認証エラー\", { status: 401 });\n }\n const b = await req.json().catch(() => ({}));\n s.draftText = (b.text || \"\").trim();\n s.candImgs = Array.isArray(b.images) ? b.images.slice(0, 3) : [];\n s.draftDate = jstDate();\n s.status = \"pending\";\n await setState(s);\n return new Response(\"OK: 下書きを保存しました。\");\n }\n // ===== 市場日報（前日相場→3枚カード）: ローカルPythonから引き渡し =====\n // 本文＋画像名(最大4)を登録し、Discordへ承認メッセージを送る。朝の学習ポストは当日抑止。\n // body: {\"text\":\"...\",\"images\":[\"market_1.png\",\"market_2.png\",\"market_3.png\"]}\n if (p.endsWith(\"/market-prep\")) {\n if (url.searchParams.get(\"key\") !== Deno.env.get(\"ADMIN_KEY\")) {\n return new Response(\"認証エラー\", { status: 401 });\n }\n const b = await req.json().catch(() => ({}));\n s.marketText = (b.text || \"\").trim();\n s.marketImgs = Array.isArray(b.images) ? b.images.slice(0, 4) : [];\n s.marketVideo = typeof b.video === \"string\" ? b.video.trim() : \"\";\n if (s.marketVideo) {\n const items = await blob.list();\n if (!items.some((it) => it.key === s.marketVideo)) {\n s.marketVideo = \"\"; // blob未到着なら画像のみで進む\n }\n }\n s.marketDate = jstDate();\n s.marketToken = crypto.randomUUID().slice(0, 8);\n s.morningSentDate = jstDate(); // 朝の学習ポストの自動送信を抑止\n await setState(s);\n await sendMarketMessage(s);\n return new Response(\n \"OK: 市場日報をDiscordに送信しました。承認で画像セット投稿されます。\",\n { headers: { \"Content-Type\": \"text/plain; charset=utf-8\" } },\n );\n }\n // 市場日報: 今すぐ画像セットで投稿\n if (p.endsWith(\"/post-market\")) {\n if (url.searchParams.get(\"token\") !== s.marketToken || !s.marketToken) {\n return page(\"リンクの有効期限が切れています。\");\n }\n const err = checkText(s.marketText);\n if (err) {\n return page(\"投稿できません：\" + err);\n }\n if (!(s.marketImgs && s.marketImgs.length)) {\n return page(\"画像がありません。\");\n }\n const useVideo = !!s.marketVideo && url.searchParams.get(\"mode\") !== \"imgs\";\n try {\n let id;\n let note = \"\";\n if (useVideo) {\n try {\n id = await postWithVideo(s.marketText, s.marketVideo);\n note = \"（🎬動画）\";\n } catch (ve) {\n id = await postWithImages(s.marketText, s.marketImgs);\n note = `（動画投稿に失敗→画像${s.marketImgs.length}枚で投稿: ` +\n String(ve).slice(0, 120) + \"）\";\n }\n } else {\n id = await postWithImages(s.marketText, s.marketImgs);\n }\n s.postedDate = jstDate();\n s.lastTweetId = id;\n s.marketDate = \"\";\n s.marketToken = \"\"; // 再クリック/再読込での二重投稿を防止\n await setState(s);\n await sendDiscord({\n content:\n `✅ 市場日報を投稿しました。${note}\\nhttps://x.com/i/status/${id}`,\n });\n return page(\"✅ 投稿しました！\");\n } catch (e) {\n return page(\"投稿に失敗：\" + String(e));\n }\n }\n // 市場日報: 本文編集フォーム（画像はそのまま維持）\n if (p.endsWith(\"/market-edit\")) {\n if (url.searchParams.get(\"token\") !== s.marketToken || !s.marketToken) {\n return page(\"リンク期限切れ\");\n }\n return new Response(\n `

市場日報を編集して投稿

`,\n { headers: { \"Content-Type\": \"text/html; charset=utf-8\" } },\n );\n }\n if (p.endsWith(\"/market-submit\") && req.method === \"POST\") {\n const f = await req.formData();\n const token = String(f.get(\"token\") || \"\");\n const text = String(f.get(\"text\") || \"\").trim();\n if (token !== s.marketToken || !s.marketToken) {\n return page(\"リンク期限切れ\");\n }\n const err = checkText(text);\n if (err) {\n return page(\"投稿できません：\" + err);\n }\n if (!(s.marketImgs && s.marketImgs.length)) {\n return page(\"画像がありません。\");\n }\n try {\n let id;\n let note = \"\";\n if (s.marketVideo) {\n try {\n id = await postWithVideo(text, s.marketVideo);\n note = \"（🎬動画）\";\n } catch (ve) {\n id = await postWithImages(text, s.marketImgs);\n note = `（動画投稿に失敗→画像${s.marketImgs.length}枚で投稿: ` +\n String(ve).slice(0, 120) + \"）\";\n }\n } else {\n id = await postWithImages(text, s.marketImgs);\n }\n s.marketText = text;\n s.postedDate = jstDate();\n s.lastTweetId = id;\n s.marketDate = \"\";\n s.marketToken = \"\"; // 再送信での二重投稿を防止\n await setState(s);\n await sendDiscord({\n content:\n `✅ 市場日報を投稿しました。${note}\\nhttps://x.com/i/status/${id}`,\n });\n return page(\"✅ 投稿しました！\");\n } catch (e) {\n return page(\"投稿に失敗：\" + String(e));\n }\n }\n // 市場日報: 目線変更（④を事前生成済みの手動版blobに差し替えて即・再送。PC不要＝スマホ完結）\n if (p.endsWith(\"/market-bias\")) {\n const set = url.searchParams.get(\"set\") || \"\";\n const jp = { up: \"上目線\", down: \"下目線\", range: \"レンジ\" };\n const isAdmin = url.searchParams.get(\"key\") === Deno.env.get(\"ADMIN_KEY\");\n const isToken = url.searchParams.get(\"token\") === s.marketToken &&\n !!s.marketToken;\n if (!isAdmin && !isToken) {\n return page(\"リンクの有効期限が切れています。\");\n }\n if (!jp[set]) {\n return page(\"不正な指定です。\");\n }\n if (\n !(s.marketImgs && s.marketImgs.length >= 4) || s.marketDate !== jstDate()\n ) {\n return page(\"本日の市場日報(④付き)の承認待ちがありません。\");\n }\n s.marketImgs[3] = `market_4_${set}.png`;\n if (s.marketVideo) {\n s.marketVideo = \"\"; // 動画は元の④で作られているため、目線変更後は画像4枚投稿に切替\n }\n s.marketToken = crypto.randomUUID().slice(0, 8); // 旧リンク失効＋新メッセージ発行\n await setState(s);\n await sendMarketMessage(s);\n return page(\n `🔁 ④を「${\n jp[set]\n }（手動）」版に差し替えました。Discordの新しい承認メッセージから投稿してください。`,\n );\n }\n if (p.endsWith(\"/market-skip\")) {\n if (url.searchParams.get(\"token\") !== s.marketToken || !s.marketToken) {\n return page(\"リンク期限切れ\");\n }\n s.marketDate = \"\";\n s.marketToken = \"\";\n await setState(s);\n return page(\"⏭ 市場日報は本日スキップしました。\");\n }\n // 投稿（今すぐ / 18時）\n if (p.endsWith(\"/post\")) {\n if (url.searchParams.get(\"token\") !== s.token || !s.token) {\n return page(\"リンクの有効期限が切れています。\");\n }\n const i = parseInt(url.searchParams.get(\"i\") || \"1\", 10);\n const when = url.searchParams.get(\"when\") || \"now\";\n const img = cands(s)[i - 1];\n const err = checkText(s.draftText);\n if (err) {\n return page(\"投稿できません：\" + err);\n }\n if (!img) {\n return page(\"画像が見つかりません。\");\n }\n if (when === \"1800\" && jstMins() < 18 * 60) {\n s.status = \"scheduled\";\n s.chosenImg = img;\n await setState(s);\n return page(`⏰ ${[\"①\", \"②\", \"③\"][i - 1]}の画像で18時に予約しました。`);\n }\n try {\n const id = await postWithImage(s.draftText, img);\n s.status = \"posted\";\n s.postedDate = jstDate();\n s.lastTweetId = id;\n s.token = \"\"; // 再クリック/再読込での二重投稿を防止\n await setState(s);\n await sendDiscord({\n content: `✅ 投稿しました。\\nhttps://x.com/i/status/${id}`,\n });\n return page(\"✅ 投稿しました！\");\n } catch (e) {\n return page(\"投稿に失敗：\" + String(e));\n }\n }\n if (p.endsWith(\"/skip\")) {\n if (url.searchParams.get(\"token\") !== s.token || !s.token) {\n return page(\"リンク期限切れ\");\n }\n s.status = \"skipped\";\n await setState(s);\n return page(\"⏭ 本日はスキップしました。\");\n }\n if (p.endsWith(\"/edit\")) {\n if (url.searchParams.get(\"token\") !== s.token || !s.token) {\n return page(\"リンク期限切れ\");\n }\n return composeForm(s);\n }\n if (p.endsWith(\"/compose\")) {\n if (!s.token) {\n s.token = crypto.randomUUID().slice(0, 8);\n await setState(s);\n }\n return composeForm(s);\n }\n // オンデマンド生成: 今すぐ相場観をAI生成し、編集フォーム(3候補＋自分の画像)を表示\n if (p.endsWith(\"/now\")) {\n if (url.searchParams.get(\"key\") !== Deno.env.get(\"ADMIN_KEY\")) {\n return new Response(\"認証エラー\", { status: 401 });\n }\n try {\n const g = await generateDraft();\n s.draftText = g.text;\n s.candImgs = g.candImgs;\n s.draftDate = jstDate();\n s.token = crypto.randomUUID().slice(0, 8);\n s.status = \"pending\";\n await setState(s);\n return composeForm(s);\n } catch (e) {\n return new Response(\"生成エラー: \" + String(e), { status: 500 });\n }\n }\n // オンデマンド生成(朝の学び投稿): 今すぐ生成→編集フォーム表示\n if (p.endsWith(\"/morning-now\")) {\n if (url.searchParams.get(\"key\") !== Deno.env.get(\"ADMIN_KEY\")) {\n return new Response(\"認証エラー\", { status: 401 });\n }\n try {\n const g = await generateMorning();\n s.draftText = g.text;\n s.candImgs = g.candImgs;\n s.draftDate = jstDate();\n s.token = crypto.randomUUID().slice(0, 8);\n s.status = \"pending\";\n await setState(s);\n return composeForm(s);\n } catch (e) {\n return new Response(\"生成エラー: \" + String(e), { status: 500 });\n }\n }\n // 翌朝分を前夜に予約: 朝の学びを生成→予約フォーム(翌朝7:25に自動投稿)\n if (p.endsWith(\"/prep\")) {\n if (url.searchParams.get(\"key\") !== Deno.env.get(\"ADMIN_KEY\")) {\n return new Response(\"認証エラー\", { status: 401 });\n }\n try {\n const g = await generateMorning();\n s.draftText = g.text;\n s.candImgs = g.candImgs;\n s.draftDate = jstDate();\n s.token = crypto.randomUUID().slice(0, 8);\n s.status = \"pending\";\n await setState(s);\n return composeForm(s, \"reserve\");\n } catch (e) {\n return new Response(\"生成エラー: \" + String(e), { status: 500 });\n }\n }\n // ライブ配信用: 詳細相場分析を生成 → 画面表示＋Discordへ(Xには投稿しない)\n if (p.endsWith(\"/analysis\")) {\n if (url.searchParams.get(\"key\") !== Deno.env.get(\"ADMIN_KEY\")) {\n return new Response(\"認証エラー\", { status: 401 });\n }\n try {\n const text = await analyzeDetailed();\n await sendDiscord({\n embeds: [{\n title: \"📊 相場分析(詳細版・ライブ用/未投稿)\",\n description: text.slice(0, 4000),\n color: 15844367,\n }],\n });\n return new Response(\n `

📊 相場分析(詳細版)

${\n text.replace(/

※ これはライブ用の分析で、Xには投稿されません。Discordにも送信済み。

`,\n { headers: { \"Content-Type\": \"text/html; charset=utf-8\" } },\n );\n } catch (e) {\n return new Response(\"分析エラー: \" + String(e), { status: 500 });\n }\n }\n // 操作メニューをDiscordへ送る(ピン留めして各リンクから操作)\n if (p.endsWith(\"/menu\")) {\n if (url.searchParams.get(\"key\") !== Deno.env.get(\"ADMIN_KEY\")) {\n return new Response(\"認証エラー\", { status: 401 });\n }\n const base = Deno.env.get(\"BOT_BASE_URL\");\n const k = url.searchParams.get(\"key\");\n await sendDiscord({\n embeds: [{\n title: \"🛠 操作メニュー(ピン留め推奨)\",\n description:\n `[☀ 今すぐ朝投稿を作る](${base}/morning-now?key=${k})\\n[📈 今すぐ相場観を作る](${base}/now?key=${k})\\n[📊 相場分析(詳細版・ライブ用/未投稿)](${base}/analysis?key=${k})\\n[🌅 明日の朝を予約する](${base}/prep?key=${k})\\n[🖼 画像の管理](${base}/manage?key=${k})\\n—— 市場日報④ 目線変更(再作成) ——\\n[⬆上目線](${base}/market-bias?key=${k}&set=up)　[⬇下目線](${base}/market-bias?key=${k}&set=down)　[↔レンジ](${base}/market-bias?key=${k}&set=range)`,\n color: 3447003,\n }],\n });\n return new Response(\n \"Discordに操作メニューを送信しました。ピン留めしておくと便利です。\",\n );\n }\n if (p.endsWith(\"/submit\") && req.method === \"POST\") {\n const f = await req.formData();\n const token = String(f.get(\"token\") || \"\");\n const text = String(f.get(\"text\") || \"\").trim();\n const i = parseInt(String(f.get(\"i\") || \"1\"), 10);\n if (token !== s.token || !s.token) {\n return page(\"リンク期限切れ\");\n }\n const err = checkText(text);\n if (err) {\n return page(\"投稿できません：\" + err);\n }\n try {\n let bytes;\n if (i === 4) {\n const file = f.get(\"uploaded\");\n if (!(file instanceof File) || file.size === 0) {\n return page(\"「④自分の画像」を選びましたが、画像が未選択です。\");\n }\n bytes = new Uint8Array(await file.arrayBuffer());\n } else {\n const name = cands(s)[i - 1];\n if (!name) {\n return page(\"画像が見つかりません。\");\n }\n bytes = await getImageBytes(name);\n }\n const mediaId = await uploadMedia(bytes);\n const id = await postTweet(text, mediaId);\n s.draftText = text;\n s.status = \"posted\";\n s.postedDate = jstDate();\n s.lastTweetId = id;\n s.token = \"\"; // 再送信での二重投稿を防止\n await setState(s);\n await sendDiscord({\n content: `✅ 投稿しました。\\nhttps://x.com/i/status/${id}`,\n });\n return page(\"✅ 投稿しました！\");\n } catch (e) {\n return page(\"投稿に失敗：\" + String(e));\n }\n }\n // 予約確定: 翌朝7:25に自動投稿する内容を保存\n if (p.endsWith(\"/reserve\") && req.method === \"POST\") {\n const f = await req.formData();\n const token = String(f.get(\"token\") || \"\");\n const text = String(f.get(\"text\") || \"\").trim();\n const i = parseInt(String(f.get(\"i\") || \"1\"), 10);\n if (token !== s.token || !s.token) {\n return page(\"リンク期限切れ\");\n }\n const err = checkText(text);\n if (err) {\n return page(\"予約できません：\" + err);\n }\n try {\n let imgName;\n if (i === 4) {\n const file = f.get(\"uploaded\");\n if (!(file instanceof File) || file.size === 0) {\n return page(\"「④自分の画像」を選びましたが画像が未選択です。\");\n }\n await blob.set(\n \"reserved_upload.png\",\n new Uint8Array(await file.arrayBuffer()),\n );\n imgName = \"reserved_upload.png\";\n } else {\n imgName = cands(s)[i - 1];\n if (!imgName) {\n return page(\"画像が見つかりません。\");\n }\n }\n s.reservedText = text;\n s.reservedImg = imgName;\n s.reservedDate = tomorrowJST();\n await setState(s);\n return page(\n `🌅 翌朝7:25に予約しました(${tomorrowJST()})。ゆっくり休んでください。`,\n );\n } catch (e) {\n return page(\"予約に失敗：\" + String(e));\n }\n }\n return new Response(\"FX午後ボット v2 稼働中\");\n}\n// 【ブロック①】ここから ------------------------------------------------------\n// 既存の投稿に「返信」としてぶら下げる（Xの本文にURLを入れずに済ませるため）\nasync function postTweetReply(text, replyToId) {\n const url = \"https://api.twitter.com/2/tweets\";\n const auth = await oauthHeader(\"POST\", url);\n const body = { text, reply: { in_reply_to_tweet_id: replyToId } };\n const res = await fetch(url, {\n method: \"POST\",\n headers: { Authorization: auth, \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n const data = await res.json();\n if (!res.ok) {\n throw new Error(\"リプ投稿失敗: \" + JSON.stringify(data));\n }\n return data.data.id;\n}\n// 【ブロック①】ここまで ------------------------------------------------------",[127],"pulls","branches",1,"forks","envVars",{"_142":144,"_145":40},"connections",{"_142":40,"_143":40},"count","unfilledCount",9,"emptyCount",{"_18":126,"_20":127,"_110":128,"_112":-5,"_113":66,"_114":64,"_116":101,"_22":152,"_63":130,"_119":131,"_121":132,"_123":26,"_124":-5,"_149":153,"_84":154},{"_18":108,"_20":109,"_110":111,"_112":-5,"_113":66,"_114":115,"_116":101,"_22":148,"_63":118,"_119":120,"_121":122,"_123":26,"_124":-5,"_149":150,"_84":151},["D",1783740199284],"children",[],[109],["D",1786796683204],[],[127],["D",1783177374203],{"_16":17,"_82":78},{"_16":17,"_75":76,"_77":78,"_33":34,"_79":80,"_81":26},{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"ctx",{"_56":-5,"_103":192,"_193":194,"_195":196,"_197":26,"_198":26,"_199":26,"_200":101,"_201":-5,"_202":-7,"_203":-7,"_204":40,"_205":26,"_206":26,"_207":-5,"_208":26,"_209":26,"_210":26,"_211":-5},"ENV",{"_163":164,"_165":166,"_167":65,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191},"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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Search