KF-MMO-Server/index.ts

import { game } from "./game";
import { users } from "./Account/users";
import { loadItems } from "./Items/items";
import { players } from "./Player/players";
import { registerItemCallbacks } from "./Items/itemSocket";
import { registerLobbyCallbacks } from "./Lobby/lobbySocket";
import { registerAccountCallbacks } from "./Account/accountSocket";

const express = require("express");
const app = express();
const port = 3000;
const server = require('http').Server(app);

server.listen(port, () => {
  console.log(`Server listening at port ${port}`);
});

const io = require("socket.io")(server, {
	cors: {
        origin: '*',
        methods: ["GET", "POST"]
    }
});

users.loadUsers();
players.loadPlayers();
loadItems()

io.on('connection', (socket) => {
	console.log("Got connection!");
	socket.emit("connectSuccess", "");

    registerAccountCallbacks(socket);
    registerLobbyCallbacks(socket);
    registerItemCallbacks(socket);
    
    socket.io = game.socketIO = io;

    socket.on("disconnect", () => {
        socket.disconnect()
        if(socket.hasOwnProperty("user")){
            game.lobbyState.removeUser(socket.user.id)
            delete socket.user
        }
        console.log(socket.id + " disconnected");
    });

    socket.on('error',function(er){
        console.log(er);
    });
});

//Send player updates to everyone
setInterval(() => {
    let userCount = game.lobbyState.players.length
    if(userCount > 0){
        game.lobbyState.hostId = game.lobbyState.users[0].id
        io.emit('lobby', JSON.stringify(game.lobbyState.copyLight()))
    }
}, 1000/30)

setInterval(() => {
    console.log("Players: " + game.lobbyState.players.length + ", users: " + game.lobbyState.users.length);
}, 60 * 1000)

process.on('SIGINT', function () {
    console.log('Ctrl-C...');
    process.exit(2);
});
process.on('exit', function () {
    users.saveUsers();
    players.savePlayers();
    console.log("exitted");
});