add webserver & d1motor

Author: Marty

_getLibrary.py

@@ -0,0 +1,241 @@
+import os
+import usocket
+import network,time
+import network , ubinascii
+
+def do_connect():
+    global connected
+    sta_if = network.WLAN(network.STA_IF)
+    sta_if.active(True)
+    print('connecting to network...')
+    sta_if.connect('webduino.io', 'webduino')
+    cnt = 0
+    while not sta_if.isconnected():
+        cnt = cnt + 1
+        time.sleep(0.5)
+        if cnt == 60:
+            break
+    connected = sta_if.isconnected()
+    print('network config:', sta_if.ifconfig())
+
+class Response:
+
+    def __init__(self, f):
+        self.raw = f
+        self.encoding = "utf-8"
+        self._cached = None
+
+    def close(self):
+        if self.raw:
+            self.raw.close()
+            self.raw = None
+        self._cached = None
+
+    @property
+    def content(self):
+        if self._cached is None:
+            try:
+                self._cached = self.raw.read()
+            finally:
+                self.raw.close()
+                self.raw = None
+        return self._cached
+
+    @property
+    def text(self):
+        return str(self.content, self.encoding)
+
+    def json(self):
+        import ujson
+        return ujson.loads(self.content)
+
+
+def request(method, url, data=None, json=None, headers={}, stream=None):
+    try:
+        proto, dummy, host, path = url.split("/", 3)
+    except ValueError:
+        proto, dummy, host = url.split("/", 2)
+        path = ""
+    if proto == "http:":
+        port = 80
+    elif proto == "https:":
+        import ussl
+        port = 443
+    else:
+        raise ValueError("Unsupported protocol: " + proto)
+
+    if ":" in host:
+        host, port = host.split(":", 1)
+        port = int(port)
+    #print("host:",host,",port:",port)
+    ai = usocket.getaddrinfo(host, port, 0, usocket.SOCK_STREAM)
+    ai = ai[0]
+
+    s = usocket.socket(ai[0], ai[1], ai[2])
+    try:
+        s.connect(ai[-1])
+        if proto == "https:":
+            s = ussl.wrap_socket(s, server_hostname=host)
+        s.write(b"%s /%s HTTP/1.0\r\n" % (method, path))
+        if not "Host" in headers:
+            s.write(b"Host: %s\r\n" % host)
+        # Iterate over keys to avoid tuple alloc
+        for k in headers:
+            s.write(k)
+            s.write(b": ")
+            s.write(headers[k])
+            s.write(b"\r\n")
+        if json is not None:
+            assert data is None
+            import ujson
+            data = ujson.dumps(json)
+            s.write(b"Content-Type: application/json\r\n")
+        if data:
+            s.write(b"Content-Length: %d\r\n" % len(data))
+        s.write(b"\r\n")
+        if data:
+            s.write(data)
+
+        l = s.readline()
+        #print(l)
+        l = l.split(None, 2)
+        status = int(l[1])
+        reason = ""
+        if len(l) > 2:
+            reason = l[2].rstrip()
+        while True:
+            l = s.readline()
+            if not l or l == b"\r\n":
+                break
+            #print(l)
+            if l.startswith(b"Transfer-Encoding:"):
+                if b"chunked" in l:
+                    raise ValueError("Unsupported " + l)
+            elif l.startswith(b"Location:") and not 200 <= status <= 299:
+                raise NotImplementedError("Redirects not yet supported")
+    except OSError:
+        s.close()
+        raise
+
+    resp = Response(s)
+    resp.status_code = status
+    resp.reason = reason
+    return resp
+
+
+def head(url, **kw):
+    return request("HEAD", url, **kw)
+
+def get(url, **kw):
+    print(">>>get>>>>",url)
+    return request("GET", url, **kw)
+
+def post(url, **kw):
+    return request("POST", url, **kw)
+
+def put(url, **kw):
+    return request("PUT", url, **kw)
+
+def patch(url, **kw):
+    return request("PATCH", url, **kw)
+
+def delete(url, **kw):
+    return request("DELETE", url, **kw)
+
+
+class Res:
+
+    def get(url,file):
+        try:
+            response = get('https://marty5499.github.io/pythonCode/'+url)
+            print(">>",len(response.text) )
+            print("get file:",file,'size:',len(response.text),',save to:',file)
+            f = open(file, 'w')
+            f.write(response.text)
+            f.close()
+            print("OK.")
+        except Exception as e:
+            print("QQ:",e)
+
+
+    def exe(dir):
+        srcDir = dir
+        try:
+            while True:
+                idx = dir.index('/')
+                try:
+                    name = dir[0:idx]
+                    try:
+                        print('mkdir',name)
+                        os.mkdir(name)
+                    except:
+                        pass
+                    try:
+                        os.chdir(name)
+                        print('cd',name)
+                    except:
+                        pass
+                except:
+                    pass
+                dir = dir[idx+1:]
+        except:
+            pos = -1
+            try:
+                pos = dir.index('.mpy')
+            except:
+                pass
+            try:
+                if pos == -1:
+                    pos = dir.index('.py')
+            except:
+                pass
+            try:
+                if pos > 0:
+                    pyFile = dir
+                    Res.get(srcDir,pyFile)
+                else:
+                    try:
+                        print("mkdir",dir)
+                        os.mkdir(dir)
+                    except:
+                        pass
+                    try:
+                        os.chdir(dir)
+                        print("cd ",dir)
+                    except:
+                        pass
+            except:
+                pass
+        os.chdir('/')
+
+
+
+print("connect...")
+do_connect()
+print("get files...")
+Res.exe('lib/webduino.py')
+Res.exe('lib/urequests.py')
+Res.exe('lib/TM1637.py')
+Res.exe('lib/mfrc522.py')
+Res.exe('lib/ssd1306.py')
+Res.exe('lib/st7789py.py')
+Res.exe('lib/umqtt/simple.py')
+Res.exe('lib/max7219.py')
+Res.exe('lib/mled.py')
+Res.exe('lib/ADXL345.py')
+Res.exe('lib/hmc5883l.py') # 三軸加速
+Res.exe('lib/mlx90614.py') #額溫
+Res.exe('lib/i2c_lcd.py') #LCD
+Res.exe('lib/uyeelight.py') #LCD
+Res.exe('lib/lcd_api.py') #LCD
+Res.exe('lib/heltec/sx127x.py') #LoRa
+Res.exe('lib/dfplayer.py') #MP3
+Res.exe('lib/scanplayer.py') #MP3
+Res.exe('lib/d1motor.py') # d1motor
+Res.exe('lib/webserver/webserver.py') #LoRa
+Res.exe('lib/webserver/index.html') #LoRa
+
+#Res.exe('lib/animations.py')
+#Res.exe('lib/pixelart.py')
+print("========")
+print('Mac address:',ubinascii.hexlify(network.WLAN().config('mac'),':').decode())

