/*
* QUANTCONNECT.COM - Democratizing Finance, Empowering Individuals.
* Lean Algorithmic Trading Engine v2.0. Copyright 2014 QuantConnect Corporation.
*
* 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 System.Collections.Generic;
using QuantConnect.Data;
using QuantConnect.Data.Auxiliary;
using QuantConnect.Data.Market;
using QuantConnect.Interfaces;
namespace QuantConnect.Lean.Engine.DataFeeds.Enumerators
{
///
/// Event provider who will emit events
///
public class DividendEventProvider : ITradableDateEventProvider
{
// we set the price factor ratio when we encounter a dividend in the factor file
// and on the next trading day we use this data to produce the dividend instance
private decimal? _priceFactorRatio;
private decimal _referencePrice;
private IFactorFileProvider _factorFileProvider;
private MapFile _mapFile;
///
/// The current instance being used
///
protected CorporateFactorProvider FactorFile { get; private set; }
///
/// The associated configuration
///
protected SubscriptionDataConfig Config { get; private set; }
///
/// Initializes this instance
///
/// The
/// The factor file provider to use
/// The provider to use
/// Start date for the data request
public void Initialize(
SubscriptionDataConfig config,
IFactorFileProvider factorFileProvider,
IMapFileProvider mapFileProvider,
DateTime startTime)
{
Config = config;
_factorFileProvider = factorFileProvider;
_mapFile = mapFileProvider.ResolveMapFile(Config);
InitializeFactorFile();
}
///
/// Check for dividends and returns them
///
/// The new tradable day event arguments
/// New Dividend event if any
public virtual IEnumerable GetEvents(NewTradableDateEventArgs eventArgs)
{
if (Config.Symbol == eventArgs.Symbol
&& FactorFile != null
&& _mapFile.HasData(eventArgs.Date))
{
if (_priceFactorRatio != null)
{
if (_referencePrice == 0)
{
throw new InvalidOperationException($"Zero reference price for {Config.Symbol} dividend at {eventArgs.Date}");
}
var baseData = Dividend.Create(
Config.Symbol,
eventArgs.Date,
_referencePrice,
_priceFactorRatio.Value
);
// let the config know about it for normalization
Config.SumOfDividends += baseData.Distribution;
_priceFactorRatio = null;
_referencePrice = 0;
yield return baseData;
}
// check the factor file to see if we have a dividend event tomorrow
decimal priceFactorRatio;
decimal referencePrice;
if (FactorFile.HasDividendEventOnNextTradingDay(eventArgs.Date, out priceFactorRatio, out referencePrice))
{
_priceFactorRatio = priceFactorRatio;
_referencePrice = referencePrice;
}
}
}
///
/// Initializes the factor file to use
///
protected void InitializeFactorFile()
{
FactorFile = _factorFileProvider.Get(Config.Symbol) as CorporateFactorProvider;
}
}
}