x-post

1import { atom, read, update } from 'claude-code'
2import type { EngineInterface, Register } from 'claude-code'
3
4import type { Mention, Mentions } from '../types'
5
6const PANE = 'x-post'
7// 横に並ぶときは columns、プロンプトの上に出るときは rows が効く。手で広げた大きさのほうが優先される
8const PANE_OPEN = { id: PANE, title: 'X', columns: 100, rows: 40 }
9const TAGS_KEY = 'hashtags'
10const GATE_KEY = 'gated'
11const ACCOUNT_KEY = 'account'
12const MAX_TAGS = 10
13const MAX_TAG_LENGTH = 50
14const MAX_WEIGHT = 280
15
16const isThinking = atom({ plugin: 'x-post', key: 'isThinking' } as const, false)
17const isGated = atom({ plugin: 'x-post', key: 'isGated' } as const, false)
18const tags = atom({ plugin: 'x-post', key: 'tags' } as const, [])
19const account = atom({ plugin: 'x-post', key: 'account' } as const, '')
20const mentions = atom({ plugin: 'x-post', key: 'mentions' } as const, { status: 'idle', items: [] })
21const draft = atom({ plugin: 'x-post', key: 'draft' } as const, '')
22const replyTo = atom({ plugin: 'x-post', key: 'replyTo' } as const, '')
23const lastResult = atom({ plugin: 'x-post', key: 'lastResult' } as const, '')
24const tagDraft = atom({ plugin: 'x-post', key: 'tagDraft' } as const, '')
25const tagNote = atom({ plugin: 'x-post', key: 'tagNote' } as const, '')
26
27const USAGE_TAG = [
28  '/x-tag            登録済みの一覧',
29  '/x-tag add 朝活 AI  登録（# はあってもなくてもよい）',
30  '/x-tag rm 朝活      削除',
31  '/x-tag clear       全部削除',
32].join('\n')
33
34// "#朝活" "＃朝活" "朝活" を同じ "朝活" にそろえる。空白や記号だけのものは捨てる
35export const normalizeTag = (raw: string): string | undefined => {
36  const tag = raw.trim().replace(/^[#＃]+/, '')
37  if (!tag || /[\s#＃]/.test(tag) || tag.length > MAX_TAG_LENGTH) return undefined
38
39  return tag
40}
41
42export const normalizeAccount = (raw: string): string | undefined => {
43  const handle = raw.trim().replace(/^[@＠]/, '')
44
45  return /^[A-Za-z0-9_]{1,15}$/.test(handle) ? handle : undefined
46}
47
48// 本文にすでに書いてあるタグは二重に足さない
49export const composeText = (body: string, list: readonly string[]): string => {
50  const missing = list.filter(tag => !body.includes(`#${tag}`) && !body.includes(`＃${tag}`))
51  if (missing.length === 0) return body
52
53  return `${body}\n\n${missing.map(tag => `#${tag}`).join(' ')}`
54}
55
56export const postWeight = (text: string): number => {
57  let weight = 0
58  const rest = text.replace(/https?:\/\/\S+/g, () => {
59    weight += 23
60    return ''
61  })
62  for (const ch of rest) {
63    const c = ch.codePointAt(0) ?? 0
64    const isNarrow =
65      c <= 0x10ff || (c >= 0x2000 && c <= 0x200d) || (c >= 0x2010 && c <= 0x201f) || (c >= 0x2032 && c <= 0x2037)
66    weight += isNarrow ? 1 : 2
67  }
68
69  return weight
70}
71
72export const intentUrl = (text: string, replyTo?: string): string =>
73  `https://x.com/intent/post?${replyTo ? `in_reply_to=${replyTo}&` : ''}text=${encodeURIComponent(text)}`
74
75export const statusId = (url: string): string | undefined =>
76  /^https?:\/\/(?:www\.|mobile\.)?(?:x|twitter)\.com\/[^/]+\/status\/(\d+)/.exec(url.trim())?.[1]
77
78// hermes の返答から、投稿URLで裏付けられた行だけを拾う
79export const parseMentions = (out: string): Mention[] =>
80  out
81    .split(/\r?\n/)
82    .map(line => {
83      const url = /https:\/\/(?:x|twitter)\.com\/\S+?\/status\/\d+/.exec(line)?.[0]
84      if (!url) return undefined
85      const text = line
86        .replace(url, '')
87        .replace(/[【】|｜]/g, ' ')
88        .replace(/^[\s\-*・\d.]+/, '')
89        .replace(/\s+/g, ' ')
90        .trim()
91
92      return { text: text || '(本文なし)', url }
93    })
94    .filter((m): m is Mention => !!m)
95    .slice(0, 20)
96
97const readList = async ($: EngineInterface): Promise<string[]> => {
98  const value = await $.store.get(TAGS_KEY)
99
100  return Array.isArray(value) ? value.filter((v): v is string => typeof v === 'string') : []
101}
102
103const saveTags = async ($: EngineInterface, list: string[]) => {
104  await $.store.set(TAGS_KEY, list)
105  await update($, tags, () => list)
106}
107
108const tagLine = (list: readonly string[]) => list.map(t => `#${t}`).join(' ')
109
110// /x-tag add とペインの欄が共通で使う。返り値は結果の一文
111const addTags = async ($: EngineInterface, words: readonly string[]): Promise<string> => {
112  const added = words.map(normalizeTag).filter((t): t is string => !!t)
113  if (added.length === 0) return `タグにできる文字がありません（空白と # は使えず、${MAX_TAG_LENGTH}文字まで）。`
114  const next = [...new Set([...(await readList($)), ...added])]
115  if (next.length > MAX_TAGS) return `ハッシュタグは ${MAX_TAGS} 個までです。減らしてから足してください。`
116  await saveTags($, next)
117
118  return `登録しました。現在: ${tagLine(next)}`
119}
120
121const removeTags = async ($: EngineInterface, words: readonly string[]): Promise<string> => {
122  const removing = new Set(words.map(normalizeTag).filter((t): t is string => !!t))
123  const next = (await readList($)).filter(t => !removing.has(t))
124  await saveTags($, next)
125
126  return next.length ? `削除しました。現在: ${tagLine(next)}` : '削除しました。登録中のハッシュタグはありません。'
127}
128
129// 推論中だけモードで、いまは投稿させないときの断り文。投稿してよいなら undefined
130const gateRefusal = async ($: EngineInterface): Promise<string | undefined> => {
131  if (!(await read($, isGated))) return undefined
132  if (await read($, isThinking)) return undefined
133
134  return '推論中だけ投稿できるモードです。Claude が考えている間に打ってください（解除は /x-mode off）。'
135}
136
137// URL をいつものブラウザで開くコマンド。Windows、macOS、それ以外(xdg-open)の順に判定する
138const openerFor = async ($: EngineInterface): Promise<string[]> => {
139  try {
140    if ((await $.env.get('OS')) === 'Windows_NT') return ['rundll32', 'url.dll,FileProtocolHandler']
141  } catch {
142    // 環境変数が読めなければ uname で判定する
143  }
144  try {
145    const { stdout } = await $.process.run(['uname', '-s'])
146    if (stdout.trim() === 'Darwin') return ['open']
147  } catch {
148    // uname が無ければ xdg-open に任せる
149  }
150
151  return ['xdg-open']
152}
153
154const openIntent = async ($: EngineInterface, url: string): Promise<boolean> => {
155  // 投稿画面を開くだけで、投稿はしない
156  try {
157    const { exitCode } = await $.process.run([...(await openerFor($)), url])
158
159    return exitCode === 0
160  } catch {
161    return false
162  }
163}
164
165const composeReply = (opened: boolean, text: string, url: string) =>
166  [
167    opened ? 'Xの投稿画面を開きました。内容を確かめて「ポスト」を押してください。' : '下のリンクからXの投稿画面を開いてください。',
168    '',
169    text,
170    '',
171    url,
172  ].join('\n')
173
174type PostOutcome = { isOpened: boolean; message: string; url?: string }
175
176// コマンドとペインの入力欄が共通で使う。replyTo はポストのURL
177const openPost = async ($: EngineInterface, body: string, replyTo?: string): Promise<PostOutcome> => {
178  const refusal = await gateRefusal($)
179  if (refusal) return { isOpened: false, message: refusal }
180  if (!body.trim()) return { isOpened: false, message: '本文が空です。' }
181
182  let id: string | undefined
183  if (replyTo?.trim()) {
184    id = statusId(replyTo)
185    if (!id) return { isOpened: false, message: '返信先がポストのURL（…/status/数字）になっていません。' }
186  }
187
188  const text = composeText(body.trim(), await readList($))
189  const weight = postWeight(text)
190  if (weight > MAX_WEIGHT) {
191    return { isOpened: false, message: `長すぎます（${weight}/${MAX_WEIGHT}。日本語は1文字2と数えます）。` }
192  }
193  const url = intentUrl(text, id)
194  const isOpened = await openIntent($, url)
195
196  return { isOpened, url, message: composeReply(isOpened, text, url) }
197}
198
199const fetchMentions = async ($: EngineInterface) => {
200  const handle = await read($, account)
201  if (!handle) {
202    await update($, mentions, m => ({ ...m, status: 'error' as const, note: '先に /x-account @名前 で自分のアカウントを登録してください。' }))
203    return
204  }
205  await update($, mentions, m => ({ ...m, status: 'loading' as const, note: undefined }))
206
207  const prompt =
208    `Xで『@${handle} 宛てのリプライやメンション（to:${handle} または @${handle} を含む投稿、直近3日）』を検索し、` +
209    'ヒットした投稿を1件1行で【@投稿者ハンドル | 投稿日時 | 本文 | 投稿URL】の形式でリスト化して。' +
210    'あなた自身の要約・一般知識は加えず、実際の検索結果の投稿データだけを出して'
211  try {
212    const { exitCode, stdout, stderr } = await $.process.run(
213      [
214        'hermes',
215        '-z',
216        prompt,
217        '-m',
218        (await $.env.get('X_POST_HERMES_MODEL')) || 'grok-4.3',
219        '--provider',
220        (await $.env.get('X_POST_HERMES_PROVIDER')) || 'xai-oauth',
221      ],
222      { timeoutMs: 240_000 },
223    )
224    const checkedAt = new Date(await $.clock.now()).toLocaleString('ja-JP')
225    if (exitCode !== 0) {
226      await update($, mentions, m => ({ ...m, status: 'error' as const, checkedAt, note: `hermes が失敗しました: ${(stderr || stdout).slice(0, 200)}` }))
227      return
228    }
229    const items = parseMentions(stdout)
230    await update($, mentions, () => ({
231      status: 'done' as const,
232      items,
233      checkedAt,
234      note: items.length ? undefined : '投稿URLつきの結果はありませんでした。',
235    }))
236    if (items.length) $.ui.toast(`Xのメンション ${items.length} 件`)
237  } catch (err) {
238    await update($, mentions, m => ({
239      ...m,
240      status: 'error' as const,
241      note: `メンション検索には hermes（Grok の X 検索）が要ります。README を見てください。（${String(err).slice(0, 120)}）`,
242    }))
243  }
244}
245
246export const register: Register = on => {
247  on('session.start', async ($, e, next) => {
248    const commands = [
249      { name: 'x', description: '本文に登録ハッシュタグを付けてXの投稿画面を開く（投稿ボタンは自分で押す）', argumentHint: '本文' },
250      { name: 'x-reply', description: '指定したポストへの返信画面を開く', argumentHint: 'ポストのURL 本文' },
251      { name: 'x-tag', description: '/x で自動で付けるハッシュタグを登録・削除する', argumentHint: 'add|rm|clear タグ' },
252      { name: 'x-mode', description: '推論中だけ投稿できるモードを切り替える', argumentHint: 'on|off' },
253      { name: 'x-account', description: 'メンションを探す自分のXアカウントを登録する', argumentHint: '@名前' },
254      { name: 'x-pane', description: 'Xのペインを右側に開く' },
255    ]
256    for (const command of commands) {
257      // 推論中にも打てるよう、ターンの終わりを待たずに走らせる
258      await $.command.register({ ...command, immediate: true })
259    }
260
261    const saved = await readList($)
262    await update($, tags, () => saved)
263    const gated = (await $.store.get(GATE_KEY)) === true
264    await update($, isGated, () => gated)
265    const handle = await $.store.get(ACCOUNT_KEY)
266    await update($, account, () => (typeof handle === 'string' ? handle : ''))
267
268    void $.ui.open(PANE_OPEN)
269
270    return next(e)
271  })
272
273  on('turn.start', async ($, e, next) => {
274    await update($, isThinking, () => true)
275
276    return next(e)
277  })
278
279  on('turn.complete', async ($, e, next) => {
280    await update($, isThinking, () => false)
281
282    return next(e)
283  })
284
285  on('command.run', { command: 'x-pane' }, async $ => {
286    const opened = await $.ui.open(PANE_OPEN)
287    if (opened.isPlaced) return { text: 'Xのペインを開きました。' }
288
289    // 開いたが、どの画面にも描かれていないとき
290    return { text: `Xのペインは開きましたが、この画面には表示されていません。理由: ${opened.reason}` }
291  })
292
293  on('command.run', { command: 'x-mode' }, async ($, e) => {
294    const arg = e.args.trim()
295    if (arg !== 'on' && arg !== 'off') {
296      const gated = await read($, isGated)
297      return { text: `推論中だけモード: ${gated ? 'オン' : 'オフ'}（切り替えは /x-mode on か /x-mode off）` }
298    }
299    const gated = arg === 'on'
300    await $.store.set(GATE_KEY, gated)
301    await update($, isGated, () => gated)
302
303    return {
304      text: gated
305        ? '推論中だけ投稿できるモードをオンにしました。Claude が考えている間だけ /x と /x-reply が使えます。'
306        : '推論中だけモードをオフにしました。いつでも投稿画面を開けます。',
307    }
308  })
309
310  on('command.run', { command: 'x-account' }, async ($, e) => {
311    const handle = normalizeAccount(e.args)
312    if (!handle) {
313      const current = await read($, account)
314      return { text: current ? `登録中のアカウント: @${current}` : '使い方: /x-account @名前' }
315    }
316    await $.store.set(ACCOUNT_KEY, handle)
317    await update($, account, () => handle)
318
319    return { text: `@${handle} を登録しました。ペインの「更新」でメンションを探します。` }
320  })
321
322  on('command.run', { command: 'x-tag' }, async ($, e) => {
323    const [sub = '', ...rest] = e.args.trim().split(/\s+/).filter(Boolean)
324    const list = await readList($)
325
326    if (sub === '') {
327      return { text: list.length ? `登録中のハッシュタグ: ${tagLine(list)}` : `登録中のハッシュタグはありません。\n${USAGE_TAG}` }
328    }
329
330    if (sub === 'add') {
331      if (rest.length === 0) return { text: `追加するタグを指定してください。
332${USAGE_TAG}` }
333      return { text: await addTags($, rest) }
334    }
335
336    if (sub === 'rm') return { text: await removeTags($, rest) }
337
338    if (sub === 'clear') {
339      await saveTags($, [])
340
341      return { text: 'ハッシュタグを全部削除しました。' }
342    }
343
344    return { text: USAGE_TAG }
345  })
346
347  on('command.run', { command: 'x' }, async ($, e) => {
348    if (!e.args.trim()) return { text: '使い方: /x 投稿したい本文' }
349
350    return { text: (await openPost($, e.args)).message }
351  })
352
353  on('command.run', { command: 'x-reply' }, async ($, e) => {
354    const [target = '', ...words] = e.args.trim().split(/\s+/)
355    const body = words.join(' ')
356    if (!statusId(target) || !body.trim()) return { text: '使い方: /x-reply https://x.com/名前/status/123… 返信の本文' }
357
358    return { text: (await openPost($, body, target)).message }
359  })
360
361  on('ui.render', { component: 'Pane', requestId: PANE }, async ($, e) => {
362    const table = $.ui.resolve(e)
363    const { Box, Text, Button, Link } = table
364    const Input = 'Input' in table ? table.Input : undefined
365    const gated = await read($, isGated)
366    const thinking = await read($, isThinking)
367    const list = await read($, tags)
368    const handle = await read($, account)
369    const m: Mentions = await read($, mentions)
370    const body = await read($, draft)
371    const target = await read($, replyTo)
372    const result = await read($, lastResult)
373    const tagText = await read($, tagDraft)
374    const tagNoteText = await read($, tagNote)
375    const isBlocked = gated && !thinking
376
377    // 表示幅は30文字前後しか取れないので、どの行も短くする
378    const modeLine = !gated ? 'いつでも投稿できます' : thinking ? '推論中: 投稿できます' : '待機中: 投稿できません'
379
380    const submit = async (value: string) => {
381      const outcome = await openPost($, value, await read($, replyTo))
382      await update($, lastResult, () =>
383        outcome.url ? (outcome.isOpened ? '投稿画面を開きました' : 'ブラウザを開けませんでした') : outcome.message,
384      )
385      if (outcome.url) {
386        await update($, draft, () => '')
387        await update($, replyTo, () => '')
388      }
389    }
390
391    // 投稿欄はペインの下端に寄せる。上はタグとメンション
392    return (
393      <Box flexDirection="column" minHeight={e.props.scroll.bodyRows} justifyContent="space-between">
394        <Box flexDirection="column">
395          <Text bold>ハッシュタグ</Text>
396          {list.length === 0 && <Text dimColor>なし（下の欄で追加）</Text>}
397          {list.length > 0 && (
398            <Box flexDirection="row" flexWrap="wrap" columnGap={1}>
399              {list.map(tag => (
400                <Button key={`tag-${tag}`} plain onPress={async () => {
401                    const note = await removeTags($, [tag])
402                    await update($, tagNote, () => note)
403                  }}
404                >
405                  #{tag} <Text dimColor>×</Text>
406                </Button>
407              ))}
408            </Box>
409          )}
410          {Input && (
411            <Input
412              key="tagAdd"
413              placeholder="タグを足す（空白で複数）"
414              value={tagText}
415              submitLabel="追加"
416              onInput={value => void update($, tagDraft, () => value)}
417              onSubmit={async value => {
418                const note = await addTags($, value.split(/\s+/).filter(Boolean))
419                await update($, tagNote, () => note)
420                if (note.startsWith('登録')) await update($, tagDraft, () => '')
421              }}
422            />
423          )}
424          {tagNoteText && <Text dimColor>{tagNoteText}</Text>}
425          <Text> </Text>
426          <Text bold>メンション</Text>
427          <Text dimColor>{handle ? `@${handle}` : '/x-account @名前 で設定'}</Text>
428          <Box flexDirection="row">
429            <Button
430              key="refresh"
431              label={m.status === 'loading' ? '検索中…' : '更新'}
432              onPress={() => (m.status === 'loading' ? undefined : fetchMentions($))}
433            />
434            {m.checkedAt && <Text dimColor> {m.checkedAt}</Text>}
435          </Box>
436          {m.note && <Text dimColor>{m.note}</Text>}
437          {m.items.map((item, i) => (
438            <Box key={`m${i}`} flexDirection="column">
439              <Text>{item.text}</Text>
440              <Link href={item.url} label="開く" />
441            </Box>
442          ))}
443        </Box>
444        <Box flexDirection="column">
445          <Text> </Text>
446          <Text bold>投稿</Text>
447          <Text color={isBlocked ? 'red' : 'green'}>{modeLine}</Text>
448          <Box flexDirection="row">
449            <Button
450              key="mode"
451              label={gated ? '推論中だけ オン' : '推論中だけ オフ'}
452              onPress={async () => {
453                const nextGated = !(await read($, isGated))
454                await $.store.set(GATE_KEY, nextGated)
455                await update($, isGated, () => nextGated)
456              }}
457            />
458          </Box>
459          {body.trim() && (
460            <Box flexDirection="column">
461              <Text dimColor color={postWeight(composeText(body.trim(), list)) > MAX_WEIGHT ? 'red' : undefined}>
462                プレビュー {postWeight(composeText(body.trim(), list))}/{MAX_WEIGHT}
463              </Text>
464              <Text wrap="wrap">{composeText(body.trim(), list)}</Text>
465            </Box>
466          )}
467          {result && <Text dimColor>{result}</Text>}
468          {Input ? (
469            <Box flexDirection="column">
470              <Text dimColor>返信先（返信のときだけ）</Text>
471              <Input
472                key="replyTo"
473                placeholder="ポストのURL"
474                value={target}
475                submitLabel="決定"
476                onInput={value => void update($, replyTo, () => value)}
477                onSubmit={value => void update($, replyTo, () => value)}
478              />
479              <Text dimColor>本文（Enterで投稿画面へ）</Text>
480              <Input
481                key="body"
482                placeholder={isBlocked ? '考えている間だけ書けます' : 'ここに書く'}
483                value={body}
484                submitLabel="投稿画面へ"
485                onInput={value => void update($, draft, () => value)}
486                onSubmit={value => void submit(value)}
487              />
488            </Box>
489          ) : (
490            <Text dimColor>入力欄なし。/x 本文 で投稿</Text>
491          )}
492        </Box>
493      </Box>
494    )
495  })
496}
497

1export type Mention = { text: string; url: string }
2
3export type Mentions = {
4  status: 'idle' | 'loading' | 'done' | 'error'
5  items: Mention[]
6  checkedAt?: string
7  note?: string
8}
9
10declare module 'claude-code' {
11  interface PluginState {
12    'x-post': {
13      isThinking: boolean
14      isGated: boolean
15      tags: string[]
16      account: string
17      mentions: Mentions
18      draft: string
19      replyTo: string
20      lastResult: string
21      tagDraft: string
22      tagNote: string
23    }
24  }
25}
26