vm.h

#pragma once
#include "gaia/config/config.h"
 
#include <cstdint>
#include <cstdio>
#include <type_traits>
 
#include "gaia/cnt/darray.h"
#include "gaia/cnt/sarray.h"
#include "gaia/cnt/sarray_ext.h"
#include "gaia/cnt/set.h"
#include "gaia/config/profiler.h"
#include "gaia/core/utility.h"
#include "gaia/ecs/api.h"
#include "gaia/ecs/archetype.h"
#include "gaia/ecs/archetype_common.h"
#include "gaia/ecs/id.h"
#include "gaia/ecs/query_common.h"
#include "gaia/ecs/query_mask.h"
#include "gaia/ecs/query_match_stamps.h"
#include "gaia/ser/ser_binary.h"
#include "gaia/util/str.h"
 
namespace gaia {
  namespace ecs {
    using EntityToArchetypeMap = cnt::map<EntityLookupKey, ComponentIndexEntryArray>;
 
  } // namespace ecs
 
  namespace ecs {
    namespace vm {
 
      enum class MatchingStyle {
        Simple,
        Wildcard,
        Complex
      };
 
      struct ArchetypeLookupView {
        using FetchByKeyFn = std::span<const ComponentIndexEntry> (*)(
            const void*, std::span<const Archetype*>, Entity, const EntityLookupKey&);
 
        const void* pData = nullptr;
        const EntityToArchetypeVersionMap* pVersions = nullptr;
        FetchByKeyFn fetchByKey = nullptr;
 
        GAIA_NODISCARD bool empty() const {
          return fetchByKey == nullptr;
        }
 
        GAIA_NODISCARD std::span<const ComponentIndexEntry>
        fetch(std::span<const Archetype*> arr, Entity ent, const EntityLookupKey& key) const {
          if (empty())
            return {};
 
          return fetchByKey(pData, arr, ent, key);
        }
 
        GAIA_NODISCARD uint32_t revision(const EntityLookupKey& key) const {
          if (pVersions == nullptr || pVersions->empty())
            return 0;
 
          const auto it = pVersions->find(key);
          return it == pVersions->end() ? 0 : it->second;
        }
      };
 
      struct MatchingCtx {
        // Setup up externally
 
        const World* pWorld;
        EntitySpan targetEntities;
        ArchetypeLookupView archetypeLookup;
        std::span<const Archetype*> allArchetypes;
        cnt::darr<const Archetype*>* pMatchesArr;
        ArchetypeMatchStamps* pMatchesStampByArchetypeId;
        uint32_t matchesVersion;
        QueryArchetypeCacheIndexMap* pLastMatchedArchetypeIdx_All;
        QueryArchetypeCacheIndexMap* pLastMatchedArchetypeIdx_Or;
        QueryArchetypeCacheIndexMap* pLastMatchedArchetypeIdx_Not;
        QueryMask queryMask;
        uint32_t as_mask_0;
        uint32_t as_mask_1;
        uint16_t flags;
        cnt::sarray<Entity, MaxVarCnt> varBindings;
        uint8_t varBindingMask = 0;
        bool skipOr = false;
 
        // For the opcode compiler to modify
 
        Entity ent;
        EntitySpan idsToMatch;
        uint32_t pc;
      };
 
      inline std::span<const ComponentIndexEntry> fetch_archetypes_for_select(
          const EntityToArchetypeMap& map, std::span<const Archetype*> arr, Entity ent, const EntityLookupKey& key) {
        (void)arr;
        (void)ent;
        GAIA_ASSERT(key != EntityBadLookupKey);
 
        const auto it = map.find(key);
        if (it == map.end() || it->second.empty())
          return {};
 
        return std::span(it->second.data(), it->second.size());
      }
 
      inline std::span<const ComponentIndexEntry> fetch_archetypes_for_select(
          const EntityToArchetypeMap& map, std::span<const Archetype*> arr, Entity ent, Entity src) {
        GAIA_ASSERT(src != EntityBad);
 
        return fetch_archetypes_for_select(map, arr, ent, EntityLookupKey(src));
      }
 
      inline std::span<const ComponentIndexEntry> fetch_archetypes_for_select(
          const SingleArchetypeLookup& map, std::span<const Archetype*> arr, Entity ent, const EntityLookupKey& key) {
        (void)ent;
        GAIA_ASSERT(key != EntityBadLookupKey);
 
        const auto it = core::find_if(map, [&](const auto& item) {
          return item.matches(key);
        });
        if (it == map.end() || arr.empty())
          return {};
 
        return std::span(&it->entry, 1);
      }
 
      inline std::span<const ComponentIndexEntry> fetch_archetypes_for_select(
          const SingleArchetypeLookup& map, std::span<const Archetype*> arr, Entity ent, Entity src) {
        GAIA_ASSERT(src != EntityBad);
 
        return fetch_archetypes_for_select(map, arr, ent, EntityLookupKey(src));
      }
 
      inline std::span<const ComponentIndexEntry> fetch_archetypes_for_select_from_map(
          const void* pData, std::span<const Archetype*> arr, Entity ent, const EntityLookupKey& key) {
        return fetch_archetypes_for_select(*(const EntityToArchetypeMap*)pData, arr, ent, key);
      }
 
      inline std::span<const ComponentIndexEntry> fetch_archetypes_for_select_from_single(
          const void* pData, std::span<const Archetype*> arr, Entity ent, const EntityLookupKey& key) {
        return fetch_archetypes_for_select(*(const SingleArchetypeLookup*)pData, arr, ent, key);
      }
 
      inline ArchetypeLookupView
      make_archetype_lookup_view(const EntityToArchetypeMap& map, const EntityToArchetypeVersionMap& versions) {
        return ArchetypeLookupView{&map, &versions, fetch_archetypes_for_select_from_map};
      }
 
      inline ArchetypeLookupView make_archetype_lookup_view(const SingleArchetypeLookup& map) {
        return ArchetypeLookupView{&map, nullptr, fetch_archetypes_for_select_from_single};
      }
 
      namespace detail {
        enum class EOpcode : uint8_t { //
          All_Simple,
          All_Wildcard,
          All_Complex,
          Or_NoAll_Simple,
          Or_NoAll_Wildcard,
          Or_NoAll_Complex,
          Or_WithAll_Simple,
          Or_WithAll_Wildcard,
          Or_WithAll_Complex,
          Not_Simple,
          Not_Wildcard,
          Not_Complex,
          Seed_All,
          Var_Filter,
          Src_AllTerm,
          Src_NotTerm,
          Src_OrTerm,
          Src_Never,
          Src_Self,
          Src_Up,
          Src_Down,
          Src_UpDown,
          Var_Term_All_Check,
          Var_Term_All_Bind,
          Var_Term_All_Src_Bind,
          Var_Term_Or_Check,
          Var_Term_Or_Bind,
          Var_Term_Any_Check,
          Var_Term_Any_Bind,
          Var_Term_Not,
          Var_Search_SelectAll,
          Var_Search_SelectOr,
          Var_Search_SelectOtherOr,
          Var_Search_SelectOtherOrBind,
          Var_Search_BeginAny,
          Var_Search_SelectAny,
          Var_Search_MaybeFinalize,
          Var_Final_Not_Check,
          Var_Final_Require_Or,
          Var_Final_Or_Check,
          Var_Final_Success
        };
 
        using VmLabel = uint16_t;
 
        struct CompiledOp {
          EOpcode opcode;
          VmLabel pc_ok;
          VmLabel pc_fail;
          uint8_t arg = 0;
          uint8_t cost = 0;
        };
 
        struct QueryCompileCtx {
          struct SourceTermOp {
            EOpcode opcode = EOpcode::Src_Never;
            QueryTerm term{};
          };
 
          struct VarTermOp {
            EOpcode sourceOpcode = EOpcode::Src_Never;
            QueryTerm term{};
            uint8_t varMask = 0;
          };
 
          struct VarProgram {
            uint16_t begin = 0;
            uint16_t count = 0;
 
            void clear() {
              begin = 0;
              count = 0;
            }
 
            GAIA_NODISCARD bool empty() const {
              return count == 0;
            }
          };
 
          struct VarSearchMeta {
            uint16_t selectAllPc = (uint16_t)-1;
            uint16_t selectOrPc = (uint16_t)-1;
            uint16_t selectOtherOrPc = (uint16_t)-1;
            uint16_t selectOtherOrBindPc = (uint16_t)-1;
            uint16_t beginAnyPc = (uint16_t)-1;
            uint16_t selectAnyPc = (uint16_t)-1;
            uint16_t maybeFinalizePc = (uint16_t)-1;
            uint16_t initialAllMask = 0;
            uint16_t initialOrMask = 0;
            uint16_t initialAnyMask = 0;
            uint16_t allBegin = 0;
            uint16_t allCheckBegin = 0;
            uint16_t allCount = 0;
            uint16_t orBegin = 0;
            uint16_t orCheckBegin = 0;
            uint16_t orCount = 0;
            uint16_t anyBegin = 0;
            uint16_t anyCheckBegin = 0;
            uint16_t anyCount = 0;
            uint16_t notBegin = 0;
            uint16_t notCount = 0;
            uint8_t orVarMask = 0;
          };
 
          struct VarProgramStep {
            VarProgram program{};
            VarSearchMeta search{};
          };
 
          cnt::darray<CompiledOp> ops;
          uint16_t mainOpsCount = 0;
          cnt::sarray_ext<Entity, MAX_ITEMS_IN_QUERY> ids_all;
          cnt::sarray_ext<Entity, MAX_ITEMS_IN_QUERY> ids_or;
          cnt::sarray_ext<Entity, MAX_ITEMS_IN_QUERY> ids_not;
          cnt::sarray_ext<SourceTermOp, MAX_ITEMS_IN_QUERY> terms_all_src;
          cnt::sarray_ext<SourceTermOp, MAX_ITEMS_IN_QUERY> terms_or_src;
          cnt::sarray_ext<SourceTermOp, MAX_ITEMS_IN_QUERY> terms_not_src;
          cnt::sarray_ext<VarTermOp, MAX_ITEMS_IN_QUERY> terms_all_var;
          cnt::sarray_ext<VarTermOp, MAX_ITEMS_IN_QUERY> terms_or_var;
          cnt::sarray_ext<VarTermOp, MAX_ITEMS_IN_QUERY> terms_not_var;
          cnt::sarray_ext<VarTermOp, MAX_ITEMS_IN_QUERY> terms_any_var;
          cnt::sarray_ext<VarProgramStep, MaxVarCnt> var_programs;
          uint8_t varMaskAll = 0;
          uint8_t varMaskOr = 0;
          uint8_t varMaskNot = 0;
          uint8_t varMaskAny = 0;
 
          GAIA_NODISCARD bool has_src_terms() const {
            return !terms_all_src.empty() || !terms_or_src.empty() || !terms_not_src.empty();
          }
 
          GAIA_NODISCARD bool has_variable_terms() const {
            return !terms_all_var.empty() || !terms_or_var.empty() || !terms_not_var.empty() || !terms_any_var.empty();
          }
 
          GAIA_NODISCARD bool has_id_terms() const {
            return !ids_all.empty() || !ids_or.empty() || !ids_not.empty();
          }
        };
 
        enum class EVarProgramTermSet : uint8_t { None, All, Or, Any, Not };
 
        struct VarProgramOpcodeMeta {
          EVarProgramTermSet termSet;
        };
 
        static constexpr auto VarProgramOpcodeFirst = EOpcode::Var_Term_All_Check;
        static constexpr auto VarProgramOpcodeLast = EOpcode::Var_Final_Success;
        static constexpr VarProgramOpcodeMeta VarProgramOpcodeMetaTable[] = {
            {EVarProgramTermSet::All}, //
            {EVarProgramTermSet::All}, //
            {EVarProgramTermSet::All}, //
            {EVarProgramTermSet::Or}, //
            {EVarProgramTermSet::Or}, //
            {EVarProgramTermSet::Any}, //
            {EVarProgramTermSet::Any}, //
            {EVarProgramTermSet::Not}, //
            {EVarProgramTermSet::None}, //
            {EVarProgramTermSet::None}, //
            {EVarProgramTermSet::None}, //
            {EVarProgramTermSet::None}, //
            {EVarProgramTermSet::None}, //
            {EVarProgramTermSet::None}, //
            {EVarProgramTermSet::None}, //
            {EVarProgramTermSet::Not}, //
            {EVarProgramTermSet::None}, //
            {EVarProgramTermSet::Or}, //
            {EVarProgramTermSet::None}, //
        };
 
        static_assert(
            sizeof(VarProgramOpcodeMetaTable) / sizeof(VarProgramOpcodeMetaTable[0]) ==
                (uint32_t)VarProgramOpcodeLast - (uint32_t)VarProgramOpcodeFirst + 1u,
            "VarProgramOpcodeMetaTable out of sync with EOpcode variable micro-op range.");
 
        GAIA_NODISCARD inline const VarProgramOpcodeMeta& var_program_opcode_meta(EOpcode opcode) {
          GAIA_ASSERT((uint32_t)opcode >= (uint32_t)VarProgramOpcodeFirst);
          GAIA_ASSERT((uint32_t)opcode <= (uint32_t)VarProgramOpcodeLast);
          return VarProgramOpcodeMetaTable[(uint32_t)opcode - (uint32_t)VarProgramOpcodeFirst];
        }
 
        GAIA_NODISCARD inline uint8_t src_term_cost(const QueryCompileCtx::SourceTermOp& termOp) {
          const bool depth1 = termOp.term.travDepth == 1;
          switch (termOp.opcode) {
            case EOpcode::Src_Never:
              return 0;
            case EOpcode::Src_Self:
              return 1;
            case EOpcode::Src_Up:
            case EOpcode::Src_Down:
              return depth1 ? 2 : 4;
            case EOpcode::Src_UpDown:
              return depth1 ? 3 : 5;
            default:
              return 6;
          }
        }
 
        GAIA_NODISCARD inline uint8_t bound_match_id_cost(Entity queryId) {
          if (!queryId.pair())
            return (!is_variable(queryId) && queryId.id() != All.id()) ? 1u : 3u;
 
          uint8_t cost = 0;
          cost += (!is_variable((EntityId)queryId.id()) && queryId.id() != All.id()) ? 1u : 3u;
          cost += (!is_variable((EntityId)queryId.gen()) && queryId.gen() != All.id()) ? 1u : 3u;
          return cost;
        }
 
        GAIA_NODISCARD inline uint8_t bound_term_cost(const QueryCompileCtx::VarTermOp& termOp) {
          uint8_t cost = bound_match_id_cost(termOp.term.id);
          if (termOp.term.src != EntityBad)
            cost = (uint8_t)(cost + src_term_cost({termOp.sourceOpcode, termOp.term}));
          return cost;
        }
 
        GAIA_NODISCARD inline uint8_t search_term_cost(const QueryCompileCtx::VarTermOp& termOp) {
          uint8_t cost = bound_term_cost(termOp);
          if (termOp.term.src != EntityBad) {
            const bool srcIsVar = is_variable(EntityId(termOp.term.src.id()));
            cost = (uint8_t)(cost + (srcIsVar ? 32u : 8u));
          }
          return cost;
        }
 
        template <typename ProgramOpsArray>
        inline void sort_program_ops_by_cost(ProgramOpsArray& ops) {
          const auto cnt = (uint32_t)ops.size();
          if (cnt < 2)
            return;
 
          for (uint32_t i = 1; i < cnt; ++i) {
            const auto key = ops[i];
 
            uint32_t j = i;
            while (j > 0) {
              const auto prev = ops[j - 1];
              if (prev.cost < key.cost)
                break;
              if (prev.cost == key.cost && (uint8_t)prev.opcode < (uint8_t)key.opcode)
                break;
              if (prev.cost == key.cost && prev.opcode == key.opcode && prev.arg <= key.arg)
                break;
              ops[j] = prev;
              --j;
            }
 
            ops[j] = key;
          }
        }
 
        template <typename SourceTermsArray>
        inline void sort_src_terms_by_cost(SourceTermsArray& terms) {
          const auto cnt = (uint32_t)terms.size();
          if (cnt < 2)
            return;
 
          for (uint32_t i = 1; i < cnt; ++i) {
            auto key = terms[i];
            const auto keyCost = src_term_cost(key);
 
            uint32_t j = i;
            while (j > 0 && src_term_cost(terms[j - 1]) > keyCost) {
              terms[j] = terms[j - 1];
              --j;
            }
 
            terms[j] = key;
          }
        }
 
        GAIA_NODISCARD inline std::span<const CompiledOp>
        program_ops(const QueryCompileCtx& comp, const QueryCompileCtx::VarProgram& program) {
          GAIA_ASSERT((uint32_t)program.begin + (uint32_t)program.count <= (uint32_t)comp.ops.size());
          return {comp.ops.data() + program.begin, program.count};
        }
 
        inline uint32_t handle_last_archetype_match(
            QueryArchetypeCacheIndexMap* pCont, EntityLookupKey entityKey, uint32_t srcArchetypeCnt,
            uint32_t srcRevision) {
          if (pCont == nullptr)
            return 0;
 
          const auto cache_it = pCont->find(entityKey);
          uint32_t lastMatchedIdx = 0;
          if (cache_it == pCont->end())
            pCont->emplace(entityKey, QueryArchetypeCacheCursor{srcArchetypeCnt, srcRevision});
          else {
            auto& cursor = cache_it->second;
            if (cursor.revision == srcRevision)
              lastMatchedIdx = cursor.index;
            cursor.index = srcArchetypeCnt;
            cursor.revision = srcRevision;
          }
          return lastMatchedIdx;
        }
 
        // Operator ALL (used by query::all)
        struct OpAll {
          static bool check_mask(const QueryMask& maskArchetype, const QueryMask& maskQuery) {
            return match_entity_mask(maskArchetype, maskQuery);
          }
          static void restart([[maybe_unused]] uint32_t& idx) {}
          static bool can_continue(bool hasMatch) {
            return hasMatch;
          }
          static bool eval(uint32_t expectedMatches, uint32_t totalMatches) {
            return expectedMatches == totalMatches;
          }
          static uint32_t handle_last_match(
              MatchingCtx& ctx, EntityLookupKey entityKey, uint32_t srcArchetypeCnt, uint32_t srcRevision) {
            return handle_last_archetype_match(
                ctx.pLastMatchedArchetypeIdx_All, entityKey, srcArchetypeCnt, srcRevision);
          }
        };
        // Operator OR (used by query::or_)
        struct OpOr {
          static bool check_mask(const QueryMask& maskArchetype, const QueryMask& maskQuery) {
            return match_entity_mask(maskArchetype, maskQuery);
          }
          static void restart(uint32_t& idx) {
            // OR terms are evaluated independently.
            idx = 0;
          }
          static bool can_continue([[maybe_unused]] bool hasMatch) {
            return true;
          }
          static bool eval(uint32_t expectedMatches, uint32_t totalMatches) {
            (void)expectedMatches;
            return totalMatches > 0;
          }
          static uint32_t handle_last_match(
              MatchingCtx& ctx, EntityLookupKey entityKey, uint32_t srcArchetypeCnt, uint32_t srcRevision) {
            return handle_last_archetype_match(
                ctx.pLastMatchedArchetypeIdx_Or, entityKey, srcArchetypeCnt, srcRevision);
          }
        };
        // Operator NOT (used by query::no)
        struct OpNo {
          static bool check_mask(const QueryMask& maskArchetype, const QueryMask& maskQuery) {
            return !match_entity_mask(maskArchetype, maskQuery);
          }
          static void restart(uint32_t& idx) {
            idx = 0;
          }
          static bool can_continue(bool hasMatch) {
            return !hasMatch;
          }
          static bool eval(uint32_t expectedMatches, uint32_t totalMatches) {
            (void)expectedMatches;
            return totalMatches == 0;
          }
          static uint32_t handle_last_match(
              MatchingCtx& ctx, EntityLookupKey entityKey, uint32_t srcArchetypeCnt, uint32_t srcRevision) {
            return handle_last_archetype_match(
                ctx.pLastMatchedArchetypeIdx_Not, entityKey, srcArchetypeCnt, srcRevision);
          }
        };
 
