glowingbear-mainbox/js/websockets.js

530 lines
18 KiB
JavaScript
Raw Normal View History

var weechat = angular.module('weechat', ['localStorage', 'weechatModels', 'plugins', 'ngSanitize']);
2013-02-18 00:49:42 +01:00
weechat.filter('toArray', function () {
'use strict';
return function (obj) {
if (!(obj instanceof Object)) {
return obj;
}
return Object.keys(obj).map(function (key) {
return Object.defineProperty(obj[key], '$key', {__proto__: null, value: key});
});
}
});
2013-02-18 00:49:42 +01:00
weechat.factory('colors', [function($scope) {
return {
prepareCss: weeChat.color.prepareCss,
parse: weeChat.color.parse
};
}]);
2013-10-08 23:55:30 +02:00
weechat.factory('handlers', ['$rootScope', 'colors', 'models', 'plugins', function($rootScope, colors, models, plugins) {
2013-08-05 03:39:23 +02:00
2013-10-02 02:32:18 +02:00
var handleBufferClosing = function(message) {
2013-10-08 03:15:25 +02:00
var bufferMessage = message['objects'][0]['content'][0];
var buffer = new models.Buffer(bufferMessage);
2013-10-08 16:13:48 +02:00
models.closeBuffer(buffer);
2013-10-02 02:32:18 +02:00
}
var handleLine = function(line, initial) {
2013-10-09 17:53:25 +02:00
var message = new models.BufferLine(line);
2013-10-06 12:34:41 +02:00
// Only react to line if its displayed
2013-10-09 17:53:25 +02:00
if(message.displayed) {
var buffer = models.getBuffer(message.buffer);
message = plugins.PluginManager.contentForMessage(message);
2013-10-09 17:53:25 +02:00
buffer.addLine(message);
2013-10-06 02:06:28 +02:00
2013-10-09 17:53:25 +02:00
if (buffer.active) {
$rootScope.scrollToBottom();
2013-10-06 12:34:41 +02:00
}
2013-10-08 15:55:07 +02:00
2013-10-09 17:53:25 +02:00
if (!initial) {
2013-10-16 00:32:56 +02:00
if (!buffer.active && !buffer.notify==0 && _.contains(message.tags, 'notify_message') && !_.contains(message.tags, 'notify_none')) {
buffer.unread++;
2013-10-15 15:21:13 +02:00
$rootScope.$emit('notificationChanged');
2013-10-09 17:53:25 +02:00
}
2013-10-16 00:32:56 +02:00
if(!buffer.notify==0 && message.highlight || _.contains(message.tags, 'notify_private') ) {
buffer.notification++;
2013-10-09 17:53:25 +02:00
$rootScope.createHighlight(buffer, message);
2013-10-15 15:21:13 +02:00
$rootScope.$emit('notificationChanged');
2013-10-09 17:53:25 +02:00
}
2013-10-06 12:34:41 +02:00
}
2013-10-08 16:03:44 +02:00
}
2013-08-05 03:39:23 +02:00
}
2013-10-06 20:20:34 +02:00
var handleBufferLineAdded = function(message) {
message['objects'][0]['content'].forEach(function(l) {
handleLine(l, false);
2013-10-06 20:20:34 +02:00
});
}
2013-08-05 03:39:23 +02:00
var handleBufferOpened = function(message) {
2013-10-08 03:15:25 +02:00
var bufferMessage = message['objects'][0]['content'][0];
var buffer = new models.Buffer(bufferMessage);
2013-10-08 16:05:46 +02:00
models.addBuffer(buffer);
2013-08-05 03:39:23 +02:00
}
2013-10-06 02:06:28 +02:00
2013-10-07 00:24:18 +02:00
var handleBufferTitleChanged = function(message) {
var obj = message['objects'][0]['content'][0];
var buffer = obj['pointers'][0];
var old = models.getBuffer(buffer);
old.fullName = obj['full_name'];
old.title = obj['title'];
old.number = obj['number'];
}
var handleBufferRenamed = function(message) {
var obj = message['objects'][0]['content'][0];
var buffer = obj['pointers'][0];
var old = models.getBuffer(buffer);
old.fullName = obj['full_name'];
old.shortName = obj['short_name'];
2013-08-05 03:39:23 +02:00
}
2013-10-06 20:20:34 +02:00
/*
* Handle answers to (lineinfo) messages
*
* (lineinfo) messages are specified by this client. It is request after bufinfo completes
*/
var handleLineInfo = function(message) {
var lines = message['objects'][0]['content'].reverse();
lines.forEach(function(l) {
handleLine(l, true);
2013-10-06 20:20:34 +02:00
});
}
2013-10-06 02:06:28 +02:00
/*
* Handle answers to hotlist request
*/
var handleHotlistInfo = function(message) {
var hotlist = message['objects'][0]['content'];
hotlist.forEach(function(l) {
var buffer = models.getBuffer(l.buffer);
// 1 is message
buffer.unread += l.count[1];
// 2 is ?
buffer.unread += l.count[2];
// 3 is highlight
buffer.notification += l.count[3];
/* Since there is unread messages, we can guess
* what the last read line is and update it accordingly
*/
var unreadSum = _.reduce(l.count, function(memo, num){ return memo + num; }, 0);
buffer.lastSeen = buffer.lines.length - 1 - unreadSum;
});
}
var handleEvent = function(event) {
if (_.has(eventHandlers, event['id'])) {
eventHandlers[event['id']](event);
}
2013-08-05 03:39:23 +02:00
}
var eventHandlers = {
2013-10-06 02:06:28 +02:00
_buffer_closing: handleBufferClosing,
2013-08-05 03:39:23 +02:00
_buffer_line_added: handleBufferLineAdded,
2013-10-07 00:24:18 +02:00
_buffer_opened: handleBufferOpened,
_buffer_title_changed: handleBufferTitleChanged,
_buffer_renamed: handleBufferRenamed
2013-08-05 03:39:23 +02:00
}
return {
2013-10-12 18:29:10 +02:00
handleEvent: handleEvent,
handleLineInfo: handleLineInfo,
handleHotlistInfo: handleHotlistInfo
2013-08-05 03:39:23 +02:00
}
}]);
2013-10-15 17:20:35 +02:00
weechat.factory('connection', ['$q', '$rootScope', '$log', '$store', 'handlers', 'colors', 'models', function($q, $rootScope, $log, storage, handlers, colors, models) {
protocol = new weeChat.Protocol();
2013-08-02 03:54:12 +02:00
var websocket = null;
var callbacks = {}
var currentCallBackId = 0;
var doSendWithCallback = function(message) {
var defer = $q.defer();
callbacks[++currentCallBackId] = {
time: new Date,
cb: defer
}
callBackIdString = "(" + currentCallBackId + ")";
doSend(callBackIdString + " " + message);
return defer.promise;
}
2013-10-06 02:06:28 +02:00
// Sanitizes messages to be sent to the weechat relay
var doSend = function(message) {
2013-08-02 03:54:12 +02:00
msgs = message.replace(/[\r\n]+$/g, "").split("\n");
for (var i = 0; i < msgs.length; i++) {
$log.log('=' + msgs[i] + '=');
2013-08-02 03:55:51 +02:00
$rootScope.commands.push("SENT: " + msgs[i]);
2013-02-18 00:49:42 +01:00
}
2013-08-02 03:54:12 +02:00
websocket.send(message);
}
// Takes care of the connection and websocket hooks
var connect = function (host, port, passwd, ssl) {
2013-10-07 15:38:47 +02:00
var proto = ssl ? 'wss':'ws';
websocket = new WebSocket(proto+"://" + host + ':' + port + "/weechat");
2013-08-02 03:54:12 +02:00
websocket.binaryType = "arraybuffer"
2013-02-18 00:49:42 +01:00
2013-08-02 03:54:12 +02:00
websocket.onopen = function (evt) {
2013-10-15 17:20:35 +02:00
$log.info("Connected to relay");
// First message must be an init request
// with the password
doSend(weeChat.Protocol.formatInit({
password: passwd,
compression: 'off'
2013-10-15 17:20:35 +02:00
}));
// password is bad until the next message
// received proven the otherwise.
$rootScope.passwordError = true;
// We are asking for the weechat version here
// to avoid two problems :
// - If the version is below 0.4.2, we will have a bug
// with websocket.
// - If the user password is wrong, we will be disconneted
// at this step.
doSendWithCallback(weeChat.Protocol.formatInfo({
name: 'version',
2013-10-15 17:20:35 +02:00
})).then(function(message) {
// If we have received this message
// that means the user password is good.
$rootScope.passwordError = false;
// Parse the version info message to retrieve
// the current weechat version.
var version = message['objects'][0]['content']['value'];
$rootScope.version = version;
$log.info(version);
2013-10-15 17:20:35 +02:00
}).then(function() {
doSendWithCallback(weeChat.Protocol.formatHdata({
path: 'buffer:gui_buffers(*)',
keys: ['local_variables,notify,number,full_name,short_name,title']
})).then(function(message) {
$log.info("Parsing bufinfo");
var bufferInfos = message['objects'][0]['content'];
// buffers objects
for (var i = 0; i < bufferInfos.length ; i++) {
var buffer = new models.Buffer(bufferInfos[i]);
models.addBuffer(buffer);
// Switch to first buffer on startup
if (i == 0) {
models.setActiveBuffer(buffer.id);
}
}
}).then(function() {
$log.info("Parsing lineinfo");
doSendWithCallback(weeChat.Protocol.formatHdata({
path: "buffer:gui_buffers(*)/own_lines/last_line(-"+storage.get('lines')+")/data",
keys: []
})).then(function(hdata) {
handlers.handleLineInfo(hdata);
});
}).then(function() {
$log.info("Requesting hotlist");
doSendWithCallback(weeChat.Protocol.formatHdata({
path: "hotlist:gui_hotlist(*)",
keys: []
})).then(function(hdata) {
handlers.handleHotlistInfo(hdata)
});
}).then(function() {
doSend(weeChat.Protocol.formatSync({}));
$log.info("Synced");
// here we are really connected !
$rootScope.connected = true;
});
});
}
2013-08-02 03:54:12 +02:00
websocket.onclose = function (evt) {
$log.info("Disconnected from relay");
2013-08-02 03:55:51 +02:00
$rootScope.connected = false;
if ($rootScope.passwordError == true) {
$log.info("wrong password");
}
$rootScope.$apply();
2013-08-02 03:54:12 +02:00
}
2013-08-02 03:54:12 +02:00
websocket.onmessage = function (evt) {
message = protocol.parse(evt.data)
if (_.has(callbacks, message['id'])) {
var promise = callbacks[message['id']];
2013-10-12 18:29:10 +02:00
promise.cb.resolve(message);
delete(callbacks[message['id']]);
} else {
handlers.handleEvent(message);
}
2013-08-02 03:55:51 +02:00
$rootScope.commands.push("RECV: " + evt.data + " TYPE:" + evt.type) ;
$rootScope.$apply();
2013-08-02 03:54:12 +02:00
}
2013-08-02 03:54:12 +02:00
websocket.onerror = function (evt) {
// on error it means the connection problem
// come from the relay not from the password.
$rootScope.passwordError = false;
2013-10-07 15:38:47 +02:00
if (evt.type == "error" && websocket.readyState != 1) {
2013-10-03 01:55:30 +02:00
$rootScope.errorMessage = true;
}
$log.error("Relay error " + evt.data);
2013-02-18 00:49:42 +01:00
}
2013-08-02 03:54:12 +02:00
this.websocket = websocket;
}
2013-10-16 14:25:07 +02:00
var disconnect = function() {
console.log(this.websocket);
this.websocket.close();
}
2013-08-02 03:54:12 +02:00
var sendMessage = function(message) {
doSend(weeChat.Protocol.formatInput({
2013-10-08 15:55:07 +02:00
buffer: models.getActiveBuffer()['fullName'],
data: message
}));
2013-08-02 03:54:12 +02:00
}
var sendCoreCommand = function(command) {
doSend(weeChat.Protocol.formatInput({
buffer: 'core.weechat',
data: command
}));
}
2013-10-06 20:20:34 +02:00
2013-08-02 03:54:12 +02:00
return {
2013-10-06 20:20:34 +02:00
send: doSend,
2013-08-02 03:54:12 +02:00
connect: connect,
2013-10-16 14:25:07 +02:00
disconnect: disconnect,
sendMessage: sendMessage,
sendCoreCommand: sendCoreCommand
2013-08-02 03:54:12 +02:00
}
2013-02-18 00:49:42 +01:00
}]);
weechat.controller('WeechatCtrl', ['$rootScope', '$scope', '$store', '$timeout', '$log', 'models', 'connection', function ($rootScope, $scope, $store, $timeout, $log, models, connection, testService) {
2013-10-08 15:55:07 +02:00
2013-10-06 12:34:41 +02:00
// Request notification permission
Notification.requestPermission(function (status) {
$log.info('Notification permission status:',status);
2013-10-06 12:34:41 +02:00
if (Notification.permission !== status) {
Notification.permission = status;
}
});
if(window.webkitNotifications != undefined) {
if (window.webkitNotifications.checkPermission() == 0) { // 0 is PERMISSION_ALLOWED
$log.info('Notification permission status:', window.webkitNotifications.checkPermission() == 0);
2013-10-06 12:34:41 +02:00
window.webkitNotifications.requestPermission();
}
}
$rootScope.$on('activeBufferChanged', function() {
$rootScope.scrollToBottom();
document.getElementById('sendMessage').focus();
var ab = models.getActiveBuffer();
$rootScope.pageTitle = ab.shortName + ' | ' + ab.title;
// If user wants to sync hotlist with weechat
// we will send a /buffer bufferName command every time
// the user switches a buffer. This will ensure that notifications
// are cleared in the buffer the user switches to
if($scope.hotlistsync && ab.fullName) {
/*
doSend(weeChat.Protocol.formatInput({
buffer: 'weechat',
data: '/buffer ' + ab.fullName
}));
*/
connection.sendCoreCommand('/buffer ' + ab.fullName);
}
});
2013-10-15 15:21:13 +02:00
$rootScope.$on('notificationChanged', function() {
2013-10-15 19:08:24 +02:00
var notifications = _.reduce(models.model.buffers, function(memo, num) { return (memo||0) + num.notification;});
2013-10-15 15:21:13 +02:00
if (notifications > 0 ) {
$scope.favico = new Favico({
animation:'none'
});
$scope.favico.badge(notifications);
}else {
2013-10-15 19:08:24 +02:00
var unread = _.reduce(models.model.buffers, function(memo, num) { return (memo||0) + num.unread;});
2013-10-15 15:21:13 +02:00
$scope.favico = new Favico({
animation:'none',
bgColor : '#5CB85C',
textColor : '#ff0',
});
$scope.favico.badge(unread);
}
});
2013-10-08 15:55:07 +02:00
$scope.buffers = models.model.buffers;
$scope.activeBuffer = models.getActiveBuffer
2013-02-18 00:49:42 +01:00
$rootScope.commands = []
2013-02-16 19:18:14 +01:00
2013-10-08 15:55:07 +02:00
$rootScope.models = models;
$rootScope.buffer = []
2013-10-08 15:55:07 +02:00
$store.bind($scope, "host", "localhost");
$store.bind($scope, "port", "9001");
$store.bind($scope, "proto", "weechat");
$store.bind($scope, "password", "");
2013-10-09 17:53:25 +02:00
$store.bind($scope, "ssl", false);
$store.bind($scope, "lines", "40");
// TODO checkbox for saving password or not?
// $scope.password = "";
//
2013-10-17 10:50:29 +02:00
// Save setting for displaying only buffers with unread messages
$store.bind($scope, "onlyUnread", false);
2013-10-17 10:50:29 +02:00
// Save setting for not showing timestamp
$store.bind($scope, "notimestamp", false);
// Save setting for syncing hotlist
$store.bind($scope, "hotlistsync", true);
2013-10-02 02:32:18 +02:00
2013-07-30 15:22:37 +02:00
$scope.setActiveBuffer = function(key) {
2013-10-08 15:55:07 +02:00
models.setActiveBuffer(key);
2013-07-30 15:22:37 +02:00
};
2013-10-07 16:58:41 +02:00
$rootScope.scrollToBottom = function() {
// FIXME doesn't work if the settimeout runs without a short delay
// 300 ms seems to do the trick but creates a noticable flickr
var scroll = function() {
2013-10-12 20:44:40 +02:00
var readmarker = document.getElementById('readmarker');
if(readmarker) {
readmarker.scrollIntoView();
}else{
window.scroll(0, document.documentElement.scrollHeight - document.documentElement.clientHeight);
2013-10-11 18:45:01 +02:00
}
}
scroll();
$timeout(scroll, 300);
2013-10-07 16:58:41 +02:00
}
2013-02-18 00:49:42 +01:00
$scope.sendMessage = function() {
connection.sendMessage($scope.command);
$scope.command = "";
2013-07-30 15:22:37 +02:00
};
2013-02-16 19:18:14 +01:00
2013-02-18 00:49:42 +01:00
$scope.connect = function() {
connection.connect($scope.host, $scope.port, $scope.password, $scope.ssl);
2013-02-16 19:18:14 +01:00
}
2013-10-16 14:44:44 +02:00
$scope.disconnect = function() {
2013-10-16 14:25:07 +02:00
connection.disconnect();
}
2013-10-06 12:34:41 +02:00
/* Function gets called from bufferLineAdded code if user should be notified */
2013-10-09 17:53:25 +02:00
$rootScope.createHighlight = function(buffer, message) {
2013-10-06 12:34:41 +02:00
var messages = "";
2013-10-09 17:53:25 +02:00
message.content.forEach(function(part) {
if (part.text != undefined)
messages += part.text + " ";
});
2013-10-06 12:34:41 +02:00
2013-10-09 17:53:25 +02:00
var title = buffer.fullName;
var content = messages;
2013-10-06 12:34:41 +02:00
var timeout = 15*1000;
$log.info('Displaying notification:buffer:',buffer,',message:',message,',with timeout:',timeout);
2013-10-06 12:34:41 +02:00
var notification = new Notification(title, {body:content, icon:'img/favicon.png'});
// Cancel notification automatically
notification.onshow = function() {
setTimeout(function() { notification.close() }, timeout);
}
};
$scope.hasUnread = function(buffer) {
// if search is set, return every buffer
2013-10-16 23:04:42 +02:00
if($scope.search && $scope.search != "") {
return true;
}
if($scope.onlyUnread) {
2013-10-11 23:47:47 +02:00
// Always show current buffer in list
if (models.getActiveBuffer() == buffer) {
return true;
}
return buffer.unread > 0 || buffer.notification > 0;
}
return true;
};
2013-10-11 15:59:55 +02:00
$rootScope.switchToActivityBuffer = function() {
// Find next buffer with activity and switch to it
2013-10-11 22:43:01 +02:00
for(i in $scope.buffers) {
var buffer = $scope.buffers[i];
if(buffer.notification > 0) {
2013-10-11 15:59:55 +02:00
$scope.setActiveBuffer(buffer.id);
2013-10-11 22:43:01 +02:00
break;
}else if(buffer.unread > 0) {
2013-10-11 15:59:55 +02:00
$scope.setActiveBuffer(buffer.id);
2013-10-11 22:43:01 +02:00
break;
2013-10-11 15:59:55 +02:00
}
2013-10-11 22:43:01 +02:00
}
2013-10-11 15:59:55 +02:00
}
$scope.handleKeyPress = function($event) {
2013-10-11 16:24:25 +02:00
// Support different browser quirks
var code = $event.keyCode ? $event.keyCode : $event.charCode;
if ($event.altKey && (code > 47 && code < 58)) {
if (code == 48) {
code = 58;
}
var bufferNumber = code - 48;
var activeBuffer = models.getBufferByIndex(bufferNumber);
if (activeBuffer) {
models.setActiveBuffer(activeBuffer.id);
$event.preventDefault();
}
}
//log('keypress', $event.charCode, $event.altKey);
2013-10-11 16:24:25 +02:00
2013-10-11 15:59:55 +02:00
// Handle alt-a
2013-10-11 16:24:25 +02:00
if($event.altKey && (code == 97 || code == 65)) {
2013-10-12 20:44:40 +02:00
$event.preventDefault();
2013-10-11 15:59:55 +02:00
$rootScope.switchToActivityBuffer();
return true;
}
// Handle ctrl-g
2013-10-11 16:24:25 +02:00
if($event.ctrlKey && (code == 103 || code == 71)) {
2013-10-12 20:44:40 +02:00
document.getElementById('bufferFilter').focus();
2013-10-11 15:59:55 +02:00
return true;
}
};
2013-10-17 13:13:01 +02:00
$scope.handleSearchBoxKey = function($event) {
// Support different browser quirks
var code = $event.keyCode ? $event.keyCode : $event.charCode;
// Handle escape
if(code == 27) {
$event.preventDefault();
$scope.search = '';
} // Handle enter
else if (code == 13) {
$event.preventDefault();
// TODO Switch to first matching buffer and reset query
$scope.search = '';
}
}
2013-10-15 15:21:13 +02:00
2013-08-02 03:54:12 +02:00
}]
);