diff --git a/QuantConnect.DataBento.Tests/DataBentoDataProviderHistoryTests.cs b/QuantConnect.DataBento.Tests/DataBentoDataProviderHistoryTests.cs index be19cbd..f0722e5 100644 --- a/QuantConnect.DataBento.Tests/DataBentoDataProviderHistoryTests.cs +++ b/QuantConnect.DataBento.Tests/DataBentoDataProviderHistoryTests.cs @@ -27,12 +27,12 @@ namespace QuantConnect.Lean.DataSource.DataBento.Tests; [TestFixture] public class DataBentoDataProviderHistoryTests { - private DataBentoProvider _historyDataProvider; + private DataBentoDataProvider _historyDataProvider; [SetUp] public void SetUp() { - _historyDataProvider = new DataBentoProvider(); + _historyDataProvider = new DataBentoDataProvider(); } [TearDown] diff --git a/QuantConnect.DataBento.Tests/DataBentoDataQueueHandlerTests.cs b/QuantConnect.DataBento.Tests/DataBentoDataQueueHandlerTests.cs index dd57c25..0e0cbbb 100644 --- a/QuantConnect.DataBento.Tests/DataBentoDataQueueHandlerTests.cs +++ b/QuantConnect.DataBento.Tests/DataBentoDataQueueHandlerTests.cs @@ -33,7 +33,7 @@ namespace QuantConnect.Lean.DataSource.DataBento.Tests; [TestFixture] public class DataBentoDataQueueHandlerTests { - private DataBentoProvider _dataProvider; + private DataBentoDataProvider _dataProvider; private CancellationTokenSource _cancellationTokenSource; [SetUp] diff --git a/QuantConnect.DataBento.Tests/DataBentoHistoryProviderTests.cs b/QuantConnect.DataBento.Tests/DataBentoHistoryProviderTests.cs index 1796688..894025b 100644 --- a/QuantConnect.DataBento.Tests/DataBentoHistoryProviderTests.cs +++ b/QuantConnect.DataBento.Tests/DataBentoHistoryProviderTests.cs @@ -30,7 +30,7 @@ namespace QuantConnect.Lean.DataSource.DataBento.Tests; [TestFixture] public class DataBentoHistoryProviderTests { - private DataBentoProvider _historyDataProvider; + private DataBentoDataProvider _historyDataProvider; [OneTimeSetUp] public void OneTimeSetUp() @@ -42,7 +42,7 @@ public void OneTimeSetUp() Assert.Fail("DataBento API key is not set. Please set 'databento-api-key' in the configuration to run these tests."); } - _historyDataProvider = new DataBentoProvider(apiKey); + _historyDataProvider = new DataBentoDataProvider(apiKey); } [OneTimeTearDown] diff --git a/QuantConnect.DataBento/DataBentoDataDownloader.cs b/QuantConnect.DataBento/DataBentoDataDownloader.cs index 9d78ce2..a944024 100644 --- a/QuantConnect.DataBento/DataBentoDataDownloader.cs +++ b/QuantConnect.DataBento/DataBentoDataDownloader.cs @@ -29,7 +29,7 @@ public class DataBentoDataDownloader : IDataDownloader, IDisposable /// /// Provides access to historical market data via the DataBento service. /// - private readonly DataBentoProvider _historyProvider; + private readonly DataBentoDataProvider _historyProvider; /// /// Provides exchange trading hours and market-specific time zone information. @@ -52,7 +52,7 @@ public DataBentoDataDownloader() /// The DataBento API key. public DataBentoDataDownloader(string apiKey) { - _historyProvider = new DataBentoProvider(apiKey); + _historyProvider = new DataBentoDataProvider(apiKey); _marketHoursDatabase = MarketHoursDatabase.FromDataFolder(); } diff --git a/QuantConnect.DataBento/DataBentoDataProvider.cs b/QuantConnect.DataBento/DataBentoDataProvider.cs index ec76052..a6c0510 100644 --- a/QuantConnect.DataBento/DataBentoDataProvider.cs +++ b/QuantConnect.DataBento/DataBentoDataProvider.cs @@ -42,7 +42,7 @@ namespace QuantConnect.Lean.DataSource.DataBento; /// Handles Subscribing, Unsubscribing, and fetching historical data from DataBento. /// It will handle if a symbol is subscribable and will log errors if it is not. /// -public partial class DataBentoProvider : IDataQueueHandler +public partial class DataBentoDataProvider : IDataQueueHandler { private HistoricalAPIClient _historicalApiClient; @@ -72,14 +72,14 @@ public partial class DataBentoProvider : IDataQueueHandler /// - /// Initializes a new instance of the DataBentoProvider + /// Initializes a new instance of the DataBentoDataProvider /// - public DataBentoProvider() + public DataBentoDataProvider() : this(Config.Get("databento-api-key")) { } - public DataBentoProvider(string apiKey) + public DataBentoDataProvider(string apiKey) { if (string.IsNullOrWhiteSpace(apiKey)) { @@ -103,7 +103,7 @@ private void Initialize(string apiKey) if (_aggregator == null) { var aggregatorName = Config.Get("data-aggregator", "QuantConnect.Lean.Engine.DataFeeds.AggregationManager"); - Log.Trace($"{nameof(DataBentoProvider)}.{nameof(Initialize)}: found no data aggregator instance, creating {aggregatorName}"); + Log.Trace($"{nameof(DataBentoDataProvider)}.{nameof(Initialize)}: found no data aggregator instance, creating {aggregatorName}"); _aggregator = Composer.Instance.GetExportedValueByTypeName(aggregatorName, forceTypeNameOnExisting: false); } @@ -127,13 +127,13 @@ private void Initialize(string apiKey) private void OnConnectionLost(object? _, ConnectionLostEventArgs cle) { - Log.Trace($"{nameof(DataBentoProvider)}.{nameof(OnConnectionLost)}: The connection was lost. Starting ReSubscription process"); + Log.Trace($"{nameof(DataBentoDataProvider)}.{nameof(OnConnectionLost)}: The connection was lost. Starting ReSubscription process"); var symbols = _levelOneServiceManager.GetSubscribedSymbols(); Subscribe(symbols); - Log.Trace($"{nameof(DataBentoProvider)}.{nameof(OnConnectionLost)}: Re-subscription completed successfully for {_levelOneServiceManager.Count} symbol(s)."); + Log.Trace($"{nameof(DataBentoDataProvider)}.{nameof(OnConnectionLost)}: Re-subscription completed successfully for {_levelOneServiceManager.Count} symbol(s)."); } private void OnSymbolMappingConfirmation(object? _, SymbolMappingConfirmationEventArgs smce) diff --git a/QuantConnect.DataBento/DataBentoHistoryProivder.cs b/QuantConnect.DataBento/DataBentoHistoryProivder.cs index e9c6095..e5afae0 100644 --- a/QuantConnect.DataBento/DataBentoHistoryProivder.cs +++ b/QuantConnect.DataBento/DataBentoHistoryProivder.cs @@ -28,7 +28,7 @@ namespace QuantConnect.Lean.DataSource.DataBento; /// Implements a history provider for DataBento historical data. /// Uses consolidators to produce the requested resolution when necessary. /// -public partial class DataBentoProvider : MappedSynchronizingHistoryProvider +public partial class DataBentoDataProvider : MappedSynchronizingHistoryProvider { private static int _dataPointCount; @@ -72,7 +72,7 @@ public override void Initialize(HistoryProviderInitializeParameters parameters) if (!_invalidSecurityTypeWarningFired) { _invalidSecurityTypeWarningFired = true; - Log.Trace($"{nameof(DataBentoProvider)}.{nameof(GetHistory)}:" + + Log.Trace($"{nameof(DataBentoDataProvider)}.{nameof(GetHistory)}:" + $"History request not supported for symbol '{historyRequest.Symbol}' (SecurityType: {historyRequest.Symbol.SecurityType}, Canonical: {historyRequest.Symbol.IsCanonical()})."); } return null; @@ -83,7 +83,7 @@ public override void Initialize(HistoryProviderInitializeParameters parameters) if (!_invalidStartTimeErrorFired) { _invalidStartTimeErrorFired = true; - Log.Error($"{nameof(DataBentoProvider)}.{nameof(GetHistory)}: Invalid date range: the start date must be earlier than the end date."); + Log.Error($"{nameof(DataBentoDataProvider)}.{nameof(GetHistory)}: Invalid date range: the start date must be earlier than the end date."); } return null; } @@ -93,7 +93,7 @@ public override void Initialize(HistoryProviderInitializeParameters parameters) if (!_dataBentoDatasetErrorFired) { _dataBentoDatasetErrorFired = true; - Log.Error($"{nameof(DataBentoProvider)}.{nameof(GetHistory)}: " + + Log.Error($"{nameof(DataBentoDataProvider)}.{nameof(GetHistory)}: " + $"DataBento dataset not found for symbol '{historyRequest.Symbol.Value}, Market = {historyRequest.Symbol.ID.Market}." ); }