        GAIA_NODISCARD inline bool is_archetype_marked(const MatchingCtx& ctx, const Archetype* pArchetype) {
          GAIA_ASSERT(ctx.pMatchesStampByArchetypeId != nullptr);
 
          const auto& stamps = *ctx.pMatchesStampByArchetypeId;
          const auto sid = (uint32_t)pArchetype->id();
          if (!stamps.has(sid))
            return false;
 
          return stamps.get(sid) == ctx.matchesVersion;
        }
 
        inline void mark_archetype_match(MatchingCtx& ctx, const Archetype* pArchetype) {
          GAIA_ASSERT(ctx.pMatchesStampByArchetypeId != nullptr);
 
          auto& stamps = *ctx.pMatchesStampByArchetypeId;
          const auto sid = (uint32_t)pArchetype->id();
          stamps.set(sid, ctx.matchesVersion);
 
          ctx.pMatchesArr->emplace_back(pArchetype);
        }
 
        inline void add_all_archetypes(MatchingCtx& ctx) {
          for (const auto* pArchetype: ctx.allArchetypes) {
            if (is_archetype_marked(ctx, pArchetype))
              continue;
 
            mark_archetype_match(ctx, pArchetype);
          }
        }
 
        template <typename OpKind>
        inline bool match_inter_eval_matches(uint32_t queryIdMarches, uint32_t& outMatches) {
          const bool hadAnyMatches = queryIdMarches > 0;
 
          // We finished checking matches with an id from query.
          // We need to check if we have sufficient amount of results in the run.
          if (!OpKind::can_continue(hadAnyMatches))
            return false;
 
          // No matter the amount of matches we only care if at least one
          // match happened with the id from query.
          outMatches += (uint32_t)hadAnyMatches;
          return true;
        }
 
        template <typename OpKind, typename CmpFunc>
        GAIA_NODISCARD inline bool match_inter(EntitySpan queryIds, EntitySpan archetypeIds, CmpFunc func) {
          const auto archetypeIdsCnt = (uint32_t)archetypeIds.size();
          const auto queryIdsCnt = (uint32_t)queryIds.size();
 
          // Arrays are sorted so we can do linear intersection lookup
          uint32_t indices[2]{}; // 0 for query ids, 1 for archetype ids
          uint32_t matches = 0;
 
          // Ids in query and archetype are sorted.
          // Therefore, to match any two ids we perform a linear intersection forward loop.
          // The only exception are transitive ids in which case we need to start searching
          // form the start.
          // Finding just one match for any id in the query is enough to start checking
          // the next it. We only have 3 different operations - ALL, OR, NOT.
          //
          // Example:
          // - query #1 ------------------------
          // queryIds    : 5, 10
          // archetypeIds: 1,  3,  5,  6,  7, 10
          // - query #2 ------------------------
          // queryIds    : 1, 10, 11
          // archetypeIds: 3,  5,  6,  7, 10, 15
          // -----------------------------------
          // indices[0]  : 0,  1,  2
          // indices[1]  : 0,  1,  2,  3,  4,  5
          //
          // For query #1:
          // We start matching 5 in the query with 1 in the archetype. They do not match.
          // We continue with 3 in the archetype. No match.
          // We continue with 5 in the archetype. Match.
          // We try to match 10 in the query with 6 in the archetype. No match.
          // ... etc.
 
          while (indices[0] < queryIdsCnt) {
            const auto idInQuery = queryIds[indices[0]];
 
            // For * and transitive ids we have to search from the start.
            if (idInQuery == All || idInQuery.id() == Is.id())
              indices[1] = 0;
 
            uint32_t queryIdMatches = 0;
            while (indices[1] < archetypeIdsCnt) {
              const auto idInArchetype = archetypeIds[indices[1]];
 
              // See if we have a match
              const auto res = func(idInQuery, idInArchetype);
 
              // Once a match is found we start matching with the next id in query.
              if (res.matched) {
                ++indices[0];
                ++indices[1];
                ++queryIdMatches;
 
                // Only continue with the next iteration unless the given Op determines it is
                // no longer needed.
                if (!match_inter_eval_matches<OpKind>(queryIdMatches, matches))
                  return false;
 
                goto next_query_id;
              } else {
                ++indices[1];
              }
            }
 
            if (!match_inter_eval_matches<OpKind>(queryIdMatches, matches))
              return false;
 
            ++indices[0];
            // Make sure to continue from the right index on the archetype array.
            // Some operators can keep moving forward (AND, OR), but NOT needs to start
            // matching from the beginning again if the previous query operator didn't find a match.
            OpKind::restart(indices[1]);
 
          next_query_id:
            continue;
          }
 
          return OpKind::eval(queryIdsCnt, matches);
        }
 
        struct IdCmpResult {
          bool matched;
        };
 
        GAIA_NODISCARD inline IdCmpResult cmp_ids(Entity idInQuery, Entity idInArchetype) {
          return {idInQuery == idInArchetype};
        }
 
        GAIA_NODISCARD inline IdCmpResult cmp_ids_pairs(Entity idInQuery, Entity idInArchetype) {
          if (idInQuery.pair()) {
            // all(Pair<All, All>) aka "any pair"
            if (idInQuery == Pair(All, All))
              return {true};
 
            // all(Pair<X, All>):
            //   X, AAA
            //   X, BBB
            //   ...
            //   X, ZZZ
            if (idInQuery.gen() == All.id())
              return {idInQuery.id() == idInArchetype.id()};
 
            // all(Pair<All, X>):
            //   AAA, X
            //   BBB, X
            //   ...
            //   ZZZ, X
            if (idInQuery.id() == All.id())
              return {idInQuery.gen() == idInArchetype.gen()};
          }
 
          // 1:1 match needed for non-pairs
          return cmp_ids(idInQuery, idInArchetype);
        }
 
        GAIA_NODISCARD inline IdCmpResult
        cmp_ids_is(const World& w, const Archetype& archetype, Entity idInQuery, Entity idInArchetype) {
          // all(Pair<Is, X>)
          if (idInQuery.pair() && idInQuery.id() == Is.id()) {
            auto archetypeIds = archetype.ids_view();
            return {
                idInQuery.gen() == idInArchetype.id() || // X vs Id
                as_relations_trav_if(w, idInQuery, [&](Entity relation) {
                  const auto idx = core::get_index(archetypeIds, relation);
                  // Stop at the first match
                  return idx != BadIndex;
                })};
          }
 
          // 1:1 match needed for non-pairs
          return cmp_ids(idInQuery, idInArchetype);
        }
 
        GAIA_NODISCARD inline IdCmpResult
        cmp_ids_is_pairs(const World& w, const Archetype& archetype, Entity idInQuery, Entity idInArchetype) {
          if (idInQuery.pair()) {
            // all(Pair<All, All>) aka "any pair"
            if (idInQuery == Pair(All, All))
              return {true};
 
            // all(Pair<Is, X>)
            if (idInQuery.id() == Is.id()) {
              // (Is, X) in archetype == (Is, X) in query
              if (idInArchetype == idInQuery)
                return {true};
 
              const auto eQ = pair_tgt(w, idInQuery);
              if (eQ == idInArchetype)
                return {true};
 
              // If the archetype entity is an (Is, X) pair treat Is as X and try matching it with
              // entities inheriting from e.
              if (idInArchetype.id() == Is.id()) {
                const auto eA = pair_tgt(w, idInArchetype);
                if (eA == eQ)
                  return {true};
 
                return {as_relations_trav_if(w, eQ, [eA](Entity relation) {
                  return eA == relation;
                })};
              }
 
              // Archetype entity is generic, try matching it with entities inheriting from e.
              auto archetypeIds = archetype.ids_view();
              return {as_relations_trav_if(w, eQ, [&archetypeIds](Entity relation) {
                // Relation does not necessary match the sorted order of components in the archetype
                // so we need to search through all of its ids.
                const auto idx = core::get_index(archetypeIds, relation);
                // Stop at the first match
                return idx != BadIndex;
              })};
            }
 
            // all(Pair<All, X>):
            //   AAA, X
            //   BBB, X
            //   ...
            //   ZZZ, X
            if (idInQuery.id() == All.id()) {
              if (idInQuery.gen() == idInArchetype.gen())
                return {true};
 
              // If there are any Is pairs on the archetype we need to check if we match them
              if (archetype.pairs_is() > 0) {
                auto archetypeIds = archetype.ids_view();
 
                const auto e = pair_tgt(w, idInQuery);
                return {as_relations_trav_if(w, e, [&](Entity relation) {
                  // Relation does not necessary match the sorted order of components in the archetype
                  // so we need to search through all of its ids.
                  const auto idx = core::get_index(archetypeIds, relation);
                  // Stop at the first match
                  return idx != BadIndex;
                })};
              }
 
              // No match found
              return {false};
            }
 
            // all(Pair<X, All>):
            //   X, AAA
            //   X, BBB
            //   ...
            //   X, ZZZ
            if (idInQuery.gen() == All.id()) {
              return {idInQuery.id() == idInArchetype.id()};
            }
          }
 
          // 1:1 match needed for non-pairs
          return cmp_ids(idInQuery, idInArchetype);
        }
 
        template <typename OpKind>
        GAIA_NODISCARD inline bool match_res(const Archetype& archetype, EntitySpan queryIds) {
          // Archetype has no pairs we can compare ids directly.
          // This has better performance.
          if (archetype.pairs() == 0) {
            return match_inter<OpKind>(
                queryIds, archetype.ids_view(),
                // Cmp func
                [](Entity idInQuery, Entity idInArchetype) {
                  return cmp_ids(idInQuery, idInArchetype);
                });
          }
 
          // Pairs are present, we have to evaluate.
          return match_inter<OpKind>(
              queryIds, archetype.ids_view(),
              // Cmp func
              [](Entity idInQuery, Entity idInArchetype) {
                return cmp_ids_pairs(idInQuery, idInArchetype);
              });
        }
 
        template <typename OpKind>
        GAIA_NODISCARD inline bool match_res_as(const World& w, const Archetype& archetype, EntitySpan queryIds) {
          // Archetype has no pairs we can compare ids directly
          if (archetype.pairs() == 0) {
            return match_inter<OpKind>(
                queryIds, archetype.ids_view(),
                // cmp func
                [&](Entity idInQuery, Entity idInArchetype) {
                  return cmp_ids_is(w, archetype, idInQuery, idInArchetype);
                });
          }
 
          return match_inter<OpKind>(
              queryIds, archetype.ids_view(),
              // cmp func
              [&](Entity idInQuery, Entity idInArchetype) {
                return cmp_ids_is_pairs(w, archetype, idInQuery, idInArchetype);
              });
        }
 
        GAIA_NODISCARD inline bool match_single_id_on_archetype(const World& w, const Archetype& archetype, Entity id) {
          const Entity ids[1] = {id};
          return match_res_as<OpOr>(w, archetype, EntitySpan{ids, 1});
        }
 
        GAIA_NODISCARD inline bool match_single_id_on_archetype_exact(const Archetype& archetype, Entity id) {
          const Entity ids[1] = {id};
          return match_res<OpOr>(archetype, EntitySpan{ids, 1});
        }
 
        GAIA_NODISCARD inline EOpcode src_opcode_from_term(const QueryTerm& term) {
          const bool includeSelf = query_trav_has(term.travKind, QueryTravKind::Self);
          const bool includeUp = query_trav_has(term.travKind, QueryTravKind::Up) && term.entTrav != EntityBad;
          const bool includeDown = query_trav_has(term.travKind, QueryTravKind::Down) && term.entTrav != EntityBad;
          if (!includeSelf && !includeUp && !includeDown)
            return EOpcode::Src_Never;
          if (includeSelf && !includeUp && !includeDown)
            return EOpcode::Src_Self;
          if (includeUp && includeDown)
            return EOpcode::Src_UpDown;
          if (includeUp)
            return EOpcode::Src_Up;
          return EOpcode::Src_Down;
        }
 
        struct SourceLookupCursor {
          uint32_t queueIdx = 0;
          uint32_t childIdx = 0;
          uint32_t childLevel = 0;
          uint32_t upDepth = 0;
          uint8_t phase = 0;
          bool initialized = false;
          bool selfEmitted = false;
          Entity upSource = EntityBad;
          std::span<const Entity> cachedSources{};
          cnt::darray<Entity> queue;
          cnt::darray<uint32_t> levels;
          cnt::darray<Entity> children;
          cnt::set<EntityLookupKey> visited;
 
          void reset_runtime_state() {
            queueIdx = 0;
            childIdx = 0;
            childLevel = 0;
            upDepth = 0;
            initialized = false;
            selfEmitted = false;
            upSource = EntityBad;
            cachedSources = {};
            queue.clear();
            levels.clear();
            children.clear();
            visited.clear();
          }
        };
 
        GAIA_NODISCARD inline bool next_lookup_src_cursor(
            const World& w, EOpcode opcode, const QueryTerm& term, Entity sourceEntity, SourceLookupCursor& cursor,
            Entity& outSource);
 
        template <typename Func>
        GAIA_NODISCARD inline bool
        each_lookup_src(const World& w, EOpcode opcode, const QueryTerm& term, Entity sourceEntity, Func&& func) {
          SourceLookupCursor cursor{};
          Entity source = EntityBad;
          while (next_lookup_src_cursor(w, opcode, term, sourceEntity, cursor, source)) {
            if (func(source))
              return true;
          }
 
          return false;
        }
 
        template <typename Func>
        GAIA_NODISCARD inline bool
        each_lookup_src(const World& w, const QueryTerm& term, Entity sourceEntity, Func&& func) {
          return each_lookup_src(w, src_opcode_from_term(term), term, sourceEntity, GAIA_FWD(func));
        }
 
        GAIA_NODISCARD inline bool next_lookup_src_cursor_up(
            const World& w, const QueryTerm& term, Entity sourceEntity, SourceLookupCursor& cursor, Entity& outSource,
            bool includeSelf) {
          if (!valid(w, sourceEntity))
            return false;
 
          const uint32_t maxDepth =
              term.travDepth == QueryTermOptions::TravDepthUnlimited ? MAX_TRAV_DEPTH : (uint32_t)term.travDepth;
 
          if (!cursor.initialized) {
            cursor.initialized = true;
            cursor.upSource = sourceEntity;
          }
 
          if (includeSelf && !cursor.selfEmitted) {
            cursor.selfEmitted = true;
            outSource = sourceEntity;
            return true;
          }
 
          while (cursor.upDepth < maxDepth) {
            const auto next = target(w, cursor.upSource, term.entTrav);
            if (next == EntityBad || next == cursor.upSource)
              return false;
            if (!world_entity_enabled(w, next))
              return false;
 
            cursor.upSource = next;
            ++cursor.upDepth;
            outSource = next;
            return true;
          }
 
          return false;
        }
 
        GAIA_NODISCARD inline bool next_lookup_src_cursor_down(
            const World& w, const QueryTerm& term, Entity sourceEntity, SourceLookupCursor& cursor, Entity& outSource,
            bool includeSelf) {
          if (!valid(w, sourceEntity))
            return false;
 
          const uint32_t maxDepth =
              term.travDepth == QueryTermOptions::TravDepthUnlimited ? MAX_TRAV_DEPTH : (uint32_t)term.travDepth;
 
          if (!cursor.initialized) {
            cursor.initialized = true;
            cursor.queue.push_back(sourceEntity);
            cursor.levels.push_back(0);
            cursor.visited.insert(EntityLookupKey(sourceEntity));
          }
 
          if (includeSelf && !cursor.selfEmitted) {
            cursor.selfEmitted = true;
            outSource = sourceEntity;
            return true;
          }
 
          for (;;) {
            if (cursor.childIdx < cursor.children.size()) {
              const auto child = cursor.children[cursor.childIdx++];
              cursor.queue.push_back(child);
              cursor.levels.push_back(cursor.childLevel);
              outSource = child;
              return true;
            }
 
            bool loadedChildren = false;
            while (cursor.queueIdx < cursor.queue.size()) {
              const auto source = cursor.queue[cursor.queueIdx];
              const auto level = cursor.levels[cursor.queueIdx];
              ++cursor.queueIdx;
              if (level >= maxDepth)
                continue;
 
              cursor.children.clear();
              cursor.childIdx = 0;
              cursor.childLevel = level + 1;
              sources(w, term.entTrav, source, [&](Entity next) {
                if (!world_entity_enabled(w, next))
                  return;
 
                const auto key = EntityLookupKey(next);
                const auto ins = cursor.visited.insert(key);
                if (!ins.second)
                  return;
 
                cursor.children.push_back(next);
              });
 
              core::sort(cursor.children, [](Entity left, Entity right) {
                return left.id() < right.id();
              });
 
              if (!cursor.children.empty()) {
                loadedChildren = true;
                break;
              }
            }
 
            if (!loadedChildren)
              return false;
          }
        }
 
        GAIA_NODISCARD inline bool next_lookup_src_cursor(
            const World& w, EOpcode opcode, const QueryTerm& term, Entity sourceEntity, SourceLookupCursor& cursor,
            Entity& outSource) {
          const bool includeSelf = query_trav_has(term.travKind, QueryTravKind::Self);
          const bool unlimitedTraversal =
              term.travDepth == QueryTermOptions::TravDepthUnlimited && term.entTrav != EntityBad;
 
          if (unlimitedTraversal && world_enabled_hierarchy_version(w) == 0 &&
              (opcode == EOpcode::Src_Up || opcode == EOpcode::Src_Down || opcode == EOpcode::Src_UpDown)) {
            if (!valid(w, sourceEntity))
              return false;
 
            if (!cursor.initialized)
              cursor.initialized = true;
 
            if (includeSelf && !cursor.selfEmitted) {
              cursor.selfEmitted = true;
              outSource = sourceEntity;
              return true;
            }
 
            const auto adv_cached_src = [&](std::span<const Entity> cachedSources) {
              if (cursor.cachedSources.data() != cachedSources.data() ||
                  cursor.cachedSources.size() != cachedSources.size()) {
                cursor.cachedSources = cachedSources;
                cursor.queueIdx = 0;
              }
 
              if (cursor.queueIdx < cursor.cachedSources.size()) {
                outSource = cursor.cachedSources[cursor.queueIdx++];
                return true;
              }
 
              return false;
            };
 
            if (opcode == EOpcode::Src_Up) {
              return adv_cached_src(targets_trav_cache(w, term.entTrav, sourceEntity));
            }
 
            if (opcode == EOpcode::Src_Down) {
              return adv_cached_src(sources_bfs_trav_cache(w, term.entTrav, sourceEntity));
            }
 
            if (cursor.phase == 0) {
              if (adv_cached_src(targets_trav_cache(w, term.entTrav, sourceEntity)))
                return true;
 
              cursor.phase = 1;
              cursor.cachedSources = {};
              cursor.queueIdx = 0;
            }
 
            return adv_cached_src(sources_bfs_trav_cache(w, term.entTrav, sourceEntity));
          }
 
          switch (opcode) {
            case EOpcode::Src_Never:
              return false;
            case EOpcode::Src_Self:
              if (cursor.initialized || !valid(w, sourceEntity))
                return false;
              cursor.initialized = true;
              outSource = sourceEntity;
              return true;
            case EOpcode::Src_Up:
              return next_lookup_src_cursor_up(w, term, sourceEntity, cursor, outSource, includeSelf);
            case EOpcode::Src_Down:
              return next_lookup_src_cursor_down(w, term, sourceEntity, cursor, outSource, includeSelf);
            case EOpcode::Src_UpDown:
              if (cursor.phase == 0) {
                if (next_lookup_src_cursor_up(w, term, sourceEntity, cursor, outSource, includeSelf))
                  return true;
                cursor.reset_runtime_state();
                cursor.phase = 1;
              }
              return next_lookup_src_cursor_down(w, term, sourceEntity, cursor, outSource, false);
            default:
              GAIA_ASSERT(false);
              return false;
          }
        }
 
