Compare commits

...

7 Commits

Author SHA1 Message Date
85190a0ce3 WIP refactoring 2019-07-27 18:20:42 -04:00
6da52f2770 lots of refactoring
backend
- join channels on frontend
- broadcast 'user connected'
- emit 'user joined', 'user left', 'changed nick', 'user disconnected'

frontend
- handleSubmit > submitMessage
- formatMessage()
- chats on state with channels and private chats
- announce 'user connected', 'user joined', 'user left', 'changed nick'
- no longer emit 'chat'
- show nick in message window instead of socketId
2019-07-27 18:43:05 +01:00
data
0630f346b5 add part and nick commands, store users as objects 2019-07-26 20:14:46 +01:00
data
100d45afdc add /nick command 2019-07-26 13:49:47 +01:00
data
9fd8ac7969 create private namespaces 2019-07-26 12:58:44 +01:00
data
1e62608188 color chat on unread messages 2019-07-25 20:02:47 +01:00
a2e7396e56 added findUnreadMessages and readMessages 2019-07-25 14:13:23 -04:00
7 changed files with 510 additions and 176 deletions

View File

@ -1,30 +1,48 @@
const users = {}
module.exports = io => { module.exports = io => {
io.on('connection', async socket => { io.on('connection', async socket => {
console.log(`A socket connection to the server has been made: ${socket.id}`) console.log(`A socket connection to the server has been made: ${socket.id}`)
socket.join('#projex', () => { users[socket.id] = { socketId: socket.id, nick: socket.id }
sendUsers()
sendNamespaces() // announce to all
}) socket.broadcast.emit('user connected', users[socket.id])
// send all users TODO remove
socket.emit(
'got users',
Object.keys(io.sockets.sockets).map(socketId => users[socketId])
)
socket.on('message', message => { socket.on('message', message => {
console.log('sending message to namespace', message.namespace, message) console.log('sending message to ', message.to, message)
io.to(message.namespace).emit('message', message) io.to(message.to).emit('message', message)
}) })
socket.on('get users', () => { socket.on('join', room => {
console.log('get users') console.log(`${socket.id} joins ${room}`)
sendUsers() socket.join(room, () => {
io.to(room).emit('user joined', { room, socketId: socket.id })
io.of(room).clients((error, clients) => {
if (error) throw error
socket.emit('got client list', clients)
})
})
})
socket.on('get all clients', () => {
io.clients((e, c) => {
if (e) console.log(e)
console.log('all clients:', c)
})
})
socket.on('part', namespace => {
console.log('part', socket.id, namespace)
io.to(namespace).emit('user left', { namespace, socketId: socket.id })
socket.leave(namespace)
}) })
socket.on('join', namespace => { socket.on('change nick', nick => {
console.log('join:', namespace) io.emit('changed nick', { socketId: socket.id, nick: nick })
socket.join(namespace, () => { users[socket.id]['nick'] = nick
sendNamespaces()
})
})
socket.on('part', () => {
console.log('part')
}) })
socket.on('get namespaces', () => sendNamespaces()) socket.on('get namespaces', () => sendNamespaces())
@ -37,14 +55,10 @@ module.exports = io => {
io.emit('got namespaces', namespaces) io.emit('got namespaces', namespaces)
} }
const sendUsers = () =>
socket.emit('got users', Object.keys(io.sockets.sockets))
socket.on('disconnect', async () => { socket.on('disconnect', async () => {
io.emit('user disconnected', { socketId: socket.id }) io.emit('user disconnected', socket.id)
console.log(`${socket.id} has disconnected.`) console.log(`${socket.id} has disconnected.`)
sendNamespaces() //sendNamespaces()
sendUsers()
}) })
}) })
} }

View File

