395 lines
12 KiB
JavaScript
395 lines
12 KiB
JavaScript
var weechat = angular.module('weechat', ['localStorage', 'weechatModels']);
|
|
|
|
weechat.factory('colors', [function($scope) {
|
|
|
|
// http://weechat.org/files/doc/devel/weechat_dev.en.html#color_codes_in_strings
|
|
var part, fg, bg, attrs, colors = ['', 'black', 'dark gray', 'dark red', 'light red', 'dark green', 'light green', 'brown', 'yellow', 'dark blue', 'light blue', 'dark magenta', 'light magenta', 'dark cyan', 'light cyan', 'gray', 'white'];
|
|
|
|
function setAttrs() {
|
|
while (part.match(/^[\*\/\_\|]/)) {
|
|
attrs.push(part.charAt(0));
|
|
part = part.slice(1);
|
|
}
|
|
}
|
|
|
|
function getColor() {
|
|
var c;
|
|
if (part.match(/^@/)) {
|
|
c = part.slice(1, 5);
|
|
part = part.slice(5);
|
|
} else {
|
|
c = part.slice(0, 2);
|
|
part = part.slice(2);
|
|
}
|
|
return c;
|
|
}
|
|
|
|
function prepareCss(color) {
|
|
/*
|
|
* Translates a weechat color string to CSS
|
|
*/
|
|
return'color-' + color.replace(' ', '-');
|
|
}
|
|
|
|
var prefixes = {
|
|
'\x19': function() {
|
|
if (part.match(/^F/)) {
|
|
part = part.slice(1);
|
|
setAttrs();
|
|
fg = getColor();
|
|
} else if (part.match(/^B/)) {
|
|
part = part.slice(1);
|
|
setAttrs();
|
|
bg = getColor();
|
|
} else {
|
|
setAttrs();
|
|
fg = getColor();
|
|
if (part.match(/^,/)) {
|
|
part = part.slice(1);
|
|
bg = getColor();
|
|
}
|
|
}
|
|
},
|
|
'\x1A': function() {
|
|
// Don't know what to do
|
|
},
|
|
'\x1B': function() {
|
|
attrs = [];
|
|
},
|
|
'\x1C': function() {
|
|
fg = '';
|
|
bg = '';
|
|
}
|
|
};
|
|
|
|
function parse(text) {
|
|
if (!text) {
|
|
return text;
|
|
}
|
|
var f, parts = text.split(/(\x19|\x1A|\x1B|\x1C)/);
|
|
if (parts.length === 1) return [{
|
|
text: parts[0]
|
|
}];
|
|
attrs = [];
|
|
|
|
return parts.map(function(p) {
|
|
var res, tmp = prefixes[p.charAt(0)];
|
|
if (f) {
|
|
part = p;
|
|
f();
|
|
res = {
|
|
text: part,
|
|
fg: colors[parseInt(fg, 10)],
|
|
bg: colors[parseInt(bg, 10)],
|
|
attrs: attrs
|
|
};
|
|
if (!res.fg) res.fg = fg;
|
|
if (!res.bg) res.bg = bg;
|
|
}
|
|
f = tmp;
|
|
return res;
|
|
}).filter(function(p) {
|
|
return p;
|
|
});
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return {
|
|
|
|
setAttrs: setAttrs,
|
|
getColor: getColor,
|
|
prepareCss: prepareCss,
|
|
parse: parse,
|
|
parts: ['', 'black', 'dark gray', 'dark red', 'light red', 'dark green', 'light green', 'brown', 'yellow', 'dark blue', 'light blue', 'dark magenta', 'light magenta', 'dark cyan', 'light cyan', 'gray', 'white']
|
|
}
|
|
|
|
}]);
|
|
|
|
weechat.factory('pluginManager', ['youtubePlugin', 'urlPlugin', 'imagePlugin', function(youtubePlugin, urlPlugin, imagePlugin) {
|
|
|
|
var plugins = [youtubePlugin, urlPlugin, imagePlugin]
|
|
|
|
var hookPlugin = function(plugin) {
|
|
plugins.push(plugin);
|
|
}
|
|
|
|
var contentForMessage = function(message) {
|
|
|
|
var content = [];
|
|
for (var i = 0; i < plugins.length; i++) {
|
|
var pluginContent = plugins[i].contentForMessage(message);
|
|
if (pluginContent) {
|
|
var pluginContent = {'visible': false, 'content': pluginContent }
|
|
content.push(pluginContent);
|
|
|
|
if (plugins[i].exclusive) {
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
return content;
|
|
}
|
|
|
|
return {
|
|
hookPlugin: hookPlugin,
|
|
contentForMessage: contentForMessage
|
|
}
|
|
|
|
}]);
|
|
|
|
weechat.factory('youtubePlugin', [function() {
|
|
|
|
var contentForMessage = function(message) {
|
|
if (message.indexOf('youtube.com') != -1) {
|
|
var index = message.indexOf("?v=");
|
|
var token = message.substr(index+3);
|
|
return '<iframe width="560" height="315" src="http://www.youtube.com/embed/' + token + '" frameborder="0" allowfullscreen></iframe>'
|
|
}
|
|
return null;
|
|
}
|
|
|
|
return {
|
|
contentForMessage: contentForMessage,
|
|
exclusive: true
|
|
}
|
|
|
|
}]);
|
|
|
|
weechat.factory('urlPlugin', [function() {
|
|
var contentForMessage = function(message) {
|
|
var urlPattern = /(http|ftp|https):\/\/[\w-]+(\.[\w-]+)+([\w.,@?^=%&:\/~+#-]*[\w@?^=%&\/~+#-])?/;
|
|
var url = message.match(urlPattern);
|
|
if (url) {
|
|
return '<a href="' + url[0] + '">' + message + '</a>';
|
|
}
|
|
return null;
|
|
}
|
|
|
|
return {
|
|
contentForMessage: contentForMessage,
|
|
exclusive: false
|
|
}
|
|
}]);
|
|
|
|
weechat.factory('imagePlugin', [function() {
|
|
var contentForMessage = function(message) {
|
|
var urls = message.match(/https?:\/\/[^\s]*\.(jpg|png|gif)\b/)
|
|
if (urls != null) {
|
|
var url = urls[0]; /* Actually parse one url per message */
|
|
return '<img src="' + url + '" height="300">';
|
|
}
|
|
return null;
|
|
}
|
|
|
|
return {
|
|
contentForMessage: contentForMessage
|
|
}
|
|
}]);
|
|
|
|
weechat.factory('handlers', ['$rootScope', 'colors', 'models', 'pluginManager', function($rootScope, colors, models, pluginManager) {
|
|
|
|
var handleBufferClosing = function(message) {
|
|
var bufferMessage = message['objects'][0]['content'][0];
|
|
var buffer = new models.Buffer(bufferMessage);
|
|
$rootScope.closeBuffer(buffer.id);
|
|
}
|
|
|
|
var handleBufferLineAdded = function(message) {
|
|
var buffer_line = {}
|
|
|
|
message = new models.BufferLine(message);
|
|
message.metadata = pluginManager.contentForMessage(message.text);
|
|
|
|
if (!_isActiveBuffer(message.buffer)) {
|
|
$rootScope.buffers[message.buffer]['notification'] = true;
|
|
}
|
|
|
|
$rootScope.buffers[message.buffer]['lines'].push(message);
|
|
}
|
|
|
|
/*
|
|
* Returns whether or not this buffer is the active buffer
|
|
*/
|
|
var _isActiveBuffer = function(buffer) {
|
|
if ($rootScope.activeBuffer['id'] == buffer) {
|
|
return true;
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
var handleBufferOpened = function(message) {
|
|
var bufferMessage = message['objects'][0]['content'][0];
|
|
var buffer = new models.Buffer(bufferMessage);
|
|
$rootScope.buffers[buffer.id] = buffer;
|
|
|
|
}
|
|
|
|
/*
|
|
* Handle answers to (bufinfo) messages
|
|
*
|
|
* (bufinfo) messages are specified by this client. It is the first
|
|
* message that is sent to the relay after connection.
|
|
*/
|
|
var handleBufferInfo = function(message) {
|
|
// buffer info from message
|
|
var bufferInfos = message['objects'][0]['content'];
|
|
// buffers objects
|
|
var buffers = {};
|
|
for (var i = 0; i < bufferInfos.length ; i++) {
|
|
var buffer = new models.Buffer(bufferInfos[i]);
|
|
buffers[buffer.id] = buffer;
|
|
if (i == 0) {
|
|
// first buffer is active buffer by default
|
|
$rootScope.activeBuffer = buffers[buffer.id];
|
|
}
|
|
}
|
|
$rootScope.buffers = buffers;
|
|
}
|
|
|
|
var handleEvent = function(event) {
|
|
if (_.has(eventHandlers, event['id'])) {
|
|
eventHandlers[event['id']](event);
|
|
}
|
|
|
|
}
|
|
|
|
var findMetaData = function(message) {
|
|
if (message.indexOf('youtube.com') != -1) {
|
|
var index = message.indexOf("?v=");
|
|
var token = message.substr(index+3);
|
|
return '<iframe width="560" height="315" src="http://www.youtube.com/embed/' + token + '" frameborder="0" allowfullscreen></iframe>'
|
|
}
|
|
return null;
|
|
}
|
|
|
|
var eventHandlers = {
|
|
bufinfo: handleBufferInfo,
|
|
_buffer_closing: handleBufferClosing,
|
|
_buffer_line_added: handleBufferLineAdded,
|
|
_buffer_opened: handleBufferOpened
|
|
}
|
|
|
|
return {
|
|
handleEvent: handleEvent
|
|
|
|
}
|
|
|
|
}]);
|
|
|
|
weechat.factory('connection', ['$rootScope', '$log', 'handlers', 'colors', function($rootScope, $log, handlers, colors) {
|
|
protocol = new WeeChatProtocol();
|
|
var websocket = null;
|
|
|
|
|
|
// Sanitizes messages to be sent to the weechat relay
|
|
var doSend = function(message) {
|
|
msgs = message.replace(/[\r\n]+$/g, "").split("\n");
|
|
for (var i = 0; i < msgs.length; i++) {
|
|
$log.log('=' + msgs[i] + '=');
|
|
$rootScope.commands.push("SENT: " + msgs[i]);
|
|
}
|
|
websocket.send(message);
|
|
}
|
|
|
|
// Takes care of the connection and websocket hooks
|
|
var connect = function (hostport, proto, passwd) {
|
|
websocket = new WebSocket("ws://" + hostport + "/weechat");
|
|
websocket.binaryType = "arraybuffer"
|
|
|
|
websocket.onopen = function (evt) {
|
|
// FIXME: does password need to be sent only if protocol is not weechat?
|
|
if (proto == "weechat") {
|
|
doSend(WeeChatProtocol.formatInit({
|
|
password: passwd,
|
|
compression: 'off'
|
|
}));
|
|
doSend(WeeChatProtocol.formatHdata({
|
|
id: 'bufinfo',
|
|
path: 'buffer:gui_buffers(*)',
|
|
keys: ['full_name']
|
|
}));
|
|
doSend(WeeChatProtocol.formatSync({}));
|
|
} else {
|
|
|
|
}
|
|
$log.info("Connected to relay");
|
|
$rootScope.connected = true;
|
|
$rootScope.$apply();
|
|
}
|
|
|
|
websocket.onclose = function (evt) {
|
|
$log.info("Disconnected from relay");
|
|
$rootScope.connected = false;
|
|
$rootScope.$apply();
|
|
}
|
|
|
|
websocket.onmessage = function (evt) {
|
|
message = protocol.parse(evt.data)
|
|
handlers.handleEvent(message);
|
|
$rootScope.commands.push("RECV: " + evt.data + " TYPE:" + evt.type) ;
|
|
$rootScope.$apply();
|
|
}
|
|
|
|
websocket.onerror = function (evt) {
|
|
if (evt.type == "error" && websocket.readyState == 0) {
|
|
$rootScope.errorMessage = true;
|
|
}
|
|
$log.error("Relay error " + evt.data);
|
|
}
|
|
|
|
this.websocket = websocket;
|
|
}
|
|
|
|
var sendMessage = function(message) {
|
|
doSend(WeeChatProtocol.formatInput({
|
|
buffer: $rootScope.activeBuffer['fullName'],
|
|
data: message
|
|
}));
|
|
}
|
|
|
|
return {
|
|
connect: connect,
|
|
sendMessage: sendMessage
|
|
}
|
|
}]);
|
|
|
|
weechat.controller('WeechatCtrl', ['$rootScope', '$scope', '$store', 'connection', function ($rootScope, $scope, $store, connection) {
|
|
$rootScope.commands = []
|
|
|
|
$rootScope.buffer = []
|
|
$rootScope.buffers = {}
|
|
$rootScope.activeBuffer = null;
|
|
$store.bind($scope, "hostport", "localhost:9001");
|
|
$store.bind($scope, "proto", "weechat");
|
|
$store.bind($scope, "password", "");
|
|
// TODO checkbox for saving password or not?
|
|
// $scope.password = "";
|
|
|
|
$rootScope.closeBuffer = function(buffer_pointer) {
|
|
delete($rootScope.buffers[buffer_pointer]);
|
|
var first_buffer = _.keys($rootScope.buffers)[0];
|
|
$scope.setActiveBuffer(first_buffer);
|
|
}
|
|
|
|
$scope.setActiveBuffer = function(key) {
|
|
$rootScope.buffers[key]['notification'] = false;
|
|
$rootScope.activeBuffer = $rootScope.buffers[key];
|
|
};
|
|
|
|
$scope.sendMessage = function() {
|
|
connection.sendMessage($scope.command);
|
|
$scope.command = "";
|
|
};
|
|
|
|
$scope.connect = function() {
|
|
connection.connect($scope.hostport, $scope.proto, $scope.password);
|
|
}
|
|
}]
|
|
);
|