summaryrefslogtreecommitdiff
path: root/sbhs_raspi/sbhs.py
blob: 515c8b6ff520eaf9861261db7cf229bfd9baa9f2 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
import serial
import os
from time import localtime, strftime, sleep

# MAP_FILE = credentials.MAP_FILE
#LOG_FILE = '../log/sbhserr.log'
# LOG_FILE = credentials.LOG_FILE

class SbhsServer(object):
    """ This is the Single Board Heater System class """

    def __init__(self):
        self.outgoing_machine_id = 252
        self.incoming_fan = 253
        self.incoming_heat = 254
        self.outgoing_temp = 255
        self.max_heat = 100
        self.max_fan = 100

    def get_usb_devices(self):
        usb_devices = []
        for tty in os.listdir('/dev'):
            if tty.startswith('ttyUSB'):
                try:
                    usb_devices.append(int(tty[6:]))
                except ValueError:
                    pass
        return usb_devices

    def connect_device(self, device_num):
        """ 
        Open a serial connection via USB to the SBHS using USB Device Number
        """
        # check for valid device number
            
        usb_device_file = '/dev/ttyUSB{}'.format(device_num)
        try:
            self.boardcon = serial.Serial(port=usb_device_file,
                                          baudrate=9600, bytesize=8,
                                          parity='N', stopbits=1,
                                          timeout=2
                                          )
            # org stopbits = 1
            status = True
        except Exception as e:
            status = False
        return status

    def map_sbhs_to_usb(self, usb_devices):
        sbhs_map = []
        if usb_devices:
            for usb in usb_devices:
                print("usb", usb)
                status = self.connect_device(usb)
                if status:
                    sbhs = self.get_machine_id()
                    sbhs_map.append({"usb_id": usb, "sbhs_mac_id": sbhs})
        return sbhs_map


    def setHeat(self, val):
        """ Sets the heat, checks if value is valid i.e. within range.
            Input: self object, val
            Output: Error message if heat cannot be set.
        """
        if val > MAX_HEAT or val < 0:
            print("Error: heat value cannot be more than {}".format(MAX_HEAT))
            return False

        try:
            self._write(chr(INCOMING_HEAT))
            sleep(0.5)
            self._write(chr(val))
            return True
        except:
            print("Error: cannot set heat for machine \
                    id {}".format(self.machine_id))
            self.log('cannot set heat for machine id \
                        %d' % self.machine_id, 'ERROR')
            return False

    def set_fan(self, val):
        """ Sets the fan speed, checks if value is valid i.e. within range.
            Input: self object, val
            Output: Error message if fan cannot be set.
        """
        if val > self.out_fan or val < 0:
            return False
        try:
            self._write(chr(self.incoming_fan))
            sleep(0.5)
            self._write(chr(val))
            return True
        except:
            return True

    def getTemp(self):
        """ Gets the temperature from the machine.
        """
        try:
            self.boardcon.flushInput()
            self._write(chr(OUTGOING_TEMP))
            temp = ord(self._read(1)) + (0.1 * ord(self._read(1)))
            return temp
        except:
            print("Error: cannot read temperature from machine id \
                    {}".format(self.machine_id))
            self.log('cannot read temperature from machine id %d' \
                        % self.machine_id, 'ERROR')
        return  0.0

    def get_machine_id(self):
        """ Gets machine id from the device """
        try:
            self.boardcon.flushInput()
            self._write(chr(self.outgoing_machine_id))
            sleep(0.5) 
            machine_id = ord(self._read(1))
        except Exception as e:
            machine_id = -1
        return int(machine_id)

    def disconnect(self):
        """ Reset the board fan and heat values and close the USB connection """
        try:
            self.boardcon.close()
            self.boardcon = False
            self.status = 0
            return True
        except:
            print('Error: cannot close connection to the machine')
            self.log('cannot close connection to the machine', 'ERROR')
            return False

    def reset_board(self):
        return self.setHeat(0) and self.setFan(100)

    def _read(self, size):
        try:
            data = self.boardcon.read(size)
            return data
        except Exception as e:
            raise

    def _write(self, data):
        try:
            self.boardcon.write(data)
            return True
        except Exception as e:
            raise

    def log(self, msg, level):
        try:
            errfile = open(LOG_FILE, 'a') # open error log file in append mode
            if not errfile:
                return
            log_msg = '%s %s %s\n' %(level, strftime('%d:%m:%Y %H:%M:%S', \
                        localtime()), msg)  

            errfile.write(log_msg)
            errfile.close()
            return
        except:
            return