add various support files

Signed-off-by: Asbjørn Sloth Tønnesen <asbjorn@asbjorn.biz>

7 files changed, 186 insertions, 1 deletions

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..e38f775
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,4 @@
+.*swp
+queue
+pack.tar.xz
+oldversions
diff --git a/Makefile b/Makefile
index 315ea01..33542c7 100644
--- a/Makefile
+++ b/Makefile
@@ -13,4 +13,6 @@ $(SUBDIRS):
 $(SUBDIRS_CLEAN):
 	make -C $(subst _clean,,$@) clean
 pack:
-	tar zcfv pack.tar.gz $(shell cat packlist)
+	tar Jcfv pack.tar.xz $(shell cat packlist)
+deploy:
+	tar Jcf - $(shell cat packlist) | ssh space.labitat.dk tar Jxf -
diff --git a/freebsd/kqueue.c b/freebsd/kqueue.c
new file mode 100644
index 0000000..e8825db
--- /dev/null
+++ b/freebsd/kqueue.c
@@ -0,0 +1,142 @@
+#include <sys/types.h>
+#include <stdint.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <fcntl.h>
+#include <sys/event.h>
+#include <sys/time.h>
+#include <sys/stat.h>
+#include <unistd.h>
+#include <string.h>
+#include <errno.h>
+
+int printer_ready;
+char * printer;
+char * queue_dir;
+char * trigger;
+#define BUFLEN 50
+char queue_dir_new[BUFLEN];
+char trigger_cmd[BUFLEN];
+
+int open_and_subscribe(struct kevent * change, const char * path)
+{
+	int f;
+	f = open(path, O_RDONLY);
+	if (f == -1) {
+		perror("open");
+		return -1;
+	}
+
+	EV_SET(change, f, EVFILT_VNODE,
+	                  EV_ADD | EV_ENABLE | EV_ONESHOT,
+	                  NOTE_DELETE | NOTE_EXTEND |
+	                  NOTE_WRITE | NOTE_ATTRIB,
+	       0, 0);
+}
+
+int check_printer_status(){
+	struct stat buf;
+	//printf("%s\n", printer);
+	int r = stat(printer, &buf);
+	if (r<0) {
+		if (printer_ready != 0) {
+			printf("Printer offline\n");
+		}
+		printer_ready = 0;
+		if (errno == ENOENT) {
+			printf("Printer not detected\n");
+		} else {
+			perror("stat");
+			return -1;
+		}
+	} else {
+		if (printer_ready != 1) {
+			printf("Printer online\n");
+			print_loop(printer, queue_dir);
+		}
+		printer_ready = 1;
+	}
+	return 0;
+}
+
+int print_loop()
+{
+	FILE * p;
+	int status;
+	char buf[BUFLEN];
+	printf("Print loop\n");
+	p = popen(trigger_cmd, "r");
+	if (p == NULL)
+		perror("popen");
+	while (fgets(buf, BUFLEN, p) != NULL)
+		printf("%s", buf);
+	status = pclose(p);
+	if (status != 0) {
+		printf("Trigger exited with status %d\n", status);
+	}
+	return status;
+}
+
+int main(int argc, const char * argv[])
+{
+	int fd, fq, kq, nev;
+	struct kevent change;
+	struct kevent event;
+
+	int len;
+
+	if (argc != 4) {
+		fprintf(stderr, "usage: %s printer queue_dir trigger\n", argv[0]);
+		return -1;
+	}
+	printer = strdup(argv[1]);
+	queue_dir = strdup(argv[2]);
+	trigger = strdup(argv[3]);
+
+	len = snprintf(trigger_cmd, BUFLEN, "%s %s %s", trigger, printer, queue_dir);
+	if (len >= BUFLEN - 1) {
+		printf("Buffer too small\n");
+		return -1;
+	}
+
+	len = snprintf(queue_dir_new, BUFLEN, "%s/new", queue_dir);
+	if (len >= BUFLEN - 1) {
+		printf("Buffer too small\n");
+		return -1;
+	}
+
+	printer_ready = 0;
+
+	kq = kqueue();
+	if (kq == -1)
+		perror("kqueue");
+
+	fq = open_and_subscribe(&change, queue_dir_new);
+
+	struct timespec timeout;
+	timeout.tv_sec = 5;
+	timeout.tv_nsec = 0;
+
+	check_printer_status();
+	for (;;) {
+		nev = kevent(kq, &change, 1, &event, 1, &timeout);
+		if (nev == -1)
+			perror("kevent");
+		if (nev == 0) { // timeout
+			check_printer_status();
+		} else if (nev > 0) {
+			if (event.fflags & NOTE_DELETE) {
+				continue;
+			}
+			printf("Got event for %d\n", event.ident);
+			if (printer_ready) {
+				print_loop(printer, queue_dir, trigger);
+			}
+		}
+	}
+
+	close(kq);
+	close(fq);
+	close(fd);
+	return EXIT_SUCCESS;
+}
diff --git a/printloop.sh b/printloop.sh
new file mode 100755
index 0000000..74ad25e
--- /dev/null
+++ b/printloop.sh
@@ -0,0 +1,15 @@
+#!/bin/sh
+
+printer="/dev/labelprinter"
+queuedir=queue
+
+print_queue(){
+	for job in $(ls -1 "$queuedir/new"); do
+		./trigger.sh "$printer" "$queuedir"
+	done
+}
+
+print_queue
+while inotifywait --quiet "$queuedir/new" /dev; do
+	print_queue
+done
diff --git a/start.sh b/start.sh
new file mode 100755
index 0000000..4cae230
--- /dev/null
+++ b/start.sh
@@ -0,0 +1 @@
+./printloop.sh | tee /dev/stderr | (cd web && ./labitrackd.lua 0.0.0.0:8081 ../queue/
diff --git a/trigger.sh b/trigger.sh
new file mode 100755
index 0000000..9740048
--- /dev/null
+++ b/trigger.sh
@@ -0,0 +1,19 @@
+#!/bin/sh
+
+printer="$1"
+queue_dir="$2"
+printed_dir=$queue_dir/printed/
+
+mkdir -p $printed_dir
+
+for file in $(ls $queue_dir/new/* 2>/dev/null); do
+	echo printing $file
+	./ql570/ql570 $printer $file
+	status=$?
+	if [ $status -ne 0 ] ; then
+		exit $status
+	fi
+	mv $file $printed_dir
+done
+
+exit 0
diff --git a/udev.rules b/udev.rules
new file mode 100644
index 0000000..d4c8353
--- /dev/null
+++ b/udev.rules
@@ -0,0 +1,2 @@
+# rule for labelprinter
+SUBSYSTEM=="usb", ATTRS{idVendor}=="04f9", ATTRS{idProduct}=="2028", SYMLINK+="labelprinter", MODE="0666"