Arbeiten mit NodeJS & JSON

Dr.West · 21. Oktober 2019

Hallo zusammen,

mittlerweile besitze ich eine eigene API die gewisse Daten aus meinem Forum abruft und diese als JSON Ausgabe wiedergibt. Das ganze schaut so aus.

Code

https://www.meinedomain.de/index.php?user-api&method=login&username=Meinusername&password=MeinPassword&secret=MeinSecretKey

Als Ausgabe bekomme ich folgendes.

Brainfuck

status	200
data	
userID	1
wscApiId	0
username	"Dr.West"
email	"webmaster@afd.de"
options	
userID	1
userOption1	""
userOption2	""
userOption3	1
userOption4	"0"
userOption5	""
userOption6	""
userOption7	""
userOption8	""
userOption9	""
userOption10	null
userOption11	null
userOption12	""
userOption13	""
userOption14	1
userOption15	"Europe/Berlin"
userOption16	1
userOption17	1
userOption18	"0"
userOption19	"0"
userOption20	"0"
userOption21	"3"
userOption22	"1"
userOption23	1
userOption24	"1"
userOption25	"0"
userOption26	"0"
userOption27	"0"
userOption28	"0"
userOption29	"0"
userOption30	1
userOption31	1
groups	
0	
groupID	1
groupName	"Jeder"
groupType	1
1	
groupID	3
groupName	"Registrierte Benutzer"
groupType	3
2	
groupID	4
groupName	"Administratoren"
groupType	9
3	
groupID	6
groupName	"Bürger"
groupType	4

Alles anzeigen

Das ganze würde ich gerne in meinem Script umgesetzt haben, wie aber genau muss das umgesetzt werden?

Code

mp.events.add("sendDataToServer", (player, user, pass, state) => {
    let loggedAccount = mp.players.toArray().find(p => p.loggedInAs == username);
    switch(state){
        //Account Login
        case 0:
        {
            if(loggedAccount){
                console.log("Logged in already.");
                player.call("loginHandler", ["logged"]);
            } else {
                gm.mysql.handle.query('SELECT `password` FROM `accounts` WHERE `username` = ?', [username], function(err, res){
                    if(res.length > 0){
                        let sqlPassword = res[0]["password"];
                        bcrypt.compare(pass, sqlPassword, function(err, res2) {
                            if(res2 === true){
                                player.name = username;
                                player.call("loginHandler", ["success"]);
                                gm.auth.loadAccount(player);
                            } else {
                                player.call("loginHandler", ["incorrectinfo"]);
                            }
                        });
                    } else {
                        player.call("loginHandler", ["incorrectinfo"]);
                    }
                });
            }
            break;
        }
        //Account Registration
        case 1:
        {
            if(username.length >= 3 && pass.length >= 5){
                gm.mysql.handle.query('SELECT * FROM `accounts` WHERE `username` = ?', [username], function(err, res){
                    if(res.length > 0){
                        player.call("loginHandler", ["takeninfo"]);
                    } else {
                        bcrypt.hash(pass, function(err, hash) {
                            if(!err){
                                gm.mysql.handle.query('INSERT INTO `accounts` SET username = ?, password = ?', [username, hash], function(err, res){
                                    if(!err){
                                        player.name = username;
                                        console.log("\x1b[92m" + username + "\x1b[39m has just registered.");
                                    } else {
                                        console.log("\x1b[31m[ERROR] " + err)
                                    }
                                });
                            } else {
                                console.log("\x1b[31m[BCrypt]: " + err)
                            }
                        });
                    }
                });
            } else {
                player.call("loginHandler", ["tooshort"]);
            }            
            break;
        }
        default:
        {
            player.outputChatBox("An error has occured, please contact your server administrator.")
            console.log("\x1b[31m[ERROR] Login/Register state was one that isn't defined. State: " + state)
            break;
        }
    }
});

Alles anzeigen

Meine Testfunktion scheint hier komplett falsch zu sein oder?

Code

