rule-watch

1import { atom, read, update } from 'claude-code'
2import type { EngineInterface, Register, RenderElement } from 'claude-code'
3
4import type { RuleKind, RuleMiss } from '../types'
5import {
6  HISTORY_MAX,
7  KINDS,
8  STICKY,
9  bandText,
10  endsWithQuestion,
11  hasLogLine,
12  isAbsolute,
13  isClosing,
14  isCommit,
15  isEnglish,
16  isTodayLog,
17  isUnder,
18  logName,
19  mentionsDir,
20  paneLines,
21  paneSvg,
22  questionLine,
23  remindText,
24} from './rules'
25import { followTheme, readTheme, short } from './style'
26
27const PANE = 'rule-watch'
28const TITLE = '約束ごとの見張り'
29const DESCRIPTION = '英語の返事・文での質問・メモと開発ログの書き忘れの数と記録のペインを開く'
30
31const MISSES = atom({ plugin: 'rule-watch', key: 'misses' } as const, [])
32const ZERO: Record<RuleKind, number> = { english: 0, question: 0, memo: 0, log: 0, logLine: 0, closing: 0 }
33const COUNTS = atom({ plugin: 'rule-watch', key: 'counts' } as const, ZERO)
34const HISTORY = atom({ plugin: 'rule-watch', key: 'history' } as const, [])
35const ASKS = atom({ plugin: 'rule-watch', key: 'asks' } as const, 0)
36const MEMO = atom({ plugin: 'rule-watch', key: 'memoPending' } as const, null)
37const LOG = atom({ plugin: 'rule-watch', key: 'log' } as const, { pending: null, isWritten: false, isClosing: false })
38
39type $ = EngineInterface
40
41// 設定は register で userConfig から入れる
42const cfg = { english: true, question: true, memoDir: '', logDir: '', grace: 0 }
43let ownsMain = false
44
45const EDIT_TOOLS = ['Write', 'Edit', 'MultiEdit', 'NotebookEdit']
46const SHELL_TOOLS = ['Bash', 'PowerShell']
47
48const isOn = (k: RuleKind) => (k === 'english' ? cfg.english : k === 'question' ? cfg.question : k === 'memo' ? cfg.memoDir !== '' : cfg.logDir !== '')
49const watching = (): RuleKind[] => KINDS.filter(isOn)
50
51const drawsSomething = (tree: RenderElement) => tree.type !== 'engine'
52
53/** メモを書いた。待ちを下ろし、帯のメモの分も消す */
54async function memoWritten($: $) {
55  await update($, MEMO, () => null)
56  await update($, MISSES, m => (m.some(x => x.rule === 'memo') ? m.filter(x => x.rule !== 'memo') : m))
57}
58
59/** 今日の開発ログを書いた。待ちを下ろし、帯のログの分も消す */
60async function logWritten($: $) {
61  await update($, LOG, l => ({ ...l, pending: null, isWritten: true }))
62  await update($, MISSES, m => (m.some(x => x.rule === 'log') ? m.filter(x => x.rule !== 'log') : m))
63}
64
65/** メインのターンの終わりに、返事とメモ・開発ログの待ちを見る */
66async function judge($: $, answer: string): Promise<RuleMiss[]> {
67  const misses: RuleMiss[] = []
68  if (cfg.english && isEnglish(answer)) misses.push({ rule: 'english', detail: '' })
69  if (cfg.question && (await read($, ASKS)) === 0 && endsWithQuestion(answer)) misses.push({ rule: 'question', detail: short(questionLine(answer), 80) })
70  const pending = await read($, MEMO)
71  if (cfg.memoDir !== '' && pending) {
72    if (pending.turns >= cfg.grace) misses.push({ rule: 'memo', detail: '' })
73    else await update($, MEMO, p => (p ? { ...p, turns: p.turns + 1 } : p))
74  }
75  if (cfg.logDir !== '') {
76    const log = await read($, LOG)
77    const name = logName(await $.clock.now())
78    if (log.pending) {
79      if (log.pending.turns >= cfg.grace) misses.push({ rule: 'log', detail: name })
80      else await update($, LOG, l => (l.pending ? { ...l, pending: { ...l.pending, turns: l.pending.turns + 1 } } : l))
81    }
82    if (log.isWritten && !hasLogLine(answer)) misses.push({ rule: 'logLine', detail: name })
83    if (log.isClosing && !log.isWritten) misses.push({ rule: 'closing', detail: name })
84  }
85  return misses
86}
87
88async function remember($: $, misses: RuleMiss[]) {
89  const before = await read($, MISSES)
90  await update($, MISSES, () => misses)
91  // メモ・開発ログの外れは、出し続けている間は 1 回だけ数える
92  const fresh = misses.filter(m => !(STICKY.includes(m.rule) && before.some(b => b.rule === m.rule)))
93  if (fresh.length === 0) return
94  const at = await $.clock.now()
95  await update($, COUNTS, c => {
96    const next = { ...c }
97    for (const m of fresh) next[m.rule] = (next[m.rule] ?? 0) + 1
98    return next
99  })
100  await update($, HISTORY, h => [...h, ...fresh.map(m => ({ ...m, at }))].slice(-HISTORY_MAX))
101}
102
103async function remind($: $) {
104  const misses = await read($, MISSES)
105  if (misses.length === 0) return
106  const r = await $.prompt.fill({ text: remindText(misses), mode: 'insert' }).catch(() => ({ isFilled: false, refusal: undefined }))
107  const why = r.refusal === 'dialog' ? '(ダイアログが開いています)' : r.refusal === 'no_composer' ? '(この画面には入力欄がありません)' : ''
108  $.ui.toast(r.isFilled ? '入力欄に入れました(送信はしていません)' : `入力欄に入れられませんでした${why}`, { timeoutMs: 5000 })
109}
110
111const openPane = async ($: $) => {
112  await $.ui.open({ id: PANE, title: TITLE })
113  return { text: '約束ごとの見張りのペインを開きました。' }
114}
115
116/** 絶対パスだけを受け付ける。ほかは未設定 */
117const dirOption = (v: unknown) => {
118  const s = String(v ?? '').trim()
119  return isAbsolute(s) ? s : ''
120}
121
122export const register: Register = (on, options) => {
123  cfg.english = options.checkEnglish !== false
124  cfg.question = options.checkQuestion !== false
125  cfg.memoDir = dirOption(options.memoDir)
126  cfg.logDir = dirOption(options.logDir)
127  const grace = Number(options.memoGraceTurns)
128  cfg.grace = Number.isFinite(grace) && grace > 0 ? Math.floor(grace) : 0
129
130  followTheme(on)
131  on('session.start', async ($, e, next) => {
132    const started = await next(e)
133    await readTheme($)
134    // 途中で読み込まれた時も帯を聞きに来るように (docs/mod-guide.md の 3 節)
135    $.ui.invalidate('ui.render')
136    const got = await $.command.register({ name: 'rulewatch', description: DESCRIPTION }).catch(() => undefined)
137    ownsMain = got?.command === 'rulewatch'
138    if (!ownsMain) await $.command.register({ name: 'rule-watch', description: DESCRIPTION }).catch(() => {})
139    return started
140  })
141
142  on('command.run', { command: 'rulewatch' }, ($, e, next) => (ownsMain ? openPane($) : next(e))).catch(($, e, next) => next(e))
143  on('command.run', { command: 'rule-watch' }, openPane)
144
145  // メインのターンの頭で、問いの数とログの印を 0 に戻し、返事についての帯を下ろす (メモ・ログの分は書くまで残す)。
146  // 依頼者の入力に締めの言葉があったかだけを覚える (文そのものは残さない)
147  on('turn.start', async ($, e, next) => {
148    if (e.agentId === undefined) {
149      await update($, ASKS, () => 0)
150      await update($, LOG, l => ({ ...l, isWritten: false, isClosing: isClosing(e.text) }))
151      await update($, MISSES, m => (m.some(x => !STICKY.includes(x.rule)) ? m.filter(x => STICKY.includes(x.rule)) : m))
152    }
153    return next(e)
154  }).catch(($, e, next) => next(e))
155
156  // AskUserQuestion を数え、コミットでメモ・ログ待ちを始め、書いたら下ろす (サブエージェントの分も見る)
157  on('tool.call', async ($, e, next) => {
158    const r = await next(e)
159    if (r.deny !== undefined || r.isError === true) return r
160    const tool = String(e.tool)
161    const args = e as unknown as Record<string, unknown>
162    if (tool === 'AskUserQuestion') {
163      if (e.agentId === undefined) await update($, ASKS, n => n + 1)
164      return r
165    }
166    if (cfg.memoDir === '' && cfg.logDir === '') return r
167    const now = await $.clock.now()
168    if (EDIT_TOOLS.includes(tool)) {
169      const path = String(args.file_path ?? args.notebook_path ?? '')
170      if (isUnder(path, cfg.memoDir)) await memoWritten($)
171      if (isTodayLog(path, cfg.logDir, now)) await logWritten($)
172    } else if (SHELL_TOOLS.includes(tool) && typeof args.command === 'string') {
173      const command = args.command
174      const memo = mentionsDir(command, cfg.memoDir)
175      const log = mentionsDir(command, cfg.logDir, logName(now))
176      if (memo) await memoWritten($)
177      if (log) await logWritten($)
178      if (!memo && !log && isCommit(command)) {
179        if (cfg.memoDir !== '') await update($, MEMO, p => p ?? { since: now, turns: 0 })
180        // このターンにもうログを書いていれば待たない (ログを書いてからコミットした)
181        if (cfg.logDir !== '') await update($, LOG, l => (l.pending || l.isWritten ? l : { ...l, pending: { since: now, turns: 0 } }))
182      }
183    }
184    return r
185  }).catch(($, e, next) => next(e))
186
187  on('turn.complete', async ($, e, next) => {
188    const done = await next(e)
189    if (e.agentId !== undefined || e.reason !== 'answer' || e.answer.trim() === '') return done
190    await remember($, await judge($, e.answer))
191    return done
192  }).catch(($, e, next) => next(e))
193
194  // 入力欄の上の帯。外れが無い時は下の mod に任せる
195  on('ui.render', { component: 'AbovePrompt' }, async ($, e, next) => {
196    if (e.props.hasSurvey) return next(e)
197    const misses = await read($, MISSES)
198    if (misses.length === 0) return next(e)
199    const below = await next(e)
200    const { Box, Text } = $.ui.resolve(e)
201    const band = (
202      <Box key="rules" flexShrink={0}>
203        <Text color="warning">{bandText(misses)}</Text>
204      </Box>
205    )
206    if (!drawsSomething(below)) return band
207    return (
208      <Box flexDirection="column">
209        {band}
210        <Box key="below">{below}</Box>
211      </Box>
212    )
213  }).catch(($, e, next) => next(e))
214
215  on('ui.render', { component: 'Pane', requestId: PANE }, async ($, e) => {
216    const t = $.ui.resolve(e)
217    const { Box, Text, Button } = t
218    // terminal の表にも Svg の名前があるので、画面の種類でも分ける
219    const Svg = e.surface !== 'terminal' && 'Svg' in t ? t.Svg : undefined
220    const input = {
221      misses: await read($, MISSES),
222      // 古い版で数えた分 (log などの欄が無い) も 0 で埋める
223      counts: { ...ZERO, ...(await read($, COUNTS)) },
224      history: await read($, HISTORY),
225      isMemoPending: (await read($, MEMO)) !== null,
226      isLogPending: (await read($, LOG)).pending !== null,
227      watching: watching(),
228    }
229    const lines = paneLines(input)
230    return (
231      <Box flexDirection="column" gap={1}>
232        {Svg ? (
233          <Svg source={paneSvg(input)} alt={lines.map(l => l.text).join('\n')} />
234        ) : (
235          <Box key="lines" flexDirection="column">
236            {lines.map(l => (
237              <Text color={l.color} dimColor={l.isDim} bold={l.isBold}>
238                {l.text}
239              </Text>
240            ))}
241          </Box>
242        )}
243        {input.misses.length > 0 ? <Button key="remind" label="Claude に伝える" variant="primary" onPress={() => void remind($)} /> : null}
244        {cfg.memoDir === '' ? <Text dimColor>メモの見張りは、設定の memoDir に引き継ぎメモのフォルダを入れると始まります。</Text> : null}
245        {cfg.logDir === '' ? <Text dimColor>開発ログの見張りは、設定の logDir に開発ログのフォルダを入れると始まります。</Text> : null}
246        <Text dimColor>知らせるだけです。「Claude に伝える」は入力欄に入れるだけで、送信はしません。</Text>
247      </Box>
248    )
249  })
250}
251

1// 約束ごとの見分けと、帯・ペインの文と SVG。どれも純関数
2import type { RuleEvent, RuleKind, RuleMiss } from '../types'
3import { C, HEADER_H, esc, frame, growBar, header, jstDay, panel, short } from './style'
4
5export const HISTORY_MAX = 20
6export const KINDS: readonly RuleKind[] = ['english', 'question', 'memo', 'log', 'logLine', 'closing']
7/** ファイルを書くまで帯に残す約束 (次のターンの頭で下ろさない) */
8export const STICKY: readonly RuleKind[] = ['memo', 'log']
9
10/** 約束ごとの名前と、外れた時の短い言葉。tell は「Claude に伝える」で足す直し方 */
11export const RULE: Record<RuleKind, { name: string; miss: string; tell?: string }> = {
12  english: { name: '日本語で答える', miss: '返事が英語でした' },
13  question: { name: '確認は選択肢で聞く', miss: '選択肢を使わずに文で質問しました' },
14  memo: { name: '区切りで引き継ぎメモ', miss: 'コミットの後、引き継ぎメモが未更新です' },
15  log: { name: '区切りで開発ログ', miss: 'コミットの後、今日の開発ログが未記入です', tell: '今日の日付の開発ログに、この作業のブロックを書いてください' },
16  logLine: { name: '開発ログの報告の 1 行', miss: '開発ログを書いたのに、記録しましたの 1 行がありません', tell: '返事に「📝 Obsidianに開発ログを記録しました(ファイル名)」の 1 行を入れてください' },
17  closing: { name: '締めの言葉で開発ログ', miss: '締めの言葉があったのに、開発ログを書いていません', tell: '今日の開発ログを書き、その日の総括も書き直してください' },
18}
19
20// ── 開発ログの見分け
21
22const CLOSING = /ありがと|お疲れ|おつかれ|一旦ここまで|いったんここまで|今日はここまで/
23
24/** 依頼者の入力に締めの言葉があるか */
25export const isClosing = (text: string) => CLOSING.test(text)
26
27/** 返事に「📝」と「開発ログ」を含む行があるか */
28export const hasLogLine = (answer: string) => answer.split('\n').some(l => l.includes('📝') && l.includes('開発ログ'))
29
30// ── 返事の読み方
31
32/** コードブロック・インラインのコード・URL・パス・HTML のタグを落とした、地の文だけ */
33export function proseOf(answer: string) {
34  return answer
35    .replace(/```[\s\S]*?(?:```|$)/g, '\n')
36    .replace(/`[^`\n]*`/g, ' ')
37    .replace(/\]\([^)]*\)/g, ']')
38    .replace(/<[^>\n]+>/g, ' ')
39    .replace(/\bhttps?:\/\/\S+/g, ' ')
40    .replace(/(?:[A-Za-z]:)?(?:[\\/][^\s\\/]+){2,}[\\/]?/g, ' ')
41}
42
43const JAPANESE = /[\p{Script=Hiragana}\p{Script=Katakana}\p{Script=Han}ー]/gu
44const LATIN = /[A-Za-z]/g
45
46/** 英語の返事か。地の文の英字が 40 字以上あって、日本語の字がその 1 割に届かない時 */
47export function isEnglish(answer: string) {
48  const prose = proseOf(answer)
49  const latin = prose.match(LATIN)?.length ?? 0
50  const jp = prose.match(JAPANESE)?.length ?? 0
51  return latin >= 40 && jp * 10 < latin
52}
53
54const ASKING = /(?:[?？]|ますか|でしょうか|ませんか|しょうか|ですか)[」』)）]*[。.!！]?\s*$/
55
56/**
57 * 文で質問して終わっているか。地の文の最後の 2 行のどれかが問いの形で終わる時。
58 * 引用 (>) と、表の行は見ない
59 */
60export function endsWithQuestion(answer: string) {
61  const lines = proseOf(answer)
62    .split('\n')
63    .map(l => l.trim())
64    .filter(l => l !== '' && !l.startsWith('>') && !l.startsWith('|'))
65  return lines.slice(-2).some(l => ASKING.test(l))
66}
67
68/** 問いの行 (帯とペインに出す) */
69export function questionLine(answer: string) {
70  const lines = proseOf(answer)
71    .split('\n')
72    .map(l => l.trim())
73    .filter(l => l !== '' && !l.startsWith('>') && !l.startsWith('|'))
74  return [...lines.slice(-2)].reverse().find(l => ASKING.test(l)) ?? ''
75}
76
77// ── コミットとメモの見分け (compact-cue と同じ形。mod は別々に入れるので写して持つ)
78
79/** 引用符の中身とヒアドキュメントの本文を Q に置き換える (コミットの文の中の言葉を拾わない) */
80export function unquote(command: string) {
81  return command
82    .replace(/<<-?\s*(['"]?)(\w+)\1[^\n]*\n[\s\S]*?\n\s*\2\s*(?=\n|$)/g, ' Q')
83    .replace(/'[^']*'|"(?:[^"\\]|\\.)*"/g, 'Q')
84}
85
86/** コマンドの区切り (&& ; | など) で分けた 1 つずつ。頭の VAR=値 と & は落とす */
87export function segments(command: string) {
88  return unquote(command)
89    .split(/&&|\|\||[;|\n`{}]|\$\(|\(/)
90    .map(s => s.trim().replace(/^(?:[\w.]+=\S*\s+)*(?:&\s*)?/, ''))
91    .filter(s => s !== '')
92}
93
94const GIT_OPTS = String.raw`(?:\s+(?:-[cC]\s+\S+|--?[\w-]+(?:=\S+)?))*`
95const GIT = String.raw`^(?:\S*[\\/])?git(?:\.exe)?\b`
96
97/** git commit か */
98export const isCommit = (command: string) => segments(command).some(s => new RegExp(`${GIT}${GIT_OPTS}\\s+commit\\b`, 'i').test(s))
99
100/** パスを比べる形にする (区切りを / に、大文字小文字を無視、末尾の / を落とす) */
101const norm = (p: string) => p.replace(/\\/g, '/').replace(/\/+$/, '').toLowerCase()
102
103/** 絶対パスか (C:\ や / で始まる)。C: だけや相対パスは未設定と同じに扱う */
104export const isAbsolute = (p: string) => /^[a-zA-Z]:[\\/]/.test(p) || p.startsWith('/') || p.startsWith('\\\\')
105
106/** path が dir の下か */
107export const isUnder = (path: string, dir: string) => dir !== '' && norm(path).startsWith(`${norm(dir)}/`)
108
109/** シェルのコマンドが dir の下 (tail を足した物) を指しているか (D:\x と /d/x の両方の書き方を見る) */
110export function mentionsDir(command: string, dir: string, tail = '') {
111  if (dir === '') return false
112  const d = `${norm(dir)}/${tail.toLowerCase()}`
113  const msys = d.replace(/^([a-z]):/, (_, x: string) => `/${x}`)
114  const c = command.replace(/\\/g, '/').toLowerCase()
115  return c.includes(d) || c.includes(msys)
116}
117
118/** 今日の開発ログのファイル名 (JST の YYYY-MM-DD.md) */
119export const logName = (now: number) => `${jstDay(now)}.md`
120
121/** path が dir の直下の、今日の開発ログか */
122export const isTodayLog = (path: string, dir: string, now: number) => dir !== '' && norm(path) === `${norm(dir)}/${logName(now)}`
123
124// ── 帯とペイン
125
126/** 帯の 1 行 */
127export const bandText = (misses: readonly RuleMiss[]) => `約束ごと: ${misses.map(m => RULE[m.rule].miss).join(' ・ ')}`
128
129/** 「Claude に伝える」で入力欄に入れる文 */
130export function remindText(misses: readonly RuleMiss[]) {
131  const lines = misses.map(m => `- ${RULE[m.rule].name}: ${RULE[m.rule].miss}${m.detail ? `(${m.detail})` : ''}${RULE[m.rule].tell ? `。${RULE[m.rule].tell}` : ''}`)
132  return `さっきの返事は約束ごとから外れていました。\n${lines.join('\n')}\n約束に沿って直してください。`
133}
134
135const clock = (ms: number) => {
136  const d = new Date(ms)
137  return [d.getHours(), d.getMinutes()].map(n => String(n).padStart(2, '0')).join(':')
138}
139
140const KIND_COLOR = (k: RuleKind) => ({ english: C.blue, question: C.yellow, memo: C.green, log: C.purple, logLine: C.orange, closing: C.red })[k]
141const KIND_TERM = (k: RuleKind) => ({ english: 'suggestion', question: 'warning', memo: 'success', log: 'success', logLine: 'warning', closing: 'warning' })[k]
142
143export type PaneInput = {
144  misses: RuleMiss[]
145  counts: Record<RuleKind, number>
146  history: RuleEvent[]
147  /** コミットの後でメモを待っているか */
148  isMemoPending: boolean
149  /** コミットの後で今日の開発ログを待っているか */
150  isLogPending: boolean
151  /** 見ている約束 */
152  watching: RuleKind[]
153}
154
155const statusWord = (i: PaneInput) => (i.misses.length === 0 ? '前の返事は約束どおりでした' : `前の返事で ${i.misses.length} つ外れました`)
156
157/** 待っている物の 1 行。無ければ空 */
158const waitWord = (i: PaneInput) =>
159  i.isMemoPending && i.isLogPending
160    ? 'コミットの後、引き継ぎメモと開発ログを待っています'
161    : i.isMemoPending
162      ? 'コミットの後、引き継ぎメモを待っています'
163      : i.isLogPending
164        ? 'コミットの後、開発ログを待っています'
165        : ''
166
167/** ペインの SVG 1 枚 */
168export function paneSvg(i: PaneInput) {
169  const accent = i.misses.length === 0 ? C.green : C.yellow
170  let s = panel(8, 8, 364, 56)
171  s += `<text x="20" y="34" font-size="15" font-weight="bold" fill="${accent}">${esc(statusWord(i))}</text>`
172  s += `<text x="20" y="52" font-size="12" fill="${C.dim}">${esc(waitWord(i) || 'このセッションで外れた数')}</text>`
173  // 約束ごとの数の棒
174  const max = Math.max(1, ...KINDS.map(k => i.counts[k]))
175  const y0 = 72
176  s += panel(8, y0, 364, KINDS.length * 34 + 16)
177  KINDS.forEach((k, n) => {
178    const y = y0 + 14 + n * 34
179    const isOn = i.watching.includes(k)
180    s += `<text x="20" y="${y + 12}" font-size="12" fill="${isOn ? C.text : C.dim}">${esc(RULE[k].name)}${isOn ? '' : '(見ていない)'}</text>`
181    s += `<text x="360" y="${y + 12}" font-size="12" font-weight="bold" text-anchor="end" fill="${C.text}">${i.counts[k]} 回</text>`
182    s += `<rect x="20" y="${y + 18}" width="340" height="6" rx="3" fill="${C.line}"/>`
183    if (i.counts[k] > 0) s += growBar(20, y + 18, Math.max(6, (340 * i.counts[k]) / max), 6, KIND_COLOR(k), n * 0.08)
184  })
185  // 最近の記録
186  const rows = i.history.slice(-6).reverse()
187  const y1 = y0 + KINDS.length * 34 + 24
188  const h = Math.max(1, rows.length) * 36 + 36
189  s += panel(8, y1, 364, h)
190  s += `<text x="20" y="${y1 + 22}" font-size="13" font-weight="bold" fill="${C.text}">最近外れたもの</text>`
191  if (rows.length === 0) s += `<text x="20" y="${y1 + 50}" font-size="12" fill="${C.dim}">まだありません</text>`
192  rows.forEach((r, n) => {
193    const y = y1 + 36 + n * 36
194    s += `<rect x="20" y="${y}" width="4" height="28" rx="2" fill="${KIND_COLOR(r.rule)}"/>`
195    s += `<text x="32" y="${y + 12}" font-size="12" font-weight="bold" fill="${C.text}">${esc(short(RULE[r.rule].miss, 22))}</text>`
196    s += `<text x="360" y="${y + 12}" font-size="11" text-anchor="end" fill="${C.dim}">${clock(r.at)}</text>`
197    if (r.detail) s += `<text x="32" y="${y + 26}" font-size="11" fill="${C.dim}">${esc(short(r.detail, 32))}</text>`
198  })
199  const total = KINDS.reduce((a, k) => a + i.counts[k], 0)
200  return frame(HEADER_H + y1 + h + 8, header('約束ごとの見張り', `外れ ${total} 回`, accent) + `<g transform="translate(0 ${HEADER_H})">${s}</g>`)
201}
202
203export type Line = { text: string; color?: string; isDim?: boolean; isBold?: boolean }
204
205/** Svg の alt と terminal で使う文の行 */
206export function paneLines(i: PaneInput): Line[] {
207  const lines: Line[] = [{ text: statusWord(i), isBold: true, color: i.misses.length === 0 ? 'success' : 'warning' }]
208  for (const m of i.misses) lines.push({ text: `・${RULE[m.rule].miss}${m.detail ? `(${m.detail})` : ''}`, color: 'warning' })
209  if (waitWord(i) !== '') lines.push({ text: waitWord(i), isDim: true })
210  for (const k of KINDS) lines.push({ text: `${RULE[k].name}${i.watching.includes(k) ? '' : '(見ていない)'}: ${i.counts[k]} 回`, isDim: !i.watching.includes(k) })
211  if (i.history.length > 0) lines.push({ text: '最近外れたもの', isBold: true })
212  for (const r of i.history.slice(-6).reverse()) lines.push({ text: `${clock(r.at)} ${RULE[r.rule].miss}${r.detail ? ` ─ ${short(r.detail, 40)}` : ''}`, color: KIND_TERM(r.rule) })
213  return lines
214}
215