        GAIA_NODISCARD inline bool match_src_term(const World& w, const QueryTerm& term, EOpcode opcode) {
          auto match_src_entity = [&](Entity source) {
            if (!valid(w, source))
              return false;
 
            auto* pArchetype = archetype_from_entity(w, source);
            if (pArchetype == nullptr)
              return false;
 
            return match_single_id_on_archetype(w, *pArchetype, term.id);
          };
 
          return each_lookup_src(w, opcode, term, term.src, match_src_entity);
        }
 
        GAIA_NODISCARD inline bool match_src_term(const World& w, const QueryTerm& term) {
          return match_src_term(w, term, src_opcode_from_term(term));
        }
 
        struct VarBindings {
          cnt::sarray<Entity, MaxVarCnt> values{};
          uint8_t mask = 0;
        };
 
        struct VarTermMatchCursor {
          uint32_t idIdx = 0;
          uint32_t sourceArchetypeIdx = 0;
          uint32_t sourceChunkIdx = 0;
          uint32_t sourceEntityIdx = 0;
          Entity source = EntityBad;
          SourceLookupCursor sourceCursor{};
        };
 
        GAIA_NODISCARD inline bool is_var_entity(Entity entity) {
          return is_variable(EntityId(entity.id()));
        }
 
        GAIA_NODISCARD inline uint32_t var_index(Entity varEntity) {
          GAIA_ASSERT(is_var_entity(varEntity));
          return (uint32_t)(varEntity.id() - Var0.id());
        }
 
        GAIA_NODISCARD inline bool var_is_bound(const VarBindings& vars, Entity varEntity) {
          const auto idx = var_index(varEntity);
          return (vars.mask & (uint8_t(1) << idx)) != 0;
        }
 
        GAIA_NODISCARD inline bool bind_var(VarBindings& vars, Entity varEntity, Entity value) {
          const auto idx = var_index(varEntity);
          const auto bit = (uint8_t(1) << idx);
          if ((vars.mask & bit) != 0)
            return vars.values[idx].id() == value.id();
 
          vars.values[idx] = value;
          vars.mask |= bit;
          return true;
        }
 
        GAIA_NODISCARD inline bool match_token(VarBindings& vars, Entity token, Entity value, bool pairSide) {
          if (pairSide && token.id() == All.id())
            return true;
 
          if (!is_var_entity(token))
            return token.id() == value.id();
 
          return bind_var(vars, token, value);
        }
 
        struct ResolvedPairToken {
          Entity token = EntityBad;
          Entity matchValue = EntityBad;
          bool concrete = false;
          bool needsBind = false;
        };
 
        struct RawMatchToken {
          uint32_t matchId = 0;
          uint8_t bindVarIdx = 0xff;
          bool concrete = false;
          bool needsBind = false;
        };
 
        GAIA_NODISCARD inline ResolvedPairToken resolve_pair_query_token(Entity queryToken, const VarBindings& vars) {
          ResolvedPairToken out{};
          out.token = queryToken;
 
          if (queryToken == EntityBad)
            return out;
 
          if (is_var_entity(queryToken)) {
            if (!var_is_bound(vars, queryToken)) {
              out.needsBind = true;
              return out;
            }
 
            out.matchValue = vars.values[var_index(queryToken)];
            out.concrete = out.matchValue.id() != All.id();
            return out;
          }
 
          if (queryToken.id() == All.id())
            return out;
 
          out.matchValue = queryToken;
          out.concrete = true;
          return out;
        }
 
        GAIA_NODISCARD inline RawMatchToken resolve_raw_pair_match_token(Entity queryToken, const VarBindings& vars) {
          RawMatchToken out{};
 
          if (queryToken == EntityBad || queryToken.id() == All.id())
            return out;
 
          if (is_var_entity(queryToken)) {
            out.bindVarIdx = (uint8_t)var_index(queryToken);
            if ((vars.mask & (uint8_t(1) << out.bindVarIdx)) == 0) {
              out.needsBind = true;
              return out;
            }
 
            out.matchId = vars.values[out.bindVarIdx].id();
            out.concrete = out.matchId != All.id();
            return out;
          }
 
          out.matchId = queryToken.id();
          out.concrete = true;
          return out;
        }
 
        GAIA_NODISCARD inline uint32_t count_pair_id_matches_limited(
            const World& w, const Archetype& archetype, Entity queryId, const VarBindings& varsIn, uint32_t limit) {
          GAIA_ASSERT(limit > 0);
          GAIA_ASSERT(queryId.pair());
 
          const auto queryRel = pair_rel(w, queryId);
          const auto queryTgt = pair_tgt(w, queryId);
          if (queryRel == EntityBad || queryTgt == EntityBad)
            return 0;
 
          const auto rel = resolve_raw_pair_match_token(queryRel, varsIn);
          const auto tgt = resolve_raw_pair_match_token(queryTgt, varsIn);
          const bool sameUnboundVar = rel.needsBind && tgt.needsBind && rel.bindVarIdx == tgt.bindVarIdx;
 
          // Candidate-local pair cardinalities let us answer the common concrete/wildcard
          // cases in O(1) without rescanning all pair ids on the archetype.
          if (!rel.needsBind && !tgt.needsBind && !sameUnboundVar) {
            const auto matchPair = Pair(
                rel.concrete ? Entity((EntityId)rel.matchId, 0, true, false, EntityKind::EK_Gen) : All,
                tgt.concrete ? Entity((EntityId)tgt.matchId, 0, true, false, EntityKind::EK_Gen) : All);
            const auto count = archetype.pair_matches(matchPair);
            return count < limit ? count : limit;
          }
 
          uint32_t count = 0;
          auto archetypeIds = archetype.ids_view();
          const auto cnt = (uint32_t)archetypeIds.size();
          GAIA_FOR(cnt) {
            const auto idInArchetype = archetypeIds[i];
            if (!idInArchetype.pair())
              continue;
            if (rel.concrete && idInArchetype.id() != rel.matchId)
              continue;
            if (tgt.concrete && idInArchetype.gen() != tgt.matchId)
              continue;
            if (sameUnboundVar && idInArchetype.id() != idInArchetype.gen())
              continue;
 
            ++count;
            if (count >= limit)
              break;
          }
 
          return count;
        }
 
        template <typename Func>
        GAIA_NODISCARD inline bool each_term_match(
            const World& w, const Archetype& candidateArchetype, const QueryCompileCtx::VarTermOp& termOp,
            const VarBindings& varsIn, Func&& func);
 
        GAIA_NODISCARD inline bool next_id_match_cursor(
            const World& w, const Archetype& archetype, Entity queryId, const VarBindings& varsIn, uint32_t& idIdx,
            VarBindings& outVars) {
          auto archetypeIds = archetype.ids_view();
          const auto cnt = (uint32_t)archetypeIds.size();
 
          if (!queryId.pair()) {
            for (uint32_t i = idIdx; i < cnt; ++i) {
              const auto idInArchetype = archetypeIds[i];
              if (idInArchetype.pair())
                continue;
 
              const auto value = id_entity(w, idInArchetype);
              if (value == EntityBad)
                continue;
 
              auto vars = varsIn;
              if (!match_token(vars, queryId, value, false))
                continue;
 
              outVars = vars;
              idIdx = i + 1;
              return true;
            }
 
            return false;
          }
 
          const auto queryRel = pair_rel(w, queryId);
          const auto queryTgt = pair_tgt(w, queryId);
          if (queryRel == EntityBad || queryTgt == EntityBad)
            return false;
          const auto rel = resolve_pair_query_token(queryRel, varsIn);
          const auto tgt = resolve_pair_query_token(queryTgt, varsIn);
 
          for (uint32_t i = idIdx; i < cnt; ++i) {
            const auto idInArchetype = archetypeIds[i];
            if (!idInArchetype.pair())
              continue;
 
            if (rel.concrete && idInArchetype.id() != rel.matchValue.id())
              continue;
            if (tgt.concrete && idInArchetype.gen() != tgt.matchValue.id())
              continue;
 
            auto vars = varsIn;
            if (rel.needsBind) {
              const auto relValue = pair_rel(w, idInArchetype);
              if (relValue == EntityBad)
                continue;
              if (!match_token(vars, rel.token, relValue, true))
                continue;
            }
            if (tgt.needsBind) {
              const auto tgtValue = pair_tgt(w, idInArchetype);
              if (tgtValue == EntityBad)
                continue;
              if (!match_token(vars, tgt.token, tgtValue, true))
                continue;
            }
 
            outVars = vars;
            idIdx = i + 1;
            return true;
          }
 
          return false;
        }
 
        GAIA_NODISCARD inline bool next_term_match_cursor(
            const World& w, const Archetype& archetype, const QueryCompileCtx::VarTermOp& termOp,
            const VarBindings& varsIn, VarTermMatchCursor& cursor, VarBindings& outVars) {
          const auto& term = termOp.term;
          if (term.src == EntityBad)
            return next_id_match_cursor(w, archetype, term.id, varsIn, cursor.idIdx, outVars);
 
          auto sourceEntity = term.src;
          if (is_var_entity(sourceEntity)) {
            if (!var_is_bound(varsIn, sourceEntity))
              return false;
            sourceEntity = varsIn.values[var_index(sourceEntity)];
          }
 
          for (;;) {
            if (cursor.source != EntityBad) {
              auto* pSrcArchetype = archetype_from_entity(w, cursor.source);
              if (pSrcArchetype != nullptr &&
                  next_id_match_cursor(w, *pSrcArchetype, term.id, varsIn, cursor.idIdx, outVars))
                return true;
 
              cursor.idIdx = 0;
              cursor.source = EntityBad;
            }
 
            Entity nextSource = EntityBad;
            if (!next_lookup_src_cursor(w, termOp.sourceOpcode, term, sourceEntity, cursor.sourceCursor, nextSource))
              return false;
 
            cursor.source = nextSource;
          }
        }
 
        GAIA_NODISCARD inline bool term_has_match_bound(
            const World& w, const Archetype& candidateArchetype, const QueryCompileCtx::VarTermOp& termOp,
            const VarBindings& vars);
 
        GAIA_NODISCARD inline bool term_has_match(
            const World& w, const Archetype& archetype, const QueryCompileCtx::VarTermOp& termOp,
            const VarBindings& varsIn) {
          if ((uint8_t)(termOp.varMask & ~varsIn.mask) == 0)
            return term_has_match_bound(w, archetype, termOp, varsIn);
 
          return each_term_match(w, archetype, termOp, varsIn, [&](const VarBindings&) {
            return true;
          });
        }
 
        GAIA_NODISCARD inline uint32_t count_term_matches_limited(
            const World& w, const Archetype& archetype, const QueryCompileCtx::VarTermOp& termOp,
            const VarBindings& varsIn, uint32_t limit) {
          GAIA_ASSERT(limit > 0);
 
          if ((uint8_t)(termOp.varMask & ~varsIn.mask) == 0)
            return term_has_match_bound(w, archetype, termOp, varsIn) ? 1u : 0u;
 
          if (termOp.term.src == EntityBad && termOp.term.id.pair())
            return count_pair_id_matches_limited(w, archetype, termOp.term.id, varsIn, limit);
 
          uint32_t count = 0;
          (void)each_term_match(w, archetype, termOp, varsIn, [&](const VarBindings&) {
            ++count;
            return count >= limit;
          });
          return count;
        }
 
        GAIA_NODISCARD inline bool has_concrete_match_id(Entity queryId) {
          if (!queryId.pair())
            return !is_variable(queryId) && queryId.id() != All.id();
 
          return !is_variable((EntityId)queryId.id()) && queryId.id() != All.id() &&
                 !is_variable((EntityId)queryId.gen()) && queryId.gen() != All.id();
        }
 
        GAIA_NODISCARD inline bool
        match_id_bound(const World& w, const Archetype& archetype, Entity queryId, const VarBindings& vars) {
          auto archetypeIds = archetype.ids_view();
          const auto cnt = (uint32_t)archetypeIds.size();
 
          if (!queryId.pair()) {
            Entity queryToken = queryId;
            if (is_var_entity(queryToken)) {
              if (!var_is_bound(vars, queryToken))
                return false;
              queryToken = vars.values[var_index(queryToken)];
            }
 
            GAIA_FOR(cnt) {
              const auto idInArchetype = archetypeIds[i];
              if (idInArchetype.pair())
                continue;
 
              const auto value = id_entity(w, idInArchetype);
              if (value == EntityBad)
                continue;
              if (queryToken.id() != value.id())
                continue;
 
              return true;
            }
 
            return false;
          }
 
          auto queryRel = pair_rel(w, queryId);
          auto queryTgt = pair_tgt(w, queryId);
          if (queryRel == EntityBad || queryTgt == EntityBad)
            return false;
 
          if (is_var_entity(queryRel)) {
            if (!var_is_bound(vars, queryRel))
              return false;
            queryRel = vars.values[var_index(queryRel)];
          }
 
          if (is_var_entity(queryTgt)) {
            if (!var_is_bound(vars, queryTgt))
              return false;
            queryTgt = vars.values[var_index(queryTgt)];
          }
 
          const bool relIsConcrete = queryRel.id() != All.id();
          const bool tgtIsConcrete = queryTgt.id() != All.id();
 
          if (relIsConcrete || tgtIsConcrete) {
            const auto count =
                archetype.pair_matches(Pair(relIsConcrete ? queryRel : All, tgtIsConcrete ? queryTgt : All));
            if (count != 0)
              return true;
 
            if (relIsConcrete && tgtIsConcrete)
              return false;
          }
 
          GAIA_FOR(cnt) {
            const auto idInArchetype = archetypeIds[i];
            if (!idInArchetype.pair())
              continue;
 
            if (relIsConcrete && idInArchetype.id() != queryRel.id())
              continue;
            if (tgtIsConcrete && idInArchetype.gen() != queryTgt.id())
              continue;
 
            if (!relIsConcrete) {
              const auto rel = pair_rel(w, idInArchetype);
              if (rel == EntityBad)
                continue;
            }
            if (!tgtIsConcrete) {
              const auto tgt = pair_tgt(w, idInArchetype);
              if (tgt == EntityBad)
                continue;
            }
 
            return true;
          }
 
          return false;
        }
 
        GAIA_NODISCARD inline bool next_self_src_var_match_cursor(
            const MatchingCtx& ctx, const QueryCompileCtx::VarTermOp& termOp, const VarBindings& varsIn,
            VarTermMatchCursor& cursor, VarBindings& outVars) {
          GAIA_ASSERT(ctx.pWorld != nullptr);
          GAIA_ASSERT(is_var_entity(termOp.term.src));
          GAIA_ASSERT(!var_is_bound(varsIn, termOp.term.src));
          GAIA_ASSERT(termOp.sourceOpcode == EOpcode::Src_Self);
 
          const auto adv_matches = [&](std::span<const ComponentIndexEntry> sourceRecords, bool idsPreFiltered) {
            for (; cursor.sourceArchetypeIdx < sourceRecords.size(); ++cursor.sourceArchetypeIdx) {
              const auto* pSrcArchetype = sourceRecords[cursor.sourceArchetypeIdx].pArchetype;
              if (pSrcArchetype == nullptr)
                continue;
              if (!idsPreFiltered && !match_single_id_on_archetype(*ctx.pWorld, *pSrcArchetype, termOp.term.id))
                continue;
 
              const auto& chunks = pSrcArchetype->chunks();
              for (; cursor.sourceChunkIdx < chunks.size(); ++cursor.sourceChunkIdx) {
                const auto* pChunk = chunks[cursor.sourceChunkIdx];
                if (pChunk == nullptr || pChunk->empty())
                  continue;
 
                const auto entities = pChunk->entity_view();
                for (; cursor.sourceEntityIdx < entities.size(); ++cursor.sourceEntityIdx) {
                  const auto entity = entities[cursor.sourceEntityIdx];
                  auto vars = varsIn;
                  if (!bind_var(vars, termOp.term.src, entity))
                    continue;
 
                  outVars = vars;
                  ++cursor.sourceEntityIdx;
                  return true;
                }
 
                cursor.sourceEntityIdx = 0;
              }
 
              cursor.sourceChunkIdx = 0;
            }
 
            return false;
          };
 
          const auto adv_matches_all = [&](std::span<const Archetype*> sourceArchetypes) {
            for (; cursor.sourceArchetypeIdx < sourceArchetypes.size(); ++cursor.sourceArchetypeIdx) {
              const auto* pSrcArchetype = sourceArchetypes[cursor.sourceArchetypeIdx];
              if (pSrcArchetype == nullptr)
                continue;
              if (!match_single_id_on_archetype(*ctx.pWorld, *pSrcArchetype, termOp.term.id))
                continue;
 
              const auto& chunks = pSrcArchetype->chunks();
              for (; cursor.sourceChunkIdx < chunks.size(); ++cursor.sourceChunkIdx) {
                const auto* pChunk = chunks[cursor.sourceChunkIdx];
                if (pChunk == nullptr || pChunk->empty())
                  continue;
 
                const auto entities = pChunk->entity_view();
                for (; cursor.sourceEntityIdx < entities.size(); ++cursor.sourceEntityIdx) {
                  const auto entity = entities[cursor.sourceEntityIdx];
                  auto vars = varsIn;
                  if (!bind_var(vars, termOp.term.src, entity))
                    continue;
 
                  outVars = vars;
                  ++cursor.sourceEntityIdx;
                  return true;
                }
 
                cursor.sourceEntityIdx = 0;
              }
 
              cursor.sourceChunkIdx = 0;
            }
 
            return false;
          };
 
          if (!ctx.archetypeLookup.empty()) {
            const auto sourceArchetypes =
                ctx.archetypeLookup.fetch(ctx.allArchetypes, termOp.term.id, EntityLookupKey(termOp.term.id));
            if (adv_matches(sourceArchetypes, true))
              return true;
          } else if (adv_matches_all(ctx.allArchetypes))
            return true;
 
          return false;
        }
 
        GAIA_NODISCARD inline bool next_src_var_match_cursor_inverse(
            const MatchingCtx& ctx, const QueryCompileCtx::VarTermOp& termOp, const VarBindings& varsIn,
            VarTermMatchCursor& cursor, VarBindings& outVars, EOpcode inverseOpcode) {
          GAIA_ASSERT(ctx.pWorld != nullptr);
          GAIA_ASSERT(is_var_entity(termOp.term.src));
          GAIA_ASSERT(!var_is_bound(varsIn, termOp.term.src));
          GAIA_ASSERT(
              inverseOpcode == EOpcode::Src_Up || inverseOpcode == EOpcode::Src_Down ||
              inverseOpcode == EOpcode::Src_UpDown);
 
          const auto adv_matches = [&](std::span<const ComponentIndexEntry> sourceRecords, bool idsPreFiltered) {
            for (; cursor.sourceArchetypeIdx < sourceRecords.size(); ++cursor.sourceArchetypeIdx) {
              const auto* pSrcArchetype = sourceRecords[cursor.sourceArchetypeIdx].pArchetype;
              if (pSrcArchetype == nullptr)
                continue;
              if (!idsPreFiltered && !match_single_id_on_archetype(*ctx.pWorld, *pSrcArchetype, termOp.term.id))
                continue;
 
              const auto& chunks = pSrcArchetype->chunks();
              for (; cursor.sourceChunkIdx < chunks.size(); ++cursor.sourceChunkIdx) {
                const auto* pChunk = chunks[cursor.sourceChunkIdx];
                if (pChunk == nullptr || pChunk->empty())
                  continue;
 
                const auto entities = pChunk->entity_view();
                while (cursor.sourceEntityIdx < entities.size()) {
                  if (cursor.source == EntityBad) {
                    cursor.source = entities[cursor.sourceEntityIdx];
                    cursor.sourceCursor = {};
                  }
 
                  Entity candidate = EntityBad;
                  if (next_lookup_src_cursor(
                          *ctx.pWorld, inverseOpcode, termOp.term, cursor.source, cursor.sourceCursor, candidate)) {
                    auto vars = varsIn;
                    if (!bind_var(vars, termOp.term.src, candidate))
                      continue;
 
                    outVars = vars;
                    return true;
                  }
 
                  cursor.source = EntityBad;
                  ++cursor.sourceEntityIdx;
                }
 
                cursor.sourceEntityIdx = 0;
              }
 
              cursor.sourceChunkIdx = 0;
            }
 
            return false;
          };
 
          const auto adv_matches_all = [&](std::span<const Archetype*> sourceArchetypes) {
            for (; cursor.sourceArchetypeIdx < sourceArchetypes.size(); ++cursor.sourceArchetypeIdx) {
              const auto* pSrcArchetype = sourceArchetypes[cursor.sourceArchetypeIdx];
              if (pSrcArchetype == nullptr)
                continue;
              if (!match_single_id_on_archetype(*ctx.pWorld, *pSrcArchetype, termOp.term.id))
                continue;
 
              const auto& chunks = pSrcArchetype->chunks();
              for (; cursor.sourceChunkIdx < chunks.size(); ++cursor.sourceChunkIdx) {
                const auto* pChunk = chunks[cursor.sourceChunkIdx];
                if (pChunk == nullptr || pChunk->empty())
                  continue;
 
                const auto entities = pChunk->entity_view();
                while (cursor.sourceEntityIdx < entities.size()) {
                  if (cursor.source == EntityBad) {
                    cursor.source = entities[cursor.sourceEntityIdx];
                    cursor.sourceCursor = {};
                  }
 
                  Entity candidate = EntityBad;
                  if (next_lookup_src_cursor(
                          *ctx.pWorld, inverseOpcode, termOp.term, cursor.source, cursor.sourceCursor, candidate)) {
                    auto vars = varsIn;
                    if (!bind_var(vars, termOp.term.src, candidate))
                      continue;
 
                    outVars = vars;
                    return true;
                  }
 
                  cursor.source = EntityBad;
                  ++cursor.sourceEntityIdx;
                }
 
                cursor.sourceEntityIdx = 0;
              }
 
              cursor.sourceChunkIdx = 0;
            }
 
            return false;
          };
 
          if (!ctx.archetypeLookup.empty()) {
            const auto sourceArchetypes =
                ctx.archetypeLookup.fetch(ctx.allArchetypes, termOp.term.id, EntityLookupKey(termOp.term.id));
            if (adv_matches(sourceArchetypes, true))
              return true;
          } else if (adv_matches_all(ctx.allArchetypes))
            return true;
 
          return false;
        }
 
