shrub/web/talk/main.js
2016-07-26 17:57:59 -07:00

2997 lines
84 KiB
JavaScript

(function e(t,n,r){function s(o,u){if(!n[o]){if(!t[o]){var a=typeof require=="function"&&require;if(!u&&a)return a(o,!0);if(i)return i(o,!0);var f=new Error("Cannot find module '"+o+"'");throw f.code="MODULE_NOT_FOUND",f}var l=n[o]={exports:{}};t[o][0].call(l.exports,function(e){var n=t[o][1][e];return s(n?n:e)},l,l.exports,e,t,n,r)}return n[o].exports}var i=typeof require=="function"&&require;for(var o=0;o<r.length;o++)s(r[o]);return s})({1:[function(require,module,exports){
var Dispatcher, Persistence, _persistence, util;
util = require('../util.coffee');
Dispatcher = require('../dispatcher/Dispatcher.coffee');
_persistence = require('../persistence/MessagePersistence.coffee');
Persistence = _persistence({
MessageActions: module.exports = {
loadMessages: function(messages, last, get) {
return Dispatcher.handleServerAction({
messages: messages,
last: last,
get: get,
type: "messages-load"
});
},
listenStation: function(station, date) {
var now;
if (!date) {
date = window.urb.util.toDate((now = new Date(), now.setSeconds(0), now.setMilliseconds(0), new Date(now - 24 * 3600 * 1000)));
}
Dispatcher.handleViewAction({
type: "messages-fetch"
});
return Persistence.listenStation(station, date);
},
listeningStation: function(station) {
return Dispatcher.handleViewAction({
station: station,
type: "messages-listen"
});
},
setTyping: function(state) {
return Dispatcher.handleViewAction({
state: state,
type: "messages-typing"
});
},
getMore: function(station, start, end) {
Dispatcher.handleViewAction({
type: "messages-fetch"
});
return Persistence.get(station, start, end);
},
sendMessage: function(txt, audience, global) {
var _audi, j, k, len, message, messageType, ref, ref1, results, say, serial, speech, speeches, v;
if (global == null) {
global = urb.user === urb.ship;
}
serial = util.uuid32();
audience = _.uniq(audience);
_audi = {};
for (k in audience) {
v = audience[k];
_audi[v] = {
envelope: {
visible: true,
sender: null
},
delivery: "pending"
};
}
speech = {
lin: {
txt: txt,
say: true
}
};
if (txt[0] === "@") {
speech.lin.txt = speech.lin.txt.slice(1).trim();
speech.lin.say = false;
} else if (txt[0] === "#") {
speech = {
"eval": speech.lin.txt.slice(1).trim()
};
} else if (window.urb.util.isURL(txt)) {
speech = {
url: txt
};
}
speeches = !(((ref = speech.lin) != null ? ref.txt.length : void 0) > 64) ? [speech] : ((ref1 = speech.lin, say = ref1.say, txt = ref1.txt, ref1), txt.match(/(.{1,64}$|.{0,64} |.{64}|.+$)/g).map(function(s, i) {
say || (say = i !== 0);
return {
lin: {
say: say,
txt: s.slice(-1 !== " ") ? s : s.slice(0, -1)
}
};
}));
results = [];
for (j = 0, len = speeches.length; j < len; j++) {
speech = speeches[j];
message = {
ship: window.urb.user,
thought: {
serial: util.uuid32(),
audience: _audi,
statement: {
bouquet: [],
speech: speech,
date: Date.now()
}
}
};
Dispatcher.handleViewAction({
message: message,
type: "message-send"
});
messageType = (global ? "publish" : "review");
results.push(Persistence.sendMessage(messageType, message.thought));
}
return results;
}
}
});
},{"../dispatcher/Dispatcher.coffee":9,"../persistence/MessagePersistence.coffee":11,"../util.coffee":15}],2:[function(require,module,exports){
var Dispatcher, Persistence, _persistence, serverAction, viewAction;
Dispatcher = require('../dispatcher/Dispatcher.coffee');
serverAction = function(f) {
return function() {
return Dispatcher.handleServerAction(f.apply(this, arguments));
};
};
viewAction = function(f) {
return function() {
return Dispatcher.handleViewAction(f.apply(this, arguments));
};
};
_persistence = require('../persistence/StationPersistence.coffee');
Persistence = _persistence({
StationActions: module.exports = {
loadGlyphs: serverAction(function(glyphs) {
return {
glyphs: glyphs,
type: "glyphs-load"
};
}),
loadMembers: serverAction(function(members) {
return {
members: members,
type: "members-load"
};
}),
loadStations: serverAction(function(stations) {
return {
stations: stations,
type: "stations-load"
};
}),
loadConfig: serverAction(function(station, config) {
return {
station: station,
config: config,
type: "config-load"
};
}),
setTyping: viewAction(function(station, state) {
return {
station: station,
state: state,
type: "typing-set"
};
}),
setAudience: viewAction(function(audience) {
return {
audience: audience,
type: "station-set-audience"
};
}),
setValidAudience: viewAction(function(valid) {
return {
valid: valid,
type: "station-set-valid-audience"
};
}),
toggleAudience: viewAction(function(station) {
return {
station: station,
type: "station-audience-toggle"
};
}),
switchStation: viewAction(function(station) {
return {
station: station,
type: "station-switch"
};
}),
listeningStation: viewAction(function(station) {
return {
station: station,
type: "station-listen"
};
}),
createStation: function(station) {
Dispatcher.handleViewAction({
station: station,
type: "station-create"
});
return Persistence.createStation(station);
},
listen: function() {
return Persistence.listen();
},
ping: function(_ping) {
return Persistence.ping(_ping);
},
removeStation: function(station) {
return Persistence.removeStation(station);
},
listenStation: function(station) {
return Persistence.listenStation(station, {
'group': 'group',
'glyph': 'glyph',
'cabal': 'cabal'
});
},
createStation: function(name) {
return Persistence.createStation(name);
},
setSources: function(station, sources) {
return Persistence.setSources(station, window.urb.ship, sources);
}
}
});
},{"../dispatcher/Dispatcher.coffee":9,"../persistence/StationPersistence.coffee":12}],3:[function(require,module,exports){
var div, recl, ref, span;
recl = React.createClass;
ref = React.DOM, span = ref.span, div = ref.div;
module.exports = recl({
displayName: "Load",
getInitialState: function() {
return {
anim: 0
};
},
componentDidMount: function() {
return this.interval = setInterval(this.setAnim, 100);
},
componentWillUnmount: function() {
return clearInterval(this.interval);
},
setAnim: function() {
var anim;
anim = this.state.anim + 1;
if (anim > 3) {
anim = 0;
}
return this.setState({
anim: anim
});
},
render: function() {
return span({
className: "loading state-" + this.state.anim
}, '');
}
});
},{}],4:[function(require,module,exports){
var Ship, div, input, recl, ref, rele, textarea;
Ship = window.tree.util.components.ship;
recl = React.createClass;
rele = React.createElement;
ref = React.DOM, div = ref.div, input = ref.input, textarea = ref.textarea;
module.exports = recl({
displayName: "Member",
render: function() {
var k, ship;
ship = this.props.ship;
k = "ship";
if (this.props.presence) {
k += " " + this.props.presence;
}
return div({
className: "iden",
key: "iden"
}, [
rele(Ship, {
ship: ship
})
]);
}
});
},{}],5:[function(require,module,exports){
var Member, a, clas, div, h2, h3, label, pre, recl, ref, util,
indexOf = [].indexOf || function(item) { for (var i = 0, l = this.length; i < l; i++) { if (i in this && this[i] === item) return i; } return -1; };
util = require('../util.coffee');
clas = require('classnames');
recl = React.createClass;
ref = React.DOM, div = ref.div, pre = ref.pre, a = ref.a, label = ref.label, h2 = ref.h2, h3 = ref.h3;
Member = require('./MemberComponent.coffee');
module.exports = recl({
displayName: "Message",
lz: function(n) {
if (n < 10) {
return "0" + n;
} else {
return "" + n;
}
},
convTime: function(time) {
var d, h, m, s;
d = new Date(time);
h = this.lz(d.getHours());
m = this.lz(d.getMinutes());
s = this.lz(d.getSeconds());
return "~" + h + "." + m + "." + s;
},
_handleAudi: function(e) {
var audi;
audi = _.map($(e.target).closest('.path').find('div'), function(div) {
return "~" + $(div).text();
});
return this.props._handleAudi(audi);
},
_handlePm: function(e) {
var user;
if (!this.props._handlePm) {
return;
}
user = $(e.target).closest('.iden').text();
if (user[0] === "~") {
user = user.slice(1);
}
if (user.toLowerCase() === 'system') {
return;
}
return this.props._handlePm(user);
},
renderSpeech: function(arg) {
var app, com, exp, fat, lin, mor, tax, url, x;
lin = arg.lin, app = arg.app, exp = arg.exp, tax = arg.tax, url = arg.url, mor = arg.mor, fat = arg.fat, com = arg.com;
switch (false) {
case !(lin || app || exp || tax):
return (lin || app || exp || tax).txt;
case !url:
return a({
href: url.txt,
target: "_blank",
key: "speech"
}, url.txt);
case !com:
return div({}, com.txt, div({}, a({
className: "btn",
href: com.url
}, "Go to thread")));
case !mor:
return mor.map(this.renderSpeech);
case !fat:
return div({}, this.renderSpeech(fat.taf), div({
className: "fat"
}, this.renderTorso(fat.tor)));
default:
return "Unknown speech type:" + ((function() {
var results;
results = [];
for (x in arguments[0]) {
results.push(" %" + x);
}
return results;
}).apply(this, arguments)).join('');
}
},
renderTorso: function(arg) {
var name, tank, text, x;
text = arg.text, tank = arg.tank, name = arg.name;
switch (false) {
case text == null:
return text;
case tank == null:
return pre({}, tank.join("\n"));
case name == null:
return div({}, name.nom, ": ", this.renderTorso(name.mon));
default:
return "Unknown torso:" + ((function() {
var results;
results = [];
for (x in arguments[0]) {
results.push(" %" + x);
}
return results;
}).apply(this, arguments)).join('');
}
},
classesInSpeech: function(arg) {
var app, exp, fat, lin, mor, url;
url = arg.url, exp = arg.exp, app = arg.app, lin = arg.lin, mor = arg.mor, fat = arg.fat;
switch (false) {
case !url:
return "url";
case !exp:
return "exp";
case !app:
return "say";
case !lin:
return {
say: lin.say === false
};
case !mor:
return mor != null ? mor.map(this.classesInSpeech) : void 0;
case !fat:
return this.classesInSpeech(fat.taf);
}
},
render: function() {
var aude, audi, bouquet, className, comment, delivery, k, mainStation, name, path, ref1, speech, style, thought, txt, type, url, v;
thought = this.props.thought;
delivery = _.uniq(_.pluck(thought.audience, "delivery"));
speech = thought.statement.speech;
bouquet = thought.statement.bouquet;
if (speech == null) {
return;
}
name = this.props.name ? this.props.name : "";
aude = _.keys(thought.audience);
audi = util.clipAudi(aude).map(function(_audi) {
return div({
key: _audi
}, _audi);
});
mainStation = util.mainStationPath(window.urb.user);
type = indexOf.call(aude, mainStation) >= 0 ? 'private' : 'public';
if (_.filter(bouquet, ["comment"]).length > 0) {
comment = true;
ref1 = speech.mor;
for (k in ref1) {
v = ref1[k];
if (v.fat) {
url = v.fat.taf.url.txt;
txt = v.fat.tor.text;
}
if (v.app) {
path = v.app.txt.replace("comment on ", "");
}
}
audi = a({
href: url
}, path);
speech = {
com: {
txt: txt,
url: url
}
};
}
className = clas('gram', (this.props.sameAs ? "same" : "first"), (delivery.indexOf("received") !== -1 ? "received" : "pending"), {
'new': this.props.unseen
}, {
comment: comment
}, this.classesInSpeech(speech));
style = {
height: this.props.height,
marginTop: this.props.marginTop
};
return div({
className: className,
'data-index': this.props.index,
key: "message",
style: style
}, div({
className: "meta",
key: "meta"
}, label({
className: "type " + type,
"data-glyph": this.props.glyph || "*"
}), h2({
className: 'author planet',
onClick: this._handlePm,
key: "member"
}, React.createElement(Member, {
ship: this.props.ship,
glyph: this.props.glyph,
key: "member"
})), h3({
className: "path",
onClick: this._handleAudi,
key: "audi"
}, audi), h3({
className: "time",
key: "time"
}, this.convTime(thought.statement.date))), div({
className: "speech",
key: "speech"
}, this.renderSpeech(speech, bouquet)));
}
});
},{"../util.coffee":15,"./MemberComponent.coffee":4,"classnames":16}],6:[function(require,module,exports){
var FONT_SIZE, INFINITE, Infinite, Load, MESSAGE_HEIGHT_FIRST, MESSAGE_HEIGHT_FIRST_MARGIN_TOP, MESSAGE_HEIGHT_SAME, Message, MessageActions, MessageStore, StationActions, StationStore, div, recl, rele, util;
util = require('../util.coffee');
Infinite = null;
recl = React.createClass;
rele = React.createElement;
div = React.DOM.div;
MessageActions = require('../actions/MessageActions.coffee');
MessageStore = require('../stores/MessageStore.coffee');
StationActions = require('../actions/StationActions.coffee');
StationStore = require('../stores/StationStore.coffee');
Message = require('./MessageComponent.coffee');
Load = require('./LoadComponent.coffee');
INFINITE = true;
MESSAGE_HEIGHT_SAME = 27;
MESSAGE_HEIGHT_FIRST = 56 - MESSAGE_HEIGHT_SAME;
MESSAGE_HEIGHT_FIRST_MARGIN_TOP = 16;
FONT_SIZE = parseInt($('body').css('font-size').match(/(\d*)px/)[1]);
module.exports = recl({
displayName: "Messages",
pageSize: 200,
paddingTop: 100,
paddingBottom: 100,
stateFromStore: function() {
return {
messages: MessageStore.getAll(),
last: MessageStore.getLast(),
fetching: MessageStore.getFetching(),
listening: MessageStore.getListening(),
station: StationStore.getStation(),
stations: StationStore.getStations(),
configs: StationStore.getConfigs(),
typing: MessageStore.getTyping(),
glyph: StationStore.getGlyphMap()
};
},
getInitialState: function() {
return this.stateFromStore();
},
_blur: function() {
this.focused = false;
return this.lastSeen = this.last;
},
_focus: function() {
this.focused = true;
this.lastSeen = null;
$('.message.new').removeClass('new');
return document.title = document.title.replace(/\ \([0-9]*\)/, "");
},
atScrollEdge: function() {
switch (this.props.chrono) {
case "reverse":
return $(window).height() < $(window).scrollTop() + $(window)[0].innerHeight + this.paddingBottom;
default:
return $(window).scrollTop() < this.paddingTop;
}
},
checkMore: function() {
var end;
if (this.atScrollEdge() && this.state.fetching === false && this.state.last && this.state.last > 0) {
end = this.state.last - this.pageSize;
if (end < 0) {
end = 0;
}
this.lastLength = this.length;
return MessageActions.getMore(this.state.station, this.state.last + 1, end);
}
},
setAudience: function() {
var laudi;
if (this.state.typing || !this.last) {
return;
}
laudi = _.keys(this.last.thought.audience);
if ((_.isEmpty(laudi)) || !_(laudi).difference(this.state.audi).isEmpty()) {
return StationActions.setAudience(_.keys(this.last.thought.audience));
}
},
sortedMessages: function(messages) {
var station;
station = this.state.station;
return _.sortBy(messages, (function(_this) {
return function(message) {
message.pending = message.thought.audience[station];
return message.key;
};
})(this));
},
componentWillMount: function() {
return Infinite = window.Infinite;
},
componentDidMount: function() {
MessageStore.addChangeListener(this._onChangeStore);
StationStore.addChangeListener(this._onChangeStore);
if (this.state.station && this.state.listening.indexOf(this.state.station) === -1) {
MessageActions.listenStation(this.state.station);
}
if (this.props["static"] == null) {
$(window).on('scroll', this.checkMore);
}
if (this.props.chrono !== "reverse") {
util.scrollToBottom();
}
this.focused = true;
$(window).on('blur', this._blur);
$(window).on('focus', this._focus);
return $(window).on('resize', _.debounce((function(_this) {
return function() {
return _this.forceUpdate();
};
})(this), 250));
},
componentWillUpdate: function(props, state) {
return this.scrollBottom = $(document).height() - ($(window).scrollTop() + window.innerHeight);
},
componentDidUpdate: function(_props, _state) {
var _messages, _oldMessages, appendedToBottom, d, ref, ref1, ref2, setOffset, t;
_messages = this.sortedMessages(this.state.messages);
_oldMessages = this.sortedMessages(_state.messages);
appendedToBottom = (((ref = _.last(_messages)) != null ? ref.key : void 0) == null) || ((ref1 = _.last(_messages)) != null ? ref1.key : void 0) > ((ref2 = _.last(_oldMessages)) != null ? ref2.key : void 0);
setOffset = $(document).height() - window.innerHeight - this.scrollBottom;
if (this.props.chrono !== "reverse") {
if (!(this.scrollBottom > 0 && appendedToBottom)) {
$(window).scrollTop(setOffset);
}
}
if (this.focused === false && this.last !== this.lastSeen) {
d = _messages.length - _messages.indexOf(this.lastSeen) - 1;
t = document.title;
if (document.title.match(/\([0-9]*\)/)) {
return document.title = document.title.replace(/\([0-9]*\)/, "(" + d + ")");
} else {
return document.title = document.title + (" (" + d + ")");
}
}
},
componentWillUnmount: function() {
MessageStore.removeChangeListener(this._onChangeStore);
return StationStore.removeChangeListener(this._onChangeStore);
},
_onChangeStore: function() {
return this.setState(this.stateFromStore());
},
_handlePm: function(user) {
var audi;
if (this.props['audience-lock'] != null) {
return;
}
audi = [util.mainStationPath(user)];
if (user === window.urb.user) {
audi.pop();
}
return StationActions.setAudience(audi);
},
_handleAudi: function(audi) {
return StationActions.setAudience(audi);
},
render: function() {
var _messageGroups, _messages, audience, body, canvas, context, fetching, height, i, index, lastIndex, lastSaid, len, lineNums, marginTop, message, messageHeights, messages, mez, nowSaid, ref, sameAs, speech, speechArr, speechLength, station;
station = this.state.station;
messages = this.sortedMessages(this.state.messages);
this.last = messages[messages.length - 1];
if (((ref = this.last) != null ? ref.ship : void 0) && this.last.ship === window.urb.user) {
this.lastSeen = this.last;
}
this.length = messages.length;
setTimeout(((function(_this) {
return function() {
if (_this.length < _this.pageSize) {
return _this.checkMore();
}
};
})(this)), 1);
lastIndex = this.lastSeen ? messages.indexOf(this.lastSeen) + 1 : null;
lastSaid = null;
messageHeights = [];
canvas = document.createElement('canvas');
context = canvas.getContext('2d');
speechLength = $('.grams').width() - (FONT_SIZE * 1.875);
_messageGroups = [[]];
for (index = i = 0, len = messages.length; i < len; index = ++i) {
message = messages[index];
nowSaid = [message.ship, _.keys(message.thought.audience)];
sameAs = _.isEqual(lastSaid, nowSaid);
lastSaid = nowSaid;
lineNums = 1;
speechArr = [];
context.font = FONT_SIZE + 'px bau';
if (message.thought.statement.speech.lin != null) {
speechArr = message.thought.statement.speech.lin.txt.split(/(\s|-)/);
} else if (message.thought.statement.speech.url != null) {
speechArr = message.thought.statement.speech.url.txt.split(/(\s|-)/);
} else if (message.thought.statement.speech.fat != null) {
context.font = (FONT_SIZE * 0.9) + 'px scp';
speechArr = message.thought.statement.speech.fat.taf.exp.txt.split(/(\s|-)/);
}
_.reduce(_.tail(speechArr), function(base, word) {
if (context.measureText(base + word).width > speechLength) {
lineNums += 1;
if (word === ' ') {
return '';
} else if (word === '-') {
return _.head(base.split(/\s|-/).reverse()) + word;
} else {
return word;
}
} else {
return base + word;
}
}, _.head(speechArr));
if (INFINITE) {
height = MESSAGE_HEIGHT_SAME * lineNums;
if (sameAs) {
marginTop = 0;
} else {
height += MESSAGE_HEIGHT_FIRST;
marginTop = MESSAGE_HEIGHT_FIRST_MARGIN_TOP;
}
} else {
height = null;
marginTop = null;
}
speech = message.thought.statement.speech;
audience = (_.keys(message.thought.audience)).join(" ");
mez = rele(Message, _.extend({}, message, {
station: station,
sameAs: sameAs,
_handlePm: this._handlePm,
_handleAudi: this._handleAudi,
height: height,
marginTop: marginTop,
index: message.key,
key: "message-" + message.key,
ship: (speech != null ? speech.app : void 0) ? "system" : message.ship,
glyph: this.state.glyph[audience] || this.props['default-glyph'],
unseen: lastIndex && lastIndex === index
}));
mez.computedHeight = height + marginTop;
if (sameAs) {
_messageGroups[0].push(mez);
} else {
_messageGroups.unshift([mez]);
}
}
if (this.props.chrono !== "reverse") {
_messageGroups = _messageGroups.reverse();
}
_messages = _.flatten(_messageGroups);
if ((this.props.readOnly == null) && INFINITE) {
body = rele(Infinite, {
useWindowAsScrollContainer: true,
containerHeight: window.innerHeight,
elementHeight: _.map(_messages, 'computedHeight'),
key: "messages-infinite"
}, _messages);
} else {
body = _messages;
}
fetching = this.state.fetching ? rele(Load, {}) : void 0;
return div({
className: "grams",
key: "messages"
}, body, fetching);
}
});
},{"../actions/MessageActions.coffee":1,"../actions/StationActions.coffee":2,"../stores/MessageStore.coffee":13,"../stores/StationStore.coffee":14,"../util.coffee":15,"./LoadComponent.coffee":3,"./MessageComponent.coffee":5}],7:[function(require,module,exports){
var Load, Member, MessageStore, StationActions, StationStore, a, clas, div, h1, h2, input, label, recl, ref, rele, span, style, util,
indexOf = [].indexOf || function(item) { for (var i = 0, l = this.length; i < l; i++) { if (i in this && this[i] === item) return i; } return -1; };
util = require('../util.coffee');
clas = require('classnames');
recl = React.createClass;
rele = React.createElement;
ref = React.DOM, div = ref.div, style = ref.style, input = ref.input, h1 = ref.h1, h2 = ref.h2, label = ref.label, span = ref.span, a = ref.a;
MessageStore = require('../stores/MessageStore.coffee');
StationStore = require('../stores/StationStore.coffee');
StationActions = require('../actions/StationActions.coffee');
Member = require('./MemberComponent.coffee');
Load = require('./LoadComponent.coffee');
module.exports = recl({
displayName: "Station",
stateFromStore: function() {
var ref1;
return {
audi: StationStore.getAudience(),
members: StationStore.getMembers(),
station: util.mainStation(),
stations: StationStore.getStations(),
configs: StationStore.getConfigs(),
fetching: MessageStore.getFetching(),
typing: StationStore.getTyping(),
listening: StationStore.getListening(),
open: (((ref1 = this.state) != null ? ref1.open : void 0) ? this.state.open : null)
};
},
getInitialState: function() {
return this.stateFromStore();
},
componentDidMount: function() {
this.$el = $(ReactDOM.findDOMNode());
StationStore.addChangeListener(this._onChangeStore);
if (this.state.listening.indexOf(this.state.station) === -1) {
return StationActions.listenStation(this.state.station);
}
},
componentWillUnmount: function() {
return StationStore.removeChangeListener(this._onChangeStore);
},
_onChangeStore: function() {
return this.setState(this.stateFromStore());
},
componentWillReceiveProps: function(nextProps) {
if (this.props.open === true && nextProps.open === false) {
return this.setState({
open: null
});
}
},
validateSource: function(s) {
var sources;
sources = this.state.configs[this.state.station].sources;
return indexOf.call(sources, s) < 0 && indexOf.call(s, "/") >= 0 && s[0] === "~" && s.length >= 5;
},
onKeyUp: function(e) {
var $input, _sources, v;
$('.menu.depth-1 .add').removeClass('valid-false');
if (e.keyCode === 13) {
$input = $(e.target);
v = $input.val().toLowerCase();
if (v[0] !== "~") {
v = "~" + v;
}
if (this.validateSource(v)) {
_sources = _.clone(this.state.configs[this.state.station].sources);
_sources.push(v);
StationActions.setSources(this.state.station, _sources);
$input.val('');
return $input.blur();
} else {
return $('.menu.depth-1 .add').addClass('valid-false');
}
}
},
_openStation: function(e) {
var $t;
$t = $(e.target);
return this.setState({
open: $t.attr('data-station')
});
},
_closeStation: function() {
return this.setState({
open: null
});
},
_remove: function(e) {
var _sources, _station;
e.stopPropagation();
e.preventDefault();
_station = $(e.target).attr("data-station");
_sources = _.clone(this.state.configs[this.state.station].sources);
_sources.splice(_sources.indexOf(_station), 1);
return StationActions.setSources(this.state.station, _sources);
},
render: function() {
var _clas, member, members, parts, source, sources, sourcesSum, station;
parts = [];
members = [];
if (this.state.station && this.state.configs[this.state.station]) {
members = (function() {
var ref1, results;
ref1 = this.state.members;
results = [];
for (station in ref1) {
members = ref1[station];
_clas = clas({
open: this.state.open === station,
closed: !(this.state.open === station),
menu: true,
'depth-2': true
});
results.push(div({
className: _clas,
"data-members": station,
key: station
}, div({
className: "contents",
onClick: this._closeStation
}, div({
className: "close"
}, "✕"), h2({}, span({}, "Members"), label({
className: "sum"
}, _.keys(members).length)), (function() {
var results1;
results1 = [];
for (member in members) {
results1.push(div({
key: member
}, div({
className: "name"
}, ""), div({
className: "planet"
}, member)));
}
return results1;
})())));
}
return results;
}).call(this);
}
if (this.state.station && this.state.configs[this.state.station]) {
sources = (function() {
var i, len, ref1, results;
ref1 = this.state.configs[this.state.station].sources;
results = [];
for (i = 0, len = ref1.length; i < len; i++) {
source = ref1[i];
results.push(div({
key: source,
className: "room"
}, div({
className: (this.state.open === source ? "selected" : ""),
onClick: this._openStation,
"data-station": source
}, source), div({
className: "close",
onClick: this._remove,
"data-station": source
}, "✕")));
}
return results;
}).call(this);
sources.push(input({
key: "placeholder",
className: "action add",
placeholder: "+ Listen",
onKeyUp: this.onKeyUp
}));
sourcesSum = this.state.configs[this.state.station].sources.length;
} else {
sources = "";
sourcesSum = 0;
}
_clas = clas({
open: this.props.open === true,
closed: this.props.open !== true,
menu: true,
'depth-1': true
});
return div({
key: "station-container"
}, div({
className: _clas,
key: 'station'
}, div({
className: "contents"
}, div({
className: "close",
onClick: this.props.toggle
}, "✕"), h2({}, span({}, "Stations"), label({
className: "sum"
}, sourcesSum)), div({}, sources))), members);
}
});
},{"../actions/StationActions.coffee":2,"../stores/MessageStore.coffee":13,"../stores/StationStore.coffee":14,"../util.coffee":15,"./LoadComponent.coffee":3,"./MemberComponent.coffee":4,"classnames":16}],8:[function(require,module,exports){
var Audience, Member, MessageActions, MessageStore, PO, SHIPSHAPE, StationActions, StationStore, br, div, husl, input, recl, ref, textToHTML, textarea, util,
hasProp = {}.hasOwnProperty;
util = require('../util.coffee');
recl = React.createClass;
ref = React.DOM, div = ref.div, br = ref.br, input = ref.input, textarea = ref.textarea;
husl = require('husl');
MessageActions = require('../actions/MessageActions.coffee');
MessageStore = require('../stores/MessageStore.coffee');
StationActions = require('../actions/StationActions.coffee');
StationStore = require('../stores/StationStore.coffee');
Member = require('./MemberComponent.coffee');
SHIPSHAPE = /^~?([a-z]{3}|[a-z]{6}(-[a-z]{6}){0,3}|[a-z]{6}(-[a-z]{6}){3}(--[a-z]{6}(-[a-z]{6}){3})+)$/;
PO = 'dozmarbinwansamlitsighidfidlissogdirwacsabwissib\nrigsoldopmodfoglidhopdardorlorhodfolrintogsilmir\nholpaslacrovlivdalsatlibtabhanticpidtorbolfosdot\nlosdilforpilramtirwintadbicdifrocwidbisdasmidlop\nrilnardapmolsanlocnovsitnidtipsicropwitnatpanmin\nritpodmottamtolsavposnapnopsomfinfonbanporworsip\nronnorbotwicsocwatdolmagpicdavbidbaltimtasmallig\nsivtagpadsaldivdactansidfabtarmonranniswolmispal\nlasdismaprabtobrollatlonnodnavfignomnibpagsopral\nbilhaddocridmocpacravripfaltodtiltinhapmicfanpat\ntaclabmogsimsonpinlomrictapfirhasbosbatpochactid\nhavsaplindibhosdabbitbarracparloddosbortochilmac\ntomdigfilfasmithobharmighinradmashalraglagfadtop\nmophabnilnosmilfopfamdatnoldinhatnacrisfotribhoc\nnimlarfitwalrapsarnalmoslandondanladdovrivbacpol\nlaptalpitnambonrostonfodponsovnocsorlavmatmipfap\n\nzodnecbudwessevpersutletfulpensytdurwepserwylsun\nrypsyxdyrnuphebpeglupdepdysputlughecryttyvsydnex\nlunmeplutseppesdelsulpedtemledtulmetwenbynhexfeb\npyldulhetmevruttylwydtepbesdexsefwycburderneppur\nrysrebdennutsubpetrulsynregtydsupsemwynrecmegnet\nsecmulnymtevwebsummutnyxrextebfushepbenmuswyxsym\nselrucdecwexsyrwetdylmynmesdetbetbeltuxtugmyrpel\nsyptermebsetdutdegtexsurfeltudnuxruxrenwytnubmed\nlytdusnebrumtynseglyxpunresredfunrevrefmectedrus\nbexlebduxrynnumpyxrygryxfeptyrtustyclegnemfermer\ntenlusnussyltecmexpubrymtucfyllepdebbermughuttun\nbylsudpemdevlurdefbusbeprunmelpexdytbyttyplevmyl\nwedducfurfexnulluclennerlexrupnedlecrydlydfenwel\nnydhusrelrudneshesfetdesretdunlernyrsebhulryllud\nremlysfynwerrycsugnysnyllyndyndemluxfedsedbecmun\nlyrtesmudnytbyrsenwegfyrmurtelreptegpecnelnevfes';
textToHTML = function(txt) {
return {
__html: $('<div>').text(txt).html()
};
};
Audience = recl({
displayName: "Audience",
onKeyDown: function(e) {
if (e.keyCode === 13) {
e.preventDefault();
if (this.props.validate()) {
setTimeout((function() {
return $('.writing').focus();
}), 0);
return false;
}
}
if (e.keyCode === 9) {
e.preventDefault();
this._autoCompleteAudience();
return false;
} else if ((this.tabAudList != null) && e.keyCode !== 16) {
this.tabAudList = null;
return this.tabAudIndex = null;
}
},
_autoCompleteAudience: function() {
var aud, g, i, j, len, len1, ref1, ref2, s, stations, txt;
txt = $('#audience .input').text().trim();
if (this.tabAudList == null) {
this.tabAudList = [];
if (txt.length === 1 && StationStore.getGlyphs()[txt[0]]) {
ref1 = this._getGlyphExpansions(txt[0]);
for (i = 0, len = ref1.length; i < len; i++) {
s = ref1[i];
this.tabAudList.push(s[0]);
}
} else {
if (!(txt[0] === '~')) {
txt = '~' + txt;
}
ref2 = StationStore.getGlyphs();
for (g in ref2) {
stations = ref2[g];
for (j = 0, len1 = stations.length; j < len1; j++) {
aud = stations[j];
if (aud[0].indexOf(txt) === 0 && this.tabAudList.indexOf(aud[0]) < 0) {
this.tabAudList.push(aud[0]);
}
}
}
}
}
if ((this.tabAudList != null) && this.tabAudList.length > 0) {
if (this.tabAudIndex != null) {
if (event.shiftKey) {
this.tabAudIndex--;
} else {
this.tabAudIndex++;
}
this.tabAudIndex = (this.tabAudIndex % this.tabAudList.length + this.tabAudList.length) % this.tabAudList.length;
} else {
this.tabAudIndex = 0;
}
return StationActions.setAudience(this.tabAudList[this.tabAudIndex].split(/\ +/));
}
},
_getGlyphExpansions: function(g) {
var glyphs;
glyphs = StationStore.getGlyphs();
if (glyphs[g]) {
return glyphs[g];
}
},
render: function() {
return div({
className: 'audience',
id: 'audience',
key: 'audience'
}, div({
className: "input valid-" + this.props.valid,
key: 'input',
contentEditable: this.props.editable ? true : void 0,
onKeyDown: this.onKeyDown,
onBlur: this.props.onBlur,
dangerouslySetInnerHTML: textToHTML(this.props.audi.join(" "))
}));
}
});
module.exports = recl({
displayName: "Writing",
set: function() {
if (window.localStorage && this.$message) {
return window.localStorage.setItem('writing', this.$message.text());
}
},
get: function() {
if (window.localStorage) {
return window.localStorage.getItem('writing');
}
},
stateFromStore: function() {
var s;
s = {
audi: StationStore.getAudience(),
ludi: MessageStore.getLastAudience(),
config: StationStore.getConfigs(),
members: StationStore.getMembers(),
typing: StationStore.getTyping(),
station: StationStore.getStation(),
valid: StationStore.getValidAudience()
};
s.audi = _.without(s.audi, util.mainStationPath(window.urb.user));
s.ludi = _.without(s.ludi, util.mainStationPath(window.urb.user));
return s;
},
getInitialState: function() {
return _.extend(this.stateFromStore(), {
length: 0,
lengthy: false
});
},
typing: function(state) {
if (this.state.typing[this.state.station] !== state) {
return StationActions.setTyping(this.state.station, state);
}
},
onBlur: function() {
this.$message.text(this.$message.text());
MessageActions.setTyping(false);
return this.typing(false);
},
onFocus: function() {
MessageActions.setTyping(true);
this.typing(true);
return this.cursorAtEnd;
},
addCC: function(audi) {
var listening, ref1, ref2;
if (urb.user !== urb.ship) {
return audi;
}
listening = (ref1 = (ref2 = this.state.config[this.props.station]) != null ? ref2.sources : void 0) != null ? ref1 : [];
if (_.isEmpty(_.intersection(audi, listening))) {
audi.push("~" + window.urb.user + "/" + this.props.station);
}
return audi;
},
sendMessage: function() {
var audi, txt;
if (this._validateAudi() === false) {
setTimeout((function() {
return $('#audience .input').focus();
}), 0);
return;
}
if (!(this.state.audi.length === 0 && $('#audience').text().trim().length > 0)) {
audi = this.state.audi;
} else {
audi = this._setAudi() || this.state.ludi;
}
if (_.isEmpty(audi)) {
console.warn("No audience");
return;
}
if (this.props['audience-lock'] != null) {
audi = _.union(audi, ["~" + window.urb.ship + "/" + this.props.station]);
}
audi = this.addCC(audi);
txt = this.$message.text().trim().replace(/\xa0/g, ' ');
MessageActions.sendMessage(txt, audi);
this.$message.text('');
this.setState({
length: 0
});
this.set();
return this.typing(false);
},
onKeyUp: function(e) {
if (!window.urb.util.isURL(this.$message.text())) {
return this.setState({
lengthy: this.$message.text().length > 62
});
}
},
onKeyDown: function(e) {
var txt;
if (e.keyCode === 13) {
txt = this.$message.text();
e.preventDefault();
if (txt.length > 0) {
if (window.talk.online) {
this.sendMessage();
} else {
$('#offline').addClass('error').one('transitionend', function() {
return $('#offline').removeClass('error');
});
}
}
return false;
}
if (e.keyCode === 9) {
e.preventDefault();
this._autoComplete();
return false;
} else if ((this.tabList != null) && e.keyCode !== 16) {
this.tabList = null;
this.tabIndex = null;
}
this.onInput();
return this.set();
},
_autoComplete: function() {
var i, msg, name, obj, ptxt, ref1, ref2, tindex, txt;
txt = this.$message.text();
tindex = txt.lastIndexOf('~');
if (tindex === -1) {
return;
}
if (this.tabList == null) {
ptxt = txt.substr(tindex + 1);
if (ptxt.length < 13 && (ptxt.match('^[a-z]{0,6}([\\-\\^_][a-z]{0,5})?$') != null)) {
this.tabList = [];
ref1 = MessageStore.getAll();
for (i = ref1.length - 1; i >= 0; i += -1) {
msg = ref1[i];
this._processAutoCompleteName(ptxt, msg.ship);
}
ref2 = this.state.members[this.state.ludi[0]];
for (name in ref2) {
if (!hasProp.call(ref2, name)) continue;
obj = ref2[name];
this._processAutoCompleteName(ptxt, name.substr(1));
}
}
}
if ((this.tabList != null) && this.tabList.length > 0) {
if (this.tabIndex != null) {
if (event.shiftKey) {
this.tabIndex--;
} else {
this.tabIndex++;
}
this.tabIndex = (this.tabIndex % this.tabList.length + this.tabList.length) % this.tabList.length;
} else {
this.tabIndex = 0;
}
name = this.tabList[this.tabIndex];
this.$message.text(this.$message.text().substr(0, tindex + 1) + name);
return this.cursorAtEnd();
}
},
_processAutoCompleteName: function(ptxt, name) {
if (name.length === 27) {
name = name.substr(-13).replace('-', '^');
} else if (name.length === 56) {
name = name.substr(0, 6) + '_' + name.substr(-6);
}
if (name.indexOf(ptxt) === 0 && this.tabList.indexOf(name) === -1) {
return this.tabList.push(name);
}
},
onInput: function(e) {
var length, text;
text = this.$message.text();
length = text.length;
return this.setState({
length: length
});
},
_validateAudiPart: function(a) {
var _a, ship;
a = a.trim();
if (a.indexOf("/") !== -1) {
_a = a.split("/");
if (_a[1].length === 0) {
return false;
}
ship = _a[0];
} else {
ship = a;
}
return (SHIPSHAPE.test(ship)) && _.all(ship.match(/[a-z]{3}/g), function(a) {
return -1 !== PO.indexOf(a);
});
},
_validateAudi: function() {
var v;
v = $('#audience .input').text();
v = v.trim();
if (v.length === 0) {
return true;
}
if (v.length < 5) {
return false;
}
return _.all(v.split(/\ +/), this._validateAudiPart);
},
_setAudi: function() {
var stan, valid;
valid = this._validateAudi();
StationActions.setValidAudience(valid);
if (valid === true) {
stan = $('#audience .input').text() || util.mainStationPath(window.urb.user);
stan = (stan.split(/\ +/)).map(function(v) {
if (v[0] === "~") {
return v;
} else {
return "~" + v;
}
});
StationActions.setAudience(stan);
return stan;
} else {
return false;
}
},
getTime: function() {
var d, seconds;
d = new Date();
seconds = d.getSeconds();
if (seconds < 10) {
seconds = "0" + seconds;
}
return "~" + d.getHours() + "." + d.getMinutes() + "." + seconds;
},
cursorAtEnd: function() {
var range, selection;
range = document.createRange();
range.selectNodeContents(this.$message[0]);
range.collapse(false);
selection = window.getSelection();
selection.removeAllRanges();
return selection.addRange(range);
},
componentDidMount: function() {
util.sendMessage = this.sendMessage;
StationStore.addChangeListener(this._onChangeStore);
MessageStore.addChangeListener(this._onChangeStore);
this.$el = $(ReactDOM.findDOMNode(this));
this.$message = $('#message .input');
this.$message.focus();
if (this.get()) {
this.$message.text(this.get());
this.onInput();
}
return this.interval = setInterval((function(_this) {
return function() {
return _this.$el.find('.time').text(_this.getTime());
};
})(this), 1000);
},
componentWillUnmount: function() {
StationStore.removeChangeListener(this._onChangeStore);
return clearInterval(this.interval);
},
_onChangeStore: function() {
return this.setState(this.stateFromStore());
},
render: function() {
var audi, iden, k, name, ship, user, v;
user = "~" + window.urb.user;
iden = StationStore.getMember(user);
ship = iden ? iden.ship : user;
name = iden ? iden.name : "";
audi = this.state.audi.length === 0 ? this.state.ludi : this.state.audi;
audi = util.clipAudi(audi);
for (k in audi) {
v = audi[k];
if (audi[k].indexOf('~~') === 0) {
audi[k] = v.slice(1);
}
}
return div({
className: 'writing',
key: 'writing'
}, React.createElement(Audience, {
audi: audi,
valid: this.state.valid,
validate: this._validateAudi,
editable: this.props['audience-lock'] == null,
onBlur: this._setAudi
}), div({
className: 'message',
id: 'message',
key: 'message'
}, div({
className: 'input',
contentEditable: true,
onPaste: this.onInput,
onInput: this.onInput,
onFocus: this.onFocus,
onBlur: this.onBlur,
onKeyDown: this.onKeyDown,
onKeyUp: this.onKeyUp,
dangerouslySetInnerHTML: {
__html: ""
}
})), div({
className: 'length',
key: 'length'
}, this.state.length + "/64 (" + (Math.ceil(this.state.length / 64)) + ")"));
}
});
},{"../actions/MessageActions.coffee":1,"../actions/StationActions.coffee":2,"../stores/MessageStore.coffee":13,"../stores/StationStore.coffee":14,"../util.coffee":15,"./MemberComponent.coffee":4,"husl":17}],9:[function(require,module,exports){
module.exports = _.extend(new Flux.Dispatcher(), {
handleServerAction: function(action) {
return this.dispatch({
source: 'server',
action: action
});
},
handleViewAction: function(action) {
return this.dispatch({
source: 'view',
action: action
});
}
});
},{}],10:[function(require,module,exports){
var MessageListComponent, StationActions, StationComponent, TreeActions, WritingComponent, div, link, ref, util;
util = require('./util.coffee');
_.merge(window, {
util: util,
talk: {
online: true
}
});
StationActions = require('./actions/StationActions.coffee');
TreeActions = window.tree.actions;
setInterval((function() {
window.talk.online = window.urb.poll.dely < 500;
if (window.talk.online) {
return $('body').removeClass('offline');
} else {
return $('body').addClass('offline');
}
}), 300);
StationComponent = require('./components/StationComponent.coffee');
MessageListComponent = React.createFactory(require('./components/MessageListComponent.coffee'));
WritingComponent = React.createFactory(require('./components/WritingComponent.coffee'));
ref = React.DOM, div = ref.div, link = ref.link;
TreeActions.registerComponent("talk", React.createClass({
displayName: "talk",
getStation: function() {
return this.props.station || util.defaultStation();
},
componentWillMount: function() {
var station;
if (!this.props.readonly) {
$(window).on('scroll', util.checkScroll);
}
station = this.getStation();
StationActions.listen();
return StationActions.switchStation(station);
},
render: function() {
var children, station;
station = this.getStation();
children = [
div({
key: "grams-container"
}, MessageListComponent(_.merge({}, this.props, {
station: station,
key: 'grams'
}), '')), this.props.readOnly == null ? div({
key: 'writing-container'
}, WritingComponent(_.merge({}, this.props, {
station: station,
key: 'writing'
}), '')) : void 0
];
if (this.props.chrono === "reverse") {
children = children.reverse();
}
return div({
key: "talk-container"
}, children);
}
}));
TreeActions.registerComponent("talk-station", StationComponent);
},{"./actions/StationActions.coffee":2,"./components/MessageListComponent.coffee":6,"./components/StationComponent.coffee":7,"./components/WritingComponent.coffee":8,"./util.coffee":15}],11:[function(require,module,exports){
var send, util;
util = require('../util.coffee');
window.urb.appl = "talk";
send = function(data, cb) {
return window.urb.send(data, {
mark: "talk-command"
}, cb);
};
module.exports = function(arg) {
var MessageActions;
MessageActions = arg.MessageActions;
return {
listenStation: function(station, since) {
var $this, path;
console.log('listen station');
console.log(arguments);
$this = this;
path = util.talkPath({
'f_grams': 'f_grams'
}, station, since);
return window.urb.bind(path, function(err, res) {
var num, ref, ref1, ref2, ref3, tele;
if (err || !res.data) {
console.log(path, 'err!');
console.log(err);
console.log(res);
$this.listenStation(station, since);
return;
}
console.log(path);
console.log(res.data);
if (res.data.ok === true) {
MessageActions.listeningStation(station);
}
if ((ref = res.data) != null ? (ref1 = ref.grams) != null ? ref1.tele : void 0 : void 0) {
ref3 = (ref2 = res.data) != null ? ref2.grams : void 0, tele = ref3.tele, num = ref3.num;
return MessageActions.loadMessages(tele, num);
}
});
},
get: function(station, start, end) {
var path;
end = window.urb.util.numDot(end);
start = window.urb.util.numDot(start);
path = util.talkPath({
'f_grams': 'f_grams'
}, station, end, start);
return window.urb.bind(path, function(err, res) {
var num, ref, ref1, ref2, ref3, tele;
if (err || !res.data) {
console.log(path, '/e/s err');
console.log(err);
return;
}
console.log(path, '/e/s');
console.log(res);
if ((ref = res.data) != null ? (ref1 = ref.grams) != null ? ref1.tele : void 0 : void 0) {
ref3 = (ref2 = res.data) != null ? ref2.grams : void 0, tele = ref3.tele, num = ref3.num;
MessageActions.loadMessages(tele, num, true);
return window.urb.drop(path, function(err, res) {
console.log('done');
return console.log(res);
});
}
});
},
sendMessage: function(messageType, message, cb) {
var obj;
return send((
obj = {},
obj["" + messageType] = [message],
obj
), function(err, res) {
console.log('sent');
console.log(arguments);
if (cb) {
return cb(err, res);
}
});
}
};
};
},{"../util.coffee":15}],12:[function(require,module,exports){
var design, send, subscribed, util;
util = require('../util.coffee');
window.urb.appl = "talk";
send = function(data, cb) {
return window.urb.send(data, {
mark: "talk-command"
}, cb);
};
design = function(party, config, cb) {
return send({
design: {
party: party,
config: config
}
}, cb);
};
subscribed = {};
module.exports = function(arg) {
var StationActions;
StationActions = arg.StationActions;
return {
createStation: function(name, cb) {
return design(name, {
sources: [],
caption: "",
cordon: {
posture: "white",
list: []
}
}, cb);
},
removeStation: function(name, cb) {
return design(name, null, cb);
},
setSources: function(station, ship, sources) {
var cordon;
cordon = {
posture: "black",
list: []
};
return design(station, {
sources: sources,
cordon: cordon,
caption: ""
}, function(err, res) {
console.log('talk-command');
return console.log(arguments);
});
},
listen: function() {
return window.urb.bind("/", function(err, res) {
var house;
if (err || !res.data) {
console.log('/ err');
console.log(err);
return;
}
console.log('/');
console.log(res.data);
house = res.data.house;
if (house) {
return StationActions.loadStations(res.data.house);
}
});
},
listenStation: function(station, arg1) {
var cabal, glyph, group, k, path, types;
group = arg1.group, glyph = arg1.glyph, cabal = arg1.cabal;
if (subscribed[station] == null) {
subscribed[station] = {};
}
types = {
a_group: group,
v_glyph: glyph,
x_cabal: cabal
};
for (k in types) {
if (subscribed[station][k]) {
delete types[k];
} else {
subscribed[station][k] = types[k];
}
}
if (_.isEmpty(types)) {
return;
}
path = util.talkPath(types, station);
return window.urb.bind(path, function(err, res) {
var ok, ref;
if (err || !res) {
console.log(path, 'err');
console.log(err);
return;
}
console.log(path);
console.log(res.data);
ref = res.data, ok = ref.ok, group = ref.group, cabal = ref.cabal, glyph = ref.glyph;
switch (false) {
case !ok:
return StationActions.listeningStation(station);
case !group:
group.global[util.mainStationPath(window.urb.user)] = group.local;
return StationActions.loadMembers(group.global);
case !(cabal != null ? cabal.loc : void 0):
return StationActions.loadConfig(station, cabal.loc);
case !glyph:
return StationActions.loadGlyphs(glyph);
}
});
}
};
};
},{"../util.coffee":15}],13:[function(require,module,exports){
var EventEmitter, MessageDispatcher, MessageStore, _fetching, _last, _listening, _messages, _station, _typing, moment;
moment = window.moment.tz;
EventEmitter = require('events').EventEmitter;
MessageDispatcher = require('../dispatcher/Dispatcher.coffee');
_messages = {};
_fetching = false;
_last = null;
_station = null;
_listening = [];
_typing = false;
MessageStore = _.merge(new EventEmitter, {
removeChangeListener: function(cb) {
return this.removeListener("change", cb);
},
emitChange: function() {
return this.emit('change');
},
addChangeListener: function(cb) {
return this.on('change', cb);
},
leadingZero: function(str) {
if (Number(str) < 10) {
return "0" + str;
} else {
return str;
}
},
convertDate: function(time) {
var d;
time = time.substr(1).split(".");
time[1] = this.leadingZero(time[1]);
time[2] = this.leadingZero(time[2]);
d = new moment(time[0] + "-" + time[1] + "-" + time[2] + "T" + time[4] + ":" + time[5] + ":" + time[6] + "Z");
d.tz("Europe/London");
return d;
},
getListening: function() {
return _listening;
},
getTyping: function() {
return _typing;
},
getLastAudience: function() {
var messages;
if (_.keys(_messages).length === 0) {
return [];
}
messages = _.sortBy(_messages, function(_message) {
return _message.thought.statement.time;
});
return _.keys(messages[messages.length - 1].thought.audience);
},
setTyping: function(state) {
return _typing = state;
},
setListening: function(station) {
if (_listening.indexOf(station) !== -1) {
return console.log('already listening on that station (somehow).');
} else {
return _listening.push(station);
}
},
setStation: function(station) {
return _station = station;
},
sendMessage: function(message) {
return _messages[message.thought.serial] = message;
},
loadMessages: function(messages, last, get) {
var i, key, len, serial, v;
key = last;
for (i = 0, len = messages.length; i < len; i++) {
v = messages[i];
serial = v.thought.serial;
v.key = key++;
_messages[serial] = v;
}
if (last < _last || _last === null || get === true) {
_last = last;
}
return _fetching = false;
},
getAll: function() {
return _.values(_messages);
},
getFetching: function() {
return _fetching;
},
setFetching: function(state) {
return _fetching = state;
},
getLast: function() {
return _last;
}
});
MessageStore.setMaxListeners(100);
MessageStore.dispatchToken = MessageDispatcher.register(function(payload) {
var action;
action = payload.action;
switch (action.type) {
case 'station-switch':
MessageStore.setStation(action.station);
break;
case 'messages-listen':
MessageStore.setListening(action.station);
MessageStore.emitChange();
break;
case 'messages-typing':
MessageStore.setTyping(action.state);
MessageStore.emitChange();
break;
case 'messages-fetch':
MessageStore.setFetching(true);
MessageStore.emitChange();
break;
case 'messages-load':
MessageStore.loadMessages(action.messages, action.last, action.get);
MessageStore.emitChange();
break;
case 'message-load':
MessageStore.loadMessage(action.time, action.message, action.author);
MessageStore.emitChange();
break;
case 'message-send':
MessageStore.sendMessage(action.message);
MessageStore.emitChange();
break;
}
});
module.exports = MessageStore;
},{"../dispatcher/Dispatcher.coffee":9,"events":18}],14:[function(require,module,exports){
var EventEmitter, StationDispatcher, StationStore, _audience, _config, _glyphs, _listening, _members, _shpylg, _station, _stations, _typing, _validAudience;
EventEmitter = require('events').EventEmitter;
StationDispatcher = require('../dispatcher/Dispatcher.coffee');
_audience = [];
_members = {};
_stations = [];
_listening = [];
_station = null;
_config = {};
_typing = {};
_glyphs = {};
_shpylg = {};
_validAudience = true;
StationStore = _.merge(new EventEmitter, {
removeChangeListener: function(cb) {
return this.removeListener("change", cb);
},
emitChange: function() {
return this.emit('change');
},
addChangeListener: function(cb) {
return this.on('change', cb);
},
getAudience: function() {
return _audience;
},
setAudience: function(audience) {
return _audience = audience;
},
getValidAudience: function() {
return _validAudience;
},
setValidAudience: function(valid) {
return _validAudience = valid;
},
toggleAudience: function(station) {
if (_audience.indexOf(station) !== -1) {
return _audience.splice(_audience.indexOf(station), 1);
} else {
return _audience.push(station);
}
},
loadConfig: function(station, config) {
return _config[station] = config;
},
getConfigs: function() {
return _config;
},
getConfig: function(station) {
return _config[station];
},
getGlyph: function(station) {
return _shpylg[station];
},
getGlyphMap: function() {
return _shpylg;
},
getGlyphAudience: function(glyph) {
var aud, ref;
aud = (ref = _glyphs[glyph]) != null ? ref : [];
if (aud.length === 1) {
return aud[0];
}
},
getMember: function(ship) {
return {
ship: ship
};
},
loadMembers: function(members) {
return _members = members;
},
getMembers: function() {
return _members;
},
getListening: function() {
return _listening;
},
setListening: function(station) {
if (_listening.indexOf(station) !== -1) {
return console.log('already listening on that station (somehow).');
} else {
return _listening.push(station);
}
},
createStation: function(station) {
if (_stations.indexOf(station) === -1) {
return _stations.push(station);
}
},
loadStations: function(stations) {
return _stations = stations;
},
loadGlyphs: function(glyphs) {
var aud, auds, char, results;
_glyphs = glyphs;
_shpylg = {};
results = [];
for (char in glyphs) {
auds = glyphs[char];
results.push((function() {
var i, len, results1;
results1 = [];
for (i = 0, len = auds.length; i < len; i++) {
aud = auds[i];
results1.push(_shpylg[aud.join(" ")] = char);
}
return results1;
})());
}
return results;
},
getGlyphs: function() {
return _glyphs;
},
getStations: function() {
return _stations;
},
setStation: function(station) {
return _station = station;
},
unsetStation: function(station) {
if (_station === station) {
return _station = null;
}
},
getStation: function() {
return _station;
},
joinStation: function(station) {
var ref;
if (((ref = _config.court) != null ? ref.sources.indexOf(station) : void 0) === -1) {
return _config.court.sources.push(station);
}
},
getTyping: function() {
return _typing;
},
setTyping: function(station, state) {
var k, v;
for (k in _typing) {
v = _typing[k];
_typing[k] = k === station;
}
return _typing[station] = state;
}
});
StationStore.setMaxListeners(100);
StationStore.dispatchToken = StationDispatcher.register(function(payload) {
var action;
action = payload.action;
switch (action.type) {
case 'station-audience-toggle':
StationStore.toggleAudience(action.station);
StationStore.emitChange();
break;
case 'station-set-audience':
StationStore.setAudience(action.audience);
StationStore.emitChange();
break;
case 'station-set-valid-audience':
StationStore.setValidAudience(action.valid);
StationStore.emitChange();
break;
case 'station-switch':
StationStore.setAudience([]);
StationStore.setStation(action.station);
StationStore.emitChange();
break;
case 'station-listen':
StationStore.setListening(action.station);
StationStore.emitChange();
break;
case "config-load":
StationStore.loadConfig(action.station, action.config);
StationStore.emitChange();
break;
case "glyphs-load":
StationStore.loadGlyphs(action.glyphs);
StationStore.emitChange();
break;
case "stations-load":
StationStore.loadStations(action.stations);
StationStore.emitChange();
break;
case "stations-leave":
StationStore.loadStations(action.stations);
StationStore.unsetStation(action.station);
StationStore.emitChange();
break;
case "station-create":
StationStore.createStation(action.station);
StationStore.emitChange();
break;
case "members-load":
StationStore.loadMembers(action.members);
StationStore.emitChange();
break;
case "typing-set":
StationStore.setTyping(action.station, action.state);
StationStore.emitChange();
break;
}
});
module.exports = StationStore;
},{"../dispatcher/Dispatcher.coffee":9,"events":18}],15:[function(require,module,exports){
var util,
slice = [].slice;
module.exports = util = {
defaultStation: function() {
var station;
if (document.location.search) {
station = document.location.search.replace(/^\?/, '');
if (station.indexOf('dbg.nopack') !== -1) {
return station = util.mainStation();
}
} else {
return util.mainStation();
}
},
mainStations: ["court", "floor", "porch"],
mainStationPath: function(user) {
if (user) {
return "~" + user + "/" + (util.mainStation(user));
}
},
mainStation: function(user) {
if (!user) {
user = window.urb.user;
}
if (!user) {
return;
}
switch (user.length) {
case 3:
return "court";
case 6:
return "floor";
default:
return "porch";
}
},
clipAudi: function(audi) {
var ms, regx;
audi = audi.join(" ");
ms = util.mainStationPath(window.urb.user);
regx = new RegExp("/" + ms, "g");
audi = audi.replace(regx, "");
return audi.split(" ");
},
expandAudi: function(audi) {
var ms;
audi = audi.join(" ");
ms = util.mainStationPath(window.urb.user);
if (audi.indexOf(ms) === -1) {
if (audi.length > 0) {
audi += " ";
}
audi += "" + ms;
}
return audi.split(" ");
},
create: function(name) {
return window.talk.StationPersistence.createStation(name, function(err, res) {});
},
subscribe: function(name) {
return window.talk.StationPersistence.addSource("main", window.urb.ship, ["~zod/" + name]);
},
uuid32: function() {
var _str, i, j, str;
str = "0v";
str += Math.ceil(Math.random() * 8) + ".";
for (i = j = 0; j <= 5; i = ++j) {
_str = Math.ceil(Math.random() * 10000000).toString(32);
_str = ("00000" + _str).substr(-5, 5);
str += _str + ".";
}
return str.slice(0, -1);
},
populate: function(station, number) {
var c, send;
c = 0;
send = function() {
var _audi, _message;
if (c < number) {
c++;
} else {
console.log('done');
return true;
}
_audi = {};
_audi[station] = "pending";
_message = {
serial: util.uuid32(),
audience: _audi,
statement: {
speech: {
say: "Message " + c
},
time: Date.now(),
now: Date.now()
}
};
return window.talk.MessagePersistence.sendMessage(_message, send);
};
return send();
},
scrollToBottom: function() {
return $(window).scrollTop($(".container").outerHeight(true));
},
getScroll: function() {
return this.writingPosition = $('.container').outerHeight(true) + $('.container').offset().top - $(window).height();
},
setScroll: function() {
util.getScroll();
return $(window).scrollTop($(".container").height());
},
isScrolling: function() {
if (!util.writingPosition) {
util.getScroll();
}
return $(window).scrollTop() + $('.writing').outerHeight() < util.writingPosition;
},
talkPath: function() {
var components, encodedTypes, key, types, val;
types = arguments[0], components = 2 <= arguments.length ? slice.call(arguments, 1) : [];
encodedTypes = ((function() {
var results;
results = [];
for (key in types) {
val = types[key];
if (key !== 'a_group' && key !== 'f_grams' && key !== 'v_glyph' && key !== 'x_cabal') {
throw new Error("Weird type: '" + key + "'");
}
if (val) {
results.push(key[0]);
} else {
results.push(void 0);
}
}
return results;
})()).join('');
return ['', encodedTypes].concat(slice.call(components)).join('/');
}
};
},{}],16:[function(require,module,exports){
/*!
Copyright (c) 2016 Jed Watson.
Licensed under the MIT License (MIT), see
http://jedwatson.github.io/classnames
*/
/* global define */
(function () {
'use strict';
var hasOwn = {}.hasOwnProperty;
function classNames () {
var classes = [];
for (var i = 0; i < arguments.length; i++) {
var arg = arguments[i];
if (!arg) continue;
var argType = typeof arg;
if (argType === 'string' || argType === 'number') {
classes.push(arg);
} else if (Array.isArray(arg)) {
classes.push(classNames.apply(null, arg));
} else if (argType === 'object') {
for (var key in arg) {
if (hasOwn.call(arg, key) && arg[key]) {
classes.push(key);
}
}
}
}
return classes.join(' ');
}
if (typeof module !== 'undefined' && module.exports) {
module.exports = classNames;
} else if (typeof define === 'function' && typeof define.amd === 'object' && define.amd) {
// register as 'classnames', consistent with npm package name
define('classnames', [], function () {
return classNames;
});
} else {
window.classNames = classNames;
}
}());
},{}],17:[function(require,module,exports){
// Generated by CoffeeScript 1.9.3
(function() {
var L_to_Y, Y_to_L, conv, distanceFromPole, dotProduct, epsilon, fromLinear, getBounds, intersectLineLine, kappa, lengthOfRayUntilIntersect, m, m_inv, maxChromaForLH, maxSafeChromaForL, refU, refV, root, toLinear;
m = {
R: [3.2409699419045214, -1.5373831775700935, -0.49861076029300328],
G: [-0.96924363628087983, 1.8759675015077207, 0.041555057407175613],
B: [0.055630079696993609, -0.20397695888897657, 1.0569715142428786]
};
m_inv = {
X: [0.41239079926595948, 0.35758433938387796, 0.18048078840183429],
Y: [0.21263900587151036, 0.71516867876775593, 0.072192315360733715],
Z: [0.019330818715591851, 0.11919477979462599, 0.95053215224966058]
};
refU = 0.19783000664283681;
refV = 0.468319994938791;
kappa = 903.2962962962963;
epsilon = 0.0088564516790356308;
getBounds = function(L) {
var bottom, channel, j, k, len1, len2, m1, m2, m3, ref, ref1, ref2, ret, sub1, sub2, t, top1, top2;
sub1 = Math.pow(L + 16, 3) / 1560896;
sub2 = sub1 > epsilon ? sub1 : L / kappa;
ret = [];
ref = ['R', 'G', 'B'];
for (j = 0, len1 = ref.length; j < len1; j++) {
channel = ref[j];
ref1 = m[channel], m1 = ref1[0], m2 = ref1[1], m3 = ref1[2];
ref2 = [0, 1];
for (k = 0, len2 = ref2.length; k < len2; k++) {
t = ref2[k];
top1 = (284517 * m1 - 94839 * m3) * sub2;
top2 = (838422 * m3 + 769860 * m2 + 731718 * m1) * L * sub2 - 769860 * t * L;
bottom = (632260 * m3 - 126452 * m2) * sub2 + 126452 * t;
ret.push([top1 / bottom, top2 / bottom]);
}
}
return ret;
};
intersectLineLine = function(line1, line2) {
return (line1[1] - line2[1]) / (line2[0] - line1[0]);
};
distanceFromPole = function(point) {
return Math.sqrt(Math.pow(point[0], 2) + Math.pow(point[1], 2));
};
lengthOfRayUntilIntersect = function(theta, line) {
var b1, len, m1;
m1 = line[0], b1 = line[1];
len = b1 / (Math.sin(theta) - m1 * Math.cos(theta));
if (len < 0) {
return null;
}
return len;
};
maxSafeChromaForL = function(L) {
var b1, j, len1, lengths, m1, ref, ref1, x;
lengths = [];
ref = getBounds(L);
for (j = 0, len1 = ref.length; j < len1; j++) {
ref1 = ref[j], m1 = ref1[0], b1 = ref1[1];
x = intersectLineLine([m1, b1], [-1 / m1, 0]);
lengths.push(distanceFromPole([x, b1 + x * m1]));
}
return Math.min.apply(Math, lengths);
};
maxChromaForLH = function(L, H) {
var hrad, j, l, len1, lengths, line, ref;
hrad = H / 360 * Math.PI * 2;
lengths = [];
ref = getBounds(L);
for (j = 0, len1 = ref.length; j < len1; j++) {
line = ref[j];
l = lengthOfRayUntilIntersect(hrad, line);
if (l !== null) {
lengths.push(l);
}
}
return Math.min.apply(Math, lengths);
};
dotProduct = function(a, b) {
var i, j, ref, ret;
ret = 0;
for (i = j = 0, ref = a.length - 1; 0 <= ref ? j <= ref : j >= ref; i = 0 <= ref ? ++j : --j) {
ret += a[i] * b[i];
}
return ret;
};
fromLinear = function(c) {
if (c <= 0.0031308) {
return 12.92 * c;
} else {
return 1.055 * Math.pow(c, 1 / 2.4) - 0.055;
}
};
toLinear = function(c) {
var a;
a = 0.055;
if (c > 0.04045) {
return Math.pow((c + a) / (1 + a), 2.4);
} else {
return c / 12.92;
}
};
conv = {
'xyz': {},
'luv': {},
'lch': {},
'husl': {},
'huslp': {},
'rgb': {},
'hex': {}
};
conv.xyz.rgb = function(tuple) {
var B, G, R;
R = fromLinear(dotProduct(m.R, tuple));
G = fromLinear(dotProduct(m.G, tuple));
B = fromLinear(dotProduct(m.B, tuple));
return [R, G, B];
};
conv.rgb.xyz = function(tuple) {
var B, G, R, X, Y, Z, rgbl;
R = tuple[0], G = tuple[1], B = tuple[2];
rgbl = [toLinear(R), toLinear(G), toLinear(B)];
X = dotProduct(m_inv.X, rgbl);
Y = dotProduct(m_inv.Y, rgbl);
Z = dotProduct(m_inv.Z, rgbl);
return [X, Y, Z];
};
Y_to_L = function(Y) {
if (Y <= epsilon) {
return Y * kappa;
} else {
return 116 * Math.pow(Y, 1 / 3) - 16;
}
};
L_to_Y = function(L) {
if (L <= 8) {
return L / kappa;
} else {
return Math.pow((L + 16) / 116, 3);
}
};
conv.xyz.luv = function(tuple) {
var L, U, V, X, Y, Z, varU, varV;
X = tuple[0], Y = tuple[1], Z = tuple[2];
if (Y === 0) {
return [0, 0, 0];
}
L = Y_to_L(Y);
varU = (4 * X) / (X + (15 * Y) + (3 * Z));
varV = (9 * Y) / (X + (15 * Y) + (3 * Z));
U = 13 * L * (varU - refU);
V = 13 * L * (varV - refV);
return [L, U, V];
};
conv.luv.xyz = function(tuple) {
var L, U, V, X, Y, Z, varU, varV;
L = tuple[0], U = tuple[1], V = tuple[2];
if (L === 0) {
return [0, 0, 0];
}
varU = U / (13 * L) + refU;
varV = V / (13 * L) + refV;
Y = L_to_Y(L);
X = 0 - (9 * Y * varU) / ((varU - 4) * varV - varU * varV);
Z = (9 * Y - (15 * varV * Y) - (varV * X)) / (3 * varV);
return [X, Y, Z];
};
conv.luv.lch = function(tuple) {
var C, H, Hrad, L, U, V;
L = tuple[0], U = tuple[1], V = tuple[2];
C = Math.sqrt(Math.pow(U, 2) + Math.pow(V, 2));
if (C < 0.00000001) {
H = 0;
} else {
Hrad = Math.atan2(V, U);
H = Hrad * 360 / 2 / Math.PI;
if (H < 0) {
H = 360 + H;
}
}
return [L, C, H];
};
conv.lch.luv = function(tuple) {
var C, H, Hrad, L, U, V;
L = tuple[0], C = tuple[1], H = tuple[2];
Hrad = H / 360 * 2 * Math.PI;
U = Math.cos(Hrad) * C;
V = Math.sin(Hrad) * C;
return [L, U, V];
};
conv.husl.lch = function(tuple) {
var C, H, L, S, max;
H = tuple[0], S = tuple[1], L = tuple[2];
if (L > 99.9999999 || L < 0.00000001) {
C = 0;
} else {
max = maxChromaForLH(L, H);
C = max / 100 * S;
}
return [L, C, H];
};
conv.lch.husl = function(tuple) {
var C, H, L, S, max;
L = tuple[0], C = tuple[1], H = tuple[2];
if (L > 99.9999999 || L < 0.00000001) {
S = 0;
} else {
max = maxChromaForLH(L, H);
S = C / max * 100;
}
return [H, S, L];
};
conv.huslp.lch = function(tuple) {
var C, H, L, S, max;
H = tuple[0], S = tuple[1], L = tuple[2];
if (L > 99.9999999 || L < 0.00000001) {
C = 0;
} else {
max = maxSafeChromaForL(L);
C = max / 100 * S;
}
return [L, C, H];
};
conv.lch.huslp = function(tuple) {
var C, H, L, S, max;
L = tuple[0], C = tuple[1], H = tuple[2];
if (L > 99.9999999 || L < 0.00000001) {
S = 0;
} else {
max = maxSafeChromaForL(L);
S = C / max * 100;
}
return [H, S, L];
};
conv.rgb.hex = function(tuple) {
var ch, hex, j, len1;
hex = "#";
for (j = 0, len1 = tuple.length; j < len1; j++) {
ch = tuple[j];
ch = Math.round(ch * 1e6) / 1e6;
if (ch < 0 || ch > 1) {
throw new Error("Illegal rgb value: " + ch);
}
ch = Math.round(ch * 255).toString(16);
if (ch.length === 1) {
ch = "0" + ch;
}
hex += ch;
}
return hex;
};
conv.hex.rgb = function(hex) {
var b, g, j, len1, n, r, ref, results;
if (hex.charAt(0) === "#") {
hex = hex.substring(1, 7);
}
r = hex.substring(0, 2);
g = hex.substring(2, 4);
b = hex.substring(4, 6);
ref = [r, g, b];
results = [];
for (j = 0, len1 = ref.length; j < len1; j++) {
n = ref[j];
results.push(parseInt(n, 16) / 255);
}
return results;
};
conv.lch.rgb = function(tuple) {
return conv.xyz.rgb(conv.luv.xyz(conv.lch.luv(tuple)));
};
conv.rgb.lch = function(tuple) {
return conv.luv.lch(conv.xyz.luv(conv.rgb.xyz(tuple)));
};
conv.husl.rgb = function(tuple) {
return conv.lch.rgb(conv.husl.lch(tuple));
};
conv.rgb.husl = function(tuple) {
return conv.lch.husl(conv.rgb.lch(tuple));
};
conv.huslp.rgb = function(tuple) {
return conv.lch.rgb(conv.huslp.lch(tuple));
};
conv.rgb.huslp = function(tuple) {
return conv.lch.huslp(conv.rgb.lch(tuple));
};
root = {};
root.fromRGB = function(R, G, B) {
return conv.rgb.husl([R, G, B]);
};
root.fromHex = function(hex) {
return conv.rgb.husl(conv.hex.rgb(hex));
};
root.toRGB = function(H, S, L) {
return conv.husl.rgb([H, S, L]);
};
root.toHex = function(H, S, L) {
return conv.rgb.hex(conv.husl.rgb([H, S, L]));
};
root.p = {};
root.p.toRGB = function(H, S, L) {
return conv.xyz.rgb(conv.luv.xyz(conv.lch.luv(conv.huslp.lch([H, S, L]))));
};
root.p.toHex = function(H, S, L) {
return conv.rgb.hex(conv.xyz.rgb(conv.luv.xyz(conv.lch.luv(conv.huslp.lch([H, S, L])))));
};
root.p.fromRGB = function(R, G, B) {
return conv.lch.huslp(conv.luv.lch(conv.xyz.luv(conv.rgb.xyz([R, G, B]))));
};
root.p.fromHex = function(hex) {
return conv.lch.huslp(conv.luv.lch(conv.xyz.luv(conv.rgb.xyz(conv.hex.rgb(hex)))));
};
root._conv = conv;
root._getBounds = getBounds;
root._maxChromaForLH = maxChromaForLH;
root._maxSafeChromaForL = maxSafeChromaForL;
if (!((typeof module !== "undefined" && module !== null) || (typeof jQuery !== "undefined" && jQuery !== null) || (typeof requirejs !== "undefined" && requirejs !== null))) {
this.HUSL = root;
}
if (typeof module !== "undefined" && module !== null) {
module.exports = root;
}
if (typeof jQuery !== "undefined" && jQuery !== null) {
jQuery.husl = root;
}
if ((typeof requirejs !== "undefined" && requirejs !== null) && (typeof define !== "undefined" && define !== null)) {
define(root);
}
}).call(this);
},{}],18:[function(require,module,exports){
// Copyright Joyent, Inc. and other Node contributors.
//
// Permission is hereby granted, free of charge, to any person obtaining a
// copy of this software and associated documentation files (the
// "Software"), to deal in the Software without restriction, including
// without limitation the rights to use, copy, modify, merge, publish,
// distribute, sublicense, and/or sell copies of the Software, and to permit
// persons to whom the Software is furnished to do so, subject to the
// following conditions:
//
// The above copyright notice and this permission notice shall be included
// in all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
// USE OR OTHER DEALINGS IN THE SOFTWARE.
function EventEmitter() {
this._events = this._events || {};
this._maxListeners = this._maxListeners || undefined;
}
module.exports = EventEmitter;
// Backwards-compat with node 0.10.x
EventEmitter.EventEmitter = EventEmitter;
EventEmitter.prototype._events = undefined;
EventEmitter.prototype._maxListeners = undefined;
// By default EventEmitters will print a warning if more than 10 listeners are
// added to it. This is a useful default which helps finding memory leaks.
EventEmitter.defaultMaxListeners = 10;
// Obviously not all Emitters should be limited to 10. This function allows
// that to be increased. Set to zero for unlimited.
EventEmitter.prototype.setMaxListeners = function(n) {
if (!isNumber(n) || n < 0 || isNaN(n))
throw TypeError('n must be a positive number');
this._maxListeners = n;
return this;
};
EventEmitter.prototype.emit = function(type) {
var er, handler, len, args, i, listeners;
if (!this._events)
this._events = {};
// If there is no 'error' event listener then throw.
if (type === 'error') {
if (!this._events.error ||
(isObject(this._events.error) && !this._events.error.length)) {
er = arguments[1];
if (er instanceof Error) {
throw er; // Unhandled 'error' event
}
throw TypeError('Uncaught, unspecified "error" event.');
}
}
handler = this._events[type];
if (isUndefined(handler))
return false;
if (isFunction(handler)) {
switch (arguments.length) {
// fast cases
case 1:
handler.call(this);
break;
case 2:
handler.call(this, arguments[1]);
break;
case 3:
handler.call(this, arguments[1], arguments[2]);
break;
// slower
default:
args = Array.prototype.slice.call(arguments, 1);
handler.apply(this, args);
}
} else if (isObject(handler)) {
args = Array.prototype.slice.call(arguments, 1);
listeners = handler.slice();
len = listeners.length;
for (i = 0; i < len; i++)
listeners[i].apply(this, args);
}
return true;
};
EventEmitter.prototype.addListener = function(type, listener) {
var m;
if (!isFunction(listener))
throw TypeError('listener must be a function');
if (!this._events)
this._events = {};
// To avoid recursion in the case that type === "newListener"! Before
// adding it to the listeners, first emit "newListener".
if (this._events.newListener)
this.emit('newListener', type,
isFunction(listener.listener) ?
listener.listener : listener);
if (!this._events[type])
// Optimize the case of one listener. Don't need the extra array object.
this._events[type] = listener;
else if (isObject(this._events[type]))
// If we've already got an array, just append.
this._events[type].push(listener);
else
// Adding the second element, need to change to array.
this._events[type] = [this._events[type], listener];
// Check for listener leak
if (isObject(this._events[type]) && !this._events[type].warned) {
if (!isUndefined(this._maxListeners)) {
m = this._maxListeners;
} else {
m = EventEmitter.defaultMaxListeners;
}
if (m && m > 0 && this._events[type].length > m) {
this._events[type].warned = true;
console.error('(node) warning: possible EventEmitter memory ' +
'leak detected. %d listeners added. ' +
'Use emitter.setMaxListeners() to increase limit.',
this._events[type].length);
if (typeof console.trace === 'function') {
// not supported in IE 10
console.trace();
}
}
}
return this;
};
EventEmitter.prototype.on = EventEmitter.prototype.addListener;
EventEmitter.prototype.once = function(type, listener) {
if (!isFunction(listener))
throw TypeError('listener must be a function');
var fired = false;
function g() {
this.removeListener(type, g);
if (!fired) {
fired = true;
listener.apply(this, arguments);
}
}
g.listener = listener;
this.on(type, g);
return this;
};
// emits a 'removeListener' event iff the listener was removed
EventEmitter.prototype.removeListener = function(type, listener) {
var list, position, length, i;
if (!isFunction(listener))
throw TypeError('listener must be a function');
if (!this._events || !this._events[type])
return this;
list = this._events[type];
length = list.length;
position = -1;
if (list === listener ||
(isFunction(list.listener) && list.listener === listener)) {
delete this._events[type];
if (this._events.removeListener)
this.emit('removeListener', type, listener);
} else if (isObject(list)) {
for (i = length; i-- > 0;) {
if (list[i] === listener ||
(list[i].listener && list[i].listener === listener)) {
position = i;
break;
}
}
if (position < 0)
return this;
if (list.length === 1) {
list.length = 0;
delete this._events[type];
} else {
list.splice(position, 1);
}
if (this._events.removeListener)
this.emit('removeListener', type, listener);
}
return this;
};
EventEmitter.prototype.removeAllListeners = function(type) {
var key, listeners;
if (!this._events)
return this;
// not listening for removeListener, no need to emit
if (!this._events.removeListener) {
if (arguments.length === 0)
this._events = {};
else if (this._events[type])
delete this._events[type];
return this;
}
// emit removeListener for all listeners on all events
if (arguments.length === 0) {
for (key in this._events) {
if (key === 'removeListener') continue;
this.removeAllListeners(key);
}
this.removeAllListeners('removeListener');
this._events = {};
return this;
}
listeners = this._events[type];
if (isFunction(listeners)) {
this.removeListener(type, listeners);
} else if (listeners) {
// LIFO order
while (listeners.length)
this.removeListener(type, listeners[listeners.length - 1]);
}
delete this._events[type];
return this;
};
EventEmitter.prototype.listeners = function(type) {
var ret;
if (!this._events || !this._events[type])
ret = [];
else if (isFunction(this._events[type]))
ret = [this._events[type]];
else
ret = this._events[type].slice();
return ret;
};
EventEmitter.prototype.listenerCount = function(type) {
if (this._events) {
var evlistener = this._events[type];
if (isFunction(evlistener))
return 1;
else if (evlistener)
return evlistener.length;
}
return 0;
};
EventEmitter.listenerCount = function(emitter, type) {
return emitter.listenerCount(type);
};
function isFunction(arg) {
return typeof arg === 'function';
}
function isNumber(arg) {
return typeof arg === 'number';
}
function isObject(arg) {
return typeof arg === 'object' && arg !== null;
}
function isUndefined(arg) {
return arg === void 0;
}
},{}]},{},[10]);