mirror of https://github.com/Minestom/Minestom.git
256 lines
13 KiB
Java
256 lines
13 KiB
Java
package net.minestom.demo;
|
|
|
|
import net.kyori.adventure.text.Component;
|
|
import net.minestom.server.MinecraftServer;
|
|
import net.minestom.server.advancements.FrameType;
|
|
import net.minestom.server.advancements.notifications.Notification;
|
|
import net.minestom.server.advancements.notifications.NotificationCenter;
|
|
import net.minestom.server.adventure.MinestomAdventure;
|
|
import net.minestom.server.adventure.audience.Audiences;
|
|
import net.minestom.server.coordinate.Point;
|
|
import net.minestom.server.coordinate.Pos;
|
|
import net.minestom.server.coordinate.Vec;
|
|
import net.minestom.server.entity.Entity;
|
|
import net.minestom.server.entity.GameMode;
|
|
import net.minestom.server.entity.ItemEntity;
|
|
import net.minestom.server.entity.Player;
|
|
import net.minestom.server.entity.damage.Damage;
|
|
import net.minestom.server.event.Event;
|
|
import net.minestom.server.event.EventNode;
|
|
import net.minestom.server.event.entity.EntityAttackEvent;
|
|
import net.minestom.server.event.item.ItemDropEvent;
|
|
import net.minestom.server.event.item.PickupItemEvent;
|
|
import net.minestom.server.event.player.*;
|
|
import net.minestom.server.event.server.ServerTickMonitorEvent;
|
|
import net.minestom.server.instance.Instance;
|
|
import net.minestom.server.instance.InstanceContainer;
|
|
import net.minestom.server.instance.InstanceManager;
|
|
import net.minestom.server.instance.LightingChunk;
|
|
import net.minestom.server.instance.block.Block;
|
|
import net.minestom.server.instance.block.predicate.BlockPredicate;
|
|
import net.minestom.server.instance.block.predicate.BlockTypeFilter;
|
|
import net.minestom.server.inventory.ContainerInventory;
|
|
import net.minestom.server.inventory.InventoryType;
|
|
import net.minestom.server.item.ItemComponent;
|
|
import net.minestom.server.item.ItemStack;
|
|
import net.minestom.server.item.Material;
|
|
import net.minestom.server.item.component.BlockPredicates;
|
|
import net.minestom.server.item.component.ItemBlockState;
|
|
import net.minestom.server.monitoring.BenchmarkManager;
|
|
import net.minestom.server.monitoring.TickMonitor;
|
|
import net.minestom.server.network.NetworkBuffer;
|
|
import net.minestom.server.network.packet.server.play.ExplosionPacket;
|
|
import net.minestom.server.particle.Particle;
|
|
import net.minestom.server.particle.data.BlockParticleData;
|
|
import net.minestom.server.sound.SoundEvent;
|
|
import net.minestom.server.utils.MathUtils;
|
|
import net.minestom.server.utils.NamespaceID;
|
|
import net.minestom.server.utils.time.TimeUnit;
|
|
import net.minestom.server.world.DimensionType;
|
|
import org.jetbrains.annotations.NotNull;
|
|
|
|
import java.time.Duration;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import java.util.Random;
|
|
import java.util.concurrent.ThreadLocalRandom;
|
|
import java.util.concurrent.atomic.AtomicReference;
|
|
|
|
public class PlayerInit {
|
|
|
|
private static final ContainerInventory inventory;
|
|
|
|
private static final EventNode<Event> DEMO_NODE = EventNode.all("demo")
|
|
.addListener(EntityAttackEvent.class, event -> {
|
|
final Entity source = event.getEntity();
|
|
final Entity entity = event.getTarget();
|
|
|
|
entity.takeKnockback(0.4f, Math.sin(source.getPosition().yaw() * 0.017453292), -Math.cos(source.getPosition().yaw() * 0.017453292));
|
|
|
|
if (entity instanceof Player) {
|
|
Player target = (Player) entity;
|
|
target.damage(Damage.fromEntity(source, 5));
|
|
}
|
|
|
|
if (source instanceof Player) {
|
|
((Player) source).sendMessage("You attacked something!");
|
|
}
|
|
})
|
|
.addListener(PlayerDeathEvent.class, event -> event.setChatMessage(Component.text("custom death message")))
|
|
.addListener(PickupItemEvent.class, event -> {
|
|
final Entity entity = event.getLivingEntity();
|
|
if (entity instanceof Player) {
|
|
// Cancel event if player does not have enough inventory space
|
|
final ItemStack itemStack = event.getItemEntity().getItemStack();
|
|
event.setCancelled(!((Player) entity).getInventory().addItemStack(itemStack));
|
|
}
|
|
})
|
|
.addListener(ItemDropEvent.class, event -> {
|
|
final Player player = event.getPlayer();
|
|
ItemStack droppedItem = event.getItemStack();
|
|
|
|
Pos playerPos = player.getPosition();
|
|
ItemEntity itemEntity = new ItemEntity(droppedItem);
|
|
itemEntity.setPickupDelay(Duration.of(500, TimeUnit.MILLISECOND));
|
|
itemEntity.setInstance(player.getInstance(), playerPos.withY(y -> y + 1.5));
|
|
Vec velocity = playerPos.direction().mul(6);
|
|
itemEntity.setVelocity(velocity);
|
|
|
|
player.sendPacket(makeExplosion(playerPos, velocity));
|
|
})
|
|
.addListener(PlayerDisconnectEvent.class, event -> System.out.println("DISCONNECTION " + event.getPlayer().getUsername()))
|
|
.addListener(AsyncPlayerConfigurationEvent.class, event -> {
|
|
final Player player = event.getPlayer();
|
|
|
|
var instances = MinecraftServer.getInstanceManager().getInstances();
|
|
Instance instance = instances.stream().skip(new Random().nextInt(instances.size())).findFirst().orElse(null);
|
|
event.setSpawningInstance(instance);
|
|
int x = Math.abs(ThreadLocalRandom.current().nextInt()) % 500 - 250;
|
|
int z = Math.abs(ThreadLocalRandom.current().nextInt()) % 500 - 250;
|
|
player.setRespawnPoint(new Pos(0, 40f, 0));
|
|
})
|
|
.addListener(PlayerSpawnEvent.class, event -> {
|
|
final Player player = event.getPlayer();
|
|
player.setGameMode(GameMode.CREATIVE);
|
|
player.setPermissionLevel(4);
|
|
ItemStack itemStack = ItemStack.builder(Material.STONE)
|
|
.amount(64)
|
|
.set(ItemComponent.CAN_PLACE_ON, new BlockPredicates(new BlockPredicate(new BlockTypeFilter.Blocks(Block.STONE), null, null)))
|
|
.set(ItemComponent.CAN_BREAK, new BlockPredicates(new BlockPredicate(new BlockTypeFilter.Blocks(Block.DIAMOND_ORE), null, null)))
|
|
.build();
|
|
player.getInventory().addItemStack(itemStack);
|
|
|
|
ItemStack bundle = ItemStack.builder(Material.BUNDLE)
|
|
.set(ItemComponent.BUNDLE_CONTENTS, List.of(
|
|
ItemStack.of(Material.DIAMOND, 5),
|
|
ItemStack.of(Material.RABBIT_FOOT, 5)
|
|
))
|
|
.build();
|
|
player.getInventory().addItemStack(bundle);
|
|
|
|
player.getInventory().addItemStack(ItemStack.builder(Material.STONE_STAIRS)
|
|
.set(ItemComponent.BLOCK_STATE, new ItemBlockState(Map.of("facing", "west", "half", "top")))
|
|
.build());
|
|
|
|
if (event.isFirstSpawn()) {
|
|
Notification notification = new Notification(
|
|
Component.text("Welcome!"),
|
|
FrameType.TASK,
|
|
Material.IRON_SWORD
|
|
);
|
|
NotificationCenter.send(notification, event.getPlayer());
|
|
}
|
|
})
|
|
.addListener(PlayerPacketOutEvent.class, event -> {
|
|
//System.out.println("out " + event.getPacket().getClass().getSimpleName());
|
|
})
|
|
.addListener(PlayerPacketEvent.class, event -> {
|
|
//System.out.println("in " + event.getPacket().getClass().getSimpleName());
|
|
})
|
|
.addListener(PlayerUseItemOnBlockEvent.class, event -> {
|
|
if (event.getHand() != Player.Hand.MAIN) return;
|
|
|
|
var itemStack = event.getItemStack();
|
|
var block = event.getInstance().getBlock(event.getPosition());
|
|
|
|
if ("false" .equals(block.getProperty("waterlogged")) && itemStack.material().equals(Material.WATER_BUCKET)) {
|
|
block = block.withProperty("waterlogged", "true");
|
|
} else if ("true" .equals(block.getProperty("waterlogged")) && itemStack.material().equals(Material.BUCKET)) {
|
|
block = block.withProperty("waterlogged", "false");
|
|
} else return;
|
|
|
|
event.getInstance().setBlock(event.getPosition(), block);
|
|
|
|
})
|
|
.addListener(PlayerBlockPlaceEvent.class, event -> {
|
|
// event.setDoBlockUpdates(false);
|
|
})
|
|
.addListener(PlayerBlockInteractEvent.class, event -> {
|
|
var block = event.getBlock();
|
|
var rawOpenProp = block.getProperty("open");
|
|
if (rawOpenProp == null) return;
|
|
|
|
block = block.withProperty("open", String.valueOf(!Boolean.parseBoolean(rawOpenProp)));
|
|
event.getInstance().setBlock(event.getBlockPosition(), block);
|
|
});
|
|
|
|
private static final byte[] AIR_BLOCK_PARTICLE = NetworkBuffer.makeArray(new BlockParticleData(Block.AIR)::write);
|
|
|
|
private static @NotNull ExplosionPacket makeExplosion(@NotNull Point position, @NotNull Vec motion) {
|
|
return new ExplosionPacket(
|
|
position.x(), position.y(), position.z(),
|
|
0, new byte[0],
|
|
(float) motion.x(), (float) motion.y(), (float) motion.z(),
|
|
ExplosionPacket.BlockInteraction.KEEP,
|
|
Particle.BLOCK.id(), AIR_BLOCK_PARTICLE,
|
|
Particle.BLOCK.id(), AIR_BLOCK_PARTICLE,
|
|
SoundEvent.of(NamespaceID.from("not.a.real.sound"), 0f)
|
|
);
|
|
}
|
|
|
|
static {
|
|
InstanceManager instanceManager = MinecraftServer.getInstanceManager();
|
|
|
|
InstanceContainer instanceContainer = instanceManager.createInstanceContainer(DimensionType.OVERWORLD);
|
|
instanceContainer.setGenerator(unit -> {
|
|
unit.modifier().fillHeight(0, 40, Block.STONE);
|
|
|
|
if (unit.absoluteStart().blockY() < 40 && unit.absoluteEnd().blockY() > 40) {
|
|
unit.modifier().setBlock(unit.absoluteStart().blockX(), 40, unit.absoluteStart().blockZ(), Block.TORCH);
|
|
}
|
|
});
|
|
instanceContainer.setChunkSupplier(LightingChunk::new);
|
|
instanceContainer.setTimeRate(0);
|
|
instanceContainer.setTime(12000);
|
|
|
|
// var i2 = new InstanceContainer(UUID.randomUUID(), DimensionType.OVERWORLD, null, NamespaceID.from("minestom:demo"));
|
|
// instanceManager.registerInstance(i2);
|
|
// i2.setGenerator(unit -> unit.modifier().fillHeight(0, 40, Block.GRASS_BLOCK));
|
|
// i2.setChunkSupplier(LightingChunk::new);
|
|
|
|
// System.out.println("start");
|
|
// var chunks = new ArrayList<CompletableFuture<Chunk>>();
|
|
// ChunkUtils.forChunksInRange(0, 0, 32, (x, z) -> chunks.add(instanceContainer.loadChunk(x, z)));
|
|
|
|
// CompletableFuture.runAsync(() -> {
|
|
// CompletableFuture.allOf(chunks.toArray(CompletableFuture[]::new)).join();
|
|
// System.out.println("load end");
|
|
// LightingChunk.relight(instanceContainer, instanceContainer.getChunks());
|
|
// System.out.println("light end");
|
|
// });
|
|
|
|
inventory = new ContainerInventory(InventoryType.CHEST_1_ROW, Component.text("Test inventory"));
|
|
inventory.setItemStack(3, ItemStack.of(Material.DIAMOND, 34));
|
|
}
|
|
|
|
private static final AtomicReference<TickMonitor> LAST_TICK = new AtomicReference<>();
|
|
|
|
public static void init() {
|
|
var eventHandler = MinecraftServer.getGlobalEventHandler();
|
|
eventHandler.addChild(DEMO_NODE);
|
|
|
|
MinestomAdventure.AUTOMATIC_COMPONENT_TRANSLATION = true;
|
|
MinestomAdventure.COMPONENT_TRANSLATOR = (c, l) -> c;
|
|
|
|
eventHandler.addListener(ServerTickMonitorEvent.class, event -> LAST_TICK.set(event.getTickMonitor()));
|
|
|
|
BenchmarkManager benchmarkManager = MinecraftServer.getBenchmarkManager();
|
|
MinecraftServer.getSchedulerManager().buildTask(() -> {
|
|
if (MinecraftServer.getConnectionManager().getOnlinePlayerCount() != 0)
|
|
return;
|
|
|
|
long ramUsage = benchmarkManager.getUsedMemory();
|
|
ramUsage /= 1e6; // bytes to MB
|
|
|
|
TickMonitor tickMonitor = LAST_TICK.get();
|
|
final Component header = Component.text("RAM USAGE: " + ramUsage + " MB")
|
|
.append(Component.newline())
|
|
.append(Component.text("TICK TIME: " + MathUtils.round(tickMonitor.getTickTime(), 2) + "ms"))
|
|
.append(Component.newline())
|
|
.append(Component.text("ACQ TIME: " + MathUtils.round(tickMonitor.getAcquisitionTime(), 2) + "ms"));
|
|
final Component footer = benchmarkManager.getCpuMonitoringMessage();
|
|
Audiences.players().sendPlayerListHeaderAndFooter(header, footer);
|
|
}).repeat(10, TimeUnit.SERVER_TICK); //.schedule();
|
|
}
|
|
}
|