Function wallet_total_forward_fees

wallet/wallet.c:4506–4532

}

struct amount_msat wallet_total_forward_fees(struct wallet *w)
{
	struct db_stmt *stmt;
	struct amount_msat total, deleted;
	bool res;

	stmt = db_prepare_v2(w->db, SQL("SELECT"
					" CAST(COALESCE(SUM(in_msatoshi - out_msatoshi), 0) AS BIGINT)"
					" FROM forwards "
					"WHERE state = ?;"));
	db_bind_int(stmt, 0, wallet_forward_status_in_db(FORWARD_SETTLED));
	db_query_prepared(stmt);

	res = db_step(stmt);
	assert(res);

	db_col_amount_msat(stmt, "CAST(COALESCE(SUM(in_msatoshi - out_msatoshi), 0) AS BIGINT)", &total);
	tal_free(stmt);

	deleted = amount_msat(db_get_intvar(w->db, "deleted_forward_fees", 0));
	if (!amount_msat_add(&total, total, deleted))
		db_fatal("Adding forward fees %s + %s overflowed",
			 type_to_string(tmpctx, struct amount_msat, &total),
			 type_to_string(tmpctx, struct amount_msat, &deleted));

	return total;
}

bool string_to_forward_status(const char *status_str,
			      size_t len,