Added centrifuge (websocket) support for thread autoupdate. Only websocket version is supported for now

boards/static/js/3party/centrifuge.js

@@ -0,0 +1,1256 b''
+/**
+ * Centrifuge javascript client
+ * v0.5.2
+ */
+;(function () {
+    'use strict';
+
+    /**
+     * Oliver Caldwell
+     * http://oli.me.uk/2013/06/01/prototypical-inheritance-done-right/
+     */
+
+    if (!Object.create) {
+        Object.create = (function(){
+            function F(){}
+
+            return function(o){
+                if (arguments.length != 1) {
+                    throw new Error('Object.create implementation only accepts one parameter.');
+                }
+                F.prototype = o;
+                return new F()
+            }
+        })()
+    }
+
+    if (!Array.prototype.indexOf) {
+        Array.prototype.indexOf = function (searchElement /*, fromIndex */) {
+            'use strict';
+            if (this == null) {
+                throw new TypeError();
+            }
+            var n, k, t = Object(this),
+                len = t.length >>> 0;
+
+            if (len === 0) {
+                return -1;
+            }
+            n = 0;
+            if (arguments.length > 1) {
+                n = Number(arguments[1]);
+                if (n != n) { // shortcut for verifying if it's NaN
+                    n = 0;
+                } else if (n != 0 && n != Infinity && n != -Infinity) {
+                    n = (n > 0 || -1) * Math.floor(Math.abs(n));
+                }
+            }
+            if (n >= len) {
+                return -1;
+            }
+            for (k = n >= 0 ? n : Math.max(len - Math.abs(n), 0); k < len; k++) {
+                if (k in t && t[k] === searchElement) {
+                    return k;
+                }
+            }
+            return -1;
+        };
+    }
+
+    function extend(destination, source) {
+        destination.prototype = Object.create(source.prototype);
+        destination.prototype.constructor = destination;
+        return source.prototype;
+    }
+
+    /**
+     * EventEmitter v4.2.3 - git.io/ee
+     * Oliver Caldwell
+     * MIT license
+     * @preserve
+     */
+
+    /**
+     * Class for managing events.
+     * Can be extended to provide event functionality in other classes.
+     *
+     * @class EventEmitter Manages event registering and emitting.
+     */
+    function EventEmitter() {}
+
+    // Shortcuts to improve speed and size
+
+    // Easy access to the prototype
+    var proto = EventEmitter.prototype;
+
+    /**
+     * Finds the index of the listener for the event in it's storage array.
+     *
+     * @param {Function[]} listeners Array of listeners to search through.
+     * @param {Function} listener Method to look for.
+     * @return {Number} Index of the specified listener, -1 if not found
+     * @api private
+     */
+    function indexOfListener(listeners, listener) {
+        var i = listeners.length;
+        while (i--) {
+            if (listeners[i].listener === listener) {
+                return i;
+            }
+        }
+
+        return -1;
+    }
+
+    /**
+     * Alias a method while keeping the context correct, to allow for overwriting of target method.
+     *
+     * @param {String} name The name of the target method.
+     * @return {Function} The aliased method
+     * @api private
+     */
+    function alias(name) {
+        return function aliasClosure() {
+            return this[name].apply(this, arguments);
+        };
+    }
+
+    /**
+     * Returns the listener array for the specified event.
+     * Will initialise the event object and listener arrays if required.
+     * Will return an object if you use a regex search. The object contains keys for each matched event. So /ba[rz]/ might return an object containing bar and baz. But only if you have either defined them with defineEvent or added some listeners to them.
+     * Each property in the object response is an array of listener functions.
+     *
+     * @param {String|RegExp} evt Name of the event to return the listeners from.
+     * @return {Function[]|Object} All listener functions for the event.
+     */
+    proto.getListeners = function getListeners(evt) {
+        var events = this._getEvents();
+        var response;
+        var key;
+
+        // Return a concatenated array of all matching events if
+        // the selector is a regular expression.
+        if (typeof evt === 'object') {
+            response = {};
+            for (key in events) {
+                if (events.hasOwnProperty(key) && evt.test(key)) {
+                    response[key] = events[key];
+                }
+            }
+        }
+        else {
+            response = events[evt] || (events[evt] = []);
+        }
+
+        return response;
+    };
+
+    /**
+     * Takes a list of listener objects and flattens it into a list of listener functions.
+     *
+     * @param {Object[]} listeners Raw listener objects.
+     * @return {Function[]} Just the listener functions.
+     */
+    proto.flattenListeners = function flattenListeners(listeners) {
+        var flatListeners = [];
+        var i;
+
+        for (i = 0; i < listeners.length; i += 1) {
+            flatListeners.push(listeners[i].listener);
+        }
+
+        return flatListeners;
+    };
+
+    /**
+     * Fetches the requested listeners via getListeners but will always return the results inside an object. This is mainly for internal use but others may find it useful.
+     *
+     * @param {String|RegExp} evt Name of the event to return the listeners from.
+     * @return {Object} All listener functions for an event in an object.
+     */
+    proto.getListenersAsObject = function getListenersAsObject(evt) {
+        var listeners = this.getListeners(evt);
+        var response;
+
+        if (listeners instanceof Array) {
+            response = {};
+            response[evt] = listeners;
+        }
+
+        return response || listeners;
+    };
+
+    /**
+     * Adds a listener function to the specified event.
+     * The listener will not be added if it is a duplicate.
+     * If the listener returns true then it will be removed after it is called.
+     * If you pass a regular expression as the event name then the listener will be added to all events that match it.
+     *
+     * @param {String|RegExp} evt Name of the event to attach the listener to.
+     * @param {Function} listener Method to be called when the event is emitted. If the function returns true then it will be removed after calling.
+     * @return {Object} Current instance of EventEmitter for chaining.
+     */
+    proto.addListener = function addListener(evt, listener) {
+        var listeners = this.getListenersAsObject(evt);
+        var listenerIsWrapped = typeof listener === 'object';
+        var key;
+
+        for (key in listeners) {
+            if (listeners.hasOwnProperty(key) && indexOfListener(listeners[key], listener) === -1) {
+                listeners[key].push(listenerIsWrapped ? listener : {
+                    listener: listener,
+                    once: false
+                });
+            }
+        }
+
+        return this;
+    };
+
+    /**
+     * Alias of addListener
+     */
+    proto.on = alias('addListener');
+
+    /**
+     * Semi-alias of addListener. It will add a listener that will be
+     * automatically removed after it's first execution.
+     *
+     * @param {String|RegExp} evt Name of the event to attach the listener to.
+     * @param {Function} listener Method to be called when the event is emitted. If the function returns true then it will be removed after calling.
+     * @return {Object} Current instance of EventEmitter for chaining.
+     */
+    proto.addOnceListener = function addOnceListener(evt, listener) {
+        //noinspection JSValidateTypes
+        return this.addListener(evt, {
+            listener: listener,
+            once: true
+        });
+    };
+
+    /**
+     * Alias of addOnceListener.
+     */
+    proto.once = alias('addOnceListener');
+
+    /**
+     * Defines an event name. This is required if you want to use a regex to add a listener to multiple events at once. If you don't do this then how do you expect it to know what event to add to? Should it just add to every possible match for a regex? No. That is scary and bad.
+     * You need to tell it what event names should be matched by a regex.
+     *
+     * @param {String} evt Name of the event to create.
+     * @return {Object} Current instance of EventEmitter for chaining.
+     */
+    proto.defineEvent = function defineEvent(evt) {
+        this.getListeners(evt);
+        return this;
+    };
+
+    /**
+     * Uses defineEvent to define multiple events.
+     *
+     * @param {String[]} evts An array of event names to define.
+     * @return {Object} Current instance of EventEmitter for chaining.
+     */
+    proto.defineEvents = function defineEvents(evts) {
+        for (var i = 0; i < evts.length; i += 1) {
+            this.defineEvent(evts[i]);
+        }
+        return this;
+    };
+
+    /**
+     * Removes a listener function from the specified event.
+     * When passed a regular expression as the event name, it will remove the listener from all events that match it.
+     *
+     * @param {String|RegExp} evt Name of the event to remove the listener from.
+     * @param {Function} listener Method to remove from the event.
+     * @return {Object} Current instance of EventEmitter for chaining.
+     */
+    proto.removeListener = function removeListener(evt, listener) {
+        var listeners = this.getListenersAsObject(evt);
+        var index;
+        var key;
+
+        for (key in listeners) {
+            if (listeners.hasOwnProperty(key)) {
+                index = indexOfListener(listeners[key], listener);
+
+                if (index !== -1) {
+                    listeners[key].splice(index, 1);
+                }
+            }
+        }
+
+        return this;
+    };
+
+    /**
+     * Alias of removeListener
+     */
+    proto.off = alias('removeListener');
+
+    /**
+     * Adds listeners in bulk using the manipulateListeners method.
+     * If you pass an object as the second argument you can add to multiple events at once. The object should contain key value pairs of events and listeners or listener arrays. You can also pass it an event name and an array of listeners to be added.
+     * You can also pass it a regular expression to add the array of listeners to all events that match it.
+     * Yeah, this function does quite a bit. That's probably a bad thing.
+     *
+     * @param {String|Object|RegExp} evt An event name if you will pass an array of listeners next. An object if you wish to add to multiple events at once.
+     * @param {Function[]} [listeners] An optional array of listener functions to add.
+     * @return {Object} Current instance of EventEmitter for chaining.
+     */
+    proto.addListeners = function addListeners(evt, listeners) {
+        // Pass through to manipulateListeners
+        return this.manipulateListeners(false, evt, listeners);
+    };
+
+    /**
+     * Removes listeners in bulk using the manipulateListeners method.
+     * If you pass an object as the second argument you can remove from multiple events at once. The object should contain key value pairs of events and listeners or listener arrays.
+     * You can also pass it an event name and an array of listeners to be removed.
+     * You can also pass it a regular expression to remove the listeners from all events that match it.
+     *
+     * @param {String|Object|RegExp} evt An event name if you will pass an array of listeners next. An object if you wish to remove from multiple events at once.
+     * @param {Function[]} [listeners] An optional array of listener functions to remove.
+     * @return {Object} Current instance of EventEmitter for chaining.
+     */
+    proto.removeListeners = function removeListeners(evt, listeners) {
+        // Pass through to manipulateListeners
+        return this.manipulateListeners(true, evt, listeners);
+    };
+
+    /**
+     * Edits listeners in bulk. The addListeners and removeListeners methods both use this to do their job. You should really use those instead, this is a little lower level.
+     * The first argument will determine if the listeners are removed (true) or added (false).
+     * If you pass an object as the second argument you can add/remove from multiple events at once. The object should contain key value pairs of events and listeners or listener arrays.
+     * You can also pass it an event name and an array of listeners to be added/removed.
+     * You can also pass it a regular expression to manipulate the listeners of all events that match it.
+     *
+     * @param {Boolean} remove True if you want to remove listeners, false if you want to add.
+     * @param {String|Object|RegExp} evt An event name if you will pass an array of listeners next. An object if you wish to add/remove from multiple events at once.
+     * @param {Function[]} [listeners] An optional array of listener functions to add/remove.
+     * @return {Object} Current instance of EventEmitter for chaining.
+     */
+    proto.manipulateListeners = function manipulateListeners(remove, evt, listeners) {
+        var i;
+        var value;
+        var single = remove ? this.removeListener : this.addListener;
+        var multiple = remove ? this.removeListeners : this.addListeners;
+
+        // If evt is an object then pass each of it's properties to this method
+        if (typeof evt === 'object' && !(evt instanceof RegExp)) {
+            for (i in evt) {
+                if (evt.hasOwnProperty(i) && (value = evt[i])) {
+                    // Pass the single listener straight through to the singular method
+                    if (typeof value === 'function') {
+                        single.call(this, i, value);
+                    }
+                    else {
+                        // Otherwise pass back to the multiple function
+                        multiple.call(this, i, value);
+                    }
+                }
+            }
+        }
+        else {
+            // So evt must be a string
+            // And listeners must be an array of listeners
+            // Loop over it and pass each one to the multiple method
+            i = listeners.length;
+            while (i--) {
+                single.call(this, evt, listeners[i]);
+            }
+        }
+
+        return this;
+    };
+
+    /**
+     * Removes all listeners from a specified event.
+     * If you do not specify an event then all listeners will be removed.
+     * That means every event will be emptied.
+     * You can also pass a regex to remove all events that match it.
+     *
+     * @param {String|RegExp} [evt] Optional name of the event to remove all listeners for. Will remove from every event if not passed.
+     * @return {Object} Current instance of EventEmitter for chaining.
+     */
+    proto.removeEvent = function removeEvent(evt) {
+        var type = typeof evt;
+        var events = this._getEvents();
+        var key;
+
+        // Remove different things depending on the state of evt
+        if (type === 'string') {
+            // Remove all listeners for the specified event
+            delete events[evt];
+        }
+        else if (type === 'object') {
+            // Remove all events matching the regex.
+            for (key in events) {
+                //noinspection JSUnresolvedFunction
+                if (events.hasOwnProperty(key) && evt.test(key)) {
+                    delete events[key];
+                }
+            }
+        }
+        else {
+            // Remove all listeners in all events
+            delete this._events;
+        }
+
+        return this;
+    };
+
+    /**
+     * Emits an event of your choice.
+     * When emitted, every listener attached to that event will be executed.
+     * If you pass the optional argument array then those arguments will be passed to every listener upon execution.
+     * Because it uses `apply`, your array of arguments will be passed as if you wrote them out separately.
+     * So they will not arrive within the array on the other side, they will be separate.
+     * You can also pass a regular expression to emit to all events that match it.
+     *
+     * @param {String|RegExp} evt Name of the event to emit and execute listeners for.
+     * @param {Array} [args] Optional array of arguments to be passed to each listener.
+     * @return {Object} Current instance of EventEmitter for chaining.
+     */
+    proto.emitEvent = function emitEvent(evt, args) {
+        var listeners = this.getListenersAsObject(evt);
+        var listener;
+        var i;
+        var key;
+        var response;
+
+        for (key in listeners) {
+            if (listeners.hasOwnProperty(key)) {
+                i = listeners[key].length;
+
+                while (i--) {
+                    // If the listener returns true then it shall be removed from the event
+                    // The function is executed either with a basic call or an apply if there is an args array
+                    listener = listeners[key][i];
+
+                    if (listener.once === true) {
+                        this.removeListener(evt, listener.listener);
+                    }
+
+                    response = listener.listener.apply(this, args || []);
+
+                    if (response === this._getOnceReturnValue()) {
+                        this.removeListener(evt, listener.listener);
+                    }
+                }
+            }
+        }
+
+        return this;
+    };
+
+    /**
+     * Alias of emitEvent
+     */
+    proto.trigger = alias('emitEvent');
+
+    //noinspection JSValidateJSDoc,JSCommentMatchesSignature
+    /**
+     * Subtly different from emitEvent in that it will pass its arguments on to the listeners, as opposed to taking a single array of arguments to pass on.
+     * As with emitEvent, you can pass a regex in place of the event name to emit to all events that match it.
+     *
+     * @param {String|RegExp} evt Name of the event to emit and execute listeners for.
+     * @param {...*} Optional additional arguments to be passed to each listener.
+     * @return {Object} Current instance of EventEmitter for chaining.
+     */
+    proto.emit = function emit(evt) {
+        var args = Array.prototype.slice.call(arguments, 1);
+        return this.emitEvent(evt, args);
+    };
+
+    /**
+     * Sets the current value to check against when executing listeners. If a
+     * listeners return value matches the one set here then it will be removed
+     * after execution. This value defaults to true.
+     *
+     * @param {*} value The new value to check for when executing listeners.
+     * @return {Object} Current instance of EventEmitter for chaining.
+     */
+    proto.setOnceReturnValue = function setOnceReturnValue(value) {
+        this._onceReturnValue = value;
+        return this;
+    };
+
+    /**
+     * Fetches the current value to check against when executing listeners. If
+     * the listeners return value matches this one then it should be removed
+     * automatically. It will return true by default.
+     *
+     * @return {*|Boolean} The current value to check for or the default, true.
+     * @api private
+     */
+    proto._getOnceReturnValue = function _getOnceReturnValue() {
+        if (this.hasOwnProperty('_onceReturnValue')) {
+            return this._onceReturnValue;
+        }
+        else {
+            return true;
+        }
+    };
+
+    /**
+     * Fetches the events object and creates one if required.
+     *
+     * @return {Object} The events storage object.
+     * @api private
+     */
+    proto._getEvents = function _getEvents() {
+        return this._events || (this._events = {});
+    };
+
+    /**
+     * Mixes in the given objects into the target object by copying the properties.
+     * @param deep if the copy must be deep
+     * @param target the target object
+     * @param objects the objects whose properties are copied into the target
+     */
+    function mixin(deep, target, objects) {
+        var result = target || {};
+
+        // Skip first 2 parameters (deep and target), and loop over the others
+        for (var i = 2; i < arguments.length; ++i) {
+            var object = arguments[i];
+
+            if (object === undefined || object === null) {
+                continue;
+            }
+
+            for (var propName in object) {
+                //noinspection JSUnfilteredForInLoop
+                var prop = fieldValue(object, propName);
+                //noinspection JSUnfilteredForInLoop
+                var targ = fieldValue(result, propName);
+
+                // Avoid infinite loops
+                if (prop === target) {
+                    continue;
+                }
+                // Do not mixin undefined values
+                if (prop === undefined) {
+                    continue;
+                }
+
+                if (deep && typeof prop === 'object' && prop !== null) {
+                    if (prop instanceof Array) {
+                        //noinspection JSUnfilteredForInLoop
+                        result[propName] = mixin(deep, targ instanceof Array ? targ : [], prop);
+                    } else {
+                        var source = typeof targ === 'object' && !(targ instanceof Array) ? targ : {};
+                        //noinspection JSUnfilteredForInLoop
+                        result[propName] = mixin(deep, source, prop);
+                    }
+                } else {
+                    //noinspection JSUnfilteredForInLoop
+                    result[propName] = prop;
+                }
+            }
+        }
+
+        return result;
+    }
+
+    function fieldValue(object, name) {
+        try {
+            return object[name];
+        } catch (x) {
+            return undefined;
+        }
+    }
+
+    function endsWith(value, suffix) {
+        return value.indexOf(suffix, value.length - suffix.length) !== -1;
+    }
+
+    function stripSlash(value) {
+        if (value.substring(value.length - 1) == "/") {
+            value = value.substring(0, value.length - 1);
+        }
+        return value;
+    }
+
+    function isString(value) {
+        if (value === undefined || value === null) {
+            return false;
+        }
+        return typeof value === 'string' || value instanceof String;
+    }
+
+    function isFunction(value) {
+        if (value === undefined || value === null) {
+            return false;
+        }
+        return typeof value === 'function';
+    }
+
+    function log(level, args) {
+        if (window.console) {
+            var logger = window.console[level];
+            if (isFunction(logger)) {
+                logger.apply(window.console, args);
+            }
+        }
+    }
+
+    function Centrifuge(options) {
+        this._sockjs = false;
+        this._status = 'disconnected';
+        this._reconnect = true;
+        this._transport = null;
+        this._messageId = 0;
+        this._clientId = null;
+        this._subscriptions = {};
+        this._messages = [];
+        this._isBatching = false;
+        this._config = {
+            retry: 3000,
+            info: null,
+            debug: false,
+            server: null,
+            protocols_whitelist: [
+                'websocket',
+                'xdr-streaming',
+                'xhr-streaming',
+                'iframe-eventsource',
+                'iframe-htmlfile',
+                'xdr-polling',
+                'xhr-polling',
+                'iframe-xhr-polling',
+                'jsonp-polling'
+            ]
+        };
+        if (options) {
+            this.configure(options);
+        }
+    }
+
+    extend(Centrifuge, EventEmitter);
+
+    var centrifuge_proto = Centrifuge.prototype;
+
+    centrifuge_proto._debug = function () {
+        if (this._config.debug === true) {
+            log('debug', arguments);
+        }
+    };
+
+    centrifuge_proto._configure = function (configuration) {
+        this._debug('Configuring centrifuge object with', configuration);
+
+        if (!configuration) {
+            configuration = {};
+        }
+
+        this._config = mixin(false, this._config, configuration);
+
+        if (!this._config.url) {
+            throw 'Missing required configuration parameter \'url\' specifying the Centrifuge server URL';
+        }
+
+        if (!this._config.token) {
+            throw 'Missing required configuration parameter \'token\' specifying the sign of authorization request';
+        }
+
+        if (!this._config.project) {
+            throw 'Missing required configuration parameter \'project\' specifying project ID in Centrifuge';
+        }
+
+        if (!this._config.user && this._config.user !== '') {
+            throw 'Missing required configuration parameter \'user\' specifying user\'s unique ID in your application';
+        }
+
+        if (!this._config.timestamp) {
+            throw 'Missing required configuration parameter \'timestamp\'';
+        }
+
+        this._config.url = stripSlash(this._config.url);
+
+        if (endsWith(this._config.url, 'connection')) {
+            //noinspection JSUnresolvedVariable
+            if (typeof window.SockJS === 'undefined') {
+                throw 'You need to include SockJS client library before Centrifuge javascript client library or use pure Websocket connection endpoint';
+            }
+            this._sockjs = true;
+        }
+    };
+
+    centrifuge_proto._setStatus = function (newStatus) {
+        if (this._status !== newStatus) {
+            this._debug('Status', this._status, '->', newStatus);
+            this._status = newStatus;
+        }
+    };
+
+    centrifuge_proto._isDisconnected = function () {
+        return this._isConnected() === false;
+    };
+
+    centrifuge_proto._isConnected = function () {
+        return this._status === 'connected';
+    };
+
+    centrifuge_proto._nextMessageId = function () {
+        return ++this._messageId;
+    };
+
+    centrifuge_proto._clearSubscriptions = function () {
+        this._subscriptions = {};
+    };
+
+    centrifuge_proto._send = function (messages) {
+        // We must be sure that the messages have a clientId.
+        // This is not guaranteed since the handshake may take time to return
+        // (and hence the clientId is not known yet) and the application
+        // may create other messages.
+        for (var i = 0; i < messages.length; ++i) {
+            var message = messages[i];
+            message.uid = '' + this._nextMessageId();
+
+            if (this._clientId) {
+                message.clientId = this._clientId;
+            }
+
+            this._debug('Send', message);
+            this._transport.send(JSON.stringify(message));
+        }
+    };
+
+    centrifuge_proto._connect = function (callback) {
+
+        this._clientId = null;
+
+        this._reconnect = true;
+
+        this._clearSubscriptions();
+
+        this._setStatus('connecting');
+
+        var self = this;
+
+        if (callback) {
+            this.on('connect', callback);
+        }
+
+        if (this._sockjs === true) {
+            //noinspection JSUnresolvedFunction
+            var sockjs_options = {
+                protocols_whitelist: this._config.protocols_whitelist
+            };
+            if (this._config.server !== null) {
+                sockjs_options['server'] = this._config.server;
+            }
+
+            this._transport = new SockJS(this._config.url, null, sockjs_options);
+
+        } else {
+            this._transport = new WebSocket(this._config.url);
+        }
+
+        this._setStatus('connecting');
+
+        this._transport.onopen = function () {
+
+            var centrifugeMessage = {
+                'method': 'connect',
+                'params': {
+                    'token': self._config.token,
+                    'user': self._config.user,
+                    'project': self._config.project,
+                    'timestamp': self._config.timestamp
+                }
+            };
+
+            if (self._config.info !== null) {
+                self._debug("connect using additional info");
+                centrifugeMessage['params']['info'] = self._config.info;
+            } else {
+                self._debug("connect without additional info");
+            }
+            self.send(centrifugeMessage);
+        };
+
+        this._transport.onerror = function (error) {
+            self._debug(error);
+        };
+
+        this._transport.onclose = function () {
+            self._setStatus('disconnected');
+            self.trigger('disconnect');
+            if (self._reconnect === true) {
+                window.setTimeout(function () {
+                    if (self._reconnect === true) {
+                        self._connect.call(self);
+                    }
+                }, self._config.retry);
+            }
+        };
+
+        this._transport.onmessage = function (event) {
+            var data;
+            data = JSON.parse(event.data);
+            self._debug('Received', data);
+            self._receive(data);
+        };
+    };
+
+    centrifuge_proto._disconnect = function () {
+        this._clientId = null;
+        this._setStatus('disconnected');
+        this._subscriptions = {};
+        this._reconnect = false;
+        this._transport.close();
+    };
+
+    centrifuge_proto._getSubscription = function (channel) {
+        var subscription;
+        subscription = this._subscriptions[channel];
+        if (!subscription) {
+            return null;
+        }
+        return subscription;
+    };
+
+    centrifuge_proto._removeSubscription = function (channel) {
+        try {
+            delete this._subscriptions[channel];
+        } catch (e) {
+            this._debug('nothing to delete for channel ', channel);
+        }
+    };
+
+    centrifuge_proto._connectResponse = function (message) {
+        if (message.error === null) {
+            this._clientId = message.body;
+            this._setStatus('connected');
+            this.trigger('connect', [message]);
+        } else {
+            this.trigger('error', [message]);
+            this.trigger('connect:error', [message]);
+        }
+    };
+
+    centrifuge_proto._disconnectResponse = function (message) {
+        if (message.error === null) {
+            this.disconnect();
+            //this.trigger('disconnect', [message]);
+            //this.trigger('disconnect:success', [message]);
+        } else {
+            this.trigger('error', [message]);
+            this.trigger('disconnect:error', [message.error]);
+        }
+    };
+
+    centrifuge_proto._subscribeResponse = function (message) {
+        if (message.error !== null) {
+            this.trigger('error', [message]);
+        }
+        var body = message.body;
+        if (body === null) {
+            return;
+        }
+        var channel = body.channel;
+        var subscription = this.getSubscription(channel);
+        if (!subscription) {
+            return;
+        }
+        if (message.error === null) {
+            subscription.trigger('subscribe:success', [body]);
+            subscription.trigger('ready', [body]);
+        } else {
+            subscription.trigger('subscribe:error', [message.error]);
+            subscription.trigger('error', [message]);
+        }
+    };
+
+    centrifuge_proto._unsubscribeResponse = function (message) {
+        var body = message.body;
+        var channel = body.channel;
+        var subscription = this.getSubscription(channel);
+        if (!subscription) {
+            return;
+        }
+        if (message.error === null) {
+            subscription.trigger('unsubscribe', [body]);
+            this._centrifuge._removeSubscription(channel);
+        }
+    };
+
+    centrifuge_proto._publishResponse = function (message) {
+        var body = message.body;
+        var channel = body.channel;
+        var subscription = this.getSubscription(channel);
+        if (!subscription) {
+            return;
+        }
+        if (message.error === null) {
+            subscription.trigger('publish:success', [body]);
+        } else {
+            subscription.trigger('publish:error', [message.error]);
+            this.trigger('error', [message]);
+        }
+    };
+
+    centrifuge_proto._presenceResponse = function (message) {
+        var body = message.body;
+        var channel = body.channel;
+        var subscription = this.getSubscription(channel);
+        if (!subscription) {
+            return;
+        }
+        if (message.error === null) {
+            subscription.trigger('presence', [body]);
+            subscription.trigger('presence:success', [body]);
+        } else {
+            subscription.trigger('presence:error', [message.error]);
+            this.trigger('error', [message]);
+        }
+    };
+
+    centrifuge_proto._historyResponse = function (message) {
+        var body = message.body;
+        var channel = body.channel;
+        var subscription = this.getSubscription(channel);
+        if (!subscription) {
+            return;
+        }
+        if (message.error === null) {
+            subscription.trigger('history', [body]);
+            subscription.trigger('history:success', [body]);
+        } else {
+            subscription.trigger('history:error', [message.error]);
+            this.trigger('error', [message]);
+        }
+    };
+
+    centrifuge_proto._joinResponse = function(message) {
+        var body = message.body;
+        var channel = body.channel;
+        var subscription = this.getSubscription(channel);
+        if (!subscription) {
+            return;
+        }
+        subscription.trigger('join', [body]);
+    };
+
+    centrifuge_proto._leaveResponse = function(message) {
+        var body = message.body;
+        var channel = body.channel;
+        var subscription = this.getSubscription(channel);
+        if (!subscription) {
+            return;
+        }
+        subscription.trigger('leave', [body]);
+    };
+
+    centrifuge_proto._messageResponse = function (message) {
+        var body = message.body;
+        var channel = body.channel;
+        var subscription = this.getSubscription(channel);
+        if (subscription === null) {
+            return;
+        }
+        subscription.trigger('message', [body]);
+    };
+
+    centrifuge_proto._dispatchMessage = function(message) {
+        if (message === undefined || message === null) {
+            return;
+        }
+
+        var method = message.method;
+
+        if (!method) {
+            return;
+        }
+
+        switch (method) {
+            case 'connect':
+                this._connectResponse(message);
+                break;
+            case 'disconnect':
+                this._disconnectResponse(message);
+                break;
+            case 'subscribe':
+                this._subscribeResponse(message);
+                break;
+            case 'unsubscribe':
+                this._unsubscribeResponse(message);
+                break;
+            case 'publish':
+                this._publishResponse(message);
+                break;
+            case 'presence':
+                this._presenceResponse(message);
+                break;
+            case 'history':
+                this._historyResponse(message);
+                break;
+            case 'join':
+                this._joinResponse(message);
+                break;
+            case 'leave':
+                this._leaveResponse(message);
+                break;
+            case 'ping':
+                break;
+            case 'message':
+                this._messageResponse(message);
+                break;
+            default:
+                break;
+        }
+    };
+
+    centrifuge_proto._receive = function (data) {
+        if (Object.prototype.toString.call(data) === Object.prototype.toString.call([])) {
+            for (var i in data) {
+                if (data.hasOwnProperty(i)) {
+                    var msg = data[i];
+                    this._dispatchMessage(msg);
+                }
+            }
+        } else if (Object.prototype.toString.call(data) === Object.prototype.toString.call({})) {
+            this._dispatchMessage(data);
+        }
+    };
+
+    centrifuge_proto._flush = function() {
+        var messages = this._messages.slice(0);
+        this._messages = [];
+        this._send(messages);
+    };
+
+    centrifuge_proto._ping = function () {
+        var centrifugeMessage = {
+            "method": "ping",
+            "params": {}
+        };
+        this.send(centrifugeMessage);
+    };
+
+    /* PUBLIC API */
+
+    centrifuge_proto.getClientId = function () {
+        return this._clientId;
+    };
+
+    centrifuge_proto.isConnected = centrifuge_proto._isConnected;
+
+    centrifuge_proto.isDisconnected = centrifuge_proto._isDisconnected;
+
+    centrifuge_proto.configure = function (configuration) {
+        this._configure.call(this, configuration);
+    };
+
+    centrifuge_proto.connect = centrifuge_proto._connect;
+
+    centrifuge_proto.disconnect = centrifuge_proto._disconnect;
+
+    centrifuge_proto.getSubscription = centrifuge_proto._getSubscription;
+
+    centrifuge_proto.ping = centrifuge_proto._ping;
+
+    centrifuge_proto.send = function (message) {
+        if (this._isBatching === true) {
+            this._messages.push(message);
+        } else {
+            this._send([message]);
+        }
+    };
+
+    centrifuge_proto.startBatching = function () {
+        // start collecting messages without sending them to Centrifuge until flush
+        // method called
+        this._isBatching = true;
+    };
+
+    centrifuge_proto.stopBatching = function(flush) {
+        // stop collecting messages
+        flush = flush || false;
+        this._isBatching = false;
+        if (flush === true) {
+            this.flush();
+        }
+    };
+
+    centrifuge_proto.flush = function() {
+        this._flush();
+    };
+
+    centrifuge_proto.subscribe = function (channel, callback) {
+
+        if (arguments.length < 1) {
+            throw 'Illegal arguments number: required 1, got ' + arguments.length;
+        }
+        if (!isString(channel)) {
+            throw 'Illegal argument type: channel must be a string';
+        }
+        if (this.isDisconnected()) {
+            throw 'Illegal state: already disconnected';
+        }
+
+        var current_subscription = this.getSubscription(channel);
+
+        if (current_subscription !== null) {
+            return current_subscription;
+        } else {
+            var subscription = new Subscription(this, channel);
+            this._subscriptions[channel] = subscription;
+            subscription.subscribe(callback);
+            return subscription;
+        }
+    };
+
+    centrifuge_proto.unsubscribe = function (channel) {
+        if (arguments.length < 1) {
+            throw 'Illegal arguments number: required 1, got ' + arguments.length;
+        }
+        if (!isString(channel)) {
+            throw 'Illegal argument type: channel must be a string';
+        }
+        if (this.isDisconnected()) {
+            return;
+        }
+
+        var subscription = this.getSubscription(channel);
+        if (subscription !== null) {
+            subscription.unsubscribe();
+        }
+    };
+
+    centrifuge_proto.publish = function (channel, data, callback) {
+        var subscription = this.getSubscription(channel);
+        if (subscription === null) {
+            this._debug("subscription not found for channel " + channel);
+            return null;
+        }
+        subscription.publish(data, callback);
+        return subscription;
+    };
+
+    centrifuge_proto.presence = function (channel, callback) {
+        var subscription = this.getSubscription(channel);
+        if (subscription === null) {
+            this._debug("subscription not found for channel " + channel);
+            return null;
+        }
+        subscription.presence(callback);
+        return subscription;
+    };
+
+    centrifuge_proto.history = function (channel, callback) {
+        var subscription = this.getSubscription(channel);
+        if (subscription === null) {
+            this._debug("subscription not found for channel " + channel);
+            return null;
+        }
+        subscription.history(callback);
+        return subscription;
+    };
+
+    function Subscription(centrifuge, channel) {
+        /**
+         * The constructor for a centrifuge object, identified by an optional name.
+         * The default name is the string 'default'.
+         * @param name the optional name of this centrifuge object
+         */
+        this._centrifuge = centrifuge;
+        this.channel = channel;
+    }
+
+    extend(Subscription, EventEmitter);
+
+    var sub_proto = Subscription.prototype;
+
+    sub_proto.getChannel = function () {
+        return this.channel;
+    };
+
+    sub_proto.getCentrifuge = function () {
+        return this._centrifuge;
+    };
+
+    sub_proto.subscribe = function (callback) {
+        var centrifugeMessage = {
+            "method": "subscribe",
+            "params": {
+                "channel": this.channel
+            }
+        };
+        this._centrifuge.send(centrifugeMessage);
+        if (callback) {
+            this.on('message', callback);
+        }
+    };
+
+    sub_proto.unsubscribe = function () {
+        this._centrifuge._removeSubscription(this.channel);
+        var centrifugeMessage = {
+            "method": "unsubscribe",
+            "params": {
+                "channel": this.channel
+            }
+        };
+        this._centrifuge.send(centrifugeMessage);
+    };
+
+    sub_proto.publish = function (data, callback) {
+        var centrifugeMessage = {
+            "method": "publish",
+            "params": {
+                "channel": this.channel,
+                "data": data
+            }
+        };
+        if (callback) {
+            this.on('publish:success', callback);
+        }
+        this._centrifuge.send(centrifugeMessage);
+    };
+
+    sub_proto.presence = function (callback) {
+        var centrifugeMessage = {
+            "method": "presence",
+            "params": {
+                "channel": this.channel
+            }
+        };
+        if (callback) {
+            this.on('presence', callback);
+        }
+        this._centrifuge.send(centrifugeMessage);
+    };
+
+    sub_proto.history = function (callback) {
+        var centrifugeMessage = {
+            "method": "history",
+            "params": {
+                "channel": this.channel
+            }
+        };
+        if (callback) {
+            this.on('history', callback);
+        }
+        this._centrifuge.send(centrifugeMessage);
+    };
+
+    // Expose the class either via AMD, CommonJS or the global object
+    if (typeof define === 'function' && define.amd) {
+        define(function () {
+            return Centrifuge;
+        });
+    } else if (typeof module === 'object' && module.exports) {
+        //noinspection JSUnresolvedVariable
+        module.exports = Centrifuge;
+    } else {
+        //noinspection JSUnusedGlobalSymbols
+        this.Centrifuge = Centrifuge;
+    }
+
+}.call(this));

