devServer.js

require('dotenv').config()
const express = require("express")
const SocketConnection = require('./services/socket')
const { createServer } = require("http")
const { Server } = require("socket.io")
const app = express()
const cookieParser = require('cookie-parser')
const cors = require("cors")
const path = require('path')
const fs = require('fs').promises;
const fsSync = require('fs');
const httpServer = createServer(app)
let origins = { origin: process.env.SOURCE }

const socketServer = new Server(httpServer, {
  cors: {
    origin: origins, methods: ["GET", "POST"]
  }
})
module.exports = { socketServer }
SocketConnection(socketServer)
app.use(express.urlencoded({ extended: true }))
app.use(cors())
app.use(express.json())
const port = process.env.PORT || 3000
let morgan = require("morgan")
app.use(morgan("dev"))
app.use(cookieParser())
app.use(express.static("public"))
const folderPath = path.join(__dirname, '/public/media')

app.get('/getMovieList', async (req, res) => {
  let result = await readMedia(folderPath)
  return res.status(200).json({ result })
})
/**
 * 
 * @todo
 * username should be generated server side
 * make the uploads parallel
 * 
 * 
 * add authhentication
 *  add accessRights to the files
 * 
 * store messges to temporary database
 * 
 * add user activity tracking
 * 
 */
async function readMedia(folderPath) {

  try {
    const files = await fs.readdir(folderPath);

    const filesList = files.map(file => {
      return path.join(folderPath, file);
    });

    return filesList;
  } catch (err) {
    console.error('Error reading directory:', err);
    throw err;
  }
}
(async () => {
  const rootDirectory = folderPath;
  try {
    const filesList = await readMedia(rootDirectory);
    console.log('Files in the media directory:', filesList);
  } catch (err) {
    console.error('Error:', err);
  }
})();

app.post('/upload', async function (req, res) {
  const fileName = 'public/media/' + req.headers["file-name"];
  console.log(fileName)
  let dataReceived = Buffer.alloc(0);
  req.on("data", chunk => {
    dataReceived = Buffer.concat([dataReceived, chunk]);
  });

  req.on('end', () => {
    fsSync.appendFileSync(fileName, dataReceived);
    return res.status(201).json({ response: 'ok' });
  });
});


httpServer.listen(process.env.PORT, () => {
  console.log(`listening on localhost:` + process.env.PORT);
});
// const httpsServer = https.createServer(credentials, app);
// httpsServer.listen(443, () => {
// 	console.log('HTTPS Server running on port 443');
// });