Merge pull request #430 from glowing-bear/refactor
[WIP] Refactor Glowing Bear
This commit is contained in:
David Cormier
commit
4f23eb7334
|
|
@ -24,6 +24,13 @@
|
|||
<script type="text/javascript" src="js/weechat.js"></script>
|
||||
<script type="text/javascript" src="js/irc-utils.js"></script>
|
||||
<script type="text/javascript" src="js/glowingbear.js"></script>
|
||||
<script type="text/javascript" src="js/utils.js"></script>
|
||||
<script type="text/javascript" src="js/notifications.js"></script>
|
||||
<script type="text/javascript" src="js/filters.js"></script>
|
||||
<script type="text/javascript" src="js/handlers.js"></script>
|
||||
<script type="text/javascript" src="js/connection.js"></script>
|
||||
<script type="text/javascript" src="js/inputbar.js"></script>
|
||||
<script type="text/javascript" src="js/plugin-directive.js"></script>
|
||||
<script type="text/javascript" src="js/websockets.js"></script>
|
||||
<script type="text/javascript" src="js/models.js"></script>
|
||||
<script type="text/javascript" src="js/plugins.js"></script>
|
||||
|
|
|
|||
|
|
@ -0,0 +1,280 @@
|
|||
var weechat = angular.module('weechat');
|
||||
|
||||
weechat.factory('connection',
|
||||
['$rootScope', '$log', 'handlers', 'models', 'ngWebsockets', function($rootScope,
|
||||
$log,
|
||||
handlers,
|
||||
models,
|
||||
ngWebsockets) {
|
||||
|
||||
protocol = new weeChat.Protocol();
|
||||
|
||||
// Takes care of the connection and websocket hooks
|
||||
|
||||
var connect = function (host, port, passwd, ssl, noCompression) {
|
||||
var proto = ssl ? 'wss' : 'ws';
|
||||
// If host is an IPv6 literal wrap it in brackets
|
||||
if (host.indexOf(":") !== -1) {
|
||||
host = "[" + host + "]";
|
||||
}
|
||||
var url = proto + "://" + host + ":" + port + "/weechat";
|
||||
$log.debug('Connecting to URL: ', url);
|
||||
|
||||
var onopen = function () {
|
||||
|
||||
|
||||
// Helper methods for initialization commands
|
||||
var _initializeConnection = function(passwd) {
|
||||
// This is not the proper way to do this.
|
||||
// WeeChat does not send a confirmation for the init.
|
||||
// Until it does, We need to "assume" that formatInit
|
||||
// will be received before formatInfo
|
||||
ngWebsockets.send(
|
||||
weeChat.Protocol.formatInit({
|
||||
password: passwd,
|
||||
compression: noCompression ? 'off' : 'zlib'
|
||||
})
|
||||
);
|
||||
|
||||
return ngWebsockets.send(
|
||||
weeChat.Protocol.formatInfo({
|
||||
name: 'version'
|
||||
})
|
||||
);
|
||||
};
|
||||
|
||||
var _requestHotlist = function() {
|
||||
return ngWebsockets.send(
|
||||
weeChat.Protocol.formatHdata({
|
||||
path: "hotlist:gui_hotlist(*)",
|
||||
keys: []
|
||||
})
|
||||
);
|
||||
};
|
||||
|
||||
var _requestBufferInfos = function() {
|
||||
return ngWebsockets.send(
|
||||
weeChat.Protocol.formatHdata({
|
||||
path: 'buffer:gui_buffers(*)',
|
||||
keys: ['local_variables,notify,number,full_name,short_name,title']
|
||||
})
|
||||
);
|
||||
};
|
||||
|
||||
var _requestSync = function() {
|
||||
return ngWebsockets.send(
|
||||
weeChat.Protocol.formatSync({})
|
||||
);
|
||||
};
|
||||
|
||||
|
||||
// First command asks for the password and issues
|
||||
// a version command. If it fails, it means the we
|
||||
// did not provide the proper password.
|
||||
_initializeConnection(passwd).then(
|
||||
function() {
|
||||
// Connection is successful
|
||||
// Send all the other commands required for initialization
|
||||
_requestBufferInfos().then(function(bufinfo) {
|
||||
//XXX move to handlers?
|
||||
var bufferInfos = bufinfo.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);
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
_requestHotlist().then(function(hotlist) {
|
||||
handlers.handleHotlistInfo(hotlist);
|
||||
});
|
||||
|
||||
_requestSync();
|
||||
$log.info("Connected to relay");
|
||||
$rootScope.connected = true;
|
||||
},
|
||||
function() {
|
||||
// Connection got closed, lets check if we ever was connected successfully
|
||||
if (!$rootScope.waseverconnected) {
|
||||
$rootScope.passwordError = true;
|
||||
}
|
||||
}
|
||||
);
|
||||
|
||||
};
|
||||
|
||||
var onmessage = function() {
|
||||
// If we recieve a message from WeeChat it means that
|
||||
// password was OK. Store that result and check for it
|
||||
// in the failure handler.
|
||||
$rootScope.waseverconnected = true;
|
||||
};
|
||||
|
||||
|
||||
var onclose = function (evt) {
|
||||
/*
|
||||
* Handles websocket disconnection
|
||||
*/
|
||||
$log.info("Disconnected from relay");
|
||||
failCallbacks('disconnection');
|
||||
$rootScope.connected = false;
|
||||
$rootScope.$emit('relayDisconnect');
|
||||
if (ssl && evt.code === 1006) {
|
||||
// A password error doesn't trigger onerror, but certificate issues do. Check time of last error.
|
||||
if (typeof $rootScope.lastError !== "undefined" && (Date.now() - $rootScope.lastError) < 1000) {
|
||||
// abnormal disconnect by client, most likely ssl error
|
||||
$rootScope.sslError = true;
|
||||
}
|
||||
}
|
||||
$rootScope.$apply();
|
||||
};
|
||||
|
||||
var onerror = function (evt) {
|
||||
/*
|
||||
* Handles cases when connection issues come from
|
||||
* the relay.
|
||||
*/
|
||||
$log.error("Relay error", evt);
|
||||
$rootScope.lastError = Date.now();
|
||||
|
||||
if (evt.type === "error" && this.readyState !== 1) {
|
||||
failCallbacks('error');
|
||||
$rootScope.errorMessage = true;
|
||||
}
|
||||
};
|
||||
|
||||
protocol.setId = function(id, message) {
|
||||
return '(' + id + ') ' + message;
|
||||
};
|
||||
|
||||
|
||||
try {
|
||||
ngWebsockets.connect(url,
|
||||
protocol,
|
||||
{
|
||||
'binaryType': "arraybuffer",
|
||||
'onopen': onopen,
|
||||
'onclose': onclose,
|
||||
'onmessage': onmessage,
|
||||
'onerror': onerror
|
||||
});
|
||||
} catch(e) {
|
||||
$log.debug("Websocket caught DOMException:", e);
|
||||
$rootScope.lastError = Date.now();
|
||||
$rootScope.errorMessage = true;
|
||||
$rootScope.securityError = true;
|
||||
$rootScope.$emit('relayDisconnect');
|
||||
}
|
||||
|
||||
};
|
||||
|
||||
var disconnect = function() {
|
||||
ngWebsockets.send(weeChat.Protocol.formatQuit());
|
||||
};
|
||||
|
||||
/*
|
||||
* Format and send a weechat message
|
||||
*
|
||||
* @returns the angular promise
|
||||
*/
|
||||
var sendMessage = function(message) {
|
||||
ngWebsockets.send(weeChat.Protocol.formatInput({
|
||||
buffer: models.getActiveBuffer().fullName,
|
||||
data: message
|
||||
}));
|
||||
};
|
||||
|
||||
var sendCoreCommand = function(command) {
|
||||
ngWebsockets.send(weeChat.Protocol.formatInput({
|
||||
buffer: 'core.weechat',
|
||||
data: command
|
||||
}));
|
||||
};
|
||||
|
||||
|
||||
var requestNicklist = function(bufferId, callback) {
|
||||
bufferId = bufferId || null;
|
||||
ngWebsockets.send(
|
||||
weeChat.Protocol.formatNicklist({
|
||||
buffer: bufferId
|
||||
})
|
||||
).then(function(nicklist) {
|
||||
handlers.handleNicklist(nicklist);
|
||||
if (callback !== undefined) {
|
||||
callback();
|
||||
}
|
||||
});
|
||||
};
|
||||
|
||||
|
||||
var fetchMoreLines = function(numLines) {
|
||||
$log.debug('Fetching ', numLines, ' lines');
|
||||
var buffer = models.getActiveBuffer();
|
||||
if (numLines === undefined) {
|
||||
// Math.max(undefined, *) = NaN -> need a number here
|
||||
numLines = 0;
|
||||
}
|
||||
// Calculate number of lines to fetch, at least as many as the parameter
|
||||
numLines = Math.max(numLines, buffer.requestedLines * 2);
|
||||
|
||||
// Indicator that we are loading lines, hides "load more lines" link
|
||||
$rootScope.loadingLines = true;
|
||||
// Send hdata request to fetch lines for this particular buffer
|
||||
return ngWebsockets.send(
|
||||
weeChat.Protocol.formatHdata({
|
||||
// "0x" is important, otherwise it won't work
|
||||
path: "buffer:0x" + buffer.id + "/own_lines/last_line(-" + numLines + ")/data",
|
||||
keys: []
|
||||
})
|
||||
).then(function(lineinfo) {
|
||||
//XXX move to handlers?
|
||||
// delete old lines and add new ones
|
||||
var oldLength = buffer.lines.length;
|
||||
// Whether to set the readmarker to the middle position
|
||||
// Don't do that if we didn't get any more lines than we already had
|
||||
var setReadmarker = (buffer.lastSeen >= 0) && (oldLength !== buffer.lines.length);
|
||||
buffer.lines.length = 0;
|
||||
// We need to set the number of requested lines to 0 here, because parsing a line
|
||||
// increments it. This is needed to also count newly arriving lines while we're
|
||||
// already connected.
|
||||
buffer.requestedLines = 0;
|
||||
// Count number of lines recieved
|
||||
var linesReceivedCount = lineinfo.objects[0].content.length;
|
||||
|
||||
// Parse the lines
|
||||
handlers.handleLineInfo(lineinfo, true);
|
||||
|
||||
if (setReadmarker) {
|
||||
// Read marker was somewhere in the old lines - we don't need it any more,
|
||||
// set it to the boundary between old and new. This way, we stay at the exact
|
||||
// same position in the text through the scrollWithBuffer below
|
||||
buffer.lastSeen = buffer.lines.length - oldLength - 1;
|
||||
} else {
|
||||
// We are currently fetching at least some unread lines, so we need to keep
|
||||
// the read marker position correct
|
||||
buffer.lastSeen -= oldLength;
|
||||
}
|
||||
// We requested more lines than we got, no more lines.
|
||||
if (linesReceivedCount < numLines) {
|
||||
buffer.allLinesFetched = true;
|
||||
}
|
||||
$rootScope.loadingLines = false;
|
||||
// Scroll read marker to the center of the screen
|
||||
$rootScope.scrollWithBuffer(true);
|
||||
});
|
||||
};
|
||||
|
||||
|
||||
return {
|
||||
connect: connect,
|
||||
disconnect: disconnect,
|
||||
sendMessage: sendMessage,
|
||||
sendCoreCommand: sendCoreCommand,
|
||||
fetchMoreLines: fetchMoreLines,
|
||||
requestNicklist: requestNicklist
|
||||
};
|
||||
}]);
|
||||
|
|
@ -0,0 +1,53 @@
|
|||
var weechat = angular.module('weechat');
|
||||
|
||||
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', { value: key });
|
||||
});
|
||||
};
|
||||
});
|
||||
|
||||
weechat.filter('irclinky', ['$filter', function($filter) {
|
||||
'use strict';
|
||||
return function(text, target) {
|
||||
if (!text) {
|
||||
return text;
|
||||
}
|
||||
|
||||
var linkiedText = $filter('linky')(text, target);
|
||||
|
||||
// This regex in no way matches all IRC channel names (they could begin with a +, an &, or an exclamation
|
||||
// mark followed by 5 alphanumeric characters, and are bounded in length by 50).
|
||||
// However, it matches all *common* IRC channels while trying to minimise false positives. "#1" is much
|
||||
// more likely to be "number 1" than "IRC channel #1".
|
||||
// Thus, we only match channels beginning with a # and having at least one letter in them.
|
||||
var channelRegex = /(^|[\s,.:;?!"'()+@-])(#+[a-z0-9-_]*[a-z][a-z0-9-_]*)/gmi;
|
||||
// This is SUPER nasty, but ng-click does not work inside a filter, as the markup has to be $compiled first, which is not possible in filter afaik.
|
||||
// Therefore, get the scope, fire the method, and $apply. Yuck. I sincerely hope someone finds a better way of doing this.
|
||||
linkiedText = linkiedText.replace(channelRegex, '$1<a href="#" onclick="var $scope = angular.element(event.target).scope(); $scope.openBuffer(\'$2\'); $scope.$apply();">$2</a>');
|
||||
return linkiedText;
|
||||
};
|
||||
}]);
|
||||
|
||||
weechat.filter('inlinecolour', ['$sce', function($sce) {
|
||||
'use strict';
|
||||
|
||||
return function(text) {
|
||||
if (!text) {
|
||||
return text;
|
||||
}
|
||||
|
||||
// only match 6-digit colour codes, 3-digit ones have too many false positives (issue numbers, etc)
|
||||
var hexColourRegex = /(^|[^&])\#([0-9a-f]{6})($|[^\w'"])/gmi;
|
||||
var substitute = '$1#$2 <div class="colourbox" style="background-color:#$2"></div> $3';
|
||||
|
||||
return $sce.trustAsHtml(text.replace(hexColourRegex, substitute));
|
||||
};
|
||||
}]);
|
||||
1113
js/glowingbear.js
1113
js/glowingbear.js
File diff suppressed because it is too large
Load Diff
|
|
@ -0,0 +1,207 @@
|
|||
var weechat = angular.module('weechat');
|
||||
|
||||
weechat.factory('handlers', ['$rootScope', '$log', 'models', 'plugins', 'notifications', function($rootScope, $log, models, plugins, notifications) {
|
||||
|
||||
var handleBufferClosing = function(message) {
|
||||
var bufferMessage = message.objects[0].content[0];
|
||||
var bufferId = bufferMessage.pointers[0];
|
||||
models.closeBuffer(bufferId);
|
||||
};
|
||||
|
||||
var handleLine = function(line, manually) {
|
||||
var message = new models.BufferLine(line);
|
||||
var buffer = models.getBuffer(message.buffer);
|
||||
buffer.requestedLines++;
|
||||
// Only react to line if its displayed
|
||||
if (message.displayed) {
|
||||
message = plugins.PluginManager.contentForMessage(message);
|
||||
buffer.addLine(message);
|
||||
|
||||
if (manually) {
|
||||
buffer.lastSeen++;
|
||||
}
|
||||
|
||||
if (buffer.active && !manually) {
|
||||
$rootScope.scrollWithBuffer();
|
||||
}
|
||||
|
||||
if (!manually && (!buffer.active || !$rootScope.isWindowFocused())) {
|
||||
if (buffer.notify > 1 && _.contains(message.tags, 'notify_message') && !_.contains(message.tags, 'notify_none')) {
|
||||
buffer.unread++;
|
||||
$rootScope.$emit('notificationChanged');
|
||||
}
|
||||
|
||||
if ((buffer.notify !== 0 && message.highlight) || _.contains(message.tags, 'notify_private')) {
|
||||
buffer.notification++;
|
||||
notifications.createHighlight(buffer, message);
|
||||
$rootScope.$emit('notificationChanged');
|
||||
}
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
var handleBufferLineAdded = function(message) {
|
||||
message.objects[0].content.forEach(function(l) {
|
||||
handleLine(l, false);
|
||||
});
|
||||
};
|
||||
|
||||
var handleBufferOpened = function(message) {
|
||||
var bufferMessage = message.objects[0].content[0];
|
||||
var buffer = new models.Buffer(bufferMessage);
|
||||
models.addBuffer(buffer);
|
||||
/* Until we can decide if user asked for this buffer to be opened
|
||||
* or not we will let user click opened buffers.
|
||||
models.setActiveBuffer(buffer.id);
|
||||
*/
|
||||
};
|
||||
|
||||
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;
|
||||
};
|
||||
|
||||
var handleBufferLocalvarChanged = function(message) {
|
||||
var obj = message.objects[0].content[0];
|
||||
var buffer = obj.pointers[0];
|
||||
var old = models.getBuffer(buffer);
|
||||
|
||||
var localvars = obj.local_variables;
|
||||
if (old !== undefined && localvars !== undefined) {
|
||||
// Update indendation status
|
||||
old.indent = (['channel', 'private'].indexOf(localvars.type) >= 0);
|
||||
}
|
||||
};
|
||||
|
||||
/*
|
||||
* Handle answers to (lineinfo) messages
|
||||
*
|
||||
* (lineinfo) messages are specified by this client. It is request after bufinfo completes
|
||||
*/
|
||||
var handleLineInfo = function(message, manually) {
|
||||
var lines = message.objects[0].content.reverse();
|
||||
if (manually === undefined) {
|
||||
manually = true;
|
||||
}
|
||||
lines.forEach(function(l) {
|
||||
handleLine(l, manually);
|
||||
});
|
||||
};
|
||||
|
||||
/*
|
||||
* Handle answers to hotlist request
|
||||
*/
|
||||
var handleHotlistInfo = function(message) {
|
||||
if (message.objects.length === 0) {
|
||||
return;
|
||||
}
|
||||
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 private
|
||||
buffer.notification += 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;
|
||||
});
|
||||
};
|
||||
|
||||
/*
|
||||
* Handle nicklist event
|
||||
*/
|
||||
var handleNicklist = function(message) {
|
||||
var nicklist = message.objects[0].content;
|
||||
var group = 'root';
|
||||
nicklist.forEach(function(n) {
|
||||
var buffer = models.getBuffer(n.pointers[0]);
|
||||
if (n.group === 1) {
|
||||
var g = new models.NickGroup(n);
|
||||
group = g.name;
|
||||
buffer.nicklist[group] = g;
|
||||
} else {
|
||||
var nick = new models.Nick(n);
|
||||
buffer.addNick(group, nick);
|
||||
}
|
||||
});
|
||||
};
|
||||
/*
|
||||
* Handle nicklist diff event
|
||||
*/
|
||||
var handleNicklistDiff = function(message) {
|
||||
var nicklist = message.objects[0].content;
|
||||
var group;
|
||||
nicklist.forEach(function(n) {
|
||||
var buffer = models.getBuffer(n.pointers[0]);
|
||||
var d = n._diff;
|
||||
if (n.group === 1) {
|
||||
group = n.name;
|
||||
if (group === undefined) {
|
||||
var g = new models.NickGroup(n);
|
||||
buffer.nicklist[group] = g;
|
||||
group = g.name;
|
||||
}
|
||||
} else {
|
||||
var nick = new models.Nick(n);
|
||||
if (d === 43) { // +
|
||||
buffer.addNick(group, nick);
|
||||
} else if (d === 45) { // -
|
||||
buffer.delNick(group, nick);
|
||||
} else if (d === 42) { // *
|
||||
buffer.updateNick(group, nick);
|
||||
}
|
||||
}
|
||||
});
|
||||
};
|
||||
|
||||
var eventHandlers = {
|
||||
_buffer_closing: handleBufferClosing,
|
||||
_buffer_line_added: handleBufferLineAdded,
|
||||
_buffer_localvar_added: handleBufferLocalvarChanged,
|
||||
_buffer_localvar_removed: handleBufferLocalvarChanged,
|
||||
_buffer_opened: handleBufferOpened,
|
||||
_buffer_title_changed: handleBufferTitleChanged,
|
||||
_buffer_renamed: handleBufferRenamed,
|
||||
_nicklist: handleNicklist,
|
||||
_nicklist_diff: handleNicklistDiff
|
||||
};
|
||||
|
||||
$rootScope.$on('onMessage', function(event, message) {
|
||||
if (_.has(eventHandlers, message.id)) {
|
||||
eventHandlers[message.id](message);
|
||||
} else {
|
||||
$log.debug('Unhandled event received: ' + message.id);
|
||||
}
|
||||
});
|
||||
|
||||
var handleEvent = function(event) {
|
||||
if (_.has(eventHandlers, event.id)) {
|
||||
eventHandlers[event.id](event);
|
||||
}
|
||||
};
|
||||
|
||||
return {
|
||||
handleEvent: handleEvent,
|
||||
handleLineInfo: handleLineInfo,
|
||||
handleHotlistInfo: handleHotlistInfo,
|
||||
handleNicklist: handleNicklist
|
||||
};
|
||||
|
||||
}]);
|
||||
|
|
@ -0,0 +1,307 @@
|
|||
var weechat = angular.module('weechat');
|
||||
|
||||
weechat.directive('inputBar', function() {
|
||||
|
||||
return {
|
||||
|
||||
templateUrl: 'directives/input.html',
|
||||
|
||||
scope: {
|
||||
inputId: '@inputId'
|
||||
},
|
||||
|
||||
controller: ['$rootScope', '$scope', '$element', '$log', 'connection', 'models', function($rootScope,
|
||||
$scope,
|
||||
$element, //XXX do we need this? don't seem to be using it
|
||||
$log,
|
||||
connection, //XXX we should eliminate this dependency and use signals instead
|
||||
models) {
|
||||
|
||||
/*
|
||||
* Returns the input element
|
||||
*/
|
||||
$scope.getInputNode = function() {
|
||||
return document.querySelector('textarea#' + $scope.inputId);
|
||||
};
|
||||
|
||||
$scope.hideSidebar = function() {
|
||||
$rootScope.hideSidebar();
|
||||
};
|
||||
|
||||
$scope.completeNick = function() {
|
||||
// input DOM node
|
||||
var inputNode = $scope.getInputNode();
|
||||
|
||||
// get current caret position
|
||||
var caretPos = inputNode.selectionStart;
|
||||
|
||||
// get current active buffer
|
||||
var activeBuffer = models.getActiveBuffer();
|
||||
|
||||
// Empty input makes $scope.command undefined -- use empty string instead
|
||||
var input = $scope.command || '';
|
||||
|
||||
// complete nick
|
||||
var nickComp = IrcUtils.completeNick(input, caretPos, $scope.iterCandidate,
|
||||
activeBuffer.getNicklistByTime(), ':');
|
||||
|
||||
// remember iteration candidate
|
||||
$scope.iterCandidate = nickComp.iterCandidate;
|
||||
|
||||
// update current input
|
||||
$scope.command = nickComp.text;
|
||||
|
||||
// update current caret position
|
||||
setTimeout(function() {
|
||||
inputNode.focus();
|
||||
inputNode.setSelectionRange(nickComp.caretPos, nickComp.caretPos);
|
||||
}, 0);
|
||||
};
|
||||
|
||||
|
||||
// Send the message to the websocket
|
||||
$scope.sendMessage = function() {
|
||||
//XXX Use a signal here
|
||||
var ab = models.getActiveBuffer();
|
||||
|
||||
// It's undefined early in the lifecycle of the program.
|
||||
// Don't send empty commands
|
||||
if($scope.command !== undefined && $scope.command !== '') {
|
||||
|
||||
// log to buffer history
|
||||
ab.addToHistory($scope.command);
|
||||
|
||||
// Split the command into multiple commands based on line breaks
|
||||
_.each($scope.command.split(/\r?\n/), function(line) {
|
||||
connection.sendMessage(line);
|
||||
});
|
||||
|
||||
// Check for /clear command
|
||||
if ($scope.command === '/buffer clear' || $scope.command === '/c') {
|
||||
$log.debug('Clearing lines');
|
||||
ab.clear();
|
||||
}
|
||||
|
||||
// Empty the input after it's sent
|
||||
$scope.command = '';
|
||||
}
|
||||
|
||||
$scope.getInputNode().focus();
|
||||
};
|
||||
|
||||
//XXX THIS DOES NOT BELONG HERE!
|
||||
$rootScope.addMention = function(prefix) {
|
||||
// Extract nick from bufferline prefix
|
||||
var nick = prefix[prefix.length - 1].text;
|
||||
|
||||
var newValue = $scope.command || ''; // can be undefined, in that case, use the empty string
|
||||
var addColon = newValue.length === 0;
|
||||
if (newValue.length > 0) {
|
||||
// Try to determine if it's a sequence of nicks
|
||||
var trimmedValue = newValue.trim();
|
||||
if (trimmedValue.charAt(trimmedValue.length - 1) === ':') {
|
||||
// get last word
|
||||
var lastSpace = trimmedValue.lastIndexOf(' ') + 1;
|
||||
var lastWord = trimmedValue.slice(lastSpace, trimmedValue.length - 1);
|
||||
var nicklist = models.getActiveBuffer().getNicklistByTime();
|
||||
// check against nicklist to see if it's a list of highlights
|
||||
for (var index in nicklist) {
|
||||
if (nicklist[index].name === lastWord) {
|
||||
// It's another highlight!
|
||||
newValue = newValue.slice(0, newValue.lastIndexOf(':')) + ' ';
|
||||
addColon = true;
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Add a space before the nick if there isn't one already
|
||||
// Last char might have changed above, so re-check
|
||||
if (newValue.charAt(newValue.length - 1) !== ' ') {
|
||||
newValue += ' ';
|
||||
}
|
||||
}
|
||||
// Add highlight to nicklist
|
||||
newValue += nick;
|
||||
if (addColon) {
|
||||
newValue += ': ';
|
||||
}
|
||||
$scope.command = newValue;
|
||||
$scope.getInputNode().focus();
|
||||
};
|
||||
|
||||
|
||||
// Handle key presses in the input bar
|
||||
$rootScope.handleKeyPress = function($event) {
|
||||
// don't do anything if not connected
|
||||
if (!$rootScope.connected) {
|
||||
return true;
|
||||
}
|
||||
|
||||
var inputNode = $scope.getInputNode();
|
||||
|
||||
// Support different browser quirks
|
||||
var code = $event.keyCode ? $event.keyCode : $event.charCode;
|
||||
|
||||
// any other key than Tab resets nick completion iteration
|
||||
var tmpIterCandidate = $scope.iterCandidate;
|
||||
$scope.iterCandidate = null;
|
||||
|
||||
// Left Alt+[0-9] -> jump to buffer
|
||||
if ($event.altKey && !$event.ctrlKey && (code > 47 && code < 58)) {
|
||||
if (code === 48) {
|
||||
code = 58;
|
||||
}
|
||||
|
||||
var bufferNumber = code - 48 - 1 ;
|
||||
// Map the buffers to only their numbers and IDs so we don't have to
|
||||
// copy the entire (possibly very large) buffer object, and then sort
|
||||
// the buffers according to their WeeChat number
|
||||
var sortedBuffers = _.map(models.getBuffers(), function(buffer) {
|
||||
return [buffer.number, buffer.id];
|
||||
}).sort(function(left, right) {
|
||||
// By default, Array.prototype.sort() sorts alphabetically.
|
||||
// Pass an ordering function to sort by first element.
|
||||
return left[0] - right[0];
|
||||
});
|
||||
var activeBufferId = sortedBuffers[bufferNumber];
|
||||
if (activeBufferId) {
|
||||
models.setActiveBuffer(activeBufferId[1]);
|
||||
$event.preventDefault();
|
||||
}
|
||||
}
|
||||
|
||||
// Tab -> nick completion
|
||||
if (code === 9 && !$event.altKey && !$event.ctrlKey) {
|
||||
$event.preventDefault();
|
||||
$scope.iterCandidate = tmpIterCandidate;
|
||||
$scope.completeNick();
|
||||
return true;
|
||||
}
|
||||
|
||||
// Left Alt+n -> toggle nicklist
|
||||
if ($event.altKey && !$event.ctrlKey && code === 78) {
|
||||
$event.preventDefault();
|
||||
$rootScope.toggleNicklist();
|
||||
return true;
|
||||
}
|
||||
|
||||
// Alt+A -> switch to buffer with activity
|
||||
if ($event.altKey && (code === 97 || code === 65)) {
|
||||
$event.preventDefault();
|
||||
$rootScope.switchToActivityBuffer();
|
||||
return true;
|
||||
}
|
||||
|
||||
// Alt+L -> focus on input bar
|
||||
if ($event.altKey && (code === 76 || code === 108)) {
|
||||
$event.preventDefault();
|
||||
inputNode.focus();
|
||||
inputNode.setSelectionRange($scope.command.length, $scope.command.length);
|
||||
return true;
|
||||
}
|
||||
|
||||
// Alt+< -> switch to previous buffer
|
||||
if ($event.altKey && (code === 60 || code === 226)) {
|
||||
var previousBuffer = models.getPreviousBuffer();
|
||||
if (previousBuffer) {
|
||||
models.setActiveBuffer(previousBuffer.id);
|
||||
$event.preventDefault();
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
// Double-tap Escape -> disconnect
|
||||
if (code === 27) {
|
||||
$event.preventDefault();
|
||||
|
||||
// Check if a modal is visible. If so, close it instead of disconnecting
|
||||
var modals = document.querySelectorAll('.gb-modal');
|
||||
for (var modalId = 0; modalId < modals.length; modalId++) {
|
||||
if (modals[modalId].getAttribute('data-state') === 'visible') {
|
||||
modals[modalId].setAttribute('data-state', 'hidden');
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
if (typeof $scope.lastEscape !== "undefined" && (Date.now() - $scope.lastEscape) <= 500) {
|
||||
// Double-tap
|
||||
connection.disconnect();
|
||||
}
|
||||
$scope.lastEscape = Date.now();
|
||||
return true;
|
||||
}
|
||||
|
||||
// Alt+G -> focus on buffer filter input
|
||||
if ($event.altKey && (code === 103 || code === 71)) {
|
||||
$event.preventDefault();
|
||||
document.getElementById('bufferFilter').focus();
|
||||
return true;
|
||||
}
|
||||
|
||||
// Arrow up -> go up in history
|
||||
if ($event.type === "keydown" && code === 38) {
|
||||
$scope.command = models.getActiveBuffer().getHistoryUp($scope.command);
|
||||
// Set cursor to last position. Need 0ms timeout because browser sets cursor
|
||||
// position to the beginning after this key handler returns.
|
||||
setTimeout(function() {
|
||||
if ($scope.command) {
|
||||
inputNode.setSelectionRange($scope.command.length, $scope.command.length);
|
||||
}
|
||||
}, 0);
|
||||
return true;
|
||||
}
|
||||
|
||||
// Arrow down -> go down in history
|
||||
if ($event.type === "keydown" && code === 40) {
|
||||
$scope.command = models.getActiveBuffer().getHistoryDown($scope.command);
|
||||
// We don't need to set the cursor to the rightmost position here, the browser does that for us
|
||||
return true;
|
||||
}
|
||||
|
||||
// Enter to submit, shift-enter for newline
|
||||
if (code == 13 && !$event.shiftKey && document.activeElement === inputNode) {
|
||||
$event.preventDefault();
|
||||
$scope.sendMessage();
|
||||
return true;
|
||||
}
|
||||
// Some readline keybindings
|
||||
if ($rootScope.readlineBindings && $event.ctrlKey && !$event.altKey && !$event.shiftKey && document.activeElement === inputNode) {
|
||||
// get current caret position
|
||||
var caretPos = inputNode.selectionStart;
|
||||
// Ctrl-a
|
||||
if (code == 65) {
|
||||
inputNode.setSelectionRange(0, 0);
|
||||
// Ctrl-e
|
||||
} else if (code == 69) {
|
||||
inputNode.setSelectionRange($scope.command.length, $scope.command.length);
|
||||
// Ctrl-u
|
||||
} else if (code == 85) {
|
||||
$scope.command = $scope.command.slice(caretPos);
|
||||
setTimeout(function() {
|
||||
inputNode.setSelectionRange(0, 0);
|
||||
});
|
||||
// Ctrl-k
|
||||
} else if (code == 75) {
|
||||
$scope.command = $scope.command.slice(0, caretPos);
|
||||
setTimeout(function() {
|
||||
inputNode.setSelectionRange($scope.command.length, $scope.command.length);
|
||||
});
|
||||
// Ctrl-w
|
||||
} else if (code == 87) {
|
||||
var trimmedValue = $scope.command.slice(0, caretPos);
|
||||
var lastSpace = trimmedValue.lastIndexOf(' ') + 1;
|
||||
$scope.command = $scope.command.slice(0, lastSpace) + $scope.command.slice(caretPos, $scope.command.length);
|
||||
setTimeout(function() {
|
||||
inputNode.setSelectionRange(lastSpace, lastSpace);
|
||||
});
|
||||
} else {
|
||||
return false;
|
||||
}
|
||||
$event.preventDefault();
|
||||
return true;
|
||||
}
|
||||
};
|
||||
}]
|
||||
};
|
||||
});
|
||||
|
|
@ -0,0 +1,141 @@
|
|||
var weechat = angular.module('weechat');
|
||||
|
||||
weechat.factory('notifications', ['$rootScope', '$log', 'models', function($rootScope, $log, models) {
|
||||
// Ask for permission to display desktop notifications
|
||||
var requestNotificationPermission = function() {
|
||||
// Firefox
|
||||
if (window.Notification) {
|
||||
Notification.requestPermission(function(status) {
|
||||
$log.info('Notification permission status: ', status);
|
||||
if (Notification.permission !== status) {
|
||||
Notification.permission = status;
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
// Webkit
|
||||
if (window.webkitNotifications !== undefined) {
|
||||
var havePermission = window.webkitNotifications.checkPermission();
|
||||
if (havePermission !== 0) { // 0 is PERMISSION_ALLOWED
|
||||
$log.info('Notification permission status: ', havePermission === 0);
|
||||
window.webkitNotifications.requestPermission();
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
|
||||
// Reduce buffers with "+" operation over a key. Mostly useful for unread/notification counts.
|
||||
var unreadCount = function(type) {
|
||||
if (!type) {
|
||||
type = "unread";
|
||||
}
|
||||
|
||||
// Do this the old-fashioned way with iterating over the keys, as underscore proved to be error-prone
|
||||
var keys = Object.keys(models.model.buffers);
|
||||
var count = 0;
|
||||
for (var key in keys) {
|
||||
count += models.model.buffers[keys[key]][type];
|
||||
}
|
||||
|
||||
return count;
|
||||
};
|
||||
|
||||
|
||||
var updateTitle = function() {
|
||||
var notifications = unreadCount('notification');
|
||||
if (notifications > 0) {
|
||||
// New notifications deserve an exclamation mark
|
||||
$rootScope.notificationStatus = '(' + notifications + ') ';
|
||||
} else {
|
||||
$rootScope.notificationStatus = '';
|
||||
}
|
||||
|
||||
var activeBuffer = models.getActiveBuffer();
|
||||
if (activeBuffer) {
|
||||
$rootScope.pageTitle = activeBuffer.shortName + ' | ' + activeBuffer.title;
|
||||
}
|
||||
};
|
||||
|
||||
var updateFavico = function() {
|
||||
var notifications = unreadCount('notification');
|
||||
if (notifications > 0) {
|
||||
$rootScope.favico.badge(notifications, {
|
||||
bgColor: '#d00',
|
||||
textColor: '#fff'
|
||||
});
|
||||
} else {
|
||||
var unread = unreadCount('unread');
|
||||
if (unread === 0) {
|
||||
$rootScope.favico.reset();
|
||||
} else {
|
||||
$rootScope.favico.badge(unread, {
|
||||
bgColor: '#5CB85C',
|
||||
textColor: '#ff0'
|
||||
});
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
/* Function gets called from bufferLineAdded code if user should be notified */
|
||||
var createHighlight = function(buffer, message) {
|
||||
var title = '';
|
||||
var body = '';
|
||||
var numNotifications = buffer.notification;
|
||||
|
||||
if (['#', '&', '+', '!'].indexOf(buffer.shortName.charAt(0)) < 0) {
|
||||
if (numNotifications > 1) {
|
||||
title = numNotifications.toString() + ' private messages from ';
|
||||
} else {
|
||||
title = 'Private message from ';
|
||||
}
|
||||
body = message.text;
|
||||
} else {
|
||||
if (numNotifications > 1) {
|
||||
title = numNotifications.toString() + ' highlights in ';
|
||||
} else {
|
||||
title = 'Highlight in ';
|
||||
}
|
||||
var prefix = '';
|
||||
for (var i = 0; i < message.prefix.length; i++) {
|
||||
prefix += message.prefix[i].text;
|
||||
}
|
||||
body = '<' + prefix + '> ' + message.text;
|
||||
}
|
||||
title += buffer.shortName;
|
||||
title += buffer.fullName.replace(/irc.([^\.]+)\..+/, " ($1)");
|
||||
|
||||
var notification = new Notification(title, {
|
||||
body: body,
|
||||
icon: 'assets/img/favicon.png'
|
||||
});
|
||||
|
||||
// Cancel notification automatically
|
||||
var timeout = 15*1000;
|
||||
notification.onshow = function() {
|
||||
setTimeout(function() {
|
||||
notification.close();
|
||||
}, timeout);
|
||||
};
|
||||
|
||||
// Click takes the user to the buffer
|
||||
notification.onclick = function() {
|
||||
models.setActiveBuffer(buffer.id);
|
||||
window.focus();
|
||||
notification.close();
|
||||
};
|
||||
|
||||
if ($rootScope.soundnotification) {
|
||||
// TODO fill in a sound file
|
||||
var audioFile = "assets/audio/sonar";
|
||||
var soundHTML = '<audio autoplay="autoplay"><source src="' + audioFile + '.ogg" type="audio/ogg" /><source src="' + audioFile + '.mp3" type="audio/mpeg" /></audio>';
|
||||
document.getElementById("soundNotification").innerHTML = soundHTML;
|
||||
}
|
||||
};
|
||||
|
||||
return {
|
||||
requestNotificationPermission: requestNotificationPermission,
|
||||
updateTitle: updateTitle,
|
||||
updateFavico: updateFavico,
|
||||
createHighlight: createHighlight,
|
||||
};
|
||||
}]);
|
||||
|
|
@ -0,0 +1,56 @@
|
|||
var weechat = angular.module('weechat');
|
||||
|
||||
weechat.directive('plugin', ['$rootScope', function($rootScope) {
|
||||
/*
|
||||
* Plugin directive
|
||||
* Shows additional plugin content
|
||||
*/
|
||||
return {
|
||||
templateUrl: 'directives/plugin.html',
|
||||
|
||||
scope: {
|
||||
plugin: '=data'
|
||||
},
|
||||
|
||||
controller: ['$scope', function($scope) {
|
||||
|
||||
$scope.displayedContent = "";
|
||||
|
||||
$scope.plugin.visible = $rootScope.auto_display_embedded_content;
|
||||
|
||||
$scope.hideContent = function() {
|
||||
$scope.plugin.visible = false;
|
||||
};
|
||||
|
||||
$scope.showContent = function() {
|
||||
/*
|
||||
* Shows the plugin content.
|
||||
* displayedContent is bound to the DOM.
|
||||
* Actual plugin content is only fetched when
|
||||
* content is shown.
|
||||
*/
|
||||
|
||||
// If the plugin is asynchronous / lazy, execute it now and store
|
||||
// the result. This ensures that the callback is executed only once
|
||||
if ($scope.plugin.content instanceof Function) {
|
||||
$scope.plugin.content = $scope.plugin.content();
|
||||
}
|
||||
$scope.displayedContent = $scope.plugin.content;
|
||||
$scope.plugin.visible = true;
|
||||
|
||||
// Scroll embed content into view
|
||||
var scroll = function() {
|
||||
var embed = document.querySelector(".embed_" + $scope.plugin.$$hashKey);
|
||||
if (embed) {
|
||||
embed.scrollIntoViewIfNeeded();
|
||||
}
|
||||
};
|
||||
setTimeout(scroll, 100);
|
||||
};
|
||||
|
||||
if ($scope.plugin.visible) {
|
||||
$scope.showContent();
|
||||
}
|
||||
}]
|
||||
};
|
||||
}]);
|
||||
|
|
@ -0,0 +1,29 @@
|
|||
var weechat = angular.module('weechat');
|
||||
|
||||
weechat.factory('utils', function() {
|
||||
// Helper to change style of a class
|
||||
var changeClassStyle = function(classSelector, attr, value) {
|
||||
_.each(document.getElementsByClassName(classSelector), function(e) {
|
||||
e.style[attr] = value;
|
||||
});
|
||||
};
|
||||
// Helper to get style from a class
|
||||
var getClassStyle = function(classSelector, attr) {
|
||||
_.each(document.getElementsByClassName(classSelector), function(e) {
|
||||
return e.style[attr];
|
||||
});
|
||||
};
|
||||
|
||||
var isMobileUi = function() {
|
||||
// TODO don't base detection solely on screen width
|
||||
// You are right. In the meantime I am renaming isMobileDevice to isMobileUi
|
||||
var mobile_cutoff = 968;
|
||||
return (document.body.clientWidth < mobile_cutoff);
|
||||
};
|
||||
|
||||
return {
|
||||
changeClassStyle: changeClassStyle,
|
||||
getClassStyle: getClassStyle,
|
||||
isMobileUi: isMobileUi
|
||||
};
|
||||
});
|
||||
|
|
@ -18,7 +18,7 @@
|
|||
"scripts": {
|
||||
"postinstall": "bower install",
|
||||
|
||||
"minify": " uglifyjs js/localstorage.js js/weechat.js js/irc-utils.js js/glowingbear.js js/websockets.js js/models.js js/plugins.js -c -m --screw-ie8 -o min.js --source-map min.map",
|
||||
"minify": " uglifyjs js/localstorage.js js/weechat.js js/irc-utils.js js/glowingbear.js js/utils.js js/notifications.js js/filters.js js/handlers.js js/connection.js js/inputbar.js js/plugin-directive.js js/websockets.js js/models.js js/plugins.js -c -m --screw-ie8 -o min.js --source-map min.map",
|
||||
|
||||
"prestart": "npm install",
|
||||
"start": "http-server -a localhost -p 8000",
|
||||
|
|
|
|||
|
|
@ -7,7 +7,20 @@ module.exports = function(config){
|
|||
'bower_components/angular/angular.js',
|
||||
'bower_components/angular-route/angular-route.js',
|
||||
'bower_components/angular-mocks/angular-mocks.js',
|
||||
'js/**/*.js',
|
||||
'js/localstorage.js',
|
||||
'js/weechat.js',
|
||||
'js/irc-utils.js',
|
||||
'js/glowingbear.js',
|
||||
'js/utils.js',
|
||||
'js/notifications.js',
|
||||
'js/filters.js',
|
||||
'js/handlers.js',
|
||||
'js/connection.js',
|
||||
'js/inputbar.js',
|
||||
'js/plugin-directive.js',
|
||||
'js/websockets.js',
|
||||
'js/models.js',
|
||||
'js/plugins.js',
|
||||
'test/unit/**/*.js'
|
||||
],
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue