feat: update WebSocket to handle new message format
This commit is contained in:
parent
b9dd9d3417
commit
6586890b6c
1 changed files with 14 additions and 10 deletions
|
@ -40,9 +40,10 @@
|
||||||
</template>
|
</template>
|
||||||
|
|
||||||
<script lang="ts" setup>
|
<script lang="ts" setup>
|
||||||
import type { MessageResponse, ScrollPosition, UserResponse } from '~/types/interfaces';
|
import type { MessageResponse, ScrollPosition, UserResponse, WSMessage } from '~/types/interfaces';
|
||||||
import scrollToBottom from '~/utils/scrollToBottom';
|
import scrollToBottom from '~/utils/scrollToBottom';
|
||||||
import { generateIrcColor } from '#imports';
|
import { generateIrcColor } from '#imports';
|
||||||
|
import { WSEvent } from '~/types/enums';
|
||||||
|
|
||||||
const { getDisplayName } = useProfile()
|
const { getDisplayName } = useProfile()
|
||||||
const { fetchMe } = useApi()
|
const { fetchMe } = useApi()
|
||||||
|
@ -195,17 +196,20 @@ if (accessToken && apiBase) {
|
||||||
ws.addEventListener("message", async (event) => {
|
ws.addEventListener("message", async (event) => {
|
||||||
console.log("event data:", event.data);
|
console.log("event data:", event.data);
|
||||||
console.log("message uuid:", event.data.uuid);
|
console.log("message uuid:", event.data.uuid);
|
||||||
const parsedData = JSON.parse(event.data);
|
const message: WSMessage = JSON.parse(event.data);
|
||||||
console.log("[MSG] parsed message:", parsedData);
|
console.log("[MSG] parsed message:", message);
|
||||||
|
|
||||||
console.log("parsed message type:", messagesType.value[parsedData.uuid]);
|
if (message.event == WSEvent.MessageSend) {
|
||||||
console.log("parsed message timestamp:", messageTimestamps.value[parsedData.uuid]);
|
const messageObject = message.entity as MessageResponse;
|
||||||
pushMessage(parsedData);
|
console.log("parsed message type:", messagesType.value[messageObject.uuid]);
|
||||||
|
console.log("parsed message timestamp:", messageTimestamps.value[messageObject.uuid]);
|
||||||
|
pushMessage(messageObject);
|
||||||
await nextTick();
|
await nextTick();
|
||||||
if (messagesElement.value) {
|
if (messagesElement.value) {
|
||||||
console.log("scrolling to bottom");
|
console.log("scrolling to bottom");
|
||||||
scrollToBottom(messagesElement.value);
|
scrollToBottom(messagesElement.value);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
} else {
|
} else {
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue