dap_chain_plugins_command.c

#include "dap_chain_plugins_command.h"

static bool s_l_restart_plugins = false;

#undef LOG_TAG
#define LOG_TAG "dap_chain_plugins_command"

void dap_chain_plugins_command_create(void){
    if (!s_l_restart_plugins){
        dap_chain_node_cli_cmd_item_create("plugins", dap_chain_plugins_command_handler, NULL,
                                           "Commands for working with plugins.",
                                           "plugins list \t- show list plugins \n"
                                           "plugins show --name <name_plugin> \t-show information for plugin \n"
                                           "plugins restart \t-Restart all plugins \n"
                                           "plugins reload --name <name_plugin> \t-Restart plugin \n\n");
        s_l_restart_plugins = true;
    }
}
int dap_chain_plugins_command_handler(int a_argc, char **a_argv, void *a_arg_func, char **a_str_reply){
    (void)a_arg_func;
    enum {
        CMD_NONE, CMD_LIST, CMD_SHOW_NAME, CMD_RESTART, CMD_RELOAD_NAME
    };
    int l_arg_index = 1;
    int l_cmd_name = CMD_NONE;
    const char *l_name_plugin = NULL;
    dap_chain_plugins_list_manifest_t *l_element = NULL;
    if (dap_chain_node_cli_find_option_val(a_argv,l_arg_index, a_argc, "list", NULL))
        l_cmd_name = CMD_LIST;
    if (dap_chain_node_cli_find_option_val(a_argv,l_arg_index, a_argc, "show", NULL))
        l_cmd_name = CMD_SHOW_NAME;
    if (dap_chain_node_cli_find_option_val(a_argv,l_arg_index, a_argc, "restart", NULL))
        l_cmd_name = CMD_RESTART;
    if (dap_chain_node_cli_find_option_val(a_argv,l_arg_index, a_argc, "reload", NULL))
        l_cmd_name = CMD_RELOAD_NAME;
    char *l_str = NULL;
    switch (l_cmd_name) {
    case CMD_LIST:
        l_str = dap_strdup("|\tName plugin\t|\tVersion\t|\tAuthor(s)\t|\n");
        LL_FOREACH(dap_chain_plugins_manifests_get_list(), l_element){
            l_str = dap_strjoin(NULL,
                              l_str, "|\t",l_element->name, "\t|\t", l_element->version, "\t|\t", l_element->author, "\t|\n", NULL);

        }
        dap_chain_node_cli_set_reply_text(a_str_reply, l_str);
        break;
    case CMD_SHOW_NAME:
        dap_chain_node_cli_find_option_val(a_argv, l_arg_index, a_argc, "--name", &l_name_plugin);
        LL_SEARCH(dap_chain_plugins_manifests_get_list(), l_element, l_name_plugin, dap_chain_plugins_manifest_name_cmp);
        if (l_element != NULL){
            char *l_dep = dap_chain_plugins_manifests_get_list_dependencyes(l_element);
            if (l_dep != NULL){
                dap_chain_node_cli_set_reply_text(a_str_reply, " Name: %s\n Version: %s\n Author: %s\n"
                                                               " Description: %s\n Dependencys: %s \n\n",
                                                  l_element->name, l_element->version, l_element->author,
                                                  l_element->description, l_dep);
                DAP_FREE(l_dep);
            } else {
                dap_chain_node_cli_set_reply_text(a_str_reply, " Name: %s\n Version: %s\n Author: %s\n"
                                                               " Description: %s\n\n",
                                                  l_element->name, l_element->version, l_element->author, l_element->description);
            }
        } else {
            dap_chain_node_cli_set_reply_text(a_str_reply, "Can't searching plugin with name %s", l_name_plugin);
        }
        break;
    case CMD_RESTART:
        log_it(L_NOTICE, "Start procedure restart python plugins module");
        dap_chain_plugins_deinit();
        dap_chain_plugins_init(g_config);
        log_it(L_NOTICE, "Done procedure restart python plugins module");
        dap_chain_node_cli_set_reply_text(a_str_reply, "Done procedure restart python plugins module.");
        break;
    case CMD_RELOAD_NAME:
        dap_chain_node_cli_find_option_val(a_argv, l_arg_index, a_argc, "--name", &l_name_plugin);
        int l_result = dap_chain_plugins_reload_plugin(l_name_plugin);
        switch (l_result) {
        case 0:
            dap_chain_node_cli_set_reply_text(a_str_reply, "Restarting the plugin %s completed successfully.", l_name_plugin);
            break;
        case -2:
            dap_chain_node_cli_set_reply_text(a_str_reply,
                                              "%s plugin has unresolved dependencys, restart all plagins",
                                              l_name_plugin);
            break;
        case -3:
            dap_chain_node_cli_set_reply_text(a_str_reply, "Registration %s manifest for %s plugin fail", l_name_plugin);
            break;
        case -4:
            dap_chain_node_cli_set_reply_text(a_str_reply, "A plugin named %s will not find", l_name_plugin);
            break;
        default:
            dap_chain_node_cli_set_reply_text(a_str_reply, "An unforeseen error has occurred.");
            break;
        }
        break;
    default:
        dap_chain_node_cli_set_reply_text(a_str_reply, "Not validation parameters");
        break;

    }
    return 0;
}