Contents

# frozen_string_literal: true

require_relative './protocol'

module DigitalFabric
  class RequestAdapter
    def initialize(agent, msg)
      @agent = agent
      @id = msg['id']
    end

    def protocol
      'df'
    end

    def get_body_chunk
      @agent.get_http_request_body(@id, 1)
    end

    def consume_request
      @agent.get_http_request_body(@id, nil)
    end

    def respond(body, headers)
      @agent.send_df_message(
        Protocol.http_response(@id, body, headers, true)
      )
    end

    def send_headers(headers, opts = {})
      @agent.send_df_message(
        Protocol.http_response(@id, nil, headers, false)
      )
  end

    def send_chunk(body, done: )
      @agent.send_df_message(
        Protocol.http_response(@id, body, nil, done)
      )
    end

    def finish
      @agent.send_df_message(
        Protocol.http_response(@id, nil, nil, true)
      )
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
tipi-0.38	lib/tipi/digital_fabric/request_adapter.rb
tipi-0.37.2	lib/tipi/digital_fabric/request_adapter.rb
tipi-0.37.1	lib/tipi/digital_fabric/request_adapter.rb
tipi-0.37	lib/tipi/digital_fabric/request_adapter.rb
tipi-0.36	lib/tipi/digital_fabric/request_adapter.rb
tipi-0.35	lib/tipi/digital_fabric/request_adapter.rb
tipi-0.34	lib/tipi/digital_fabric/request_adapter.rb