boards/middlewares.py

@@ -1,46 +1,45 b''
 from django.shortcuts import redirect
 from boards import utils
 from boards.models import Ban
 from django.utils.html import strip_spaces_between_tags
 from django.conf import settings
-from boards.views.banned import BannedView
 
 RESPONSE_CONTENT_TYPE = 'Content-Type'
 
 TYPE_HTML = 'text/html'
 
 
 class BanMiddleware:
     """
     This is run before showing the thread. Banned users don't need to see
     anything
     """
 
     def __init__(self):
         pass
 
     def process_view(self, request, view_func, view_args, view_kwargs):
 
-        if view_func != BannedView.as_view:
+        if request.path != '/banned/':
             ip = utils.get_client_ip(request)
             bans = Ban.objects.filter(ip=ip)
 
             if bans.exists():
                 ban = bans[0]
                 if not ban.can_read:
                     return redirect('banned')
 
 
 class MinifyHTMLMiddleware(object):
     def process_response(self, request, response):
         try:
             compress_html = settings.COMPRESS_HTML
         except AttributeError:
             compress_html = False
 
         if RESPONSE_CONTENT_TYPE in response\
                 and TYPE_HTML in response[RESPONSE_CONTENT_TYPE]\
                 and compress_html:
             response.content = strip_spaces_between_tags(
                 response.content.strip())
         return response
  No newline at end of file

boards/models/post.py

@@ -1,346 +1,417 b''
 from datetime import datetime, timedelta, date
 from datetime import time as dtime
+from adjacent import Client
 import logging
 import re
 
 from django.core.cache import cache
 from django.core.urlresolvers import reverse
 from django.db import models, transaction
+from django.shortcuts import get_object_or_404
+from django.template import RequestContext
 from django.template.loader import render_to_string
 from django.utils import timezone
 from markupfield.fields import MarkupField
+from boards import settings
 
 from boards.models import PostImage
 from boards.models.base import Viewable
 from boards.models.thread import Thread
+from boards.utils import datetime_to_epoch
 
+WS_CHANNEL_THREAD = "thread:"
 
 APP_LABEL_BOARDS = 'boards'
 
 CACHE_KEY_PPD = 'ppd'
 CACHE_KEY_POST_URL = 'post_url'
 
 POSTS_PER_DAY_RANGE = 7
 
 BAN_REASON_AUTO = 'Auto'
 
 IMAGE_THUMB_SIZE = (200, 150)
 
 TITLE_MAX_LENGTH = 200
 
 DEFAULT_MARKUP_TYPE = 'bbcode'
 
 # TODO This should be removed
 NO_IP = '0.0.0.0'
 
 # TODO Real user agent should be saved instead of this
 UNKNOWN_UA = ''
 
 REGEX_REPLY = re.compile(r'\[post\](\d+)\[/post\]')
 
