server.js

import express from 'express';
import mongoose from 'mongoose';
import bodyParser from 'body-parser';
import cors from 'cors';
import 'dotenv/config.js';
import morgan from 'morgan';

import registerRouter from './src/routes/register.js';
import loginRouter from './src/routes/login.js';
import matchRouter from './src/routes/match.js';
import chatRouter from './src/routes/chatRoutes.js';
import { sendMessage, sendMessageNC } from './src/socket/chatSocket.js';
import newsRouter from './src/routes/news.js';
import testRouter from './src/routes/test.js';

const app = express();
const port = process.env.PORT || 5000;

app.use(cors());
app.use(bodyParser.urlencoded({ extended: false }));
app.use(bodyParser.json());
app.use(morgan('dev'));

const database = process.env.DATABASE_URI;
mongoose
  .connect(database, {
    useNewUrlParser: true,
    useUnifiedTopology: true,
  })
  .then(() => console.log('MongoDB successfully connected'))
  .catch((err) => console.log(err));

app.use('/register', registerRouter);
app.use('/login', loginRouter);
app.use('/match', matchRouter);
app.use('/chat', chatRouter);
app.use('/news', newsRouter);
app.use('/', testRouter);

import { Server } from 'http';
import * as server from 'socket.io';

const http = Server(app);
const io = new server.Server(http, {
  cors: {
    origin: '*',
    methods: ['GET', 'POST'],
  },
});

// io.on("connection", function(socket) {
//   socket.on("new-operations", function(data) {
//     io.emit("new-remote-operations", data);
//   });
// });
io.on('connection', function (socket) {
  socket.on('sendMessage', (data) => {
    sendMessage(data, socket);
  });
  socket.on('sendMessageNC', (data) => {
    sendMessageNC(data, socket);
  });
});

// const server = createServer(app);
// const socketio = new io.Server(server);

// socketio.on('connection', (socket) => {
//   console.log('user connected');
//   socket.on('disconnect', () => {
//     console.log('Disconnected');
//   });
// });

// socketio.on('sendMessage', (data) => {
//   sendMessage(data, socket);
// });

// // socketio.on("deleteMessage", (data) => {
// //   deleteMessage(data, socket);
// // });

// socketio.on('chat message', function (msg) {
//   console.log('message: ' + msg);
//   //broadcast message to everyone in port:5000 except yourself.
//   socket.broadcast.emit('received', { message: msg });
// });

// server.listen(port, () => {
//   console.log(`SERVER Server is running on port: ${port}`);
// });

http.listen(port, function () {
  console.log('listening on *:5000');
});