esp01_ds18b20.py

import network, time, machine, ubinascii, os
import usocket, ntptime, random
from machine import Pin, PWM, Timer, WDT
from umqtt.simple import MQTTClient
import machine, onewire, ds18x20, time
#import dht


class debug:
    def print(msg="",msg2="",msg3=""):
        print("[debug]",msg,msg2,msg3)
        pass

class WiFi:

    def ip():
        print(Wifi.sta.ifconfig())
        
    def check():
        print(WiFi.sta.isconnected())

    def disconnect():
        WiFi.sta.disconnect()

    def checkConnection():
        debug.print("wifi state:",WiFi.sta.isconnected())
        if not WiFi.sta.isconnected():
            debug.print("connect broke ! retry...")
            WiFi.connect()
            debug.print("!!!! online callback... !!!!")

    def setup(ssid="webduino.io",pwd="webduino"):
        WiFi.ssid = ssid
        WiFi.pwd = pwd

    def connect():
        WiFi.sta = sta_if = network.WLAN(network.STA_IF)
        sta_if.active(True)
        debug.print('connecting WiFi:',WiFi.ssid,WiFi.pwd)
        cnt = 0
        sta_if.connect(WiFi.ssid,WiFi.pwd)
        while not sta_if.isconnected():
            cnt = cnt + 1
            time.sleep(0.5)
            if cnt == 10:
                cnt = 0
                debug.print("retry connect...")
        WiFi.ip = sta_if.ifconfig()[0];
        return True

class MQTT():

    def setup(server = 'mqtt1.webduino.io',user ='webduino' ,pwd='webduino',keepalive=60):
        MQTT.user = user
        MQTT.pwd = pwd
        MQTT.server = server
        userId = 'guest'#+str(random.randint(0,10000))
        MQTT.client = MQTTClient(userId, MQTT.server, user=MQTT.user, password=MQTT.pwd)
        MQTT.connectState = False
    
    def connect():
        while MQTT.connectState is not True:
            MQTT.connectState = True if MQTT.client.connect() == 0 else False
            time.sleep(1)
        try:
            MQTT.subTopic
            debug.print("resubscribe:",MQTT.subTopic)
            MQTT.sub(MQTT.subTopic,MQTT.callback)
        except:
            pass
        
    def pub(topic,msg):
        try:
            MQTT.client.publish(topic,msg)
        except OSError as e:
            print("reconnecting...")
            MQTT.client.connect(False)
            MQTT.sub(MQTT.subTopic,MQTT.callback)
            print("reconected.")

    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 OSError as e:
            print("reconnecting...")
            MQTT.client.connect(False)
            MQTT.sub(MQTT.subTopic,MQTT.callback)
            print("reconected.")

class ESP01():
    
    def init():
        ESP01.wifi = WiFi
        ESP01.mqtt = MQTT
        ESP01.wifi.setup('KingKit_2.4G','webduino')
        ESP01.mqtt.setup('mqtt1.webduino.io','webduino','webduino')
        
        
    def connect():
        ESP01.wifi.connect()
        debug.print("wifi connected.")
        ESP01.mqtt.connect()
        debug.print("mqtt connected.")




class DS18B20:
    
    def init(name):
        DS18B20.name = str.encode(name)
        DS18B20.esp01 = ESP01
        DS18B20.sensor = ds18x20.DS18X20(onewire.OneWire(machine.Pin(3)))
        DS18B20.roms = DS18B20.sensor.scan()
        DS18B20.sensor.convert_temp()
        DS18B20.esp01.init()
        DS18B20.esp01.connect()

    def run():
        now = 0
        min = 10
        enableDeepSleepMode = 0
        while True:
            if now % 100 == 0:
                DS18B20.esp01.mqtt.client.ping()
            if now == min or now == 0:
                print("Trigger....")
                now = 0
                try:
                    DS18B20.esp01.wifi.checkConnection()
                    for rom in DS18B20.roms:
                        info = str(rom)+" "+str(DS18B20.sensor.read_temp(rom))
                        DS18B20.esp01.mqtt.pub((DS18B20.name+b'/state'), str.encode(info))
                    print("ok")
                except Exception as e:
                    print("DS18B20 exception:",e)
            DS18B20.esp01.mqtt.checkMsg()
            time.sleep(0.1)
            now = now + 1

DS18B20.init("ds18b20")
DS18B20.esp01.mqtt.pub((DS18B20.name+b'/state'), str.encode("Start..."))
DS18B20.run()