+PARAMETER_TRUNCATED = 'truncated'
+PARAMETER_TAG = 'tag'
+PARAMETER_OFFSET = 'offset'
+PARAMETER_DIFF_TYPE = 'type'
+
+DIFF_TYPE_HTML = 'html'
+DIFF_TYPE_JSON = 'json'
+
 logger = logging.getLogger(__name__)
 
 
 class PostManager(models.Manager):
     def create_post(self, title, text, image=None, thread=None, ip=NO_IP,
                     tags=None):
         """
         Creates new post
         """
 
         if not tags:
             tags = []
 
         posting_time = timezone.now()
         if not thread:
             thread = Thread.objects.create(bump_time=posting_time,
                                            last_edit_time=posting_time)
             new_thread = True
         else:
             thread.bump()
             thread.last_edit_time = posting_time
             thread.save()
             new_thread = False
 
         post = self.create(title=title,
                            text=text,
                            pub_time=posting_time,
                            thread_new=thread,
                            poster_ip=ip,
                            poster_user_agent=UNKNOWN_UA,  # TODO Get UA at
                            # last!
                            last_edit_time=posting_time)
 
         logger.info('Created post #%d with title "%s"' % (post.id,
                                                         post.title))
 
         if image:
             post_image = PostImage.objects.create(image=image)
             post.images.add(post_image)
             logger.info('Created image #%d for post #%d' % (post_image.id,
                                                             post.id))
 
         thread.replies.add(post)
         list(map(thread.add_tag, tags))
 
         if new_thread:
             Thread.objects.process_oldest_threads()
         self.connect_replies(post)
 
         return post
 
     def delete_post(self, post):
         """
         Deletes post and update or delete its thread
         """
 
         post_id = post.id
 
         thread = post.get_thread()
 
         if post.is_opening():
             thread.delete()
         else:
             thread.last_edit_time = timezone.now()
             thread.save()
 
             post.delete()
 
         logger.info('Deleted post #%d (%s)' % (post_id, post.get_title()))
 
     def delete_posts_by_ip(self, ip):
         """
         Deletes all posts of the author with same IP
         """
 
         posts = self.filter(poster_ip=ip)
         for post in posts:
             self.delete_post(post)
 
-    def connect_replies(self, post):
+    def  connect_replies(self, post):
         """
         Connects replies to a post to show them as a reflink map
         """
 
         for reply_number in re.finditer(REGEX_REPLY, post.text.raw):
             post_id = reply_number.group(1)
             ref_post = self.filter(id=post_id)
             if ref_post.count() > 0:
                 referenced_post = ref_post[0]
                 referenced_post.referenced_posts.add(post)
                 referenced_post.last_edit_time = post.pub_time
                 referenced_post.build_refmap()
                 referenced_post.save(update_fields=['refmap', 'last_edit_time'])
 
                 referenced_thread = referenced_post.get_thread()
                 referenced_thread.last_edit_time = post.pub_time
                 referenced_thread.save(update_fields=['last_edit_time'])
 
     def get_posts_per_day(self):
         """
         Gets average count of posts per day for the last 7 days
         """
 
         day_end = date.today()
         day_start = day_end - timedelta(POSTS_PER_DAY_RANGE)
 
         cache_key = CACHE_KEY_PPD + str(day_end)
         ppd = cache.get(cache_key)
         if ppd:
             return ppd
 
         day_time_start = timezone.make_aware(datetime.combine(
             day_start, dtime()), timezone.get_current_timezone())
         day_time_end = timezone.make_aware(datetime.combine(
             day_end, dtime()), timezone.get_current_timezone())
 
         posts_per_period = float(self.filter(
             pub_time__lte=day_time_end,
             pub_time__gte=day_time_start).count())
 
         ppd = posts_per_period / POSTS_PER_DAY_RANGE
 
         cache.set(cache_key, ppd)
         return ppd
 
 
 class Post(models.Model, Viewable):
     """A post is a message."""
 
     objects = PostManager()
 
     class Meta:
         app_label = APP_LABEL_BOARDS
         ordering = ('id',)
 
     title = models.CharField(max_length=TITLE_MAX_LENGTH)
     pub_time = models.DateTimeField()
     text = MarkupField(default_markup_type=DEFAULT_MARKUP_TYPE,
                        escape_html=False)
 
     images = models.ManyToManyField(PostImage, null=True, blank=True,
                                     related_name='ip+', db_index=True)
 
     poster_ip = models.GenericIPAddressField()
     poster_user_agent = models.TextField()
 
     thread_new = models.ForeignKey('Thread', null=True, default=None,
                                    db_index=True)
     last_edit_time = models.DateTimeField()
 
     referenced_posts = models.ManyToManyField('Post', symmetrical=False,
                                               null=True,
                                               blank=True, related_name='rfp+',
                                               db_index=True)
     refmap = models.TextField(null=True, blank=True)
 
     def __unicode__(self):
         return '#' + str(self.id) + ' ' + self.title + ' (' + \
                self.text.raw[:50] + ')'
 
     def get_title(self):
         """
         Gets original post title or part of its text.
         """
 
         title = self.title
         if not title:
             title = self.text.rendered
 
         return title
 
     def build_refmap(self):
         """
         Builds a replies map string from replies list. This is a cache to stop
         the server from recalculating the map on every post show.
         """
         map_string = ''
 
         first = True
         for refpost in self.referenced_posts.all():
             if not first:
                 map_string += ', '
             map_string += '<a href="%s">&gt;&gt;%s</a>' % (refpost.get_url(),
                                                            refpost.id)
             first = False
 
         self.refmap = map_string
 
     def get_sorted_referenced_posts(self):
         return self.refmap
 
     def is_referenced(self):
         return len(self.refmap) > 0
 
     def is_opening(self):
         """
         Checks if this is an opening post or just a reply.
         """
 
         return self.get_thread().get_opening_post_id() == self.id
 
     @transaction.atomic
     def add_tag(self, tag):
         edit_time = timezone.now()
 
         thread = self.get_thread()
         thread.add_tag(tag)
         self.last_edit_time = edit_time
         self.save(update_fields=['last_edit_time'])
 
         thread.last_edit_time = edit_time
         thread.save(update_fields=['last_edit_time'])
 
     @transaction.atomic
     def remove_tag(self, tag):
         edit_time = timezone.now()
 
         thread = self.get_thread()
         thread.remove_tag(tag)
         self.last_edit_time = edit_time
         self.save(update_fields=['last_edit_time'])
 
         thread.last_edit_time = edit_time
         thread.save(update_fields=['last_edit_time'])
 
     def get_url(self, thread=None):
         """
         Gets full url to the post.
         """
 
         cache_key = CACHE_KEY_POST_URL + str(self.id)
         link = cache.get(cache_key)
 
         if not link:
             if not thread:
                 thread = self.get_thread()
 
             opening_id = thread.get_opening_post_id()
 
             if self.id != opening_id:
                 link = reverse('thread', kwargs={
                     'post_id': opening_id}) + '#' + str(self.id)
             else:
                 link = reverse('thread', kwargs={'post_id': self.id})
 
             cache.set(cache_key, link)
 
         return link
 
     def get_thread(self):
         """
         Gets post's thread.
         """
 
         return self.thread_new
 
     def get_referenced_posts(self):
         return self.referenced_posts.only('id', 'thread_new')
 
     def get_text(self):
         return self.text
 
     def get_view(self, moderator=False, need_open_link=False,
                  truncated=False, *args, **kwargs):
         if 'is_opening' in kwargs:
             is_opening = kwargs['is_opening']
         else:
             is_opening = self.is_opening()
 
         if 'thread' in kwargs:
             thread = kwargs['thread']
         else:
             thread = self.get_thread()
 
         if 'can_bump' in kwargs:
             can_bump = kwargs['can_bump']
         else:
             can_bump = thread.can_bump()
 
         if is_opening:
             opening_post_id = self.id
         else:
             opening_post_id = thread.get_opening_post_id()
 
         return render_to_string('boards/post.html', {
             'post': self,
             'moderator': moderator,
             'is_opening': is_opening,
             'thread': thread,
             'bumpable': can_bump,
             'need_open_link': need_open_link,
             'truncated': truncated,
             'opening_post_id': opening_post_id,
         })
 
     def get_first_image(self):
         return self.images.earliest('id')
 
     def delete(self, using=None):
         """
         Deletes all post images and the post itself.
         """
 
         self.images.all().delete()
 
         super(Post, self).delete(using)
