X-Git-Url: http://jaekl.net/gitweb/?p=quanlib.git;a=blobdiff_plain;f=book_loader.rb;fp=book_loader.rb;h=5516f0482f553238d45309935c399c1d15cb47df;hp=0000000000000000000000000000000000000000;hb=56ed007c7918ec7ea34b431b1f0f4ef9bbb02c56;hpb=5c1cd0b8778c301090bfdda6f9cb2399e70b792d

diff --git a/book_loader.rb b/book_loader.rb
new file mode 100644
index 0000000..5516f04
--- /dev/null
+++ b/book_loader.rb
@@ -0,0 +1,28 @@
+
+require_relative 'book'
+require_relative 'store'
+
+class BookLoader 
+  DONE_MARKER = '<END>'
+
+  def initialize(config_file, queue)
+    @config_file = config_file
+    @queue = queue
+  end
+
+  def run
+    @store = Store.new(@config_file)
+    @store.connect()
+
+    file = @queue.pop
+    until file == DONE_MARKER do
+      book = Book.new(@store)
+      book.load_from_file!(file)
+      @store.store_book(book)
+
+      file = @queue.pop
+    end
+
+    @store.disconnect()
+  end
+end