class Riak::Client::BeefcakeProtobuffsBackend
  def bucket_properties_operator
    BucketPropertiesOperator.new(self)
  end


  class BucketPropertiesOperator
    attr_reader :backend

    QUORUMS = Riak::Client::ProtobuffsBackend::QUORUMS

    def initialize(backend)
      @backend = backend
    end

    def get(bucket, options={})
      response = backend.protocol do |p|
        p.write :GetBucketReq, get_request(bucket, options)
        p.expect :GetBucketResp, RpbGetBucketResp
      end

      properties = response.props.to_hash.stringify_keys

      return rubyfy(properties)
    end

    def put(bucket, props={}, options={})
      properties = riakify props

      request = put_request bucket, properties, options
      
      backend.protocol do |p|
        p.write :SetBucketReq, request
        p.expect :SetBucketResp
      end
    end

    private
    def rubyfy(received_properties)
      props = received_properties.dup

      rubyfy_quorums(props)
      rubyfy_hooks(props)
      rubyfy_modfuns(props)
      
      return props
    end

    def riakify(requested_properties)
      props = requested_properties.stringify_keys

      riakify_quorums(props)
      riakify_hooks(props)
      riakify_modfuns(props)
      riakify_repl_mode(props)

      return props
    end

    def rubyfy_quorums(props)
      %w{r pr w pw dw rw}.each do |k|
        next unless props[k]
        next unless QUORUMS.values.include? props[k]

        props[k] = QUORUMS.invert[props[k]]
      end
    end

    def riakify_quorums(props)
      %w{r pr w pw dw rw}.each do |k|
        next unless props[k]
        v = props[k].to_s
        next unless QUORUMS.keys.include? v

        props[k] = QUORUMS[v]
      end
    end

    def rubyfy_hooks(props)
      %w{precommit postcommit}.each do |k|
        next unless props[k]
        props[k] = props[k].map do |v|
          next v[:name] if v[:name]
          rubyfy_modfun(v[:modfun])
        end
      end
    end

    def riakify_hooks(props)
      %w{precommit postcommit}.each do |k|
        next unless v = props[k]

        if v.is_a? Array
          props[k] = v.map{ |e| riakify_single_hook(e) }
        else
          props[k] = [riakify_single_hook(v)]
        end
      end
    end

    def riakify_single_hook(hook)
      message = RpbCommitHook.new

      if hook.is_a? String
        message.name = hook
      elsif hook['name']
        message.name = hook['name']
      else
        message.modfun = riakify_modfun(hook)
      end
      return message
    end

    def rubyfy_modfuns(props)
      %w{chash_keyfun linkfun}.each do |k|
        next if props[k].nil?
        props[k] = rubyfy_modfun(props[k])
      end
    end

    def riakify_modfuns(props)
      %w{chash_keyfun linkfun}.each do |k|
        next if props[k].nil?
        props[k] = riakify_modfun(props[k])
      end
    end

    def rubyfy_modfun(modfun)
      { 
        'mod' => modfun[:module],
        'fun' => modfun[:function]
      }
    end

    def riakify_modfun(modfun)
      m = modfun.stringify_keys
      RpbModFun.new(module: m['mod'], function: m['fun'])
    end

    def riakify_repl_mode(props)
      return unless props['repl'].is_a? Symbol

      props['repl'] = case props['repl']
                      when :false
                        0
                      when :realtime
                        1
                      when :fullsync
                        2
                      when :true
                        3
                      end
    end
    
    def name_options(bucket)
      o = {}
      if bucket.is_a? Riak::Bucket
        o[:bucket] = bucket.name 
        o[:type] = bucket.type.name if bucket.needs_type?
      else
        o[:bucket] = bucket
      end
      
      return o
    end

    def get_request(bucket, options)
      RpbGetBucketReq.new options.merge name_options(bucket)
    end

    def put_request(bucket, props, options)
      req_options = options.merge name_options(bucket)
      req_options[:props] = RpbBucketProps.new props.symbolize_keys

      RpbSetBucketReq.new req_options
    end
  end
end