lib/pubnub/events/set_state.rb in pubnub-4.0.9 vs lib/pubnub/events/set_state.rb in pubnub-4.0.12
- old
+ new
@@ -11,11 +11,15 @@
app.apply_state(self)
end
private
- def parameters
+ def current_operation
+ Pubnub::Constants::OPERATION_SET_STATE
+ end
+
+ def parameters(*_args)
parameters = super
parameters.merge!(state: encode_parameter(@state))
parameters.merge!('channel-group' => format_channel_group(@group).join(',')) unless @group.blank?
parameters
end
@@ -32,22 +36,10 @@
@app.uuid,
'data'
].join('/')
end
- def format_envelopes(response, request)
- parsed_response, error = Formatter.parse_json(response.body)
-
- error = response if parsed_response && response.code.to_i != 200
-
- if error
- error_envelope(parsed_response, error, request: request, response: response)
- else
- valid_envelope(parsed_response, request: request, response: response)
- end
- end
-
def valid_envelope(_parsed_response, req_res_objects)
Pubnub::Envelope.new(
event: @event,
event_options: @given_options,
timetoken: nil,
@@ -63,29 +55,9 @@
current_timetoken: nil,
last_timetoken: nil,
subscribed_channels: nil,
subscribed_channel_groups: nil,
-
- config: get_config
- }
- )
- end
-
- def error_envelope(_parsed_response, error, req_res_objects)
- Pubnub::ErrorEnvelope.new(
- event: @event,
- event_options: @given_options,
- timetoken: nil,
- status: {
- code: req_res_objects[:response].code,
- operation: Pubnub::Constants::OPERATION_SET_STATE,
- client_request: req_res_objects[:request],
- server_response: req_res_objects[:response],
- data: nil,
- category: (error ? Pubnub::Constants::STATUS_NON_JSON_RESPONSE : Pubnub::Constants::STATUS_ERROR),
- error: true,
- auto_retried: false,
config: get_config
}
)
end