package emu.grasscutter.scripts;

import static emu.grasscutter.scripts.constants.EventType.EVENT_TIMER_EVENT;

import com.github.davidmoten.rtreemulti.RTree;
import com.github.davidmoten.rtreemulti.geometry.Geometry;
import emu.grasscutter.Grasscutter;
import emu.grasscutter.data.GameData;
import emu.grasscutter.data.server.Grid;
import emu.grasscutter.database.DatabaseHelper;
import emu.grasscutter.game.entity.*;
import emu.grasscutter.game.entity.gadget.platform.BaseRoute;
import emu.grasscutter.game.props.EntityType;
import emu.grasscutter.game.quest.GameQuest;
import emu.grasscutter.game.quest.QuestGroupSuite;
import emu.grasscutter.game.world.Scene;
import emu.grasscutter.game.world.SceneGroupInstance;
import emu.grasscutter.net.proto.VisionTypeOuterClass;
import emu.grasscutter.scripts.constants.EventType;
import emu.grasscutter.scripts.data.*;
import emu.grasscutter.scripts.service.ScriptMonsterSpawnService;
import emu.grasscutter.scripts.service.ScriptMonsterTideService;
import emu.grasscutter.server.packet.send.PacketGroupSuiteNotify;
import emu.grasscutter.utils.FileUtils;
import emu.grasscutter.utils.GridPosition;
import emu.grasscutter.utils.JsonUtils;
import emu.grasscutter.utils.Position;
import io.netty.util.concurrent.FastThreadLocalThread;
import it.unimi.dsi.fastutil.ints.Int2ObjectMap;
import it.unimi.dsi.fastutil.ints.Int2ObjectOpenHashMap;
import java.io.FileWriter;
import java.io.IOException;
import java.nio.file.Files;
import java.util.*;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors;
import javax.annotation.Nonnull;
import javax.annotation.Nullable;
import kotlin.Pair;
import lombok.val;
import org.luaj.vm2.LuaError;
import org.luaj.vm2.LuaValue;
import org.luaj.vm2.lib.jse.CoerceJavaToLua;

public class SceneScriptManager {
    private final Scene scene;
    private final Map<String, Integer> variables;
    private SceneMeta meta;
    private boolean isInit;

    /** current triggers controlled by RefreshGroup */
    private final Map<Integer, Set<SceneTrigger>> currentTriggers;

    private final Map<String, Set<SceneTrigger>> triggersByGroupScene;
    private final Map<Integer, Set<Pair<String, Integer>>> activeGroupTimers;
    private final Map<String, AtomicInteger> triggerInvocations;
    private final Map<Integer, EntityRegion> regions; // <EntityId-Region>
    private final Map<Integer, SceneGroup> sceneGroups;
    private final Map<Integer, SceneGroupInstance> sceneGroupsInstances;
    private final Map<Integer, SceneGroupInstance> cachedSceneGroupsInstances;
    private ScriptMonsterTideService scriptMonsterTideService;
    private ScriptMonsterSpawnService scriptMonsterSpawnService;
    /** blockid - loaded groupSet */
    private final Map<Integer, Set<SceneGroup>> loadedGroupSetPerBlock;

    private static final Int2ObjectMap<List<Grid>> groupGridsCache = new Int2ObjectOpenHashMap<>();
    public static final ExecutorService eventExecutor;

    static {
        eventExecutor =
                new ThreadPoolExecutor(
                        4,
                        4,
                        60,
                        TimeUnit.SECONDS,
                        new LinkedBlockingDeque<>(10000),
                        FastThreadLocalThread::new,
                        new ThreadPoolExecutor.AbortPolicy());
    }

    public SceneScriptManager(Scene scene) {
        this.scene = scene;
        this.currentTriggers = new ConcurrentHashMap<>();
        this.triggersByGroupScene = new ConcurrentHashMap<>();
        this.activeGroupTimers = new ConcurrentHashMap<>();
        this.triggerInvocations = new ConcurrentHashMap<>();

        this.regions = new ConcurrentHashMap<>();
        this.variables = new ConcurrentHashMap<>();
        this.sceneGroups = new ConcurrentHashMap<>();
        this.sceneGroupsInstances = new ConcurrentHashMap<>();
        this.cachedSceneGroupsInstances = new ConcurrentHashMap<>();
        this.scriptMonsterSpawnService = new ScriptMonsterSpawnService(this);
        this.loadedGroupSetPerBlock = new ConcurrentHashMap<>();

        // TEMPORARY
        if (this.getScene().getId() < 10
                && !Grasscutter.getConfig().server.game.enableScriptInBigWorld) {
            return;
        }

        // Create
        new Thread(this::init).start();
    }

    public Scene getScene() {
        return scene;
    }

    public SceneConfig getConfig() {
        return this.isInit ? this.meta.config : null;
    }

    public Map<Integer, SceneBlock> getBlocks() {
        return meta.blocks;
    }

    @Nullable public Map<String, Integer> getVariables(int group_id) {
        if (this.getCachedGroupInstanceById(group_id) == null) return Collections.emptyMap();
        return getCachedGroupInstanceById(group_id).getCachedVariables();
    }

    public Set<SceneTrigger> getTriggersByEvent(int eventId) {
        return currentTriggers.computeIfAbsent(eventId, e -> ConcurrentHashMap.newKeySet());
    }

    public int getTriggerCount() {
        return currentTriggers.size();
    }

    public void registerTrigger(List<SceneTrigger> triggers) {
        triggers.forEach(this::registerTrigger);
    }