        GAIA_NODISCARD inline bool next_up_src_var_match_cursor(
            const MatchingCtx& ctx, const QueryCompileCtx::VarTermOp& termOp, const VarBindings& varsIn,
            VarTermMatchCursor& cursor, VarBindings& outVars) {
          GAIA_ASSERT(ctx.pWorld != nullptr);
          GAIA_ASSERT(is_var_entity(termOp.term.src));
          GAIA_ASSERT(!var_is_bound(varsIn, termOp.term.src));
          GAIA_ASSERT(termOp.sourceOpcode == EOpcode::Src_Up);
          return next_src_var_match_cursor_inverse(ctx, termOp, varsIn, cursor, outVars, EOpcode::Src_Down);
        }
 
        GAIA_NODISCARD inline bool next_down_src_var_match_cursor(
            const MatchingCtx& ctx, const QueryCompileCtx::VarTermOp& termOp, const VarBindings& varsIn,
            VarTermMatchCursor& cursor, VarBindings& outVars) {
          GAIA_ASSERT(termOp.sourceOpcode == EOpcode::Src_Down);
          return next_src_var_match_cursor_inverse(ctx, termOp, varsIn, cursor, outVars, EOpcode::Src_Up);
        }
 
        GAIA_NODISCARD inline bool next_updown_src_var_match_cursor(
            const MatchingCtx& ctx, const QueryCompileCtx::VarTermOp& termOp, const VarBindings& varsIn,
            VarTermMatchCursor& cursor, VarBindings& outVars) {
          GAIA_ASSERT(termOp.sourceOpcode == EOpcode::Src_UpDown);
          return next_src_var_match_cursor_inverse(ctx, termOp, varsIn, cursor, outVars, EOpcode::Src_UpDown);
        }
 
        GAIA_NODISCARD inline bool next_term_match_cursor(
            const MatchingCtx& ctx, const Archetype& archetype, const QueryCompileCtx::VarTermOp& termOp,
            const VarBindings& varsIn, VarTermMatchCursor& cursor, VarBindings& outVars) {
          const auto& term = termOp.term;
          const bool hasUnboundVar =
              term.src != EntityBad && is_var_entity(term.src) && !var_is_bound(varsIn, term.src);
          if (hasUnboundVar && termOp.sourceOpcode == EOpcode::Src_Self) {
            return next_self_src_var_match_cursor(ctx, termOp, varsIn, cursor, outVars);
          }
          if (hasUnboundVar && termOp.sourceOpcode == EOpcode::Src_Up) {
            return next_up_src_var_match_cursor(ctx, termOp, varsIn, cursor, outVars);
          }
          if (hasUnboundVar && termOp.sourceOpcode == EOpcode::Src_Down) {
            return next_down_src_var_match_cursor(ctx, termOp, varsIn, cursor, outVars);
          }
          if (hasUnboundVar && termOp.sourceOpcode == EOpcode::Src_UpDown) {
            return next_updown_src_var_match_cursor(ctx, termOp, varsIn, cursor, outVars);
          }
 
          return next_term_match_cursor(*ctx.pWorld, archetype, termOp, varsIn, cursor, outVars);
        }
 
        GAIA_NODISCARD inline bool term_has_match_bound(
            const World& w, const Archetype& candidateArchetype, const QueryCompileCtx::VarTermOp& termOp,
            const VarBindings& vars) {
          const auto& term = termOp.term;
          auto match_on_archetype = [&](const Archetype& archetype) {
            return match_id_bound(w, archetype, term.id, vars);
          };
 
          if (term.src == EntityBad)
            return match_on_archetype(candidateArchetype);
 
          auto sourceEntity = term.src;
          if (is_var_entity(sourceEntity)) {
            if (!var_is_bound(vars, sourceEntity))
              return false;
            sourceEntity = vars.values[var_index(sourceEntity)];
          }
 
          return each_lookup_src(w, termOp.sourceOpcode, term, sourceEntity, [&](Entity source) {
            auto* pSrcArchetype = archetype_from_entity(w, source);
            if (pSrcArchetype == nullptr)
              return false;
            if (!match_on_archetype(*pSrcArchetype))
              return false;
 
            return true;
          });
        }
 
        template <typename Func>
        GAIA_NODISCARD inline bool each_id_match(
            const World& w, const Archetype& archetype, Entity queryId, const VarBindings& varsIn, Func&& func) {
          auto archetypeIds = archetype.ids_view();
          const auto cnt = (uint32_t)archetypeIds.size();
 
          if (!queryId.pair()) {
            GAIA_FOR(cnt) {
              const auto idInArchetype = archetypeIds[i];
              if (idInArchetype.pair())
                continue;
 
              const auto value = id_entity(w, idInArchetype);
              if (value == EntityBad)
                continue;
 
              auto vars = varsIn;
              if (!match_token(vars, queryId, value, false))
                continue;
 
              if (func(vars))
                return true;
            }
            return false;
          }
 
          const auto queryRel = pair_rel(w, queryId);
          const auto queryTgt = pair_tgt(w, queryId);
          if (queryRel == EntityBad || queryTgt == EntityBad)
            return false;
          const auto rel = resolve_pair_query_token(queryRel, varsIn);
          const auto tgt = resolve_pair_query_token(queryTgt, varsIn);
 
          GAIA_FOR(cnt) {
            const auto idInArchetype = archetypeIds[i];
            if (!idInArchetype.pair())
              continue;
 
            if (rel.concrete && idInArchetype.id() != rel.matchValue.id())
              continue;
            if (tgt.concrete && idInArchetype.gen() != tgt.matchValue.id())
              continue;
 
            if (!rel.needsBind && !tgt.needsBind) {
              if (func(varsIn))
                return true;
              continue;
            }
 
            auto vars = varsIn;
            if (rel.needsBind) {
              const auto relValue = pair_rel(w, idInArchetype);
              if (relValue == EntityBad)
                continue;
              if (!match_token(vars, rel.token, relValue, true))
                continue;
            }
            if (tgt.needsBind) {
              const auto tgtValue = pair_tgt(w, idInArchetype);
              if (tgtValue == EntityBad)
                continue;
              if (!match_token(vars, tgt.token, tgtValue, true))
                continue;
            }
 
            if (func(vars))
              return true;
          }
 
          return false;
        }
 
        template <typename Func>
        GAIA_NODISCARD inline bool each_term_match(
            const World& w, const Archetype& candidateArchetype, const QueryCompileCtx::VarTermOp& termOp,
            const VarBindings& varsIn, Func&& func) {
          const auto& term = termOp.term;
          auto&& matchFunc = GAIA_FWD(func);
          auto each_on_src = [&](Entity sourceEntity, const VarBindings& vars) {
            return each_lookup_src(w, termOp.sourceOpcode, term, sourceEntity, [&](Entity source) {
              auto* pSrcArchetype = archetype_from_entity(w, source);
              if (pSrcArchetype == nullptr)
                return false;
 
              return each_id_match(w, *pSrcArchetype, term.id, vars, matchFunc);
            });
          };
 
          if (term.src == EntityBad)
            return each_id_match(w, candidateArchetype, term.id, varsIn, matchFunc);
 
          if (is_var_entity(term.src)) {
            if (!var_is_bound(varsIn, term.src))
              return false;
 
            const auto source = varsIn.values[var_index(term.src)];
            return each_on_src(source, varsIn);
          }
 
          return each_on_src(term.src, varsIn);
        }
 
        template <typename OpKind, MatchingStyle Style>
        inline void match_archetype_inter(MatchingCtx& ctx, std::span<const ComponentIndexEntry> records) {
          if constexpr (Style != MatchingStyle::Complex) {
            if (ctx.idsToMatch.size() == 1) {
              for (const auto& entry: records) {
                const auto* pArchetype = entry.pArchetype;
                if (is_archetype_marked(ctx, pArchetype))
                  continue;
#if GAIA_USE_PARTITIONED_BLOOM_FILTER >= 0
                if constexpr (Style == MatchingStyle::Simple) {
                  if (!OpKind::check_mask(pArchetype->queryMask(), ctx.queryMask))
                    continue;
                }
#endif
                mark_archetype_match(ctx, pArchetype);
              }
              return;
            }
          }
 
          if constexpr (Style == MatchingStyle::Complex) {
            for (const auto& record: records) {
              const auto* pArchetype = record.pArchetype;
              if (is_archetype_marked(ctx, pArchetype))
                continue;
 
              if (!match_res_as<OpKind>(*ctx.pWorld, *pArchetype, ctx.idsToMatch))
                continue;
 
              mark_archetype_match(ctx, pArchetype);
            }
          }
#if GAIA_USE_PARTITIONED_BLOOM_FILTER >= 0
          else if constexpr (Style == MatchingStyle::Simple) {
            for (const auto& record: records) {
              const auto* pArchetype = record.pArchetype;
              if (is_archetype_marked(ctx, pArchetype))
                continue;
 
              // Try early exit
              if (!OpKind::check_mask(pArchetype->queryMask(), ctx.queryMask))
                continue;
 
              if (!match_res<OpKind>(*pArchetype, ctx.idsToMatch))
                continue;
 
              mark_archetype_match(ctx, pArchetype);
            }
          }
#endif
          else {
            for (const auto& record: records) {
              const auto* pArchetype = record.pArchetype;
              if (is_archetype_marked(ctx, pArchetype))
                continue;
 
              if (!match_res<OpKind>(*pArchetype, ctx.idsToMatch))
                continue;
 
              mark_archetype_match(ctx, pArchetype);
            }
          }
        }
 
        template <typename OpKind, MatchingStyle Style>
        inline void match_archetype_inter(MatchingCtx& ctx, std::span<const Archetype*> archetypes) {
          if constexpr (Style == MatchingStyle::Complex) {
            for (const auto* pArchetype: archetypes) {
              if (is_archetype_marked(ctx, pArchetype))
                continue;
 
              if (!match_res_as<OpKind>(*ctx.pWorld, *pArchetype, ctx.idsToMatch))
                continue;
 
              mark_archetype_match(ctx, pArchetype);
            }
          }
#if GAIA_USE_PARTITIONED_BLOOM_FILTER >= 0
          else if constexpr (Style == MatchingStyle::Simple) {
            for (const auto* pArchetype: archetypes) {
              if (is_archetype_marked(ctx, pArchetype))
                continue;
 
              if (!OpKind::check_mask(pArchetype->queryMask(), ctx.queryMask))
                continue;
 
              if (!match_res<OpKind>(*pArchetype, ctx.idsToMatch))
                continue;
 
              mark_archetype_match(ctx, pArchetype);
            }
          }
#endif
          else {
            for (const auto* pArchetype: archetypes) {
              if (is_archetype_marked(ctx, pArchetype))
                continue;
 
              if (!match_res<OpKind>(*pArchetype, ctx.idsToMatch))
                continue;
 
              mark_archetype_match(ctx, pArchetype);
            }
          }
        }
 
        template <typename OpKind, MatchingStyle Style>
        inline void match_archetype_inter(
            MatchingCtx& ctx, EntityLookupKey entityKey, std::span<const ComponentIndexEntry> records) {
          const uint32_t lookupRevision = ctx.archetypeLookup.revision(entityKey);
          uint32_t lastMatchedIdx = OpKind::handle_last_match(ctx, entityKey, (uint32_t)records.size(), lookupRevision);
          if (lastMatchedIdx >= records.size())
            return;
 
          auto recordsNew = std::span(&records[lastMatchedIdx], records.size() - lastMatchedIdx);
          match_archetype_inter<OpKind, Style>(ctx, recordsNew);
        }
 
        template <typename OpKind, MatchingStyle Style>
        inline void
        match_archetype_inter(MatchingCtx& ctx, EntityLookupKey entityKey, std::span<const Archetype*> archetypes) {
          const uint32_t lookupRevision = ctx.archetypeLookup.revision(entityKey);
          uint32_t lastMatchedIdx =
              OpKind::handle_last_match(ctx, entityKey, (uint32_t)archetypes.size(), lookupRevision);
          if (lastMatchedIdx >= archetypes.size())
            return;
 
          auto archetypesNew = std::span(&archetypes[lastMatchedIdx], archetypes.size() - lastMatchedIdx);
          match_archetype_inter<OpKind, Style>(ctx, archetypesNew);
        }
 
        template <MatchingStyle Style>
        inline void match_archetype_all(MatchingCtx& ctx) {
          if constexpr (Style == MatchingStyle::Complex) {
            // For ALL we need all the archetypes to match. We start by checking
            // if the first one is registered in the world at all.
            if (ctx.ent.id() == Is.id()) {
              ctx.ent = EntityBad;
              match_archetype_inter<OpAll, Style>(ctx, EntityBadLookupKey, ctx.allArchetypes);
            } else {
              auto entityKey = EntityLookupKey(ctx.ent);
 
              auto archetypes = ctx.archetypeLookup.fetch(ctx.allArchetypes, ctx.ent, entityKey);
              if (archetypes.empty())
                return;
 
              match_archetype_inter<OpAll, Style>(ctx, entityKey, archetypes);
            }
          } else {
            auto entityKey = EntityLookupKey(ctx.ent);
 
            // For ALL we need all the archetypes to match. We start by checking
            // if the first one is registered in the world at all.
            auto archetypes = ctx.archetypeLookup.fetch(ctx.allArchetypes, ctx.ent, entityKey);
            if (archetypes.empty())
              return;
 
            match_archetype_inter<OpAll, Style>(ctx, entityKey, archetypes);
          }
        }
 
        template <MatchingStyle Style>
        inline void match_archetype_or(MatchingCtx& ctx) {
          EntityLookupKey entityKey(ctx.ent);
 
          // For OR we need at least one archetype to match.
          // However, because any of them can match, we need to check them all.
          // Iterating all of them is caller's responsibility.
          auto archetypes = ctx.archetypeLookup.fetch(ctx.allArchetypes, ctx.ent, entityKey);
          if (archetypes.empty())
            return;
 
          match_archetype_inter<OpOr, Style>(ctx, entityKey, archetypes);
        }
 
        inline void match_archetype_or_as(MatchingCtx& ctx) {
          EntityLookupKey entityKey = EntityBadLookupKey;
 
          // For OR we need at least one archetype to match.
          // However, because any of them can match, we need to check them all.
          // Iterating all of them is caller's responsibility.
          if (ctx.ent.id() == Is.id()) {
            ctx.ent = EntityBad;
            match_archetype_inter<OpOr, MatchingStyle::Complex>(ctx, entityKey, ctx.allArchetypes);
          } else {
            entityKey = EntityLookupKey(ctx.ent);
 
            auto archetypes = ctx.archetypeLookup.fetch(ctx.allArchetypes, ctx.ent, entityKey);
            if (archetypes.empty())
              return;
 
            match_archetype_inter<OpOr, MatchingStyle::Complex>(ctx, entityKey, archetypes);
          }
        }
 
        template <MatchingStyle Style>
        inline void match_archetype_no_2(MatchingCtx& ctx) {
          // We had some matches already (with ALL or OR). We need to remove those
          // that match with the NO list.
 
          if constexpr (Style == MatchingStyle::Complex) {
            for (uint32_t i = 0; i < ctx.pMatchesArr->size();) {
              const auto* pArchetype = (*ctx.pMatchesArr)[i];
 
              if (match_res_as<OpNo>(*ctx.pWorld, *pArchetype, ctx.idsToMatch)) {
                ++i;
                continue;
              }
 
              core::swap_erase(*ctx.pMatchesArr, i);
            }
          }
#if GAIA_USE_PARTITIONED_BLOOM_FILTER >= 0
          else if constexpr (Style == MatchingStyle::Simple) {
            for (uint32_t i = 0; i < ctx.pMatchesArr->size();) {
              const auto* pArchetype = (*ctx.pMatchesArr)[i];
 
              // Try early exit
              if (OpNo::check_mask(pArchetype->queryMask(), ctx.queryMask))
                continue;
 
              if (match_res<OpNo>(*pArchetype, ctx.idsToMatch)) {
                ++i;
                continue;
              }
 
              core::swap_erase(*ctx.pMatchesArr, i);
            }
          }
#endif
          else {
            for (uint32_t i = 0; i < ctx.pMatchesArr->size();) {
              const auto* pArchetype = (*ctx.pMatchesArr)[i];
 
              if (match_res<OpNo>(*pArchetype, ctx.idsToMatch)) {
                ++i;
                continue;
              }
 
              core::swap_erase(*ctx.pMatchesArr, i);
            }
          }
        }
 
        template <typename OpKind, MatchingStyle Style, bool WildcardWithAsFallback = false>
        inline void filter_current_matches(MatchingCtx& ctx, EntitySpan idsToMatch) {
          if constexpr (Style == MatchingStyle::Complex) {
            for (uint32_t i = 0; i < ctx.pMatchesArr->size();) {
              const auto* pArchetype = (*ctx.pMatchesArr)[i];
              if (match_res_as<OpKind>(*ctx.pWorld, *pArchetype, idsToMatch)) {
                ++i;
                continue;
              }
 
              core::swap_erase(*ctx.pMatchesArr, i);
            }
          }
#if GAIA_USE_PARTITIONED_BLOOM_FILTER >= 0
          else if constexpr (Style == MatchingStyle::Simple) {
            for (uint32_t i = 0; i < ctx.pMatchesArr->size();) {
              const auto* pArchetype = (*ctx.pMatchesArr)[i];
              if (OpKind::check_mask(pArchetype->queryMask(), ctx.queryMask) &&
                  match_res<OpKind>(*pArchetype, idsToMatch)) {
                ++i;
                continue;
              }
 
              core::swap_erase(*ctx.pMatchesArr, i);
            }
          }
#endif
          else {
            for (uint32_t i = 0; i < ctx.pMatchesArr->size();) {
              const auto* pArchetype = (*ctx.pMatchesArr)[i];
              if (match_res<OpKind>(*pArchetype, idsToMatch) ||
                  (WildcardWithAsFallback && match_res_as<OpKind>(*ctx.pWorld, *pArchetype, idsToMatch))) {
                ++i;
                continue;
              }
 
              core::swap_erase(*ctx.pMatchesArr, i);
            }
          }
        }
 
