const app = express();
const server = http.createServer(app);
const cb = new ChaturbateSocketServer(server);

process.on('exit', () => {
  cb.stop();
  server.close();
});

server.listen(8080, () => {
  console.log(`Listening on ${server.address().port}`);
});

const socket = io();

// username of the room to monitor 
const USERNAME = 'myusername'; 

socket.on('connect', () => {
  console.log('connected')
  // tell the backend to load this profile
  socket.emit('init', USERNAME);
});

socket.on('init', (e) => {
  console.log(`Welcome to ${e.room}'s room!`);
  console.log(`Current room subject is: ${e.subject}`);
});

socket.on('room_entry', (e) => {
  console.log(`${e.user.username} has joined the room`);
});

socket.on('room_leave', (e) => {
  console.log(`${e.user.username} has left the room`); 
});

socket.on('tip', (e) => {
  console.log(`${e.user.username} tipped ${e.amount} tokens`);   
});

socket.on('room_message', (e) => {
  console.log(`${e.user.username}: ${e.message}`);  
});

socket.on('disconnect', () => {
  console.log('disconnect')
});