    public void registerTrigger(SceneTrigger trigger) {
        this.triggerInvocations.put(trigger.getName(), new AtomicInteger(0));
        this.getTriggersByEvent(trigger.getEvent()).add(trigger);
        Grasscutter.getLogger().trace("Registered trigger {}", trigger.getName());
    }

    public void deregisterTrigger(List<SceneTrigger> triggers) {
        triggers.forEach(this::deregisterTrigger);
    }

    public void deregisterTrigger(SceneTrigger trigger) {
        this.getTriggersByEvent(trigger.getEvent()).remove(trigger);
        Grasscutter.getLogger().trace("deregistered trigger {}", trigger.getName());
    }

    public void resetTriggers(int eventId) {
        currentTriggers.put(eventId, ConcurrentHashMap.newKeySet());
    }

    public void resetTriggersForGroupSuite(SceneGroup group, int suiteIndex) {
        Grasscutter.getLogger().debug("reset triggers for group {} suite {}", group.id, suiteIndex);
        var suite = group.getSuiteByIndex(suiteIndex);
        if (suite == null) {
            Grasscutter.getLogger()
                    .warn(
                            "Trying to load null suite Triggers for group {} with suiteindex {}",
                            group.id,
                            suiteIndex);
            return;
        }

        var groupSceneTriggers = triggersByGroupScene.get(group.id + "_" + suiteIndex);
        if (groupSceneTriggers == null) {
            groupSceneTriggers = new HashSet<>();
        }

        if (!groupSceneTriggers.isEmpty()) {
            for (var trigger : groupSceneTriggers) {
                currentTriggers.get(trigger.getEvent()).remove(trigger);
            }
            groupSceneTriggers.clear();
        }

        if (!suite.sceneTriggers.isEmpty()) {
            groupSceneTriggers.addAll(suite.sceneTriggers);
            for (var trigger : groupSceneTriggers) {
                registerTrigger(trigger);
                /*this.currentTriggers.computeIfAbsent(trigger.event, k -> ConcurrentHashMap.newKeySet())
                .add(trigger);*/
            }
        }
        triggersByGroupScene.put(group.id + "_" + suiteIndex, groupSceneTriggers);
    }

    public void refreshGroup(SceneGroupInstance groupInstance) {
        if (groupInstance == null || groupInstance.getLuaGroup().suites == null) {
            return;
        }
        // for (int i = 1; i<= group.suites.size();i++){
        // refreshGroup(group, i);
        refreshGroup(
                groupInstance, groupInstance.getActiveSuiteId(), false); // Refresh the last group triggers
        // }
    }

    public int refreshGroup(
            SceneGroupInstance groupInstance, int suiteIndex, boolean excludePrevSuite) {
        return this.refreshGroup(groupInstance, suiteIndex, excludePrevSuite, null);
    }

    public int refreshGroup(
            SceneGroupInstance groupInstance,
            int suiteIndex,
            boolean excludePrevSuite,
            List<GameEntity> entitiesAdded) {
        SceneGroup group = groupInstance.getLuaGroup();
        if (suiteIndex == 0) {
            if (excludePrevSuite) {
                suiteIndex = group.findInitSuiteIndex(groupInstance.getActiveSuiteId());
            } else suiteIndex = group.findInitSuiteIndex(0);
        }
        if (suiteIndex == 0) return 0;

        var suiteData = group.getSuiteByIndex(suiteIndex);
        if (suiteData == null) {
            Grasscutter.getLogger().warn("Group {} suite {} not found", group.id, suiteIndex);
            return 0;
        }

        int prevSuiteIndex = groupInstance.getActiveSuiteId();
        boolean waitForOne = false;
        SceneSuite prevSuiteData = null;
        if (prevSuiteIndex != 0) {
            prevSuiteData = group.getSuiteByIndex(prevSuiteIndex);
            if (prevSuiteData != null) {
                if (prevSuiteData.ban_refresh && !suiteData.ban_refresh) {
                    waitForOne = true;
                }
            }
        }

        if (waitForOne
                && (groupInstance.getTargetSuiteId() == 0
                        || prevSuiteIndex != groupInstance.getTargetSuiteId())) {
            groupInstance.setTargetSuiteId(suiteIndex);
            Grasscutter.getLogger()
                    .debug("Group {} suite {} wating one more refresh", group.id, suiteIndex);
            return 0;
        }

        groupInstance.setTargetSuiteId(0);

        if (prevSuiteData != null) {
            removeGroupSuite(group, prevSuiteData);
        } // Remove old group suite

        this.addGroupSuite(groupInstance, suiteData, entitiesAdded);

        // Refesh variables here
        group.variables.forEach(
                variable -> {
                    if (!variable.no_refresh)
                        groupInstance.getCachedVariables().put(variable.name, variable.value);
                });

        groupInstance.setActiveSuiteId(suiteIndex);
        groupInstance.setLastTimeRefreshed(getScene().getWorld().getGameTime());
        return suiteIndex;
    }

    public boolean refreshGroupSuite(int groupId, int suiteId) {
        var targetGroupInstance = getGroupInstanceById(groupId);
        if (targetGroupInstance == null) {
            getGroupById(
                    groupId); // Load the group, this ensures an instance is created and the if neccesary
            // unloaded, but the suite data is stored
            targetGroupInstance = getGroupInstanceById(groupId);
            Grasscutter.getLogger()
                    .debug(
                            "trying to regresh group suite {} in an unloaded and uncached group {} in scene {}",
                            suiteId,
                            groupId,
                            getScene().getId());
        } else {
            Grasscutter.getLogger().debug("Refreshing group {} suite {}", groupId, suiteId);
            suiteId =
                    refreshGroup(
                            targetGroupInstance,
                            suiteId,
                            false); // If suiteId is zero, the value of suiteId changes
            scene.broadcastPacket(new PacketGroupSuiteNotify(groupId, suiteId));
        }

        return true;
    }

