PortalCreateEventListener.java

package com.worldql.client.listeners;

import WorldQLFB_OLD.StandardEvents.Update;
import com.google.flatbuffers.FlatBufferBuilder;
import com.worldql.client.WorldQLClient;
import org.bukkit.Location;
import org.bukkit.Material;
import org.bukkit.block.BlockState;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.block.BlockPhysicsEvent;
import org.bukkit.event.world.PortalCreateEvent;
import zmq.ZMQ;

public class PortalCreateEventListener implements Listener {
    @EventHandler
    public void onPortalCreate(PortalCreateEvent e) {
        WorldQLClient.getPluginInstance().getLogger().info(String.valueOf(e.getReason()));
        //WorldQLClient.logger.info("!!!");
        for (final BlockState b : e.getBlocks()) {
            //WorldQLClient.logger.info(b.getBlockData().getMaterial().toString());
            if (b.getBlockData().getMaterial().equals(Material.NETHER_PORTAL) || b.getBlockData().getMaterial().equals(Material.OBSIDIAN)) {
                Location l = b.getLocation();
                FlatBufferBuilder builder = new FlatBufferBuilder(1024);

                int instruction = builder.createString("MinecraftBlockPlace");
                int blockData = builder.createString(b.getBlockData().getAsString());
                int worldName = builder.createString(b.getBlock().getWorld().getName());
                int[] paramsArray = {blockData};
                int params = Update.createParamsVector(builder, paramsArray);

                Update.startUpdate(builder);
                Update.addInstruction(builder, instruction);
                Update.addWorldName(builder, worldName);
                Update.addPosition(builder, PlayerBreakBlockListener.createRoundedVec3(builder, l.getX(), l.getY(), l.getZ()));
                Update.addParams(builder, params);
                Update.addSenderid(builder, WorldQLClient.getPluginInstance().getZmqPortClientId());

                int blockUpdate = Update.endUpdate(builder);
                builder.finish(blockUpdate);

                byte[] buf = builder.sizedByteArray();
                WorldQLClient.getPluginInstance().getPushSocket().send(buf, ZMQ.ZMQ_DONTWAIT);
            }
        }
    }


    @EventHandler
    public void onBlockPhysics(BlockPhysicsEvent e) {
        /*
        if(e.getChangedType() == Material.NETHER_PORTAL && e.getSourceBlock().getBlockData().getMaterial().equals(Material.AIR)) {

            //WorldQLClient.logger.info("BLOCKPHYSICS ON NETHER PORTAL");
            Location l = e.getBlock().getLocation();
            FlatBufferBuilder builder = new FlatBufferBuilder(1024);
            int instruction = builder.createString("MinecraftBlockBreak");
            int blockdata = builder.createString(e.getBlock().getBlockData().getAsString());
            int worldName = builder.createString(e.getBlock().getWorld().getName());
            int[] params_array = {blockdata};
            int params = Update.createParamsVector(builder, params_array);
            Update.startUpdate(builder);
            Update.addInstruction(builder, instruction);
            Update.addWorldName(builder, worldName);
            Update.addPosition(builder, PlayerBlockPlaceListener.createRoundedVec3(builder, l.getX(), l.getY(), l.getZ()));
            Update.addParams(builder, params);
            Update.addSenderid(builder, WorldQLClient.zmqPortClientId);
            int blockupdate = Update.endUpdate(builder);
            builder.finish(blockupdate);

            byte[] buf = builder.sizedByteArray();
            WorldQLClient.push_socket.send(buf, 0);
        }

         */
    }

}