#!/usr/bin/env ruby
# encoding: utf-8

$: << File.expand_path('/var/www/oddb.org/src', File.dirname(__FILE__))

require 'drb'
require 'util/oddbconfig'

class RequestStub
end
##
# * ODDB::Package
#   * ODDB::Part
#     * ODDB::ActiveAgent
class PartChecker
  def initialize
    @admin = ThreadGroup.new
    req = RequestStub.new
    @request = DRb.start_service('druby://localhost:0', req)
    @app = DRbObject.new(nil, ODDB::SERVER_URI)
  end
  def count_and_delete
    result = ''
    result.extend(DRb::DRbUndumped)
    input = <<CODE
      count = 0
      each_package do |pac|
        first_agents = nil
        pac.parts.each_with_index do |part, i|
          if i == 0
            first_agents = part.active_agents
            next
          end
          if first_agents
            if part.active_agents == first_agents
              #pac.delete_part(part.odba_id)
              #part.odba_delete
              #pac.odba_store
              count += 1
            end
          end
        end
      end
      "duped parts: " + count.to_s
CODE
    $current = @app._admin(input, result)
    $current.join
    $stdout.puts result
  end
end

checker = PartChecker.new
checker.count_and_delete