mirror of
https://github.com/urbit/shrub.git
synced 2024-12-13 16:03:36 +03:00
05ceafbb2b
Selecting previous messages' audiences would result in ~~him/foo messages, which would promptly be rejected by the server.
2997 lines
84 KiB
JavaScript
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, ref1, ship;
|
|
ship = (ref1 = this.props.ship) != null ? ref1 : "";
|
|
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]);
|