|
| 1 | +module.exports=(config)-> |
| 2 | + fs=require "fs" |
| 3 | + http=require "http" |
| 4 | + server=http.createServer() |
| 5 | + io=require("socket.io")(server) |
| 6 | + express=require 'express' |
| 7 | + app=express(); |
| 8 | + mineflayer = require 'mineflayer' |
| 9 | + Chunk = require("prismarine-chunk")("1.16.1") |
| 10 | + vec3=require "vec3" |
| 11 | + |
| 12 | + sf={} |
| 13 | + port=config["express-port"] |
| 14 | + world={} |
| 15 | + #Zapisywanie i odczytywanie świata |
| 16 | + saveWorld=-> |
| 17 | + fs.writeFileSync __dirname+"/savedWorld.json",JSON.stringify(world) |
| 18 | + restoreWorld=-> |
| 19 | + world=JSON.parse fs.readFileSync(__dirname+'/savedWorld.json') |
| 20 | + |
| 21 | + restoreWorld() |
| 22 | + |
| 23 | + players={} |
| 24 | + socketInfo={} |
| 25 | + |
| 26 | + |
| 27 | + app.use express.static(__dirname + "/client/") |
| 28 | + app.use (req, res, next) -> |
| 29 | + res.set 'Cache-Control', 'no-store' |
| 30 | + next() |
| 31 | + app.get "/websocket/",(req,res)-> |
| 32 | + res.send String(config["websocket-port"]) |
| 33 | + app.get "/host/",(req,res)-> |
| 34 | + res.send String(config["host"]) |
| 35 | + app.listen port |
| 36 | + |
| 37 | + server.listen config["websocket-port"] |
| 38 | + |
| 39 | + #On connect |
| 40 | + io.sockets.on "connection", (socket)-> |
| 41 | + |
| 42 | + #Trying to run special functions |
| 43 | + socket.on "initClient",(data)-> |
| 44 | + console.log "NEW: "+socket.id |
| 45 | + #init socketInfo |
| 46 | + socketInfo[socket.id]=data |
| 47 | + |
| 48 | + #socketInfo add Bot |
| 49 | + socketInfo[socket.id].bot=mineflayer.createBot { |
| 50 | + host: config.realServer.ip |
| 51 | + port: config.realServer.port |
| 52 | + username: socketInfo[socket.id].nick |
| 53 | + } |
| 54 | + #On recieve real Map Chunk |
| 55 | + socketInfo[socket.id].bot._client.on "map_chunk",(packet)-> |
| 56 | + |
| 57 | + # cell=new Chunk() |
| 58 | + # cell.load packet.chunkData,packet.bitMap,false,true |
| 59 | + # console.log cell.fromJson |
| 60 | + io.to(socket.id).emit "mapChunk", packet |
| 61 | + |
| 62 | + # console.log packet |
| 63 | + return |
| 64 | + |
| 65 | + socketInfo[socket.id].bot.on 'chat',(username, message)-> |
| 66 | + if username is socketInfo[socket.id].bot.username |
| 67 | + return |
| 68 | + socketInfo[socket.id].bot.chat message |
| 69 | + return |
| 70 | + #first world load |
| 71 | + io.to(socket.id).emit "firstLoad",world |
| 72 | + return |
| 73 | + socket.on "playerUpdate",(data)-> |
| 74 | + players[socket.id]=data |
| 75 | + io.sockets.emit "playerUpdate", data |
| 76 | + socket.on "blockUpdate",(block)-> |
| 77 | + world["#{block[0]}:#{block[1]}:#{block[2]}"]=block[3] |
| 78 | + if block[3] is 0 |
| 79 | + delete world["#{block[0]}:#{block[1]}:#{block[2]}"] |
| 80 | + io.sockets.emit "blockUpdate",block |
| 81 | + saveWorld() |
| 82 | + socket.on "disconnect", -> |
| 83 | + console.log "DIS: "+socket.id |
| 84 | + |
| 85 | + #end bot session |
| 86 | + socketInfo[socket.id].bot.end() |
| 87 | + #delete socketinfo |
| 88 | + delete players[socket.id] |
| 89 | + delete socketInfo[socket.id] |
| 90 | + return |
0 commit comments