hippoz/waffle
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

add config settings for typing notifications, message history and typing updates

Browse source
This commit is contained in:
hippoz 2022-08-31 11:40:10 +03:00
parent e42176fac7
commit 8c75b96696
No known key found for this signature in database
GPG key ID: 7C52899193467641
2 changed files with 29 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
frontend/src/storage.js
View file

@ -8,7 +8,11 @@ const defaults = {
"log:Gateway": false,
"log:Store": false,
"ui:stateful:presistSelectedChannel": true,
"ui:showSidebarToggle": false
"ui:showSidebarToggle": false,
"ui:online:processRemoteTypingEvents": true,
"ui:online:processRemotePresenceEvents": true,
"ui:online:loadMessageHistory": true,
"ui:online:sendTypingUpdates": true
};
const store = new Map(Object.entries(defaults));
const persistentProvider = localStorage;

44
frontend/src/stores.js
View file

@ -229,7 +229,7 @@ class MessageStore extends Store {
}
async loadOlderMessages(beforeCommitToStore=null) {
if (this.channelId === -1)
if (!getItem("ui:online:loadMessageHistory") || this.channelId === -1)
return;
const oldestMessage = this.value[0];
@ -331,17 +331,19 @@ class TypingStore extends Store {
this.ownTimeout = null;
this.ownNeedsUpdate = true;
gateway.subscribe(GatewayPayloadType.TypingStart, ({ user, channel, time }) => {
if (userInfoStore && user.id === userInfoStore.value.id)
return;
this.startedTyping(user, channel.id, time);
});
// assume someone has stopped typing once they send a message
gateway.subscribe(GatewayPayloadType.MessageCreate, ({ author_id }) => {
this.stoppedTyping(author_id);
});
if (getItem("ui:online:processRemoteTypingEvents")) {
gateway.subscribe(GatewayPayloadType.TypingStart, ({ user, channel, time }) => {
if (userInfoStore && user.id === userInfoStore.value.id)
return;
this.startedTyping(user, channel.id, time);
});
// assume someone has stopped typing once they send a message
gateway.subscribe(GatewayPayloadType.MessageCreate, ({ author_id }) => {
this.stoppedTyping(author_id);
});
}
}
stoppedTyping(id) {
@ -392,7 +394,7 @@ class TypingStore extends Store {
}
async didInputKey() {
if (!userInfoStore.value)
if (!userInfoStore.value || !getItem("ui:online:sendTypingUpdates"))
return;
this.startedTyping(userInfoStore.value, selectedChannel.value.id, 6500);
@ -407,13 +409,15 @@ class PresenceStore extends Store {
constructor() {
super([], "PresenceStore");
gateway.subscribe(GatewayEventType.Ready, ({ presence }) => {
this.ingestPresenceUpdate(presence);
});
gateway.subscribe(GatewayEventType.PresenceUpdate, (data) => {
this.ingestPresenceUpdate(data);
});
if (getItem("ui:online:processRemotePresenceEvents")) {
gateway.subscribe(GatewayEventType.Ready, ({ presence }) => {
this.ingestPresenceUpdate(presence);
});
gateway.subscribe(GatewayEventType.PresenceUpdate, (data) => {
this.ingestPresenceUpdate(data);
});
}
}
entryIndexByUserId(userId) {