cryptoTickerGraph/main.py at main · Shaun-Harrison/cryptoTickerGraph · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
import numpy as np
import requests
import os
import dateparser
import pytz
import json
import random
import time
import itertools
from datetime import datetime, timezone, timedelta
from urllib.error import HTTPError, URLError
from urllib.request import Request, urlopen

from config.builder import Builder
from config.config import config
from logs import logger
from presentation.observer import Observable

DATA_SLICE_DAYS = 1
DATETIME_FORMAT = "%Y-%m-%dT%H:%M"
CRYPTO = ['BTC','ETH','SOL','DOT','OMI','ATOM','MOON']

def get_dummy_data():
    logger.info('Generating dummy data')

def fetch_prices(token):
    try:
        days_ago = DATA_SLICE_DAYS
        endtime = int(time.time())
        starttime = endtime - 60*60*24*days_ago
        starttimeseconds = starttime
        endtimeseconds = endtime
        if token == "BTC":
            tokenname = "bitcoin"
        elif token == "ETH":
            tokenname = "ethereum"
        elif token == "SOL":
            tokenname = "solana"
        elif token == "DOT":
            tokenname = "polkadot"
        elif token == "OMI":
            tokenname = "ecomi"
        elif token == "ATOM":
            tokenname = "cosmos"
        elif token == "MOON":
            tokenname = "moon"
        else:
            print("Unknown Token, please add to if statement")
            exit()
        geckourlhistorical = "https://api.coingecko.com/api/v3/coins/"+str(tokenname)+"/market_chart/range?vs_currency=usd&from="+str(starttimeseconds)+"&to="+str(endtimeseconds)
#       logger.info(geckourlhistorical)
        rawtimeseries = requests.get(geckourlhistorical).json()
#       logger.info(str(rawtimeseries))
        timeseriesarray = rawtimeseries['prices']
        prices = []
        length=len (timeseriesarray)
        i=0
        while i < length:
            prices.append(timeseriesarray[i][1])
            i+=1
        # Get 24H Change
        geckourl24h = "https://api.coingecko.com/api/v3/simple/price?ids=" +str(tokenname)+"&vs_currencies=usd&include_24hr_change=true"
#       logger.info(geckourl24h)
        raw24h = requests.get(geckourl24h).json()
        actual24h = raw24h[str(tokenname)]['usd_24h_change']
        liveprice = raw24h[str(tokenname)]['usd']

        # Add values to list
        prices.append(liveprice)
        prices.append(actual24h)
        prices.append(token)
        return prices
    except:
        logger.info("Unexpected error")
        return ("null")
def main():
    logger.info('Initialize')

    data_sink = Observable()
    builder = Builder(config)
    builder.bind(data_sink)

    while True:
        for coin in itertools.cycle(CRYPTO):
            try:
                prices = fetch_prices(coin)
                if prices != "null":
                    data_sink.update_observers(prices)
                    time.sleep(300)
            except (HTTPError, URLError) as e:
                logger.info(str(e))
                time.sleep(5)
            except KeyboardInterrupt:
                logger.info('Exit')
                data_sink.close()
                exit()

if __name__ == "__main__":
    main()