Version 1.6 - important fix for high memory usage

api/websockets/app.ts

@@ -1,96 +0,0 @@
-import { App } from 'uWebSockets.js';
-import * as Login from './login';
-const config = require("./config.json");
-
-let Sessions = new Set();
-let Clients = {};
-let QuickLogin = {};
-
-App({
-    // options for ssl
-    key_file_name: 'key.pem',
-    cert_file_name: 'cert.pem'
-}).ws('/*', {
-    compression: 0,
-    maxPayloadLength: 64 * 1024,
-    idleTimeout: 10,
-    open: (ws, req) => {
-        ws.uid = null;
-        Sessions.add(ws);        
-    },
-    close: (ws, code, message) => {
-        if (ws.uid && Clients[ws.uid] == ws) {
-            delete Clients[ws.uid];
-            delete QuickLogin[ws.short_code];
-            delete QuickLogin[ws.full_code];
-        }
-        Sessions.delete(ws);
-    },
-    message: (ws, message, isBinary) => {
-        try {
-            let data = JSON.parse(String.fromCharCode.apply(null, new Uint8Array(message)));
-            if (data["type"] == "init") {
-                if (ws.uid || typeof (data["uid"]) != "string" || data["uid"].length < 10) {
-                    return ws.end(1, "Invalid init message"); // already has an uid or uid is invalid
-                }
-                ws.uid = data["uid"];
-                ws.version = data["version"]
-                if (Clients[ws.uid]) {
-                    Clients[ws.uid].close();
-                }
-                ws.short_code = "XXXX";
-                ws.full_code = "Login on server otclient.ovh. XXXX";
-                Clients[ws.uid] = ws;
-                QuickLogin[ws.short_code] = ws;
-                QuickLogin[ws.full_code] = ws;
-                return ws.send(JSON.stringify({
-                    "type": "quick_login",
-                    "code": ws.short_code,
-                    "qrcode": ws.full_code,
-                    "message": ""
-                }));
-            }
-            if (!ws.uid) {
-                return ws.end(2, "Missing uid");
-            }
-            if (data["type"] == "login") {
-                return Login.login(ws, data["account"], data["password"]);
-            }
-        } catch (e) {
-            try {
-                return ws.end(3, "Exception");
-            } catch (e) {}
-        }
-    }
-}).any('/login', (res, req) => {
-    let buffer: string = "";
-    res.onData((chunk, last) => {
-        try {
-            buffer += String.fromCharCode.apply(null, new Uint8Array(chunk));
-            if (!last) {
-                return;
-            }
-            const data = JSON.parse(buffer);
-            const code = data["code"];
-            const client = QuickLogin[code];
-            if (!client) {
-                return res.end("Invalid code");
-            }
-            Login.quickLogin(res, client, data);
-        } catch (e) {
-            res.end("Exception");
-        }
-    });
-
-    res.onAborted(() => {
-        return res.end("Aborted");
-    });
-}).any('/*', (res, req) => {
-    res.end('404');
-}).listen(config.port, (listenSocket) => {
-    if (listenSocket) {
-        console.log(`Listening to port ${config.port}`);
-    } else {
-        console.log(`Error, can't listen on port ${config.port}`)
-    }
-});

api/websockets/config.json

@@ -1,36 +0,0 @@
-{
-  "port": 88,
-  "sql": {
-    "host": "otclient.ovh",
-    "user": "otclient",
-    "password": "otclient",
-    "database": "otclient"
-  },
-  "maxLogins": 10,
-  "blockTime": 60,
-  "hash": "sha1",
-  "serverName": "OTClientV8",
-  "serverIP": "otclient.ovh",
-  "serverPort": 7172,
-  "version": 1099,
-  "things": {
-    "sprites": [ "1099/Tibia.spr", "63d38646597649a55a8be463d6c0fb49" ],
-    "data": [ "1099/Tibia.dat", "ae7157cfff42f14583d6363e77044df7" ]
-  },
-  "customProtocol": null,
-  "options": {
-    "allowFullView": true
-  },
-  "features": {
-    "22": true,
-    "25": true,
-    "30": true,
-    "80": true,
-    "90": true,
-    "95": true
-  },
-  "proxies": {
-
-  },
-  "rsa": "109120132967399429278860960508995541528237502902798129123468757937266291492576446330739696001110603907230888610072655818825358503429057592827629436413108566029093628212635953836686562675849720620786279431090218017681061521755056710823876476444260558147179707119674283982419152118103759076030616683978566631413"
-}

