# coding=utf-8
import serial
import sys
import time


esp_messages = ["OK\r\n", "ready\r\n", "ERROR\r\n", "WIFI CONNECTED\r\n", "WIFI	GOT	IP\r\n",\
				"WIFI DISCONNECT\r\n", "CONNECT\r\n", "CLOSED\r\n"] #+IPD



#http://149.11.65.227/MAXIMAFM_SC
header_maxima = "GET /MAXIMAFM_SC HTTP/1.1\r\n Icy-MetaData: 1 \r\nUser-Agent: Internet Explorer\r\n "\
				"Host: 20853.live.streamtheworld.com\r\n Connection: Close\r\n sCache-Control: no-cache\r\n\r\n"



addres_zlote_przeboje = "http://poznan7.radio.pionier.net.pl:8000/tuba9-1.mp3"

header_zlote_przeboje = "GET /tuba9-1.mp3 HTTP/1.1\r\n Icy-MetaData: 1 \r\nUser-Agent: Internet Explorer\r\n "\
				        "Host: 20853.live.streamtheworld.com\r\n Connection: Close\r\n sCache-Control: no-cache\r\n\r\n"




# searching for all avilable com ports
def search_serial_ports():
	ports = ['COM%s' % (i + 1) for i in range(256)]
	found = []
	for port in ports:
		try:
			ser = serial.Serial(port)
			ser.close()
			found.append(port)
		except (OSError, serial.SerialException):
			pass
	return found



# receive data
def receive_until(port,txt):
	d=""
	while d.find(txt) == -1:
		try:
			dnow=port.read(1)
			if len(dnow)==0:
				return
		except (OSError, serial.SerialException):
			return "Serial error"
		d= d+dnow
	return d




def printtext(text):
    for c in text:
        sys.stdout.write(c)
        sys.stdout.flush()





####################################### main program ##################################################

# search com ports in system
com_ports = search_serial_ports()
print("Found "+str(len(com_ports))+" com ports!")

#connect to port
com = serial.Serial(com_ports[0],115200)
print("Connected!:")
print(receive_until(com,"IP\r\n"))

#change uart speed
com.write("AT+UART_CUR?\r\n")
print(receive_until(com,"OK\r\n"))
#+UART:115273,8,1,0,1

#max 2Mb = 2000000b
com.write("AT+UART_CUR=2000000,8,1,0,1\r\n")
print(receive_until(com,"OK\r\n"))
time.sleep(1)
com.baudrate=2000000

com.write("AT+UART_CUR?\r\n")
print(receive_until(com,"OK\r\n"))




#com.write('AT+CIPDNS_CUR=1,"8.8.8.8"\r\n')
#print(receive_until(com,"OK\r\n"))


#while 1:
#	try:
#		sys.stdout.write(com.read(1))
#		sys.stdout.flush()
#	except (OSError, serial.SerialException):
#		pass



com.write('AT+CIPSTART="UDP","poznan7.radio.pionier.net.pl",8000\r\n')



print(receive_until(com,"OK\r\n"))

get_header = 'GET /tuba9-1.mp3\r\n HTTP/1.1 Host: poznan7.radio.pionier.net.pl\r\n Connection: Keep-Alive\r\n\r\n'


com.write("AT+CIPSEND="+str(len(get_header))+"\r\n")
com.write(get_header)
while 1:
	try:
		sys.stdout.write(com.read(1))
		sys.stdout.flush()
	except (OSError, serial.SerialException):
		pass
receive_until(com,"\r\n")




#TODO:remove +IPD:
# AT+CIPDINFO=1.
log = open("log.txt","w")
tmp_str=receive_until(com,"CLOSED\r\n")

log.write(tmp_str)
log.close()
print(tmp_str)
#while 1:
#	try:
#		sys.stdout.write(com.read(1))
#		sys.stdout.flush()
#	except (OSError, serial.SerialException):
#		pass

com.close()