Class: Radiator::ErrorParser

Inherits:
Object
  • Object
show all
Includes:
Utils
Defined in:
lib/radiator/error_parser.rb

Constant Summary collapse

REPREPARE_WHITELIST =
[
  'is_canonical( c ): signature is not canonical',
  'now < trx.expiration: '
]
DUPECHECK =
'(skip & skip_transaction_dupe_check) || trx_idx.indices().get<by_trx_id>().find(trx_id) == trx_idx.indices().get<by_trx_id>().end(): Duplicate transaction check failed'
REPREPARE_BLACKLIST =
[DUPECHECK]

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Utils

#extract_signatures, #hexlify, #pakArr, #pakC, #pakHash, #pakI, #pakL!, #pakS, #pakStr, #pakc, #paks, #send_log, #unhexlify, #varint, #warning

Constructor Details

#initialize(response) ⇒ ErrorParser

Returns a new instance of ErrorParser.



24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
# File 'lib/radiator/error_parser.rb', line 24

def initialize(response)
  @response = response
  
  @error = nil
  @error_code = nil
  @error_message = nil
  @api_name = nil
  @api_method = nil
  @api_params = nil
  
  @expiry = nil
  @can_retry = nil
  @can_reprepare = nil
  @trx_id = nil
  @debug = nil
  
  parse_error_response
end

Instance Attribute Details

#api_methodObject (readonly)

Returns the value of attribute api_method.



7
8
9
# File 'lib/radiator/error_parser.rb', line 7

def api_method
  @api_method
end

#api_nameObject (readonly)

Returns the value of attribute api_name.



7
8
9
# File 'lib/radiator/error_parser.rb', line 7

def api_name
  @api_name
end

#api_paramsObject (readonly)

Returns the value of attribute api_params.



7
8
9
# File 'lib/radiator/error_parser.rb', line 7

def api_params
  @api_params
end

#can_reprepareObject (readonly) Also known as: can_reprepare?

Returns the value of attribute can_reprepare.



7
8
9
# File 'lib/radiator/error_parser.rb', line 7

def can_reprepare
  @can_reprepare
end

#can_retryObject (readonly) Also known as: can_retry?

Returns the value of attribute can_retry.



7
8
9
# File 'lib/radiator/error_parser.rb', line 7

def can_retry
  @can_retry
end

#debugObject (readonly)

Returns the value of attribute debug.



7
8
9
# File 'lib/radiator/error_parser.rb', line 7

def debug
  @debug
end

#errorObject (readonly)

Returns the value of attribute error.



7
8
9
# File 'lib/radiator/error_parser.rb', line 7

def error
  @error
end

#error_codeObject (readonly)

Returns the value of attribute error_code.



7
8
9
# File 'lib/radiator/error_parser.rb', line 7

def error_code
  @error_code
end

#error_messageObject (readonly)

Returns the value of attribute error_message.



7
8
9
# File 'lib/radiator/error_parser.rb', line 7

def error_message
  @error_message
end

#expiryObject (readonly) Also known as: expiry?

Returns the value of attribute expiry.



7
8
9
# File 'lib/radiator/error_parser.rb', line 7

def expiry
  @expiry
end

#responseObject (readonly)

Returns the value of attribute response.



7
8
9
# File 'lib/radiator/error_parser.rb', line 7

def response
  @response
end

#trx_idObject (readonly)

Returns the value of attribute trx_id.



7
8
9
# File 'lib/radiator/error_parser.rb', line 7

def trx_id
  @trx_id
end

Instance Method Details

#inspectObject



137
138
139
# File 'lib/radiator/error_parser.rb', line 137

def inspect
  "#<#{self.class.name} [#{to_s}]>"
end

#parse_error_responseObject



43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
# File 'lib/radiator/error_parser.rb', line 43

def parse_error_response
  if response.nil?
    @expiry = false
    @can_retry = false
    @can_reprepare = false
    
    return
  end
  
  @response = JSON[response] if response.class == String

  @error = if !!@response['error']
    response['error']
  else
    response
  end

  begin
    @error_code = @error['data']['code']
    stacks = @error['data']['stack']
    stack_formats = stacks.map { |s| s['format'] }
    stack_datum = stacks.map { |s| s['data'] }
    data_call_method = stack_datum.find { |data| data['call.method'] == 'call' }
    
    @error_message = stack_formats.reject(&:empty?).join('; ')
    
    @api_name, @api_method, @api_params = if !!data_call_method
      @api_name = data_call_method['call.params']
    end
    
    # See if we can recover a transaction id out of this hot mess.
    data_trx_ix = stack_datum.find { |data| !!data['trx_ix'] }
    @trx_id = data_trx_ix['trx_ix'] if !!data_trx_ix
    
    case @error_code
    when 10
      @expiry = false
      @can_retry = false
      @can_reprepare = if @api_name == 'network_broadcast_api'
        (stack_formats & REPREPARE_WHITELIST).any?
      else
        false
      end
    when 13
      @error_message = @error['data']['message']
      @expiry = false
      @can_retry = false
      @can_reprepare = false
    when 3030000
      @error_message = @error['data']['message']
      @expiry = false
      @can_retry = false
      @can_reprepare = false
    when 4030100
      # Code 4030100 is "transaction_expiration_exception: transaction
      # expiration exception".  If we assume the expiration was valid, the
      # node might be bad and needs to be dropped.
      
      @expiry = true
      @can_retry = true
      @can_reprepare = false
    when 4030200
      # Code 4030200 is "transaction tapos exception".  They are recoverable
      # if the transaction hasn't expired yet.  A tapos exception can be
      # retried in situations where the node is behind and the tapos is
      # based on a block the node doesn't know about yet.
      
      @expiry = false
      @can_retry = true
      
      # Allow fall back to reprepare if retry fails.
      @can_reprepare = true
    else
      @expiry = false
      @can_retry = false
      @can_reprepare = false
    end
  rescue => e
    ap error_perser_exception: e, original_response: response
    
    @expiry = false
    @can_retry = false
    @can_reprepare = false
  end
end

#to_sObject



129
130
131
132
133
134
135
# File 'lib/radiator/error_parser.rb', line 129

def to_s
  if !!error_message && !error_message.empty?
    "#{error_code}: #{error_message}"
  else
    error_code.to_s
  end
end