#ifndef LIGHTNING_LIGHTNINGD_CHANNEL_H #define LIGHTNING_LIGHTNINGD_CHANNEL_H #include "config.h" #include #include #include #include struct uncommitted_channel; struct billboard { /* Status information to display on listpeers */ const char *permanent[CHANNEL_STATE_MAX+1]; const char *transient; }; struct channel { /* Inside peer->channels. */ struct list_node list; /* Peer context */ struct peer *peer; /* Database ID: 0 == not in db yet */ u64 dbid; /* Error message (iff in error state) */ u8 *error; /* Their shachain. */ struct wallet_shachain their_shachain; /* What's happening. */ enum channel_state state; /* Which side offered channel? */ enum side funder; /* Is there a single subdaemon responsible for us? */ struct subd *owner; /* History */ struct log *log; struct billboard billboard; /* Channel flags from opening message. */ u8 channel_flags; /* Our channel config. */ struct channel_config our_config; /* Minimum funding depth (specified by us if they fund). */ u32 minimum_depth; /* Tracking commitment transaction numbers. */ u64 next_index[NUM_SIDES]; u64 next_htlc_id; /* Funding txid and amounts */ struct bitcoin_txid funding_txid; u16 funding_outnum; struct amount_sat funding; struct amount_msat push; bool remote_funding_locked; /* Channel if locked locally. */ struct short_channel_id *scid; /* Amount going to us, not counting unfinished HTLCs; if we have one. */ struct amount_msat our_msat; /* Statistics for min and max our_msatoshi. */ struct amount_msat msat_to_us_min; struct amount_msat msat_to_us_max; /* Timer we use in case they don't add an HTLC in a timely manner. */ struct oneshot *htlc_timeout; /* Last tx they gave us. */ struct bitcoin_tx *last_tx; enum wallet_tx_type last_tx_type; struct bitcoin_signature last_sig; secp256k1_ecdsa_signature *last_htlc_sigs; /* Keys for channel */ struct channel_info channel_info; /* Our local basepoints */ struct basepoints local_basepoints; /* Our funding tx pubkey. */ struct pubkey local_funding_pubkey; /* Their scriptpubkey if they sent shutdown. */ u8 *remote_shutdown_scriptpubkey; /* Address for any final outputs */ u64 final_key_idx; /* Reestablishment stuff: last sent commit and revocation details. */ bool last_was_revoke; struct changed_htlc *last_sent_commit; /* Blockheight at creation, scans for funding confirmations * will start here */ u32 first_blocknum; /* Feerate range */ u32 min_possible_feerate, max_possible_feerate; /* Does gossipd need to know if the owner dies? (ie. not onchaind) */ bool connected; /* Do we have an "impossible" future per_commitment_point from * peer via option_data_loss_protect? */ const struct pubkey *future_per_commitment_point; /* Feerate per channel */ u32 feerate_base, feerate_ppm; /* If they used option_upfront_shutdown_script. */ const u8 *remote_upfront_shutdown_script; }; struct channel *new_channel(struct peer *peer, u64 dbid, /* NULL or stolen */ struct wallet_shachain *their_shachain, enum channel_state state, enum side funder, /* NULL or stolen */ struct log *log, const char *transient_billboard TAKES, u8 channel_flags, const struct channel_config *our_config, u32 minimum_depth, u64 next_index_local, u64 next_index_remote, u64 next_htlc_id, const struct bitcoin_txid *funding_txid, u16 funding_outnum, struct amount_sat funding, struct amount_msat push, bool remote_funding_locked, /* NULL or stolen */ struct short_channel_id *scid, struct amount_msat our_msatoshi, struct amount_msat msatoshi_to_us_min, struct amount_msat msatoshi_to_us_max, /* Stolen */ struct bitcoin_tx *last_tx, const struct bitcoin_signature *last_sig, /* NULL or stolen */ secp256k1_ecdsa_signature *last_htlc_sigs, const struct channel_info *channel_info, /* NULL or stolen */ u8 *remote_shutdown_scriptpubkey, u64 final_key_idx, bool last_was_revoke, /* NULL or stolen */ struct changed_htlc *last_sent_commit, u32 first_blocknum, u32 min_possible_feerate, u32 max_possible_feerate, bool connected, const struct basepoints *local_basepoints, const struct pubkey *local_funding_pubkey, const struct pubkey *future_per_commitment_point, u32 feerate_base, u32 feerate_ppm, /* NULL or stolen */ const u8 *remote_upfront_shutdown_script); void delete_channel(struct channel *channel); const char *channel_state_name(const struct channel *channel); const char *channel_state_str(enum channel_state state); void channel_set_owner(struct channel *channel, struct subd *owner); /* Channel has failed, but can try again. */ PRINTF_FMT(2,3) void channel_fail_reconnect(struct channel *channel, const char *fmt, ...); /* Channel has failed, but can try again after a minute. */ PRINTF_FMT(2,3) void channel_fail_reconnect_later(struct channel *channel, const char *fmt,...); /* Channel has failed, give up on it. */ void channel_fail_permanent(struct channel *channel, const char *fmt, ...); /* Permanent error, but due to internal problems, not peer. */ void channel_internal_error(struct channel *channel, const char *fmt, ...); void channel_set_state(struct channel *channel, enum channel_state old_state, enum channel_state state); /* Find a channel which is not onchain, if any */ struct channel *peer_active_channel(struct peer *peer); /* Find a channel which is in state CHANNELD_NORMAL, if any */ struct channel *peer_normal_channel(struct peer *peer); /* Get active channel for peer, optionally any uncommitted_channel. */ struct channel *active_channel_by_id(struct lightningd *ld, const struct node_id *id, struct uncommitted_channel **uc); struct channel *channel_by_dbid(struct lightningd *ld, const u64 dbid); void channel_set_last_tx(struct channel *channel, struct bitcoin_tx *tx, const struct bitcoin_signature *sig, enum wallet_tx_type type); static inline bool channel_can_add_htlc(const struct channel *channel) { return channel->state == CHANNELD_NORMAL; } static inline bool channel_fees_can_change(const struct channel *channel) { return channel->state == CHANNELD_NORMAL || channel->state == CHANNELD_SHUTTING_DOWN; } static inline bool channel_state_on_chain(enum channel_state state) { return state == ONCHAIN; } static inline bool channel_on_chain(const struct channel *channel) { return channel_state_on_chain(channel->state); } static inline bool channel_active(const struct channel *channel) { return channel->state != FUNDING_SPEND_SEEN && channel->state != CLOSINGD_COMPLETE && !channel_on_chain(channel); } void get_channel_basepoints(struct lightningd *ld, const struct node_id *peer_id, const u64 dbid, struct basepoints *local_basepoints, struct pubkey *local_funding_pubkey); void channel_set_billboard(struct channel *channel, bool perm, const char *str TAKES); struct htlc_in *channel_has_htlc_in(struct channel *channel); struct htlc_out *channel_has_htlc_out(struct channel *channel); #endif /* LIGHTNING_LIGHTNINGD_CHANNEL_H */