1// 全 mod で共通の見た目(色・見出し・動き)と小物。
2// 正本は shared/style.ts。各 mod の hooks/style.ts はその写しなので、直すのは正本だけにして
3// `node tools/copy_shared.mts` で写す(`--check` で写しのずれを見つける)。
4import type { EngineInterface, On } from 'claude-code'
5
6export type Palette = {
7  bg: string
8  face: string
9  line: string
10  text: string
11  dim: string
12  weak: string
13  blue: string
14  green: string
15  yellow: string
16  red: string
17  purple: string
18  orange: string
19}
20
21/** GitHub Dark 系(docs/mod-guide.md の 7 節) */
22export const DARK: Palette = {
23  bg: '#0d1117',
24  face: '#161b22',
25  line: '#30363d',
26  text: '#c9d1d9',
27  dim: '#8b949e',
28  weak: '#8b949e',
29  blue: '#58a6ff',
30  green: '#3fb950',
31  yellow: '#d29922',
32  red: '#f85149',
33  purple: '#bc8cff',
34  orange: '#f78166',
35}
36
37/** GitHub Light 系 */
38export const LIGHT: Palette = {
39  bg: '#ffffff',
40  face: '#f6f8fa',
41  line: '#d0d7de',
42  text: '#1f2328',
43  dim: '#656d76',
44  weak: '#656d76',
45  blue: '#0969da',
46  green: '#1a7f37',
47  yellow: '#9a6700',
48  red: '#cf222e',
49  purple: '#8250df',
50  orange: '#bc4c00',
51}
52
53// ponytail: 今の色はモジュールの変数 1 個(この mod の中だけ)。SVG を作る関数は C.bg などを呼ぶたびに読むので、
54// 引数を増やさずにテーマが変わる。描く途中で切り替わることは無い(JS は 1 本で走る)
55/** 今の色。setTheme で中身が入れ替わる(同じ物を指し続けるので、import した C のままでよい) */
56export const C: Palette = { ...DARK }
57let isLightNow = false
58
59export const isLight = () => isLightNow
60
61/** /config の theme の値が明るい系か('light'・'light-daltonized'・'light-ansi' など) */
62export const isLightTheme = (value: unknown) => typeof value === 'string' && value.startsWith('light')
63
64export function setTheme(light: boolean) {
65  isLightNow = light
66  Object.assign(C, light ? LIGHT : DARK)
67}
68
69/**
70 * 今の /config の theme を読んで色を合わせる。mod 自身の session.start の中で呼ぶ
71 * (同じイベントに matcher 無しのフックを 2 つ置くと読み込みを拒まれるので、ここでは on しない)。
72 * VS Code の配色は mod から読めないので、Claude Code の theme が light 系の時だけ明るくなる
73 */
74export async function readTheme($: EngineInterface) {
75  const rows = await $.config.list().catch(() => [])
76  setTheme(isLightTheme(rows.find(r => r.key === 'theme')?.value))
77}
78
79/** /config で theme が変わったら色を替えて描き直す。register の中で 1 回呼ぶ */
80export function followTheme(on: On) {
81  on('config.set', { key: 'theme' }, async ($, e, next) => {
82    const r = await next(e)
83    if (r.deny === undefined) {
84      setTheme(isLightTheme(r.value))
85      $.ui.invalidate('ui.render')
86    }
87    return r
88  })
89}
90
91// ---- 小物 ----
92
93/** 外から来る文字列の制御文字を落とす。エンジンは制御文字を含む Text の子や alt を拒み、ペインが閉じる */
94export const clean = (s: string) => s.replace(/[\t\n\r]+/g, ' ').replace(/[\x00-\x1f\x7f-\x9f]/g, '').trim()
95
96/** SVG の文字に入れる前のエスケープ(制御文字も落とす) */
97export const esc = (s: string) =>
98  clean(s).replace(/&/g, '&amp;').replace(/</g, '&lt;').replace(/>/g, '&gt;').replace(/"/g, '&quot;')
99
100// ---- 時間帯と季節 (日本時間 JST = UTC+9 固定。動いている環境のタイムゾーンには頼らない) ----
101
102export type DayPart = '朝' | '昼' | '夕' | '夜'
103export type Season = '春' | '夏' | '秋' | '冬'
104
105const jstDate = (now: number) => new Date(now + 9 * 3_600_000)
106
107/** 時間帯。朝 5-10 時 / 昼 10-16 時 / 夕 16-19 時 / 夜 19-5 時 */
108export const dayPart = (now: number): DayPart => {
109  const h = jstDate(now).getUTCHours()
110  return h >= 5 && h < 10 ? '朝' : h >= 10 && h < 16 ? '昼' : h >= 16 && h < 19 ? '夕' : '夜'
111}
112
113/** 季節。春 3-5 月 / 夏 6-8 月 / 秋 9-11 月 / 冬 12-2 月 */
114export const season = (now: number): Season => {
115  const m = jstDate(now).getUTCMonth() + 1
116  return m >= 3 && m <= 5 ? '春' : m >= 6 && m <= 8 ? '夏' : m >= 9 && m <= 11 ? '秋' : '冬'
117}
118
119/** n 文字を超えたら … で切る */
120export const short = (s: string, n: number) => (s.length > n ? `${s.slice(0, Math.max(0, n - 1))}…` : s)
121
122// ---- 記録を守る(docs/mod-guide.md の 9 節) ----
123
124/** JST の YYYY-MM-DD */
125export const jstDay = (now: number) => jstDate(now).toISOString().slice(0, 10)
126
127export type Backup = { day: string; value: unknown }
128
129// ponytail: $.fs に消す手が無いので、曜日ごとの 7 つの枠を上書きして 7 日分だけ残す。もっと残すなら枠を日付にして process で消す
130const backupPath = (dir: string, plugin: string, key: string, wd: number) => `${dir.replace(/[\\/]+$/, '')}/${plugin}/${key}-${wd}.json`
131
132/**
133 * $.store の key の値を、その日はじめて呼ばれた時だけ dir に控える(曜日ごとの枠で 7 日分)。
134 * dir が空なら何もしない(公開の既定は空。入れた人が backupDir を設定する)。書いたら true
135 */
136export async function backupDaily($: EngineInterface, dir: string, key: string, value: unknown, now: number): Promise<boolean> {
137  if (!dir.trim() || value === undefined) return false
138  const day = jstDay(now)
139  const path = backupPath(dir, $.plugin.name, key, jstDate(now).getUTCDay())
140  // 壊れた枠(途中まで・null)は無いのと同じに扱って上書きする
141  const old = await $.fs.read(path).then(t => parseBackup(t)?.day ?? '', () => '')
142  if (old === day) return false
143  await $.fs.write(path, JSON.stringify({ day, value } satisfies Backup))
144  return true
145}
146
147/** 控えの 1 枠を読む。壊れていれば undefined */
148export function parseBackup(text: string): Backup | undefined {
149  try {
150    const b = JSON.parse(text) as Partial<Backup> | null
151    return b && typeof b.day === 'string' && /^\d{4}-\d{2}-\d{2}$/.test(b.day) && b.value !== undefined ? (b as Backup) : undefined
152  } catch {
153    return undefined
154  }
155}
156
157/** 控えの一覧。新しい日から順。読めない枠・壊れた枠は飛ばす */
158export async function listBackups($: EngineInterface, dir: string, key: string): Promise<Backup[]> {
159  if (!dir.trim()) return []
160  const all = await Promise.all(
161    [0, 1, 2, 3, 4, 5, 6].map(wd =>
162      $.fs.read(backupPath(dir, $.plugin.name, key, wd)).then(parseBackup, () => undefined),
163    ),
164  )
165  return all.filter((b): b is Backup => b !== undefined).sort((a, b) => b.day.localeCompare(a.day))
166}
167
168let loadedPrint: string | undefined
169let staleAt = 0
170let isStaleNow = false
171let toldStale = false
172
173const normPath = (p: string) => p.replace(/[\\/]+/g, '/').replace(/\/$/, '').toLowerCase()
174
175/** FNV-1a 32bit。中身が変わったかを見るだけ */
176function fnv(s: string) {
177  let h = 0x811c9dc5
178  for (let i = 0; i < s.length; i++) h = Math.imul(h ^ s.charCodeAt(i), 0x01000193)
179  return (h >>> 0).toString(16)
180}
181
182/**
183 * 今ディスクにある、この mod の指紋。plugin.json と hooks の .ts / .tsx の中身から作る
184 * (版の数字を上げずに中身だけ変えた時も変わる)。plugin.json が読めなければ undefined
185 */
186async function diskPrint($: EngineInterface): Promise<string | undefined> {
187  const root = $.plugin.root
188  let manifest: string | undefined
189  for (const p of [`${root}/.claude-plugin/plugin.json`, `${root}/plugin.json`]) {
190    manifest = await $.fs.read(p).then(t => t, () => undefined)
191    if (manifest !== undefined) break
192  }
193  if (manifest === undefined) return undefined
194  const names = await $.fs.list(`${root}/hooks`).then(
195    es => es.filter(e => e.kind === 'file' && /\.tsx?$/.test(e.name)).map(e => e.name).sort(),
196    () => [] as string[],
197  )
198  const parts = await Promise.all(names.map(n => $.fs.read(`${root}/hooks/${n}`).then(t => `${n}\n${t}`, () => n)))
199  return fnv([manifest, ...parts].join('\0'))
200}
201
202/**
203 * マーケットプレイスから入れた形(<plugins>/cache/<market>/<name>/<版>)なら、installed_plugins.json に
204 * 今入っている場所が自分と違うか。違えば新しい版が入っている。分からなければ false
205 */
206async function replacedInCache($: EngineInterface): Promise<boolean> {
207  const root = normPath($.plugin.root)
208  const at = root.lastIndexOf('/plugins/cache/')
209  if (at < 0) return false
210  const raw = await $.fs.read(`${$.plugin.root.slice(0, at + '/plugins'.length)}/installed_plugins.json`).then(t => t, () => '')
211  try {
212    const plugins = (JSON.parse(raw) as { plugins?: Record<string, { installPath?: unknown }[]> }).plugins ?? {}
213    const mine = Object.entries(plugins)
214      .filter(([k]) => k.startsWith(`${$.plugin.name}@`))
215      .flatMap(([, v]) => (Array.isArray(v) ? v : []))
216      .map(e => (typeof e.installPath === 'string' ? normPath(e.installPath) : ''))
217    return mine.length > 0 && !mine.includes(root)
218  } catch {
219    return false
220  }
221}
222
223/** 読み込んだ時の指紋を覚える。mod の session.start で 1 回呼ぶ */
224export async function rememberVersion($: EngineInterface) {
225  loadedPrint ??= await diskPrint($)
226}
227
228/**
229 * 新しい版が入ったのに、このセッションはまだ古い版で動いているか。
230 * フォルダから読ませている時は中身の指紋が読み込んだ時と違えば、マーケットプレイスから入れた時は
231 * 入っている場所が自分でなくなれば true。読み直すのは 60 秒に 1 回まで。分からない時は false
232 */
233export async function isStale($: EngineInterface, now: number): Promise<boolean> {
234  if (isStaleNow || now - staleAt < 60_000) return isStaleNow
235  staleAt = now
236  if (await replacedInCache($)) return (isStaleNow = true)
237  if (loadedPrint === undefined) return false
238  const p = await diskPrint($)
239  isStaleNow = p !== undefined && p !== loadedPrint
240  return isStaleNow
241}
242
243/**
244 * $.store に書いてよいか。古い版のままなら書かず、1 回だけトーストで開き直しを頼む
245 * (古い版は新しい版の欄を知らないので、書くと消してしまう)
246 */
247export async function mayWrite($: EngineInterface, now: number): Promise<boolean> {
248  if (!(await isStale($, now))) return true
249  if (!toldStale) {
250    toldStale = true
251    $.ui.toast(`${$.plugin.name}: 新しい版が入りました。VS Code を開き直すまで記録は書きません`)
252  }
253  return false
254}
255
256// ---- SVG の部品 ----
257
258export const W = 380
259export const HEADER_H = 44
260
261/** SVG 全体の枠。地を塗って body を入れる。幅は W にそろえる */
262export const frame = (h: number, body: string, w = W) =>
263  `<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 ${w} ${h}" font-family="sans-serif">` +
264  `<rect width="${w}" height="${h}" rx="10" fill="${C.bg}"/>${body}</svg>`
265
266/** 面(カード)。角丸 8、線 1 */
267export const panel = (x: number, y: number, w: number, h: number, fill = C.face) =>
268  `<rect x="${x}" y="${y}" width="${w}" height="${h}" rx="8" fill="${fill}" stroke="${C.line}"/>`
269
270/**
271 * 共通の見出し帯(高さ HEADER_H)。左に色の縦線、左に題、右に添え書き。
272 * 下の細い線が左から伸びる
273 */
274export function header(title: string, sub = '', accent = C.blue, y = 0, w = W) {
275  const pad = 14
276  return [
277    `<rect x="0" y="${y}" width="${w}" height="${HEADER_H}" rx="10" fill="${C.face}"/>`,
278    `<rect x="0" y="${y + 8}" width="4" height="${HEADER_H - 16}" rx="2" fill="${accent}"/>`,
279    `<text x="${pad}" y="${y + 28}" font-size="16" font-weight="bold" fill="${C.text}">${esc(title)}</text>`,
280    sub === '' ? '' : `<text x="${w - pad}" y="${y + 28}" font-size="12" fill="${C.dim}" text-anchor="end">${esc(sub)}</text>`,
281    growBar(pad, y + HEADER_H - 3, w - pad * 2, 2, accent, 0, 0.35),
282  ].join('')
283}
284
285/** 横に伸びる棒。幅 0 から w まで伸びて止まる(shots.mts は終わりの値で撮る) */
286export const growBar = (x: number, y: number, w: number, h: number, fill: string, delay = 0, opacity = 1) =>
287  `<rect x="${x}" y="${y}" width="${Math.max(0, w)}" height="${h}" rx="${Math.min(3, h / 2)}" fill="${fill}"${opacity === 1 ? '' : ` opacity="${opacity}"`}>` +
288  `<animate attributeName="width" from="0" to="${Math.max(0, w)}" begin="${delay}s" dur="0.6s" fill="freeze"/></rect>`
289
290/** 下から伸びる縦の棒(下端 bottom・高さ h) */
291export const growColumn = (x: number, bottom: number, w: number, h: number, fill: string, delay = 0) =>
292  `<rect x="${x}" y="${bottom - h}" width="${w}" height="${Math.max(0, h)}" rx="${Math.min(3, w / 2)}" fill="${fill}">` +
293  `<animate attributeName="y" from="${bottom}" to="${bottom - h}" begin="${delay}s" dur="0.6s" fill="freeze"/>` +
294  `<animate attributeName="height" from="0" to="${Math.max(0, h)}" begin="${delay}s" dur="0.6s" fill="freeze"/></rect>`
295
296/** ふわっと出る。中身は SVG の断片 */
297export const fadeIn = (body: string, delay = 0) =>
298  `<g opacity="1"><animate attributeName="opacity" from="0" to="1" begin="${delay}s" dur="0.4s" fill="freeze"/>${body}</g>`
299
300/**
301 * 0 から value まで数字が増えて止まる。コマ送りの文字を重ね、最後のコマだけが残る。
302 * attrs は <text> に付ける属性(x・y・font-size・fill など)。format で桁区切りや単位を付ける
303 */
304export function countUp(value: number, attrs: string, format: (n: number) => string = n => String(n), delay = 0) {
305  const STEPS = 8
306  const d = 0.08
307  const last = `<text ${attrs} opacity="0">${esc(format(value))}<animate attributeName="opacity" from="0" to="1" begin="${(delay + (STEPS - 1) * d).toFixed(2)}s" dur="0.01s" fill="freeze"/></text>`
308  if (!Number.isFinite(value) || value === 0) return `<text ${attrs}>${esc(format(value))}</text>`
309  const frames = Array.from({ length: STEPS - 1 }, (_, k) => {
310    const n = Number.isInteger(value) ? Math.round((value * k) / (STEPS - 1)) : (value * k) / (STEPS - 1)
311    return `<text ${attrs} opacity="0">${esc(format(n))}<animate attributeName="opacity" values="1;1" begin="${(delay + k * d).toFixed(2)}s" dur="${d}s"/></text>`
312  })
313  return frames.join('') + last
314}
315

1/**
2 * 見ている約束ごと。english は日本語で答える、question は確認を選択肢で聞く、memo は区切りで引き継ぎメモを書く、
3 * log はコミットの後に今日の開発ログを書く、logLine は開発ログを書いたら返事に「📝 … 開発ログ …」の 1 行を入れる、
4 * closing は締めの言葉の時に開発ログを書く
5 */
6export type RuleKind = 'english' | 'question' | 'memo' | 'log' | 'logLine' | 'closing'
7
8/** 前の返事で外れた約束 1 つ */
9export type RuleMiss = {
10  rule: RuleKind
11  /** 問いの行など。無ければ空 */
12  detail: string
13}
14
15/** 記録の 1 件。古い順、最大 20 */
16export type RuleEvent = RuleMiss & { at: number }
17
18/** コミットの後でメモを待っている間の印。turns はそこから終わったメインのターンの数 */
19export type MemoPending = { since: number; turns: number }
20
21/** 開発ログの見張り */
22export type LogWatch = {
23  /** コミットの後で今日の開発ログを待っている間の印 */
24  pending: MemoPending | null
25  /** このメインのターンに今日の開発ログを書いたか (ターンの頭で false に戻す) */
26  isWritten: boolean
27  /** このメインのターンの依頼者の入力に締めの言葉があったか */
28  isClosing: boolean
29}
30
31declare module 'claude-code' {
32  interface PluginState {
33    'rule-watch': {
34      /** 前のメインの返事で外れた約束 (帯に出す) */
35      misses: RuleMiss[]
36      /** このセッションで外れた数 */
37      counts: Record<RuleKind, number>
38      history: RuleEvent[]
39      /** このターンに AskUserQuestion を呼んだ数 (メインのターンの頭で 0 に戻す) */
40      asks: number
41      memoPending: MemoPending | null
42      log: LogWatch
43    }
44  }
45}
46