#include <stdio.h>
#include <stdlib.h>

#include <xs.h>

/* ------------------------------------------------------------- */

int main(int argc, char *argv[])
{
    struct xs_handle  *xenstore;
    struct xs_transaction_handle *xst;
    char *xs_value = NULL, **vec;
    char *value;
    unsigned int count;

    xenstore = xs_daemon_open_readonly();
    if (NULL == xenstore) {
	fprintf(stderr,"can't connect to %s\n",xs_daemon_socket_ro());
	exit(1);
    }
    xs_watch(xenstore, "/", "token");

    for (;;) {
	vec = xs_read_watch(xenstore, &count);
	if (NULL == vec) {
	    fprintf(stderr,"xs_read_watch() failed\n");
	    exit(1);
	}
	switch (vec[XS_WATCH_PATH][0]) {
	case '/':
	    xst = xs_transaction_start(xenstore);
	    if (NULL != xst) {
		xs_value = xs_read(xenstore, xst, vec[XS_WATCH_PATH], NULL);
		xs_transaction_end(xenstore, xst, 0);
		if (NULL == xs_value)
		    value = "<deleted>";
		else
		    value = xs_value;
	    } else {
		value = "<error>";
	    }
	    break;
	default:
	    value = "<null>";
	    break;
	}
	fprintf(stderr,"%-64s :  \"%s\"\n", vec[XS_WATCH_PATH], value);

	if (xs_value) {
	    free(xs_value);
	    xs_value = NULL;
	}
	free(vec);
    }
}