Agent KB_modules_p7

Subsystem: modules (page 7 of 14)

Previous: KB_modules_p6.md

modules/lazy_loop.py

• Doc: Lazy autonomous loop for LazyOwn.
• Layer: utility
• Language: py
• Symbols:
  • plausible_command (function, line 150) def plausible_command(command)
  • _sudo_unavailable (function, line 236) def _sudo_unavailable(output)
  • _is_ip_literal (function, line 242) def _is_ip_literal(value)
  • _host_from_token (function, line 253) def _host_from_token(token)
  • loop_exiting (function, line 305) def loop_exiting()
  • _register_loop_executor (function, line 310) def _register_loop_executor(executor)
  • _unregister_loop_executor (function, line 316) def _unregister_loop_executor(executor)
  • arm_exit_watchdog (function, line 322) def arm_exit_watchdog(seconds)
  • scrub_secrets (function, line 363) def scrub_secrets(text)
  • _restrict_file (function, line 387) def _restrict_file(path)
  • _channel_encryption_key (function, line 395) def _channel_encryption_key()
  • _encrypt_channel_secret (function, line 411) def _encrypt_channel_secret(plaintext)
  • _decrypt_channel_secret (function, line 449) def _decrypt_channel_secret(stored)
  • wake_task (function, line 467) def wake_task(task_id)
  • _wake_event (function, line 481) def _wake_event(task_id)
  • _drop_wake_event (function, line 491) def _drop_wake_event(task_id)
  • register_worker (function, line 501) def register_worker(worker)
  • unregister_worker (function, line 507) def unregister_worker(worker)
  • shutdown_loop_runtime (function, line 513) def shutdown_loop_runtime(reason)
  • _noa_enabled (function, line 599) def _noa_enabled()
  • _now (function, line 641) def _now()
  • _store_path (function, line 646) def _store_path(name)
  • _load_json (function, line 659) def _load_json(path, default)
  • _save_json (function, line 669) def _save_json(path, payload)
  • _slug (function, line 684) def _slug(value)
  • _traffic_template (function, line 689) def _traffic_template(command)
  • _llm_error_reply (function, line 699) def _llm_error_reply(text)
  • _llm_quota_reply (function, line 707) def _llm_quota_reply(text)
  • task_llm_chain (function, line 728) def task_llm_chain(store, task_id)
  • parse_judge_output (function, line 738) def parse_judge_output(raw)
  • judge_command (function, line 766) def judge_command(command, background, fail_action)
  • ExplorationNode (class, line 808) class ExplorationNode
  • ExplorationEdge (class, line 822) class ExplorationEdge
  • AssetNode (class, line 831) class AssetNode
  • LazyTask (class, line 845) class LazyTask
  • AssetGraph (class, line 856) class AssetGraph
  • ExplorationGraph (class, line 1019) class ExplorationGraph
  • Frontier (class, line 1299) class Frontier
  • ActivityLog (class, line 1327) class ActivityLog
  • TrafficLog (class, line 1460) class TrafficLog
  • Guard (class, line 1718) class Guard
  • _scope_host (function, line 1926) def _scope_host(value)
  • _scope_covers (function, line 1936) def _scope_covers(scope_kind, scope_value, asset)
  • _target_as_asset (function, line 1986) def _target_as_asset(value)
  • _asset_candidates (function, line 2003) def _asset_candidates(target)
  • _match_gate_rule (function, line 2024) def _match_gate_rule(rule, target)
  • AssetGate (class, line 2059) class AssetGate
  • Budget (class, line 2153) class Budget
  • RuntimeTracker (class, line 2237) class RuntimeTracker
  • InterceptQueue (class, line 2305) class InterceptQueue
  • TodoStore (class, line 2465) class TodoStore
  • TaskStore (class, line 2507) class TaskStore
  • extract_scope_items (function, line 2780) def extract_scope_items(goal_text, description)
  • extract_constraint_items (function, line 2812) def extract_constraint_items(goal_text, description)
  • load_intel_scores (function, line 2840) def load_intel_scores()
  • resolve_target (function, line 2855) def resolve_target(task_id, store, graph)
  • decompose_goals (function, line 2878) def decompose_goals(goal_text, description)
  • enrich_asset (function, line 2915) def enrich_asset(value)
  • Planner (class, line 2938) class Planner
  • Worker (class, line 3378) class Worker
  • Retester (class, line 5073) class Retester
  • ColdCompactor (class, line 5166) class ColdCompactor
  • constraint_block (function, line 5735) def constraint_block(constraints, scope)
  • settlement_prompt (function, line 5769) def settlement_prompt(agent, reason)
  • build_prompt_context (function, line 5792) def build_prompt_context(task_id, graph, assets, store, budget, top)
  • _mask_prompt_context (function, line 5863) def _mask_prompt_context(text)
  • finding_severity (function, line 5873) def finding_severity(text, evidence)
  • FindingService (class, line 5887) class FindingService
  • EvidenceStore (class, line 6137) class EvidenceStore
  • Notifier (class, line 6240) class Notifier
  • TriggerStore (class, line 6406) class TriggerStore
  • LlmPool (class, line 6555) class LlmPool
  • ToolCatalog (class, line 6975) class ToolCatalog
  • SideQuestions (class, line 7019) class SideQuestions
  • CompanyScope (class, line 7093) class CompanyScope
  • TaskArchive (class, line 7123) class TaskArchive
  • TaskTemplate (class, line 7242) class TaskTemplate
  • TaskCategory (class, line 7285) class TaskCategory
  • TaskChat (class, line 7312) class TaskChat
  • LazyLoopEngine (class, line 7417) class LazyLoopEngine
  • _kill (function, line 332) def _kill()
  • _mask_key (function, line 372) def _mask_key(match)
  • __init__ (method, line 859) def __init__(self)
  • _persist (method, line 873) def _persist(self)
  • dedupe_key (method, line 877) def dedupe_key(self, kind, value, parent_id)
  • insert (method, line 881) def insert(self, kind, value, parent_id, meta, task_id)
  • get (method, line 911) def get(self, asset_id)
  • list (method, line 915) def list(self, kind)
  • mark_tested (method, line 922) def mark_tested(self, asset_id)
  • coverage (method, line 932) def coverage(self, scope)
  • scoped (method, line 948) def scoped(self, scope, kind)
  • untested (method, line 961) def untested(self, limit)
  • coverage_for (method, line 966) def coverage_for(self, graph, scope)
  • untested_for (method, line 994) def untested_for(self, graph, scope, limit)
  • __init__ (method, line 1022) def __init__(self, task_id)
  • _persist (method, line 1044) def _persist(self)
  • add_node (method, line 1056) def add_node(self, kind, text, state, priority, meta)
  • get (method, line 1084) def get(self, node_id)
  • set_state (method, line 1088) def set_state(self, node_id, state)
  • add_edge (method, line 1099) def add_edge(self, src, dst, kind)
  • anchor (method, line 1112) def anchor(self, node_id, asset_id)
  • anchors_for (method, line 1123) def anchors_for(self, node_id)
  • anchored_nodes (method, line 1127) def anchored_nodes(self, asset_id)
  • list (method, line 1131) def list(self, kind, state)
  • children (method, line 1140) def children(self, node_id, kind)
  • parents (method, line 1147) def parents(self, node_id, kind)
  • overview (method, line 1154) def overview(self)
  • reload (method, line 1177) def reload(self)
  • compare_and_claim (method, line 1201) def compare_and_claim(self, node_id)
  • finding_signature (method, line 1229) def finding_signature(self, text)
  • has_finding (method, line 1235) def has_finding(self, text)
  • node_detail (method, line 1245) def node_detail(self, node_id)
  • list_facts (method, line 1261) def list_facts(self, query, limit, hot_full)
  • record_fact (method, line 1277) def record_fact(self, text, evidence, confidence, intent_id, asset_ids)
  • __init__ (method, line 1302) def __init__(self, graph)
  • pending (method, line 1307) def pending(self)
  • claim_next (method, line 1312) def claim_next(self)
  • __init__ (method, line 1330) def __init__(self, task_id)
  • emit (method, line 1335) def emit(self, worker, kind, text, intent_id, tool_use_id)
  • read (method, line 1360) def read(self, limit)
  • for_intent (method, line 1374) def for_intent(self, intent_id)
  • trace (method, line 1378) def trace(self, intent_id, query, step_id, limit)
  • search_all (method, line 1416) def search_all(self, query, limit)
  • search (method, line 1446) def search(self, query, exclude_intent)
  • __init__ (method, line 1463) def __init__(self, task_id)
  • record (method, line 1468) def record(self, kind, command, output, meta)
  • read (method, line 1490) def read(self, limit)
  • search (method, line 1504) def search(self, query, limit)
  • search_host (method, line 1515) def search_host(self, host, port, limit)
  • get (method, line 1543) def get(self, digest)
  • recorder_body (method, line 1550) def recorder_body(self, digest)
  • recorder_blob (method, line 1579) def recorder_blob(self, digest, part, offset, length)
  • templates (method, line 1610) def templates(self, limit)
  • by_template (method, line 1619) def by_template(self, template, limit)
  • bind (method, line 1624) def bind(self, finding_id, digest, graph, role, note)
  • _normalize_refs (method, line 1655) def _normalize_refs(raw)
  • evidence (method, line 1672) def evidence(self, finding_id, graph)
  • reorder_evidence (method, line 1681) def reorder_evidence(self, finding_id, digests, graph)
  • export (method, line 1695) def export(self, path, limit)
  • archive (method, line 1702) def archive(self, label)
  • clear (method, line 1708) def clear(self)
  • __init__ (method, line 1721) def __init__(self, task_id)
  • _persist (method, line 1740) def _persist(self)
  • add_rule (method, line 1747) def add_rule(self, pattern, action, reason, priority)
  • remove_rule (method, line 1758) def remove_rule(self, pattern)
  • set_judge (method, line 1767) def set_judge(self, enabled, fail_action)
  • check (method, line 1789) def check(self, tool, command, tool_use_id, source, intent_id)
  • audit (method, line 1841) def audit(self, limit, action, source, query)
  • lookup (method, line 1869) def lookup(self, tool_use_id)
  • stats (method, line 1911) def stats(self)
  • __init__ (method, line 2068) def __init__(self, task_id)
  • _load_global (method, line 2075) def _load_global(self)
  • _load_task (method, line 2079) def _load_task(self)
  • _save_global (method, line 2086) def _save_global(self, block)
  • _save_task (method, line 2090) def _save_task(self, payload)
  • add (method, line 2095) def add(self, kind, pattern, note, action)
  • remove (method, line 2116) def remove(self, rule_id, action)
  • list (method, line 2134) def list(self)
  • evaluate (method, line 2138) def evaluate(self, target)
  • __init__ (method, line 2156) def __init__(self, store)
  • limits (method, line 2160) def limits(self, task_id)
  • set_limits (method, line 2171) def set_limits(self, task_id)
  • usage (method, line 2184) def usage(self, task_id)
  • record_toolcall (method, line 2194) def record_toolcall(self, task_id, intent_id)
  • record_round (method, line 2206) def record_round(self, task_id)
  • check (method, line 2224) def check(self, task_id)
  • __init__ (method, line 2240) def __init__(self, store)
  • heartbeat (method, line 2244) def heartbeat(self, task_id)
  • beat (method, line 2262) def beat(self, task_id, workers)
  • abort (method, line 2277) def abort(self, task_id, cause, detail)
  • note_trigger (method, line 2293) def note_trigger(self, task_id, trigger_id)
  • _event_for (method, line 2312) def _event_for(cls, path, item_id)
  • _drop_event (method, line 2329) def _drop_event(cls, path, item_id)
  • __init__ (method, line 2334) def __init__(self, task_id)
  • _load (method, line 2340) def _load(self)
  • _save (method, line 2344) def _save(self, payload)
  • request (method, line 2348) def request(self, tool, command, reason, tool_use_id)
  • pending (method, line 2366) def pending(self)
  • history (method, line 2370) def history(self, page, per_page, states, query)
  • decide (method, line 2422) def decide(self, item_id, verdict)
  • wait (method, line 2436) def wait(self, item_id, timeout_sec)
  • __init__ (method, line 2468) def __init__(self, task_id)
  • _persist (method, line 2475) def _persist(self)
  • add (method, line 2479) def add(self, text)
  • complete (method, line 2486) def complete(self, item_id)
  • next_pending (method, line 2495) def next_pending(self)
  • as_list (method, line 2502) def as_list(self)
  • __init__ (method, line 2510) def __init__(self)
  • _persist (method, line 2515) def _persist(self)
  • create (method, line 2519) def create(self, goal, description)
  • get (method, line 2530) def get(self, task_id)
  • list (method, line 2534) def list(self)
  • set_status (method, line 2538) def set_status(self, task_id, status)
  • pause (method, line 2550) def pause(self, task_id)
  • resume (method, line 2554) def resume(self, task_id)
  • delete (method, line 2563) def delete(self, task_id)
  • active_count (method, line 2572) def active_count(self, exclude)
  • queue (method, line 2576) def queue(self)
  • enqueue (method, line 2581) def enqueue(self, task_id)
  • dequeue_next (method, line 2592) def dequeue_next(self)
  • _refresh (method, line 2603) def _refresh(self)
  • set_llm_chain (method, line 2607) def set_llm_chain(self, task_id, members, active)
  • llm_state (method, line 2635) def llm_state(self, task_id)
  • advance_llm (method, line 2641) def advance_llm(self, task_id)
  • set_skills (method, line 2665) def set_skills(self, task_id, names, auto)
  • set_deadline (method, line 2690) def set_deadline(self, task_id, timeout_sec)
  • expired (method, line 2700) def expired(self, task_id)
  • add_constraint (method, line 2706) def add_constraint(self, task_id, ctype, text, scope)
  • add_scope (method, line 2725) def add_scope(self, task_id, kind, value, reason)
  • steer (method, line 2736) def steer(self, task_id, intent_id, message)
  • kill (method, line 2745) def kill(self, task_id, intent_id)
  • steer_for (method, line 2756) def steer_for(self, task_id, intent_id)
  • clear_steer (method, line 2761) def clear_steer(self, task_id, intent_id)
  • killed (method, line 2774) def killed(self, task_id, intent_id)
  • __init__ (method, line 2941) def __init__(self, task_id, assets, graph, activity, store)
  • _constraints (method, line 2952) def _constraints(self)
  • _denied (method, line 2961) def _denied(self, text)
  • plan (method, line 2969) def plan(self, triggers)
  • refine (method, line 3048) def refine(self)
  • _origin_fact (method, line 3121) def _origin_fact(self)
  • _candidates (method, line 3130) def _candidates(self)
  • finalize (method, line 3264) def finalize(self, reason)
  • _delta_sink (method, line 3280) def _delta_sink(self)
  • _llm_candidates (method, line 3294) def _llm_candidates(self, existing)
  • _stall_intent (method, line 3352) def _stall_intent(self, existing)
  • __init__ (method, line 3381) def __init__(self, name, task_id, assets, graph, activity, traffic, guard, store, shell, ephemeral)
  • rebind (method, line 3426) def rebind(self, assets, graph, activity, traffic, guard, store, shell)
  • close (method, line 3450) def close(self)
  • _scope_allows_target (method, line 3461) def _scope_allows_target(self, target)
  • _prior_steps (method, line 3490) def _prior_steps(self, intent)
  • execute (method, line 3514) def execute(self, intent, executor, timeout_sec)
  • _finish (method, line 3712) def _finish(self, intent, outcome, transcripts, worker_tools, skipped_tools)
  • _target_for (method, line 3777) def _target_for(self, intent)
  • _guard_step (method, line 3785) def _guard_step(self, intent, command, executor, budget, intercept, retry_state)
  • _agent_checkpoint (method, line 3967) def _agent_checkpoint(self, intent)
  • _drain_steer (method, line 3982) def _drain_steer(self, intent)
  • _agent_preflight (method, line 3993) def _agent_preflight(self, intent, command)
  • _start_background_job (method, line 4026) def _start_background_job(self, command, intent, transcripts)
  • _open_shell_session (method, line 4058) def _open_shell_session(self, intent)
  • _send_shell (method, line 4093) def _send_shell(self, command, intent, timeout_sec)
  • _close_shell_session (method, line 4129) def _close_shell_session(self)
  • _agent_tools (method, line 4156) def _agent_tools(self, intent, executor, transcripts, budget, intercept, retry_state)
  • _agent_system_prompt (method, line 4337) def _agent_system_prompt(self, intent)
  • _agentic_try (method, line 4369) def _agentic_try(self, intent, outcome, transcripts, executor, budget, intercept, retry_state)
  • _denied (method, line 4467) def _denied(self, command)
  • _auto_approve (method, line 4478) def _auto_approve(self, command)
  • _missing_tool (method, line 4490) def _missing_tool(self, command)
  • _run (method, line 4506) def _run(self, command, executor)
  • _with_llm_steps (method, line 4556) def _with_llm_steps(self, intent, steps, prior_text)
  • _llm_steps (method, line 4567) def _llm_steps(self, intent, prior_text)
  • _settle_partial (method, line 4649) def _settle_partial(self, intent, transcripts, reason)
  • _delta_sink (method, line 4685) def _delta_sink(self, intent_id)
  • _resolved_command (method, line 4709) def _resolved_command(self, command)
  • _sudo_guard (method, line 4723) def _sudo_guard(self, intent, command)
  • _task_executed_commands (method, line 4750) def _task_executed_commands(self)
  • _sanitize_step (method, line 4773) def _sanitize_step(self, intent, command)
  • _command_in_scope (method, line 4827) def _command_in_scope(self, command)
  • _auto_bind_body_hits (method, line 4836) def _auto_bind_body_hits(self, finding, seed)
  • _steps_for (method, line 4888) def _steps_for(self, intent)
  • _writeback (method, line 4948) def _writeback(self, intent, transcripts, allow_finding)
  • __init__ (method, line 5076) def __init__(self, graph, activity, traffic)
  • retest (method, line 5082) def retest(self, finding_id, executor, note)
  • retest_context (method, line 5152) def retest_context(self, finding_id)
  • __init__ (method, line 5174) def __init__(self, graph, activity)
  • _cold_path (method, line 5179) def _cold_path(self)
  • _load_cold (method, line 5183) def _load_cold(self)
  • _save_cold (method, line 5187) def _save_cold(self, payload)
  • _bodies_path (method, line 5191) def _bodies_path(self)
  • _load_bodies (method, line 5195) def _load_bodies(self)
  • _save_bodies (method, line 5199) def _save_bodies(self, payload)
  • _request_bodies (method, line 5203) def _request_bodies(self, blocks, cold)
  • _noa_archive (method, line 5252) def _noa_archive(self, signature, members, anchors)
  • noa_archives (method, line 5284) def noa_archives(self, limit)
  • _apply_stored_bodies (method, line 5309) def _apply_stored_bodies(self, bodies)
  • _is_live_intent (method, line 5333) def _is_live_intent(self, node)
  • _foldable (method, line 5337) def _foldable(self, node)
  • hot_set (method, line 5343) def hot_set(self)
  • structural_cold (method, line 5365) def structural_cold(self, hot)
  • _content_versions (method, line 5369) def _content_versions(self)
  • _block_signature (method, line 5377) def _block_signature(self, members, anchors, versions)
  • _group (method, line 5386) def _group(self, eligible)
  • covered_members (method, line 5450) def covered_members(self)
  • on_planner_round (method, line 5462) def on_planner_round(self)
  • compact (method, line 5503) def compact(self, threshold, mode, debounce_sec)
  • expand (method, line 5630) def expand(self, digest_id, role)
  • cold_index (method, line 5654) def cold_index(self)
  • unfolded (method, line 5672) def unfolded(self, limit)
  • digest_overview (method, line 5688) def digest_overview(self)
  • __init__ (method, line 5890) def __init__(self, task_id, graph, activity, store)
  • report (method, line 5897) def report(self, name, summary, poc, severity, vulnclass, intent_id, asset_ids, traffic_refs)
  • _drafts_ready_path (method, line 5961) def _drafts_ready_path(self)
  • _draft_report (method, line 5965) def _draft_report(self, node)
  • _reporter_reply (method, line 6020) def _reporter_reply(self, pool, chain, entry)
  • _write_draft (method, line 6036) def _write_draft(self, finding_id, report, evidence_version)
  • apply_drafts (method, line 6054) def apply_drafts(self)
  • set_status (method, line 6091) def set_status(self, finding_id, status)
  • update_report (method, line 6108) def update_report(self, finding_id, report)
  • ranked (method, line 6130) def ranked(self)
  • __init__ (method, line 6140) def __init__(self, task_id)
  • _load (method, line 6145) def _load(self)
  • add (method, line 6149) def add(self, finding_id, kind, body)
  • verify (method, line 6166) def verify(self)
  • gc (method, line 6175) def gc(self, valid_findings)
  • for_finding (method, line 6191) def for_finding(self, finding_id)
  • read (method, line 6195) def read(self, evidence_id, offset, length)
  • export (method, line 6232) def export(self, path)
  • __init__ (method, line 6243) def __init__(self, store)
  • channels (method, line 6247) def channels(self)
  • add_channel (method, line 6255) def add_channel(self, kind, target, min_severity, extra)
  • remove_channel (method, line 6302) def remove_channel(self, index)
  • _send_email (method, line 6315) def _send_email(channel, line, event)
  • emit (method, line 6353) def emit(self, task_id, event, data)
  • __init__ (method, line 6409) def __init__(self, task_id)
  • _load (method, line 6414) def _load(self)
  • add (method, line 6418) def add(self, kind, arg, every_sec)
  • remove (method, line 6437) def remove(self, trigger_id)
  • list (method, line 6447) def list(self)
  • ensure_service_trigger (method, line 6451) def ensure_service_trigger(self)
  • due (method, line 6464) def due(self, task_id, graph, activity, assets, store)
  • __init__ (method, line 6572) def __init__(self)
  • _seed_defaults (method, line 6583) def _seed_defaults(self)
  • members (method, line 6607) def members(self)
  • add_member (method, line 6612) def add_member(self, name, model, priority)
  • remove_member (method, line 6621) def remove_member(self, name)
  • set_priority (method, line 6631) def set_priority(self, name, priority)
  • usage (method, line 6644) def usage(self)
  • _record (method, line 6648) def _record(self, member, ok, text)
  • _rotated_chain (method, line 6654) def _rotated_chain(self, chain)
  • _reorder_with_ai (method, line 6683) def _reorder_with_ai(self, chain, live_log)
  • _record_ai_outcome (method, line 6723) def _record_ai_outcome(self, member, ok, live_log)
  • complete (method, line 6736) def complete(self, prompt, max_tokens, empty_retries, members, task_id, on_delta)
  • health (method, line 6901) def health(self)
  • context_budget (method, line 6912) def context_budget(self)
  • record_raw (method, line 6917) def record_raw(self)
  • set_record_raw (method, line 6922) def set_record_raw(self, enabled)
  • raw_entries (method, line 6929) def raw_entries(self, limit)
  • _record_raw (method, line 6943) def _record_raw(self, member, prompt, reply, ok)
  • set_context_budget (method, line 6960) def set_context_budget(self, chars)
  • __init__ (method, line 6978) def __init__(self)
  • _load (method, line 6982) def _load(self)
  • bindings (method, line 6995) def bindings(self, agent)
  • bind (method, line 7000) def bind(self, agent, tool)
  • unbind (method, line 7009) def unbind(self, agent, tool)
  • ask (method, line 7029) def ask(self, task_id, question, pool, session)
  • history (method, line 7075) def history(self, task_id, session, limit)
  • sessions (method, line 7083) def sessions(self, task_id)
  • __init__ (method, line 7096) def __init__(self)
  • _load (method, line 7100) def _load(self)
  • add (method, line 7104) def add(self, name, scope)
  • list (method, line 7113) def list(self)
  • match (method, line 7117) def match(self, value)
  • save (method, line 7126) def save(self, task_id)
  • list (method, line 7147) def list(self)
  • restore (method, line 7169) def restore(self, path)
  • stats (method, line 7236) def stats(self)
  • __init__ (method, line 7245) def __init__(self)
  • _load (method, line 7249) def _load(self)
  • list (method, line 7253) def list(self)
  • add (method, line 7257) def add(self, name, goal)
  • remove (method, line 7267) def remove(self, name)
  • get (method, line 7277) def get(self, name)
  • __init__ (method, line 7288) def __init__(self, store)
  • set (method, line 7293) def set(self, task_id, category)
  • get (method, line 7300) def get(self, task_id)
  • list (method, line 7304) def list(self, category)
  • say (method, line 7319) def say(self, task_id, text, pool, session)
  • log (method, line 7362) def log(self, task_id, limit, session)
  • sessions (method, line 7378) def sessions(self, task_id)
  • clear (method, line 7387) def clear(self, task_id, session)
  • __init__ (method, line 7442) def __init__(self, shell)
  • bind_shell (method, line 7468) def bind_shell(self, shell)
  • ensure_target (method, line 7472) def ensure_target(self, task_id, target, reason)
  • orchestrate (method, line 7499) def orchestrate(self, goal, task_id, target, max_rounds, workers, timeout_sec, executor)
  • _parts (method, line 7522) def _parts(self, task_id)
  • create_task (method, line 7527) def create_task(self, goal, description)
  • spawn_task (method, line 7556) def spawn_task(self, goal, source_task_ids, description)
  • list_tasks (method, line 7606) def list_tasks(self)
  • pause_task (method, line 7634) def pause_task(self, task_id, reason)
  • resume_task (method, line 7645) def resume_task(self, task_id)
  • task_graph (method, line 7655) def task_graph(self, task_id)
  • task_findings (method, line 7661) def task_findings(self, task_id)
  • task_traces (method, line 7680) def task_traces(self, task_id, query, limit)
  • task_node_detail (method, line 7689) def task_node_detail(self, task_id, node_id)
  • update_finding_report (method, line 7695) def update_finding_report(self, task_id, finding_id, report)
  • broadcast_events (method, line 7707) def broadcast_events(self, task_id, cursor, batch)
  • add_hint (method, line 7740) def add_hint(self, task_id, text)
  • add_intent (method, line 7758) def add_intent(self, task_id, summary, asset_ids, parent_ids, priority)
  • set_goals (method, line 7783) def set_goals(self, task_id, specs)
  • edit_goal (method, line 7800) def edit_goal(self, task_id, goal_id, text)
  • delete_goal (method, line 7812) def delete_goal(self, task_id, goal_id)
  • preview_delete_intent (method, line 7823) def preview_delete_intent(self, task_id, intent_id)
  • delete_intent (method, line 7846) def delete_intent(self, task_id, intent_id, mode, reason)
  • _intent_subtree (method, line 7955) def _intent_subtree(self, graph, intent_id)
  • _split_exclusive (method, line 7970) def _split_exclusive(self, graph, reachable)
  • pause_intent (method, line 7991) def pause_intent(self, task_id, intent_id)
  • resume_intent (method, line 8016) def resume_intent(self, task_id, intent_id)
  • send_worker_message (method, line 8039) def send_worker_message(self, task_id, intent_id, message, request_id)
  • goal_met (method, line 8087) def goal_met(self, task_id, reason)
  • record_fact (method, line 8097) def record_fact(self, task_id, text, evidence, intent_id)
  • record_verdict (method, line 8104) def record_verdict(self, task_id, finding_id, verdict, note)
  • _sync_intel (method, line 8145) def _sync_intel(self, task_id, activity, force)
  • run_round (method, line 8189) def run_round(self, task_id, workers, executor, pool)
  • _drain_triggers (method, line 8438) def _drain_triggers(self, task_id, graph)
  • _auto_enrich (method, line 8487) def _auto_enrich(self, task_id, graph, activity, limit)
  • _auto_retest (method, line 8523) def _auto_retest(self, task_id, graph, activity, traffic, executor, limit)
  • _wrapup_summary (method, line 8543) def _wrapup_summary(self, task_id, reason)
  • _evaluate_goal (method, line 8578) def _evaluate_goal(self, task_id)
  • run (method, line 8666) def run(self, task_id, max_rounds, workers, executor, timeout_sec)
  • prove_goal (method, line 8849) def prove_goal(self, task_id, goal_id, evidence_id, reason)
  • _check_goals (method, line 8882) def _check_goals(self, task_id, graph, activity)
  • _goals_met (method, line 8889) def _goals_met(self, task_id)
  • delete_task (method, line 8895) def delete_task(self, task_id)
  • proxy_start (method, line 8929) def proxy_start(self, host, port, task_id, trust, upstream)
  • proxy_stop (method, line 8965) def proxy_stop(self)
  • proxy_status (method, line 8973) def proxy_status(self)
  • proxy_env (method, line 8979) def proxy_env(self)
  • set_concurrency (method, line 8988) def set_concurrency(self, limit)
  • _sync_c2_board (method, line 9000) def _sync_c2_board(self, task_ids)
  • admission_check (method, line 9009) def admission_check(self, task_id)
  • drain_queue (method, line 9028) def drain_queue(self, max_tasks)
  • ingest_proxy_traffic (method, line 9056) def ingest_proxy_traffic(self, task_id, limit)
  • search_proxy_body (method, line 9110) def search_proxy_body(self, task_id, query, limit)
  • _maybe_proxy_gc (method, line 9136) def _maybe_proxy_gc(self)
  • _maybe_import_inbox (method, line 9162) def _maybe_import_inbox(self)
  • _maybe_selfupdate_check (method, line 9182) def _maybe_selfupdate_check(self)
  • export_task_traffic (method, line 9202) def export_task_traffic(self, task_id)
  • export_evidence (method, line 9231) def export_evidence(self, task_id, dest)
  • export_findings_report (method, line 9290) def export_findings_report(self, task_id, path, fmt)
  • status (method, line 9386) def status(self, task_id)
  • graph_overview (method, line 9406) def graph_overview(self, task_id)
  • _finding_list (method, line 9439) def _finding_list(self, graph)
  • broadcast (method, line 9468) def broadcast(self, task_id, kinds, query, order, page, per_page, states)
  • _broadcast_row (method, line 9543) def _broadcast_row(self, graph, node)
  • loop_graph (method, line 9592) def loop_graph(self, task_id)
  • graph_context (method, line 9661) def graph_context(self, task_id, top)
  • _signature (function, line 3062) def _signature(text)
  • sink (function, line 3284) def sink(text)
  • _work (function, line 4038) def _work()
  • _reader (function, line 4080) def _reader()
  • run_command (function, line 4167) def run_command(command, background)
  • record_fact (function, line 4192) def record_fact(text)
  • report_finding (function, line 4201) def report_finding(name, evidence, severity)
  • traffic_search (function, line 4212) def traffic_search(query)
  • graph_state (function, line 4225) def graph_state()
  • shell_open (function, line 4240) def shell_open()
  • shell_send (function, line 4244) def shell_send(command)
  • job_status (function, line 4248) def job_status(job_id)
  • job_output (function, line 4256) def job_output(job_id)
  • sink (function, line 4694) def sink(text)
  • _worker (function, line 5224) def _worker(work)
  • _find (function, line 5398) def _find(value)
  • _union (function, line 5404) def _union(left, right)
  • _work (function, line 5999) def _work()
  • _run_one (function, line 8293) def _run_one(index_node)
  • stage_enabled (function, line 8240) def stage_enabled(_name)
  • _stage_enabled (function, line 8754) def _stage_enabled(_name)
