const PayloadSources = { VIEW_ACTION: "VIEW_ACTION", SERVER_ACTION: "SERVER_ACTION" }; function Dispatcher() {"use strict"; this.callbacks = []; } Dispatcher.prototype.register=function(callback) {"use strict"; this.callbacks.push(callback); }; Dispatcher.prototype.unregister=function(callback) {"use strict"; var index = this.callbacks.indexOf(f); if (index >= 0) { this.callbacks.splice(this.callbacks.indexOf(f), 1); } }; Dispatcher.prototype.dispatch=function(payload) {"use strict"; console.debug("dispatch", payload); this.callbacks.forEach(function(callback) { callback(payload); }); }; AppDispatcher = new Dispatcher(); AppDispatcher.dispatchViewAction = function(action) { action.actionSource = PayloadSources.VIEW_ACTION; this.dispatch(action); }; AppDispatcher.dispatchServerAction = function(action) { action.actionSource = PayloadSources.SERVER_ACTION; this.dispatch(action); }; var ActionTypes = { SETTINGS_UPDATE: "SETTINGS_UPDATE", EVENTLOG_ADD: "EVENTLOG_ADD" }; var SettingsActions = { update:function(settings) { settings = _.merge({}, SettingsStore.getAll(), settings); //TODO: Update server. //Facebook Flux: We do an optimistic update on the client already. AppDispatcher.dispatchViewAction({ actionType: ActionTypes.SETTINGS_UPDATE, settings: settings }); } }; function EventEmitter() {"use strict"; this.listeners = {}; } EventEmitter.prototype.emit=function(event) {"use strict"; if (!(event in this.listeners)) { return; } this.listeners[event].forEach(function(listener) { listener.apply(this, arguments); }.bind(this)); }; EventEmitter.prototype.addListener=function(event, f) {"use strict"; this.listeners[event] = this.listeners[event] || []; this.listeners[event].push(f); }; EventEmitter.prototype.removeListener=function(event, f) {"use strict"; if (!(event in this.listeners)) { return false; } var index = this.listeners[event].indexOf(f); if (index >= 0) { this.listeners[event].splice(index, 1); } }; for(var EventEmitter____Key in EventEmitter){if(EventEmitter.hasOwnProperty(EventEmitter____Key)){_SettingsStore[EventEmitter____Key]=EventEmitter[EventEmitter____Key];}}var ____SuperProtoOfEventEmitter=EventEmitter===null?null:EventEmitter.prototype;_SettingsStore.prototype=Object.create(____SuperProtoOfEventEmitter);_SettingsStore.prototype.constructor=_SettingsStore;_SettingsStore.__superConstructor__=EventEmitter; function _SettingsStore() {"use strict"; EventEmitter.call(this); //FIXME: What do we do if we haven't requested anything from the server yet? this.settings = { version: "0.12", showEventLog: true, mode: "transparent", }; } _SettingsStore.prototype.getAll=function() {"use strict"; return this.settings; }; _SettingsStore.prototype.handle=function(action) {"use strict"; switch (action.actionType) { case ActionTypes.SETTINGS_UPDATE: this.settings = action.settings; this.emit("change"); break; default: return; } }; var SettingsStore = new _SettingsStore(); AppDispatcher.register(SettingsStore.handle.bind(SettingsStore)); // // We have an EventLogView and an EventLogStore: // The basic architecture is that one can request views on the event log // from the store, which returns a view object and then deals with getting the data required for the view. // The view object is accessed by React components and distributes updates etc. // // See also: components/EventLog.react.js for(var EventEmitter____Key in EventEmitter){if(EventEmitter.hasOwnProperty(EventEmitter____Key)){EventLogView[EventEmitter____Key]=EventEmitter[EventEmitter____Key];}}var ____SuperProtoOfEventEmitter=EventEmitter===null?null:EventEmitter.prototype;EventLogView.prototype=Object.create(____SuperProtoOfEventEmitter);EventLogView.prototype.constructor=EventLogView;EventLogView.__superConstructor__=EventEmitter; function EventLogView(store, live) {"use strict"; EventEmitter.call(this); this.$EventLogView_store = store; this.live = live; this.log = []; this.add = this.add.bind(this); if (live) { this.$EventLogView_store.addListener("new_entry", this.add); } } EventLogView.prototype.close=function() {"use strict"; this.$EventLogView_store.removeListener("new_entry", this.add); }; EventLogView.prototype.getAll=function() {"use strict"; return this.log; }; EventLogView.prototype.add=function(entry) {"use strict"; this.log.push(entry); this.emit("change"); }; EventLogView.prototype.add_bulk=function(messages) {"use strict"; var log = messages; var last_id = log[log.length - 1].id; var to_add = _.filter(this.log, function(entry) {return entry.id > last_id;}); this.log = log.concat(to_add); this.emit("change"); }; for(EventEmitter____Key in EventEmitter){if(EventEmitter.hasOwnProperty(EventEmitter____Key)){_EventLogStore[EventEmitter____Key]=EventEmitter[EventEmitter____Key];}}_EventLogStore.prototype=Object.create(____SuperProtoOfEventEmitter);_EventLogStore.prototype.constructor=_EventLogStore;_EventLogStore.__superConstructor__=EventEmitter;function _EventLogStore(){"use strict";if(EventEmitter!==null){EventEmitter.apply(this,arguments);}} _EventLogStore.prototype.getView=function(since) {"use strict"; var view = new EventLogView(this, !since); //TODO: Really do bulk retrieval of last messages. window.setTimeout(function() { view.add_bulk([{ id: 1, message: "Hello World" }, { id: 2, message: "I was already transmitted as an event." }]); }, 100); var id = 2; view.add({ id: id++, message: "I was already transmitted as an event." }); view.add({ id: id++, message: "I was only transmitted as an event before the bulk was added.." }); window.setInterval(function() { view.add({ id: id++, message: "." }); }, 1000); return view; }; _EventLogStore.prototype.handle=function(action) {"use strict"; switch (action.actionType) { case ActionTypes.EVENTLOG_ADD: this.emit("new_message", action.message); break; default: return; } }; var EventLogStore = new _EventLogStore(); AppDispatcher.register(EventLogStore.handle.bind(EventLogStore)); function _Connection(root) {"use strict"; if (!root) { root = location.origin + "/api/v1"; } this.root = root; } _Connection.prototype.init=function() {"use strict"; this.openWebSocketConnection(); }; _Connection.prototype.openWebSocketConnection=function() {"use strict"; this.ws = new WebSocket(this.root.replace("http", "ws") + "/ws"); var ws = this.ws; ws.onopen = this.onopen.bind(this); ws.onmessage = this.onmessage.bind(this); ws.onerror = this.onerror.bind(this); ws.onclose = this.onclose.bind(this); }; _Connection.prototype.onopen=function(open) {"use strict"; console.log("onopen", this, arguments); }; _Connection.prototype.onmessage=function(message) {"use strict"; //AppDispatcher.dispatchServerAction(...); console.log("onmessage", this, arguments); }; _Connection.prototype.onerror=function(error) {"use strict"; console.log("onerror", this, arguments); }; _Connection.prototype.onclose=function(close) {"use strict"; console.log("onclose", this, arguments); }; var Connection = new _Connection(); /** @jsx React.DOM */ var MainMenu = React.createClass({displayName: 'MainMenu', toggleEventLog:function() { SettingsActions.update({ showEventLog: !this.props.settings.showEventLog }); }, render:function(){ return ( React.DOM.div(null, React.DOM.button({className: "btn " + (this.props.settings.showEventLog ? "btn-primary" : "btn-default"), onClick: this.toggleEventLog}, React.DOM.i({className: "fa fa-database"}), " Display Event Log" ) ) ); } }); var ToolsMenu = React.createClass({displayName: 'ToolsMenu', render:function(){ return React.DOM.div(null, "Tools Menu"); } }); var ReportsMenu = React.createClass({displayName: 'ReportsMenu', render:function(){ return React.DOM.div(null, "Reports Menu"); } }); var _Header_Entries = { main: { title: "Traffic", route: "main", menu: MainMenu }, tools: { title: "Tools", route: "main", menu: ToolsMenu }, reports: { title: "Visualization", route: "reports", menu: ReportsMenu } }; var Header = React.createClass({displayName: 'Header', getInitialState:function(){ return { active: "main" }; }, handleClick:function(active){ this.setState({active: active}); ReactRouter.transitionTo(_Header_Entries[active].route); return false; }, handleFileClick:function(){ console.log("File click"); }, render:function(){ var header = []; for(var item in _Header_Entries){ var classes = this.state.active == item ? "active" : ""; header.push(React.DOM.a({key: item, href: "#", className: classes, onClick: this.handleClick.bind(this, item)}, _Header_Entries[item].title)); } var menu = _Header_Entries[this.state.active].menu({ settings: this.props.settings }); return ( React.DOM.header(null, React.DOM.div({className: "title-bar"}, "mitmproxy ", this.props.settings.version ), React.DOM.nav(null, React.DOM.a({href: "#", className: "special", onClick: this.handleFileClick}, " File "), header ), React.DOM.div({className: "menu"}, menu ) ) ); } }); /** @jsx React.DOM */ var TrafficTable = React.createClass({displayName: 'TrafficTable', getInitialState:function() { return { flows: [] }; }, componentDidMount:function() { //this.flowStore = FlowStore.getView(); //this.flowStore.addListener("change",this.onFlowChange); }, componentWillUnmount:function() { //this.flowStore.removeListener("change",this.onFlowChange); //this.flowStore.close(); }, onFlowChange:function() { this.setState({ //flows: this.flowStore.getAll() }); }, render:function() { /*var flows = this.state.flows.map(function(flow){ return