-
A
-
Assistant
-
-
-
-
-
+
}
diff --git a/libs/chat/src/lib/styles/chat-markdown.ts b/libs/chat/src/lib/styles/chat-markdown.ts
index ca64e2772..ec85e32a4 100644
--- a/libs/chat/src/lib/styles/chat-markdown.ts
+++ b/libs/chat/src/lib/styles/chat-markdown.ts
@@ -52,38 +52,38 @@ export function renderMarkdown(content: string, sanitizer: DomSanitizer): SafeHt
* Must be included in a component with ViewEncapsulation.None or via ::ng-deep.
*/
export const CHAT_MARKDOWN_STYLES = `
- .chat-md p { margin: 0 0 0.75em; }
- .chat-md p:last-child { margin-bottom: 0; }
- .chat-md code {
+ :host ::ng-deep .chat-md p { margin: 0 0 0.75em; }
+ :host ::ng-deep .chat-md p:last-child { margin-bottom: 0; }
+ :host ::ng-deep .chat-md code {
background: var(--chat-bg-alt);
padding: 2px 6px;
border-radius: 4px;
font-size: 0.875em;
font-family: 'SF Mono', 'Fira Code', 'Cascadia Code', monospace;
}
- .chat-md pre {
+ :host ::ng-deep .chat-md pre {
background: var(--chat-bg-alt);
padding: 12px 16px;
border-radius: var(--chat-radius-card);
overflow-x: auto;
margin: 0.75em 0;
}
- .chat-md pre code { background: none; padding: 0; }
- .chat-md ul, .chat-md ol { margin: 0.5em 0; padding-left: 1.5em; }
- .chat-md li { margin: 0.25em 0; }
- .chat-md a { color: var(--chat-text); text-decoration: underline; }
- .chat-md strong { font-weight: 600; }
- .chat-md blockquote {
+ :host ::ng-deep .chat-md pre code { background: none; padding: 0; }
+ :host ::ng-deep .chat-md ul, :host ::ng-deep .chat-md ol { margin: 0.5em 0; padding-left: 1.5em; }
+ :host ::ng-deep .chat-md li { margin: 0.25em 0; }
+ :host ::ng-deep .chat-md a { color: var(--chat-text); text-decoration: underline; }
+ :host ::ng-deep .chat-md strong { font-weight: 600; }
+ :host ::ng-deep .chat-md blockquote {
border-left: 3px solid var(--chat-border);
padding-left: 12px;
margin: 0.75em 0;
color: var(--chat-text-muted);
}
- .chat-md h1, .chat-md h2, .chat-md h3, .chat-md h4 { margin: 1em 0 0.5em; font-weight: 600; }
- .chat-md h1 { font-size: 1.25em; }
- .chat-md h2 { font-size: 1.125em; }
- .chat-md h3 { font-size: 1em; }
- .chat-md table { border-collapse: collapse; width: 100%; margin: 0.75em 0; }
- .chat-md th, .chat-md td { border: 1px solid var(--chat-border); padding: 6px 12px; text-align: left; }
- .chat-md th { background: var(--chat-bg-alt); font-weight: 600; font-size: 0.875em; }
+ :host ::ng-deep .chat-md h1, :host ::ng-deep .chat-md h2, :host ::ng-deep .chat-md h3, :host ::ng-deep .chat-md h4 { margin: 1em 0 0.5em; font-weight: 600; }
+ :host ::ng-deep .chat-md h1 { font-size: 1.25em; }
+ :host ::ng-deep .chat-md h2 { font-size: 1.125em; }
+ :host ::ng-deep .chat-md h3 { font-size: 1em; }
+ :host ::ng-deep .chat-md table { border-collapse: collapse; width: 100%; margin: 0.75em 0; }
+ :host ::ng-deep .chat-md th, :host ::ng-deep .chat-md td { border: 1px solid var(--chat-border); padding: 6px 12px; text-align: left; }
+ :host ::ng-deep .chat-md th { background: var(--chat-bg-alt); font-weight: 600; font-size: 0.875em; }
`;
diff --git a/libs/stream-resource/src/lib/internals/stream-manager.bridge.ts b/libs/stream-resource/src/lib/internals/stream-manager.bridge.ts
index f48d1ca3f..0620a6a69 100644
--- a/libs/stream-resource/src/lib/internals/stream-manager.bridge.ts
+++ b/libs/stream-resource/src/lib/internals/stream-manager.bridge.ts
@@ -102,24 +102,64 @@ export function createStreamManagerBridge
)['id'];
+ const idx = id ? merged.findIndex(m => (m as unknown as Record)['id'] === id) : -1;
+ if (idx >= 0) {
+ merged[idx] = msg;
+ } else {
+ merged.push(msg);
+ }
+ }
+ subjects.messages$.next(merged);
} else {
- subjects.messages$.next(msgs as BaseMessage[]);
+ subjects.messages$.next(normalized);
}
return;
}
+ // normalizeSdkEvent spreads event data directly into the event object,
+ // so the values/updates payload is at event['data'] (the original data object),
+ // NOT at event['values'] or event['updates'].
switch (event.type) {
- case 'values':
- subjects.values$.next(event['values'] as T);
+ case 'values': {
+ const vals = extractEventData(event);
+ if (vals != null) {
+ subjects.values$.next(vals as T);
+ // Also sync messages$ from the values state so the full message
+ // history (including human messages) is available to consumers.
+ const stateMessages = (vals as Record)['messages'];
+ if (Array.isArray(stateMessages)) {
+ if (options.toMessage) {
+ subjects.messages$.next(stateMessages.map(options.toMessage));
+ } else {
+ subjects.messages$.next(stateMessages as BaseMessage[]);
+ }
+ }
+ }
break;
- case 'updates':
- subjects.values$.next({
- ...subjects.values$.value,
- ...(event['updates'] as object),
- } as T);
+ }
+ case 'updates': {
+ const upd = extractEventData(event);
+ if (upd != null) {
+ subjects.values$.next({
+ ...subjects.values$.value,
+ ...(upd as object),
+ } as T);
+ }
break;
+ }
case 'error':
subjects.error$.next(event['error']);
subjects.status$.next(ResourceStatus.Error);
@@ -177,6 +217,29 @@ export function createStreamManagerBridge 0 ? rest : d;
+}
+
function isMessagesEvent(type: StreamEvent['type']): boolean {
return type === 'messages' || type.startsWith('messages/');
}
diff --git a/libs/stream-resource/src/lib/stream-resource.fn.ts b/libs/stream-resource/src/lib/stream-resource.fn.ts
index 517459317..faa25aeb1 100644
--- a/libs/stream-resource/src/lib/stream-resource.fn.ts
+++ b/libs/stream-resource/src/lib/stream-resource.fn.ts
@@ -91,7 +91,7 @@ export function streamResource<
// Track hasValue — becomes true once values or messages arrive
values$.pipe(takeUntil(destroy$)).subscribe(v => {
- if (Object.keys(v as object).length > 0) hasValue$.next(true);
+ if (v != null && Object.keys(v as object).length > 0) hasValue$.next(true);
});
messages$.pipe(takeUntil(destroy$)).subscribe(m => { if (m.length > 0) hasValue$.next(true); });