hanzo-api 1.1.12

use std::collections::HashMap;

use async_channel::Sender;
use chrono::{DateTime, Local, Utc};
use ed25519_dalek::VerifyingKey;
use serde_json::{Map, Value};
use hanzo_messages::{
    schemas::{
        coinbase_mpc_config::CoinbaseMPCWalletConfig,
        crontab::{CronTask, CronTaskAction},
        custom_prompt::CustomPrompt,
        identity::{Identity, StandardIdentity},
        job_config::JobConfig,
        llm_providers::{agent::Agent, serialized_llm_provider::SerializedLLMProvider, hanzo_backend::QuotaResponse},
        mcp_server::MCPServer,
        hanzo_name::HanzoName,
        hanzo_tool_offering::{HanzoToolOffering, UsageTypeInquiry},
        hanzo_tools::{CodeLanguage, DynamicToolType},
        smart_inbox::V2SmartInbox,
        tool_router_key::ToolRouterKey,
        wallet_complementary::{WalletRole, WalletSource},

        x402_types::Network,
    },
    hanzo_message::{
        hanzo_message::HanzoMessage,
        hanzo_message_schemas::{
            APIAddOllamaModels, APIChangeJobAgentRequest, APIVecFsCopyFolder, APIVecFsCopyItem, APIVecFsCreateFolder,
            APIVecFsDeleteFolder, APIVecFsDeleteItem, APIVecFsMoveFolder, APIVecFsMoveItem,
            APIVecFsRetrievePathSimplifiedJson, APIVecFsRetrieveSourceFile, APIVecFsSearchItems,
            ExportInboxMessagesFormat, IdentityPermissions, JobCreationInfo, JobMessage, RegistrationCodeType,
            V2ChatMessage,
        },
    },
    hanzo_utils::job_scope::MinimalJobScope,
};

use hanzo_tools::tools::{
    mcp_server_tool::MCPServerTool,
    hanzo_tool::{HanzoTool, HanzoToolHeader, HanzoToolWithAssets},
    tool_config::OAuth,
    tool_playground::ToolPlayground,
    tool_types::{OperatingSystem, RunnerType},
};
// use crate::{
//     prompts::custom_prompt::CustomPrompt, tools::hanzo_tool::{HanzoTool, HanzoToolHeader}, wallet::{
//         coinbase_mpc_wallet::CoinbaseMPCWalletConfig, local_ether_wallet::WalletSource, wallet_manager::WalletRole,
//     }
// };
use x25519_dalek::PublicKey as EncryptionPublicKey;

use crate::{
    api_v2::api_v2_handlers_mcp_servers::{AddMCPServerRequest, DeleteMCPServerResponse, UpdateMCPServerRequest},
    node_api_router::{APIUseRegistrationCodeSuccessResponse, SendResponseBody},
};

#[derive(Debug, Clone, PartialEq, serde::Serialize, serde::Deserialize)]
pub struct EmbeddingMigrationRequest {
    pub embedding_model: String,
    pub force: bool,
}

use super::{
    api_v2::api_v2_handlers_general::InitialRegistrationRequest,
    node_api_router::{APIError, GetPublicKeysResponse, SendResponseBodyData},
};

