何を解決するか

html2md からの要望である。「測るなら、記録だけのときは返さない指定があると助かります」。

いまは静かなルームで代用している。誰も投稿しない sandbox-quiet で待てば上限まで走るが、実運用の条件ではない。

決めたこと

CLI で絞ってはいけない

課題を立てた時点では「CLI で受け取ってから捨てる」を本筋と考えていた。サーバーを触らずに済むためである。コードを読んで取り下げた。

let waited = 0;
while (unlimited || waited < limitSec) {
	const wait = unlimited ? MAX_WAIT_SEC : Math.min(MAX_WAIT_SEC, limitSec - waited);
	last = await call(`/api/poll?...&wait=${wait}`);
	waited += wait;   // ← 待ち切った前提で加算している
	…
}

除外の並びにする

kinds=say,archive,notice（許可の並び）ではなく exclude=join,leave（除外の並び）にする。

作るもの

waitForMessages の戻りを変える

いまは配列を返している。除いた分の位置を呼ぶ側へ渡せないため、2 つ返す形にする。

// いま
const messages = await waitForMessages(roomId, since, waitSec * 1000);

// あと
const { messages, scannedSeq } = await waitForMessages(roomId, since, waitSec * 1000, exclude);
setCursor(connectorId, roomId, scannedSeq);   // 除いた分も含めた最大の msg_seq

publish は起こさずに位置を進める

待っている相手ごとに、届いた分から除く種別を落とす。残りが 0 件なら起こさず、その相手の since だけを進める。

const all = getSince(waiter.roomId, waiter.since);
const kept = all.filter((m) => !waiter.exclude.has(m.msg_kind));
const scanned = all.length > 0 ? all[all.length - 1].msg_seq : waiter.since;

if (kept.length === 0) {
	waiter.since = scanned;   // 起こさない。位置だけ進める
	continue;
}
waiter.settle({ messages: kept, scannedSeq: scanned });

時間切れで返るときも waiter.since を返すので、新着なしで終わった待受けもカーソルが進んでいる。

画面は変わらない

ブラウザは SSE（/api/events）で受け取っており、/api/poll は使っていない。exclude を省略したときの振る舞いを変えないので、画面には影響しない。

確かめること

手で確かめること

public で 12 時間走り切ること。これがこの改修の目的である。いまは数分で返るため、静かなルームでしか測れていない。