|
|
@@ -23,7 +23,6 @@ const childProcess = require('child_process'); |
|
|
|
|
|
|
|
//Imports |
|
|
|
const objects = require('../objects/objects'); |
|
|
|
const connections = require('../security/connections'); |
|
|
|
const { mapList } = require('./mapManager'); |
|
|
|
const { registerCallback } = require('./atlas/registerCallback'); |
|
|
|
const events = require('../misc/events'); |
|
|
@@ -33,10 +32,6 @@ const threads = []; |
|
|
|
const listenersOnZoneIdle = []; |
|
|
|
|
|
|
|
//Helpers |
|
|
|
const getThreadFromName = name => { |
|
|
|
return threads.find(t => t.name === name); |
|
|
|
}; |
|
|
|
|
|
|
|
const getThreadFromId = threadId => { |
|
|
|
return threads.find(t => t.id === threadId); |
|
|
|
}; |
|
|
@@ -100,22 +95,6 @@ const messageHandlers = { |
|
|
|
player.auth.gaTracker.track(message.obj); |
|
|
|
}, |
|
|
|
|
|
|
|
callDifferentThread: function (thread, message) { |
|
|
|
let obj = connections.players.find(p => (p.name === message.playerName)); |
|
|
|
if (!obj) |
|
|
|
return; |
|
|
|
|
|
|
|
let newThread = getThreadFromName(obj.zoneName); |
|
|
|
if (!newThread) |
|
|
|
return; |
|
|
|
|
|
|
|
newThread.worker.send({ |
|
|
|
module: message.data.module, |
|
|
|
method: message.data.method, |
|
|
|
args: message.data.args |
|
|
|
}); |
|
|
|
}, |
|
|
|
|
|
|
|
rezone: async function (thread, message) { |
|
|
|
const { args: { obj, newZone, keepPos = true } } = message; |
|
|
|
|
|
|
|