Handle streaming messages about extwitter

[parroty]

Yes, I haven't been able to support these message types yet... Thinking to add an option to receive messages in addition to standard tweet payloads, as existing I/F just sends tweets.

like,

pid = spawn(fn ->
  stream = ExTwitter.stream_filter(track: "twitter", receive_messages: true)
  for message <- stream do
    case message do
      tweet = %ExTwitter.Tweet{} ->
        IO.puts tweet.text
      warning = %ExTwitter.Streaming.StallWarning{} ->
        IO.puts warning.code
    end
  end
end)

or something.

[parroty]

I've pushed experimental implementation for several message, but haven't been able to test all of the message. In the case you know good way to test (reproduce message), please let me know.

[mroth]

Which messages have you not been able to reproduce? I can look into trying to help generate them.

[parroty]

Thanks. I think I couldn't reproduce stall warning, though I tried with slowing down stream read (through sleeping). At the moment, I implemented / tested based on the example in the twitter page in the above.

[mroth]

Did you send stall_warnings: true parameter to Twitter endpoint when initiating the stream? Looks like perhaps they only send them in that case (and only once "about every 5 minutes" which means they may not be consistent..).

(That said, the mocked test for this looks good to me!)

[parroty]

Thanks for the information. I wasn't aware about the 5 minutes part, so retried with the following and left for a while. But seems not receiving (though not sure if this sleep is reasonable).

stream = ExTwitter.stream_filter(track: "twitter", stall_warnings: true, receive_messages: true)
for message <- stream do
  case message do
     warning = %ExTwitter.Model.StallWarning{} ->
       IO.inspect warning
     _ ->
       :timer.sleep(1000)
  end
end

Please let me close at the moment (with mock test), and reopen if any issue are found.