|
@@ -63,11 +63,16 @@ export class RemoteInferenceService implements OnDestroy {
|
|
|
return body;
|
|
return body;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- if (body) {
|
|
|
|
|
|
|
+ if (body && typeof body === 'object') {
|
|
|
const extractedRecords = body.records || body.data || body.items || body.history;
|
|
const extractedRecords = body.records || body.data || body.items || body.history;
|
|
|
if (Array.isArray(extractedRecords)) {
|
|
if (Array.isArray(extractedRecords)) {
|
|
|
return extractedRecords;
|
|
return extractedRecords;
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
|
|
+ const values = Object.values(body);
|
|
|
|
|
+ if (values.length > 0 && values.every(v => v !== null && typeof v === 'object')) {
|
|
|
|
|
+ return values as any[];
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
return [];
|
|
return [];
|
|
@@ -128,7 +133,7 @@ export class RemoteInferenceService implements OnDestroy {
|
|
|
this.dpService.stream(message).subscribe({
|
|
this.dpService.stream(message).subscribe({
|
|
|
next: (res: any) => {
|
|
next: (res: any) => {
|
|
|
// Gracefully intercept and isolate system finalization frames before parsing
|
|
// Gracefully intercept and isolate system finalization frames before parsing
|
|
|
- if (res && res.complete === true && !res.message) {
|
|
|
|
|
|
|
+ if (res && res.complete === true) {
|
|
|
observer.complete();
|
|
observer.complete();
|
|
|
return;
|
|
return;
|
|
|
}
|
|
}
|