-
Notifications
You must be signed in to change notification settings - Fork 0
/
litecoin.py
154 lines (138 loc) · 6.77 KB
/
litecoin.py
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
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
from config import *
from discord_webhook import DiscordWebhook
from discord_webhook import DiscordEmbed
import json, numpy as np
import websocket
import talib
import strategy
from threading import Thread
import time
url = 'https://discord.com/api/webhooks/853609737060876348/4gnRYvcOnwMgZjwmBvz_ZUFDIhSr2oKTO_-yfcTfvF1IWIRHmGVQH5xuNABw7-huAVmY'
webhook4 = DiscordWebhook(url=url, rate_limit_retry=True,
content='Is Logged In')
webhook4.execute()
securitynumber = 0
crypto = 'LTC/USDT'
cc = 'ltcusdt'
interval = '1m'
date = time.ctime()
socket = f'wss://stream.binance.com:9443/ws/{cc}@kline_{interval}'
amount = 500000
trade_amount = 5000
stop_loss = 0
pattern = ''
portfolio = 0
investment, real_time_portfolio_value, closes, highs, lows, opens = [], [], [], [], [], []
money_end = amount
prices = []
timer = False
def buy(allocated_money, price):
global portfolio, money_end
quantity = allocated_money/price
money_end -= quantity*price
portfolio += quantity
if investment == []:
investment.append(allocated_money)
else:
investment.append(allocated_money)
investment[-1] += investment[-2]
def sell(allocated_money, price):
global portfolio, money_end
quantity = allocated_money/price
money_end += quantity*price
portfolio -= quantity
investment.append(-allocated_money)
investment[-1] += investment[-2]
def trailingStop(price):
global stop_loss, timer, portfolio, money_end, amount, real_time_portfolio_value
bitcoin_position = portfolio*price
if bitcoin_position <= stop_loss and stop_loss != 0:
real_time_portfolio_value = stop_loss + money_end
sell(bitcoin_position, price)
webhook1 = DiscordWebhook(url=url, rate_limit_retry=True)
embed1 = DiscordEmbed(title='Sell Litecoin', description=f'Sold Litecoin on trailing-stop', color=0xffb029)
embed1.set_thumbnail(url='https://media.discordapp.net/attachments/791583496283881532/856208378736410635/kisspng-litecoin-cryptocurrency-bitcoin-logo-cryptocurrency-5b081f1979b524.5871818715272589054985.png')
embed1.add_embed_field(name='Amount:', value=f'${str(bitcoin_position)}', inline=True)
embed1.add_embed_field(name='Quantity:', value=f'{str(round(portfolio, 2))}', inline=True)
embed1.add_embed_field(name='Litecoin Price:', value=f'${str(round(price))}', inline=True)
embed1.add_embed_field(name='Portfolio:', value=f'{str(round(real_time_portfolio_value))}/{str(amount)}', inline=True)
embed1.set_footer(text=f'Sold Litecoin at {date}')
webhook1.add_embed(embed1)
webhook1.execute()
print('Selled all the bitcoins!')
timer = True
del prices[:]
prices.append(0)
else:
prices.append(bitcoin_position)
prices.sort()
print(prices)
if prices[-1] == bitcoin_position:
stop_loss = bitcoin_position-5
print('stop-loss moved')
print(f'Stop-Loss: {stop_loss}\n')
class Bot(Thread):
def run(self):
def on_message(ws, message):
global portfolio, investment, closes, highs, lows, opens, money_end, real_time_portfolio_value, timer, stop_loss, securitynumber, crypto, pattern
json_message = json.loads(message)
cs = json_message['k']
candle_closed, close, open, low, high = cs['x'], cs['c'], cs['o'], cs['l'], cs['h']
if candle_closed:
closes.append(float(close))
highs.append(float(high))
lows.append(float(low))
opens.append(float(open))
bar = [opens]
last_price = closes[-1]
#Strategies
securitynumber = strategy.strategy(crypto=crypto, security=securitynumber, type=pattern)
# print(securitynumber)
# engulfing = talib.CDLENGULFING(np.array(opens), np.array(highs), np.array(lows), np.array(closes))
# doji = talib.CDLDOJI(np.array(opens), np.array(highs), np.array(lows), np.array(closes))
# hammer = talib.CDLHAMMER(np.array(opens), np.array(highs), np.array(lows), np.array(closes))
# if engulfing[-1] >= 0:
# securitynumber += 1
# pattern = 'Engulfing'
# elif doji[-1] >= 0:
# securitynumber += 1
# pattern = 'Doji'
# elif hammer[-1] >= 0:
# securitynumber += 1
# pattern = 'Hammer'
# else:
# pass
if securitynumber == 0:
pass
elif securitynumber > 0 and securitynumber < 3:
amt = trade_amount - 2000
elif securitynumber > 0 and securitynumber < 5:
amt = trade_amount -1000
elif securitynumber > 0:
amt = trade_amount
else:
amt = 0
real_time_portfolio_value = portfolio*last_price + money_end
webhook5 = DiscordWebhook(url='https://discord.com/api/webhooks/855698858684579860/k8DjBmPGq7bgrfcQgb07vrGxQl6aaAMhOiWVokAXjTitYGWneNt371BvjmhnwQJ6J4TQ', rate_limit_retry=True, content = str(real_time_portfolio_value))
webhook5.execute()
date = time.ctime()
if amt > 0 and amt < money_end:
buy(amt, price=last_price)
webhook2 = DiscordWebhook(url=url, rate_limit_retry=True)
embed2 = DiscordEmbed(title='Bought Litecoin', description=f'Bought Litecoin on "{pattern}" strategy', color=0xffb029)
embed2.set_thumbnail(url='https://media.discordapp.net/attachments/791583496283881532/856208378736410635/kisspng-litecoin-cryptocurrency-bitcoin-logo-cryptocurrency-5b081f1979b524.5871818715272589054985.png')
embed2.add_embed_field(name='Amount:', value=f'${str(amt)}', inline=True)
embed2.add_embed_field(name='Quantity:', value=f'{str(round(amt/last_price, 2))}', inline=True)
embed2.add_embed_field(name='Litecoin Price:', value=f'${str(round(last_price))}', inline=True)
embed2.add_embed_field(name='Portfolio:', value=f'{str(round(real_time_portfolio_value))}/{str(amount)}', inline=True)
embed2.set_footer(text=f'Bought Litecoin at {date}')
webhook2.add_embed(embed2)
webhook2.execute()
print(f'We have bought ${amt} worth of bitcoin')
trailingStop(last_price)
if timer == True:
time.sleep(200)
timer = False
stop_loss = 0
ws = websocket.WebSocketApp(socket, on_message=on_message)
ws.run_forever()