api/websockets/login.ts

@@ -1,84 +0,0 @@
-import { HttpResponse, WebSocket } from 'uWebSockets.js';
-import * as mysql from 'mysql2/promise';
-import * as crypto from 'crypto';
-const config = require("./config.json");
-
-function hash(algorithm: string, data: string): string {
-    return crypto.createHash(algorithm).update(data).digest("hex");
-}
-
-function time(): number {
-    return new Date().getTime();
-}
-
-export async function login(ws: WebSocket, login: string, password: string) {
-    let sql : mysql.Connection = null;
-    try {
-        sql = await mysql.createConnection({
-            host: config.sql.host,
-            user: config.sql.user,
-            password: config.sql.password,
-            database: config.sql.database
-        });
-
-        let hash_password = password
-        if (config.hash == "md5") {
-            hash_password = hash("md5", password);
-        } else if (config.hash == "sha1") {
-            hash_password = hash("sha1", password);
-        }
-
-        const [accounts, accountFields] = await sql.execute('SELECT * FROM `accounts` where `name` = ? and `password` = ?', [login, hash_password]);
-        if (accounts.length != 1) {
-            await sql.end();
-            return ws.send(JSON.stringify({"type": "login", "error": "Invalid account/password"}), false);
-        }
-        const account = accounts[0];
-        const [players, playersFields] = await sql.execute('SELECT * FROM `players` where `account_id` = ?', [account.id]);
-        await sql.end(); 
-
-        let response = {
-            "type": "login",
-            "error": "",
-            "rsa": config.rsa,
-            "version": config.version,
-            "things": config.things,
-            "customProtocol": config.customProtocol,
-            "session": "",
-            "characters": [],
-            "account": {},
-            "options": config.options,
-            "features": config.features,
-            "proxies": config.proxies
-        }
-
-        response["session"] = `${login}\n${password}\n\n${time()}`;
-
-        response["account"]["status"] = 0; // 0=ok, 1=frozen, 2=supsended
-        response["account"]["subStatus"] = 1; // 0=free, 1=premium
-        response["account"]["premDays"] = 65535;
-
-        for (let i = 0; i < players.length; ++i) {
-            response.characters.push({
-                "name": players[i].name,
-                "worldName": config.serverName,
-                "worldIp": config.serverIP,
-                "worldPort": config.serverPort
-            })
-        }
-
-        console.log(response);
-        ws.send(JSON.stringify(response), false);
-    } catch (e) {
-        try {
-            await sql.end()
-        } catch (e) { };
-        try {
-            ws.end(5, "Login exception");
-        } catch (e) { };
-    }
-}
-
-export async function quickLogin(res : HttpResponse, ws: WebSocket, data: any) {
-
-}

api/websockets/package.json

@@ -1,22 +0,0 @@
-{
-  "name": "otcv8socks",
-  "version": "1.0.0",
-  "description": "Websockets server for otclientv8",
-  "main": "app.js",
-  "author": {
-    "name": ""
-  },
-  "scripts": {
-    "build": "tsc --build",
-    "clean": "tsc --build --clean"
-  },
-  "devDependencies": {
-    "@types/mysql2": "github:types/mysql2",
-    "@types/node": "^8.0.14",
-    "typescript": "^3.2.2"
-  },
-  "dependencies": {
-    "mysql2": "^2.0.1",
-    "uWebSockets.js": "github:uNetworking/uWebSockets.js#v16.4.0"
-  }
-}

api/websockets/tsconfig.json

@@ -1,11 +0,0 @@
-{
-  "compilerOptions": {
-    "module": "commonjs",
-    "target": "es6",
-    "lib": ["es6"],
-    "sourceMap": true
-  },
-  "exclude": [
-    "node_modules"
-  ]
-}

api/websockets/typings.json

@@ -1,5 +0,0 @@
-{
-  "dependencies": {
-    "mysql2": "registry:npm/mysql2#1.1.1+20170314181009"
-  }
-}