52d69df10f
We take over the --bookkeeper-dir and --bookkeeper-db options, and then if we can find the bookkeeper db we extract the records to initialize our chain_moves and channel_moves tables. Of course, bookkeeper now needs to not register those options. When bookkeeper gets invoked the first time, it will reconstruct everything from listchannelmoves and listcoinmoves. It cannot preserve manually-added descriptions, so we put those in the datastore for it ready to go. Note that the order of onchain_fee changes slightly from the original. But this is fine. Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
71 lines
2.2 KiB
C
71 lines
2.2 KiB
C
#ifndef LIGHTNING_LIGHTNINGD_COIN_MVTS_H
|
|
#define LIGHTNING_LIGHTNINGD_COIN_MVTS_H
|
|
#include "config.h"
|
|
|
|
#include <common/coin_mvt.h>
|
|
|
|
struct htlc_in;
|
|
struct htlc_out;
|
|
struct json_stream;
|
|
struct lightningd;
|
|
|
|
struct account_balance {
|
|
const char *acct_id;
|
|
const char *bip173_name;
|
|
struct amount_msat balance;
|
|
};
|
|
|
|
struct balance_snapshot {
|
|
struct node_id *node_id;
|
|
u32 blockheight;
|
|
u32 timestamp;
|
|
|
|
struct account_balance **accts;
|
|
};
|
|
|
|
struct channel_coin_mvt *new_channel_mvt_invoice_hin(const tal_t *ctx,
|
|
const struct htlc_in *hin,
|
|
const struct channel *channel);
|
|
struct channel_coin_mvt *new_channel_mvt_routed_hin(const tal_t *ctx,
|
|
const struct htlc_in *hin,
|
|
const struct channel *channel);
|
|
struct channel_coin_mvt *new_channel_mvt_invoice_hout(const tal_t *ctx,
|
|
const struct htlc_out *hout,
|
|
const struct channel *channel);
|
|
struct channel_coin_mvt *new_channel_mvt_routed_hout(const tal_t *ctx,
|
|
const struct htlc_out *hout,
|
|
const struct channel *channel);
|
|
struct channel_coin_mvt *new_channel_mvt_penalty_adj(const tal_t *ctx,
|
|
const struct channel *channel,
|
|
struct amount_msat amount,
|
|
enum coin_mvt_dir direction);
|
|
|
|
void send_account_balance_snapshot(struct lightningd *ld);
|
|
|
|
/* Shared by listcoinmoves and notifications code */
|
|
void json_add_chain_mvt_fields(struct json_stream *stream,
|
|
bool include_tags_arr,
|
|
bool include_old_utxo_fields,
|
|
bool include_old_txid_field,
|
|
const struct chain_coin_mvt *chain_mvt,
|
|
u64 id);
|
|
void json_add_channel_mvt_fields(struct json_stream *stream,
|
|
bool include_tags_arr,
|
|
const struct channel_coin_mvt *chan_mvt,
|
|
u64 id,
|
|
bool extra_tags_field);
|
|
|
|
/* For db code to get incremental ids */
|
|
u64 chain_mvt_index_created(struct lightningd *ld,
|
|
struct db *db,
|
|
const struct mvt_account_id *account,
|
|
struct amount_msat credit,
|
|
struct amount_msat debit);
|
|
|
|
u64 channel_mvt_index_created(struct lightningd *ld,
|
|
struct db *db,
|
|
const struct mvt_account_id *account,
|
|
struct amount_msat credit,
|
|
struct amount_msat debit);
|
|
#endif /* LIGHTNING_LIGHTNINGD_COIN_MVTS_H */
|