/* Author: Raphaël Velt, IRI

 * 

 * Licence: CeCILL-B - http://www.cecill.info/licences/Licence_CeCILL-B_V1-fr.html

 * 

 * */

Btv_TweetArray = function() {

    this.tweets = [];

    this.idIndex = [];

}

Btv_TweetArray.prototype.push = function(_tweet) {

    this.tweets.push(_tweet);

    this.idIndex.push(_tweet.id_str);

}

Btv_TweetArray.prototype.addTweet = function(_tweet, _inhibitCallback) {

    if (this.idIndex.indexOf(_tweet.id_str) != -1) {

        return;

    }

    if (!_tweet.date_value) {

        _tweet.date_value = Date.parse(_tweet.created_at.replace(/(\+|-)/,'UTC$1'));

    }

    var _pos = this.tweets.length;

    while (_pos && this.idIndex[_pos - 1] > _tweet.id_str) {

        _pos--;

    }

    this.tweets.splice(_pos,0,_tweet);

    this.idIndex.splice(_pos,0,_tweet.id_str);

}

Btv_TweetArray.prototype.addMultipleTweets = function(_multiTweets) {

    var _l = _multiTweets.length;

    for (var _i = 0; _i < _l; _i++) {

        this.addTweet(_multiTweets[_i], true);

    }

}

Btv_TweetArray.prototype.count = function() {

    return this.tweets.length;

}

Btv_TweetArray.prototype.getTweet = function(_i) {

    return this.tweets(_i);

}

Btv_TweetArray.prototype.slice = function(_start, _end) {

    var _slice = this.tweets.slice(_start, _end),

        _result = new Btv_TweetArray(),

        _l = _slice.length;

    for (var _i = 0; _i < _l; _i++) {

        _result.push(_slice[_i]);

    }

    return _result;

}

Btv_TweetArray.prototype.reverse = function() {

    var _result = new Btv_TweetArray(),

        _l = this.tweets.length;

    for (var _i = _l-1; _i >= 0; _i--) {

        _result.push(this.tweets[_i]);

    }

    return _result;

}

Btv_TweetArray.prototype.each = function(_callback) {

    var _l = this.count();

    for (var _i = 0; _i < _l; _i++) {

        _callback(this.tweets[_i]);

    }

}

Btv_TweetArray.prototype.map = function(_callback) {

    var _result = [];

    this.each(function(_tweet) {

        _result.push(_callback(_tweet))

    });

    return _result;

}

Btv_TweetArray.prototype.search = function(_filter) {

    var _filtered = new Btv_TweetArray(),

        _reFilter = new RegExp(_filter.replace(/\W/gim,'\\$1'),'gim');

    this.each(function(_tweet) {

        var _mention = '@' + _tweet.from_user;

        if (( _tweet.text.search(_reFilter) != -1 ) || ( _mention.search(_reFilter) != -1 )) {

            _filtered.push(_tweet);

        }

    });

    return _filtered;

}

Btv_TweetArray.prototype.beforeDate = function(_date) {

    var _filtered = new Btv_TweetArray();

    this.each(function(_tweet) {

        if (_tweet.date_value < _date) {

            _filtered.push(_tweet);

        }

    });

    return _filtered;

}

Btv_TweetArray.prototype.afterDate = function(_date) {

    var _filtered = new Btv_TweetArray();

    this.each(function(_tweet) {

        if (_tweet.date_value > _date) {

            _filtered.push(_tweet);

        }

    });

    return _filtered;

}

Btv_TweetArray.prototype.tweetById = function(_tweetId) {

    var _index = this.idIndex.indexOf(_tweetId);

    return (_index ? this.tweets[_index] : null);

}

Btv_TweetArray.prototype.lastTweet = function() {

    return this.tweets[this.tweets.length - 1];

}

/*

 * 

 */

Btv_TweetSource = function(_opts) {

    Btv_TweetArray.call(this);

    this.loading = false;

    if (!_opts || !_opts.keywords || !_opts.keywords.length) {

        return;

    }

    this.options = _opts;

    var _this = this;

    this.retrieveInitialTweets()

    setInterval(function() {

        _this.retrieveNewTweets();

    }, 5000);

}

Btv_TweetSource.prototype = new Btv_TweetArray();

Btv_TweetSource.prototype.retrieveTweets = function(_opts) {

    function getTwitterUrl(url) {

        $.getJSON(url, function(data) {

            _currentPage++;

            var _isLast = true;

            if (data.results && data.results.length) {

                _this.addMultipleTweets(data.results);

                var _oldestTweetId = data.results[data.results.length - 1].id_str,

                    _maxId = _oldestTweetId;

                if (_currentPage < _opts.pages) {

                    _isLast = false;

                    getTwitterUrl(_baseurl + _firstparams + '&max_id=' + _maxId + _lastparams);

                }

            }

            if (_isLast) {

                _this.loading = false;

                if (_this.tweetsCallback) {

                    _this.tweetsCallback();

                }

            }

        });

    }

    if (this.loading) {

        return;

    }

    this.loading = true;

    var _baseurl = "http://search.twitter.com/search.json",

        _currentPage = 0,

        _firstparams = "?q="

            + encodeURIComponent(this.options.keywords.join(' OR '))

            + "&rpp=100"

            + (this.options.lang ? "&lang=" + this.options.lang : '' ),

        _lastparams = ( _opts.since_id ? "&since_id=" + _opts.since_id : '' )

            + "&callback=?",

        _jsonurl = _baseurl + _firstparams + _lastparams,

        _this = this;

    getTwitterUrl(_jsonurl);

}

Btv_TweetSource.prototype.retrieveInitialTweets = function() {

    this.retrieveTweets({

        "pages": 6

    });

}

Btv_TweetSource.prototype.retrieveNewTweets = function() {

    this.retrieveTweets({

        "pages": 1,

        "since_id": this.lastTweet().id_str

    });

}

Btv_TweetArray.prototype.setTweetsCallback = function(_callback) {

    this.tweetsCallback = _callback;

}

/*

Btv_TweetSubscriber = function(tweetArray) {

    this.tweetArray = tweetArray;

    this.position = 0;

}

Btv_TweetSubscriber.getTweets = function() {

    var _p = this.position,

        _l = this.tweetArray.count();

    this.position = _l;

    return this.tweetArray.slice(_p,_l);

}

*/