An Erlang client for the Twitter Streaming API.
Important notice: As is this library isn't currently usable since Twitter deprecated basic auth. OAuth support is WIP, see the oauth branch and issue for further details.
You probably want to include it as a depedency in Rebar:
{deps,
[
{twerl, ".*", {git, "https://github.com/lucaspiller/twerl.git", "master"}},
]
}.
Generate auth headers:
Headers = stream_client_util:generate_auth_headers(TwitterUsername, TwitterPassword).
Generate params:
{ok, Params} = stream_client_util:keywords_to_track(["erlang"]).
Build a callback function:
Callback = fun(Data) ->
Tweet = proplists:get_value(<<"text">>, Data),
io:format("Erlang <3: ~s~n", [Tweet])
end.
Start streaming:
stream_client:connect(stream_client_util:filter_url(), Headers, Params, Callback).
The function stream_client:connect/4
blocks, and only returns once the stream ends. You can use the manager which is a simple gen_server which wraps the functionality and adds some nice additions, such as allowing you to change filter params and the callback.
Start the manager:
stream_client_manager:start_link(awesomeness).
Set auth headers:
Headers = stream_client_util:generate_auth_headers(TwitterUsername, TwitterPassword),
stream_client_manager:set_headers(awesomeness, Headers).
Set params:
{ok, Params} = stream_client_util:keywords_to_track(["erlang"]),
stream_client_manager:set_params(awesomeness, Params).
Start streaming (you can set a callback after, and change it without losing data):
stream_client_manager:start_stream(awesomeness).
Set a callback:
stream_client_manager:set_callback(awesomeness, fun(Data) ->
Tweet = proplists:get_value(<<"text">>, Data),
io:format("Erlang <3: ~s~n", [Tweet])
end).
Stop streaming:
stream_client_manager:stop_stream(awesomeness).
Stop the manager:
stream_client_manager:stop(awesomeness).
One of the goals is to be able to change the filter params without losing any data. This is still WIP as data could be lost or duplicated.
Start an Erlang shell with reloader support:
make dev
Compile new code:
make compile
Run tests (written in espec):
make test
CHANGELOG.md
describing your change.MIT License. See LICENSE.md
for details.
Copyright (c) 2011-2013 Luca Spiller.