MusareFork/backend/logic/socketHandler.js

'use strict';

module.exports = (core, io) => {

	io.on('connection', socket => {
		console.log("User has connected");
		let _user = socket.request.user;

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

		socket.on('/stations', cb => {
			core['/stations'](result => {
				cb(result);
			});
		});

		/*socket.on('/station/:id/join', (id, cb) => {
			console.log("JOINED!!!");
			core['/station/:id/join'](id, socket.id, result => {
				console.log("CALLBACK!!!");
				cb(result);
			});
		});*/

		socket.on('/youtube/getVideos/:query', (query, cb) => {
			core['/youtube/getVideos/:query'](query, result => {
				cb(result);
			});
		});

		socket.on('/songs/queue/addSongs/:songs', (songs, cb) => {
			core['/songs/queue/addSongs/:songs'](songs, _user, result => {
				cb(result);
			});
		});

		socket.on('/songs/queue/getSongs', (cb) => {
			core['/songs/queue/getSongs'](_user, result => {
				cb(result);
			});
		});

		socket.on('/songs/queue/updateSong/:id', (id, object, cb) => {
			core['/songs/queue/updateSong/:id'](_user, id, object, result => {
				cb(result);
			});
		});

		/*socket.on('/stations/search/:query', (query, cb) => {
			core['/stations/search/:query'](query, result => {
				cb(result);
			});
		});*/

		// this lets the client socket know that they can start making request
		socket.emit('ready', socket.request.user.logged_in);
	});
};