#include "config.h"
#include <ccan/array_size/array_size.h>
#include <ccan/tal/str/str.h>
#include <common/json_param.h>
#include <common/json_stream.h>
#include <common/memleak.h>
#include <plugins/libplugin.h>

/* Stash this in plugin's data */
struct test_libplugin {
	char *somearg;
	bool self_disable;
	bool dont_shutdown;
	u32 dynamic_opt;
};

static struct test_libplugin *get_test_libplugin(struct plugin *plugin)
{
	return plugin_get_data(plugin, struct test_libplugin);
}

static struct command_result *get_ds_done(struct command *cmd,
					  const char *val,
					  char *arg)
{
	if (!val)
		val = "NOT FOUND";
	return command_success(cmd, json_out_obj(cmd, arg, val));
}

static struct command_result *get_ds_bin_done(struct command *cmd,
					      const u8 *val,
					      char *arg)
{
	plugin_log(cmd->plugin, LOG_INFORM, "get_ds_bin_done: %s",
		   val ? tal_hex(tmpctx, val) : "NOT FOUND");

	return jsonrpc_get_datastore_string(cmd,
					    "test_libplugin/name",
					    get_ds_done, arg);
}

static struct command_result *json_helloworld(struct command *cmd,
					      const char *buf,
					      const jsmntok_t *params)
{
	const char *name;

	if (!param(cmd, buf, params,
		   p_opt("name", param_string, &name),
		   NULL))
		return command_param_failed();

	plugin_notify_message(cmd, LOG_INFORM, "Notification from %s", "json_helloworld");

	if (!name)
		return jsonrpc_get_datastore_binary(cmd,
						    "test_libplugin/name",
						    get_ds_bin_done,
						    "hello");

	return command_success(cmd, json_out_obj(cmd, "hello", name));
}

static struct command_result *
json_peer_connected(struct command *cmd,
		    const char *buf,
		    const jsmntok_t *params)
{
	const jsmntok_t *peertok, *idtok;
	struct json_stream *response;

	peertok = json_get_member(buf, params, "peer");
	assert(peertok);
	idtok = json_get_member(buf, peertok, "id");
	assert(idtok);
	plugin_log(cmd->plugin, LOG_INFORM, "%s peer_connected",
		   json_strdup(tmpctx, buf, idtok));

	response = jsonrpc_stream_success(cmd);
	json_add_string(response, "result", "continue");

	return command_finished(cmd, response);
}

static struct command_result *json_connected(struct command *cmd,
					     const char *buf,
					     const jsmntok_t *params)
{
	const jsmntok_t *connecttok, *idtok;

	connecttok = json_get_member(buf, params, "connect");
	assert(connecttok);
	idtok = json_get_member(buf, connecttok, "id");
	assert(idtok);
	plugin_log(cmd->plugin, LOG_INFORM, "%s connected",
		   json_strdup(tmpctx, buf, idtok));
	return notification_handled(cmd);
}

static struct command_result *json_shutdown(struct command *cmd,
					    const char *buf,
					    const jsmntok_t *params)
{
	struct test_libplugin *tlp = get_test_libplugin(cmd->plugin);
	plugin_log(cmd->plugin, LOG_DBG, "shutdown called");

	if (tlp->dont_shutdown)
		return notification_handled(cmd);

	plugin_exit(cmd->plugin, 0);
}

static struct command_result *json_all_notifs(struct command *cmd,
					      const char *buf,
					      const jsmntok_t *params)
{
	plugin_log(cmd->plugin, LOG_DBG, "all: %s: %.*s",
		   cmd->methodname,
		   json_tok_full_len(params),
		   json_tok_full(buf, params));
	return notification_handled(cmd);
}

static struct command_result *testrpc_cb(struct command *cmd,
					 const char *method UNUSED,
					 const char *buf,
					 const jsmntok_t *params,
					 void *cb_arg UNUSED)
{
	int i = 0;
	const jsmntok_t *t;
	struct json_stream *response;

	response = jsonrpc_stream_success(cmd);
	json_for_each_obj(i, t, params)
		json_add_tok(response, json_strdup(tmpctx, buf, t), t+1, buf);

	return command_finished(cmd, response);
}

static struct command_result *json_testrpc(struct command *cmd,
					   const char *buf,
					   const jsmntok_t *params)
{
	struct out_req *req;

	if (!param(cmd, buf, params, NULL))
		return command_param_failed();

	req = jsonrpc_request_start(cmd, "getinfo", testrpc_cb,
				    testrpc_cb, NULL);
	return send_outreq(req);
}

static struct command_result *listdatastore_ok(struct command *cmd,
					       const char *method,
					       const char *buf,
					       const jsmntok_t *params,
					       void *cb_arg UNUSED)
{
	if (command_check_only(cmd))
		return command_check_done(cmd);

	return forward_result(cmd, method, buf, params, NULL);
}