@ -1,18 +1,16 @@
import React from 'react' import React from 'react'
import socket from './socket' import socket from './socket'
import { Topbar, Sidebar, Messages } from './components'
import { Navbar, Nav, Dropdown, Button } from 'react-bootstrap'
import uuid from 'uuid' import uuid from 'uuid'
import moment from 'moment' import moment from 'moment'
const initialState = { const initialState = {
loading: true, loading: true,
messages: [], allSockets: [],
message: '', allMessages: [],
namespaces: [], buffers: [],
namespace: '/', buffer: '/',
allUsers: [],
user: {},
} }
class App extends React.Component { class App extends React.Component {
@ -20,9 +18,13 @@ class App extends React.Component {
super() super()
this.state = initialState this.state = initialState
this.socket = socket this.socket = socket
this.handleChange = this.handleChange.bind(this) this.submitMessage = this.submitMessage.bind(this)
this.handleSubmit = this.handleSubmit.bind(this)
this.join = this.join.bind(this) this.join = this.join.bind(this)
this.readMessages = this.readMessages.bind(this)
this.countUnreadMessages = this.countUnreadMessages.bind(this)
this.readMessages = this.readMessages.bind(this)
this.activateChat = this.activateChat.bind(this)
this.query = this.query.bind(this)
} }
async fetchData() { async fetchData() {
@ -32,22 +34,148 @@ class App extends React.Component {
componentDidMount() { componentDidMount() {
this.fetchData() this.fetchData()
this.socket.on('connect', () => { this.socket.on('connect', () => {
console.log('connected!') console.log(`I am ${this.socket.id}`)
const user = { socketId: this.socket.id } this.join('#projex')
this.setState({ user }) this.socket.nick = this.socket.id
}) })
this.socket.on('user connected', payload => { this.socket.on('user connected', user => {
console.log('a new user connected!', payload) console.log(`${user.nick} connected.`)
const allUsers = this.state.allUsers.concat(user)
this.setState({ allUsers })
}) })
this.socket.on('user disconnected', payload => { this.socket.on('user disconnected', socketId => {
console.log('a user disconnected.', payload) console.log(`${socketId} disconnected.`)
// const allUsers = this.state.allUsers.map(u => {
// if (u.socketId === socketId) u.offline = true
// return u
// })
// const oldNick = allUsers.find(u => u.socketId === socketId).nick
// this.setState({ allUsers })
// // inform channels user was part of
// this.state.chats.map(c => {
// if (c === socketId) {
// const messages = this.state.messages.concat(
// this.formatMessage(
// `${oldNick} disconnected`,
// socketId,
// '[server]',
// c,
// c === this.state.namespace ? true : false
// )
// )
// this.setState({ messages })
// }
// this.state.allNamespaces.map(n => {
// if (n.namespace === c && n.sockets.find(s => s === socketId)) {
// const messages = this.state.messages.concat(
// this.formatMessage(
// `${oldNick} disconnected`,
// socketId,
// '[server]',
// c,
// c === this.state.namespace ? true : false
// )
// )
// this.setState({ messages })
// }
// return n
// })
// return c
// })
}) })
this.socket.on('got namespaces', namespaces => { this.socket.on('user joined', data => {
console.log('got namespaces:', namespaces) console.log(data)
this.setState({ namespaces }) // const { namespace, socketId } = data
// const user = this.state.allUsers.find(u => u.socketId === socketId)
// console.log(`${user.nick} joined ${namespace}`)
// const messages = this.state.messages.concat(
// this.formatMessage(
// `${user.nick} joined ${namespace}`,
// socketId,
// '[server]',
// namespace,
// namespace === this.state.namespace ? true : false
// )
// )
// this.setState({ messages })
})
this.socket.on('user left', data => {
console.log(data)
// const { namespace, socketId } = data
// const user = this.state.allUsers.find(u => u.socketId === socketId)
// console.log(`${user.nick} left ${namespace}`)
// const messages = this.state.messages.concat(
// this.formatMessage(
// `${user.nick} left ${namespace}`,
// socketId,
// '[server]',
// namespace,
// namespace === this.state.namespace ? true : false
// )
// )
// this.setState({ messages })
})
this.socket.on('changed nick', user => {
console.log(user)
// if (user.socketId === this.state.user.socketId) return
// console.log(`${user.socketId} is now known as ${user.nick}.`)
// const allUsers = this.state.allUsers
// const oldNick = allUsers.find(u => u.socketId === user.socketId).nick
// // inform channels user is part of
// this.state.chats.map(c => {
// if (c === user.socketId) {
// const messages = this.state.messages.concat(
// this.formatMessage(
// `${oldNick} is now known as ${user.nick}`,
// user.socketId,
// '[server]',
// c,
// c === this.state.namespace ? true : false
// )
// )
// this.setState({ messages })
// }
// this.state.allNamespaces.map(n => {
// if (n.namespace === c && n.sockets.find(s => s === user.socketId)) {
// const messages = this.state.messages.concat(
// this.formatMessage(
// `${oldNick} is now known as ${user.nick}`,
// user.socketId,
// '[server]',
// c,
// c === this.state.namespace ? true : false
// )
// )
// this.setState({ messages })
// }
// return n
// })
// return c
// })
// // update nick
// allUsers.map(u => {
// if (u.socketId === user.socketId) u.nick = user.nick
// return u
// })
// this.setState({ allUsers })
})
this.socket.on('got namespace', namespace => {
console.log('got namespace:', namespace)
const allNamespaces = this.state.allNamespaces
.filter(n => n.namespace !== namespace.namespace)
.concat(namespace)
this.setState({ allNamespaces })
})
this.socket.on('got namespaces', allNamespaces => {
console.log('got namespaces:', allNamespaces)
this.setState({ allNamespaces })
}) })
this.socket.on('got users', allUsers => { this.socket.on('got users', allUsers => {
@ -56,36 +184,72 @@ class App extends React.Component {
}) })
this.socket.on('message', msg => { this.socket.on('message', msg => {
if (
msg.to === this.state.user.socketId &&
!this.state.chats.find(c => c === msg.from)
) {
console.log(`${msg.from} wants to chat with me.`)
const chats = this.state.chats.concat(msg.from)
this.setState({ chats })
}
if (
(msg.to[0] === '#' && msg.to === this.state.namespace) ||
(msg.to[0] !== '#' && msg.from === this.state.namespace)
)
msg.read = true
const messages = this.state.messages.concat(msg) const messages = this.state.messages.concat(msg)
console.log(msg)
this.setState({ messages }) this.setState({ messages })
}) })
} }
handleChange(e) {
this.setState({ [e.target.name]: e.target.value })
}
parseCommand() { parseCommand() {
const args = this.state.message.split(' ') const args = this.state.message.split(' ')
const cmd = args[0].slice(1) const cmd = args[0].slice(1)
console.log('command:', cmd) if (cmd === 'join') {
if (cmd === 'join') this.join(args[1]) if (!args[1]) {
alert('did you forget a channel to join?')
return
}
this.join(args[1])
} else if (cmd === 'part' || cmd === 'leave') {
this.part(args[1] ? args[1] : this.state.namespace)
} else if (cmd === 'nick') this.nick(args[1])
else {
alert(`unknown command: ${cmd}`)
}
this.setState({ message: '' }) this.setState({ message: '' })
} }
handleSubmit(e) { formatMessage(text, from, nick, to, read) {
e.preventDefault() if (!text || !from || !to || !nick) {
console.log(
if (this.state.message[0] === '/') return this.parseCommand() '[formatMessage] Dropping malformed message (requiring text, from, nick and to).'
)
}
const message = { const message = {
id: uuid(), id: uuid(),
date: moment().format('MMMM D YYYY, h:mm a'), date: moment().format('MMMM D YYYY, h:mm a'),
socketId: this.socket.id, text: text,
text: this.state.message, from: from,
namespace: this.state.namespace, nick: nick,
to: to,
read: read,
} }
return message
}
submitMessage(msg) {
console.log(msg)
if (msg[0] === '/') return this.parseCommand()
if (!msg.length > 0) return
this.sendMessage(message) this.sendMessage(
this.formatMessage(
msg,
this.state.user.socketId,
this.state.user.nick,
this.state.namespace
)
)
this.setState({ message: '' }) this.setState({ message: '' })
} }
renderLoading() { renderLoading() {
@ -95,136 +259,94 @@ class App extends React.Component {
renderError() { renderError() {
return <div>something went wrong.</div> return <div>something went wrong.</div>
} }
join(namespace) { join(room) {
if (namespace.slice(0, 1) !== '#') return alert('Use a leading #, silly!') if (room[0] !== '#') return alert('Use a leading #, silly!')
console.log('joining', namespace) if (this.state.chats.find(c => c === room)) return
this.socket.emit('join', namespace) console.log('joining', room)
this.setState({ namespace }) const chats = this.state.chats.concat(room)
this.socket.emit('join', room, ack => console.log('ack', ack))
this.setState({ room, chats })
}
part(namespace) {
console.log(`leaving ${namespace}`)
socket.emit('part', namespace)
const chats = this.state.chats.filter(c => c !== namespace)
this.setState({ chats, namespace: '/' })
}
nick(nick) {
if (nick[0] === '#') {
alert('nick cannot start with #, sorry!')
return
}
console.log(`Changing nick to ${nick}`)
const user = this.state.user
user.nick = nick
this.setState({ user })
this.socket.emit('change nick', nick)
}
query(user) {
if (this.state.chats.find(c => c === user.socketId)) {
this.setState({ namespace: user.socketId })
return
}
console.log(`starting chat with ${user.nick}`)
const chats = this.state.chats.concat(user.socketId)
this.setState({ namespace: user.socketId, chats })
} }
sendMessage(msg) { sendMessage(msg) {
this.socket.emit('message', msg) this.socket.emit('message', msg)
if (msg.to[0] !== '#') {
if (msg.to === this.state.namespace) msg.read = true
const messages = this.state.messages.concat(msg)
this.setState({ messages })
}
}
countUnreadMessages(nsp) {
return this.state.messages.filter(
m =>
!m.read &&
(m.to === nsp || (m.to === this.state.user.socketId && m.from === nsp))
).length
}
readMessages(nsp) {
const messages = this.state.messages
messages.map(m => {
if (!m.read && (m.to === nsp || m.from === nsp)) {
m.read = true
}
return m
})
this.setState({ messages })
}
activateChat(namespace) {
this.readMessages(namespace)
this.setState({ namespace })
} }
renderApp() { renderApp() {
const title = const title =
this.state.namespace[0] === '#' this.state.namespace[0] === '#'
? 'Channel' ? 'Channel'
: this.state.namespace[0] === '/' : this.state.namespace === this.state.user.socketId
? 'server messages' ? 'Namespace'
: 'User' : 'Chat with'
console.log(this.socket)
return ( return (
<main role="main" className="d-flex h-100 flex-column"> <main role="main" className="d-flex h-100 flex-column">
{/*Navbar*/} <Topbar query={this.query} join={this.join} {...this.state} />
<Navbar bg="dark" variant="dark" expand="lg">
<Navbar.Toggle aria-controls="basic-navbar-nav" />
<Navbar.Collapse id="basic-navbar-nav">
<Nav className="ml-auto mr-3">
<Dropdown>
<Dropdown.Toggle variant="dark" id="dropdown-basic">
Users
</Dropdown.Toggle>
<Dropdown.Menu className="bg-dark">
{this.state.allUsers.map(u => (
<Dropdown.Item key={u} className="bg-dark text-light">
{u}
</Dropdown.Item>
))}
</Dropdown.Menu>
</Dropdown>
<Dropdown>
<Dropdown.Toggle variant="dark" id="dropdown-basic">
Channels
</Dropdown.Toggle>
<Dropdown.Menu className="bg-dark">
{this.state.namespaces.map(r => (
<Dropdown.Item
key={r.namespace}
className="bg-dark text-light"
onClick={() => this.join(r.namespace)}
>
{r.namespace}
</Dropdown.Item>
))}
</Dropdown.Menu>
</Dropdown>
</Nav>
</Navbar.Collapse>
</Navbar>
<div className="d-flex h-100"> <div className="d-flex h-100">
{/*Side Bar 2*/} <Sidebar
<div activateChat={this.activateChat}
className="d-flex flex-column col-sm-2 bg-dark text-light p-2" countUnreadMessages={this.countUnreadMessages}
id="sidebar2" {...this.state}
> />
<h5 className=" border-bottom pb-2">User Channels</h5> <Messages
title={title}
<Button submitMessage={this.submitMessage}
key="/" {...this.state}
className="btn btn-dark d-flex"
onClick={() => this.setState({ namespace: '/' })}
>
<div className="mr-auto">server</div>
{/*<div className="ml-auto">{this.state.allUsers.length}</div>*/}
</Button>
{this.state.namespaces
.filter(
r =>
r.namespace[0] === '#' &&
r.sockets.includes(this.state.user.socketId)
)
.map(r => (
<Button
key={r.namespace}
className="btn btn-dark d-flex"
onClick={() => this.setState({ namespace: r.namespace })}
>
<div className="mr-auto">{r.namespace}</div>
<div className="ml-auto">{r.sockets.length}</div>
</Button>
))}
</div>
{/*Main Section*/}
<div className="bg-secondary d-flex flex-column flex-grow-1 px-2 pb-4">
{/*Main Section Header*/}
<div className="d-flex justify-content-between flex-wrap flex-md-nowrap pt-3 pb-2 mb-3 border-bottom">
<h4 className="mr-auto ml-3">
{title}: {this.state.namespace}
</h4>
</div>
{/*Main Section Content*/}
<div className="d-flex flex-column border border-secondary flex-grow-1">
<div className="bg-dark flex-grow-1 p-2 text-light">
{this.state.messages
.filter(m => m.namespace === this.state.namespace)
.map(m => (
<div className="d-flex justify-content-between" key={m.id}>
<div>{m.date}</div>
<div>{m.socketId}</div>
<div>{m.text}</div>
</div>
))}
</div>
<form onSubmit={this.handleSubmit}>
<input
className="bg-light p-2 w-100"
name="message"
value={this.state.message}
placeholder="Enter message"
onChange={this.handleChange}
/> />
<Button
className="btn btn-dark"
type="submit"
onSubmit={this.handleSubmit}
>
submit
</Button>
</form>
</div>
</div>
</div> </div>
</main> </main>
) )

View File

@ -0,0 +1,42 @@
import React from 'react'
import { Button } from 'react-bootstrap'
class MessageEntryForm extends React.Component {
constructor() {
super()
this.state = { message: '' }
this.handleChange = this.handleChange.bind(this)
this.handleSubmit = this.handleSubmit.bind(this)
}
handleChange(e) {
this.setState({ [e.target.name]: e.target.value })
}
handleSubmit(e) {
e.preventDefault()
this.props.submitMessage(this.state.message)
}
render() {
return (
<form onSubmit={this.handleSubmit}>
<input
className="bg-light p-2 w-100"
name="message"
value={this.state.message}
placeholder="Enter message"
onChange={this.handleChange}
/>
<Button
className="btn btn-dark"
type="submit"
onSubmit={this.handleSubmit}
>
submit as {this.props.user.nick}
</Button>
</form>
)
}
}
export default MessageEntryForm

View File

@ -0,0 +1,37 @@
import React from 'react'
import MessageEntryForm from './MessageEntryForm'
const Messages = props => {
const { title, namespace, messages, user, submitMessage } = props
return (
<div className="bg-secondary d-flex flex-column flex-grow-1 px-2 pb-4">
{/*Main Section Header*/}
<div className="d-flex justify-content-between flex-wrap flex-md-nowrap pt-3 pb-2 mb-3 border-bottom">
<h4 className="mr-auto ml-3">
{title} {namespace}
</h4>
</div>
{/*Main Section Content*/}
<div className="d-flex flex-column border border-secondary flex-grow-1">
<div className="bg-dark flex-grow-1 p-2 text-light">
{messages
.filter(
m =>
(m.to[0] === '#' && m.to === namespace) ||
(m.to[0] !== '#' && m.from === namespace) ||
(m.from === user.socketId && m.to === namespace)
)
.map(m => (
<div className="row d-flex justify-content-between" key={m.id}>
<div className="col">{m.date}</div>
<div className="col">{m.nick}</div>
<div>{m.text}</div>
</div>
))}
</div>
<MessageEntryForm submitMessage={submitMessage} user={user} />
</div>
</div>
)
}
export default Messages

60
src/components/Sidebar.js Normal file
View File

@ -0,0 +1,60 @@
import React from 'react'
import { Button } from 'react-bootstrap'
const Sidebar = props => {
const {
activateChat,
chats,
allUsers,
countUnreadMessages,
allNamespaces,
} = props
return (
<div
className="d-flex flex-column col-sm-2 bg-dark text-light p-2"
id="sidebar2"
>
<h5 className=" border-bottom pb-2">Chats</h5>
<Button
key="/"
className="btn btn-dark d-flex"
onClick={() => activateChat('/')}
>
<div className="mr-auto">server</div>
{/*<div className="ml-auto">{allUsers.length}</div>*/}
</Button>
{chats.map(c => (
<Button
key={c}
className="btn btn-dark d-flex"
onClick={() => activateChat(c)}
>
<div
className={`mr-auto ${
countUnreadMessages(c) > 0 ? 'text-danger' : ''
}`}
>
{c[0] === '#' || !allUsers.find(u => u.socketId === c)
? c
: allUsers.find(u => u.socketId === c)['nick']}
</div>
{countUnreadMessages(c) > 0 ? (
<div className="mr-auto badge bg-danger">
{countUnreadMessages(c)}
</div>
) : null}
{/* user count for channels */}
{c[0] === '#' &&
allNamespaces &&
allNamespaces.find(n => n.namespace === c) ? (
<div className="ml-auto">
{allNamespaces.find(n => n.namespace === c).sockets.length}
</div>
) : null}
</Button>
))}
</div>
)
}
export default Sidebar

56
src/components/Topbar.js Normal file
View File

@ -0,0 +1,56 @@
import React from 'react'
import { Navbar, Nav, Dropdown } from 'react-bootstrap'
const Topbar = props => {
const { allUsers, user, allNamespaces, query, join } = props
return (
<Navbar bg="dark" variant="dark" expand="lg">
<Navbar.Toggle aria-controls="basic-navbar-nav" />
<Navbar.Collapse id="basic-navbar-nav">
<Nav className="ml-auto mr-3">
<Dropdown>
<Dropdown.Toggle variant="dark" id="dropdown-basic">
Users
</Dropdown.Toggle>
<Dropdown.Menu className="bg-dark">
{allUsers
.filter(u => u.socketId !== user.id && u.offline !== true)
.map(u => (
<Dropdown.Item
key={u.socketId}
className="bg-dark text-light"
onClick={() => query(u)}
>
{u.nick}
</Dropdown.Item>
))}
</Dropdown.Menu>
</Dropdown>
<Dropdown>
<Dropdown.Toggle variant="dark" id="dropdown-basic">
Channels
</Dropdown.Toggle>
<Dropdown.Menu className="bg-dark">
{allNamespaces
.filter(n => n.namespace[0] === '#')
.map(r => (
<Dropdown.Item
key={r.namespace}
className="bg-dark text-light"
onClick={() => join(r.namespace)}
>
{r.namespace}
</Dropdown.Item>
))}
</Dropdown.Menu>
</Dropdown>
</Nav>
</Navbar.Collapse>
</Navbar>
)
}
export default Topbar

3
src/components/index.js Normal file
View File

@ -0,0 +1,3 @@
export { default as Messages } from './Messages'
export { default as Sidebar } from './Sidebar'
export { default as Topbar } from './Topbar'