1 Commits

9 changed files with 9 additions and 374 deletions
-2
View File
@@ -6,5 +6,3 @@
/compile_commands.json
/CMakeLists.txt
/.vscode
/.idea
github_mirror.lua
-4
View File
@@ -1,9 +1,6 @@
#pragma once
#include "Global.h"
#include <gmlib/mc/world/actor/UnloadedActor.h>
extern void MainForm(Player* player);
using namespace ll::chrono_literals;
namespace Cleaner {
@@ -20,7 +17,6 @@ extern void CleanTask();
extern void reloadCleaner();
extern void loadCleaner();
extern void unloadCleaner();
extern bool shouldIgnore(gmlib::GMActor* ac);
extern bool isMatch(std::string& A, std::string& B);
-288
View File
@@ -1,288 +0,0 @@
#include "Cleaner.h"
#include "Global.h"
#include "Mod.h"
#include "ll/api/base/Containers.h"
#include "ll/api/service/Bedrock.h"
#include "mc/common/Globals.h"
#include "mc/world/level/Level.h"
#include <gmlib/mc/world/Level.h>
#include <gmlib/mc/world/actor/UnloadedActor.h>
#include <ll/api/form/CustomForm.h>
#include <ll/api/form/ModalForm.h>
#include <ll/api/form/SimpleForm.h>
#include <string>
#include <thread>
#include <vector>
#include <mutex>
using UnloadEntityMap = std::unordered_map<std::string, std::vector<gmlib::UnloadedActor>>;
struct {
std::chrono::system_clock::time_point lastUpdate{};
std::atomic_bool isUpdating{false};
UnloadEntityMap offlineEntities{};
ll::SmallDenseSet<ActorUniqueID> waitedPlayers{};
std::atomic_bool requireUpdate{false};
std::mutex offlineEntitiesMutex; // ✅ 新增
} OfflineEntity;
auto typeNameToLocString(std::string const& typeName) {
return EntityTypeToLocString(
EntityTypeFromString(typeName),
ActorTypeNamespaceRules::ReturnWithoutNamespace
);
}
auto getAllEntityTypes() {
return std::ranges::to<ll::SmallDenseSet<std::string>>(
ll::service::getLevel()->getRuntimeActorList()
| std::views::transform(&Actor::getTypeName)
);
}
auto getEntityCountByType(std::string const& typeName) {
return std::ranges::count_if(
ll::service::getLevel()->getRuntimeActorList(),
[&](const Actor* a) { return a && a->getTypeName() == typeName; }
);
}
void ConfirmForm(Player& player, bool isOnline, const std::string& TypeName, bool needCondition) {
auto fm = ll::form::ModalForm(
tr("cleaner.form.confirm.title"),
tr(isOnline&&needCondition?"cleaner.form.confirm.important"
:"cleaner.form.confirm.warning",{
tr(typeNameToLocString(TypeName)),
TypeName,
std::to_string(
isOnline
? getEntityCountByType(TypeName)
: OfflineEntity.offlineEntities[TypeName].size()
)
}),
tr("cleaner.form.confirm.confirm"),
tr("cleaner.form.confirm.cancel")
);
fm.sendTo(player, [isOnline, TypeName, needCondition](
const Player& player,
ll::form::ModalFormResult rst,
ll::form::FormCancelReason res
) {
if (res) return;
if (!rst || rst.value() != ll::form::ModalFormSelectedButton::Upper)
return;
if (isOnline) {
for (auto en : ll::service::getLevel()->getRuntimeActorList()) {
auto actor = (gmlib::GMActor*)en;
if (en->getTypeName() == TypeName &&
(!needCondition || !Cleaner::shouldIgnore(actor))) {
en->despawn();
}
}
} else {
if (!OfflineEntity.isUpdating.exchange(true)) {
std::thread([TypeName]() {
{
std::lock_guard<std::mutex> lock(
OfflineEntity.offlineEntitiesMutex
);
auto it = OfflineEntity.offlineEntities.find(TypeName);
if (it != OfflineEntity.offlineEntities.end()) {
for (auto& en : it->second) {
if (en.isValid()) en.remove();
}
OfflineEntity.offlineEntities.erase(it);
}
}
OfflineEntity.isUpdating.store(false);
}).detach();
} else {
player.sendMessage(tr(""));
}
}
});
}
void SettingCleanForm(Player& player, bool isOnline, const std::string& TypeName) {
if (!isOnline) {
ConfirmForm(player, isOnline, TypeName, false);
return;
}
auto fm = ll::form::CustomForm(tr("cleaner.form.setting.title"));
fm.appendLabel(
tr("cleaner.form.setting.content",{
tr(typeNameToLocString(TypeName)),
TypeName,
std::to_string(
isOnline
? getEntityCountByType(TypeName)
: OfflineEntity.offlineEntities[TypeName].size()
)
})
);
fm.appendToggle(
"cleanIgnoreActor",
tr("cleaner.form.setting.cleanIgnore"),
false,
tr("cleaner.form.setting.cleanIgnore.tip")
);
fm.sendTo(player, [TypeName, isOnline](
Player& player,
const ll::form::CustomFormResult& rst,
ll::form::FormCancelReason res
) {
if (!rst) return;
bool cleanIgnoreActor =
std::get<uint64>(rst->at("cleanIgnoreActor"));
ConfirmForm(player, isOnline, TypeName, !cleanIgnoreActor);
});
}
void OnlineEntityForm(Player& player) {
auto fm = ll::form::SimpleForm(tr("cleaner.form.runtime.title"), tr("cleaner.form.runtime.content"));
for (auto& entityID : getAllEntityTypes()) {
fm.appendButton(
typeNameToLocString(entityID),
[entityID](Player& player) {
SettingCleanForm(player, true, entityID);
}
);
}
fm.sendTo(player);
}
void updateUnloadEntityMap(const Player& player, bool notice = false) {
if (OfflineEntity.lastUpdate.time_since_epoch().count() == 0)
OfflineEntity.requireUpdate.store(true);
if (OfflineEntity.lastUpdate >=
std::chrono::system_clock::now() - std::chrono::minutes(10)) {
if (notice) player.sendMessage(tr("cleaner.unload.updated.warn"));
return;
}
if (!OfflineEntity.isUpdating.exchange(true) &&
OfflineEntity.requireUpdate) {
std::thread([]() {
UnloadEntityMap offlineEntityMap{};
gmlib::UnloadedActor::foreachUnloadedActor(
[&](gmlib::UnloadedActor& actor) -> bool {
offlineEntityMap[actor.getTypeName()]
.emplace_back(std::move(actor));
return true;
}
);
{
std::lock_guard<std::mutex> lock(
OfflineEntity.offlineEntitiesMutex
);
for (auto& playerID : OfflineEntity.waitedPlayers) {
if (auto pl =
ll::service::getLevel()->getPlayer(playerID))
pl->sendMessage(tr("cleaner.unload.updated.msg"));
}
OfflineEntity.offlineEntities.swap(offlineEntityMap);
}
OfflineEntity.lastUpdate = std::chrono::system_clock::now();
OfflineEntity.isUpdating.store(false);
}).detach();
} else if (notice) {
player.sendMessage(tr("cleaner.unload.update.warn"));
}
}
void OfflineEntityForm(Player& player) {
Cleaner::Entry::getInstance().getSelf().getLogger().info("preload");
updateUnloadEntityMap(player);
auto fm = ll::form::SimpleForm(tr("cleaner.form.unload.title"), tr("cleaner.form.unload.content"));
if (OfflineEntity.lastUpdate !=
std::chrono::system_clock::time_point{}) {
fm.appendLabel(
tr("cleaner.form.unload.updated",{std::format("{:%Y-%m-%d %H:%M}", OfflineEntity.lastUpdate)})
);
}
if (OfflineEntity.isUpdating.load()) {
fm.appendLabel(
tr("cleaner.form.unload.updating")
);
{
std::lock_guard<std::mutex> lock(
OfflineEntity.offlineEntitiesMutex
);
OfflineEntity.waitedPlayers.insert(
player.getOrCreateUniqueID()
);
}
fm.appendButton(tr("cleaner.form.unload.refresh"), [](Player& player) {
OfflineEntityForm(player);
});
} else {
fm.appendButton(tr("cleaner.form.unload.refresh"), [](Player& player) {
OfflineEntity.requireUpdate.store(true);
updateUnloadEntityMap(player, true);
});
}
{
std::lock_guard<std::mutex> lock(
OfflineEntity.offlineEntitiesMutex
);
for (auto& entity : OfflineEntity.offlineEntities) {
fm.appendButton(
typeNameToLocString(entity.first),
[typeName = entity.first](Player& player) {
SettingCleanForm(player, false, typeName);
}
);
}
}
fm.sendTo(player);
}
void MainForm(Player* player) {
auto fm = ll::form::SimpleForm(tr("cleaner.form.main.title"), tr("cleaner.form.main.context"));
fm.appendButton(tr("cleaner.form.main.runtime"), [](Player& player) {
OnlineEntityForm(player);
});
fm.appendButton(tr("cleaner.form.main.unload"), [](Player& player) {
OfflineEntityForm(player);
});
fm.sendTo(*player);
}
-2
View File
@@ -5,7 +5,6 @@
namespace UnloadActorClean {
void cleanUnloadActor() {
auto& config = Cleaner::Entry::getInstance().getConfig();
std::thread([config]() {
gmlib::UnloadedActor::foreachUnloadedActor(
[config](gmlib::UnloadedActor& actor) -> bool {
for (auto& actorname : config.UnloadActorClean.CleanList) {
@@ -16,6 +15,5 @@ void cleanUnloadActor() {
return true;
}
);
}).detach();
}
} // namespace UnloadActorClean
-48
View File
@@ -35,30 +35,6 @@ std::string en_US = R"(
cleaner.vote.title=Vote Cleaning
cleaner.vote.voted=You have been voted!
cleaner.vote.voteMessage=%1$s lunched a clean vote. If you agree cleaning entities but did not received a form, please type command /voteclean to vote.
cleaner.form.main.title=§e§lCleaner§r - Main Menu
cleaner.form.main.context=Select entity category to clean:
cleaner.form.main.runtime=Loaded Entities
cleaner.form.main.unload=Unloaded Entities
cleaner.form.runtime.title=§e§lCleaner§r - Loaded Entity Manager
cleaner.form.runtime.content=Select loaded entity to clean:
cleaner.form.unload.title=§e§lCleaner§r - Unloaded Entity Manager
cleaner.form.unload.content=Select unloaded entity to clean:
cleaner.form.unload.updating=§2Updating...§r\nIf your world contains many entities, this may take §b a long time (~20k entities/min)§r. You can close this panel first; you'll be notified when the update finishes.
cleaner.form.unload.updated=Last updated: §b%1$s§r\n§eData may be out of sync. Click "Refresh" to update. Max 1 refresh per 10 minutes.\n§c§lWarning: Cleaning unloaded entities will force-remove ALL of them, including named, tamed, and ignored ones. Proceed with caution.
cleaner.form.unload.refresh=Refresh
cleaner.unload.updated.msg=§e§lUnloaded entity list§r has finished loading
cleaner.unload.update.warn=§g§lUnloaded entity list is already updating, cannot trigger again§r
cleaner.unload.updated.warn=§g§lUnloaded entity list refresh too frequent (max once per 10 min)§r
cleaner.form.setting.title=§e§lCleaner§r - Clean Options
cleaner.form.setting.content=Deleting entities\n§b%1$s (%2$s)\n§eTotal: %3$s
cleaner.form.setting.cleanIgnore=Force Clean All Entities
cleaner.form.setting.cleanIgnore.tip=§c§lDangerous: §r§gThis will clean ALL entities including named, tamed, and config-ignored ones
cleaner.form.confirm.title=Confirmation
cleaner.form.confirm.warning=§c§lConfirm dangerous operation:§r\nConfirm §c§lforce §rdeletion of\n§b%1$s (%2$s)\n§eTotal: %3$s ?
cleaner.form.confirm.important=§u§lConfirm operation:§r\nConfirm deletion of\n§b%1$s (%2$s)\n§eTotal: %3$s ? This will force-remove ALL including named, tamed, config-ignored, etc. Proceed with caution.
cleaner.form.confirm.confirm=Confirm
cleaner.form.confirm.cancel=Cancel
cleaner.confirm.unload.warn=Form is updating, deletion temporarily unavailable
)";
std::string zh_CN = R"(
@@ -95,28 +71,4 @@ std::string zh_CN = R"(
cleaner.vote.title=
cleaner.vote.voted=
cleaner.vote.voteMessage=%1$s /voteclean
cleaner.form.main.title=§e§lCleaner§r
cleaner.form.main.context=:
cleaner.form.main.runtime=
cleaner.form.main.unload=
cleaner.form.runtime.title=§e§lCleaner§r-
cleaner.form.runtime.content=:
cleaner.form.unload.title=§e§lCleaner-
cleaner.form.unload.content=:
cleaner.form.unload.updating=§2...§r\n如果您存档中有较多实体§b较长时间(2w个生物/)§r,
cleaner.form.unload.updated=:§b %1$s \n§e数据有时不同步10\n§c§l注意, , , ,
cleaner.form.unload.refresh=
cleaner.unload.updated.msg=§e§l离线生物列表§r已完成加载
cleaner.unload.update.warn=§g§l离线生物列表正在更新§r
cleaner.unload.updated.warn=§g§l离线生物列表更新过频繁10
cleaner.form.setting.title=§e§lCleaner-
cleaner.form.setting.content=\n§b%1$s (%2$s)\n§e共计: %3$s
cleaner.form.setting.cleanIgnore=
cleaner.form.setting.cleanIgnore.tip=§c§l危险操作: §r§g这会清理包过有命名, ,
cleaner.form.confirm.title=
cleaner.form.confirm.warning=§c§l确认危险操作:§r\n确认§c§l强制§r删除生物\n§b%1$s (%2$s)\n§e共计: %3$s ?
cleaner.form.confirm.important=§u§l确认操作:§r\n确认删除生物\n§b%1$s (%2$s)\n§e共计: %3$s ?, , , ,
cleaner.form.confirm.confirm=
cleaner.form.confirm.cancel=
cleaner.confirm.unload.warn=,
)";
-9
View File
@@ -3,8 +3,6 @@
#include "Global.h"
#include "Language.h"
#include "ll/api/utils/ErrorUtils.h"
#include "ll/api/memory/Hook.h"
#include "mc/world/actor/Actor.h"
#include "gmlib/mc/locale/I18nAPI.h"
#include "gmlib/gm/data/TpsStatus.h"
@@ -29,14 +27,12 @@ bool Entry::enable() {
gmlib::I18nAPI::updateOrCreateLanguageFile(getSelf().getLangDir(), "en_US", en_US);
gmlib::I18nAPI::updateOrCreateLanguageFile(getSelf().getLangDir(), "zh_CN", zh_CN);
gmlib::I18nAPI::loadLanguagesFromDirectory(getSelf().getLangDir());
gmlib::I18nAPI::chooseLanguage(Cleaner::Entry::getInstance().getConfig().language);
Cleaner::ListenEvents();
RegisterCommands();
Cleaner::loadCleaner();
getSelf().getLogger().info("Cleaner Loaded!");
getSelf().getLogger().info("Author: GroupMountain");
getSelf().getLogger().info("Repository: https://github.com/GroupMountain/Cleaner");
return true;
}
@@ -46,11 +42,6 @@ bool Entry::disable() {
return true;
}
bool Entry::unload() {
return true;
}
Config& Entry::getConfig() { return mConfig.value(); }
void Entry::saveConfig() { ll::config::saveConfig(*mConfig, getSelf().getConfigDir() / "config.json"); }
+1 -1
View File
@@ -25,7 +25,7 @@ public:
// TODO: Implement this method if you need to unload the mod.
// /// @return True if the mod is unloaded successfully.
bool unload();
// bool unload();
Config& getConfig();
+1 -13
View File
@@ -4,7 +4,7 @@
#include "mc/server/commands/CommandOutput.h"
struct CleanerParam {
enum class Despawn { despawn } despawn;
enum class Action { gui ,tps, clean, reload, mspt } action;
enum class Action { tps, clean, reload, mspt } action;
enum class DespawnTime { despawntime } despawntime;
int ticks;
CommandSelector<Actor> entity;
@@ -24,14 +24,6 @@ void RegCleanerCommand() {
return output.error(tr("cleaner.command.error.noTarget"));
}
for (auto en : ens) {
/*NO NEED
*Tip: Player don't exit through normal logic when despawn player
*That may cause other plugins crash,causing Levilamina crash
*if (en->hasCategory(ActorCategory::Player)) {
auto pl=(Player*)en;
pl->disconnect("You've been despawn by Cleaner");
continue;
}*/
en->despawn();
}
return output.success(tr("cleaner.command.despawnSuccess", {S(ens.size())}));
@@ -69,10 +61,6 @@ void RegCleanerCommand() {
Cleaner::reloadCleaner();
return output.success(tr("cleaner.output.reload"));
}
case CleanerParam::Action::gui:
if (origin.getOriginType()==CommandOriginType::Player)
MainForm((Player*)origin.getEntity());
break;
}
}
);
+4 -4
View File
@@ -9,10 +9,10 @@ if not has_config("vs_runtime") then
end
-- Option 1: Use the latest version of LeviLamina released on GitHub.
add_requires("levilamina 26.10.5", {configs = {target_type = "server"}})
add_requires("levibuildscript")
add_requires("gmlib 26.10.0")
add_requires("ilistenattentively 0.12.0")
add_requires("levilamina 1.9.5", {configs = {target_type = "server"}})
add_requires("levibuildscript 0.6.0")
add_requires("gmlib 1.9.1")
add_requires("ilistenattentively 0.11.0")
target("Cleaner") -- Change this to your mod name.
add_cxflags(