mirror of
https://gitea.toothfairyai.com/ToothFairyAI/tf_code.git
synced 2026-04-09 02:09:12 +00:00
186 lines
5.5 KiB
TypeScript
186 lines
5.5 KiB
TypeScript
import type { UserMessage } from "@opencode-ai/sdk/v2"
|
|
import { useLocation, useNavigate } from "@solidjs/router"
|
|
import { createEffect, createMemo, onMount } from "solid-js"
|
|
import { messageIdFromHash } from "./message-id-from-hash"
|
|
|
|
export { messageIdFromHash } from "./message-id-from-hash"
|
|
|
|
export const useSessionHashScroll = (input: {
|
|
sessionKey: () => string
|
|
sessionID: () => string | undefined
|
|
messagesReady: () => boolean
|
|
visibleUserMessages: () => UserMessage[]
|
|
turnStart: () => number
|
|
currentMessageId: () => string | undefined
|
|
pendingMessage: () => string | undefined
|
|
setPendingMessage: (value: string | undefined) => void
|
|
setActiveMessage: (message: UserMessage | undefined) => void
|
|
setTurnStart: (value: number) => void
|
|
autoScroll: { pause: () => void; forceScrollToBottom: () => void }
|
|
scroller: () => HTMLDivElement | undefined
|
|
anchor: (id: string) => string
|
|
scheduleScrollState: (el: HTMLDivElement) => void
|
|
consumePendingMessage: (key: string) => string | undefined
|
|
}) => {
|
|
const visibleUserMessages = createMemo(() => input.visibleUserMessages())
|
|
const messageById = createMemo(() => new Map(visibleUserMessages().map((m) => [m.id, m])))
|
|
const messageIndex = createMemo(() => new Map(visibleUserMessages().map((m, i) => [m.id, i])))
|
|
let pendingKey = ""
|
|
|
|
const location = useLocation()
|
|
const navigate = useNavigate()
|
|
|
|
const clearMessageHash = () => {
|
|
if (!location.hash) return
|
|
navigate(location.pathname + location.search, { replace: true })
|
|
}
|
|
|
|
const updateHash = (id: string) => {
|
|
navigate(location.pathname + location.search + `#${input.anchor(id)}`, {
|
|
replace: true,
|
|
})
|
|
}
|
|
|
|
const scrollToElement = (el: HTMLElement, behavior: ScrollBehavior) => {
|
|
const root = input.scroller()
|
|
if (!root) return false
|
|
|
|
const a = el.getBoundingClientRect()
|
|
const b = root.getBoundingClientRect()
|
|
const sticky = root.querySelector("[data-session-title]")
|
|
const inset = sticky instanceof HTMLElement ? sticky.offsetHeight : 0
|
|
const top = Math.max(0, a.top - b.top + root.scrollTop - inset)
|
|
root.scrollTo({ top, behavior })
|
|
return true
|
|
}
|
|
|
|
const scrollToMessage = (message: UserMessage, behavior: ScrollBehavior = "smooth") => {
|
|
console.log({ message, behavior })
|
|
if (input.currentMessageId() !== message.id) input.setActiveMessage(message)
|
|
|
|
const index = messageIndex().get(message.id) ?? -1
|
|
if (index !== -1 && index < input.turnStart()) {
|
|
input.setTurnStart(index)
|
|
|
|
requestAnimationFrame(() => {
|
|
const el = document.getElementById(input.anchor(message.id))
|
|
if (!el) {
|
|
requestAnimationFrame(() => {
|
|
const next = document.getElementById(input.anchor(message.id))
|
|
if (!next) return
|
|
scrollToElement(next, behavior)
|
|
})
|
|
return
|
|
}
|
|
scrollToElement(el, behavior)
|
|
})
|
|
|
|
updateHash(message.id)
|
|
return
|
|
}
|
|
|
|
const el = document.getElementById(input.anchor(message.id))
|
|
if (!el) {
|
|
updateHash(message.id)
|
|
requestAnimationFrame(() => {
|
|
const next = document.getElementById(input.anchor(message.id))
|
|
if (!next) return
|
|
if (!scrollToElement(next, behavior)) return
|
|
})
|
|
return
|
|
}
|
|
if (scrollToElement(el, behavior)) {
|
|
updateHash(message.id)
|
|
return
|
|
}
|
|
|
|
requestAnimationFrame(() => {
|
|
const next = document.getElementById(input.anchor(message.id))
|
|
if (!next) return
|
|
if (!scrollToElement(next, behavior)) return
|
|
})
|
|
updateHash(message.id)
|
|
}
|
|
|
|
const applyHash = (behavior: ScrollBehavior) => {
|
|
const hash = location.hash.slice(1)
|
|
if (!hash) {
|
|
input.autoScroll.forceScrollToBottom()
|
|
const el = input.scroller()
|
|
if (el) input.scheduleScrollState(el)
|
|
return
|
|
}
|
|
|
|
const messageId = messageIdFromHash(hash)
|
|
if (messageId) {
|
|
input.autoScroll.pause()
|
|
const msg = messageById().get(messageId)
|
|
if (msg) {
|
|
scrollToMessage(msg, behavior)
|
|
return
|
|
}
|
|
return
|
|
}
|
|
|
|
const target = document.getElementById(hash)
|
|
if (target) {
|
|
input.autoScroll.pause()
|
|
scrollToElement(target, behavior)
|
|
return
|
|
}
|
|
|
|
input.autoScroll.forceScrollToBottom()
|
|
const el = input.scroller()
|
|
if (el) input.scheduleScrollState(el)
|
|
}
|
|
|
|
createEffect(() => {
|
|
location.hash
|
|
if (!input.sessionID() || !input.messagesReady()) return
|
|
requestAnimationFrame(() => applyHash("auto"))
|
|
})
|
|
|
|
createEffect(() => {
|
|
if (!input.sessionID() || !input.messagesReady()) return
|
|
|
|
visibleUserMessages()
|
|
input.turnStart()
|
|
|
|
let targetId = input.pendingMessage()
|
|
if (!targetId) {
|
|
const key = input.sessionKey()
|
|
if (pendingKey !== key) {
|
|
pendingKey = key
|
|
const next = input.consumePendingMessage(key)
|
|
if (next) {
|
|
input.setPendingMessage(next)
|
|
targetId = next
|
|
}
|
|
}
|
|
}
|
|
|
|
if (!targetId) targetId = messageIdFromHash(location.hash)
|
|
if (!targetId) return
|
|
if (input.currentMessageId() === targetId) return
|
|
|
|
const msg = messageById().get(targetId)
|
|
if (!msg) return
|
|
|
|
if (input.pendingMessage() === targetId) input.setPendingMessage(undefined)
|
|
input.autoScroll.pause()
|
|
requestAnimationFrame(() => scrollToMessage(msg, "auto"))
|
|
})
|
|
|
|
onMount(() => {
|
|
if (typeof window !== "undefined" && "scrollRestoration" in window.history) {
|
|
window.history.scrollRestoration = "manual"
|
|
}
|
|
})
|
|
|
|
return {
|
|
clearMessageHash,
|
|
scrollToMessage,
|
|
applyHash,
|
|
}
|
|
}
|