Skip to content

fix: normalize streamed Markdown text #30

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
tiye merged 3 commits into from
Aug 23, 2026
Merged

fix: normalize streamed Markdown text #30

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
e07e6a4
fix: normalize streamed markdown text
tiye Aug 23, 2026
311be5d
fix: type stream text boundary
tiye Aug 23, 2026
8c18d63
chore: use respo-markdown 0.4.24
tiye Aug 23, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
31 changes: 23 additions & 8 deletions calcit.cirru
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -123,7 +123,7 @@
if (option:none? content-opt)
do (println |content-is-nil) (recur xss)
let
content $ option:unwrap-or content-opt |
content $ stream-text (option:unwrap-or content-opt |)
do (swap! *text str content)
d! (:: :states-merge cursor state)
{} (:answer @*text) (:loading? false) (:done? false)
Expand Down Expand Up @@ -316,7 +316,7 @@
prompt-feedback $ unsafe-coerce (.-promptFeedback chunk-data) 'Dynamic
fallback-text $ if (js-present-dynamic? prompt-feedback) (.-blockReason prompt-feedback) js/undefined
text0 $ if (js-present-dynamic? primary-text) primary-text fallback-text
text $ if (js-present-dynamic? text0) (unsafe-coerce text0 'String) |
text $ if (js-present-dynamic? text0) (stream-text text0) |
if is-thinking? (swap! *thinking-text str text) (swap! *text str text)
d! $ :: :states-merge cursor state
{} (:answer @*text) (:thinking @*thinking-text) (:loading? false) (:done? false)
Expand Down Expand Up @@ -462,9 +462,9 @@
choice0 $ unsafe-coerce (.-0 choices) 'Dynamic
choice $ unsafe-coerce (.-delta choice0) 'Dynamic
reason0 $ .-reasoning_content choice
reason $ if (js-present-dynamic? reason0) (unsafe-coerce reason0 'String) |
reason $ if (js-present-dynamic? reason0) (stream-text reason0) |
text0 $ .-content choice
text $ if (js-present-dynamic? text0) (unsafe-coerce text0 'String) |
text $ if (js-present-dynamic? text0) (stream-text text0) |
if
not $ blank? reason
swap! *thinking-text str reason
Expand Down Expand Up @@ -642,8 +642,8 @@
:args $ [] 'Number 'app.schema/ChatMessage
[] idx $ let
role $ :role msg
content $ :content msg
thinking $ :thinking msg
content $ stream-text (:content msg)
thinking $ stream-text (:thinking msg)
div
{} $ :class-name
str-spaced style-message-item $ if (= role :assistant) style-message-assistant style-message-user
Expand Down Expand Up @@ -767,8 +767,8 @@
:args $ [] 'Number 'app.schema/ChatMessage
[] idx $ let
role $ :role msg
content $ :content msg
thinking $ :thinking msg
content $ stream-text (:content msg)
thinking $ stream-text (:thinking msg)
div
{} $ :class-name
str-spaced style-message-item $ if (= role :assistant) style-message-assistant style-message-user
Expand Down Expand Up @@ -1411,6 +1411,21 @@
:schema $ :: 'Fn
{} (:return 'app.schema/Store)
:args $ [] 'app.schema/Store 'app.schema/ChatState
|stream-text $ %{} 'CodeEntry (:doc |)
:code $ quote
defn stream-text (value)
hint-fn $ {}
:generics $ [] 'T
:args $ [] 'T
:return 'String
:features $ #{} :js-ffi
if (string? value) value $ do (js/console.warn "|msg-buffer: ignored non-string streaming text" value) |
:examples $ []
:schema $ :: 'Fn
{} (:return 'String)
:args $ [] 'T
:features $ #{} :js-ffi
:generics $ [] 'T
|style-a-toggler $ %{} 'CodeEntry (:doc |)
:code $ quote
defstyle style-a-toggler $ {}
Expand Down
2 changes: 1 addition & 1 deletion deps.cirru
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,6 @@
:dependencies $ {} (|Respo/alerts.calcit |0.10.19)
|Respo/reel.calcit |0.6.7
|Respo/respo-feather.calcit |0.4.4
|Respo/respo-markdown.calcit |0.4.23
|Respo/respo-markdown.calcit |0.4.24
|Respo/respo-ui.calcit |0.7.10
|Respo/respo.calcit |0.16.83