from clr import AddReference
AddReference("System.Core")
AddReference("QuantConnect.Common")
AddReference("QuantConnect.Algorithm")

from System import *
from QuantConnect import *
from QuantConnect.Algorithm import QCAlgorithm
from QuantConnect.Data import SubscriptionDataSource
from QuantConnect.Python import PythonData

from datetime import datetime, timedelta
import json

class ExuberAlgorithm(QCAlgorithm):

    def Initialize(self):
        self.SetStartDate(2015, 5, 1)
        self.symbol = self.AddData(Radf, "RADFDATA", Resolution.Hour).Symbol

    def OnData(self, data):
        if data.ContainsKey(self.symbol):
            self.Quit(f'Data Received. Value: {data[self.symbol].Value}. adf: {data[self.symbol].GetProperty("adf")}')

class Radf(PythonData):

    def GetSource(self, config, date, isLive):
        source = "http://207.154.227.4/alphar/radf_point?symbols=AAPL&date=2021-01-01&window=100&price_lag=1&use_log=1&dl=1"
        return SubscriptionDataSource(source, SubscriptionTransportMedium.RemoteFile)


    def Reader(self, config, line, date, isLive):
        index = Radf()
        index.Symbol = config.Symbol
        
        line = json.loads(line)[0]
        index.Time = datetime.strptime(line['datetime'], '%Y-%m-%d %H:%M:%S')
        index.Value = 1.0  # Random value
        index.SetProperty('adf', line['adf'])
        
        
        return index