v1.3.7 — END_DATA_PACK_RELOAD 훅 추가로 /reload 직후 false negative 회피

v1.3.6 에서 SERVER_STARTED + JOIN + ServerTick 셋에 presence pulse 를
달았지만 한 케이스가 남아 있었음:

데이터팩의 load.mcfunction 이 /reload 때마다 mq_chat_mod objective 를
remove/add 하고 #server 점수를 0 으로 재설정. 그런데 tick 이벤트가
죽은 호스트 + 이미 접속 중인 플레이어 조합이면 SERVER_STARTED 도
JOIN 도 발화 안 되어 reload 후 영영 다시 1 로 안 올라감 → 같은
false negative 가 reload 단위로 재발.

이번 변경:
- Fabric (1216, 2612): ServerLifecycleEvents.END_DATA_PACK_RELOAD
  등록. success=true 일 때만 markModPresence (실패한 reload 는 가드
  통과시키면 안 됨).
- NeoForge (1216): OnDatapackSyncEvent 등록. /reload 끝나면 player=null
  로 한 번 broadcast 되므로 reload 직후 presence 가 다시 찍힘.
- ChatAnswerCore.onDataPackReload 추가 (markModPresence + 진단 log).

v1.3.6 jar 는 retire — 사용자 환경이 /reload 기반 워크플로라 reload
케이스 fix 가 필수.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

build.gradle

@@ -63,11 +63,17 @@ tasks.register('containerJar', Jar) {
         }
     }
 
-    // 3. Fabric nested jars (Fabric Loader 가 META-INF/jars/ 를 스캔해서
-    //    depends.minecraft 매칭되는 jar 만 활성화).
+    // 3. Fabric nested jars. Fabric Loader 는 META-INF/jars/ 를 자동 스캔하지
+    //    않고 outer fabric.mod.json 의 "jars" 배열에 명시된 파일만 처리하므로,
+    //    container-resources/fabric.mod.json 의 jars 항목과 일치하는 고정 파일명
+    //    (버전 suffix 제거) 으로 넣는다.
     into('META-INF/jars') {
-        from project(':fabric-1216').tasks.named('remapJar').flatMap { it.archiveFile }
-        from project(':fabric-2612').tasks.named('remapJar').flatMap { it.archiveFile }
+        from(project(':fabric-1216').tasks.named('remapJar').flatMap { it.archiveFile }) {
+            rename '.+\\.jar', 'chat_answer-fabric-1216.jar'
+        }
+        from(project(':fabric-2612').tasks.named('remapJar').flatMap { it.archiveFile }) {
+            rename '.+\\.jar', 'chat_answer-fabric-2612.jar'
+        }
     }
 }
 

common/src/main/java/kr/tkrmagid/chatanswer/core/ChatAnswerCore.java

@@ -1,5 +1,9 @@
 package kr.tkrmagid.chatanswer.core;
 
+import java.util.Iterator;
+import java.util.Map;
+import java.util.UUID;
+import java.util.concurrent.ConcurrentHashMap;
 import net.minecraft.commands.CommandSourceStack;
 import net.minecraft.server.MinecraftServer;
 import net.minecraft.server.level.ServerPlayer;
@@ -29,25 +33,104 @@ public final class ChatAnswerCore {
     private static final String SCOREBOARD_HOLDER = "init";
     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 를 받을 준비가 안 됐을 수 있어
+     *  tellraw 패킷이 사라지는 경우가 있다. 그래서 N 틱 늦춰서 호출한다. */
+    private static final int NOTICE_DELAY_TICKS = 20;
+    private static final Map<UUID, Integer> PENDING_NOTICES = new ConcurrentHashMap<>();
+
     private ChatAnswerCore() {}
 
     /**
-     * 플레이어 로그인 직후 호출. 데이터팩이 "모드 살아있음" 신호로 쓸 수 있게
-     * storage chat_answer:status 에 active=1b 를 세팅한다. 데이터팩의 mq:load 가
-     * 매 /reload 와 서버 시작 시 이 값을 0b 로 clear 하므로, 모드가 없으면 이
-     * 호출이 일어나지 않아 0b 로 유지되고, 모드가 있으면 첫 로그인 직후 1b 로 갱신.
+     * 플레이어 로그인 시점에 호출. 음악퀴즈 데이터팩의
+     *   mq:players/mod_active_notice
+     * 함수를 해당 플레이어 컨텍스트로 호출한다. 단, JOIN 이벤트가 너무 일러서
+     * 즉시 호출 시 tellraw 가 클라이언트에 도달하지 못하는 race 가 있어
+     * {@link #NOTICE_DELAY_TICKS} 만큼 늦춘다 ({@link #onServerTick} 가 처리).
      */
     public static void onPlayerJoin(ServerPlayer player) {
+        String name = player.getName().getString();
+        LOG.info("[{}] onPlayerJoin fired for {}, scheduling notice in {} ticks",
+                MOD_ID, name, NOTICE_DELAY_TICKS);
+        PENDING_NOTICES.put(player.getUUID(), NOTICE_DELAY_TICKS);
+        // tick 이벤트가 안 들어오는 호스트 대비 — join 시점에도 presence 한 번 찍는다.
         MinecraftServer server = player.level().getServer();
-        if (server == null) return;
-        CommandSourceStack source = server.createCommandSourceStack().withSuppressedOutput();
+        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 마다 호출해야 한다. */
+    public static void onServerTick(MinecraftServer server) {
+        markModPresence(server);
+        if (PENDING_NOTICES.isEmpty()) return;
+        Iterator<Map.Entry<UUID, Integer>> it = PENDING_NOTICES.entrySet().iterator();
+        while (it.hasNext()) {
+            Map.Entry<UUID, Integer> e = it.next();
+            int remaining = e.getValue() - 1;
+            if (remaining > 0) {
+                e.setValue(remaining);
+                continue;
+            }
+            UUID uuid = e.getKey();
+            it.remove();
+            ServerPlayer player = server.getPlayerList().getPlayer(uuid);
+            if (player == null) continue;
+            deliverNotice(server, player);
+        }
+    }
+
+    /**
+     * 데이터팩의 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) {
+        String name = player.getName().getString();
+        // 플레이어 자체를 source 로 써서 함수 안의 @s 가 그대로 player.
+        CommandSourceStack source = player.createCommandSourceStack().withSuppressedOutput();
         try {
-            server.getCommands().performPrefixedCommand(
-                source,
-                "data modify storage chat_answer:status active set value 1b"
-            );
+            server.getCommands().performPrefixedCommand(source, "function mq:players/mod_active_notice");
+            LOG.info("[{}] mod_active_notice delivered for {}", MOD_ID, name);
         } catch (Exception e) {
-            LOG.debug("[{}] failed to set active flag: {}", MOD_ID, e.toString());
+            LOG.warn("[{}] failed to deliver mod_active_notice for {}: {}", MOD_ID, name, e.toString(), e);
         }
     }
 

container-resources/fabric.mod.json

@@ -8,6 +8,10 @@
   "license": "MIT",
   "icon": "assets/chat_answer/icon.png",
   "environment": "*",
+  "jars": [
+    { "file": "META-INF/jars/chat_answer-fabric-1216.jar" },
+    { "file": "META-INF/jars/chat_answer-fabric-2612.jar" }
+  ],
   "depends": {
     "fabricloader": ">=0.16.0",
     "java": ">=21"

fabric-1216/src/main/java/kr/tkrmagid/chatanswer/fabric/ChatAnswerFabric.java

@@ -2,17 +2,35 @@ package kr.tkrmagid.chatanswer.fabric;
 
 import kr.tkrmagid.chatanswer.core.ChatAnswerCore;
 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.message.v1.ServerMessageEvents;
 import net.fabricmc.fabric.api.networking.v1.ServerPlayConnectionEvents;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public final class ChatAnswerFabric implements ModInitializer {
+    private static final Logger LOG = LoggerFactory.getLogger(ChatAnswerCore.MOD_ID);
+
     @Override
     public void onInitialize() {
-        ServerMessageEvents.ALLOW_CHAT_MESSAGE.register((message, sender, params) ->
-            ChatAnswerCore.handleChat(sender, message.signedContent())
-        );
-        ServerPlayConnectionEvents.JOIN.register((handler, sender, server) ->
-            ChatAnswerCore.onPlayerJoin(handler.player)
-        );
+        LOG.info("[{}] Fabric entrypoint onInitialize starting", ChatAnswerCore.MOD_ID);
+        try {
+            ServerMessageEvents.ALLOW_CHAT_MESSAGE.register((message, sender, params) ->
+                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) ->
+                ChatAnswerCore.onPlayerJoin(handler.player)
+            );
+            ServerTickEvents.END_SERVER_TICK.register(ChatAnswerCore::onServerTick);
+            LOG.info("[{}] Fabric entrypoint registered: ALLOW_CHAT_MESSAGE + SERVER_STARTED + END_DATA_PACK_RELOAD + JOIN + TICK", ChatAnswerCore.MOD_ID);
+        } catch (Throwable t) {
+            LOG.error("[{}] Fabric entrypoint event registration failed", ChatAnswerCore.MOD_ID, t);
+            throw t;
+        }
     }
 }

fabric-2612/src/main/java/kr/tkrmagid/chatanswer/fabric/ChatAnswerFabric.java

@@ -2,17 +2,35 @@ package kr.tkrmagid.chatanswer.fabric;
 
 import kr.tkrmagid.chatanswer.core.ChatAnswerCore;
 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.message.v1.ServerMessageEvents;
 import net.fabricmc.fabric.api.networking.v1.ServerPlayConnectionEvents;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public final class ChatAnswerFabric implements ModInitializer {
+    private static final Logger LOG = LoggerFactory.getLogger(ChatAnswerCore.MOD_ID);
+
     @Override
     public void onInitialize() {
-        ServerMessageEvents.ALLOW_CHAT_MESSAGE.register((message, sender, params) ->
-            ChatAnswerCore.handleChat(sender, message.signedContent())
-        );
-        ServerPlayConnectionEvents.JOIN.register((handler, sender, server) ->
-            ChatAnswerCore.onPlayerJoin(handler.player)
-        );
+        LOG.info("[{}] Fabric entrypoint onInitialize starting", ChatAnswerCore.MOD_ID);
+        try {
+            ServerMessageEvents.ALLOW_CHAT_MESSAGE.register((message, sender, params) ->
+                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) ->
+                ChatAnswerCore.onPlayerJoin(handler.player)
+            );
+            ServerTickEvents.END_SERVER_TICK.register(ChatAnswerCore::onServerTick);
+            LOG.info("[{}] Fabric entrypoint registered: ALLOW_CHAT_MESSAGE + SERVER_STARTED + END_DATA_PACK_RELOAD + JOIN + TICK", ChatAnswerCore.MOD_ID);
+        } catch (Throwable t) {
+            LOG.error("[{}] Fabric entrypoint event registration failed", ChatAnswerCore.MOD_ID, t);
+            throw t;
+        }
     }
 }

gradle.properties

@@ -3,7 +3,7 @@ org.gradle.parallel=true
 
 # ───── mod metadata ─────────────────────────────────────────────────────────
 mod_id=chat_answer
-mod_version=1.3.0
+mod_version=1.3.7
 mod_group=kr.tkrmagid.chatanswer
 mod_name=채팅정답
 

neoforge-1216/src/main/java/kr/tkrmagid/chatanswer/neoforge/ChatAnswerNeoForge.java

@@ -6,14 +6,20 @@ import net.neoforged.bus.api.IEventBus;
 import net.neoforged.bus.api.SubscribeEvent;
 import net.neoforged.fml.common.Mod;
 import net.neoforged.neoforge.common.NeoForge;
+import net.neoforged.neoforge.event.OnDatapackSyncEvent;
 import net.neoforged.neoforge.event.ServerChatEvent;
 import net.neoforged.neoforge.event.entity.player.PlayerEvent;
+import net.neoforged.neoforge.event.server.ServerStartedEvent;
+import net.neoforged.neoforge.event.tick.ServerTickEvent;
 
 @Mod(ChatAnswerCore.MOD_ID)
 public final class ChatAnswerNeoForge {
     public ChatAnswerNeoForge(IEventBus modBus) {
         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::onServerTick);
     }
 
     @SubscribeEvent
@@ -24,10 +30,28 @@ 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
     public static void onPlayerLogin(PlayerEvent.PlayerLoggedInEvent event) {
         if (event.getEntity() instanceof ServerPlayer player) {
             ChatAnswerCore.onPlayerJoin(player);
         }
     }
+
+    @SubscribeEvent
+    public static void onServerTick(ServerTickEvent.Post event) {
+        ChatAnswerCore.onServerTick(event.getServer());
+    }
 }