function getTestPersonaLoginCredentials(callback) {


    return http.get({
        host: 'personatestuser.org',
        path: '/email',
        headers: { 'User-Agent': 'Projekt Reallife Agent 1.0.0' }
    }, function(response) {
        // Continuously update stream with data
        var body = '';
        response.on('data', function(d) {
            body += d;
        });
        response.on('end', function() {


            // Data reception is done, do whatever with it!
            var parsed = JSON.parse(body);
            callback({
                email: parsed.email,
                password: parsed.pass
            });
        });
    });
}

Alles anzeigen

Ich möchte halt anstelle aus der Datenbank den USer aus dem Forum abfragen und wenn der User in der Bürger gruppe ist (ID 4), dann darf er einloggen und der Server sagt ok!

LeonMrBonnie · 21. Oktober 2019

Warum verbindest du dich nicht einfach zum MySQL Server des Forums auf deinem NodeJS Server? Wenn der Gameserver vom Forum abhängig ist, sorgt das eher für Probleme. (Forum Mal down = Niemand kann sich auf dem Server einloggen)
Auch sendest du dann dort Name und Passwort des Nutzers nicht nur von Client zu Server sondern nochmal weiter übers Internet zu einem weiteren Server. Stichwort: Datensicherheit

Dr.West · 21. Oktober 2019

Meine Api bietet ein wenig mehr als nur die Login Funktion.

Brainfuck

# Documentation


* method - string (examples: create, login, get, ...)
* secret - api secret


## Users


Endpoint `https://www.example.de/index.php?user-api`


### create
Parameters
* username
* password
* email


### login
Parameters
* username
* password


### get
Parameters
* userID


### getByName
Parameters
* username


### update
Parameters
* userID
* username
* wscApiId
* userOptionXX - XX represent the id (eg 01, 02, 03)


Either username, wscApiId or userOptionXX is required. 


### notification
Parameters
* userID
* title
* message
* url


This function is currently experimental.


## Groups


Endpoint `https://www.example.de/index.php?user-group-api`


### add
Parameters
* groupID


### remove
Parameters
* groupID
* userID - number or array


### get
Parameters
* groupID
* userID - number or array

Alles anzeigen

Daher werde ich nicht mit dem MySql Server der Foren Datenbank arbeiten. Bleiben wir daher bitte bei der Frage, wie setze ich das mir JSON um? Um die Datensicherheit braucht sich keiner einen Kopf machen. Das habe ich schon im Griff.

LeonMrBonnie · 21. Oktober 2019

Du erweiterst die Funktion um 2 Parameter, Name und Passwort, dann kannst du mit diesen Variablen die URL für die Anfrage zusammensetzen. Da es eine HTTP Anfrage ist, würd es sich auch lohnen Promises zu verwenden. (Async/await) Dann kannst du das Callback weglassen. Ist aber natürlich deine Entscheidung ob du den klassischen Callbackstil von NodeJS verwendest oder es mit einer modernen Methode (Promises) machst.

Dr.West · 21. Oktober 2019

Gibt es dazu auch einen Code? Denn genau das ist dass was ich seid Stunden suche und nicht finde. Danke. Deswegen Frage ich hier ja auch.

LeonMrBonnie · 21. Oktober 2019

JavaScript

const apiHost = "https://testseite.de";
const apiSecret = "SECRET123";


function loginUser(username, password, callback)
{
    if(!username || !password || typeof callback !== "function") return console.error(`loginUser was called with invalid parameters`); // Die angegeben Parameter sind falsch
    http.get({
        host: `${apiHost}`,
        path: `/index.php?user-api&method=login&username=${username}&password=${password}&secret=${apiSecret}`, // Die Daten des Users werden in die URL geschrieben
        headers: { 'User-Agent': 'Projekt Reallife Agent 1.0.0' }
    }, (response) => {
        let status = response.statusCode;
        if(status !== 200) // Die Antwort war nicht 200, also ist irgendwas schief gelaufen
        {
            response.resume(); // Den Rest der Anfrage verarbeiten, damit kein Memory Overflow entsteht
            callback(`Request failed. Server responded with status code ${status}`);
        }
        else
        {
            let data = "";
            response.on('data', (chunk) => {
                data += chunk;
            });
            response.on('end', () => {
                let parsed = JSON.parse(data);
                callback(null, {
                    id: parsed.userID,
                    email: parsed.email,
                    groups: parsed.groups
                });
            });
        }
    });
}

