Compare commits
9 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1913181d02 | ||
|
|
d11289309b | ||
|
|
de723fd0b4 | ||
|
|
e3c25fc845 | ||
|
|
2fc09deb4f | ||
|
|
6e242bb675 | ||
|
|
849e53096c | ||
|
|
c53ebcc30d | ||
|
|
6896870186 |
1
.gitignore
vendored
1
.gitignore
vendored
@@ -1,5 +1,6 @@
|
||||
.gradle/
|
||||
build/
|
||||
dist/
|
||||
out/
|
||||
.idea/
|
||||
.vscode/
|
||||
|
||||
20
README.md
20
README.md
@@ -3,7 +3,7 @@
|
||||
마인크래프트 안에서 임의의 동영상 URL을 벽·바닥·천장에 평면으로 재생하는 Fabric 모드.
|
||||
|
||||
- 모드 ID: `video_player`
|
||||
- 현재 버전: **0.4.11**
|
||||
- 현재 버전: **0.4.12**
|
||||
- 마인크래프트 버전: **26.1.2**
|
||||
- 필요 Java: **25** (마인크래프트 26.x 가 요구함)
|
||||
|
||||
@@ -51,23 +51,23 @@ Fabric은 마인크래프트에 모드 기능을 추가해 주는 로더입니
|
||||
https://cdn.modrinth.com/data/P7dR8mSH/versions/Sy2Bq7Xc/fabric-api-0.149.0%2B26.1.2.jar
|
||||
- 더 최신 빌드를 찾을 땐: https://modrinth.com/mod/fabric-api/versions → 페이지에서 게임 버전 필터 `26.1.2` 를 직접 선택. (URL 파라미터 필터가 듣지 않는 경우가 있어서 페이지 안에서 한 번 더 확인하는 게 안전합니다.)
|
||||
- 받은 `fabric-api-0.149.0+26.1.2.jar` 를 `mods` 폴더에 넣습니다.
|
||||
2. **video_player** (이 모드, 0.4.11 부터 JavaCV 가 jar 안에 포함됨)
|
||||
2. **video_player** (이 모드, 0.4.12 부터 JavaCV 가 jar 안에 포함됨)
|
||||
- 다운로드: https://git.tkrmagid.kr/tkrmagid/mc_video_player_mod/releases
|
||||
- 자신의 OS·CPU 에 맞는 jar **한 개** 만 받아서 `mods` 폴더에 넣으면 됩니다 (별도 JavaCV 설치 불필요):
|
||||
- Windows 64bit: `video_player-windows-x86_64-0.4.11.jar` (~32MB)
|
||||
- macOS Intel: `video_player-macosx-x86_64-0.4.11.jar` (~24MB)
|
||||
- macOS Apple Silicon (M1/M2/M3/M4): `video_player-macosx-arm64-0.4.11.jar` (~21MB)
|
||||
- Linux 64bit: `video_player-linux-x86_64-0.4.11.jar` (~27MB)
|
||||
- Windows 64bit: `video_player-windows-x86_64-0.4.12.jar` (~32MB)
|
||||
- macOS Intel: `video_player-macosx-x86_64-0.4.12.jar` (~24MB)
|
||||
- macOS Apple Silicon (M1/M2/M3/M4): `video_player-macosx-arm64-0.4.12.jar` (~21MB)
|
||||
- Linux 64bit: `video_player-linux-x86_64-0.4.12.jar` (~27MB)
|
||||
- 자기 OS 가 헷갈리면: Windows 는 거의 다 `windows-x86_64`, 인텔맥은 `macosx-x86_64`, 애플 실리콘 맥은 `macosx-arm64`, 리눅스는 `linux-x86_64`.
|
||||
|
||||
이전 버전(`video_player-0.4.0.jar`, `0.4.2.jar`, `0.4.3.jar`, `0.3.x.jar` 등)이 mods 폴더에 남아있다면 **반드시 삭제**하세요. 두 개가 같이 있으면 마인크래프트가 충돌로 켜지지 않습니다. 0.4.7 이하에서 쓰던 JVM 인수(`-Xbootclasspath/a:...javacv...`) 도 0.4.11 부터는 **빼주세요** — 모드 jar 안에 같은 JavaCV 가 들어있어서 부트클래스패스의 것과 충돌해 검은 화면이 날 수 있습니다.
|
||||
이전 버전(`video_player-0.4.0.jar`, `0.4.2.jar`, `0.4.3.jar`, `0.3.x.jar` 등)이 mods 폴더에 남아있다면 **반드시 삭제**하세요. 두 개가 같이 있으면 마인크래프트가 충돌로 켜지지 않습니다. 0.4.7 이하에서 쓰던 JVM 인수(`-Xbootclasspath/a:...javacv...`) 도 0.4.12 부터는 **빼주세요** — 모드 jar 안에 같은 JavaCV 가 들어있어서 부트클래스패스의 것과 충돌해 검은 화면이 날 수 있습니다.
|
||||
|
||||
### STEP 5. 잘 설치됐는지 확인
|
||||
|
||||
게임 안에서 채팅창에 `/videostick` 을 입력하세요. 정상이라면:
|
||||
|
||||
- 인벤토리에 **비디오 스틱** 아이템이 들어옵니다 (보라/검정 missing-texture 가 아니라 작대기 모양 아이콘).
|
||||
- 보라/검정 missing texture 가 나오면 **STEP 4** 에서 이전 버전 jar(`video_player-0.4.0.jar` / `0.4.1.jar` 등)가 mods 폴더에 같이 남아있는 경우입니다. 다 지우고 `0.4.11` 만 남기고 다시 시작하세요. (0.4.1 이하는 Fabric 26.1.2 model 로더가 unprefixed `item/generated` parent 를 거부해서 스틱 아이콘이 missing-model 큐브로 보입니다 — 0.4.2 에서 수정됨.)
|
||||
- 보라/검정 missing texture 가 나오면 **STEP 4** 에서 이전 버전 jar(`video_player-0.4.0.jar` / `0.4.1.jar` 등)가 mods 폴더에 같이 남아있는 경우입니다. 다 지우고 `0.4.12` 만 남기고 다시 시작하세요. (0.4.1 이하는 Fabric 26.1.2 model 로더가 unprefixed `item/generated` parent 를 거부해서 스틱 아이콘이 missing-model 큐브로 보입니다 — 0.4.2 에서 수정됨.)
|
||||
|
||||
---
|
||||
|
||||
@@ -172,7 +172,7 @@ Fabric은 마인크래프트에 모드 기능을 추가해 주는 로더입니
|
||||
```sh
|
||||
JAVA_HOME=/usr/lib/jvm/java-25-openjdk-amd64 ./gradlew build
|
||||
```
|
||||
산출물: `build/libs/video_player-0.4.11.jar` (~85KB)
|
||||
산출물: `build/libs/video_player-0.4.12.jar` (~85KB)
|
||||
|
||||
플랫폼별 fat jar (JavaCV 1.5.13 + ffmpeg 8.0.1 네이티브 nested):
|
||||
```sh
|
||||
@@ -181,7 +181,7 @@ JAVA_HOME=/usr/lib/jvm/java-25-openjdk-amd64 ./gradlew clean build -Pplatform=li
|
||||
JAVA_HOME=/usr/lib/jvm/java-25-openjdk-amd64 ./gradlew clean build -Pplatform=macosx-x86_64
|
||||
JAVA_HOME=/usr/lib/jvm/java-25-openjdk-amd64 ./gradlew clean build -Pplatform=macosx-arm64
|
||||
```
|
||||
산출물: `build/libs/video_player-<platform>-0.4.11.jar` (~21-32MB, jar 내부에 nested 로 javacv/javacpp/ffmpeg jar 5개 포함, Fabric loader 가 런타임에 classpath 로 풀어서 로딩)
|
||||
산출물: `build/libs/video_player-<platform>-0.4.12.jar` (~21-32MB, jar 내부에 nested 로 javacv/javacpp/ffmpeg jar 5개 포함, Fabric loader 가 런타임에 classpath 로 풀어서 로딩)
|
||||
|
||||
JavaCV를 직접 의존성으로 가져오는 경우의 Maven 좌표:
|
||||
```
|
||||
|
||||
@@ -5,7 +5,7 @@ org.gradle.configuration-cache=false
|
||||
|
||||
# Mod
|
||||
mod_id=video_player
|
||||
mod_version=0.4.11
|
||||
mod_version=0.4.20
|
||||
maven_group=com.ejclaw.videoplayer
|
||||
archives_base_name=video_player
|
||||
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
package com.ejclaw.videoplayer;
|
||||
|
||||
import com.ejclaw.videoplayer.block.VideoAnchorBlockEntity;
|
||||
import com.ejclaw.videoplayer.client.MusicQuizClient;
|
||||
import com.ejclaw.videoplayer.client.net.ClientNetworking;
|
||||
import com.ejclaw.videoplayer.client.playback.VideoPlayback;
|
||||
import com.ejclaw.videoplayer.client.render.VideoAnchorRenderer;
|
||||
@@ -28,6 +29,7 @@ public class VideoPlayerClient implements ClientModInitializer {
|
||||
@Override
|
||||
public void onInitializeClient() {
|
||||
ClientNetworking.register();
|
||||
MusicQuizClient.register();
|
||||
|
||||
BlockEntityRendererRegistry.register(
|
||||
VideoPlayerBlockEntities.VIDEO_ANCHOR,
|
||||
|
||||
@@ -2,6 +2,8 @@ package com.ejclaw.videoplayer;
|
||||
|
||||
import com.google.gson.Gson;
|
||||
import com.google.gson.GsonBuilder;
|
||||
import com.google.gson.JsonArray;
|
||||
import com.google.gson.JsonElement;
|
||||
import com.google.gson.JsonObject;
|
||||
import com.google.gson.JsonParser;
|
||||
import net.fabricmc.loader.api.FabricLoader;
|
||||
@@ -12,88 +14,314 @@ import java.nio.file.Files;
|
||||
import java.nio.file.Path;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Collections;
|
||||
import java.util.LinkedHashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* Server-side mod config, stored at {@code <gameDir>/config/video_player.json}.
|
||||
*
|
||||
* <p>Format (auto-generated on first start):
|
||||
* <p>Schema (auto-generated on first start):
|
||||
* <pre>{@code
|
||||
* {
|
||||
* // List of HTTP(S) video URLs that the server will tell every player to preload
|
||||
* // into their local video_player_cache/ folder when they join. Identical to running
|
||||
* // /videopreload <url> for each joining player.
|
||||
* "max_preload_mb": 1024,
|
||||
* "preload_urls": [
|
||||
* "https://example.com/intro.mp4"
|
||||
* ],
|
||||
* "cache_entries": [
|
||||
* { "name": "intro", "url": "https://example.com/intro.mp4" }
|
||||
* ]
|
||||
* }
|
||||
* }</pre>
|
||||
*
|
||||
* <p>Why a list and not a dedicated tool: the same {@link
|
||||
* com.ejclaw.videoplayer.net.PreloadPayload} that powers {@code /videopreload} is reused, so the
|
||||
* client-side cache, chat feedback, and {@code /videoplace} → cache lookup paths all behave
|
||||
* identically for config-driven and command-driven preloads.
|
||||
* <p>{@code max_preload_mb} is the hard ceiling each client enforces on a single video download
|
||||
* (default 1024 MB ≈ 1 GB; enough headroom for ~50 short FHD clips). Pushed to every client on
|
||||
* join via {@link com.ejclaw.videoplayer.net.CachePolicyPayload}.
|
||||
*
|
||||
* <p>{@code cache_entries} is the named cache index managed by {@code /videocache add|list|remove}.
|
||||
* Each entry's URL is pushed to clients on join (and immediately on {@code add}). Names are unique.
|
||||
*
|
||||
* <p>{@code preload_urls} is the legacy un-named auto-preload list — same behavior as
|
||||
* {@code cache_entries} but without a removable handle. Kept for backward-compat.
|
||||
*/
|
||||
public final class VideoPlayerConfig {
|
||||
private VideoPlayerConfig() {}
|
||||
|
||||
private static final String FILE_NAME = "video_player.json";
|
||||
private static volatile List<String> PRELOAD_URLS = Collections.emptyList();
|
||||
|
||||
/**
|
||||
* Default per-video download cap in MB. Sized to allow a single 4K short clip
|
||||
* (≈25 Mbps × 60 s ≈ 190 MB, with headroom for higher-bitrate sources). Per-video
|
||||
* cap is intentionally separate from the total-cache cap below.
|
||||
*/
|
||||
private static final int DEFAULT_MAX_PRELOAD_MB = 2048;
|
||||
/**
|
||||
* Default total-cache cap in MB. Sized to comfortably fit ~50 short FHD clips:
|
||||
* FHD H.264 at ~5 Mbps × 20 s ≈ 12.5 MB, so 50 × 15 MB ≈ 750 MB with headroom.
|
||||
*/
|
||||
private static final int DEFAULT_MAX_CACHE_MB = 750;
|
||||
/** Default render-distance cap for video anchors, in blocks. 128 = the legacy hard-coded value. */
|
||||
private static final int DEFAULT_RENDER_DISTANCE = 128;
|
||||
|
||||
private static volatile int maxPreloadMb = DEFAULT_MAX_PRELOAD_MB;
|
||||
private static volatile int maxCacheMb = DEFAULT_MAX_CACHE_MB;
|
||||
private static volatile int renderDistanceBlocks = DEFAULT_RENDER_DISTANCE;
|
||||
private static volatile List<String> preloadUrls = Collections.emptyList();
|
||||
/** Insertion-ordered name → url. Mutated only under the class monitor. */
|
||||
private static final Map<String, String> CACHE_ENTRIES = new LinkedHashMap<>();
|
||||
|
||||
/** Load (or create) the config file. Called once during mod initialization. */
|
||||
public static void load() {
|
||||
Path path = FabricLoader.getInstance().getConfigDir().resolve(FILE_NAME);
|
||||
public static synchronized void load() {
|
||||
Path path = configPath();
|
||||
try {
|
||||
if (!Files.exists(path)) {
|
||||
writeDefault(path);
|
||||
VideoPlayerMod.LOG.info("[{}] created default config at {}",
|
||||
VideoPlayerMod.MOD_ID, path);
|
||||
PRELOAD_URLS = Collections.emptyList();
|
||||
maxPreloadMb = DEFAULT_MAX_PRELOAD_MB;
|
||||
maxCacheMb = DEFAULT_MAX_CACHE_MB;
|
||||
preloadUrls = Collections.emptyList();
|
||||
CACHE_ENTRIES.clear();
|
||||
return;
|
||||
}
|
||||
String raw = Files.readString(path, StandardCharsets.UTF_8);
|
||||
JsonObject json = JsonParser.parseString(raw).getAsJsonObject();
|
||||
|
||||
// Track whether any expected key was missing; if so, we rewrite the file at the
|
||||
// end so users don't have to delete their config to pick up new options.
|
||||
boolean augmented = false;
|
||||
|
||||
// max_preload_mb (per-video cap, sanity-clamped to [16, 16384])
|
||||
int cap = DEFAULT_MAX_PRELOAD_MB;
|
||||
if (json.has("max_preload_mb") && json.get("max_preload_mb").isJsonPrimitive()
|
||||
&& json.get("max_preload_mb").getAsJsonPrimitive().isNumber()) {
|
||||
cap = json.get("max_preload_mb").getAsInt();
|
||||
} else {
|
||||
augmented = true;
|
||||
}
|
||||
if (cap < 16) cap = 16;
|
||||
if (cap > 16384) cap = 16384;
|
||||
maxPreloadMb = cap;
|
||||
|
||||
// max_cache_mb (total-cache cap, sanity-clamped to [16, 65536])
|
||||
int total = DEFAULT_MAX_CACHE_MB;
|
||||
if (json.has("max_cache_mb") && json.get("max_cache_mb").isJsonPrimitive()
|
||||
&& json.get("max_cache_mb").getAsJsonPrimitive().isNumber()) {
|
||||
total = json.get("max_cache_mb").getAsInt();
|
||||
} else {
|
||||
augmented = true;
|
||||
}
|
||||
if (total < 16) total = 16;
|
||||
if (total > 65536) total = 65536;
|
||||
maxCacheMb = total;
|
||||
|
||||
// render_distance_blocks (sanity-clamped to [16, 2048])
|
||||
int rd = DEFAULT_RENDER_DISTANCE;
|
||||
if (json.has("render_distance_blocks") && json.get("render_distance_blocks").isJsonPrimitive()
|
||||
&& json.get("render_distance_blocks").getAsJsonPrimitive().isNumber()) {
|
||||
rd = json.get("render_distance_blocks").getAsInt();
|
||||
} else {
|
||||
augmented = true;
|
||||
}
|
||||
if (rd < 16) rd = 16;
|
||||
if (rd > 2048) rd = 2048;
|
||||
renderDistanceBlocks = rd;
|
||||
|
||||
// preload_urls (legacy)
|
||||
List<String> urls = new ArrayList<>();
|
||||
if (json.has("preload_urls") && json.get("preload_urls").isJsonArray()) {
|
||||
json.getAsJsonArray("preload_urls").forEach(el -> {
|
||||
if (el.isJsonPrimitive() && el.getAsJsonPrimitive().isString()) {
|
||||
String u = el.getAsString().trim();
|
||||
if (!u.isEmpty() && (u.startsWith("http://") || u.startsWith("https://"))
|
||||
&& u.length() <= 256) {
|
||||
urls.add(u);
|
||||
} else if (!u.isEmpty()) {
|
||||
VideoPlayerMod.LOG.warn(
|
||||
"[{}] config: ignoring invalid preload url '{}' (must be http/https, ≤256 chars)",
|
||||
VideoPlayerMod.MOD_ID, u);
|
||||
}
|
||||
String u = sanitizeUrl(el.getAsString());
|
||||
if (u != null) urls.add(u);
|
||||
}
|
||||
});
|
||||
}
|
||||
PRELOAD_URLS = Collections.unmodifiableList(urls);
|
||||
VideoPlayerMod.LOG.info("[{}] config loaded: {} preload url(s)",
|
||||
VideoPlayerMod.MOD_ID, urls.size());
|
||||
preloadUrls = Collections.unmodifiableList(urls);
|
||||
|
||||
// cache_entries (named)
|
||||
CACHE_ENTRIES.clear();
|
||||
if (json.has("cache_entries") && json.get("cache_entries").isJsonArray()) {
|
||||
for (JsonElement el : json.getAsJsonArray("cache_entries")) {
|
||||
if (!el.isJsonObject()) continue;
|
||||
JsonObject o = el.getAsJsonObject();
|
||||
String name = o.has("name") && o.get("name").isJsonPrimitive()
|
||||
? o.get("name").getAsString().trim() : null;
|
||||
String url = o.has("url") && o.get("url").isJsonPrimitive()
|
||||
? sanitizeUrl(o.get("url").getAsString()) : null;
|
||||
if (name == null || name.isEmpty() || url == null) continue;
|
||||
if (CACHE_ENTRIES.containsKey(name)) {
|
||||
VideoPlayerMod.LOG.warn(
|
||||
"[{}] config: duplicate cache entry name '{}' — keeping first",
|
||||
VideoPlayerMod.MOD_ID, name);
|
||||
continue;
|
||||
}
|
||||
CACHE_ENTRIES.put(name, url);
|
||||
}
|
||||
}
|
||||
|
||||
VideoPlayerMod.LOG.info(
|
||||
"[{}] config loaded: per-video={} MB, total-cache={} MB, render={} blocks, "
|
||||
+ "preload_urls={}, cache_entries={}",
|
||||
VideoPlayerMod.MOD_ID, maxPreloadMb, maxCacheMb, renderDistanceBlocks,
|
||||
urls.size(), CACHE_ENTRIES.size());
|
||||
|
||||
// Auto-augment: rewrite the file once so missing keys appear after a mod update.
|
||||
if (augmented) {
|
||||
VideoPlayerMod.LOG.info(
|
||||
"[{}] config missing one or more keys — rewriting with defaults filled in",
|
||||
VideoPlayerMod.MOD_ID);
|
||||
save();
|
||||
}
|
||||
} catch (Throwable t) {
|
||||
VideoPlayerMod.LOG.warn("[{}] failed to read config {}: {} — using empty list",
|
||||
VideoPlayerMod.LOG.warn("[{}] failed to read config {}: {} — using defaults",
|
||||
VideoPlayerMod.MOD_ID, path, t.toString());
|
||||
PRELOAD_URLS = Collections.emptyList();
|
||||
maxPreloadMb = DEFAULT_MAX_PRELOAD_MB;
|
||||
maxCacheMb = DEFAULT_MAX_CACHE_MB;
|
||||
renderDistanceBlocks = DEFAULT_RENDER_DISTANCE;
|
||||
preloadUrls = Collections.emptyList();
|
||||
CACHE_ENTRIES.clear();
|
||||
}
|
||||
}
|
||||
|
||||
/** URLs to push to each joining player. Never null; possibly empty. */
|
||||
public static List<String> preloadUrls() {
|
||||
return PRELOAD_URLS;
|
||||
// -- accessors ---------------------------------------------------------------------------
|
||||
|
||||
/** Hard cap on a single client-side video download, in MB. */
|
||||
public static int maxPreloadMb() { return maxPreloadMb; }
|
||||
|
||||
/** Same value in bytes. */
|
||||
public static long maxPreloadBytes() { return (long) maxPreloadMb * 1024L * 1024L; }
|
||||
|
||||
/** Hard cap on the client-side total cache directory, in MB. */
|
||||
public static int maxCacheMb() { return maxCacheMb; }
|
||||
|
||||
/** Same value in bytes. */
|
||||
public static long maxCacheBytes() { return (long) maxCacheMb * 1024L * 1024L; }
|
||||
|
||||
/** Anchor BE view-distance cap, in blocks. */
|
||||
public static int renderDistanceBlocks() { return renderDistanceBlocks; }
|
||||
|
||||
/** Legacy un-named preload list (still pushed at join). Never null. */
|
||||
public static List<String> preloadUrls() { return preloadUrls; }
|
||||
|
||||
/** Snapshot of name → url, insertion-ordered. Never null. */
|
||||
public static synchronized Map<String, String> cacheEntries() {
|
||||
return new LinkedHashMap<>(CACHE_ENTRIES);
|
||||
}
|
||||
|
||||
/** Lookup a single entry's URL by name. */
|
||||
public static synchronized String cacheUrl(String name) {
|
||||
return CACHE_ENTRIES.get(name);
|
||||
}
|
||||
|
||||
/**
|
||||
* Accept either a raw HTTP(S) URL or a previously-registered cache entry name and return
|
||||
* the canonical URL to store on the anchor. Returns the trimmed input when it's already a
|
||||
* URL, the looked-up URL when the input matches a cache entry name, or {@code null} if the
|
||||
* input is neither (caller decides whether to fail or fall through).
|
||||
*/
|
||||
public static synchronized String resolveUrlOrName(String input) {
|
||||
if (input == null) return null;
|
||||
String t = input.trim();
|
||||
if (t.isEmpty()) return "";
|
||||
if (t.startsWith("http://") || t.startsWith("https://")) return t;
|
||||
return CACHE_ENTRIES.get(t);
|
||||
}
|
||||
|
||||
// -- mutations (driven by /videocache add|remove) -----------------------------------------
|
||||
|
||||
/** Returns true if added; false if the name already exists. Persists on success. */
|
||||
public static synchronized boolean addCacheEntry(String name, String url) {
|
||||
if (name == null || name.isEmpty() || url == null) return false;
|
||||
if (CACHE_ENTRIES.containsKey(name)) return false;
|
||||
CACHE_ENTRIES.put(name, url);
|
||||
save();
|
||||
return true;
|
||||
}
|
||||
|
||||
/** Returns the removed URL, or null if no entry by that name. Persists on success. */
|
||||
public static synchronized String removeCacheEntry(String name) {
|
||||
if (name == null) return null;
|
||||
String removed = CACHE_ENTRIES.remove(name);
|
||||
if (removed != null) save();
|
||||
return removed;
|
||||
}
|
||||
|
||||
/**
|
||||
* Drop every named cache entry and return the URLs that were registered so the caller
|
||||
* can broadcast {@code DeleteCachePayload} for each. Persists on any non-empty removal.
|
||||
*/
|
||||
public static synchronized java.util.List<String> clearCacheEntries() {
|
||||
if (CACHE_ENTRIES.isEmpty()) return java.util.Collections.emptyList();
|
||||
java.util.List<String> urls = new java.util.ArrayList<>(CACHE_ENTRIES.values());
|
||||
CACHE_ENTRIES.clear();
|
||||
save();
|
||||
return urls;
|
||||
}
|
||||
|
||||
// -- io ----------------------------------------------------------------------------------
|
||||
|
||||
private static Path configPath() {
|
||||
return FabricLoader.getInstance().getConfigDir().resolve(FILE_NAME);
|
||||
}
|
||||
|
||||
private static String sanitizeUrl(String s) {
|
||||
if (s == null) return null;
|
||||
String t = s.trim();
|
||||
if (t.isEmpty() || t.length() > 256) return null;
|
||||
if (!(t.startsWith("http://") || t.startsWith("https://"))) return null;
|
||||
return t;
|
||||
}
|
||||
|
||||
private static void writeDefault(Path path) throws IOException {
|
||||
Files.createDirectories(path.getParent());
|
||||
// Hand-rolled rather than Gson-serialized so we can carry a `_comment` field that
|
||||
// explains the format directly inside the file.
|
||||
JsonObject root = new JsonObject();
|
||||
root.addProperty("_comment",
|
||||
"preload_urls: HTTP(S) video URLs broadcast to every player on join. "
|
||||
+ "Equivalent to running /videopreload <url> per joiner. Max 256 chars per url.");
|
||||
root.add("preload_urls", new com.google.gson.JsonArray());
|
||||
"max_preload_mb: per-video download cap (each client). "
|
||||
+ "max_cache_mb: total cache directory cap (each client). "
|
||||
+ "render_distance_blocks: max distance at which a video anchor still renders. "
|
||||
+ "preload_urls: HTTP(S) videos auto-pushed to every player on join (no name). "
|
||||
+ "cache_entries: named entries managed by /videoCache add|list|remove.");
|
||||
root.addProperty("max_preload_mb", DEFAULT_MAX_PRELOAD_MB);
|
||||
root.addProperty("max_cache_mb", DEFAULT_MAX_CACHE_MB);
|
||||
root.addProperty("render_distance_blocks", DEFAULT_RENDER_DISTANCE);
|
||||
root.add("preload_urls", new JsonArray());
|
||||
root.add("cache_entries", new JsonArray());
|
||||
Gson gson = new GsonBuilder().setPrettyPrinting().disableHtmlEscaping().create();
|
||||
Files.writeString(path, gson.toJson(root), StandardCharsets.UTF_8);
|
||||
}
|
||||
|
||||
/** Persist current in-memory state. Best-effort; logs on failure. */
|
||||
private static void save() {
|
||||
Path path = configPath();
|
||||
try {
|
||||
Files.createDirectories(path.getParent());
|
||||
JsonObject root = new JsonObject();
|
||||
root.addProperty("_comment",
|
||||
"max_preload_mb: per-video download cap (each client). "
|
||||
+ "max_cache_mb: total cache directory cap (each client). "
|
||||
+ "render_distance_blocks: max distance at which a video anchor still renders. "
|
||||
+ "preload_urls: legacy un-named auto-preload list. "
|
||||
+ "cache_entries: managed by /videoCache add|list|remove.");
|
||||
root.addProperty("max_preload_mb", maxPreloadMb);
|
||||
root.addProperty("max_cache_mb", maxCacheMb);
|
||||
root.addProperty("render_distance_blocks", renderDistanceBlocks);
|
||||
JsonArray legacyArr = new JsonArray();
|
||||
for (String u : preloadUrls) legacyArr.add(u);
|
||||
root.add("preload_urls", legacyArr);
|
||||
JsonArray entriesArr = new JsonArray();
|
||||
for (Map.Entry<String, String> e : CACHE_ENTRIES.entrySet()) {
|
||||
JsonObject o = new JsonObject();
|
||||
o.addProperty("name", e.getKey());
|
||||
o.addProperty("url", e.getValue());
|
||||
entriesArr.add(o);
|
||||
}
|
||||
root.add("cache_entries", entriesArr);
|
||||
Gson gson = new GsonBuilder().setPrettyPrinting().disableHtmlEscaping().create();
|
||||
Files.writeString(path, gson.toJson(root), StandardCharsets.UTF_8);
|
||||
} catch (Throwable t) {
|
||||
VideoPlayerMod.LOG.warn("[{}] failed to save config: {}",
|
||||
VideoPlayerMod.MOD_ID, t.toString());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,12 +1,14 @@
|
||||
package com.ejclaw.videoplayer;
|
||||
|
||||
import com.ejclaw.videoplayer.command.VideoCacheCommand;
|
||||
import com.ejclaw.videoplayer.command.VideoDeleteCommand;
|
||||
import com.ejclaw.videoplayer.command.VideoMuteCommand;
|
||||
import com.ejclaw.videoplayer.command.VideoPlaceCommand;
|
||||
import com.ejclaw.videoplayer.command.VideoPreloadCommand;
|
||||
import com.ejclaw.videoplayer.command.VideoStickCommand;
|
||||
import com.ejclaw.videoplayer.net.CachePolicyPayload;
|
||||
import com.ejclaw.videoplayer.net.PreloadPayload;
|
||||
import com.ejclaw.videoplayer.net.VideoPlayerNetwork;
|
||||
import com.ejclaw.videoplayer.server.MusicQuizPresence;
|
||||
import com.ejclaw.videoplayer.registry.VideoPlayerBlockEntities;
|
||||
import com.ejclaw.videoplayer.registry.VideoPlayerBlocks;
|
||||
import com.ejclaw.videoplayer.registry.VideoPlayerItems;
|
||||
@@ -29,6 +31,7 @@ public class VideoPlayerMod implements ModInitializer {
|
||||
|
||||
VideoPlayerNetwork.registerPayloadTypes();
|
||||
VideoPlayerNetwork.registerServerReceivers();
|
||||
MusicQuizPresence.register();
|
||||
|
||||
VideoPlayerConfig.load();
|
||||
|
||||
@@ -37,20 +40,34 @@ public class VideoPlayerMod implements ModInitializer {
|
||||
VideoPlaceCommand.register(dispatcher);
|
||||
VideoDeleteCommand.register(dispatcher);
|
||||
VideoMuteCommand.register(dispatcher);
|
||||
VideoPreloadCommand.register(dispatcher);
|
||||
VideoCacheCommand.register(dispatcher);
|
||||
});
|
||||
|
||||
// When a player finishes joining, push every preload URL from the config so their
|
||||
// client kicks off the background download. Reuses the same PreloadPayload that
|
||||
// /videopreload sends, so the client-side caching path is identical.
|
||||
// On join: (1) push the per-video download cap so the client knows whether to abort
|
||||
// an over-cap stream, (2) replay every legacy preload_urls entry, (3) replay every
|
||||
// named /videocache entry. Policy must go first so caps are honored before downloads
|
||||
// start. Each PreloadPayload is fire-and-forget; clients post their own "[videopreload]"
|
||||
// status lines when downloads finish.
|
||||
ServerPlayConnectionEvents.JOIN.register((handler, sender, server) -> {
|
||||
java.util.List<String> urls = VideoPlayerConfig.preloadUrls();
|
||||
if (urls.isEmpty()) return;
|
||||
for (String url : urls) {
|
||||
ServerPlayNetworking.send(handler.getPlayer(), new PreloadPayload(url));
|
||||
var player = handler.getPlayer();
|
||||
ServerPlayNetworking.send(player, new CachePolicyPayload(
|
||||
VideoPlayerConfig.maxPreloadBytes(),
|
||||
VideoPlayerConfig.maxCacheBytes(),
|
||||
VideoPlayerConfig.renderDistanceBlocks()));
|
||||
|
||||
int sent = 0;
|
||||
for (String url : VideoPlayerConfig.preloadUrls()) {
|
||||
ServerPlayNetworking.send(player, new PreloadPayload(url));
|
||||
sent++;
|
||||
}
|
||||
for (var e : VideoPlayerConfig.cacheEntries().entrySet()) {
|
||||
ServerPlayNetworking.send(player, new PreloadPayload(e.getValue()));
|
||||
sent++;
|
||||
}
|
||||
if (sent > 0) {
|
||||
LOG.info("[{}] sent policy + {} preload(s) to {}",
|
||||
MOD_ID, sent, player.getName().getString());
|
||||
}
|
||||
LOG.info("[{}] sent {} config preload(s) to {}",
|
||||
MOD_ID, urls.size(), handler.getPlayer().getName().getString());
|
||||
});
|
||||
|
||||
LOG.info("[{}] initialized", MOD_ID);
|
||||
|
||||
@@ -0,0 +1,30 @@
|
||||
package com.ejclaw.videoplayer.client;
|
||||
|
||||
import com.ejclaw.videoplayer.VideoPlayerMod;
|
||||
import net.fabricmc.api.EnvType;
|
||||
import net.fabricmc.api.Environment;
|
||||
|
||||
/**
|
||||
* Client-side mirror of the server's policy bundle (pushed via {@code CachePolicyPayload}
|
||||
* on join). Currently just the anchor render-distance cap; the per-video download cap lives
|
||||
* directly on {@link com.ejclaw.videoplayer.client.playback.VideoCache}.
|
||||
*
|
||||
* <p>Default 128 matches the legacy hard-coded value, so unpaired clients (e.g. dev tests
|
||||
* with no JOIN packet, or older servers without the payload) render identically to before.
|
||||
*/
|
||||
@Environment(EnvType.CLIENT)
|
||||
public final class ClientPolicy {
|
||||
private ClientPolicy() {}
|
||||
|
||||
private static volatile int renderDistanceBlocks = 128;
|
||||
|
||||
public static int renderDistanceBlocks() { return renderDistanceBlocks; }
|
||||
|
||||
public static void setRenderDistanceBlocks(int blocks) {
|
||||
if (blocks < 16) blocks = 16;
|
||||
if (blocks > 2048) blocks = 2048;
|
||||
renderDistanceBlocks = blocks;
|
||||
VideoPlayerMod.LOG.info("[{}] anchor render distance set to {} blocks",
|
||||
VideoPlayerMod.MOD_ID, blocks);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,56 @@
|
||||
package com.ejclaw.videoplayer.client;
|
||||
|
||||
import com.ejclaw.videoplayer.net.MqHelloPayload;
|
||||
import net.fabricmc.api.EnvType;
|
||||
import net.fabricmc.api.Environment;
|
||||
import net.fabricmc.fabric.api.client.event.lifecycle.v1.ClientTickEvents;
|
||||
import net.fabricmc.fabric.api.client.networking.v1.ClientPlayConnectionEvents;
|
||||
import net.fabricmc.fabric.api.client.networking.v1.ClientPlayNetworking;
|
||||
|
||||
/**
|
||||
* Client side of the {@code music_quiz} datapack handshake
|
||||
* ({@code docs/mc_video_player_mod_integration.md}). Sends one {@link MqHelloPayload}
|
||||
* on JOIN, then repeats every 100 client ticks (~5 s at 20 tps).
|
||||
*
|
||||
* <p>The periodic resend is <em>mandatory</em>: the datapack's
|
||||
* {@code mq:players/login} resets the per-player score to 0 the moment the player
|
||||
* passes the spawn dialog. The single JOIN-time send can land before that reset,
|
||||
* leaving the score at 0 and breaking the {@code mq:commands/start} guard. With a
|
||||
* 5-second resend, the score is restored to 1 within at most one cycle.
|
||||
*/
|
||||
@Environment(EnvType.CLIENT)
|
||||
public final class MusicQuizClient {
|
||||
private MusicQuizClient() {}
|
||||
|
||||
/** ~5 s at 20 tps. Spec recommends ≤5 s; tighter is fine but unnecessary. */
|
||||
private static final int RESEND_INTERVAL_TICKS = 100;
|
||||
|
||||
private static int tickCounter = 0;
|
||||
|
||||
public static void register() {
|
||||
ClientPlayConnectionEvents.JOIN.register((handler, sender, client) ->
|
||||
send());
|
||||
|
||||
ClientTickEvents.END_CLIENT_TICK.register(client -> {
|
||||
// Gate on world presence — when the player isn't in-game, level is null and the
|
||||
// counter resets so the next session starts fresh instead of firing immediately.
|
||||
if (client.level == null) {
|
||||
tickCounter = 0;
|
||||
return;
|
||||
}
|
||||
tickCounter++;
|
||||
if (tickCounter >= RESEND_INTERVAL_TICKS) {
|
||||
tickCounter = 0;
|
||||
send();
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
private static void send() {
|
||||
// ClientPlayNetworking.send no-ops when the server hasn't registered the payload
|
||||
// type (e.g. vanilla server or server without this mod) — safe to call blindly.
|
||||
if (ClientPlayNetworking.canSend(MqHelloPayload.TYPE)) {
|
||||
ClientPlayNetworking.send(new MqHelloPayload(MqHelloPayload.CURRENT_VERSION));
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,9 +1,13 @@
|
||||
package com.ejclaw.videoplayer.client.net;
|
||||
|
||||
import com.ejclaw.videoplayer.block.VideoAnchorBlockEntity;
|
||||
import com.ejclaw.videoplayer.client.ClientPolicy;
|
||||
import com.ejclaw.videoplayer.client.gui.VideoConfigScreen;
|
||||
import com.ejclaw.videoplayer.client.playback.VideoCache;
|
||||
import com.ejclaw.videoplayer.client.playback.VideoPlayback;
|
||||
import com.ejclaw.videoplayer.net.CachePolicyPayload;
|
||||
import com.ejclaw.videoplayer.net.ClearCachePayload;
|
||||
import com.ejclaw.videoplayer.net.DeleteCachePayload;
|
||||
import com.ejclaw.videoplayer.net.OpenScreenPayload;
|
||||
import com.ejclaw.videoplayer.net.PreloadPayload;
|
||||
import com.ejclaw.videoplayer.net.SyncAnchorPayload;
|
||||
@@ -40,5 +44,24 @@ public final class ClientNetworking {
|
||||
ClientPlayNetworking.registerGlobalReceiver(PreloadPayload.TYPE, (payload, context) -> {
|
||||
VideoCache.preload(payload.url());
|
||||
});
|
||||
|
||||
// Server tells us the per-video and total-cache download caps (bytes). Must arrive
|
||||
// before PreloadPayload (server sends policy first on JOIN) so we don't use stale
|
||||
// defaults.
|
||||
ClientPlayNetworking.registerGlobalReceiver(CachePolicyPayload.TYPE, (payload, context) -> {
|
||||
VideoCache.setMaxBytes(payload.maxPerVideoBytes());
|
||||
VideoCache.setMaxCacheBytes(payload.maxCacheBytes());
|
||||
ClientPolicy.setRenderDistanceBlocks(payload.renderDistanceBlocks());
|
||||
});
|
||||
|
||||
// /videocache remove — drop the URL from this client's disk cache.
|
||||
ClientPlayNetworking.registerGlobalReceiver(DeleteCachePayload.TYPE, (payload, context) -> {
|
||||
VideoCache.purge(payload.url());
|
||||
});
|
||||
|
||||
// /videoCache clear — wipe the entire client cache directory.
|
||||
ClientPlayNetworking.registerGlobalReceiver(ClearCachePayload.TYPE, (payload, context) -> {
|
||||
VideoCache.clearAll();
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
@@ -164,16 +164,44 @@ public class JavaCvBackend implements VideoBackend {
|
||||
try { line.stop(); } catch (Throwable ignored) {}
|
||||
try { line.flush(); } catch (Throwable ignored) {}
|
||||
}
|
||||
// Yank the grabber too so a blocked grab() inside an HTTP read returns promptly.
|
||||
// JavaCV's close() is best-effort thread-safe — worst case we trip an AVERROR which
|
||||
// the catch-all in runLoop swallows.
|
||||
Object g = grabberHandle;
|
||||
if (g != null) {
|
||||
try { g.getClass().getMethod("close").invoke(g); } catch (Throwable ignored) {}
|
||||
}
|
||||
// CRITICAL: we do NOT call grabber.close() from this (caller) thread. The decoder's
|
||||
// per-frame path is:
|
||||
//
|
||||
// frame = grab(grabber); // grabber-owned native memory
|
||||
// src = frame.image[0]; // DirectByteBuffer over that memory
|
||||
// need = src.remaining(); // (lock-free)
|
||||
// srcAddr = MemoryUtil.memAddress(src); // (lock-free)
|
||||
// synchronized (frameLock) {
|
||||
// MemoryUtil.memCopy(srcAddr, ...); // reads from grabber-owned memory
|
||||
// }
|
||||
//
|
||||
// Even if we held frameLock while closing the grabber, there's a window between
|
||||
// grab() returning and entering the synchronized block where the decoder is holding a
|
||||
// stale srcAddr — closing the grabber there frees the av_frame plane and the next
|
||||
// memcpy crashes inside StubRoutines::jbyte_disjoint_arraycopy (exactly the 4K-delete
|
||||
// crash dump we saw). So the safe rule is: only the decoder thread touches the
|
||||
// grabber. External stop signals `running=false`, stops the audio line, interrupts the
|
||||
// worker, and joins briefly; the worker's own `finally` calls grabber.close(). Inside
|
||||
// the loop, grab() unblocks via the rw_timeout/timeout options (3 s, set in runLoop)
|
||||
// even on a stuck HTTP read, so the join below normally returns within a frame.
|
||||
Thread t = worker;
|
||||
worker = null;
|
||||
if (t != null) t.interrupt();
|
||||
if (t != null) {
|
||||
t.interrupt();
|
||||
try {
|
||||
t.join(2000);
|
||||
} catch (InterruptedException ie) {
|
||||
Thread.currentThread().interrupt();
|
||||
}
|
||||
if (t.isAlive()) {
|
||||
// Worker still blocked in native grab() — let it finish on its own. Its
|
||||
// finally still closes the grabber when grab() eventually returns / throws.
|
||||
// No native pointers leak in the meantime because we don't touch them here.
|
||||
VideoPlayerMod.LOG.warn(
|
||||
"[{}] decoder did not exit within 2 s of stop; orphaning until next grab() returns",
|
||||
VideoPlayerMod.MOD_ID);
|
||||
}
|
||||
}
|
||||
ready = false;
|
||||
}
|
||||
|
||||
@@ -299,10 +327,31 @@ public class JavaCvBackend implements VideoBackend {
|
||||
// top to absorb the burst-then-stall caused by SourceDataLine backpressure
|
||||
// pacing only at audio-buffer granularity.
|
||||
int need = src.remaining();
|
||||
// Reviewer-mandated sanity bounds: memCopy is a raw native copy with no
|
||||
// fence against overrun. Validate against (a) the source buffer's own
|
||||
// capacity (so a corrupt plane can't read past it) and (b) the expected
|
||||
// RGBA frame size (width*height*4) (so an unexpectedly oversized plane
|
||||
// can't smash the dst slot we'll allocate). If either fails, skip this
|
||||
// frame and continue — the next grab() will give us a fresh one.
|
||||
int expected = width * height * 4;
|
||||
if (need > src.capacity()) {
|
||||
VideoPlayerMod.LOG.warn("[{}] frame overruns source capacity (need={}, cap={}); skipping",
|
||||
VideoPlayerMod.MOD_ID, need, src.capacity());
|
||||
need = 0;
|
||||
} else if (need > expected) {
|
||||
VideoPlayerMod.LOG.warn("[{}] frame larger than expected RGBA size (need={}, expected={}); skipping",
|
||||
VideoPlayerMod.MOD_ID, need, expected);
|
||||
need = 0;
|
||||
}
|
||||
if (need > 0) {
|
||||
int srcPos = src.position();
|
||||
long srcAddr = MemoryUtil.memAddress(src) + srcPos;
|
||||
synchronized (frameLock) {
|
||||
// Recheck shutdown inside the lock: stopWorker() flipped running=false
|
||||
// before signaling, so worker is the only writer here and grabber.close()
|
||||
// only runs from this thread's finally — but the explicit check keeps
|
||||
// the contract obvious to future readers.
|
||||
if (!running.get() || closed) break;
|
||||
int idx = ringTail;
|
||||
if (ringBufs[idx] == null || ringBufs[idx].capacity() < need) {
|
||||
ringBufs[idx] = ByteBuffer.allocateDirect(need).order(ByteOrder.nativeOrder());
|
||||
|
||||
@@ -20,6 +20,9 @@ import java.util.HashSet;
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
import java.util.concurrent.atomic.AtomicLong;
|
||||
|
||||
/**
|
||||
* Client-side disk cache for preloaded HTTP video URLs. Driven by the {@code /videopreload}
|
||||
@@ -38,17 +41,160 @@ public final class VideoCache {
|
||||
|
||||
/** url → local absolute path of the fully-downloaded cache file. */
|
||||
private static final Map<String, Path> READY = new ConcurrentHashMap<>();
|
||||
/** urls whose download is currently in flight. */
|
||||
/** urls whose download is currently queued or in flight. */
|
||||
private static final Set<String> IN_FLIGHT = ConcurrentHashMap.newKeySet();
|
||||
/**
|
||||
* Monotonic cache-generation counter. {@link #clearAll()} bumps this; every download
|
||||
* captures the value at submit time and bails (deletes its {@code .part} without
|
||||
* publishing) if the epoch has moved since. This is the cancellation channel for the
|
||||
* in-flight download — without it, {@code clearAll} only wipes already-finalized files
|
||||
* while the running download keeps writing and re-publishes one entry post-clear.
|
||||
*/
|
||||
private static final AtomicLong CACHE_EPOCH = new AtomicLong(0);
|
||||
|
||||
/** Hard ceiling on a single preload — 512 MB. Keeps an accidental giant URL from filling disk. */
|
||||
private static final long MAX_BYTES = 512L * 1024 * 1024;
|
||||
/**
|
||||
* Single-thread executor that serializes all downloads. Cap enforcement (the total
|
||||
* cache size check) needs an authoritative view of the cache directory at the moment a
|
||||
* download starts, so we run one download at a time — that way the directory scan in
|
||||
* {@link #cacheDirSize} reflects every finished download up to this point. Parallel
|
||||
* downloads were racing the cap by each reading the directory before any of them had
|
||||
* renamed their .part to final.
|
||||
*/
|
||||
private static final ExecutorService DOWNLOAD_POOL = Executors.newSingleThreadExecutor(r -> {
|
||||
Thread t = new Thread(r, "video_player-preload");
|
||||
t.setDaemon(true);
|
||||
return t;
|
||||
});
|
||||
|
||||
/**
|
||||
* Hard ceiling on a single preload, in bytes. Default 2 GB sized to allow a single 4K
|
||||
* short clip; overridden per-session by {@link com.ejclaw.videoplayer.net.CachePolicyPayload}
|
||||
* on join, which carries the server's {@code max_preload_mb} config value.
|
||||
*/
|
||||
private static volatile long MAX_BYTES = 2048L * 1024 * 1024;
|
||||
|
||||
/**
|
||||
* Hard ceiling on the total cache directory size, in bytes. Default 750 MB sized to fit
|
||||
* ~50 short FHD clips; overridden per-session by {@link com.ejclaw.videoplayer.net.CachePolicyPayload}
|
||||
* on join, which carries the server's {@code max_cache_mb} config value. Enforced
|
||||
* cooperatively at the start of each download — running cache + new download must stay
|
||||
* within this cap.
|
||||
*/
|
||||
private static volatile long MAX_CACHE_BYTES = 750L * 1024 * 1024;
|
||||
|
||||
/** Server-driven override of the per-video cap. */
|
||||
public static void setMaxBytes(long bytes) {
|
||||
if (bytes < 16L * 1024 * 1024) bytes = 16L * 1024 * 1024;
|
||||
if (bytes > 16L * 1024 * 1024 * 1024) bytes = 16L * 1024 * 1024 * 1024;
|
||||
MAX_BYTES = bytes;
|
||||
VideoPlayerMod.LOG.info("[{}] per-video preload cap set to {} MB",
|
||||
VideoPlayerMod.MOD_ID, bytes / (1024 * 1024));
|
||||
}
|
||||
|
||||
/** Server-driven override of the total-cache cap. */
|
||||
public static void setMaxCacheBytes(long bytes) {
|
||||
if (bytes < 16L * 1024 * 1024) bytes = 16L * 1024 * 1024;
|
||||
if (bytes > 64L * 1024 * 1024 * 1024) bytes = 64L * 1024 * 1024 * 1024;
|
||||
MAX_CACHE_BYTES = bytes;
|
||||
VideoPlayerMod.LOG.info("[{}] total-cache cap set to {} MB",
|
||||
VideoPlayerMod.MOD_ID, bytes / (1024 * 1024));
|
||||
}
|
||||
|
||||
/** Server-driven delete of a cached URL. Removes from READY and from disk. */
|
||||
public static void purge(String url) {
|
||||
if (url == null || url.isEmpty()) return;
|
||||
Path p = READY.remove(url);
|
||||
if (p == null) {
|
||||
// Not in this session's index, but the file may still be on disk from a prior run.
|
||||
// Reconstruct the path by hash + extension and try to delete it.
|
||||
try {
|
||||
Path dir = cacheDir();
|
||||
if (dir != null) {
|
||||
Path guess = dir.resolve(sha256(url) + extensionFromUrl(url));
|
||||
if (Files.exists(guess)) p = guess;
|
||||
}
|
||||
} catch (Throwable ignored) {}
|
||||
}
|
||||
if (p != null) {
|
||||
try {
|
||||
boolean gone = Files.deleteIfExists(p);
|
||||
VideoPlayerMod.LOG.info("[{}] purge: {} -> deleted={} ({})",
|
||||
VideoPlayerMod.MOD_ID, url, gone, p.getFileName());
|
||||
if (gone) notifyChat("[videocache] 캐시 삭제: " + url, ChatFormatting.YELLOW);
|
||||
} catch (Throwable t) {
|
||||
VideoPlayerMod.LOG.warn("[{}] purge failed for {}: {}",
|
||||
VideoPlayerMod.MOD_ID, url, t.toString());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Wipe the entire cache directory and drop both indexes. Sent in response to
|
||||
* {@code /videoCache clear}.
|
||||
*
|
||||
* <p>Three phases that need to stay in this order:
|
||||
* <ol>
|
||||
* <li>Bump the epoch first — that flips the cancellation flag for any in-flight
|
||||
* download. The download thread checks the epoch in the read loop and at the
|
||||
* move step, so after this point it will refuse to publish a new entry and
|
||||
* will delete its own {@code .part}.</li>
|
||||
* <li>Clear the in-memory indexes. (READY clears whatever was already finalized
|
||||
* pre-clear; IN_FLIGHT is wiped so a subsequent same-URL preload re-enters
|
||||
* the queue instead of getting deduped by stale state.)</li>
|
||||
* <li>Best-effort delete every regular file in the cache directory. We do this
|
||||
* last so that if the in-flight download was momentarily holding a {@code .part}
|
||||
* open, the listing here also catches its post-close residue (though normally
|
||||
* phase 1 → the download deletes its own part).</li>
|
||||
* </ol>
|
||||
*
|
||||
* <p>Best-effort per-file deletion; logs failures but doesn't abort on the first one.
|
||||
* On Windows the open {@code .part} may not be deletable here — phase 1's cancellation
|
||||
* + the download's own cleanup-on-bail handles that case.
|
||||
*/
|
||||
public static void clearAll() {
|
||||
// Phase 1: signal cancellation to any in-flight download BEFORE wiping disk.
|
||||
CACHE_EPOCH.incrementAndGet();
|
||||
|
||||
// Phase 2: drop indexes.
|
||||
READY.clear();
|
||||
IN_FLIGHT.clear();
|
||||
|
||||
// Phase 3: delete files on disk.
|
||||
int deleted = 0;
|
||||
int failed = 0;
|
||||
try {
|
||||
Path dir = cacheDir();
|
||||
if (dir != null && Files.isDirectory(dir)) {
|
||||
try (var stream = Files.newDirectoryStream(dir)) {
|
||||
for (Path p : stream) {
|
||||
try {
|
||||
if (Files.isRegularFile(p) && Files.deleteIfExists(p)) deleted++;
|
||||
} catch (Throwable t) {
|
||||
failed++;
|
||||
VideoPlayerMod.LOG.warn("[{}] clearAll: could not delete {}: {}",
|
||||
VideoPlayerMod.MOD_ID, p.getFileName(), t.toString());
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
} catch (Throwable t) {
|
||||
VideoPlayerMod.LOG.warn("[{}] clearAll failed: {}",
|
||||
VideoPlayerMod.MOD_ID, t.toString());
|
||||
}
|
||||
VideoPlayerMod.LOG.info("[{}] clearAll: deleted={} failed={}",
|
||||
VideoPlayerMod.MOD_ID, deleted, failed);
|
||||
notifyChat("[videocache] 전체 캐시 삭제: " + deleted + "개 파일", ChatFormatting.YELLOW);
|
||||
}
|
||||
|
||||
/** Kick off a background download. No-op if already cached or in flight. */
|
||||
public static void preload(String url) {
|
||||
if (url == null || url.isEmpty()) return;
|
||||
if (!(url.startsWith("http://") || url.startsWith("https://"))) return;
|
||||
if (READY.containsKey(url)) {
|
||||
// Use lookup() (which also verifies the file exists on disk) instead of
|
||||
// READY.containsKey — defends against READY containing a stale entry whose
|
||||
// backing file was removed by clearAll() / a user-side file delete. Without this,
|
||||
// a stale key would silently block a re-preload.
|
||||
if (lookup(url) != null) {
|
||||
VideoPlayerMod.LOG.info("[{}] preload: already cached {}", VideoPlayerMod.MOD_ID, url);
|
||||
notifyChat("[videopreload] 이미 캐시됨: " + url, ChatFormatting.GRAY);
|
||||
return;
|
||||
@@ -58,10 +204,12 @@ public final class VideoCache {
|
||||
notifyChat("[videopreload] 이미 다운로드 중: " + url, ChatFormatting.GRAY);
|
||||
return;
|
||||
}
|
||||
notifyChat("[videopreload] 다운로드 시작: " + url, ChatFormatting.YELLOW);
|
||||
Thread t = new Thread(() -> download(url), "video_player-preload");
|
||||
t.setDaemon(true);
|
||||
t.start();
|
||||
notifyChat("[videopreload] 다운로드 대기열 추가: " + url, ChatFormatting.YELLOW);
|
||||
// Capture the current epoch at submit time. The download thread checks against
|
||||
// CACHE_EPOCH later — any mismatch means clearAll() ran in between and this
|
||||
// download must abort without publishing.
|
||||
long epoch = CACHE_EPOCH.get();
|
||||
DOWNLOAD_POOL.submit(() -> download(url, epoch));
|
||||
}
|
||||
|
||||
/** Return the local cached file path for this URL, or {@code null} if not yet ready. */
|
||||
@@ -85,31 +233,70 @@ public final class VideoCache {
|
||||
|
||||
// -- internals -----------------------------------------------------------------------
|
||||
|
||||
private static void download(String url) {
|
||||
private static void download(String url, long startEpoch) {
|
||||
Path cacheDir = cacheDir();
|
||||
Path partPath = null;
|
||||
try {
|
||||
if (cacheDir == null) {
|
||||
VideoPlayerMod.LOG.warn("[{}] preload: no game dir, skipping {}",
|
||||
VideoPlayerMod.MOD_ID, url);
|
||||
return;
|
||||
}
|
||||
// Pre-flight cancellation check — if clearAll already ran between submit and now,
|
||||
// skip the whole thing. Avoids creating directories / .part files post-clear.
|
||||
if (CACHE_EPOCH.get() != startEpoch) {
|
||||
VideoPlayerMod.LOG.info("[{}] preload: cancelled before start (clearAll ran) — {}",
|
||||
VideoPlayerMod.MOD_ID, url);
|
||||
return;
|
||||
}
|
||||
Files.createDirectories(cacheDir);
|
||||
|
||||
String hash = sha256(url);
|
||||
String ext = extensionFromUrl(url);
|
||||
Path finalPath = cacheDir.resolve(hash + ext);
|
||||
Path partPath = cacheDir.resolve(hash + ext + ".part");
|
||||
partPath = cacheDir.resolve(hash + ext + ".part");
|
||||
|
||||
// Resume-friendly: if the file's already on disk from an earlier session, just
|
||||
// index it without re-downloading.
|
||||
if (Files.exists(finalPath) && Files.size(finalPath) > 0) {
|
||||
// Pre-publish check — bail if clearAll has run since submit.
|
||||
if (CACHE_EPOCH.get() != startEpoch) return;
|
||||
READY.put(url, finalPath);
|
||||
// Post-publish re-check: same window as the post-move check on the download
|
||||
// path. If clearAll landed between the epoch read above and the READY.put,
|
||||
// it would have wiped READY + the file, and our put() resurrected a stale
|
||||
// entry pointing at a now-deleted path. Roll it back: remove our entry
|
||||
// (compareAndRemove via remove(key, value) to avoid clobbering a concurrent
|
||||
// legitimate re-put) and best-effort delete the file.
|
||||
if (CACHE_EPOCH.get() != startEpoch) {
|
||||
READY.remove(url, finalPath);
|
||||
try { Files.deleteIfExists(finalPath); } catch (Throwable ignored) {}
|
||||
VideoPlayerMod.LOG.info("[{}] preload: reindex cancelled (clearAll ran) — {}",
|
||||
VideoPlayerMod.MOD_ID, url);
|
||||
return;
|
||||
}
|
||||
VideoPlayerMod.LOG.info("[{}] preload: indexed existing cache {} -> {}",
|
||||
VideoPlayerMod.MOD_ID, url, finalPath.getFileName());
|
||||
notifyChat("[videopreload] 기존 캐시 사용: " + url, ChatFormatting.GREEN);
|
||||
return;
|
||||
}
|
||||
|
||||
// Total-cache check: refuse to start if the cache directory is already at the cap.
|
||||
// We re-check during the read loop too, since other downloads may be in flight in
|
||||
// parallel. {@code existingCacheBytes} excludes our own .part (which we just wrote 0
|
||||
// bytes to / haven't created yet).
|
||||
long existingCacheBytes = cacheDirSize(cacheDir, partPath);
|
||||
if (existingCacheBytes >= MAX_CACHE_BYTES) {
|
||||
long capMb = MAX_CACHE_BYTES / (1024 * 1024);
|
||||
long usedMb = existingCacheBytes / (1024 * 1024);
|
||||
VideoPlayerMod.LOG.warn(
|
||||
"[{}] preload: total-cache cap reached ({}/{} MB); aborting {}",
|
||||
VideoPlayerMod.MOD_ID, usedMb, capMb, url);
|
||||
notifyChat("[videopreload] 실패 (전체 캐시 " + capMb + "MB 초과 / 현재 "
|
||||
+ usedMb + "MB): " + url, ChatFormatting.RED);
|
||||
return;
|
||||
}
|
||||
|
||||
URLConnection raw = URI.create(url).toURL().openConnection();
|
||||
raw.setConnectTimeout(10_000);
|
||||
raw.setReadTimeout(30_000);
|
||||
@@ -126,26 +313,77 @@ public final class VideoCache {
|
||||
}
|
||||
|
||||
long total = 0;
|
||||
boolean cancelled = false;
|
||||
try (InputStream in = raw.getInputStream();
|
||||
OutputStream out = Files.newOutputStream(partPath)) {
|
||||
byte[] buf = new byte[64 * 1024];
|
||||
int n;
|
||||
while ((n = in.read(buf)) >= 0) {
|
||||
// Cancellation check inside the loop. Break (not return) so the try-with
|
||||
// closes the output stream first — on Windows, deleting an open .part can
|
||||
// fail with AccessDeniedException, so we always close before deleting.
|
||||
if (CACHE_EPOCH.get() != startEpoch) {
|
||||
cancelled = true;
|
||||
break;
|
||||
}
|
||||
total += n;
|
||||
if (total > MAX_BYTES) {
|
||||
long capMb = MAX_BYTES / (1024 * 1024);
|
||||
VideoPlayerMod.LOG.warn(
|
||||
"[{}] preload: {} exceeded {} MB cap; aborting",
|
||||
VideoPlayerMod.MOD_ID, url, MAX_BYTES / (1024 * 1024));
|
||||
try { Files.deleteIfExists(partPath); } catch (Throwable ignored) {}
|
||||
notifyChat("[videopreload] 실패 (512MB 초과): " + url, ChatFormatting.RED);
|
||||
return;
|
||||
"[{}] preload: {} exceeded per-video {} MB cap; aborting",
|
||||
VideoPlayerMod.MOD_ID, url, capMb);
|
||||
// Same close-before-delete dance for Windows.
|
||||
cancelled = true;
|
||||
notifyChat("[videopreload] 실패 (단일 영상 " + capMb + "MB 초과): " + url,
|
||||
ChatFormatting.RED);
|
||||
break;
|
||||
}
|
||||
if (existingCacheBytes + total > MAX_CACHE_BYTES) {
|
||||
long capMb = MAX_CACHE_BYTES / (1024 * 1024);
|
||||
long usedMb = (existingCacheBytes + total) / (1024 * 1024);
|
||||
VideoPlayerMod.LOG.warn(
|
||||
"[{}] preload: total-cache cap exceeded ({}>{} MB); aborting {}",
|
||||
VideoPlayerMod.MOD_ID, usedMb, capMb, url);
|
||||
cancelled = true;
|
||||
notifyChat("[videopreload] 실패 (전체 캐시 " + capMb + "MB 초과): " + url,
|
||||
ChatFormatting.RED);
|
||||
break;
|
||||
}
|
||||
out.write(buf, 0, n);
|
||||
}
|
||||
}
|
||||
// Now the .part file is closed — safe to delete on Windows.
|
||||
if (cancelled) {
|
||||
try { Files.deleteIfExists(partPath); } catch (Throwable ignored) {}
|
||||
return;
|
||||
}
|
||||
|
||||
// Pre-move cancellation check. If clearAll ran during the read loop, abort
|
||||
// before promoting .part to final — saves a wasted move + delete.
|
||||
if (CACHE_EPOCH.get() != startEpoch) {
|
||||
VideoPlayerMod.LOG.info("[{}] preload: cancelled before move (clearAll ran) — {}",
|
||||
VideoPlayerMod.MOD_ID, url);
|
||||
try { Files.deleteIfExists(partPath); } catch (Throwable ignored) {}
|
||||
return;
|
||||
}
|
||||
|
||||
Files.move(partPath, finalPath, StandardCopyOption.REPLACE_EXISTING,
|
||||
StandardCopyOption.ATOMIC_MOVE);
|
||||
|
||||
// Post-move cancellation check. clearAll() may have run between the pre-move
|
||||
// check above and the move itself — in that case clearAll's directory scan
|
||||
// either missed our file (it didn't exist yet) or saw the .part and skipped /
|
||||
// failed to delete it. Either way, finalPath now exists on disk but the
|
||||
// user-visible cache state is "cleared", so we must delete the file and skip
|
||||
// both the READY.put and the "완료" chat. Without this check, a clear right at
|
||||
// this window leaves a resurrected file in READY and a stale "완료" message.
|
||||
if (CACHE_EPOCH.get() != startEpoch) {
|
||||
VideoPlayerMod.LOG.info("[{}] preload: cancelled after move (clearAll ran) — {}",
|
||||
VideoPlayerMod.MOD_ID, url);
|
||||
try { Files.deleteIfExists(finalPath); } catch (Throwable ignored) {}
|
||||
return;
|
||||
}
|
||||
|
||||
READY.put(url, finalPath);
|
||||
VideoPlayerMod.LOG.info("[{}] preload: cached {} ({} bytes) -> {}",
|
||||
VideoPlayerMod.MOD_ID, url, total, finalPath.getFileName());
|
||||
@@ -156,6 +394,10 @@ public final class VideoCache {
|
||||
VideoPlayerMod.MOD_ID, url, t.toString());
|
||||
notifyChat("[videopreload] 실패 (" + t.getClass().getSimpleName() + "): " + url,
|
||||
ChatFormatting.RED);
|
||||
// Best-effort cleanup of any leftover .part on the error path.
|
||||
if (partPath != null) {
|
||||
try { Files.deleteIfExists(partPath); } catch (Throwable ignored) {}
|
||||
}
|
||||
} finally {
|
||||
IN_FLIGHT.remove(url);
|
||||
}
|
||||
@@ -171,6 +413,32 @@ public final class VideoCache {
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Sum of regular-file sizes under {@code dir}, skipping {@code excludePart} (the .part file
|
||||
* for the in-flight download — we account for that via the running {@code total} counter).
|
||||
* Best-effort: errors collapse to 0 so a transient FS hiccup doesn't strand a download.
|
||||
*/
|
||||
private static long cacheDirSize(Path dir, Path excludePart) {
|
||||
if (dir == null) return 0L;
|
||||
try {
|
||||
if (!Files.isDirectory(dir)) return 0L;
|
||||
final long[] sum = { 0L };
|
||||
try (var stream = Files.newDirectoryStream(dir)) {
|
||||
for (Path p : stream) {
|
||||
if (excludePart != null && p.equals(excludePart)) continue;
|
||||
try {
|
||||
if (Files.isRegularFile(p)) sum[0] += Files.size(p);
|
||||
} catch (Throwable ignored) {}
|
||||
}
|
||||
}
|
||||
return sum[0];
|
||||
} catch (Throwable t) {
|
||||
VideoPlayerMod.LOG.warn("[{}] cacheDirSize failed: {}",
|
||||
VideoPlayerMod.MOD_ID, t.toString());
|
||||
return 0L;
|
||||
}
|
||||
}
|
||||
|
||||
private static Path cacheDir() {
|
||||
Minecraft mc = Minecraft.getInstance();
|
||||
if (mc == null || mc.gameDirectory == null) return null;
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
package com.ejclaw.videoplayer.client.render;
|
||||
|
||||
import com.ejclaw.videoplayer.block.VideoAnchorBlockEntity;
|
||||
import com.ejclaw.videoplayer.client.ClientPolicy;
|
||||
import com.ejclaw.videoplayer.client.playback.VideoPlayback;
|
||||
import com.mojang.blaze3d.vertex.PoseStack;
|
||||
import com.mojang.math.Axis;
|
||||
@@ -76,16 +77,14 @@ public class VideoAnchorRenderer implements BlockEntityRenderer<VideoAnchorBlock
|
||||
final Matrix4f mat = new Matrix4f(pose.last().pose());
|
||||
RenderType rt = RenderTypes.entityCutout(tex);
|
||||
collector.submitCustomGeometry(pose, rt, (poseUnused, vc) -> {
|
||||
// Front face (visible from outside, looking back at the wall)
|
||||
// Single-sided: the back of the anchor is by design pressed against the wall the
|
||||
// player clicked, so a back face is pure GPU waste. Halves the fragment shader work
|
||||
// per anchor and removes the mirrored-texture artifact a player would see if they
|
||||
// somehow clipped behind the wall.
|
||||
emit(vc, mat, 0F, 0F, 0F, 0F, 1F, light);
|
||||
emit(vc, mat, w, 0F, 0F, 1F, 1F, light);
|
||||
emit(vc, mat, w, h, 0F, 1F, 0F, light);
|
||||
emit(vc, mat, 0F, h, 0F, 0F, 0F, light);
|
||||
// Back face (in case the player ends up on the other side, e.g. clipping into the wall)
|
||||
emit(vc, mat, 0F, h, 0F, 0F, 0F, light);
|
||||
emit(vc, mat, w, h, 0F, 1F, 0F, light);
|
||||
emit(vc, mat, w, 0F, 0F, 1F, 1F, light);
|
||||
emit(vc, mat, 0F, 0F, 0F, 0F, 1F, light);
|
||||
});
|
||||
|
||||
pose.popPose();
|
||||
@@ -126,7 +125,9 @@ public class VideoAnchorRenderer implements BlockEntityRenderer<VideoAnchorBlock
|
||||
|
||||
@Override
|
||||
public int getViewDistance() {
|
||||
return 128;
|
||||
// Driven by server config (video_player.json:render_distance_blocks), pushed to clients
|
||||
// on join. Default 128 = legacy behavior, so an unpaired client behaves identically.
|
||||
return ClientPolicy.renderDistanceBlocks();
|
||||
}
|
||||
|
||||
/** Per-frame render data extracted from the BE. */
|
||||
|
||||
@@ -0,0 +1,174 @@
|
||||
package com.ejclaw.videoplayer.command;
|
||||
|
||||
import com.ejclaw.videoplayer.VideoPlayerConfig;
|
||||
import com.ejclaw.videoplayer.net.ClearCachePayload;
|
||||
import com.ejclaw.videoplayer.net.DeleteCachePayload;
|
||||
import com.ejclaw.videoplayer.net.PreloadPayload;
|
||||
import com.mojang.brigadier.CommandDispatcher;
|
||||
import com.mojang.brigadier.arguments.StringArgumentType;
|
||||
import com.mojang.brigadier.builder.LiteralArgumentBuilder;
|
||||
import com.mojang.brigadier.context.CommandContext;
|
||||
import com.mojang.brigadier.exceptions.CommandSyntaxException;
|
||||
import net.fabricmc.fabric.api.networking.v1.PlayerLookup;
|
||||
import net.fabricmc.fabric.api.networking.v1.ServerPlayNetworking;
|
||||
import net.minecraft.ChatFormatting;
|
||||
import net.minecraft.commands.CommandSourceStack;
|
||||
import net.minecraft.commands.Commands;
|
||||
import net.minecraft.network.chat.ClickEvent;
|
||||
import net.minecraft.network.chat.Component;
|
||||
import net.minecraft.network.chat.MutableComponent;
|
||||
import net.minecraft.network.chat.Style;
|
||||
import net.minecraft.server.MinecraftServer;
|
||||
import net.minecraft.server.level.ServerPlayer;
|
||||
import net.minecraft.server.permissions.Permissions;
|
||||
|
||||
import java.net.URI;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* {@code /videocache add <name> <url>} — name a URL, store it in server config, and broadcast a
|
||||
* preload request to every client.
|
||||
* <br>{@code /videocache list} — print the named index with clickable URLs.
|
||||
* <br>{@code /videocache remove <name>} — drop the entry from server config and tell every client
|
||||
* to delete the matching cache file.
|
||||
*
|
||||
* <p>Replaces the old {@code /videopreload}. Same permission gate
|
||||
* ({@link Permissions#COMMANDS_GAMEMASTER}) so command blocks can drive it.
|
||||
*/
|
||||
public final class VideoCacheCommand {
|
||||
private VideoCacheCommand() {}
|
||||
|
||||
public static void register(CommandDispatcher<CommandSourceStack> dispatcher) {
|
||||
dispatcher.register(build("videoCache"));
|
||||
}
|
||||
|
||||
private static LiteralArgumentBuilder<CommandSourceStack> build(String root) {
|
||||
return Commands.literal(root)
|
||||
.requires(s -> s.permissions().hasPermission(Permissions.COMMANDS_GAMEMASTER))
|
||||
.then(Commands.literal("add")
|
||||
.then(Commands.argument("name", StringArgumentType.word())
|
||||
.then(Commands.argument("url", StringArgumentType.greedyString())
|
||||
.executes(VideoCacheCommand::runAdd))))
|
||||
.then(Commands.literal("list")
|
||||
.executes(VideoCacheCommand::runList))
|
||||
.then(Commands.literal("remove")
|
||||
.then(Commands.argument("name", StringArgumentType.word())
|
||||
.executes(VideoCacheCommand::runRemove)))
|
||||
.then(Commands.literal("clear")
|
||||
.executes(VideoCacheCommand::runClear));
|
||||
}
|
||||
|
||||
private static int runAdd(CommandContext<CommandSourceStack> ctx) throws CommandSyntaxException {
|
||||
CommandSourceStack src = ctx.getSource();
|
||||
String name = StringArgumentType.getString(ctx, "name").trim();
|
||||
String url = StringArgumentType.getString(ctx, "url").trim();
|
||||
|
||||
if (name.isEmpty() || name.length() > 64) {
|
||||
src.sendFailure(Component.literal("이름은 1~64자여야 합니다"));
|
||||
return 0;
|
||||
}
|
||||
if (url.isEmpty() || !(url.startsWith("http://") || url.startsWith("https://"))) {
|
||||
src.sendFailure(Component.literal("url 은 http:// 또는 https:// 로 시작해야 합니다"));
|
||||
return 0;
|
||||
}
|
||||
if (url.length() > 256) {
|
||||
src.sendFailure(Component.literal("url 이 너무 깁니다 (최대 256자)"));
|
||||
return 0;
|
||||
}
|
||||
if (VideoPlayerConfig.cacheUrl(name) != null) {
|
||||
src.sendFailure(Component.literal("이미 사용 중인 이름입니다: " + name));
|
||||
return 0;
|
||||
}
|
||||
if (!VideoPlayerConfig.addCacheEntry(name, url)) {
|
||||
src.sendFailure(Component.literal("저장 실패: 이름 중복 또는 IO 오류"));
|
||||
return 0;
|
||||
}
|
||||
|
||||
MinecraftServer server = src.getServer();
|
||||
PreloadPayload payload = new PreloadPayload(url);
|
||||
int sent = 0;
|
||||
for (ServerPlayer p : PlayerLookup.all(server)) {
|
||||
ServerPlayNetworking.send(p, payload);
|
||||
sent++;
|
||||
}
|
||||
final int sentFinal = sent;
|
||||
src.sendSuccess(() -> Component.literal(
|
||||
"[videocache] 추가됨: " + name + " → " + url
|
||||
+ " (" + sentFinal + " 클라이언트에 preload 전송)"), false);
|
||||
return 1;
|
||||
}
|
||||
|
||||
private static int runList(CommandContext<CommandSourceStack> ctx) {
|
||||
CommandSourceStack src = ctx.getSource();
|
||||
Map<String, String> entries = VideoPlayerConfig.cacheEntries();
|
||||
if (entries.isEmpty()) {
|
||||
src.sendSuccess(() -> Component.literal("[videocache] 저장된 항목이 없습니다")
|
||||
.withStyle(ChatFormatting.GRAY), false);
|
||||
return 0;
|
||||
}
|
||||
src.sendSuccess(() -> Component.literal("[videocache] 저장된 항목 " + entries.size() + "개:")
|
||||
.withStyle(ChatFormatting.YELLOW), false);
|
||||
for (Map.Entry<String, String> e : entries.entrySet()) {
|
||||
String url = e.getValue();
|
||||
ClickEvent click;
|
||||
try {
|
||||
click = new ClickEvent.OpenUrl(URI.create(url));
|
||||
} catch (Throwable t) {
|
||||
click = null; // bad URI — show without click action rather than failing the whole list
|
||||
}
|
||||
Style urlStyle = Style.EMPTY.withColor(ChatFormatting.AQUA).withUnderlined(true);
|
||||
if (click != null) urlStyle = urlStyle.withClickEvent(click);
|
||||
MutableComponent line = Component.literal(" • " + e.getKey() + " : ")
|
||||
.withStyle(ChatFormatting.WHITE)
|
||||
.append(Component.literal(url).withStyle(urlStyle));
|
||||
src.sendSuccess(() -> line, false);
|
||||
}
|
||||
return entries.size();
|
||||
}
|
||||
|
||||
private static int runClear(CommandContext<CommandSourceStack> ctx) {
|
||||
CommandSourceStack src = ctx.getSource();
|
||||
// Drop server-side named entries (preload_urls is left alone — it's an admin-edited
|
||||
// list, not something /videoCache manages).
|
||||
java.util.List<String> urls = VideoPlayerConfig.clearCacheEntries();
|
||||
|
||||
// Always broadcast a full-cache wipe to every client, even if the named index was
|
||||
// empty — leftover files from prior sessions, legacy preload_urls downloads, and
|
||||
// any in-flight stragglers all get scrubbed in one shot.
|
||||
MinecraftServer server = src.getServer();
|
||||
ClearCachePayload payload = new ClearCachePayload();
|
||||
int clients = 0;
|
||||
for (ServerPlayer p : PlayerLookup.all(server)) {
|
||||
ServerPlayNetworking.send(p, payload);
|
||||
clients++;
|
||||
}
|
||||
final int sentFinal = clients;
|
||||
final int countFinal = urls.size();
|
||||
src.sendSuccess(() -> Component.literal(
|
||||
"[videocache] 전체 삭제: 등록 항목 " + countFinal + "개 제거"
|
||||
+ " + " + sentFinal + " 클라이언트 디스크 캐시 전체 wipe"), false);
|
||||
return Math.max(countFinal, 1);
|
||||
}
|
||||
|
||||
private static int runRemove(CommandContext<CommandSourceStack> ctx) throws CommandSyntaxException {
|
||||
CommandSourceStack src = ctx.getSource();
|
||||
String name = StringArgumentType.getString(ctx, "name").trim();
|
||||
String url = VideoPlayerConfig.removeCacheEntry(name);
|
||||
if (url == null) {
|
||||
src.sendFailure(Component.literal("해당 이름의 항목이 없습니다: " + name));
|
||||
return 0;
|
||||
}
|
||||
MinecraftServer server = src.getServer();
|
||||
DeleteCachePayload payload = new DeleteCachePayload(url);
|
||||
int sent = 0;
|
||||
for (ServerPlayer p : PlayerLookup.all(server)) {
|
||||
ServerPlayNetworking.send(p, payload);
|
||||
sent++;
|
||||
}
|
||||
final int sentFinal = sent;
|
||||
src.sendSuccess(() -> Component.literal(
|
||||
"[videocache] 삭제됨: " + name + " → " + url
|
||||
+ " (" + sentFinal + " 클라이언트에 cache_delete 전송)"), false);
|
||||
return 1;
|
||||
}
|
||||
}
|
||||
@@ -19,7 +19,6 @@ public final class VideoDeleteCommand {
|
||||
|
||||
public static void register(CommandDispatcher<CommandSourceStack> dispatcher) {
|
||||
dispatcher.register(build("videoDelete"));
|
||||
dispatcher.register(build("videodelete"));
|
||||
}
|
||||
|
||||
private static com.mojang.brigadier.builder.LiteralArgumentBuilder<CommandSourceStack>
|
||||
|
||||
@@ -22,7 +22,6 @@ public final class VideoMuteCommand {
|
||||
|
||||
public static void register(CommandDispatcher<CommandSourceStack> dispatcher) {
|
||||
dispatcher.register(build("videoMute"));
|
||||
dispatcher.register(build("videomute"));
|
||||
}
|
||||
|
||||
private static com.mojang.brigadier.builder.LiteralArgumentBuilder<CommandSourceStack>
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
package com.ejclaw.videoplayer.command;
|
||||
|
||||
import com.ejclaw.videoplayer.VideoPlayerConfig;
|
||||
import com.ejclaw.videoplayer.block.VideoAnchorBlockEntity;
|
||||
import com.ejclaw.videoplayer.net.SyncAnchorPayload;
|
||||
import com.ejclaw.videoplayer.registry.VideoPlayerBlocks;
|
||||
@@ -27,7 +28,6 @@ public final class VideoPlaceCommand {
|
||||
|
||||
public static void register(CommandDispatcher<CommandSourceStack> dispatcher) {
|
||||
dispatcher.register(build("videoPlace"));
|
||||
dispatcher.register(build("videoplace"));
|
||||
}
|
||||
|
||||
private static com.mojang.brigadier.builder.LiteralArgumentBuilder<CommandSourceStack>
|
||||
@@ -54,9 +54,14 @@ public final class VideoPlaceCommand {
|
||||
}
|
||||
int width = IntegerArgumentType.getInteger(ctx, "width");
|
||||
int height = IntegerArgumentType.getInteger(ctx, "height");
|
||||
String url = StringArgumentType.getString(ctx, "url").trim();
|
||||
if (!url.isEmpty() && !(url.startsWith("http://") || url.startsWith("https://"))) {
|
||||
src.sendFailure(Component.literal("url must be http:// or https:// (or empty)"));
|
||||
String raw = StringArgumentType.getString(ctx, "url").trim();
|
||||
// Accept either an http(s) URL or a /videoCache add <name> entry: resolveUrlOrName()
|
||||
// returns the canonical URL in both cases, or null when a non-URL string didn't match
|
||||
// any named entry.
|
||||
String url = VideoPlayerConfig.resolveUrlOrName(raw);
|
||||
if (url == null) {
|
||||
src.sendFailure(Component.literal(
|
||||
"url 은 http(s):// 로 시작하거나 /videoCache add 로 등록된 이름이어야 합니다: " + raw));
|
||||
return 0;
|
||||
}
|
||||
if (url.length() > 256) url = url.substring(0, 256);
|
||||
|
||||
@@ -1,74 +0,0 @@
|
||||
package com.ejclaw.videoplayer.command;
|
||||
|
||||
import com.ejclaw.videoplayer.net.PreloadPayload;
|
||||
import com.mojang.brigadier.CommandDispatcher;
|
||||
import com.mojang.brigadier.arguments.StringArgumentType;
|
||||
import com.mojang.brigadier.exceptions.CommandSyntaxException;
|
||||
import net.fabricmc.fabric.api.networking.v1.PlayerLookup;
|
||||
import net.fabricmc.fabric.api.networking.v1.ServerPlayNetworking;
|
||||
import net.minecraft.commands.CommandSourceStack;
|
||||
import net.minecraft.commands.Commands;
|
||||
import net.minecraft.network.chat.Component;
|
||||
import net.minecraft.server.MinecraftServer;
|
||||
import net.minecraft.server.level.ServerPlayer;
|
||||
import net.minecraft.server.permissions.Permissions;
|
||||
|
||||
/**
|
||||
* {@code /videoPreload <url>} — broadcast a preload request to every connected client so each
|
||||
* client fully downloads the URL into its local {@code video_player_cache/} folder. Subsequent
|
||||
* {@code /videoPlace} calls (or right-click placements) that use the same URL will then play
|
||||
* from the local file, eliminating mid-stream stutter.
|
||||
*
|
||||
* <p>Uses the same {@link Permissions#COMMANDS_GAMEMASTER} gate as {@code /videoPlace} et al.,
|
||||
* so command blocks (which run at op level 2 by default) can invoke it.
|
||||
*/
|
||||
public final class VideoPreloadCommand {
|
||||
private VideoPreloadCommand() {}
|
||||
|
||||
public static void register(CommandDispatcher<CommandSourceStack> dispatcher) {
|
||||
dispatcher.register(build("videoPreload"));
|
||||
dispatcher.register(build("videopreload"));
|
||||
}
|
||||
|
||||
private static com.mojang.brigadier.builder.LiteralArgumentBuilder<CommandSourceStack>
|
||||
build(String name) {
|
||||
return Commands.literal(name)
|
||||
.requires(s -> s.permissions().hasPermission(Permissions.COMMANDS_GAMEMASTER))
|
||||
.then(Commands.argument("url", StringArgumentType.greedyString())
|
||||
.executes(VideoPreloadCommand::run));
|
||||
}
|
||||
|
||||
private static int run(com.mojang.brigadier.context.CommandContext<CommandSourceStack> ctx)
|
||||
throws CommandSyntaxException {
|
||||
CommandSourceStack src = ctx.getSource();
|
||||
String url = StringArgumentType.getString(ctx, "url").trim();
|
||||
if (url.isEmpty()) {
|
||||
src.sendFailure(Component.literal("url is required"));
|
||||
return 0;
|
||||
}
|
||||
if (!(url.startsWith("http://") || url.startsWith("https://"))) {
|
||||
src.sendFailure(Component.literal("url must be http:// or https://"));
|
||||
return 0;
|
||||
}
|
||||
if (url.length() > 256) {
|
||||
src.sendFailure(Component.literal("url too long (max 256)"));
|
||||
return 0;
|
||||
}
|
||||
|
||||
MinecraftServer server = src.getServer();
|
||||
PreloadPayload payload = new PreloadPayload(url);
|
||||
int sent = 0;
|
||||
for (ServerPlayer p : PlayerLookup.all(server)) {
|
||||
ServerPlayNetworking.send(p, payload);
|
||||
sent++;
|
||||
}
|
||||
final int sentFinal = sent;
|
||||
// Use sendSuccess(..., false) so the chat noise is local-only and command blocks don't
|
||||
// spam every operator on each tick. Be explicit that this is fire-and-forget: each
|
||||
// client posts its own "[videopreload] 완료" chat line when the download finishes.
|
||||
src.sendSuccess(() -> Component.literal(
|
||||
"preload 요청을 " + sentFinal + " 클라이언트에 전송: " + payload.url()
|
||||
+ " (완료 알림 후 재생하세요)"), false);
|
||||
return sent;
|
||||
}
|
||||
}
|
||||
@@ -14,9 +14,6 @@ public final class VideoStickCommand {
|
||||
public static void register(CommandDispatcher<CommandSourceStack> dispatcher) {
|
||||
dispatcher.register(Commands.literal("videoStick")
|
||||
.executes(ctx -> run(ctx.getSource())));
|
||||
// Lowercase alias — Brigadier is case-sensitive.
|
||||
dispatcher.register(Commands.literal("videostick")
|
||||
.executes(ctx -> run(ctx.getSource())));
|
||||
}
|
||||
|
||||
private static int run(CommandSourceStack source) {
|
||||
|
||||
@@ -0,0 +1,32 @@
|
||||
package com.ejclaw.videoplayer.net;
|
||||
|
||||
import com.ejclaw.videoplayer.VideoPlayerMod;
|
||||
import net.minecraft.network.RegistryFriendlyByteBuf;
|
||||
import net.minecraft.network.codec.ByteBufCodecs;
|
||||
import net.minecraft.network.codec.StreamCodec;
|
||||
import net.minecraft.network.protocol.common.custom.CustomPacketPayload;
|
||||
import net.minecraft.resources.Identifier;
|
||||
|
||||
/**
|
||||
* S2C — broadcasts the server-configured client-side policy bundle on join, before any
|
||||
* {@link PreloadPayload}. Carries: {@code maxPerVideoBytes} (per-video download cap),
|
||||
* {@code maxCacheBytes} (total-cache directory cap), and {@code renderDistanceBlocks}
|
||||
* (anchor BE view-distance cap).
|
||||
*/
|
||||
public record CachePolicyPayload(long maxPerVideoBytes, long maxCacheBytes, int renderDistanceBlocks)
|
||||
implements CustomPacketPayload {
|
||||
public static final CustomPacketPayload.Type<CachePolicyPayload> TYPE =
|
||||
new CustomPacketPayload.Type<>(Identifier.fromNamespaceAndPath(VideoPlayerMod.MOD_ID, "cache_policy"));
|
||||
|
||||
public static final StreamCodec<RegistryFriendlyByteBuf, CachePolicyPayload> CODEC = StreamCodec.composite(
|
||||
ByteBufCodecs.VAR_LONG, CachePolicyPayload::maxPerVideoBytes,
|
||||
ByteBufCodecs.VAR_LONG, CachePolicyPayload::maxCacheBytes,
|
||||
ByteBufCodecs.VAR_INT, CachePolicyPayload::renderDistanceBlocks,
|
||||
CachePolicyPayload::new
|
||||
);
|
||||
|
||||
@Override
|
||||
public Type<? extends CustomPacketPayload> type() {
|
||||
return TYPE;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,26 @@
|
||||
package com.ejclaw.videoplayer.net;
|
||||
|
||||
import com.ejclaw.videoplayer.VideoPlayerMod;
|
||||
import net.minecraft.network.RegistryFriendlyByteBuf;
|
||||
import net.minecraft.network.codec.StreamCodec;
|
||||
import net.minecraft.network.protocol.common.custom.CustomPacketPayload;
|
||||
import net.minecraft.resources.Identifier;
|
||||
|
||||
/**
|
||||
* S2C — tell every client to wipe its entire {@code video_player_cache} directory and reset
|
||||
* the in-memory READY/IN_FLIGHT index. Sent by {@code /videoCache clear}. Carries no payload —
|
||||
* the receiving client just nukes everything under the cache dir regardless of how the file
|
||||
* got there (named entry, legacy preload_url, or leftover from a prior session).
|
||||
*/
|
||||
public record ClearCachePayload() implements CustomPacketPayload {
|
||||
public static final CustomPacketPayload.Type<ClearCachePayload> TYPE =
|
||||
new CustomPacketPayload.Type<>(Identifier.fromNamespaceAndPath(VideoPlayerMod.MOD_ID, "cache_clear"));
|
||||
|
||||
public static final StreamCodec<RegistryFriendlyByteBuf, ClearCachePayload> CODEC =
|
||||
StreamCodec.unit(new ClearCachePayload());
|
||||
|
||||
@Override
|
||||
public Type<? extends CustomPacketPayload> type() {
|
||||
return TYPE;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,28 @@
|
||||
package com.ejclaw.videoplayer.net;
|
||||
|
||||
import com.ejclaw.videoplayer.VideoPlayerMod;
|
||||
import net.minecraft.network.RegistryFriendlyByteBuf;
|
||||
import net.minecraft.network.codec.ByteBufCodecs;
|
||||
import net.minecraft.network.codec.StreamCodec;
|
||||
import net.minecraft.network.protocol.common.custom.CustomPacketPayload;
|
||||
import net.minecraft.resources.Identifier;
|
||||
|
||||
/**
|
||||
* S2C — tell connected clients to drop a previously preloaded URL from their on-disk cache.
|
||||
* Sent by {@code /videocache remove <name>}. Each client deletes the matching cache file and
|
||||
* drops it from {@code VideoCache.READY}.
|
||||
*/
|
||||
public record DeleteCachePayload(String url) implements CustomPacketPayload {
|
||||
public static final CustomPacketPayload.Type<DeleteCachePayload> TYPE =
|
||||
new CustomPacketPayload.Type<>(Identifier.fromNamespaceAndPath(VideoPlayerMod.MOD_ID, "cache_delete"));
|
||||
|
||||
public static final StreamCodec<RegistryFriendlyByteBuf, DeleteCachePayload> CODEC = StreamCodec.composite(
|
||||
ByteBufCodecs.STRING_UTF8, DeleteCachePayload::url,
|
||||
DeleteCachePayload::new
|
||||
);
|
||||
|
||||
@Override
|
||||
public Type<? extends CustomPacketPayload> type() {
|
||||
return TYPE;
|
||||
}
|
||||
}
|
||||
35
src/main/java/com/ejclaw/videoplayer/net/MqHelloPayload.java
Normal file
35
src/main/java/com/ejclaw/videoplayer/net/MqHelloPayload.java
Normal file
@@ -0,0 +1,35 @@
|
||||
package com.ejclaw.videoplayer.net;
|
||||
|
||||
import com.ejclaw.videoplayer.VideoPlayerMod;
|
||||
import net.minecraft.network.RegistryFriendlyByteBuf;
|
||||
import net.minecraft.network.codec.ByteBufCodecs;
|
||||
import net.minecraft.network.codec.StreamCodec;
|
||||
import net.minecraft.network.protocol.common.custom.CustomPacketPayload;
|
||||
import net.minecraft.resources.Identifier;
|
||||
|
||||
/**
|
||||
* C2S — client-presence handshake for the {@code music_quiz} datapack
|
||||
* ({@code docs/mc_video_player_mod_integration.md}). Each modded client sends one on JOIN
|
||||
* and one every ~5 s thereafter. The server side flips the player's {@code mq_video_mod}
|
||||
* scoreboard score to {@code 1}, which the datapack reads in its {@code mq:commands/start}
|
||||
* guard.
|
||||
*
|
||||
* <p>Payload body is a single int (protocol version) so future schema bumps don't require
|
||||
* a new packet id. v1 is the only version that exists today.
|
||||
*/
|
||||
public record MqHelloPayload(int version) implements CustomPacketPayload {
|
||||
public static final int CURRENT_VERSION = 1;
|
||||
|
||||
public static final CustomPacketPayload.Type<MqHelloPayload> TYPE =
|
||||
new CustomPacketPayload.Type<>(Identifier.fromNamespaceAndPath(VideoPlayerMod.MOD_ID, "mq_hello"));
|
||||
|
||||
public static final StreamCodec<RegistryFriendlyByteBuf, MqHelloPayload> CODEC = StreamCodec.composite(
|
||||
ByteBufCodecs.VAR_INT, MqHelloPayload::version,
|
||||
MqHelloPayload::new
|
||||
);
|
||||
|
||||
@Override
|
||||
public Type<? extends CustomPacketPayload> type() {
|
||||
return TYPE;
|
||||
}
|
||||
}
|
||||
@@ -1,5 +1,6 @@
|
||||
package com.ejclaw.videoplayer.net;
|
||||
|
||||
import com.ejclaw.videoplayer.VideoPlayerConfig;
|
||||
import com.ejclaw.videoplayer.VideoPlayerMod;
|
||||
import com.ejclaw.videoplayer.block.VideoAnchorBlockEntity;
|
||||
import net.fabricmc.fabric.api.networking.v1.PayloadTypeRegistry;
|
||||
@@ -25,9 +26,13 @@ public final class VideoPlayerNetwork {
|
||||
PayloadTypeRegistry.clientboundPlay().register(OpenScreenPayload.TYPE, OpenScreenPayload.CODEC);
|
||||
PayloadTypeRegistry.clientboundPlay().register(SyncAnchorPayload.TYPE, SyncAnchorPayload.CODEC);
|
||||
PayloadTypeRegistry.clientboundPlay().register(PreloadPayload.TYPE, PreloadPayload.CODEC);
|
||||
PayloadTypeRegistry.clientboundPlay().register(CachePolicyPayload.TYPE, CachePolicyPayload.CODEC);
|
||||
PayloadTypeRegistry.clientboundPlay().register(DeleteCachePayload.TYPE, DeleteCachePayload.CODEC);
|
||||
PayloadTypeRegistry.clientboundPlay().register(ClearCachePayload.TYPE, ClearCachePayload.CODEC);
|
||||
// C2S
|
||||
PayloadTypeRegistry.serverboundPlay().register(SaveConfigPayload.TYPE, SaveConfigPayload.CODEC);
|
||||
PayloadTypeRegistry.serverboundPlay().register(DeleteAnchorPayload.TYPE, DeleteAnchorPayload.CODEC);
|
||||
PayloadTypeRegistry.serverboundPlay().register(MqHelloPayload.TYPE, MqHelloPayload.CODEC);
|
||||
}
|
||||
|
||||
public static void registerServerReceivers() {
|
||||
@@ -95,13 +100,13 @@ public final class VideoPlayerNetwork {
|
||||
|
||||
private static String trimUrl(String s) {
|
||||
if (s == null) return "";
|
||||
String t = s.trim();
|
||||
if (t.length() > 256) t = t.substring(0, 256);
|
||||
// SPEC §4.4: only https?:// or empty
|
||||
if (!t.isEmpty() && !(t.startsWith("http://") || t.startsWith("https://"))) {
|
||||
return "";
|
||||
}
|
||||
return t;
|
||||
// GUI / C2S accepts either an http(s) URL or a /videoCache add <name>. Names resolve
|
||||
// to their stored URL; URLs pass through verbatim. Anything else collapses to empty
|
||||
// (SPEC §4.4: anchors with non-URL urls are no-ops).
|
||||
String resolved = VideoPlayerConfig.resolveUrlOrName(s);
|
||||
if (resolved == null) return "";
|
||||
if (resolved.length() > 256) resolved = resolved.substring(0, 256);
|
||||
return resolved;
|
||||
}
|
||||
|
||||
private static int clamp(int v, int lo, int hi) {
|
||||
|
||||
@@ -0,0 +1,74 @@
|
||||
package com.ejclaw.videoplayer.server;
|
||||
|
||||
import com.ejclaw.videoplayer.VideoPlayerMod;
|
||||
import com.ejclaw.videoplayer.net.MqHelloPayload;
|
||||
import net.fabricmc.fabric.api.event.lifecycle.v1.ServerTickEvents;
|
||||
import net.fabricmc.fabric.api.networking.v1.ServerPlayNetworking;
|
||||
import net.minecraft.server.MinecraftServer;
|
||||
import net.minecraft.server.level.ServerPlayer;
|
||||
import net.minecraft.world.scores.Objective;
|
||||
import net.minecraft.world.scores.ScoreHolder;
|
||||
import net.minecraft.world.scores.Scoreboard;
|
||||
|
||||
/**
|
||||
* Implements the server side of the {@code music_quiz} datapack handshake described in
|
||||
* {@code docs/mc_video_player_mod_integration.md}.
|
||||
*
|
||||
* <p>Two scoreboard writes against objective {@code mq_video_mod} (dummy):
|
||||
* <ul>
|
||||
* <li>Every server tick — {@code #server mq_video_mod = 1}. Proves the mod jar is on the
|
||||
* server side. The datapack's {@code mq:commands/start} guard checks this first.</li>
|
||||
* <li>Every received {@link MqHelloPayload} — {@code <player> mq_video_mod = 1}. Proves
|
||||
* the sending player's client has the mod installed. Per-player flag is needed
|
||||
* because rendering is client-side; the server can't tell from join state alone.</li>
|
||||
* </ul>
|
||||
*
|
||||
* <p>The objective itself ({@code scoreboard objectives add mq_video_mod dummy}) is
|
||||
* created by the datapack's {@code mq:load} function. If it isn't present yet (datapack
|
||||
* not applied, or load hasn't run), the writes are silently skipped — when the datapack
|
||||
* appears later, the next tick / next payload arrival populates it.
|
||||
*/
|
||||
public final class MusicQuizPresence {
|
||||
private MusicQuizPresence() {}
|
||||
|
||||
/** Scoreboard objective name expected by the {@code music_quiz} datapack. */
|
||||
private static final String OBJECTIVE = "mq_video_mod";
|
||||
/** Fake holder used to mark "the server has the mod" (datapack reads {@code #server}). */
|
||||
private static final String SERVER_HOLDER = "#server";
|
||||
|
||||
/** Call from {@code VideoPlayerMod.onInitialize} after payload types are registered. */
|
||||
public static void register() {
|
||||
// (a) per-tick server presence
|
||||
ServerTickEvents.END_SERVER_TICK.register(MusicQuizPresence::onServerTick);
|
||||
|
||||
// (b) per-player client presence — flipped on every received Hello
|
||||
ServerPlayNetworking.registerGlobalReceiver(MqHelloPayload.TYPE, (payload, context) -> {
|
||||
ServerPlayer player = context.player();
|
||||
MinecraftServer server = context.server();
|
||||
// hop back onto the server thread before touching the scoreboard
|
||||
server.execute(() -> markPlayerPresent(server, player));
|
||||
});
|
||||
}
|
||||
|
||||
private static void onServerTick(MinecraftServer server) {
|
||||
Scoreboard sb = server.getScoreboard();
|
||||
Objective obj = sb.getObjective(OBJECTIVE);
|
||||
// Datapack not loaded yet — silently skip. The score holder doesn't exist until
|
||||
// the objective does, and trying to write blind would just blow up.
|
||||
if (obj == null) return;
|
||||
sb.getOrCreatePlayerScore(ScoreHolder.forNameOnly(SERVER_HOLDER), obj).set(1);
|
||||
}
|
||||
|
||||
private static void markPlayerPresent(MinecraftServer server, ServerPlayer player) {
|
||||
Scoreboard sb = server.getScoreboard();
|
||||
Objective obj = sb.getObjective(OBJECTIVE);
|
||||
if (obj == null) {
|
||||
VideoPlayerMod.LOG.debug("[{}] mq hello from {} but objective '{}' not present",
|
||||
VideoPlayerMod.MOD_ID, player.getName().getString(), OBJECTIVE);
|
||||
return;
|
||||
}
|
||||
// ServerPlayer itself implements ScoreHolder, so this matches selector @s on the
|
||||
// datapack side without name-formatting quirks (uuid vs profile name).
|
||||
sb.getOrCreatePlayerScore(player, obj).set(1);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user