diff options
| author | Shpuld Shpludson <shp@cock.li> | 2021-02-22 15:01:05 +0000 |
|---|---|---|
| committer | Shpuld Shpludson <shp@cock.li> | 2021-02-22 15:01:05 +0000 |
| commit | 589ab6510c1effc909ee9f6b64cd7791d3f55ee7 (patch) | |
| tree | 0018c6e6dc200dbe9c09f331b5af7c70873431d1 /src/services/chat_service/chat_service.js | |
| parent | e8b8c3cc49171a7372bf49ee29930fd55c95ce98 (diff) | |
| parent | 67f3532ac95b2a8740ccbde581e74ac65eb20a9a (diff) | |
Merge branch 'feat/keep-chat-perf-up' into 'develop'
Optimize chat perf in long run
See merge request pleroma/pleroma-fe!1350
Diffstat (limited to 'src/services/chat_service/chat_service.js')
| -rw-r--r-- | src/services/chat_service/chat_service.js | 17 |
1 files changed, 17 insertions, 0 deletions
diff --git a/src/services/chat_service/chat_service.js b/src/services/chat_service/chat_service.js index e653ebc1..92ff689d 100644 --- a/src/services/chat_service/chat_service.js +++ b/src/services/chat_service/chat_service.js @@ -48,6 +48,22 @@ const deleteMessage = (storage, messageId) => { } } +const cullOlderMessages = (storage) => { + const maxIndex = storage.messages.length + const minIndex = maxIndex - 50 + if (maxIndex <= 50) return + + storage.messages = _.sortBy(storage.messages, ['id']) + storage.minId = storage.messages[minIndex].id + for (const message of storage.messages) { + if (message.id < storage.minId) { + delete storage.idIndex[message.id] + delete storage.idempotencyKeyIndex[message.idempotency_key] + } + } + storage.messages = storage.messages.slice(minIndex, maxIndex) +} + const handleMessageError = (storage, fakeId, isRetry) => { if (!storage) { return } const fakeMessage = storage.idIndex[fakeId] @@ -201,6 +217,7 @@ const ChatService = { empty, getView, deleteMessage, + cullOlderMessages, resetNewMessageCount, clear, handleMessageError |
