diff --git a/apps/chat/src/js/api.js b/apps/chat/src/js/api.js index 1d6ac9992..b13af3e77 100644 --- a/apps/chat/src/js/api.js +++ b/apps/chat/src/js/api.js @@ -39,6 +39,10 @@ class UrbitApi { this.action("chat", "chat-action", data); } + chatCommand(data) { + this.action("chat", "json", data); + } + action(appl, mark, data) { return new Promise((resolve, reject) => { window.urb.poke(ship, appl, mark, data, diff --git a/apps/chat/src/js/components/chat.js b/apps/chat/src/js/components/chat.js index e807d6d87..13ae753ed 100644 --- a/apps/chat/src/js/components/chat.js +++ b/apps/chat/src/js/components/chat.js @@ -18,9 +18,10 @@ export class ChatScreen extends Component { host: props.match.params.ship, numPeople: 0, numPages: 1, - scrollLocked: false + scrollLocked: false, }; + this.hasAskedForMessages = false; this.topMessage = {}; this.buildMessage = this.buildMessage.bind(this); this.onScroll = this.onScroll.bind(this); @@ -33,6 +34,61 @@ export class ChatScreen extends Component { } } + componentDidUpdate(prevProps, prevState) { + const { props } = this; + + if (prevProps.messages.length < props.messages.length - 300) { + this.hasAskedForMessages = false; + this.forceUpdate(); + this.topMessage = {}; + } else if (prevProps.match.params.ship !== props.match.params.ship || + prevProps.match.params.station !== props.match.params.station + ) { + this.setState({ + station: props.match.params.ship + "/" + props.match.params.station, + circle: props.match.params.station, + host: props.match.params.ship, + numPeople: 0, + scrollLocked: false + }); + + this.topMessage = {}; + this.forceUpdate(); + } + + this.updateReadNumber(); + this.updateNumPeople(); + this.updateNumMessagesLoaded(prevProps, prevState); + this.scrollToBottom(); + } + + askForMessages() { + const { props, state } = this; + let messages = props.messages; + + if (state.numPages * 50 < props.messages.length - 200 || + this.hasAskedForMessages) { + return; + } + + if (messages.length > 0) { + let end = messages[0].num; + if (end > 0) { + let start = ((end - 400) > 0) ? end - 400 : 0; + + this.hasAskedForMessages = true; + + props.api.chatCommand({ + messages: { + circle: state.station, + start, + end: end - 1 + } + }); + } + } + } + scrollToBottom() { if (!this.state.scrollLocked && this.scrollElement) { this.scrollElement.scrollIntoView({ behavior: 'smooth' }); @@ -40,14 +96,14 @@ export class ChatScreen extends Component { } onScroll(e) { - if (e.target.scrollTop === 0) { - let topMessage = this.topMessage; - + if (e.target.scrollTop === 0 + && this.state.numPages * 50 <= this.props.messages.length) { this.setState({ numPages: this.state.numPages + 1, scrollLocked: true }, () => { if (this.topMessage && this.topMessage[1]) { + this.askForMessages(); this.topMessage[1].scrollIntoView(true); } }); @@ -62,23 +118,6 @@ export class ChatScreen extends Component { } } - componentDidUpdate(prevProps, prevState) { - const { props } = this; - - if (prevProps !== props) { - this.setState({ - station: props.match.params.ship + "/" + props.match.params.station, - circle: props.match.params.station, - host: props.match.params.ship, - numPeople: 0 - }); - } - - this.updateReadNumber(); - this.updateNumPeople(); - this.updateNumMessagesLoaded(prevProps, prevState); - this.scrollToBottom(); - } updateReadNumber() { const { props, state } = this; @@ -130,13 +169,18 @@ export class ChatScreen extends Component { if (index % 50 === 0) { let pageNum = index / 50; return ( -
{ this.topMessage[pageNum] = el; }}> +
{ this.topMessage[pageNum] = el; }}>
); } else { return ( - + ); } } @@ -144,7 +188,7 @@ export class ChatScreen extends Component { render() { const { props, state } = this; - let messages = props.messages[state.station] || []; + let messages = props.messages; if (messages.length > 50 * state.numPages) { messages = messages @@ -155,7 +199,8 @@ export class ChatScreen extends Component { let peers = props.peers[state.station] || [window.ship]; return ( -
+

{state.circle}

{ + let station = + props.match.params.ship + + "/" + + props.match.params.station; + let messages = state.messages[station] || []; return ( diff --git a/apps/chat/src/js/reducers/update.js b/apps/chat/src/js/reducers/update.js index dc0d28fe3..19d4b8f2f 100644 --- a/apps/chat/src/js/reducers/update.js +++ b/apps/chat/src/js/reducers/update.js @@ -28,25 +28,31 @@ export class UpdateReducer { } } - reduceMessages(messages, state) { - if (messages) { - let station = state.messages[messages.circle]; - if (messages.circle in state.messages) { - if ( - station[station.length - 1].num === station.length - 1 && - messages.start === station.length - ) { - state.messages[messages.circle] = - state.messages[messages.circle].concat(messages.envelopes); - } else if (station.length === 0) { - state.messages[messages.circle] = messages.envelopes; + reduceMessages(msgs, state) { + if (msgs) { + + let staMsgs = state.messages[msgs.circle]; + if (msgs.circle in state.messages) { + console.log('new messages object: ', msgs); + console.log('lowest num in store: ', staMsgs[0].num); + console.log('highest num in store: ', staMsgs[staMsgs.length - 1].num); + + if (staMsgs.length > 0 && staMsgs[0].num - 1 === msgs.end) { + state.messages[msgs.circle] = msgs.envelopes.concat(staMsgs); + + } else if (staMsgs.length === 0) { + state.messages[msgs.circle] = msgs.envelopes; + } else { - console.error('%messages has indices inconsistent with localStorage'); + console.error('%messages has inconsistent indices'); + } + } else { - state.messages[messages.circle] = messages.envelopes; + state.messages[msgs.circle] = msgs.envelopes; } } + } reduceConfig(config, state) { diff --git a/apps/chat/src/js/store.js b/apps/chat/src/js/store.js index 17a1095ae..65e39f5f1 100644 --- a/apps/chat/src/js/store.js +++ b/apps/chat/src/js/store.js @@ -6,23 +6,23 @@ import { UpdateReducer } from '/reducers/update'; class Store { constructor() { - let state = localStorage.getItem('store'); + //let state = localStorage.getItem('store'); this.start = performance.now(); - if (!state) { - this.state = { - inbox: {}, - messages: {}, - configs: {}, - circles: [], - peers: {}, - local: false - }; - } else { + //if (!state) { + this.state = { + inbox: {}, + messages: {}, + configs: {}, + circles: [], + peers: {}, + local: false + }; + /* } else { this.state = JSON.parse(state); this.state.local = true; - } + }*/ this.initialReducer = new InitialReducer(); this.configReducer = new ConfigReducer(); @@ -46,7 +46,7 @@ class Store { this.end = performance.now(); console.log('performance.now(): ', this.end - this.start); - localStorage.setItem('store', JSON.stringify(this.state)); + //localStorage.setItem('store', JSON.stringify(this.state)); } } diff --git a/apps/chat/src/js/subscription.js b/apps/chat/src/js/subscription.js index 022e4fda0..30d627acf 100644 --- a/apps/chat/src/js/subscription.js +++ b/apps/chat/src/js/subscription.js @@ -15,7 +15,7 @@ export class Subscription { } initializeChat() { - if (store.state.local) { + /* if (store.state.local) { let path = []; let msg = Object.keys(store.state.messages); for (let i = 0; i < msg.length; i++) { @@ -43,16 +43,16 @@ export class Subscription { api.bind(path, 'PUT', api.authTokens.ship, 'chat', this.handleEvent.bind(this), this.handleError.bind(this)); - } else { + } else {*/ console.log('primary'); api.bind('/primary', 'PUT', api.authTokens.ship, 'chat', this.handleEvent.bind(this), this.handleError.bind(this)); - } + //} - api.bind('/updates', 'PUT', api.authTokens.ship, 'chat', +/* api.bind('/updates', 'PUT', api.authTokens.ship, 'chat', this.handleEvent.bind(this), - this.handleError.bind(this)); + this.handleError.bind(this));*/ } handleEvent(diff) { diff --git a/apps/chat/urbit/app/chat.hoon b/apps/chat/urbit/app/chat.hoon index 0872f9653..28892279f 100644 --- a/apps/chat/urbit/app/chat.hoon +++ b/apps/chat/urbit/app/chat.hoon @@ -51,7 +51,6 @@ ++ prep |= old=(unit state) ^- (quip move _this) - ~& %we-prepping ?~ old =/ inboxpat /circle/inbox/config/group =/ circlespat /circles/[(scot %p our.bol)] @@ -79,45 +78,29 @@ :: +peer-messages: subscribe to subset of messages and updates :: :: - ++ peer-primary |= wir=wire ^- (quip move _this) - =/ lisval=(list [@t @]) - %+ turn (generate-circle-indices wir) - |= [cir=circle:hall ind=@] - ^- [@t @] - [(crip (circ:en-tape:hall-json cir)) ind] - ::?~ lisval - :: :_ this - :: [ost.bol %diff %chat-initial str.sta]~ - =/ indices/(map @t @) (molt lisval) =* messages messages.str.sta =/ lisunitmov=(list (unit move)) %+ turn ~(tap by messages) |= [cir=circle:hall lis=(list envelope:hall)] ^- (unit move) - =/ pattcir/@t (crip (circ:en-tape:hall-json cir)) - =/ index (~(get by indices) pattcir) =/ envs/(unit (list envelope:hall)) (~(get by messages) cir) ?~ envs ~ - ?~ index - :- ~ - :* ost.bol - %diff - %chat-update - [%messages cir 0 (lent u.envs) u.envs] - == - =/ start/@ u.index - =/ end/@ (lent u.envs) - ?: (gte start end) - ~ + =/ length/@ (lent u.envs) + =/ start/@ + ?: (gte length 100) + (sub length 100) + 0 + =/ end/@ length + =/ offset/@ (sub end start) :- ~ :* ost.bol %diff %chat-update - [%messages cir start end (swag [start end] u.envs)] + [%messages cir start end (swag [start offset] u.envs)] == :_ this %+ weld @@ -130,17 +113,6 @@ %.y need :: -++ peer-updates - |= wir=wire - ^- (quip move _this) - [~ this] -:: -++ poke-noun - |= a=* - ^- (quip move _this) - ~& sta - [~ this] -:: :: +poke-chat: send us an action :: ++ poke-chat-action @@ -157,12 +129,38 @@ [%hall-action hac] == :: +++ poke-json + |= jon=json + ^- (quip move _this) + =/ com/(unit command:chat) (parse-chat-command jon) + ?~ com + [~ this] + =* messages messages.str.sta + =/ envs/(unit (list envelope:hall)) (~(get by messages) cir.u.com) + ?~ envs + [~ this] + ?: (gte start.u.com (lent u.envs)) + [~ this] + =/ end/@ + ?: (gte end.u.com (lent u.envs)) + (dec (lent u.envs)) + end.u.com + =/ offset (sub end start.u.com) + :_ this + %- send-chat-update + :* %messages + cir.u.com + start.u.com + end + (swag [start.u.com offset] u.envs) + == +:: :: +send-chat-update: utility func for sending updates to all our subscribers :: ++ send-chat-update |= upd=update ^- (list move) - %+ turn (prey:pubsub:userlib /updates bol) + %+ turn (prey:pubsub:userlib /primary bol) |= [=bone *] [bone %diff %chat-update upd] :: diff --git a/apps/chat/urbit/app/chat/js/index.js b/apps/chat/urbit/app/chat/js/index.js index d29111f10..ed4caf81f 100644 --- a/apps/chat/urbit/app/chat/js/index.js +++ b/apps/chat/urbit/app/chat/js/index.js @@ -45659,6 +45659,10 @@ this.action("chat", "chat-action", data); } + chatCommand(data) { + this.action("chat", "json", data); + } + action(appl, mark, data) { return new Promise((resolve, reject) => { window.urb.poke(ship, appl, mark, data, @@ -45813,25 +45817,31 @@ } } - reduceMessages(messages, state) { - if (messages) { - let station = state.messages[messages.circle]; - if (messages.circle in state.messages) { - if ( - station[station.length - 1].num === station.length - 1 && - messages.start === station.length - ) { - state.messages[messages.circle] = - state.messages[messages.circle].concat(messages.envelopes); - } else if (station.length === 0) { - state.messages[messages.circle] = messages.envelopes; + reduceMessages(msgs, state) { + if (msgs) { + + let staMsgs = state.messages[msgs.circle]; + if (msgs.circle in state.messages) { + console.log('new messages object: ', msgs); + console.log('lowest num in store: ', staMsgs[0].num); + console.log('highest num in store: ', staMsgs[staMsgs.length - 1].num); + + if (staMsgs.length > 0 && staMsgs[0].num - 1 === msgs.end) { + state.messages[msgs.circle] = msgs.envelopes.concat(staMsgs); + + } else if (staMsgs.length === 0) { + state.messages[msgs.circle] = msgs.envelopes; + } else { - console.error('%messages has indices inconsistent with localStorage'); + console.error('%messages has inconsistent indices'); + } + } else { - state.messages[messages.circle] = messages.envelopes; + state.messages[msgs.circle] = msgs.envelopes; } } + } reduceConfig(config, state) { @@ -45856,23 +45866,23 @@ class Store { constructor() { - let state = localStorage.getItem('store'); + //let state = localStorage.getItem('store'); this.start = performance.now(); - if (!state) { - this.state = { - inbox: {}, - messages: {}, - configs: {}, - circles: [], - peers: {}, - local: false - }; - } else { + //if (!state) { + this.state = { + inbox: {}, + messages: {}, + configs: {}, + circles: [], + peers: {}, + local: false + }; + /* } else { this.state = JSON.parse(state); this.state.local = true; - } + }*/ this.initialReducer = new InitialReducer(); this.configReducer = new ConfigReducer(); @@ -45896,7 +45906,7 @@ this.end = performance.now(); console.log('performance.now(): ', this.end - this.start); - localStorage.setItem('store', JSON.stringify(this.state)); + //localStorage.setItem('store', JSON.stringify(this.state)); } } @@ -51063,9 +51073,10 @@ host: props.match.params.ship, numPeople: 0, numPages: 1, - scrollLocked: false + scrollLocked: false, }; + this.hasAskedForMessages = false; this.topMessage = {}; this.buildMessage = this.buildMessage.bind(this); this.onScroll = this.onScroll.bind(this); @@ -51078,6 +51089,61 @@ } } + componentDidUpdate(prevProps, prevState) { + const { props } = this; + + if (prevProps.messages.length < props.messages.length - 300) { + this.hasAskedForMessages = false; + this.forceUpdate(); + this.topMessage = {}; + } else if (prevProps.match.params.ship !== props.match.params.ship || + prevProps.match.params.station !== props.match.params.station + ) { + this.setState({ + station: props.match.params.ship + "/" + props.match.params.station, + circle: props.match.params.station, + host: props.match.params.ship, + numPeople: 0, + scrollLocked: false + }); + + this.topMessage = {}; + this.forceUpdate(); + } + + this.updateReadNumber(); + this.updateNumPeople(); + this.updateNumMessagesLoaded(prevProps, prevState); + this.scrollToBottom(); + } + + askForMessages() { + const { props, state } = this; + let messages = props.messages; + + if (state.numPages * 50 < props.messages.length - 200 || + this.hasAskedForMessages) { + return; + } + + if (messages.length > 0) { + let end = messages[0].num; + if (end > 0) { + let start = ((end - 400) > 0) ? end - 400 : 0; + + this.hasAskedForMessages = true; + + props.api.chatCommand({ + messages: { + circle: state.station, + start, + end: end - 1 + } + }); + } + } + } + scrollToBottom() { if (!this.state.scrollLocked && this.scrollElement) { this.scrollElement.scrollIntoView({ behavior: 'smooth' }); @@ -51085,14 +51151,14 @@ } onScroll(e) { - if (e.target.scrollTop === 0) { - let topMessage = this.topMessage; - + if (e.target.scrollTop === 0 + && this.state.numPages * 50 <= this.props.messages.length) { this.setState({ numPages: this.state.numPages + 1, scrollLocked: true }, () => { if (this.topMessage && this.topMessage[1]) { + this.askForMessages(); this.topMessage[1].scrollIntoView(true); } }); @@ -51107,23 +51173,6 @@ } } - componentDidUpdate(prevProps, prevState) { - const { props } = this; - - if (prevProps !== props) { - this.setState({ - station: props.match.params.ship + "/" + props.match.params.station, - circle: props.match.params.station, - host: props.match.params.ship, - numPeople: 0 - }); - } - - this.updateReadNumber(); - this.updateNumPeople(); - this.updateNumMessagesLoaded(prevProps, prevState); - this.scrollToBottom(); - } updateReadNumber() { const { props, state } = this; @@ -51166,7 +51215,7 @@ return ( react.createElement('a', { className: "vanilla hoverline text-600 text-mono" , - href: prettyShip(msg.gam.aut)[1], __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 122}} + href: prettyShip(msg.gam.aut)[1], __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 161}} , prettyShip(`~${msg.gam.aut}`)[0] ) ); @@ -51175,13 +51224,18 @@ if (index % 50 === 0) { let pageNum = index / 50; return ( - react.createElement('div', { key: msg.gam.uid,ref: el => { this.topMessage[pageNum] = el; }, __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 133}} - , react.createElement(Message, { msg: msg.gam, details: details, __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 134}} ) + react.createElement('div', { + key: msg.gam.uid + "key" + Math.random() + "key" + msg.num, + ref: el => { this.topMessage[pageNum] = el; }, __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 172}} + , react.createElement(Message, { msg: msg.gam, details: details, __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 175}} ) ) ); } else { return ( - react.createElement(Message, { key: msg.gam.uid, msg: msg.gam, details: details, __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 139}} ) + react.createElement(Message, { + key: msg.gam.uid + Math.random(), + msg: msg.gam, + details: details, __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 180}} ) ); } } @@ -51189,7 +51243,7 @@ render() { const { props, state } = this; - let messages = props.messages[state.station] || []; + let messages = props.messages; if (messages.length > 50 * state.numPages) { messages = messages @@ -51200,26 +51254,27 @@ let peers = props.peers[state.station] || [window.ship]; return ( - react.createElement('div', { className: "h-100 w-100 overflow-hidden flex flex-column" , __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 158}} - , react.createElement('div', { className: "pl2 pt2 bb mb3" , __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 159}} - , react.createElement('h2', {__self: this, __source: {fileName: _jsxFileName$c, lineNumber: 160}}, state.circle) + react.createElement('div', { key: state.station, + className: "h-100 w-100 overflow-hidden flex flex-column" , __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 202}} + , react.createElement('div', { className: "pl2 pt2 bb mb3" , __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 204}} + , react.createElement('h2', {__self: this, __source: {fileName: _jsxFileName$c, lineNumber: 205}}, state.circle) , react.createElement(ChatTabBar, { ...props, station: state.station, - numPeers: peers.length, __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 161}} ) + numPeers: peers.length, __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 206}} ) ) , react.createElement('div', { className: "overflow-y-scroll", style: { flexGrow: 1 }, - onScroll: this.onScroll, __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 165}} + onScroll: this.onScroll, __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 210}} , chatMessages - , react.createElement('div', { ref: el => { this.scrollElement = el; }, __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 170}}) + , react.createElement('div', { ref: el => { this.scrollElement = el; }, __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 215}}) ) , react.createElement(ChatInput, { api: props.api, configs: props.configs, station: state.station, circle: state.circle, - placeholder: "Message...", __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 172}} ) + placeholder: "Message...", __self: this, __source: {fileName: _jsxFileName$c, lineNumber: 217}} ) ) ) } @@ -57724,6 +57779,11 @@ lyrtesmudnytbyrsenwegfyrmurtelreptegpecnelnevfes\ }, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 101}} ) , react.createElement(Route, { exact: true, path: "/~chat/:ship/:station", render: (props) => { + let station = + props.match.params.ship + + "/" + + props.match.params.station; + let messages = state.messages[station] || []; return ( react.createElement(Skeleton, { sidebar: @@ -57733,15 +57793,15 @@ lyrtesmudnytbyrsenwegfyrmurtelreptegpecnelnevfes\ invites: invites, unreads: unreads, api: api, - ...props, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 127}} + ...props, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 132}} ) - , __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 125}} + , __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 130}} , react.createElement(ChatScreen, { api: api, configs: configs, - messages: state.messages, + messages: messages, peers: state.peers, - ...props, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 136}} + ...props, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 141}} ) ) ); @@ -57757,17 +57817,17 @@ lyrtesmudnytbyrsenwegfyrmurtelreptegpecnelnevfes\ invites: invites, unreads: unreads, api: api, - ...props, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 151}} + ...props, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 156}} ) - , __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 149}} + , __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 154}} , react.createElement(MemberScreen, { ...props, api: api, - peers: state.peers, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 160}} + peers: state.peers, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 165}} ) ) ); - }, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 146}} ) + }, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 151}} ) , react.createElement(Route, { exact: true, path: "/~chat/:ship/:station/settings", render: (props) => { return ( @@ -57779,17 +57839,17 @@ lyrtesmudnytbyrsenwegfyrmurtelreptegpecnelnevfes\ invites: invites, unreads: unreads, api: api, - ...props, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 173}} + ...props, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 178}} ) - , __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 171}} + , __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 176}} , react.createElement(SettingsScreen, { ...props, api: api, peers: state.peers, - store: store, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 182}} ) + store: store, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 187}} ) ) ); - }, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 168}} ) + }, __self: this, __source: {fileName: _jsxFileName$h, lineNumber: 173}} ) ) ) ) @@ -57806,14 +57866,14 @@ lyrtesmudnytbyrsenwegfyrmurtelreptegpecnelnevfes\ } initializeChat() { - if (store.state.local) { + /* if (store.state.local) { let path = []; let msg = Object.keys(store.state.messages); for (let i = 0; i < msg.length; i++) { let cir = msg[i].split('/'); if (cir.length > 1) { let hos = cir[0]; - if (src.isValidPatp(hos)) { + if (urbitOb.isValidPatp(hos)) { let nom = cir[1]; let len = 0; if (msg[i] in store.state.messages) { @@ -57834,16 +57894,16 @@ lyrtesmudnytbyrsenwegfyrmurtelreptegpecnelnevfes\ api.bind(path, 'PUT', api.authTokens.ship, 'chat', this.handleEvent.bind(this), this.handleError.bind(this)); - } else { + } else {*/ console.log('primary'); api.bind('/primary', 'PUT', api.authTokens.ship, 'chat', this.handleEvent.bind(this), this.handleError.bind(this)); - } + //} - api.bind('/updates', 'PUT', api.authTokens.ship, 'chat', + /* api.bind('/updates', 'PUT', api.authTokens.ship, 'chat', this.handleEvent.bind(this), - this.handleError.bind(this)); + this.handleError.bind(this));*/ } handleEvent(diff) { diff --git a/apps/chat/urbit/lib/chat.hoon b/apps/chat/urbit/lib/chat.hoon index 10950d07e..e39d86ee2 100644 --- a/apps/chat/urbit/lib/chat.hoon +++ b/apps/chat/urbit/lib/chat.hoon @@ -1,4 +1,5 @@ /- hall +/+ hall-json |% :: +$ move [bone card] @@ -57,18 +58,21 @@ [%peers cir=circle:hall per=(set @p)] == :: -+$ action [%actions lis=(list action:hall)] - -+$ pareto-mark - $% - [%json pax=path name=@t jon=json] - [%path name=@t obj=(map @t json)] - == ++$ command [%messages cir=circle:hall start=@ud end=@ud] :: ++$ action [%actions lis=(list action:hall)] :: :: :: +utilities :: +++ parse-chat-command + =, dejs:format + =, dejs:hall-json + %- of + :~ + [%messages (ot circle+circ start+ni end+ni ~)] + == +:: +$ indices-internal-state $: lis=(list [circle:hall @]) diff --git a/apps/chat/urbit/mar/chat/action.hoon b/apps/chat/urbit/mar/chat/action.hoon index 81145b48c..db2647987 100644 --- a/apps/chat/urbit/mar/chat/action.hoon +++ b/apps/chat/urbit/mar/chat/action.hoon @@ -11,7 +11,7 @@ :: ++ grab |% - ++ noun streams:chat + ++ noun action:chat ++ json |= jon=^json =< (parse-chat-action jon) diff --git a/apps/chat/urbit/mar/chat/command.hoon b/apps/chat/urbit/mar/chat/command.hoon new file mode 100644 index 000000000..6f9a117b0 --- /dev/null +++ b/apps/chat/urbit/mar/chat/command.hoon @@ -0,0 +1,21 @@ +:: +:: +/- hall +/+ chat, hall-json +=, dejs:format +=, dejs:hall-json +:: +|_ com=command:chat +:: +++ grab + :: + |% + ++ noun command:chat + ++ json + %- of + :~ + [%messages (ot circle+circ start+ni end+ni ~)] + == + -- + :: +--