_i2c_scanner.py

@@ -0,0 +1,16 @@
+from machine import I2C, Pin
+
+#i2c = I2C(scl=Pin(5), sda=Pin(4), freq=100000) #wemos
+
+i2c = I2C(scl=Pin(5), sda=Pin(4), freq=100000)
+
+print('Scan i2c bus...')
+devices = i2c.scan()
+
+if len(devices) == 0:
+  print("No i2c device !")
+else:
+  print('i2c devices found:',len(devices))
+
+  for device in devices:  
+    print("Decimal address: ",device," | Hexa address: ",hex(device))

board_esp01.py

@@ -0,0 +1,14 @@
+from webduino import *
+from machine import Pin,I2C
+import time
+
+# esp01
+esp01 = Board()
+esp01.connect("KingKit_2.4G","webduino")
+esp01.mqtt.pub("qq123","OKOK")
+
+def onMsg(topic,msg):
+    print(topic,msg)
+
+esp01.mqtt.sub('debug/display',onMsg)
+esp01.loop()

board_wemos_d1motor.py

@@ -0,0 +1,31 @@
+import d1motor, time
+from machine import SoftI2C, Pin
+from webduino import *
+from machine import Pin,I2C
+import time, ssd1306
+
+
+def initMotor():
+    global m0,m1
+    i2c = SoftI2C(scl=Pin(5), sda=Pin(4), freq=100000)
+    m0 = d1motor.Motor(0, i2c)
+    m1 = d1motor.Motor(1, i2c)    
+
+initMotor()
+m0.speed(50)
+m1.speed(50)
+time.sleep(1)
+m0.brake()
+m1.brake()
+
+# wemos
+wemos = Board()
+wemos.connect("KingKit_2.4G","webduino")
+
+def runCode(topic,msg):
+    print('topic:',topic,' ,msg:',msg)
+    if(topic == b'wemos/motor'):
+        eval(msg.decode("utf-8"))
+
+wemos.mqtt.sub('wemos/motor',runCode)
+wemos.loop()

config.py

@@ -0,0 +1,10 @@
+
+app_config = {
+    'camera': 'ESP32-CAM',  # camera -> 'ESP32-CAM' or 'M5CAMERA'
+    'led': 4, # led -> 4: ESP32-CAM or 14: M5CAMERA
+}
+
+wifi_config = {
+    'ssid':'webduino.io',
+    'password':'webduino'
+}

i2c_scanner.py

@@ -2,7 +2,7 @@
 
 #i2c = I2C(scl=Pin(5), sda=Pin(4), freq=100000) #wemos
 
-i2c = I2C(scl=Pin(2), sda=Pin(0), freq=100000)
+i2c = I2C(scl=Pin(5), sda=Pin(4), freq=100000)
 
 print('Scan i2c bus...')
 devices = i2c.scan()

lib/d1motor.py

@@ -1,10 +1,7 @@
 """
-d1motor.py - driver for the D1 mini motor-shield(?)
-source: https://bitbucket.org/thesheep/micropython-d1motor/src/a6d659db76a3?at=default
-2017-1017 PePo new, not-tested yet.
 import d1motor
 from machine import I2C, Pin
-i2c = I2C(Pin(5), Pin(4), freq=10000)
+i2c = I2C(Pin(5), Pin(4), freq=100000)
 m0 = d1motor.Motor(0, i2c)
 m1 = d1motor.Motor(1, i2c)
 m0.speed(5000)
@@ -68,4 +65,5 @@ def sleep(self):
     def brake(self):
         self._speed = 0
         self._state = _STATE_BRAKE
-        self.update()
+        self.update()
+

lib/webduino.py

@@ -161,8 +161,6 @@ def online(self,status):
             debug.print("connect mqtt...")
             self.mqtt.connect()
             debug.print("mqtt OK")
-            lcd.text("MQTT connnected!",0,0)
-            lcd.show()
         else:
             debug.print("offline...")
             pass