diff --git a/relay.c b/relay.c index e1601ad..8fc43a0 100644 --- a/relay.c +++ b/relay.c @@ -127,7 +127,9 @@ static void relay_main(struct relay_node *r) { sexp_t *args = sexp_tail(message); size_t msglen = sexp_length(message); - /* TODO: have constant atoms for post, subscribe, unsubscribe etc (see also post_node()) */ + /* TODO: have constant atoms for post, subscribe, unsubscribe + etc (see also post_node() and the handler in queue.c etc) */ + if (!cmsg_bytes_cmp(selector, cmsg_cstring_bytes("post")) && (msglen == 4) && sexp_stringp(sexp_head(args))) { cmsg_bytes_t nodename = sexp_data(sexp_head(args));