        template <MatchingStyle Style>
        GAIA_NODISCARD inline bool exec_not_impl(const QueryCompileCtx& comp, MatchingCtx& ctx) {
          ctx.idsToMatch = std::span{comp.ids_not.data(), comp.ids_not.size()};
 
          if (ctx.targetEntities.empty()) {
            // We searched for nothing more than NOT matches
            if (ctx.pMatchesArr->empty()) {
              // If there are no previous matches (no ALL or OR matches),
              // we need to search among all archetypes.
              match_archetype_inter<detail::OpNo, Style>(ctx, EntityBadLookupKey, ctx.allArchetypes);
            } else {
              match_archetype_no_2<Style>(ctx);
            }
          } else {
            // We searched for nothing more than NOT matches
            if (ctx.pMatchesArr->empty())
              match_archetype_inter<detail::OpNo, Style>(ctx, ctx.allArchetypes);
            else
              match_archetype_no_2<Style>(ctx);
          }
 
          return true;
        }
 
        template <MatchingStyle Style>
        GAIA_NODISCARD inline bool exec_all_impl(const QueryCompileCtx& comp, MatchingCtx& ctx) {
          ctx.ent = comp.ids_all[0];
          ctx.idsToMatch = std::span{comp.ids_all.data(), comp.ids_all.size()};
 
          if (ctx.targetEntities.empty())
            match_archetype_all<Style>(ctx);
          else
            match_archetype_inter<OpAll, Style>(ctx, ctx.allArchetypes);
 
          // If no ALL matches were found, we can quit right away.
          return !ctx.pMatchesArr->empty();
        }
 
        template <MatchingStyle Style>
        GAIA_NODISCARD inline bool exec_or_noall_impl(const QueryCompileCtx& comp, MatchingCtx& ctx) {
          if (ctx.skipOr)
            return true;
 
          const auto cnt = comp.ids_or.size();
          // Try find matches with OR components.
          GAIA_FOR(cnt) {
            ctx.ent = comp.ids_or[i];
            const Entity idsToMatchData[1] = {ctx.ent};
            ctx.idsToMatch = EntitySpan{idsToMatchData, 1};
 
            if constexpr (Style == MatchingStyle::Complex)
              match_archetype_or_as(ctx);
            else
              match_archetype_or<Style>(ctx);
          }
 
          return true;
        }
 
        template <MatchingStyle Style>
        GAIA_NODISCARD inline bool exec_or_withall_impl(const QueryCompileCtx& comp, MatchingCtx& ctx) {
          if (ctx.skipOr)
            return true;
 
          ctx.idsToMatch = std::span{comp.ids_or.data(), comp.ids_or.size()};
 
          if constexpr (Style == MatchingStyle::Complex)
            filter_current_matches<OpOr, MatchingStyle::Complex>(ctx, ctx.idsToMatch);
          else if constexpr (Style == MatchingStyle::Simple)
            filter_current_matches<OpOr, MatchingStyle::Simple>(ctx, ctx.idsToMatch);
          else
            filter_current_matches<OpOr, MatchingStyle::Wildcard, true>(ctx, ctx.idsToMatch);
 
          return true;
        }
 
        template <typename SourceTermsArray>
        GAIA_NODISCARD inline const QueryCompileCtx::SourceTermOp&
        get_src_term_op(const QueryCompileCtx& comp, const MatchingCtx& ctx, const SourceTermsArray& terms) {
          const auto& stackItem = comp.ops[ctx.pc];
          GAIA_ASSERT(stackItem.arg < terms.size());
          return terms[stackItem.arg];
        }
      } // namespace detail
 
      class VirtualMachine {
        static constexpr uint32_t OpcodeArgLimit = 256u;
        static_assert(
            MAX_ITEMS_IN_QUERY <= OpcodeArgLimit,
            "CompiledOp::arg is uint8_t. Increase arg width if query term capacity grows above 256.");
 
        detail::QueryCompileCtx m_compCtx;
 
      private:
        static const char* opcode_name(detail::EOpcode opcode) {
          static const char* s_names[] = {
              "all", //
              "allw", //
              "allc", //
              "or", //
              "orw", //
              "orc", //
              "ora", //
              "oraw", //
              "orac", //
              "not", //
              "notw", //
              "notc", //
              "seed", //
              "varf", //
              "src_all_t", //
              "src_not_t", //
              "src_or_t", //
              "nev", //
              "self", //
              "up", //
              "down", //
              "updown", //
              "term_all_check", //
              "term_all_bind", //
              "term_all_src_bind", //
              "term_or_check", //
              "term_or_bind", //
              "term_any_check", //
              "term_any_bind", //
              "term_not", //
              "search_all", //
              "search_or", //
              "search_other_or", //
              "search_other_or_bind", //
              "search_begin_any", //
              "search_any", //
              "search_maybe_finalize", //
              "final_not_check", //
              "final_require_or", //
              "final_or_check", //
              "final_success", //
          };
          static_assert(
              sizeof(s_names) / sizeof(s_names[0]) == (uint32_t)detail::EOpcode::Var_Final_Success + 1u,
              "Opcode name table out of sync with EOpcode.");
          return s_names[(uint32_t)opcode];
        }
 
        GAIA_NODISCARD static bool opcode_has_arg(detail::EOpcode opcode) {
          return opcode == detail::EOpcode::Src_AllTerm || //
                 opcode == detail::EOpcode::Src_NotTerm || //
                 opcode == detail::EOpcode::Src_OrTerm;
        }
 
        static void add_uint(util::str& out, uint32_t value) {
          char buffer[32];
          const auto len = GAIA_STRFMT(buffer, sizeof(buffer), "%u", value);
          GAIA_ASSERT(len >= 0);
          out.append(buffer, (uint32_t)len);
        }
 
        static void add_cstr(util::str& out, const char* value) {
          GAIA_ASSERT(value != nullptr);
          out.append(value, (uint32_t)GAIA_STRLEN(value, 64));
        }
 
        static void add_id_expr(util::str& out, const World& world, EntityId id) {
          if (is_variable(id)) {
            out.append('$');
            add_uint(out, (uint32_t)(id - Var0.id()));
            return;
          }
 
          if (id == All.id()) {
            out.append('*');
            return;
          }
 
          const auto entity = entity_from_id(world, id);
          if (entity != EntityBad)
            add_entity_expr(out, world, entity);
          else {
            out.append('#');
            add_uint(out, (uint32_t)id);
          }
        }
 
        static void add_entity_expr(util::str& out, const World& world, Entity entity) {
          if (entity == EntityBad) {
            out.append("EntityBad");
            return;
          }
 
          if (entity.pair()) {
            out.append('(');
            add_id_expr(out, world, (EntityId)entity.id());
            out.append(',');
            add_id_expr(out, world, (EntityId)entity.gen());
            out.append(')');
            return;
          }
 
          if (is_variable(EntityId(entity.id()))) {
            out.append('$');
            add_uint(out, (uint32_t)(entity.id() - Var0.id()));
            return;
          }
 
          if (entity.id() == All.id()) {
            out.append('*');
            return;
          }
 
          const auto name = entity_name(world, entity);
          if (!name.empty()) {
            out.append(name.data(), name.size());
            return;
          }
 
          add_uint(out, entity.id());
          out.append('.');
          add_uint(out, entity.gen());
        }
 
        static void add_term_expr(util::str& out, const World& world, const QueryTerm& term) {
          add_entity_expr(out, world, term.id);
          out.append('(');
          if (term.src == EntityBad)
            out.append("$this");
          else
            add_entity_expr(out, world, term.src);
          out.append(')');
 
          if (term.entTrav != EntityBad) {
            out.append(" trav=");
            add_entity_expr(out, world, term.entTrav);
            out.append(" depth=");
            if (term.travDepth == QueryTermOptions::TravDepthUnlimited)
              out.append('*');
            else
              add_uint(out, (uint32_t)term.travDepth);
          }
        }
 
        static void
        add_ids_section(util::str& out, const char* title, std::span<const Entity> ids, const World& world) {
          if (ids.empty())
            return;
 
          add_cstr(out, title);
          out.append(": ");
          add_uint(out, (uint32_t)ids.size());
          out.append('\n');
 
          const auto cnt = (uint32_t)ids.size();
          GAIA_FOR(cnt) {
            out.append("  [");
            add_uint(out, i);
            out.append("] ");
            add_entity_expr(out, world, ids[i]);
            out.append('\n');
          }
        }
 
        static void add_src_terms_section(
            util::str& out, const char* title,
            const cnt::sarray_ext<detail::QueryCompileCtx::SourceTermOp, MAX_ITEMS_IN_QUERY>& terms,
            const World& world) {
          if (terms.empty())
            return;
 
          add_cstr(out, title);
          out.append(": ");
          add_uint(out, (uint32_t)terms.size());
          out.append('\n');
 
          const auto cnt = (uint32_t)terms.size();
          GAIA_FOR(cnt) {
            out.append("  [");
            add_uint(out, i);
            out.append("] ");
            add_cstr(out, opcode_name(terms[i].opcode));
            out.append(" id=");
            add_term_expr(out, world, terms[i].term);
            out.append('\n');
          }
        }
 
        static void add_var_terms_section(
            util::str& out, const char* title,
            const cnt::sarray_ext<detail::QueryCompileCtx::VarTermOp, MAX_ITEMS_IN_QUERY>& terms, const World& world) {
          if (terms.empty())
            return;
 
          add_cstr(out, title);
          out.append(": ");
          add_uint(out, (uint32_t)terms.size());
          out.append('\n');
 
          const auto cnt = (uint32_t)terms.size();
          GAIA_FOR(cnt) {
            out.append("  [");
            add_uint(out, i);
            out.append("] ");
            add_cstr(out, opcode_name(terms[i].sourceOpcode));
            out.append(" id=");
            add_term_expr(out, world, terms[i].term);
            out.append('\n');
          }
        }
 
        GAIA_NODISCARD static const QueryTerm&
        var_program_op_term(const detail::QueryCompileCtx& comp, const detail::CompiledOp& op) {
          switch (detail::var_program_opcode_meta(op.opcode).termSet) {
            case detail::EVarProgramTermSet::None:
              GAIA_ASSERT(false);
              return comp.terms_all_var[0].term;
            case detail::EVarProgramTermSet::Or:
              return comp.terms_or_var[(uint32_t)op.arg].term;
            case detail::EVarProgramTermSet::Any:
              return comp.terms_any_var[(uint32_t)op.arg].term;
            case detail::EVarProgramTermSet::Not:
              return comp.terms_not_var[(uint32_t)op.arg].term;
            case detail::EVarProgramTermSet::All:
            default:
              return comp.terms_all_var[(uint32_t)op.arg].term;
          }
        }
 
        static void add_var_program_ops_section(
            util::str& out, const char* title, std::span<const detail::CompiledOp> ops,
            const detail::QueryCompileCtx& comp, const World& world) {
          if (ops.empty())
            return;
 
          add_cstr(out, title);
          out.append(": ");
          add_uint(out, (uint32_t)ops.size());
          out.append('\n');
 
          const auto cnt = (uint32_t)ops.size();
          GAIA_FOR(cnt) {
            const auto& op = ops[i];
            out.append("  [");
            add_uint(out, i);
            out.append("] ");
            add_cstr(out, opcode_name(op.opcode));
            if (detail::var_program_opcode_meta(op.opcode).termSet != detail::EVarProgramTermSet::None) {
              out.append(" term=");
              add_uint(out, (uint32_t)op.arg);
              out.append(" cost=");
              add_uint(out, (uint32_t)op.cost);
              out.append(" id=");
              add_term_expr(out, world, var_program_op_term(comp, op));
            }
            out.append(" ok=");
            add_uint(out, (uint32_t)op.pc_ok);
            out.append(" fail=");
            add_uint(out, (uint32_t)op.pc_fail);
            out.append('\n');
          }
        }
 
        static void add_var_program_exec_section(util::str& out, const detail::QueryCompileCtx& comp) {
          if (comp.var_programs.empty())
            return;
 
          out.append("var_exec: ");
          add_uint(out, (uint32_t)comp.var_programs.size());
          out.append('\n');
 
          const auto cnt = (uint32_t)comp.var_programs.size();
          GAIA_FOR(cnt) {
            out.append("  [");
            add_uint(out, i);
            out.append("] search");
            out.append('\n');
          }
        }
 
        static void add_var_program_sections(util::str& out, const detail::QueryCompileCtx& comp, const World& world) {
          const auto cnt = (uint32_t)comp.var_programs.size();
          GAIA_FOR(cnt) {
            const auto& step = comp.var_programs[i];
            char title[32];
            [[maybe_unused]] const auto len = GAIA_STRFMT(title, sizeof(title), "varp%u", i);
            GAIA_ASSERT(len > 0);
            add_var_program_ops_section(out, title, detail::program_ops(comp, step.program), comp, world);
          }
        }
 
      private:
        GAIA_NODISCARD static detail::VarBindings make_initial_var_bindings(const MatchingCtx& ctx) {
          detail::VarBindings vars{};
          vars.mask = ctx.varBindingMask;
          GAIA_FOR(MaxVarCnt) {
            const auto bit = (uint8_t(1) << i);
            if ((vars.mask & bit) == 0)
              continue;
            vars.values[i] = ctx.varBindings[i];
          }
          return vars;
        }
 
        GAIA_NODISCARD static uint8_t
        term_unbound_var_mask(const World& world, const QueryTerm& term, const detail::VarBindings& vars) {
          uint8_t mask = 0;
 
          if (detail::is_var_entity(term.src) && !detail::var_is_bound(vars, term.src))
            mask |= (uint8_t(1) << detail::var_index(term.src));
 
          if (!term.id.pair()) {
            const auto idEnt = id_entity(world, term.id);
            if (detail::is_var_entity(idEnt) && !detail::var_is_bound(vars, idEnt))
              mask |= (uint8_t(1) << detail::var_index(idEnt));
            return mask;
          }
 
          const auto relEnt = pair_rel(world, term.id);
          if (detail::is_var_entity(relEnt) && !detail::var_is_bound(vars, relEnt))
            mask |= (uint8_t(1) << detail::var_index(relEnt));
 
          const auto tgtEnt = pair_tgt(world, term.id);
          if (detail::is_var_entity(tgtEnt) && !detail::var_is_bound(vars, tgtEnt))
            mask |= (uint8_t(1) << detail::var_index(tgtEnt));
 
          return mask;
        }
 
        GAIA_NODISCARD bool eval_variable_terms_program_on_archetype(
            const MatchingCtx& ctx, const Archetype& archetype, bool orAlreadySatisfied) const {
          GAIA_ASSERT(m_compCtx.var_programs.size() == 1);
          const auto& programStep = m_compCtx.var_programs[0];
          return match_search_program_on_archetype(ctx, archetype, programStep, orAlreadySatisfied);
        }
 
        GAIA_NODISCARD const detail::QueryCompileCtx::VarTermOp&
        search_program_term_op(const detail::CompiledOp& op) const {
          switch (op.opcode) {
            case detail::EOpcode::Var_Term_Or_Check:
            case detail::EOpcode::Var_Term_Or_Bind:
            case detail::EOpcode::Var_Final_Or_Check:
              return m_compCtx.terms_or_var[(uint32_t)op.arg];
            case detail::EOpcode::Var_Term_Any_Check:
            case detail::EOpcode::Var_Term_Any_Bind:
              return m_compCtx.terms_any_var[(uint32_t)op.arg];
            case detail::EOpcode::Var_Term_Not:
            case detail::EOpcode::Var_Final_Not_Check:
              return m_compCtx.terms_not_var[(uint32_t)op.arg];
            case detail::EOpcode::Var_Term_All_Check:
            case detail::EOpcode::Var_Term_All_Bind:
            case detail::EOpcode::Var_Term_All_Src_Bind:
              return m_compCtx.terms_all_var[(uint32_t)op.arg];
            default:
              GAIA_ASSERT(false);
              return m_compCtx.terms_all_var[0];
          }
        }
 
        GAIA_NODISCARD bool select_next_pending_search_all_term(
            std::span<const detail::CompiledOp> programOps, const detail::QueryCompileCtx::VarSearchMeta& search,
            uint16_t pendingMask, const detail::VarBindings& vars, uint32_t& outLocalIdx, uint32_t& outPc,
            bool preferBoundTerms = true) const {
          outLocalIdx = (uint32_t)-1;
          outPc = (uint32_t)-1;
          uint32_t firstReadyLocalIdx = (uint32_t)-1;
          uint32_t firstReadyPc = (uint32_t)-1;
 
          for (uint32_t localIdx = 0; localIdx < search.allCount; ++localIdx) {
            const auto bit = (uint16_t)(uint16_t(1) << localIdx);
            if ((pendingMask & bit) == 0)
              continue;
 
            const auto bindPc = (uint32_t)search.allBegin + localIdx;
            const auto& bindOp = programOps[bindPc];
            const auto& termOp = search_program_term_op(bindOp);
            if (detail::is_var_entity(termOp.term.src) && !detail::var_is_bound(vars, termOp.term.src) &&
                bindOp.opcode != detail::EOpcode::Var_Term_All_Src_Bind)
              continue;
 
            const bool bindsNewVars = (uint8_t)(termOp.varMask & ~vars.mask) != 0;
            const auto pc = bindsNewVars ? bindPc : (uint32_t)search.allCheckBegin + localIdx;
            if (preferBoundTerms && !bindsNewVars) {
              outLocalIdx = localIdx;
              outPc = pc;
              return true;
            }
 
            if (firstReadyLocalIdx == (uint32_t)-1) {
              firstReadyLocalIdx = localIdx;
              firstReadyPc = pc;
            }
          }
 
          if (firstReadyLocalIdx == (uint32_t)-1)
            return false;
 
          outLocalIdx = firstReadyLocalIdx;
          outPc = firstReadyPc;
          return true;
        }
 
        GAIA_NODISCARD bool select_next_pending_search_or_term(
            std::span<const detail::CompiledOp> programOps, const detail::QueryCompileCtx::VarSearchMeta& search,
            uint16_t pendingMask, uint16_t pendingCheckMask, const detail::VarBindings& vars, bool preferBoundTerms,
            bool requireNewBindings, uint32_t& outLocalIdx, uint32_t& outPc) const {
          outLocalIdx = (uint32_t)-1;
          outPc = (uint32_t)-1;
          if (requireNewBindings && (uint8_t)(search.orVarMask & ~vars.mask) == 0)
            return false;
 
          uint32_t firstReadyLocalIdx = (uint32_t)-1;
          uint32_t firstReadyPc = (uint32_t)-1;
 
          for (uint32_t localIdx = 0; localIdx < search.orCount; ++localIdx) {
            const auto bit = (uint16_t)(uint16_t(1) << localIdx);
            if ((pendingMask & bit) == 0)
              continue;
 
            const auto bindPc = (uint32_t)search.orBegin + localIdx;
            const auto& bindOp = programOps[bindPc];
            const auto& termOp = search_program_term_op(bindOp);
            if (detail::is_var_entity(termOp.term.src) && !detail::var_is_bound(vars, termOp.term.src))
              continue;
 
            const bool bindsNewVars = (uint8_t)(termOp.varMask & ~vars.mask) != 0;
            if (requireNewBindings) {
              if (!bindsNewVars)
                continue;
              outLocalIdx = localIdx;
              outPc = bindPc;
              return true;
            }
 
            if (!bindsNewVars && (pendingCheckMask & bit) == 0)
              continue;
 
            const auto pc = bindsNewVars ? bindPc : (uint32_t)search.orCheckBegin + localIdx;
            if (preferBoundTerms && !bindsNewVars) {
              outLocalIdx = localIdx;
              outPc = pc;
              return true;
            }
 
            if (firstReadyLocalIdx == (uint32_t)-1) {
              firstReadyLocalIdx = localIdx;
              firstReadyPc = pc;
            }
          }
 
          if (firstReadyLocalIdx == (uint32_t)-1)
            return false;
 
          outLocalIdx = firstReadyLocalIdx;
          outPc = firstReadyPc;
          return true;
        }
 