Alles anzeigen

Der erste Parameter des Callbacks ist der Fehler, falls keiner vorhanden ist, ist dieser null. Der zweite Parameter sind die empfangenen Daten.
Du nutzt es also so:

JavaScript

loginUser(username, password, (error, data) => 
{
    if(error) return console.log(error); // Bei einem Error sind keine Daten vorhanden, also muss returnt werden, damit der 2. Parameter nicht verwendet wird
    // ...
});

Dr.West · 23. Oktober 2019

Hab das mal so eingebaut wie du gesagt hast, funktioniert nicht.

Java

mp.events.add("sendDataToServer", (player, username, password, state) => {
    let loggedAccount = mp.players.toArray().find(p => p.loggedInAs == username);
    switch(state){
        //Account Login
        case 0:
        {
            if(loggedAccount){
                console.log("Logged in already.");
                player.call("loginHandler", ["logged"]);
            } else {

				function loginUser(username, password, callback)
				{
					if(!username || !password || typeof callback !== "function")
						return console.error(`loginUser was called with invalid parameters`); // Die angegeben Parameter sind falsch
					http.get({
						host: `${apiHost}`,
						path: `/index.php?user-api&method=login&username=${username}&password=${password}&secret=${apiSecret}`, // Die Daten des Users werden in die URL geschrieben
						headers: { 'User-Agent': 'Projekt Reallife Agent 1.0.0' }
					}, (response) => {
						let status = response.statusCode;
						if(status !== 200) // Die Antwort war nicht 200, also ist irgendwas schief gelaufen
						{
							response.resume(); // Den Rest der Anfrage verarbeiten, damit kein Memory Overflow entsteht
							callback(`Request failed. Server responded with status code ${status}`);
						}
						else
						{
							let data = "";
							response.on('data', (chunk) => {
								data += chunk;
							});

							response.on('end', () => {
								let parsed = JSON.parse(data);
								callback(null, {
									id: parsed.userID,
									email: parsed.email,
									groups: parsed.groups

								});
							});					
						}
					});
				}

				loginUser(username, password, (error, data) => 
				{
					if(error) return console.log(error); // Bei einem Error sind keine Daten vorhanden, also muss returnt werden, damit der 2. Parameter nicht verwendet wird
					if(parsed.groups === 6) {
						player.name = username;
                        player.call("loginHandler", ["success"]);
                        gm.auth.loadAccount(player);
					} else {
                        player.call("loginHandler", ["incorrectinfo"]);
                    }
					console.log(data);
				});


				
				/*gm.mysql.handle.query('SELECT `password` FROM `accounts` WHERE `username` = ?', [username], function(err, res){
                    if(res.length > 0){
                        let sqlPassword = res[0]["password"];
                        bcrypt.compare(pass, sqlPassword, function(err, res2) {
                            if(res2 === true){
                                player.name = username;
                                player.call("loginHandler", ["success"]);
                                gm.auth.loadAccount(player);
                            } else {
                                player.call("loginHandler", ["incorrectinfo"]);
                            }
                        });
                    } else {
                        player.call("loginHandler", ["incorrectinfo"]);
                    }
                });*/
            }
            break;
        }
        //Account Registration
        case 1:
        {
            if(username.length >= 3 && pass.length >= 5){
                gm.mysql.handle.query('SELECT * FROM `accounts` WHERE `username` = ?', [username], function(err, res){
                    if(res.length > 0){
                        player.call("loginHandler", ["takeninfo"]);
                    } else {
                        bcrypt.hash(pass, function(err, hash) {
                            if(!err){
                                gm.mysql.handle.query('INSERT INTO `accounts` SET username = ?, password = ?', [username, hash], function(err, res){
                                    if(!err){
                                        player.name = username;
                                        console.log("\x1b[92m" + username + "\x1b[39m has just registered.");
                                    } else {
                                        console.log("\x1b[31m[ERROR] " + err)
                                    }
                                });
                            } else {
                                console.log("\x1b[31m[BCrypt]: " + err)
                            }
                        });
                    }
                });
            } else {
                player.call("loginHandler", ["tooshort"]);
            }            
            break;
        }
        default:
        {
            player.outputChatBox("An error has occured, please contact your server administrator.")
            console.log("\x1b[31m[ERROR] Login/Register state was one that isn't defined. State: " + state)
            break;
        }
    }
});

