Function chaininfo_getchaininfo_done

plugins/bwatch/bwatch_interface.c:240–285

Got chain state from bcli: optionally roll back, then forward to watchman. */

/* Got chain state from bcli: optionally roll back, then forward to watchman. */
static struct command_result *chaininfo_getchaininfo_done(struct command *cmd,
							  const char *method UNUSED,
							  const char *buf,
							  const jsmntok_t *result,
							  void *unused UNUSED)
{
	struct bwatch *bwatch = bwatch_of(cmd->plugin);
	struct out_req *req;
	const char *chain;
	u32 headercount, blockcount;
	bool ibd;
	const char *err;

	err = json_scan(tmpctx, buf, result,
			"{chain:%,headercount:%,blockcount:%,ibd:%}",
			JSON_SCAN_TAL(tmpctx, json_strdup, &chain),
			JSON_SCAN(json_to_number, &headercount),
			JSON_SCAN(json_to_number, &blockcount),
			JSON_SCAN(json_to_bool, &ibd));
	if (err) {
		plugin_log(cmd->plugin, LOG_BROKEN,
			   "getchaininfo parse failed: %s", err);
		return timer_complete(cmd);
	}

	/* Startup-only rollback: if bitcoind's chain is shorter than our
	 * stored tip, peel off stale blocks now.  During normal polling the
	 * shorter-chain case is handled by hash-mismatch reorg detection
	 * inside handle_block. */
	if (blockcount < bwatch->current_height) {
		plugin_log(cmd->plugin, LOG_INFORM,
			   "Startup: chain at %u but bwatch at %u; rolling back",
			   blockcount, bwatch->current_height);
		while (bwatch->current_height > blockcount
		       && bwatch_last_block(bwatch))
			bwatch_remove_tip(cmd, bwatch);
	}

	req = jsonrpc_request_start(cmd, "chaininfo",
				    chaininfo_ack, chaininfo_err, NULL);
	json_add_string(req->js, "chain", chain);
	json_add_u32(req->js, "headercount", headercount);
	json_add_u32(req->js, "blockcount", blockcount);
	json_add_bool(req->js, "ibd", ibd);
	return send_outreq(req);
}

/* bcli unreachable: log and fall back to polling so we don't stall init. */
static struct command_result *chaininfo_getchaininfo_failed(struct command *cmd,