Optimize code

Author: EugeneKisel-sm

SdkTestAutomation.Sdk/Core/SdkFactory.cs

@@ -1,8 +1,8 @@
 using SdkTestAutomation.Sdk.Core.Interfaces;
-using SdkTestAutomation.Sdk.Implementations.CSharp;
+using SdkTestAutomation.Sdk.Implementations.CSharp.Adapters;
 using SdkTestAutomation.Sdk.Implementations.Java.Conductor;
-using SdkTestAutomation.Sdk.Implementations.Python;
-using SdkTestAutomation.Sdk.Implementations.Go;
+using SdkTestAutomation.Sdk.Implementations.Python.Adapters;
+using SdkTestAutomation.Sdk.Implementations.Go.Adapters;
 using SdkTestAutomation.Sdk.Implementations.Java.Orkes;
 
 namespace SdkTestAutomation.Sdk.Core;

SdkTestAutomation.Sdk/Implementations/CSharp/Adapters/CSharpEventAdapter.cs

@@ -0,0 +1,63 @@
+using SdkTestAutomation.Sdk.Core.Interfaces;
+using SdkTestAutomation.Sdk.Core.Models;
+
+namespace SdkTestAutomation.Sdk.Implementations.CSharp.Adapters;
+
+public class CSharpEventAdapter : BaseCSharpAdapter, IEventAdapter
+{
+    public SdkResponse AddEvent(string name, string eventType, bool active = true)
+    {
+        return ExecuteCSharpOperation(() =>
+        {
+            var eventHandler = new Conductor.Client.Models.EventHandler
+            {
+                Name = name,
+                _Event = eventType,
+                Active = active,
+                Actions = new List<Action>()
+            };
+            
+            _client.EventApi.AddEventHandler(eventHandler);
+        }, "AddEvent");
+    }
+    
+    public SdkResponse GetEvents()
+    {
+        return ExecuteCSharpOperation(() =>
+        {
+            return _client.EventApi.GetEventHandlers();
+        }, "GetEvents");
+    }
+    
+    public SdkResponse GetEventByName(string eventName)
+    {
+        return ExecuteCSharpOperation(() =>
+        {
+            return _client.EventApi.GetEventHandlersForEvent(eventName, false);
+        }, "GetEventByName");
+    }
+    
+    public SdkResponse UpdateEvent(string name, string eventType, bool active = true)
+    {
+        return ExecuteCSharpOperation(() =>
+        {
+            var eventHandler = new Conductor.Client.Models.EventHandler
+            {
+                Name = name,
+                _Event = eventType,
+                Active = active,
+                Actions = new List<Action>()
+            };
+            
+            _client.EventApi.UpdateEventHandler(eventHandler);
+        }, "UpdateEvent");
+    }
+    
+    public SdkResponse DeleteEvent(string name)
+    {
+        return ExecuteCSharpOperation(() =>
+        {
+            _client.EventApi.RemoveEventHandlerStatus(name);
+        }, "DeleteEvent");
+    }
+} 

SdkTestAutomation.Sdk/Implementations/CSharp/Adapters/CSharpTokenAdapter.cs

@@ -0,0 +1,21 @@
+using SdkTestAutomation.Sdk.Core.Interfaces;
+using SdkTestAutomation.Sdk.Core.Models;
+
+namespace SdkTestAutomation.Sdk.Implementations.CSharp.Adapters;
+
+public class CSharpTokenAdapter : BaseCSharpAdapter, ITokenAdapter
+{
+    public SdkResponse GenerateToken(string keyId, string keySecret)
+    {
+        return ExecuteCSharpOperation(() =>
+        {
+            var generateTokenRequest = new Conductor.Client.Models.GenerateTokenRequest(keyId, keySecret);
+            return _client.TokenApi.GenerateToken(generateTokenRequest);
+        }, "GenerateToken");
+    }
+    
+    public SdkResponse GetUserInfo()
+    {
+        throw new NotImplementedException();
+    }
+} 

SdkTestAutomation.Sdk/Implementations/CSharp/Adapters/CSharpWorkflowAdapter.cs

@@ -0,0 +1,47 @@
+using Conductor.Client.Models;
+using SdkTestAutomation.Sdk.Core.Interfaces;
+using SdkTestAutomation.Sdk.Core.Models;
+
+namespace SdkTestAutomation.Sdk.Implementations.CSharp.Adapters;
+
+public class CSharpWorkflowAdapter : BaseCSharpAdapter, IWorkflowAdapter
+{
+    public SdkResponse GetWorkflow(string workflowId)
+    {
+        return ExecuteCSharpOperation(() =>
+        {
+            return _client.WorkflowApi.GetExecutionStatus(workflowId);
+        }, "GetWorkflow");
+    }
+    
+    public SdkResponse GetWorkflows()
+    {
+        return ExecuteCSharpOperation(() =>
+        {
+            return _client.WorkflowApi.GetRunningWorkflow("", null, 100, 0);
+        }, "GetWorkflows");
+    }
+    
+    public SdkResponse StartWorkflow(string name, int version, string correlationId = null)
+    {
+        return ExecuteCSharpOperation(() =>
+        {
+            var startWorkflowRequest = new StartWorkflowRequest
+            {
+                Name = name,
+                Version = version,
+                CorrelationId = correlationId
+            };
+            
+            return _client.WorkflowApi.StartWorkflow(startWorkflowRequest);
+        }, "StartWorkflow");
+    }
+    
+    public SdkResponse TerminateWorkflow(string workflowId, string reason = null)
+    {
+        return ExecuteCSharpOperation(() =>
+        {
+            _client.WorkflowApi.Terminate(workflowId, reason);
+        }, "TerminateWorkflow");
+    }
+} 

SdkTestAutomation.Sdk/Implementations/CSharp/BaseCSharpAdapter.cs

@@ -0,0 +1,69 @@
+using SdkTestAutomation.Sdk.Core.Models;
+
+namespace SdkTestAutomation.Sdk.Implementations.CSharp;
+
+public abstract class BaseCSharpAdapter
+{
+    protected readonly CSharpClient _client;
+    
+    protected BaseCSharpAdapter()
+    {
+        _client = new CSharpClient();
+    }
+    
+    public string SdkType => "csharp";
+    
+    public bool Initialize(string serverUrl)
+    {
+        try
+        {
+            _client.Initialize(serverUrl);
+            return _client.IsInitialized;
+        }
+        catch (Exception ex)
+        {
+            throw new InvalidOperationException($"Failed to initialize C# adapter: {ex.Message}", ex);
+        }
+    }
+
+    protected SdkResponse ExecuteCSharpOperation(Func<object> operation, string operationName)
+    {
+        try
+        {
+            if (_client == null || !_client.IsInitialized)
+            {
+                return SdkResponse.CreateError("C# client is not initialized");
+            }
+            
+            var result = operation();
+            return SdkResponse.CreateSuccess(result);
+        }
+        catch (Exception ex)
+        {
+            return SdkResponse.CreateError($"{operationName} failed: {ex.Message}");
+        }
+    }
+    
+    protected SdkResponse ExecuteCSharpOperation(Action operation, string operationName)
+    {
+        try
+        {
+            if (_client == null || !_client.IsInitialized)
+            {
+                return SdkResponse.CreateError("C# client is not initialized");
+            }
+            
+            operation();
+            return SdkResponse.CreateSuccess();
+        }
+        catch (Exception ex)
+        {
+            return SdkResponse.CreateError($"{operationName} failed: {ex.Message}");
+        }
+    }
+    
+    public void Dispose()
+    {
+        _client?.Dispose();
+    }
+}