from AlgorithmImports import *

class VirtualYellowGiraffe(QCAlgorithm):

    def Initialize(self):
        self.SetStartDate(2018, 1, 17)
        self.SetEndDate(2023, 12, 17)
        self.SetCash(50000) 
        self.equity = self.AddEquity('ADBE', Resolution.Minute)
    
        self.InitOptionsAndGreeks(self.equity)

        self.delta = 0.25
        self.days_to_exp = 40

        self.has_stock = 0
        self.has_options = 0

        self.SetBenchmark ('ADBE')
        

    ## Initialize Options settings, chain filters, pricing models, etc
    ## ====================================================================
    def InitOptionsAndGreeks(self, theEquity ):

        ## 1. Specify the data normalization mode (must be 'Raw' for options)
        theEquity.SetDataNormalizationMode(DataNormalizationMode.Raw)
        
        ## 2. Set Warmup period of at leasr 30 days
        self.SetWarmup(30, Resolution.Daily)

        ## 3. Set the security initializer to call SetMarketPrice
        self.SetSecurityInitializer(lambda x: x.SetMarketPrice(self.GetLastKnownPrice(x)))

        ## 4. Subscribe to the option feed for the symbol
        theOptionSubscription = self.AddOption(theEquity.Symbol)

        ## 5. set the pricing model, to calculate Greeks and volatility
        theOptionSubscription.PriceModel = OptionPriceModels.CrankNicolsonFD()  # both European & American, automatically
                
        ## 6. Set the function to filter out strikes and expiry dates from the option chain
        theOptionSubscription.SetFilter(self.OptionsFilterFunction)

    def OnData(self, data):

        #if not self.Portfolio.Invested:
        #    self.has_stock = 0
        #    self.has_options = 0
        
        ## If we're done warming up, and not invested, Sell a put. 
        if (not self.IsWarmingUp): 
            if (self.has_stock == 0) and (self.has_options == 0):
                self.SellAnOTMPut()
                
            elif (self.has_stock == 1) and (self.has_options == 0):
                self.SellAnOTMCall()
                

      
    ## Sell an OTM Put Option.
    ## Use Delta to select a put contract to sell
    ## ==================================================================
    def SellAnOTMPut(self):
        
        ## Sell a 20 delta put expiring in 2 weeks (14 days)
        putContract = self.SelectContractByDelta(self.equity.Symbol, self.delta, self.days_to_exp, OptionRight.Put)
        
        ## construct an order message -- good for debugging and order rrecords

        if self.CurrentSlice.ContainsKey(self.equity.Symbol):
            orderMessage = f"Stock @ ${self.CurrentSlice[self.equity.Symbol].Close} |" + \
                        f"Sell PUT {putContract.Symbol} "+ \
                        f"({round(putContract.Greeks.Delta,2)} Delta)"
                        
            self.Debug(f"{self.Time} {orderMessage}")
            self.Order(putContract.Symbol, -1, False, orderMessage  )   
           
   
    def SellAnOTMCall(self):
        
        ## Sell a 20 delta call expiring in 2 weeks (14 days)
        callContract = self.SelectContractByDelta(self.equity.Symbol, self.delta, self.days_to_exp, OptionRight.Call)
        
        ## construct an order message -- good for debugging and order rrecords

        if self.CurrentSlice.ContainsKey(self.equity.Symbol):
            orderMessage = f"Stock @ ${self.CurrentSlice[self.equity.Symbol].Close} |" + \
                        f"Sell CALL {callContract.Symbol} "+ \
                        f"({round(callContract.Greeks.Delta,2)} Delta)"
                        
            self.Debug(f"{self.Time} {orderMessage}")
            self.Order(callContract.Symbol, -1, False, orderMessage  )   
           
    ## Get an options contract that matches the specified criteria:
    ## Underlying symbol, delta, days till expiration, Option right (put or call)
    ## ============================================================================
    def SelectContractByDelta(self, symbolArg, strikeDeltaArg, expiryDTE, optionRightArg= OptionRight.Call):

        canonicalSymbol = self.AddOption(symbolArg)
        if (self.CurrentSlice.OptionChains.values().__len__()>0):
            theOptionChain  = self.CurrentSlice.OptionChains[canonicalSymbol.Symbol]
            theExpiryDate   = self.Time + timedelta(days=expiryDTE)
            
            ## Filter the Call/Put options contracts
            filteredContracts = [x for x in theOptionChain if x.Right == optionRightArg] 

            ## Sort the contracts according to their closeness to our desired expiry
            contractsSortedByExpiration = sorted(filteredContracts, key=lambda p: abs(p.Expiry - theExpiryDate), reverse=False)
            closestExpirationDate = contractsSortedByExpiration[0].Expiry                                        
                                                
            ## Get all contracts for selected expiration
            contractsMatchingExpiryDTE = [contract for contract in contractsSortedByExpiration if contract.Expiry == closestExpirationDate]
        
            ## Get the contract with the contract with the closest delta
            closestContract = min(contractsMatchingExpiryDTE, key=lambda x: abs(abs(x.Greeks.Delta)-strikeDeltaArg))

            return closestContract

    ## The options filter function.
    ## Filter the options chain so we only have relevant strikes & expiration dates. 
    ## =============================================================================
    def OptionsFilterFunction(self, optionsContractsChain):

        strikeCount  = 50 # no of strikes around underyling price => for universe selection
        minExpiryDTE = 30  # min num of days to expiration => for uni selection
        maxExpiryDTE = 50  # max num of days to expiration => for uni selection
        
        return optionsContractsChain.IncludeWeeklys()\
                                    .Strikes(-strikeCount, strikeCount)\
                                    .Expiration(timedelta(minExpiryDTE), timedelta(maxExpiryDTE))
    
    def OnOrderEvent(self, orderEvent):
        self.Debug(str(orderEvent))
        if orderEvent.Status == 3: #filled
            if (orderEvent.Symbol.Value == 'ADBE'): #we have the stock
                self.has_options = 0
                if (orderEvent.FillQuantity > 0): #buying stock, assigned a PUT
                    self.has_stock = 1
                elif (orderEvent.FillQuantity < 0): #selling stock, assigned a CALL        
                    self.has_stock = 0
            elif (orderEvent.Symbol.Value != 'ADBE'): #we have an option
                if orderEvent.IsAssignment or orderEvent.Message[0:3] == 'OTM': #assignment or option expired worthless
                    self.has_options = 0
                else:
                    self.has_options = 1
            


        #if orderEvent.IsAssignment != True and orderEvent.Status == 3 and orderEvent.Symbol.Value != 'ADBE':
        #    self.has_options = 1
        
    def OnAssignmentOrderEvent(self, assignmentEvent):
        #if assignmentEvent.Status == 3:
        #    if (assignmentEvent.FillQuantity > 0) and (assignmentEvent.Symbol.Value == 'ADBE'): #buying, assigned a PUT
        #        self.has_options = 0
        #        self.has_stock = 1
        #    elif (assignmentEvent.FillQuantity < 0) and (assignmentEvent.Symbol.Value == 'ADBE'): #selling, assigned a CALL
        #        self.has_options = 0
        #        self.has_stock = 0
        self.Debug(str(assignmentEvent))