Monitor incoming trades

ArchiSteamFarm.OfficialPlugins.Monitoring/MonitoringPlugin.cs

@@ -22,6 +22,7 @@
 // limitations under the License.
 
 using System;
+using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.ComponentModel.DataAnnotations;
 using System.Composition;
@@ -35,6 +36,7 @@
 using ArchiSteamFarm.Plugins;
 using ArchiSteamFarm.Plugins.Interfaces;
 using ArchiSteamFarm.Steam;
+using ArchiSteamFarm.Steam.Exchange;
 using ArchiSteamFarm.Storage;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.Extensions.DependencyInjection;
@@ -45,7 +47,7 @@ namespace ArchiSteamFarm.OfficialPlugins.Monitoring;
 
 [Export(typeof(IPlugin))]
 [SuppressMessage("ReSharper", "MemberCanBeFileLocal")]
-internal sealed class MonitoringPlugin : OfficialPlugin, IDisposable, IOfficialGitHubPluginUpdates, IWebInterface, IWebServiceProvider {
+internal sealed class MonitoringPlugin : OfficialPlugin, IDisposable, IOfficialGitHubPluginUpdates, IWebInterface, IWebServiceProvider, IBotTradeOfferResults {
  private const string MeterName = SharedInfo.AssemblyName;
 
  private const string MetricNamePrefix = "asf";
@@ -77,10 +79,25 @@ internal sealed class MonitoringPlugin : OfficialPlugin, IDisposable, IOfficialG
  [Required]
  public override Version Version => typeof(MonitoringPlugin).Assembly.GetName().Version ?? throw new InvalidOperationException(nameof(Version));
 
+ private readonly ConcurrentDictionary<Bot, TradeStatistics> TradeStatistics = new();
+
  private Meter? Meter;
 
  public void Dispose() => Meter?.Dispose();
 
+ public Task OnBotTradeOfferResults(Bot bot, IReadOnlyCollection<ParseTradeResult> tradeResults) {
+ ArgumentNullException.ThrowIfNull(bot);
+ ArgumentNullException.ThrowIfNull(tradeResults);
+
+ TradeStatistics statistics = TradeStatistics.GetOrAdd(bot, static _ => new TradeStatistics());
+
+ foreach (ParseTradeResult result in tradeResults) {
+ statistics.Include(result);
+ }
+
+ return Task.CompletedTask;
+ }
+
  public void OnConfiguringEndpoints(IApplicationBuilder app) {
  ArgumentNullException.ThrowIfNull(app);
 
@@ -230,5 +247,53 @@ internal sealed class MonitoringPlugin : OfficialPlugin, IDisposable, IOfficialG
  },
  description: "Remaining games to redeem in background per bot"
  );
+
+ Meter.CreateObservableCounter(
+ $"{MetricNamePrefix}_bot_trades", () => TradeStatistics.SelectMany<KeyValuePair<Bot, TradeStatistics>, Measurement<uint>>(
+ static kv => [
+ new Measurement<uint>(
+ kv.Value.AcceptedOffers,
+ new KeyValuePair<string, object?>(TagNames.BotName, kv.Key.BotName),
+ new KeyValuePair<string, object?>(TagNames.SteamID, kv.Key.SteamID),
+ new KeyValuePair<string, object?>(TagNames.TradeOfferResult, "accepted")
+ ),
+ new Measurement<uint>(
+ kv.Value.RejectedOffers,
+ new KeyValuePair<string, object?>(TagNames.BotName, kv.Key.BotName),
+ new KeyValuePair<string, object?>(TagNames.SteamID, kv.Key.SteamID),
+ new KeyValuePair<string, object?>(TagNames.TradeOfferResult, "rejected")
+ ),
+ new Measurement<uint>(
+ kv.Value.IgnoredOffers,
+ new KeyValuePair<string, object?>(TagNames.BotName, kv.Key.BotName),
+ new KeyValuePair<string, object?>(TagNames.SteamID, kv.Key.SteamID),
+ new KeyValuePair<string, object?>(TagNames.TradeOfferResult, "ignored")
+ ),
+ new Measurement<uint>(
+ kv.Value.BlacklistedOffers,
+ new KeyValuePair<string, object?>(TagNames.BotName, kv.Key.BotName),
+ new KeyValuePair<string, object?>(TagNames.SteamID, kv.Key.SteamID),
+ new KeyValuePair<string, object?>(TagNames.TradeOfferResult, "blacklisted")
+ ),
+ new Measurement<uint>(
+ kv.Value.ConfirmedOffers,
+ new KeyValuePair<string, object?>(TagNames.BotName, kv.Key.BotName),
+ new KeyValuePair<string, object?>(TagNames.SteamID, kv.Key.SteamID),
+ new KeyValuePair<string, object?>(TagNames.TradeOfferResult, "confirmed")
+ )
+ ]
+ ),
+ description: "Trade offers per bot and action taken by ASF"
+ );
+
+ Meter.CreateObservableCounter(
+ $"{MetricNamePrefix}_bot_items_given", () => TradeStatistics.Select(static kv => new Measurement<uint>(kv.Value.ItemsGiven, new KeyValuePair<string, object?>(TagNames.BotName, kv.Key.BotName), new KeyValuePair<string, object?>(TagNames.SteamID, kv.Key.SteamID))),
+ description: "Items given per bot"
+ );
+
+ Meter.CreateObservableCounter(
+ $"{MetricNamePrefix}_bot_items_received", () => TradeStatistics.Select(static kv => new Measurement<uint>(kv.Value.ItemsReceived, new KeyValuePair<string, object?>(TagNames.BotName, kv.Key.BotName), new KeyValuePair<string, object?>(TagNames.SteamID, kv.Key.SteamID))),
+ description: "Items received per bot"
+ );
  }
 }

