re-frame integration and lan-on/off functions.

``` javascript
athens.core.lan_on();
ahtens.core.lan_off();
```

Author: neotyk

README.self-hosted.md

@@ -0,0 +1,62 @@
+# Athens Lan Party Mode
+
+## Client
+
+Standard procedure for running dev client.
+
+Open DevConsole.
+
+**Join LanParty**
+
+``` javascript
+athens.core.lan_on();
+```
+
+**Leave LanParty**
+
+``` javascript
+athens.core.lan_off();
+```
+
+## Server
+
+### Running Athens Self-Hosted Server
+
+``` shell
+lein run
+```
+
+This will start HTTP server on port 3010, unless you've modified `src/clj/config.edn`.
+
+Also nRELP server is started on port 8877, unless you've modified `src/clj/config.edn`.
+
+### Developing Athens Self-Hosted Server
+
+Start REPL:
+
+``` shell
+lein repl
+```
+
+Start the system:
+
+``` clojure
+(dev)
+(start)
+```
+
+Same way you can start the system after `cider-jack-in`.
+
+After starting HTTP & nREPL servers are running on default ports or changes in `config.edn`.
+
+**Resetting the system**
+
+``` clojure
+(reset)
+```
+
+**Clean the Datahike DB**
+
+Stop the Self-Hosted server. [ctrl+c] if using `lein run` or [ctrl+d] if repl.
+By default Datahike DB is stored in `/tmp/exmaple`, remove this forlder
+start the srever and Bob's your unkle.

dev/cljs/user.cljs

@@ -1,3 +1,7 @@
+#_{:clj-kondo/ignore [:unused-namespace
+                      :unused-referred-var]}
+
+
 (ns cljs.user
   "Commonly used symbols for easy access in the ClojureScript REPL during
   development."
@@ -6,3 +10,4 @@
                                   find-doc print-doc pst source)]
     [clojure.pprint :refer (pprint)]
     [clojure.string :as str]))
+

src/clj/athens/self_hosted/components/datahike.clj

@@ -1,5 +1,6 @@
 (ns athens.self-hosted.components.datahike
   (:require
+    [athens.athens-datoms       :as athens-datoms]
     [clojure.tools.logging      :as log]
     [com.stuartsierra.component :as component]
     [datahike.api               :as d]))
@@ -63,16 +64,21 @@
 
   (start
     [component]
-    (let [dh-conf (get-in config [:config :datahike])
-          conf-with-schema (assoc dh-conf :initial-tx schema)]
+    (let [dh-conf          (get-in config [:config :datahike])
+          conf-with-schema (assoc dh-conf :initial-tx schema)
+          new-db?          (atom false)]
       (if (d/database-exists? dh-conf)
         (log/info "Connecting to existing Datahike database")
         (do
           (log/info "Creating new Datahike database")
-          (d/create-database conf-with-schema)))
+          (d/create-database conf-with-schema)
+          (reset! new-db? true)))
       (log/info "Starting Datahike connection: " dh-conf)
       (let [connection (d/connect conf-with-schema)]
         (log/debug "Datahike connected")
+        (when @new-db?
+          (log/debug "Populating fresh db with datoms.")
+          (d/transact connection athens-datoms/lan-datoms))
         (assoc component :conn connection))))
 
 

src/clj/athens/self_hosted/web/presence.clj

@@ -37,9 +37,7 @@
     (clients/add-client! channel username)
     (clients/broadcast! (common-events/build-presence-online username max-tx))
 
-    (let [datoms (d/q '[:find ?e ?a ?v ?t ?add
-                        :where [?e ?a ?v ?t ?add]]
-                      @(:conn datahike))]
+    (let [datoms (d/datoms @(:conn datahike) :eavt)]
       (log/debug channel "Sending" (count datoms) "eavt")
       (clients/send! channel
                      (common-events/build-db-dump datoms max-tx)))

src/cljs/athens/athens_datoms.cljs src/cljc/athens/athens_datoms.cljc

@@ -149,7 +149,7 @@
    [:event/args
     [:map
      [:datoms
-      [:set vector?]]]]])
+      [:sequential datom]]]]])
 
 
 (def presence-online

src/cljc/athens/common_events/schema.cljc

@@ -12,6 +12,7 @@
     [athens.events]
     [athens.listeners :as listeners]
     [athens.router :as router]
+    [athens.self-hosted.client :as client]
     [athens.style :as style]
     [athens.subs]
     [athens.util :as util]
@@ -123,3 +124,15 @@
     (rf/dispatch-sync [:boot/web]))
   (dev-setup)
   (mount-root))
+
+
+(defn ^:export lan-on
+  ([] ; TODO take default from configuration
+   (lan-on client/ws-url))
+  ([url]
+   (rf/dispatch [:remote/connect! {:url url}])))
+
+
+(defn ^:export lan-off
+  []
+  (rf/dispatch [:remote/disconnect!]))

src/cljs/athens/core.cljs

@@ -12,6 +12,7 @@
     [cljs.core.async             :refer [go <!]]
     [cljs.pprint                 :refer [pprint]]
     [clojure.string              :as str]
+    [com.stuartsierra.component  :as component]
     [dat.sync.client]
     [datascript.core             :as d]
     [datascript.transit          :as dt]
@@ -393,6 +394,32 @@
         (set! (.. right-sidebar -scrollTop) 0)))))
 
 
