/*
	 * Copyright 2025-2026 the Pacemaker project contributors
	 *
	 * The version control history for this file may have further details.
	 *
	 * This source code is licensed under the GNU General Public License version 2
	 * or later (GPLv2+) WITHOUT ANY WARRANTY.
	 */
	
	#include <crm_internal.h>
	
	#include <errno.h>              // EINVAL, ENODEV, ENOENT, ENOTCONN
	#include <locale.h>             // setlocale
	#include <stdbool.h>
	#include <stddef.h>
	#include <stdlib.h>             // setenv, unsetenv
	#include <syslog.h>             // LOG_DEBUG
	#include <sys/stat.h>           // umask, S_IRGRP, S_IROTH, ...
	#include <sys/wait.h>           // WEXITSTATUS
	#include <unistd.h>             // geteuid
	
	#include <glib.h>
	#include <libxml/tree.h>        // xmlNode, xmlNodeGetContent
	#include <libxml/xmlmemory.h>   // xmlFree
	#include <libxml/xmlstring.h>   // xmlChar
	
	#include <crm/cib/internal.h>   // cib__clean_up_connection, cib__signon_query
	#include <crm/common/internal.h>
	#include <crm/common/results.h>
	#include <crm/common/xml.h>     // crm_element_value, PCMK_XA_*
	
	#include <pacemaker-internal.h> // pcmk__query_node_name
	
	#define SUMMARY "cibsecret - manage sensitive information in Pacemaker CIB"
	
	#define LRM_MAGIC "lrm://"
	#define SSH_OPTS "-o StrictHostKeyChecking=no"
	
	static gchar **remainder = NULL;
	static gboolean no_cib = FALSE;
	
	static GOptionEntry entries[] = {
	    { "no-cib", 'C', G_OPTION_FLAG_NONE, G_OPTION_ARG_NONE, &no_cib,
	      "Don't read or write the CIB",
	      NULL },
	
	    { G_OPTION_REMAINING, 0, G_OPTION_FLAG_NONE, G_OPTION_ARG_STRING_ARRAY, &remainder,
	      NULL,
	      NULL },
	
	    { NULL }
	};
	
	/*!
	 * \internal
	 * \brief A function for running a command on remote hosts
	 *
	 * \param[in,out] out     Output object
	 * \param[in]     nodes   A list of remote hosts
	 * \param[in]     argv    The list of command line arguments to run
	 *
	 * \return Standard Pacemaker return code
	 *
	 * \note On error, \p out->err() will be called to record stderr of the process
	 */
	typedef int (*rsh_fn_t)(pcmk__output_t *out, char **nodes, char **argv);
	
	/*!
	 * \internal
	 * \brief A function for copying a file to remote hosts
	 *
	 * \param[in,out] out     Output object
	 * \param[in]     nodes   A list of remote hosts
	 * \param[in]     to      The destination path on the remote host
	 * \param[in]     from    The local file (or directory) to copy
	 *
	 * \return Standard Pacemaker return code
	 *
	 * \note \p from can either be a single file or a directory.  It cannot be
	 *       be multiple files in a space-separated string.  If multiple files need
	 *       to be copied, either copy the entire directory at once or call this
	 *       function multiple times.
	 *
	 * \note On error, \p out->err() will be called to record stderr of the process
	 */
	typedef int (*rcp_fn_t)(pcmk__output_t *out, char **nodes, const char *to,
	                        const char *from);
	
	struct subcommand_entry {
	    const char *name;
	    int args;
	    const char *usage;
	    bool requires_cib;
	    int (*handler)(pcmk__output_t *out, rsh_fn_t rsh_fn, rcp_fn_t rcp_fn);
	};
	
	/*!
	 * \internal
	 * \brief Run a command line process
	 *
	 * \param[in,out] out          Output object
	 * \param[in]     argv         The list of command line arguments to run
	 * \param[out]    standard_out If not NULL, where to save stdout of the process
	 *
	 * \return Standard Pacemaker return code
	 *
	 * \note On error, \p out->err() will be called to record stderr of the process
	 */
	static int
	run_cmdline(pcmk__output_t *out, char **argv, char **standard_out)
	{
	    int rc = pcmk_rc_ok;
	    gboolean success = FALSE;
	    GError *error = NULL;
	    gchar *sout = NULL;
	    gchar *serr = NULL;
	    int status;
	
	    /* A failure here is a failure starting the program (for example, it doesn't
	     * exist on the $PATH), not that it ran but exited with an error code.
	     */
	    success = g_spawn_sync(NULL, argv, NULL, G_SPAWN_SEARCH_PATH, NULL, NULL,
	                           &sout, &serr, &status, &error);
	    if (!success) {
	        out->err(out, "%s", error->message);
	        rc = pcmk_rc_error;
	        goto done;
	    }
	
	    /* A failure here indicates that the program exited with a non-zero exit
	     * code or due to a fatal signal.
	     */
	    /* @FIXME @COMPAT g_spawn_check_exit_status is deprecated as of glib 2.70
	     * and is replaced with g_spawn_check_wait_status.
	     */
	    success = g_spawn_check_exit_status(status, &error);
	
	    if (!success) {
	        out->err(out, "%s",  error->message);
	        out->subprocess_output(out, WEXITSTATUS(status), sout, serr);
	        rc = pcmk_rc_error;
	    }
	
	done:
	    pcmk__str_update(standard_out, sout);
	
	    g_free(sout);
	    g_free(serr);
	    g_clear_error(&error);
	
	    return rc;
	}
	
	static int
	pssh(pcmk__output_t *out, char **nodes, char **cmd)
	{
	    int rc = pcmk_rc_ok;
	    gchar *hosts = g_strjoinv(" ", nodes);
	
	    int cmd_len = g_strv_length(cmd);
	    // Length of our args, plus the length of cmd, plus 1 for terminating NULL
	    int total_len = 7 + cmd_len + 1;
	    gchar **argv = g_new0(gchar *, total_len);
	
	    argv[0] = g_strdup("pssh");
	    argv[1] = g_strdup("-i");
	    argv[2] = g_strdup("-H");
	    argv[3] = hosts;
	    argv[4] = g_strdup("-O");
	    argv[5] = g_strdup("StrictHostKeyChecking=no");
	    argv[6] = g_strdup("--");
	
	    // Append passed in args to argv
	    for (int i = 0; i < cmd_len; i++) {
	        argv[i+7] = g_strdup(cmd[i]);
	    }
	
	    argv[total_len-1] = NULL;
	
	    rc = run_cmdline(out, argv, NULL);
	    g_strfreev(argv);
	    return rc;
	}
	
	static int
	pdsh(pcmk__output_t *out, char **nodes, char **cmd)
	{
	    int rc = pcmk_rc_ok;
	    gchar *hosts = g_strjoinv(",", nodes);
	
	    int cmd_len = g_strv_length(cmd);
	    int total_len = 4 + cmd_len + 1;
	    gchar **argv = g_new0(gchar *, total_len);
	
	    argv[0] = g_strdup("pdsh");
	    argv[1] = g_strdup("-w");
	    argv[2] = hosts;
	    argv[3] = g_strdup("--");
	
	    for (int i = 0; i < cmd_len; i++) {
	        argv[i+4] = g_strdup(cmd[i]);
	    }
	
	    argv[total_len-1] = NULL;
	
	    setenv("PDSH_SSH_ARGS_APPEND", SSH_OPTS, 1);
	    rc = run_cmdline(out, argv, NULL);
	    unsetenv("PDSH_SSH_ARGS_APPEND");
	
	    g_strfreev(argv);
	    return rc;
	}
	
	static int
	ssh(pcmk__output_t *out, char **nodes, char **cmd)
	{
	    int cmd_len = g_strv_length(cmd);
	    int total_len = 5 + cmd_len + 1;
	    int rc = pcmk_rc_ok;
	
	    for (char **node = nodes; *node != NULL; node++) {
	        gchar **argv = g_new0(gchar *, total_len);
	
	        argv[0] = g_strdup("ssh");
	        argv[1] = g_strdup("-o");
	        argv[2] = g_strdup("StrictHostKeyChecking=no");
	        argv[3] = g_strdup(*node);
	        argv[4] = g_strdup("--");
	
	        for (int i = 0; i < cmd_len; i++) {
	            argv[i+5] = g_strdup(cmd[i]);
	        }
	
	        argv[total_len-1] = NULL;
	
	        rc = run_cmdline(out, argv, NULL);
	        g_strfreev(argv);
	
	        if (rc != pcmk_rc_ok) {
	            return rc;
	        }
	    }
	
	    return rc;
	}
	
	static int
	pscp(pcmk__output_t *out, char **nodes, const char *to, const char *from)
	{
	    int rc = pcmk_rc_ok;
	    gchar **argv = g_new0(gchar *, 11);
	    gchar *hosts = g_strjoinv(" ", nodes);
	
	    argv[0] = g_strdup("pscp.pssh");
	    argv[1] = g_strdup("-H");
	    argv[2] = hosts;
	    argv[3] = g_strdup("-x");
	    argv[4] = g_strdup("-pr");
	    argv[5] = g_strdup("-O");
	    argv[6] = g_strdup("StrictHostKeyChecking=no");
	    argv[7] = g_strdup("--");
	    argv[8] = g_strdup(from);
	    argv[9] = g_strdup(to);
	    argv[10] = NULL;
	
	    rc = run_cmdline(out, argv, NULL);
	
	    g_strfreev(argv);
	    return rc;
	}
	
	static int
	pdcp(pcmk__output_t *out, char **nodes, const char *to, const char *from)
	{
	    int rc = pcmk_rc_ok;
	    gchar **argv = g_new0(gchar *, 8);
	    gchar *hosts = g_strjoinv(",", nodes);
	
	    argv[0] = g_strdup("pdcp");
	    argv[1] = g_strdup("-pr");
	    argv[2] = g_strdup("-w");
	    argv[3] = hosts;
	    argv[4] = g_strdup("--");
	    argv[5] = g_strdup(from);
	    argv[6] = g_strdup(to);
	    argv[7] = NULL;
	
	    setenv("PDSH_SSH_ARGS_APPEND", SSH_OPTS, 1);
	    rc = run_cmdline(out, argv, NULL);
	    unsetenv("PDSH_SSH_ARGS_APPEND");
	
	    g_strfreev(argv);
	    return rc;
	}
	
	static int
	scp(pcmk__output_t *out, char **nodes, const char *to, const char *from)
	{
	    int rc = pcmk_rc_ok;
	
	    for (char **node = nodes; *node != NULL; node++) {
	        gchar **argv = g_new0(gchar *, 7);
	
	        argv[0] = g_strdup("scp");
	        argv[1] = g_strdup("-pqr");
	        argv[2] = g_strdup("-o");
	        argv[3] = g_strdup("StrictHostKeyChecking=no");
	        argv[4] = g_strdup(from);
	        argv[5] = g_strdup_printf("%s:%s", *node, to);
	        argv[6] = NULL;
	
	        rc = run_cmdline(out, argv, NULL);
	        g_strfreev(argv);
	
	        if (rc != pcmk_rc_ok) {
	            return rc;
	        }
	    }
	
	    return rc;
	}
	
	static gchar **
	reachable_hosts(pcmk__output_t *out, GList *all)
	{
	    GPtrArray *reachable = NULL;
	    gchar *path = NULL;
	
	    path = g_find_program_in_path("fping");
	
	    reachable = g_ptr_array_new();
	
	    if ((path == NULL) || (geteuid() != 0)) {
	        for (GList *host = all; host != NULL; host = host->next) {
	            int rc = pcmk_rc_ok;
	            gchar **argv = g_new0(gchar *, 6);
	
	            argv[0] = g_strdup("ping");
	            argv[1] = g_strdup("-c");
	            argv[2] = g_strdup("2");
	            argv[3] = g_strdup("-q");
	            argv[4] = g_strdup(host->data);
	            argv[5] = NULL;
	
	            rc = run_cmdline(out, argv, NULL);
	            g_strfreev(argv);
	
	            if (rc == pcmk_rc_ok) {
	                g_ptr_array_add(reachable, g_strdup(host->data));
	            }
	        }
	
	    } else {
	        GString *all_str = g_string_sized_new(64);
	        gchar **parts = NULL;
	        gchar **argv = g_new0(gchar *, 5);
	        char *standard_out = NULL;
	
	        for (GList *host = all; host != NULL; host = host->next) {
	            pcmk__add_word(&all_str, 64, host->data);
	        }
	
	        argv[0] = g_strdup("fping");
	        argv[1] = g_strdup("-a");
	        argv[2] = g_strdup("-q");
	        argv[3] = g_strdup(all_str->str);
	        argv[4] = NULL;
	
	        run_cmdline(out, argv, &standard_out);
	        g_strfreev(argv);
	
	        parts = g_strsplit(standard_out, "\n", 0);
	        for (gchar **p = parts; *p != NULL; p++) {
	            if (pcmk__str_empty(*p)) {
	                continue;
	            }
	
	            g_ptr_array_add(reachable, g_strdup(*p));
	        }
	
	        free(standard_out);
	        g_string_free(all_str, TRUE);
	        g_strfreev(parts);
	    }
	
	    g_free(path);
	    g_ptr_array_add(reachable, NULL);
	    return (char **) g_ptr_array_free(reachable, FALSE);
	}
	
	struct node_data {
	    pcmk__output_t *out;
	    char *local_node;
	    const char *field;
	    GList *all_nodes;
	};
	
	static void
	node_iter_helper(xmlNode *result, void *user_data)
	{
	    struct node_data *data = user_data;
	    const char *uname = pcmk__xe_get(result, PCMK_XA_UNAME);
	    const char *id = pcmk__xe_get(result, data->field);
	    const char *name = pcmk__s(uname, id);
	
	    /* Filter out the local node */
	    if (pcmk__str_eq(name, data->local_node, pcmk__str_null_matches)) {
	        return;
	    }
	
	    data->all_nodes = g_list_append(data->all_nodes, g_strdup(name));
	}
	
	static gchar **
	get_live_peers(pcmk__output_t *out)
	{
	    int rc = pcmk_rc_ok;
	    xmlNode *xml_node = NULL;
	    gchar **reachable = NULL;
	    cib_t *cib = NULL;
	
	    struct node_data nd = {
	        .out = out,
	        .local_node = NULL,
	        .all_nodes = NULL
	    };
	
	    rc = cib__signon_query(out, &cib, &xml_node);
	    if (rc != pcmk_rc_ok) {
	        out->err(out, "Could not get list of cluster nodes");
	        goto done;
	    }
	
	    /* Get the local node name if possible. */
	    if (cib->variant != cib_file) {
	        rc = pcmk__query_node_name(out, 0, &(nd.local_node), 0);
	        if (rc != pcmk_rc_ok) {
	            out->err(out, "Could not get local node name");
	            goto done;
	        }
	    }
	
	    /* Filter out the local node from the list of all node names.  If we don't
	     * have a local node (for instance, because CIB_file is set) then we'll
	     * just use the list of all node names instead.
	     */
	    nd.field = PCMK_XA_ID;
	    pcmk__xpath_foreach_result(xml_node->doc, PCMK__XP_MEMBER_NODE_CONFIG,
	                               node_iter_helper, &nd);
	    nd.field = PCMK_XA_VALUE;
	    pcmk__xpath_foreach_result(xml_node->doc, PCMK__XP_GUEST_NODE_CONFIG,
	                               node_iter_helper, &nd);
	    nd.field = PCMK_XA_ID;
	    pcmk__xpath_foreach_result(xml_node->doc, PCMK__XP_REMOTE_NODE_CONFIG,
	                               node_iter_helper, &nd);
	
	    if (nd.all_nodes == NULL) {
	        goto done;
	    }
	
	    /* Get a list of all nodes that respond to pings */
	    reachable = reachable_hosts(out, nd.all_nodes);
	
	    /* Warn the user about any that didn't respond to pings */
	    for (const GList *iter = nd.all_nodes; iter != NULL; iter = iter->next) {
	        const char *node_name = iter->data;
	
	        if (!pcmk__g_strv_contains(reachable, node_name)) {
	            out->info(out, "Node %s is down - you'll need to update it "
	                      "with `cibsecret sync` later", node_name);
	        }
	    }
	
	done:
	    cib__clean_up_connection(&cib);
	
	    free(nd.local_node);
	    free(xml_node);
	    g_list_free_full(nd.all_nodes, g_free);
	
	    return reachable;
	}
	
	static int
	sync_one_file(pcmk__output_t *out, rsh_fn_t rsh_fn, rcp_fn_t rcp_fn,
	              const char *path)
	{
	    int rc = pcmk_rc_ok;
	    gchar *dirname = NULL;
	    gchar **peers = get_live_peers(out);
	    gchar *peer_str = NULL;
	    gchar **argv = g_new0(gchar *, 4);
	
	    if (peers == NULL) {
	        g_strfreev(argv);
	        return pcmk_rc_ok;
	    }
	
	    peer_str = g_strjoinv(" ", peers);
	
	    if (pcmk__str_eq(remainder[0], "delete", pcmk__str_none)) {
	        out->info(out, "Deleting %s from %s ...", path, peer_str);
	    } else {
	        out->info(out, "Syncing %s to %s ...", path, peer_str);
	    }
	
	    dirname = g_path_get_dirname(path);
	
	    argv[0] = g_strdup("mkdir");
	    argv[1] = g_strdup("-p");
	    argv[2] = g_strdup(dirname);
	    argv[3] = NULL;
	
	    rc = rsh_fn(out, peers, argv);
	
	    if (rc != pcmk_rc_ok) {
	        goto done;
	    }
	
	    if (g_file_test(path, G_FILE_TEST_EXISTS | G_FILE_TEST_IS_REGULAR)) {
	        char *sign_path = NULL;
	
	        rc = rcp_fn(out, peers, dirname, path);
	        if (rc != pcmk_rc_ok) {
	            goto done;
	        }
	
	        sign_path = pcmk__assert_asprintf("%s.sign", path);
	        rc = rcp_fn(out, peers, dirname, sign_path);
	        free(sign_path);
	
	    } else {
	        g_strfreev(argv);
	        argv = g_new0(gchar *, 5);
	
	        argv[0] = g_strdup("rm");
	        argv[1] = g_strdup("-f");
	        argv[2] = g_strdup(path);
	        argv[3] = g_strdup_printf("%s.sign", path);
	        argv[4] = NULL;
	
	        rc = rsh_fn(out, peers, argv);
	    }
	
	done:
	    g_free(dirname);
	    g_strfreev(argv);
	    g_strfreev(peers);
	    g_free(peer_str);
	    return rc;
	}
	
	static int
	check_cib_rsc(pcmk__output_t *out, const char *rsc)
	{
	    int rc = pcmk_rc_ok;
	    gchar **argv = g_new0(gchar *, 5);
	
	    if (no_cib) {
	        goto done;
	    }
	
	    argv[0] = g_strdup("crm_resource");
	    argv[1] = g_strdup("-r");
	    argv[2] = g_strdup(rsc);
	    argv[3] = g_strdup("-W");
	    argv[4] = NULL;
	
	    rc = run_cmdline(out, argv, NULL);
	
	done:
	    g_strfreev(argv);
	    return rc;
	}
	
	static bool
	is_secret(const char *s)
	{
	    if (no_cib) {
	        /* Assume that the secret is in the CIB if we can't connect */
	        return true;
	    }
	
	    return pcmk__str_eq(s, LRM_MAGIC, pcmk__str_none);
	}
	
	static char *
	get_cib_param(pcmk__output_t *out, const char *rsc, const char *param)
	{
	    int rc = pcmk_rc_ok;
	    gchar **argv = g_new0(gchar *, 7);
	    char *standard_out = NULL;
	    char *retval = NULL;
	    char *xpath = NULL;
	    xmlNode *xml = NULL;
	    xmlNode *node = NULL;
	    xmlChar *content = NULL;
	
	    if (no_cib) {
	        g_strfreev(argv);
	        return NULL;
	    }
	
	    argv[0] = g_strdup("crm_resource");
	    argv[1] = g_strdup("-r");
	    argv[2] = g_strdup(rsc);
	    argv[3] = g_strdup("-g");
	    argv[4] = g_strdup(param);
	    argv[5] = g_strdup("--output-as=xml");
	    argv[6] = NULL;
	
	    rc = run_cmdline(out, argv, &standard_out);
	    g_strfreev(argv);
	
	    if (rc != pcmk_rc_ok) {
	        goto done;
	    }
	
	    xml = pcmk__xml_parse(standard_out);
	
	    if (xml == NULL) {
	        goto done;
	    }
	
	    xpath = pcmk__assert_asprintf("//" PCMK_XE_ITEM "[@" PCMK_XA_NAME "='%s']",
	                                  param);
	    node = pcmk__xpath_find_one(xml->doc, xpath, LOG_DEBUG);
	
	    if (node == NULL) {
	        goto done;
	    }
	
	    content = xmlNodeGetContent(node);
	
	    if (content != NULL) {
	        retval = pcmk__str_copy((char *) content);
	        xmlFree(content);
	    }
	
	done:
	    free(standard_out);
	    free(xpath);
	    pcmk__xml_free(xml);
	    return retval;
	}
	
	static int
	remove_cib_param(pcmk__output_t *out, const char *rsc, const char *param)
	{
	    int rc = pcmk_rc_ok;
	    gchar **argv = g_new0(gchar *, 6);
	
	    if (no_cib) {
	        goto done;
	    }
	
	    argv[0] = g_strdup("crm_resource");
	    argv[1] = g_strdup("-r");
	    argv[2] = g_strdup(rsc);
	    argv[3] = g_strdup("-d");
	    argv[4] = g_strdup(param);
	    argv[5] = NULL;
	
	    rc = run_cmdline(out, argv, NULL);
	
	done:
	    g_strfreev(argv);
	    return rc;
	}
	
	static int
	set_cib_param(pcmk__output_t *out, const char *rsc, const char *param,
	              const char *value)
	{
	    int rc = pcmk_rc_ok;
	    gchar **argv = g_new0(gchar *, 8);
	
	    if (no_cib) {
	        goto done;
	    }
	
	    argv[0] = g_strdup("crm_resource");
	    argv[1] = g_strdup("-r");
	    argv[2] = g_strdup(rsc);
	    argv[3] = g_strdup("-p");
	    argv[4] = g_strdup(param);
	    argv[5] = g_strdup("-v");
	    argv[6] = g_strdup(value);
	    argv[7] = NULL;
	
	    rc = run_cmdline(out, argv, NULL);
	
	done:
	    g_strfreev(argv);
	    return rc;
	}
	
	static char *
	local_files_get(const char *rsc, const char *param)
	{
	    char *retval = NULL;
	    char *lf_file = NULL;
	    gchar *contents = NULL;
	
	    lf_file = pcmk__assert_asprintf(PCMK__CIB_SECRETS_DIR "/%s/%s", rsc, param);
	    if (g_file_get_contents(lf_file, &contents, NULL, NULL)) {
	        contents = g_strchomp(contents);
	        retval = pcmk__str_copy(contents);
	        g_free(contents);
	    }
	
	    free(lf_file);
	    return retval;
	}
	
	static char *
	local_files_getsum(const char *rsc, const char *param)
	{
	    char *retval = NULL;
	    char *lf_file = NULL;
	    gchar *contents = NULL;
	
	    lf_file = pcmk__assert_asprintf(PCMK__CIB_SECRETS_DIR "/%s/%s.sign", rsc,
	                                    param);
	    if (g_file_get_contents(lf_file, &contents, NULL, NULL)) {
	        contents = g_strchomp(contents);
	        retval = pcmk__str_copy(contents);
	        g_free(contents);
	    }
	
	    free(lf_file);
	    return retval;
	}
	
	static int
	local_files_remove(pcmk__output_t *out, rsh_fn_t rsh_fn, rcp_fn_t rcp_fn,
	                   const char *rsc, const char *param)
	{
	    int rc = pcmk_rc_ok;
	    char *lf_file = NULL;
	    gchar **argv = g_new0(gchar *, 5);
	
	    lf_file = pcmk__assert_asprintf(PCMK__CIB_SECRETS_DIR "/%s/%s", rsc, param);
	
	    argv[0] = g_strdup("rm");
	    argv[1] = g_strdup("-f");
	    argv[2] = g_strdup(lf_file);
	    argv[3] = g_strdup_printf("%s.sign", lf_file);
	    argv[4] = NULL;
	
	    rc = run_cmdline(out, argv, NULL);
	
	    if (rc == pcmk_rc_ok) {
	        rc = sync_one_file(out, rsh_fn, rcp_fn, lf_file);
	    }
	
	    free(lf_file);
	    g_strfreev(argv);
	    return rc;
	}
	
	static int
	local_files_set(pcmk__output_t *out, rsh_fn_t rsh_fn, rcp_fn_t rcp_fn,
	                const char *rsc, const char *param, const char *value)
	{
	    char *contents = NULL;
	    char *lf_dir = NULL;
	    char *lf_file = NULL;
	    char *sign_file = NULL;
	    char *calc_sum = NULL;
	    int rc = pcmk_rc_ok;
	
	    lf_dir = pcmk__assert_asprintf(PCMK__CIB_SECRETS_DIR "/%s", rsc);
	
	    if (g_mkdir_with_parents(lf_dir, 0700) != 0) {
	        rc = errno;
	        out->err(out, "Could not create directory %s: %s", lf_dir,
	                 pcmk_rc_str(rc));
	        goto done;
	    }
	
	    lf_file = pcmk__assert_asprintf("%s/%s", lf_dir, param);
	    contents = pcmk__assert_asprintf("%s\n", value);
	    if (!g_file_set_contents(lf_file, contents, -1, NULL)) {
	        rc = EIO;
	        out->err(out, "Could not create file %s: %s", lf_file,
	                 pcmk_rc_str(rc));
	        goto done;
	    }
	
	    free(contents);
	
	    sign_file = pcmk__assert_asprintf("%s/%s.sign", lf_dir, param);
	    calc_sum = pcmk__md5sum(value);
	    contents = pcmk__assert_asprintf("%s\n", calc_sum);
	
	    if (!g_file_set_contents(sign_file, contents, -1, NULL)) {
	        rc = EIO;
	        out->err(out, "Could not create file %s: %s", sign_file,
	                 pcmk_rc_str(rc));
	        goto done;
	    }
	
	    rc = sync_one_file(out, rsh_fn, rcp_fn, lf_file);
	
	done:
	    free(contents);
	    free(calc_sum);
	    free(sign_file);
	    free(lf_dir);
	    free(lf_file);
	    return rc;
	}
	
	static int
	subcommand_check(pcmk__output_t *out, rsh_fn_t rsh_fn, rcp_fn_t rcp_fn)
	{
	    int rc = pcmk_rc_ok;
	    const char *rsc = remainder[1];
	    const char *param = remainder[2];
	    char *value = NULL;
	    char *calc_sum = NULL;
	    char *local_sum = NULL;
	    char *local_value = NULL;
	
	    if (check_cib_rsc(out, rsc) != pcmk_rc_ok) {
	        rc = ENODEV;
	        goto done;
	    }
	
	    value = get_cib_param(out, rsc, param);
	    if ((value == NULL) || !is_secret(value)) {
	        out->err(out, "Resource %s parameter %s not set as secret, nothing to check",
	                 rsc, param);
	
	        /* I don't like this error code, but (1) it maps to CRM_EX_CONFIG which
	         * is what the old cibsecret.in would return in this case, and (2) we
	         * return it all over the place for a variety of CIB checking errors.
	         */
	        rc = pcmk_rc_unpack_error;
	        goto done;
	    }
	
	    local_sum = local_files_getsum(rsc, param);
	    if (local_sum == NULL) {
	        out->err(out, "No checksum for resource %s parameter %s", rsc, param);
	        rc = ENOENT;
	        goto done;
	    }
	
	    local_value = local_files_get(rsc, param);
	    if (local_value != NULL) {
	        calc_sum = pcmk__md5sum(local_value);
	    }
	
	    if ((local_value == NULL) || !pcmk__str_eq(calc_sum, local_sum, pcmk__str_none)) {
	        out->err(out, "Checksum mismatch for resource %s parameter %s", rsc, param);
	        rc = pcmk_rc_digest_mismatch;
	    }
	
	done:
	    free(local_sum);
	    free(local_value);
	    free(calc_sum);
	    free(value);
	    return rc;
	}
	
	static int
	subcommand_delete(pcmk__output_t *out, rsh_fn_t rsh_fn, rcp_fn_t rcp_fn)
	{
	    int rc = pcmk_rc_ok;
	    const char *rsc = remainder[1];
	    const char *param = remainder[2];
	
	    if (check_cib_rsc(out, rsc) != pcmk_rc_ok) {
	        return ENODEV;
	    }
	
	    rc = local_files_remove(out, rsh_fn, rcp_fn, rsc, param);
	    if (rc != pcmk_rc_ok) {
	        return rc;
	    }
	
	    return remove_cib_param(out, rsc, param);
	}
	
	static int
	subcommand_get(pcmk__output_t *out, rsh_fn_t rsh_fn, rcp_fn_t rcp_fn)
	{
	    int rc = subcommand_check(out, rsh_fn, rcp_fn);
	    char *value = NULL;
	    const char *rsc = remainder[1];
	    const char *param = remainder[2];
	
	    if (rc != pcmk_rc_ok) {
	        return rc;
	    }
	
	    value = local_files_get(rsc, param);
	    pcmk__assert(value != NULL);
	    out->info(out, "%s", value);
	
	    free(value);
	    return pcmk_rc_ok;
	}
	
	/* The previous shell implementation of cibsecret allowed passing the value
	 * to set (what would be remainder[3] here) via stdin, which we do not support
	 * here at the moment.
	 */
	static int
	subcommand_set(pcmk__output_t *out, rsh_fn_t rsh_fn, rcp_fn_t rcp_fn)
	{
	    int rc = pcmk_rc_ok;
	    const char *rsc = remainder[1];
	    const char *param = remainder[2];
	    const char *value = remainder[3];
	    char *current = NULL;
	
	    if (check_cib_rsc(out, rsc) != pcmk_rc_ok) {
	        rc = ENODEV;
	        goto done;
	    }
	
	    current = get_cib_param(out, rsc, param);
	    if ((current != NULL) && !pcmk__str_any_of(current, LRM_MAGIC, value, NULL)) {
	        out->err(out, "CIB value <%s> different for %s rsc parameter %s; please "
	                 "delete it first", current, rsc, param);
	
	        /* I don't like this error code, but (1) it maps to CRM_EX_CONFIG which
	         * is what the old cibsecret.in would return in this case, and (2) we
	         * return it all over the place for a variety of CIB checking errors.
	         */
	        rc = pcmk_rc_unpack_error;
	        goto done;
	    }
	
	    rc = local_files_set(out, rsh_fn, rcp_fn, rsc, param, value);
	    if (rc != pcmk_rc_ok) {
	        goto done;
	    }
	
	    rc = set_cib_param(out, rsc, param, LRM_MAGIC);
	
	done:
	    free(current);
	    return rc;
	}
	
	static int
	subcommand_stash(pcmk__output_t *out, rsh_fn_t rsh_fn, rcp_fn_t rcp_fn)
	{
	    int rc = pcmk_rc_ok;
	    const char *rsc = remainder[1];
	    const char *param = remainder[2];
	    char *value = NULL;
	
	    if (check_cib_rsc(out, rsc) != pcmk_rc_ok) {
	        rc = ENODEV;
	        goto done;
	    }
	
	    value = get_cib_param(out, rsc, param);
	    if ((value == NULL) || is_secret(value)) {
	        if (value == NULL) {
	            out->err(out, "Nothing to stash for resource %s parameter %s", rsc,
	                     param);
	            rc = ENOENT;
	        } else {
	            out->err(out, "Resource %s parameter %s already set as secret", rsc,
	                     param);
	            rc = EEXIST;
	        }
	
	        goto done;
	    }
	
	    remainder = g_realloc(remainder, sizeof(gchar *) * 5);
	    remainder[3] = g_strdup(value);
	    remainder[4] = NULL;
	
	    rc = subcommand_set(out, rsh_fn, rcp_fn);
	
	done:
	    free(value);
	    return rc;
	}
	
	static int
	subcommand_sync(pcmk__output_t *out, rsh_fn_t rsh_fn, rcp_fn_t rcp_fn)
	{
	    int rc = pcmk_rc_ok;
	    gchar *dirname = NULL;

	    gchar **argv = g_new0(gchar *, 4);
	    gchar **peers = get_live_peers(out);
	    gchar *peer_str = NULL;
	

	    if (peers == NULL) {

	        return pcmk_rc_ok;
	    }
	
	    peer_str = g_strjoinv(" ", peers);
	
	    out->info(out, "Syncing %s to %s ...", PCMK__CIB_SECRETS_DIR, peer_str);
	    g_free(peer_str);
	
	    dirname = g_path_get_dirname(PCMK__CIB_SECRETS_DIR);
	
	    argv[0] = g_strdup("rm");
	    argv[1] = g_strdup("-rf");
	    argv[2] = g_strdup(PCMK__CIB_SECRETS_DIR);
	    argv[3] = NULL;
	
	    rc = rsh_fn(out, peers, argv);
	    if (rc != pcmk_rc_ok) {
	        goto done;
	    }
	
	    g_strfreev(argv);
	    argv = g_new0(gchar *, 4);
	
	    argv[0] = g_strdup("mkdir");
	    argv[1] = g_strdup("-p");
	    argv[2] = g_strdup(dirname);
	    argv[3] = NULL;
	
	    rc = rsh_fn(out, peers, argv);
	    if (rc != pcmk_rc_ok) {
	        goto done;
	    }
	
	    rc = rcp_fn(out, peers, dirname, PCMK__CIB_SECRETS_DIR);
	
	done:
	    g_strfreev(argv);
	    g_strfreev(peers);
	    g_free(dirname);
	    return rc;
	}
	
	static int
	subcommand_unstash(pcmk__output_t *out, rsh_fn_t rsh_fn, rcp_fn_t rcp_fn)
	{
	    int rc = pcmk_rc_ok;
	    const char *rsc = remainder[1];
	    const char *param = remainder[2];
	    char *local_value = NULL;
	    char *cib_value = NULL;
	
	    local_value = local_files_get(rsc, param);
	    if (local_value == NULL) {
	        out->err(out, "Nothing to unstash for resource %s parameter %s",
	                 rsc, param);
	        rc = ENOENT;
	        goto done;
	    }
	
	    if (check_cib_rsc(out, rsc) != pcmk_rc_ok) {
	        rc = ENODEV;
	        goto done;
	    }
	
	    cib_value = get_cib_param(out, rsc, param);
	    if (!is_secret(cib_value)) {
	        out->info(out, "Resource %s parameter %s is not set as secret, but we "
	                  "have a local value so proceeding anyway", rsc, param);
	    }
	
	    rc = local_files_remove(out, rsh_fn, rcp_fn, rsc, param);
	    if (rc != pcmk_rc_ok) {
	        goto done;
	    }
	
	    rc = set_cib_param(out, rsc, param, local_value);
	
	done:
	    free(cib_value);
	    free(local_value);
	    return rc;
	}
	
	static struct subcommand_entry subcommand_table[] = {
	    { "check", 2, "check <resource-id> <resource-parameter>", false,
	      subcommand_check },
	    { "delete", 2, "delete <resource-id> <resource-parameter>", false,
	      subcommand_delete },
	    { "get", 2, "get <resource-id> <resource-parameter>", false,
	      subcommand_get },
	    { "set", 3, "set <resource-id> <resource-parameter> <value>", false,
	      subcommand_set },
	    { "stash", 2, "stash <resource-id> <resource-parameter>", true,
	      subcommand_stash },
	    { "sync", 0, "sync", false, subcommand_sync },
	    { "unstash", 2, "unstash <resource-id> <resource-parameter>", true,
	      subcommand_unstash },
	    { NULL },
	};
	
	static bool
	tools_installed(pcmk__output_t *out, rsh_fn_t *rsh_fn, rcp_fn_t *rcp_fn,
	                GError **error)
	{
	    gchar *path = NULL;
	
	    path = g_find_program_in_path("pssh");
	    if (path != NULL) {
	        g_free(path);
	        *rsh_fn = pssh;
	        *rcp_fn = pscp;
	        return true;
	    }
	
	    path = g_find_program_in_path("pdsh");
	    if (path != NULL) {
	        g_free(path);
	        *rsh_fn = pdsh;
	        *rcp_fn = pdcp;
	        return true;
	    }
	
	    path = g_find_program_in_path("ssh");
	    if (path != NULL) {
	        g_free(path);
	        *rsh_fn = ssh;
	        *rcp_fn = scp;
	        return true;
	    }
	
	    out->err(out, "Please install one of pssh, pdsh, or ssh");
	    return false;
	}
	
	static pcmk__supported_format_t formats[] = {
	    PCMK__SUPPORTED_FORMAT_NONE,
	    PCMK__SUPPORTED_FORMAT_TEXT,
	    PCMK__SUPPORTED_FORMAT_XML,
	    { NULL, NULL, NULL }
	};
	
	static GOptionContext *
	build_arg_context(pcmk__common_args_t *args, GOptionGroup **group) {
	    const char *desc = NULL;
	    GOptionContext *context = NULL;
	
	    desc = "This command manages sensitive resource parameter values that should not be\n"
	           "stored directly in Pacemaker's Cluster Information Base (CIB). Such values\n"
	           "are handled by storing a special string directly in the CIB that tells\n"
	           "Pacemaker to look in a separate, protected file for the actual value.\n\n"
	
	           "The secret files are not encrypted, but protected by file system permissions\n"
	           "such that only root can read or modify them.\n\n"
	
	           "Since the secret files are stored locally, they must be synchronized across all\n"
	           "cluster nodes. This command handles the synchronization using (in order of\n"
	           "preference) pssh, pdsh, or ssh, so one of those must be installed. Before\n"
	           "synchronizing, this command will ping the cluster nodes to determine which are\n"
	           "alive, using fping if it is installed, otherwise the ping command. Installing\n"
	           "fping is strongly recommended for better performance.\n\n"
	
	           "Commands and their parameters:\n\n"
	           "check <resource-id> <resource-parameter>\n"
	           "\tVerify that the locally stored value of a sensitive resource parameter\n"
	           "\tmatches its locally stored MD5 hash.\n\n"
	           "delete <resource-id> <resource-parameter>\n"
	           "\tRemove a sensitive resource parameter value.\n\n"
	           "get <resource-id> <resource-parameter>\n"
	           "\tDisplay the locally stored value of a sensitive resource parameter.\n\n"
	           "set <resource-id> <resource-parameter> <value>\n"
	           "\tSet the value of a sensitive resource parameter.\n\n"
	           "stash <resource-id> <resource-parameter>\n"
	           "\tMake a non-sensitive resource parameter that is already in the CIB\n"
	           "\tsensitive (move its value to a locally stored and protected file).\n"
	           "\tThis may not be used with -C.\n\n"
	           "sync\n"
	           "\tCopy all locally stored secrets to all other nodes.\n\n"
	           "unstash <resource-id> <resource-parameter>\n"
	           "\tMake a sensitive resource parameter that is already in the CIB\n"
	           "\tnon-sensitive (move its value from the locally stored file to the CIB).\n"
	           "\tThis may not be used with -C.\n\n\n"
	
	           "Known limitations:\n\n"
	
	           "This command can only be run from full cluster nodes (not Pacemaker Remote\n"
	           "nodes).\n\n"
	
	           "Changes are not atomic, so the cluster may use different values while a\n"
	           "change is in progress. To avoid problems, it is recommended to put the\n"
	           "cluster in maintenance mode when making changes with this command.\n\n"
	
	           "Changes in secret values do not trigger an agent reload or restart of the\n"
	           "affected resource, since they do not change the CIB. If a response is\n"
	           "desired before the next cluster recheck interval, any CIB change (such as\n"
	           "setting a node attribute) will trigger it.\n\n"
	
	           "If any node is down when changes to secrets are made, or a new node is\n"
	           "later added to the cluster, it may have different values when it joins the\n"
	           "cluster, before 'cibsecret sync' is run. To avoid this, it is recommended to\n"
	           "run the sync command (from another node) before starting Pacemaker on the\n"
	           "node.\n\n"
	
	           "Examples:\n\n"
	
	           "# cibsecret set ipmi_node1 passwd SecreT_PASS\n\n"
	           "# cibsecret get ipmi_node1 passwd\n\n"
	           "# cibsecret check ipmi_node1 passwd\n\n"
	           "# cibsecret stash ipmi_node2 passwd\n\n"
	           "# cibsecret sync\n";
	
	    context = pcmk__build_arg_context(args, "text (default), xml", group,
	                                      "<subcommand> [options]");
	    g_option_context_set_description(context, desc);
	    pcmk__add_main_args(context, entries);
	    return context;
	}
	
	int
	main(int argc, char **argv)
	{
	    crm_exit_t exit_code = CRM_EX_OK;
	    int rc = pcmk_rc_ok;
	
	    pcmk__output_t *out = NULL;
	
	    GError *error = NULL;
	
	    GOptionGroup *output_group = NULL;
	    pcmk__common_args_t *args = pcmk__new_common_args(SUMMARY);
	    gchar **processed_args = pcmk__cmdline_preproc(argv, NULL);
	    GOptionContext *context = build_arg_context(args, &output_group);
	
	    struct subcommand_entry cmd;
	    rsh_fn_t rsh_fn;
	    rcp_fn_t rcp_fn;
	
	    // Load locale information for the local host from the environment
	    setlocale(LC_ALL, "");
	
	    pcmk__register_formats(output_group, formats);
	    if (!g_option_context_parse_strv(context, &processed_args, &error)) {
	        exit_code = CRM_EX_USAGE;
	        goto done;
	    }
	
	    pcmk__cli_init_logging("cibsecret", args->verbosity);
	
	    rc = pcmk__output_new(&out, args->output_ty, args->output_dest, argv);
	    if (rc != pcmk_rc_ok) {
	        exit_code = CRM_EX_ERROR;
	        g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
	                    "Error creating output format %s: %s", args->output_ty,
	                    pcmk_rc_str(rc));
	        goto done;
	    }
	
	    if (args->version) {
	        out->version(out);
	        goto done;
	    }
	
	    /* No subcommand was given */
	    if ((remainder == NULL) || (g_strv_length(remainder) == 0)) {
	        gchar *help = g_option_context_get_help(context, TRUE, NULL);
	
	        exit_code = CRM_EX_USAGE;
	        g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
	                    "Must specify a command option\n\n%s", help);
	        g_free(help);
	        goto done;
	    }
	
	    /* Traverse the subcommand table looking for a match. */
	    for (int i = 0; i < PCMK__NELEM(subcommand_table); i++) {
	        cmd = subcommand_table[i];
	
	        if (!pcmk__str_eq(remainder[0], cmd.name, pcmk__str_none)) {
	            continue;
	        }
	
	        /* We found a match.  Check that enough arguments were given and
	         * display a usage message if not.  The "+ 1" is because the table
	         * entry lists how many arguments the subcommand takes, which does not
	         * include the subcommand itself.
	         */
	        if (g_strv_length(remainder) != cmd.args + 1) {
	            exit_code = CRM_EX_USAGE;
	            g_set_error(&error, PCMK__EXITC_ERROR, exit_code, "Usage: %s",
	                        cmd.usage);
	            goto done;
	        }
	
	        /* We've found the subcommand handler and it's used correctly. */
	        break;
	    }
	
	    /* If we didn't find a match, a valid subcommand wasn't given. */
	    if (cmd.name == NULL) {
	        exit_code = CRM_EX_USAGE;
	        g_set_error(&error, PCMK__EXITC_ERROR, exit_code,
	                    "Invalid subcommand given; valid subcommands: "
	                    "check, delete, get, set, stash, sync, unstash");
	        goto done;
	    }
	
	    /* Check that we have the tools necessary to manage secrets */
	    if (!tools_installed(out, &rsh_fn, &rcp_fn, &error)) {
	        exit_code = CRM_EX_NOT_INSTALLED;
	        goto done;
	    }
	
	    /* Set a default umask so files we create are only accessible by the
	     * cluster user.
	     */
	    umask(S_IRGRP | S_IWGRP | S_IXGRP | S_IROTH | S_IWOTH | S_IXOTH);
	
	    /* Call the subcommand handler.  If the handler fails, it will have already
	     * set exit_code to the reason why so there's no need to worry with
	     * additional error checking here at the moment.
	     */
	    if (cmd.requires_cib && no_cib) {
	        out->err(out, "No access to Pacemaker, %s not supported", cmd.name);
	        exit_code = CRM_EX_USAGE;
	        goto done;
	    }
	
	    rc = cmd.handler(out, rsh_fn, rcp_fn);
	    exit_code = pcmk_rc2exitc(rc);
	
	 done:
	    g_strfreev(processed_args);
	    g_strfreev(remainder);
	    pcmk__free_arg_context(context);
	
	    pcmk__output_and_clear_error(&error, out);
	
	    if (out != NULL) {
	        out->finish(out, exit_code, true, NULL);
	        pcmk__output_free(out);
	    }
	    pcmk__unregister_formats();
	    crm_exit(exit_code);
	}