Skip to content
This repository has been archived by the owner on Nov 10, 2022. It is now read-only.

Commit

Permalink
feat: add composition (urlQuerySpec) update
Browse files Browse the repository at this point in the history
  • Loading branch information
severo committed Jan 16, 2020
1 parent fb948e1 commit 95bef62
Showing 1 changed file with 17 additions and 3 deletions.
20 changes: 17 additions & 3 deletions index.js
Original file line number Diff line number Diff line change
Expand Up @@ -15,11 +15,14 @@ const chat = io.on('connection', socket => {
})
})

// state
const guests = new Map()
let urlQuerySpec = {}

const setGuest = g => guests.set(g.sId, g)
const deleteGuest = id => guests.delete(id)
const getGuestsArray = () => [...guests.values()]
const timestamp = guest => {
const touch = guest => {
const t = Date.now()
setGuest({ ...guest, updatedDate: t, expirationDate: t + 1000 * 60 * 10 })
}
Expand All @@ -28,15 +31,25 @@ const onNewGuest = socket => (guest, ack) => {
guest.name = guest.name || `Guest_${Date.now()}`
guest.color = guest.color || rnd({ luminosity: 'dark' })
setGuest(guest)
timestamp(guest)
touch(guest)
emitListGuests()
ack(guest)
ack(guest, urlQuerySpec)
}
const onUpdateGuest = socket => (guest, ack) => {
// Used to update the name or the color
// For now, there is no difference with onNewGuest
onNewGuest(socket)(guest, ack)
}
const onUpdateUrlQuerySpec = socket => (newUrlQuerySpec, ack) => {
console.log('new urlQuerySpec')
const guest = guests.get(socket.id)
if (guest !== undefined) {
touch(guest)
urlQuerySpec = newUrlQuerySpec
socket.broadcast.emit('urlqueryspec', urlQuerySpec)
ack(urlQuerySpec)
}
}
const onByeBye = socket => _ => {
deleteGuest(socket.id)
emitListGuests()
Expand All @@ -55,6 +68,7 @@ const occupappBeta = io.of('/occupapp-beta').on('connection', socket => {
console.log('New occupapp user connected')
socket.on('new-guest', onNewGuest(socket))
socket.on('update-guest', onUpdateGuest(socket))
socket.on('update-urlqueryspec', onUpdateUrlQuerySpec(socket))
socket.on('bye-bye', onByeBye(socket))
})

Expand Down

0 comments on commit 95bef62

Please sign in to comment.