app.js

require('dotenv').config();

const express    = require('express');
const http       = require('http');
const app        = express();
const server     = http.createServer(app);
const { Server } = require('socket.io');
const io         = new Server(server, {
    cors: {
        origin: process.env.ORIGIN,
        methods: ['GET', 'POST']
    }
});
const cors       = require('cors');

const search  = require('./routes/search');
const player  = require('./routes/player');
const queue   = require('./routes/queue');
const utils   = require('./utils');
const { getFirstInQueue, popQueue } = require('./utils');

app.use(cors());
app.use(express.json());

app.use((req, res, next) => {
    res.header("Access-Control-Allow-Origin", "*");
    res.header("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept");
    next();
});

app.use('/search', search);
app.use('/player', player);
app.use('/queue', queue);

io.on('connection', socket => {
    console.log('utilisateur connecté !');
});

setInterval(() => {
    utils.getPlayback().then(playback => {
        
        if(!playback) {
            io.emit('playback', {
                name: 'Pas de lecture en cours',
                artists: [
                    {
                        name: 'Cliquez sur un titre pour l\'écouter'
                    }
                ]
            });
        }

        if (playback.item.name) {
            getFirstInQueue().then(song => {
                if (song !== null) {
                    if (playback.item.name === song.name) {
                        console.log('prochaine en file détectée');
                        popQueue().then(() => {
                            io.emit('del_queue', song);
                        });
                    }
                }
            });
        }

        io.emit('playback', playback);
    });
}, 5000);

server.listen(process.env.PORT, () => {
    console.log(`Écoute sur le port ${process.env.PORT}`);
});