        GAIA_NODISCARD bool select_next_pending_search_any_term(
            std::span<const detail::CompiledOp> programOps, const detail::QueryCompileCtx::VarSearchMeta& search,
            uint16_t pendingMask, const detail::VarBindings& vars, uint32_t& outLocalIdx, uint32_t& outPc) const {
          outLocalIdx = (uint32_t)-1;
          outPc = (uint32_t)-1;
          uint32_t firstReadyBindingLocalIdx = (uint32_t)-1;
          uint32_t firstReadyBindingPc = (uint32_t)-1;
 
          for (uint32_t localIdx = 0; localIdx < search.anyCount; ++localIdx) {
            const auto bit = (uint16_t)(uint16_t(1) << localIdx);
            if ((pendingMask & bit) == 0)
              continue;
 
            const auto bindPc = (uint32_t)search.anyBegin + localIdx;
            const auto& bindOp = programOps[bindPc];
            const auto& termOp = search_program_term_op(bindOp);
            if (detail::is_var_entity(termOp.term.src) && !detail::var_is_bound(vars, termOp.term.src))
              continue;
 
            const bool bindsNewVars = (uint8_t)(termOp.varMask & ~vars.mask) != 0;
            if (!bindsNewVars) {
              outLocalIdx = localIdx;
              outPc = (uint32_t)search.anyCheckBegin + localIdx;
              return true;
            }
 
            if (firstReadyBindingLocalIdx == (uint32_t)-1) {
              firstReadyBindingLocalIdx = localIdx;
              firstReadyBindingPc = bindPc;
            }
          }
 
          if (firstReadyBindingLocalIdx == (uint32_t)-1)
            return false;
 
          outLocalIdx = firstReadyBindingLocalIdx;
          outPc = firstReadyBindingPc;
          return true;
        }
 
        GAIA_NODISCARD int32_t select_best_pending_search_term(
            const MatchingCtx& ctx, const Archetype& archetype, std::span<const detail::CompiledOp> programOps,
            uint16_t begin, uint16_t count, uint16_t pendingMask, const detail::VarBindings& vars,
            uint32_t& outBestIdx) const {
          constexpr uint32_t MatchProbeLimit = 64;
          outBestIdx = (uint32_t)-1;
          uint32_t bestMatchCnt = MatchProbeLimit + 1;
 
          for (uint32_t localIdx = 0; localIdx < count; ++localIdx) {
            const auto i = (uint32_t)begin + localIdx;
            const auto bit = (uint16_t)(uint16_t(1) << i);
            if ((pendingMask & bit) == 0)
              continue;
 
            const auto& termOp = search_program_term_op(programOps[i]);
            if (detail::is_var_entity(termOp.term.src) && !detail::var_is_bound(vars, termOp.term.src))
              continue;
 
            const auto matchCnt =
                detail::count_term_matches_limited(*ctx.pWorld, archetype, termOp, vars, bestMatchCnt);
            if (matchCnt == 0)
              return -1;
 
            if (outBestIdx == (uint32_t)-1 || matchCnt < bestMatchCnt) {
              outBestIdx = i;
              bestMatchCnt = matchCnt;
              if (bestMatchCnt == 1)
                break;
            }
          }
 
          return outBestIdx == (uint32_t)-1 ? 0 : 1;
        }
 
        GAIA_NODISCARD bool can_skip_pending_search_all(
            std::span<const detail::CompiledOp> programOps, const detail::QueryCompileCtx::VarSearchMeta& search,
            uint16_t pendingAllMask, const detail::VarBindings& vars) const {
          const auto anyVarMask = m_compCtx.varMaskAny;
          for (uint32_t localIdx = 0; localIdx < search.allCount; ++localIdx) {
            const auto i = (uint32_t)search.allBegin + localIdx;
            const auto bit = (uint16_t(1) << i);
            if ((pendingAllMask & bit) == 0)
              continue;
 
            const auto& termOp = search_program_term_op(programOps[i]);
            const auto missingMask = (uint8_t)(termOp.varMask & ~vars.mask);
            if (missingMask == 0)
              return false;
            if ((missingMask & ~anyVarMask) != 0)
              return false;
          }
 
          return true;
        }
 
        static inline constexpr uint16_t BacktrackPC = (uint16_t)-1;
 
        GAIA_NODISCARD bool match_search_program_on_archetype(
            const MatchingCtx& ctx, const Archetype& archetype,
            const detail::QueryCompileCtx::VarProgramStep& programStep, bool orAlreadySatisfied) const {
          using namespace detail;
 
          struct SearchProgramState {
            VarBindings vars{};
            uint16_t pendingAllMask = 0;
            uint16_t pendingOrMask = 0;
            uint16_t pendingFinalOrMask = 0;
            uint16_t pendingAnyMask = 0;
            uint16_t pc = BacktrackPC;
            uint8_t termOpIdx = 0xff;
            uint8_t bestOrIdx = 0xff;
            uint8_t scanIdx = 0;
            bool orMatched = false;
            bool anyMatched = false;
            bool currentAnyMatched = false;
          };
 
          struct SearchBacktrackFrame {
            SearchProgramState state{};
            VarBindings varsBase{};
            VarTermMatchCursor cursor{};
          };
 
          const auto& program = programStep.program;
          const auto& search = programStep.search;
          const auto programOps = detail::program_ops(m_compCtx, program);
          if (programOps.empty())
            return true;
          GAIA_ASSERT(search.selectAllPc != BacktrackPC);
          GAIA_ASSERT(search.selectOrPc != BacktrackPC);
          GAIA_ASSERT(search.selectOtherOrPc != BacktrackPC);
          GAIA_ASSERT(search.selectOtherOrBindPc != BacktrackPC);
          GAIA_ASSERT(search.beginAnyPc != BacktrackPC);
          GAIA_ASSERT(search.selectAnyPc != BacktrackPC);
          GAIA_ASSERT(search.maybeFinalizePc != BacktrackPC);
 
          const auto is_term_ready = [&](const detail::CompiledOp& op, const VarBindings& vars) {
            const auto& termOp = search_program_term_op(op);
            return !is_var_entity(termOp.term.src) || var_is_bound(vars, termOp.term.src) ||
                   op.opcode == EOpcode::Var_Term_All_Src_Bind;
          };
 
          const auto can_binding_satisfy_pending_or = [&](const SearchProgramState& state,
                                                          const VarBindings& nextVars) {
            if (state.orMatched || search.orCount == 0 || state.pendingOrMask == 0)
              return true;
 
            bool hasDeferredOr = false;
            for (uint32_t localIdx = 0; localIdx < search.orCount; ++localIdx) {
              const auto bit = (uint16_t)(uint16_t(1) << localIdx);
              if ((state.pendingOrMask & bit) == 0)
                continue;
 
              const auto bindPc = (uint32_t)search.orBegin + localIdx;
              const auto& bindOp = programOps[bindPc];
              const auto& termOp = search_program_term_op(bindOp);
              const auto missingMaskBefore = (uint8_t)(termOp.varMask & ~state.vars.mask);
              const auto missingMaskAfter = (uint8_t)(termOp.varMask & ~nextVars.mask);
              if (missingMaskAfter != 0) {
                hasDeferredOr = true;
                continue;
              }
 
              if (missingMaskBefore == 0 && (state.pendingFinalOrMask & bit) == 0)
                continue;
 
              if (term_has_match(*ctx.pWorld, archetype, termOp, nextVars))
                return true;
            }
 
            return hasDeferredOr;
          };
 
          const auto adv_after_search_term_success = [&](SearchProgramState& state, const detail::CompiledOp& op,
                                                         VarBindings nextVars) {
            const auto bit = (uint16_t)(uint16_t(1) << state.termOpIdx);
            state.vars = nextVars;
            switch (op.opcode) {
              case EOpcode::Var_Term_All_Check:
              case EOpcode::Var_Term_All_Bind:
              case EOpcode::Var_Term_All_Src_Bind:
                state.pendingAllMask = (uint16_t)(state.pendingAllMask & ~bit);
                state.pc = op.pc_ok;
                break;
              case EOpcode::Var_Term_Or_Check:
              case EOpcode::Var_Term_Or_Bind:
                state.pendingOrMask = (uint16_t)(state.pendingOrMask & ~(uint16_t(1) << state.termOpIdx));
                state.pendingFinalOrMask = (uint16_t)(state.pendingFinalOrMask & ~(uint16_t(1) << state.termOpIdx));
                state.orMatched = true;
                state.pc = op.pc_ok;
                break;
              case EOpcode::Var_Term_Any_Check:
              case EOpcode::Var_Term_Any_Bind:
                state.pendingAnyMask = (uint16_t)(state.pendingAnyMask & ~(uint16_t(1) << state.termOpIdx));
                state.anyMatched = true;
                state.currentAnyMatched = true;
                state.pc = op.pc_ok;
                break;
              default:
                GAIA_ASSERT(false);
                state.pc = BacktrackPC;
                break;
            }
          };
 
          const auto handle_search_term_exhausted = [&](SearchProgramState& state, const detail::CompiledOp& op) {
            if (op.opcode == EOpcode::Var_Term_Any_Check || op.opcode == EOpcode::Var_Term_Any_Bind) {
              state.pendingAnyMask = (uint16_t)(state.pendingAnyMask & ~(uint16_t(1) << state.termOpIdx));
            }
            state.pc = op.pc_fail;
          };
 
          const auto try_enter_search_term = [&](SearchProgramState& state,
                                                 cnt::sarray_ext<SearchBacktrackFrame, MAX_ITEMS_IN_QUERY>& stack) {
            const auto& op = programOps[state.pc];
            const auto& termOp = search_program_term_op(op);
            SearchBacktrackFrame frame{};
            frame.state = state;
            frame.varsBase = state.vars;
 
            VarBindings nextVars{};
            for (;;) {
              if (!detail::next_term_match_cursor(ctx, archetype, termOp, frame.varsBase, frame.cursor, nextVars))
                return false;
              if (can_binding_satisfy_pending_or(state, nextVars))
                break;
            }
 
            if (op.opcode == EOpcode::Var_Term_Any_Check || op.opcode == EOpcode::Var_Term_Any_Bind) {
              frame.state.anyMatched = true;
              frame.state.currentAnyMatched = true;
            }
 
            stack.push_back(GAIA_MOV(frame));
            adv_after_search_term_success(state, op, nextVars);
            return true;
          };
 
          const auto backtrack = [&](SearchProgramState& state,
                                     cnt::sarray_ext<SearchBacktrackFrame, MAX_ITEMS_IN_QUERY>& stack) {
            while (!stack.empty()) {
              auto& frame = stack.back();
              const auto resumeState = frame.state;
              const auto& op = programOps[resumeState.pc];
              const auto& termOp = search_program_term_op(op);
              VarBindings nextVars{};
 
              if (detail::next_term_match_cursor(ctx, archetype, termOp, frame.varsBase, frame.cursor, nextVars)) {
                if (op.opcode == EOpcode::Var_Term_Any_Check || op.opcode == EOpcode::Var_Term_Any_Bind) {
                  frame.state.anyMatched = true;
                  frame.state.currentAnyMatched = true;
                }
 
                state = frame.state;
                adv_after_search_term_success(state, op, nextVars);
                return true;
              }
 
              stack.pop_back();
              state = resumeState;
              handle_search_term_exhausted(state, op);
              if (state.pc != BacktrackPC)
                return true;
            }
 
            return false;
          };
 
          cnt::sarray_ext<SearchBacktrackFrame, MAX_ITEMS_IN_QUERY> stack;
          SearchProgramState state{};
          state.vars = make_initial_var_bindings(ctx);
          state.pendingAllMask = search.initialAllMask;
          state.pendingOrMask = search.initialOrMask;
          state.pendingFinalOrMask = search.initialOrMask;
          state.pendingAnyMask = search.initialAnyMask;
          state.pc = search.selectAllPc;
 
          for (;;) {
            if (state.pc == BacktrackPC) {
              if (!backtrack(state, stack))
                return false;
              continue;
            }
            const auto& op = programOps[state.pc];
            switch (op.opcode) {
              case EOpcode::Var_Search_SelectAll: {
                if (state.pendingAllMask == 0) {
                  state.pc = op.pc_fail;
                  break;
                }
 
                if (search.orCount == 0 && search.anyCount == 0) {
                  uint32_t nextAllLocalIdx = (uint32_t)-1;
                  uint32_t nextAllPc = (uint32_t)-1;
                  if (select_next_pending_search_all_term(
                          programOps, search, state.pendingAllMask, state.vars, nextAllLocalIdx, nextAllPc)) {
                    const auto bindPc = (uint32_t)search.allBegin + nextAllLocalIdx;
                    if (nextAllPc != bindPc) {
                      state.termOpIdx = (uint8_t)nextAllLocalIdx;
                      state.pc = (uint16_t)nextAllPc;
                      break;
                    }
                  }
 
                  uint32_t bestAllIdx = (uint32_t)-1;
                  const auto allSel = select_best_pending_search_term(
                      ctx, archetype, programOps, search.allBegin, search.allCount, state.pendingAllMask, state.vars,
                      bestAllIdx);
                  if (allSel < 0) {
                    if (!backtrack(state, stack))
                      return false;
                    break;
                  }
 
                  if (allSel > 0) {
                    state.termOpIdx = (uint8_t)bestAllIdx;
                    state.pc = (uint16_t)bestAllIdx;
                    break;
                  }
                } else {
                  uint32_t nextAllLocalIdx = (uint32_t)-1;
                  uint32_t nextAllPc = (uint32_t)-1;
                  if (select_next_pending_search_all_term(
                          programOps, search, state.pendingAllMask, state.vars, nextAllLocalIdx, nextAllPc)) {
                    state.termOpIdx = (uint8_t)nextAllLocalIdx;
                    state.pc = (uint16_t)nextAllPc;
                    break;
                  }
                }
 
                state.pc = op.pc_fail;
                break;
              }
              case EOpcode::Var_Search_SelectOr: {
                if (!state.orMatched && search.anyCount == 0 && (uint8_t)(search.orVarMask & ~state.vars.mask) == 0) {
                  state.bestOrIdx = 0xff;
                  state.scanIdx = 0;
                  state.pc = search.maybeFinalizePc;
                  break;
                }
 
                if (state.orMatched && (uint8_t)(search.orVarMask & ~state.vars.mask) == 0) {
                  state.bestOrIdx = 0xff;
                  state.scanIdx = 0;
                  state.pc = search.beginAnyPc;
                  break;
                }
 
                uint32_t nextOrLocalIdx = (uint32_t)-1;
                uint32_t nextOrPc = (uint32_t)-1;
                if (select_next_pending_search_or_term(
                        programOps, search, state.pendingOrMask, state.pendingFinalOrMask, state.vars, !state.orMatched,
                        state.orMatched, nextOrLocalIdx, nextOrPc)) {
                  state.bestOrIdx = (uint8_t)nextOrLocalIdx;
                  state.scanIdx = 0;
                  state.termOpIdx = state.bestOrIdx;
                  state.pc = (uint16_t)nextOrPc;
                  break;
                }
 
                state.bestOrIdx = 0xff;
                state.scanIdx = 0;
                state.pc = op.pc_fail;
                break;
              }
              case EOpcode::Var_Search_SelectOtherOr: {
                if (state.orMatched && (uint8_t)(search.orVarMask & ~state.vars.mask) == 0) {
                  state.scanIdx = 0;
                  state.pc = search.beginAnyPc;
                  break;
                }
 
                bool found = false;
                while (state.scanIdx < search.orCount) {
                  const auto localIdx = (uint32_t)state.scanIdx++;
                  if (localIdx == state.bestOrIdx)
                    continue;
 
                  const auto bit = (uint16_t)(uint16_t(1) << localIdx);
                  if ((state.pendingOrMask & bit) == 0)
                    continue;
                  const auto bindPc = (uint32_t)search.orBegin + localIdx;
                  if (!is_term_ready(programOps[bindPc], state.vars))
                    continue;
 
                  const bool bindsNewVars =
                      (uint8_t)(search_program_term_op(programOps[bindPc]).varMask & ~state.vars.mask) != 0;
                  if (state.orMatched) {
                    if (!bindsNewVars)
                      continue;
                  } else {
                    if (!bindsNewVars && (state.pendingFinalOrMask & bit) == 0)
                      continue;
                    if (bindsNewVars)
                      continue;
                  }
 
                  state.termOpIdx = (uint8_t)localIdx;
                  state.pc = (uint16_t)((uint32_t)search.orCheckBegin + localIdx);
                  found = true;
                  break;
                }
 
                if (!found) {
                  state.scanIdx = 0;
                  state.pc = op.pc_fail;
                }
                break;
              }
              case EOpcode::Var_Search_SelectOtherOrBind: {
                if (state.orMatched) {
                  state.pc = op.pc_fail;
                  break;
                }
 
                bool found = false;
                for (uint32_t localIdx = state.scanIdx; localIdx < search.orCount; ++localIdx) {
                  if (localIdx == state.bestOrIdx)
                    continue;
 
                  const auto bit = (uint16_t)(uint16_t(1) << localIdx);
                  if ((state.pendingOrMask & bit) == 0)
                    continue;
 
                  const auto bindPc = (uint32_t)search.orBegin + localIdx;
                  if (!is_term_ready(programOps[bindPc], state.vars))
                    continue;
 
                  const auto& termOp = search_program_term_op(programOps[bindPc]);
                  const bool bindsNewVars = (uint8_t)(termOp.varMask & ~state.vars.mask) != 0;
                  if (!bindsNewVars)
                    continue;
 
                  state.scanIdx = (uint8_t)(localIdx + 1u);
                  state.termOpIdx = (uint8_t)localIdx;
                  state.pc = (uint16_t)bindPc;
                  found = true;
                  break;
                }
 
                if (!found)
                  state.pc = op.pc_fail;
                break;
              }
              case EOpcode::Var_Search_BeginAny:
                state.anyMatched = false;
                state.scanIdx = 0;
                state.currentAnyMatched = false;
                state.pc = op.pc_ok;
                break;
              case EOpcode::Var_Search_SelectAny: {
                uint32_t nextAnyLocalIdx = (uint32_t)-1;
                uint32_t nextAnyPc = (uint32_t)-1;
                const bool found = select_next_pending_search_any_term(
                    programOps, search, state.pendingAnyMask, state.vars, nextAnyLocalIdx, nextAnyPc);
                if (found) {
                  state.termOpIdx = (uint8_t)nextAnyLocalIdx;
                  state.currentAnyMatched = false;
                  state.pc = (uint16_t)nextAnyPc;
                }
 
                if (found)
                  break;
                state.pc = op.pc_fail;
                break;
              }
              case EOpcode::Var_Search_MaybeFinalize:
                if (!state.anyMatched &&
                    can_skip_pending_search_all(programOps, search, state.pendingAllMask, state.vars))
                  state.pc = op.pc_ok;
                else if (op.pc_fail != BacktrackPC)
                  state.pc = op.pc_fail;
                else if (!backtrack(state, stack))
                  return false;
                break;
              case EOpcode::Var_Term_All_Check:
                if (term_has_match(*ctx.pWorld, archetype, search_program_term_op(op), state.vars))
                  adv_after_search_term_success(state, op, state.vars);
                else {
                  handle_search_term_exhausted(state, op);
                  if (state.pc == BacktrackPC && !backtrack(state, stack))
                    return false;
                }
                break;
              case EOpcode::Var_Term_All_Bind:
              case EOpcode::Var_Term_All_Src_Bind:
                if (!try_enter_search_term(state, stack)) {
                  handle_search_term_exhausted(state, op);
                  if (state.pc == BacktrackPC && !backtrack(state, stack))
                    return false;
                }
                break;
              case EOpcode::Var_Term_Or_Check:
              case EOpcode::Var_Term_Or_Bind:
              case EOpcode::Var_Term_Any_Check:
              case EOpcode::Var_Term_Any_Bind: {
                const auto& termOp = search_program_term_op(op);
                const bool bindsNewVars = (uint8_t)(termOp.varMask & ~state.vars.mask) != 0;
                if (!bindsNewVars) {
                  if (term_has_match(*ctx.pWorld, archetype, termOp, state.vars))
                    adv_after_search_term_success(state, op, state.vars);
                  else {
                    if (op.opcode == EOpcode::Var_Term_Or_Check || op.opcode == EOpcode::Var_Term_Or_Bind)
                      state.pendingFinalOrMask =
                          (uint16_t)(state.pendingFinalOrMask & ~(uint16_t(1) << state.termOpIdx));
                    handle_search_term_exhausted(state, op);
                    if (state.pc == BacktrackPC && !backtrack(state, stack))
                      return false;
                  }
                  break;
                }
 
                if (!try_enter_search_term(state, stack)) {
                  handle_search_term_exhausted(state, op);
                  if (state.pc == BacktrackPC && !backtrack(state, stack))
                    return false;
                }
                break;
              }
              case EOpcode::Var_Final_Not_Check:
                if (term_has_match(*ctx.pWorld, archetype, search_program_term_op(op), state.vars)) {
                  if (!backtrack(state, stack))
                    return false;
                } else
                  state.pc = op.pc_ok;
                break;
              case EOpcode::Var_Final_Require_Or:
                if (orAlreadySatisfied || state.orMatched || search.orCount == 0)
                  state.pc = op.pc_ok;
                else if (op.pc_fail != BacktrackPC)
                  state.pc = op.pc_fail;
                else if (!backtrack(state, stack))
                  return false;
                break;
              case EOpcode::Var_Final_Or_Check:
                if ((state.pendingFinalOrMask & (uint16_t(1) << op.arg)) == 0)
                  state.pc = op.pc_fail;
                else if (term_has_match(*ctx.pWorld, archetype, search_program_term_op(op), state.vars))
                  state.pc = op.pc_ok;
                else {
                  state.pendingFinalOrMask = (uint16_t)(state.pendingFinalOrMask & ~(uint16_t(1) << op.arg));
                  if (op.pc_fail != BacktrackPC)
                    state.pc = op.pc_fail;
                  else if (!backtrack(state, stack))
                    return false;
                }
                break;
              case EOpcode::Var_Final_Success:
                return true;
              default:
                GAIA_ASSERT(false);
                return false;
            }
          }
        }
        using VarEvalFunc = bool (VirtualMachine::*)(const MatchingCtx&, const Archetype&, bool) const;
 
