add d1motor ,mqtt username

Author: Marty

esp01.py

@@ -1,183 +1,61 @@
-import network, time, machine, ubinascii, os
-import usocket
-from machine import Pin, PWM, Timer, WDT
-from umqtt.simple import MQTTClient
+from webduino import *
+from machine import Pin,I2C
+import time, ssd1306
 
-class debug:
-    def print(msg="",msg2=""):
-        print(msg,msg2)
-        pass
+# ssd1306
+i2c = I2C(scl=Pin(0), sda=Pin(2), freq=100000)  #Init i2c
+lcd = ssd1306.SSD1306_I2C(128,64,i2c) #create LCD object,Specify col and row
 
-class LED():
-    def __init__(self,pin,pwm=True):
-        self.pin = pin
-        self.strong=2
-        self.state = False
-        self.timer = None
-        self.isBlink = False
-        if pwm:
-            self.pwm = PWM(Pin(pin))
-            self.pwm.freq(1024)
-            self.pwm.duty(0)
-        self.off()
-        time.sleep(0.01)
-        self.off()
-        time.sleep(0.01)
-        self.off()
-        time.sleep(0.01)
-            
-    def on(self,strong=-1):
-        self.state = True
-        if not strong == -1:
-            self.strong= strong
-        self.pwm.duty(self.strong)
-        
-    def off(self):
-        self.state = False
-        self.pwm.duty(0)
-    
-    def run(self,n):
-        if self.isBlink:
-            if self.state:
-                self.off()
-            else:
-                self.on()
-    
-    def blink(self,peroid):
-        _p_ = int(peroid*1000)
-        if _p_ == 0:
-            self.isBlink = False
-            self.off()
-            return
-        else:
-            self.isBlink = True
-            self.on()
-        
-        if self.timer == None:
-            self.timer = Timer(1)
-            self.timer.init(period=_p_, mode=Timer.PERIODIC, callback=self.run)
-            debug.print("LED:default use Timer(0)",self.timer)
-        else:
-            self.timer.deinit()
-            self.timer = Timer(1)
-            self.timer.init(period=_p_, mode=Timer.PERIODIC, callback=self.run)
-            
-
-class WiFi:
-
-    def disconnect():
-        WiFi.sta.disconnect()
-
-    def check():
-        print(WiFi.sta.isconnected())
-
-    def onlilne(cb):
-        WiFi.onlineCallback = cb
-
-    def startKeepConnect():
-        WiFi.timer = Timer(0)
-        WiFi.timer.init(period=3000, mode=Timer.PERIODIC, callback=WiFi.checkConnection)
-        
-    def checkConnection(t):
-        #print("wifi:",WiFi.sta.isconnected())
-        if not WiFi.sta.isconnected():
-            debug.print("connect broke ! retry...")
-            WiFi.connect(WiFi.ssid,WiFi.pwd)
-            debug.print("!!!! online callback... !!!!")
-        
-    def connect(ssid="ttt",pwd="webduino"):
-        WiFi.ssid = ssid
-        WiFi.pwd = pwd
-        WiFi.sta = sta_if = network.WLAN(network.STA_IF)
-        sta_if.active(True)
-        debug.print('connecting to network...')
-        WiFi.onlineCallback(False)
-        if not sta_if.isconnected():
-            try:
-                sta_if.connect(ssid,pwd)
-            except:
-                debug.print("connect...")
-        cnt = 0
-        while not sta_if.isconnected():
-            cnt = cnt + 1
-            time.sleep(0.5)
-            if cnt == 10:
-                cnt = 0
-                debug.print("retry connect...")
-        WiFi.ip = WiFi.sta.ifconfig()[0];
-        WiFi.onlineCallback(True)
-        WiFi.startKeepConnect()
-        return True
-
-    def ip():
-        print(Wifi.sta.ifconfig())
 
-
-class MQTT():
+class Board:
 
-    def connect(server = 'mqtt1.webduino.io',user ='webduino' ,pwd='webduino'):
-        MQTT.server = server
-        MQTT.user = user
-        MQTT.pwd = pwd
-        MQTT.client = MQTTClient('guest', server, user=user, password=pwd)
-        state = True if MQTT.client.connect() == 0 else False
-        try:
-            MQTT.subTopic
-            debug.print("resubscribe:",MQTT.subTopic)
-            MQTT.sub(MQTT.subTopic,MQTT.callback)
-        except:
-            pass
-        return state
+    def init(self):
+        self.wifi = WiFi
+        self.mqtt = MQTT
+        self.wifi.onlilne(self.online)
 
-    def pub(topic,msg):
-        MQTT.client.publish(topic,msg)
-
-    def sub(topic,cb):
-        MQTT.subTopic = topic
-        MQTT.callback = cb
-        MQTT.client.set_callback(cb)
-        MQTT.client.subscribe(topic)
-
-    def checkMsg():
-        try:
-            MQTT.client.check_msg()
-        except:
-            pass
-
-
-
-class esp01():
-    
-    def init():
-        esp01.led = LED(2)
-        esp01.wifi = WiFi
-        esp01.mqtt = MQTT
-        esp01.wifi.onlilne(esp01.online)
-        
-    def online(status):
+    def online(self,status):
         if status:
-            debug.print("online,stop blink...")
-            esp01.led.blink(1)
-            esp01.mqtt.connect()
-            esp01.led.blink(0)
+            debug.print("connect mqtt...")
+            self.mqtt.connect()
+            debug.print("mqtt OK")
+            lcd.text("MQTT connnected!",0,0)
+            lcd.show()
         else:
