wownero
/
cyberwow
Archived
4
0
Fork 1
Code Issues 3 Pull Requests Releases 9 Wiki Activity

add transaction pool rpc

Browse Source
pull/2/head
fuwa 5 years ago
parent 94de787125
commit 0b23a15642
1 changed files with 44 additions and 52 deletions
Show Stats Download Patch File Download Diff File

96
cyberwow/lib/controller/rpc.dart
Unescape View File

@ -73,40 +73,6 @@ Future<String> rpcString(String method, {String field}) async {
}
}
Future<http.Response> rpcOther(String method) async {
final url = 'http://127.0.0.1:${config.port}/json_rpc';
var response;
try {
response = await http.post
( url,
);
}
catch (e) {
// print(e);
}
return response;
}
Future<String> rpcOtherString(String method, {String field}) async {
var response = await rpcOther(method);
if (response == null) return '';
if (response.statusCode != 200) {
return '';
} else {
final _body= json.decode(response.body);
final _field = field == null ? _body: _body[field];
final JsonEncoder encoder = new JsonEncoder.withIndent(' ');
return encoder.convert(_field);
}
}
Future<http.Response> syncInfo() async => rpc('sync_info');
Future<String> syncInfoString() async => rpcString('sync_info');
@ -184,29 +150,55 @@ Future<int> incomingConnectionsCount() async {
}
}
Future<String> getConnectionsString() async => rpcString('get_connections', field: 'connections');
// Future<http.Response> getInfo() async {
// // print('rpc get_info');
// return rpc('get_info');
// }
Future<http.Response> rpcOther(String method) async {
final url = 'http://127.0.0.1:${config.port}/json_rpc';
// Future<String> getInfoString() async {
// var response = await getInfo();
var response;
try {
response = await http.post
( url,
);
}
catch (e) {
// print(e);
}
// if (response == null) return '';
return response;
}
// if (response.statusCode != 200) {
// return '';
// } else {
// final _getInfo = json.decode(response.body)['result'];
Future<String> rpcOtherString(String method, {String field}) async {
var response = await rpcOther(method);
// JsonEncoder encoder = new JsonEncoder.withIndent(' ');
// String _prettyInfo = encoder.convert(_getInfo);
// return _prettyInfo;
// }
// }
if (response == null) return '';
if (response.statusCode != 200) {
return '';
} else {
final _body= json.decode(response.body);
final _field = field == null ? _body: _body[field];
Future<String> getConnectionsString() async => rpcString('get_connections', field: 'connections');
Future<String> getTransactionPoolString() async => rpcOtherString('get_transaction_pool');
final JsonEncoder encoder = new JsonEncoder.withIndent(' ');
return encoder.convert(_field);
}
}
// Future<String> getTransactionPoolString() async => rpcOtherString('get_transaction_pool');
Future<http.Response> getTransactionPool() async => rpc('get_transaction_pool');
Future<Map<String, dynamic>> getTransactionPoolSimple() async {
var response = await getTransactionPool();
if (response == null) return {};
// print('Response status: ${response.statusCode}');
if (response.statusCode != 200) {
return {};
} else {
final responseBody = json.decode(response.body);
return responseBody;
}
}