- replay the transactions

src/imdb/boot.clj

@@ -23,7 +23,18 @@
   (swap! before-fs conj fstart)
   (swap! after-fs conj fstop))
 
-(defn- clear
+
+(defn clear-state
+  []
+  (alter-var-root #'state (constantly (atom {}))))
+
+(defn clear-index
+  []
+  (doseq [c @state]
+    (when (.endsWith (str (first c)) "idx")
+      (swap! state dissoc (first c)))))
+
+(defn clear
   []
   (alter-var-root #'state (constantly (atom {})))
   (alter-var-root #'after-fs (constantly (atom [])))
@@ -49,7 +60,7 @@
   (swap! after-fs conj f))
 
 (defn stop! []
-  (if-not (empty? @state)
+  (when-not (empty? @state)
     (reduce (fn [r f]
               (f state))
             state

src/imdb/core.clj

@@ -6,6 +6,7 @@
             [imdb.boot :as b]
             [imdb.schema :as sc]
             [imdb.query :as query]
+            [clj-leveldb :as cl]
             )
   (:use [clojure.test]))
 
@@ -31,6 +32,11 @@
   (if-let [pieces (cmd/cmd-to-pieces cmd)]
     (tx/run-tx pieces handle-pieces) ))
 
+(defn replay!
+  []
+  (doseq [i (cl/iterator (b/get-state :log-db))]
+    (handle-pieces (second i))))
+
 (def schemas
   {:user {:name [:string :index :uniqure]
           :event [:string :index]
@@ -46,12 +52,16 @@
   (start! [this]
     (b/attach :schemas schemas)
     (b/attach :piece-name-ids (sc/store-piece-name-ids schemas))
+    (replay!)
     (println "starting imdb"))
   (stop! [this]
     (println "stopping imdb")))
 
 
 
+
+
+
 (def query-sample
   {:entity :user
    :query [:and
@@ -113,3 +123,21 @@
       (is (= '(111111) (:idx (q imdb query-sample1))))
       (is (= '(111119 111112) (:idx (q imdb query-end-with))))
       (stop! imdb))))
+
+
+(deftest test-replay
+  (testing ""
+    (let [cmds  test-data
+          imdb (SimpleImdb. schemas)]
+      (start! imdb)
+      (doseq [cmd cmds]
+        (pub imdb cmd))
+      (is (not (nil? (b/get-state ":user-:name-vidx"))))
+      (b/clear-index)
+      (is (nil? (b/get-state ":user-:name-vidx")))
+      (stop! imdb)
+      (start! imdb)
+      (is (= '(111113) (:idx (q imdb query-sample))))
+      (is (= '(111111) (:idx (q imdb query-sample1))))
+      (is (= '(111119 111112) (:idx (q imdb query-end-with))))
+      (stop! imdb))))

src/imdb/warmup.clj

@@ -6,7 +6,7 @@
 (defn start-tx-db
   [state]
   (b/attach :log-db (leveldb/create-db
-                     (b/get-state :tx-db-path "/tmp/tx-db4")
+                     (b/get-state :tx-db-path "/tmp/tx-db10")
                      {:key-encoder cvt/->bytes
                       :val-encoder cvt/->bytes
                       :key-decoder cvt/->long
@@ -15,7 +15,7 @@
 (defn start-schema-db
   [state]
   (b/attach :schema-db (leveldb/create-db
-                        (b/get-state :schema-db-path "/tmp/schema-db4")
+                        (b/get-state :schema-db-path "/tmp/schema-db10")
                         {:key-encoder cvt/->bytes
                          :val-encoder cvt/->bytes
                          :key-decoder cvt/->long