Class: Foobara::McpConnector::JsonrpcRequest

Inherits:
CommandConnector::Request show all
Defined in:
foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb

Overview

Isolating jsonrpc specific logic to this abstract class

Direct Known Subclasses

Request

Defined Under Namespace

Classes: EmptyBatchError, InvalidJsonError, InvalidJsonrpcMethodError, InvalidJsonrpcParamsError, InvalidJsonrpcRequestStructureError, InvalidJsonrpcVersionError

Constant Summary

Constants included from TruncatedInspect

TruncatedInspect::MAX_LENGTH

Instance Attribute Summary collapse

Attributes inherited from CommandConnector::Request

#action, #authenticated_credential, #authenticated_user, #command, #command_class, #command_connector, #error, #full_command_name, #inputs, #response, #serializers

Instance Method Summary collapse

Methods inherited from CommandConnector::Request

#authenticate, #authenticator, #error_collection, #mutate_request, #outcome, #relevant_entity_classes, #response_body, #result, #serializer, #success?

Methods included from NestedTransactionable

#auto_detect_current_transactions, #commit_transaction, #commit_transaction_if_open, #open_transaction, #opened_transactions, #relevant_entity_classes, relevant_entity_classes_for_type, #relevant_entity_classes_for_type, #rollback_transaction, #transactions, #use_transaction, with_needed_transactions_for_type

Methods included from Concern

foobara_class_methods_module_for, foobara_concern?, included

Methods included from TruncatedInspect

#inspect, truncating

Constructor Details

#initialize(request_json, is_batch_child: false) ⇒ JsonrpcRequest

Returns a new instance of JsonrpcRequest.



32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 32

def initialize(request_json, *, is_batch_child: false, **, &)
  self.is_batch_child = is_batch_child
  self.raw_request_json = request_json

  set_parsed_json

  unless error
    if batch?
      self.batch = parsed_request_body.map do |request|
        self.class.new(request, *, is_batch_child: true, **, &)
      end

      validate_batch_not_empty
    else
      validate_request_structure

      unless error
        self.request_id = parsed_request_body["id"]
        verify_jsonrpc_version
      end
    end
  end

  super(*, **, &)
end

Instance Attribute Details

#batch ⇒ Object

TODO: push response into base class?



30
31
32
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 30

def batch
  @batch
end

#is_batch_child ⇒ Object

TODO: push response into base class?



30
31
32
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 30

def is_batch_child
  @is_batch_child
end

#parsed_request_body ⇒ Object

TODO: push response into base class?



30
31
32
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 30

def parsed_request_body
  @parsed_request_body
end

#raw_request_json ⇒ Object

TODO: push response into base class?



30
31
32
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 30

def raw_request_json
  @raw_request_json
end

#request_id ⇒ Object

TODO: push response into base class?



30
31
32
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 30

def request_id
  @request_id
end

Instance Method Details

#batch? ⇒ Boolean

Returns:

  • (Boolean) 


107
108
109
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 107

def batch?
  parsed_request_body.is_a?(::Array)
end

#batch_child? ⇒ Boolean

Returns:

  • (Boolean) 


91
92
93
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 91

def batch_child?
  is_batch_child
end

#error? ⇒ Boolean

TODO: push this up into foobara gem

Returns:

  • (Boolean) 


134
135
136
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 134

def error?
  !!error
end

#method ⇒ Object 



74
75
76
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 74

def method
  @method ||= parsed_request_body.is_a?(::Hash) && parsed_request_body["method"]
end

#notification? ⇒ Boolean

Returns:

  • (Boolean) 


95
96
97
98
99
100
101
102
103
104
105
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 95

def notification?
  return false if response&.status == -32_600

  if parsed_request_body
    if valid_batch?
      batch.all?(&:notification?)
    else
      parsed_request_body.is_a?(::Hash) && !parsed_request_body.key?("id")
    end
  end
end

#params ⇒ Object 



78
79
80
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 78

def params
  @params ||= parsed_request_body["params"]
end

#set_parsed_json ⇒ Object 



58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 58

def set_parsed_json
  self.parsed_request_body = if batch_child?
                               raw_request_json
                             else
                               begin
                                 JSON.parse(raw_request_json)
                               rescue => e
                                 self.error = InvalidJsonError.new(
                                   message: "Could not parse request: #{e.message}"
                                 )
                                 error.set_backtrace(caller)
                                 nil
                               end
                             end
end

#valid_batch? ⇒ Boolean

Returns:

  • (Boolean) 


111
112
113
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 111

def valid_batch?
  batch? && batch && !batch.empty?
end

#validate_batch_not_empty ⇒ Object 



115
116
117
118
119
120
121
122
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 115

def validate_batch_not_empty
  if batch? && batch.empty?
    self.error = EmptyBatchError.new(
      message: "An empty array/batch is not allowed"
    )
    error.set_backtrace(caller)
  end
end

#validate_request_structure ⇒ Object 



124
125
126
127
128
129
130
131
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 124

def validate_request_structure
  unless parsed_request_body.is_a?(::Hash)
    self.error = InvalidJsonrpcRequestStructureError.new(
      message: "Invalid jsonrpc request structure. Expected a hash but got a #{parsed_request_body.class}"
    )
    error.set_backtrace(caller)
  end
end

#verify_jsonrpc_version ⇒ Object 



82
83
84
85
86
87
88
89
 
# File 'foobara-mcp-connector-0.0.5/src/jsonrpc_request.rb', line 82

def verify_jsonrpc_version
  if parsed_request_body["jsonrpc"] != "2.0"
    self.error = InvalidJsonrpcVersionError.new(
      message: "Unsupported jsonrpc version: #{parsed_request_body["jsonrpc"]}"
    )
    error.set_backtrace(caller)
  end
end