• Depends on: core/config.py, core/crypto.py, core/hardening.py, core/logging.py, core/process.py, modules/__init__.py, modules/auto_registry.py, modules/custom_tools.py, modules/finding_lifecycle.py, modules/intercept.py, modules/lazy_bridge.py, modules/lazy_engine.py, modules/lazy_installer.py, modules/lazy_intel.py, modules/lazy_orchestrator_feedback.py, modules/lazy_roles.py, modules/lazy_skills.py, modules/llm_factory.py, modules/llm_pool.py, modules/loop_ai_bridge.py, modules/notify.py, modules/orchestrator_config.py, modules/selfupdate.py, modules/traffic_recorder.py, utils.py
• Imported by: cli/commands/misc_migrated.py, cli/commands/session_ops.py, cli/lazy_orchestrator.py, lazyc2.py, lazyown.py, modules/custom_tools.py, modules/lazy_agent.py, modules/lazy_engine.py, modules/lazy_intel.py, modules/lazy_mentions.py, modules/lazy_roles.py, modules/lazy_runner.py, modules/tools/loop_smoke.py, modules/tools/monitor_smoke.py, skills/lazyown_mcp.py, tests/conftest.py, tests/test_asset_gate.py, tests/test_auto_crypto.py, tests/test_intel_fusion.py, tests/test_lazy_agent.py, tests/test_lazy_engine.py, tests/test_lazy_evidence.py, tests/test_lazy_loop.py, tests/test_lazy_orchestrator.py, tests/test_lazy_proxy.py, tests/test_lazy_runner.py, tests/test_lazy_streaming.py, tests/test_lazy_worker_safety.py, tests/test_loop_ai_bridge.py, tests/test_loop_auto_orchestrator.py, tests/test_loop_broadcast.py, tests/test_loop_cold_overview.py, tests/test_loop_force_graph.py, tests/test_loop_guard_audit.py, tests/test_loop_intent_delete.py, tests/test_loop_llm_resilience.py, tests/test_loop_scope_traffic_evidence.py, tests/test_loop_spawn_side.py, tests/test_loop_store_race.py, tests/test_loop_supervision.py, tests/test_loop_worker_traces.py, tests/test_pi_leg.py, tests/test_security_alerts_fix.py, tests/test_security_codeql_batch.py

