Add iAM lib

.gitignore

@@ -136,3 +136,5 @@ dmypy.json
 
 # Cython debug symbols
 cython_debug/
+
+iam-lib/airsensor/airsensor
\ No newline at end of file

iam-lib/README.md

+# Introduction
+Instructions how to install the airsensor utility on Linux.
+
+# Tested on
+* Raspbian (Raspberry Pi)
+
+# Details
+
+## Requirements
+The Applied Sensors Indoor Air Monitor USB sensor, also sold as Voltcraft CO-20 at Conrad.
+
+## LibUSB-dev
+Install LibUSB-dev, which is needed when compiling the airsensor utility.
+
+```
+$ sudo apt-get install libusb-dev
+```
+
+# Compile tempsensor from sources
+
+## Install required software
+The 'build-essential' package is needed to be able to compile the source code.
+
+```
+$ sudo apt-get install build-essential
+```
+
+## Compile
+
+
+Compile the source code
+
+```
+$ gcc -o airsensor airsensor.c -lusb
+```
+
+## Test
+You can now execute the airsensor and see if you get readings, as seen on most Linux installations it seems that you must be root user, or then add udev rule to make the device read/write.
+
+To run with root access
+
+```
+$ sudo ./airsensor -o
+2013-04-28 14:55:56, VOC: 450, RESULT: OK
+$
+```
+
+Without root access it will print following
+
+```
+$ ./airsensor -o
+2013-04-28 14:55:19, Error: claim failed with error:  -1
+$
+```
+
+## Make Udev rule
+
+Insert a udev rule to get read/write access to the device from normal user.
+
+Create and edit following file:
+
+```
+$ sudo nano /etc/udev/rules.d/99-usb.rules
+```
+
+Add following lines:
+
+```
+# iAQ 
+SUBSYSTEM=="usb", ATTR{idVendor}=="03eb", ATTR{idProduct}=="2013", MODE="0666"
+```
+
+Save and reboot, now the device should be writable and give you results.
+
+Example, without sudo
+
+```
+$ ./airsensor -o
+2013-04-28 15:08:55, VOC: 450, RESULT: OK
+$
+```
+
+Please see readme for more usage instructions
+
+# Troubleshooting
+
+## Error: claim failed with error: -1
+
+If you get following issue when running air sensor:
+
+```
+$ ./airsensor -o
+2013-04-28 14:55:19, Error: claim failed with error:  -1
+$
+```
+
+It means that you have no access to the USB device, two solutions;
+
+a) use sudo, eg ```sudo ./airsensor```
+
+b) create the udev rule as above

iam-lib/airsensor/airsensor.c

