mirror of
https://github.com/Creators-of-Create/Create.git
synced 2024-11-14 22:44:07 +01:00
1edda9b564
- Yet another attempt at preventing elevator fall damage - Flexcrate now has comparator output - Basin now has comparator output - Kinetic Gauges now have comparator output - Stress Gauge -> Stressometer
95 lines
4.4 KiB
Java
95 lines
4.4 KiB
Java
package com.simibubi.create;
|
|
|
|
import java.util.function.BiConsumer;
|
|
import java.util.function.Function;
|
|
import java.util.function.Supplier;
|
|
|
|
import com.simibubi.create.foundation.behaviour.filtering.FilteringCountUpdatePacket;
|
|
import com.simibubi.create.foundation.behaviour.scrollvalue.ScrollValueUpdatePacket;
|
|
import com.simibubi.create.foundation.command.ConfigureConfigPacket;
|
|
import com.simibubi.create.foundation.item.AbstractToolItem;
|
|
import com.simibubi.create.foundation.packet.NbtPacket;
|
|
import com.simibubi.create.foundation.packet.SimplePacketBase;
|
|
import com.simibubi.create.foundation.utility.ServerSpeedProvider;
|
|
import com.simibubi.create.modules.contraptions.components.contraptions.CancelPlayerFallPacket;
|
|
import com.simibubi.create.modules.contraptions.components.contraptions.ContraptionStallPacket;
|
|
import com.simibubi.create.modules.contraptions.relays.advanced.sequencer.ConfigureSequencedGearshiftPacket;
|
|
import com.simibubi.create.modules.curiosities.symmetry.SymmetryEffectPacket;
|
|
import com.simibubi.create.modules.curiosities.zapper.ZapperBeamPacket;
|
|
import com.simibubi.create.modules.logistics.item.filter.FilterScreenPacket;
|
|
import com.simibubi.create.modules.logistics.packet.ConfigureFlexcratePacket;
|
|
import com.simibubi.create.modules.logistics.packet.ConfigureStockswitchPacket;
|
|
import com.simibubi.create.modules.schematics.packet.ConfigureSchematicannonPacket;
|
|
import com.simibubi.create.modules.schematics.packet.SchematicPlacePacket;
|
|
import com.simibubi.create.modules.schematics.packet.SchematicUploadPacket;
|
|
|
|
import net.minecraft.network.PacketBuffer;
|
|
import net.minecraft.util.ResourceLocation;
|
|
import net.minecraftforge.fml.network.NetworkEvent.Context;
|
|
import net.minecraftforge.fml.network.NetworkRegistry;
|
|
import net.minecraftforge.fml.network.simple.SimpleChannel;
|
|
|
|
public enum AllPackets {
|
|
|
|
// Client to Server
|
|
NBT(NbtPacket.class, NbtPacket::new),
|
|
CONFIGURE_SCHEMATICANNON(ConfigureSchematicannonPacket.class, ConfigureSchematicannonPacket::new),
|
|
CONFIGURE_FLEXCRATE(ConfigureFlexcratePacket.class, ConfigureFlexcratePacket::new),
|
|
CONFIGURE_STOCKSWITCH(ConfigureStockswitchPacket.class, ConfigureStockswitchPacket::new),
|
|
CONFIGURE_SEQUENCER(ConfigureSequencedGearshiftPacket.class, ConfigureSequencedGearshiftPacket::new),
|
|
PLACE_SCHEMATIC(SchematicPlacePacket.class, SchematicPlacePacket::new),
|
|
UPLOAD_SCHEMATIC(SchematicUploadPacket.class, SchematicUploadPacket::new),
|
|
CONFIGURE_FILTER(FilterScreenPacket.class, FilterScreenPacket::new),
|
|
CONFIGURE_FILTERING_AMOUNT(FilteringCountUpdatePacket.class, FilteringCountUpdatePacket::new),
|
|
CONFIGURE_SCROLLABLE(ScrollValueUpdatePacket.class, ScrollValueUpdatePacket::new),
|
|
CANCEL_FALL(CancelPlayerFallPacket.class, CancelPlayerFallPacket::new),
|
|
|
|
// Server to Client
|
|
SYMMETRY_EFFECT(SymmetryEffectPacket.class, SymmetryEffectPacket::new),
|
|
SERVER_SPEED(ServerSpeedProvider.Packet.class, ServerSpeedProvider.Packet::new),
|
|
BEAM_EFFECT(ZapperBeamPacket.class, ZapperBeamPacket::new),
|
|
CONFIGURE_CONFIG(ConfigureConfigPacket.class, ConfigureConfigPacket::new),
|
|
CONTRAPTION_STALL(ContraptionStallPacket.class, ContraptionStallPacket::new),
|
|
TOOL_HARVEST(AbstractToolItem.HarvestPacket.class, AbstractToolItem.HarvestPacket::new),
|
|
|
|
;
|
|
|
|
public static final ResourceLocation CHANNEL_NAME = new ResourceLocation(Create.ID, "network");
|
|
public static final String NETWORK_VERSION = new ResourceLocation(Create.ID, "1").toString();
|
|
public static SimpleChannel channel;
|
|
|
|
private LoadedPacket<?> packet;
|
|
|
|
private <T extends SimplePacketBase> AllPackets(Class<T> type, Function<PacketBuffer, T> factory) {
|
|
packet = new LoadedPacket<>(type, factory);
|
|
}
|
|
|
|
public static void registerPackets() {
|
|
channel = NetworkRegistry.ChannelBuilder.named(CHANNEL_NAME).serverAcceptedVersions(s -> true)
|
|
.clientAcceptedVersions(s -> true).networkProtocolVersion(() -> NETWORK_VERSION).simpleChannel();
|
|
for (AllPackets packet : values())
|
|
packet.packet.register();
|
|
|
|
}
|
|
|
|
private static class LoadedPacket<T extends SimplePacketBase> {
|
|
private static int index = 0;
|
|
BiConsumer<T, PacketBuffer> encoder;
|
|
Function<PacketBuffer, T> decoder;
|
|
BiConsumer<T, Supplier<Context>> handler;
|
|
Class<T> type;
|
|
|
|
private LoadedPacket(Class<T> type, Function<PacketBuffer, T> factory) {
|
|
encoder = T::write;
|
|
decoder = factory;
|
|
handler = T::handle;
|
|
this.type = type;
|
|
}
|
|
|
|
private void register() {
|
|
channel.messageBuilder(type, index++).encoder(encoder).decoder(decoder).consumer(handler).add();
|
|
}
|
|
}
|
|
|
|
}
|