status-im
/
status-mobile
mirror of https://github.com/status-im/status-mobile.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

[#6956] delete duplicates after iteration over messages/statuses

This commit is contained in:
Roman Volosovskyi 2018-12-06 11:08:07 +02:00
parent c15a57571d
commit 4aaaf58e99
No known key found for this signature in database
GPG Key ID: 0238A4B5ECEE70DE
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/status_im/data_store/realm/schemas/account/migrations.cljs
View File

@ -246,7 +246,9 @@
(defn v27 [old-ream new-realm] (defn v27 [old-ream new-realm]
(let [messages (.objects new-realm "message") (let [messages (.objects new-realm "message")
user-statuses (.objects new-realm "user-status") user-statuses (.objects new-realm "user-status")
old-ids->new-ids (volatile! {})] old-ids->new-ids (volatile! {})
messages-to-be-deleted (volatile! [])
statuses-to-be-deleted (volatile! [])]
(dotimes [i (.-length messages)] (dotimes [i (.-length messages)]
(let [message (aget messages i) (let [message (aget messages i)
prev-message-id (aget message "message-id") prev-message-id (aget message "message-id")
@ -270,12 +272,15 @@
new-realm new-realm
"message" "message"
message-id) message-id)
(.delete new-realm message) (vswap! messages-to-be-deleted conj message)
(do (do
(aset message "message-id" message-id) (aset message "message-id" message-id)
(aset message "raw-payload-hash" raw-payload-hash) (aset message "raw-payload-hash" raw-payload-hash)
(aset message "old-message-id" old-message-id))))) (aset message "old-message-id" old-message-id)))))
(doseq [message @messages-to-be-deleted]
(.delete new-realm message))
(dotimes [i (.-length user-statuses)] (dotimes [i (.-length user-statuses)]
(let [user-status (aget user-statuses i) (let [user-status (aget user-statuses i)
message-id (aget user-status "message-id") message-id (aget user-status "message-id")
@ -286,7 +291,10 @@
new-realm new-realm
"user-status" "user-status"
new-status-id) new-status-id)
(.delete new-realm user-status) (vswap! statuses-to-be-deleted conj user-status)
(when (contains? @old-ids->new-ids message-id) (when (contains? @old-ids->new-ids message-id)
(aset user-status "status-id" new-status-id) (aset user-status "status-id" new-status-id)
(aset user-status "message-id" new-message-id))))))) (aset user-status "message-id" new-message-id)))))
(doseq [status @statuses-to-be-deleted]
(.delete new-realm status))))