+
+    def get_post_data(self, format_type=DIFF_TYPE_JSON, request=None,
+                      include_last_update=False):
+        """
+        Gets post HTML or JSON data that can be rendered on a page or used by
+        API.
+        """
+
+        if format_type == DIFF_TYPE_HTML:
+            context = RequestContext(request)
+            context['post'] = self
+            if PARAMETER_TRUNCATED in request.GET:
+                context[PARAMETER_TRUNCATED] = True
+
+            return render_to_string('boards/api_post.html', context)
+        elif format_type == DIFF_TYPE_JSON:
+            post_json = {
+                'id': self.id,
+                'title': self.title,
+                'text': self.text.rendered,
+                }
+            if self.images.exists():
+                post_image = self.get_first_image()
+                post_json['image'] = post_image.image.url
+                post_json['image_preview'] = post_image.image.url_200x150
+            if include_last_update:
+                post_json['bump_time'] = datetime_to_epoch(
+                    self.thread_new.bump_time)
+            return post_json
+
+    def send_to_websocket(self, request, recursive=True):
+        """
+        Sends post HTML data to the thread web socket.
+        """
+
+        if not settings.WEBSOCKETS_ENABLED:
+            return
+
+        client = Client()
+
+        channel_name = WS_CHANNEL_THREAD + str(self.get_thread().get_opening_post_id())
+        client.publish(channel_name, {
+            'html': self.get_post_data(
+                format_type=DIFF_TYPE_HTML,
+                request=request),
+            'diff_type': 'added' if recursive else 'updated',
+        })
+        client.send()
+
+        logger.info('Sent post #{} to channel {}'.format(self.id, channel_name))
+
+        if recursive:
+            for reply_number in re.finditer(REGEX_REPLY, self.text.raw):
+                post_id = reply_number.group(1)
+                ref_post = Post.objects.filter(id=post_id)[0]
+
+                ref_post.send_to_websocket(request, recursive=False)
  No newline at end of file

boards/settings.py

@@ -1,20 +1,22 b''
 VERSION = '2.1 Aya'
 SITE_NAME = 'Neboard'
 
 CACHE_TIMEOUT = 600  # Timeout for caching, if cache is used
 LOGIN_TIMEOUT = 3600  # Timeout between login tries
 MAX_TEXT_LENGTH = 30000  # Max post length in characters
 MAX_IMAGE_SIZE = 8 * 1024 * 1024  # Max image size
 
 # Thread bumplimit
 MAX_POSTS_PER_THREAD = 10
 # Old posts will be archived or deleted if this value is reached
 MAX_THREAD_COUNT = 5
 THREADS_PER_PAGE = 3
 DEFAULT_THEME = 'md'
 LAST_REPLIES_COUNT = 3
 
 # Enable archiving threads instead of deletion when the thread limit is reached
 ARCHIVE_THREADS = True
 # Limit posting speed
 LIMIT_POSTING_SPEED = False
+# Thread update
+WEBSOCKETS_ENABLED = True
  No newline at end of file

boards/static/js/thread_update.js

@@ -1,288 +1,278 b''
 /*
  @licstart  The following is the entire license notice for the
  JavaScript code in this page.
 
 
  Copyright (C) 2013  neko259
 
  The JavaScript code in this page is free software: you can
  redistribute it and/or modify it under the terms of the GNU
  General Public License (GNU GPL) as published by the Free Software
  Foundation, either version 3 of the License, or (at your option)
  any later version.  The code is distributed WITHOUT ANY WARRANTY;
  without even the implied warranty of MERCHANTABILITY or FITNESS
  FOR A PARTICULAR PURPOSE.  See the GNU GPL for more details.
 
  As additional permission under GNU GPL version 3 section 7, you
  may distribute non-source (e.g., minimized or compacted) forms of
  that code without the copy of the GNU GPL normally required by
  section 4, provided you include this license notice and a URL
  through which recipients can access the Corresponding Source.
 
  @licend  The above is the entire license notice
  for the JavaScript code in this page.
  */
 
-var THREAD_UPDATE_DELAY = 10000;
+var wsUrl = 'ws://localhost:9090/connection/websocket';
+var wsUser = '';
 
 var loading = false;
 var lastUpdateTime = null;
 var unreadPosts = 0;
 
+// Thread ID does not change, can be stored one time
+var threadId = $('div.thread').children('.post').first().attr('id');
+
+function connectWebsocket() {
+    var metapanel = $('.metapanel')[0];
+
+    var wsHost = metapanel.getAttribute('data-ws-host');
+    var wsPort = metapanel.getAttribute('data-ws-port');
+
+    if (wsHost.length > 0 && wsPort.length > 0)
+    var centrifuge = new Centrifuge({
+        "url": 'ws://' + wsHost + ':' + wsPort + "/connection/websocket",
+        "project": metapanel.getAttribute('data-ws-project'),
+        "user": wsUser,
+        "timestamp": metapanel.getAttribute('data-last-update'),
+        "token": metapanel.getAttribute('data-ws-token'),
+        "debug": true
+    });
+
+    centrifuge.on('error', function(error_message) {
+        alert("Error connecting to websocket server.");
+    });
+
+    centrifuge.on('connect', function() {
+        var channelName = 'thread:' + threadId;
+        centrifuge.subscribe(channelName, function(message) {
+            var postHtml = message.data['html'];
+            var isAdded = (message.data['diff_type'] === 'added');
+
+            if (postHtml) {
+                updatePost(postHtml, isAdded);
+            }
+        });
+
+        $('#autoupdate').text('[+]');
+    });
+
+    centrifuge.connect();
+}
+
+function updatePost(postHtml, isAdded) {
+    // This needs to be set on start because the page is scrolled after posts
+    // are added or updated
+    var bottom = isPageBottom();
+
+    var post = $(postHtml);
+
+    var threadPosts = $('div.thread').children('.post');
+
+    var lastUpdate = '';
+
+    if (isAdded) {
+        var lastPost = threadPosts.last();
+
+        post.appendTo(lastPost.parent());
+
+        updateBumplimitProgress(1);
+        showNewPostsTitle(1);
+
+        lastUpdate = post.children('.post-info').first()
+            .children('.pub_time').first().text();
+
+        if (bottom) {
+            scrollToBottom();
+        }
+    } else {
+        var postId = post.attr('id');
+
+        var oldPost = $('div.thread').children('.post[id=' + postId + ']');
+
+        oldPost.replaceWith(post);
+    }
+
+    processNewPost(post);
+    updateMetadataPanel(lastUpdate)
+}
+
 function blink(node) {
     var blinkCount = 2;
 
     var nodeToAnimate = node;
     for (var i = 0; i < blinkCount; i++) {
         nodeToAnimate = nodeToAnimate.fadeTo('fast', 0.5).fadeTo('fast', 1.0);
     }
 }
 
-function updateThread() {
-    if (loading) {
-        return;
-    }
-
-    loading = true;
-
-    var threadPosts = $('div.thread').children('.post');
-
-    var lastPost = threadPosts.last();
-    var threadId = threadPosts.first().attr('id');
-
-    var diffUrl = '/api/diff_thread/' + threadId + '/' + lastUpdateTime + '/';
-    $.getJSON(diffUrl)
-        .success(function(data) {
-            var bottom = isPageBottom();
-
-            var lastUpdate = '';
-
-            var addedPosts = data.added;
-            for (var i = 0; i < addedPosts.length; i++) {
-                var postText = addedPosts[i];
-
-                var post = $(postText);
-
-                if (lastUpdate === '') {
-                    lastUpdate = post.find('.pub_time').text();
-                }
-
-                post.appendTo(lastPost.parent());
-                processNewPost(post);
-
-                lastPost = post;
-                blink(post);
-            }
-
-            var updatedPosts = data.updated;
-            for (var i = 0; i < updatedPosts.length; i++) {
-                var postText = updatedPosts[i];
-
-                var post = $(postText);
-
-                if (lastUpdate === '') {
-                    lastUpdate = post.find('.pub_time').text();
-                }
-
-                var postId = post.attr('id');
-
-                var oldPost = $('div.thread').children('.post[id=' + postId + ']');
-                
-                oldPost.replaceWith(post);
-                processNewPost(post);
-
-                blink(post);
-            }
-
-            // TODO Process deleted posts
-
-            lastUpdateTime = data.last_update;
-            loading = false;
-
-            if (bottom) {
-                scrollToBottom();
-            }
-
-            var hasPostChanges = (updatedPosts.length > 0)
-                || (addedPosts.length > 0);
-            if (hasPostChanges) {
-                updateMetadataPanel(lastUpdate);
-            }
-
-            updateBumplimitProgress(data.added.length);
-
-            if (data.added.length + data.updated.length > 0) {
-                showNewPostsTitle(data.added.length);
-            }
-        })
-        .error(function(data) {
-            // TODO Show error message that server is unavailable?
-
-            loading = false;
-        });
-}
-
 function isPageBottom() {
     var scroll = $(window).scrollTop() / ($(document).height()
         - $(window).height())
 
     return scroll == 1
 }
 
 function initAutoupdate() {
-    loading = false;
-
-    lastUpdateTime = $('.metapanel').attr('data-last-update');
-
-    setInterval(updateThread, THREAD_UPDATE_DELAY);
+    connectWebsocket()
 }
 
 function getReplyCount() {
     return $('.thread').children('.post').length
 }
 
 function getImageCount() {
     return $('.thread').find('img').length
 }
 
 function updateMetadataPanel(lastUpdate) {
     var replyCountField = $('#reply-count');
     var imageCountField = $('#image-count');
 
     replyCountField.text(getReplyCount());
     imageCountField.text(getImageCount());
 
     if (lastUpdate !== '') {
         var lastUpdateField = $('#last-update');
         lastUpdateField.text(lastUpdate);
         blink(lastUpdateField);
     }
 
     blink(replyCountField);
     blink(imageCountField);
 }
 
 /**
  * Update bumplimit progress bar
  */
 function updateBumplimitProgress(postDelta) {
     var progressBar = $('#bumplimit_progress');
     if (progressBar) {
         var postsToLimitElement = $('#left_to_limit');
 
         var oldPostsToLimit = parseInt(postsToLimitElement.text());
         var postCount = getReplyCount();
         var bumplimit = postCount - postDelta + oldPostsToLimit;
 
         var newPostsToLimit = bumplimit - postCount;
         if (newPostsToLimit <= 0) {
             $('.bar-bg').remove();
             $('.thread').children('.post').addClass('dead_post');
         } else {
             postsToLimitElement.text(newPostsToLimit);
             progressBar.width((100 - postCount / bumplimit * 100.0) + '%');
         }
     }
 }
 
 var documentOriginalTitle = '';
 /**
  * Show 'new posts' text in the title if the document is not visible to a user
  */
 function showNewPostsTitle(newPostCount) {
     if (document.hidden) {
         if (documentOriginalTitle === '') {
             documentOriginalTitle = document.title;
         }
         unreadPosts = unreadPosts + newPostCount;
         document.title = '[' + unreadPosts + '] ' + documentOriginalTitle;
 
         document.addEventListener('visibilitychange', function() {
             if (documentOriginalTitle !== '') {
                 document.title = documentOriginalTitle;
                 documentOriginalTitle = '';
                 unreadPosts = 0;
             }
 
             document.removeEventListener('visibilitychange', null);
         });
     }
 }
 
 /**
  * Clear all entered values in the form fields
  */
 function resetForm(form) {
     form.find('input:text, input:password, input:file, select, textarea').val('');
     form.find('input:radio, input:checkbox')
              .removeAttr('checked').removeAttr('selected');
     $('.file_wrap').find('.file-thumb').remove();
 }
 
 /**
  * When the form is posted, this method will be run as a callback
  */
 function updateOnPost(response, statusText, xhr, form) {
     var json = $.parseJSON(response);
     var status = json.status;
 
     showAsErrors(form, '');
 
     if (status === 'ok') {
         resetForm(form);
-        updateThread();
     } else {
         var errors = json.errors;
         for (var i = 0; i < errors.length; i++) {
             var fieldErrors = errors[i];
 
             var error = fieldErrors.errors;
 
             showAsErrors(form, error);
         }
     }
 }
 
 /**
  * Show text in the errors row of the form.
  * @param form
  * @param text
  */
 function showAsErrors(form, text) {
     form.children('.form-errors').remove();
 
     if (text.length > 0) {
         var errorList = $('<div class="form-errors">' + text
             + '<div>');
         errorList.appendTo(form);
     }
 }
 
 /**
  * Run js methods that are usually run on the document, on the new post
  */
 function processNewPost(post) {
     addRefLinkPreview(post[0]);
     highlightCode(post);
+    blink(post);
 }
 
 $(document).ready(function(){
     initAutoupdate();
 
     // Post form data over AJAX
     var threadId = $('div.thread').children('.post').first().attr('id');
 
     var form = $('#form');
 
     var options = {
         beforeSubmit: function(arr, $form, options) {
             showAsErrors($('form'), gettext('Sending message...'));
         },
         success: updateOnPost,
         url: '/api/add_post/' + threadId + '/'
     };
 
     form.ajaxForm(options);
 
     resetForm(form);
 });