Alles anzeigen

LeonMrBonnie · 23. Oktober 2019

Wie gibts du bei der API die Gruppen zurück? Ich habe mal erwartet, dass es ein Array dass aus Objekten mit den Daten für die jeweilige Gruppe zurückgibt.

Wenn es so ist, dann ersetz Zeile 50 mit:

Code

if(parsed.groups.find(group => group.groupID === 6))

Dr.West · 23. Oktober 2019

So ist der Ausgabewert. Wenn man aber etwas falsches eingibt..

Falsches Passwort / Kein User vorhanden ->

Und wenn ich innerhalb von dem Code gewisse Sachen in der Console zum Testen ausgeben mag, functioniert das auch nicht. Als würde er das nicht aufrufen alles.

LeonMrBonnie · 23. Oktober 2019

JavaScript

mp.events.add("sendDataToServer", (player, username, password, state) => {
    let loggedAccount = mp.players.toArray().find(p => p.loggedInAs == username);
    switch(state){
        //Account Login
        case 0:
        {
            if(loggedAccount){
                console.log("Logged in already.");
                player.call("loginHandler", ["logged"]);
            } else {
				function loginUser(username, password, callback)
				{
					if(!username || !password || typeof callback !== "function")
						return console.error(`loginUser was called with invalid parameters`); // Die angegeben Parameter sind falsch
					http.get({
						host: `${apiHost}`,
						path: `/index.php?user-api&method=login&username=${username}&password=${password}&secret=${apiSecret}`, // Die Daten des Users werden in die URL geschrieben
						headers: { 'User-Agent': 'Projekt Reallife Agent 1.0.0' }
					}, (response) => {
						let status = response.statusCode;
						if(status !== 200) // Die Antwort war nicht 200, also ist irgendwas schief gelaufen
						{
							response.resume(); // Den Rest der Anfrage verarbeiten, damit kein Memory Overflow entsteht
							callback({ Status: status, Error: "The server did not respond with 200 - OK" });
						}
						else
						{
							let data = "";
							response.on('data', (chunk) => {
								data += chunk;
							});
							response.on('end', () => {
								let parsed = JSON.parse(data);
								callback(null, {
									id: parsed.userID,
									email: parsed.email,
									groups: parsed.groups
								});
							});					
						}
					});
				}
				loginUser(username, password, (error, data) => 
				{
                    console.log(JSON.stringify(data));
                    if(error) 
                    {
                        if(error.Status === 412) return player.call("loginHandler", ["incorrectinfo"]); // Falscher Name/Passwort
                        else return console.log(error.Error); // Bei einem Error sind keine Daten vorhanden, also muss returnt werden, damit der 2. Parameter nicht verwendet wird
                    }
					if(data.groups.find(group => group.groupID === 6)) {
						player.name = username;
                        player.call("loginHandler", ["success"]);
                        gm.auth.loadAccount(player);
					} else {
                        player.call("loginHandler", ["incorrectinfo"]);
                    }
				});
            }
            break;
        }
        //Account Registration
        case 1:
        {
            if(username.length >= 3 && pass.length >= 5){
                gm.mysql.handle.query('SELECT * FROM `accounts` WHERE `username` = ?', [username], function(err, res){
                    if(res.length > 0){
                        player.call("loginHandler", ["takeninfo"]);
                    } else {
                        bcrypt.hash(pass, function(err, hash) {
                            if(!err){
                                gm.mysql.handle.query('INSERT INTO `accounts` SET username = ?, password = ?', [username, hash], function(err, res){
                                    if(!err){
                                        player.name = username;
                                        console.log("\x1b[92m" + username + "\x1b[39m has just registered.");
                                    } else {
                                        console.log("\x1b[31m[ERROR] " + err)
                                    }
                                });
                            } else {
                                console.log("\x1b[31m[BCrypt]: " + err)
                            }
                        });
                    }
                });
            } else {
                player.call("loginHandler", ["tooshort"]);
            }            
            break;
        }
        default:
        {
            player.outputChatBox("An error has occured, please contact your server administrator.")
            console.log("\x1b[31m[ERROR] Login/Register state was one that isn't defined. State: " + state)
            break;
        }
    }
});

