/* * KubaTech - Gregtech Addon * Copyright (C) 2022 kuba6000 * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; either * version 3 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public License * along with this library. If not, see . * */ package kubatech.api.network; import cpw.mods.fml.common.network.simpleimpl.IMessage; import cpw.mods.fml.common.network.simpleimpl.IMessageHandler; import cpw.mods.fml.common.network.simpleimpl.MessageContext; import io.netty.buffer.ByteBuf; import java.nio.charset.StandardCharsets; import java.util.HashMap; import java.util.HashSet; import kubatech.config.Config; import kubatech.config.OverridesConfig; import kubatech.kubatech; import kubatech.loaders.MobRecipeLoader; public class LoadConfigPacket implements IMessage { public static final LoadConfigPacket instance = new LoadConfigPacket(); public final HashSet mobsToLoad = new HashSet<>(); public final HashMap mobsOverrides = new HashMap<>(); @Override public void fromBytes(ByteBuf buf) { if (!buf.readBoolean()) mobsToLoad.clear(); else { mobsToLoad.clear(); int mobssize = buf.readInt(); for (int i = 0; i < mobssize; i++) { byte[] sbytes = new byte[buf.readInt()]; buf.readBytes(sbytes); mobsToLoad.add(new String(sbytes, StandardCharsets.UTF_8)); } int overridessize = buf.readInt(); for (int i = 0; i < overridessize; i++) { byte[] sbytes = new byte[buf.readInt()]; buf.readBytes(sbytes); mobsOverrides.put( new String(sbytes, StandardCharsets.UTF_8), OverridesConfig.MobOverride.readFromByteBuf(buf)); } } } @Override public void toBytes(ByteBuf buf) { if (!Config.mobHandlerEnabled) buf.writeBoolean(false); else { buf.writeBoolean(true); buf.writeInt(mobsToLoad.size()); mobsToLoad.forEach(s -> { byte[] sbytes = s.getBytes(StandardCharsets.UTF_8); buf.writeInt(sbytes.length); buf.writeBytes(sbytes); }); buf.writeInt(mobsOverrides.size()); mobsOverrides.forEach((k, v) -> { byte[] sbytes = k.getBytes(StandardCharsets.UTF_8); buf.writeInt(sbytes.length); buf.writeBytes(sbytes); v.writeToByteBuf(buf); }); } } public static class Handler implements IMessageHandler { @Override public IMessage onMessage(LoadConfigPacket message, MessageContext ctx) { kubatech.info("Received Mob Handler config, parsing"); MobRecipeLoader.processMobRecipeMap(message.mobsToLoad, message.mobsOverrides); return null; } } }