module Rhoconnect
  class SourceAdapterException < RuntimeError; end

  # raise this to cause client to be logged out during a sync
  class SourceAdapterLoginException < SourceAdapterException; end

  class SourceAdapterLogoffException < SourceAdapterException; end

  # raise these to trigger rhoconnect sending an error to the client
  class SourceAdapterServerTimeoutException < SourceAdapterException; end
  class SourceAdapterServerErrorException < SourceAdapterException; end
  
  class SourceAdapterObjectConflictError < SourceAdapterException; end

  class SourceAdapter
    attr_accessor :session
    
    def initialize(source,credential=nil)
      @source = source
    end
    
    def self.create(source,credential=nil)
      adapter=nil
      if source
        begin
          if source.name
            source.name = source.name.dup if source.name.frozen?
            source.name.strip!
          end
          # fix until source adpaters are phased out, checking for Rhoconnect namespace 
          # so that backend models with same name as Rhoconnect models are instantiated correctly
          if Object.const_defined?(source.name) && Object.const_get(source.name).to_s.split("::").first != 'Rhoconnect'
            require under_score(source.name)
            adapter=(Object.const_get(source.name)).new(source)
          else
            adapter=DynamicAdapter.new(source)
          end
        rescue ArgumentError => e
          # Backward compatibility with code generated by gems < 2.2.0
          adapter=(Object.const_get(source.name)).new(source,credential)
          log "WARNING: credential parameter in `initialize` method is deprecated and removed in version >= 2.2.0."
        rescue Exception => e
          log "Failure to create adapter from class #{source.name}: #{e.inspect.to_s}"
          raise e
        end
      end
      adapter
    end

    def login; end
  
    def query(params=nil); end
    
    def search(params=nil); end
    
    def sync
      if @result and @result.empty?
        @source.lock(:md) do |s|
          s.flash_data(:md)
          s.put_value(:md_size,0)
        end
      else
        if @result
          Store.put_data(@tmp_docname,@result) 
          @stash_size += @result.size
        end  
        @source.lock(:md) do |s|
          s.flash_data(:md)
          Store.rename(@tmp_docname,s.docname(:md))
          s.put_value(:md_size,@stash_size)
        end
      end
    end
    
    def do_query(params=nil)
      @tmp_docname = @source.docname(:md) + get_random_uuid
      @stash_size = 0
      params ? self.query(params) : self.query
      if @source.is_pass_through?
        @result
      else
        self.sync
        true
      end
    end
    
    def stash_result
      return if @result.nil?
      Store.put_data(@tmp_docname,@result,true)
      @stash_size += @result.size
      @result = nil
    end
    
    def expire_bulk_data(partition = :user)
      Rhoconnect.expire_bulk_data(current_user.login,partition)
    end
  
    def create(create_hash); end

    def update(update_hash); end

    def delete(delete_hash); end
    
    def ask(params=nil); end

    def logoff; end
    
    def save(docname)
      return if @result.nil?
      if @result.empty?
        Store.flash_data(docname)
      else
        Store.put_data(docname,@result)
      end
    end
    
    protected
    def current_user
      @source.user
    end
    
  end
end