flying-squid/src/lib/playerPlugins/login.js

var Entity=require("prismarine-entity");
var spiralloop = require('spiralloop');
var Vec3=require("vec3");

module.exports=inject;

function inject(serv,player)
{
  function addPlayer()
  {
    serv.entityMaxId++;
    player.entity=new Entity(serv.entityMaxId);
    serv.entities[player.entity.id]=player.entity;
    player.entity.player=player;
    player.entity.health = 20;
    player.entity.food = 20;
    player.view=8;
    player.username=player._client.username;
    serv.players.push(player);
    serv.uuidToPlayer[player._client.uuid] = player;
    player.loadedChunks={};
  }

  function toFixedPosition(p)
  {
    return p.scaled(32).floored();
  }
  function sendLogin()
  {
    // send init data so client will start rendering world
    player._client.write('login', {
      entityId: player.entity.id,
      levelType: 'default',
      gameMode: player.gameMode,
      dimension: 0,
      difficulty: 0,
      reducedDebugInfo: false,
      maxPlayers: serv._server.maxPlayers
    });
    player.entity.position=toFixedPosition(player.spawnPoint);
  }

  function spiral(arr)
  {
    var t=[];
    spiralloop(arr,function(x,z){
      t.push([x,z]);
    });
    return t;
  }


  function sendChunk(chunkX,chunkZ,column)
  {
    player._client.write('map_chunk', {
      x: chunkX,
      z: chunkZ,
      groundUp: true,
      bitMap: 0xffff,
      chunkData: column.dump()
    });
    return Promise.resolve();
  }

  function sendChunksAroundPlayer(view)
  {
    player.lastPositionChunkUpdated=player.entity.position;
    var playerChunkX=Math.floor(player.entity.position.x/16/32);
    var playerChunkZ=Math.floor(player.entity.position.z/16/32);
    return spiral([view*2,view*2])
      .map(t => ({
        chunkX:playerChunkX+t[0]-view,
        chunkZ:playerChunkZ+t[1]-view
      }))
      .filter(({chunkX,chunkZ}) => {
        var key=chunkX+","+chunkZ;
        var loaded=player.loadedChunks[key];
        if(!loaded) player.loadedChunks[key]=1;
        return !loaded;
      })
      .reduce((acc,{chunkX,chunkZ})=>
         acc
          //.then(() => sleep(100))
          .then(() => serv.world.getColumn(chunkX,chunkZ))
          .then((column) => sendChunk(chunkX,chunkZ,column))
      ,Promise.resolve());
  }

  function sendMap()
  {
    return sendChunksAroundPlayer(3);
  }

  function sendRestMap()
  {
    player.sendingChunks=true;
    sendChunksAroundPlayer(player.view).then(() => player.sendingChunks=false);

    player.on("positionChanged",function(){
      if(!player.sendingChunks && player.entity.position.distanceTo(player.lastPositionChunkUpdated)>16*32)
      {
        player.sendingChunks=true;
        sendChunksAroundPlayer(player.view).then(() => player.sendingChunks=false);
      }
    });
  }


  function sleep(ms = 0) {
    return new Promise(r => setTimeout(r, ms));
  }



  function sendSpawnPosition()
  {
    console.log("setting spawn at "+player.spawnPoint);
    player._client.write('spawn_position',{
      "location":player.spawnPoint
    });
  }

  function sendInitialPosition()
  {
    player.entity.position=toFixedPosition(player.spawnPoint);
    player.entity.yaw=0;
    player.entity.pitch=0;
    player._client.write('position', {
      x: player.entity.position.x/32,
      y: player.entity.position.y/32,
      z: player.entity.position.z/32,
      yaw: player.entity.yaw,
      pitch: player.entity.pitch,
      flags: 0x00
    });
  }

  function updateTime()
  {
    player._client.write('update_time', {
      age: [0, 0],
      time: [0, serv.time]
    });
  }

  function setGameMode(gameMode)
  {
    player._client.write('game_state_change', {
      reason: 3,
      gameMode: gameMode
    });
    player.gameMode=gameMode;
  }

  function fillTabList()
  {
    player._writeOthers('player_info',{
        action: 0,
        data: [{
          UUID: player._client.uuid,
          name: player.username,
          properties: [],
          gamemode: player.gameMode,
          ping: 1,
          hasDisplayName: true,
          displayName: {'text':player.username}
        }]
      });

    serv.players.map((otherPlayer) => {
      player._client.write('player_info', {
        action: 0,
        data: [{
          UUID: otherPlayer._client.uuid,
          name: otherPlayer.username,
          properties: [],
          gamemode: otherPlayer.gameMode,
          ping: 1,
          hasDisplayName: true,
          displayName: {'text':player.username}
        }]
      });
    });
  }


  function spawnOthers()
  {
    player.getOthers().forEach(function (otherPlayer) {
      player._client.write('named_entity_spawn', {
        entityId: otherPlayer.entity.id,
        playerUUID: otherPlayer._client.uuid,
        x: otherPlayer.entity.position.x,
        y: otherPlayer.entity.position.y,
        z: otherPlayer.entity.position.z,
        yaw: otherPlayer.entity.yaw,
        pitch: otherPlayer.entity.pitch,
        currentItem: 0,
        metadata: otherPlayer.entity.metadata
      });
    });

  }

  function spawn()
  {
    player._writeOthers('named_entity_spawn',{
      entityId: player.entity.id,
      playerUUID: player._client.uuid,
      x: player.entity.position.x,
      y: player.entity.position.y,
      z: player.entity.position.z,
      yaw: player.entity.yaw,
      pitch: player.entity.pitch,
      currentItem: 0,
      metadata: player.entity.metadata
    });
  }


  function announceJoin()
  {
    serv.broadcast(player.username + ' joined the game.', "yellow");
    player.emit("connected");
  }

  async function login()
  { 
    if (serv.uuidToPlayer[player._client.uuid]) {
      player._client.end("You are already connected");
      return;
    }
    if (serv.bannedPlayers[player._client.uuid]) {
      player.kick(serv.bannedPlayers[player._client.uuid].reason);
      return;
    }

    addPlayer();
    sendLogin();
    await sendMap();
    sendSpawnPosition();
    sendInitialPosition();
    player.updateHealth(player.entity.health);

    player.emit("spawned");

    updateTime();
    setGameMode(player.gameMode);
    fillTabList();
    spawnOthers();
    spawn();

    announceJoin();

    setTimeout(sendRestMap,100);
  }

  player.setGameMode=setGameMode;
  player.login=login;
  player.sendInitialPosition=sendInitialPosition;
  player.spawn=spawn;
}