+/*
+	
+	airsensor.c
+	
+	Original source: Rodric Yates http://code.google.com/p/airsensor-linux-usb/
+	Modified from source: Ap15e (MiOS) http://wiki.micasaverde.com/index.php/CO2_Sensor
+	
+	This version created by Sebastian Sjoholm, sebastian.sjoholm@gmail.com
+
+	Modified by Jonathan Weth (iam@jonathanweth.de)
+	
+	requirement:
+	
+	libusb
+	
+	compile:
+	
+	gcc -o airsensor airsensor.c -lusb
+	
+*/
+
+#include <assert.h>
+#include <signal.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <usb.h>
+#include <asm/byteorder.h>
+#include <sys/types.h>
+#include <sys/wait.h>
+#include <time.h>
+ 
+struct usb_dev_handle *devh;
+
+void help() {
+
+	printf("AirSensor [options]\n");
+	printf("Options:\n");
+	printf("-d = debug printout\n");
+	printf("-v = Print VOC value only\n");
+	printf("-o = One value and then exit\n");
+	printf("-h = Help, this printout\n");
+	exit(0);
+	
+}
+
+void printout(char *str, int value) {
+	
+	time_t t = time(NULL);
+	struct tm tm = *localtime(&t);
+	
+	printf("%04d-%02d-%02d %02d:%02d:%02d, ", tm.tm_year + 1900, tm.tm_mon + 1, tm.tm_mday, tm.tm_hour, tm.tm_min, tm.tm_sec);
+	if (value == 0) {
+		printf("%s\n", str); 
+	} else {
+		printf("%s %d\n", str, value); 
+	}
+}
+
+void release_usb_device(int dummy) {
+	int ret;
+	ret = usb_release_interface(devh, 0);
+	usb_close(devh);
+	exit(ret);
+}
+ 
+struct usb_device* find_device(int vendor, int product) {
+	struct usb_bus *bus;
+ 
+	for (bus = usb_get_busses(); bus; bus = bus->next) {
+		struct usb_device *dev;
+		
+		for (dev = bus->devices; dev; dev = dev->next) {
+			if (dev->descriptor.idVendor == vendor
+				&& dev->descriptor.idProduct == product)
+			return dev;
+		}
+	}
+	return NULL;
+}
+ 
+int main(int argc, char *argv[])
+{
+	int ret, vendor, product, debug, counter, one_read;
+	int print_voc_only;
+	struct usb_device *dev;
+	char buf[1000];
+	// char str[5];
+	
+	debug = 0;
+	print_voc_only = 0;
+	one_read = 0; 	
+	
+	vendor = 0x03eb;
+	product = 0x2013; 
+	dev = NULL;
+	
+	while ((argc > 1) && (argv[1][0] == '-'))
+	{
+		switch (argv[1][1])
+		{
+			case 'd':
+				debug = 1;
+				break;
+			
+			case 'v':
+				print_voc_only = 1;
+				break;
+			
+			case 'o':
+				one_read = 1;
+				break;
+			
+			case 'h':
+				help();
+				
+		}
+		
+		++argv;
+		--argc;
+	}
+	
+	if (debug == 1) {
+		printout("DEBUG: Active", 0);
+	}
+	
+	if (debug == 1) {
+		printout("DEBUG: Init USB", 0);
+	}
+	
+	usb_init();
+	
+	counter = 0;
+	
+	do {
+		
+		usb_set_debug(0);
+		usb_find_busses();
+		usb_find_devices();
+		dev = find_device(vendor, product);
+		sleep(1);
+		
+		if (dev == NULL)
+			if (debug == 1)
+				printout("DEBUG: No device found, wait 10sec...", 0);
+		
+		sleep(10);
+		
+		++counter;
+		
+		if (counter == 10) {
+			printout("Error: Device not found", 0);
+			exit(1);
+		}
+				
+	}  while (dev == NULL);
+	
+	assert(dev);
+	
+	if (debug == 1)
+		printout("DEBUG: USB device found", 0);
+	
+	devh = usb_open(dev);
+	assert(devh);
+	
+	signal(SIGTERM, release_usb_device);
+	
+	ret = usb_get_driver_np(devh, 0, buf, sizeof(buf));
+	if (ret == 0) {
+		ret = usb_detach_kernel_driver_np(devh, 0);
+	}
+		
+	ret = usb_claim_interface(devh, 0);
+	if (ret != 0) {
+		printout("Error: claim failed with error: ", ret);
+		exit(1);
+	}
+	
+	unsigned short iresult=0;
+	unsigned short voc=0;
+	
+	if (debug == 1)
+		printout("DEBUG: Read any remaining data from USB", 0);
+		
+	ret = usb_interrupt_read(devh, 0x00000081, buf, 0x0000010, 1000);
+	
+	if (debug == 1)
+		printout("DEBUG: Return code from USB read: ", ret);
+	
+	while(0==0) {
+	
+		time_t t = time(NULL);
+		struct tm tm = *localtime(&t);
+		
+		// USB COMMAND TO REQUEST DATA
+ 		// @h*TR
+		if (debug == 1)
+			printout("DEBUG: Write data to device", 0);
+		
+		memcpy(buf, "\x40\x68\x2a\x54\x52\x0a\x40\x40\x40\x40\x40\x40\x40\x40\x40\x40", 0x0000010);
+		ret = usb_interrupt_write(devh, 0x00000002, buf, 0x0000010, 1000);
+		
+		if (debug == 1)
+			printout("DEBUG: Return code from USB write: ", ret);
+		
+		if (debug == 1)
+			printout("DEBUG: Read USB", 0);
+		
+		ret = usb_interrupt_read(devh, 0x00000081, buf, 0x0000010, 1000);
+		
+		if (debug == 1)
+			printout("DEBUG: Return code from USB read: ", ret);
+		
+		if ( !((ret == 0) || (ret == 16)))
+		{
+			if (print_voc_only == 1) {
+				printf("0\n");
+			} else {
+				printout("ERROR: Invalid result code: ", ret);
+			}
+		}
+		
+		if (ret == 0) {
+			
+			if (debug == 1)
+				printout("DEBUG: Read USB", 0);
+			
+			sleep(1);
+			ret = usb_interrupt_read(devh, 0x00000081, buf, 0x0000010, 1000);
+			
+			if (debug == 1)
+				printout("DEBUG: Return code from USB read: ", ret);
+		}
+ 		
+		memcpy(&iresult,buf+2,2);
+		voc = __le16_to_cpu(iresult);
+		sleep(1);
+		
+		if (debug == 1) {
+			printout("DEBUG: Read USB [flush]", 0);
+		}
+		
+		ret = usb_interrupt_read(devh, 0x00000081, buf, 0x0000010, 1000);
+		
+		if (debug == 1)
+			printout("DEBUG: Return code from USB read: ", ret);
+ 		
+ 		// According to AppliedSensor specifications the output range is between 450 and 2000
+ 		// So only printout values between this range
+ 		
+//		if ( voc >= 450 && voc <= 2001) {
+        if (print_voc_only == 1) {
+            printf("%d\n", voc);
+        } else {
+            printf("%04d-%02d-%02d %02d:%02d:%02d, ", tm.tm_year + 1900, tm.tm_mon + 1, tm.tm_mday, tm.tm_hour, tm.tm_min, tm.tm_sec);
+            printf("VOC: %d, RESULT: OK\n", voc);
+        }
+//		} else {
+//			if (print_voc_only == 1) {
+//				printf("0\n");
+//			} else {
+//				printf("%04d-%02d-%02d %02d:%02d:%02d, ", tm.tm_year + 1900, tm.tm_mon + 1, tm.tm_mday, tm.tm_hour, tm.tm_min, tm.tm_sec);
+//				printf("VOC: %d, RESULT: Error value out of range\n", voc);
+//			}
+//		}
+		
+		// If one read, then exit
+		if (one_read == 1)
+			exit(0);
+		
+		// Wait for next request for data
+		sleep(10);
+	
+	}
+ 
+}
\ No newline at end of file

iam.py

+import re
+from subprocess import Popen, PIPE
+
+regex = r"VOC: ([0-9]*), RESULT: ([A-Z]*)"
+reg = re.compile(regex)
+
+
+class AirSensor(object):
+    @staticmethod
+    def __parse_result(s):
+        s = str(s)
+        m = reg.search(s)
+        voc, code = m.groups()
+        voc = int(voc)
+        return code, voc
+
+    @staticmethod
+    def __do_subprocess():
+        process = Popen(['iam-lib/airsensor/airsensor', '-o'], stdout=PIPE, stderr=PIPE)
+        return process.communicate()
+
+    @staticmethod
+    def get_value():
+        stdout, stderr = AirSensor.__do_subprocess()
+        code, voc = AirSensor.__parse_result(stdout)
+        if code == "OK":
+            return voc
+        else:
+            return None
+
+
+if __name__ == "__main__":
+    print(AirSensor.get_value())