auto updating files

Author: unknown

CoinCap.py

@@ -0,0 +1,28 @@
+import requests
+#@Author Ethen Pociask
+#DATA API REQUEST CLASS
+class CoinCap:
+
+	#TAKES COIN NAME AS PARAM
+	def __init__(self, asset):
+
+		self.asset = asset
+		self.APIURL = "http://api.coincap.io/v2/assets/" + self.asset
+
+	# Returns json data from api
+	def getData(self):
+
+
+		PARAMS = {'limit': 1}
+		try:
+			r = requests.get(url = self.APIURL, params = PARAMS)
+
+		except:
+			self.getData()
+
+		l = []
+
+		dic = {}
+		data = r.json()
+
+		return data

Driver.py

@@ -0,0 +1,15 @@
+from Schedule import *
+import multiprocessing as mp
+
+
+
+def main():
+
+	pool = mp.Pool(mp.cpu_count())
+
+
+	pool.map(Schedule, ["ethereum", "bitcoin", "ripple", "litecoin"])
+
+
+if __name__ == "__main__":
+	main()

IndicatorDataHandler.py

@@ -0,0 +1,66 @@
+#!/usr/bin/python
+import psycopg2
+from config import config
+from datetime import datetime
+import time, sys, json, datetime
+from CoinCap import CoinCap
+import keyboard
+from Indicators import *
+
+
+TABLE_NAME = "bitcoin_indicator_data"
+
+class IndicatorDataWriter:
+
+  def __init__(self, coin):
+    self.coin = coin
+    self.TABLE_NAME = "{}_indicator_data".format(self.coin)
+
+  # Returns query string to insert data into db
+
+
+  def runDataInsertions(self, cursor):
+    try:
+      		
+      print("Time: {} Price: {} 24 hr Volume: {} Market Cap: {}".format(datetime.datetime.now(), price, dayVolume, marketCap))
+      insertQuery = self.generateQuery(price, marketCap, dayVolume)
+      cursor.execute(insertQuery)
+
+    except(Exception) as error:
+      print("ERROR INSERTING DATA: ", error)
+
+  # Connects to the db via psycopg2 and inserts data
+  def connect(self):
+    """ Connect to PGSQL server """
+    conn = None
+
+    try:
+      params = config()
+      print("Connecting to postgres database...")
+      conn = psycopg2.connect(user = "postgres",
+                                  password = "1Derekdad1",
+                                  host = "localhost",
+                                  port = "5433",
+                                  database = "coindata")
+
+
+      # create a cursor
+      cur = conn.cursor()
+
+      # Generate and execute insertion query
+      print("Starting data collection... Press q to quit")
+      while(True):
+        if(keyboard.is_pressed('q')):
+          print("Stopping data collection.")
+          break
+        self.runDataInsertions(cur)
+        conn.commit() # Commits changes to db
+
+      cur.close() # Closes communication with db
+    except(Exception, psycopg2.DatabaseError) as error:
+      print("ERROR: ", error)
+    finally:
+      if conn is not None:
+        conn.close()
+        print('Database connection closed.')
+

IndicatorDataWriter.py

@@ -0,0 +1,81 @@
+import psycopg2
+from config import config
+from datetime import datetime
+import time, sys, json, datetime
+from Time import *
+from SMA import *
+
+class IndicatorDataWriter:
+
+  def __init__(self, coin, timeLength):
+    self.coin = coin
+    self.timeLength = timeLength
+    self.INDICATOR_TABLE_NAME = "{}_indicators".format(self.coin)
+    self.PRICE_TABLE_NAME = "{}_price_data".format(self.coin)
+    self.time = Time()
+    self.sma = SMA()
+
+  #SELECTS TIME_STAMP & PRICE DATA FROM COIN_PRICE_DATA
+  def SelectQuery(self):
+
+    self.timeStep = self.time.calculateTime(self.timeLength)
+    self.timeRef = self.time.calculateRef(self.timeLength)
+
+    return "SELECT time_stamp, price FROM {} ORDER BY time_stamp DESC LIMIT {};".format(self.PRICE_TABLE_NAME, self.timeStep)
+
+
+  def createTableQuery(self):
+    return "CREATE TABLE {} (time_stamp timestamp without time zone DEFAULT CURRENT_TIMESTAMP PRIMARY KEY NOT NULL, sma_1 numeric , sma_5 numeric , sma_10 numeric , sma_30 numeric , sma_60 numeric , sma_180 numeric , sma_360 numeric , sma_720 numeric , sma_1440 numeric );".format(self.INDICATOR_TABLE_NAME)
+  #INSERTS CALCULATED SMA VALUE INTO INDICATOR TABLE
+  def insertionQuery(self, data):
+
+      return "INSERT INTO {} (sma_{}) VALUES ({});".format(self.INDICATOR_TABLE_NAME, self.timeRef, data)
+
+  def runDataCollection(self, cursor):
+    try:
+      
+      Query = self.SelectQuery()
+      cursor.execute(Query)
+      x = cursor.fetchall()
+      count = 0
+      for i in x:
+        i = str(i)
+        x[count] = float((i[i.find("Decimal")+9 : len(i)-3]))
+        count+=1
+      print(x)
+      cursor.execute(self.insertionQuery(self.sma.calculateSMA(x)))
+      return None
+    except(Exception) as error:
+      print("ERROR COLLECTING/INSERTING DATA: ", error)
+      return error
+
+ # Connects to the db via psycopg2 and inserts data
+  def connect(self):
+    """ Connect to PGSQL server """
+    conn = None
+
+    try:
+      params = config()
+      print("Connecting to postgres database...")
+      conn = psycopg2.connect(**params)
+      # create a cursor
+      cur = conn.cursor()
+
+      # Generate and execute insertion quer
+      err = self.runDataCollection(cur)
+      conn.commit() # Commits changes to db
+      cur.close() # Closes communication with db
+    except(Exception, psycopg2.DatabaseError) as error:
+      print("ERROR: ", error)
+    finally:
+      if err != None:
+        curr = conn.cursor()
+        curr.execute(self.createTableQuery())
+        conn.commit()
+        conn.close()
+        self.connect()
+
+      cur.close()
+      print('Database connection closed.')
+
+