ArchiSteamFarm.OfficialPlugins.Monitoring/TagNames.cs

@@ -31,6 +31,7 @@ internal static class TagNames {
  internal const string OS = "operating_system";
  internal const string Runtime = "runtime";
  internal const string SteamID = "steamid";
+ internal const string TradeOfferResult = "result";
  internal const string Variant = "variant";
  internal const string Version = "version";
 }

ArchiSteamFarm.OfficialPlugins.Monitoring/TradeStatistics.cs

@@ -0,0 +1,76 @@
+// ----------------------------------------------------------------------------------------------
+// _ _ _ ____ _ _____
+// / \ _ __ ___ | |__ (_)/ ___| | |_ ___ __ _ _ __ ___ | ___|__ _ _ __ _ __ ___
+// / _ \ | '__|/ __|| '_ \ | |\___ \ | __|/ _ \ / _` || '_ ` _ \ | |_ / _` || '__|| '_ ` _ \
+// / ___ \ | | | (__ | | | || | ___) || |_| __/| (_| || | | | | || _|| (_| || | | | | | | |
+// /_/ \_\|_| \___||_| |_||_||____/ \__|\___| \__,_||_| |_| |_||_| \__,_||_| |_| |_| |_|
+// ----------------------------------------------------------------------------------------------
+// |
+// Copyright 2015-2024 Łukasz "JustArchi" Domeradzki
+// Contact: [email protected]
+// |
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+// |
+// http://www.apache.org/licenses/LICENSE-2.0
+// |
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+using System;
+using ArchiSteamFarm.Steam.Exchange;
+
+namespace ArchiSteamFarm.OfficialPlugins.Monitoring;
+
+internal sealed class TradeStatistics {
+ private readonly object Lock = new();
+
+ internal uint AcceptedOffers { get; private set; }
+
+ internal uint BlacklistedOffers { get; private set; }
+
+ internal uint ConfirmedOffers { get; private set; }
+
+ internal uint IgnoredOffers { get; private set; }
+
+ internal uint ItemsGiven { get; private set; }
+
+ internal uint ItemsReceived { get; private set; }
+
+ internal uint RejectedOffers { get; private set; }
+
+ internal void Include(ParseTradeResult result) {
+ ArgumentNullException.ThrowIfNull(result);
+
+ lock (Lock) {
+ switch (result.Result) {
+ case ParseTradeResult.EResult.Accepted when result.Confirmed:
+ ++ConfirmedOffers;
+ ItemsGiven += (uint) (result.ItemsToGive?.Count ?? 0);
+ ItemsReceived += (uint) (result.ItemsToReceive?.Count ?? 0);
+
+ goto case ParseTradeResult.EResult.Accepted;
+ case ParseTradeResult.EResult.Accepted:
+ ++AcceptedOffers;
+
+ break;
+ case ParseTradeResult.EResult.Rejected:
+ ++RejectedOffers;
+
+ break;
+ case ParseTradeResult.EResult.Blacklisted:
+ ++BlacklistedOffers;
+
+ break;
+ case ParseTradeResult.EResult.Ignored:
+ ++IgnoredOffers;
+
+ break;
+ }
+ }
+ }
+}