Files
penguin-harness/packages/web/src/features/chat/stream-follow.ts
T
Yaowei Zheng d4faee3a1e Changelog, dev startup, README, AgentHub 0.4.0, model catalog, and landing site (#7)
Branch-length batch covering tooling, the model layer, the Web App and the public
surfaces. Highlights:

- Changelog: a per-release `changelog/<version>/` tree, grouped by the surface each
  change touches, with a root CHANGELOG.md holding one line per release.
- Dev startup: `scripts/dev-prebuild.mjs` serializes the skills+core prebuild behind a
  lock and keeps `pnpm install` current; `pnpm dev` runs server+web together.
- AgentHub 0.3.3 -> 0.4.0: OmniMessage complete payloads carry one opaque `fidelity`
  object in place of item-level `signature`/`phase`, threaded verbatim through Trace,
  replay and resume; malformed classification adapted to the new error types.
- Model layer: a model is always referenced by an explicit `(provider, model_id)` pair.
  The provider is never inferred, guessed or defaulted -- both the catalog inference and
  the unique-match config resolution are gone, and CLI, SDK, server routes and
  run_subagent all require the complete pair. Catalog gains the Qwen Token Plan, Qwen
  Pay-As-You-Go and Fireworks AI gateways, plus an expanded OpenRouter group.
- Web App: catalog preset sync and per-group speed test on the Models page, positional
  slash commands, a markdown renderer, skill-library update reminders, and a vertically
  centred draft page whose upward menus size themselves to the room available.
- Public surfaces: restructured READMEs, the penguin.ooo landing site and blog, refreshed
  benchmark results for both suites, and the demo videos playing on the landing page.

Includes the fixes from a full review of the branch: 23 confirmed findings, among them a
provider-inference bug that could send one vendor's API key to another vendor's endpoint,
and an Escape handler that destroyed the composer's contents unrecoverably.

Verified on the branch head: pnpm test (1127 passing, 7 packages), pnpm typecheck and
pnpm format:check clean, Playwright e2e 14/14.
2026-07-21 17:43:31 +08:00

85 lines
3.4 KiB
TypeScript

/**
* Follow-decision logic for auto-stick-to-bottom in the message stream (pure logic,
* unit-testable; issue #75).
*
* "Exiting follow" and "resuming follow" are two independent judgments:
* - Exit: any user intent to scroll up takes effect immediately — detected from the input event
* itself for wheel-up / touch-drag-down (even if position doesn't change, e.g. already at the
* top), and from a scrollTop regression for scrollbar-drag-up / keyboard. This doesn't rely on
* an "80px from bottom" threshold — otherwise a short scroll area with less than 80px of
* scrollable slack could never exit, and streaming updates would keep fighting the upward
* gesture back and forth.
* - Resume: only resumes once the user brings the viewport back near the bottom (within 80px).
* Programmatic stick-to-bottom only happens while following (idempotent); content shrinking
* (e.g. a group collapsing) that clamps scrollTop downward while still touching the bottom
* (≤1px) doesn't count as scrolling up and doesn't change intent.
* - The first scroll event has no direction to judge from, so it initializes from position
* (≥80px from bottom is treated as being at a historical position, i.e. not following) — this
* doesn't depend on the call-ordering guarantee of "must stick to bottom programmatically right
* after mount."
*/
export interface ScrollMetrics {
scrollTop: number;
scrollHeight: number;
clientHeight: number;
}
export interface StreamFollow {
/** Whether it should currently auto-stick to bottom on streaming updates. */
readonly stick: boolean;
/** wheel: deltaY < 0 is scroll-up intent, exits follow immediately. */
wheel(deltaY: number): void;
touchStart(clientY: number): void;
/** Touch drag: finger moving down = content scrolling up, exits follow. */
touchMove(clientY: number): void;
touchEnd(): void;
/** scroll event (user scrolling and programmatic stick-to-bottom share this path): moving up exits; otherwise nearing the bottom resumes; the first event initializes from position. */
scrolled(m: ScrollMetrics): void;
/** Explicit re-entry (the back-to-bottom button): resumes follow immediately — the caller scrolls to the bottom right after, and the resulting scroll event sees a bottom position, keeping it stuck. */
resume(): void;
}
export function createStreamFollow(): StreamFollow {
let stick = true;
let lastTop: number | null = null;
let touchY: number | null = null;
return {
get stick() {
return stick;
},
wheel(deltaY) {
if (deltaY < 0) stick = false;
},
touchStart(clientY) {
touchY = clientY;
},
touchMove(clientY) {
if (touchY !== null && clientY > touchY) stick = false;
touchY = clientY;
},
touchEnd() {
touchY = null;
},
scrolled(m) {
const dist = m.scrollHeight - m.scrollTop - m.clientHeight;
const prev = lastTop;
lastTop = m.scrollTop;
if (prev === null) {
stick = dist < 80;
return;
}
if (m.scrollTop < prev && dist > 1) {
stick = false;
return;
}
if (dist < 80) stick = true;
},
resume() {
stick = true;
// Forget the last position: the caller jumps to the bottom right after, and that large
// downward scroll must not be judged against a stale historical scrollTop.
lastTop = null;
},
};
}