add listall and delete all for kvStore

Author: AlaaElattar

.dart_tool/package_config.json

@@ -656,7 +656,7 @@
       "languageVersion": "3.2"
     }
   ],
-  "generated": "2024-04-16T10:54:09.162011Z",
+  "generated": "2024-04-18T09:13:15.973441Z",
   "generator": "pub",
   "generatorVersion": "3.3.3"
 }

.vscode/settings.json

@@ -1,3 +1,3 @@
 {
-  "cSpell.words": ["keypair", "polkadot", "tfchain"]
+  "cSpell.words": ["keypair", "polkadot", "sublist", "tfchain", "TFKV", "twoxx"]
 }

packages/tfchain_client/bin/tfchain_client.dart

@@ -24,8 +24,6 @@ void main() async {
       "sr25519");
   await client.connect();
 
-  // final extrinsic =
-  //     client.kvStrore.set(KVStoreSetOptions(key: "mnemonic", value: "value"));
   // await client.apply(extrinsic);
   client.kvStrore.list();
 

packages/tfchain_client/lib/src/client.dart

@@ -98,7 +98,6 @@ class Client extends QueryClient {
     checkInputs();
     if (keypairType == "sr25519") {
       keypair = await signer.fromMnemonic(mnemonic, Signer.KPType.sr25519);
-      print("ADDRESS ${keypair!.address}");
       address = keypair!.address;
     } else {
       keypair = await signer.fromMnemonic(mnemonic, Signer.KPType.ed25519);
@@ -140,6 +139,10 @@ class Client extends QueryClient {
     final encodedCall = runtimeCall.encode();
     final nonce = await api.rpc.system.accountNextIndex(keyring.address);
 
+    // await api.rpc.state.queryStorageAt(keys)
+    // state vs systemApi
+    // different naming between polkadot vs flutter
+    // how to make rpc call on state
     final payloadToSign = SigningPayload(
         method: encodedCall,
         specVersion: specVersion,

packages/tfchain_client/lib/src/kvstore.dart

@@ -1,7 +1,5 @@
-import 'dart:convert';
-
-import 'package:tfchain_client/generated/dev/dev.dart';
-import 'package:tfchain_client/generated/dev/types/tfchain_runtime/runtime.dart';
+import 'dart:typed_data';
+import 'package:polkadart/polkadart.dart';
 import 'package:tfchain_client/generated/dev/types/tfchain_runtime/runtime_call.dart';
 import 'package:tfchain_client/models/kvstore.dart';
 import 'package:tfchain_client/tfchain_client.dart';
@@ -25,16 +23,53 @@ class KVStore {
 
   Future<String> get(KVStoreGetOptions options) async {
     final res = await client.api.query.tFKVStore
-        .tFKVStore(client.keypair!.publicKey.bytes, options.key.codeUnits);
+        .tFKVStore(client.keypair!.publicKey.bytes, []);
+    print(res);
     return String.fromCharCodes(res);
   }
 
-  void list() async {
-    // final queries = client.api.query.
-    // final res = await queries.tFKVStore.
+  Future<Map<String, String>> list() async {
+    final moduleHash =
+        Hasher.twoxx128.hash(Uint8List.fromList('TFKVStore'.codeUnits));
+
+    final functionHash =
+        Hasher.twoxx128.hash(Uint8List.fromList('TFKVStore'.codeUnits));
+
+    final keyHash = Hasher.blake2b128
+        .hash(Uint8List.fromList(client.keypair!.publicKey.bytes));
+
+    Uint8List partialKey = Uint8List.fromList([
+      ...moduleHash,
+      ...functionHash,
+      ...keyHash,
+      ...client.keypair!.publicKey.bytes
+    ]);
+
+    final keys = await client.api.rpc.state.getKeys(key: partialKey);
+
+    final keysValues = await client.api.rpc.state.queryStorageAt(keys);
+
+    Map<String, String> keyValueMap = {};
+
+    for (var change in keysValues[0].changes) {
+      final key = change.key;
+      var value = change.value;
+
+      final added = key.sublist(partialKey.length + 17);
+
+      value = value!.sublist(1);
+      keyValueMap[String.fromCharCodes(added)] = String.fromCharCodes(value);
+    }
+
+    return keyValueMap;
   }
 
-  void deleteAll(){
+  void deleteAll() async {
+    Map<String, String> keys = await list();
 
+    for (String key in keys.keys) {
+      final extrinsic = delete(KVStoreGetOptions(key: key));
+      await client.apply(extrinsic);
+    }
   }
 }

packages/tfchain_client/pubspec.yaml

@@ -15,6 +15,7 @@ dependencies:
   moment_dart: ^2.0.2
   signer: 
     path: ../signer
+  hashlib: ^1.13.1
 
 dev_dependencies:
   lints: ^3.0.0