IndicatorHandler.py

@@ -0,0 +1,66 @@
+#!/usr/bin/python
+import psycopg2
+from config import config
+from datetime import datetime
+import time, sys, json, datetime
+from CoinCap import CoinCap
+import keyboard
+from Indicators import *
+
+
+TABLE_NAME = "bitcoin_indicator_data"
+
+class IndicatorDataWriter:
+
+  def __init__(self, coin):
+    self.coin = coin
+    self.TABLE_NAME = "{}_indicator_data".format(self.coin)
+
+  # Returns query string to insert data into db
+
+
+  def runDataInsertions(self, cursor):
+    try:
+      		
+      print("Time: {} Price: {} 24 hr Volume: {} Market Cap: {}".format(datetime.datetime.now(), price, dayVolume, marketCap))
+      insertQuery = self.generateQuery(price, marketCap, dayVolume)
+      cursor.execute(insertQuery)
+
+    except(Exception) as error:
+      print("ERROR INSERTING DATA: ", error)
+
+  # Connects to the db via psycopg2 and inserts data
+  def connect(self):
+    """ Connect to PGSQL server """
+    conn = None
+
+    try:
+      params = config()
+      print("Connecting to postgres database...")
+      conn = psycopg2.connect(user = "postgres",
+                                  password = "1Derekdad1",
+                                  host = "localhost",
+                                  port = "5433",
+                                  database = "coindata")
+
+
+      # create a cursor
+      cur = conn.cursor()
+
+      # Generate and execute insertion query
+      print("Starting data collection... Press q to quit")
+      while(True):
+        if(keyboard.is_pressed('q')):
+          print("Stopping data collection.")
+          break
+        self.runDataInsertions(cur)
+        conn.commit() # Commits changes to db
+
+      cur.close() # Closes communication with db
+    except(Exception, psycopg2.DatabaseError) as error:
+      print("ERROR: ", error)
+    finally:
+      if conn is not None:
+        conn.close()
+        print('Database connection closed.')
+

Indicators/EMA.py

@@ -0,0 +1,29 @@
+
+class EMA:
+
+	def __init__(self):
+		pass
+
+	def calculate(self, priceList, period):
+		
+		priceList = array(priceList)
+		ema = []
+		j = 1
+
+		#CALCULATES SMA FIRST
+		sma = sum(priceList[:period]) / period
+
+		multiplier = 2 / float(1 + n)
+
+
+		ema.append(sma)
+		# CURRENT EMA = ((Price(Current) - EMA(Previous)) * Multiplier) + EMA(Previous)
+		ema.append((s[j] - sma) * multiplier + sma)
+
+		for i in s[n + 1:]:
+			temp = ( (i - ema[j]) * multiplier) + ema[j]
+			j++
+			ema.append(temp)
+
+
+		return ema

Indicators/RSI.py

@@ -0,0 +1,20 @@
+import pandas as pd
+import numpy as np
+class RSI:
+
+	def __init__(self):
+		pass
+
+	def calculate(self, series, period):
+		delta = series.diff().dropna()
+        u = delta * 0
+    	d = u.copy()
+    	u[delta > 0] = delta[delta > 0]
+    	d[delta < 0] = -delta[delta < 0]
+    	u[u.index[period-1]] = np.mean( u[:period] ) #first value is sum of avg gains
+    	u = u.drop(u.index[:(period-1)])
+    	d[d.index[period-1]] = np.mean( d[:period] ) #first value is sum of avg losses
+    	d = d.drop(d.index[:(period-1)])
+    	rs = pd.stats.moments.ewma(u, com=period-1, adjust=False) / \
+        pd.stats.moments.ewma(d, com=period-1, adjust=False)
+    	return 100 - 100 / (1 + rs)

Indicators/SMA.py

@@ -0,0 +1,21 @@
+#Property of TrendSellers LLC 
+#@author Ethen Pociask
+
+class SMA:
+
+	def __init__(self):
+		pass
+
+	def calculateSMA(self,  priceSet):
+		priceTotal = 0
+
+		for price in priceSet:
+			priceTotal = priceTotal + float(price)
+
+
+
+		return priceTotal/len(priceSet)
+
+
+
+	

Indicators/Time.py

@@ -0,0 +1,28 @@
+class Time:
+
+	def __init__(self):
+			pass
+
+	def calculateTime(self, timePeriod):
+
+		step, ref = 0
+		if timePeriod == "one-minute":
+			step = 12
+			ref = 1
+
+		elif timePeriod == "five-minute":
+			step = 60
+			ref = 5
+		elif timePeriod == "ten-minute":
+			step = 120
+			ref = 10
+		elif timePeriod == "thirty-minute":
+			step = 360
+			ref = 30
+		elif timePeriod == "one-hour":
+			step = 720
+			ref = 60
+
+		return step, ref
+
+