Merge pull request #20 from jacqueskang/issue-17-byte-array

support byte array in interface

Author: jacqueskang

src/IpcServiceSample.ConsoleClient/Program.cs

@@ -1,6 +1,7 @@
 using IpcServiceSample.ServiceContracts;
 using JKang.IpcServiceFramework;
 using System;
+using System.Text;
 using System.Threading.Tasks;
 
 namespace IpcServiceSample.ConsoleClient
@@ -20,13 +21,13 @@ private static async Task MainAsync(string[] args)
 
                 // test 1: call IPC service method with primitive types
                 float result1 = await client.InvokeAsync(x => x.AddFloat(1.23f, 4.56f));
-                Console.WriteLine($"sum of 2 floating number is: {result1}");
+                Console.WriteLine($"[TEST 1] sum of 2 floating number is: {result1}");
 
                 // test 2: call IPC service method with complex types
                 ComplexNumber result2 = await client.InvokeAsync(x => x.AddComplexNumber(
                     new ComplexNumber(0.1f, 0.3f),
                     new ComplexNumber(0.2f, 0.6f)));
-                Console.WriteLine($"sum of 2 complexe number is: {result2.A}+{result2.B}i");
+                Console.WriteLine($"[TEST 2] sum of 2 complexe number is: {result2.A}+{result2.B}i");
 
                 // test 3: call IPC service method with an array of complex types
                 ComplexNumber result3 = await client.InvokeAsync(x => x.AddComplexNumbers(new[]
@@ -35,19 +36,25 @@ private static async Task MainAsync(string[] args)
                     new ComplexNumber(0.2f, 0.1f),
                     new ComplexNumber(0.3f, 0.5f),
                 }));
-                Console.WriteLine($"sum of 3 complexe number is: {result3.A}+{result3.B}i");
+                Console.WriteLine($"[TEST 3] sum of 3 complexe number is: {result3.A}+{result3.B}i");
 
                 // test 4: call IPC service method without parameter or return
                 await client.InvokeAsync(x => x.DoNothing());
-                Console.WriteLine($"invoked DoNothing()");
+                Console.WriteLine($"[TEST 4] invoked DoNothing()");
 
                 // test 5: call IPC service method with enum parameter
                 string text = await client.InvokeAsync(x => x.ConvertText("hEllO woRd!", TextStyle.Upper));
-                Console.WriteLine(text);
+                Console.WriteLine($"[TEST 5] {text}");
 
                 // test 6: call IPC service method returning GUID
                 Guid generatedId = await client.InvokeAsync(x => x.GenerateId());
-                Console.WriteLine($"generated ID is: {generatedId}");
+                Console.WriteLine($"[TEST 6] generated ID is: {generatedId}");
+
+                // test 7: call IPC service method with byte array
+                byte[] input = Encoding.UTF8.GetBytes("Test");
+                byte[] reversed = await client.InvokeAsync(x => x.ReverseBytes(input));
+                Console.WriteLine($"[TEST 7] reversed bytes are: {Convert.ToBase64String(reversed)}");
+
             }
             catch (Exception ex)
             {

src/IpcServiceSample.ConsoleServer/ComputingService.cs

@@ -1,6 +1,7 @@
 using System;
 using System.Collections.Generic;
 using System.Globalization;
+using System.Linq;
 using IpcServiceSample.ServiceContracts;
 using Microsoft.Extensions.Logging;
 
@@ -58,5 +59,10 @@ public Guid GenerateId()
         {
             return Guid.NewGuid();
         }
+
+        public byte[] ReverseBytes(byte[] input)
+        {
+            return input.Reverse().ToArray();
+        }
     }
 }

src/IpcServiceSample.ServiceContracts/IComputingService.cs

@@ -11,6 +11,7 @@ public interface IComputingService
         void DoNothing();
         string ConvertText(string text, TextStyle style);
         Guid GenerateId();
+        byte[] ReverseBytes(byte[] input);
     }
 
     public class ComplexNumber

src/JKang.IpcServiceFramework.Core/Services/DefaultIpcMessageSerializer.cs

@@ -7,7 +7,7 @@ public class DefaultIpcMessageSerializer : IIpcMessageSerializer
     {
         private static readonly JsonSerializerSettings _settings = new JsonSerializerSettings
         {
-            TypeNameHandling = TypeNameHandling.Objects
+            TypeNameHandling = TypeNameHandling.None
         };
 
         public IpcRequest DeserializeRequest(byte[] binary)

src/JKang.IpcServiceFramework.Server/IpcServiceHost.cs

@@ -91,7 +91,7 @@ private IpcResponse GetReponse(IpcRequest request, IServiceScope scope)
             var @interface = Type.GetType(request.InterfaceName);
             if (@interface == null)
             {
-                return IpcResponse.Fail($"Interface '{@interface}' not found.");
+                return IpcResponse.Fail($"Interface '{request.InterfaceName}' not found.");
             }
 
             object service = scope.ServiceProvider.GetService(@interface);