Method WritePacketWithCompression

connection.go:361–414

(packet Packet)

}

func (player *Player) WritePacketWithCompression(packet Packet) (err error) {
	buff := newVarBuffer(256)
	tmp := player.io
	player.io = &ConnReadWrite{
		rdr: tmp.rdr,
		wtr: buff,
	}

	id, proto := packet.Id()
	if player.state == PLAY {
		id = player.HackClientbound(id, proto)
	}
	if id == -1 {
		return
	}
	player.WriteVarInt(id)
	packet.Write(player)

	var rBuff []byte
	var dataLength = 0
	if buff.Len() < config.Threshold {
		rBuff = buff.Bytes()
	} else {
		var b bytes.Buffer
		w := zlib.NewWriter(&b)
		w.Write(buff.Bytes())
		w.Close()
		rBuff = b.Bytes()
		dataLength = len(rBuff)
	}

	buff2 := newVarBuffer(1)
	player.io.wtr = buff2
	player.WriteVarInt(dataLength)
	packetLength := len(rBuff) + buff2.Len()

	buff3 := newVarBuffer(1)
	player.io.wtr = buff3
	player.WriteVarInt(packetLength)

	player.io = tmp
	player.conn.Write(buff3.Bytes())
	player.conn.Write(buff2.Bytes())
	player.conn.Write(rBuff)

	if config.Logs {
		if buff.Len() < config.Threshold {
			log.Println("<-u", id, packet)
		} else {
			log.Println("<-c", id, packet)
		}
	}
	return nil
}