slackbot_cryptocurrencies.py

import time
import yaml

from slackclient import SlackClient
from KrakenAPI import KrakenPublic

config = yaml.load(open('config.yml', 'r'))

slack_token = config['SLACK_API_TOKEN']
sc = SlackClient(slack_token)

kraken=KrakenPublic()

botID=(config['bot'])['id']
botname=(config['bot'])['name']

vul=['encul', 'fdp', 'ntm', 'fuck']

def createMessage(currency):
	
	message="Server Time: "+kraken.getTime()+"\n\n"
		
	for c in currency:
		pct=(c['high']/c['low'])-1
		message += "*" + c['symbol'] + "* (" + str(c['nb']) + " trades today)" + "\tH: " + str(c['high']) + "€; L: " + str(c['low']) + "€; "
		message += "Volatility: " + str(int((c['high']-c['low'])*100)/100) + "€ (" + str(int(pct*10000)/100) + "%); "
		pct=(c['current']/c['opening'])-1
		message+= "Openning: "+ str(c['opening']) + "€ (00:00 UTC); *Current: " + str(c['current']) + "€* (" + str(int(pct*10000)/100) + "%)" + "\n" 

	return message

def message_help():
	msg="My aim is to help people enjoying *crypto-trading* ~and fucking the world~.\n\"_Speculation is pejorative_\""
	msg+="\nWhat can I understand for the moment:\n"
	msg+="\n\t- *hey/hello*: welcome message"
	msg+="\n\t- *help*: print this little help"
	msg+="\n\t- *time*: print Kraken Time Server"
	msg+="\n\t- *@blockbot* (only): print market informations about Bitcoin and Ehter"
	msg+="\n\t- *currency1 currency2*: print market informations about 2 submitted currencies"
	msg+="\n\t\t+ Available Currencies: EUR, USD, CAD, JPY, GBP"
	msg+="\n\t\t+ Available Crypto-Currencies: ETC, ETH, LTC, REP, RPZ, XBT, XLM, XMR, XRP, ZEC"
	msg+="\n\nThanks to Kraken"

	return msg

def message_time():
	return "Kraken - Time Server "+kraken.getTime()

def message_hello():
	return "Hey, *Welcome* to the *Blockchain Jungle* !"

def message_vulg():
	return "Fais le malin aujourd'hui, tu le feras moins demain quand je serai *millionaire*. :heart:"


def word_analyze(resp):
	msg=""
	words=(resp['text']).split()

	if ('<@'+botID+'>') in words[0]:
		if len(words)==1:
			words=[]
		else:
			words=words[1:]

	if len(words)==0:
		info=[kraken.getBitcoin(), kraken.getEther()]
		msg=createMessage(info)
	
	elif len(words)==2 and ("help" not in words[0]):
		
		info = kraken.getCurrency(words[0],words[1])
		
		if info:
			msg=createMessage([info])
		
		else:
			msg="Sorry but I don't know one of submitted currencies..."
	
	else:
		
		for w in words:
			
			if 'help' in w.lower():
				msg=message_help()
				break
			
			elif 'hey' in w.lower():
				msg=message_hello()
				break
			
			elif 'hello' in w.lower():
				msg=message_hello()
				break
			
			elif 'time' in w.lower():
				msg=message_time()
				break

	for w in vul:
		if w in (resp['text']).lower():
			msg=message_vulg()

	if len(msg)>0:
		sc.rtm_send_message(resp['channel'],msg)
	else:
		sc.rtm_send_message(resp['channel'],"Sorry, I can't understand ~yet~")

def handle_message(resp, chans):
	in_chan=0
	#print(chans)
	for k in chans:
		if resp['channel']==chans[k]:
			in_chan=1
	try:	
		if in_chan and (('<@'+botID+'>') in resp['text']):
			word_analyze(resp)
			print("Query in channel "+chans[k]+" by "+resp['user']+": "+resp['text'])
	
		elif not in_chan:
			word_analyze(resp)
			print("Query direct "+chans[k]+" by "+resp['user']+": "+resp['text'])
	except:
		print("Not concerned !")

def handle_response(resp):
	chans=(config['chans'])

	if 'type' in resp:
		if resp['type']=='error':
			sc.rtm_send_message(chans['testbots'], (resp['error'])['msg'])
		
		elif (resp['type']=='message') and (('text' and 'channel') in resp):
			if ('reply_to' not in resp) and ('is_ephemeral' not in resp):
				#print(resp)
				handle_message(resp, chans)	

def main_program():
	if sc.rtm_connect():
	    while True:
        	resp = sc.rtm_read()
        
	        if len(resp)>0:
        		resp=resp[0]
        		handle_response(resp)
	        time.sleep(1)
	else:
	    print("Connection Failed, invalid token?")

def main():
	main_program()

if __name__ == '__main__':
	main()