Merge remote-tracking branch 'origin/main'

cw_core/lib/node.dart

@@ -6,7 +6,7 @@ import 'dart:convert';
 import 'package:http/http.dart' as http;
 import 'package:hive/hive.dart';
 import 'package:cw_core/wallet_type.dart';
-//import 'package:cake_wallet/entities/digest_request.dart';
+import 'package:http/io_client.dart' as ioc;
 
 part 'node.g.dart';
 
@@ -95,30 +95,41 @@ class Node extends HiveObject with Keyable {
   }
 
   Future<bool> requestMoneroNode() async {
-    return false;
-    //try {
-    //  Map<String, dynamic> resBody;
-
-    //  if (login != null && password != null) {
-    //    final digestRequest = DigestRequest();
-    //    final response = await digestRequest.request(
-    //        uri: uri.toString(), login: login, password: password);
-    //    resBody = response.data as Map<String, dynamic>;
-    //  } else {
-    //    final rpcUri = Uri.http(uri.authority, '/json_rpc');
-    //    final headers = {'Content-type': 'application/json'};
-    //    final body =
-    //        json.encode({'jsonrpc': '2.0', 'id': '0', 'method': 'get_info'});
-    //    final response =
-    //        await http.post(rpcUri.toString(), headers: headers, body: body);
-    //    resBody = json.decode(response.body) as Map<String, dynamic>;
-    //  }
-
-    //  return !(resBody['result']['offline'] as bool);
-    //} catch (_) {
-    //  return false;
-    //}
-  }
+  
+    final path = '/json_rpc';
+    final rpcUri = isSSL ? Uri.https(uri.authority, path) : Uri.http(uri.authority, path);
+    final realm = 'monero-rpc';
+    final body = {
+        'jsonrpc': '2.0', 
+        'id': '0', 
+        'method': 'get_info'
+    };
+
+    try {
+      final authenticatingClient = HttpClient();
+    
+      authenticatingClient.addCredentials(
+          rpcUri,
+          realm, 
+          HttpClientDigestCredentials(login ?? '', password ?? ''),
+      );
+    
+      final http.Client client = ioc.IOClient(authenticatingClient);
+    
+      final response = await client.post(
+          rpcUri,
+          headers: {'Content-Type': 'application/json'},
+          body: json.encode(body),
+      );
+    
+      client.close();
+
+      final resBody = json.decode(response.body) as Map<String, dynamic>;
+      return !(resBody['result']['offline'] as bool);
+    } catch (_) {
+      return false;
+    }
+}
 
   Future<bool> requestElectrumServer() async {
     try {

lib/entities/digest_request.dart

@@ -1,96 +0,0 @@
-import 'dart:convert';
-import 'package:dio/dio.dart' as __dio;
-import 'package:crypto/crypto.dart' as crypto;
-import 'dart:math' as math;
-
-class DigestRequest {
-  final md5 = crypto.md5;
-
-  String generateCnonce() {
-    final rnd = math.Random.secure();
-    final values = List<int>.generate(32, (i) => rnd.nextInt(256));
-    return base64Url.encode(values).substring(0, 8);
-  }
-
-  String generateHA1({String realm, String username, String password}) {
-    final ha1CredentialsData =
-        Utf8Encoder().convert('$username:$realm:$password');
-    final ha1 = md5.convert(ha1CredentialsData).toString();
-
-    return ha1;
-  }
-
-  String generateHA2({String method, String uri}) {
-    final ha2Data = Utf8Encoder().convert('$method:$uri');
-    final ha2 = md5.convert(ha2Data).toString();
-
-    return ha2;
-  }
-
-  String generateResponseString(
-      {String ha1,
-      String ha2,
-      String nonce,
-      String nonceCount,
-      String cnonce,
-      String qop}) {
-    final responseData =
-        Utf8Encoder().convert('$ha1:$nonce:$nonceCount:$cnonce:$qop:$ha2');
-    final response = md5.convert(responseData).toString();
-
-    return response;
-  }
-
-  Map<String, String> parsetAuthorizationHeader({String source}) {
-    final authHeaderParts =
-        source.substring(7).split(',').map((item) => item.trim());
-    final authenticate = Map<String, String>();
-
-    for (final part in authHeaderParts) {
-      final kv = part.split('=');
-      authenticate[kv[0]] =
-          kv.getRange(1, kv.length).join('=').replaceAll('"', '');
-    }
-
-    return authenticate;
-  }
-
-  Future<__dio.Response> request(
-      {String uri, String login, String password}) async {
-    const path = '/json_rpc';
-    const method = 'POST';
-    final url = Uri.http(uri, path);
-    final dio = __dio.Dio();
-    final headers = {'Content-type': 'application/json'};
-    final body =
-        json.encode({"jsonrpc": "2.0", "id": "0", "method": "get_info"});
-    final credentialsResponse = await dio.post<Object>(url.toString(),
-        options: __dio.Options(headers: headers, validateStatus: (_) => true));
-    final authenticate = parsetAuthorizationHeader(
-        source: credentialsResponse.headers['www-authenticate'].first);
-    final qop = authenticate['qop'];
-    final algorithm = 'MD5';
-    final realm = 'monero-rpc';
-    final nonce = authenticate['nonce'];
-    final cnonce = generateCnonce();
-    final nonceCount = '00000001';
-    final ha1 = generateHA1(realm: realm, username: login, password: password);
-    final ha2 = generateHA2(method: method, uri: path);
-    final response = generateResponseString(
-        ha1: ha1,
-        ha2: ha2,
-        nonce: nonce,
-        nonceCount: nonceCount,
-        cnonce: cnonce,
-        qop: qop);
-
-    final authorizationHeaders = {
-      'Content-type': 'application/json',
-      'Authorization':
-          'Digest username="$login",realm="$realm",nonce="$nonce",uri="$path",algorithm="$algorithm",qop=$qop,nc=$nonceCount,cnonce="$cnonce",response="$response"'
-    };
-
-    return await dio.post<Object>(url.toString(),
-        options: __dio.Options(headers: authorizationHeaders), data: body);
-  }
-}