hendrik/lens
1
0
Fork 0
mirror of https://github.com/lensapp/lens.git synced 2025-05-20 05:10:56 +00:00
Code Issues Projects Releases Wiki Activity

fix: parse multiple kube-events from stream's chunk

Browse Source 
Signed-off-by: Roman <ixrock@gmail.com>
This commit is contained in:
Roman 2021-01-18 15:15:04 +02:00
parent 34d8fa4c69
commit de4226a24a
1 changed files with 19 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/renderer/api/kube-watch-api.ts
View File

@ -106,7 +106,7 @@ export class KubeWatchApi {
}); });
const reader = req.body.getReader(); const reader = req.body.getReader();
const handleEvent = this.handleEvent.bind(this); const handleEvent = this.handleStreamEvent.bind(this);
this.stream = new ReadableStream({ this.stream = new ReadableStream({
start(controller) { start(controller) {
@ -138,17 +138,25 @@ export class KubeWatchApi {
} }
} }
protected handleEvent(eventStreamChunk: Uint8Array) { protected handleStreamEvent(chunk: Uint8Array) {
try { const jsonText = new TextDecoder().decode(chunk);
const jsonText = new TextDecoder().decode(eventStreamChunk); if (!jsonText) {
const event: IKubeWatchEvent = JSON.parse(jsonText); return;
const message = this.getMessage(event);
this.onMessage.emit(message);
} catch (error) {
this.writeLog({
error: ["failed to parse watch-api event", error]
});
} }
// decoded json might contain multiple kube-events at a time
const events = jsonText.split("\n");
events.forEach(kubeEvent => {
try {
const message = this.getMessage(JSON.parse(kubeEvent));
this.onMessage.emit(message);
} catch (error) {
this.writeLog({
error: ["failed to parse watch-api event", { error, jsonText }]
});
}
})
} }
protected getMessage(event: IKubeWatchEvent): IKubeWatchMessage { protected getMessage(event: IKubeWatchEvent): IKubeWatchMessage {