Agent API_p16 - grisuno/LazyOwn GitHub Wiki
Previous: API_p15.md
-
PEParser.__init__(method)modules/reflective_dll.py:151def __init__(self, pe_data) -
PEParser.parse_file_header(method)modules/reflective_dll.py:166def parse_file_header(self)-- Extract the COFF file header. -
PEParser.parse_sections(method)modules/reflective_dll.py:208def parse_sections(self, num_sections)-- Parse all section headers from the PE. -
PEParser.parse_data_directories(method)modules/reflective_dll.py:243def parse_data_directories(self, num_entries)-- Parse the PE data directory entries. -
PEParser.rva_to_offset(method)modules/reflective_dll.py:265def rva_to_offset(self, rva, sections)-- Convert a relative virtual address to a file offset. -
PEParser.parse_imports(method)modules/reflective_dll.py:280def parse_imports(self, import_dir, sections)-- Parse the import directory to enumerate imported DLLs and functions. -
PEParser.parse_relocations(method)modules/reflective_dll.py:326def parse_relocations(self, reloc_dir, sections)-- Parse base relocation entries. -
PEParser.parse_exports(method)modules/reflective_dll.py:374def parse_exports(self, export_dir, sections)-- Parse the export directory. -
PEParser.is_64bit(method)modules/reflective_dll.py:456def is_64bit(self) -
PEParser.raw_data(method)modules/reflective_dll.py:460def raw_data(self) -
ReflectiveLoader.__init__(method)modules/reflective_dll.py:492def __init__(self, pe_data, config) -
ReflectiveLoader.sha256(method)modules/reflective_dll.py:505def sha256(self)-- SHA-256 hash of the raw PE bytes. -
ReflectiveLoader.architecture(method)modules/reflective_dll.py:510def architecture(self)-- CPU architecture string ('x64' or 'x86'). -
ReflectiveLoader.required_imports(method)modules/reflective_dll.py:515def required_imports(self)-- DLL names needed for import resolution. -
ReflectiveLoader.plan_injection(method)modules/reflective_dll.py:526def plan_injection(self)-- Generate an injection plan based on the configured technique. -
ReflectiveLoader.generate_c_stub(method)modules/reflective_dll.py:588def generate_c_stub(self)-- Generate a C stub that implements reflective loading. -
ReflectiveLoader.generate_powershell_stub(method)modules/reflective_dll.py:666def generate_powershell_stub(self)-- Generate PowerShell reflective loader script. -
ReflectiveLoader.summarize(method)modules/reflective_dll.py:685def summarize(self)-- Human-readable summary of the parsed PE for operator review.
Depends on: core/safe_exec.py
Imported by: cli/commands/resource_scripting.py, tests/test_resource_script.py, tests/test_security_hardening_v3.py
-
ScriptContext.__init__(method)modules/resource_script.py:89def __init__(self, shell_params, on_command, on_print) -
ScriptContext.print(method)modules/resource_script.py:138def print(self, msg) -
ScriptContext.run_command(method)modules/resource_script.py:147def run_command(self, cmd) -
ScriptContext.eval_condition(method)modules/resource_script.py:191def eval_condition(self, raw_condition)-- Evaluate anif/whilecondition expression. -
ResourceScriptEngine.__init__(method)modules/resource_script.py:276def __init__(self, context) -
ResourceScriptEngine.execute(method)modules/resource_script.py:279def execute(self, script_path)-- Load and run a script file. -
ResourceScriptEngine.execute_lines(method)modules/resource_script.py:293def execute_lines(self, lines, source)-- Execute a list of script lines. -
ResourceScriptEngine.execute_string(method)modules/resource_script.py:327def execute_string(self, script)-- Execute a script string (split on newlines).
-
reverse_shell_init(function)modules/reverse-shell.c:12static int __init reverse_shell_init(void)-- call_usermodehelper function is used to create user mode processes from kernel space -
reverse_shell_exit(function)modules/reverse-shell.c:16static void __exit reverse_shell_exit(void)
-
xlAutoOpen(function)modules/revshell.c:5void __cdecl xlAutoOpen() -
DllMain(function)modules/revshell.c:10BOOL APIENTRY DllMain(HMODULE hModule, DWORD ul_reason_for_call, LPVOID lpReserved)
Depends on: core/console.py, modules/dashboard_engine.py
Imported by: cli/commands/pwn.py
-
RichDashboard.__init__(method)modules/rich_tui.py:74def __init__(self, dashboard_engine, refresh_interval, live)-- Initialize the Rich dashboard. -
RichDashboard.run(method)modules/rich_tui.py:96def run(self)-- Run the dashboard. -
RichDashboard.stop(method)modules/rich_tui.py:132def stop(self)-- Gracefully shut down the dashboard and restore terminal state.
Depends on: core/logging.py
Imported by: modules/lesson_ingestor.py, modules/loop_ai_bridge.py, skills/autonomous_daemon.py, skills/swan_agent.py, tests/test_moe_rl_swan.py
-
IStateEncoder.encode(method)modules/rl_trainer.py:105def encode(self, task_type, engagement_phase, recent_reward_ema)-- Return a string key representing the current state. -
BucketedStateEncoder.encode(method)modules/rl_trainer.py:131def encode(self, task_type, engagement_phase, recent_reward_ema) -
QValueStore.__init__(method)modules/rl_trainer.py:156def __init__(self, path, optimistic_init) -
QValueStore.get(method)modules/rl_trainer.py:168def get(self, state, action) -
QValueStore.set(method)modules/rl_trainer.py:172def set(self, state, action, value) -
QValueStore.max_q(method)modules/rl_trainer.py:176def max_q(self, state, candidates)-- Return max Q(state, a) over the given candidate actions. -
QValueStore.argmax(method)modules/rl_trainer.py:182def argmax(self, state, candidates)-- Return the action with highest Q(state, a). -
QValueStore.save(method)modules/rl_trainer.py:188def save(self) -
EpsilonTracker.__init__(method)modules/rl_trainer.py:218def __init__(self, start, minimum, decay, path) -
EpsilonTracker.epsilon(method)modules/rl_trainer.py:233def epsilon(self) -
EpsilonTracker.step(method)modules/rl_trainer.py:236def step(self)-- Apply one decay step and persist. -
RLTrainer.__init__(method)modules/rl_trainer.py:284def __init__(self, config, state_encoder, q_store, epsilon_tracker) -
RLTrainer.encode_state(method)modules/rl_trainer.py:304def encode_state(self, task_type, engagement_phase, recent_reward_ema)-- Convert environment observations into a discrete state key. -
RLTrainer.select_action(method)modules/rl_trainer.py:313def select_action(self, state, candidates, force_exploit)-- Epsilon-greedy expert selection. -
RLTrainer.update(method)modules/rl_trainer.py:347def update(self, state, action, reward, next_state, candidates, detection_prob)-- Apply one Q-learning update. -
RLTrainer.best_expert_for_state(method)modules/rl_trainer.py:389def best_expert_for_state(self, state, candidates)-- Return the highest Q-value expert for the given state (greedy). -
RLTrainer.q_values_for_state(method)modules/rl_trainer.py:393def q_values_for_state(self, state, candidates)-- Return {expert_id: q_value} for diagnostics. -
RLTrainer.save(method)modules/rl_trainer.py:397def save(self)-- Persist Q-table to disk. -
RLTrainer.epsilon(method)modules/rl_trainer.py:402def epsilon(self) -
get_trainer(function)modules/rl_trainer.py:425def get_trainer(config)-- Return (or create) the module-level singleton RLTrainer.
-
get_ld_preload(function)modules/rootkit/mr.c:84char *get_ld_preload() -
set_ld_preload(function)modules/rootkit/mr.c:87void set_ld_preload(const char *ld_preload) -
ensure_ld_preload(function)modules/rootkit/mr.c:100void ensure_ld_preload() -
ensure_pid_file_exists(function)modules/rootkit/mr.c:117void ensure_pid_file_exists() -
check_elevate(function)modules/rootkit/mr.c:136int check_elevate() -
write_file(function)modules/rootkit/mr.c:145void write_file(const char *path, const char *content, mode_t mode) -
crontab(function)modules/rootkit/mr.c:156void crontab(const char *path) -
generate_random_string(function)modules/rootkit/mr.c:168char *generate_random_string() -
xdg(function)modules/rootkit/mr.c:178void xdg(const char *path, int admin) -
kde_plasma(function)modules/rootkit/mr.c:200void kde_plasma(const char *path) -
copy_binary(function)modules/rootkit/mr.c:215void copy_binary(const char *source, const char *destination) -
persist(function)modules/rootkit/mr.c:234void persist(const char *path) -
ensure_key_file_exists(function)modules/rootkit/mr.c:253void ensure_key_file_exists() -
ensure_hide_file_exists(function)modules/rootkit/mr.c:271void ensure_hide_file_exists() -
infect_command(function)modules/rootkit/mr.c:289void infect_command() -
load_rootkit(function)modules/rootkit/mr.c:303void load_rootkit() -
unload_rootkit(function)modules/rootkit/mr.c:314void unload_rootkit() -
handle_client(function)modules/rootkit/mr.c:321void *handle_client(void *client_socket) -
mon_shell(function)modules/rootkit/mr.c:521void *mon_shell(void *data) -
signal_handler(function)modules/rootkit/mr.c:609void signal_handler(int signum) -
reboot_system(function)modules/rootkit/mr.c:615void reboot_system() -
main(function)modules/rootkit/mr.c:639int main()
-
load_hidden_pids(function)modules/rootkit/mrhyde.c:73void load_hidden_pids() -
load_hidden_files(function)modules/rootkit/mrhyde.c:93void load_hidden_files() -
unlink(function)modules/rootkit/mrhyde.c:113int unlink(const char *pathname) -
kill(function)modules/rootkit/mrhyde.c:125int kill(pid_t pid, int sig) -
remove(function)modules/rootkit/mrhyde.c:145int remove(const char *pathname) -
unlinkat(function)modules/rootkit/mrhyde.c:157int unlinkat(int dirfd, const char *pathname, int flags) -
get_username_from_pid(function)modules/rootkit/mrhyde.c:178char* get_username_from_pid(pid_t pid) -
should_hide_pid(function)modules/rootkit/mrhyde.c:197int should_hide_pid(const char* pid) -
should_hide_file(function)modules/rootkit/mrhyde.c:212int should_hide_file(const char* filename) -
readdir(function)modules/rootkit/mrhyde.c:222struct dirent* readdir(DIR* dirp) -
fopen(function)modules/rootkit/mrhyde.c:283FILE *fopen(const char *pathname, const char *mode) -
my_open(function)modules/rootkit/mrhyde.c:327int my_open(const char *pathname, int flags, mode_t mode) -
my_openat(function)modules/rootkit/mrhyde.c:371int my_openat(int dirfd, const char *pathname, int flags, mode_t mode) -
stat(function)modules/rootkit/mrhyde.c:415int stat(const char *pathname, struct stat *statbuf) -
lstat(function)modules/rootkit/mrhyde.c:459int lstat(const char *pathname, struct stat *statbuf) -
fstat(function)modules/rootkit/mrhyde.c:503int fstat(int fd, struct stat *statbuf) -
getdents(function)modules/rootkit/mrhyde.c:557int getdents(unsigned int fd, struct linux_dirent64 *dirp, unsigned int count) -
getdents64(function)modules/rootkit/mrhyde.c:618int getdents64(unsigned int fd, struct linux_dirent64 *dirp, unsigned int count) -
main(function)modules/rootkit/mrhyde.c:678int main()
-
load_hidden_pids(function)modules/rootkit/mrhyde2.c:63void load_hidden_pids() -
unlink(function)modules/rootkit/mrhyde2.c:83int unlink(const char *pathname) -
kill(function)modules/rootkit/mrhyde2.c:95int kill(pid_t pid, int sig) -
remove(function)modules/rootkit/mrhyde2.c:115int remove(const char *pathname) -
unlinkat(function)modules/rootkit/mrhyde2.c:127int unlinkat(int dirfd, const char *pathname, int flags) -
get_username_from_pid(function)modules/rootkit/mrhyde2.c:148char* get_username_from_pid(pid_t pid) -
should_hide_pid(function)modules/rootkit/mrhyde2.c:167int should_hide_pid(const char* pid) -
readdir(function)modules/rootkit/mrhyde2.c:182struct dirent* readdir(DIR* dirp) -
fopen(function)modules/rootkit/mrhyde2.c:238FILE *fopen(const char *pathname, const char *mode) -
my_open(function)modules/rootkit/mrhyde2.c:275int my_open(const char *pathname, int flags, mode_t mode) -
my_openat(function)modules/rootkit/mrhyde2.c:312int my_openat(int dirfd, const char *pathname, int flags, mode_t mode) -
stat(function)modules/rootkit/mrhyde2.c:349int stat(const char *pathname, struct stat *statbuf) -
lstat(function)modules/rootkit/mrhyde2.c:386int lstat(const char *pathname, struct stat *statbuf) -
fstat(function)modules/rootkit/mrhyde2.c:423int fstat(int fd, struct stat *statbuf) -
getdents(function)modules/rootkit/mrhyde2.c:470int getdents(unsigned int fd, struct linux_dirent64 *dirp, unsigned int count) -
getdents64(function)modules/rootkit/mrhyde2.c:527int getdents64(unsigned int fd, struct linux_dirent64 *dirp, unsigned int count) -
main(function)modules/rootkit/mrhyde2.c:583int main()
-
uring_queue_init(function)modules/rootkit/mrhyde3.c:85static int uring_queue_init(unsigned int entries, struct io_uring *ring)-- /* Syscalls static inline int __io_uring_setup(unsigned int entries, struct io_uring_params *p) { return... -
uring_get_sqe(function)modules/rootkit/mrhyde3.c:130static struct io_uring_sqe *uring_get_sqe(struct io_uring *ring)-- ring->cq.head = (unsigned *)((char *)cq_ring + params.cq_off.head); ring->cq.tail = (unsigned *)((char *)cq_ring +... -
uring_submit(function)modules/rootkit/mrhyde3.c:141static int uring_submit(struct io_uring *ring)-- } /* Obtener SQE static struct io_uring_sqe *uring_get_sqe(struct io_uring *ring) { unsigned head = *ring->sq.head... -
uring_wait_cqe_timeout(function)modules/rootkit/mrhyde3.c:149static int uring_wait_cqe_timeout(struct io_uring *ring, struct io_uring_cqe **cqe_ptr, int timeo...-- struct io_uring_sqe *sqe = &ring->sq.sqes[tail & *ring->sq.ring_mask]; memset(sqe, 0, sizeof(*sqe)); return sqe; }... -
uring_cqe_seen(function)modules/rootkit/mrhyde3.c:163static void uring_cqe_seen(struct io_uring *ring, struct io_uring_cqe *cqe) -
init_root_ring(function)modules/rootkit/mrhyde3.c:176static int init_root_ring(void)-- static void uring_cqe_seen(struct io_uring *ring, struct io_uring_cqe *cqe) { (ring->cq.head)++; } / Estado global... -
uring_read_whole_file(function)modules/rootkit/mrhyde3.c:197static char *uring_read_whole_file(const char *path)-- } ring_ok = 1; /* Registrar buffer (opcional) struct iovec iov; iov.iov_base = malloc(IO_URING_BUFFER_SIZE)... -
traditional_read_file(function)modules/rootkit/mrhyde3.c:253static char *traditional_read_file(const char *path)-- if (bytes_read <= 0) break; buf = realloc(buf, total_read + bytes_read + 1); if (!buf) { close(fd)... -
load_hidden_pids(function)modules/rootkit/mrhyde3.c:268void load_hidden_pids(void)-- FILE *f = fopen(path, "rb"); if (!f) return NULL; fseek(f, 0, SEEK_END); long size = ftell(f); fseek(f, 0... -
load_hidden_files(function)modules/rootkit/mrhyde3.c:282void load_hidden_files(void) -
get_username_from_pid(function)modules/rootkit/mrhyde3.c:297char* get_username_from_pid(pid_t pid)-- char *data = uring_read_whole_file(FILE_HIDE_PATH); if (!data) data = traditional_read_file(FILE_HIDE_PATH); if... -
should_hide_pid(function)modules/rootkit/mrhyde3.c:320int should_hide_pid(const char* pid) -
should_hide_file(function)modules/rootkit/mrhyde3.c:329int should_hide_file(const char* filename) -
readdir(function)modules/rootkit/mrhyde3.c:336struct dirent* readdir(DIR* dirp) -
unlink(function)modules/rootkit/mrhyde3.c:367int unlink(const char *pathname) -
kill(function)modules/rootkit/mrhyde3.c:373int kill(pid_t pid, int sig) -
remove(function)modules/rootkit/mrhyde3.c:383int remove(const char *pathname) -
unlinkat(function)modules/rootkit/mrhyde3.c:389int unlinkat(int dirfd, const char *pathname, int flags) -
fopen(function)modules/rootkit/mrhyde3.c:407FILE *fopen(const char *pathname, const char *mode) -
open(function)modules/rootkit/mrhyde3.c:430int open(const char *pathname, int flags, ...) -
openat(function)modules/rootkit/mrhyde3.c:458int openat(int dirfd, const char *pathname, int flags, ...) -
stat(function)modules/rootkit/mrhyde3.c:487int stat(const char *pathname, struct stat *statbuf) -
lstat(function)modules/rootkit/mrhyde3.c:511int lstat(const char *pathname, struct stat *statbuf) -
fstat(function)modules/rootkit/mrhyde3.c:535int fstat(int fd, struct stat *statbuf) -
getdents(function)modules/rootkit/mrhyde3.c:569int getdents(unsigned int fd, struct linux_dirent64 *dirp, unsigned int count) -
getdents64(function)modules/rootkit/mrhyde3.c:605ssize_t getdents64(int fd, void *dirp, size_t count)
Depends on: core/crypto.py, lazyown-docker/init.sh
-
regs_override_return(function)modules/rootkit/rootkit.c:43static inline void regs_override_return(struct pt_regs *regs, long new_ret)-- Define regs_override_return function -
hooked_getdents(function)modules/rootkit/rootkit.c:75static int hooked_getdents(struct kretprobe_instance *ri, struct pt_regs *regs)-- Hooked getdents function -
hooked_getdents64(function)modules/rootkit/rootkit.c:101static int hooked_getdents64(struct kretprobe_instance *ri, struct pt_regs *regs)-- Hooked getdents64 function -
hooked_read(function)modules/rootkit/rootkit.c:127static int hooked_read(struct kretprobe_instance *ri, struct pt_regs *regs)-- Hooked read function to create a backdoor -
disable_module_signature_verification(function)modules/rootkit/rootkit.c:181static void disable_module_signature_verification(void)-- Function to disable module signature verification -
hook_syscalls(function)modules/rootkit/rootkit.c:195static int __init hook_syscalls(void)-- Function to hook system calls -
unhook_syscalls(function)modules/rootkit/rootkit.c:208static void __exit unhook_syscalls(void)-- Function to unhook system calls
Imported by: cli/commands/cloud_attacks.py
-
SaaSEnumerationTools.microsoft365_commands(method)modules/saas_attacks.py:75def microsoft365_commands() -
SaaSEnumerationTools.google_workspace_commands(method)modules/saas_attacks.py:100def google_workspace_commands() -
SaaSEnumerationTools.salesforce_commands(method)modules/saas_attacks.py:118def salesforce_commands() -
SaaSEnumerationTools.servicenow_commands(method)modules/saas_attacks.py:135def servicenow_commands() -
SaaSAttackEngine.__init__(method)modules/saas_attacks.py:163def __init__(self, config) -
SaaSAttackEngine.enumerate_all(method)modules/saas_attacks.py:166def enumerate_all(self)-- Generate enumeration commands for all supported SaaS platforms. -
SaaSAttackEngine.m365_ews_mail_search(method)modules/saas_attacks.py:179def m365_ews_mail_search(self, search_term)-- Search mailboxes via Exchange Web Services (EWS). -
SaaSAttackEngine.google_workspace_domain_wide_delegation(method)modules/saas_attacks.py:228def google_workspace_domain_wide_delegation(self)-- Abuse Google Workspace Domain-Wide Delegation (DWD). -
SaaSAttackEngine.salesforce_report_mining(method)modules/saas_attacks.py:257def salesforce_report_mining(self)-- Mine Salesforce reports and dashboards for sensitive data. -
SaaSAttackEngine.slack_data_mining(method)modules/saas_attacks.py:286def slack_data_mining(self)-- Mine Slack Enterprise for sensitive conversations and files. -
SaaSAttackEngine.detect_external_sharing(method)modules/saas_attacks.py:327def detect_external_sharing(self)-- Detect external sharing configurations across SaaS platforms. -
SaaSAttackEngine.summary(method)modules/saas_attacks.py:352def summary(self)
Imported by: lazyc2.py, lazyc2/blueprints/phishing.py, modules/lazyown_bprfuzzer.py, pwntomate.py, tests/test_security_sanitizers.py
-
SecurityConfig.from_payload(method)modules/security_sanitizers.py:68def from_payload(cls, payload)-- Build a configuration object from a[payload.json](https://github.com/grisuno/LazyOwn/blob/146a52570ef792d1ec01ec4d3709b0c159990e47/payload.json)mapping. -
HeaderValueSanitizer.__init__(method)modules/security_sanitizers.py:115def __init__(self, config)-- Bind the sanitizer to a configuration instance. -
HeaderValueSanitizer.is_valid_name(method)modules/security_sanitizers.py:129def is_valid_name(self, name)-- Return True iffnameis a syntactically valid header token. -
HeaderValueSanitizer.sanitize_value(method)modules/security_sanitizers.py:139def sanitize_value(self, value)-- Return a header value that cannot smuggle a response split. -
SessionPathResolver.__init__(method)modules/security_sanitizers.py:174def __init__(self, base_dir, config)-- Bind the resolver to an absolute, real base directory. -
SessionPathResolver.base_dir(method)modules/security_sanitizers.py:192def base_dir(self)-- The resolved, absolute base directory. -
SessionPathResolver.resolve(method)modules/security_sanitizers.py:196def resolve(self, untrusted_name)-- Return(absolute, relative)for a safe filename. -
SessionPathResolver.file_exists(method)modules/security_sanitizers.py:238def file_exists(self, untrusted_name)-- Return True iffuntrusted_nameresolves to an existing file. -
BindAddressResolver.__init__(method)modules/security_sanitizers.py:269def __init__(self, config, preferred_addresses)-- Build a resolver with a prioritised list of candidate addresses. -
BindAddressResolver.resolve(method)modules/security_sanitizers.py:298def resolve(self)-- Return the address sockets should bind to. -
CommandRedactor.__init__(method)modules/security_sanitizers.py:333def __init__(self, config)-- Bind the redactor to a configuration instance. -
CommandRedactor.render(method)modules/security_sanitizers.py:359def render(self, template, substitutions, username, password)-- Return(executable, display)for a templated command. -
OutputSanitizer.__init__(method)modules/security_sanitizers.py:418def __init__(self, config)-- Bind the sanitizer to a configuration instance. -
OutputSanitizer.sanitize(method)modules/security_sanitizers.py:429def sanitize(self, value)-- Returnvalueprojected into a JSON-serialisable form. -
build_default_config(function)modules/security_sanitizers.py:477def build_default_config(payload)-- Return a :class:SecurityConfigpopulated frompayload.
Imported by: cli/commands/lazyops.py, modules/lazy_loop.py, tests/test_autonomous_ops.py, tests/test_lazy_loop.py
-
Updater.__init__(method)modules/selfupdate.py:47def __init__(self, live_path)-- Bind the updater to the binary that may be replaced. -
Updater.verify(method)modules/selfupdate.py:52def verify(self, artifact)-- Return True when the payload matches its recorded digest. -
Updater.stage(method)modules/selfupdate.py:57def stage(self, artifact, directory)-- Write a verified payload intodirectory. -
Updater.rollback(method)modules/selfupdate.py:77def rollback(self)-- Restore the<name>.oldsnapshot over the live binary. -
current_branch(function)modules/selfupdate.py:96def current_branch(runner)-- Return the checked-out branch name (empty on failure). -
dirty(function)modules/selfupdate.py:102def dirty(runner)-- Return True when the working tree has uncommitted changes. -
check(function)modules/selfupdate.py:108def check(branch, runner)-- Fetch the branch and report ahead/behind counts. -
apply(function)modules/selfupdate.py:140def apply(branch, confirm, runner)-- Fast-forward the tree to origin/ when safe.
Imported by: lazyown.py, tests/test_infra_disposable.py
-
find_cloudflared_pids(function)modules/session_cleanup.py:28def find_cloudflared_pids(ps_output)-- Extract PIDs ofcloudflared tunnelprocesses from ps output. -
stop_cloudflared_processes(function)modules/session_cleanup.py:94def stop_cloudflared_processes()-- Terminate straycloudflared tunnelhost processes. -
cleanup_ephemeral_infra(function)modules/session_cleanup.py:120def cleanup_ephemeral_infra()-- Stop all disposable infrastructure owned by this checkout.
Depends on: core/logging.py
Imported by: cli/commands/mcp_bridge.py, modules/reactive_engine.py, skills/lazyown_groq_agents.py, skills/lazyown_mcp.py, tests/integration_autonomous_flow.py, tests/test_core_modules.py
-
_KeywordFallback.__init__(method)modules/session_rag.py:111def __init__(self) -
_KeywordFallback.load(method)modules/session_rag.py:115def load(self, path)-- Load index from disk (no-op if file absent or corrupt). -
_KeywordFallback.save(method)modules/session_rag.py:126def save(self, path)-- Atomically persist index to disk. -
_KeywordFallback.add(method)modules/session_rag.py:136def add(self, doc_id, text, meta) -
_KeywordFallback.query(method)modules/session_rag.py:146def query(self, query_text, n) -
_KeywordFallback.count(method)modules/session_rag.py:156def count(self) -
_KeywordFallback.reset(method)modules/session_rag.py:159def reset(self) -
_RagState.load(method)modules/session_rag.py:172def load(cls) -
_RagState.save(method)modules/session_rag.py:181def save(self) -
SessionRAG.__init__(method)modules/session_rag.py:191def __init__(self) -
SessionRAG.index_new(method)modules/session_rag.py:301def index_new(self)-- Incrementally index only new or changed files. -
SessionRAG.index_parquet_sources(method)modules/session_rag.py:322def index_parquet_sources(self, force)-- Index knowledge-base parquets (techniques_enriched, binarios, lolbas_index) into the RAG store. -
SessionRAG.index_all(method)modules/session_rag.py:411def index_all(self)-- Full re-index from scratch. -
SessionRAG.query(method)modules/session_rag.py:439def query(self, query_text, n, collection)-- Return top-n relevant chunks as dicts with keys: text, source, chunk, score. -
SessionRAG.context_for_step(method)modules/session_rag.py:489def context_for_step(self, phase, target, cmd, n)-- Return a compact RAG context string suitable for injection into an LLM prompt. -
SessionRAG.stats(method)modules/session_rag.py:509def stats(self) -
get_rag(function)modules/session_rag.py:535def get_rag()
Imported by: skills/lazyown_groq_agents.py, skills/lazyown_mcp.py, tests/test_core_modules.py
-
ImplantRecord.is_privileged(method)modules/session_reader.py:55def is_privileged(self) -
ImplantRecord.platform(method)modules/session_reader.py:60def platform(self) -
ImplantRecord.ip_list(method)modules/session_reader.py:69def ip_list(self) -
SessionSummary.active_client_ids(method)modules/session_reader.py:94def active_client_ids(self) -
SessionSummary.privileged_sessions(method)modules/session_reader.py:101def privileged_sessions(self) -
SessionSummary.unprivileged_sessions(method)modules/session_reader.py:108def unprivileged_sessions(self) -
SessionSummary.latest_for(method)modules/session_reader.py:114def latest_for(self, client_id) -
SessionSummary.task_by_status(method)modules/session_reader.py:118def task_by_status(self, status) -
AbstractReader.read(method)modules/session_reader.py:129def read(self, sessions_dir) -
ImplantCSVReader.read(method)modules/session_reader.py:157def read(self, sessions_dir) -
CommandOutputReader.read(method)modules/session_reader.py:199def read(self, sessions_dir) -
DiscoveredHostReader.read(method)modules/session_reader.py:217def read(self, sessions_dir) -
TaskReader.read(method)modules/session_reader.py:235def read(self, sessions_dir) -
TaskWriter.__init__(method)modules/session_reader.py:260def __init__(self, sessions_dir) -
TaskWriter.append(method)modules/session_reader.py:263def append(self, title, description, operator, status) -
TaskWriter.update_status(method)modules/session_reader.py:288def update_status(self, task_id, status) -
SessionAggregator.__init__(method)modules/session_reader.py:319def __init__(self, implant_reader, output_reader, host_reader, task_reader) -
SessionAggregator.aggregate(method)modules/session_reader.py:331def aggregate(self, sessions_dir) -
get_aggregator(function)modules/session_reader.py:347def get_aggregator()
Imported by: modules/recommender.py, skills/heartbeat.py, skills/lazyown_daemon.py, skills/lazyown_mcp.py
-
build_state(function)modules/session_state.py:189def build_state()-- Assemble and return the current session state dict. -
refresh(function)modules/session_state.py:240def refresh()-- Build state and persist to sessions/session_state.json. -
load(function)modules/session_state.py:251def load()-- Return the last written state, or build it fresh if stale/missing.
Imported by: cli/commands/ai.py, tests/test_autonomous_ops.py
-
SideQuestionService.__init__(method)modules/sidequestion.py:55def __init__(self, answer_fn, config)-- Initialize registries with an optional answer function. -
SideQuestionService.capture(method)modules/sidequestion.py:66def capture(self, task_id, text)-- Freeze main-loop context into an immutable snapshot. -
SideQuestionService.ask(method)modules/sidequestion.py:75def ask(self, snapshot_id, question)-- Answer from a snapshot without touching main state. -
SideQuestionService.cancel(method)modules/sidequestion.py:104def cancel(self, request_id)-- Mark a pending request cancelled. -
SideQuestionService.history(method)modules/sidequestion.py:113def history(self, limit, before)-- Page request history newest first.
Depends on: cli/commands/enum.py, core/logging.py
Imported by: cli/commands/sleep_obfuscation.py, modules/beacon_config_builder.py, tests/test_sleep_obfuscation.py
-
SleepObfuscationConfig.to_dict(method)modules/sleep_obfuscation.py:129def to_dict(self)-- Serialize to dictionary. -
SleepObfuscationConfig.from_dict(method)modules/sleep_obfuscation.py:146def from_dict(cls, raw)-- Build from dictionary. -
SleepTechniqueCatalog.__init__(method)modules/sleep_obfuscation.py:170def __init__(self) -
SleepTechniqueCatalog.register(method)modules/sleep_obfuscation.py:173def register(self, technique)-- Register a technique in the catalog. -
SleepTechniqueCatalog.get(method)modules/sleep_obfuscation.py:177def get(self, name)-- Retrieve a technique by name. -
SleepTechniqueCatalog.list_all(method)modules/sleep_obfuscation.py:184def list_all(self)-- Return all registered techniques sorted by detection resistance. -
SleepTechniqueCatalog.list_by_platform(method)modules/sleep_obfuscation.py:192def list_by_platform(self, platform)-- Return techniques supported on a given platform. -
SleepTechniqueCatalog.list_names(method)modules/sleep_obfuscation.py:196def list_names(self)-- Return sorted list of technique names. -
SleepTechniqueValidator.validate(method)modules/sleep_obfuscation.py:369def validate(config, technique)-- Validate config against a technique definition. -
SleepTechniqueValidator.validate_config(method)modules/sleep_obfuscation.py:386def validate_config(config)-- Validate the config itself for internal consistency. -
SleepObfuscationEngine.__init__(method)modules/sleep_obfuscation.py:407def __init__(self, catalog) -
SleepObfuscationEngine.catalog(method)modules/sleep_obfuscation.py:416def catalog(self)-- Return the technique catalog. -
SleepObfuscationEngine.config(method)modules/sleep_obfuscation.py:421def config(self)-- Return the active runtime configuration. -
SleepObfuscationEngine.detection_resistance(method)modules/sleep_obfuscation.py:426def detection_resistance(self)-- Return the detection resistance score of the active technique. -
SleepObfuscationEngine.select(method)modules/sleep_obfuscation.py:442def select(self, technique_name)-- Select a technique from the catalog. -
SleepObfuscationEngine.configure(method)modules/sleep_obfuscation.py:449def configure(self, technique, overrides)-- Build a validated SleepObfuscationConfig for a technique. -
SleepObfuscationEngine.validate(method)modules/sleep_obfuscation.py:484def validate(self, config)-- Validate configuration against the active technique. -
SleepObfuscationEngine.recommend(method)modules/sleep_obfuscation.py:500def recommend(self, platform)-- Recommend techniques for a platform sorted by detection resistance. -
SleepObfuscationEngine.to_dict(method)modules/sleep_obfuscation.py:513def to_dict(self)-- Serialize the entire engine state to a dictionary. -
SleepObfuscationEngine.from_dict(method)modules/sleep_obfuscation.py:522def from_dict(cls, raw)-- Build an engine from a serialized state dictionary.
Depends on: cli/commands/enum.py, core/logging.py
Imported by: cli/commands/socks_proxy.py, modules/beacon_config_builder.py, tests/test_socks_proxy.py
-
SocksReply.message(method)modules/socks_proxy.py:103def message(self)-- Return a human-readable message for this reply code. -
SocksSession.elapsed_seconds(method)modules/socks_proxy.py:144def elapsed_seconds(self)-- Return seconds since session creation. -
SocksSession.to_dict(method)modules/socks_proxy.py:150def to_dict(self)-- Serialize session to dictionary. -
SocksProxyConfig.to_dict(method)modules/socks_proxy.py:199def to_dict(self)-- Serialize config to dictionary. -
SocksProxyConfig.from_dict(method)modules/socks_proxy.py:218def from_dict(cls, raw)-- Build config from dictionary. -
SocksValidator.validate_config(method)modules/socks_proxy.py:253def validate_config(config)-- Validate a SocksProxyConfig and return error messages. -
SocksValidator.validate_request(method)modules/socks_proxy.py:300def validate_request(command, address_type, host, port, config)-- Validate a SOCKS5 request against the proxy configuration. -
SocksProxyEngine.__init__(method)modules/socks_proxy.py:381def __init__(self, config) -
SocksProxyEngine.config(method)modules/socks_proxy.py:387def config(self)-- Return the current proxy configuration. -
SocksProxyEngine.sessions(method)modules/socks_proxy.py:392def sessions(self)-- Return active proxied sessions. -
SocksProxyEngine.session_count(method)modules/socks_proxy.py:397def session_count(self)-- Return the number of active sessions. -
SocksProxyEngine.validate(method)modules/socks_proxy.py:401def validate(self, config)-- Validate the configuration. -
SocksProxyEngine.build_spec(method)modules/socks_proxy.py:413def build_spec(self)-- Build a JSON-serializable proxy specification for beacon delivery. -
SocksProxyEngine.create_session(method)modules/socks_proxy.py:436def create_session(self, session_id, target_host, target_port, beacon_client_id)-- Create and track a new proxied session. -
SocksProxyEngine.remove_session(method)modules/socks_proxy.py:475def remove_session(self, session_id)-- Remove a session by ID. -
SocksProxyEngine.get_session(method)modules/socks_proxy.py:482def get_session(self, session_id)-- Return a session by ID, or None. -
SocksProxyEngine.add_bytes(method)modules/socks_proxy.py:486def add_bytes(self, session_id, sent, received)-- Update byte counters for a session. -
SocksProxyEngine.cleanup_expired(method)modules/socks_proxy.py:497def cleanup_expired(self)-- Remove sessions that have exceeded the timeout. -
SocksProxyEngine.list_sessions(method)modules/socks_proxy.py:511def list_sessions(self)-- Return a list of all active sessions as dictionaries. -
SocksProxyEngine.from_dict(method)modules/socks_proxy.py:522def from_dict(cls, raw)-- Build a SocksProxyEngine from a configuration dictionary. -
SocksProxyEngine.from_payload(method)modules/socks_proxy.py:528def from_payload(cls, payload)-- Build a SocksProxyEngine from a LazyOwn payload configuration.
Imported by: cli/commands/payload_arsenal.py
-
StagedDeliveryFactory.__init__(method)modules/staged_delivery.py:83def __init__(self, config, output_dir) -
StagedDeliveryFactory.generate_hta(method)modules/staged_delivery.py:134def generate_hta(self)-- Generate an HTA (HTML Application) dropper. -
StagedDeliveryFactory.generate_vba_macro(method)modules/staged_delivery.py:171def generate_vba_macro(self)-- Generate a VBA macro for Office documents (Word/Excel). -
StagedDeliveryFactory.generate_xlm_macro(method)modules/staged_delivery.py:219def generate_xlm_macro(self)-- Generate an Excel 4.0 (XLM) macro for legacy macro execution. -
StagedDeliveryFactory.generate_lnk(method)modules/staged_delivery.py:237def generate_lnk(self)-- Generate a Windows .lnk shortcut file with embedded command execution. -
StagedDeliveryFactory.generate_iso(method)modules/staged_delivery.py:301def generate_iso(self, inner_files)-- Generate an ISO 9660 image with an embedded payload autorun. -
StagedDeliveryFactory.generate_vhd(method)modules/staged_delivery.py:370def generate_vhd(self, inner_files)-- Generate a VHD (Virtual Hard Disk) image with embedded payloads. -
StagedDeliveryFactory.generate_all(method)modules/staged_delivery.py:420def generate_all(self)-- Generate all delivery formats for the current configuration. -
StagedDeliveryFactory.generate_phishing_page(method)modules/staged_delivery.py:460def generate_phishing_page(self, template)-- Generate a credential harvesting HTML page.
Depends on: core/logging.py, modules/db.py, modules/event_bus.py, modules/world_model.py
Imported by: cli/commands/automation.py, lazyc2.py, lazyc2/blueprints/beacon.py, lazyown.py, modules/conditional_hooks.py, modules/event_consumers.py, modules/unified_bridge.py
-
StateManager.__init__(method)modules/state_manager.py:107def __init__(self, db_path, sessions_dir, world_model_path, facts_path) -
StateManager.instance(method)modules/state_manager.py:129def instance(cls) -
StateManager.db(method)modules/state_manager.py:137def db(self) -
StateManager.workspace_id(method)modules/state_manager.py:146def workspace_id(self) -
StateManager.set_payload(method)modules/state_manager.py:165def set_payload(self, payload) -
StateManager.close(method)modules/state_manager.py:202def close(self) -
StateManager.add_host(method)modules/state_manager.py:213def add_host(self, address, mac, hostname, os, state) -
StateManager.get_host(method)modules/state_manager.py:236def get_host(self, address) -
StateManager.list_hosts(method)modules/state_manager.py:245def list_hosts(self) -
StateManager.advance_host(method)modules/state_manager.py:249def advance_host(self, address, new_state) -
StateManager.delete_host(method)modules/state_manager.py:275def delete_host(self, address) -
StateManager.add_service(method)modules/state_manager.py:287def add_service(self, host_address, port, protocol, name, product, version, state) -
StateManager.list_services(method)modules/state_manager.py:319def list_services(self, host_address) -
StateManager.add_credential(method)modules/state_manager.py:328def add_credential(self, host_address, username, password, realm, cred_type, origin) -
StateManager.list_credentials(method)modules/state_manager.py:362def list_credentials(self, host_address) -
StateManager.add_vulnerability(method)modules/state_manager.py:373def add_vulnerability(self, host_address, name, severity, description, refs) -
StateManager.list_vulnerabilities(method)modules/state_manager.py:398def list_vulnerabilities(self, host_address, severity) -
StateManager.add_loot(method)modules/state_manager.py:411def add_loot(self, name, loot_type, path, notes, host_address) -
StateManager.list_loot(method)modules/state_manager.py:444def list_loot(self) -
StateManager.add_note(method)modules/state_manager.py:450def add_note(self, data, note_type, host_address) -
StateManager.list_notes(method)modules/state_manager.py:473def list_notes(self) -
StateManager.import_nmap_xml(method)modules/state_manager.py:479def import_nmap_xml(self, xml_path) -
StateManager.import_nmap_from_facts(method)modules/state_manager.py:495def import_nmap_from_facts(self, facts)-- Import hosts and services from a FactStore-style facts dict into DB. -
StateManager.status(method)modules/state_manager.py:550def status(self) -
StateManager.get_world_model_cache(method)modules/state_manager.py:606def get_world_model_cache(self) -
StateManager.load_world_model(method)modules/state_manager.py:612def load_world_model(self)-- Return a WorldModel instance populated from DB state. -
StateManager.session_snapshot(method)modules/state_manager.py:653def session_snapshot(self) -
StateManager.export_csv(method)modules/state_manager.py:757def export_csv(self, table) -
StateManager.export_summary(method)modules/state_manager.py:761def export_summary(self) -
get_state_manager(function)modules/state_manager.py:776def get_state_manager()
Depends on: core/logging.py
-
get_controlling_tty(function)modules/sudo_tiocsti.py:52def get_controlling_tty()-- Return (file_descriptor, tty_path) for the controlling terminal. -
inject_byte(function)modules/sudo_tiocsti.py:64def inject_byte(fd, byte_char)-- Inject a single byte via TIOCSTI; return success status. -
inject_payload(function)modules/sudo_tiocsti.py:79def inject_payload(fd, payload, char_delay)-- Inject a multi‑character payload. -
get_sudo_pids_on_tty(function)modules/sudo_tiocsti.py:102def get_sudo_pids_on_tty(tty_path)-- Return a list of PIDs that are running 'sudo' and have the same controlling terminal as the given tty_path. -
sudo_cache_valid(function)modules/sudo_tiocsti.py:139def sudo_cache_valid()-- Return True if sudo credentials are cached (i.e., sudo -n succeeds). -
mode_poll(function)modules/sudo_tiocsti.py:149def mode_poll(fd, tty_path)-- Poll for sudo processes; inject payload when sudo exits. -
mode_prefill(function)modules/sudo_tiocsti.py:175def mode_prefill(fd)-- Inject payload repeatedly, regardless of sudo state. -
mode_cache(function)modules/sudo_tiocsti.py:185def mode_cache(fd)-- Check sudo cache; if valid, inject sudo -i once. -
main(function)modules/sudo_tiocsti.py:198def main()
Imported by: cli/commands/surface.py, tests/test_estorides_fusion.py
-
is_ipv4(function)modules/surface_ops.py:18def is_ipv4(value)-- Return True for dotted-quad IPv4 literals with 0-255 octets. -
parse_confirm(function)modules/surface_ops.py:26def parse_confirm(answer)-- Return True for an affirmative scan confirmation answer. -
discovery_targets(function)modules/surface_ops.py:31def discovery_targets(sessions_dir)-- List every discovery IP across the sessions discovery files. -
write_world_model_hosts(function)modules/surface_ops.py:50def write_world_model_hosts(document, sessions)-- Append unknown estorides host IPs to world_model.json hosts.
-
get_machine_id(function)modules/tel.py:10def get_machine_id() -
get_version(function)modules/tel.py:24def get_version() -
to_numbers(function)modules/tel.py:36def to_numbers(hex_str)-- Simula la función toNumbers de JavaScript -
to_hex(function)modules/tel.py:41def to_hex(byte_list)-- Simula la función toHex de JavaScript -
decrypt_cookie(function)modules/tel.py:46def decrypt_cookie(encrypted, key, iv)-- Descifra usando AES en modo CBC (como slowAES.decrypt(c,2,a,b)) -
main(function)modules/tel.py:53def main()-- Sistema de telemetría de uso por instalación no invasiva.
Depends on: core/logging.py
Imported by: cli/commands/mcp_bridge.py, skills/lazyown_groq_agents.py, skills/lazyown_mcp.py, tests/test_core_modules.py
-
ThreatModelBuilder.build(method)modules/threat_model.py:270def build(self) -
ThreatModelBuilder.load(method)modules/threat_model.py:293def load(self) -
get_builder(function)modules/threat_model.py:592def get_builder()
Depends on: modules/ai_fallback.py
Imported by: skills/heartbeat.py, skills/lazyown_daemon.py, skills/lazyown_mcp.py
-
narrate(function)modules/timeline_narrator.py:130def narrate(api_key, force)-- Generate and return the timeline narrative. -
load_timeline(function)modules/timeline_narrator.py:165def load_timeline()-- Return the last written timeline.md or empty string.
Imported by: cli/commands/opsec_cleanup.py
-
Timestomper.__init__(method)modules/timestomper.py:106def __init__(self, config) -
Timestomper.windows_timestomp_powershell(method)modules/timestomper.py:110def windows_timestomp_powershell(self)-- Generate PowerShell commands for Windows file timestomping. -
Timestomper.windows_timestomp_c(method)modules/timestomper.py:152def windows_timestomp_c(self)-- Generate C code for Windows timestomping via SetFileTime API. -
Timestomper.linux_timestomp_commands(method)modules/timestomper.py:200def linux_timestomp_commands(self)-- Generate Linux commands for file timestomping. -
Timestomper.macos_timestomp_commands(method)modules/timestomper.py:241def macos_timestomp_commands(self)-- Generate macOS commands for file timestomping. -
Timestomper.generate_random_timestamps(method)modules/timestomper.py:280def generate_random_timestamps(self, reference_ts, window_days)-- Generate randomized timestamps within a window around the reference. -
Timestomper.verify_timestamps(method)modules/timestomper.py:300def verify_timestamps(self, target_paths)-- Verify timestamps on target files after modification. -
Timestomper.summary(method)modules/timestomper.py:326def summary(self)-- Return a summary of available timestomping capabilities.
Depends on: modules/lazy_engine.py, modules/lazy_loop.py, modules/lazy_runner.py
-
FakeShell.onecmd_plus_hooks(method)modules/tools/loop_smoke.py:25def onecmd_plus_hooks(self, command)-- Emit recognizable output for every routed verb. -
FakeEngine.__init__(method)modules/tools/loop_smoke.py:36def __init__(self)-- Bind a sandboxed task store and runtime tracker. -
FakeEngine.bind_shell(method)modules/tools/loop_smoke.py:44def bind_shell(self, shell)-- Record the bound shell (runner contract). -
FakeEngine.set_concurrency(method)modules/tools/loop_smoke.py:48def set_concurrency(self, value)-- Accept the concurrency knob without scheduling anything. -
FakeEngine.create_task(method)modules/tools/loop_smoke.py:52def create_task(self, goal, description)-- Create the task record and return its id. -
FakeEngine.orchestrate(method)modules/tools/loop_smoke.py:56def orchestrate(self)-- Run the injected executor once and report a done summary. -
run(function)modules/tools/loop_smoke.py:77def run()-- Run the smoke and return{"ok": bool, "checks": {...}, "result": {...}}. -
main(function)modules/tools/loop_smoke.py:114def main()-- CLI entry point: print the checks and exit 0/1.
Depends on: cli/lazy_monitor.py, modules/lazy_engine.py, modules/lazy_loop.py
-
run(function)modules/tools/monitor_smoke.py:20def run()-- Run the monitor smoke and return{"ok": bool, "checks": {...}}. -
main(function)modules/tools/monitor_smoke.py:59def main()-- CLI entry point: print the checks and exit 0/1.
Imported by: skills/autonomous_daemon.py
-
builtin_seeds(function)modules/toolset.py:35def builtin_seeds()-- Return the default graph-tool catalog (handlers stay in code). -
resolve(function)modules/toolset.py:72def resolve(agent, tool_key)-- Return the seed when bound to agent, else None (LAZY ToolResolve). -
extract_tool(function)modules/toolset.py:105def extract_tool(command)-- Split tool name with shlex; flag shell metacharacters. -
validate_shell(function)modules/toolset.py:128def validate_shell(role, command)-- Check a shell command against the role allowlist.
Depends on: core/logging.py
Imported by: modules/ai_fallback.py, modules/hive_invoke.py, modules/llm_factory.py, modules/moe_router.py, modules/unified_bridge.py, skills/toposwarm_autonomous.py
-
RoutedCall.lazyown_command(method)modules/toposwarm_bridge.py:81def lazyown_command(self)-- Return the LazyOwn shell command string to execute this tool call. -
OnlineFeedbackLoop.__init__(method)modules/toposwarm_bridge.py:296def __init__(self, maxsize) -
OnlineFeedbackLoop.register(method)modules/toposwarm_bridge.py:303def register(self, result, hidden)-- Register a routing result as pending feedback. -
OnlineFeedbackLoop.feedback(method)modules/toposwarm_bridge.py:318def feedback(self, result_id, good, comment, routing_head)-- Apply feedback for a routing decision. -
OnlineFeedbackLoop.pending_count(method)modules/toposwarm_bridge.py:379def pending_count(self) -
OnlineFeedbackLoop.stats(method)modules/toposwarm_bridge.py:382def stats(self) -
OnlineFeedbackLoop.load_feedback_for_training(method)modules/toposwarm_bridge.py:389def load_feedback_for_training(self)-- Load persisted feedback for --finetune. -
TopoSwarmBridge.__init__(method)modules/toposwarm_bridge.py:432def __init__(self) -
TopoSwarmBridge.available(method)modules/toposwarm_bridge.py:444def available(self)-- True if TopoSwarm directory exists (even if model not loaded). -
TopoSwarmBridge.model_loaded(method)modules/toposwarm_bridge.py:449def model_loaded(self) -
TopoSwarmBridge.feedback(method)modules/toposwarm_bridge.py:562def feedback(self, result_id, good, comment)-- Optional user feedback on a routing decision. -
TopoSwarmBridge.route(method)modules/toposwarm_bridge.py:586def route(self, prompt)-- Route an operator prompt to a LazyOwn tool call. -
TopoSwarmBridge.execute_via_orchestrator(method)modules/toposwarm_bridge.py:613def execute_via_orchestrator(self, prompt, no_model)-- Execute a prompt through the full TopoSwarm orchestrator (subprocess). -
get_bridge(function)modules/toposwarm_bridge.py:645def get_bridge()-- Return the module-level TopoSwarmBridge singleton (lazy init).
Imported by: cli/commands/persist_migrated.py
-
TrafficMorpher.__init__(method)modules/traffic_morpher.py:77def __init__(self) -
TrafficMorpher.get_random_http_headers(method)modules/traffic_morpher.py:81def get_random_http_headers(self)-- Return a randomized set of HTTP headers mimicking a real browser. -
TrafficMorpher.get_cdn_fronting_hosts(method)modules/traffic_morpher.py:91def get_cdn_fronting_hosts(self, provider, count)-- Return CDN domains suitable for domain fronting. -
TrafficMorpher.generate_traffic_padding(method)modules/traffic_morpher.py:108def generate_traffic_padding(self, min_bytes, max_bytes)-- Generate random padding bytes to normalize packet sizes. -
TrafficMorpher.generate_jitter(method)modules/traffic_morpher.py:125def generate_jitter(self, base_delay, jitter_pct)-- Calculate a sleep delay with jitter. -
TrafficMorpher.generate_dns_tunnel_payload(method)modules/traffic_morpher.py:138def generate_dns_tunnel_payload(self, data, domain)-- Encode data as DNS query subdomains for tunneling. -
TrafficMorpher.generate_icmp_exfil_payload(method)modules/traffic_morpher.py:164def generate_icmp_exfil_payload(self, data, chunk_size)-- Generate ICMP echo payloads for data exfiltration. -
TrafficMorpher.generate_websocket_masking(method)modules/traffic_morpher.py:190def generate_websocket_masking(self, data)-- Apply WebSocket frame masking with random key. -
TrafficMorpher.generate_cloudflare_worker_proxy_config(method)modules/traffic_morpher.py:205def generate_cloudflare_worker_proxy_config(self, c2_host, c2_port, auth_token)-- Generate a Cloudflare Worker script that proxies C2 traffic. -
TrafficMorpher.generate_beacon_profile(method)modules/traffic_morpher.py:270def generate_beacon_profile(self, name, protocol, jitter_pct, user_agent)-- Generate a complete C2 beacon profile configuration.
Next: API_p17.md