namespace QuantConnect.Algorithm.CSharp {
	
	using QuantConnect.Data.Market;
	using QuantConnect.Securities;
	using QuantConnect.Securities.Future;
	
    public class FuturesTrader : QCAlgorithm {

		private String[] futureSymbols = new[] {"ES", "ZB", "CL", "GC"};
		private Dictionary<Symbol, FuturesChain> contract_chains = new Dictionary<Symbol, FuturesChain>();
		private Dictionary<Symbol, Future> contracts = new Dictionary<Symbol, Future>();
		private bool contractsChecked = false;

        public override void Initialize() {
            SetStartDate(2019, 1, 1);  //Set Start Date
            SetEndDate(2019, 10, 1);  //Set Start Date
            SetCash(100000);             //Set Strategy Cash
            
			SetWarmUp(TimeSpan.FromDays(5));
        	SetTimeZone("America/Los_Angeles");
      
    		foreach (var futureSymbol in futureSymbols) {
    			Debug($"Registering {futureSymbol}");
				Future fut = AddFuture(futureSymbol, Resolution.Minute);
            	fut.SetFilter(universe => universe.FrontMonth());
    		}
        }

        public override void OnData(Slice data) {
            // if (!Portfolio.Invested)
            // {
            //    SetHoldings(_spy, 1);
            //    Debug("Purchased Stock");
            //}
        }
    }
}

namespace QuantConnect.Algorithm.Framework.Selection {

	public class FuturesUniverseSelectionModel : FutureUniverseSelectionModel{
		public FuturesUniverseSelectionModel(Func<DateTime, IEnumerable<Symbol>> futureChainSymbolSelector)
			:base(TimeSpan.FromDays(1), futureChainSymbolSelector){
			}
		public FutureFilterUniverse filter(FutureFilterUniverse filter){
			return filter.Expiration(TimeSpan.FromDays(0), TimeSpan.FromDays(90))
                      .OnlyApplyFilterAtMarketOpen();
		}
	}

}