nostr/more-speech
1
0
Fork 0
mirror of https://github.com/unclebob/more-speech.git synced 2024-09-30 02:21:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

On startup read files, latest first, and concurrently open the relays.

Browse Source
This commit is contained in:
Robert C. Martin 2022-09-06 08:14:48 -05:00
parent 8412639372
commit 037e575a2f
1 changed files with 12 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/more_speech/data_storage.clj
View File

@ -23,14 +23,14 @@
(with-out-str
(clojure.pprint/pprint (relays/relays-for-writing))))
(spit @config/tabs-list-filename
(with-out-str
(clojure.pprint/pprint (:tabs-list @event-context))))
(with-out-str
(clojure.pprint/pprint (:tabs-list @event-context))))
(spit @config/user-configuration-filename
(with-out-str
(clojure.pprint/pprint (:user-configuration @event-context))))
(with-out-str
(clojure.pprint/pprint (:user-configuration @event-context))))
(spit @config/contact-lists-filename
(with-out-str
(clojure.pprint/pprint (:contact-lists @event-context))))
(with-out-str
(clojure.pprint/pprint (:contact-lists @event-context))))
))
(defn write-messages []
@ -140,10 +140,11 @@
now (quot (System/currentTimeMillis) 1000)
last-time (if (nil? last-time) (- now 86400) last-time)
first-time (if (nil? first-time) now first-time)]
(doseq [file-name file-names]
(prn 'reading file-name)
(let [old-events (read-string (slurp (str @config/messages-directory "/" file-name)))]
(load-events old-events event-context handler)))
(swap! event-context assoc :days-changed #{} :earliest-loaded-time first-time)
(future
(doseq [file-name (reverse file-names)]
(prn 'reading file-name)
(let [old-events (read-string (slurp (str @config/messages-directory "/" file-name)))]
(load-events old-events event-context handler)))
(swap! event-context assoc :days-changed #{(quot last-time 86400)} :earliest-loaded-time first-time))
last-time))