        void filter_variable_terms(MatchingCtx& ctx, VarEvalFunc evalFunc) const {
          if (!m_compCtx.has_variable_terms())
            return;
 
          const bool orAlreadySatisfied = !m_compCtx.ids_or.empty() || ctx.skipOr;
          const auto sourceCnt = ctx.pMatchesArr->size();
          constexpr uint32_t FilterChunkSize = 64;
          cnt::sarray_ext<const Archetype*, FilterChunkSize> filtered;
          uint32_t writeIdx = 0;
 
          const auto flush_filtered = [&]() {
            for (const auto* pFiltered: filtered) {
              (*ctx.pMatchesArr)[writeIdx++] = pFiltered;
            }
            filtered.clear();
          };
 
          GAIA_FOR(sourceCnt) {
            const auto* pArchetype = (*ctx.pMatchesArr)[i];
            const bool matched = (this->*evalFunc)(ctx, *pArchetype, orAlreadySatisfied);
            if (!matched)
              continue;
 
            filtered.push_back(pArchetype);
            if (filtered.size() != FilterChunkSize)
              continue;
 
            flush_filtered();
          }
 
          if (!filtered.empty())
            flush_filtered();
 
          ctx.pMatchesArr->resize(writeIdx);
        }
        GAIA_NODISCARD detail::VmLabel add_op(detail::CompiledOp&& op) {
          const auto cnt = (detail::VmLabel)m_compCtx.ops.size();
          op.pc_ok = cnt + 1;
          op.pc_fail = cnt - 1;
          m_compCtx.ops.push_back(GAIA_MOV(op));
          return cnt;
        }
 
        GAIA_NODISCARD detail::VmLabel add_gate_op(detail::CompiledOp&& op) {
          const auto cnt = add_op(GAIA_MOV(op));
          m_compCtx.ops[cnt].pc_fail = (detail::VmLabel)-1;
          return cnt;
        }
 
        GAIA_NODISCARD static uint8_t opcode_arg(uint32_t idx) {
          GAIA_ASSERT(idx < OpcodeArgLimit);
          return (uint8_t)idx;
        }
 
        template <typename SourceTermsArray>
        void emit_src_gate_terms(const SourceTermsArray& terms, detail::EOpcode opcode) {
          const auto cnt = (uint32_t)terms.size();
          GAIA_FOR(cnt) {
            detail::CompiledOp op{};
            op.opcode = opcode;
            op.arg = opcode_arg(i);
            (void)add_gate_op(GAIA_MOV(op));
          }
        }
 
        void emit_src_or_terms(bool hasOrFallback) {
          cnt::sarray_ext<detail::VmLabel, MAX_ITEMS_IN_QUERY> orSrcOpLabels;
 
          const auto srcOrCnt = (uint32_t)m_compCtx.terms_or_src.size();
          GAIA_FOR(srcOrCnt) {
            detail::CompiledOp op{};
            op.opcode = detail::EOpcode::Src_OrTerm;
            op.arg = opcode_arg(i);
            orSrcOpLabels.push_back(add_op(GAIA_MOV(op)));
          }
 
          const auto orExitPc = (detail::VmLabel)m_compCtx.ops.size();
          for (const auto opLabel: orSrcOpLabels)
            m_compCtx.ops[opLabel].pc_ok = orExitPc;
 
          const auto lastIdx = (uint32_t)orSrcOpLabels.size() - 1u;
          GAIA_FOR(lastIdx) {
            m_compCtx.ops[orSrcOpLabels[i]].pc_fail = orSrcOpLabels[i + 1];
          }
 
          m_compCtx.ops[orSrcOpLabels[lastIdx]].pc_fail = hasOrFallback ? orExitPc : (detail::VmLabel)-1;
        }
 
        GAIA_NODISCARD static detail::EOpcode pick_all_opcode(bool isSimple, bool isAs) {
          if (isSimple)
            return detail::EOpcode::All_Simple;
          if (isAs)
            return detail::EOpcode::All_Complex;
          return detail::EOpcode::All_Wildcard;
        }
 
        GAIA_NODISCARD static detail::EOpcode pick_or_opcode(bool hasAllTerms, bool isSimple, bool isAs) {
          if (!hasAllTerms) {
            if (isSimple)
              return detail::EOpcode::Or_NoAll_Simple;
            if (isAs)
              return detail::EOpcode::Or_NoAll_Complex;
            return detail::EOpcode::Or_NoAll_Wildcard;
          }
 
          if (isSimple)
            return detail::EOpcode::Or_WithAll_Simple;
          if (isAs)
            return detail::EOpcode::Or_WithAll_Complex;
          return detail::EOpcode::Or_WithAll_Wildcard;
        }
 
        GAIA_NODISCARD static detail::EOpcode pick_not_opcode(bool isSimple, bool isAs) {
          if (isSimple)
            return detail::EOpcode::Not_Simple;
          if (isAs)
            return detail::EOpcode::Not_Complex;
          return detail::EOpcode::Not_Wildcard;
        }
 
        using OpcodeFunc = bool (VirtualMachine::*)(MatchingCtx&) const;
 
        GAIA_NODISCARD bool op_all_simple(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_and_simple);
          return detail::exec_all_impl<MatchingStyle::Simple>(m_compCtx, ctx);
        }
 
        GAIA_NODISCARD bool op_all_wildcard(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_and_wildcard);
          return detail::exec_all_impl<MatchingStyle::Wildcard>(m_compCtx, ctx);
        }
 
        GAIA_NODISCARD bool op_all_complex(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_and_complex);
          return detail::exec_all_impl<MatchingStyle::Complex>(m_compCtx, ctx);
        }
 