boards/templates/boards/thread.html

@@ -1,98 +1,107 b''
 {% extends "boards/base.html" %}
 
 {% load i18n %}
 {% load cache %}
 {% load static from staticfiles %}
 {% load board %}
 {% load compress %}
 
 {% block head %}
     <title>{{ opening_post.get_title|striptags|truncatewords:10 }}
         - {{ site_name }}</title>
 {% endblock %}
 
 {% block content %}
     {% spaceless %}
     {% get_current_language as LANGUAGE_CODE %}
 
     {% cache 600 thread_view thread.id thread.last_edit_time moderator LANGUAGE_CODE %}
 
     <div class="image-mode-tab">
         <a class="current_mode" href="{% url 'thread' opening_post.id %}">{% trans 'Normal mode' %}</a>,
         <a href="{% url 'thread_mode' opening_post.id 'gallery' %}">{% trans 'Gallery mode' %}</a>
     </div>
 
     {% if bumpable %}
         <div class="bar-bg">
             <div class="bar-value" style="width:{{ bumplimit_progress }}%" id="bumplimit_progress">
             </div>
             <div class="bar-text">
                 <span id="left_to_limit">{{ posts_left }}</span> {% trans 'posts to bumplimit' %}
             </div>
         </div>
     {% endif %}
 
     <div class="thread">
         {% with can_bump=thread.can_bump %}
         {% for post in thread.get_replies %}
             {% if forloop.first %}
                 {% post_view post moderator=moderator is_opening=True thread=thread can_bump=can_bump opening_post_id=opening_post.id %}
             {% else %}
                 {% post_view post moderator=moderator is_opening=False thread=thread can_bump=can_bump opening_post_id=opening_post.id %}
             {% endif %}
         {% endfor %}
         {% endwith %}
     </div>
 
     {% if not thread.archived %}
 
     <div class="post-form-w" id="form">
         <script src="{% static 'js/panel.js' %}"></script>
         <div class="form-title">{% trans "Reply to thread" %} #{{ opening_post.id }}</div>
         <div class="post-form" id="compact-form">
             <div class="swappable-form-full">
                 <form enctype="multipart/form-data" method="post"
                         >{% csrf_token %}
                         <div class="compact-form-text"></div>
                     {{ form.as_div }}
                     <div class="form-submit">
                         <input type="submit" value="{% trans "Post" %}"/>
                     </div>
                 </form>
             </div>
             <a onclick="swapForm(); return false;" href="#">
                 {% trans 'Switch mode' %}
             </a>
             <div><a href="{% url "staticpage" name="help" %}">
                 {% trans 'Text syntax' %}</a></div>
         </div>
     </div>
 
-    <script src="{% static 'js/jquery.form.min.js' %}"></script>
-    <script src="{% static 'js/thread_update.js' %}"></script>
+        <script src="{% static 'js/jquery.form.min.js' %}"></script>
+        {% compress js %}
+            <script src="{% static 'js/thread_update.js' %}"></script>
+            <script src="{% static 'js/3party/centrifuge.js' %}"></script>
+        {% endcompress %}
     {% endif %}
 
     {% compress js %}
         <script src="{% static 'js/form.js' %}"></script>
         <script src="{% static 'js/thread.js' %}"></script>
     {% endcompress %}
 
     {% endcache %}
 
     {% endspaceless %}
 {% endblock %}
 
 {% block metapanel %}
 
     {% get_current_language as LANGUAGE_CODE %}
 
-    <span class="metapanel" data-last-update="{{ last_update }}">
+    <span class="metapanel"
+          data-last-update="{{ last_update }}"
+          data-ws-token="{{ ws_token }}"
+          data-ws-project="{{ ws_project }}"
+          data-ws-host="{{ ws_host }}"
+          data-ws-port="{{ ws_port }}">
         {% cache 600 thread_meta thread.last_edit_time moderator LANGUAGE_CODE %}
+            <span id="autoupdate">[-]</span>
             <span id="reply-count">{{ thread.get_reply_count }}</span>/{{ max_replies }} {% trans 'messages' %},
             <span id="image-count">{{ thread.get_images_count }}</span> {% trans 'images' %}.
             {% trans 'Last update: ' %}<span id="last-update">{{ thread.last_edit_time }}</span>
             [<a href="rss/">RSS</a>]
         {% endcache %}
     </span>
 
 {% endblock %}

boards/utils.py

@@ -1,78 +1,92 b''
 """
 This module contains helper functions and helper classes.
 """
-import hashlib
 import time
+import hmac
 
 from django.utils import timezone
 
 from neboard import settings
 
 
 KEY_CAPTCHA_FAILS = 'key_captcha_fails'
 KEY_CAPTCHA_DELAY_TIME = 'key_captcha_delay_time'
 KEY_CAPTCHA_LAST_ACTIVITY = 'key_captcha_last_activity'
 
 
 def need_include_captcha(request):
     """
     Check if request is made by a user.
     It contains rules which check for bots.
     """
 
     if not settings.ENABLE_CAPTCHA:
         return False
 
     enable_captcha = False
 
     #newcomer
     if KEY_CAPTCHA_LAST_ACTIVITY not in request.session:
         return settings.ENABLE_CAPTCHA
 
     last_activity = request.session[KEY_CAPTCHA_LAST_ACTIVITY]
     current_delay = int(time.time()) - last_activity
 
     delay_time = (request.session[KEY_CAPTCHA_DELAY_TIME]
                   if KEY_CAPTCHA_DELAY_TIME in request.session
                   else settings.CAPTCHA_DEFAULT_SAFE_TIME)
 
     if current_delay < delay_time:
         enable_captcha = True
 
     return enable_captcha
 
 
 def update_captcha_access(request, passed):
     """
     Update captcha fields.
     It will reduce delay time if user passed captcha verification and
     it will increase it otherwise.
     """
     session = request.session
 
     delay_time = (request.session[KEY_CAPTCHA_DELAY_TIME]
                   if KEY_CAPTCHA_DELAY_TIME in request.session
                   else settings.CAPTCHA_DEFAULT_SAFE_TIME)
 
     if passed:
         delay_time -= 2 if delay_time >= 7 else 5
     else:
         delay_time += 10
 
     session[KEY_CAPTCHA_LAST_ACTIVITY] = int(time.time())
     session[KEY_CAPTCHA_DELAY_TIME] = delay_time
 
 
 def get_client_ip(request):
     x_forwarded_for = request.META.get('HTTP_X_FORWARDED_FOR')
     if x_forwarded_for:
         ip = x_forwarded_for.split(',')[-1].strip()
     else:
         ip = request.META.get('REMOTE_ADDR')
     return ip
 
 
 def datetime_to_epoch(datetime):
     return int(time.mktime(timezone.localtime(
         datetime,timezone.get_current_timezone()).timetuple())
                * 1000000 + datetime.microsecond)
+
+
+def get_websocket_token(user_id='', timestamp=''):
+    """
+    Create token to validate information provided by new connection.
+    """
+
+    sign = hmac.new(settings.CENTRIFUGE_PROJECT_SECRET.encode())
+    sign.update(settings.CENTRIFUGE_PROJECT_ID.encode())
+    sign.update(user_id.encode())
+    sign.update(timestamp.encode())
+    token = sign.hexdigest()
+
+    return token
  No newline at end of file

boards/views/all_threads.py

@@ -1,139 +1,141 b''
 import string
 
 from django.db import transaction
 from django.shortcuts import render, redirect
 
 from boards import utils, settings
 from boards.abstracts.paginator import get_paginator
 from boards.abstracts.settingsmanager import get_settings_manager
 from boards.forms import ThreadForm, PlainErrorList
 from boards.models import Post, Thread, Ban, Tag
 from boards.views.banned import BannedView
 from boards.views.base import BaseBoardView, CONTEXT_FORM
 from boards.views.posting_mixin import PostMixin
 
 FORM_TAGS = 'tags'
 FORM_TEXT = 'text'
 FORM_TITLE = 'title'
 FORM_IMAGE = 'image'
 
 TAG_DELIMITER = ' '
 
 PARAMETER_CURRENT_PAGE = 'current_page'
 PARAMETER_PAGINATOR = 'paginator'
 PARAMETER_THREADS = 'threads'
 
 TEMPLATE = 'boards/posting_general.html'
 DEFAULT_PAGE = 1
 
 
 class AllThreadsView(PostMixin, BaseBoardView):
 
     def __init__(self):
         self.settings_manager = None
         super(AllThreadsView, self).__init__()
 
     def get(self, request, page=DEFAULT_PAGE, form=None):
         context = self.get_context_data(request=request)
 
         if not form:
             form = ThreadForm(error_class=PlainErrorList)
 
         self.settings_manager = get_settings_manager(request)
         paginator = get_paginator(self.get_threads(),
                                   settings.THREADS_PER_PAGE)
         paginator.current_page = int(page)
 
         threads = paginator.page(page).object_list
 
         context[PARAMETER_THREADS] = threads
         context[CONTEXT_FORM] = form
 
         self._get_page_context(paginator, context, page)
 
         return render(request, TEMPLATE, context)
 
     def post(self, request, page=DEFAULT_PAGE):
         form = ThreadForm(request.POST, request.FILES,
                           error_class=PlainErrorList)
         form.session = request.session
 
         if form.is_valid():
             return self.create_thread(request, form)
         if form.need_to_ban:
             # Ban user because he is suspected to be a bot
             self._ban_current_user(request)
 
         return self.get(request, page, form)
 
     @staticmethod
     def _get_page_context(paginator, context, page):
         """
         Get pagination context variables
         """
 
         context[PARAMETER_PAGINATOR] = paginator
         context[PARAMETER_CURRENT_PAGE] = paginator.page(int(page))
 
     @staticmethod
     def parse_tags_string(tag_strings):
         """
         Parses tag list string and returns tag object list.
         """
 
         tags = []
 
         if tag_strings:
             tag_strings = tag_strings.split(TAG_DELIMITER)
             for tag_name in tag_strings:
                 tag_name = tag_name.strip().lower()
                 if len(tag_name) > 0:
                     tag, created = Tag.objects.get_or_create(name=tag_name)
                     tags.append(tag)
 
         return tags
 
     @transaction.atomic
     def create_thread(self, request, form, html_response=True):
         """
         Creates a new thread with an opening post.
         """
 
         ip = utils.get_client_ip(request)
         is_banned = Ban.objects.filter(ip=ip).exists()
 
         if is_banned:
             if html_response:
                 return redirect(BannedView().as_view())
             else:
                 return
 
         data = form.cleaned_data
 
         title = data[FORM_TITLE]
         text = data[FORM_TEXT]
 
         text = self._remove_invalid_links(text)
 
         if FORM_IMAGE in list(data.keys()):
             image = data[FORM_IMAGE]
         else:
             image = None
 
         tag_strings = data[FORM_TAGS]
 
         tags = self.parse_tags_string(tag_strings)
 
         post = Post.objects.create_post(title=title, text=text, image=image,
                                         ip=ip, tags=tags)
