Merge pull request #18 from easymorph/development/5.7.0

5.7.0

Author: strongtigerman

src/BusinessLogic/Commands/CommandsFactory.cs

@@ -43,6 +43,12 @@ public static ICommand Construct(Command command, IOutputEndpoint output, IInput
                     return new ListTasksCommand(output, input, apiClient);
                 case Command.HttpSecureChallengeTest:
                     return new HttpSecureChallengeTestCommand(output, input, apiClient);
+                case Command.Remember:
+                    return new SharedMemoryRememberCommand(output, input, apiClient);
+                case Command.Recall:
+                    return new SharedMemoryRecallCommand(output, input, apiClient);
+                case Command.Forget:
+                    return new SharedMemoryForgetCommand(output, input, apiClient);
                 default:
                     throw new Exception("Command not supported");
             }

src/BusinessLogic/Commands/SharedMemoryForgetCommand.cs

@@ -0,0 +1,32 @@
+using System.Threading.Tasks;
+using Morph.Server.Sdk.Client;
+using MorphCmd.Exceptions;
+using MorphCmd.Interfaces;
+using MorphCmd.Models;
+
+namespace MorphCmd.BusinessLogic.Commands
+{
+    internal class SharedMemoryForgetCommand : BaseCommand, ICommand
+    {
+        public SharedMemoryForgetCommand(IOutputEndpoint output, IInputEndpoint input, IMorphServerApiClient apiClient) : base(
+            output, input, apiClient)
+        {
+        }
+
+        public bool IsApiSessionRequired => true;
+
+        public async Task Execute(Parameters parameters)
+        {
+            if (string.IsNullOrWhiteSpace(parameters.Key))
+                throw new WrongCommandFormatException("Key is required");
+
+            using (var session = await OpenSession(parameters))
+            {
+                _output.WriteInfo($"Deleting shared memory record {parameters.Key} in space {session.SpaceName}...");
+                var deletedKeyCount = await _apiClient.SharedMemoryForget(session, parameters.Key,
+                    _cancellationTokenSource.Token);
+                _output.WriteInfo($"Operation completed, {deletedKeyCount} records deleted");
+            }
+        }
+    }
+}

src/BusinessLogic/Commands/SharedMemoryRecallCommand.cs

@@ -0,0 +1,32 @@
+using System.Threading.Tasks;
+using Morph.Server.Sdk.Client;
+using Morph.Server.Sdk.Model.SharedMemory;
+using MorphCmd.Exceptions;
+using MorphCmd.Interfaces;
+using MorphCmd.Models;
+
+namespace MorphCmd.BusinessLogic.Commands
+{
+    internal class SharedMemoryRecallCommand : BaseCommand, ICommand
+    {
+        public SharedMemoryRecallCommand(IOutputEndpoint output, IInputEndpoint input, IMorphServerApiClient apiClient) : base(
+            output, input, apiClient)
+        {
+        }
+
+        public bool IsApiSessionRequired => true;
+
+        public async Task Execute(Parameters parameters)
+        {
+            if (string.IsNullOrWhiteSpace(parameters.Key))
+                throw new WrongCommandFormatException("Key is required");
+            
+            using (var session = await OpenSession(parameters))
+            {
+                _output.WriteInfo($"Retrieving shared memory record {parameters.Key} in space {session.SpaceName}...");
+                var result = await _apiClient.SharedMemoryRecall(session, parameters.Key, _cancellationTokenSource.Token);
+                _output.WriteInfo(result.Contents.ToString());
+            }
+        }
+    }
+}

src/BusinessLogic/Commands/SharedMemoryRememberCommand.cs

@@ -0,0 +1,39 @@
+using System.Threading.Tasks;
+using Morph.Server.Sdk.Client;
+using Morph.Server.Sdk.Model.SharedMemory;
+using MorphCmd.Exceptions;
+using MorphCmd.Interfaces;
+using MorphCmd.Models;
+
+namespace MorphCmd.BusinessLogic.Commands
+{
+    internal class SharedMemoryRememberCommand : BaseCommand, ICommand
+    {
+        public SharedMemoryRememberCommand(IOutputEndpoint output, IInputEndpoint input, IMorphServerApiClient apiClient) : base(
+            output, input, apiClient)
+        {
+        }
+
+        public bool IsApiSessionRequired => true;
+
+        public async Task Execute(Parameters parameters)
+        {
+            if (string.IsNullOrWhiteSpace(parameters.Key))
+                throw new WrongCommandFormatException("Key is required");
+            if (string.IsNullOrWhiteSpace(parameters.Value))
+                throw new WrongCommandFormatException("Value is required");
+
+            using (var session = await OpenSession(parameters))
+            {
+                _output.WriteInfo($"Saving shared memory record {parameters.Key} in space {session.SpaceName}...");
+                _ = await _apiClient.SharedMemoryRemember(
+                    session,
+                    parameters.Key,
+                    SharedMemoryValue.NewText(parameters.Value),
+                    OverwriteBehavior.Overwrite,
+                    _cancellationTokenSource.Token);
+                _output.WriteInfo($"Operation completed");
+            }
+        }
+    }
+}

src/BusinessLogic/ParametersHelper.cs

@@ -83,6 +83,11 @@ public static Parameters ExtractParameters(string command, string host, Dictiona
                 parameters.TaskId = guid;
 
             }
+            
+            if (paramsDict.TryGetValue("key", out var value))
+                parameters.Key = value;
+            if (paramsDict.TryGetValue("value", out value))
+                parameters.Value = value;
 
             if (Enum.TryParse<Command>(command.Trim(), true, out var cmd))
             {

src/BusinessLogic/RunUsageSamples.cs

@@ -31,6 +31,17 @@ public static void WriteCommadUsage(Command cmd, IOutputEndpoint output)
                 case Command.Del:
                     output.WriteInfo("DEL usage sample: ems-cmd del http://10.20.30.40:6330 -space Default -target \"folder 1\\sample.txt\" ");
                     break;
+                
+                case Command.Remember:
+                    output.WriteInfo("REMEMBER usage sample: ems-cmd remember http://10.20.30.40:6330 -space Default -key path1\\path2\\abc -value XYZ");
+                    break;
+                case Command.Recall:
+                    output.WriteInfo("RECALL usage sample: ems-cmd recall http://10.20.30.40:6330 -space Default -key path1\\path2\\abc");
+                    break;
+                case Command.Forget:
+                    output.WriteInfo("FORGET usage sample: ems-cmd forget http://10.20.30.40:6330 -space Default -key path1\\path2\\abc");
+                    break;
+                
                 default:
                     output.WriteInfo("This command hasn't usage example");
                     break;

src/Models/Command.cs

@@ -21,8 +21,11 @@ public enum Command
         ListSpaces,
         SpaceStatus,
         ListTasks,
-        HttpSecureChallengeTest
-
-
+        HttpSecureChallengeTest,
+        
+        // Shared memory commands
+        Remember,
+        Recall,
+        Forget,
     }
 }

src/Models/Parameters.cs

@@ -28,6 +28,14 @@ public class Parameters
         public string Password { get; set; }
         public bool SuppressSslErrors { get; set; }
         public List<TaskRunParameter> TaskRunParameters { get; set; }
+
+        #region Shared Memory Command Parameters 
+
+        public string Key { get; set; }
+        public string Value { get; set; }
+
+        #endregion
+        
         public Parameters()
         {
             TaskRunParameters = new List<TaskRunParameter>();