Merge pull request #420 from area363/insert-transfer-asset3

Add insert transferasset3
planetarium · Jul 11, 2023 · 718df44 · 718df44
2 parents 74eccfb + 3a68162
commit 718df44
Showing 1 changed file with 32 additions and 0 deletions.
diff --git a/NineChronicles.DataProvider/RenderSubscriber.cs b/NineChronicles.DataProvider/RenderSubscriber.cs
@@ -977,6 +977,38 @@ protected override Task ExecuteAsync(CancellationToken stoppingToken)
                     }
                 });
 
+            _actionRenderer.EveryRender<TransferAsset3>()
+                .Subscribe(ev =>
+                {
+                    try
+                    {
+                        if (ev.Exception == null && ev.Action is { } transferAsset3)
+                        {
+                            var start = DateTimeOffset.UtcNow;
+                            var actionString = ev.TxId.ToString();
+                            var actionByteArray = Encoding.UTF8.GetBytes(actionString!).Take(16).ToArray();
+                            var id = new Guid(actionByteArray);
+                            _transferAssetList.Add(TransferAssetData.GetTransferAssetInfo(
+                                id,
+                                (TxId)ev.TxId!,
+                                ev.BlockIndex,
+                                _blockHash!,
+                                transferAsset3.Sender,
+                                transferAsset3.Recipient,
+                                transferAsset3.Amount.Currency.Ticker,
+                                transferAsset3.Amount,
+                                _blockTimeOffset));
+
+                            var end = DateTimeOffset.UtcNow;
+                            Log.Debug("Stored TransferAsset action in block #{index}. Time Taken: {time} ms.", ev.BlockIndex, (end - start).Milliseconds);
+                        }
+                    }
+                    catch (Exception ex)
+                    {
+                        Log.Error("RenderSubscriber: {message}", ex.Message);
+                    }
+                });
+
             _actionRenderer.EveryRender<TransferAssets>()
                 .Subscribe(ev =>
                 {