class ActiveFedora::File

def self.relation
  FileRelation.new(self)
end

def ==(comparison_object)
  super ||
    comparison_object.instance_of?(self.class) &&
    uri.value.present? &&
    comparison_object.uri == uri
end

def attribute_will_change!(attr)
  if attr == 'content'
    changed_attributes['content'] = true
  else
    super
  end
end

def behaves_like_io?(obj)
  [IO, Tempfile, StringIO].any? { |klass| obj.kind_of? klass } || (defined?(Rack) && obj.is_a?(Rack::Test::UploadedFile))
end

def build_ldp_resource(id)
  build_ldp_resource_via_uri self.class.id_to_uri(id)
end

def build_ldp_resource_via_uri(uri=nil, content='')
  Ldp::Resource::BinarySource.new(ldp_connection, uri, content, ActiveFedora.fedora.host + ActiveFedora.fedora.base_path)
end

def changed?
  super || content_changed?
end

def check_fixity
  FixityService.new(@ldp_source.subject).check
end

def content
  local_or_remote_content(true)
end

def content= string_or_io
  content_will_change! unless @content == string_or_io
  @content = string_or_io
end

def content_changed?
  return true if new_record? and !local_or_remote_content(false).blank?
  local_or_remote_content(false) != @ds_content
end

def create_record(options = {})
  return false if content.nil?
  ldp_source.content = content
  ldp_source.create do |req|
    req.headers.merge!(ldp_headers)
  end
  refresh
end

def datastream_will_change!
  attribute_will_change! :profile
end

def described_by
  raise "#{self} isn't persisted yet" if new_record?
  links['describedby'].first
end

def exists!
  @exists = true
end

def freeze
  @frozen = true
end

def frozen?
  !!@frozen
end

def initialize(parent_or_url_or_hash = nil, path=nil, options={}, &block)
  case parent_or_url_or_hash
  when Hash
    @ldp_source = build_ldp_resource_via_uri
  when nil, String, ::RDF::URI
    @ldp_source = build_ldp_resource_via_uri parent_or_url_or_hash
  when ActiveFedora::Base
    Deprecation.warn File, "Initializing a file by passing a container is deprecated. Initialize with a uri instead. This capability will be removed in active-fedora 10.0"
    uri = if parent_or_url_or_hash.uri.kind_of?(::RDF::URI) && parent_or_url_or_hash.uri.value.empty?
      nil
    else
      "#{parent_or_url_or_hash.uri}/#{path}"
    end
    @ldp_source = build_ldp_resource_via_uri(uri, nil)
  else
    raise "The first argument to #{self} must be a String or an ActiveFedora::Base. You provided a #{parent_or_url_or_hash.class}"
  end
  @attributes = {}.with_indifferent_access
  yield self if block_given?
end

def inspect
  "#<#{self.class} uri=\"#{uri}\" >"
end

def ldp_connection
  ActiveFedora.fedora.connection
end

def ldp_headers
  headers = { 'Content-Type'.freeze => mime_type, 'Content-Length'.freeze => content.size.to_s }
  headers['Content-Disposition'.freeze] = "attachment; filename=\"#{URI.encode(@original_name)}\"" if @original_name
  headers
end

def ldp_source
  @ldp_source || raise("NO source")
end

def local_or_remote_content(ensure_fetch = true)
  return @content if new_record?
  @content ||= ensure_fetch ? remote_content : @ds_content
  if behaves_like_io?(@content)
    begin
      @content.rewind
      @content.read
    ensure
      @content.rewind
    end
  else
    @content
  end
  @content
end

def metadata
  @metadata ||= ActiveFedora::WithMetadata::MetadataNode.new(self)
end

def metadata?
  false
end

def new_record?
  !@exists && ldp_source.new?
end

def prefix(path)
  path ? "#{path.underscore}__" : ''
end

def readonly?
  false
end

def refresh
  @ldp_source = build_ldp_resource_via_uri(uri)
  @original_name = nil
  @mime_type = nil
  @content = nil
  @metadata = nil
  changed_attributes.clear
end

def reload
  return if new_record?
  refresh
end

def remote_content
  return if new_record?
  @ds_content ||= retrieve_content
end

def retrieve_content
  ldp_source.get.body
end

def serialize!
end

def to_solr(solr_doc={}, opts={})
  solr_doc
end

def update_record(options = {})
  return true unless content_changed?
  ldp_source.content = content
  ldp_source.update do |req|
    req.headers.merge!(ldp_headers)
  end
  refresh
end

def uploaded_file?(payload)
  defined?(ActionDispatch::Http::UploadedFile) and payload.instance_of?(ActionDispatch::Http::UploadedFile)
end

def uri= uri
  @ldp_source = build_ldp_resource_via_uri(uri)
end