Contents

require 'rubydora'

module ActiveFedora
  class RubydoraConnection
    
    attr_accessor :options, :connection

    def initialize(params={})
      params = params.dup
      self.options = params
      connect
    end

    def connect(force=false)
      return unless @connection.nil? or force
      allowable_options = [:url, :user, :password, :timeout, :open_timeout, :ssl_client_cert, :ssl_client_key, :validateChecksum]
      client_options = options.reject { |k,v| not allowable_options.include?(k) }
      #puts "CLIENT OPTS #{client_options.inspect}"
      @connection = Rubydora.connect client_options

      Rubydora::Transaction.after_rollback do |options|
        begin
          case options[:method]
            when :ingest
              solr = ActiveFedora::SolrService.instance.conn
              solr.delete_by_id(options[:pid])
              solr.commit
            else
              ActiveFedora::Base.find(options[:pid]).update_index
          end
        rescue
          # no-op
        end

      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
active-fedora-7.0.0.rc2	lib/active_fedora/rubydora_connection.rb
active-fedora-7.0.0.rc1	lib/active_fedora/rubydora_connection.rb
active-fedora-7.0.0.pre3	lib/active_fedora/rubydora_connection.rb
active-fedora-7.0.0.pre2	lib/active_fedora/rubydora_connection.rb
active-fedora-7.0.0.pre1	lib/active_fedora/rubydora_connection.rb