f = False
if f:
    from AlgorithmImports import *
from collections import deque
from typing import List
import configs as cfg
from indicators import GoldenCross, ATRBuySell

from datetime import timedelta

class EnergeticBlueDonkey(QCAlgorithm):

    def Initialize(self):
        self.SetStartDate(2020, 1, 1)
        self.SetEndDate(2021, 2, 5)
        self.SetCash(100000)
        self.symbol = self.AddEquity('SPY', Resolution.Minute).Symbol
        self.gc = GoldenCross(cfg.fast_sma_period, cfg.slow_sma_period)
        self.atrbs = ATRBuySell()

        option = self.AddOption(self.symbol)
        option.SetFilter(-20, +20, timedelta(25), timedelta(35))

        self.options : List[Symbol] = []

        # makes it so we emulate Daily Resolution on Minute Resolution
        # this is necessary since we are dealing with options, which only work on Minute or finer data
        self.curr_day = -1 

        self.SetWarmUp(cfg.slow_sma_period + 3, Resolution.Daily)

    def Print(self, msg:str):
        '''
        Just Debug, but with a check that debugging is enabled
        '''
        if cfg.debug:
            self.Debug(msg)

    def OnData(self, data:Slice):
        if self.curr_day == self.Time.day:
            return
        self.curr_day = self.Time.day

        self.ProcessOptions(data)

        if not data.Bars.ContainsKey(self.symbol):
            return

        self.gc.Update(data[self.symbol])
        self.atrbs.Update(data[self.symbol])

        if self.IsWarmingUp or not self.gc.IsReady or not self.atrbs.IsReady:
            return

        self.Plots()

    def Rebalance(self):
        self.Print('Rebalancing...')
        if self.atrbs.Value == 1:
            self.Print('TakeProfit')
            self.Liquidate()
        elif self.atrbs.Value == -1:
            self.Print('StopLoss')
            self.Liquidate()
            

    def ProcessOptions(self, data:Slice):
        self.Print('Processing options...')
        
        self.options = []
        for chain in data.OptionChains.Values:
            chain: OptionChain = chain
            contracts = [optionContract for optionContract in chain if cfg.option_filter(optionContract)]
            underlying_price = self.Securities[self.symbol].Price
            nearTheMoney = sorted(contracts, key=lambda contract: abs(contract.Strike - underlying_price))[:cfg.options_count]
            self.options.extend([contract.Symbol for contract in nearTheMoney])

        self.Print(f'Found {len(self.options)} options')

    def Plots(self):
        if not cfg.debug:
            return
        self.Plot('GoldenCross', 'Value', self.gc.Value)


    
                

f = False
if f:
    from AlgorithmImports import *

import configs as cfg
from collections import deque

class GoldenCross:
    def __init__(self, fast_period:int, slow_period:int):
        '''
        GoldenCross indicator
        .Value = 0 -> not golden cross or death cross
        .Value = 1 -> golden cross formed, entry not
        .Value = 2 -> entry formed after golden cross
        '''
        self.Value = 0

        self.fast_sma = SimpleMovingAverage(fast_period)
        self.slow_sma = SimpleMovingAverage(slow_period)

        # fast sma - slow sma
        self.sma_diffs = deque(maxlen=3)

    def dq_rdy(self, vals:deque):
        '''
        returns True iff the deque is has maxlen elements
        '''
        return len(vals) == vals.maxlen

    def Update(self, input:TradeBar):
        '''
        updates the Golden Cross indicator with a new bar of data
        returns self.IsReady
        '''
        self.Time = input.EndTime
        close = input.Close

        self.fast_sma.Update(self.Time, close)
        self.slow_sma.Update(self.Time, close)
        
        if not self.slow_sma.IsReady:
            # since the slow_sma takes more values, if its ready
            # the fast_sma must be ready
            return False

        self.sma_diffs.append(
            self.fast_sma.Current.Value - self.slow_sma.Current.Value  
        )
        
        if not self.dq_rdy(self.sma_diffs):
            return False 
        
        is_crossed = (
            self.sma_diffs[2] > 0 and self.sma_diffs[1] < 0 and self.sma_diffs[0] < 0
        ) # if the fast just recently rises above the slow

        is_death_crossed = (
            self.sma_diffs[2] < 0 and self.sma_diffs[1] > 0 and self.sma_diffs[0] > 0
        ) # if the fast just recently dips above the slow

        if is_death_crossed:
            self.Value = 0
        if self.Value <= 0 and is_crossed:
            self.Value = 1
        elif self.Value == 1 and cfg.entry_condition(close, self.fast_sma.Current.Value, self.slow_sma.Current.Value)   :
            self.Value = 2

        return True
    
    def Warmup(self):
        pass

    @property
    def IsReady(self):
        '''
        returns True iff the indicator is ready to use
        '''
        return self.dq_rdy(self.sma_diffs)

class ATRBuySell:
    def __init__(self):
        '''
        ATR Take Profit and Stop Loss
        .Value = -1 -> stop loss
        .Value = 0 -> neutral
        .Value = 1 -> take profit
        '''
        self.Value = 0

        self.atr = AverageTrueRange(cfg.atr_period)
        self.Close = 0
        self.StopLoss = 0
        self.TakeProfit = 0

    def Update(self, input:TradeBar):
        '''
        updates the ATRBuySell indicator with a new bar of data
        returns self.IsReady
        '''
        self.Time = input.EndTime
        self.Close = input.Close

        self.atr.Update(input)
        
        if not self.atr.IsReady:
            return False

        if input.Close > self.TakeProfit:
            self.Value = 1
        elif input.Close < self.StopLoss:
            self.Value = -1

        return True
    
    def SetLevels(self):
        '''
        Sets the TakeProfit and StopLoss levels, which are used to determine .Value
        '''
        self.Value = 0
        atr = self.atr.Current.Value
        self.TakeProfit = self.Close + 2 * atr
        self.StopLoss = self.Close - atr

    def Warmup(self):
        pass

    @property
    def IsReady(self):
        '''
        returns True iff the indicator is ready to use
        '''
        return self.atr.IsReady

f = False
if f: from AlgorithmImports import *

# disable below if you want to reduce logging/plotting
debug = True

#BEGIN GoldenCross configurations
fast_sma_period = 5
slow_sma_period = 20
assert(fast_sma_period < slow_sma_period)

# entry condition after cross has formed
def entry_condition(curr_price:float, fast_sma:float, slow_sma:float)->bool:
    '''
    return True iff entry condition is met 
    '''
    sma_avg = (fast_sma + slow_sma) / 2

    # 4% within average of two SMAs
    return abs(1-(curr_price / sma_avg)) < .04
#END GoldenCross configurations

#BEGIN Misc configs
atr_period = 14
#END Misc configs

#BEGIN Options configurations
options_count = 3 # how many of the top delta options

target_delta = .5

def option_filter(optionContract: OptionContract):
    '''
    return True iff contract is a call and Greek conditions are met
    '''
    if optionContract.Right != OptionRight.Call:
        return False
    elif optionContract.Greeks.Theta < -.05:
        return False
    elif (  # .45 < delta < .55
        optionContract.Greeks.Delta < target_delta * .9 
        or optionContract.Greeks.Delta > target_delta * 1.1
    ):
        return False
    return True
#END Options configurations