Compare commits

..

2 commits

3 changed files with 10 additions and 5 deletions

View file

@ -232,7 +232,7 @@ async function syncSpaceExpressions(data, checkBeforeSync) {
} }
if (isDeepStrictEqual(existing, content)) return if (isDeepStrictEqual(existing, content)) return
} }
api.sendState(spaceID, "im.ponies.room_emotes", eventKey, content) await api.sendState(spaceID, "im.ponies.room_emotes", eventKey, content)
} }
await update(spaceID, "emojis", "moe.cadence.ooye.pack.emojis", expression.emojisToState) await update(spaceID, "emojis", "moe.cadence.ooye.pack.emojis", expression.emojisToState)

View file

@ -48,7 +48,7 @@ async function sendMessage(message, channel, guild, row) {
const eventIDs = [] const eventIDs = []
if (events.length) { if (events.length) {
db.prepare("REPLACE INTO message_channel (message_id, channel_id) VALUES (?, ?)").run(message.id, message.channel_id) db.prepare("REPLACE INTO message_channel (message_id, channel_id) VALUES (?, ?)").run(message.id, message.channel_id)
if (senderMxid) api.sendTyping(roomID, false, senderMxid) if (senderMxid) api.sendTyping(roomID, false, senderMxid).catch(() => {})
} }
for (const event of events) { for (const event of events) {
const part = event === events[0] ? 0 : 1 const part = event === events[0] ? 0 : 1

View file

@ -51,9 +51,14 @@ const utils = {
} }
if (listen === "full") { if (listen === "full") {
eventDispatcher.checkMissedExpressions(message.d) try {
eventDispatcher.checkMissedPins(client, message.d) await eventDispatcher.checkMissedExpressions(message.d)
eventDispatcher.checkMissedMessages(client, message.d) await eventDispatcher.checkMissedPins(client, message.d)
await eventDispatcher.checkMissedMessages(client, message.d)
} catch (e) {
console.error("Failed to sync missed events. To retry, please fix this error and restart OOYE:")
console.error(e)
}
} }
} else if (message.t === "GUILD_UPDATE") { } else if (message.t === "GUILD_UPDATE") {