Alles anzeigen

Versuch mal die Daten stringified zu printen. Dazu hast du auch statt dem data Parameter parsed verwendet, die Variable ist aber nur innerhalb der Funktion.

Dr.West · 23. Oktober 2019

Wie bereits gesagt, funktioniert das mit dem Log in der Console nicht.

LeonMrBonnie · 23. Oktober 2019

Hast du auch das http Package requiret? Versuch mal innerhalb der loginUser Funktion ein paar Logs zu platzieren und guck wo es stehen bleibt.

Dr.West · 23. Oktober 2019

JavaScript

var mysql = require('mysql');
var http = require('http');
const bcrypt = require('bcryptjs');
const apiHost = "https://www.projekt-xyz.de";
const apiSecret = "asasasasasasasasasasas";

Ja habe ich bereits alles versucht. Klappt aber nicht.

LeonMrBonnie · 23. Oktober 2019

const apiHost = "https://www.projekt-xyz.de";
zu
const apiHost = "projekt-xyz.de";

Ist anscheinend irgendein komisches Problem mit dem HTTP Package.

Dr.West · 23. Oktober 2019

Okay, also nun habe ich ein Response vom Server bekommen.

Code

The server did not respond with 200 - OK

Das ganze wird aktuell als JSON so ausgegeben bei einem Aufruf.

Zitat

{

status: 200,

data: {

userID: 10,

wscApiId: 0,

username: "Test",

email: "test@localhost.com",

options: {

userID: 10,

userOption1: "",

userOption2: "",

userOption3: 1,

userOption4: "0",

userOption5: "",

userOption6: "",

userOption7: "",

userOption8: "",

userOption9: "",

userOption10: null,

userOption11: null,

userOption12: "",

userOption13: "",

userOption14: 1,

userOption15: "Europe/Berlin",

userOption16: 1,

userOption17: 1,

userOption18: "0",

userOption19: "0",

userOption20: "0",

userOption21: "3",

userOption22: "1",

userOption23: 1,

userOption24: "1",

userOption25: "0",

userOption26: "0",

userOption27: "0",

userOption28: "0",

userOption29: "0",

userOption30: 1,

userOption31: 1

},

groups: [

{

groupID: 1,

groupName: "Jeder",

groupType: 1

},

{

groupID: 3,

groupName: "Registrierte Benutzer",

groupType: 3

},

{

groupID: 6,

groupName: "Bürger",

groupType: 4

}

]

}

}

Alles anzeigen

Mein Webserver is so konzipiert, dass er immer automatisch auf https umsteigt, kann ich die Anfrage auch in https versuchen?

LeonMrBonnie · 23. Oktober 2019

Ja, dann musst du natürlich das https Package nehmen und nicht http.

Dr.West · 23. Oktober 2019

So, das ganze ist nun als https, jedoch auch hier, keinerlei Response innerhalb der Console. Ich kann das ganze script in der Loginfunktion mit console.log("Aufruf A"); oder was auch immer pflastern, es passiert nüscht.

Ich zeig mal auf wie genau etwas passiert.

Login Form sendet an den Clientseitigen Script ein Befehl..

HTML

<body>
	<div id="app">
		<form ref='form' action="" class='signin-form'>
			<div class="form-group">
				<label for="password">Benutzername</label>
				<input required v-model='username' id="loginUsername" type="text" name="username" placeholder="Dein Benutzername" required>
			</div>
			<div class="form-group">
				<label for="password">Passwort</label>
				<input required v-model='password' id="loginPass" type="password" name="password" placeholder="Dein Passwort" required>
			</div>
			<input type="submit" value="Login" v-on:click="sendAccountInfo(0)">
		</form>
	</div>


	<script>
		const app = new Vue({
			el: '#app',


			data: function () {
				return {
				    username: "",
					password: ""
				};
			},
			methods: {
				sendAccountInfo: function (state) {
					if (state === 0) {
						mp.trigger("loginDataToServer", this.username, this.password, state);
					}
				}
			}
		});
	</script>
</body>

