1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
import 'dart:async';
import 'dart:ffi';
import 'dart:typed_data';
import 'package:ffi/ffi.dart';
import 'package:ledger_flutter/src/ledger.dart';
import 'package:ledger_flutter/src/ledger/ledger_operation.dart';
import 'package:ledger_flutter/src/models/ledger_device.dart';
import 'package:ledger_flutter/src/utils/buffer.dart';
import 'package:monero/monero.dart' as monero;
Timer? _ledgerExchangeTimer;
String _lastLedgerRequest = '';
void enableLedgerExchange(
monero.wallet ptr, Ledger ledger, LedgerDevice device) {
_ledgerExchangeTimer = Timer.periodic(Duration(milliseconds: 1), (_) async {
final ledgerRequestLength = monero.Wallet_getSendToDeviceLength(ptr);
final ledgerRequest = monero.Wallet_getSendToDevice(ptr)
.cast<Uint8>()
.asTypedList(ledgerRequestLength);
if (ledgerRequestLength > 0 && _lastLedgerRequest != ledgerRequest.join()) {
_lastLedgerRequest = ledgerRequest.join();
final response = await exchange(ledger, device, ledgerRequest);
final Pointer<Uint8> result = malloc<Uint8>(response.length);
for (var i = 0; i < response.length; i++) {
result.asTypedList(response.length)[i] = response[i];
}
monero.Wallet_setDeviceReceivedData(
ptr, result.cast<UnsignedChar>(), response.length);
monero.Wallet_setDeviceSendData(
ptr, malloc<Uint8>(0).cast<UnsignedChar>(), 0);
}
});
}
void disableLedgerExchange() {
_ledgerExchangeTimer?.cancel();
}
Future<Uint8List> exchange(
Ledger ledger, LedgerDevice device, Uint8List data) async {
return ledger.sendOperation<Uint8List>(
device,
ExchangeOperation(
cla: 0x00,
ins: 0x00,
p1: 0x00,
p2: 0x00,
inputData: data,
),
);
}
class ExchangeOperation extends LedgerOperation<Uint8List> {
final int cla;
final int ins;
final int p1;
final int p2;
final Uint8List inputData;
ExchangeOperation({
required this.cla,
required this.ins,
required this.p1,
required this.p2,
required this.inputData,
});
@override
Future<Uint8List> read(ByteDataReader reader) async =>
reader.read(reader.remainingLength);
@override
Future<List<Uint8List>> write(ByteDataWriter writer) async {
writer.write(inputData);
return [writer.toBytes()];
}
}
|