        GAIA_NODISCARD bool op_or_noall_simple(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_or);
          return detail::exec_or_noall_impl<MatchingStyle::Simple>(m_compCtx, ctx);
        }
 
        GAIA_NODISCARD bool op_or_noall_wildcard(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_or);
          return detail::exec_or_noall_impl<MatchingStyle::Wildcard>(m_compCtx, ctx);
        }
 
        GAIA_NODISCARD bool op_or_noall_complex(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_or);
          return detail::exec_or_noall_impl<MatchingStyle::Complex>(m_compCtx, ctx);
        }
 
        GAIA_NODISCARD bool op_or_withall_simple(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_or);
          return detail::exec_or_withall_impl<MatchingStyle::Simple>(m_compCtx, ctx);
        }
 
        GAIA_NODISCARD bool op_or_withall_wildcard(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_or);
          return detail::exec_or_withall_impl<MatchingStyle::Wildcard>(m_compCtx, ctx);
        }
 
        GAIA_NODISCARD bool op_or_withall_complex(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_or);
          return detail::exec_or_withall_impl<MatchingStyle::Complex>(m_compCtx, ctx);
        }
 
        GAIA_NODISCARD bool op_not_simple(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_not);
          return detail::exec_not_impl<MatchingStyle::Simple>(m_compCtx, ctx);
        }
 
        GAIA_NODISCARD bool op_not_wildcard(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_not);
          return detail::exec_not_impl<MatchingStyle::Wildcard>(m_compCtx, ctx);
        }
 
        GAIA_NODISCARD bool op_not_complex(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_not);
          return detail::exec_not_impl<MatchingStyle::Complex>(m_compCtx, ctx);
        }
 
        GAIA_NODISCARD bool op_seed_all(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_seed_all);
          detail::add_all_archetypes(ctx);
          return true;
        }
 
        GAIA_NODISCARD bool op_var_filter(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_var_filter);
          GAIA_ASSERT(!m_compCtx.var_programs.empty());
          filter_variable_terms(ctx, &VirtualMachine::eval_variable_terms_program_on_archetype);
          return true;
        }
 
        GAIA_NODISCARD bool op_src_all_term(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_src_all);
          const auto& termOp = detail::get_src_term_op(m_compCtx, ctx, m_compCtx.terms_all_src);
          return detail::match_src_term(*ctx.pWorld, termOp.term, termOp.opcode);
        }
 
        GAIA_NODISCARD bool op_src_not_term(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_src_not);
          const auto& termOp = detail::get_src_term_op(m_compCtx, ctx, m_compCtx.terms_not_src);
          return !detail::match_src_term(*ctx.pWorld, termOp.term, termOp.opcode);
        }
 
        GAIA_NODISCARD bool op_src_or_term(MatchingCtx& ctx) const {
          GAIA_PROF_SCOPE(vm::op_src_or);
          const auto& termOp = detail::get_src_term_op(m_compCtx, ctx, m_compCtx.terms_or_src);
          const bool matched = detail::match_src_term(*ctx.pWorld, termOp.term, termOp.opcode);
          if (!matched)
            return false;
 
          ctx.skipOr = true;
          if (m_compCtx.ids_all.empty())
            detail::add_all_archetypes(ctx);
          return true;
        }
 
        static constexpr OpcodeFunc OpcodeFuncs[] = {
            &VirtualMachine::op_all_simple, //
            &VirtualMachine::op_all_wildcard, //
            &VirtualMachine::op_all_complex, //
            &VirtualMachine::op_or_noall_simple, //
            &VirtualMachine::op_or_noall_wildcard, //
            &VirtualMachine::op_or_noall_complex, //
            &VirtualMachine::op_or_withall_simple, //
            &VirtualMachine::op_or_withall_wildcard, //
            &VirtualMachine::op_or_withall_complex, //
            &VirtualMachine::op_not_simple, //
            &VirtualMachine::op_not_wildcard, //
            &VirtualMachine::op_not_complex, //
            &VirtualMachine::op_seed_all, //
            &VirtualMachine::op_var_filter, //
            &VirtualMachine::op_src_all_term, //
            &VirtualMachine::op_src_not_term, //
            &VirtualMachine::op_src_or_term //
        };
        static_assert(
            sizeof(OpcodeFuncs) / sizeof(OpcodeFuncs[0]) == (uint32_t)detail::EOpcode::Src_Never,
            "OpcodeFuncs must contain all executable opcodes.");
 
        GAIA_NODISCARD bool exec_opcode(const detail::CompiledOp& stackItem, MatchingCtx& ctx) const {
          const auto opcodeIdx = (uint32_t)stackItem.opcode;
          GAIA_ASSERT(opcodeIdx < (uint32_t)detail::EOpcode::Src_Never);
          return (this->*OpcodeFuncs[opcodeIdx])(ctx);
        }
 
      public:
        GAIA_NODISCARD util::str bytecode(const World& world) const {
          util::str out;
          out.reserve(2048);
 
          out.append("main_ops: ");
          add_uint(out, (uint32_t)m_compCtx.mainOpsCount);
          out.append('\n');
 
          const auto opsCnt = (uint32_t)m_compCtx.mainOpsCount;
          GAIA_FOR(opsCnt) {
            const auto& op = m_compCtx.ops[i];
            out.append("  [");
            add_uint(out, i);
            out.append("] ");
            add_cstr(out, opcode_name(op.opcode));
            if (opcode_has_arg(op.opcode)) {
              out.append(" arg=");
              add_uint(out, op.arg);
            }
            out.append(" ok=");
            add_uint(out, op.pc_ok);
            out.append(" fail=");
            add_uint(out, op.pc_fail);
            out.append('\n');
          }
 
          add_ids_section(
              out, "ids_all", std::span<const Entity>{m_compCtx.ids_all.data(), m_compCtx.ids_all.size()}, world);
          add_ids_section(
              out, "ids_or", std::span<const Entity>{m_compCtx.ids_or.data(), m_compCtx.ids_or.size()}, world);
          add_ids_section(
              out, "ids_not", std::span<const Entity>{m_compCtx.ids_not.data(), m_compCtx.ids_not.size()}, world);
 
          add_src_terms_section(out, "src_all", m_compCtx.terms_all_src, world);
          add_src_terms_section(out, "src_or", m_compCtx.terms_or_src, world);
          add_src_terms_section(out, "src_not", m_compCtx.terms_not_src, world);
 
          add_var_terms_section(out, "var_all", m_compCtx.terms_all_var, world);
          add_var_terms_section(out, "var_or", m_compCtx.terms_or_var, world);
          add_var_terms_section(out, "var_not", m_compCtx.terms_not_var, world);
          add_var_terms_section(out, "var_any", m_compCtx.terms_any_var, world);
          add_var_program_exec_section(out, m_compCtx);
          add_var_program_sections(out, m_compCtx, world);
 
          return out;
        }
 
        void compile(
            const EntityToArchetypeMap& entityToArchetypeMap, std::span<const Archetype*> allArchetypes,
            QueryCtx& queryCtx) {
          GAIA_PROF_SCOPE(vm::compile);
          (void)entityToArchetypeMap;
          (void)allArchetypes;
 
          m_compCtx.ids_all.clear();
          m_compCtx.ids_or.clear();
          m_compCtx.ids_not.clear();
          m_compCtx.terms_all_src.clear();
          m_compCtx.terms_or_src.clear();
          m_compCtx.terms_not_src.clear();
          m_compCtx.terms_all_var.clear();
          m_compCtx.terms_or_var.clear();
          m_compCtx.terms_not_var.clear();
          m_compCtx.terms_any_var.clear();
          m_compCtx.varMaskAll = 0;
          m_compCtx.varMaskOr = 0;
          m_compCtx.varMaskNot = 0;
          m_compCtx.varMaskAny = 0;
          m_compCtx.var_programs.clear();
          m_compCtx.mainOpsCount = 0;
          m_compCtx.ops.clear();
 
          auto& data = queryCtx.data;
          GAIA_ASSERT(queryCtx.w != nullptr);
          const auto& world = *queryCtx.w;
          const bool hasEntityFilterTerms = data.deps.has_dep_flag(QueryCtx::DependencyHasEntityFilterTerms);
          auto isNonFragmentingDirectTerm = [&](const QueryTerm& term) {
            if (term.src != EntityBad || term.entTrav != EntityBad || term_has_variables(term))
              return false;
 
            const auto id = term.id;
            return (id.pair() && world_relation_uses_non_fragmenting_storage(world, pair_rel(world, id))) ||
                   (!id.pair() && world_component_is_non_fragmenting(world, id));
          };
 
          QueryTermSpan terms = data.terms_view_mut();
          QueryTermSpan terms_all = terms.subspan(0, data.firstOr);
          QueryTermSpan terms_or = terms.subspan(data.firstOr, data.firstNot - data.firstOr);
          QueryTermSpan terms_not = terms.subspan(data.firstNot, data.firstAny - data.firstNot);
          QueryTermSpan terms_any = terms.subspan(data.firstAny);
 
          // ALL
          if (!terms_all.empty()) {
            GAIA_PROF_SCOPE(vm::compile_all);
 
            const auto cnt = terms_all.size();
            GAIA_FOR(cnt) {
              auto& p = terms_all[i];
              if (isNonFragmentingDirectTerm(p))
                continue;
              if (term_has_variables(p)) {
                const auto varMask = term_unbound_var_mask(world, p, detail::VarBindings{});
                m_compCtx.terms_all_var.push_back({detail::src_opcode_from_term(p), p, varMask});
                m_compCtx.varMaskAll |= varMask;
                continue;
              }
 
              if (p.src == EntityBad) {
                m_compCtx.ids_all.push_back(p.id);
                continue;
              }
              m_compCtx.terms_all_src.push_back({detail::src_opcode_from_term(p), p});
            }
          }
 
          // OR
          if (!terms_or.empty()) {
            GAIA_PROF_SCOPE(vm::compile_or);
 
            const auto cnt = terms_or.size();
            GAIA_FOR(cnt) {
              auto& p = terms_or[i];
              if (p.src == EntityBad && hasEntityFilterTerms)
                continue;
              if (term_has_variables(p)) {
                const auto varMask = term_unbound_var_mask(world, p, detail::VarBindings{});
                m_compCtx.terms_or_var.push_back({detail::src_opcode_from_term(p), p, varMask});
                m_compCtx.varMaskOr |= varMask;
                continue;
              }
 
              if (p.src == EntityBad)
                m_compCtx.ids_or.push_back(p.id);
              else
                m_compCtx.terms_or_src.push_back({detail::src_opcode_from_term(p), p});
            }
          }
 
          // NOT
          if (!terms_not.empty()) {
            GAIA_PROF_SCOPE(vm::compile_not);
 
            const auto cnt = terms_not.size();
            GAIA_FOR(cnt) {
              auto& p = terms_not[i];
              if (isNonFragmentingDirectTerm(p))
                continue;
              if (term_has_variables(p)) {
                const auto varMask = term_unbound_var_mask(world, p, detail::VarBindings{});
                m_compCtx.terms_not_var.push_back({detail::src_opcode_from_term(p), p, varMask});
                m_compCtx.varMaskNot |= varMask;
                continue;
              }
 
              if (p.src == EntityBad)
                m_compCtx.ids_not.push_back(p.id);
              else
                m_compCtx.terms_not_src.push_back({detail::src_opcode_from_term(p), p});
            }
          }
 
          // ANY
          if (!terms_any.empty()) {
            GAIA_PROF_SCOPE(vm::compile_any);
 
            const auto cnt = terms_any.size();
            GAIA_FOR(cnt) {
              auto& p = terms_any[i];
              if (!term_has_variables(p))
                continue;
              const auto varMask = term_unbound_var_mask(world, p, detail::VarBindings{});
              m_compCtx.terms_any_var.push_back({detail::src_opcode_from_term(p), p, varMask});
              m_compCtx.varMaskAny |= varMask;
            }
          }
 
          detail::sort_src_terms_by_cost(m_compCtx.terms_all_src);
          detail::sort_src_terms_by_cost(m_compCtx.terms_or_src);
          detail::sort_src_terms_by_cost(m_compCtx.terms_not_src);
 
          constexpr uint32_t VarSearchProgramOpCapacity = MAX_ITEMS_IN_QUERY * 3u + 8u;
          cnt::sarray_ext<detail::CompiledOp, VarSearchProgramOpCapacity> varSearchProgramOps;
          detail::QueryCompileCtx::VarSearchMeta varSearchMeta{};
 
          auto init_var_search_program = [&]() {
            varSearchProgramOps.clear();
            varSearchMeta = {};
            cnt::sarray_ext<detail::CompiledOp, MAX_ITEMS_IN_QUERY> searchAllBindOps;
            cnt::sarray_ext<detail::CompiledOp, MAX_ITEMS_IN_QUERY> searchAllCheckOps;
            cnt::sarray_ext<detail::CompiledOp, MAX_ITEMS_IN_QUERY> searchOrBindOps;
            cnt::sarray_ext<detail::CompiledOp, MAX_ITEMS_IN_QUERY> searchOrCheckOps;
            cnt::sarray_ext<detail::CompiledOp, MAX_ITEMS_IN_QUERY> searchAnyBindOps;
            cnt::sarray_ext<detail::CompiledOp, MAX_ITEMS_IN_QUERY> searchAnyCheckOps;
            cnt::sarray_ext<detail::CompiledOp, MAX_ITEMS_IN_QUERY> finalNotOps;
            cnt::sarray_ext<detail::CompiledOp, MAX_ITEMS_IN_QUERY> finalOrCheckOps;
 
            const auto allVarCnt = (uint32_t)m_compCtx.terms_all_var.size();
            GAIA_FOR(allVarCnt) {
              const auto cost = detail::search_term_cost(m_compCtx.terms_all_var[i]);
              const auto srcVarBit =
                  detail::is_var_entity(m_compCtx.terms_all_var[i].term.src)
                      ? (uint8_t)(uint8_t(1) << detail::var_index(m_compCtx.terms_all_var[i].term.src))
                      : 0;
              const auto canBindFromSelfSource =
                  m_compCtx.terms_all_var[i].sourceOpcode == detail::EOpcode::Src_Self &&
                  detail::is_var_entity(m_compCtx.terms_all_var[i].term.src) &&
                  m_compCtx.terms_all_var[i].varMask == srcVarBit &&
                  (uint8_t)(m_compCtx.terms_all_var[i].varMask & m_compCtx.varMaskAny) == 0;
              const auto canBindFromUpSource =
                  m_compCtx.terms_all_var[i].sourceOpcode == detail::EOpcode::Src_Up &&
                  detail::is_var_entity(m_compCtx.terms_all_var[i].term.src) &&
                  m_compCtx.terms_all_var[i].varMask == srcVarBit &&
                  (uint8_t)(m_compCtx.terms_all_var[i].varMask & m_compCtx.varMaskAny) == 0;
              const auto canBindFromDownSource =
                  m_compCtx.terms_all_var[i].sourceOpcode == detail::EOpcode::Src_Down &&
                  detail::is_var_entity(m_compCtx.terms_all_var[i].term.src) &&
                  m_compCtx.terms_all_var[i].varMask == srcVarBit &&
                  (uint8_t)(m_compCtx.terms_all_var[i].varMask & m_compCtx.varMaskAny) == 0;
              const auto canBindFromUpDownSource =
                  m_compCtx.terms_all_var[i].sourceOpcode == detail::EOpcode::Src_UpDown &&
                  detail::is_var_entity(m_compCtx.terms_all_var[i].term.src) &&
                  m_compCtx.terms_all_var[i].varMask == srcVarBit &&
                  (uint8_t)(m_compCtx.terms_all_var[i].varMask & m_compCtx.varMaskAny) == 0;
              const auto opcode =
                  canBindFromSelfSource || canBindFromUpSource || canBindFromDownSource || canBindFromUpDownSource
                      ? detail::EOpcode::Var_Term_All_Src_Bind
                      : detail::EOpcode::Var_Term_All_Bind;
              searchAllBindOps.push_back({opcode, 0, 0, (uint8_t)i, cost});
              searchAllCheckOps.push_back({detail::EOpcode::Var_Term_All_Check, 0, 0, (uint8_t)i, cost});
            }
            detail::sort_program_ops_by_cost(searchAllBindOps);
            detail::sort_program_ops_by_cost(searchAllCheckOps);
 
            const auto orVarCnt = (uint32_t)m_compCtx.terms_or_var.size();
            GAIA_FOR(orVarCnt) {
              const auto cost = detail::search_term_cost(m_compCtx.terms_or_var[i]);
              searchOrBindOps.push_back({detail::EOpcode::Var_Term_Or_Bind, 0, 0, (uint8_t)i, cost});
              searchOrCheckOps.push_back({detail::EOpcode::Var_Term_Or_Check, 0, 0, (uint8_t)i, cost});
              finalOrCheckOps.push_back({detail::EOpcode::Var_Final_Or_Check, 0, 0, (uint8_t)i, cost});
              varSearchMeta.orVarMask = (uint8_t)(varSearchMeta.orVarMask | m_compCtx.terms_or_var[i].varMask);
            }
            detail::sort_program_ops_by_cost(searchOrBindOps);
            detail::sort_program_ops_by_cost(searchOrCheckOps);
            detail::sort_program_ops_by_cost(finalOrCheckOps);
 
            const auto anyVarCnt = (uint32_t)m_compCtx.terms_any_var.size();
            GAIA_FOR(anyVarCnt) {
              const auto cost = detail::search_term_cost(m_compCtx.terms_any_var[i]);
              searchAnyBindOps.push_back({detail::EOpcode::Var_Term_Any_Bind, 0, 0, (uint8_t)i, cost});
              searchAnyCheckOps.push_back({detail::EOpcode::Var_Term_Any_Check, 0, 0, (uint8_t)i, cost});
            }
            detail::sort_program_ops_by_cost(searchAnyBindOps);
            detail::sort_program_ops_by_cost(searchAnyCheckOps);
 
            const auto notVarCnt = (uint32_t)m_compCtx.terms_not_var.size();
            GAIA_FOR(notVarCnt) {
              finalNotOps.push_back(
                  {detail::EOpcode::Var_Final_Not_Check, 0, 0, (uint8_t)i,
                   detail::search_term_cost(m_compCtx.terms_not_var[i])});
            }
            detail::sort_program_ops_by_cost(finalNotOps);
 
            for (const auto& op: searchAllBindOps)
              varSearchProgramOps.push_back(op);
            for (const auto& op: searchOrBindOps)
              varSearchProgramOps.push_back(op);
            for (const auto& op: searchAnyBindOps)
              varSearchProgramOps.push_back(op);
 
            varSearchMeta.allBegin = 0;
            varSearchMeta.allCount = (uint16_t)searchAllBindOps.size();
            varSearchMeta.orBegin = varSearchMeta.allCount;
            varSearchMeta.orCount = (uint16_t)searchOrBindOps.size();
            varSearchMeta.anyBegin = (uint16_t)(varSearchMeta.orBegin + varSearchMeta.orCount);
            varSearchMeta.anyCount = (uint16_t)searchAnyBindOps.size();
            varSearchMeta.notBegin = 0;
            varSearchMeta.notCount = 0;
 
            const auto termOpsCnt = (uint16_t)varSearchProgramOps.size();
            const auto selectAllPc = termOpsCnt;
            const auto selectOrPc = (uint16_t)(termOpsCnt + 1u);
            const auto selectOtherOrPc = (uint16_t)(termOpsCnt + 2u);
            const auto selectOtherOrBindPc = (uint16_t)(termOpsCnt + 3u);
            const auto beginAnyPc = (uint16_t)(termOpsCnt + 4u);
            const auto selectAnyPc = (uint16_t)(termOpsCnt + 5u);
            const auto maybeFinalizePc = (uint16_t)(termOpsCnt + 6u);
            const auto allCheckBegin = (uint16_t)(termOpsCnt + 7u);
            const auto orCheckBegin = (uint16_t)(allCheckBegin + searchAllCheckOps.size());
            const auto anyCheckBegin = (uint16_t)(orCheckBegin + searchOrCheckOps.size());
            const auto finalNotBegin = (uint16_t)(anyCheckBegin + searchAnyCheckOps.size());
            const auto finalRequireOrPc = (uint16_t)(finalNotBegin + finalNotOps.size());
            const auto finalOrCheckBegin = (uint16_t)(finalRequireOrPc + 1u);
            const auto finalSuccessPc = (uint16_t)(finalOrCheckBegin + finalOrCheckOps.size());
            const auto finalBegin = !finalNotOps.empty() ? finalNotBegin : finalRequireOrPc;
            const auto backtrackPc = (detail::VmLabel)-1;
 
            for (auto& op: varSearchProgramOps) {
              switch (op.opcode) {
                case detail::EOpcode::Var_Term_All_Bind:
                case detail::EOpcode::Var_Term_All_Src_Bind:
                  op.pc_ok = selectAllPc;
                  op.pc_fail = backtrackPc;
                  break;
                case detail::EOpcode::Var_Term_Or_Bind:
                  op.pc_ok = selectAllPc;
                  op.pc_fail = selectOtherOrBindPc;
                  break;
                case detail::EOpcode::Var_Term_Any_Bind:
                  op.pc_ok = selectAllPc;
                  op.pc_fail = maybeFinalizePc;
                  break;
                default:
                  break;
              }
            }
 
            varSearchProgramOps.push_back({detail::EOpcode::Var_Search_SelectAll, selectAllPc, selectOrPc, 0, 0});
            varSearchProgramOps.push_back({detail::EOpcode::Var_Search_SelectOr, selectOrPc, selectOtherOrPc, 0, 0});
            varSearchProgramOps.push_back(
                {detail::EOpcode::Var_Search_SelectOtherOr, selectOtherOrPc, selectOtherOrBindPc, 0, 0});
            varSearchProgramOps.push_back(
                {detail::EOpcode::Var_Search_SelectOtherOrBind, selectOtherOrBindPc, beginAnyPc, 0, 0});
            varSearchProgramOps.push_back({detail::EOpcode::Var_Search_BeginAny, selectAnyPc, backtrackPc, 0, 0});
            varSearchProgramOps.push_back({detail::EOpcode::Var_Search_SelectAny, selectAnyPc, maybeFinalizePc, 0, 0});
            varSearchProgramOps.push_back({detail::EOpcode::Var_Search_MaybeFinalize, finalBegin, backtrackPc, 0, 0});
            for (auto op: searchAllCheckOps) {
              op.pc_ok = selectAllPc;
              op.pc_fail = backtrackPc;
              varSearchProgramOps.push_back(op);
            }
            for (auto op: searchOrCheckOps) {
              op.pc_ok = selectAllPc;
              op.pc_fail = selectOtherOrBindPc;
              varSearchProgramOps.push_back(op);
            }
            for (auto op: searchAnyCheckOps) {
              op.pc_ok = selectAllPc;
              op.pc_fail = maybeFinalizePc;
              varSearchProgramOps.push_back(op);
            }
            for (uint32_t i = 0; i < finalNotOps.size(); ++i) {
              auto op = finalNotOps[i];
              op.pc_ok = (i + 1u < finalNotOps.size()) ? (uint16_t)(finalNotBegin + i + 1u) : finalRequireOrPc;
              op.pc_fail = backtrackPc;
              varSearchProgramOps.push_back(op);
            }
            varSearchProgramOps.push_back(
                {detail::EOpcode::Var_Final_Require_Or, finalSuccessPc,
                 searchOrCheckOps.empty() ? backtrackPc : finalOrCheckBegin, 0, 0});
            for (uint32_t i = 0; i < finalOrCheckOps.size(); ++i) {
              auto op = finalOrCheckOps[i];
              op.pc_ok = finalSuccessPc;
              op.pc_fail = (i + 1u < finalOrCheckOps.size()) ? (uint16_t)(finalOrCheckBegin + i + 1u) : backtrackPc;
              varSearchProgramOps.push_back(op);
            }
            varSearchProgramOps.push_back({detail::EOpcode::Var_Final_Success, finalSuccessPc, backtrackPc, 0, 0});
 
            varSearchMeta.selectAllPc = selectAllPc;
            varSearchMeta.selectOrPc = selectOrPc;
            varSearchMeta.selectOtherOrPc = selectOtherOrPc;
            varSearchMeta.selectOtherOrBindPc = selectOtherOrBindPc;
            varSearchMeta.beginAnyPc = beginAnyPc;
            varSearchMeta.selectAnyPc = selectAnyPc;
            varSearchMeta.maybeFinalizePc = maybeFinalizePc;
            varSearchMeta.allCheckBegin = allCheckBegin;
            varSearchMeta.orCheckBegin = orCheckBegin;
            varSearchMeta.anyCheckBegin = anyCheckBegin;
            varSearchMeta.notBegin = finalNotBegin;
            varSearchMeta.notCount = (uint16_t)finalNotOps.size();
 
            auto init_mask = [](uint16_t begin, uint16_t count) {
              uint16_t mask = 0;
              for (uint16_t i = 0; i < count; ++i)
                mask = (uint16_t)(mask | (uint16_t(1) << (begin + i)));
              return mask;
            };
 
            varSearchMeta.initialAllMask = init_mask(varSearchMeta.allBegin, varSearchMeta.allCount);
            varSearchMeta.initialOrMask = init_mask(0, varSearchMeta.orCount);
            varSearchMeta.initialAnyMask = init_mask(0, varSearchMeta.anyCount);
          };
 
          create_opcodes(queryCtx);
 
          init_var_search_program();
 
          auto emit_flat_program = [&](std::span<const detail::CompiledOp> ops) {
            detail::QueryCompileCtx::VarProgram program{};
            program.clear();
            if (ops.empty())
              return program;
 
            GAIA_ASSERT(m_compCtx.ops.size() <= UINT16_MAX);
            program.begin = (uint16_t)m_compCtx.ops.size();
            program.count = (uint16_t)ops.size();
            for (const auto& op: ops)
              m_compCtx.ops.push_back(op);
            return program;
          };
 
          m_compCtx.var_programs.clear();
          if (m_compCtx.has_variable_terms()) {
            const auto program = emit_flat_program(
                std::span<const detail::CompiledOp>{varSearchProgramOps.data(), varSearchProgramOps.size()});
            if (!program.empty())
              m_compCtx.var_programs.push_back({program, varSearchMeta});
          }
        }
 
        void create_opcodes(QueryCtx& queryCtx) {
          const bool isSimple = (queryCtx.data.flags & QueryCtx::QueryFlags::Complex) == 0U;
          const bool isAs = (queryCtx.data.as_mask_0 + queryCtx.data.as_mask_1) != 0U;
          cnt::darray_ext<detail::CompiledOp, 32> preservedVarOps;
          uint16_t preservedProgramBase = 0;
          cnt::sarray_ext<uint16_t, MaxVarCnt> preservedProgramOffsets;
          preservedProgramOffsets.clear();
 
          if (!m_compCtx.var_programs.empty()) {
            preservedProgramBase = m_compCtx.var_programs[0].program.begin;
            GAIA_ASSERT(preservedProgramBase <= m_compCtx.ops.size());
            const auto preservedCnt = (uint32_t)m_compCtx.ops.size() - (uint32_t)preservedProgramBase;
            preservedVarOps.reserve(preservedCnt);
            for (uint32_t i = 0; i < preservedCnt; ++i)
              preservedVarOps.push_back(m_compCtx.ops[(uint32_t)preservedProgramBase + i]);
 
            for (const auto& step: m_compCtx.var_programs) {
              GAIA_ASSERT(step.program.begin >= preservedProgramBase);
              preservedProgramOffsets.push_back((uint16_t)(step.program.begin - preservedProgramBase));
            }
          }
 
          m_compCtx.ops.clear();
 
          // Source ALL terms: all must match, each is a dedicated gate opcode.
          if (!m_compCtx.terms_all_src.empty())
            emit_src_gate_terms(m_compCtx.terms_all_src, detail::EOpcode::Src_AllTerm);
 
          // Source NOT terms: none can match, each is a dedicated gate opcode.
          if (!m_compCtx.terms_not_src.empty())
            emit_src_gate_terms(m_compCtx.terms_not_src, detail::EOpcode::Src_NotTerm);
 
          // Source OR terms: emit a fallback chain that backtracks across alternatives.
          if (!m_compCtx.terms_or_src.empty()) {
            const bool hasOrFallback = !m_compCtx.ids_or.empty() || !m_compCtx.terms_or_var.empty();
            emit_src_or_terms(hasOrFallback);
          }
 
          // Queries without direct id terms seed from all archetypes via explicit bytecode.
          if (!m_compCtx.has_id_terms() &&
              (m_compCtx.has_src_terms() || m_compCtx.has_variable_terms() ||
               queryCtx.data.deps.has_dep_flag(QueryCtx::DependencyHasEntityFilterTerms))) {
            detail::CompiledOp op{};
            op.opcode = detail::EOpcode::Seed_All;
            (void)add_op(GAIA_MOV(op));
          }
 
          // ALL
          if (!m_compCtx.ids_all.empty()) {
            detail::CompiledOp op{};
            op.opcode = pick_all_opcode(isSimple, isAs);
            (void)add_gate_op(GAIA_MOV(op));
          }
 
          // OR
          if (!m_compCtx.ids_or.empty()) {
            detail::CompiledOp op{};
            op.opcode = pick_or_opcode(!m_compCtx.ids_all.empty(), isSimple, isAs);
            (void)add_op(GAIA_MOV(op));
          }
 
          // NOT
          if (!m_compCtx.ids_not.empty()) {
            detail::CompiledOp op{};
            op.opcode = pick_not_opcode(isSimple, isAs);
            (void)add_op(GAIA_MOV(op));
          }
 
          // Variable term evaluation is part of the VM stream.
          if (m_compCtx.has_variable_terms()) {
            detail::CompiledOp op{};
            op.opcode = detail::EOpcode::Var_Filter;
            (void)add_gate_op(GAIA_MOV(op));
          }
 
          m_compCtx.mainOpsCount = (uint16_t)m_compCtx.ops.size();
 
          if (!preservedVarOps.empty()) {
            const auto newProgramBase = (uint16_t)m_compCtx.ops.size();
            for (const auto& op: preservedVarOps)
              m_compCtx.ops.push_back(op);
 
            GAIA_ASSERT(preservedProgramOffsets.size() == m_compCtx.var_programs.size());
            const auto programCnt = (uint32_t)m_compCtx.var_programs.size();
            GAIA_FOR(programCnt)
            m_compCtx.var_programs[i].program.begin = (uint16_t)(newProgramBase + preservedProgramOffsets[i]);
          }
 
          // Mark as compiled
          queryCtx.data.flags &= ~QueryCtx::QueryFlags::Recompile;
        }
 
        GAIA_NODISCARD bool is_compiled() const {
          return !m_compCtx.ops.empty();
        }
 
        GAIA_NODISCARD uint32_t op_count() const {
          return (uint32_t)m_compCtx.ops.size();
        }
 
        GAIA_NODISCARD uint64_t op_signature() const {
          uint64_t hash = 1469598103934665603ull;
          for (const auto& op: m_compCtx.ops) {
            const uint64_t packed = //
                (uint64_t)(uint8_t)op.opcode | //
                ((uint64_t)op.pc_ok << 8u) | //
                ((uint64_t)op.pc_fail << 24u) | //
                ((uint64_t)op.arg << 40u) | //
                ((uint64_t)op.cost << 48u);
            hash ^= packed;
            hash *= 1099511628211ull;
          }
          return hash;
        }
 
        void exec(MatchingCtx& ctx) {
          GAIA_PROF_SCOPE(vm::exec);
          ctx.skipOr = false;
          if (m_compCtx.mainOpsCount == 0)
            return;
 
          ctx.pc = 0;
 
          // Extract data from the buffer
          do {
            auto& stackItem = m_compCtx.ops[ctx.pc];
            GAIA_ASSERT((uint32_t)stackItem.opcode < (uint32_t)detail::EOpcode::Src_Never);
            const bool ret = exec_opcode(stackItem, ctx);
            ctx.pc = ret ? stackItem.pc_ok : stackItem.pc_fail;
          } while (ctx.pc < m_compCtx.mainOpsCount); // (uint32_t)-1 falls in this category as well
        }
      };
 
    } // namespace vm
  } // namespace ecs
 
} // namespace gaia