Skip to content

test: add wallet creation SQLite lifecycle integration coverage #94

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
j-kon wants to merge 4 commits into
base: main
Choose a base branch
from
Open

test: add wallet creation SQLite lifecycle integration coverage #94

Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
141304e
test: cover wallet creation SQLite lifecycle
j-kon Jun 23, 2026
48bd644
test: cover multiple SQLite wallet address reveals
j-kon Jun 26, 2026
a72b126
test: cover explicit SQLite wallet persist contract
j-kon Jun 26, 2026
08997e5
test: cover independent SQLite keychain indexes
j-kon Jun 26, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
376 changes: 376 additions & 0 deletions test/integration/wallet_creation_test.dart
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,376 @@
// @Tags(['integration'])

import 'dart:io';

import 'package:bdk_dart/bdk.dart';
import 'package:test/test.dart';

import '../test_constants.dart';

Future<void> _deleteDirectoryWithRetry(Directory directory) async {
for (var attempt = 0; attempt < 10; attempt++) {
try {
if (directory.existsSync()) {
await directory.delete(recursive: true);
}
return;
} on PathAccessException {
await Future<void>.delayed(const Duration(milliseconds: 100));
}
}

if (directory.existsSync()) {
await directory.delete(recursive: true);
}
}

void main() {
group('Wallet creation integration', () {
test('persists derivation state across a SQLite reopen', () {
final tempDir = Directory.systemTemp.createTempSync(
'bdk_dart_wallet_creation_',
);
addTearDown(() => _deleteDirectoryWithRetry(tempDir));

final dbPath = '${tempDir.path}/wallet.sqlite';
final descriptor = buildBip84Descriptor(Network.testnet);
final changeDescriptor = buildBip84ChangeDescriptor(Network.testnet);
Persister? persister;
Wallet? wallet;
Persister? reopenedPersister;
Wallet? reopenedWallet;

try {
expect(File(dbPath).existsSync(), isFalse);

final initialPersister = Persister.newSqlite(path: dbPath);
persister = initialPersister;

wallet = Wallet(
descriptor: descriptor,
changeDescriptor: changeDescriptor,
network: Network.testnet,
persister: initialPersister,
lookahead: defaultLookahead,
);

final externalAddress = wallet.revealNextAddress(
keychain: KeychainKind.external_,
);
final internalAddress = wallet.revealNextAddress(
keychain: KeychainKind.internal,
);

expect(externalAddress.index, equals(0));
expect(internalAddress.index, equals(0));
expect(wallet.persist(persister: initialPersister), isTrue);

wallet.dispose();
wallet = null;
persister.dispose();
persister = null;

expect(File(dbPath).existsSync(), isTrue);

reopenedPersister = Persister.newSqlite(path: dbPath);
reopenedWallet = Wallet.load(
descriptor: descriptor,
changeDescriptor: changeDescriptor,
persister: reopenedPersister,
lookahead: defaultLookahead,
);

expect(reopenedWallet.network(), equals(Network.testnet));
expect(reopenedWallet.balance().total.toSat(), equals(0));
expect(
reopenedWallet.nextDerivationIndex(keychain: KeychainKind.external_),
equals(1),
);
expect(
reopenedWallet.nextDerivationIndex(keychain: KeychainKind.internal),
equals(1),
);

final reopenedExternalAddress = reopenedWallet.peekAddress(
keychain: KeychainKind.external_,
index: externalAddress.index,
);
final reopenedInternalAddress = reopenedWallet.peekAddress(
keychain: KeychainKind.internal,
index: internalAddress.index,
);

expect(
reopenedExternalAddress.address.scriptPubkey().toBytes(),
orderedEquals(externalAddress.address.scriptPubkey().toBytes()),
);
expect(
reopenedInternalAddress.address.scriptPubkey().toBytes(),
orderedEquals(internalAddress.address.scriptPubkey().toBytes()),
);
} finally {
reopenedWallet?.dispose();
reopenedPersister?.dispose();
wallet?.dispose();
persister?.dispose();
descriptor.dispose();
changeDescriptor.dispose();
}
});

test('cover multiple SQLite wallet address reveals', () {
final tempDir = Directory.systemTemp.createTempSync(
'bdk_dart_wallet_creation_test1_',
);
addTearDown(() => _deleteDirectoryWithRetry(tempDir));

final dbPath = '${tempDir.path}/wallet.sqlite';
final descriptor = buildBip84Descriptor(Network.testnet);
final changeDescriptor = buildBip84ChangeDescriptor(Network.testnet);
Persister? persister;
Wallet? wallet;
Persister? reopenedPersister;
Wallet? reopenedWallet;

try {
final initialPersister = Persister.newSqlite(path: dbPath);
persister = initialPersister;

wallet = Wallet(
descriptor: descriptor,
changeDescriptor: changeDescriptor,
network: Network.testnet,
persister: initialPersister,
lookahead: defaultLookahead,
);

final ext0 = wallet.revealNextAddress(keychain: KeychainKind.external_);
final ext1 = wallet.revealNextAddress(keychain: KeychainKind.external_);
final ext2 = wallet.revealNextAddress(keychain: KeychainKind.external_);
final int0 = wallet.revealNextAddress(keychain: KeychainKind.internal);

expect(ext0.index, equals(0));
expect(ext1.index, equals(1));
expect(ext2.index, equals(2));
expect(int0.index, equals(0));

expect(wallet.persist(persister: initialPersister), isTrue);

wallet.dispose();
wallet = null;
persister.dispose();
persister = null;

reopenedPersister = Persister.newSqlite(path: dbPath);
reopenedWallet = Wallet.load(
descriptor: descriptor,
changeDescriptor: changeDescriptor,
persister: reopenedPersister,
lookahead: defaultLookahead,
);

expect(
reopenedWallet.nextDerivationIndex(keychain: KeychainKind.external_),
equals(3),
);
expect(
reopenedWallet.nextDerivationIndex(keychain: KeychainKind.internal),
equals(1),
);

final reopenedExt0 = reopenedWallet.peekAddress(
keychain: KeychainKind.external_,
index: 0,
);
final reopenedExt1 = reopenedWallet.peekAddress(
keychain: KeychainKind.external_,
index: 1,
);
final reopenedExt2 = reopenedWallet.peekAddress(
keychain: KeychainKind.external_,
index: 2,
);
final reopenedInt0 = reopenedWallet.peekAddress(
keychain: KeychainKind.internal,
index: 0,
);

expect(
reopenedExt0.address.scriptPubkey().toBytes(),
orderedEquals(ext0.address.scriptPubkey().toBytes()),
);
expect(
reopenedExt1.address.scriptPubkey().toBytes(),
orderedEquals(ext1.address.scriptPubkey().toBytes()),
);
expect(
reopenedExt2.address.scriptPubkey().toBytes(),
orderedEquals(ext2.address.scriptPubkey().toBytes()),
);
expect(
reopenedInt0.address.scriptPubkey().toBytes(),
orderedEquals(int0.address.scriptPubkey().toBytes()),
);
} finally {
reopenedWallet?.dispose();
reopenedPersister?.dispose();
wallet?.dispose();
persister?.dispose();
descriptor.dispose();
changeDescriptor.dispose();
}
});

test('cover explicit SQLite wallet persist contract', () {
final tempDir = Directory.systemTemp.createTempSync(
'bdk_dart_wallet_creation_test2_',
);
addTearDown(() => _deleteDirectoryWithRetry(tempDir));

final dbPath = '${tempDir.path}/wallet.sqlite';
final descriptor = buildBip84Descriptor(Network.testnet);
final changeDescriptor = buildBip84ChangeDescriptor(Network.testnet);
Persister? persister;
Wallet? wallet;
Persister? reopenedPersister;
Wallet? reopenedWallet;

try {
final initialPersister = Persister.newSqlite(path: dbPath);
persister = initialPersister;

wallet = Wallet(
descriptor: descriptor,
changeDescriptor: changeDescriptor,
network: Network.testnet,
persister: initialPersister,
lookahead: defaultLookahead,
);

final ext0 = wallet.revealNextAddress(keychain: KeychainKind.external_);
expect(ext0.index, equals(0));

expect(wallet.persist(persister: initialPersister), isTrue);

final ext1 = wallet.revealNextAddress(keychain: KeychainKind.external_);
expect(ext1.index, equals(1));

wallet.dispose();
wallet = null;
persister.dispose();
persister = null;

reopenedPersister = Persister.newSqlite(path: dbPath);
reopenedWallet = Wallet.load(
descriptor: descriptor,
changeDescriptor: changeDescriptor,
persister: reopenedPersister,
lookahead: defaultLookahead,
);

expect(
reopenedWallet.nextDerivationIndex(keychain: KeychainKind.external_),
equals(1),
);
} finally {
reopenedWallet?.dispose();
reopenedPersister?.dispose();
wallet?.dispose();
persister?.dispose();
descriptor.dispose();
changeDescriptor.dispose();
}
});

test('cover independent SQLite keychain indexes', () {
final tempDir = Directory.systemTemp.createTempSync(
'bdk_dart_wallet_creation_test3_',
);
addTearDown(() => _deleteDirectoryWithRetry(tempDir));

final dbPath = '${tempDir.path}/wallet.sqlite';
final descriptor = buildBip84Descriptor(Network.testnet);
final changeDescriptor = buildBip84ChangeDescriptor(Network.testnet);
Persister? persister;
Wallet? wallet;
Persister? reopenedPersister;
Wallet? reopenedWallet;

try {
final initialPersister = Persister.newSqlite(path: dbPath);
persister = initialPersister;

wallet = Wallet(
descriptor: descriptor,
changeDescriptor: changeDescriptor,
network: Network.testnet,
persister: initialPersister,
lookahead: defaultLookahead,
);

final ext0 = wallet.revealNextAddress(keychain: KeychainKind.external_);
final ext1 = wallet.revealNextAddress(keychain: KeychainKind.external_);
final ext2 = wallet.revealNextAddress(keychain: KeychainKind.external_);

final int0 = wallet.revealNextAddress(keychain: KeychainKind.internal);
final int1 = wallet.revealNextAddress(keychain: KeychainKind.internal);

expect(ext0.index, equals(0));
expect(ext1.index, equals(1));
expect(ext2.index, equals(2));

expect(int0.index, equals(0));
expect(int1.index, equals(1));

expect(wallet.persist(persister: initialPersister), isTrue);

wallet.dispose();
wallet = null;
persister.dispose();
persister = null;

reopenedPersister = Persister.newSqlite(path: dbPath);
reopenedWallet = Wallet.load(
descriptor: descriptor,
changeDescriptor: changeDescriptor,
persister: reopenedPersister,
lookahead: defaultLookahead,
);

expect(
reopenedWallet.nextDerivationIndex(keychain: KeychainKind.external_),
equals(3),
);
expect(
reopenedWallet.nextDerivationIndex(keychain: KeychainKind.internal),
equals(2),
);

final reopenedExt1 = reopenedWallet.peekAddress(
keychain: KeychainKind.external_,
index: 1,
);
final reopenedInt0 = reopenedWallet.peekAddress(
keychain: KeychainKind.internal,
index: 0,
);

expect(
reopenedExt1.address.scriptPubkey().toBytes(),
orderedEquals(ext1.address.scriptPubkey().toBytes()),
);
expect(
reopenedInt0.address.scriptPubkey().toBytes(),
orderedEquals(int0.address.scriptPubkey().toBytes()),
);
} finally {
reopenedWallet?.dispose();
reopenedPersister?.dispose();
wallet?.dispose();
persister?.dispose();
descriptor.dispose();
changeDescriptor.dispose();
}
});
});
}
Loading