Function parse_and_log_chain_move

plugins/bkpr/bookkeeper.c:1404–1584

}

static void
parse_and_log_chain_move(struct command *cmd,
			 const char *buf,
			 const jsmntok_t *chainmove,
			 struct refresh_info *rinfo)
{
	struct chain_event *e = tal(cmd, struct chain_event);
	struct sha256 *payment_hash = tal(cmd, struct sha256);
	struct bitcoin_txid *spending_txid = tal(cmd, struct bitcoin_txid);
	struct node_id *peer_id;
	struct account *acct;
	u32 closed_count;
	char *acct_name;
	const char *err;
	struct bkpr *bkpr = bkpr_of(cmd->plugin);
	enum mvt_tag tag, *tags;

	/* Fields we expect on *every* chain movement */
	closed_count = 0;
	err = json_scan(tmpctx, buf, chainmove,
			"{account_id:%"
			",created_index:%"
			",credit_msat:%"
			",debit_msat:%"
			",timestamp:%"
			",utxo:%"
			",output_msat:%"
			",blockheight:%"
			",primary_tag:%"
			",extra_tags:%"
			",output_count?:%"
			"}",
			JSON_SCAN_TAL(tmpctx, json_strdup, &acct_name),
			JSON_SCAN(json_to_u64, &e->db_id),
			JSON_SCAN(json_to_msat, &e->credit),
			JSON_SCAN(json_to_msat, &e->debit),
			JSON_SCAN(json_to_u64, &e->timestamp),
			JSON_SCAN(json_to_outpoint, &e->outpoint),
			JSON_SCAN(json_to_msat, &e->output_value),
			JSON_SCAN(json_to_number, &e->blockheight),
			JSON_SCAN(json_to_coin_mvt_tag, &tag),
			JSON_SCAN_TAL(tmpctx, json_to_tags, &tags),
			JSON_SCAN(json_to_number, &closed_count));
	if (err)
		plugin_err(cmd->plugin,
			   "chainmove did"
			   " not scan %s: %.*s",
			   err, json_tok_full_len(chainmove),
			   json_tok_full(buf, chainmove));

	/* Now try to get out the optional parts */
	err = json_scan(tmpctx, buf, chainmove,
			"{spending_txid:%"
			"}",
			JSON_SCAN(json_to_txid, spending_txid));

	if (err) {
		spending_txid = tal_free(spending_txid);