Inject customized mock managers to simulate the internal Django API objects.

Build a tool-calling agent executor scoped to `user`. `ChatOllama` is the local LLM; `create_tool_calling_agent` binds the tools to the model

Whether the assistant can serve a turn now (chatbot worker + Ollama), cached briefly.

Return and delete the pending payload iff it exists and belongs to `user_id` (one-shot).

Deletes cache keys associated with the list of instances for the given user. Args: user (User): The user for whom the ca

Retrieve members of the organization associated with the authenticated user. If the 'org' query parameter is set to 'true', this met

Reads the configured parameters for the plugin. Args: user (User): The user for whom the parameters are read.

Produce a cache key that changes every ``self.window_seconds``. Key format: ``chatbot_rate_{key}_{window_ts}`` Example: ``chatbot_r

Ensure a writable cache directory exists for capa. Returns the path to the writable cache directory. Falls back to a temporar

Retrieve all subclasses of the plugin class. Returns: list: Sorted list of plugin subclasses.

Close only the current page without stopping the browser or context.

Standard response for DNS resolver analyzers :param observable: observable analyzed :type observable: str :param resolutions: list of DNS

Annotates jobs with a weight based on the user and their organization. Args: user (User): The user to check. Re

Checks if the plugin configuration is configured. Args: user (User): The user for whom the configuration is checked (opt

A streamlined request handler with proper timeout management.

Return the current UTC time formatted as a human-readable string.

In case the analysis is stuck for whatever reason, we should force the status "failed" to avoid special exceptions, we can just put t

Connects a websocket communicator to this testcase application, forcing given user to be added to its scope. To be used as context ma

Creates jobs from the given playbook configuration. Args: value (Any): The value to be serialized. tlp (str)

Periodic cleanup: delete ChatSessions whose last activity is older than CHATBOT_MESSAGE_RETENTION_DAYS. "Last activity" is the most recent me

Disable the plugin due to rate limiting.

Generates task signatures for each configuration. Args: job (Job): The job instance. Yields: Genera

Recursively masks sensitive keys in dictionaries and lists. Uses word-boundary/camelCase aware matching to avoid false positives.

Called from *start* function and wrapped in a try-catch block. Should be overwritten in child class. Returns: di

Serializes the job and sends it to the appropriate channel groups. This method is called to send the job data to all relevant groups

Validates that the user has visibility to the selected playbooks. Args: user (User): The user to validate playbooks for.

Dynamically aggregate Job objects based on a specified field and time range. This method identifies the most frequent values of a gi