Alles anzeigen

Das Script geht also zum Clienten in das Verarbeitungsscript ...

JavaScript

mp.events.add("loginDataToServer", (username, password, state) => {
    mp.events.callRemote("sendDataToServer", username, password, state);
});

Dieses Script wiederrum ruft nun die Serverseite auf und macht halt folgendes.

JavaScript

mp.events.add("sendDataToServer", (player, username, password, state) => {
    let loggedAccount = mp.players.toArray().find(p => p.loggedInAs == username);
    switch(state){
        //Account Login
        case 0:
        {
            if(loggedAccount){
                console.log("Logged in already.");
                player.call("loginHandler", ["logged"]);
            } else {
				function loginUser(username, password, callback)
				{
					if(!username || !password || typeof callback !== "function")
						return console.error(`loginUser was called with invalid parameters`); // Die angegeben Parameter sind falsch
					http.get({
						host: `${apiHost}`,
						path: `/index.php?user-api&method=login&username=${username}&password=${password}&secret=${apiSecret}`, // Die Daten des Users werden in die URL geschrieben
						headers: { 'User-Agent': 'Projekt Reallife Agent 1.0.0' }
					}, (response) => {
						let status = response.statusCode;
						if(status !== 200) // Die Antwort war nicht 200, also ist irgendwas schief gelaufen
						{
							response.resume(); // Den Rest der Anfrage verarbeiten, damit kein Memory Overflow entsteht
							callback({ Status: status, Error: "The server did not respond with 200 - OK" });
						}
						else
						{
							let data = "";
							response.on('data', (chunk) => {
								data += chunk;
							});
							response.on('end', () => {
								let parsed = JSON.parse(data);
								callback(null, {
									id: parsed.userID,
									email: parsed.email,
									groups: parsed.groups
								});
							});								
						}
						console.log(JSON.stringify(parsed));	
					});

				}

				loginUser(username, password, (error, data) => 
				{
                    if(error) 
                    {
                        if(error.Status === 412) return player.call("loginHandler", ["incorrectinfo"]); // Falscher Name/Passwort
                        else return console.log(error.Error); // Bei einem Error sind keine Daten vorhanden, also muss returnt werden, damit der 2. Parameter nicht verwendet wird
                    }
					if(data.groups.find(group => group.groupID === 6)) {
						player.name = username;
                        player.call("loginHandler", ["success"]);
                        gm.auth.loadAccount(player);
					} else {
                        player.call("loginHandler", ["incorrectinfo"]);
                    }
					console.log(JSON.stringify(parsed));
					console.log(JSON.stringify(data));
				});
            }
            break;
        }
        //Account Registration
        case 1:
        {
            if(username.length >= 3 && pass.length >= 5){
                gm.mysql.handle.query('SELECT * FROM `accounts` WHERE `username` = ?', [username], function(err, res){
                    if(res.length > 0){
                        player.call("loginHandler", ["takeninfo"]);
                    } else {
                        bcrypt.hash(pass, function(err, hash) {
                            if(!err){
                                gm.mysql.handle.query('INSERT INTO `accounts` SET username = ?, password = ?', [username, hash], function(err, res){
                                    if(!err){
                                        player.name = username;
                                        console.log("\x1b[92m" + username + "\x1b[39m has just registered.");
                                    } else {
                                        console.log("\x1b[31m[ERROR] " + err)
                                    }
                                });
                            } else {
                                console.log("\x1b[31m[BCrypt]: " + err)
                            }
                        });
                    }
                });
            } else {
                player.call("loginHandler", ["tooshort"]);
            }            
            break;
        }
        default:
        {
            player.outputChatBox("An error has occured, please contact your server administrator.")
            console.log("\x1b[31m[ERROR] Login/Register state was one that isn't defined. State: " + state)
            break;
        }
    }
});

Alles anzeigen

Ab hier verliert sich jegliche Meldung, es kommt kein Debug Log, es kommt kein Output nichts.

LeonMrBonnie · 23. Oktober 2019

http.get ?

Dr.West · 23. Oktober 2019

Nope auch nicht. ich verzweifel langsam.

LeonMrBonnie · 23. Oktober 2019

Ich meine von http.get zu https.get ändern.