|
@@ -102,7 +102,6 @@ function asynchronize({s, chunkEventName="message", endEventName="close"}){
|
|
|
*/
|
|
*/
|
|
|
function broadcast(data){
|
|
function broadcast(data){
|
|
|
for (s of sockets){
|
|
for (s of sockets){
|
|
|
- console.log(data)
|
|
|
|
|
s.send(JSON.stringify(data))
|
|
s.send(JSON.stringify(data))
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -116,8 +115,10 @@ let RPC = {
|
|
|
* addMessage - saves message in history, broadcast it then returns length of history
|
|
* addMessage - saves message in history, broadcast it then returns length of history
|
|
|
*/
|
|
*/
|
|
|
addMessage({nick, message, id}){
|
|
addMessage({nick, message, id}){
|
|
|
- messages.push({nick, message, timestamp: (new Date).getTime()})
|
|
|
|
|
- broadcast({func: 'addMessage', nick, message, id})
|
|
|
|
|
|
|
+ let messageObject = {nick, message, timestamp: (new Date).getTime(), id, sent: true}
|
|
|
|
|
+ console.log(messageObject)
|
|
|
|
|
+ messages.push(messageObject)
|
|
|
|
|
+ broadcast({func: 'addMessage', ...messageObject})
|
|
|
return messages.length;
|
|
return messages.length;
|
|
|
},
|
|
},
|
|
|
|
|
|