-            debug.print("offline,blink...")
-            esp01.led.blink(2)
+            debug.print("offline...")
             pass
 
-    def connect(ssid='webduino.io',pwd='webduino'):
+    def connect(self,ssid='webduino.io',pwd='webduino'):
         while True:
-            if esp01.wifi.connect(ssid,pwd):
-                if esp01.mqtt.connect('mqtt1.webduino.io','webduino','webduino'):
+            if self.wifi.connect(ssid,pwd):
+                if self.mqtt.connect('mqtt1.webduino.io','webduino','webduino'):
                     break
         debug.print("WiFi Ready , MQTT Ready , ready to go...")
+    
+    def loop(self):
+        debug.print("run...")
+        now = 0
+        while True:
+            now = now + 1
+            if now % 100 == 0:
+                self.mqtt.client.ping()
+            self.mqtt.checkMsg()
+            time.sleep(0.1)
+
 
+# esp01
+esp01 = Board()
 esp01.init()
 esp01.connect("KingKit_2.4G","webduino")
 esp01.mqtt.pub("qq123","OKOK")
 
-def test(topic,msg):
-    print(topic,msg)
+def execEval(topic,msg):
+    topic = topic.decode("utf-8")
+    msg = msg.decode("utf-8")
+    print('topic:',topic,' ,msg:',msg)
+    if(topic == 'display'):
+        eval(msg)
+        lcd.show()
 
-esp01.mqtt.sub(b'esp01/qq123',test)
-print("sub...ok")
+esp01.mqtt.sub('debug/display',execEval)
+esp01.loop()

esp01_buzzer.py

@@ -0,0 +1,41 @@
+import os,machine,math,time
+from machine import ADC, I2C, Pin
+
+class Buzzer():
+    # 262 294 330 349 392 440 494
+    def __init__(self):
+        self.queue = []
+        self.isPause = False
+        gnd = machine.Pin(1)
+        gnd.off()
+
+    def play(self,freq=300,delay=0.1):
+        pin25 = machine.PWM(machine.Pin(3), duty=512)
+        pin25.freq(freq)
+        time.sleep(delay)
+        machine.PWM(machine.Pin(3), duty=0)
+
+    def playList(self,list):
+        self.queue.extend(list)
+
+    def pause(self,b):
+        self.isPause = b
+
+    def stop(self):
+        self.queue = []
+
+    def run(self):
+        while True:
+            if len(self.queue)>0 and not self.isPause:
+                note = self.queue[0]
+                del self.queue[0]
+                self.play(note[0],note[1])
+
+buzzer = Buzzer()              
+buzzer.play(262,0.15)
+buzzer.play(294,0.1)
+buzzer.play(330,0.1)
+buzzer.play(349,0.1)
+buzzer.play(392,0.1)
+buzzer.play(440,0.1)
+buzzer.play(494,0.1)

esp01_dht22.py

@@ -0,0 +1,6 @@
+import dht, machine
+
+d = dht.DHT22(machine.Pin(2))
+print('d.measure():',d.measure())
+print('d.temperature():',d.temperature())
+print('d.humidity():',d.humidity())

esp01_ssd1306.py

@@ -2,7 +2,7 @@
 import ssd1306
 
 i2c = I2C(scl=Pin(0), sda=Pin(2), freq=100000)  #Init i2c
-lcd=ssd1306.SSD1306_I2C(64,48,i2c) #create LCD object,Specify col and row
+lcd=ssd1306.SSD1306_I2C(128,64,i2c) #create LCD object,Specify col and row
 lcd.text("ESP8266",0,0)
 lcd.text("test",0,16)
 lcd.text("123456",0,32)

esp01_ssd1306_mqtt.py

@@ -0,0 +1,60 @@
+from webduino import *
+from machine import Pin,I2C
+import time, ssd1306
+
+
+# ssd1306
+i2c = I2C(scl=Pin(0), sda=Pin(2), freq=100000)  #Init i2c
+lcd = ssd1306.SSD1306_I2C(128,64,i2c) #create LCD object,Specify col and row
+
+
+class Board:
+    
+    def init(self):
+        self.wifi = WiFi
+        self.mqtt = MQTT
+        self.wifi.onlilne(self.online)
+        
+    def online(self,status):
+        if 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
+
+    def connect(self,ssid='webduino.io',pwd='webduino'):
+        while True:
+            if self.wifi.connect(ssid,pwd):
+                if self.mqtt.connect('mqtt1.webduino.io','webduino','webduino'):
+                    break
+        debug.print("WiFi Ready , MQTT Ready , ready to go...")
+    
+    def loop(self):
+        debug.print("run...")
+        while True:
+            self.mqtt.checkMsg()
+            time.sleep(0.1)
+
+
+# esp01
+esp01 = Board()
+esp01.init()
+esp01.connect("KingKit_2.4G","webduino")
+
+def execEval(topic,msg):
+    topic = topic.decode("utf-8")
+    msg = msg.decode("utf-8")
+    print('topic:',topic,' ,msg:',msg)
+    if(topic == 'debug/display'):
+        try:
+            eval(msg)
+            lcd.show()
+        except:
+            pass
+
+esp01.mqtt.sub('debug/display',execEval)
+esp01.loop()

getLibrary.py

@@ -231,6 +231,7 @@ def exe(dir):
 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/animations.py')
 #Res.exe('lib/pixelart.py')