rmb connection creation && send, read requests

Author: AlaaElattar

packages/rmb_client/bin/rmb_client.dart

@@ -1,15 +1,28 @@
+import 'dart:io';
+
 import 'package:rmb_client/rmb_client.dart';
 
 void main() async {
   final client = Client(
-      "wss://relay.dev.grid.tf",
-      "wss://tfchain.dev.grid.tf/ws",
-      "picnic flip cigar rival risk scatter slide aware trust garlic solution token",
-      "session",
+      relayUrl: "wss://relay.dev.grid.tf/",
+      chainUrl: "wss://tfchain.dev.grid.tf/ws",
+      mnemonic:
+          "valid end trumpet hunt produce close hire virus fee rebel gentle claim",
+      session: "testclient",
       retries: 3,
-      keypairType: "ed25519");
+      keypairType: "sr25519");
 
   await client.connect();
+  // final ID = await client.send("zos.statistics.get", "{}", 17, 5, 3);
+
+  final ID =
+      await client.send("twinserver.balance.getMyBalance", "{}", 7845, 5, 3);
+
+  // sleep(Duration(seconds: 20));
+
+  // await client.read(ID!);
+
+  // await client.send("requestCommand", "requestData", 17, 5, 0);
 
   // client.closeConnection();
 }

packages/rmb_client/lib/rmb_client.dart

@@ -2,11 +2,23 @@ library rmb_client;
 
 import 'dart:async';
 import 'dart:convert';
+import 'dart:io';
 import 'dart:typed_data';
+import 'package:fixnum/fixnum.dart';
 import 'package:polkadart_keyring/polkadart_keyring.dart';
+import 'package:rmb_client/src/envelope.dart';
 import 'package:rmb_client/src/sign.dart';
+import 'package:rmb_client/src/utils.dart';
+import 'package:rmb_client/types/generated/types.pbserver.dart';
+import 'package:tfchain_client/generated/dev/types/pallet_collective/raw_origin.dart';
+import 'package:tfchain_client/generated/dev/types/pallet_tfgrid/types/twin.dart';
+import 'package:tfchain_client/generated/dev/types/tfchain_runtime/runtime_event.dart';
 import 'package:tfchain_client/models/twins.dart';
+import 'package:uuid/uuid.dart';
+import 'package:web_socket_channel/status.dart';
 import 'package:web_socket_channel/web_socket_channel.dart';
 import 'package:tfchain_client/tfchain_client.dart' as TFClient;
+import 'package:async_locks/async_locks.dart';
+import 'dart:async';
 
 part 'src/client.dart';