require 'pp'
require 'solr'

require 'openrecord'
require 'bibquest/contexts/bw1'

solr = ARGV.first || 'http://localhost:8983/solr'
conn = Solr::Connection.new(solr)

buffer = []

YAML.load_documents(STDIN) do |record|
  bw_record = OpenRecord::Record.new_for_context(:bw1, record)
  buffer.push(bw_record.to_hash)
  if buffer.length >= 100
    conn.add(buffer)
    buffer.clear
  end
end

conn.add(buffer)
conn.commit
conn.optimize