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}."
);
}