DataStore editing..

1 files changed, 29 insertions, 0 deletions

diff --git a/Software/Visual_Studio/PPC/Tango.PPC.Common/DataStore/DefaultDataStoreService.cs b/Software/Visual_Studio/PPC/Tango.PPC.Common/DataStore/DefaultDataStoreService.cs
index ddc0f6cdb..7c8cf4158 100644
--- a/Software/Visual_Studio/PPC/Tango.PPC.Common/DataStore/DefaultDataStoreService.cs
+++ b/Software/Visual_Studio/PPC/Tango.PPC.Common/DataStore/DefaultDataStoreService.cs
@@ -17,6 +17,7 @@ using Tango.PPC.Common.ExternalBridge;
 using Tango.Transport;
 using Tango.Core.ExtensionMethods;
 using Newtonsoft.Json.Linq;
+using Tango.BL;
 
 namespace Tango.PPC.Common.DataStore
 {
@@ -132,6 +133,34 @@ namespace Tango.PPC.Common.DataStore
             }, token);
         }
 
+        [ExternalBridgeRequestHandlerMethod(typeof(RemoteDataStoreGetAllItemsRequest), RequestHandlerLoggingMode.LogRequestName)]
+        public async Task RemoteDataStoreGetAllItemsRequest(RemoteDataStoreGetAllItemsRequest request, String token, ExternalBridgeReceiver receiver)
+        {
+            List<RemoteDataStoreCollection> collections = new List<RemoteDataStoreCollection>();
+
+            using (ObservablesContext db = ObservablesContext.CreateDefault())
+            {
+                var items = db.DataStoreItems.ToList();
+
+                foreach (var itemsGroup in items.GroupBy(x => x.CollectionName))
+                {
+                    RemoteDataStoreCollection collection = new RemoteDataStoreCollection();
+                    collection.Name = itemsGroup.First().CollectionName;
+                    collections.Add(collection);
+
+                    foreach (var item in itemsGroup)
+                    {
+                        collection.Items.Add(CreateRemoteItem(item.ToDataStoreItem()));
+                    }
+                }
+            }
+
+            await receiver.SendGenericResponse(new RemoteDataStoreGetAllItemsResponse()
+            {
+                Collections = collections
+            }, token);
+        }
+
         private RemoteDataStoreItem CreateRemoteItem(IDataStoreItem item)
         {
             RemoteDataStoreItem remote = new RemoteDataStoreItem();