Class: Foobara::CommandConnector::Request

Inherits:
Object
  • Object
show all
Includes:
NestedTransactionable, TruncatedInspect
Defined in:
foobara-0.5.8/projects/command_connectors/src/command_connector/request.rb

Constant Summary

Constants included from TruncatedInspect

TruncatedInspect::MAX_LENGTH

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from NestedTransactionable

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

Methods included from TruncatedInspect

#inspect, truncating

Constructor Details

#initialize(**opts) ⇒ Request

Returns a new instance of Request.



23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 23

def initialize(**opts)
  valid_keys = [:inputs, :full_command_name, :action, :serializers, :authenticator, :auth_mappers]

  invalid_keys = opts.keys - valid_keys

  unless invalid_keys.empty?
    # :nocov:
    raise ArgumentError, "invalid keys: #{invalid_keys} expected only #{valid_keys}"
    # :nocov:
  end

  self.inputs = opts[:inputs] if opts.key?(:inputs)
  self.action = opts[:action] if opts.key?(:action)
  self.auth_mappers = opts[:auth_mappers] if opts.key?(:auth_mappers)
  self.authenticator = opts[:authenticator] if opts.key?(:authenticator)
  self.full_command_name = opts[:full_command_name] if opts.key?(:full_command_name)
  self.serializers = Util.array(opts[:serializers]) if opts.key?(:serializers)
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(method_name) ⇒ Object 



86
87
88
89
90
91
92
93
94
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 86

def method_missing(method_name, ...)
  if auth_mapped_method?(method_name)
    auth_mapped_value_for(method_name)
  else
    # :nocov:
    super
    # :nocov:
  end
end

Instance Attribute Details

#action ⇒ Object

TODO: this feels like a smell of some sort…



8
9
10
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 8

def action
  @action
end

#auth_mappers ⇒ Object

TODO: this feels like a smell of some sort…



8
9
10
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 8

def auth_mappers
  @auth_mappers
end

#authenticated_credential ⇒ Object

TODO: this feels like a smell of some sort…



8
9
10
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 8

def authenticated_credential
  @authenticated_credential
end

#authenticated_user ⇒ Object

TODO: this feels like a smell of some sort…



8
9
10
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 8

def authenticated_user
  @authenticated_user
end

#authenticator ⇒ Object

TODO: this feels like a smell of some sort…



8
9
10
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 8

def authenticator
  @authenticator
end

#command ⇒ Object

TODO: this feels like a smell of some sort…



8
9
10
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 8

def command
  @command
end

#command_class ⇒ Object

TODO: this feels like a smell of some sort…



8
9
10
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 8

def command_class
  @command_class
end

#command_connector ⇒ Object

TODO: this feels like a smell of some sort…



8
9
10
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 8

def command_connector
  @command_connector
end

#error ⇒ Object

TODO: this feels like a smell of some sort…



8
9
10
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 8

def error
  @error
end

#full_command_name ⇒ Object

TODO: this feels like a smell of some sort…



8
9
10
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 8

def full_command_name
  @full_command_name
end

#inputs ⇒ Object

TODO: this feels like a smell of some sort…



8
9
10
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 8

def inputs
  @inputs
end

#response ⇒ Object

TODO: this feels like a smell of some sort…



8
9
10
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 8

def response
  @response
end

#serializers ⇒ Object

TODO: this feels like a smell of some sort…



8
9
10
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 8

def serializers
  @serializers
end

Instance Method Details

#auth_mapped_method?(method_name) ⇒ Boolean

Returns:

  • (Boolean) 


66
67
68
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 66

def auth_mapped_method?(method_name)
  auth_mappers&.key?(method_name)
end

#auth_mapped_value_for(name) ⇒ Object 



74
75
76
77
78
79
80
81
82
83
84
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 74

def auth_mapped_value_for(name)
  return unless authenticated_user

  @auth_mapper_cache ||= {}

  if @auth_mapper_cache.key?(name)
    @auth_mapper_cache[name]
  else
    @auth_mapper_cache[name] = auth_mapper_for(name)&.process_value!(authenticated_user)
  end
end

#auth_mapper_for(name) ⇒ Object 



70
71
72
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 70

def auth_mapper_for(name)
  auth_mappers&.[](name.to_sym)
end

#authenticate ⇒ Object 



51
52
53
54
55
56
57
58
59
60
61
62
63
64
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 51

def authenticate
  return if error
  return unless command_class.respond_to?(:requires_authentication) && command_class.requires_authentication

  authenticated_user, authenticated_credential = authenticator.authenticate(self)

  # TODO: why are these on the command instead of the request??
  self.authenticated_user = authenticated_user
  self.authenticated_credential = authenticated_credential

  unless authenticated_user
    self.error = CommandConnector::UnauthenticatedError.new
  end
end

#error_collection ⇒ Object 



146
147
148
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 146

def error_collection
  outcome.error_collection
end

#mutate_request ⇒ Object 



42
43
44
45
46
47
48
49
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 42

def mutate_request
  return if error

  # TODO: we really need to revisit these interfaces. Something is wrong.
  if command_class.respond_to?(:mutate_request)
    command_class.mutate_request(self)
  end
end

#outcome ⇒ Object 



134
135
136
137
138
139
140
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 134

def outcome
  if error
    Outcome.error(error)
  else
    command&.outcome
  end
end

#relevant_entity_classes ⇒ Object

TODO: move this to entity_plumbing



151
152
153
154
155
156
157
158
159
160
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 151

def relevant_entity_classes
  if command_class.is_a?(::Class) && command_class < TransformedCommand
    if authenticator.respond_to?(:relevant_entity_classes)
      entity_classes = authenticator.relevant_entity_classes(self)
      [*entity_classes, *relevant_entity_classes_from_inputs_transformer]
    else
      relevant_entity_classes_from_inputs_transformer
    end
  end || EMPTY_ARRAY
end

#respond_to_missing?(method_name, private = false) ⇒ Boolean

Returns:

  • (Boolean) 


96
97
98
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 96

def respond_to_missing?(method_name, private = false)
  auth_mapped_method?(method_name) || super
end

#response_body ⇒ Object 



117
118
119
120
121
122
123
124
125
126
127
128
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 117

def response_body
  @response_body ||= begin
    # TODO: should we have separate ways to register success and failure serializers?
    body = success? ? result : error_collection

    if serializer
      serializer.process_value!(body)
    else
      body
    end
  end
end

#result ⇒ Object 



142
143
144
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 142

def result
  outcome.result
end

#serializer ⇒ Object 



100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 100

def serializer
  return @serializer if defined?(@serializer)

  if serializers.nil? || serializers.empty?
    @serializer = nil
    return
  end

  actual_serializers = objects_to_serializers(serializers)

  @serializer = if actual_serializers.size == 1
                  actual_serializers.first
                else
                  Value::Processor::Pipeline.new(processors: actual_serializers)
                end
end

#success? ⇒ Boolean

Returns:

  • (Boolean) 


130
131
132
 
# File 'projects/command_connectors/src/command_connector/request.rb', line 130

def success?
  outcome.success?
end