    public boolean refreshGroupSuite(int groupId, int suiteId, GameQuest quest) {
        var result = refreshGroupSuite(groupId, suiteId);
        if (suiteId != 0 && quest != null) {
            quest
                    .getMainQuest()
                    .getQuestGroupSuites()
                    .add(
                            QuestGroupSuite.of().scene(getScene().getId()).group(groupId).suite(suiteId).build());
        }

        return result;
    }

    public boolean refreshGroupMonster(int groupId) {
        var groupInstance = getGroupInstanceById(groupId);
        if (groupInstance == null) {
            Grasscutter.getLogger()
                    .warn(
                            "trying to refesh monster group in unloaded and uncached group {} in scene {}",
                            groupId,
                            getScene().getId());
            return false;
        }

        var group = groupInstance.getLuaGroup();
        var monstersToSpawn =
                group.monsters.values().stream()
                        .filter(
                                m -> {
                                    var entity = scene.getEntityByConfigId(m.config_id);
                                    return (entity == null
                                            || entity.getGroupId()
                                                    != group
                                                            .id); /*&& !groupInstance.getDeadEntities().contains(entity); */ // TODO: Investigate the usage of deadEntities
                                })
                        .map(mob -> createMonster(group.id, group.block_id, mob))
                        .toList(); // TODO check if it interferes with bigworld or anything else
        this.addEntities(monstersToSpawn);

        return true;
    }

    public EntityRegion getRegionById(int id) {
        return regions.get(id);
    }

    public void registerRegion(EntityRegion region) {
        regions.put(region.getId(), region);
        Grasscutter.getLogger()
                .trace(
                        "Registered region {} from group {}",
                        region.getMetaRegion().config_id,
                        region.getGroupId());
    }

    public void registerRegionInGroupSuite(SceneGroup group, SceneSuite suite) {
        suite.sceneRegions.stream()
                .map(region -> new EntityRegion(this.getScene(), region))
                .forEach(this::registerRegion);
    }

    public synchronized void deregisterRegion(SceneRegion region) {
        this.regions.values().stream()
                .filter(r -> r.getMetaRegion().equals(region))
                .findFirst()
                .ifPresent(entityRegion -> this.regions.remove(entityRegion.getId()));
    }

    public Map<Integer, Set<SceneGroup>> getLoadedGroupSetPerBlock() {
        return loadedGroupSetPerBlock;
    }

    // TODO optimize
    public SceneGroup getGroupById(int groupId) {
        for (var block : getBlocks().values()) {
            this.getScene().loadBlock(block);

            var group = block.groups.get(groupId);
            if (group == null) {
                continue;
            }

            if (!this.sceneGroupsInstances.containsKey(groupId)) {
                this.getScene().onLoadGroup(List.of(group));
                this.getScene().onRegisterGroups();
            }
            return group;
        }
        return null;
    }

    public SceneGroupInstance getGroupInstanceById(int groupId) {
        return sceneGroupsInstances.getOrDefault(groupId, null);
    }

    public Map<Integer, SceneGroupInstance> getCachedGroupInstances() {
        return cachedSceneGroupsInstances;
    }

    public SceneGroupInstance getCachedGroupInstanceById(int groupId) {
        var instance = cachedSceneGroupsInstances.getOrDefault(groupId, null);
        if (instance == null) {
            instance = DatabaseHelper.loadGroupInstance(groupId, scene.getWorld().getHost());
            if (instance != null) cachedSceneGroupsInstances.put(groupId, instance);
        }

        return instance;
    }

    private static void addGridPositionToMap(
            Map<GridPosition, Set<Integer>> map, int group_id, int vision_level, Position position) {
        // Convert position to grid position
        GridPosition gridPos;
        int width = Grasscutter.getConfig().server.game.visionOptions[vision_level].gridWidth;
        gridPos =
                new GridPosition((int) (position.getX() / width), (int) (position.getZ() / width), width);

        Set<Integer> groups = map.getOrDefault(gridPos, new HashSet<>());
        groups.add(group_id);
        map.put(gridPos, groups);
    }

    private static int getGadgetVisionLevel(int gadget_id) {
        var gadget = GameData.getGadgetDataMap().get(gadget_id);
        if (gadget == null || gadget.getVisionLevel() == null) return 0;

        var visionOptions = Grasscutter.getConfig().server.game.visionOptions;
        for (int i = 0; i < visionOptions.length; i++)
            if (visionOptions[i].name.compareTo(gadget.getVisionLevel()) == 0) {
                return i;
            }

        return 0;
    }

    private void init() {
        var meta = ScriptLoader.getSceneMeta(getScene().getId());
        if (meta == null) {
            return;
        }
        this.meta = meta;

        // TEMP
        this.isInit = true;
    }

