;;;; -*- Mode: Lisp; Syntax: ANSI-Common-Lisp; Base: 10 -*-

(defparameter *db-spec* '("bgpstore" "bgpstore" "bgpstore" "localhost" ))

(defun marker (mark)
  (format t mark)
  (force-output))

(defun start-bgpstore (host port)
  (with-connection *db-spec* 
    (let ((reader (new-reader host port))
	  (count 0))
      (marker (format nil "~A: bgpstore started "
		      (iso-date (get-universal-time) t)))
      (do ((e (next-xml-blurb reader "BGP_MESSAGE")
	      (next-xml-blurb reader "BGP_MESSAGE")))
	  ((null e))
	(dolist (obj (new-entries (xml-top-elem-from-octets e)))
	  (insert-dao obj)
	  (incf count)
	  (when (= 0 (mod count 10)) (marker "."))
	  (when (= 0 (mod count 100)) (marker "+"))
	  (when (= 0 (mod count 1000))
	    (marker (format nil "~%~A: ~A "
			    (iso-date (get-universal-time) t)
			    count)))))
      (close-reader))))

(defun stop-bgpstore ())