Contents

module TeslaApi
  module Stream
    def stream(&reciever)
      EventMachine.run do
        http.stream do |chunk|
          attributes = chunk.split(",")

          reciever.call({
              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
          })
        end

        http.callback { EventMachine.stop }
        http.errback { EventMachine.stop }
      end
    end

    private

    def request
      @request ||= EventMachine::HttpRequest.new(
          "#{stream_endpoint}/stream/#{self["vehicle_id"]}/?values=#{stream_params}")
    end

    def http
      @http ||= request.get(
          head: {
              "authorization" => [email, self["tokens"].first]
          },
          inactivity_timeout: 15)
    end

    def stream_endpoint
      "https://streaming.vn.teslamotors.com"
    end

    def stream_params
      "speed,odometer,soc,elevation,est_heading,est_lat,est_lng,power"
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
tesla_api-1.2.0	lib/tesla_api/stream.rb