Compare commits
5 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8540d693a0 | ||
|
|
48d73daaf7 | ||
|
|
5aaa3c2ace | ||
|
|
41fcc82953 | ||
|
|
8057fa1112 |
@@ -33,6 +33,21 @@ public final class ChatAnswerCore {
|
|||||||
private static final String SCOREBOARD_HOLDER = "init";
|
private static final String SCOREBOARD_HOLDER = "init";
|
||||||
private static final int ACCEPTING_ANSWER_STATE = 5;
|
private static final int ACCEPTING_ANSWER_STATE = 5;
|
||||||
|
|
||||||
|
/** 음악퀴즈 데이터팩이 선언한 "모드 존재 확인" 점수 이름.
|
||||||
|
* 본 모드는 서버 측에서 채팅을 가로채는 server-only 모드 — 클라이언트는
|
||||||
|
* 설치할 필요가 없고 server 한 곳에 있으면 모든 플레이어에게 적용된다.
|
||||||
|
* 따라서 per-player 검증은 무의미하고, fake player {@link #PRESENCE_HOLDER}
|
||||||
|
* 점수만 1 로 set 한다. 데이터팩의 start 가드는
|
||||||
|
* `score <PRESENCE_HOLDER> <OBJECTIVE> matches 1` 로 검사.
|
||||||
|
*
|
||||||
|
* presence pulse 는 여러 이벤트에서 중복 호출한다 — banner/mohist 같은
|
||||||
|
* fabric-bukkit 하이브리드 호스트에서 일부 Fabric 이벤트(특히
|
||||||
|
* ServerTickEvents.END_SERVER_TICK) 가 안 들어오는 케이스가 보고됨.
|
||||||
|
* SERVER_STARTED / PlayerJoin / TickEnd 셋 중 하나라도 firing 되면
|
||||||
|
* 데이터팩 가드가 통과하도록 모든 진입점에서 markModPresence 호출. */
|
||||||
|
private static final String MOD_PRESENCE_OBJECTIVE = "mq_chat_mod";
|
||||||
|
private static final String PRESENCE_HOLDER = "#server";
|
||||||
|
|
||||||
/** JOIN 이벤트 시점엔 클라이언트가 chat HUD 를 받을 준비가 안 됐을 수 있어
|
/** JOIN 이벤트 시점엔 클라이언트가 chat HUD 를 받을 준비가 안 됐을 수 있어
|
||||||
* tellraw 패킷이 사라지는 경우가 있다. 그래서 N 틱 늦춰서 호출한다. */
|
* tellraw 패킷이 사라지는 경우가 있다. 그래서 N 틱 늦춰서 호출한다. */
|
||||||
private static final int NOTICE_DELAY_TICKS = 20;
|
private static final int NOTICE_DELAY_TICKS = 20;
|
||||||
@@ -52,10 +67,31 @@ public final class ChatAnswerCore {
|
|||||||
LOG.info("[{}] onPlayerJoin fired for {}, scheduling notice in {} ticks",
|
LOG.info("[{}] onPlayerJoin fired for {}, scheduling notice in {} ticks",
|
||||||
MOD_ID, name, NOTICE_DELAY_TICKS);
|
MOD_ID, name, NOTICE_DELAY_TICKS);
|
||||||
PENDING_NOTICES.put(player.getUUID(), NOTICE_DELAY_TICKS);
|
PENDING_NOTICES.put(player.getUUID(), NOTICE_DELAY_TICKS);
|
||||||
|
// tick 이벤트가 안 들어오는 호스트 대비 — join 시점에도 presence 한 번 찍는다.
|
||||||
|
MinecraftServer server = player.level().getServer();
|
||||||
|
if (server != null) markModPresence(server);
|
||||||
|
}
|
||||||
|
|
||||||
|
/** 각 로더 entrypoint 가 서버 부팅 완료 시점에 호출. tick 이벤트가
|
||||||
|
* 발화되지 않는 환경(banner/mohist) 에서 최소 한 번은 presence 가 찍히도록.
|
||||||
|
* 데이터팩 load 가 SERVER_STARTED 보다 먼저 끝나므로 objective 도 이미 존재. */
|
||||||
|
public static void onServerStarted(MinecraftServer server) {
|
||||||
|
LOG.info("[{}] onServerStarted fired, marking presence", MOD_ID);
|
||||||
|
markModPresence(server);
|
||||||
|
}
|
||||||
|
|
||||||
|
/** /reload 직후 호출. load.mcfunction 이 mq_chat_mod objective 를 remove/add
|
||||||
|
* 하고 `#server` 점수를 0 으로 재설정하므로, reload 끝난 직후 즉시
|
||||||
|
* 다시 1 로 찍어야 함. tick 이벤트가 죽은 호스트 + 이미 접속 중인
|
||||||
|
* 플레이어 조합에서 SERVER_STARTED/JOIN 둘 다 발화 안 되는 케이스 커버. */
|
||||||
|
public static void onDataPackReload(MinecraftServer server) {
|
||||||
|
LOG.info("[{}] onDataPackReload fired, re-marking presence", MOD_ID);
|
||||||
|
markModPresence(server);
|
||||||
}
|
}
|
||||||
|
|
||||||
/** 각 로더 entrypoint 가 매 server tick 마다 호출해야 한다. */
|
/** 각 로더 entrypoint 가 매 server tick 마다 호출해야 한다. */
|
||||||
public static void onServerTick(MinecraftServer server) {
|
public static void onServerTick(MinecraftServer server) {
|
||||||
|
markModPresence(server);
|
||||||
if (PENDING_NOTICES.isEmpty()) return;
|
if (PENDING_NOTICES.isEmpty()) return;
|
||||||
Iterator<Map.Entry<UUID, Integer>> it = PENDING_NOTICES.entrySet().iterator();
|
Iterator<Map.Entry<UUID, Integer>> it = PENDING_NOTICES.entrySet().iterator();
|
||||||
while (it.hasNext()) {
|
while (it.hasNext()) {
|
||||||
@@ -73,6 +109,19 @@ public final class ChatAnswerCore {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 데이터팩의 mq_chat_mod 점수(fake player #server 키) 를 1 로 set.
|
||||||
|
* 데이터팩이 아직 load 되지 않아 objective 가 없으면 조용히 skip.
|
||||||
|
* 점수 값이 이미 1 이면 Minecraft 가 packet 전송을 생략하므로
|
||||||
|
* 매 tick 호출해도 트래픽은 늘지 않는다.
|
||||||
|
*/
|
||||||
|
private static void markModPresence(MinecraftServer server) {
|
||||||
|
Scoreboard scoreboard = server.getScoreboard();
|
||||||
|
Objective objective = scoreboard.getObjective(MOD_PRESENCE_OBJECTIVE);
|
||||||
|
if (objective == null) return;
|
||||||
|
scoreboard.getOrCreatePlayerScore(ScoreHolder.forNameOnly(PRESENCE_HOLDER), objective).set(1);
|
||||||
|
}
|
||||||
|
|
||||||
private static void deliverNotice(MinecraftServer server, ServerPlayer player) {
|
private static void deliverNotice(MinecraftServer server, ServerPlayer player) {
|
||||||
String name = player.getName().getString();
|
String name = player.getName().getString();
|
||||||
// 플레이어 자체를 source 로 써서 함수 안의 @s 가 그대로 player.
|
// 플레이어 자체를 source 로 써서 함수 안의 @s 가 그대로 player.
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ package kr.tkrmagid.chatanswer.fabric;
|
|||||||
|
|
||||||
import kr.tkrmagid.chatanswer.core.ChatAnswerCore;
|
import kr.tkrmagid.chatanswer.core.ChatAnswerCore;
|
||||||
import net.fabricmc.api.ModInitializer;
|
import net.fabricmc.api.ModInitializer;
|
||||||
|
import net.fabricmc.fabric.api.event.lifecycle.v1.ServerLifecycleEvents;
|
||||||
import net.fabricmc.fabric.api.event.lifecycle.v1.ServerTickEvents;
|
import net.fabricmc.fabric.api.event.lifecycle.v1.ServerTickEvents;
|
||||||
import net.fabricmc.fabric.api.message.v1.ServerMessageEvents;
|
import net.fabricmc.fabric.api.message.v1.ServerMessageEvents;
|
||||||
import net.fabricmc.fabric.api.networking.v1.ServerPlayConnectionEvents;
|
import net.fabricmc.fabric.api.networking.v1.ServerPlayConnectionEvents;
|
||||||
@@ -18,11 +19,15 @@ public final class ChatAnswerFabric implements ModInitializer {
|
|||||||
ServerMessageEvents.ALLOW_CHAT_MESSAGE.register((message, sender, params) ->
|
ServerMessageEvents.ALLOW_CHAT_MESSAGE.register((message, sender, params) ->
|
||||||
ChatAnswerCore.handleChat(sender, message.signedContent())
|
ChatAnswerCore.handleChat(sender, message.signedContent())
|
||||||
);
|
);
|
||||||
|
ServerLifecycleEvents.SERVER_STARTED.register(ChatAnswerCore::onServerStarted);
|
||||||
|
ServerLifecycleEvents.END_DATA_PACK_RELOAD.register((server, resourceManager, success) -> {
|
||||||
|
if (success) ChatAnswerCore.onDataPackReload(server);
|
||||||
|
});
|
||||||
ServerPlayConnectionEvents.JOIN.register((handler, sender, server) ->
|
ServerPlayConnectionEvents.JOIN.register((handler, sender, server) ->
|
||||||
ChatAnswerCore.onPlayerJoin(handler.player)
|
ChatAnswerCore.onPlayerJoin(handler.player)
|
||||||
);
|
);
|
||||||
ServerTickEvents.END_SERVER_TICK.register(ChatAnswerCore::onServerTick);
|
ServerTickEvents.END_SERVER_TICK.register(ChatAnswerCore::onServerTick);
|
||||||
LOG.info("[{}] Fabric entrypoint registered: ALLOW_CHAT_MESSAGE + JOIN + TICK", ChatAnswerCore.MOD_ID);
|
LOG.info("[{}] Fabric entrypoint registered: ALLOW_CHAT_MESSAGE + SERVER_STARTED + END_DATA_PACK_RELOAD + JOIN + TICK", ChatAnswerCore.MOD_ID);
|
||||||
} catch (Throwable t) {
|
} catch (Throwable t) {
|
||||||
LOG.error("[{}] Fabric entrypoint event registration failed", ChatAnswerCore.MOD_ID, t);
|
LOG.error("[{}] Fabric entrypoint event registration failed", ChatAnswerCore.MOD_ID, t);
|
||||||
throw t;
|
throw t;
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ package kr.tkrmagid.chatanswer.fabric;
|
|||||||
|
|
||||||
import kr.tkrmagid.chatanswer.core.ChatAnswerCore;
|
import kr.tkrmagid.chatanswer.core.ChatAnswerCore;
|
||||||
import net.fabricmc.api.ModInitializer;
|
import net.fabricmc.api.ModInitializer;
|
||||||
|
import net.fabricmc.fabric.api.event.lifecycle.v1.ServerLifecycleEvents;
|
||||||
import net.fabricmc.fabric.api.event.lifecycle.v1.ServerTickEvents;
|
import net.fabricmc.fabric.api.event.lifecycle.v1.ServerTickEvents;
|
||||||
import net.fabricmc.fabric.api.message.v1.ServerMessageEvents;
|
import net.fabricmc.fabric.api.message.v1.ServerMessageEvents;
|
||||||
import net.fabricmc.fabric.api.networking.v1.ServerPlayConnectionEvents;
|
import net.fabricmc.fabric.api.networking.v1.ServerPlayConnectionEvents;
|
||||||
@@ -18,11 +19,15 @@ public final class ChatAnswerFabric implements ModInitializer {
|
|||||||
ServerMessageEvents.ALLOW_CHAT_MESSAGE.register((message, sender, params) ->
|
ServerMessageEvents.ALLOW_CHAT_MESSAGE.register((message, sender, params) ->
|
||||||
ChatAnswerCore.handleChat(sender, message.signedContent())
|
ChatAnswerCore.handleChat(sender, message.signedContent())
|
||||||
);
|
);
|
||||||
|
ServerLifecycleEvents.SERVER_STARTED.register(ChatAnswerCore::onServerStarted);
|
||||||
|
ServerLifecycleEvents.END_DATA_PACK_RELOAD.register((server, resourceManager, success) -> {
|
||||||
|
if (success) ChatAnswerCore.onDataPackReload(server);
|
||||||
|
});
|
||||||
ServerPlayConnectionEvents.JOIN.register((handler, sender, server) ->
|
ServerPlayConnectionEvents.JOIN.register((handler, sender, server) ->
|
||||||
ChatAnswerCore.onPlayerJoin(handler.player)
|
ChatAnswerCore.onPlayerJoin(handler.player)
|
||||||
);
|
);
|
||||||
ServerTickEvents.END_SERVER_TICK.register(ChatAnswerCore::onServerTick);
|
ServerTickEvents.END_SERVER_TICK.register(ChatAnswerCore::onServerTick);
|
||||||
LOG.info("[{}] Fabric entrypoint registered: ALLOW_CHAT_MESSAGE + JOIN + TICK", ChatAnswerCore.MOD_ID);
|
LOG.info("[{}] Fabric entrypoint registered: ALLOW_CHAT_MESSAGE + SERVER_STARTED + END_DATA_PACK_RELOAD + JOIN + TICK", ChatAnswerCore.MOD_ID);
|
||||||
} catch (Throwable t) {
|
} catch (Throwable t) {
|
||||||
LOG.error("[{}] Fabric entrypoint event registration failed", ChatAnswerCore.MOD_ID, t);
|
LOG.error("[{}] Fabric entrypoint event registration failed", ChatAnswerCore.MOD_ID, t);
|
||||||
throw t;
|
throw t;
|
||||||
|
|||||||
@@ -3,7 +3,7 @@ org.gradle.parallel=true
|
|||||||
|
|
||||||
# ───── mod metadata ─────────────────────────────────────────────────────────
|
# ───── mod metadata ─────────────────────────────────────────────────────────
|
||||||
mod_id=chat_answer
|
mod_id=chat_answer
|
||||||
mod_version=1.3.4
|
mod_version=1.3.7
|
||||||
mod_group=kr.tkrmagid.chatanswer
|
mod_group=kr.tkrmagid.chatanswer
|
||||||
mod_name=채팅정답
|
mod_name=채팅정답
|
||||||
|
|
||||||
|
|||||||
@@ -6,14 +6,18 @@ import net.neoforged.bus.api.IEventBus;
|
|||||||
import net.neoforged.bus.api.SubscribeEvent;
|
import net.neoforged.bus.api.SubscribeEvent;
|
||||||
import net.neoforged.fml.common.Mod;
|
import net.neoforged.fml.common.Mod;
|
||||||
import net.neoforged.neoforge.common.NeoForge;
|
import net.neoforged.neoforge.common.NeoForge;
|
||||||
|
import net.neoforged.neoforge.event.OnDatapackSyncEvent;
|
||||||
import net.neoforged.neoforge.event.ServerChatEvent;
|
import net.neoforged.neoforge.event.ServerChatEvent;
|
||||||
import net.neoforged.neoforge.event.entity.player.PlayerEvent;
|
import net.neoforged.neoforge.event.entity.player.PlayerEvent;
|
||||||
|
import net.neoforged.neoforge.event.server.ServerStartedEvent;
|
||||||
import net.neoforged.neoforge.event.tick.ServerTickEvent;
|
import net.neoforged.neoforge.event.tick.ServerTickEvent;
|
||||||
|
|
||||||
@Mod(ChatAnswerCore.MOD_ID)
|
@Mod(ChatAnswerCore.MOD_ID)
|
||||||
public final class ChatAnswerNeoForge {
|
public final class ChatAnswerNeoForge {
|
||||||
public ChatAnswerNeoForge(IEventBus modBus) {
|
public ChatAnswerNeoForge(IEventBus modBus) {
|
||||||
NeoForge.EVENT_BUS.addListener(ChatAnswerNeoForge::onServerChat);
|
NeoForge.EVENT_BUS.addListener(ChatAnswerNeoForge::onServerChat);
|
||||||
|
NeoForge.EVENT_BUS.addListener(ChatAnswerNeoForge::onServerStarted);
|
||||||
|
NeoForge.EVENT_BUS.addListener(ChatAnswerNeoForge::onDatapackSync);
|
||||||
NeoForge.EVENT_BUS.addListener(ChatAnswerNeoForge::onPlayerLogin);
|
NeoForge.EVENT_BUS.addListener(ChatAnswerNeoForge::onPlayerLogin);
|
||||||
NeoForge.EVENT_BUS.addListener(ChatAnswerNeoForge::onServerTick);
|
NeoForge.EVENT_BUS.addListener(ChatAnswerNeoForge::onServerTick);
|
||||||
}
|
}
|
||||||
@@ -26,6 +30,19 @@ public final class ChatAnswerNeoForge {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@SubscribeEvent
|
||||||
|
public static void onServerStarted(ServerStartedEvent event) {
|
||||||
|
ChatAnswerCore.onServerStarted(event.getServer());
|
||||||
|
}
|
||||||
|
|
||||||
|
/** OnDatapackSyncEvent: /reload 끝나면 player=null 로 한 번 broadcast,
|
||||||
|
* 로그인 때마다 해당 player 로 한 번 더 fire. 어느 쪽이든 reload 직후
|
||||||
|
* presence 가 다시 찍히는 것이 목적이라 둘 다 OK. */
|
||||||
|
@SubscribeEvent
|
||||||
|
public static void onDatapackSync(OnDatapackSyncEvent event) {
|
||||||
|
ChatAnswerCore.onDataPackReload(event.getPlayerList().getServer());
|
||||||
|
}
|
||||||
|
|
||||||
@SubscribeEvent
|
@SubscribeEvent
|
||||||
public static void onPlayerLogin(PlayerEvent.PlayerLoggedInEvent event) {
|
public static void onPlayerLogin(PlayerEvent.PlayerLoggedInEvent event) {
|
||||||
if (event.getEntity() instanceof ServerPlayer player) {
|
if (event.getEntity() instanceof ServerPlayer player) {
|
||||||
|
|||||||
Reference in New Issue
Block a user