aljaz/lightning
1
0
Fork 0
mirror of https://github.com/aljazceru/lightning.git synced 2025-12-20 15:44:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

wallet: Add function to add filteredblocks from backfilling

Browse Source 
Signed-off-by: Christian Decker <decker.christian@gmail.com>
This commit is contained in:
Christian Decker
2019-08-05 23:16:32 +02:00
committed by Rusty Russell
parent f4e434d8e1
commit 3dbaae38e3
2 changed files with 60 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
wallet/wallet.c
View File

@@ -8,7 +8,6 @@
#include <common/memleak.h>
#include <common/wireaddr.h>
#include <inttypes.h>
#include <lightningd/bitcoind.h>
#include <lightningd/lightningd.h>
#include <lightningd/notification.h>
#include <lightningd/peer_control.h>
@@ -2412,6 +2411,53 @@ void wallet_utxoset_add(struct wallet *w, const struct bitcoin_tx *tx,
outpointfilter_add(w->utxoset_outpoints, &txid, outnum);
}
void wallet_filteredblock_add(struct wallet *w, struct filteredblock *fb)
{
if (wallet_have_block(w, fb->height))
return;
sqlite3_stmt *stmt = db_prepare(w->db, "INSERT OR IGNORE INTO blocks "
"(height, hash, prev_hash) "
"VALUES (?, ?, ?);");
sqlite3_bind_int(stmt, 1, fb->height);
sqlite3_bind_sha256_double(stmt, 2, &fb->id.shad);
sqlite3_bind_sha256_double(stmt, 3, &fb->prev_hash.shad);
db_exec_prepared(w->db, stmt);
for (size_t i = 0; i < tal_count(fb->outpoints); i++) {
struct filteredblock_outpoint *o = fb->outpoints[i];
stmt = db_prepare(w->db, "INSERT INTO utxoset ("
" txid,"
" outnum,"
" blockheight,"
" spendheight,"
" txindex,"
" scriptpubkey,"
" satoshis"
") VALUES(?, ?, ?, ?, ?, ?, ?);");
sqlite3_bind_sha256_double(stmt, 1, &o->txid.shad);
sqlite3_bind_int(stmt, 2, o->outnum);
sqlite3_bind_int(stmt, 3, fb->height);
sqlite3_bind_null(stmt, 4);
sqlite3_bind_int(stmt, 5, o->txindex);
sqlite3_bind_blob(stmt, 6, o->scriptPubKey,
tal_count(o->scriptPubKey), SQLITE_TRANSIENT);
sqlite3_bind_amount_sat(stmt, 7, o->satoshis);
db_exec_prepared(w->db, stmt);
outpointfilter_add(w->utxoset_outpoints, &o->txid, o->outnum);
}
}
bool wallet_have_block(struct wallet *w, u32 blockheight)
{
bool result;
sqlite3_stmt *stmt = db_select_prepare(w->db, "height FROM blocks WHERE height = ?");
sqlite3_bind_int(stmt, 1, blockheight);
result = sqlite3_step(stmt) == SQLITE_ROW;
db_stmt_done(stmt);
return result;
}
struct outpoint *wallet_outpoint_for_scid(struct wallet *w, tal_t *ctx,
const struct short_channel_id *scid)
{