/* A command which does async, even if it is a check */
static struct command_result *json_checkthis(struct command *cmd,
					     const char *buf,
					     const jsmntok_t *params)
{
	struct out_req *req;
	const jsmntok_t *key;

	/* We are deliberately MORE restrictive than datastore, so we can
	 * fail here if we want to */
	if (!param_check(cmd, buf, params,
			 p_opt("key", param_array, &key),
			 NULL))
		return command_param_failed();

	req = jsonrpc_request_start(cmd,
				    "listdatastore",
				    listdatastore_ok,
				    forward_error, NULL);
	if (key)
		json_add_tok(req->js, "key", key, buf);
	return send_outreq(req);
}

static char *set_dynamic(struct plugin *plugin,
			 const char *arg,
			 bool check_only,
			 u32 *dynamic_opt)
{
	int val = atol(arg);

	/* Whee, let's allow odd */
	if (val % 2 == 0)
		return "I don't like \"even\" numbers (valid JSON? Try {})!";

	if (check_only)
		return NULL;

	*dynamic_opt = val;
	return NULL;
}

static const char *init(struct command *init_cmd,
			const char *buf UNUSED,
			const jsmntok_t *config UNUSED)
{
	const char *name, *err_str, *err_hex;
	const u8 *binname;
	struct plugin *p = init_cmd->plugin;
	struct test_libplugin *tlp = get_test_libplugin(p);

	plugin_log(p, LOG_DBG, "test_libplugin initialised!");
	if (tlp->somearg)
		plugin_log(p, LOG_DBG, "somearg = %s", tlp->somearg);
	tlp->somearg = tal_free(tlp->somearg);

	if (tlp->self_disable)
		return "Disabled via selfdisable option";

	/* Test rpc_scan_datastore funcs */
	err_str = rpc_scan_datastore_str(tmpctx, init_cmd, "test_libplugin/name",
					 JSON_SCAN_TAL(tmpctx, json_strdup,
						       &name));
	if (err_str)
		name = NULL;
	err_hex = rpc_scan_datastore_hex(tmpctx, init_cmd, "test_libplugin/name",
					 JSON_SCAN_TAL(tmpctx, json_tok_bin_from_hex,
						       &binname));
	if (err_hex)
		binname = NULL;

	plugin_log(p, LOG_INFORM, "String name from datastore: %s",
		   name ? name : err_str);
	plugin_log(p, LOG_INFORM, "Hex name from datastore: %s",
		   binname ? tal_hex(tmpctx, binname) : err_hex);

 	return NULL;
}

static const struct plugin_command commands[] = { {
		"helloworld",
		json_helloworld,
	},
	{
		"testrpc",
		json_testrpc,
	},
	{
		"testrpc-deprecated",
		json_testrpc,
		"v0.9.1",
		CLN_NEXT_VERSION,
	},
	{
		"checkthis",
		json_checkthis,
	},
};

static const char *before[] = { "dummy", NULL };
static const char *after[] = { "dummy", NULL };

static const struct plugin_hook hooks[] = { {
		"peer_connected",
		json_peer_connected,
		before,
		after
	}
};

static const struct plugin_notification notifs[] = { {
		"connect",
		json_connected,
	}, {
		"shutdown",
		json_shutdown
	}, {
		"*",
		json_all_notifs
	}
};

int main(int argc, char *argv[])
{
	setup_locale();
	/* We allocate now, so we can hand pointers for plugin options,
	 * but by specifying take() to plugin_main, it reparents it to
	 * the plugin */
	struct test_libplugin *tlp = tal(NULL, struct test_libplugin);
	tlp->somearg = NULL;
	tlp->self_disable = false;
	tlp->dont_shutdown = false;
	tlp->dynamic_opt = 7;

	plugin_main(argv, init, take(tlp), PLUGIN_RESTARTABLE, true, NULL,
		    commands, ARRAY_SIZE(commands),
	            notifs, ARRAY_SIZE(notifs), hooks, ARRAY_SIZE(hooks),
		    NULL, 0,  /* Notification topics we publish */
		    plugin_option("somearg",
				  "string",
				  "Argument to print at init.",
				  charp_option, charp_jsonfmt, &tlp->somearg),
		    plugin_option_deprecated("somearg-deprecated",
					     "string",
					     "Deprecated arg for init.",
					     CLN_NEXT_VERSION, NULL,
					     charp_option, charp_jsonfmt,
					     &tlp->somearg),
		    plugin_option("selfdisable",
				  "flag",
				  "Whether to disable.",
				  flag_option, flag_jsonfmt,
				  &tlp->self_disable),
		    plugin_option("dont_shutdown",
				  "flag",
				  "Whether to timeout when asked to shutdown.",
				  flag_option, flag_jsonfmt,
				  &tlp->dont_shutdown),
		    plugin_option_dynamic("dynamicopt",
					  "int",
					  "Set me!",
					  set_dynamic, u32_jsonfmt,
					  &tlp->dynamic_opt),
		    NULL);
}