twitter-stream 0.9.0

extern crate serde_json as json;
extern crate tweetust;
extern crate twitter_stream;
extern crate twitter_stream_message;

use std::fs::File;
use std::path::PathBuf;
use twitter_stream::rt::{self, Future, Stream};
use twitter_stream::{Error, Token, TwitterStreamBuilder};
use twitter_stream_message::StreamMessage;

fn main() {
    const TRACK: &str = "@NAME_OF_YOUR_ACCOUNT";

    // `credential.json` must have the following form:
    // {"consumer_key": "...", "consumer_secret": "...", "access_key": "...", "access_secret": "..."}

    let mut credential_path = PathBuf::from(env!("CARGO_MANIFEST_DIR"));
    credential_path.pop();
    credential_path.push("credential.json");

    let credential = File::open(credential_path).unwrap();
    let token: Token = json::from_reader(credential).unwrap();

    let stream = TwitterStreamBuilder::filter(&token)
        .track(Some(TRACK))
        .listen()
        .flatten_stream();
    let rest = tweetust::TwitterClient::new(
        token,
        tweetust::DefaultHttpHandler::with_https_connector().unwrap(),
    );

    // Information of the authenticated user:
    let user = rest
        .account()
        .verify_credentials()
        .execute()
        .unwrap()
        .object;

    let bot = stream
        .for_each(move |json| {
            if let Ok(StreamMessage::Tweet(tweet)) = StreamMessage::from_str(&json) {
                if tweet.user.id != user.id as u64 && tweet
                    .entities
                    .user_mentions
                    .iter()
                    .any(|mention| mention.id == user.id as u64)
                {
                    println!(
                        "On {}, @{} tweeted: {:?}",
                        tweet.created_at, tweet.user.screen_name, tweet.text
                    );

                    let response = format!("@{} {}", tweet.user.screen_name, tweet.text);
                    rest.statuses()
                        .update(response)
                        .in_reply_to_status_id(tweet.id as _)
                        .execute()
                        .map_err(Error::custom)?;
                }
            }

            Ok(())
        }).map_err(|e| println!("error: {}", e));

    rt::run(bot);
}