+        # FIXME
+        post.send_to_websocket(request)
 
         if html_response:
             return redirect(post.get_url())
 
     def get_threads(self):
         """
         Gets list of threads that will be shown on a page.
         """
 
         return Thread.objects.all().order_by('-bump_time')\
             .exclude(tags__in=self.settings_manager.get_hidden_tags())

boards/views/api.py

@@ -1,248 +1,227 b''
 from datetime import datetime
 import json
 import logging
 from django.db import transaction
 from django.http import HttpResponse
 from django.shortcuts import get_object_or_404, render
 from django.template import RequestContext
 from django.utils import timezone
 from django.core import serializers
 from django.template.loader import render_to_string
 
 from boards.forms import PostForm, PlainErrorList
 from boards.models import Post, Thread, Tag
 from boards.utils import datetime_to_epoch
 from boards.views.thread import ThreadView
 
 __author__ = 'neko259'
 
 PARAMETER_TRUNCATED = 'truncated'
 PARAMETER_TAG = 'tag'
 PARAMETER_OFFSET = 'offset'
 PARAMETER_DIFF_TYPE = 'type'
 
 DIFF_TYPE_HTML = 'html'
 DIFF_TYPE_JSON = 'json'
 
 STATUS_OK = 'ok'
 STATUS_ERROR = 'error'
 
 logger = logging.getLogger(__name__)
 
 
 @transaction.atomic
 def api_get_threaddiff(request, thread_id, last_update_time):
     """
     Gets posts that were changed or added since time
     """
 
     thread = get_object_or_404(Post, id=thread_id).get_thread()
 
     # Add 1 to ensure we don't load the same post over and over
     last_update_timestamp = float(last_update_time) + 1
 
     filter_time = datetime.fromtimestamp(last_update_timestamp / 1000000,
                                          timezone.get_current_timezone())
 
     json_data = {
         'added': [],
         'updated': [],
         'last_update': None,
     }
     added_posts = Post.objects.filter(thread_new=thread,
                                       pub_time__gt=filter_time) \
         .order_by('pub_time')
     updated_posts = Post.objects.filter(thread_new=thread,
                                         pub_time__lte=filter_time,
                                         last_edit_time__gt=filter_time)
 
     diff_type = DIFF_TYPE_HTML
     if PARAMETER_DIFF_TYPE in request.GET:
         diff_type = request.GET[PARAMETER_DIFF_TYPE]
 
     for post in added_posts:
-        json_data['added'].append(_get_post_data(post.id, diff_type, request))
+        json_data['added'].append(get_post_data(post.id, diff_type, request))
     for post in updated_posts:
-        json_data['updated'].append(_get_post_data(post.id, diff_type, request))
+        json_data['updated'].append(get_post_data(post.id, diff_type, request))
     json_data['last_update'] = datetime_to_epoch(thread.last_edit_time)
 
     return HttpResponse(content=json.dumps(json_data))
 
 
 def api_add_post(request, opening_post_id):
     """
     Adds a post and return the JSON response for it
     """
 
     opening_post = get_object_or_404(Post, id=opening_post_id)
 
     logger.info('Adding post via api...')
 
     status = STATUS_OK
     errors = []
 
     if request.method == 'POST':
         form = PostForm(request.POST, request.FILES, error_class=PlainErrorList)
         form.session = request.session
 
         if form.need_to_ban:
             # Ban user because he is suspected to be a bot
             # _ban_current_user(request)
             status = STATUS_ERROR
         if form.is_valid():
             post = ThreadView().new_post(request, form, opening_post,
                                          html_response=False)
             if not post:
                 status = STATUS_ERROR
             else:
                 logger.info('Added post #%d via api.' % post.id)
         else:
             status = STATUS_ERROR
             errors = form.as_json_errors()
 
     response = {
         'status': status,
         'errors': errors,
     }
 
     return HttpResponse(content=json.dumps(response))
 
 
 def get_post(request, post_id):
     """
     Gets the html of a post. Used for popups. Post can be truncated if used
     in threads list with 'truncated' get parameter.
     """
 
     logger.info('Getting post #%s' % post_id)
 
     post = get_object_or_404(Post, id=post_id)
 
     context = RequestContext(request)
     context['post'] = post
     if PARAMETER_TRUNCATED in request.GET:
         context[PARAMETER_TRUNCATED] = True
 
     return render(request, 'boards/api_post.html', context)
 
 
 # TODO Test this
 def api_get_threads(request, count):
     """
     Gets the JSON thread opening posts list.
     Parameters that can be used for filtering:
     tag, offset (from which thread to get results)
     """
 
     if PARAMETER_TAG in request.GET:
         tag_name = request.GET[PARAMETER_TAG]
         if tag_name is not None:
             tag = get_object_or_404(Tag, name=tag_name)
             threads = tag.threads.filter(archived=False)
     else: 
         threads = Thread.objects.filter(archived=False)
 
     if PARAMETER_OFFSET in request.GET:
         offset = request.GET[PARAMETER_OFFSET]
         offset = int(offset) if offset is not None else 0
     else:
         offset = 0
 
     threads = threads.order_by('-bump_time')
     threads = threads[offset:offset + int(count)]
 
     opening_posts = []
     for thread in threads:
         opening_post = thread.get_opening_post()
 
         # TODO Add tags, replies and images count
