# encoding: utf-8

require 'mongo'
include Mongo

DB_BASE_NAME = "production"

main_db = MongoClient.new("localhost", 27017).db("#{DB_BASE_NAME}_#{0}")
main_bulletin = main_db["bulletins"]
main_cat =  main_db["bulletin_categories"]

copy_db = MongoClient.new("localhost", 27017).db("#{DB_BASE_NAME}_#{11}")
copy_bulletin = copy_db["bulletins"]
copy_cat =  copy_db["bulletin_categories"]


main_cat.find(key: /rss_/).each do |category|
  category_id = \
  if cat = copy_cat.find_one(key: category['key'])
    cat['_id']
  else
    copy_category = category.clone
    copy_category['_id'] = BSON::ObjectId.new
    copy_cat.save copy_category
  end

  main_bulletin.find(bulletin_category_id: category['_id']).each do |bulletin|
    unless copy_bulletin.find_one(rss_link: bulletin['rss_link'])
      copybulletin = bulletin.clone
      copybulletin['_id'] = BSON::ObjectId.new
      copybulletin['bulletin_category_id'] = category_id
      bulletin_id = copy_bulletin.save copybulletin
    end
  end
end