/* 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);
}
*/