class TokyoBreakout(QCAlgorithm):

    openingBar = None 
    
    def Initialize(self):
        
        self.SetStartDate(2018,6, 1)
        self.SetEndDate(2019,6,1)
        self.SetCash(1000)
        self.AddForex("USDJPY", Resolution.Hour, Market.Oanda)
        self.SetBrokerageModel(BrokerageName.OandaBrokerage)
        self.Consolidate("USDJPY", timedelta(hours=1), self.OnDataConsolidated)
        self.Schedule.On(self.DateRules.EveryDay("USDJPY"), self.TimeRules.At(13, 0), self.ClosePositions)
        
    def OnData(self, data):
        
        if self.Portfolio.Invested or self.openingBar is None:
            return
        
        if data["USDJPY"].Close > self.openingBar.High:
            self.MarketOrder("USDJPY", 1000)
            
        elif data["USDJPY"].Close < self.openingBar.Low:
            self.MarketOrder("USDJPY", -1000)
            
    def OnDataConsolidated(self, bar):
        
        if bar.Time.hour == 0 and bar.Time.minute == 0:
            self.openingBar = bar

    def ClosePositions(self):
        self.openingBar = None
        self.Liquidate("USDJPY")