enhancement #1819

src/server/components/auth.js

@@ -283,7 +283,7 @@ module.exports = {
 		}
 		
 		this.username = username;
-		cons.logOut(this.obj);
+		await cons.logOut(this.obj);
 
 		this.initTracker();
 

src/server/security/connections.js

@@ -152,7 +152,7 @@ module.exports = {
 		msg.callback();
 	},
 
-	logOut: function (exclude) {
+	logOut: async function (exclude) {
 		let players = this.players;
 		let pLen = players.length;
 		for (let i = 0; i < pLen; i++) {
@@ -161,6 +161,9 @@ module.exports = {
 			if ((!p) || (p === exclude) || (!p.auth))
 				continue;
 
+			if (p.name && p.zoneName)
+				await atlas.forceSavePlayer(p.name, p.zoneName);
+
 			if (p.auth.username === exclude.auth.username)
 				p.socket.emit('dc', {});
 		}

src/server/world/atlas.js

@@ -262,5 +262,24 @@ module.exports = {
 				});
 			});
 		});
+	},
+
+	forceSavePlayer: async function (playerName, zoneName) {
+		const thread = this.getThreadFromName(zoneName);
+
+		if (!thread)
+			return;
+
+		return new Promise(res => {
+			const callbackId = this.registerCallback(res);
+
+			thread.worker.send({
+				method: 'forceSavePlayer',
+				args: {
+					playerName,
+					callbackId
+				}
+			});
+		});
 	}
 };

src/server/world/instancer.js

@@ -337,5 +337,22 @@ module.exports = {
 		process.send({
 			method: 'onZoneIdle'
 		});
+	},
+
+	forceSavePlayer: async function ({ playerName, callbackId }) {
+		const player = objects.objects.find(o => o.player && o.name === playerName);
+
+		if (!player?.auth)
+			return;
+
+		await player.auth.doSave();
+
+		process.send({
+			module: 'atlas',
+			method: 'resolveCallback',
+			msg: {
+				id: callbackId
+			}
+		});
 	}
 };