web: prevent duplicate messages
This commit is contained in:
parent
a63702ef90
commit
b63b789f77
|
@ -8,7 +8,7 @@ export function showMessage(message: APIMessage): void {
|
||||||
if (!container) {
|
if (!container) {
|
||||||
throw new Error("failed to find message container");
|
throw new Error("failed to find message container");
|
||||||
}
|
}
|
||||||
container.messages.push(message);
|
container.addMessage(message);
|
||||||
container.requestUpdate();
|
container.requestUpdate();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -34,6 +34,14 @@ export class MessageContainer extends LitElement {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// add a new message, but only if the message isn't currently shown.
|
||||||
|
addMessage(message: APIMessage): void {
|
||||||
|
const matchingMessages = this.messages.filter(m => m.message == message.message);
|
||||||
|
if (matchingMessages.length < 1) {
|
||||||
|
this.messages.push(message);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
connect(): void {
|
connect(): void {
|
||||||
if (navigator.webdriver) return;
|
if (navigator.webdriver) return;
|
||||||
const wsUrl = `${window.location.protocol.replace("http", "ws")}//${
|
const wsUrl = `${window.location.protocol.replace("http", "ws")}//${
|
||||||
|
@ -60,7 +68,7 @@ export class MessageContainer extends LitElement {
|
||||||
});
|
});
|
||||||
this.messageSocket.addEventListener("message", (e) => {
|
this.messageSocket.addEventListener("message", (e) => {
|
||||||
const data = JSON.parse(e.data);
|
const data = JSON.parse(e.data);
|
||||||
this.messages.push(data);
|
this.addMessage(data);
|
||||||
this.requestUpdate();
|
this.requestUpdate();
|
||||||
});
|
});
|
||||||
this.messageSocket.addEventListener("error", (e) => {
|
this.messageSocket.addEventListener("error", (e) => {
|
||||||
|
@ -76,8 +84,8 @@ export class MessageContainer extends LitElement {
|
||||||
.message=${m}
|
.message=${m}
|
||||||
.onRemove=${(m: APIMessage) => {
|
.onRemove=${(m: APIMessage) => {
|
||||||
this.messages = this.messages.filter((v) => v !== m);
|
this.messages = this.messages.filter((v) => v !== m);
|
||||||
this.requestUpdate();
|
this.requestUpdate();
|
||||||
}}>
|
}}>
|
||||||
</ak-message>`;
|
</ak-message>`;
|
||||||
})}
|
})}
|
||||||
</ul>`;
|
</ul>`;
|
||||||
|
|
Reference in New Issue