-        opening_posts.append(_get_post_data(opening_post.id,
+        opening_posts.append(get_post_data(opening_post.id,
                                             include_last_update=True))
 
     return HttpResponse(content=json.dumps(opening_posts))
 
 
 # TODO Test this
 def api_get_tags(request):
     """
     Gets all tags or user tags.
     """
 
     # TODO Get favorite tags for the given user ID
 
     tags = Tag.objects.get_not_empty_tags()
     tag_names = []
     for tag in tags:
         tag_names.append(tag.name)
 
     return HttpResponse(content=json.dumps(tag_names))
 
 
 # TODO The result can be cached by the thread last update time
 # TODO Test this
 def api_get_thread_posts(request, opening_post_id):
     """
     Gets the JSON array of thread posts
     """
 
     opening_post = get_object_or_404(Post, id=opening_post_id)
     thread = opening_post.get_thread()
     posts = thread.get_replies()
 
     json_data = {
         'posts': [],
         'last_update': None,
     }
     json_post_list = []
 
     for post in posts:
-        json_post_list.append(_get_post_data(post.id))
+        json_post_list.append(get_post_data(post.id))
     json_data['last_update'] = datetime_to_epoch(thread.last_edit_time)
     json_data['posts'] = json_post_list
 
     return HttpResponse(content=json.dumps(json_data))
 
 
 def api_get_post(request, post_id):
     """
     Gets the JSON of a post. This can be
     used as and API for external clients.
     """
 
     post = get_object_or_404(Post, id=post_id)
 
     json = serializers.serialize("json", [post], fields=(
         "pub_time", "_text_rendered", "title", "text", "image",
         "image_width", "image_height", "replies", "tags"
     ))
 
     return HttpResponse(content=json)
 
 
-# TODO Add pub time and replies
-def _get_post_data(post_id, format_type=DIFF_TYPE_JSON, request=None,
-        include_last_update=False):
-    if format_type == DIFF_TYPE_HTML:
-        post = get_object_or_404(Post, id=post_id)
-
-        context = RequestContext(request)
-        context['post'] = post
-        if PARAMETER_TRUNCATED in request.GET:
-            context[PARAMETER_TRUNCATED] = True
-
-        return render_to_string('boards/api_post.html', context)
-    elif format_type == DIFF_TYPE_JSON:
-        post = get_object_or_404(Post, id=post_id)
-        post_json = {
-            'id': post.id,
-            'title': post.title,
-            'text': post.text.rendered,
-        }
-        if post.images.exists():
-            post_image = post.get_first_image()
-            post_json['image'] = post_image.image.url
-            post_json['image_preview'] = post_image.image.url_200x150
-        if include_last_update:
-            post_json['bump_time'] = datetime_to_epoch(
-                post.thread_new.bump_time)
-        return post_json
+# TODO Remove this method and use post method directly
+def get_post_data(post_id, format_type=DIFF_TYPE_JSON, request=None,
+                  include_last_update=False):
+    post = get_object_or_404(Post, id=post_id)
+    return post.get_post_data(format_type=format_type, request=request,
+                              include_last_update=include_last_update)

boards/views/thread.py

@@ -1,142 +1,155 b''
 from django.core.urlresolvers import reverse
 from django.db import transaction
 from django.http import Http404
 from django.shortcuts import get_object_or_404, render, redirect
 from django.views.generic.edit import FormMixin
 
 from boards import utils, settings
 from boards.forms import PostForm, PlainErrorList
 from boards.models import Post, Ban
 from boards.views.banned import BannedView
 from boards.views.base import BaseBoardView, CONTEXT_FORM
 from boards.views.posting_mixin import PostMixin
+import neboard
 
 TEMPLATE_GALLERY = 'boards/thread_gallery.html'
 TEMPLATE_NORMAL = 'boards/thread.html'
 
 CONTEXT_POSTS = 'posts'
 CONTEXT_OP = 'opening_post'
 CONTEXT_BUMPLIMIT_PRG = 'bumplimit_progress'
 CONTEXT_POSTS_LEFT = 'posts_left'
 CONTEXT_LASTUPDATE = "last_update"
 CONTEXT_MAX_REPLIES = 'max_replies'
 CONTEXT_THREAD = 'thread'
 CONTEXT_BUMPABLE = 'bumpable'
+CONTEXT_WS_TOKEN = 'ws_token'
+CONTEXT_WS_PROJECT = 'ws_project'
+CONTEXT_WS_HOST = 'ws_host'
+CONTEXT_WS_PORT = 'ws_port'
 
 FORM_TITLE = 'title'
 FORM_TEXT = 'text'
 FORM_IMAGE = 'image'
 
 MODE_GALLERY = 'gallery'
 MODE_NORMAL = 'normal'
 
 
 class ThreadView(BaseBoardView, PostMixin, FormMixin):
 
     def get(self, request, post_id, mode=MODE_NORMAL, form=None):
         try:
             opening_post = Post.objects.filter(id=post_id).only('thread_new')[0]
         except IndexError:
             raise Http404
 
         # If this is not OP, don't show it as it is
         if not opening_post or not opening_post.is_opening():
             raise Http404
 
         if not form:
             form = PostForm(error_class=PlainErrorList)
 
         thread_to_show = opening_post.get_thread()
 
         context = self.get_context_data(request=request)
 
         context[CONTEXT_FORM] = form
-        context[CONTEXT_LASTUPDATE] = utils.datetime_to_epoch(
-            thread_to_show.last_edit_time)
+        context[CONTEXT_LASTUPDATE] = str(utils.datetime_to_epoch(
+            thread_to_show.last_edit_time))
         context[CONTEXT_THREAD] = thread_to_show
         context[CONTEXT_MAX_REPLIES] = settings.MAX_POSTS_PER_THREAD
 
+        if settings.WEBSOCKETS_ENABLED:
+            context[CONTEXT_WS_TOKEN] = utils.get_websocket_token(
+                timestamp=context[CONTEXT_LASTUPDATE])
+            context[CONTEXT_WS_PROJECT] = neboard.settings.CENTRIFUGE_PROJECT_ID
+            context[CONTEXT_WS_HOST] = request.get_host().split(':')[0]
+            context[CONTEXT_WS_PORT] = neboard.settings.CENTRIFUGE_PORT
+
         if MODE_NORMAL == mode:
             bumpable = thread_to_show.can_bump()
             context[CONTEXT_BUMPABLE] = bumpable
             if bumpable:
                 left_posts = settings.MAX_POSTS_PER_THREAD \
                              - thread_to_show.get_reply_count()
                 context[CONTEXT_POSTS_LEFT] = left_posts
                 context[CONTEXT_BUMPLIMIT_PRG] = str(
                     float(left_posts) / settings.MAX_POSTS_PER_THREAD * 100)
 
             context[CONTEXT_OP] = opening_post
 
             document = TEMPLATE_NORMAL
         elif MODE_GALLERY == mode:
             context[CONTEXT_POSTS] = thread_to_show.get_replies_with_images(
                 view_fields_only=True)
 
             document = TEMPLATE_GALLERY
         else:
             raise Http404
 
         return render(request, document, context)
 
     def post(self, request, post_id, mode=MODE_NORMAL):
         opening_post = get_object_or_404(Post, id=post_id)
 
         # If this is not OP, don't show it as it is
         if not opening_post.is_opening():
             raise Http404
 
         if not opening_post.get_thread().archived:
             form = PostForm(request.POST, request.FILES,
                             error_class=PlainErrorList)
             form.session = request.session
 
             if form.is_valid():
                 return self.new_post(request, form, opening_post)
             if form.need_to_ban:
                 # Ban user because he is suspected to be a bot
                 self._ban_current_user(request)
 
             return self.get(request, post_id, mode, form)
 
     @transaction.atomic
     def new_post(self, request, form, opening_post=None, html_response=True):
         """Add a new post (in thread or as a reply)."""
 
         ip = utils.get_client_ip(request)
         is_banned = Ban.objects.filter(ip=ip).exists()
 
         if is_banned:
             if html_response:
                 return redirect(BannedView().as_view())
             else:
                 return None
 
         data = form.cleaned_data
 
         title = data[FORM_TITLE]
         text = data[FORM_TEXT]
 
         text = self._remove_invalid_links(text)
 
         if FORM_IMAGE in list(data.keys()):
             image = data[FORM_IMAGE]
         else:
             image = None
 
         tags = []
 
         post_thread = opening_post.get_thread()
 
         post = Post.objects.create_post(title=title, text=text, image=image,
                                         thread=post_thread, ip=ip, tags=tags)
+        post.send_to_websocket(request)
 
         thread_to_show = (opening_post.id if opening_post else post.id)
 
         if html_response:
             if opening_post:
                 return redirect(
                     reverse('thread', kwargs={'post_id': thread_to_show})
                     + '#' + str(post.id))
         else:
             return post

neboard/settings.py

@@ -1,239 +1,245 b''
 # Django settings for neboard project.
 import os
 from boards.mdx_neboard import bbcode_extended
 
 DEBUG = True
 TEMPLATE_DEBUG = DEBUG
 
 ADMINS = (
     # ('Your Name', '[e-mail]'),
     ('admin', '[e-mail]')
 )
 
 MANAGERS = ADMINS
 
 DATABASES = {
     'default': {
         'ENGINE': 'django.db.backends.sqlite3', # Add 'postgresql_psycopg2', 'mysql', 'sqlite3' or 'oracle'.
         'NAME': 'database.db',                      # Or path to database file if using sqlite3.
         'USER': '',                      # Not used with sqlite3.
         'PASSWORD': '',                  # Not used with sqlite3.
         'HOST': '',                      # Set to empty string for localhost. Not used with sqlite3.
         'PORT': '',                      # Set to empty string for default. Not used with sqlite3.
 	'CONN_MAX_AGE': None,
     }
 }
 
 # Local time zone for this installation. Choices can be found here:
 # http://en.wikipedia.org/wiki/List_of_tz_zones_by_name
 # although not all choices may be available on all operating systems.
 # In a Windows environment this must be set to your system time zone.
 TIME_ZONE = 'Europe/Kiev'
 
 # Language code for this installation. All choices can be found here:
 # http://www.i18nguy.com/unicode/language-identifiers.html
 LANGUAGE_CODE = 'en'
 
 SITE_ID = 1
 
 # If you set this to False, Django will make some optimizations so as not
 # to load the internationalization machinery.
 USE_I18N = True
 
 # If you set this to False, Django will not format dates, numbers and
 # calendars according to the current locale.
 USE_L10N = True
 
 # If you set this to False, Django will not use timezone-aware datetimes.
 USE_TZ = True
 
 # Absolute filesystem path to the directory that will hold user-uploaded files.
 # Example: "/home/media/media.lawrence.com/media/"
 MEDIA_ROOT = './media/' 
 
 # URL that handles the media served from MEDIA_ROOT. Make sure to use a
 # trailing slash.
 # Examples: "http://media.lawrence.com/media/", "http://example.com/media/"
 MEDIA_URL = '/media/'
 
 # Absolute path to the directory static files should be collected to.
 # Don't put anything in this directory yourself; store your static files
 # in apps' "static/" subdirectories and in STATICFILES_DIRS.
 # Example: "/home/media/media.lawrence.com/static/"
 STATIC_ROOT = ''
 
 # URL prefix for static files.
 # Example: "http://media.lawrence.com/static/"
 STATIC_URL = '/static/'
 
 # Additional locations of static files
 # It is really a hack, put real paths, not related
 STATICFILES_DIRS = (
     os.path.dirname(__file__) + '/boards/static',
 
 #    '/d/work/python/django/neboard/neboard/boards/static',
     # Put strings here, like "/home/html/static" or "C:/www/django/static".
     # Always use forward slashes, even on Windows.
     # Don't forget to use absolute paths, not relative paths.
 )
 
 # List of finder classes that know how to find static files in
 # various locations.
 STATICFILES_FINDERS = (
     'django.contrib.staticfiles.finders.FileSystemFinder',
     'django.contrib.staticfiles.finders.AppDirectoriesFinder',
     'compressor.finders.CompressorFinder',
 )
 
 if DEBUG:
     STATICFILES_STORAGE = \
         'django.contrib.staticfiles.storage.StaticFilesStorage'
 else:
     STATICFILES_STORAGE = \
         'django.contrib.staticfiles.storage.CachedStaticFilesStorage'
 
 # Make this unique, and don't share it with anybody.
 SECRET_KEY = '@1rc$o(7=tt#kd+4s$u6wchm**z^)4x90)7f6z(i&55@o11*8o'
 
 # List of callables that know how to import templates from various sources.
 TEMPLATE_LOADERS = (
     'django.template.loaders.filesystem.Loader',
     'django.template.loaders.app_directories.Loader',
 )
 
 TEMPLATE_CONTEXT_PROCESSORS = (
     'django.core.context_processors.media',
     'django.core.context_processors.static',
     'django.core.context_processors.request',
     'django.contrib.auth.context_processors.auth',
     'boards.context_processors.user_and_ui_processor',
 )
 
 MIDDLEWARE_CLASSES = (
     'django.contrib.sessions.middleware.SessionMiddleware',
     'django.middleware.locale.LocaleMiddleware',
     'django.middleware.common.CommonMiddleware',
     'django.contrib.auth.middleware.AuthenticationMiddleware',
     'django.contrib.messages.middleware.MessageMiddleware',
     'boards.middlewares.BanMiddleware',
     'boards.middlewares.MinifyHTMLMiddleware',
 )
 
 ROOT_URLCONF = 'neboard.urls'
 
 # Python dotted path to the WSGI application used by Django's runserver.
 WSGI_APPLICATION = 'neboard.wsgi.application'
 
 TEMPLATE_DIRS = (
     # Put strings here, like "/home/html/django_templates" or "C:/www/django/templates".
     # Always use forward slashes, even on Windows.
     # Don't forget to use absolute paths, not relative paths.
     'templates',
 )
 
 INSTALLED_APPS = (
     'django.contrib.auth',
     'django.contrib.contenttypes',
     'django.contrib.sessions',
     # 'django.contrib.sites',
     'django.contrib.messages',
     'django.contrib.staticfiles',
     # Uncomment the next line to enable the admin:
     'django.contrib.admin',
     # Uncomment the next line to enable admin documentation:
     # 'django.contrib.admindocs',
     'django.contrib.humanize',
     'django_cleanup',
 
     # Migrations
     'south',
     'debug_toolbar',
 
     # Search
     'haystack',
 
     # Static files compressor
     'compressor',
 
     'boards',
 )
 
 # A sample logging configuration. The only tangible logging
 # performed by this configuration is to send an email to
 # the site admins on every HTTP 500 error when DEBUG=False.
 # See http://docs.djangoproject.com/en/dev/topics/logging for
 # more details on how to customize your logging configuration.
 LOGGING = {
     'version': 1,
     'disable_existing_loggers': False,
     'formatters': {
         'verbose': {
             'format': '%(levelname)s %(asctime)s %(module)s %(process)d %(thread)d %(message)s'
         },
         'simple': {
             'format': '%(levelname)s %(asctime)s [%(module)s] %(message)s'
         },
     },
     'filters': {
         'require_debug_false': {
             '()': 'django.utils.log.RequireDebugFalse'
         }
     },
     'handlers': {
         'console': {
             'level': 'DEBUG',
             'class': 'logging.StreamHandler',
             'formatter': 'simple'
         },
     },
     'loggers': {
         'boards': {
             'handlers': ['console'],
             'level': 'DEBUG',
         }
     },
 }
 
 HAYSTACK_CONNECTIONS = {
     'default': {
         'ENGINE': 'haystack.backends.whoosh_backend.WhooshEngine',
         'PATH': os.path.join(os.path.dirname(__file__), 'whoosh_index'),
     },
 }
 
 MARKUP_FIELD_TYPES = (
     ('bbcode', bbcode_extended),
 )
 
 THEMES = [
     ('md', 'Mystic Dark'),
     ('md_centered', 'Mystic Dark (centered)'),
     ('sw', 'Snow White'),
     ('pg', 'Photon Gray'),
 ]
 
-POPULAR_TAGS = 10
-
 POSTING_DELAY = 20  # seconds
 
-COMPRESS_HTML = True
+COMPRESS_HTML = False
+
+# Websocket settins
+CENTRIFUGE_HOST = 'localhost'
+CENTRIFUGE_PORT = '9090'
+
+CENTRIFUGE_ADDRESS = 'http://{}:{}'.format(CENTRIFUGE_HOST, CENTRIFUGE_PORT)
+CENTRIFUGE_PROJECT_ID = '<project id here>'
+CENTRIFUGE_PROJECT_SECRET = '<project secret here>'
+CENTRIFUGE_TIMEOUT = 5
 
 # Debug mode middlewares
 if DEBUG:
     MIDDLEWARE_CLASSES += (
         'debug_toolbar.middleware.DebugToolbarMiddleware',
     )
 
     def custom_show_toolbar(request):
         return False
 
     DEBUG_TOOLBAR_CONFIG = {
         'ENABLE_STACKTRACES': True,
         'SHOW_TOOLBAR_CALLBACK': 'neboard.settings.custom_show_toolbar',
     }
 
     # FIXME Uncommenting this fails somehow. Need to investigate this
     #DEBUG_TOOLBAR_PANELS += (
     #    'debug_toolbar.panels.profiling.ProfilingDebugPanel',
-    #)
-
+    #)
  No newline at end of file

requirements.txt

@@ -1,8 +1,9 b''
+adjacent
 south>=0.8.4
 haystack
 pillow
 django>=1.6
 django_cleanup
 django-markupfield
 bbcode
 django_compressor
  No newline at end of file