<reponame>psby233/PiBot
#!/usr/bin/env python

import rospy
from time import time, sleep
from pibot import srv, msg
import Adafruit_DHT as dht


class AM2302:
    def __init__(self, pin):
        self.pin = pin
        self.timestamp = -1
        self.temperature = 0
        self.humidity = 0
        self.read()

    def handler(self, req):
        res = srv.am2302Response()
        res.timestamp = self.timestamp
        res.temperature = self.temperature
        res.humidity = self.humidity
        return res

    def read(self):
        h, t = dht.read_retry(dht.AM2302, self.pin)
        if (t is not None) and (h is not None):
            self.timestamp = time()
            self.temperature = t
            self.humidity = h 

def main():
    rospy.init_node('am2302')

    pin = rospy.get_param('/pibot/pins/AM2302')
    sensor = AM2302(pin)
    rospy.loginfo('AM2302 @%s' % pin)

    s = rospy.Service('srv_am2302', srv.am2302, lambda req: sensor.handler(req)) 

    pub = rospy.Publisher('/pibot/air', msg.air, queue_size=5)

    rate = rospy.Rate(1.0/60)  # every minute
    sleep(5)
    while not rospy.is_shutdown():
        ts = sensor.timestamp
        sensor.read()
        if sensor.timestamp != ts:
            m = msg.air()
            m.timestamp = sensor.timestamp
            m.temperature = sensor.temperature
            m.humidity = sensor.humidity
            pub.publish(m)
        rate.sleep()


if __name__ == "__main__":
    try:
        main()
    except rospy.ROSInterruptException:
        pass


#!/usr/bin/env python

import rospy
from time import time, sleep
from pibot import srv, msg
import Adafruit_DHT as dht


class AM2302:
    def __init__(self, pin):
        self.pin = pin
        self.timestamp = -1
        self.temperature = 0
        self.humidity = 0
        self.read()

    def handler(self, req):
        res = srv.am2302Response()
        res.timestamp = self.timestamp
        res.temperature = self.temperature
        res.humidity = self.humidity
        return res

    def read(self):
        h, t = dht.read_retry(dht.AM2302, self.pin)
        if (t is not None) and (h is not None):
            self.timestamp = time()
            self.temperature = t
            self.humidity = h 

def main():
    rospy.init_node('am2302')

    pin = rospy.get_param('/pibot/pins/AM2302')
    sensor = AM2302(pin)
    rospy.loginfo('AM2302 @%s' % pin)

    s = rospy.Service('srv_am2302', srv.am2302, lambda req: sensor.handler(req)) 

    pub = rospy.Publisher('/pibot/air', msg.air, queue_size=5)

    rate = rospy.Rate(1.0/60)  # every minute
    sleep(5)
    while not rospy.is_shutdown():
        ts = sensor.timestamp
        sensor.read()
        if sensor.timestamp != ts:
            m = msg.air()
            m.timestamp = sensor.timestamp
            m.temperature = sensor.temperature
            m.humidity = sensor.humidity
            pub.publish(m)
        rate.sleep()


if __name__ == "__main__":
    try:
        main()
    except rospy.ROSInterruptException:
        pass
#!/usr/bin/env python # every minute