first commit

This commit is contained in:
MoePus committed 2025-09-27 15:22:10 +09:00
commit e75b4f309a
20 files changed
+1361

No files matched your search

+26
View File
@@ -0,0 +1,26 @@
# eclipse
bin
*.launch
.settings
.metadata
.classpath
.project
# idea
out
*.ipr
*.iws
*.iml
.idea
# gradle
build
.gradle
# other
eclipse
run
runs
run-data
repo
+183
View File
@@ -0,0 +1,183 @@
plugins {
id 'java-library'
id 'maven-publish'
id 'idea'
id 'net.neoforged.moddev' version '2.0.107'
}
version = mod_version
group = mod_group_id
repositories {
mavenLocal()
maven {
url "https://cursemaven.com"
content {
includeGroup "curse.maven"
}
}
maven {
name = "Modrinth"
url = "https://api.modrinth.com/maven"
}
maven { url = "https://maven.createmod.net" } // Create, Ponder, Flywheel
maven { url = "https://mvn.devos.one/snapshots" } // Registrate
maven { url = "https://raw.githubusercontent.com/Fuzss/modresources/main/maven/" } // ForgeConfigAPIPort
maven { url = "https://maven.theillusivec4.top" }
maven {
// location of the maven that hosts JEI files since January 2023
name = "Jared's maven"
url = "https://maven.blamejared.com/"
}
maven {
// location of a maven mirror for JEI files, as a fallback
name = "ModMaven"
url = "https://modmaven.dev"
}
}
base {
archivesName = mod_id
}
java.toolchain.languageVersion = JavaLanguageVersion.of(21)
neoForge {
// Specify the version of NeoForge to use.
version = project.neo_version
parchment {
mappingsVersion = project.parchment_mappings_version
minecraftVersion = project.parchment_minecraft_version
}
accessTransformers = project.files('src/main/resources/META-INF/accesstransformer.cfg')
// Default run configurations.
// These can be tweaked, removed, or duplicated as needed.
runs {
client {
client()
// Comma-separated list of namespaces to load gametests from. Empty = all namespaces.
systemProperty 'neoforge.enabledGameTestNamespaces', project.mod_id
}
server {
server()
programArgument '--nogui'
systemProperty 'neoforge.enabledGameTestNamespaces', project.mod_id
}
// This run config launches GameTestServer and runs all registered gametests, then exits.
// By default, the server will crash when no gametests are provided.
// The gametest system is also enabled by default for other run configs under the /test command.
gameTestServer {
type = "gameTestServer"
systemProperty 'neoforge.enabledGameTestNamespaces', project.mod_id
}
data {
data()
// example of overriding the workingDirectory set in configureEach above, uncomment if you want to use it
// gameDirectory = project.file('run-data')
// Specify the modid for data generation, where to output the resulting resource, and where to look for existing resources.
programArguments.addAll '--mod', project.mod_id, '--all', '--output', file('src/generated/resources/').getAbsolutePath(), '--existing', file('src/main/resources/').getAbsolutePath()
}
// applies to all the run configs above
configureEach {
// Recommended logging data for a userdev environment
// The markers can be added/remove as needed separated by commas.
// "SCAN": For mods scan.
// "REGISTRIES": For firing of registry events.
// "REGISTRYDUMP": For getting the contents of all registries.
systemProperty 'forge.logging.markers', 'REGISTRIES'
// Recommended logging level for the console
// You can set various levels here.
// Please read: https://stackoverflow.com/questions/2031163/when-to-use-the-different-log-levels
logLevel = org.slf4j.event.Level.DEBUG
}
}
mods {
// define mod <-> source bindings
// these are used to tell the game which sources are for which mod
// mostly optional in a single mod project
// but multi mod projects should define one per mod
"${mod_id}" {
sourceSet(sourceSets.main)
}
}
}
// Include resources generated by data generators.
sourceSets.main.resources { srcDir 'src/generated/resources' }
dependencies {
compileOnly "mezz.jei:jei-${minecraft_version}-common-api:${jei_version}"
compileOnly "mezz.jei:jei-${minecraft_version}-neoforge-api:${jei_version}"
implementation "mezz.jei:jei-${minecraft_version}-neoforge:${jei_version}"
runtimeOnly "curse.maven:spark-361579:6225208"
implementation "curse.maven:create-power-loader-936020:6549980"
implementation("com.simibubi.create:create-${minecraft_version}:${create_version}:slim") { transitive = false }
implementation("net.createmod.ponder:Ponder-NeoForge-${minecraft_version}:${ponder_version}")
compileOnly("dev.engine-room.flywheel:flywheel-neoforge-api-${minecraft_version}:${flywheel_version}")
runtimeOnly("dev.engine-room.flywheel:flywheel-neoforge-${minecraft_version}:${flywheel_version}")
implementation("com.tterrag.registrate:Registrate:${registrate_version}")
runtimeOnly "curse.maven:xaeros-minimap-263420:6778051"
runtimeOnly "curse.maven:xaeros-world-map-317780:6778114"
}
// This block of code expands all declared replace properties in the specified resource targets.
// A missing property will result in an error. Properties are expanded using ${} Groovy notation.
var generateModMetadata = tasks.register("generateModMetadata", ProcessResources) {
var replaceProperties = [minecraft_version : minecraft_version,
minecraft_version_range: minecraft_version_range,
neo_version : neo_version,
neo_version_range : neo_version_range,
loader_version_range : loader_version_range,
mod_id : mod_id,
mod_name : mod_name,
mod_license : mod_license,
mod_version : mod_version,
mod_authors : mod_authors,
mod_description : mod_description]
inputs.properties replaceProperties
expand replaceProperties
from "src/main/templates"
into "build/generated/sources/modMetadata"
}
// Include the output of "generateModMetadata" as an input directory for the build
// this works with both building through Gradle and the IDE.
sourceSets.main.resources.srcDir generateModMetadata
// To avoid having to run "generateModMetadata" manually, make it run on every project reload
neoForge.ideSyncTask generateModMetadata
// Example configuration to allow publishing using the maven-publish plugin
publishing {
publications {
register('mavenJava', MavenPublication) {
from components.java
}
}
repositories {
maven {
url "file://${project.projectDir}/repo"
}
}
}
// IDEA no longer automatically downloads sources/javadoc jars for dependencies, so we need to explicitly enable the behavior.
idea {
module {
downloadSources = true
downloadJavadoc = true
}
}
+47
View File
@@ -0,0 +1,47 @@
# Sets default memory used for gradle commands. Can be overridden by user or command line properties.
org.gradle.jvmargs=-Xmx2G
org.gradle.daemon=true
org.gradle.parallel=true
org.gradle.caching=true
org.gradle.configuration-cache=true
## Environment Properties
# You can find the latest versions here: https://projects.neoforged.net/neoforged/neoforge
# The Minecraft version must agree with the Neo version to get a valid artifact
minecraft_version=1.21.1
# The Minecraft version range can use any release version of Minecraft as bounds.
# Snapshots, pre-releases, and release candidates are not guaranteed to sort properly
# as they do not follow standard versioning conventions.
minecraft_version_range=[1.21.1,1.22)
# The Neo version must agree with the Minecraft version to get a valid artifact
neo_version=21.1.160
# The Neo version range can use any version of Neo as bounds
neo_version_range=[21,)
# The loader version range can only use the major version of FML as bounds
loader_version_range=[4,)
parchment_minecraft_version=1.21.1
parchment_mappings_version=2024.11.17
## Mod Properties
# The unique mod identifier for the mod. Must be lowercase in English locale. Must fit the regex [a-z][a-z0-9_]{1,63}
# Must match the String constant located in the main mod class annotated with @Mod.
mod_id=serverwarashi
# The human-readable display name for the mod.
mod_name=ServerWarashi
# The license of the mod. Review your options at https://choosealicense.com/. All Rights Reserved is the default.
mod_license=MIT
# The mod version. See https://semver.org/
mod_version=1.0.0
# The group ID for the mod. It is only important when publishing as an artifact to a Maven repository.
# This should match the base package used for the mod sources.
# See https://maven.apache.org/guides/mini/guide-naming-conventions.html
mod_group_id=com.moepus
# The authors of the mod. This is a simple text string that is used for display purposes in the mod list.
mod_authors=MoePus
# The description of the mod. This is a simple multiline text string that is used for display purposes in the mod list.
mod_description=
create_version = 6.0.6-98
ponder_version = 1.0.59
flywheel_version = 1.0.4
registrate_version = MC1.21-1.3.0+67
curios_version = 9.2.2
jei_version = 19.21.2.313
Binary file not shown.
+7
View File
@@ -0,0 +1,7 @@
distributionBase=GRADLE_USER_HOME
distributionPath=wrapper/dists
distributionUrl=https\://services.gradle.org/distributions/gradle-8.8-bin.zip
networkTimeout=10000
validateDistributionUrl=true
zipStoreBase=GRADLE_USER_HOME
zipStorePath=wrapper/dists
Vendored
+249
View File
@@ -0,0 +1,249 @@
#!/bin/sh
#
# Copyright © 2015-2021 the original authors.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
##############################################################################
#
# Gradle start up script for POSIX generated by Gradle.
#
# Important for running:
#
# (1) You need a POSIX-compliant shell to run this script. If your /bin/sh is
# noncompliant, but you have some other compliant shell such as ksh or
# bash, then to run this script, type that shell name before the whole
# command line, like:
#
# ksh Gradle
#
# Busybox and similar reduced shells will NOT work, because this script
# requires all of these POSIX shell features:
# * functions;
# * expansions «$var», «${var}», «${var:-default}», «${var+SET}»,
# «${var#prefix}», «${var%suffix}», and «$( cmd )»;
# * compound commands having a testable exit status, especially «case»;
# * various built-in commands including «command», «set», and «ulimit».
#
# Important for patching:
#
# (2) This script targets any POSIX shell, so it avoids extensions provided
# by Bash, Ksh, etc; in particular arrays are avoided.
#
# The "traditional" practice of packing multiple parameters into a
# space-separated string is a well documented source of bugs and security
# problems, so this is (mostly) avoided, by progressively accumulating
# options in "$@", and eventually passing that to Java.
#
# Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS,
# and GRADLE_OPTS) rely on word-splitting, this is performed explicitly;
# see the in-line comments for details.
#
# There are tweaks for specific operating systems such as AIX, CygWin,
# Darwin, MinGW, and NonStop.
#
# (3) This script is generated from the Groovy template
# https://github.com/gradle/gradle/blob/HEAD/platforms/jvm/plugins-application/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt
# within the Gradle project.
#
# You can find Gradle at https://github.com/gradle/gradle/.
#
##############################################################################
# Attempt to set APP_HOME
# Resolve links: $0 may be a link
app_path=$0
# Need this for daisy-chained symlinks.
while
APP_HOME=${app_path%"${app_path##*/}"} # leaves a trailing /; empty if no leading path
[ -h "$app_path" ]
do
ls=$( ls -ld "$app_path" )
link=${ls#*' -> '}
case $link in #(
/*) app_path=$link ;; #(
*) app_path=$APP_HOME$link ;;
esac
done
# This is normally unused
# shellcheck disable=SC2034
APP_BASE_NAME=${0##*/}
# Discard cd standard output in case $CDPATH is set (https://github.com/gradle/gradle/issues/25036)
APP_HOME=$( cd "${APP_HOME:-./}" > /dev/null && pwd -P ) || exit
# Use the maximum available, or set MAX_FD != -1 to use that value.
MAX_FD=maximum
warn () {
echo "$*"
} >&2
die () {
echo
echo "$*"
echo
exit 1
} >&2
# OS specific support (must be 'true' or 'false').
cygwin=false
msys=false
darwin=false
nonstop=false
case "$( uname )" in #(
CYGWIN* ) cygwin=true ;; #(
Darwin* ) darwin=true ;; #(
MSYS* | MINGW* ) msys=true ;; #(
NONSTOP* ) nonstop=true ;;
esac
CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
# Determine the Java command to use to start the JVM.
if [ -n "$JAVA_HOME" ] ; then
if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
# IBM's JDK on AIX uses strange locations for the executables
JAVACMD=$JAVA_HOME/jre/sh/java
else
JAVACMD=$JAVA_HOME/bin/java
fi
if [ ! -x "$JAVACMD" ] ; then
die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
Please set the JAVA_HOME variable in your environment to match the
location of your Java installation."
fi
else
JAVACMD=java
if ! command -v java >/dev/null 2>&1
then
die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
Please set the JAVA_HOME variable in your environment to match the
location of your Java installation."
fi
fi
# Increase the maximum file descriptors if we can.
if ! "$cygwin" && ! "$darwin" && ! "$nonstop" ; then
case $MAX_FD in #(
max*)
# In POSIX sh, ulimit -H is undefined. That's why the result is checked to see if it worked.
# shellcheck disable=SC2039,SC3045
MAX_FD=$( ulimit -H -n ) ||
warn "Could not query maximum file descriptor limit"
esac
case $MAX_FD in #(
'' | soft) :;; #(
*)
# In POSIX sh, ulimit -n is undefined. That's why the result is checked to see if it worked.
# shellcheck disable=SC2039,SC3045
ulimit -n "$MAX_FD" ||
warn "Could not set maximum file descriptor limit to $MAX_FD"
esac
fi
# Collect all arguments for the java command, stacking in reverse order:
# * args from the command line
# * the main class name
# * -classpath
# * -D...appname settings
# * --module-path (only if needed)
# * DEFAULT_JVM_OPTS, JAVA_OPTS, and GRADLE_OPTS environment variables.
# For Cygwin or MSYS, switch paths to Windows format before running java
if "$cygwin" || "$msys" ; then
APP_HOME=$( cygpath --path --mixed "$APP_HOME" )
CLASSPATH=$( cygpath --path --mixed "$CLASSPATH" )
JAVACMD=$( cygpath --unix "$JAVACMD" )
# Now convert the arguments - kludge to limit ourselves to /bin/sh
for arg do
if
case $arg in #(
-*) false ;; # don't mess with options #(
/?*) t=${arg#/} t=/${t%%/*} # looks like a POSIX filepath
[ -e "$t" ] ;; #(
*) false ;;
esac
then
arg=$( cygpath --path --ignore --mixed "$arg" )
fi
# Roll the args list around exactly as many times as the number of
# args, so each arg winds up back in the position where it started, but
# possibly modified.
#
# NB: a `for` loop captures its iteration list before it begins, so
# changing the positional parameters here affects neither the number of
# iterations, nor the values presented in `arg`.
shift # remove old arg
set -- "$@" "$arg" # push replacement arg
done
fi
# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
# Collect all arguments for the java command:
# * DEFAULT_JVM_OPTS, JAVA_OPTS, JAVA_OPTS, and optsEnvironmentVar are not allowed to contain shell fragments,
# and any embedded shellness will be escaped.
# * For example: A user cannot expect ${Hostname} to be expanded, as it is an environment variable and will be
# treated as '${Hostname}' itself on the command line.
set -- \
"-Dorg.gradle.appname=$APP_BASE_NAME" \
-classpath "$CLASSPATH" \
org.gradle.wrapper.GradleWrapperMain \
"$@"
# Stop when "xargs" is not available.
if ! command -v xargs >/dev/null 2>&1
then
die "xargs is not available"
fi
# Use "xargs" to parse quoted args.
#
# With -n1 it outputs one arg per line, with the quotes and backslashes removed.
#
# In Bash we could simply go:
#
# readarray ARGS < <( xargs -n1 <<<"$var" ) &&
# set -- "${ARGS[@]}" "$@"
#
# but POSIX shell has neither arrays nor command substitution, so instead we
# post-process each arg (as a line of input to sed) to backslash-escape any
# character that might be a shell metacharacter, then use eval to reverse
# that process (while maintaining the separation between arguments), and wrap
# the whole thing up as a single "set" statement.
#
# This will of course break if any of these variables contains a newline or
# an unmatched quote.
#
eval "set -- $(
printf '%s\n' "$DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS" |
xargs -n1 |
sed ' s~[^-[:alnum:]+,./:=@_]~\\&~g; ' |
tr '\n' ' '
)" '"$@"'
exec "$JAVACMD" "$@"
Vendored
+92
View File
@@ -0,0 +1,92 @@
@rem
@rem Copyright 2015 the original author or authors.
@rem
@rem Licensed under the Apache License, Version 2.0 (the "License");
@rem you may not use this file except in compliance with the License.
@rem You may obtain a copy of the License at
@rem
@rem https://www.apache.org/licenses/LICENSE-2.0
@rem
@rem Unless required by applicable law or agreed to in writing, software
@rem distributed under the License is distributed on an "AS IS" BASIS,
@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@rem See the License for the specific language governing permissions and
@rem limitations under the License.
@rem
@if "%DEBUG%"=="" @echo off
@rem ##########################################################################
@rem
@rem Gradle startup script for Windows
@rem
@rem ##########################################################################
@rem Set local scope for the variables with windows NT shell
if "%OS%"=="Windows_NT" setlocal
set DIRNAME=%~dp0
if "%DIRNAME%"=="" set DIRNAME=.
@rem This is normally unused
set APP_BASE_NAME=%~n0
set APP_HOME=%DIRNAME%
@rem Resolve any "." and ".." in APP_HOME to make it shorter.
for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m"
@rem Find java.exe
if defined JAVA_HOME goto findJavaFromJavaHome
set JAVA_EXE=java.exe
%JAVA_EXE% -version >NUL 2>&1
if %ERRORLEVEL% equ 0 goto execute
echo. 1>&2
echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. 1>&2
echo. 1>&2
echo Please set the JAVA_HOME variable in your environment to match the 1>&2
echo location of your Java installation. 1>&2
goto fail
:findJavaFromJavaHome
set JAVA_HOME=%JAVA_HOME:"=%
set JAVA_EXE=%JAVA_HOME%/bin/java.exe
if exist "%JAVA_EXE%" goto execute
echo. 1>&2
echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME% 1>&2
echo. 1>&2
echo Please set the JAVA_HOME variable in your environment to match the 1>&2
echo location of your Java installation. 1>&2
goto fail
:execute
@rem Setup the command line
set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
@rem Execute Gradle
"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %*
:end
@rem End local scope for the variables with windows NT shell
if %ERRORLEVEL% equ 0 goto mainEnd
:fail
rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
rem the _cmd.exe /c_ return code!
set EXIT_CODE=%ERRORLEVEL%
if %EXIT_CODE% equ 0 set EXIT_CODE=1
if not ""=="%GRADLE_EXIT_CONSOLE%" exit %EXIT_CODE%
exit /b %EXIT_CODE%
:mainEnd
if "%OS%"=="Windows_NT" endlocal
:omega
+11
View File
@@ -0,0 +1,11 @@
pluginManagement {
repositories {
mavenLocal()
gradlePluginPortal()
maven { url = 'https://maven.neoforged.net/releases' }
}
}
plugins {
id 'org.gradle.toolchains.foojay-resolver-convention' version '0.8.0'
}
@@ -0,0 +1,22 @@
package com.moepus.serverwarashi;
import net.neoforged.neoforge.common.ModConfigSpec;
public class Config
{
private static final ModConfigSpec.Builder BUILDER = new ModConfigSpec.Builder();
public static final ModConfigSpec.ConfigValue<Boolean> ENABLED = BUILDER
.define("enabled", false);
public static final ModConfigSpec.ConfigValue<Boolean> PAUSE_ALL_TICKETS = BUILDER
.define("pause_all_tickets", false);
public static final ModConfigSpec.ConfigValue<Integer> TICKET_GROUP_SIZE = BUILDER
.defineInRange("ticket_group_size", 48, 16, 2048);
public static final ModConfigSpec.ConfigValue<Integer> RUN_EVERY = BUILDER
.defineInRange("run_every", 10, 1, 1200);
public static final ModConfigSpec.ConfigValue<Integer> PROXIMITY_THRESHOLD = BUILDER
.defineInRange("proximity_threshold", 5, 1, 12);
static final ModConfigSpec SPEC = BUILDER.build();
}
@@ -0,0 +1,10 @@
package com.moepus.serverwarashi;
public interface IPauseableTicket {
boolean serverWarashi$isPaused();
boolean serverWarashi$needUpdate();
void serverWarashi$setPaused(boolean paused);
void serverWarashi$clearDirty();
int serverWarashi$getLevel();
Object serverWarashi$getKey();
}
@@ -0,0 +1,27 @@
package com.moepus.serverwarashi;
import com.mojang.logging.LogUtils;
import net.neoforged.bus.api.IEventBus;
import net.neoforged.bus.api.SubscribeEvent;
import net.neoforged.fml.ModContainer;
import net.neoforged.fml.common.Mod;
import net.neoforged.fml.config.ModConfig;
import net.neoforged.neoforge.common.NeoForge;
import net.neoforged.neoforge.event.RegisterCommandsEvent;
import org.slf4j.Logger;
@Mod(Serverwarashi.MODID)
public class Serverwarashi {
public static final String MODID = "serverwarashi";
public static final Logger LOGGER = LogUtils.getLogger();
public Serverwarashi(IEventBus modEventBus, ModContainer modContainer) {
NeoForge.EVENT_BUS.register(this);
modContainer.registerConfig(ModConfig.Type.SERVER, Config.SPEC);
}
@SubscribeEvent
public void onRegisterCommands(RegisterCommandsEvent event) {
WarashiCommands.register(event.getDispatcher());
}
}
@@ -0,0 +1,194 @@
package com.moepus.serverwarashi;
import com.moepus.serverwarashi.mixin.DistanceManagerAccessor;
import it.unimi.dsi.fastutil.longs.*;
import net.minecraft.server.level.DistanceManager;
import net.minecraft.server.level.ServerLevel;
import net.minecraft.server.level.Ticket;
import net.minecraft.server.level.TicketType;
import net.minecraft.util.SortedArraySet;
import net.minecraft.world.level.ChunkPos;
import net.minecraft.world.level.Level;
import net.neoforged.bus.api.SubscribeEvent;
import net.neoforged.fml.common.EventBusSubscriber;
import net.neoforged.neoforge.event.tick.LevelTickEvent;
import net.neoforged.neoforge.event.tick.ServerTickEvent;
import org.jetbrains.annotations.NotNull;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.List;
@EventBusSubscriber(modid = Serverwarashi.MODID)
public class TicketManager {
static int age = 0;
@SubscribeEvent
public static void onServerTickPre(ServerTickEvent.Pre event) {
age++;
}
@SubscribeEvent
public static void onLevelTickPre(LevelTickEvent.Pre event) {
if (!Config.ENABLED.get()) return;
Level level = event.getLevel();
if (level.isClientSide) return;
if (level instanceof ServerLevel serverLevel) {
processTickets(serverLevel);
}
}
private static void processTickets(ServerLevel level) {
if (age % Config.RUN_EVERY.get() != 0) return;
DistanceManager distanceManager = level.getChunkSource().chunkMap.getDistanceManager();
var tickets = ((DistanceManagerAccessor) distanceManager).getTickets().long2ObjectEntrySet();
// Collect all tickets
List<TicketEntry> allTickets = new ArrayList<>();
for (var entry : tickets) {
long chunkPosLong = entry.getLongKey();
int chunkX = ChunkPos.getX(chunkPosLong);
int chunkZ = ChunkPos.getZ(chunkPosLong);
long morton = morton2D(chunkX, chunkZ);
for (Ticket<?> ticket : entry.getValue()) {
if (isSystemTicket(ticket)) continue;
allTickets.add(new TicketEntry(ticket, morton, chunkPosLong));
}
}
if (allTickets.isEmpty()) return;
if (Config.PAUSE_ALL_TICKETS.get()) {
Long2BooleanOpenHashMap modifiedChunks = new Long2BooleanOpenHashMap();
for (TicketEntry entry : allTickets) {
IPauseableTicket pauseable = (IPauseableTicket) (Object) entry.ticket;
pauseable.serverWarashi$setPaused(true);
if (pauseable.serverWarashi$needUpdate()) {
modifiedChunks.put(entry.chunkPos, false);
pauseable.serverWarashi$clearDirty();
}
}
updateChunkLevel((DistanceManagerAccessor) distanceManager, modifiedChunks);
return;
}
// Sort tickets by Morton code
allTickets.sort(Comparator.comparingLong(te -> te.morton));
List<List<TicketEntry>> buckets = divideChunkBuckets(allTickets);
// Determine active bucket
int currentGroupIndex = (age / Config.RUN_EVERY.get()) % buckets.size();
Long2BooleanOpenHashMap modifiedChunks = new Long2BooleanOpenHashMap();
for (int i = 0; i < buckets.size(); i++) {
boolean isActive = (i == currentGroupIndex);
for (TicketEntry entry : buckets.get(i)) {
IPauseableTicket pauseable = (IPauseableTicket) (Object) entry.ticket;
pauseable.serverWarashi$setPaused(!isActive);
if (pauseable.serverWarashi$needUpdate()) {
modifiedChunks.computeIfAbsent(entry.chunkPos, k -> isActive);
pauseable.serverWarashi$clearDirty();
}
}
}
// Update chunk levels
updateChunkLevel((DistanceManagerAccessor) distanceManager, modifiedChunks);
}
private static void updateChunkLevel(DistanceManagerAccessor distanceManager, Long2BooleanOpenHashMap modifiedChunks) {
for (long chunkPos : modifiedChunks.keySet()) {
var ticketSet = distanceManager.getTickets().get(chunkPos);
if (ticketSet != null) {
int newLevel = updateTicketSet(ticketSet);
boolean isDecreasing = modifiedChunks.get(chunkPos);
distanceManager.getTicketTracker().update(chunkPos, newLevel, isDecreasing);
if (!ticketSet.isEmpty() && isDecreasing) {
distanceManager.getTickingTicketsTracker().update(chunkPos, newLevel, true);
}
}
}
}
private static int updateTicketSet(SortedArraySet<Ticket<?>> tickets) {
List<Ticket<?>> tmp = new ArrayList<>(tickets);
tickets.clear();
tickets.addAll(tmp);
return getTicketLevel(tickets);
}
private static int getTicketLevel(SortedArraySet<Ticket<?>> tickets) {
if (tickets.isEmpty()) return 45;
return tickets.first().getTicketLevel();
}
private static @NotNull List<List<TicketEntry>> divideChunkBuckets(List<TicketEntry> allTickets) {
int targetBucketSize = Config.TICKET_GROUP_SIZE.get();
int maxBucketSize = targetBucketSize * 2;
List<List<TicketEntry>> buckets = new ArrayList<>();
List<TicketEntry> current = new ArrayList<>();
for (int i = 0; i < allTickets.size(); i++) {
TicketEntry entry = allTickets.get(i);
if (current.size() < targetBucketSize) {
current.add(entry);
} else {
boolean tooClose = false;
if (!current.isEmpty()) {
long diff = entry.morton - current.get(current.size() - 1).morton;
tooClose = (diff <= Config.PROXIMITY_THRESHOLD.get());
}
if (tooClose && current.size() < maxBucketSize) {
current.add(entry);
} else {
buckets.add(current);
current = new ArrayList<>();
current.add(entry);
}
}
}
if (!current.isEmpty()) {
buckets.add(current);
}
return buckets;
}
private static boolean isSystemTicket(Ticket<?> ticket) {
if (((IPauseableTicket) (Object) ticket).serverWarashi$getLevel() > 32) return true;
var type = ticket.getType();
return type == TicketType.START ||
type == TicketType.PLAYER ||
type == TicketType.FORCED ||
type == TicketType.PORTAL ||
type == TicketType.POST_TELEPORT ||
type == TicketType.DRAGON;
}
private static long morton2D(int x, int z) {
long xx = Integer.toUnsignedLong(x);
long zz = Integer.toUnsignedLong(z);
return interleaveBits(xx) | (interleaveBits(zz) << 1);
}
private static long interleaveBits(long x) {
x = (x | (x << 16)) & 0x0000FFFF0000FFFFL;
x = (x | (x << 8)) & 0x00FF00FF00FF00FFL;
x = (x | (x << 4)) & 0x0F0F0F0F0F0F0F0FL;
x = (x | (x << 2)) & 0x3333333333333333L;
x = (x | (x << 1)) & 0x5555555555555555L;
return x;
}
private record TicketEntry(Ticket<?> ticket, long morton, long chunkPos) {
}
}
@@ -0,0 +1,108 @@
package com.moepus.serverwarashi;
import net.minecraft.core.BlockPos;
import net.minecraft.network.chat.*;
import net.minecraft.server.level.ServerLevel;
import net.minecraft.server.level.Ticket;
import net.minecraft.world.entity.Entity;
import net.minecraft.world.level.block.state.BlockState;
import java.lang.reflect.Field;
import java.util.Objects;
import java.util.UUID;
public class TicketOwner<OwnerType> {
private Object owner;
private String name;
private BlockPos pos;
public TicketOwner(Ticket<OwnerType> ticket, ServerLevel level) {
IPauseableTicket pauseable = (IPauseableTicket) (Object) ticket;
OwnerType key = (OwnerType) pauseable.serverWarashi$getKey();
this.name = ticket.getType().toString();
if (key.getClass().getName().endsWith("ForcedChunkManager$TicketOwner")) {
try {
Field ownerField = key.getClass().getDeclaredField("owner");
ownerField.setAccessible(true);
owner = ownerField.get(key);
} catch (NoSuchFieldException | IllegalAccessException ignored) {
}
if (owner instanceof BlockPos blockPos) {
BlockState blockState = level.getBlockState(blockPos);
if (blockState != null) {
this.name = blockState.getBlock().toString();
} else {
this.name = "Unknown block";
}
this.pos = blockPos;
} else if (owner instanceof UUID uuid) {
Entity entity = level.getEntity(uuid);
if (entity != null) {
this.name = entity.getType().toString();
this.pos = entity.blockPosition();
} else {
this.name = "Unknown entity";
}
}
} else {
owner = key;
if (owner instanceof BlockPos blockPos) {
this.pos = blockPos;
}
}
}
@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
TicketOwner<?> that = (TicketOwner<?>) o;
return Objects.equals(this.name, that.name)
&& Objects.equals(this.owner, that.owner);
}
@Override
public int hashCode() {
return Objects.hash(name, owner);
}
private String getName() {
return name;
}
@Override
public String toString() {
String position = (pos == null) ? "null" : String.format("(%d, %d, %d)", pos.getX(), pos.getY(), pos.getZ());
return getName() + "@" + position;
}
public Component asComponent() {
if (pos == null) {
return Component.literal(getName() + "@null");
}
int x = pos.getX();
int y = pos.getY();
int z = pos.getZ();
MutableComponent message = Component.empty();
// 普通部分:名字 + @
Component base = Component.literal(getName() + "@");
// 坐标部分:金色 + 可点击
Component coord = Component.literal("(" + x + "," + y + "," + z + ")")
.setStyle(
Style.EMPTY
.withColor(TextColor.fromRgb(0xFFD700))
.withClickEvent(new ClickEvent(
ClickEvent.Action.RUN_COMMAND,
String.format("/tp @p %d %d %d", x, y, z)
))
);
return message.append(base).append(coord);
}
}
@@ -0,0 +1,184 @@
package com.moepus.serverwarashi;
import com.moepus.serverwarashi.mixin.DistanceManagerAccessor;
import com.mojang.brigadier.CommandDispatcher;
import com.mojang.brigadier.arguments.BoolArgumentType;
import com.mojang.brigadier.arguments.IntegerArgumentType;
import com.mojang.brigadier.context.CommandContext;
import com.mojang.brigadier.suggestion.Suggestions;
import com.mojang.brigadier.suggestion.SuggestionsBuilder;
import it.unimi.dsi.fastutil.longs.Long2ObjectMap;
import net.minecraft.commands.CommandSourceStack;
import net.minecraft.commands.SharedSuggestionProvider;
import net.minecraft.network.chat.Component;
import net.minecraft.network.chat.MutableComponent;
import net.minecraft.server.level.*;
import net.minecraft.util.SortedArraySet;
import net.minecraft.world.level.ChunkPos;
import net.minecraft.world.level.chunk.ChunkAccess;
import net.minecraft.world.level.chunk.status.ChunkStatus;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.concurrent.CompletableFuture;
public class WarashiCommands {
private static final java.util.function.Predicate<CommandSourceStack> ADMIN_PERMISSION =
source -> source.hasPermission(2);
public static void register(CommandDispatcher<CommandSourceStack> dispatcher) {
dispatcher.register(net.minecraft.commands.Commands.literal("warashi")
.requires(ADMIN_PERMISSION)
.then(net.minecraft.commands.Commands.literal("enabled")
.executes(context -> {
context.getSource().sendSuccess(() ->
Component.literal("enabled = " + Config.ENABLED.get()), false);
return 1;
})
.then(net.minecraft.commands.Commands.argument("enabled", BoolArgumentType.bool())
.suggests(WarashiCommands::suggestBoolean)
.executes(context -> {
Config.ENABLED.set(BoolArgumentType.getBool(context, "enabled"));
Config.SPEC.save();
context.getSource().sendSuccess(() ->
Component.literal("enabled set to " + Config.ENABLED.get()), false);
return 1;
})
)
)
.then(net.minecraft.commands.Commands.literal("ticket")
.then(net.minecraft.commands.Commands.literal("pauseAll")
.executes(context -> {
context.getSource().sendSuccess(() ->
Component.literal("pauseAll = " + Config.PAUSE_ALL_TICKETS.get()), false);
return 1;
})
.then(net.minecraft.commands.Commands.argument("pauseAll", BoolArgumentType.bool())
.suggests(WarashiCommands::suggestBoolean)
.executes(context -> {
Config.PAUSE_ALL_TICKETS.set(BoolArgumentType.getBool(context, "pauseAll"));
Config.SPEC.save();
context.getSource().sendSuccess(() ->
Component.literal("pauseAll set to " + Config.PAUSE_ALL_TICKETS.get()), false);
return 1;
})
)
)
.then(net.minecraft.commands.Commands.literal("groupSize")
.executes(context -> {
context.getSource().sendSuccess(() ->
Component.literal("groupSize = " + Config.TICKET_GROUP_SIZE.get()), false);
return 1;
})
.then(net.minecraft.commands.Commands.argument("groupSize", IntegerArgumentType.integer(16, 2048))
.executes(context -> {
Config.TICKET_GROUP_SIZE.set(IntegerArgumentType.getInteger(context, "groupSize"));
Config.SPEC.save();
context.getSource().sendSuccess(() ->
Component.literal("groupSize set to " + Config.TICKET_GROUP_SIZE.get()), false);
return 1;
})
)
)
.then(net.minecraft.commands.Commands.literal("runEvery")
.executes(context -> {
context.getSource().sendSuccess(() ->
Component.literal("runEvery = " + Config.RUN_EVERY.get()), false);
return 1;
})
.then(net.minecraft.commands.Commands.argument("runEvery", IntegerArgumentType.integer(1, 1200))
.executes(context -> {
Config.RUN_EVERY.set(IntegerArgumentType.getInteger(context, "runEvery"));
Config.SPEC.save();
context.getSource().sendSuccess(() ->
Component.literal("runEvery set to " + Config.RUN_EVERY.get()), false);
return 1;
})
)
)
.then(net.minecraft.commands.Commands.literal("dump")
.executes(context -> DumpTickets(context, false))
.then(net.minecraft.commands.Commands.literal("currentWorking")
.executes(context -> DumpTickets(context, true))
)
)
)
);
}
private static CompletableFuture<Suggestions> suggestBoolean(
CommandContext<CommandSourceStack> context, SuggestionsBuilder builder) {
return SharedSuggestionProvider.suggest(List.of("true", "false"), builder);
}
private static Ticket<?> GetTicket(SortedArraySet<Ticket<?>> tickets, boolean currentWorking) {
for (Ticket<?> ticket : tickets) {
if (ticket.getType() == TicketType.PLAYER) continue;
if (ticket.getType() == TicketType.START) continue;
int level;
if (currentWorking) {
level = ticket.getTicketLevel();
} else {
IPauseableTicket pauseable = (IPauseableTicket) (Object) ticket;
level = pauseable.serverWarashi$getLevel();
}
if (level > 32) continue;
return ticket;
}
return null;
}
private static int DumpTickets(CommandContext<CommandSourceStack> context, boolean currentWorking) {
context.getSource().sendSuccess(() -> {
MutableComponent message = Component.empty().append("Dumped tickets:\n");
ChunkMap chunkMap = context.getSource().getLevel().getChunkSource().chunkMap;
HashMap<TicketOwner<?>, Set<Long>> ownerMap = new HashMap<>();
ServerLevel level = context.getSource().getLevel();
for (Long2ObjectMap.Entry<ChunkHolder> entry : chunkMap.visibleChunkMap.long2ObjectEntrySet()) {
long chunkPos = entry.getLongKey();
DistanceManagerAccessor distanceManager = (DistanceManagerAccessor) chunkMap.getDistanceManager();
var tickets = distanceManager.getTickets().get(chunkPos);
if (tickets == null || tickets.isEmpty()) continue;
Ticket<?> ticket = GetTicket(tickets, currentWorking);
if (ticket == null) continue;
TicketOwner<?> owner = new TicketOwner<>(ticket, level);
ownerMap.computeIfAbsent(owner, k -> new HashSet<>()).add(chunkPos);
}
for (var entry : ownerMap.entrySet()) {
TicketOwner<?> owner = entry.getKey();
Set<Long> chunks = entry.getValue();
message.append(owner.asComponent());
message.append(" loads " + chunks.size() + " chunks ");
int totalBlockEntities = 0;
for (long chunkPos : chunks) {
ChunkPos pos = new ChunkPos(chunkPos);
ChunkAccess chunk = level.getChunk(pos.x, pos.z, ChunkStatus.FULL, false);
if (chunk != null) {
totalBlockEntities += chunk.getBlockEntitiesPos().size();
}
}
message.append("with " + totalBlockEntities + " block entities\n");
}
if (ownerMap.isEmpty()) {
message.append("No tickets found\n");
}
return message;
}, true)
;
return 1;
}
}
@@ -0,0 +1,28 @@
package com.moepus.serverwarashi.mixin;
import it.unimi.dsi.fastutil.longs.Long2ObjectOpenHashMap;
import net.minecraft.server.level.DistanceManager;
import net.minecraft.server.level.Ticket;
import net.minecraft.server.level.TickingTracker;
import net.minecraft.util.SortedArraySet;
import org.spongepowered.asm.mixin.Mixin;
import org.spongepowered.asm.mixin.gen.Accessor;
import org.spongepowered.asm.mixin.gen.Invoker;
@Mixin(value = DistanceManager.class, remap = false)
public interface DistanceManagerAccessor {
@Accessor
Long2ObjectOpenHashMap<SortedArraySet<Ticket<?>>> getTickets();
@Accessor
DistanceManager.ChunkTicketTracker getTicketTracker();
@Accessor
Long2ObjectOpenHashMap<SortedArraySet<Ticket<?>>> getForcedTickets();
@Accessor
TickingTracker getTickingTicketsTracker();
@Invoker("getTicketDebugString")
String invokeGetTicketDebugString(long chunkPos);
}
@@ -0,0 +1,70 @@
package com.moepus.serverwarashi.mixin;
import com.moepus.serverwarashi.IPauseableTicket;
import net.minecraft.server.level.Ticket;
import org.spongepowered.asm.mixin.Final;
import org.spongepowered.asm.mixin.Mixin;
import org.spongepowered.asm.mixin.Shadow;
import org.spongepowered.asm.mixin.Unique;
import org.spongepowered.asm.mixin.gen.Accessor;
import org.spongepowered.asm.mixin.injection.At;
import org.spongepowered.asm.mixin.injection.Inject;
import org.spongepowered.asm.mixin.injection.callback.CallbackInfoReturnable;
@Mixin(value = Ticket.class, remap = false)
public abstract class TicketMixin implements IPauseableTicket {
@Shadow
@Final
private int ticketLevel;
@Unique
private boolean serverWarashi$isPaused = false;
@Unique
private boolean serverWarashi$dirty = false;
@Override
@Unique
public boolean serverWarashi$isPaused() {
return serverWarashi$isPaused;
}
@Override
public boolean serverWarashi$needUpdate() {
return serverWarashi$dirty;
}
@Override
@Unique
public void serverWarashi$setPaused(boolean paused) {
if (this.serverWarashi$isPaused != paused) {
this.serverWarashi$dirty = true;
}
serverWarashi$isPaused = paused;
}
@Override
public void serverWarashi$clearDirty() {
serverWarashi$dirty = false;
}
@Override
public int serverWarashi$getLevel() {
return ticketLevel;
}
@Override
public Object serverWarashi$getKey() {
return getKey();
}
@Inject(method = "getTicketLevel", at = @At("HEAD"), cancellable = true)
private void onGetTicketLevel(CallbackInfoReturnable<Integer> cir) {
if (serverWarashi$isPaused) {
cir.setReturnValue(33);
}
}
@Accessor
abstract Object getKey();
}
@@ -0,0 +1,3 @@
public net.minecraft.server.level.DistanceManager$ChunkTicketTracker
public net.minecraft.server.level.Ticket timedOut
public net.minecraft.server.level.ChunkMap visibleChunkMap
@@ -0,0 +1,3 @@
{
}
@@ -0,0 +1,18 @@
{
"required": true,
"minVersion": "0.8",
"package": "com.moepus.serverwarashi.mixin",
"compatibilityLevel": "JAVA_21",
"mixins": [
"DistanceManagerAccessor",
"TicketMixin"
],
"client": [
],
"injectors": {
"defaultRequire": 1
},
"overwrites": {
"requireAnnotations": true
}
}
@@ -0,0 +1,79 @@
# This is an example mods.toml file. It contains the data relating to the loading mods.
# There are several mandatory fields (#mandatory), and many more that are optional (#optional).
# The overall format is standard TOML format, v0.5.0.
# Note that there are a couple of TOML lists in this file.
# Find more information on toml format here: https://github.com/toml-lang/toml
# The name of the mod loader type to load - for regular FML @Mod mods it should be javafml
modLoader = "javafml" #mandatory
# A version range to match for said mod loader - for regular FML @Mod it will be the the FML version. This is currently 47.
loaderVersion = "${loader_version_range}" #mandatory
# The license for you mod. This is mandatory metadata and allows for easier comprehension of your redistributive properties.
# Review your options at https://choosealicense.com/. All rights reserved is the default copyright stance, and is thus the default here.
license = "${mod_license}"
# A URL to refer people to when problems occur with this mod
#issueTrackerURL="https://change.me.to.your.issue.tracker.example.invalid/" #optional
# A list of mods - how many allowed here is determined by the individual mod loader
[[mods]] #mandatory
# The modid of the mod
modId = "${mod_id}" #mandatory
# The version number of the mod
version = "${mod_version}" #mandatory
# A display name for the mod
displayName = "${mod_name}" #mandatory
# A URL to query for updates for this mod. See the JSON update specification https://docs.neoforge.net/docs/misc/updatechecker/
#updateJSONURL="https://change.me.example.invalid/updates.json" #optional
# A URL for the "homepage" for this mod, displayed in the mod UI
#displayURL="https://change.me.to.your.mods.homepage.example.invalid/" #optional
# A file name (in the root of the mod JAR) containing a logo for display
#logoFile="serverwarashi.png" #optional
# A text field displayed in the mod UI
#credits="" #optional
# A text field displayed in the mod UI
authors = "${mod_authors}" #optional
# The description text for the mod (multi line!) (#mandatory)
description = '''${mod_description}'''
# The [[mixins]] block allows you to declare your mixin config to FML so that it gets loaded.
[[mixins]]
config = "${mod_id}.mixins.json"
# The [[accessTransformers]] block allows you to declare where your AT file is.
# If this block is omitted, a fallback attempt will be made to load an AT from META-INF/accesstransformer.cfg
#[[accessTransformers]]
#file="META-INF/accesstransformer.cfg"
# The coremods config file path is not configurable and is always loaded from META-INF/coremods.json
# A dependency - use the . to indicate dependency for a specific modid. Dependencies are optional.
[[dependencies."${mod_id}"]] #optional
# the modid of the dependency
modId = "neoforge" #mandatory
# The type of the dependency. Can be one of "required", "optional", "incompatible" or "discouraged" (case insensitive).
# 'required' requires the mod to exist, 'optional' does not
# 'incompatible' will prevent the game from loading when the mod exists, and 'discouraged' will show a warning
type = "required" #mandatory
# Optional field describing why the dependency is required or why it is incompatible
# reason="..."
# The version range of the dependency
versionRange = "${neo_version_range}" #mandatory
# An ordering relationship for the dependency.
# BEFORE - This mod is loaded BEFORE the dependency
# AFTER - This mod is loaded AFTER the dependency
ordering = "NONE"
# Side this dependency is applied on - BOTH, CLIENT, or SERVER
side = "BOTH"
# Here's another dependency
[[dependencies."${mod_id}"]]
modId = "minecraft"
type = "required"
# This version range declares a minimum of the current minecraft version up to but not including the next major version
versionRange = "${minecraft_version_range}"
ordering = "NONE"
side = "BOTH"
# Features are specific properties of the game environment, that you may want to declare you require. This example declares
# that your mod requires GL version 3.2 or higher. Other features will be added. They are side aware so declaring this won't
# stop your mod loading on the server for example.
#[features."${mod_id}"]
#openGLVersion="[3.2,)"