mirror of
https://github.com/cypherstack/stack_wallet.git
synced 2024-11-18 10:11:03 +00:00
1702 lines
65 KiB
Dart
1702 lines
65 KiB
Dart
import 'package:decimal/decimal.dart';
|
|
import 'package:flutter_test/flutter_test.dart';
|
|
import 'package:hive/hive.dart';
|
|
import 'package:hive_test/hive_test.dart';
|
|
import 'package:mockito/annotations.dart';
|
|
import 'package:mockito/mockito.dart';
|
|
import 'package:stackwallet/db/main_db.dart';
|
|
import 'package:stackwallet/electrumx_rpc/cached_electrumx.dart';
|
|
import 'package:stackwallet/electrumx_rpc/electrumx.dart';
|
|
import 'package:stackwallet/hive/db.dart';
|
|
import 'package:stackwallet/models/paymint/fee_object_model.dart';
|
|
import 'package:stackwallet/services/coins/namecoin/namecoin_wallet.dart';
|
|
import 'package:stackwallet/services/transaction_notification_tracker.dart';
|
|
import 'package:stackwallet/utilities/enums/coin_enum.dart';
|
|
import 'package:stackwallet/utilities/flutter_secure_storage_interface.dart';
|
|
|
|
import 'namecoin_history_sample_data.dart';
|
|
import 'namecoin_transaction_data_samples.dart';
|
|
import 'namecoin_wallet_test.mocks.dart';
|
|
import 'namecoin_wallet_test_parameters.dart';
|
|
|
|
@GenerateMocks([
|
|
ElectrumX,
|
|
CachedElectrumX,
|
|
TransactionNotificationTracker,
|
|
MainDB,
|
|
])
|
|
void main() {
|
|
group("namecoin constants", () {
|
|
test("namecoin minimum confirmations", () async {
|
|
expect(MINIMUM_CONFIRMATIONS, 2);
|
|
});
|
|
test("namecoin dust limit", () async {
|
|
expect(DUST_LIMIT, 546);
|
|
});
|
|
test("namecoin mainnet genesis block hash", () async {
|
|
expect(GENESIS_HASH_MAINNET,
|
|
"000000000062b72c5e2ceb45fbc8587e807c155b0da735e6483dfba2f0a9c770");
|
|
});
|
|
test("namecoin testnet genesis block hash", () async {
|
|
expect(GENESIS_HASH_TESTNET,
|
|
"00000007199508e34a9ff81e6ec0c477a4cccff2a4767a8eee39c11db367b008");
|
|
});
|
|
});
|
|
|
|
test("namecoin DerivePathType enum", () {
|
|
expect(DerivePathType.values.length, 3);
|
|
expect(DerivePathType.values.toString(),
|
|
"[DerivePathType.bip44, DerivePathType.bip49, DerivePathType.bip84]");
|
|
});
|
|
|
|
group("bip32 node/root", () {
|
|
test("getBip32Root", () {
|
|
final root = getBip32Root(TEST_MNEMONIC, namecoin);
|
|
expect(root.toWIF(), ROOT_WIF);
|
|
});
|
|
|
|
// test("getBip32NodeFromRoot", () {
|
|
// final root = getBip32Root(TEST_MNEMONIC, namecoin);
|
|
// // two mainnet
|
|
// final node44 = getBip32NodeFromRoot(0, 0, root, DerivePathType.bip44);
|
|
// expect(node44.toWIF(), NODE_WIF_44);
|
|
// final node49 = getBip32NodeFromRoot(0, 0, root, DerivePathType.bip49);
|
|
// expect(node49.toWIF(), NODE_WIF_49);
|
|
// // and one on testnet
|
|
// final node84 = getBip32NodeFromRoot(
|
|
// 0, 0, getBip32Root(TEST_MNEMONIC, testnet), DerivePathType.bip84);
|
|
// expect(node84.toWIF(), NODE_WIF_84);
|
|
// // a bad derive path
|
|
// bool didThrow = false;
|
|
// try {
|
|
// getBip32NodeFromRoot(0, 0, root, null);
|
|
// } catch (_) {
|
|
// didThrow = true;
|
|
// }
|
|
// expect(didThrow, true);
|
|
// // finally an invalid network
|
|
// didThrow = false;
|
|
// final invalidNetwork = NetworkType(
|
|
// messagePrefix: '\x18hello world\n',
|
|
// bech32: 'gg',
|
|
// bip32: Bip32Type(public: 0x055521e, private: 0x055555),
|
|
// pubKeyHash: 0x55,
|
|
// scriptHash: 0x55,
|
|
// wif: 0x00);
|
|
// try {
|
|
// getBip32NodeFromRoot(0, 0, getBip32Root(TEST_MNEMONIC, invalidNetwork),
|
|
// DerivePathType.bip44);
|
|
// } catch (_) {
|
|
// didThrow = true;
|
|
// }
|
|
// expect(didThrow, true);
|
|
// });
|
|
|
|
// test("basic getBip32Node", () {
|
|
// final node =
|
|
// getBip32Node(0, 0, TEST_MNEMONIC, testnet, DerivePathType.bip84);
|
|
// expect(node.toWIF(), NODE_WIF_84);
|
|
// });
|
|
});
|
|
|
|
group("validate mainnet namecoin addresses", () {
|
|
MockElectrumX? client;
|
|
MockCachedElectrumX? cachedClient;
|
|
late FakeSecureStorage secureStore;
|
|
MockTransactionNotificationTracker? tracker;
|
|
late MockMainDB mockMainDB;
|
|
|
|
NamecoinWallet? mainnetWallet;
|
|
|
|
setUp(() {
|
|
client = MockElectrumX();
|
|
cachedClient = MockCachedElectrumX();
|
|
secureStore = FakeSecureStorage();
|
|
tracker = MockTransactionNotificationTracker();
|
|
mockMainDB = MockMainDB();
|
|
|
|
mainnetWallet = NamecoinWallet(
|
|
walletId: "validateAddressMainNet",
|
|
walletName: "validateAddressMainNet",
|
|
coin: Coin.namecoin,
|
|
client: client!,
|
|
cachedClient: cachedClient!,
|
|
tracker: tracker!,
|
|
secureStore: secureStore,
|
|
mockableOverride: mockMainDB,
|
|
);
|
|
});
|
|
|
|
test("valid mainnet legacy/p2pkh address type", () {
|
|
expect(
|
|
mainnetWallet?.addressType(
|
|
address: "N673DDbjPcrNgJmrhJ1xQXF9LLizQzvjEs"),
|
|
DerivePathType.bip44);
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
verifyNoMoreInteractions(tracker);
|
|
});
|
|
|
|
test("valid mainnet bech32 p2wpkh address type", () {
|
|
expect(
|
|
mainnetWallet?.addressType(
|
|
address: "nc1q6k4x8ye6865z3rc8zkt8gyu52na7njqt6hsk4v"),
|
|
DerivePathType.bip84);
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
verifyNoMoreInteractions(tracker);
|
|
});
|
|
|
|
test("invalid bech32 address type", () {
|
|
expect(
|
|
() => mainnetWallet?.addressType(
|
|
address: "tb1qzzlm6mnc8k54mx6akehl8p9ray8r439va5ndyq"),
|
|
throwsArgumentError);
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
verifyNoMoreInteractions(tracker);
|
|
});
|
|
|
|
test("address has no matching script", () {
|
|
expect(
|
|
() => mainnetWallet?.addressType(
|
|
address: "mpMk94ETazqonHutyC1v6ajshgtP8oiFKU"),
|
|
throwsArgumentError);
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
verifyNoMoreInteractions(tracker);
|
|
});
|
|
});
|
|
|
|
group("testNetworkConnection", () {
|
|
MockElectrumX? client;
|
|
MockCachedElectrumX? cachedClient;
|
|
late FakeSecureStorage secureStore;
|
|
MockTransactionNotificationTracker? tracker;
|
|
late MockMainDB mockMainDB;
|
|
|
|
NamecoinWallet? nmc;
|
|
|
|
setUp(() {
|
|
client = MockElectrumX();
|
|
cachedClient = MockCachedElectrumX();
|
|
secureStore = FakeSecureStorage();
|
|
tracker = MockTransactionNotificationTracker();
|
|
mockMainDB = MockMainDB();
|
|
|
|
nmc = NamecoinWallet(
|
|
walletId: "testNetworkConnection",
|
|
walletName: "testNetworkConnection",
|
|
coin: Coin.namecoin,
|
|
client: client!,
|
|
cachedClient: cachedClient!,
|
|
tracker: tracker!,
|
|
secureStore: secureStore,
|
|
mockableOverride: mockMainDB,
|
|
);
|
|
});
|
|
|
|
test("attempted connection fails due to server error", () async {
|
|
when(client?.ping()).thenAnswer((_) async => false);
|
|
final bool? result = await nmc?.testNetworkConnection();
|
|
expect(result, false);
|
|
expect(secureStore.interactions, 0);
|
|
verify(client?.ping()).called(1);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("attempted connection fails due to exception", () async {
|
|
when(client?.ping()).thenThrow(Exception);
|
|
final bool? result = await nmc?.testNetworkConnection();
|
|
expect(result, false);
|
|
expect(secureStore.interactions, 0);
|
|
verify(client?.ping()).called(1);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("attempted connection test success", () async {
|
|
when(client?.ping()).thenAnswer((_) async => true);
|
|
final bool? result = await nmc?.testNetworkConnection();
|
|
expect(result, true);
|
|
expect(secureStore.interactions, 0);
|
|
verify(client?.ping()).called(1);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
});
|
|
|
|
group("basic getters, setters, and functions", () {
|
|
const testWalletId = "NMCtestWalletID";
|
|
const testWalletName = "NMCWallet";
|
|
|
|
MockElectrumX? client;
|
|
MockCachedElectrumX? cachedClient;
|
|
|
|
late FakeSecureStorage secureStore;
|
|
MockTransactionNotificationTracker? tracker;
|
|
late MockMainDB mockMainDB;
|
|
|
|
NamecoinWallet? nmc;
|
|
|
|
setUp(() async {
|
|
client = MockElectrumX();
|
|
cachedClient = MockCachedElectrumX();
|
|
|
|
secureStore = FakeSecureStorage();
|
|
tracker = MockTransactionNotificationTracker();
|
|
mockMainDB = MockMainDB();
|
|
|
|
nmc = NamecoinWallet(
|
|
walletId: testWalletId,
|
|
walletName: testWalletName,
|
|
coin: Coin.namecoin,
|
|
client: client!,
|
|
cachedClient: cachedClient!,
|
|
tracker: tracker!,
|
|
secureStore: secureStore,
|
|
mockableOverride: mockMainDB,
|
|
);
|
|
});
|
|
|
|
test("get networkType main", () async {
|
|
expect(Coin.namecoin, Coin.namecoin);
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("get networkType test", () async {
|
|
nmc = NamecoinWallet(
|
|
walletId: testWalletId,
|
|
walletName: testWalletName,
|
|
coin: Coin.namecoin,
|
|
client: client!,
|
|
cachedClient: cachedClient!,
|
|
tracker: tracker!,
|
|
secureStore: secureStore,
|
|
mockableOverride: mockMainDB,
|
|
);
|
|
expect(Coin.namecoin, Coin.namecoin);
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("get cryptoCurrency", () async {
|
|
expect(Coin.namecoin, Coin.namecoin);
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("get coinName", () async {
|
|
expect(Coin.namecoin, Coin.namecoin);
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("get coinTicker", () async {
|
|
expect(Coin.namecoin, Coin.namecoin);
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("get and set walletName", () async {
|
|
expect(Coin.namecoin, Coin.namecoin);
|
|
nmc?.walletName = "new name";
|
|
expect(nmc?.walletName, "new name");
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("estimateTxFee", () async {
|
|
expect(nmc?.estimateTxFee(vSize: 356, feeRatePerKB: 1), 356);
|
|
expect(nmc?.estimateTxFee(vSize: 356, feeRatePerKB: 900), 356);
|
|
expect(nmc?.estimateTxFee(vSize: 356, feeRatePerKB: 999), 356);
|
|
expect(nmc?.estimateTxFee(vSize: 356, feeRatePerKB: 1000), 356);
|
|
expect(nmc?.estimateTxFee(vSize: 356, feeRatePerKB: 1001), 712);
|
|
expect(nmc?.estimateTxFee(vSize: 356, feeRatePerKB: 1699), 712);
|
|
expect(nmc?.estimateTxFee(vSize: 356, feeRatePerKB: 2000), 712);
|
|
expect(nmc?.estimateTxFee(vSize: 356, feeRatePerKB: 12345), 4628);
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("get fees succeeds", () async {
|
|
when(client?.ping()).thenAnswer((_) async => true);
|
|
when(client?.getServerFeatures()).thenAnswer((_) async => {
|
|
"hosts": <dynamic, dynamic>{},
|
|
"pruning": null,
|
|
"server_version": "Unit tests",
|
|
"protocol_min": "1.4",
|
|
"protocol_max": "1.4.2",
|
|
"genesis_hash": GENESIS_HASH_MAINNET,
|
|
"hash_function": "sha256",
|
|
"services": <dynamic>[]
|
|
});
|
|
when(client?.estimateFee(blocks: 1))
|
|
.thenAnswer((realInvocation) async => Decimal.zero);
|
|
when(client?.estimateFee(blocks: 5))
|
|
.thenAnswer((realInvocation) async => Decimal.one);
|
|
when(client?.estimateFee(blocks: 20))
|
|
.thenAnswer((realInvocation) async => Decimal.ten);
|
|
|
|
final fees = await nmc?.fees;
|
|
expect(fees, isA<FeeObject>());
|
|
expect(fees?.slow, 1000000000);
|
|
expect(fees?.medium, 100000000);
|
|
expect(fees?.fast, 0);
|
|
|
|
verify(client?.estimateFee(blocks: 1)).called(1);
|
|
verify(client?.estimateFee(blocks: 5)).called(1);
|
|
verify(client?.estimateFee(blocks: 20)).called(1);
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("get fees fails", () async {
|
|
when(client?.ping()).thenAnswer((_) async => true);
|
|
when(client?.getServerFeatures()).thenAnswer((_) async => {
|
|
"hosts": <dynamic, dynamic>{},
|
|
"pruning": null,
|
|
"server_version": "Unit tests",
|
|
"protocol_min": "1.4",
|
|
"protocol_max": "1.4.2",
|
|
"genesis_hash": GENESIS_HASH_MAINNET,
|
|
"hash_function": "sha256",
|
|
"services": <dynamic>[]
|
|
});
|
|
when(client?.estimateFee(blocks: 1))
|
|
.thenAnswer((realInvocation) async => Decimal.zero);
|
|
when(client?.estimateFee(blocks: 5))
|
|
.thenAnswer((realInvocation) async => Decimal.one);
|
|
when(client?.estimateFee(blocks: 20))
|
|
.thenThrow(Exception("some exception"));
|
|
|
|
bool didThrow = false;
|
|
try {
|
|
await nmc?.fees;
|
|
} catch (_) {
|
|
didThrow = true;
|
|
}
|
|
|
|
expect(didThrow, true);
|
|
|
|
verify(client?.estimateFee(blocks: 1)).called(1);
|
|
verify(client?.estimateFee(blocks: 5)).called(1);
|
|
verify(client?.estimateFee(blocks: 20)).called(1);
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
// test("get maxFee", () async {
|
|
// when(client?.ping()).thenAnswer((_) async => true);
|
|
// when(client?.getServerFeatures()).thenAnswer((_) async => {
|
|
// "hosts": <dynamic, dynamic>{},
|
|
// "pruning": null,
|
|
// "server_version": "Unit tests",
|
|
// "protocol_min": "1.4",
|
|
// "protocol_max": "1.4.2",
|
|
// "genesis_hash": GENESIS_HASH_TESTNET,
|
|
// "hash_function": "sha256",
|
|
// "services": <dynamic>[]
|
|
// });
|
|
// when(client?.estimateFee(blocks: 20))
|
|
// .thenAnswer((realInvocation) async => Decimal.zero);
|
|
// when(client?.estimateFee(blocks: 5))
|
|
// .thenAnswer((realInvocation) async => Decimal.one);
|
|
// when(client?.estimateFee(blocks: 1))
|
|
// .thenAnswer((realInvocation) async => Decimal.ten);
|
|
//
|
|
// final maxFee = await nmc?.maxFee;
|
|
// expect(maxFee, 1000000000);
|
|
//
|
|
// verify(client?.estimateFee(blocks: 1)).called(1);
|
|
// verify(client?.estimateFee(blocks: 5)).called(1);
|
|
// verify(client?.estimateFee(blocks: 20)).called(1);
|
|
// expect(secureStore.interactions, 0);
|
|
// verifyNoMoreInteractions(client);
|
|
// verifyNoMoreInteractions(cachedClient);
|
|
// verifyNoMoreInteractions(tracker);
|
|
//
|
|
// });
|
|
});
|
|
|
|
group("Namecoin service class functions that depend on shared storage", () {
|
|
const testWalletId = "NMCtestWalletID";
|
|
const testWalletName = "NMCWallet";
|
|
|
|
bool hiveAdaptersRegistered = false;
|
|
|
|
MockElectrumX? client;
|
|
MockCachedElectrumX? cachedClient;
|
|
|
|
late FakeSecureStorage secureStore;
|
|
MockTransactionNotificationTracker? tracker;
|
|
late MockMainDB mockMainDB;
|
|
|
|
NamecoinWallet? nmc;
|
|
|
|
setUp(() async {
|
|
await setUpTestHive();
|
|
if (!hiveAdaptersRegistered) {
|
|
hiveAdaptersRegistered = true;
|
|
|
|
final wallets = await Hive.openBox<dynamic>('wallets');
|
|
await wallets.put('currentWalletName', testWalletName);
|
|
}
|
|
|
|
client = MockElectrumX();
|
|
cachedClient = MockCachedElectrumX();
|
|
|
|
secureStore = FakeSecureStorage();
|
|
tracker = MockTransactionNotificationTracker();
|
|
mockMainDB = MockMainDB();
|
|
|
|
nmc = NamecoinWallet(
|
|
walletId: testWalletId,
|
|
walletName: testWalletName,
|
|
coin: Coin.namecoin,
|
|
client: client!,
|
|
cachedClient: cachedClient!,
|
|
tracker: tracker!,
|
|
secureStore: secureStore,
|
|
mockableOverride: mockMainDB,
|
|
);
|
|
});
|
|
|
|
// test("initializeWallet no network", () async {
|
|
// when(client?.ping()).thenAnswer((_) async => false);
|
|
// expect(await nmc?.initializeWallet(), false);
|
|
// expect(secureStore.interactions, 0);
|
|
// verify(client?.ping()).called(1);
|
|
// verifyNoMoreInteractions(client);
|
|
// verifyNoMoreInteractions(cachedClient);
|
|
//
|
|
// });
|
|
|
|
// test("initializeWallet no network exception", () async {
|
|
// when(client?.ping()).thenThrow(Exception("Network connection failed"));
|
|
// final wallets = await Hive.openBox<dynamic>(testWalletId);
|
|
// expect(await nmc?.initializeExisting(), false);
|
|
// expect(secureStore.interactions, 0);
|
|
// verify(client?.ping()).called(1);
|
|
// verifyNoMoreInteractions(client);
|
|
// verifyNoMoreInteractions(cachedClient);
|
|
//
|
|
// });
|
|
|
|
test("initializeWallet mainnet throws bad network", () async {
|
|
when(client?.ping()).thenAnswer((_) async => true);
|
|
when(client?.getServerFeatures()).thenAnswer((_) async => {
|
|
"hosts": <dynamic, dynamic>{},
|
|
"pruning": null,
|
|
"server_version": "Unit tests",
|
|
"protocol_min": "1.4",
|
|
"protocol_max": "1.4.2",
|
|
"genesis_hash": GENESIS_HASH_MAINNET,
|
|
"hash_function": "sha256",
|
|
"services": <dynamic>[]
|
|
});
|
|
// await nmc?.initializeNew();
|
|
await Hive.openBox<dynamic>(testWalletId);
|
|
|
|
await expectLater(
|
|
() => nmc?.initializeExisting(), throwsA(isA<Exception>()))
|
|
.then((_) {
|
|
expect(secureStore.interactions, 0);
|
|
// verify(client?.ping()).called(1);
|
|
// verify(client?.getServerFeatures()).called(1);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
});
|
|
|
|
test("initializeWallet throws mnemonic overwrite exception", () async {
|
|
when(client?.ping()).thenAnswer((_) async => true);
|
|
when(client?.getServerFeatures()).thenAnswer((_) async => {
|
|
"hosts": <dynamic, dynamic>{},
|
|
"pruning": null,
|
|
"server_version": "Unit tests",
|
|
"protocol_min": "1.4",
|
|
"protocol_max": "1.4.2",
|
|
"genesis_hash": GENESIS_HASH_MAINNET,
|
|
"hash_function": "sha256",
|
|
"services": <dynamic>[]
|
|
});
|
|
await secureStore.write(
|
|
key: "${testWalletId}_mnemonic", value: "some mnemonic");
|
|
|
|
await Hive.openBox<dynamic>(testWalletId);
|
|
await expectLater(
|
|
() => nmc?.initializeExisting(), throwsA(isA<Exception>()))
|
|
.then((_) {
|
|
expect(secureStore.interactions, 1);
|
|
// verify(client?.ping()).called(1);
|
|
// verify(client?.getServerFeatures()).called(1);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
});
|
|
|
|
// test(
|
|
// "recoverFromMnemonic using empty seed on mainnet fails due to bad genesis hash match",
|
|
// () async {
|
|
// when(client?.getServerFeatures()).thenAnswer((_) async => {
|
|
// "hosts": <dynamic, dynamic>{},
|
|
// "pruning": null,
|
|
// "server_version": "Unit tests",
|
|
// "protocol_min": "1.4",
|
|
// "protocol_max": "1.4.2",
|
|
// "genesis_hash": GENESIS_HASH_TESTNET,
|
|
// "hash_function": "sha256",
|
|
// "services": <dynamic>[]
|
|
// });
|
|
//
|
|
// bool hasThrown = false;
|
|
// try {
|
|
// await nmc?.recoverFromMnemonic(
|
|
// mnemonic: TEST_MNEMONIC,
|
|
// maxUnusedAddressGap: 2,
|
|
// maxNumberOfIndexesToCheck: 1000,
|
|
// height: 4000);
|
|
// } catch (_) {
|
|
// hasThrown = true;
|
|
// }
|
|
// expect(hasThrown, false);
|
|
//
|
|
// verify(client?.getServerFeatures()).called(1);
|
|
//
|
|
// expect(secureStore.interactions, 0);
|
|
// verifyNoMoreInteractions(client);
|
|
// verifyNoMoreInteractions(cachedClient);
|
|
//
|
|
// });
|
|
|
|
test(
|
|
"recoverFromMnemonic using empty seed on mainnet fails due to attempted overwrite of mnemonic",
|
|
() async {
|
|
when(client?.getServerFeatures()).thenAnswer((_) async => {
|
|
"hosts": <dynamic, dynamic>{},
|
|
"pruning": null,
|
|
"server_version": "Unit tests",
|
|
"protocol_min": "1.4",
|
|
"protocol_max": "1.4.2",
|
|
"genesis_hash": GENESIS_HASH_MAINNET,
|
|
"hash_function": "sha256",
|
|
"services": <dynamic>[]
|
|
});
|
|
|
|
await secureStore.write(
|
|
key: "${testWalletId}_mnemonic", value: "some mnemonic words");
|
|
|
|
bool hasThrown = false;
|
|
try {
|
|
await nmc?.recoverFromMnemonic(
|
|
mnemonic: TEST_MNEMONIC,
|
|
maxUnusedAddressGap: 2,
|
|
maxNumberOfIndexesToCheck: 1000,
|
|
height: 4000);
|
|
} catch (_) {
|
|
hasThrown = true;
|
|
}
|
|
expect(hasThrown, true);
|
|
|
|
verify(client?.getServerFeatures()).called(1);
|
|
|
|
expect(secureStore.interactions, 2);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("recoverFromMnemonic using empty seed on mainnet succeeds", () async {
|
|
when(client?.getServerFeatures()).thenAnswer((_) async => {
|
|
"hosts": <dynamic, dynamic>{},
|
|
"pruning": null,
|
|
"server_version": "Unit tests",
|
|
"protocol_min": "1.4",
|
|
"protocol_max": "1.4.2",
|
|
"genesis_hash": GENESIS_HASH_MAINNET,
|
|
"hash_function": "sha256",
|
|
"services": <dynamic>[]
|
|
});
|
|
when(client?.getBatchHistory(args: historyBatchArgs0))
|
|
.thenAnswer((_) async => emptyHistoryBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs1))
|
|
.thenAnswer((_) async => emptyHistoryBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs2))
|
|
.thenAnswer((_) async => emptyHistoryBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs3))
|
|
.thenAnswer((_) async => emptyHistoryBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs4))
|
|
.thenAnswer((_) async => emptyHistoryBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs5))
|
|
.thenAnswer((_) async => emptyHistoryBatchResponse);
|
|
await DB.instance.init();
|
|
await Hive.openBox<dynamic>(testWalletId);
|
|
bool hasThrown = false;
|
|
try {
|
|
await nmc?.recoverFromMnemonic(
|
|
mnemonic: TEST_MNEMONIC,
|
|
maxUnusedAddressGap: 2,
|
|
maxNumberOfIndexesToCheck: 1000,
|
|
height: 4000);
|
|
} catch (_) {
|
|
hasThrown = true;
|
|
}
|
|
expect(hasThrown, false);
|
|
|
|
verify(client?.getServerFeatures()).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs0)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs1)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs2)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs3)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs4)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs5)).called(1);
|
|
|
|
expect(secureStore.interactions, 20);
|
|
expect(secureStore.writes, 7);
|
|
expect(secureStore.reads, 13);
|
|
expect(secureStore.deletes, 0);
|
|
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("get mnemonic list", () async {
|
|
when(client?.getServerFeatures()).thenAnswer((_) async => {
|
|
"hosts": <dynamic, dynamic>{},
|
|
"pruning": null,
|
|
"server_version": "Unit tests",
|
|
"protocol_min": "1.4",
|
|
"protocol_max": "1.4.2",
|
|
"genesis_hash": GENESIS_HASH_MAINNET,
|
|
"hash_function": "sha256",
|
|
"services": <dynamic>[]
|
|
});
|
|
when(client?.getBatchHistory(args: historyBatchArgs0))
|
|
.thenAnswer((_) async => emptyHistoryBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs1))
|
|
.thenAnswer((_) async => emptyHistoryBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs2))
|
|
.thenAnswer((_) async => emptyHistoryBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs3))
|
|
.thenAnswer((_) async => emptyHistoryBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs4))
|
|
.thenAnswer((_) async => emptyHistoryBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs5))
|
|
.thenAnswer((_) async => emptyHistoryBatchResponse);
|
|
|
|
await Hive.openBox<dynamic>(testWalletId);
|
|
|
|
await nmc?.recoverFromMnemonic(
|
|
mnemonic: TEST_MNEMONIC,
|
|
maxUnusedAddressGap: 2,
|
|
maxNumberOfIndexesToCheck: 1000,
|
|
height: 4000);
|
|
|
|
expect(await nmc?.mnemonic, TEST_MNEMONIC.split(" "));
|
|
|
|
verify(client?.getServerFeatures()).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs0)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs1)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs2)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs3)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs4)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs5)).called(1);
|
|
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("recoverFromMnemonic using non empty seed on mainnet succeeds",
|
|
() async {
|
|
when(client?.getServerFeatures()).thenAnswer((_) async => {
|
|
"hosts": <dynamic, dynamic>{},
|
|
"pruning": null,
|
|
"server_version": "Unit tests",
|
|
"protocol_min": "1.4",
|
|
"protocol_max": "1.4.2",
|
|
"genesis_hash": GENESIS_HASH_MAINNET,
|
|
"hash_function": "sha256",
|
|
"services": <dynamic>[]
|
|
});
|
|
when(client?.getBatchHistory(args: historyBatchArgs0))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs1))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs2))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs3))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs4))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs5))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
|
|
List<dynamic> dynamicArgValues = [];
|
|
|
|
when(client?.getBatchHistory(args: anyNamed("args")))
|
|
.thenAnswer((realInvocation) async {
|
|
if (realInvocation.namedArguments.values.first.length == 1) {
|
|
dynamicArgValues.add(realInvocation.namedArguments.values.first);
|
|
}
|
|
|
|
return historyBatchResponse;
|
|
});
|
|
|
|
await Hive.openBox<dynamic>(testWalletId);
|
|
|
|
bool hasThrown = false;
|
|
try {
|
|
await nmc?.recoverFromMnemonic(
|
|
mnemonic: TEST_MNEMONIC,
|
|
maxUnusedAddressGap: 2,
|
|
maxNumberOfIndexesToCheck: 1000,
|
|
height: 4000);
|
|
} catch (_) {
|
|
hasThrown = true;
|
|
}
|
|
expect(hasThrown, false);
|
|
|
|
verify(client?.getServerFeatures()).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs0)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs1)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs2)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs3)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs4)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs5)).called(1);
|
|
|
|
for (final arg in dynamicArgValues) {
|
|
final map = Map<String, List<dynamic>>.from(arg as Map);
|
|
|
|
verify(client?.getBatchHistory(args: map)).called(1);
|
|
expect(activeScriptHashes.contains(map.values.first.first as String),
|
|
true);
|
|
}
|
|
|
|
expect(secureStore.interactions, 14);
|
|
expect(secureStore.writes, 7);
|
|
expect(secureStore.reads, 7);
|
|
expect(secureStore.deletes, 0);
|
|
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("fullRescan succeeds", () async {
|
|
when(client?.getServerFeatures()).thenAnswer((_) async => {
|
|
"hosts": <dynamic, dynamic>{},
|
|
"pruning": null,
|
|
"server_version": "Unit tests",
|
|
"protocol_min": "1.4",
|
|
"protocol_max": "1.4.2",
|
|
"genesis_hash": GENESIS_HASH_MAINNET,
|
|
"hash_function": "sha256",
|
|
"services": <dynamic>[]
|
|
});
|
|
when(client?.getBatchHistory(args: historyBatchArgs0))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs1))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs2))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs3))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs4))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs5))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(cachedClient?.clearSharedTransactionCache(coin: Coin.namecoin))
|
|
.thenAnswer((realInvocation) async {});
|
|
|
|
when(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"dd63fc12f5e6c1ada2cf3c941d1648e6d561ce4024747bb2117d72112d83287c"
|
|
]
|
|
})).thenAnswer((realInvocation) async => {"0": []});
|
|
|
|
when(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"86906979fc9107d06d560275d7de8305b69d7189c3206ac9070ad76e6abff874"
|
|
]
|
|
})).thenAnswer((realInvocation) async => {"0": []});
|
|
|
|
when(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"c068e7fa4aa0b8a63114f6d11c047ca4be6a8fa333eb0dac48506e8f150af73b"
|
|
]
|
|
})).thenAnswer((realInvocation) async => {"0": []});
|
|
|
|
when(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"cd3dd4abe4f9efc7149ba334d2d6790020331805b0bd5c7ed89a3ac6a22f10b9"
|
|
]
|
|
})).thenAnswer((realInvocation) async => {"0": []});
|
|
when(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"587943864cefed4f1643a5ee2ce2b3c13a0c6ad7c435373f0ac328e144a15c1e"
|
|
]
|
|
})).thenAnswer((realInvocation) async => {"0": []});
|
|
when(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"42d6e40636f4740f9c7f95ef0bbc2a4c17f54da2bc98a32a622e2bf73eb675c3"
|
|
]
|
|
})).thenAnswer((realInvocation) async => {"0": []});
|
|
|
|
final wallet = await Hive.openBox<dynamic>(testWalletId);
|
|
|
|
// restore so we have something to rescan
|
|
await nmc?.recoverFromMnemonic(
|
|
mnemonic: TEST_MNEMONIC,
|
|
maxUnusedAddressGap: 2,
|
|
maxNumberOfIndexesToCheck: 1000,
|
|
height: 4000);
|
|
|
|
// fetch valid wallet data
|
|
final preReceivingAddressesP2PKH =
|
|
await wallet.get('receivingAddressesP2PKH');
|
|
final preReceivingAddressesP2SH =
|
|
await wallet.get('receivingAddressesP2SH');
|
|
final preReceivingAddressesP2WPKH =
|
|
await wallet.get('receivingAddressesP2WPKH');
|
|
final preChangeAddressesP2PKH = await wallet.get('changeAddressesP2PKH');
|
|
final preChangeAddressesP2SH = await wallet.get('changeAddressesP2SH');
|
|
final preChangeAddressesP2WPKH =
|
|
await wallet.get('changeAddressesP2WPKH');
|
|
final preReceivingIndexP2PKH = await wallet.get('receivingIndexP2PKH');
|
|
final preReceivingIndexP2SH = await wallet.get('receivingIndexP2SH');
|
|
final preReceivingIndexP2WPKH = await wallet.get('receivingIndexP2WPKH');
|
|
final preChangeIndexP2PKH = await wallet.get('changeIndexP2PKH');
|
|
final preChangeIndexP2SH = await wallet.get('changeIndexP2SH');
|
|
final preChangeIndexP2WPKH = await wallet.get('changeIndexP2WPKH');
|
|
final preUtxoData = await wallet.get('latest_utxo_model');
|
|
final preReceiveDerivationsStringP2PKH = await secureStore.read(
|
|
key: "${testWalletId}_receiveDerivationsP2PKH");
|
|
final preChangeDerivationsStringP2PKH =
|
|
await secureStore.read(key: "${testWalletId}_changeDerivationsP2PKH");
|
|
final preReceiveDerivationsStringP2SH =
|
|
await secureStore.read(key: "${testWalletId}_receiveDerivationsP2SH");
|
|
final preChangeDerivationsStringP2SH =
|
|
await secureStore.read(key: "${testWalletId}_changeDerivationsP2SH");
|
|
final preReceiveDerivationsStringP2WPKH = await secureStore.read(
|
|
key: "${testWalletId}_receiveDerivationsP2WPKH");
|
|
final preChangeDerivationsStringP2WPKH = await secureStore.read(
|
|
key: "${testWalletId}_changeDerivationsP2WPKH");
|
|
|
|
// destroy the data that the rescan will fix
|
|
await wallet.put(
|
|
'receivingAddressesP2PKH', ["some address", "some other address"]);
|
|
await wallet.put(
|
|
'receivingAddressesP2SH', ["some address", "some other address"]);
|
|
await wallet.put(
|
|
'receivingAddressesP2WPKH', ["some address", "some other address"]);
|
|
await wallet
|
|
.put('changeAddressesP2PKH', ["some address", "some other address"]);
|
|
await wallet
|
|
.put('changeAddressesP2SH', ["some address", "some other address"]);
|
|
await wallet
|
|
.put('changeAddressesP2WPKH', ["some address", "some other address"]);
|
|
await wallet.put('receivingIndexP2PKH', 123);
|
|
await wallet.put('receivingIndexP2SH', 123);
|
|
await wallet.put('receivingIndexP2WPKH', 123);
|
|
await wallet.put('changeIndexP2PKH', 123);
|
|
await wallet.put('changeIndexP2SH', 123);
|
|
await wallet.put('changeIndexP2WPKH', 123);
|
|
await secureStore.write(
|
|
key: "${testWalletId}_receiveDerivationsP2PKH", value: "{}");
|
|
await secureStore.write(
|
|
key: "${testWalletId}_changeDerivationsP2PKH", value: "{}");
|
|
await secureStore.write(
|
|
key: "${testWalletId}_receiveDerivationsP2SH", value: "{}");
|
|
await secureStore.write(
|
|
key: "${testWalletId}_changeDerivationsP2SH", value: "{}");
|
|
await secureStore.write(
|
|
key: "${testWalletId}_receiveDerivationsP2WPKH", value: "{}");
|
|
await secureStore.write(
|
|
key: "${testWalletId}_changeDerivationsP2WPKH", value: "{}");
|
|
|
|
bool hasThrown = false;
|
|
try {
|
|
await nmc?.fullRescan(2, 1000);
|
|
} catch (_) {
|
|
hasThrown = true;
|
|
}
|
|
expect(hasThrown, false);
|
|
|
|
// fetch wallet data again
|
|
final receivingAddressesP2PKH =
|
|
await wallet.get('receivingAddressesP2PKH');
|
|
final receivingAddressesP2SH = await wallet.get('receivingAddressesP2SH');
|
|
final receivingAddressesP2WPKH =
|
|
await wallet.get('receivingAddressesP2WPKH');
|
|
final changeAddressesP2PKH = await wallet.get('changeAddressesP2PKH');
|
|
final changeAddressesP2SH = await wallet.get('changeAddressesP2SH');
|
|
final changeAddressesP2WPKH = await wallet.get('changeAddressesP2WPKH');
|
|
final receivingIndexP2PKH = await wallet.get('receivingIndexP2PKH');
|
|
final receivingIndexP2SH = await wallet.get('receivingIndexP2SH');
|
|
final receivingIndexP2WPKH = await wallet.get('receivingIndexP2WPKH');
|
|
final changeIndexP2PKH = await wallet.get('changeIndexP2PKH');
|
|
final changeIndexP2SH = await wallet.get('changeIndexP2SH');
|
|
final changeIndexP2WPKH = await wallet.get('changeIndexP2WPKH');
|
|
final utxoData = await wallet.get('latest_utxo_model');
|
|
final receiveDerivationsStringP2PKH = await secureStore.read(
|
|
key: "${testWalletId}_receiveDerivationsP2PKH");
|
|
final changeDerivationsStringP2PKH =
|
|
await secureStore.read(key: "${testWalletId}_changeDerivationsP2PKH");
|
|
final receiveDerivationsStringP2SH =
|
|
await secureStore.read(key: "${testWalletId}_receiveDerivationsP2SH");
|
|
final changeDerivationsStringP2SH =
|
|
await secureStore.read(key: "${testWalletId}_changeDerivationsP2SH");
|
|
final receiveDerivationsStringP2WPKH = await secureStore.read(
|
|
key: "${testWalletId}_receiveDerivationsP2WPKH");
|
|
final changeDerivationsStringP2WPKH = await secureStore.read(
|
|
key: "${testWalletId}_changeDerivationsP2WPKH");
|
|
|
|
expect(preReceivingAddressesP2PKH, receivingAddressesP2PKH);
|
|
expect(preReceivingAddressesP2SH, receivingAddressesP2SH);
|
|
expect(preReceivingAddressesP2WPKH, receivingAddressesP2WPKH);
|
|
expect(preChangeAddressesP2PKH, changeAddressesP2PKH);
|
|
expect(preChangeAddressesP2SH, changeAddressesP2SH);
|
|
expect(preChangeAddressesP2WPKH, changeAddressesP2WPKH);
|
|
expect(preReceivingIndexP2PKH, receivingIndexP2PKH);
|
|
expect(preReceivingIndexP2SH, receivingIndexP2SH);
|
|
expect(preReceivingIndexP2WPKH, receivingIndexP2WPKH);
|
|
expect(preChangeIndexP2PKH, changeIndexP2PKH);
|
|
expect(preChangeIndexP2SH, changeIndexP2SH);
|
|
expect(preChangeIndexP2WPKH, changeIndexP2WPKH);
|
|
expect(preUtxoData, utxoData);
|
|
expect(preReceiveDerivationsStringP2PKH, receiveDerivationsStringP2PKH);
|
|
expect(preChangeDerivationsStringP2PKH, changeDerivationsStringP2PKH);
|
|
expect(preReceiveDerivationsStringP2SH, receiveDerivationsStringP2SH);
|
|
expect(preChangeDerivationsStringP2SH, changeDerivationsStringP2SH);
|
|
expect(preReceiveDerivationsStringP2WPKH, receiveDerivationsStringP2WPKH);
|
|
expect(preChangeDerivationsStringP2WPKH, changeDerivationsStringP2WPKH);
|
|
|
|
verify(client?.getServerFeatures()).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs0)).called(2);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs1)).called(2);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs2)).called(2);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs3)).called(2);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs4)).called(2);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs5)).called(2);
|
|
verify(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"dd63fc12f5e6c1ada2cf3c941d1648e6d561ce4024747bb2117d72112d83287c"
|
|
]
|
|
})).called(2);
|
|
verify(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"86906979fc9107d06d560275d7de8305b69d7189c3206ac9070ad76e6abff874"
|
|
]
|
|
})).called(2);
|
|
|
|
verify(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"c068e7fa4aa0b8a63114f6d11c047ca4be6a8fa333eb0dac48506e8f150af73b"
|
|
]
|
|
})).called(2);
|
|
|
|
verify(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"cd3dd4abe4f9efc7149ba334d2d6790020331805b0bd5c7ed89a3ac6a22f10b9"
|
|
]
|
|
})).called(2);
|
|
|
|
verify(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"587943864cefed4f1643a5ee2ce2b3c13a0c6ad7c435373f0ac328e144a15c1e"
|
|
]
|
|
})).called(2);
|
|
|
|
verify(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"42d6e40636f4740f9c7f95ef0bbc2a4c17f54da2bc98a32a622e2bf73eb675c3"
|
|
]
|
|
})).called(2);
|
|
verify(cachedClient?.clearSharedTransactionCache(coin: Coin.namecoin))
|
|
.called(1);
|
|
|
|
// for (final arg in dynamicArgValues) {
|
|
// final map = Map<String, List<dynamic>>.from(arg as Map);
|
|
// Map<String, int> argCount = {};
|
|
//
|
|
// // verify(client?.getBatchHistory(args: map)).called(1);
|
|
// // expect(activeScriptHashes.contains(map.values.first.first as String),
|
|
// // true);
|
|
// }
|
|
|
|
// Map<String, int> argCount = {};
|
|
//
|
|
// for (final arg in dynamicArgValues) {
|
|
// final map = Map<String, List<dynamic>>.from(arg as Map);
|
|
//
|
|
// final str = jsonEncode(map);
|
|
//
|
|
// if (argCount[str] == null) {
|
|
// argCount[str] = 1;
|
|
// } else {
|
|
// argCount[str] = argCount[str]! + 1;
|
|
// }
|
|
// }
|
|
//
|
|
// argCount.forEach((key, value) => print("arg: $key\ncount: $value"));
|
|
|
|
expect(secureStore.writes, 25);
|
|
expect(secureStore.reads, 32);
|
|
expect(secureStore.deletes, 6);
|
|
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("fullRescan fails", () async {
|
|
when(client?.getServerFeatures()).thenAnswer((_) async => {
|
|
"hosts": <dynamic, dynamic>{},
|
|
"pruning": null,
|
|
"server_version": "Unit tests",
|
|
"protocol_min": "1.4",
|
|
"protocol_max": "1.4.2",
|
|
"genesis_hash": GENESIS_HASH_MAINNET,
|
|
"hash_function": "sha256",
|
|
"services": <dynamic>[]
|
|
});
|
|
|
|
when(client?.getBatchHistory(args: historyBatchArgs0))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs1))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs2))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs3))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs4))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs5))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
|
|
when(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"dd63fc12f5e6c1ada2cf3c941d1648e6d561ce4024747bb2117d72112d83287c"
|
|
]
|
|
})).thenAnswer((realInvocation) async => {"0": []});
|
|
|
|
when(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"cd3dd4abe4f9efc7149ba334d2d6790020331805b0bd5c7ed89a3ac6a22f10b9"
|
|
]
|
|
})).thenAnswer((realInvocation) async => {"0": []});
|
|
|
|
when(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"42d6e40636f4740f9c7f95ef0bbc2a4c17f54da2bc98a32a622e2bf73eb675c3"
|
|
]
|
|
})).thenAnswer((realInvocation) async => {"0": []});
|
|
|
|
when(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"587943864cefed4f1643a5ee2ce2b3c13a0c6ad7c435373f0ac328e144a15c1e"
|
|
]
|
|
})).thenAnswer((realInvocation) async => {"0": []});
|
|
|
|
when(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"86906979fc9107d06d560275d7de8305b69d7189c3206ac9070ad76e6abff874"
|
|
]
|
|
})).thenAnswer((realInvocation) async => {"0": []});
|
|
|
|
when(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"c068e7fa4aa0b8a63114f6d11c047ca4be6a8fa333eb0dac48506e8f150af73b"
|
|
]
|
|
})).thenAnswer((realInvocation) async => {"0": []});
|
|
|
|
when(cachedClient?.clearSharedTransactionCache(coin: Coin.namecoin))
|
|
.thenAnswer((realInvocation) async {});
|
|
|
|
final wallet = await Hive.openBox<dynamic>(testWalletId);
|
|
|
|
// restore so we have something to rescan
|
|
await nmc?.recoverFromMnemonic(
|
|
mnemonic: TEST_MNEMONIC,
|
|
maxUnusedAddressGap: 2,
|
|
maxNumberOfIndexesToCheck: 1000,
|
|
height: 4000);
|
|
|
|
// fetch wallet data
|
|
final preReceivingAddressesP2PKH =
|
|
await wallet.get('receivingAddressesP2PKH');
|
|
final preReceivingAddressesP2SH =
|
|
await wallet.get('receivingAddressesP2SH');
|
|
final preReceivingAddressesP2WPKH =
|
|
await wallet.get('receivingAddressesP2WPKH');
|
|
final preChangeAddressesP2PKH = await wallet.get('changeAddressesP2PKH');
|
|
final preChangeAddressesP2SH = await wallet.get('changeAddressesP2SH');
|
|
final preChangeAddressesP2WPKH =
|
|
await wallet.get('changeAddressesP2WPKH');
|
|
final preReceivingIndexP2PKH = await wallet.get('receivingIndexP2PKH');
|
|
final preReceivingIndexP2SH = await wallet.get('receivingIndexP2SH');
|
|
final preReceivingIndexP2WPKH = await wallet.get('receivingIndexP2WPKH');
|
|
final preChangeIndexP2PKH = await wallet.get('changeIndexP2PKH');
|
|
final preChangeIndexP2SH = await wallet.get('changeIndexP2SH');
|
|
final preChangeIndexP2WPKH = await wallet.get('changeIndexP2WPKH');
|
|
final preUtxoData = await wallet.get('latest_utxo_model');
|
|
final preReceiveDerivationsStringP2PKH = await secureStore.read(
|
|
key: "${testWalletId}_receiveDerivationsP2PKH");
|
|
final preChangeDerivationsStringP2PKH =
|
|
await secureStore.read(key: "${testWalletId}_changeDerivationsP2PKH");
|
|
final preReceiveDerivationsStringP2SH =
|
|
await secureStore.read(key: "${testWalletId}_receiveDerivationsP2SH");
|
|
final preChangeDerivationsStringP2SH =
|
|
await secureStore.read(key: "${testWalletId}_changeDerivationsP2SH");
|
|
final preReceiveDerivationsStringP2WPKH = await secureStore.read(
|
|
key: "${testWalletId}_receiveDerivationsP2WPKH");
|
|
final preChangeDerivationsStringP2WPKH = await secureStore.read(
|
|
key: "${testWalletId}_changeDerivationsP2WPKH");
|
|
|
|
when(client?.getBatchHistory(args: historyBatchArgs0))
|
|
.thenThrow(Exception("fake exception"));
|
|
|
|
bool hasThrown = false;
|
|
try {
|
|
await nmc?.fullRescan(2, 1000);
|
|
} catch (_) {
|
|
hasThrown = true;
|
|
}
|
|
expect(hasThrown, true);
|
|
|
|
// fetch wallet data again
|
|
final receivingAddressesP2PKH =
|
|
await wallet.get('receivingAddressesP2PKH');
|
|
final receivingAddressesP2SH = await wallet.get('receivingAddressesP2SH');
|
|
final receivingAddressesP2WPKH =
|
|
await wallet.get('receivingAddressesP2WPKH');
|
|
final changeAddressesP2PKH = await wallet.get('changeAddressesP2PKH');
|
|
final changeAddressesP2SH = await wallet.get('changeAddressesP2SH');
|
|
final changeAddressesP2WPKH = await wallet.get('changeAddressesP2WPKH');
|
|
final receivingIndexP2PKH = await wallet.get('receivingIndexP2PKH');
|
|
final receivingIndexP2SH = await wallet.get('receivingIndexP2SH');
|
|
final receivingIndexP2WPKH = await wallet.get('receivingIndexP2WPKH');
|
|
final changeIndexP2PKH = await wallet.get('changeIndexP2PKH');
|
|
final changeIndexP2SH = await wallet.get('changeIndexP2SH');
|
|
final changeIndexP2WPKH = await wallet.get('changeIndexP2WPKH');
|
|
final utxoData = await wallet.get('latest_utxo_model');
|
|
final receiveDerivationsStringP2PKH = await secureStore.read(
|
|
key: "${testWalletId}_receiveDerivationsP2PKH");
|
|
final changeDerivationsStringP2PKH =
|
|
await secureStore.read(key: "${testWalletId}_changeDerivationsP2PKH");
|
|
final receiveDerivationsStringP2SH =
|
|
await secureStore.read(key: "${testWalletId}_receiveDerivationsP2SH");
|
|
final changeDerivationsStringP2SH =
|
|
await secureStore.read(key: "${testWalletId}_changeDerivationsP2SH");
|
|
final receiveDerivationsStringP2WPKH = await secureStore.read(
|
|
key: "${testWalletId}_receiveDerivationsP2WPKH");
|
|
final changeDerivationsStringP2WPKH = await secureStore.read(
|
|
key: "${testWalletId}_changeDerivationsP2WPKH");
|
|
|
|
expect(preReceivingAddressesP2PKH, receivingAddressesP2PKH);
|
|
expect(preReceivingAddressesP2SH, receivingAddressesP2SH);
|
|
expect(preReceivingAddressesP2WPKH, receivingAddressesP2WPKH);
|
|
expect(preChangeAddressesP2PKH, changeAddressesP2PKH);
|
|
expect(preChangeAddressesP2SH, changeAddressesP2SH);
|
|
expect(preChangeAddressesP2WPKH, changeAddressesP2WPKH);
|
|
expect(preReceivingIndexP2PKH, receivingIndexP2PKH);
|
|
expect(preReceivingIndexP2SH, receivingIndexP2SH);
|
|
expect(preReceivingIndexP2WPKH, receivingIndexP2WPKH);
|
|
expect(preChangeIndexP2PKH, changeIndexP2PKH);
|
|
expect(preChangeIndexP2SH, changeIndexP2SH);
|
|
expect(preChangeIndexP2WPKH, changeIndexP2WPKH);
|
|
expect(preUtxoData, utxoData);
|
|
expect(preReceiveDerivationsStringP2PKH, receiveDerivationsStringP2PKH);
|
|
expect(preChangeDerivationsStringP2PKH, changeDerivationsStringP2PKH);
|
|
expect(preReceiveDerivationsStringP2SH, receiveDerivationsStringP2SH);
|
|
expect(preChangeDerivationsStringP2SH, changeDerivationsStringP2SH);
|
|
expect(preReceiveDerivationsStringP2WPKH, receiveDerivationsStringP2WPKH);
|
|
expect(preChangeDerivationsStringP2WPKH, changeDerivationsStringP2WPKH);
|
|
|
|
verify(client?.getServerFeatures()).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs0)).called(2);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs1)).called(2);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs2)).called(2);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs3)).called(2);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs4)).called(2);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs5)).called(2);
|
|
|
|
verify(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"dd63fc12f5e6c1ada2cf3c941d1648e6d561ce4024747bb2117d72112d83287c"
|
|
]
|
|
})).called(2);
|
|
verify(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"cd3dd4abe4f9efc7149ba334d2d6790020331805b0bd5c7ed89a3ac6a22f10b9"
|
|
]
|
|
})).called(1);
|
|
verify(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"42d6e40636f4740f9c7f95ef0bbc2a4c17f54da2bc98a32a622e2bf73eb675c3"
|
|
]
|
|
})).called(2);
|
|
verify(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"587943864cefed4f1643a5ee2ce2b3c13a0c6ad7c435373f0ac328e144a15c1e"
|
|
]
|
|
})).called(2);
|
|
verify(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"86906979fc9107d06d560275d7de8305b69d7189c3206ac9070ad76e6abff874"
|
|
]
|
|
})).called(2);
|
|
verify(client?.getBatchHistory(args: {
|
|
"0": [
|
|
"c068e7fa4aa0b8a63114f6d11c047ca4be6a8fa333eb0dac48506e8f150af73b"
|
|
]
|
|
})).called(2);
|
|
verify(cachedClient?.clearSharedTransactionCache(coin: Coin.namecoin))
|
|
.called(1);
|
|
|
|
expect(secureStore.writes, 19);
|
|
expect(secureStore.reads, 32);
|
|
expect(secureStore.deletes, 12);
|
|
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("prepareSend fails", () async {
|
|
when(client?.getServerFeatures()).thenAnswer((_) async => {
|
|
"hosts": <dynamic, dynamic>{},
|
|
"pruning": null,
|
|
"server_version": "Unit tests",
|
|
"protocol_min": "1.4",
|
|
"protocol_max": "1.4.2",
|
|
"genesis_hash": GENESIS_HASH_MAINNET,
|
|
"hash_function": "sha256",
|
|
"services": <dynamic>[]
|
|
});
|
|
when(client?.getBatchHistory(args: historyBatchArgs0))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs1))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs2))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs3))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs4))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs5))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
|
|
List<dynamic> dynamicArgValues = [];
|
|
|
|
when(client?.getBatchHistory(args: anyNamed("args")))
|
|
.thenAnswer((realInvocation) async {
|
|
if (realInvocation.namedArguments.values.first.length == 1) {
|
|
dynamicArgValues.add(realInvocation.namedArguments.values.first);
|
|
}
|
|
|
|
return historyBatchResponse;
|
|
});
|
|
|
|
await Hive.openBox<dynamic>(testWalletId);
|
|
|
|
when(cachedClient?.getTransaction(
|
|
txHash:
|
|
"dffa9543852197f9fb90f8adafaab8a0b9b4925e9ada8c6bdcaf00bf2e9f60d7",
|
|
coin: Coin.namecoin))
|
|
.thenAnswer((_) async => tx2Raw);
|
|
when(cachedClient?.getTransaction(
|
|
txHash:
|
|
"71b56532e9e7321bd8c30d0f8b14530743049d2f3edd5623065c46eee1dda04d",
|
|
coin: Coin.namecoin))
|
|
.thenAnswer((_) async => tx3Raw);
|
|
when(cachedClient?.getTransaction(
|
|
txHash:
|
|
"c7e700f7e23a85bbdd9de86d502322a933607ee7ea7e16adaf02e477cdd849b9",
|
|
coin: Coin.namecoin,
|
|
)).thenAnswer((_) async => tx4Raw);
|
|
|
|
// recover to fill data
|
|
await nmc?.recoverFromMnemonic(
|
|
mnemonic: TEST_MNEMONIC,
|
|
maxUnusedAddressGap: 2,
|
|
maxNumberOfIndexesToCheck: 1000,
|
|
height: 4000);
|
|
|
|
// modify addresses to properly mock data to build a tx
|
|
final rcv44 = await secureStore.read(
|
|
key: "${testWalletId}_receiveDerivationsP2PKH");
|
|
await secureStore.write(
|
|
key: "${testWalletId}_receiveDerivationsP2PKH",
|
|
value: rcv44?.replaceFirst("1RMSPixoLPuaXuhR2v4HsUMcRjLncKDaw",
|
|
"16FuTPaeRSPVxxCnwQmdyx2PQWxX6HWzhQ"));
|
|
final rcv49 =
|
|
await secureStore.read(key: "${testWalletId}_receiveDerivationsP2SH");
|
|
await secureStore.write(
|
|
key: "${testWalletId}_receiveDerivationsP2SH",
|
|
value: rcv49?.replaceFirst("3AV74rKfibWmvX34F99yEvUcG4LLQ9jZZk",
|
|
"36NvZTcMsMowbt78wPzJaHHWaNiyR73Y4g"));
|
|
final rcv84 = await secureStore.read(
|
|
key: "${testWalletId}_receiveDerivationsP2WPKH");
|
|
await secureStore.write(
|
|
key: "${testWalletId}_receiveDerivationsP2WPKH",
|
|
value: rcv84?.replaceFirst(
|
|
"bc1qggtj4ka8jsaj44hhd5mpamx7mp34m2d3w7k0m0",
|
|
"bc1q42lja79elem0anu8q8s3h2n687re9jax556pcc"));
|
|
|
|
// nmc?.outputsList = utxoList;
|
|
|
|
bool didThrow = false;
|
|
try {
|
|
await nmc?.prepareSend(
|
|
address: "nc1q6k4x8ye6865z3rc8zkt8gyu52na7njqt6hsk4v",
|
|
satoshiAmount: 15000);
|
|
} catch (_) {
|
|
didThrow = true;
|
|
}
|
|
|
|
expect(didThrow, true);
|
|
|
|
verify(client?.getServerFeatures()).called(1);
|
|
|
|
/// verify transaction no matching calls
|
|
|
|
// verify(cachedClient?.getTransaction(
|
|
// txHash:
|
|
// "2087ce09bc316877c9f10971526a2bffa3078d52ea31752639305cdcd8230703",
|
|
// coin: Coin.namecoin,
|
|
// callOutSideMainIsolate: false))
|
|
// .called(1);
|
|
// verify(cachedClient?.getTransaction(
|
|
// txHash:
|
|
// "ed32c967a0e86d51669ac21c2bb9bc9c50f0f55fbacdd8db21d0a986fba93bd7",
|
|
// coin: Coin.namecoin,
|
|
// callOutSideMainIsolate: false))
|
|
// .called(1);
|
|
// verify(cachedClient?.getTransaction(
|
|
// txHash:
|
|
// "3f0032f89ac44b281b50314cff3874c969c922839dddab77ced54e86a21c3fd4",
|
|
// coin: Coin.namecoin,
|
|
// callOutSideMainIsolate: false))
|
|
// .called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs0)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs1)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs2)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs3)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs4)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs5)).called(1);
|
|
|
|
for (final arg in dynamicArgValues) {
|
|
final map = Map<String, List<dynamic>>.from(arg as Map);
|
|
|
|
verify(client?.getBatchHistory(args: map)).called(1);
|
|
expect(activeScriptHashes.contains(map.values.first.first as String),
|
|
true);
|
|
}
|
|
|
|
expect(secureStore.interactions, 20);
|
|
expect(secureStore.writes, 10);
|
|
expect(secureStore.reads, 10);
|
|
expect(secureStore.deletes, 0);
|
|
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("confirmSend no hex", () async {
|
|
bool didThrow = false;
|
|
try {
|
|
await nmc?.confirmSend(txData: {"some": "strange map"});
|
|
} catch (_) {
|
|
didThrow = true;
|
|
}
|
|
|
|
expect(didThrow, true);
|
|
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("confirmSend hex is not string", () async {
|
|
bool didThrow = false;
|
|
try {
|
|
await nmc?.confirmSend(txData: {"hex": true});
|
|
} catch (_) {
|
|
didThrow = true;
|
|
}
|
|
|
|
expect(didThrow, true);
|
|
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("confirmSend hex is string but missing other data", () async {
|
|
bool didThrow = false;
|
|
try {
|
|
await nmc?.confirmSend(txData: {"hex": "a string"});
|
|
} catch (_) {
|
|
didThrow = true;
|
|
}
|
|
|
|
expect(didThrow, true);
|
|
|
|
verify(client?.broadcastTransaction(
|
|
rawTx: "a string", requestID: anyNamed("requestID")))
|
|
.called(1);
|
|
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("confirmSend fails due to vSize being greater than fee", () async {
|
|
bool didThrow = false;
|
|
try {
|
|
await nmc
|
|
?.confirmSend(txData: {"hex": "a string", "fee": 1, "vSize": 10});
|
|
} catch (_) {
|
|
didThrow = true;
|
|
}
|
|
|
|
expect(didThrow, true);
|
|
|
|
verify(client?.broadcastTransaction(
|
|
rawTx: "a string", requestID: anyNamed("requestID")))
|
|
.called(1);
|
|
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
test("confirmSend fails when broadcast transactions throws", () async {
|
|
when(client?.broadcastTransaction(
|
|
rawTx: "a string", requestID: anyNamed("requestID")))
|
|
.thenThrow(Exception("some exception"));
|
|
|
|
bool didThrow = false;
|
|
try {
|
|
await nmc
|
|
?.confirmSend(txData: {"hex": "a string", "fee": 10, "vSize": 10});
|
|
} catch (_) {
|
|
didThrow = true;
|
|
}
|
|
|
|
expect(didThrow, true);
|
|
|
|
verify(client?.broadcastTransaction(
|
|
rawTx: "a string", requestID: anyNamed("requestID")))
|
|
.called(1);
|
|
|
|
expect(secureStore.interactions, 0);
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
verifyNoMoreInteractions(tracker);
|
|
});
|
|
//
|
|
// // this test will create a non mocked electrumx client that will try to connect
|
|
// // to the provided ipAddress below. This will throw a bunch of errors
|
|
// // which what we want here as actually calling electrumx calls here is unwanted.
|
|
// // test("listen to NodesChangedEvent", () async {
|
|
// // nmc = NamecoinWallet(
|
|
// // walletId: testWalletId,
|
|
// // walletName: testWalletName,
|
|
// // networkType: BasicNetworkType.test,
|
|
// // client: client,
|
|
// // cachedClient: cachedClient,
|
|
// //
|
|
// // secureStore: secureStore,
|
|
// mockableOverride: mockMainDB,
|
|
// // );
|
|
// //
|
|
// // // set node
|
|
// // final wallet = await Hive.openBox<dynamic>(testWalletId);
|
|
// // await wallet.put("nodes", {
|
|
// // "default": {
|
|
// // "id": "some nodeID",
|
|
// // "ipAddress": "some address",
|
|
// // "port": "9000",
|
|
// // "useSSL": true,
|
|
// // }
|
|
// // });
|
|
// // await wallet.put("activeNodeID_Bitcoin", "default");
|
|
// //
|
|
// // final a = nmc.cachedElectrumXClient;
|
|
// //
|
|
// // // return when refresh is called on node changed trigger
|
|
// // nmc.longMutex = true;
|
|
// //
|
|
// // GlobalEventBus.instance
|
|
// // .fire(NodesChangedEvent(NodesChangedEventType.updatedCurrentNode));
|
|
// //
|
|
// // // make sure event has processed before continuing
|
|
// // await Future.delayed(Duration(seconds: 5));
|
|
// //
|
|
// // final b = nmc.cachedElectrumXClient;
|
|
// //
|
|
// // expect(identical(a, b), false);
|
|
// //
|
|
// // await nmc.exit();
|
|
// //
|
|
// // expect(secureStore.interactions, 0);
|
|
// // verifyNoMoreInteractions(client);
|
|
// // verifyNoMoreInteractions(cachedClient);
|
|
// //
|
|
// // });
|
|
|
|
test("refresh wallet mutex locked", () async {
|
|
when(client?.getServerFeatures()).thenAnswer((_) async => {
|
|
"hosts": <dynamic, dynamic>{},
|
|
"pruning": null,
|
|
"server_version": "Unit tests",
|
|
"protocol_min": "1.4",
|
|
"protocol_max": "1.4.2",
|
|
"genesis_hash": GENESIS_HASH_MAINNET,
|
|
"hash_function": "sha256",
|
|
"services": <dynamic>[]
|
|
});
|
|
when(client?.getBatchHistory(args: historyBatchArgs0))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs1))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs2))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs3))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs4))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
when(client?.getBatchHistory(args: historyBatchArgs5))
|
|
.thenAnswer((_) async => historyBatchResponse);
|
|
|
|
List<dynamic> dynamicArgValues = [];
|
|
|
|
when(client?.getBatchHistory(args: anyNamed("args")))
|
|
.thenAnswer((realInvocation) async {
|
|
if (realInvocation.namedArguments.values.first.length == 1) {
|
|
dynamicArgValues.add(realInvocation.namedArguments.values.first);
|
|
}
|
|
|
|
return historyBatchResponse;
|
|
});
|
|
|
|
await Hive.openBox<dynamic>(testWalletId);
|
|
|
|
// recover to fill data
|
|
await nmc?.recoverFromMnemonic(
|
|
mnemonic: TEST_MNEMONIC,
|
|
maxUnusedAddressGap: 2,
|
|
maxNumberOfIndexesToCheck: 1000,
|
|
height: 4000);
|
|
|
|
nmc?.refreshMutex = true;
|
|
|
|
await nmc?.refresh();
|
|
|
|
verify(client?.getServerFeatures()).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs0)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs1)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs2)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs3)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs4)).called(1);
|
|
verify(client?.getBatchHistory(args: historyBatchArgs5)).called(1);
|
|
|
|
for (final arg in dynamicArgValues) {
|
|
final map = Map<String, List<dynamic>>.from(arg as Map);
|
|
|
|
verify(client?.getBatchHistory(args: map)).called(1);
|
|
expect(activeScriptHashes.contains(map.values.first.first as String),
|
|
true);
|
|
}
|
|
|
|
expect(secureStore.interactions, 14);
|
|
expect(secureStore.writes, 7);
|
|
expect(secureStore.reads, 7);
|
|
expect(secureStore.deletes, 0);
|
|
|
|
verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
verifyNoMoreInteractions(tracker);
|
|
});
|
|
|
|
test("refresh wallet normally", () async {
|
|
when(client?.getBlockHeadTip()).thenAnswer((realInvocation) async =>
|
|
{"height": 520481, "hex": "some block hex"});
|
|
when(client?.getServerFeatures()).thenAnswer((_) async => {
|
|
"hosts": <dynamic, dynamic>{},
|
|
"pruning": null,
|
|
"server_version": "Unit tests",
|
|
"protocol_min": "1.4",
|
|
"protocol_max": "1.4.2",
|
|
"genesis_hash": GENESIS_HASH_MAINNET,
|
|
"hash_function": "sha256",
|
|
"services": <dynamic>[]
|
|
});
|
|
when(client?.getHistory(scripthash: anyNamed("scripthash")))
|
|
.thenAnswer((_) async => []);
|
|
when(client?.estimateFee(blocks: anyNamed("blocks")))
|
|
.thenAnswer((_) async => Decimal.one);
|
|
|
|
final List<dynamic> dynamicArgValues = [];
|
|
|
|
when(client?.getBatchHistory(args: anyNamed("args")))
|
|
.thenAnswer((realInvocation) async {
|
|
dynamicArgValues.add(realInvocation.namedArguments.values.first);
|
|
return historyBatchResponse;
|
|
});
|
|
|
|
await Hive.openBox<dynamic>(testWalletId);
|
|
|
|
// recover to fill data
|
|
await nmc?.recoverFromMnemonic(
|
|
mnemonic: TEST_MNEMONIC,
|
|
maxUnusedAddressGap: 2,
|
|
maxNumberOfIndexesToCheck: 1000,
|
|
height: 4000);
|
|
|
|
when(client?.getBatchHistory(args: anyNamed("args")))
|
|
.thenAnswer((_) async => {});
|
|
when(client?.getBatchUTXOs(args: anyNamed("args")))
|
|
.thenAnswer((_) async => emptyHistoryBatchResponse);
|
|
|
|
await nmc?.refresh();
|
|
|
|
verify(client?.getServerFeatures()).called(1);
|
|
verify(client?.getHistory(scripthash: anyNamed("scripthash"))).called(4);
|
|
verify(client?.estimateFee(blocks: anyNamed("blocks"))).called(3);
|
|
verify(client?.getBlockHeadTip()).called(1);
|
|
|
|
for (final arg in dynamicArgValues) {
|
|
final map = Map<String, List<dynamic>>.from(arg as Map);
|
|
|
|
verify(client?.getBatchHistory(args: map)).called(1);
|
|
}
|
|
|
|
expect(secureStore.interactions, 14);
|
|
expect(secureStore.writes, 7);
|
|
expect(secureStore.reads, 7);
|
|
expect(secureStore.deletes, 0);
|
|
|
|
// verifyNoMoreInteractions(client);
|
|
verifyNoMoreInteractions(cachedClient);
|
|
});
|
|
|
|
tearDown(() async {
|
|
await tearDownTestHive();
|
|
});
|
|
});
|
|
}
|