如何刷新推特流？(Npm 模块和 Twitter API)

Question

我想刷新一个tweet流。

我有一个使用npm模块Twit制作的Twitter流(你可以在这里找到它:https://github.com/ttezel/twit)。

下面是我的代码:

Researches.find().observeChanges({
    added: function(){
        hashArray = Researches.find().fetch();
        hashCount = Researches.find().count();
        for(i=0; i<hashCount; i++){
            hashArray[i]= hashArray[i].hashtag;
        }
    }
});
stream = T.stream('statuses/filter', {track: hashArray});
//Launch stream
stream.on('tweet', Meteor.bindEnvironment(function(tweet) {
    //Get the hashtag of the tweet
    tweetText = tweet.text;
    tweetText = tweetText.toLowerCase();
    //Get the hashtag of the current tweet
    for(i=0; i<hashCount; i++){
        var hashCompare = hashArray[i];
        hashCompare = hashCompare.toLowerCase();
        var isInString = tweetText.search(hashCompare);
        if(isInString>=0)
            goodHash = hashArray[i];
    }
    // Get the tweet informations
    tweetToInsert = {
        user: tweet.user.screen_name, 
        tweet: tweet.text, 
        picture: tweet.user.profile_image_url, 
        date: new Date().getTime(),
        hashtag: goodHash
    };
    matchTweet = Tweets.findOne({tweet:tweetToInsert.tweet});
    //Store tweets
    if(matchTweet || (lastTweet.user == tweetToInsert.user) || (lastTweet.tweet == tweetToInsert.tweet)){
        
    } else {
        console.log(tweetToInsert.tweet);
        Tweets.insert(tweetToInsert, function(error) {
            if(error)
                console.log(error);
        });
    }
    //Store last tweet
    lastTweet = {
        user: tweetToInsert.user,
        tweet: tweetToInsert.tweet
    }
    //Delete tweet overflow
    nbTweet = Tweets.find({hashtag: goodHash}).count();
    tweetToDelete = nbTweet-25;
    if(nbTweet>25){
        for(i=0; i<tweetToDelete;i++){
            idDelete = Tweets.findOne({hashtag: goodHash});
            Tweets.remove(idDelete._id);
        }
    }
}));

正如你所看到的，我对我的研究集合有一个观察，我用所有的标签制作了一个数组。然后，我使用这个数组创建我的流来跟踪每个hashtag。

现在，这是我的问题。当我的集合中有一个新的标签时，我的数组用新的标签更新自己，这很好。问题是流不会自己更新。

我已经试过了

我已经尝试过。stop()流，符合Twit文档(这工作得很好)，但是当我试图用。start()重新启动他时，它不起作用。

下面是我试过的代码:

Researches.find().observeChanges({
    added: function(){
        hashArray = Researches.find().fetch();
        hashCount = Researches.find().count();
        for(i=0; i<hashCount; i++){
            hashArray[i]= hashArray[i].hashtag;
        }
        if(stream){
            stream.stop();
            stream.start();
        }
    }
});

那么，你知道如何刷新/更新tweet流或删除并创建一个新的，每次一个标签被添加到集合。由于

Answer 1

这个github问题&评论回答你的问题:https://github.com/ttezel/twit/issues/90#issuecomment-41247402

基本上你需要创建第二个流，并在刷新列表时关闭第一个流。

var Twit = require('twit');
var twit = new Twit(config);
var stream1 = twit.stream('statuses/filter', { track: [ '#yolo' ] });
// ... some time passes ...
 // initiate a new streaming connection with our updated track list
var stream2 = twit.stream('statuses/filter', { track: [ '#yolo', '#fun' ] });
stream2.once('connected', function (res) {
    console.log('second stream connected')
    // stop the first stream ASAP so twitter doesn't block us
    stream1.stop();
    stream2.on('tweet', function (tweet) {
        // handle tweets
    });
});