+;; TODO: temporary, and limits to one client opened.
+(def self-hosted-client (atom nil))
+
+
+(reg-fx
+  :remote/client-connect!
+  (fn [{:keys [url] :as connection-config}]
+    (js/console.debug ":remote/client-connect!" (pr-str connection-config))
+    (when @self-hosted-client
+      (js/console.log ":remote/client-connect! already connected, restarting")
+      (component/stop @self-hosted-client))
+    (js/console.log ":remote/client-connect! connecting")
+    (reset! self-hosted-client (-> url
+                                   client/new-ws-client
+                                   component/start))))
+
+
+(reg-fx
+  :remote/client-disconnect!
+  (fn []
+    (js/console.debug ":remote/client-disconnect!")
+    (when @self-hosted-client
+      (component/stop @self-hosted-client)
+      (reset! self-hosted-client nil))))
+
+
 (reg-fx
   :remote/send-event!
   (fn [event]
@@ -406,3 +433,5 @@
                             (m/explain event)
                             (me/humanize))]
         (js/console.warn "Tried to send invalid event. Error:" (pr-str explanation))))))
+
+

src/cljs/athens/effects.cljs

@@ -3,6 +3,7 @@
     [athens.athens-datoms :as athens-datoms]
     [athens.db :as db]
     [athens.patterns :as patterns]
+    [athens.self-hosted.client :as client]
     [athens.style :refer [zoom-level-min zoom-level-max]]
     [athens.util :as util :refer [ipcMainChannels]]
     [cljs.reader :refer [read-string]]
@@ -502,7 +503,9 @@
     If the write operation succeeds, a backup is created and index.transit is overwritten.
     User should eventually have MANY backups files. It's their job to manage these backups :)"
     [copy?]
-    (when-not @(subscribe [:socket-status])
+    (when-not (or (client/open?)
+                  ;; TODO this is part of Self-Hosted API, remove later
+                  @(subscribe [:socket-status]))
       (let [filepath     @(subscribe [:db/filepath])
             data         (dt/write-transit-str @db/dsdb)
             r            (.. stream -Readable (from data))

src/cljs/athens/electron.cljs

@@ -37,6 +37,34 @@
      :local-storage/set! ["db/filepath" filepath]}))
 
 
+(reg-event-fx
+  :remote/connect!
+  (fn [{:keys [db]} [_ connection-config]]
+    (js/console.log ":remote/connect!" (pr-str connection-config))
+    {:db                     (-> db
+                                 (dissoc :db/filepath)
+                                 (assoc :db/remote connection-config))
+     :remote/client-connect! connection-config
+     :local-storage/set!     ["db/remote" connection-config]
+     :fx                     [[:dispatch [:loading/set]]]}))
+
+
+(reg-event-fx
+  :remote/connected
+  (fn [{:keys [db]} _]
+    (js/console.log ":remote/connected")
+    {:db (dissoc db :db/remote)
+     :fx [[:dispatch [:loading/unset]]]}))
+
+
+(reg-event-fx
+  :remote/disconnect!
+  (fn [{:keys [db]} _]
+    {:db                        (dissoc db :db/remote)
+     :remote/client-disconnect! nil
+     :local-storage/set!        ["db/remote" nil]}))
+
+
 (reg-event-db
   :db/sync
   (fn [db [_]]

src/cljs/athens/events.cljs

@@ -25,7 +25,7 @@
 
 (defn- connect-to-self-hosted!
   [url]
-  (js/console.log "WS Client Connecting to:" url)
+  (js/console.log "WSClient Connecting to:" url)
   (when url
     (doto (js/WebSocket. url)
       (.addEventListener "open" open-handler)
@@ -240,12 +240,13 @@
                                :db/valueType
                                :db/unique}
                              ;; attribute
-                             (second %)))
+                             (:a %)))
          ;; group by entity id
-         (group-by first)
+         (group-by :e)
          (reduce (fn [acc [entity-id datoms]]
+                   (js/console.debug "reduce1:" (pr-str entity-id))
                    (assoc acc entity-id
-                          (reduce (fn [entity [_ a v]]
+                          (reduce (fn [entity {:keys [a v]}]
                                     (assoc entity a
                                            (if (= :block/children a)
                                              (conj (:block/children entity #{})
@@ -263,8 +264,11 @@
   (js/console.debug "Received DB Dump")
   (let [entities (reconstruct-entities-from-db-dump datoms)]
     (js/console.debug "Reconstructed" (count entities) "entities")
-    (d/transact! db/dsdb entities)
+    (rf/dispatch [:reset-conn (d/empty-db db/schema)])
+    (rf/dispatch [:transact entities])
     (rf/dispatch [:remote/last-seen-tx! last-tx])
+    (rf/dispatch [:db/sync])
+    (rf/dispatch [:remote/connected])
     (js/console.log "✅ Transacted DB dump. last-seen-tx" last-tx)))
 
 
@@ -311,6 +315,7 @@
         {:event/keys
          [id]}    packet
         req-event (get @awaiting-response id)]
+    (js/console.log "message-handler" (pr-str packet))
     (if req-event
       (awaited-response-handler req-event packet)
       (server-event-handler packet))))
@@ -359,6 +364,7 @@
       component)))
 
 
+;; TODO: password protection
 (defn new-ws-client
   [url]
   (map->WSClient {:url url}))