lib/tesla_api/stream.rb in tesla_api-1.2.0 vs lib/tesla_api/stream.rb in tesla_api-1.3.0

- old
+ new

@@ -4,19 +4,23 @@ EventMachine.run do http.stream do |chunk| attributes = chunk.split(",") reciever.call({ - time: DateTime.strptime((attributes[0].to_i/1000).to_s, "%s"), + time: DateTime.strptime((attributes[0].to_i/1000).to_s, '%s'), speed: attributes[1].to_f, odometer: attributes[2].to_f, soc: attributes[3].to_f, elevation: attributes[4].to_f, est_heading: attributes[5].to_f, est_lat: attributes[6].to_f, est_lng: attributes[7].to_f, - power: attributes[8].to_f + power: attributes[8].to_f, + shift_state: attributes[9].to_s, + range: attributes[10].to_f, + est_range: attributes[11].to_f, + heading: attributes[12].to_f }) end http.callback { EventMachine.stop } http.errback { EventMachine.stop } @@ -25,25 +29,25 @@ private def request @request ||= EventMachine::HttpRequest.new( - "#{stream_endpoint}/stream/#{self["vehicle_id"]}/?values=#{stream_params}") + "#{stream_endpoint}/stream/#{self['vehicle_id']}/?values=#{stream_params}") end def http - @http ||= request.get( + request.get( head: { - "authorization" => [email, self["tokens"].first] + 'authorization' => [email, self['tokens'].first] }, inactivity_timeout: 15) end def stream_endpoint - "https://streaming.vn.teslamotors.com" + 'https://streaming.vn.teslamotors.com' end def stream_params - "speed,odometer,soc,elevation,est_heading,est_lat,est_lng,power" + 'speed,odometer,soc,elevation,est_heading,est_lat,est_lng,power,shift_state,range,est_range,heading' end end end