/* Author: Raphaël Velt, IRI
 * 
 * Licence: CeCILL-B - http://www.cecill.info/licences/Licence_CeCILL-B_V1-fr.html
 * 
 * */

function regexpFromText(_text) {
    return new RegExp('(' + _text.replace(/\W/gim,'\\$1') + ')','gim');
}

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.setOnAdd = function(_callback) {
    this.onAdd = _callback;
}

Btv_TweetArray.prototype.addTweet = function(_tweet) {
    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);
    if (typeof this.onAdd == "function") {
        this.onAdd(_tweet);
    }
}

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.tweetAtPos = 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 = regexpFromText(_filter);
    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 (typeof _this.onNewTweets == "function") {
                    _this.onNewTweets();
                }
            }
        });
    }
    
    
    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": 4
    });
}

Btv_TweetSource.prototype.retrieveNewTweets = function() {
    this.retrieveTweets({
        "pages": 1,
        "since_id": this.lastTweet().id_str
    });
}

Btv_TweetSource.prototype.setOnNewTweets = function(_callback) {
    this.onNewTweets = _callback;
}

Btv_TweetQueueManager = function(_tweetArray, _callback) {
    this.tweetArray = _tweetArray;
    this.majorInterval = 10000; // Time slices for calculating the minor Interval setting
    this.minimumInterval = 1000; // Safe limit to avoid tweets going to the wrong column
    this.initialBuffer = 20000; // don't start with empty columns, but show the tweets of the last 20000 seconds
    this.waitIfNoTweets = 2000;
    this.callback = _callback;
    this.lastEndTime = new Date().valueOf() - 20000;
    this.isPaused = false;
    this.onMajorInterval();
}

Btv_TweetQueueManager.prototype.onMinorInterval = function() {
    if (this.isPaused) {
        this.waitMinorInterval();
    } else {
        var _l = this.currentSlice.count();
        if (this.position < _l) {
            this.callback(this.currentSlice.tweetAtPos(this.position));
            this.position++;
            this.waitMinorInterval();
        } else {
            this.onMajorInterval();
        }
    }
}

Btv_TweetQueueManager.prototype.waitMinorInterval = function() {
    var _this = this;
    window.setTimeout(function() {
        _this.onMinorInterval();
    }, this.minorInterval);
}

Btv_TweetQueueManager.prototype.onMajorInterval = function() {
    this.position = 0;
    this.currentSlice = this.tweetArray.afterDate(this.lastEndTime);
    var _l = this.currentSlice.count();
    if (_l) {
        this.lastEndTime = this.currentSlice.tweetAtPos(_l - 1).date_value;
        this.minorInterval = Math.floor(Math.max(this.minimumInterval, this.majorInterval / _l));
        console.log("Added "+_l+" tweets to the queue, with an interval of "+this.minorInterval+" ms");
        this.onMinorInterval();
    } else {
        var _this = this;
        console.log("No tweets in the queue, waiting");
        window.setTimeout(function() {
            _this.onMajorInterval();
        }, this.waitIfNoTweets);
    }
}

Btv_TweetQueueManager.prototype.playPause = function() {
    this.isPaused = !this.isPaused;
    return this.isPaused;
}