Function plugin_log_handle

lightningd/plugin.c:478–535

				     const jsmntok_t *paramstok)
	WARN_UNUSED_RESULT;
static const char *plugin_log_handle(struct plugin *plugin,
				     const char *buffer,
				     const jsmntok_t *paramstok)
{
	const jsmntok_t *msgtok, *leveltok;
	enum log_level level;
	bool call_notifier;
	msgtok = json_get_member(buffer, paramstok, "message");
	leveltok = json_get_member(buffer, paramstok, "level");

	if (!msgtok || msgtok->type != JSMN_STRING) {
		return tal_fmt(plugin, "Log notification from plugin doesn't have "
			       "a string \"message\" field");
	}

	if (!leveltok)
		level = LOG_INFORM;
	else if (!log_level_parse(buffer + leveltok->start,
				  leveltok->end - leveltok->start,
				  &level)
		 /* FIXME: Allow io logging? */
		 || level == LOG_IO_IN
		 || level == LOG_IO_OUT) {
		return tal_fmt(plugin,
			       "Unknown log-level %.*s, valid values are "
			       "\"trace\", \"debug\", \"info\", \"warn\", or \"error\".",
			       json_tok_full_len(leveltok),
			       json_tok_full(buffer, leveltok));
	}

	call_notifier = (level == LOG_BROKEN || level == LOG_UNUSUAL)? true : false;

	/* Only bother unescaping and splitting if it has \ */
	if (memchr(buffer + msgtok->start, '\\', msgtok->end - msgtok->start)) {
		const char *log_msg = json_escape_unescape_len(tmpctx,
							       buffer + msgtok->start,
							       msgtok->end - msgtok->start);
		char **lines;

		/* Weird \ escapes aren't handled by json_escape_unescape.  This is for you, clboss! */
		if (!log_msg)
			goto print_raw;

		lines = tal_strsplit(tmpctx, log_msg, "\n", STR_EMPTY_OK);

		for (size_t i = 0; lines[i]; i++) {
			/* FIXME: Let plugin specify node_id? */
			log_(plugin->log, level, NULL, call_notifier, "%s", lines[i]);
		}
	} else {
	print_raw:
		log_(plugin->log, level, NULL, call_notifier, "%.*s",
		     msgtok->end - msgtok->start,
		     buffer + msgtok->start);
	}

	return NULL;
}