Cleanup

Author: artemiusgreat

Core/Core/Models/Criteria.cs

@@ -10,6 +10,11 @@ public record Criteria
     /// </summary>
     public int? Count { get; init; }
 
+    /// <summary>
+    /// Cache
+    /// </summary>
+    public bool Store { get; init; } = true;
+
     /// <summary>
     /// Start date
     /// </summary>

Core/Core/Services/MessageService.cs

@@ -16,20 +16,24 @@ public class MessageService
     /// <summary>
     /// Subscribe to messages
     /// </summary>
-    public virtual string Subscribe<T>(Func<T, Task> action, string name = null)
+    /// <typeparam name="T"></typeparam>
+    /// <param name="action"></param>
+    /// <param name="descriptor"></param>
+    public virtual string Subscribe<T>(Func<T, Task> action, string descriptor)
     {
       var group = typeof(T);
-      var descriptor = name ?? $"{Guid.NewGuid()}";
-
+      
       subscriptions[group] = subscriptions.Get(group) ?? new();
       subscriptions[group][descriptor] = o => action((T)o);
 
       return descriptor;
     }
 
     /// <summary>
-    /// Unsubscribe from messages
+    /// Unsubscribe
     /// </summary>
+    /// <typeparam name="T"></typeparam>
+    /// <param name="name"></param>
     public virtual void Unsubscribe<T>(string name)
     {
       if (subscriptions.TryGetValue(typeof(T), out var actions))
@@ -39,8 +43,10 @@ public virtual void Unsubscribe<T>(string name)
     }
 
     /// <summary>
-    /// Send message without state change
+    /// Send message
     /// </summary>
+    /// <typeparam name="T"></typeparam>
+    /// <param name="state"></param>
     public virtual async Task Send<T>(T state)
     {
       if (subscriptions.TryGetValue(typeof(T), out var actions))

Dashboard/Dashboard/Components/PositionsComponent.razor.cs

@@ -82,7 +82,7 @@ public virtual async void Update(IEnumerable<IGateway> adapters)
         Items = [.. positions.Select(o => new Row
         {
           Name = o?.Operation?.Instrument?.Name,
-          Group = o?.Operation?.Instrument?.Basis?.Name ?? o?.Operation?.Instrument?.Name,
+          Group = o.Descriptor ?? o?.Operation?.Instrument?.Basis?.Name ?? o?.Operation?.Instrument?.Name,
           Time = new DateTime(o.Operation.Time ?? DateTime.MinValue.Ticks),
           Side = o.Side,
           Size = o.Operation.Amount ?? 0,

Dashboard/Dashboard/Pages/BasePage.cs

@@ -34,8 +34,8 @@ protected override async Task OnAfterRenderAsync(bool setup)
       if (setup)
       {
         await OnView();
-        Messenger.Subscribe<Instrument>(OnViewUpdate);
-        Messenger.Subscribe<Instrument>(OnTradeUpdate);
+        Messenger.Subscribe<Instrument>(OnViewUpdate, nameof(OnViewUpdate));
+        Messenger.Subscribe<Instrument>(OnTradeUpdate, nameof(OnTradeUpdate));
         State.Subscribe(async state =>
         {
           if (state.Previous is SubscriptionEnum.None && state.Next is SubscriptionEnum.Progress)
@@ -58,7 +58,7 @@ protected override async Task OnAfterRenderAsync(bool setup)
     /// </summary>
     /// <param name="items"></param>
     /// <param name="index"></param>
-    protected virtual string GetDateByIndex(IList<IShape> items, int index)
+    protected virtual string GetDate(IList<IShape> items, int index)
     {
       var empty = index <= 0 ? items.FirstOrDefault()?.X : items.LastOrDefault()?.X;
       var stamp = (long)(items.ElementAtOrDefault(index)?.X ?? empty ?? DateTime.Now.Ticks);

Dashboard/Dashboard/Pages/Futures/Leads.razor.cs

@@ -35,10 +35,10 @@ protected override async Task OnView()
       await IndicatorsView.Create("Indicators");
       await PerformanceView.Create("Performance");
 
-      LeaderView.Composers.ForEach(o => o.ShowIndex = i => GetDateByIndex(o.Items, (int)i));
-      FollowerView.Composers.ForEach(o => o.ShowIndex = i => GetDateByIndex(o.Items, (int)i));
-      IndicatorsView.Composers.ForEach(o => o.ShowIndex = i => GetDateByIndex(o.Items, (int)i));
-      PerformanceView.Composers.ForEach(o => o.ShowIndex = i => GetDateByIndex(o.Items, (int)i));
+      LeaderView.Composers.ForEach(o => o.ShowIndex = i => GetDate(o.Items, (int)i));
+      FollowerView.Composers.ForEach(o => o.ShowIndex = i => GetDate(o.Items, (int)i));
+      IndicatorsView.Composers.ForEach(o => o.ShowIndex = i => GetDate(o.Items, (int)i));
+      PerformanceView.Composers.ForEach(o => o.ShowIndex = i => GetDate(o.Items, (int)i));
     }
 
     protected override Task OnTrade()

Dashboard/Dashboard/Pages/Gateways/InterBrokerDemo.razor.cs

@@ -80,8 +80,8 @@ protected override async Task OnTradeUpdate(Instrument instrument)
       var price = instrument.Price;
       var adapter = View.Adapters["Prime"];
       var account = adapter.Account;
-      var orders = (await adapter.GetOrders(default)).Data;
-      var positions = (await adapter.GetPositions(default)).Data;
+      var orders = (await adapter.GetOrders(new() { Store = false })).Data;
+      var positions = (await adapter.GetPositions(new() { Store = false })).Data;
 
       if (orders.Count is 0 && positions.Count is 0)
       {

Dashboard/Dashboard/Pages/Options/ShortConvexProtection.razor

@@ -0,0 +1,14 @@
+@inherits BasePage
+
+@page "/options/short-convex-protection"
+
+<ControlsComponent @ref="View">
+  <ChartsComponent Name="Prices" @ref="DataView" />
+  <ChartsComponent Name="Delta" @ref="DeltaView" />
+  <ChartsComponent Name="Variance" @ref="VarianceView" />
+  <ChartsComponent Name="Performance" @ref="PerformanceView" />
+  <OrdersComponent Name="Orders" @ref="OrdersView" />
+  <PositionsComponent Name="Positions" @ref="PositionsView" />
+  <TransactionsComponent Name="Transactions" @ref="TransactionsView" />
+  <StatementsComponent Name="Statements" Adapters="View.Adapters" @ref="StatementsView" />
+</ControlsComponent>