Home-Integration/motion/main.c

#include "USBMicroX.h"
#include <fcntl.h>
#include <sys/stat.h>
#include <sys/time.h>

#define DATA_DIR "plexMonitor/"
#define OUT_FILE_DEFAULT "MOTION"
#define SLEEP_DELAY 250000
#define TIMEOUT 2
#define MAX_STR_LEN 4096

//#define DEBUG

// Typedef
typedef unsigned char u8;

// Prototypes
void timeout(int sig);
USBmX_DeviceRef init();
u8 readDev(USBmX_DeviceRef dev);
char * initPaths(const char *name);

// Globals
USBmX_ContextRef ctx;

int main(int argc, const char * argv[])
{
	char *outfile;
	const char *serial;
	unsigned int motion;
	USBmX_DeviceRef device;

	// Sanity check
	if (argc < 2) {
		fprintf(stderr, "Usage: %s SERIAL [NAME]\n", argv[0]);
		exit(-1);
	}

	// Setup the output file
	if (argc > 2) {
		outfile = initPaths(argv[2]);
	} else {
		outfile = initPaths(OUT_FILE_DEFAULT);
	}

	// Monitor for alarms
	signal(SIGALRM, timeout);

	// Setup the USB devices
	device = init(argv[1]);
	
	// Read forever
	while (1) {
		// Check for motion in any device
		motion = 0;
		if (readDev(device)) {
			motion = 1;
		}

		// If we detected motion
		if (motion > 0) {
			#ifdef DEBUG
			printf("Motion detected\n");
			#endif
			if (utimes(outfile, NULL) != 0) {
				fprintf(stderr, "Error touching output file (%s): %s\n", strerror(errno), outfile);
				exit(2);
			}
		} else {
			#ifdef DEBUG
			printf("\n");
			#endif
		}	

		// Delay and loop
		usleep(SLEEP_DELAY);
	}
	
	// Cleanup (we never get here)
	USBmX_Destroy(ctx);
	return 0;
}

// Catch the timeout
void timeout(int sig) {
	signal(sig, SIG_IGN);
	fprintf(stderr, "Timeout waiting for USB read\n");
	exit(1);
}

// Setup the USBMicro context and build refs to our specified devices
USBmX_DeviceRef init(const char *serial) {
	USBmX_DeviceRef device;

	// Create a new USBmicroX context as needed
	if (!ctx) {
		ctx = USBmX_Create();
		USBmX_Begin(ctx);
	}

	// Find the specified device
	device = USBmX_DeviceWithSerial(ctx, serial);
	if (!device) {
		fprintf(stderr, "Device not found: %s\n", serial);
		exit(1);
	}

	// Return device handle
	return device;
}

// Read the specified USBMicro device
u8 readDev(USBmX_DeviceRef dev) {
	unsigned char data = 0x00;

	// Enable the timeout
	alarm(TIMEOUT);

	// Read from the device
	if (USBmX_ReadA(dev, &data) != 0) {
		fprintf(stderr, "Device read error\n");
		exit(1);
	}

	// Clear the timeout
	alarm(0);

	// Return pin A5
	return (data & 0x20);
}

// Setup the data directory and output file
char * initPaths(const char *name) {
	int fd;
	size_t dirLen, fileLen;
	char *datadir, *outfile;
	struct stat statbuf;

	// Construct the data directory and output file paths
	dirLen = confstr(_CS_DARWIN_USER_TEMP_DIR, NULL, (size_t) 0);
	dirLen += sizeof(DATA_DIR);
	fileLen = dirLen + strnlen(name, MAX_STR_LEN);
	datadir = malloc(dirLen);
	outfile = malloc(fileLen);
	if (datadir == NULL || outfile == NULL) {
		fprintf(stderr, "Out of memory\n");
		exit(1);
	}
	confstr(_CS_DARWIN_USER_TEMP_DIR, datadir, dirLen);
	strlcat(datadir, DATA_DIR, dirLen);
	strlcpy(outfile, datadir, fileLen);
	strlcat(outfile, name, fileLen);

	// Create the datadir as needed
	stat(datadir, &statbuf);
	if (!S_ISDIR(statbuf.st_mode)) {
		fprintf(stderr, "Creating data directory: %s\n", datadir);
		if (mkdir(datadir, S_IRUSR | S_IWUSR | S_IXUSR) != 0) {
			fprintf(stderr, "Error creating data directory (%s): %s\n", strerror(errno), datadir);
			exit(1);
		}
	}

	// Create the output file as needed
	stat(outfile, &statbuf);
	if(!S_ISREG(statbuf.st_mode)) {
		fprintf(stderr, "Creating output file: %s\n", outfile);
		fd = open(outfile, O_RDWR | O_CREAT, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH);
		if (fd <= 0 || close(fd) != 0) {
			fprintf(stderr, "Error creating output file (%s): %s\n", strerror(errno), outfile);
			exit(1);
		}
	}

	// Return the output file path
	return outfile;
}