Function wallet_channel_insert

wallet/wallet.c:3037–3085

}

void wallet_channel_insert(struct wallet *w, struct channel *chan)
{
	struct db_stmt *stmt;

	assert(chan->dbid != 0);
	assert(chan->unsaved_dbid == 0);

	if (chan->peer->dbid == 0)
		wallet_peer_save(w, chan->peer);

	/* Insert a stub, that we update, unifies INSERT and UPDATE paths */
	stmt = db_prepare_v2(
	    w->db, SQL("INSERT INTO channels ("
		       "  peer_id"
		       ", first_blocknum"
		       ", id"
		       ", revocation_basepoint_local"
		       ", payment_basepoint_local"
		       ", htlc_basepoint_local"
		       ", delayed_payment_basepoint_local"
		       ", funding_pubkey_local"
		       ", require_confirm_inputs_remote"
		       ", require_confirm_inputs_local"
		       ") VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?);"));
	db_bind_u64(stmt, chan->peer->dbid);
	db_bind_int(stmt, chan->first_blocknum);
	db_bind_int(stmt, chan->dbid);

	db_bind_pubkey(stmt, &chan->local_basepoints.revocation);
	db_bind_pubkey(stmt, &chan->local_basepoints.payment);
	db_bind_pubkey(stmt, &chan->local_basepoints.htlc);
	db_bind_pubkey(stmt, &chan->local_basepoints.delayed_payment);
	db_bind_pubkey(stmt, &chan->local_funding_pubkey);
	db_bind_int(stmt, chan->req_confirmed_ins[REMOTE]);
	db_bind_int(stmt, chan->req_confirmed_ins[LOCAL]);

	db_exec_prepared_v2(take(stmt));

	wallet_channel_config_insert(w, &chan->our_config);
	wallet_channel_config_insert(w, &chan->channel_info.their_config);
	if (chan->scid && is_stub_scid(*chan->scid)) {
		wallet_stub_shachain_init(w, &chan->their_shachain);
	} else {
		wallet_shachain_init(w, &chan->their_shachain);
	}

	/* Now save path as normal */
	wallet_channel_save(w, chan);
}

void wallet_delete_old_htlcs(struct wallet *w)
{