 (defn create-store
   "Creates a konserve store"
   [state]
-  (swap! state assoc :store (<!! (new-mem-store) #_(new-fs-store "store")))
+  (swap! state assoc :store (<?? (new-mem-store) #_(new-fs-store "store")))
   state)
 
 (def hooks (atom {[#".*"
-                   #uuid "26558dfe-59bb-4de4-95c3-4028c56eb5b5"
-                   "master"]
+                   #uuid "26558dfe-59bb-4de4-95c3-4028c56eb5b5"]
                   [["eve@topiq.es"
-                    #uuid "26558dfe-59bb-4de4-95c3-4028c56eb5b5"
-                    "master"]]}))
+                    #uuid "26558dfe-59bb-4de4-95c3-4028c56eb5b5"]]}))
 
 (def err-ch (chan))
 


  (<?? (k/get-in (:store @server-state) [:peer-config]))

  (def commit-eval {'(fn replace [old params] params) (fn replace [old params] [params])
                    '(fn [old params] (d/db-with old params)) (fn [old params] (conj old params))})

  (count (<!! (s/commit-value (:store @server-state) commit-eval
                              (:causal-order (<!! (k/get-in (:store @server-state) [["eve@topiq.es" #uuid "26558dfe-59bb-4de4-95c3-4028c56eb5b5"]])))
                              #uuid "05b162ca-b6a6-5106-838f-00e30a1a5b9b")))

  (require '[replikativ.crdt.materialize :refer [key->crdt]])


(ns topiq.core
  (:gen-class :main true)
  (:require [clojure.core.async :refer [timeout sub chan >!! >! go go-loop] :as async]
            [clojure.edn :as edn]
            [clojure.java.io :as io]
            [clojure.tools.logging :refer [info warn error]]
