1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
package lv.enes.mc.eris_alchemy.utils;
import jakarta.annotation.Nonnull;
import lombok.Getter;
import lv.enes.mc.eris_alchemy.ErisAlchemyRegistry;
import net.fabricmc.api.EnvType;
import net.minecraft.network.FriendlyByteBuf;
import net.minecraft.server.level.ServerPlayer;
import org.quiltmc.loader.api.minecraft.MinecraftQuiltLoader;
import org.quiltmc.qsl.networking.api.PacketByteBufs;
import org.quiltmc.qsl.networking.api.ServerPlayNetworking;
import org.quiltmc.qsl.networking.api.client.ClientPlayNetworking;
import java.lang.ref.WeakReference;
import java.util.Collection;
import java.util.HashMap;
import java.util.Map;
public sealed abstract class SyncedValue<E> {
private final static Map<Long, WeakReference<SyncedValue<?>>> values = new HashMap<>();
private final long id;
private boolean changed = true;
@Getter
private E value;
public SyncedValue(E value) {
this(genId(), value);
}
public SyncedValue(long id, E value) {
this.id = id;
this.value = value;
values.put(this.id, new WeakReference<>(this));
}
protected abstract @Nonnull E read(FriendlyByteBuf buf);
protected abstract void write(FriendlyByteBuf buf, @Nonnull E value);
public void serialize(FriendlyByteBuf buf) {
buf.writeLongLE(id);
write(buf, value);
}
public void setValue(E value) {
this.value = value;
this.changed = true;
}
public void syncIfChanged(Collection<ServerPlayer> players) {
if (!changed) {
return;
}
var buf = PacketByteBufs.create();
serialize(buf);
ServerPlayNetworking.send(players, ErisAlchemyRegistry.NetworkingConstants.UPDATE_SYNCED_VALUE, buf);
changed = false;
}
private void readData(FriendlyByteBuf buf) {
this.changed = false;
this.value = read(buf);
}
private static long nextId = 0;
private static long genId() {
return nextId++;
}
static {
if (MinecraftQuiltLoader.getEnvironmentType() == EnvType.CLIENT) {
ClientPlayNetworking.registerGlobalReceiver(
ErisAlchemyRegistry.NetworkingConstants.UPDATE_SYNCED_VALUE,
(client, handler, buf, responseSender) -> {
var id = buf.readLongLE();
var ref = values.get(id);
var holder = ref == null ? null : ref.get();
if (holder != null) {
holder.readData(buf);
}
}
);
}
}
public static final class SyncedDouble extends SyncedValue<Double> {
public SyncedDouble(double value) {
super(value);
}
public SyncedDouble(long id, double value) {
super(id, value);
}
public static SyncedDouble deserialize(FriendlyByteBuf buf) {
var id = buf.readLongLE();
var value = buf.readDoubleLE();
return new SyncedDouble(id, value);
}
@Nonnull
@Override
protected Double read(FriendlyByteBuf buf) {
return buf.readDoubleLE();
}
@Override
protected void write(FriendlyByteBuf buf, @Nonnull Double value) {
buf.writeDoubleLE(value);
}
}
}
|