modules/lazy_mentions.py

• Doc: LAZY chat mentions with multi-type search and scroll pagination.
• Layer: utility
• Language: py
• Symbols:
  • LazyMention (class, line 35) class LazyMention
  • LazyMentionPage (class, line 45) class LazyMentionPage
  • InvalidCursor (class, line 52) class InvalidCursor(ValueError)
  • _encode_cursor (function, line 56) def _encode_cursor(last_id, last_kind, exact, scope, query)
  • _decode_cursor (function, line 64) def _decode_cursor(cursor, scope, query)
  • _literal_match (function, line 84) def _literal_match(haystack, query)
  • _collect_candidates (function, line 91) def _collect_candidates(kind, query)
  • _finding_hits (function, line 108) def _finding_hits(query)
  • _company_hits (function, line 142) def _company_hits(query)
  • _asset_hits (function, line 167) def _asset_hits(kind, query)
  • _store_glob (function, line 186) def _store_glob(pattern)
  • search_mentions_page (function, line 193) def search_mentions_page(kind, query, cursor)
  • parse_mentions (function, line 237) def parse_mentions(message)
  • compose_message (function, line 268) def compose_message(message)
  • _load_snapshot (function, line 296) def _load_snapshot(kind, ref_id)
• Depends on: modules/lazy_loop.py
• Imported by: cli/commands/lazyloop.py, lazyc2.py, skills/lazyown_mcp.py, tests/test_security_codeql_batch.py

Next: KB_modules_p8.md