    public List<Grid> getGroupGrids() {
        int sceneId = scene.getId();
        if (groupGridsCache.containsKey(sceneId) && groupGridsCache.get(sceneId) != null) {
            Grasscutter.getLogger().trace("Hit cache for scene {}", sceneId);
            return groupGridsCache.get(sceneId);
        } else {
            var path = FileUtils.getCachePath("scene" + sceneId + "_grid.json");
            if (path.toFile().isFile() && !Grasscutter.config.server.game.cacheSceneEntitiesEveryRun) {
                try {
                    var groupGrids = JsonUtils.loadToList(path, Grid.class);
                    groupGridsCache.put(sceneId, groupGrids);
                    if (groupGrids != null) return groupGrids;
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

            // otherwise generate the grids
            List<Map<GridPosition, Set<Integer>>> groupPositions = new ArrayList<>();
            for (int i = 0; i < 6; i++) groupPositions.add(new HashMap<>());

            var visionOptions = Grasscutter.config.server.game.visionOptions;
            meta.blocks
                    .values()
                    .forEach(
                            block -> {
                                block.load(sceneId, meta.context);
                                block.groups.values().stream()
                                        .filter(g -> !g.dynamic_load)
                                        .forEach(
                                                group -> {
                                                    group.load(this.scene.getId());

                                                    // Add all entities here
                                                    Set<Integer> vision_levels = new HashSet<>();

                                                    if (group.monsters != null) {
                                                        group
                                                                .monsters
                                                                .values()
                                                                .forEach(
                                                                        m -> {
                                                                            addGridPositionToMap(
                                                                                    groupPositions.get(m.vision_level),
                                                                                    group.id,
                                                                                    m.vision_level,
                                                                                    m.pos);
                                                                            vision_levels.add(m.vision_level);
                                                                        });
                                                    } else {
                                                        Grasscutter.getLogger()
                                                                .error("group.monsters null for group {}", group.id);
                                                    }
                                                    if (group.gadgets != null) {
                                                        group
                                                                .gadgets
                                                                .values()
                                                                .forEach(
                                                                        g -> {
                                                                            int vision_level =
                                                                                    Math.max(
                                                                                            getGadgetVisionLevel(g.gadget_id), g.vision_level);
                                                                            addGridPositionToMap(
                                                                                    groupPositions.get(vision_level),
                                                                                    group.id,
                                                                                    vision_level,
                                                                                    g.pos);
                                                                            vision_levels.add(vision_level);
                                                                        });
                                                    } else {
                                                        Grasscutter.getLogger()
                                                                .error("group.gadgets null for group {}", group.id);
                                                    }

                                                    if (group.npcs != null) {
                                                        group
                                                                .npcs
                                                                .values()
                                                                .forEach(
                                                                        n ->
                                                                                addGridPositionToMap(
                                                                                        groupPositions.get(n.vision_level),
                                                                                        group.id,
                                                                                        n.vision_level,
                                                                                        n.pos));
                                                    } else {
                                                        Grasscutter.getLogger().error("group.npcs null for group {}", group.id);
                                                    }

                                                    if (group.regions != null) {
                                                        group
                                                                .regions
                                                                .values()
                                                                .forEach(
                                                                        r ->
                                                                                addGridPositionToMap(
                                                                                        groupPositions.get(0), group.id, 0, r.pos));
                                                    } else {
                                                        Grasscutter.getLogger()
                                                                .error("group.regions null for group {}", group.id);
                                                    }

                                                    if (group.garbages != null && group.garbages.gadgets != null)
                                                        group.garbages.gadgets.forEach(
                                                                g ->
                                                                        addGridPositionToMap(
                                                                                groupPositions.get(g.vision_level),
                                                                                group.id,
                                                                                g.vision_level,
                                                                                g.pos));

                                                    int max_vision_level = -1;
                                                    if (!vision_levels.isEmpty()) {
                                                        for (int vision_level : vision_levels) {
                                                            if (max_vision_level == -1
                                                                    || visionOptions[max_vision_level].visionRange
                                                                            < visionOptions[vision_level].visionRange)
                                                                max_vision_level = vision_level;
                                                        }
                                                    }
                                                    if (max_vision_level == -1) max_vision_level = 0;

                                                    addGridPositionToMap(
                                                            groupPositions.get(max_vision_level),
                                                            group.id,
                                                            max_vision_level,
                                                            group.pos);
                                                });
                            });

            var groupGrids = new ArrayList<Grid>();
            for (int i = 0; i < 6; i++) {
                groupGrids.add(new Grid());
                groupGrids.get(i).grid = groupPositions.get(i);
            }
            groupGridsCache.put(scene.getId(), groupGrids);

            try {
                Files.createDirectories(path.getParent());
            } catch (IOException ignored) {
            }
            try (var file = new FileWriter(path.toFile())) {
                file.write(JsonUtils.encode(groupGrids));
                Grasscutter.getLogger().info("Scene {} saved grid file.", getScene().getId());
            } catch (Exception e) {
                Grasscutter.getLogger().error("Scene {} unable to save grid file.", getScene().getId(), e);
            }
            return groupGrids;
        }
    }

    public boolean isInit() {
        return isInit;
    }

    public void loadBlockFromScript(SceneBlock block) {
        block.load(scene.getId(), meta.context);
    }

    public void loadGroupFromScript(SceneGroup group) {
        group.load(getScene().getId());

        this.sceneGroups.put(group.id, group);
        if (this.getCachedGroupInstanceById(group.id) != null) {
            this.sceneGroupsInstances.put(group.id, this.cachedSceneGroupsInstances.get(group.id));
            this.cachedSceneGroupsInstances.get(group.id).setCached(false);
            this.cachedSceneGroupsInstances.get(group.id).setLuaGroup(group);
        } else {
            var instance = new SceneGroupInstance(group, getScene().getWorld().getHost());
            this.sceneGroupsInstances.put(group.id, instance);
            this.cachedSceneGroupsInstances.put(group.id, instance);
            instance.save(); // Save the instance
        }

        if (group.variables != null) {
            group.variables.forEach(
                    variable -> {
                        val variables = this.getVariables(group.id);
                        if (variables != null && !variables.containsKey(variable.name))
                            variables.put(variable.name, variable.value);
                    });
        }
    }

    public void unregisterGroup(SceneGroup group) {
        this.sceneGroups.remove(group.id);
        this.sceneGroupsInstances.values().removeIf(i -> i.getLuaGroup().equals(group));
        this.cachedSceneGroupsInstances.values().stream()
                .filter(i -> i.getLuaGroup().equals(group))
                .forEach(s -> s.setCached(true));
    }

    public void checkRegions() {
        if (this.regions.size() == 0) {
            return;
        }

        for (var region : this.regions.values()) {
            // currently all condition_ENTER_REGION Events check for avatar, so we have no necessary to
            // add other types of entity
            var entities =
                    getScene().getEntities().values().stream()
                            .filter(
                                    e ->
                                            e.getEntityType() == EntityType.Avatar.getValue()
                                                    && region.getMetaRegion().contains(e.getPosition()))
                            .toList();
            entities.forEach(region::addEntity);

            var targetId = 0;
            if (entities.size() > 0) {
                targetId = entities.get(0).getId();
            }

            if (region.entityHasEntered()) {
                Grasscutter.getLogger()
                        .trace("Call EVENT_ENTER_REGION_{}", region.getMetaRegion().config_id);
                this.callEvent(
                        new ScriptArgs(region.getGroupId(), EventType.EVENT_ENTER_REGION, region.getConfigId())
                                .setSourceEntityId(region.getId())
                                .setTargetEntityId(targetId));

                region.resetNewEntities();
            }

            for (var entityId : region.getEntities()) {
                var entity = this.getScene().getEntityById(entityId);
                if (entity == null || !region.getMetaRegion().contains(entity.getPosition())) {
                    region.removeEntity(entityId);
                }
            }

            if (region.entityHasLeft()) {
                this.callEvent(
                        new ScriptArgs(region.getGroupId(), EventType.EVENT_LEAVE_REGION, region.getConfigId())
                                .setSourceEntityId(region.getId())
                                .setTargetEntityId(region.getFirstEntityId()));

                region.resetNewEntities();
            }
        }
    }

    public List<EntityGadget> getGadgetsInGroupSuite(
            SceneGroupInstance groupInstance, SceneSuite suite) {
        var group = groupInstance.getLuaGroup();
        return suite.sceneGadgets.stream()
                .filter(
                        m -> {
                            var entity = scene.getEntityByConfigId(m.config_id);
                            return (entity == null || entity.getGroupId() != group.id)
                                    && (!m.isOneoff
                                            || !m.persistent
                                            || !groupInstance.getDeadEntities().contains(m.config_id));
                        })
                .map(g -> createGadget(group.id, group.block_id, g, groupInstance.getCachedGadgetState(g)))
                .peek(g -> groupInstance.cacheGadgetState(g.getMetaGadget(), g.getState()))
                .filter(Objects::nonNull)
                .toList();
    }

    public List<EntityMonster> getMonstersInGroupSuite(
            SceneGroupInstance groupInstance, SceneSuite suite) {
        var group = groupInstance.getLuaGroup();
        return suite.sceneMonsters.stream()
                .filter(
                        m -> {
                            var entity = scene.getEntityByConfigId(m.config_id);
                            return (entity == null
                                    || entity.getGroupId()
                                            != group
                                                    .id); /*&& !groupInstance.getDeadEntities().contains(entity); */ // TODO:
                            // Investigate the usage of deadEntities
                        }) // TODO: Add persistent monster cached data
                .map(mob -> createMonster(group.id, group.block_id, mob))
                .filter(Objects::nonNull)
                .toList();
    }

    public void addGroupSuite(SceneGroupInstance groupInstance, SceneSuite suite) {
        this.addGroupSuite(groupInstance, suite, null);
    }

    public void addGroupSuite(
            SceneGroupInstance groupInstance, SceneSuite suite, List<GameEntity> entities) {
        // we added trigger first
        registerTrigger(suite.sceneTriggers);

        var group = groupInstance.getLuaGroup();
        var toCreate = new ArrayList<GameEntity>();
        toCreate.addAll(getGadgetsInGroupSuite(groupInstance, suite));
        toCreate.addAll(getMonstersInGroupSuite(groupInstance, suite));
        if (entities != null) entities.addAll(toCreate);
        else this.addEntities(toCreate);

        registerRegionInGroupSuite(group, suite);
    }

    public void refreshGroupSuite(SceneGroupInstance groupInstance, SceneSuite suite) {
        // we added trigger first
        registerTrigger(suite.sceneTriggers);

        var group = groupInstance.getLuaGroup();
        var toCreate = new ArrayList<GameEntity>();
        toCreate.addAll(getGadgetsInGroupSuite(groupInstance, suite));
        toCreate.addAll(getMonstersInGroupSuite(groupInstance, suite));
        addEntities(toCreate);

        registerRegionInGroupSuite(group, suite);
    }

    public void removeGroupSuite(SceneGroup group, SceneSuite suite) {
        deregisterTrigger(suite.sceneTriggers);
        removeMonstersInGroup(group, suite);
        removeGadgetsInGroup(group, suite);

        suite.sceneRegions.forEach(this::deregisterRegion);
    }

    public void killGroupSuite(SceneGroup group, SceneSuite suite) {
        deregisterTrigger(suite.sceneTriggers);

        killMonstersInGroup(group, suite);
        killGadgetsInGroup(group, suite);

        suite.sceneRegions.forEach(this::deregisterRegion);
    }

    public void startMonsterTideInGroup(
            SceneGroup group, Integer[] ordersConfigId, int tideCount, int sceneLimit) {
        this.scriptMonsterTideService =
                new ScriptMonsterTideService(this, group, tideCount, sceneLimit, ordersConfigId);
    }

    public void unloadCurrentMonsterTide() {
        if (this.getScriptMonsterTideService() == null) {
            return;
        }
        this.getScriptMonsterTideService().unload();
    }

    public void spawnMonstersByConfigId(SceneGroup group, int configId, int delayTime) {
        // TODO delay
        var entity = scene.getEntityByConfigId(configId);
        if (entity != null && entity.getGroupId() == group.id) {
            Grasscutter.getLogger()
                    .debug("entity already exists failed in group {} with config {}", group.id, configId);
            return;
        }
        entity = createMonster(group.id, group.block_id, group.monsters.get(configId));
        if (entity != null) {
            getScene().addEntity(entity);
        } else {
            Grasscutter.getLogger()
                    .warn("failed to create entity with group {} and config {}", group.id, configId);
        }
    }
    // Events
    public void callEvent(int groupId, int eventType) {
        callEvent(new ScriptArgs(groupId, eventType));
    }

    public void callEvent(@Nonnull ScriptArgs params) {
        /**
         * We use ThreadLocal to trans SceneScriptManager context to ScriptLib, to avoid eval script for
         * every groups' trigger in every scene instances. But when callEvent is called in a ScriptLib
         * func, it may cause NPE because the inner call cleans the ThreadLocal so that outer call could
         * not get it. e.g. CallEvent -> set -> ScriptLib.xxx -> CallEvent -> set -> remove -> NPE ->
         * (remove) So we use thread pool to clean the stack to avoid this new issue.
         */
        eventExecutor.submit(() -> this.realCallEvent(params));
    }

    private void realCallEvent(@Nonnull ScriptArgs params) {
        try {
            ScriptLoader.getScriptLib().setSceneScriptManager(this);
            int eventType = params.type;
            Set<SceneTrigger> relevantTriggers = new HashSet<>();
            if (eventType == EventType.EVENT_ENTER_REGION || eventType == EventType.EVENT_LEAVE_REGION) {
                relevantTriggers =
                        this.getTriggersByEvent(eventType).stream()
                                .filter(
                                        t ->
                                                t.getCondition().contains(String.valueOf(params.param1))
                                                        && (t.getSource().isEmpty()
                                                                || t.getSource().equals(params.getEventSource())))
                                .collect(Collectors.toSet());
            } else {
                relevantTriggers =
                        this.getTriggersByEvent(eventType).stream()
                                .filter(
                                        t -> params.getGroupId() == 0 || t.getCurrentGroup().id == params.getGroupId())
                                .filter(
                                        t -> (t.getSource().isEmpty() || t.getSource().equals(params.getEventSource())))
                                .collect(Collectors.toSet());
            }
            for (SceneTrigger trigger : relevantTriggers) {
                handleEventForTrigger(params, trigger);
            }
        } catch (Throwable throwable) {
            Grasscutter.getLogger()
                    .error("Condition Trigger " + params.type + " triggered exception", throwable);
        } finally {
            // make sure it is removed
            ScriptLoader.getScriptLib().removeSceneScriptManager();
        }
    }

    private boolean handleEventForTrigger(ScriptArgs params, SceneTrigger trigger) {
        Grasscutter.getLogger()
                .trace("checking trigger {} for event {}", trigger.getName(), params.type);
        try {
            // setup execution
            ScriptLoader.getScriptLib().setCurrentGroup(trigger.currentGroup);
            ScriptLoader.getScriptLib().setCurrentCallParams(params);

            if (evaluateTriggerCondition(trigger, params)) {
                callTrigger(trigger, params);
                return true;
            } else {
                Grasscutter.getLogger()
                        .trace("Condition Trigger {} returned false", trigger.getCondition());
            }
            // TODO some ret do not bool
            return false;
        } catch (Throwable ex) {
            Grasscutter.getLogger()
                    .error("Condition Trigger " + trigger.getName() + " triggered exception", ex);
            return false;
        } finally {
            ScriptLoader.getScriptLib().removeCurrentGroup();
        }
    }

    private boolean evaluateTriggerCondition(SceneTrigger trigger, ScriptArgs params) {
        Grasscutter.getLogger()
                .trace(
                        "Call Condition Trigger {}, [{},{},{}]",
                        trigger.getCondition(),
                        params.param1,
                        params.source_eid,
                        params.target_eid);
        LuaValue ret = this.callScriptFunc(trigger.getCondition(), trigger.currentGroup, params);
        return ret.isboolean() && ret.checkboolean();
    }

    private void callTrigger(SceneTrigger trigger, ScriptArgs params) {
        // the SetGroupVariableValueByGroup in tower need the param to record the first stage time
        var ret = this.callScriptFunc(trigger.getAction(), trigger.currentGroup, params);
        var invocationsCounter = triggerInvocations.get(trigger.getName());
        var invocations = invocationsCounter.incrementAndGet();
        Grasscutter.getLogger().trace("Call Action Trigger {}", trigger.getAction());

        var activeChallenge = scene.getChallenge();
        if (activeChallenge != null) {
            activeChallenge.onGroupTriggerDeath(trigger);
        }

        if (trigger.getEvent() == EventType.EVENT_ENTER_REGION) {
            var region =
                    this.regions.values().stream()
                            .filter(p -> p.getConfigId() == params.param1)
                            .toList()
                            .get(0);
            this.getScene().getPlayers().forEach(p -> p.onEnterRegion(region.getMetaRegion()));
            this.deregisterRegion(region.getMetaRegion());
        } else if (trigger.getEvent() == EventType.EVENT_LEAVE_REGION) {
            var region =
                    this.regions.values().stream()
                            .filter(p -> p.getConfigId() == params.param1)
                            .toList()
                            .get(0);
            this.getScene().getPlayers().forEach(p -> p.onLeaveRegion(region.getMetaRegion()));
            this.deregisterRegion(region.getMetaRegion());
        }

        if (trigger.getEvent() == EVENT_TIMER_EVENT) {
            cancelGroupTimerEvent(trigger.currentGroup.id, trigger.getSource());
        }

        // always deregister on error, otherwise only if the count is reached
        if (ret.isboolean() && !ret.checkboolean()
                || ret.isint() && ret.checkint() != 0
                || trigger.getTrigger_count() > 0 && invocations >= trigger.getTrigger_count()) {
            deregisterTrigger(trigger);
        }
    }

    private LuaValue callScriptFunc(String funcName, SceneGroup group, ScriptArgs params) {
        LuaValue funcLua = null;
        if (funcName != null && !funcName.isEmpty()) {
            funcLua = (LuaValue) group.getBindings().get(funcName);
        }

        LuaValue ret = LuaValue.TRUE;

        if (funcLua != null) {
            LuaValue args = LuaValue.NIL;

            if (params != null) {
                args = CoerceJavaToLua.coerce(params);
            }

            ret = safetyCall(funcName, funcLua, args, group);
        }
        return ret;
    }

    public LuaValue safetyCall(String name, LuaValue func, LuaValue args, SceneGroup group) {
        try {
            return func.call(ScriptLoader.getScriptLibLua(), args);
        } catch (LuaError error) {
            ScriptLib.logger.error(
                    "[LUA] call trigger failed in group {} with {},{}", group.id, name, args, error);
            return LuaValue.valueOf(-1);
        }
    }

    public ScriptMonsterTideService getScriptMonsterTideService() {
        return scriptMonsterTideService;
    }

    public ScriptMonsterSpawnService getScriptMonsterSpawnService() {
        return scriptMonsterSpawnService;
    }

    public EntityGadget createGadget(int groupId, int blockId, SceneGadget g) {
        return createGadget(groupId, blockId, g, g.state);
    }

    public EntityGadget createGadget(int groupId, int blockId, SceneGadget g, int state) {
        if (g.isOneoff) {
            var hasEntity =
                    getScene().getEntities().values().stream()
                            .filter(e -> e instanceof EntityGadget)
                            .filter(e -> e.getGroupId() == g.group.id)
                            .filter(e -> e.getConfigId() == g.config_id)
                            .findFirst();
            if (hasEntity.isPresent()) {
                return null;
            }
        }
        EntityGadget entity = new EntityGadget(getScene(), g.gadget_id, g.pos);

        if (entity.getGadgetData() == null) {
            return null;
        }

        entity.setBlockId(blockId);
        entity.setConfigId(g.config_id);
        entity.setGroupId(groupId);
        entity.getRotation().set(g.rot);
        entity.setState(state);

        entity.setPointType(g.point_type);
        entity.setRouteConfig(BaseRoute.fromSceneGadget(g));
        entity.setMetaGadget(g);
        entity.buildContent();

        return entity;
    }

    public EntityNPC createNPC(SceneNPC npc, int blockId, int suiteId) {
        return new EntityNPC(getScene(), npc, blockId, suiteId);
    }

    public EntityMonster createMonster(int groupId, int blockId, SceneMonster monster) {
        if (monster == null) {
            return null;
        }

        var data = GameData.getMonsterDataMap().get(monster.monster_id);

        if (data == null) {
            return null;
        }

        // Calculate level
        int level = monster.level;

        if (getScene().getDungeonManager() != null) {
            level = getScene().getDungeonManager().getLevelForMonster(monster.config_id);
        } else if (getScene().getWorld().getWorldLevel() > 0) {
            var worldLevelData =
                    GameData.getWorldLevelDataMap().get(getScene().getWorld().getWorldLevel());

            if (worldLevelData != null) {
                level = worldLevelData.getMonsterLevel();
            }
        }

        // Spawn mob
        EntityMonster entity = new EntityMonster(getScene(), data, monster.pos, level);
        entity.getRotation().set(monster.rot);
        entity.setGroupId(groupId);
        entity.setBlockId(blockId);
        entity.setConfigId(monster.config_id);
        entity.setPoseId(monster.pose_id);
        entity.setMetaMonster(monster);

        this.getScriptMonsterSpawnService()
                .onMonsterCreatedListener
                .forEach(action -> action.onNotify(entity));

        return entity;
    }

    public void addEntity(GameEntity gameEntity) {
        getScene().addEntity(gameEntity);
    }

    public void meetEntities(List<? extends GameEntity> gameEntity) {
        getScene().addEntities(gameEntity, VisionTypeOuterClass.VisionType.VISION_TYPE_MEET);
    }

    public void addEntities(List<? extends GameEntity> gameEntity) {
        getScene().addEntities(gameEntity);
    }

    public void removeEntities(List<? extends GameEntity> gameEntity) {
        getScene()
                .removeEntities(
                        gameEntity.stream().map(e -> (GameEntity) e).collect(Collectors.toList()),
                        VisionTypeOuterClass.VisionType.VISION_TYPE_REFRESH);
    }

    public RTree<SceneBlock, Geometry> getBlocksIndex() {
        return meta.sceneBlockIndex;
    }

    public void removeMonstersInGroup(SceneGroup group, SceneSuite suite) {
        var configSet = suite.sceneMonsters.stream().map(m -> m.config_id).collect(Collectors.toSet());
        var toRemove =
                getScene().getEntities().values().stream()
                        .filter(e -> e instanceof EntityMonster)
                        .filter(e -> e.getGroupId() == group.id)
                        .filter(e -> configSet.contains(e.getConfigId()))
                        .toList();

        getScene().removeEntities(toRemove, VisionTypeOuterClass.VisionType.VISION_TYPE_MISS);
    }

    public void removeGadgetsInGroup(SceneGroup group, SceneSuite suite) {
        var configSet = suite.sceneGadgets.stream().map(m -> m.config_id).collect(Collectors.toSet());
        var toRemove =
                getScene().getEntities().values().stream()
                        .filter(e -> e instanceof EntityGadget)
                        .filter(e -> e.getGroupId() == group.id)
                        .filter(e -> configSet.contains(e.getConfigId()))
                        .toList();

        getScene().removeEntities(toRemove, VisionTypeOuterClass.VisionType.VISION_TYPE_MISS);
    }

    public void killMonstersInGroup(SceneGroup group, SceneSuite suite) {
        var configSet = suite.sceneMonsters.stream().map(m -> m.config_id).collect(Collectors.toSet());
        var toRemove =
                getScene().getEntities().values().stream()
                        .filter(e -> e instanceof EntityMonster)
                        .filter(e -> e.getGroupId() == group.id)
                        .filter(e -> configSet.contains(e.getConfigId()))
                        .toList();

        toRemove.forEach(getScene()::killEntity);
    }

    public void killGadgetsInGroup(SceneGroup group, SceneSuite suite) {
        var configSet = suite.sceneGadgets.stream().map(m -> m.config_id).collect(Collectors.toSet());
        var toRemove =
                getScene().getEntities().values().stream()
                        .filter(e -> e instanceof EntityGadget)
                        .filter(e -> e.getGroupId() == group.id)
                        .filter(e -> configSet.contains(e.getConfigId()))
                        .toList();

        toRemove.forEach(getScene()::killEntity);
    }

    public int createGroupTimerEvent(int groupID, String source, double time) {
        // TODO also remove timers when refreshing and test
        var group = getGroupById(groupID);
        if (group == null || group.triggers == null) {
            Grasscutter.getLogger()
                    .debug(
                            "trying to create a timer for unknown group with id {} and source {}",
                            groupID,
                            source);
            return 1;
        }
        Grasscutter.getLogger()
                .debug(
                        "creating group timer event for group {} with source {} and time {}",
                        groupID,
                        source,
                        time);
        for (SceneTrigger trigger : group.triggers.values()) {
            if (trigger.getEvent() == EVENT_TIMER_EVENT && trigger.getSource().equals(source)) {
                Grasscutter.getLogger()
                        .debug(
                                "[LUA] Found timer trigger with source {} for group {} : {}",
                                source,
                                groupID,
                                trigger.getName());
                this.cancelGroupTimerEvent(groupID, source);
                var taskIdentifier =
                        Grasscutter.getGameServer()
                                .getScheduler()
                                .scheduleDelayedRepeatingTask(
                                        () ->
                                                callEvent(
                                                        new ScriptArgs(groupID, EVENT_TIMER_EVENT).setEventSource(source)),
                                        (int) time,
                                        (int) time);
                var groupTasks = activeGroupTimers.computeIfAbsent(groupID, k -> new HashSet<>());
                groupTasks.add(new Pair<>(source, taskIdentifier));
            }
        }
        return 0;
    }

    public int cancelGroupTimerEvent(int groupID, String source) {
        // TODO test
        var groupTimers = activeGroupTimers.get(groupID);
        if (groupTimers != null && !groupTimers.isEmpty()) {
            for (var timer : new HashSet<>(groupTimers)) {
                if (timer.component1().equals(source)) {
                    Grasscutter.getGameServer().getScheduler().cancelTask(timer.component2());
                    groupTimers.remove(timer);
                    return 0;
                }
            }
        }

        Grasscutter.getLogger()
                .warn("trying to cancel a timer that's not active {} {}", groupID, source);
        return 1;
    }

    // todo use killed monsters instead of spawned entites for check?
    public boolean isClearedGroupMonsters(int groupId) {
        val groupInstance = getGroupInstanceById(groupId);
        if (groupInstance == null || groupInstance.getLuaGroup() == null) return false;

        val monsters = groupInstance.getLuaGroup().monsters;

        if (monsters == null || monsters.isEmpty()) return true;

        return monsters.values().stream()
                .noneMatch(
                        m -> {
                            val entity = scene.getEntityByConfigId(m.config_id);
                            return entity != null && entity.getGroupId() == groupId;
                        });
    }

    public void onDestroy() {
        activeGroupTimers.forEach(
                (gid, times) ->
                        times.forEach(
                                (e) -> Grasscutter.getGameServer().getScheduler().cancelTask(e.getSecond())));
        activeGroupTimers.clear();
    }
}