Add debug mode to the applicationlog to get log info

src/ApplicationLogs/LogReader.cs

@@ -24,8 +24,9 @@ namespace Neo.Plugins
 {
  public class LogReader : Plugin
  {
- private IStore _db;
- private ISnapshot _snapshot;
+ private static IStore _db;
+ private static ISnapshot _snapshot;
+ private static readonly byte[] LogPrefix = { 0x12 };
 
  public override string Name => "ApplicationLogs";
  public override string Description => "Synchronizes the smart contract log with the NativeContract log (Notify)";
@@ -34,12 +35,16 @@ public LogReader()
  {
  Blockchain.Committing += OnCommitting;
  Blockchain.Committed += OnCommitted;
+ if (Settings.Default.Debug)
+ ApplicationEngine.Log += ApplicationEngine_Log;
  }
 
  public override void Dispose()
  {
  Blockchain.Committing -= OnCommitting;
  Blockchain.Committed -= OnCommitted;
+ if (Settings.Default.Debug)
+ ApplicationEngine.Log -= ApplicationEngine_Log;
  }
 
  protected override void Configure()
@@ -76,6 +81,12 @@ public JToken GetApplicationLog(JArray _params)
  i++;
  }
  }
+ if (!Settings.Default.Debug) return raw;
+ byte[] logs = _db.TryGet(LogPrefix.Concat(hash.ToArray()).ToArray());
+ if (logs != null)
+ {
+ raw["executions"]["logs"] = (JArray)JToken.Parse(Neo.Utility.StrictUTF8.GetString(value));
+ }
  return raw;
  }
 
@@ -186,6 +197,33 @@ private void OnCommitting(NeoSystem system, Block block, DataCache snapshot, IRe
  }
  }
 
+ private static void ApplicationEngine_Log(object sender, LogEventArgs args)
+ {
+ if (!Settings.Default.Debug) return;
+
+ var tx = ((Transaction)args.ScriptContainer).Hash;
+
+ byte[] value = _db.TryGet(LogPrefix.Concat(tx.ToArray()).ToArray());
+
+ JArray logList = null;
+ if (value is null)
+ {
+ logList = new JArray();
+ }
+ else
+ {
+ logList = (JArray)JToken.Parse(Neo.Utility.StrictUTF8.GetString(value));
+ }
+ var logJson = new JObject
+ {
+ ["contract"] = args.ScriptHash.ToString(),
+ ["message"] = args.Message
+ };
+ logList?.Add(logJson);
+
+ _snapshot.Put(LogPrefix.Concat(tx.ToArray()).ToArray(), Neo.Utility.StrictUTF8.GetBytes(logList?.ToString()!));
+ }
+
  private void OnCommitted(NeoSystem system, Block block)
  {
  if (system.Settings.Network != Settings.Default.Network) return;

src/ApplicationLogs/Settings.cs

@@ -18,13 +18,16 @@ internal class Settings
  public uint Network { get; }
  public int MaxStackSize { get; }
 
+ public bool Debug { get; }
+
  public static Settings Default { get; private set; }
 
  private Settings(IConfigurationSection section)
  {
  this.Path = section.GetValue("Path", "ApplicationLogs_{0}");
  this.Network = section.GetValue("Network", 5195086u);
  this.MaxStackSize = section.GetValue("MaxStackSize", (int)ushort.MaxValue);
+ this.Debug = section.GetValue("Debug", false);
  }
 
  public static void Load(IConfigurationSection section)

src/ApplicationLogs/config.json

@@ -2,7 +2,8 @@
  "PluginConfiguration": {
  "Path": "ApplicationLogs_{0}",
  "Network": 860833102,
- "MaxStackSize": 65535
+ "MaxStackSize": 65535,
+ "Debug": false
  },
  "Dependency": [
  "RpcServer"

src/RpcClient/Models/RpcApplicationLog.cs

@@ -61,6 +61,8 @@ public class Execution
 
  public List<RpcNotifyEventArgs> Notifications { get; set; }
 
+ public List<RpcLogEventArgs> Logs { get; set; }
+
  public JObject ToJson()
  {
  JObject json = new();
@@ -70,6 +72,11 @@ public JObject ToJson()
  json["exception"] = ExceptionMessage;
  json["stack"] = Stack.Select(q => q.ToJson()).ToArray();
  json["notifications"] = Notifications.Select(q => q.ToJson()).ToArray();
+ // Only add "logs" to json if Logs is not null
+ if (Logs != null)
+ {
+ json["logs"] = Logs.Select(q => q.ToJson()).ToArray();
+ }
  return json;
  }
 
@@ -82,7 +89,8 @@ public static Execution FromJson(JObject json, ProtocolSettings protocolSettings
  GasConsumed = long.Parse(json["gasconsumed"].AsString()),
  ExceptionMessage = json["exception"]?.AsString(),
  Stack = ((JArray)json["stack"]).Select(p => Utility.StackItemFromJson((JObject)p)).ToList(),
- Notifications = ((JArray)json["notifications"]).Select(p => RpcNotifyEventArgs.FromJson((JObject)p, protocolSettings)).ToList()
+ Notifications = ((JArray)json["notifications"]).Select(p => RpcNotifyEventArgs.FromJson((JObject)p, protocolSettings)).ToList(),
+ Logs = ((JArray)json["logs"])?.Select(p => RpcLogEventArgs.FromJson((JObject)p, protocolSettings)).ToList()
  };
  }
  }
@@ -114,4 +122,29 @@ public static RpcNotifyEventArgs FromJson(JObject json, ProtocolSettings protoco
  };
  }
  }
+
+ public class RpcLogEventArgs
+ {
+ public UInt160 Contract { get; set; }
+
+ public string Message { get; set; }
+
+ public JObject ToJson()
+ {
+ return new JObject
+ {
+ ["contract"] = Contract.ToString(),
+ ["message"] = Message
+ };
+ }
+
+ public static RpcLogEventArgs FromJson(JObject json, ProtocolSettings protocolSettings)
+ {
+ return new RpcLogEventArgs
+ {
+ Contract = json["contract"].ToScriptHash(protocolSettings),
+ Message = json["message"]?.AsString(),
+ };
+ }
+ }
 }