Unify akka logs with neo logs

src/neo/Consensus/ConsensusService.cs

@@ -189,7 +189,7 @@ private void InitializeConsensus(byte viewNumber)
 
         private void Log(string message, LogLevel level = LogLevel.Info)
         {
-            Utility.Log(nameof(ConsensusService), level, message);
+            Utility.Log<ConsensusService>(level, message);
         }
 
         private void OnChangeViewReceived(ConsensusPayload payload, ChangeView message)

src/neo/LogLevel.cs

@@ -2,10 +2,10 @@ namespace Neo
 {
     public enum LogLevel : byte
     {
-        Fatal,
-        Error,
-        Warning,
-        Info,
-        Debug
+        Debug = 0,
+        Info = 1,
+        Warning = 2,
+        Error = 3,
+        Fatal = 4
     }
 }

src/neo/NeoSystem.cs

@@ -12,7 +12,7 @@ namespace Neo
     public class NeoSystem : IDisposable
     {
         public ActorSystem ActorSystem { get; } = ActorSystem.Create(nameof(NeoSystem),
-            $"akka {{ log-dead-letters = off }}" +
+            $"akka {{ log-dead-letters = off , loglevel = warning, loggers = [ \"{typeof(Utility.Logger).AssemblyQualifiedName}\" ] }}" +
             $"blockchain-mailbox {{ mailbox-type: \"{typeof(BlockchainMailbox).AssemblyQualifiedName}\" }}" +
             $"task-manager-mailbox {{ mailbox-type: \"{typeof(TaskManagerMailbox).AssemblyQualifiedName}\" }}" +
             $"remote-node-mailbox {{ mailbox-type: \"{typeof(RemoteNodeMailbox).AssemblyQualifiedName}\" }}" +

src/neo/Plugins/Plugin.cs

@@ -109,7 +109,7 @@ private static Assembly CurrentDomain_AssemblyResolve(object sender, ResolveEven
             }
             catch (Exception ex)
             {
-                Utility.Log(nameof(Plugin), LogLevel.Error, $"Failed to resolve assembly or its dependency: {ex.Message}");
+                Utility.Log(an.Name, LogLevel.Error, $"Failed to resolve assembly or its dependency: {ex.Message}");
                 return null;
             }
         }
@@ -137,7 +137,7 @@ private static void LoadPlugin(Assembly assembly)
                 }
                 catch (Exception ex)
                 {
-                    Utility.Log(nameof(Plugin), LogLevel.Error, $"Failed to initialize plugin: {ex.Message}");
+                    Utility.Log(type.Name, LogLevel.Error, $"Failed to initialize plugin: {ex.Message}");
                 }
             }
         }

src/neo/Utility.cs

@@ -1,3 +1,5 @@
+using Akka.Actor;
+using Akka.Event;
 using Microsoft.Extensions.Configuration;
 using Neo.Plugins;
 using System;
@@ -6,6 +8,28 @@ namespace Neo
 {
     public static class Utility
     {
+        internal class Logger : ReceiveActor
+        {
+            public Logger()
+            {
+                Receive<Debug>(e => OnLog(LogLevel.Debug, e.ToString()));
+                Receive<Info>(e => OnLog(LogLevel.Info, e.ToString()));
+                Receive<Warning>(e => OnLog(LogLevel.Warning, e.ToString()));
+                Receive<Error>(e => OnLog(LogLevel.Error, e.ToString()));
+                Receive<InitializeLogger>(_ => Init(Sender));
+            }
+
+            private void Init(IActorRef sender)
+            {
+                sender.Tell(new LoggerInitialized());
+            }
+
+            private void OnLog(LogLevel level, string message)
+            {
+                Log<NeoSystem>(level, message);
+            }
+        }
+
         /// <summary>
         /// Load configuration with different Environment Variable
         /// </summary>
@@ -25,5 +49,10 @@ public static void Log(string source, LogLevel level, string message)
             foreach (ILogPlugin plugin in Plugin.Loggers)
                 plugin.Log(source, level, message);
         }
+
+        public static void Log<T>(LogLevel level, string message)
+        {
+            Log(typeof(T).Name, level, message);
+        }
     }
 }