pub enum NodeCommand {
    Shutdown,
    // Command to make the node ping all the other nodes it knows about.
    PingAll,
    // Command to request the node's public keys for signing and encryption. The sender will receive the keys.
    GetPublicKeys(Sender<(VerifyingKey, EncryptionPublicKey)>),
    // Command to make the node send a `HanzoMessage` in an onionized (i.e., anonymous and encrypted) way.
    SendOnionizedMessage {
        msg: HanzoMessage,
        res: async_channel::Sender<Result<SendResponseBodyData, APIError>>,
    },
    GetNodeName {
        res: Sender<String>,
    },
    // Command to make the node create a registration code through the API. The sender will receive the code.
    APICreateRegistrationCode {
        msg: HanzoMessage,
        res: Sender<Result<String, APIError>>,
    },
    // Command to make the node create a registration code locally. The sender will receive the code.
    LocalCreateRegistrationCode {
        permissions: IdentityPermissions,
        code_type: RegistrationCodeType,
        res: Sender<String>,
    },
    // Command to make the node use a registration code encapsulated in a `HanzoMessage`. The sender will receive
    // the result.
    APIUseRegistrationCode {
        msg: HanzoMessage,
        res: Sender<Result<APIUseRegistrationCodeSuccessResponse, APIError>>,
    },
    // Command to fetch the last 'n' messages, where 'n' is defined by `limit`. The sender will receive the messages.
    FetchLastMessages {
        limit: usize,
        res: Sender<Vec<HanzoMessage>>,
    },
    // Command to request all subidentities that the node manages. The sender will receive the list of subidentities.
    APIGetAllSubidentities {
        res: Sender<Result<Vec<StandardIdentity>, APIError>>,
    },
    GetAllSubidentitiesDevicesAndLLMProviders(Sender<Result<Vec<Identity>, APIError>>),
    APIGetAllInboxesForProfile {
        msg: HanzoMessage,
        res: Sender<Result<Vec<String>, APIError>>,
    },
    GetLastMessagesFromInbox {
        inbox_name: String,
        limit: usize,
        offset_key: Option<String>,
        res: Sender<Vec<HanzoMessage>>,
    },
    GetLastMessagesFromInboxWithBranches {
        inbox_name: String,
        limit: usize,
        offset_key: Option<String>,
        res: Sender<Vec<Vec<HanzoMessage>>>,
    },
    APICreateJob {
        msg: HanzoMessage,
        res: Sender<Result<String, APIError>>,
    },
    APIJobMessage {
        msg: HanzoMessage,
        res: Sender<Result<SendResponseBodyData, APIError>>,
    },
    APIAddAgent {
        msg: HanzoMessage,
        res: Sender<Result<String, APIError>>,
    },
    AddAgent {
        agent: SerializedLLMProvider,
        profile: HanzoName,
        res: Sender<String>,
    },
    APIChangeJobAgent {
        msg: HanzoMessage,
        res: Sender<Result<String, APIError>>,
    },
    APIAvailableLLMProviders {
        msg: HanzoMessage,
        res: Sender<Result<Vec<SerializedLLMProvider>, APIError>>,
    },
    APIRemoveAgent {
        msg: HanzoMessage,
        res: Sender<Result<String, APIError>>,
    },
    APIModifyAgent {
        msg: HanzoMessage,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiImportAgent {
        bearer: String,
        url: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiImportAgentZip {
        bearer: String,
        file_data: Vec<u8>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiExportAgent {
        bearer: String,
        agent_id: String,
        res: Sender<Result<Vec<u8>, APIError>>,
    },
    V2ApiPublishAgent {
        bearer: String,
        agent_id: String,
        res: Sender<Result<Value, APIError>>,
    },
    AvailableLLMProviders {
        full_profile_name: String,
        res: Sender<Result<Vec<SerializedLLMProvider>, String>>,
    },
    APIChangeNodesName {
        msg: HanzoMessage,
        res: Sender<Result<(), APIError>>,
    },
    IsPristine {
        res: Sender<bool>,
    },
    APIScanOllamaModels {
        msg: HanzoMessage,
        res: Sender<Result<Vec<serde_json::Value>, APIError>>,
    },
    APIAddOllamaModels {
        msg: HanzoMessage,
        res: Sender<Result<(), APIError>>,
    },
    LocalScanOllamaModels {
        res: Sender<Result<Vec<serde_json::Value>, String>>,
    },
    AddOllamaModels {
        target_profile: HanzoName,
        models: Vec<String>,
        res: Sender<Result<(), String>>,
    },
    APIUpdateDefaultEmbeddingModel {
        msg: HanzoMessage,
        res: Sender<Result<String, APIError>>,
    },
    APIUpdateSupportedEmbeddingModels {
        msg: HanzoMessage,
        res: Sender<Result<String, APIError>>,
    },
    InternalCheckRustToolsInstallation {
        res: Sender<Result<bool, String>>,
    },
    // V2 API
    V2ApiGetPublicKeys {
        res: Sender<Result<GetPublicKeysResponse, APIError>>,
    },
    V2ApiInitialRegistration {
        payload: InitialRegistrationRequest,
        res: Sender<Result<APIUseRegistrationCodeSuccessResponse, APIError>>,
    },
    V2ApiAvailableLLMProviders {
        bearer: String,
        res: Sender<Result<Vec<SerializedLLMProvider>, APIError>>,
    },
    V2ApiGetAllSmartInboxes {
        bearer: String,
        limit: Option<usize>,
        offset: Option<String>,
        show_hidden: Option<bool>,
        agent_id: Option<String>,
        res: Sender<Result<Vec<V2SmartInbox>, APIError>>,
    },
    V2ApiGetAllSmartInboxesPaginated {
        bearer: String,
        limit: Option<usize>,
        offset: Option<String>,
        show_hidden: Option<bool>,
        agent_id: Option<String>,
        res: Sender<Result<serde_json::Value, APIError>>,
    },
    V2ApiUpdateSmartInboxName {
        bearer: String,
        inbox_name: String,
        custom_name: String,
        res: Sender<Result<(), APIError>>,
    },
    V2ApiGetLastMessagesFromInbox {
        bearer: String,
        inbox_name: String,
        limit: usize,
        offset_key: Option<String>,
        res: Sender<Result<Vec<V2ChatMessage>, APIError>>,
    },
    V2ApiGetLastMessagesFromInboxWithBranches {
        bearer: String,
        inbox_name: String,
        limit: usize,
        offset_key: Option<String>,
        res: Sender<Result<Vec<Vec<V2ChatMessage>>, APIError>>,
    },
    V2ApiCreateJob {
        bearer: String,
        job_creation_info: JobCreationInfo,
        llm_provider: String,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiJobMessage {
        bearer: String,
        job_message: JobMessage,
        res: Sender<Result<SendResponseBodyData, APIError>>,
    },
    V2ApiAddMessagesGodMode {
        bearer: String,
        job_id: String,
        messages: Vec<JobMessage>,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiForkJobMessages {
        bearer: String,
        job_id: String,
        message_id: String,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiRemoveJob {
        bearer: String,
        job_id: String,
        res: Sender<Result<SendResponseBody, APIError>>,
    },
    V2ApiVecFSRetrievePathSimplifiedJson {
        bearer: String,
        payload: APIVecFsRetrievePathSimplifiedJson,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiVecFSRetrieveVectorResource {
        bearer: String,
        path: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiVecFSRetrieveFilesForJob {
        bearer: String,
        job_id: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiVecFSGetFolderNameForJob {
        bearer: String,
        job_id: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiVecFSCreateFolder {
        bearer: String,
        payload: APIVecFsCreateFolder,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiMoveItem {
        bearer: String,
        payload: APIVecFsMoveItem,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiCopyItem {
        bearer: String,
        payload: APIVecFsCopyItem,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiMoveFolder {
        bearer: String,
        payload: APIVecFsMoveFolder,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiCopyFolder {
        bearer: String,
        payload: APIVecFsCopyFolder,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiDeleteFolder {
        bearer: String,
        payload: APIVecFsDeleteFolder,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiDeleteItem {
        bearer: String,
        payload: APIVecFsDeleteItem,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiSearchItems {
        bearer: String,
        payload: APIVecFsSearchItems,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiCreateFilesInbox {
        bearer: String, //
        res: Sender<Result<String, APIError>>,
    },
    V2ApiAddFileToInbox {
        bearer: String,
        file_inbox_name: String,
        filename: String,
        file: Vec<u8>,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiUploadFileToFolder {
        bearer: String,
        filename: String,
        file: Vec<u8>,
        path: String,
        file_datetime: Option<DateTime<Utc>>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiUploadFileToJob {
        bearer: String,
        job_id: String,
        filename: String,
        file: Vec<u8>,
        file_datetime: Option<DateTime<Utc>>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiRetrieveFile {
        bearer: String,
        payload: APIVecFsRetrieveSourceFile,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiSearchWorkflows {
        bearer: String,
        query: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiSearchHanzoTool {
        bearer: String,
        query: String,
        agent_or_llm: Option<String>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiListAllHanzoTools {
        bearer: String,
        category: Option<String>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiListAllMcpHanzoTools {
        category: Option<String>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiListAllNetworkHanzoTools {
        bearer: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiListAllHanzoToolsVersions {
        bearer: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiSetHanzoTool {
        bearer: String,
        tool_key: String,
        payload: Value,
        res: Sender<Result<HanzoTool, APIError>>,
    },
    V2ApiAddHanzoTool {
        bearer: String,
        hanzo_tool: HanzoToolWithAssets,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiAddNetworkAgent {
        bearer: String,
        hanzo_tool: HanzoToolWithAssets,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGetHanzoTool {
        bearer: String,
        payload: String,
        serialize_config: bool,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGetDefaultEmbeddingModel {
        bearer: String,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiGetSupportedEmbeddingModels {
        bearer: String,
        res: Sender<Result<Vec<String>, APIError>>,
    },
    V2ApiUpdateDefaultEmbeddingModel {
        bearer: String,
        model_name: String,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiUpdateSupportedEmbeddingModels {
        bearer: String,
        models: Vec<String>,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiAddLlmProvider {
        bearer: String,
        agent: SerializedLLMProvider,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiChangeJobLlmProvider {
        bearer: String,
        payload: APIChangeJobAgentRequest,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiUpdateJobConfig {
        bearer: String,
        job_id: String,
        config: JobConfig,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiGetJobConfig {
        bearer: String,
        job_id: String,
        res: Sender<Result<JobConfig, APIError>>,
    },
    V2ApiGetJobProvider {
        bearer: String,
        job_id: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiRemoveLlmProvider {
        bearer: String,
        llm_provider_id: String,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiModifyLlmProvider {
        bearer: String,
        agent: SerializedLLMProvider,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiChangeNodesName {
        bearer: String,
        new_name: String,
        res: Sender<Result<(), APIError>>,
    },
    V2ApiHanzoBackendGetQuota {
        bearer: String,
        model_type: String,
        res: Sender<Result<QuotaResponse, APIError>>,
    },
    V2ApiIsPristine {
        bearer: String,
        res: Sender<Result<bool, APIError>>,
    },
    V2ApiHealthCheck {
        res: Sender<Result<serde_json::Value, APIError>>,
    },
    V2ApiTriggerEmbeddingMigration {
        bearer: String,
        payload: EmbeddingMigrationRequest,
        res: Sender<Result<serde_json::Value, APIError>>,
    },
    V2ApiGetMigrationStatus {
        bearer: String,
        res: Sender<Result<serde_json::Value, APIError>>,
    },
    V2ApiDockerStatus {
        res: Sender<Result<serde_json::Value, APIError>>,
    },
    V2ApiGetStorageLocation {
        bearer: String,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiScanOllamaModels {
        bearer: String,
        res: Sender<Result<Vec<serde_json::Value>, APIError>>,
    },
    V2ApiAddOllamaModels {
        bearer: String,
        payload: APIAddOllamaModels,
        res: Sender<Result<(), APIError>>,
    },
    V2ApiGetToolsFromToolset {
        bearer: String,
        tool_set_key: String,
        res: Sender<Result<Vec<HanzoTool>, APIError>>,
    },
    V2SetCommonToolSetConfig {
        bearer: String,
        tool_set_key: String,
        value: HashMap<String, serde_json::Value>,
        res: Sender<Result<Vec<String>, APIError>>,
    },
    V2ApiGetToolOffering {
        bearer: String,
        tool_key_name: String,
        res: Sender<Result<HanzoToolOffering, APIError>>,
    },
    V2ApiRemoveToolOffering {
        bearer: String,
        tool_key_name: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGetAllToolOfferings {
        bearer: String,
        res: Sender<Result<Vec<HanzoToolHeader>, APIError>>,
    },
    V2ApiSetToolOffering {
        bearer: String,
        tool_offering: HanzoToolOffering,
        res: Sender<Result<HanzoToolOffering, APIError>>,
    },
    V2ApiGetAgentNetworkOffering {
        bearer: String,
        node_name: String,
        auto_check: bool,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiRestoreLocalEthersWallet {
        bearer: String,
        network: Network,
        source: WalletSource,
        role: WalletRole,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiCreateLocalEthersWallet {
        bearer: String,
        network: Network,
        role: WalletRole,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiCreateCoinbaseMPCWallet {
        bearer: String,
        network: Network,
        config: Option<CoinbaseMPCWalletConfig>,
        role: WalletRole,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiRestoreCoinbaseMPCWallet {
        bearer: String,
        network: Network,
        config: Option<CoinbaseMPCWalletConfig>,
        wallet_id: String,
        role: WalletRole,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiListWallets {
        bearer: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGetWalletBalance {
        bearer: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiRequestInvoice {
        bearer: String,
        tool_key_name: String,
        usage: UsageTypeInquiry,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiPayInvoice {
        bearer: String,
        invoice_id: String,
        data_for_tool: Value,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiRejectInvoice {
        bearer: String,
        invoice_id: String,
        reason: Option<String>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiListInvoices {
        bearer: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiAddCustomPrompt {
        bearer: String,
        prompt: CustomPrompt,
        res: Sender<Result<CustomPrompt, APIError>>,
    },
    V2ApiDeleteCustomPrompt {
        bearer: String,
        prompt_name: String,
        res: Sender<Result<CustomPrompt, APIError>>,
    },
    V2ApiGetAllCustomPrompts {
        bearer: String,
        res: Sender<Result<Vec<CustomPrompt>, APIError>>,
    },
    V2ApiGetCustomPrompt {
        bearer: String,
        prompt_name: String,
        res: Sender<Result<CustomPrompt, APIError>>,
    },
    V2ApiSearchCustomPrompts {
        bearer: String,
        query: String,
        res: Sender<Result<Vec<CustomPrompt>, APIError>>,
    },
    V2ApiUpdateCustomPrompt {
        bearer: String,
        prompt: CustomPrompt,
        res: Sender<Result<CustomPrompt, APIError>>,
    },
    V2ApiStopLLM {
        bearer: String,
        inbox_name: String,
        res: Sender<Result<(), APIError>>,
    },
    V2ApiAddAgent {
        bearer: String,
        agent: Agent,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiRemoveAgent {
        bearer: String,
        agent_id: String,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiUpdateAgent {
        bearer: String,
        partial_agent: serde_json::Value,
        res: Sender<Result<Agent, APIError>>,
    },
    V2ApiGetAgent {
        bearer: String,
        agent_id: String,
        res: Sender<Result<Agent, APIError>>,
    },
    V2ApiGetAllAgents {
        bearer: String,
        filter: Option<String>,
        res: Sender<Result<Vec<Agent>, APIError>>,
    },
    V2ApiRetryMessage {
        bearer: String,
        inbox_name: String,
        message_id: String,
        res: Sender<Result<SendResponseBodyData, APIError>>,
    },
    V2ApiUpdateJobScope {
        bearer: String,
        job_id: String,
        job_scope: MinimalJobScope,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGetJobScope {
        bearer: String,
        job_id: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGetToolingLogs {
        bearer: String,
        message_id: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGetMessageTraces {
        bearer: String,
        message_id: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiExecuteTool {
        bearer: String,
        tool_router_key: String,
        parameters: Map<String, Value>,
        tool_id: String,
        app_id: String,
        agent_id: Option<String>,
        llm_provider: String,
        extra_config: Map<String, Value>,
        mounts: Option<Vec<String>>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiExecuteMcpTool {
        tool_router_key: String,
        parameters: Map<String, Value>,
        tool_id: String,
        app_id: String,
        agent_id: Option<String>,
        extra_config: Map<String, Value>,
        mounts: Option<Vec<String>>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiCheckTool {
        bearer: String,
        code: String,
        language: CodeLanguage,
        additional_headers: Option<HashMap<String, String>>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiExecuteCode {
        bearer: String,
        code: String,
        tools: Vec<ToolRouterKey>,
        tool_type: DynamicToolType,
        parameters: Map<String, Value>,
        extra_config: Map<String, Value>,
        oauth: Option<Vec<OAuth>>,
        tool_id: String,
        app_id: String,
        agent_id: Option<String>,
        llm_provider: String,
        mounts: Option<Vec<String>>,
        runner: Option<RunnerType>,
        operating_system: Option<Vec<OperatingSystem>>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGenerateToolDefinitions {
        bearer: String,
        language: CodeLanguage,
        tools: Vec<ToolRouterKey>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGenerateToolFetchQuery {
        bearer: String,
        language: CodeLanguage,
        tools: Vec<ToolRouterKey>,
        code: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGenerateToolImplementation {
        bearer: String,
        message: JobMessage,
        language: CodeLanguage,
        tools: Vec<ToolRouterKey>,
        post_check: bool,
        raw: bool,
        res: Sender<Result<SendResponseBodyData, APIError>>,
    },
    V2ApiGenerateToolMetadataImplementation {
        bearer: String,
        job_id: String,
        language: CodeLanguage,
        tools: Vec<ToolRouterKey>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiExportMessagesFromInbox {
        bearer: String,
        inbox_name: String,
        format: ExportInboxMessagesFormat,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiSetPlaygroundTool {
        bearer: String,
        payload: ToolPlayground,
        tool_id: String,
        app_id: String,
        original_tool_key_path: Option<String>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiListPlaygroundTools {
        bearer: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiRemovePlaygroundTool {
        bearer: String,
        tool_key: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGetPlaygroundTool {
        bearer: String,
        tool_key: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiToolImplementationUndoTo {
        bearer: String,
        message_hash: String,
        job_id: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiToolImplementationCodeUpdate {
        bearer: String,
        job_id: String,
        code: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiExportTool {
        bearer: String,
        tool_key_path: String,
        res: Sender<Result<Vec<u8>, APIError>>,
    },
    V2ApiPublishTool {
        bearer: String,
        tool_key_path: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiImportTool {
        bearer: String,
        url: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiImportToolZip {
        bearer: String,
        file_data: Vec<u8>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiRemoveTool {
        bearer: String,
        tool_key: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiResolveHanzoFileProtocol {
        bearer: String,
        hanzo_file_protocol: String,
        res: Sender<Result<Vec<u8>, APIError>>,
    },
    V2ApiAddCronTask {
        bearer: String,
        cron: String,
        action: CronTaskAction,
        name: String,
        description: Option<String>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiListAllCronTasks {
        bearer: String,
        res: Sender<Result<Vec<CronTask>, APIError>>,
    },
    V2ApiGetSpecificCronTask {
        bearer: String,
        cron_task_id: i64,
        res: Sender<Result<Option<CronTask>, APIError>>,
    },
    V2ApiRemoveCronTask {
        bearer: String,
        cron_task_id: i64,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGetCronTaskLogs {
        bearer: String,
        cron_task_id: i64,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiUpdateCronTask {
        bearer: String,
        cron_task_id: i64,
        cron: String,
        action: CronTaskAction,
        name: String,
        description: Option<String>,
        paused: bool,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiForceExecuteCronTask {
        bearer: String,
        cron_task_id: i64,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGetCronSchedule {
        bearer: String,
        res: Sender<Result<Vec<(CronTask, chrono::DateTime<Local>)>, APIError>>,
    },
    V2ApiTestLlmProvider {
        bearer: String,
        provider: SerializedLLMProvider,
        res: Sender<Result<serde_json::Value, APIError>>,
    },
    V2ApiGetOAuthToken {
        bearer: String,
        connection_name: String,
        tool_key: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiSetOAuthToken {
        bearer: String,
        code: String,
        state: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiUploadToolAsset {
        bearer: String,
        tool_id: String,
        app_id: String,
        file_name: String,
        file_data: Vec<u8>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiUploadPlaygroundFile {
        bearer: String,
        tool_id: String,
        app_id: String,
        file_name: String,
        file_data: Vec<u8>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiListToolAssets {
        bearer: String,
        tool_id: String,
        app_id: String,
        res: Sender<Result<Vec<String>, APIError>>,
    },
    V2ApiDeleteToolAsset {
        bearer: String,
        tool_id: String,
        app_id: String,
        file_name: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiUploadAppFile {
        bearer: String,
        tool_id: String,
        app_id: String,
        file_name: String,
        file_data: Vec<u8>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGetAppFile {
        bearer: String,
        tool_id: String,
        app_id: String,
        file_name: String,
        res: Sender<Result<Vec<u8>, APIError>>,
    },
    V2ApiUpdateAppFile {
        bearer: String,
        tool_id: String,
        app_id: String,
        file_name: String,
        new_name: Option<String>,
        file_data: Option<Vec<u8>>,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiListAppFiles {
        bearer: String,
        tool_id: String,
        app_id: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiDeleteAppFile {
        bearer: String,
        tool_id: String,
        app_id: String,
        file_name: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiImportCronTask {
        bearer: String,
        url: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiExportCronTask {
        bearer: String,
        cron_task_id: i64,
        res: Sender<Result<Vec<u8>, APIError>>,
    },
    V2ApiSearchFilesByName {
        bearer: String,
        name: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiEnableAllTools {
        bearer: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiDisableAllTools {
        bearer: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiDuplicateTool {
        bearer: String,
        tool_key_path: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiAddRegexPattern {
        bearer: String,
        provider_name: String,
        pattern: String,
        response: String,
        description: Option<String>,
        priority: i32,
        res: Sender<Result<i64, APIError>>,
    },
    V2ApiStoreProxy {
        bearer: String,
        tool_router_key: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiStandAlonePlayground {
        bearer: String,
        code: Option<String>,
        metadata: Option<Value>,
        assets: Option<Vec<String>>,
        language: CodeLanguage,
        tools: Option<Vec<ToolRouterKey>>,
        parameters: Option<Value>,
        config: Option<Value>,
        oauth: Option<Vec<OAuth>>,
        tool_id: String,
        app_id: String,
        llm_provider: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiCheckDefaultToolsSync {
        bearer: String,
        res: Sender<Result<bool, APIError>>,
    },
    V2ApiComputeQuestsStatus {
        bearer: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiComputeAndSendQuestsStatus {
        bearer: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiListMCPServers {
        bearer: String,
        res: Sender<Result<Vec<MCPServer>, APIError>>,
    },
    V2ApiAddMCPServer {
        bearer: String,
        mcp_server: AddMCPServerRequest,
        res: Sender<Result<MCPServer, APIError>>,
    },
    V2ApiUpdateMCPServer {
        bearer: String,
        mcp_server: UpdateMCPServerRequest,
        res: Sender<Result<MCPServer, APIError>>,
    },
    V2ApiImportMCPServerFromGitHubURL {
        bearer: String,
        github_url: String,
        res: Sender<Result<AddMCPServerRequest, APIError>>,
    },
    V2ApiDeleteMCPServer {
        bearer: String,
        mcp_server_id: i64,
        res: Sender<Result<DeleteMCPServerResponse, APIError>>,
    },
    V2ApiGetAllMCPServerTools {
        bearer: String,
        mcp_server_id: i64,
        res: Sender<Result<Vec<MCPServerTool>, APIError>>,
    },
    V2ApiSetToolEnabled {
        bearer: String,
        tool_router_key: String,
        enabled: bool,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiSetToolMcpEnabled {
        bearer: String,
        tool_router_key: String,
        mcp_enabled: bool,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiCopyToolAssets {
        bearer: String,
        is_first_playground: bool,
        first_path: String,
        is_second_playground: bool,
        second_path: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiSetPreferences {
        bearer: String,
        payload: HashMap<String, serde_json::Value>,
        res: Sender<Result<String, APIError>>,
    },
    V2ApiGetPreferences {
        bearer: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGetLastUsedAgentsAndLLMs {
        bearer: String,
        last: usize,
        res: Sender<Result<Vec<String>, APIError>>,
    },
    V2ApiGetHanzoToolMetadata {
        bearer: String,
        tool_router_key: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGetToolWithOffering {
        bearer: String,
        tool_key_name: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGetToolsWithOfferings {
        bearer: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiSetEnableMCPServer {
        bearer: String,
        mcp_server_id: i64,
        is_enabled: bool,
        res: Sender<Result<MCPServer, APIError>>,
    },
    V2ApiSetNgrokAuthToken {
        bearer: String,
        auth_token: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiClearNgrokAuthToken {
        bearer: String,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiSetNgrokEnabled {
        bearer: String,
        enabled: bool,
        res: Sender<Result<Value, APIError>>,
    },
    V2ApiGetNgrokStatus {
        bearer: String,
        res: Sender<Result<Value, APIError>>,
    },
}