Class: OpenC3::JsonDrbRack

Inherits:
Object show all
Defined in:
lib/openc3/io/json_drb_rack.rb

Overview

JsonDrbRack implements a rack application that can be served by a webserver to process OpenC3 json_drb requests via http.

Instance Method Summary collapse

Constructor Details

#initialize(drb) ⇒ JsonDrbRack

Returns a new instance of JsonDrbRack.

Parameters:

  • drb (JsonDRb) —

    • An instance of the JsonDRb class that'll be used

    to process the JSON request and generate a response



31
32
33
 
# File 'lib/openc3/io/json_drb_rack.rb', line 31

def initialize(drb)
  @drb = drb
end

Instance Method Details

#call(env) ⇒ Integer, ...

Handles a request.

Parameters:

  • env (Hash) —

    • A rack env hash, can be turned into a Rack::Request

Returns:

  • (Integer, Hash, [String]) —

    • Http response code, content headers,

    response body



40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/openc3/io/json_drb_rack.rb', line 40

def call(env)
  request = Rack::Request.new(env)

  if request.post?
    request_headers = Hash[*request.env.select { |k, v| k.start_with? 'HTTP_' }.sort.flatten]
    request_data = request.body.read
    status, content_type, body = handle_post(request_data, request_headers)
  else
    status       = 405
    content_type = "text/plain"
    body         = "Request not allowed"
  end

  return status, { 'Content-Type' => content_type }, [body]
end

#handle_post(request_data, request_headers) ⇒ Integer, String

Handles an http post.

Parameters:

  • request_data (String) —

    • A String of the post body from the request

  • request_headers (Hash) —

    • A Hash of the headers from the post request

Returns:

  • (Integer, String, String) —

    • Http response code, content type,

    response body.



62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
 
# File 'lib/openc3/io/json_drb_rack.rb', line 62

def handle_post(request_data, request_headers)
  response_data, error_code = @drb.process_request(
    request_data: request_data,
    request_headers: request_headers,
    start_time: Time.now.sys
  )

  # Convert json error code into html status code
  # see http://www.jsonrpc.org/historical/json-rpc-over-http.html#errors
  if error_code
    case error_code
    when JsonRpcError::ErrorCode::PARSE_ERROR      then status = 500 # Internal server error
    when JsonRpcError::ErrorCode::INVALID_REQUEST  then status = 400 # Bad request
    when JsonRpcError::ErrorCode::METHOD_NOT_FOUND then status = 404 # Not found
    when JsonRpcError::ErrorCode::INVALID_PARAMS   then status = 500 # Internal server error
    when JsonRpcError::ErrorCode::INTERNAL_ERROR   then status = 500 # Internal server error
    else status = 500 # Internal server error
    end
  else
    status = 200 # OK
  end

  return status, "application/json-rpc", response_data
end