From 8651169fac81e34685f52f8bb9147115f7ac8765 Mon Sep 17 00:00:00 2001 From: Roy Ben Shabat Date: Fri, 13 Nov 2020 03:13:31 +0200 Subject: Working on data store ! --- .../Tango.Emulations/Emulators/MachineEmulator.cs | 41 ++++++++++++++++++++++ .../Tango.Emulations/Tango.Emulations.csproj | 2 +- 2 files changed, 42 insertions(+), 1 deletion(-) (limited to 'Software/Visual_Studio/Tango.Emulations') diff --git a/Software/Visual_Studio/Tango.Emulations/Emulators/MachineEmulator.cs b/Software/Visual_Studio/Tango.Emulations/Emulators/MachineEmulator.cs index 6b49ca4eb..1c848a97f 100644 --- a/Software/Visual_Studio/Tango.Emulations/Emulators/MachineEmulator.cs +++ b/Software/Visual_Studio/Tango.Emulations/Emulators/MachineEmulator.cs @@ -470,6 +470,9 @@ namespace Tango.Emulations.Emulators case MessageType.StandByRequest: HandleStandByRequest(MessageFactory.ParseTangoMessageFromContainer(container)); break; + case MessageType.DataStoreItemModifiedRequest: + HandleDataStoreItemModifiedRequest(MessageFactory.ParseTangoMessageFromContainer(container)); + break; } } @@ -1719,6 +1722,17 @@ namespace Tango.Emulations.Emulators await Transporter.SendResponse(new StandByResponse(), request.Container.Token); } + private async void HandleDataStoreItemModifiedRequest(TangoMessage request) + { + await Transporter.SendResponse(new DataStoreItemModifiedResponse(), request.Container.Token); + + GetDataStoreItem(new GetDataStoreItemRequest() + { + Collection = request.Message.Collection, + Key = request.Message.Key + }); + } + #endregion #region Public Methods @@ -2115,6 +2129,33 @@ namespace Tango.Emulations.Emulators } } + public async void PutDataStoreItem(PutDataStoreItemRequest request) + { + LogManager.Log($"Sending PutDataStoreItemRequest:\n{request.ToJsonString()}"); + try + { + var response = await Transporter.SendRequest(request); + } + catch (Exception ex) + { + LogManager.Log(ex, "Error putting data store item."); + } + } + + public async void GetDataStoreItem(GetDataStoreItemRequest request) + { + LogManager.Log($"Sending GetDataStoreItemRequest:\n{request.ToJsonString()}"); + try + { + var response = await Transporter.SendRequest(request); + LogManager.Log($"Received GetDataStoreItemResponse:\n{response.Message.ToJsonString()}"); + } + catch (Exception ex) + { + LogManager.Log(ex, "Error getting data store item."); + } + } + #endregion } } diff --git a/Software/Visual_Studio/Tango.Emulations/Tango.Emulations.csproj b/Software/Visual_Studio/Tango.Emulations/Tango.Emulations.csproj index e01f0be8d..022188335 100644 --- a/Software/Visual_Studio/Tango.Emulations/Tango.Emulations.csproj +++ b/Software/Visual_Studio/Tango.Emulations/Tango.Emulations.csproj @@ -90,7 +90,7 @@ - + \ No newline at end of file -- cgit v1.3.1