boot.py

import gc
import network
import time
import usocket as socket
import ure
import ujson


gc.enable()
CONTENT = open('index.html', 'r').read()


def connection(network_name, network_password):
	attempts = 0
	station = network.WLAN(network.STA_IF)
	if not station.isconnected():
		print("Connecting to network...")
		station.active(True)
		station.connect(network_name, network_password)
		while not station.isconnected():
			print("Attempts: {}".format(attempts))
			attempts += 1
			time.sleep(5)
			if attempts > 3:
				return False
				break
	print('Network Config:', station.ifconfig())
	return True


class DNSQuery:
	def __init__(self, data):
		self.data = data
		self.domain = ''

		m = data[2]
		tipo = (m >> 3) & 15
		if tipo == 0:
			ini = 12
			lon = data[ini]
			while lon != 0:
				self.domain += data[ini+1:ini+lon+1].decode("utf-8") + "."
				ini += lon+1
				lon = data[ini]


	def response(self, ip):
		packet = b''
		print("Response {} == {}".format(self.domain, ip))
		if self.domain:
			packet += self.data[:2] + b"\x81\x80"
			packet += self.data[4:6] + b"\x00\x00\x00\x00"
			packet += self.data[12:]
			packet += b"\xc0\x0c"
			packet += b"\x00\x01\x00\x01\x00\x00\x00\x3c\x00\x04"
			packet += bytes(map(int, ip.split(".")))
		return packet


def captive_portal(essid_name):
	existing_config = False
	try:
		f = open("config.json", "r")
		configs = f.read()
		j = ujson.loads(configs)
		print(j)
		f.close()
		con = connection(j['network_name'], j['network_password'])
		if con is True:
			existing_config = True
			print("Network connected")
			ap = network.WLAN(network.AP_IF)
			ap.active(False)    # turn off AP SSID
		else:
			existing_config = False
			print("Incorrect network configuration")
	except:
		print("No saved network")

	if existing_config is False:
		ap = network.WLAN(network.AP_IF)
		ap.active(True)
		ap.config(essid=essid_name, authmode=1)
		ip = ap.ifconfig()[0]
		print("DNS Server: dom.query. 60 in A {:s}".format(ip))

		udps = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
		udps.setblocking(False)
		udps.bind(('',53))

		s = socket.socket()
		ai = socket.getaddrinfo(ip, 80)
		print("Web Server: Bind address information: ", ai)
		addr = ai[0][-1]

		s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
		s.bind(addr)
		s.listen(1)
		s.settimeout(2)
		print("Web Server: Listening http://{}:80/".format(ip))

		regex = ure.compile("network\?ssid=(.*?)&password=(.*?)\sHTTP")

		set_connection = False
		while set_connection is False:
			try:
				data, addr = udps.recvfrom(4096)
				print("Incoming data...")
				DNS = DNSQuery(data)
				udps.sendto(DNS.response(ip), addr)
				print("Replying: {:s} -> {:s}".format(DNS.domain, ip))
			except:
				print("No DNS")

			try:
				res = s.accept()
				client_sock = res[0]
				client_addr = res[1]

				req = client_sock.recv(4096)
				print("Request:")
				print(req)
				client_sock.send(CONTENT)
				client_sock.close()
				print()
				search_result = regex.search(req)
				if search_result:
					incoming_network_name = search_result.group(1)
					incoming_network_pass = search_result.group(2)
					con = connection(incoming_network_name, incoming_network_pass)
					if con is True:
						d = {"network_name": incoming_network_name, "network_password": incoming_network_pass}
						f = open("config.json", "w")
						f.write(ujson.dumps(d))
						f.close()
						set_connection = True


			except:
				print("Timeout")
			time.sleep_ms(1000)
		udps.close()


def main():
	captive_portal("WeatherApp")


main()