Implement Askar-Store Methods

src/Hyperledger.Aries/AskarStore/IStorageRecordService.cs → src/Hyperledger.Aries/AskarStore/Abstractions/IStorageRecordService.cs

@@ -5,7 +5,7 @@
 using System.Text;
 using System.Threading.Tasks;
 
-namespace Hyperledger.Aries.AskarStore
+namespace Hyperledger.Aries.AskarStore.Abstractions
 {
     public interface IStorageRecordService
     {
@@ -15,5 +15,6 @@ public interface IStorageRecordService
         Task<StorageRecord> GetRecord(Store store, string recordType, string recordId, bool for_update = false);
         Task<StorageRecord> FindRecord(Store store, StorageRecord record, string tag_query, long limit, bool for_update = false);
         Task<IEnumerable<StorageRecord>> FindAllRecord(Store store, StorageRecord record, string tag_query, long limit, bool for_update = false);
+        Task<long> RemoveAllRecords(Store store, StorageRecord record, string tagFilter = null);
     }
 }

src/Hyperledger.Aries/AskarStore/Abstractions/IStorageService.cs

@@ -0,0 +1,22 @@
+using aries_askar_dotnet.Models;
+using Hyperledger.Aries.AskarStore.Models;
+using System;
+using System.Collections.Generic;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Hyperledger.Aries.AskarStore.Abstractions
+{
+    public interface IStorageService
+    {
+        Task<bool> RemoveStoreAsync(Store store);
+        Task<Store> OpenStoreAsync(Store store, bool provision = false);
+        Task<string> GenerateRawKeyAsync(string Seed = null);
+        Task<string> CreateProfileAsync(Store store, string profile = null);
+        Task<string> GetProfileNameAsync(Store store);
+        Task<string> GetDefaultProfileAsync(Store store);
+        Task<bool> SetDefaultProfileAsync(Store store, string profile);
+        Task<bool> RemoveProfileAsync(Store store, string profile);
+        Task<IEnumerable<AskarProfile>> GetListProfilesAsync(Store store);
+    }
+}

src/Hyperledger.Aries/AskarStore/DefaultStorageRecordService.cs

@@ -1,5 +1,6 @@
 using aries_askar_dotnet.AriesAskar;
 using aries_askar_dotnet.Models;
+using Hyperledger.Aries.AskarStore.Abstractions;
 using Hyperledger.Aries.AskarStore.Models;
 using Hyperledger.Aries.Extensions;
 using Newtonsoft.Json;
@@ -71,11 +72,17 @@ public async Task<IEnumerable<StorageRecord>> FindAllRecord(Store store, Storage
             Session session = await CreateSession(store);
             var items = await session.FetchAllAsync(record.Type, tag_query, limit, for_update);
             var rows = JsonConvert.DeserializeObject<IEnumerable<StorageRecord>>(items.ToJson());
-            var results = new List<StorageRecord >();
+            var results = new List<StorageRecord>();
             foreach (StorageRecord row in rows) {
                 results.Add(row);
             }
             return results;
         }
+
+        public async Task<long> RemoveAllRecords(Store store, StorageRecord record, string tagFilter = null)
+        {
+            Session session = await CreateSession(store);
+            return await session.RemoveAllAsync(record.Type, tagFilter);
+        }
     }
 }

src/Hyperledger.Aries/AskarStore/DefaultStorageService.cs

@@ -1,21 +1,45 @@
 using aries_askar_dotnet.AriesAskar;
 using aries_askar_dotnet.Models;
+using Hyperledger.Aries.AskarStore.Abstractions;
+using Hyperledger.Aries.AskarStore.Models;
+using Hyperledger.Aries.Extensions;
+using Newtonsoft.Json.Linq;
+using Stateless.Graph;
 using System;
 using System.Collections.Generic;
+using System.Runtime.InteropServices;
 using System.Text;
 using System.Threading.Tasks;
 
 namespace Hyperledger.Aries.AskarStore
 {
     public class DefaultStorageService : IStorageService
     {
+        public async Task<string> CreateProfileAsync(Store store, string profile = null)
+        {
+            return await store.CreateProfileAsync(profile);
+        }
+
         public Task<string> GenerateRawKeyAsync(string Seed = null)
         {
-            var key = StoreApi.GenerateRawKeyAsync(Seed);
-            return key;
+            return StoreApi.GenerateRawKeyAsync(Seed);
+        }
+
+        public async Task<string> GetDefaultProfileAsync(Store store)
+        {
+            return await store.GetDefaultProfileAsync();
         }
 
-        public async Task<Store> OpenStore(Store store, bool provision = false)
+        public async Task<string> GetProfileNameAsync(Store store)
+        {
+           return await store.GetProfileNameAsync();
+        }
+        public async Task<bool> RemoveProfileAsync(Store store, string profile)
+        {
+            return await store.RemoveProfileAsync(profile);
+        }
+
+        public async Task<Store> OpenStoreAsync(Store store, bool provision = false)
         {
             if (provision)
             {
@@ -33,5 +57,25 @@ public Task<bool> RemoveStoreAsync(Store store)
         {
             return StoreApi.CloseAsync(store);
         }
+
+        public async Task<bool> SetDefaultProfileAsync(Store store, string profile)
+        {
+           return await store.SetDefaultProfileAsync(profile);
+        }
+
+        public async Task<IEnumerable<AskarProfile>> GetListProfilesAsync(Store store)
+        {
+             var response =  await store.GetListProfilesAsync();
+             var jobj = JArray.Parse(response.ToJson());
+            var profileList = new List<AskarProfile>();
+             foreach (var item in jobj)
+            {
+                profileList.Add(new AskarProfile
+                {
+                    Name = item["profile_id"].ToString()
+                });
+            }
+             return profileList;
+        }
     }
 }

src/Hyperledger.Aries/AskarStore/Models/AskarProfile.cs

@@ -0,0 +1,13 @@
+using aries_askar_dotnet.Models;
+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace Hyperledger.Aries.AskarStore.Models
+{
+    public class AskarProfile
+    {
+        public string Name { get; set; }
+        public bool Opened { get; set; }
+    }
+}