sites

dwm-ipc-20201106-f04cac6.diff (90493B)

---

 From 9c4c16485ac374583a1055ff7c26cba53ac92c05 Mon Sep 17 00:00:00 2001
 From: mihirlad55 <mihirlad55@gmail.com>
 Date: Fri, 6 Nov 2020 17:13:42 +0000
 Subject: [PATCH] Add IPC support through a unix socket
 
 This patch currently supports the following requests:
 * Run custom commands with arguments (similar to key bind functions)
 * Get monitor properties
 * Get all available layouts
 * Get available tags
 * Get client properties
 * Subscribe to tag change, client focus change, and layout change,
   monitor focus change, focused title change, and client state change
   events
 
 This patch includes a dwm-msg cli program that supports all of the
 above requests for easy integration into shell scripts.
 
 The messages are sent in a JSON format to promote integration to
 increase scriptability in languages like Python/JavaScript.
 
 The patch requires YAJL for JSON parsing and a system with epoll
 support. Portability is planned to be increased in the future.
 
 This patch is best applied after all other patches to avoid merge
 conflicts.
 
 For more info on the IPC implementation and how to send/receive
 messages, documentation can be found at
 https://github.com/mihirlad55/dwm-ipc
 ---
  IPCClient.c  |   66 +++
  IPCClient.h  |   61 +++
  Makefile     |   10 +-
  config.def.h |   18 +
  config.mk    |    8 +-
  dwm-msg.c    |  548 +++++++++++++++++++++++
  dwm.c        |  150 ++++++-
  ipc.c        | 1202 ++++++++++++++++++++++++++++++++++++++++++++++++++
  ipc.h        |  320 ++++++++++++++
  util.c       |  135 ++++++
  util.h       |   10 +
  yajl_dumps.c |  351 +++++++++++++++
  yajl_dumps.h |   65 +++
  13 files changed, 2931 insertions(+), 13 deletions(-)
  create mode 100644 IPCClient.c
  create mode 100644 IPCClient.h
  create mode 100644 dwm-msg.c
  create mode 100644 ipc.c
  create mode 100644 ipc.h
  create mode 100644 yajl_dumps.c
  create mode 100644 yajl_dumps.h
 
 diff --git a/IPCClient.c b/IPCClient.c
 new file mode 100644
 index 0000000..0d3eefb
 --- /dev/null
 +++ b/IPCClient.c
 @@ -0,0 +1,66 @@
 +#include "IPCClient.h"
 +
 +#include <string.h>
 +#include <sys/epoll.h>
 +
 +#include "util.h"
 +
 +IPCClient *
 +ipc_client_new(int fd)
 +{
 +  IPCClient *c = (IPCClient *)malloc(sizeof(IPCClient));
 +
 +  if (c == NULL) return NULL;
 +
 +  // Initialize struct
 +  memset(&c->event, 0, sizeof(struct epoll_event));
 +
 +  c->buffer_size = 0;
 +  c->buffer = NULL;
 +  c->fd = fd;
 +  c->event.data.fd = fd;
 +  c->next = NULL;
 +  c->prev = NULL;
 +  c->subscriptions = 0;
 +
 +  return c;
 +}
 +
 +void
 +ipc_list_add_client(IPCClientList *list, IPCClient *nc)
 +{
 +  DEBUG("Adding client with fd %d to list\n", nc->fd);
 +
 +  if (*list == NULL) {
 +    // List is empty, point list at first client
 +    *list = nc;
 +  } else {
 +    IPCClient *c;
 +    // Go to last client in list
 +    for (c = *list; c && c->next; c = c->next)
 +      ;
 +    c->next = nc;
 +    nc->prev = c;
 +  }
 +}
 +
 +void
 +ipc_list_remove_client(IPCClientList *list, IPCClient *c)
 +{
 +  IPCClient *cprev = c->prev;
 +  IPCClient *cnext = c->next;
 +
 +  if (cprev != NULL) cprev->next = c->next;
 +  if (cnext != NULL) cnext->prev = c->prev;
 +  if (c == *list) *list = c->next;
 +}
 +
 +IPCClient *
 +ipc_list_get_client(IPCClientList list, int fd)
 +{
 +  for (IPCClient *c = list; c; c = c->next) {
 +    if (c->fd == fd) return c;
 +  }
 +
 +  return NULL;
 +}
 diff --git a/IPCClient.h b/IPCClient.h
 new file mode 100644
 index 0000000..307dfba
 --- /dev/null
 +++ b/IPCClient.h
 @@ -0,0 +1,61 @@
 +#ifndef IPC_CLIENT_H_
 +#define IPC_CLIENT_H_
 +
 +#include <stdio.h>
 +#include <stdlib.h>
 +#include <sys/epoll.h>
 +
 +typedef struct IPCClient IPCClient;
 +/**
 + * This structure contains the details of an IPC Client and pointers for a
 + * linked list
 + */
 +struct IPCClient {
 +  int fd;
 +  int subscriptions;
 +
 +  char *buffer;
 +  uint32_t buffer_size;
 +
 +  struct epoll_event event;
 +  IPCClient *next;
 +  IPCClient *prev;
 +};
 +
 +typedef IPCClient *IPCClientList;
 +
 +/**
 + * Allocate memory for new IPCClient with the specified file descriptor and
 + * initialize struct.
 + *
 + * @param fd File descriptor of IPC client
 + *
 + * @return Address to allocated IPCClient struct
 + */
 +IPCClient *ipc_client_new(int fd);
 +
 +/**
 + * Add an IPC Client to the specified list
 + *
 + * @param list Address of the list to add the client to
 + * @param nc Address of the IPCClient
 + */
 +void ipc_list_add_client(IPCClientList *list, IPCClient *nc);
 +
 +/**
 + * Remove an IPCClient from the specified list
 + *
 + * @param list Address of the list to remove the client from
 + * @param c Address of the IPCClient
 + */
 +void ipc_list_remove_client(IPCClientList *list, IPCClient *c);
 +
 +/**
 + * Get an IPCClient from the specified IPCClient list
 + *
 + * @param list List to remove the client from
 + * @param fd File descriptor of the IPCClient
 + */
 +IPCClient *ipc_list_get_client(IPCClientList list, int fd);
 +
 +#endif  // IPC_CLIENT_H_
 diff --git a/Makefile b/Makefile
 index 77bcbc0..0456754 100644
 --- a/Makefile
 +++ b/Makefile
 @@ -6,7 +6,7 @@ include config.mk
  SRC = drw.c dwm.c util.c
  OBJ = ${SRC:.c=.o}
  
 -all: options dwm
 +all: options dwm dwm-msg
  
  options:
  	@echo dwm build options:
 @@ -25,8 +25,11 @@ config.h:
  dwm: ${OBJ}
  	${CC} -o $@ ${OBJ} ${LDFLAGS}
  
 +dwm-msg: dwm-msg.o
 +	${CC} -o $@ $< ${LDFLAGS}
 +
  clean:
 -	rm -f dwm ${OBJ} dwm-${VERSION}.tar.gz
 +	rm -f dwm dwm-msg ${OBJ} dwm-${VERSION}.tar.gz
  
  dist: clean
  	mkdir -p dwm-${VERSION}
 @@ -38,8 +41,9 @@ dist: clean
  
  install: all
  	mkdir -p ${DESTDIR}${PREFIX}/bin
 -	cp -f dwm ${DESTDIR}${PREFIX}/bin
 +	cp -f dwm dwm-msg ${DESTDIR}${PREFIX}/bin
  	chmod 755 ${DESTDIR}${PREFIX}/bin/dwm
 +	chmod 755 ${DESTDIR}${PREFIX}/bin/dwm-msg
  	mkdir -p ${DESTDIR}${MANPREFIX}/man1
  	sed "s/VERSION/${VERSION}/g" < dwm.1 > ${DESTDIR}${MANPREFIX}/man1/dwm.1
  	chmod 644 ${DESTDIR}${MANPREFIX}/man1/dwm.1
 diff --git a/config.def.h b/config.def.h
 index 1c0b587..059a831 100644
 --- a/config.def.h
 +++ b/config.def.h
 @@ -113,3 +113,21 @@ static Button buttons[] = {
  	{ ClkTagBar,            MODKEY,         Button3,        toggletag,      {0} },
  };
  
 +static const char *ipcsockpath = "/tmp/dwm.sock";
 +static IPCCommand ipccommands[] = {
 +  IPCCOMMAND(  view,                1,      {ARG_TYPE_UINT}   ),
 +  IPCCOMMAND(  toggleview,          1,      {ARG_TYPE_UINT}   ),
 +  IPCCOMMAND(  tag,                 1,      {ARG_TYPE_UINT}   ),
 +  IPCCOMMAND(  toggletag,           1,      {ARG_TYPE_UINT}   ),
 +  IPCCOMMAND(  tagmon,              1,      {ARG_TYPE_UINT}   ),
 +  IPCCOMMAND(  focusmon,            1,      {ARG_TYPE_SINT}   ),
 +  IPCCOMMAND(  focusstack,          1,      {ARG_TYPE_SINT}   ),
 +  IPCCOMMAND(  zoom,                1,      {ARG_TYPE_NONE}   ),
 +  IPCCOMMAND(  incnmaster,          1,      {ARG_TYPE_SINT}   ),
 +  IPCCOMMAND(  killclient,          1,      {ARG_TYPE_SINT}   ),
 +  IPCCOMMAND(  togglefloating,      1,      {ARG_TYPE_NONE}   ),
 +  IPCCOMMAND(  setmfact,            1,      {ARG_TYPE_FLOAT}  ),
 +  IPCCOMMAND(  setlayoutsafe,       1,      {ARG_TYPE_PTR}    ),
 +  IPCCOMMAND(  quit,                1,      {ARG_TYPE_NONE}   )
 +};
 +
 diff --git a/config.mk b/config.mk
 index 7084c33..8570938 100644
 --- a/config.mk
 +++ b/config.mk
 @@ -20,9 +20,13 @@ FREETYPEINC = /usr/include/freetype2
  # OpenBSD (uncomment)
  #FREETYPEINC = ${X11INC}/freetype2
  
 +# yajl
 +YAJLLIBS = -lyajl
 +YAJLINC = /usr/include/yajl
 +
  # includes and libs
 -INCS = -I${X11INC} -I${FREETYPEINC}
 -LIBS = -L${X11LIB} -lX11 ${XINERAMALIBS} ${FREETYPELIBS}
 +INCS = -I${X11INC} -I${FREETYPEINC} -I${YAJLINC}
 +LIBS = -L${X11LIB} -lX11 ${XINERAMALIBS} ${FREETYPELIBS} ${YAJLLIBS}
  
  # flags
  CPPFLAGS = -D_DEFAULT_SOURCE -D_BSD_SOURCE -D_POSIX_C_SOURCE=200809L -DVERSION=\"${VERSION}\" ${XINERAMAFLAGS}
 diff --git a/dwm-msg.c b/dwm-msg.c
 new file mode 100644
 index 0000000..1971d32
 --- /dev/null
 +++ b/dwm-msg.c
 @@ -0,0 +1,548 @@
 +#include <ctype.h>
 +#include <errno.h>
 +#include <inttypes.h>
 +#include <stdarg.h>
 +#include <stdint.h>
 +#include <stdio.h>
 +#include <stdlib.h>
 +#include <string.h>
 +#include <sys/socket.h>
 +#include <sys/un.h>
 +#include <unistd.h>
 +#include <yajl/yajl_gen.h>
 +
 +#define IPC_MAGIC "DWM-IPC"
 +// clang-format off
 +#define IPC_MAGIC_ARR { 'D', 'W', 'M', '-', 'I', 'P', 'C' }
 +// clang-format on
 +#define IPC_MAGIC_LEN 7  // Not including null char
 +
 +#define IPC_EVENT_TAG_CHANGE "tag_change_event"
 +#define IPC_EVENT_CLIENT_FOCUS_CHANGE "client_focus_change_event"
 +#define IPC_EVENT_LAYOUT_CHANGE "layout_change_event"
 +#define IPC_EVENT_MONITOR_FOCUS_CHANGE "monitor_focus_change_event"
 +#define IPC_EVENT_FOCUSED_TITLE_CHANGE "focused_title_change_event"
 +#define IPC_EVENT_FOCUSED_STATE_CHANGE "focused_state_change_event"
 +
 +#define YSTR(str) yajl_gen_string(gen, (unsigned char *)str, strlen(str))
 +#define YINT(num) yajl_gen_integer(gen, num)
 +#define YDOUBLE(num) yajl_gen_double(gen, num)
 +#define YBOOL(v) yajl_gen_bool(gen, v)
 +#define YNULL() yajl_gen_null(gen)
 +#define YARR(body)                                                             \
 +  {                                                                            \
 +    yajl_gen_array_open(gen);                                                  \
 +    body;                                                                      \
 +    yajl_gen_array_close(gen);                                                 \
 +  }
 +#define YMAP(body)                                                             \
 +  {                                                                            \
 +    yajl_gen_map_open(gen);                                                    \
 +    body;                                                                      \
 +    yajl_gen_map_close(gen);                                                   \
 +  }
 +
 +typedef unsigned long Window;
 +
 +const char *DEFAULT_SOCKET_PATH = "/tmp/dwm.sock";
 +static int sock_fd = -1;
 +static unsigned int ignore_reply = 0;
 +
 +typedef enum IPCMessageType {
 +  IPC_TYPE_RUN_COMMAND = 0,
 +  IPC_TYPE_GET_MONITORS = 1,
 +  IPC_TYPE_GET_TAGS = 2,
 +  IPC_TYPE_GET_LAYOUTS = 3,
 +  IPC_TYPE_GET_DWM_CLIENT = 4,
 +  IPC_TYPE_SUBSCRIBE = 5,
 +  IPC_TYPE_EVENT = 6
 +} IPCMessageType;
 +
 +// Every IPC message must begin with this
 +typedef struct dwm_ipc_header {
 +  uint8_t magic[IPC_MAGIC_LEN];
 +  uint32_t size;
 +  uint8_t type;
 +} __attribute((packed)) dwm_ipc_header_t;
 +
 +static int
 +recv_message(uint8_t *msg_type, uint32_t *reply_size, uint8_t **reply)
 +{
 +  uint32_t read_bytes = 0;
 +  const int32_t to_read = sizeof(dwm_ipc_header_t);
 +  char header[to_read];
 +  char *walk = header;
 +
 +  // Try to read header
 +  while (read_bytes < to_read) {
 +    ssize_t n = read(sock_fd, header + read_bytes, to_read - read_bytes);
 +
 +    if (n == 0) {
 +      if (read_bytes == 0) {
 +        fprintf(stderr, "Unexpectedly reached EOF while reading header.");
 +        fprintf(stderr,
 +                "Read %" PRIu32 " bytes, expected %" PRIu32 " total bytes.\n",
 +                read_bytes, to_read);
 +        return -2;
 +      } else {
 +        fprintf(stderr, "Unexpectedly reached EOF while reading header.");
 +        fprintf(stderr,
 +                "Read %" PRIu32 " bytes, expected %" PRIu32 " total bytes.\n",
 +                read_bytes, to_read);
 +        return -3;
 +      }
 +    } else if (n == -1) {
 +      return -1;
 +    }
 +
 +    read_bytes += n;
 +  }
 +
 +  // Check if magic string in header matches
 +  if (memcmp(walk, IPC_MAGIC, IPC_MAGIC_LEN) != 0) {
 +    fprintf(stderr, "Invalid magic string. Got '%.*s', expected '%s'\n",
 +            IPC_MAGIC_LEN, walk, IPC_MAGIC);
 +    return -3;
 +  }
 +
 +  walk += IPC_MAGIC_LEN;
 +
 +  // Extract reply size
 +  memcpy(reply_size, walk, sizeof(uint32_t));
 +  walk += sizeof(uint32_t);
 +
 +  // Extract message type
 +  memcpy(msg_type, walk, sizeof(uint8_t));
 +  walk += sizeof(uint8_t);
 +
 +  (*reply) = malloc(*reply_size);
 +
 +  // Extract payload
 +  read_bytes = 0;
 +  while (read_bytes < *reply_size) {
 +    ssize_t n = read(sock_fd, *reply + read_bytes, *reply_size - read_bytes);
 +
 +    if (n == 0) {
 +      fprintf(stderr, "Unexpectedly reached EOF while reading payload.");
 +      fprintf(stderr, "Read %" PRIu32 " bytes, expected %" PRIu32 " bytes.\n",
 +              read_bytes, *reply_size);
 +      free(*reply);
 +      return -2;
 +    } else if (n == -1) {
 +      if (errno == EINTR || errno == EAGAIN) continue;
 +      free(*reply);
 +      return -1;
 +    }
 +
 +    read_bytes += n;
 +  }
 +
 +  return 0;
 +}
 +
 +static int
 +read_socket(IPCMessageType *msg_type, uint32_t *msg_size, char **msg)
 +{
 +  int ret = -1;
 +
 +  while (ret != 0) {
 +    ret = recv_message((uint8_t *)msg_type, msg_size, (uint8_t **)msg);
 +
 +    if (ret < 0) {
 +      // Try again (non-fatal error)
 +      if (ret == -1 && (errno == EINTR || errno == EAGAIN)) continue;
 +
 +      fprintf(stderr, "Error receiving response from socket. ");
 +      fprintf(stderr, "The connection might have been lost.\n");
 +      exit(2);
 +    }
 +  }
 +
 +  return 0;
 +}
 +
 +static ssize_t
 +write_socket(const void *buf, size_t count)
 +{
 +  size_t written = 0;
 +
 +  while (written < count) {
 +    const ssize_t n =
 +        write(sock_fd, ((uint8_t *)buf) + written, count - written);
 +
 +    if (n == -1) {
 +      if (errno == EAGAIN || errno == EWOULDBLOCK || errno == EINTR)
 +        continue;
 +      else
 +        return n;
 +    }
 +    written += n;
 +  }
 +  return written;
 +}
 +
 +static void
 +connect_to_socket()
 +{
 +  struct sockaddr_un addr;
 +
 +  int sock = socket(AF_UNIX, SOCK_STREAM, 0);
 +
 +  // Initialize struct to 0
 +  memset(&addr, 0, sizeof(struct sockaddr_un));
 +
 +  addr.sun_family = AF_UNIX;
 +  strcpy(addr.sun_path, DEFAULT_SOCKET_PATH);
 +
 +  connect(sock, (const struct sockaddr *)&addr, sizeof(struct sockaddr_un));
 +
 +  sock_fd = sock;
 +}
 +
 +static int
 +send_message(IPCMessageType msg_type, uint32_t msg_size, uint8_t *msg)
 +{
 +  dwm_ipc_header_t header = {
 +      .magic = IPC_MAGIC_ARR, .size = msg_size, .type = msg_type};
 +
 +  size_t header_size = sizeof(dwm_ipc_header_t);
 +  size_t total_size = header_size + msg_size;
 +
 +  uint8_t buffer[total_size];
 +
 +  // Copy header to buffer
 +  memcpy(buffer, &header, header_size);
 +  // Copy message to buffer
 +  memcpy(buffer + header_size, msg, header.size);
 +
 +  write_socket(buffer, total_size);
 +
 +  return 0;
 +}
 +
 +static int
 +is_float(const char *s)
 +{
 +  size_t len = strlen(s);
 +  int is_dot_used = 0;
 +  int is_minus_used = 0;
 +
 +  // Floats can only have one decimal point in between or digits
 +  // Optionally, floats can also be below zero (negative)
 +  for (int i = 0; i < len; i++) {
 +    if (isdigit(s[i]))
 +      continue;
 +    else if (!is_dot_used && s[i] == '.' && i != 0 && i != len - 1) {
 +      is_dot_used = 1;
 +      continue;
 +    } else if (!is_minus_used && s[i] == '-' && i == 0) {
 +      is_minus_used = 1;
 +      continue;
 +    } else
 +      return 0;
 +  }
 +
 +  return 1;
 +}
 +
 +static int
 +is_unsigned_int(const char *s)
 +{
 +  size_t len = strlen(s);
 +
 +  // Unsigned int can only have digits
 +  for (int i = 0; i < len; i++) {
 +    if (isdigit(s[i]))
 +      continue;
 +    else
 +      return 0;
 +  }
 +
 +  return 1;
 +}
 +
 +static int
 +is_signed_int(const char *s)
 +{
 +  size_t len = strlen(s);
 +
 +  // Signed int can only have digits and a negative sign at the start
 +  for (int i = 0; i < len; i++) {
 +    if (isdigit(s[i]))
 +      continue;
 +    else if (i == 0 && s[i] == '-') {
 +      continue;
 +    } else
 +      return 0;
 +  }
 +
 +  return 1;
 +}
 +
 +static void
 +flush_socket_reply()
 +{
 +  IPCMessageType reply_type;
 +  uint32_t reply_size;
 +  char *reply;
 +
 +  read_socket(&reply_type, &reply_size, &reply);
 +
 +  free(reply);
 +}
 +
 +static void
 +print_socket_reply()
 +{
 +  IPCMessageType reply_type;
 +  uint32_t reply_size;
 +  char *reply;
 +
 +  read_socket(&reply_type, &reply_size, &reply);
 +
 +  printf("%.*s\n", reply_size, reply);
 +  fflush(stdout);
 +  free(reply);
 +}
 +
 +static int
 +run_command(const char *name, char *args[], int argc)
 +{
 +  const unsigned char *msg;
 +  size_t msg_size;
 +
 +  yajl_gen gen = yajl_gen_alloc(NULL);
 +
 +  // Message format:
 +  // {
 +  //   "command": "<name>",
 +  //   "args": [ ... ]
 +  // }
 +  // clang-format off
 +  YMAP(
 +    YSTR("command"); YSTR(name);
 +    YSTR("args"); YARR(
 +      for (int i = 0; i < argc; i++) {
 +        if (is_signed_int(args[i])) {
 +          long long num = atoll(args[i]);
 +          YINT(num);
 +        } else if (is_float(args[i])) {
 +          float num = atof(args[i]);
 +          YDOUBLE(num);
 +        } else {
 +          YSTR(args[i]);
 +        }
 +      }
 +    )
 +  )
 +  // clang-format on
 +
 +  yajl_gen_get_buf(gen, &msg, &msg_size);
 +
 +  send_message(IPC_TYPE_RUN_COMMAND, msg_size, (uint8_t *)msg);
 +
 +  if (!ignore_reply)
 +    print_socket_reply();
 +  else
 +    flush_socket_reply();
 +
 +  yajl_gen_free(gen);
 +
 +  return 0;
 +}
 +
 +static int
 +get_monitors()
 +{
 +  send_message(IPC_TYPE_GET_MONITORS, 1, (uint8_t *)"");
 +  print_socket_reply();
 +  return 0;
 +}
 +
 +static int
 +get_tags()
 +{
 +  send_message(IPC_TYPE_GET_TAGS, 1, (uint8_t *)"");
 +  print_socket_reply();
 +
 +  return 0;
 +}
 +
 +static int
 +get_layouts()
 +{
 +  send_message(IPC_TYPE_GET_LAYOUTS, 1, (uint8_t *)"");
 +  print_socket_reply();
 +
 +  return 0;
 +}
 +
 +static int
 +get_dwm_client(Window win)
 +{
 +  const unsigned char *msg;
 +  size_t msg_size;
 +
 +  yajl_gen gen = yajl_gen_alloc(NULL);
 +
 +  // Message format:
 +  // {
 +  //   "client_window_id": "<win>"
 +  // }
 +  // clang-format off
 +  YMAP(
 +    YSTR("client_window_id"); YINT(win);
 +  )
 +  // clang-format on
 +
 +  yajl_gen_get_buf(gen, &msg, &msg_size);
 +
 +  send_message(IPC_TYPE_GET_DWM_CLIENT, msg_size, (uint8_t *)msg);
 +
 +  print_socket_reply();
 +
 +  yajl_gen_free(gen);
 +
 +  return 0;
 +}
 +
 +static int
 +subscribe(const char *event)
 +{
 +  const unsigned char *msg;
 +  size_t msg_size;
 +
 +  yajl_gen gen = yajl_gen_alloc(NULL);
 +
 +  // Message format:
 +  // {
 +  //   "event": "<event>",
 +  //   "action": "subscribe"
 +  // }
 +  // clang-format off
 +  YMAP(
 +    YSTR("event"); YSTR(event);
 +    YSTR("action"); YSTR("subscribe");
 +  )
 +  // clang-format on
 +
 +  yajl_gen_get_buf(gen, &msg, &msg_size);
 +
 +  send_message(IPC_TYPE_SUBSCRIBE, msg_size, (uint8_t *)msg);
 +
 +  if (!ignore_reply)
 +    print_socket_reply();
 +  else
 +    flush_socket_reply();
 +
 +  yajl_gen_free(gen);
 +
 +  return 0;
 +}
 +
 +static void
 +usage_error(const char *prog_name, const char *format, ...)
 +{
 +  va_list args;
 +  va_start(args, format);
 +
 +  fprintf(stderr, "Error: ");
 +  vfprintf(stderr, format, args);
 +  fprintf(stderr, "\nusage: %s <command> [...]\n", prog_name);
 +  fprintf(stderr, "Try '%s help'\n", prog_name);
 +
 +  va_end(args);
 +  exit(1);
 +}
 +
 +static void
 +print_usage(const char *name)
 +{
 +  printf("usage: %s [options] <command> [...]\n", name);
 +  puts("");
 +  puts("Commands:");
 +  puts("  run_command <name> [args...]    Run an IPC command");
 +  puts("");
 +  puts("  get_monitors                    Get monitor properties");
 +  puts("");
 +  puts("  get_tags                        Get list of tags");
 +  puts("");
 +  puts("  get_layouts                     Get list of layouts");
 +  puts("");
 +  puts("  get_dwm_client <window_id>      Get dwm client proprties");
 +  puts("");
 +  puts("  subscribe [events...]           Subscribe to specified events");
 +  puts("                                  Options: " IPC_EVENT_TAG_CHANGE ",");
 +  puts("                                  " IPC_EVENT_LAYOUT_CHANGE ",");
 +  puts("                                  " IPC_EVENT_CLIENT_FOCUS_CHANGE ",");
 +  puts("                                  " IPC_EVENT_MONITOR_FOCUS_CHANGE ",");
 +  puts("                                  " IPC_EVENT_FOCUSED_TITLE_CHANGE ",");
 +  puts("                                  " IPC_EVENT_FOCUSED_STATE_CHANGE);
 +  puts("");
 +  puts("  help                            Display this message");
 +  puts("");
 +  puts("Options:");
 +  puts("  --ignore-reply                  Don't print reply messages from");
 +  puts("                                  run_command and subscribe.");
 +  puts("");
 +}
 +
 +int
 +main(int argc, char *argv[])
 +{
 +  const char *prog_name = argv[0];
 +
 +  connect_to_socket();
 +  if (sock_fd == -1) {
 +    fprintf(stderr, "Failed to connect to socket\n");
 +    return 1;
 +  }
 +
 +  int i = 1;
 +  if (i < argc && strcmp(argv[i], "--ignore-reply") == 0) {
 +    ignore_reply = 1;
 +    i++;
 +  }
 +
 +  if (i >= argc) usage_error(prog_name, "Expected an argument, got none");
 +
 +  if (strcmp(argv[i], "help") == 0)
 +    print_usage(prog_name);
 +  else if (strcmp(argv[i], "run_command") == 0) {
 +    if (++i >= argc) usage_error(prog_name, "No command specified");
 +    // Command name
 +    char *command = argv[i];
 +    // Command arguments are everything after command name
 +    char **command_args = argv + ++i;
 +    // Number of command arguments
 +    int command_argc = argc - i;
 +    run_command(command, command_args, command_argc);
 +  } else if (strcmp(argv[i], "get_monitors") == 0) {
 +    get_monitors();
 +  } else if (strcmp(argv[i], "get_tags") == 0) {
 +    get_tags();
 +  } else if (strcmp(argv[i], "get_layouts") == 0) {
 +    get_layouts();
 +  } else if (strcmp(argv[i], "get_dwm_client") == 0) {
 +    if (++i < argc) {
 +      if (is_unsigned_int(argv[i])) {
 +        Window win = atol(argv[i]);
 +        get_dwm_client(win);
 +      } else
 +        usage_error(prog_name, "Expected unsigned integer argument");
 +    } else
 +      usage_error(prog_name, "Expected the window id");
 +  } else if (strcmp(argv[i], "subscribe") == 0) {
 +    if (++i < argc) {
 +      for (int j = i; j < argc; j++) subscribe(argv[j]);
 +    } else
 +      usage_error(prog_name, "Expected event name");
 +    // Keep listening for events forever
 +    while (1) {
 +      print_socket_reply();
 +    }
 +  } else
 +    usage_error(prog_name, "Invalid argument '%s'", argv[i]);
 +
 +  return 0;
 +}
 diff --git a/dwm.c b/dwm.c
 index 9fd0286..c90c61a 100644
 --- a/dwm.c
 +++ b/dwm.c
 @@ -30,6 +30,7 @@
  #include <unistd.h>
  #include <sys/types.h>
  #include <sys/wait.h>
 +#include <sys/epoll.h>
  #include <X11/cursorfont.h>
  #include <X11/keysym.h>
  #include <X11/Xatom.h>
 @@ -67,9 +68,21 @@ enum { WMProtocols, WMDelete, WMState, WMTakeFocus, WMLast }; /* default atoms *
  enum { ClkTagBar, ClkLtSymbol, ClkStatusText, ClkWinTitle,
         ClkClientWin, ClkRootWin, ClkLast }; /* clicks */
  
 +typedef struct TagState TagState;
 +struct TagState {
 +	int selected;
 +	int occupied;
 +	int urgent;
 +};
 +
 +typedef struct ClientState ClientState;
 +struct ClientState {
 +	int isfixed, isfloating, isurgent, neverfocus, oldstate, isfullscreen;
 +};
 +
  typedef union {
 -	int i;
 -	unsigned int ui;
 +	long i;
 +	unsigned long ui;
  	float f;
  	const void *v;
  } Arg;
 @@ -97,6 +110,7 @@ struct Client {
  	Client *snext;
  	Monitor *mon;
  	Window win;
 +	ClientState prevstate;
  };
  
  typedef struct {
 @@ -111,8 +125,10 @@ typedef struct {
  	void (*arrange)(Monitor *);
  } Layout;
  
 +
  struct Monitor {
  	char ltsymbol[16];
 +	char lastltsymbol[16];
  	float mfact;
  	int nmaster;
  	int num;
 @@ -122,14 +138,17 @@ struct Monitor {
  	unsigned int seltags;
  	unsigned int sellt;
  	unsigned int tagset[2];
 +	TagState tagstate;
  	int showbar;
  	int topbar;
  	Client *clients;
  	Client *sel;
 +	Client *lastsel;
  	Client *stack;
  	Monitor *next;
  	Window barwin;
  	const Layout *lt[2];
 +	const Layout *lastlt;
  };
  
  typedef struct {
 @@ -175,6 +194,7 @@ static long getstate(Window w);
  static int gettextprop(Window w, Atom atom, char *text, unsigned int size);
  static void grabbuttons(Client *c, int focused);
  static void grabkeys(void);
 +static int handlexevent(struct epoll_event *ev);
  static void incnmaster(const Arg *arg);
  static void keypress(XEvent *e);
  static void killclient(const Arg *arg);
 @@ -201,8 +221,10 @@ static void setclientstate(Client *c, long state);
  static void setfocus(Client *c);
  static void setfullscreen(Client *c, int fullscreen);
  static void setlayout(const Arg *arg);
 +static void setlayoutsafe(const Arg *arg);
  static void setmfact(const Arg *arg);
  static void setup(void);
 +static void setupepoll(void);
  static void seturgent(Client *c, int urg);
  static void showhide(Client *c);
  static void sigchld(int unused);
 @@ -261,17 +283,27 @@ static void (*handler[LASTEvent]) (XEvent *) = {
  	[UnmapNotify] = unmapnotify
  };
  static Atom wmatom[WMLast], netatom[NetLast];
 +static int epoll_fd;
 +static int dpy_fd;
  static int running = 1;
  static Cur *cursor[CurLast];
  static Clr **scheme;
  static Display *dpy;
  static Drw *drw;
 -static Monitor *mons, *selmon;
 +static Monitor *mons, *selmon, *lastselmon;
  static Window root, wmcheckwin;
  
 +#include "ipc.h"
 +
  /* configuration, allows nested code to access above variables */
  #include "config.h"
  
 +#ifdef VERSION
 +#include "IPCClient.c"
 +#include "yajl_dumps.c"
 +#include "ipc.c"
 +#endif
 +
  /* compile-time check if all tags fit into an unsigned int bit array. */
  struct NumTags { char limitexceeded[LENGTH(tags) > 31 ? -1 : 1]; };
  
 @@ -492,6 +524,12 @@ cleanup(void)
  	XSync(dpy, False);
  	XSetInputFocus(dpy, PointerRoot, RevertToPointerRoot, CurrentTime);
  	XDeleteProperty(dpy, root, netatom[NetActiveWindow]);
 +
 +	ipc_cleanup();
 +
 +	if (close(epoll_fd) < 0) {
 +			fprintf(stderr, "Failed to close epoll file descriptor\n");
 +	}
  }
  
  void
 @@ -964,6 +1002,25 @@ grabkeys(void)
  	}
  }
  
 +int
 +handlexevent(struct epoll_event *ev)
 +{
 +	if (ev->events & EPOLLIN) {
 +		XEvent ev;
 +		while (running && XPending(dpy)) {
 +			XNextEvent(dpy, &ev);
 +			if (handler[ev.type]) {
 +				handler[ev.type](&ev); /* call handler */
 +				ipc_send_events(mons, &lastselmon, selmon);
 +			}
 +		}
 +	} else if (ev-> events & EPOLLHUP) {
 +		return -1;
 +	}
 +
 +	return 0;
 +}
 +
  void
  incnmaster(const Arg *arg)
  {
 @@ -1373,12 +1430,40 @@ restack(Monitor *m)
  void
  run(void)
  {
 -	XEvent ev;
 -	/* main event loop */
 +	int event_count = 0;
 +	const int MAX_EVENTS = 10;
 +	struct epoll_event events[MAX_EVENTS];
 +
  	XSync(dpy, False);
 -	while (running && !XNextEvent(dpy, &ev))
 -		if (handler[ev.type])
 -			handler[ev.type](&ev); /* call handler */
 +
 +	/* main event loop */
 +	while (running) {
 +		event_count = epoll_wait(epoll_fd, events, MAX_EVENTS, -1);
 +
 +		for (int i = 0; i < event_count; i++) {
 +			int event_fd = events[i].data.fd;
 +			DEBUG("Got event from fd %d\n", event_fd);
 +
 +			if (event_fd == dpy_fd) {
 +				// -1 means EPOLLHUP
 +				if (handlexevent(events + i) == -1)
 +					return;
 +			} else if (event_fd == ipc_get_sock_fd()) {
 +				ipc_handle_socket_epoll_event(events + i);
 +			} else if (ipc_is_client_registered(event_fd)){
 +				if (ipc_handle_client_epoll_event(events + i, mons, &lastselmon, selmon,
 +							tags, LENGTH(tags), layouts, LENGTH(layouts)) < 0) {
 +					fprintf(stderr, "Error handling IPC event on fd %d\n", event_fd);
 +				}
 +			} else {
 +				fprintf(stderr, "Got event from unknown fd %d, ptr %p, u32 %d, u64 %lu",
 +						event_fd, events[i].data.ptr, events[i].data.u32,
 +						events[i].data.u64);
 +				fprintf(stderr, " with events %d\n", events[i].events);
 +				return;
 +			}
 +		}
 +	}
  }
  
  void
 @@ -1512,6 +1597,18 @@ setlayout(const Arg *arg)
  		drawbar(selmon);
  }
  
 +void
 +setlayoutsafe(const Arg *arg)
 +{
 +	const Layout *ltptr = (Layout *)arg->v;
 +	if (ltptr == 0)
 +			setlayout(arg);
 +	for (int i = 0; i < LENGTH(layouts); i++) {
 +		if (ltptr == &layouts[i])
 +			setlayout(arg);
 +	}
 +}
 +
  /* arg > 1.0 will set mfact absolutely */
  void
  setmfact(const Arg *arg)
 @@ -1595,8 +1692,37 @@ setup(void)
  	XSelectInput(dpy, root, wa.event_mask);
  	grabkeys();
  	focus(NULL);
 +	setupepoll();
  }
  
 +void
 +setupepoll(void)
 +{
 +	epoll_fd = epoll_create1(0);
 +	dpy_fd = ConnectionNumber(dpy);
 +	struct epoll_event dpy_event;
 +
 +	// Initialize struct to 0
 +	memset(&dpy_event, 0, sizeof(dpy_event));
 +
 +	DEBUG("Display socket is fd %d\n", dpy_fd);
 +
 +	if (epoll_fd == -1) {
 +		fputs("Failed to create epoll file descriptor", stderr);
 +	}
 +
 +	dpy_event.events = EPOLLIN;
 +	dpy_event.data.fd = dpy_fd;
 +	if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, dpy_fd, &dpy_event)) {
 +		fputs("Failed to add display file descriptor to epoll", stderr);
 +		close(epoll_fd);
 +		exit(1);
 +	}
 +
 +	if (ipc_init(ipcsockpath, epoll_fd, ipccommands, LENGTH(ipccommands)) < 0) {
 +		fputs("Failed to initialize IPC\n", stderr);
 +	}
 +}
  
  void
  seturgent(Client *c, int urg)
 @@ -1998,10 +2124,18 @@ updatestatus(void)
  void
  updatetitle(Client *c)
  {
 +	char oldname[sizeof(c->name)];
 +	strcpy(oldname, c->name);
 +
  	if (!gettextprop(c->win, netatom[NetWMName], c->name, sizeof c->name))
  		gettextprop(c->win, XA_WM_NAME, c->name, sizeof c->name);
  	if (c->name[0] == '\0') /* hack to mark broken clients */
  		strcpy(c->name, broken);
 +
 +	for (Monitor *m = mons; m; m = m->next) {
 +		if (m->sel == c && strcmp(oldname, c->name) != 0)
 +			ipc_focused_title_change_event(m->num, c->win, oldname, c->name);
 +	}
  }
  
  void
 diff --git a/ipc.c b/ipc.c
 new file mode 100644
 index 0000000..c404791
 --- /dev/null
 +++ b/ipc.c
 @@ -0,0 +1,1202 @@
 +#include "ipc.h"
 +
 +#include <errno.h>
 +#include <fcntl.h>
 +#include <inttypes.h>
 +#include <stdarg.h>
 +#include <stdio.h>
 +#include <stdlib.h>
 +#include <sys/epoll.h>
 +#include <sys/socket.h>
 +#include <sys/un.h>
 +#include <unistd.h>
 +#include <yajl/yajl_gen.h>
 +#include <yajl/yajl_tree.h>
 +
 +#include "util.h"
 +#include "yajl_dumps.h"
 +
 +static struct sockaddr_un sockaddr;
 +static struct epoll_event sock_epoll_event;
 +static IPCClientList ipc_clients = NULL;
 +static int epoll_fd = -1;
 +static int sock_fd = -1;
 +static IPCCommand *ipc_commands;
 +static unsigned int ipc_commands_len;
 +// Max size is 1 MB
 +static const uint32_t MAX_MESSAGE_SIZE = 1000000;
 +static const int IPC_SOCKET_BACKLOG = 5;
 +
 +/**
 + * Create IPC socket at specified path and return file descriptor to socket.
 + * This initializes the static variable sockaddr.
 + */
 +static int
 +ipc_create_socket(const char *filename)
 +{
 +  char *normal_filename;
 +  char *parent;
 +  const size_t addr_size = sizeof(struct sockaddr_un);
 +  const int sock_type = SOCK_STREAM | SOCK_NONBLOCK | SOCK_CLOEXEC;
 +
 +  normalizepath(filename, &normal_filename);
 +
 +  // In case socket file exists
 +  unlink(normal_filename);
 +
 +  // For portability clear the addr structure, since some implementations have
 +  // nonstandard fields in the structure
 +  memset(&sockaddr, 0, addr_size);
 +
 +  parentdir(normal_filename, &parent);
 +  // Create parent directories
 +  mkdirp(parent);
 +  free(parent);
 +
 +  sockaddr.sun_family = AF_LOCAL;
 +  strcpy(sockaddr.sun_path, normal_filename);
 +  free(normal_filename);
 +
 +  sock_fd = socket(AF_LOCAL, sock_type, 0);
 +  if (sock_fd == -1) {
 +    fputs("Failed to create socket\n", stderr);
 +    return -1;
 +  }
 +
 +  DEBUG("Created socket at %s\n", sockaddr.sun_path);
 +
 +  if (bind(sock_fd, (const struct sockaddr *)&sockaddr, addr_size) == -1) {
 +    fputs("Failed to bind socket\n", stderr);
 +    return -1;
 +  }
 +
 +  DEBUG("Socket binded\n");
 +
 +  if (listen(sock_fd, IPC_SOCKET_BACKLOG) < 0) {
 +    fputs("Failed to listen for connections on socket\n", stderr);
 +    return -1;
 +  }
 +
 +  DEBUG("Now listening for connections on socket\n");
 +
 +  return sock_fd;
 +}
 +
 +/**
 + * Internal function used to receive IPC messages from a given file descriptor.
 + *
 + * Returns -1 on error reading (could be EAGAIN or EINTR)
 + * Returns -2 if EOF before header could be read
 + * Returns -3 if invalid IPC header
 + * Returns -4 if message length exceeds MAX_MESSAGE_SIZE
 + */
 +static int
 +ipc_recv_message(int fd, uint8_t *msg_type, uint32_t *reply_size,
 +                 uint8_t **reply)
 +{
 +  uint32_t read_bytes = 0;
 +  const int32_t to_read = sizeof(dwm_ipc_header_t);
 +  char header[to_read];
 +  char *walk = header;
 +
 +  // Try to read header
 +  while (read_bytes < to_read) {
 +    const ssize_t n = read(fd, header + read_bytes, to_read - read_bytes);
 +
 +    if (n == 0) {
 +      if (read_bytes == 0) {
 +        fprintf(stderr, "Unexpectedly reached EOF while reading header.");
 +        fprintf(stderr,
 +                "Read %" PRIu32 " bytes, expected %" PRIu32 " total bytes.\n",
 +                read_bytes, to_read);
 +        return -2;
 +      } else {
 +        fprintf(stderr, "Unexpectedly reached EOF while reading header.");
 +        fprintf(stderr,
 +                "Read %" PRIu32 " bytes, expected %" PRIu32 " total bytes.\n",
 +                read_bytes, to_read);
 +        return -3;
 +      }
 +    } else if (n == -1) {
 +      // errno will still be set
 +      return -1;
 +    }
 +
 +    read_bytes += n;
 +  }
 +
 +  // Check if magic string in header matches
 +  if (memcmp(walk, IPC_MAGIC, IPC_MAGIC_LEN) != 0) {
 +    fprintf(stderr, "Invalid magic string. Got '%.*s', expected '%s'\n",
 +            IPC_MAGIC_LEN, walk, IPC_MAGIC);
 +    return -3;
 +  }
 +
 +  walk += IPC_MAGIC_LEN;
 +
 +  // Extract reply size
 +  memcpy(reply_size, walk, sizeof(uint32_t));
 +  walk += sizeof(uint32_t);
 +
 +  if (*reply_size > MAX_MESSAGE_SIZE) {
 +    fprintf(stderr, "Message too long: %" PRIu32 " bytes. ", *reply_size);
 +    fprintf(stderr, "Maximum message size is: %d\n", MAX_MESSAGE_SIZE);
 +    return -4;
 +  }
 +
 +  // Extract message type
 +  memcpy(msg_type, walk, sizeof(uint8_t));
 +  walk += sizeof(uint8_t);
 +
 +  if (*reply_size > 0)
 +    (*reply) = malloc(*reply_size);
 +  else
 +    return 0;
 +
 +  read_bytes = 0;
 +  while (read_bytes < *reply_size) {
 +    const ssize_t n = read(fd, *reply + read_bytes, *reply_size - read_bytes);
 +
 +    if (n == 0) {
 +      fprintf(stderr, "Unexpectedly reached EOF while reading payload.");
 +      fprintf(stderr, "Read %" PRIu32 " bytes, expected %" PRIu32 " bytes.\n",
 +              read_bytes, *reply_size);
 +      free(*reply);
 +      return -2;
 +    } else if (n == -1) {
 +      // TODO: Should we return and wait for another epoll event?
 +      // This would require saving the partial read in some way.
 +      if (errno == EINTR || errno == EAGAIN || errno == EWOULDBLOCK) continue;
 +
 +      free(*reply);
 +      return -1;
 +    }
 +
 +    read_bytes += n;
 +  }
 +
 +  return 0;
 +}
 +
 +/**
 + * Internal function used to write a buffer to a file descriptor
 + *
 + * Returns number of bytes written if successful write
 + * Returns 0 if no bytes were written due to EAGAIN or EWOULDBLOCK
 + * Returns -1 on unknown error trying to write, errno will carry over from
 + *   write() call
 + */
 +static ssize_t
 +ipc_write_message(int fd, const void *buf, size_t count)
 +{
 +  size_t written = 0;
 +
 +  while (written < count) {
 +    const ssize_t n = write(fd, (uint8_t *)buf + written, count - written);
 +
 +    if (n == -1) {
 +      if (errno == EAGAIN || errno == EWOULDBLOCK)
 +        return written;
 +      else if (errno == EINTR)
 +        continue;
 +      else
 +        return n;
 +    }
 +
 +    written += n;
 +    DEBUG("Wrote %zu/%zu to client at fd %d\n", written, count, fd);
 +  }
 +
 +  return written;
 +}
 +
 +/**
 + * Initialization for generic event message. This is used to allocate the yajl
 + * handle, set yajl options, and in the future any other initialization that
 + * should occur for event messages.
 + */
 +static void
 +ipc_event_init_message(yajl_gen *gen)
 +{
 +  *gen = yajl_gen_alloc(NULL);
 +  yajl_gen_config(*gen, yajl_gen_beautify, 1);
 +}
 +
 +/**
 + * Prepares buffers of IPC subscribers of specified event using buffer from yajl
 + * handle.
 + */
 +static void
 +ipc_event_prepare_send_message(yajl_gen gen, IPCEvent event)
 +{
 +  const unsigned char *buffer;
 +  size_t len = 0;
 +
 +  yajl_gen_get_buf(gen, &buffer, &len);
 +  len++;  // For null char
 +
 +  for (IPCClient *c = ipc_clients; c; c = c->next) {
 +    if (c->subscriptions & event) {
 +      DEBUG("Sending selected client change event to fd %d\n", c->fd);
 +      ipc_prepare_send_message(c, IPC_TYPE_EVENT, len, (char *)buffer);
 +    }
 +  }
 +
 +  // Not documented, but this frees temp_buffer
 +  yajl_gen_free(gen);
 +}
 +
 +/**
 + * Initialization for generic reply message. This is used to allocate the yajl
 + * handle, set yajl options, and in the future any other initialization that
 + * should occur for reply messages.
 + */
 +static void
 +ipc_reply_init_message(yajl_gen *gen)
 +{
 +  *gen = yajl_gen_alloc(NULL);
 +  yajl_gen_config(*gen, yajl_gen_beautify, 1);
 +}
 +
 +/**
 + * Prepares the IPC client's buffer with a message using the buffer of the yajl
 + * handle.
 + */
 +static void
 +ipc_reply_prepare_send_message(yajl_gen gen, IPCClient *c,
 +                               IPCMessageType msg_type)
 +{
 +  const unsigned char *buffer;
 +  size_t len = 0;
 +
 +  yajl_gen_get_buf(gen, &buffer, &len);
 +  len++;  // For null char
 +
 +  ipc_prepare_send_message(c, msg_type, len, (const char *)buffer);
 +
 +  // Not documented, but this frees temp_buffer
 +  yajl_gen_free(gen);
 +}
 +
 +/**
 + * Find the IPCCommand with the specified name
 + *
 + * Returns 0 if a command with the specified name was found
 + * Returns -1 if a command with the specified name could not be found
 + */
 +static int
 +ipc_get_ipc_command(const char *name, IPCCommand *ipc_command)
 +{
 +  for (int i = 0; i < ipc_commands_len; i++) {
 +    if (strcmp(ipc_commands[i].name, name) == 0) {
 +      *ipc_command = ipc_commands[i];
 +      return 0;
 +    }
 +  }
 +
 +  return -1;
 +}
 +
 +/**
 + * Parse a IPC_TYPE_RUN_COMMAND message from a client. This function extracts
 + * the arguments, argument count, argument types, and command name and returns
 + * the parsed information as an IPCParsedCommand. If this function returns
 + * successfully, the parsed_command must be freed using
 + * ipc_free_parsed_command_members.
 + *
 + * Returns 0 if the message was successfully parsed
 + * Returns -1 otherwise
 + */
 +static int
 +ipc_parse_run_command(char *msg, IPCParsedCommand *parsed_command)
 +{
 +  char error_buffer[1000];
 +  yajl_val parent = yajl_tree_parse(msg, error_buffer, 1000);
 +
 +  if (parent == NULL) {
 +    fputs("Failed to parse command from client\n", stderr);
 +    fprintf(stderr, "%s\n", error_buffer);
 +    fprintf(stderr, "Tried to parse: %s\n", msg);
 +    return -1;
 +  }
 +
 +  // Format:
 +  // {
 +  //   "command": "<command name>"
 +  //   "args": [ "arg1", "arg2", ... ]
 +  // }
 +  const char *command_path[] = {"command", 0};
 +  yajl_val command_val = yajl_tree_get(parent, command_path, yajl_t_string);
 +
 +  if (command_val == NULL) {
 +    fputs("No command key found in client message\n", stderr);
 +    yajl_tree_free(parent);
 +    return -1;
 +  }
 +
 +  const char *command_name = YAJL_GET_STRING(command_val);
 +  size_t command_name_len = strlen(command_name);
 +  parsed_command->name = (char *)malloc((command_name_len + 1) * sizeof(char));
 +  strcpy(parsed_command->name, command_name);
 +
 +  DEBUG("Received command: %s\n", parsed_command->name);
 +
 +  const char *args_path[] = {"args", 0};
 +  yajl_val args_val = yajl_tree_get(parent, args_path, yajl_t_array);
 +
 +  if (args_val == NULL) {
 +    fputs("No args key found in client message\n", stderr);
 +    yajl_tree_free(parent);
 +    return -1;
 +  }
 +
 +  unsigned int *argc = &parsed_command->argc;
 +  Arg **args = &parsed_command->args;
 +  ArgType **arg_types = &parsed_command->arg_types;
 +
 +  *argc = args_val->u.array.len;
 +
 +  // If no arguments are specified, make a dummy argument to pass to the
 +  // function. This is just the way dwm's void(Arg*) functions are setup.
 +  if (*argc == 0) {
 +    *args = (Arg *)malloc(sizeof(Arg));
 +    *arg_types = (ArgType *)malloc(sizeof(ArgType));
 +    (*arg_types)[0] = ARG_TYPE_NONE;
 +    (*args)[0].i = 0;
 +    (*argc)++;
 +  } else if (*argc > 0) {
 +    *args = (Arg *)calloc(*argc, sizeof(Arg));
 +    *arg_types = (ArgType *)malloc(*argc * sizeof(ArgType));
 +
 +    for (int i = 0; i < *argc; i++) {
 +      yajl_val arg_val = args_val->u.array.values[i];
 +
 +      if (YAJL_IS_NUMBER(arg_val)) {
 +        if (YAJL_IS_INTEGER(arg_val)) {
 +          // Any values below 0 must be a signed int
 +          if (YAJL_GET_INTEGER(arg_val) < 0) {
 +            (*args)[i].i = YAJL_GET_INTEGER(arg_val);
 +            (*arg_types)[i] = ARG_TYPE_SINT;
 +            DEBUG("i=%ld\n", (*args)[i].i);
 +            // Any values above 0 should be an unsigned int
 +          } else if (YAJL_GET_INTEGER(arg_val) >= 0) {
 +            (*args)[i].ui = YAJL_GET_INTEGER(arg_val);
 +            (*arg_types)[i] = ARG_TYPE_UINT;
 +            DEBUG("ui=%ld\n", (*args)[i].i);
 +          }
 +          // If the number is not an integer, it must be a float
 +        } else {
 +          (*args)[i].f = (float)YAJL_GET_DOUBLE(arg_val);
 +          (*arg_types)[i] = ARG_TYPE_FLOAT;
 +          DEBUG("f=%f\n", (*args)[i].f);
 +          // If argument is not a number, it must be a string
 +        }
 +      } else if (YAJL_IS_STRING(arg_val)) {
 +        char *arg_s = YAJL_GET_STRING(arg_val);
 +        size_t arg_s_size = (strlen(arg_s) + 1) * sizeof(char);
 +        (*args)[i].v = (char *)malloc(arg_s_size);
 +        (*arg_types)[i] = ARG_TYPE_STR;
 +        strcpy((char *)(*args)[i].v, arg_s);
 +      }
 +    }
 +  }
 +
 +  yajl_tree_free(parent);
 +
 +  return 0;
 +}
 +
 +/**
 + * Free the members of a IPCParsedCommand struct
 + */
 +static void
 +ipc_free_parsed_command_members(IPCParsedCommand *command)
 +{
 +  for (int i = 0; i < command->argc; i++) {
 +    if (command->arg_types[i] == ARG_TYPE_STR) free((void *)command->args[i].v);
 +  }
 +  free(command->args);
 +  free(command->arg_types);
 +  free(command->name);
 +}
 +
 +/**
 + * Check if the given arguments are the correct length and type. Also do any
 + * casting to correct the types.
 + *
 + * Returns 0 if the arguments were the correct length and types
 + * Returns -1 if the argument count doesn't match
 + * Returns -2 if the argument types don't match
 + */
 +static int
 +ipc_validate_run_command(IPCParsedCommand *parsed, const IPCCommand actual)
 +{
 +  if (actual.argc != parsed->argc) return -1;
 +
 +  for (int i = 0; i < parsed->argc; i++) {
 +    ArgType ptype = parsed->arg_types[i];
 +    ArgType atype = actual.arg_types[i];
 +
 +    if (ptype != atype) {
 +      if (ptype == ARG_TYPE_UINT && atype == ARG_TYPE_PTR)
 +        // If this argument is supposed to be a void pointer, cast it
 +        parsed->args[i].v = (void *)parsed->args[i].ui;
 +      else if (ptype == ARG_TYPE_UINT && atype == ARG_TYPE_SINT)
 +        // If this argument is supposed to be a signed int, cast it
 +        parsed->args[i].i = parsed->args[i].ui;
 +      else
 +        return -2;
 +    }
 +  }
 +
 +  return 0;
 +}
 +
 +/**
 + * Convert event name to their IPCEvent equivalent enum value
 + *
 + * Returns 0 if a valid event name was given
 + * Returns -1 otherwise
 + */
 +static int
 +ipc_event_stoi(const char *subscription, IPCEvent *event)
 +{
 +  if (strcmp(subscription, "tag_change_event") == 0)
 +    *event = IPC_EVENT_TAG_CHANGE;
 +  else if (strcmp(subscription, "client_focus_change_event") == 0)
 +    *event = IPC_EVENT_CLIENT_FOCUS_CHANGE;
 +  else if (strcmp(subscription, "layout_change_event") == 0)
 +    *event = IPC_EVENT_LAYOUT_CHANGE;
 +  else if (strcmp(subscription, "monitor_focus_change_event") == 0)
 +    *event = IPC_EVENT_MONITOR_FOCUS_CHANGE;
 +  else if (strcmp(subscription, "focused_title_change_event") == 0)
 +    *event = IPC_EVENT_FOCUSED_TITLE_CHANGE;
 +  else if (strcmp(subscription, "focused_state_change_event") == 0)
 +    *event = IPC_EVENT_FOCUSED_STATE_CHANGE;
 +  else
 +    return -1;
 +  return 0;
 +}
 +
 +/**
 + * Parse a IPC_TYPE_SUBSCRIBE message from a client. This function extracts the
 + * event name and the subscription action from the message.
 + *
 + * Returns 0 if message was successfully parsed
 + * Returns -1 otherwise
 + */
 +static int
 +ipc_parse_subscribe(const char *msg, IPCSubscriptionAction *subscribe,
 +                    IPCEvent *event)
 +{
 +  char error_buffer[100];
 +  yajl_val parent = yajl_tree_parse((char *)msg, error_buffer, 100);
 +
 +  if (parent == NULL) {
 +    fputs("Failed to parse command from client\n", stderr);
 +    fprintf(stderr, "%s\n", error_buffer);
 +    return -1;
 +  }
 +
 +  // Format:
 +  // {
 +  //   "event": "<event name>"
 +  //   "action": "<subscribe|unsubscribe>"
 +  // }
 +  const char *event_path[] = {"event", 0};
 +  yajl_val event_val = yajl_tree_get(parent, event_path, yajl_t_string);
 +
 +  if (event_val == NULL) {
 +    fputs("No 'event' key found in client message\n", stderr);
 +    return -1;
 +  }
 +
 +  const char *event_str = YAJL_GET_STRING(event_val);
 +  DEBUG("Received event: %s\n", event_str);
 +
 +  if (ipc_event_stoi(event_str, event) < 0) return -1;
 +
 +  const char *action_path[] = {"action", 0};
 +  yajl_val action_val = yajl_tree_get(parent, action_path, yajl_t_string);
 +
 +  if (action_val == NULL) {
 +    fputs("No 'action' key found in client message\n", stderr);
 +    return -1;
 +  }
 +
 +  const char *action = YAJL_GET_STRING(action_val);
 +
 +  if (strcmp(action, "subscribe") == 0)
 +    *subscribe = IPC_ACTION_SUBSCRIBE;
 +  else if (strcmp(action, "unsubscribe") == 0)
 +    *subscribe = IPC_ACTION_UNSUBSCRIBE;
 +  else {
 +    fputs("Invalid action specified for subscription\n", stderr);
 +    return -1;
 +  }
 +
 +  yajl_tree_free(parent);
 +
 +  return 0;
 +}
 +
 +/**
 + * Parse an IPC_TYPE_GET_DWM_CLIENT message from a client. This function
 + * extracts the window id from the message.
 + *
 + * Returns 0 if message was successfully parsed
 + * Returns -1 otherwise
 + */
 +static int
 +ipc_parse_get_dwm_client(const char *msg, Window *win)
 +{
 +  char error_buffer[100];
 +
 +  yajl_val parent = yajl_tree_parse(msg, error_buffer, 100);
 +
 +  if (parent == NULL) {
 +    fputs("Failed to parse message from client\n", stderr);
 +    fprintf(stderr, "%s\n", error_buffer);
 +    return -1;
 +  }
 +
 +  // Format:
 +  // {
 +  //   "client_window_id": <client window id>
 +  // }
 +  const char *win_path[] = {"client_window_id", 0};
 +  yajl_val win_val = yajl_tree_get(parent, win_path, yajl_t_number);
 +
 +  if (win_val == NULL) {
 +    fputs("No client window id found in client message\n", stderr);
 +    return -1;
 +  }
 +
 +  *win = YAJL_GET_INTEGER(win_val);
 +
 +  yajl_tree_free(parent);
 +
 +  return 0;
 +}
 +
 +/**
 + * Called when an IPC_TYPE_RUN_COMMAND message is received from a client. This
 + * function parses, executes the given command, and prepares a reply message to
 + * the client indicating success/failure.
 + *
 + * NOTE: There is currently no check for argument validity beyond the number of
 + * arguments given and types of arguments. There is also no way to check if the
 + * function succeeded based on dwm's void(const Arg*) function types. Pointer
 + * arguments can cause crashes if they are not validated in the function itself.
 + *
 + * Returns 0 if message was successfully parsed
 + * Returns -1 on failure parsing message
 + */
 +static int
 +ipc_run_command(IPCClient *ipc_client, char *msg)
 +{
 +  IPCParsedCommand parsed_command;
 +  IPCCommand ipc_command;
 +
 +  // Initialize struct
 +  memset(&parsed_command, 0, sizeof(IPCParsedCommand));
 +
 +  if (ipc_parse_run_command(msg, &parsed_command) < 0) {
 +    ipc_prepare_reply_failure(ipc_client, IPC_TYPE_RUN_COMMAND,
 +                              "Failed to parse run command");
 +    return -1;
 +  }
 +
 +  if (ipc_get_ipc_command(parsed_command.name, &ipc_command) < 0) {
 +    ipc_prepare_reply_failure(ipc_client, IPC_TYPE_RUN_COMMAND,
 +                              "Command %s not found", parsed_command.name);
 +    ipc_free_parsed_command_members(&parsed_command);
 +    return -1;
 +  }
 +
 +  int res = ipc_validate_run_command(&parsed_command, ipc_command);
 +  if (res < 0) {
 +    if (res == -1)
 +      ipc_prepare_reply_failure(ipc_client, IPC_TYPE_RUN_COMMAND,
 +                                "%u arguments provided, %u expected",
 +                                parsed_command.argc, ipc_command.argc);
 +    else if (res == -2)
 +      ipc_prepare_reply_failure(ipc_client, IPC_TYPE_RUN_COMMAND,
 +                                "Type mismatch");
 +    ipc_free_parsed_command_members(&parsed_command);
 +    return -1;
 +  }
 +
 +  if (parsed_command.argc == 1)
 +    ipc_command.func.single_param(parsed_command.args);
 +  else if (parsed_command.argc > 1)
 +    ipc_command.func.array_param(parsed_command.args, parsed_command.argc);
 +
 +  DEBUG("Called function for command %s\n", parsed_command.name);
 +
 +  ipc_free_parsed_command_members(&parsed_command);
 +
 +  ipc_prepare_reply_success(ipc_client, IPC_TYPE_RUN_COMMAND);
 +  return 0;
 +}
 +
 +/**
 + * Called when an IPC_TYPE_GET_MONITORS message is received from a client. It
 + * prepares a reply with the properties of all of the monitors in JSON.
 + */
 +static void
 +ipc_get_monitors(IPCClient *c, Monitor *mons, Monitor *selmon)
 +{
 +  yajl_gen gen;
 +  ipc_reply_init_message(&gen);
 +  dump_monitors(gen, mons, selmon);
 +
 +  ipc_reply_prepare_send_message(gen, c, IPC_TYPE_GET_MONITORS);
 +}
 +
 +/**
 + * Called when an IPC_TYPE_GET_TAGS message is received from a client. It
 + * prepares a reply with info about all the tags in JSON.
 + */
 +static void
 +ipc_get_tags(IPCClient *c, const char *tags[], const int tags_len)
 +{
 +  yajl_gen gen;
 +  ipc_reply_init_message(&gen);
 +
 +  dump_tags(gen, tags, tags_len);
 +
 +  ipc_reply_prepare_send_message(gen, c, IPC_TYPE_GET_TAGS);
 +}
 +
 +/**
 + * Called when an IPC_TYPE_GET_LAYOUTS message is received from a client. It
 + * prepares a reply with a JSON array of available layouts
 + */
 +static void
 +ipc_get_layouts(IPCClient *c, const Layout layouts[], const int layouts_len)
 +{
 +  yajl_gen gen;
 +  ipc_reply_init_message(&gen);
 +
 +  dump_layouts(gen, layouts, layouts_len);
 +
 +  ipc_reply_prepare_send_message(gen, c, IPC_TYPE_GET_LAYOUTS);
 +}
 +
 +/**
 + * Called when an IPC_TYPE_GET_DWM_CLIENT message is received from a client. It
 + * prepares a JSON reply with the properties of the client with the specified
 + * window XID.
 + *
 + * Returns 0 if the message was successfully parsed and if the client with the
 + *   specified window XID was found
 + * Returns -1 if the message could not be parsed
 + */
 +static int
 +ipc_get_dwm_client(IPCClient *ipc_client, const char *msg, const Monitor *mons)
 +{
 +  Window win;
 +
 +  if (ipc_parse_get_dwm_client(msg, &win) < 0) return -1;
 +
 +  // Find client with specified window XID
 +  for (const Monitor *m = mons; m; m = m->next)
 +    for (Client *c = m->clients; c; c = c->next)
 +      if (c->win == win) {
 +        yajl_gen gen;
 +        ipc_reply_init_message(&gen);
 +
 +        dump_client(gen, c);
 +
 +        ipc_reply_prepare_send_message(gen, ipc_client,
 +                                       IPC_TYPE_GET_DWM_CLIENT);
 +
 +        return 0;
 +      }
 +
 +  ipc_prepare_reply_failure(ipc_client, IPC_TYPE_GET_DWM_CLIENT,
 +                            "Client with window id %d not found", win);
 +  return -1;
 +}
 +
 +/**
 + * Called when an IPC_TYPE_SUBSCRIBE message is received from a client. It
 + * subscribes/unsubscribes the client from the specified event and replies with
 + * the result.
 + *
 + * Returns 0 if the message was successfully parsed.
 + * Returns -1 if the message could not be parsed
 + */
 +static int
 +ipc_subscribe(IPCClient *c, const char *msg)
 +{
 +  IPCSubscriptionAction action = IPC_ACTION_SUBSCRIBE;
 +  IPCEvent event = 0;
 +
 +  if (ipc_parse_subscribe(msg, &action, &event)) {
 +    ipc_prepare_reply_failure(c, IPC_TYPE_SUBSCRIBE, "Event does not exist");
 +    return -1;
 +  }
 +
 +  if (action == IPC_ACTION_SUBSCRIBE) {
 +    DEBUG("Subscribing client on fd %d to %d\n", c->fd, event);
 +    c->subscriptions |= event;
 +  } else if (action == IPC_ACTION_UNSUBSCRIBE) {
 +    DEBUG("Unsubscribing client on fd %d to %d\n", c->fd, event);
 +    c->subscriptions ^= event;
 +  } else {
 +    ipc_prepare_reply_failure(c, IPC_TYPE_SUBSCRIBE,
 +                              "Invalid subscription action");
 +    return -1;
 +  }
 +
 +  ipc_prepare_reply_success(c, IPC_TYPE_SUBSCRIBE);
 +  return 0;
 +}
 +
 +int
 +ipc_init(const char *socket_path, const int p_epoll_fd, IPCCommand commands[],
 +         const int commands_len)
 +{
 +  // Initialize struct to 0
 +  memset(&sock_epoll_event, 0, sizeof(sock_epoll_event));
 +
 +  int socket_fd = ipc_create_socket(socket_path);
 +  if (socket_fd < 0) return -1;
 +
 +  ipc_commands = commands;
 +  ipc_commands_len = commands_len;
 +
 +  epoll_fd = p_epoll_fd;
 +
 +  // Wake up to incoming connection requests
 +  sock_epoll_event.data.fd = socket_fd;
 +  sock_epoll_event.events = EPOLLIN;
 +  if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, socket_fd, &sock_epoll_event)) {
 +    fputs("Failed to add sock file descriptor to epoll", stderr);
 +    return -1;
 +  }
 +
 +  return socket_fd;
 +}
 +
 +void
 +ipc_cleanup()
 +{
 +  IPCClient *c = ipc_clients;
 +  // Free clients and their buffers
 +  while (c) {
 +    ipc_drop_client(c);
 +    c = ipc_clients;
 +  }
 +
 +  // Stop waking up for socket events
 +  epoll_ctl(epoll_fd, EPOLL_CTL_DEL, sock_fd, &sock_epoll_event);
 +
 +  // Uninitialize all static variables
 +  epoll_fd = -1;
 +  sock_fd = -1;
 +  ipc_commands = NULL;
 +  ipc_commands_len = 0;
 +  memset(&sock_epoll_event, 0, sizeof(struct epoll_event));
 +  memset(&sockaddr, 0, sizeof(struct sockaddr_un));
 +
 +  // Delete socket
 +  unlink(sockaddr.sun_path);
 +
 +  shutdown(sock_fd, SHUT_RDWR);
 +  close(sock_fd);
 +}
 +
 +int
 +ipc_get_sock_fd()
 +{
 +  return sock_fd;
 +}
 +
 +IPCClient *
 +ipc_get_client(int fd)
 +{
 +  return ipc_list_get_client(ipc_clients, fd);
 +}
 +
 +int
 +ipc_is_client_registered(int fd)
 +{
 +  return (ipc_get_client(fd) != NULL);
 +}
 +
 +int
 +ipc_accept_client()
 +{
 +  int fd = -1;
 +
 +  struct sockaddr_un client_addr;
 +  socklen_t len = 0;
 +
 +  // For portability clear the addr structure, since some implementations
 +  // have nonstandard fields in the structure
 +  memset(&client_addr, 0, sizeof(struct sockaddr_un));
 +
 +  fd = accept(sock_fd, (struct sockaddr *)&client_addr, &len);
 +  if (fd < 0 && errno != EINTR) {
 +    fputs("Failed to accept IPC connection from client", stderr);
 +    return -1;
 +  }
 +
 +  if (fcntl(fd, F_SETFD, FD_CLOEXEC) < 0) {
 +    shutdown(fd, SHUT_RDWR);
 +    close(fd);
 +    fputs("Failed to set flags on new client fd", stderr);
 +  }
 +
 +  IPCClient *nc = ipc_client_new(fd);
 +  if (nc == NULL) return -1;
 +
 +  // Wake up to messages from this client
 +  nc->event.data.fd = fd;
 +  nc->event.events = EPOLLIN | EPOLLHUP;
 +  epoll_ctl(epoll_fd, EPOLL_CTL_ADD, fd, &nc->event);
 +
 +  ipc_list_add_client(&ipc_clients, nc);
 +
 +  DEBUG("%s%d\n", "New client at fd: ", fd);
 +
 +  return fd;
 +}
 +
 +int
 +ipc_drop_client(IPCClient *c)
 +{
 +  int fd = c->fd;
 +  shutdown(fd, SHUT_RDWR);
 +  int res = close(fd);
 +
 +  if (res == 0) {
 +    struct epoll_event ev;
 +
 +    // Stop waking up to messages from this client
 +    epoll_ctl(epoll_fd, EPOLL_CTL_DEL, fd, &ev);
 +    ipc_list_remove_client(&ipc_clients, c);
 +
 +    free(c->buffer);
 +    free(c);
 +
 +    DEBUG("Successfully removed client on fd %d\n", fd);
 +  } else if (res < 0 && res != EINTR) {
 +    fprintf(stderr, "Failed to close fd %d\n", fd);
 +  }
 +
 +  return res;
 +}
 +
 +int
 +ipc_read_client(IPCClient *c, IPCMessageType *msg_type, uint32_t *msg_size,
 +                char **msg)
 +{
 +  int fd = c->fd;
 +  int ret =
 +      ipc_recv_message(fd, (uint8_t *)msg_type, msg_size, (uint8_t **)msg);
 +
 +  if (ret < 0) {
 +    // This will happen if these errors occur while reading header
 +    if (ret == -1 &&
 +        (errno == EINTR || errno == EAGAIN || errno == EWOULDBLOCK))
 +      return -2;
 +
 +    fprintf(stderr, "Error reading message: dropping client at fd %d\n", fd);
 +    ipc_drop_client(c);
 +
 +    return -1;
 +  }
 +
 +  // Make sure receive message is null terminated to avoid parsing issues
 +  if (*msg_size > 0) {
 +    size_t len = *msg_size;
 +    nullterminate(msg, &len);
 +    *msg_size = len;
 +  }
 +
 +  DEBUG("[fd %d] ", fd);
 +  if (*msg_size > 0)
 +    DEBUG("Received message: '%.*s' ", *msg_size, *msg);
 +  else
 +    DEBUG("Received empty message ");
 +  DEBUG("Message type: %" PRIu8 " ", (uint8_t)*msg_type);
 +  DEBUG("Message size: %" PRIu32 "\n", *msg_size);
 +
 +  return 0;
 +}
 +
 +ssize_t
 +ipc_write_client(IPCClient *c)
 +{
 +  const ssize_t n = ipc_write_message(c->fd, c->buffer, c->buffer_size);
 +
 +  if (n < 0) return n;
 +
 +  // TODO: Deal with client timeouts
 +
 +  if (n == c->buffer_size) {
 +    c->buffer_size = 0;
 +    free(c->buffer);
 +    // No dangling pointers!
 +    c->buffer = NULL;
 +    // Stop waking up when client is ready to receive messages
 +    if (c->event.events & EPOLLOUT) {
 +      c->event.events -= EPOLLOUT;
 +      epoll_ctl(epoll_fd, EPOLL_CTL_MOD, c->fd, &c->event);
 +    }
 +    return n;
 +  }
 +
 +  // Shift unwritten buffer to beginning of buffer and reallocate
 +  c->buffer_size -= n;
 +  memmove(c->buffer, c->buffer + n, c->buffer_size);
 +  c->buffer = (char *)realloc(c->buffer, c->buffer_size);
 +
 +  return n;
 +}
 +
 +void
 +ipc_prepare_send_message(IPCClient *c, const IPCMessageType msg_type,
 +                         const uint32_t msg_size, const char *msg)
 +{
 +  dwm_ipc_header_t header = {
 +      .magic = IPC_MAGIC_ARR, .type = msg_type, .size = msg_size};
 +
 +  uint32_t header_size = sizeof(dwm_ipc_header_t);
 +  uint32_t packet_size = header_size + msg_size;
 +
 +  if (c->buffer == NULL)
 +    c->buffer = (char *)malloc(c->buffer_size + packet_size);
 +  else
 +    c->buffer = (char *)realloc(c->buffer, c->buffer_size + packet_size);
 +
 +  // Copy header to end of client buffer
 +  memcpy(c->buffer + c->buffer_size, &header, header_size);
 +  c->buffer_size += header_size;
 +
 +  // Copy message to end of client buffer
 +  memcpy(c->buffer + c->buffer_size, msg, msg_size);
 +  c->buffer_size += msg_size;
 +
 +  // Wake up when client is ready to receive messages
 +  c->event.events |= EPOLLOUT;
 +  epoll_ctl(epoll_fd, EPOLL_CTL_MOD, c->fd, &c->event);
 +}
 +
 +void
 +ipc_prepare_reply_failure(IPCClient *c, IPCMessageType msg_type,
 +                          const char *format, ...)
 +{
 +  yajl_gen gen;
 +  va_list args;
 +
 +  // Get output size
 +  va_start(args, format);
 +  size_t len = vsnprintf(NULL, 0, format, args);
 +  va_end(args);
 +  char *buffer = (char *)malloc((len + 1) * sizeof(char));
 +
 +  ipc_reply_init_message(&gen);
 +
 +  va_start(args, format);
 +  vsnprintf(buffer, len + 1, format, args);
 +  va_end(args);
 +  dump_error_message(gen, buffer);
 +
 +  ipc_reply_prepare_send_message(gen, c, msg_type);
 +  fprintf(stderr, "[fd %d] Error: %s\n", c->fd, buffer);
 +
 +  free(buffer);
 +}
 +
 +void
 +ipc_prepare_reply_success(IPCClient *c, IPCMessageType msg_type)
 +{
 +  const char *success_msg = "{\"result\":\"success\"}";
 +  const size_t msg_len = strlen(success_msg) + 1;  // +1 for null char
 +
 +  ipc_prepare_send_message(c, msg_type, msg_len, success_msg);
 +}
 +
 +void
 +ipc_tag_change_event(int mon_num, TagState old_state, TagState new_state)
 +{
 +  yajl_gen gen;
 +  ipc_event_init_message(&gen);
 +  dump_tag_event(gen, mon_num, old_state, new_state);
 +  ipc_event_prepare_send_message(gen, IPC_EVENT_TAG_CHANGE);
 +}
 +
 +void
 +ipc_client_focus_change_event(int mon_num, Client *old_client,
 +                              Client *new_client)
 +{
 +  yajl_gen gen;
 +  ipc_event_init_message(&gen);
 +  dump_client_focus_change_event(gen, old_client, new_client, mon_num);
 +  ipc_event_prepare_send_message(gen, IPC_EVENT_CLIENT_FOCUS_CHANGE);
 +}
 +
 +void
 +ipc_layout_change_event(const int mon_num, const char *old_symbol,
 +                        const Layout *old_layout, const char *new_symbol,
 +                        const Layout *new_layout)
 +{
 +  yajl_gen gen;
 +  ipc_event_init_message(&gen);
 +  dump_layout_change_event(gen, mon_num, old_symbol, old_layout, new_symbol,
 +                           new_layout);
 +  ipc_event_prepare_send_message(gen, IPC_EVENT_LAYOUT_CHANGE);
 +}
 +
 +void
 +ipc_monitor_focus_change_event(const int last_mon_num, const int new_mon_num)
 +{
 +  yajl_gen gen;
 +  ipc_event_init_message(&gen);
 +  dump_monitor_focus_change_event(gen, last_mon_num, new_mon_num);
 +  ipc_event_prepare_send_message(gen, IPC_EVENT_MONITOR_FOCUS_CHANGE);
 +}
 +
 +void
 +ipc_focused_title_change_event(const int mon_num, const Window client_id,
 +                               const char *old_name, const char *new_name)
 +{
 +  yajl_gen gen;
 +  ipc_event_init_message(&gen);
 +  dump_focused_title_change_event(gen, mon_num, client_id, old_name, new_name);
 +  ipc_event_prepare_send_message(gen, IPC_EVENT_FOCUSED_TITLE_CHANGE);
 +}
 +
 +void
 +ipc_focused_state_change_event(const int mon_num, const Window client_id,
 +                               const ClientState *old_state,
 +                               const ClientState *new_state)
 +{
 +  yajl_gen gen;
 +  ipc_event_init_message(&gen);
 +  dump_focused_state_change_event(gen, mon_num, client_id, old_state,
 +                                  new_state);
 +  ipc_event_prepare_send_message(gen, IPC_EVENT_FOCUSED_STATE_CHANGE);
 +}
 +
 +void
 +ipc_send_events(Monitor *mons, Monitor **lastselmon, Monitor *selmon)
 +{
 +  for (Monitor *m = mons; m; m = m->next) {
 +    unsigned int urg = 0, occ = 0, tagset = 0;
 +
 +    for (Client *c = m->clients; c; c = c->next) {
 +      occ |= c->tags;
 +
 +      if (c->isurgent) urg |= c->tags;
 +    }
 +    tagset = m->tagset[m->seltags];
 +
 +    TagState new_state = {.selected = tagset, .occupied = occ, .urgent = urg};
 +
 +    if (memcmp(&m->tagstate, &new_state, sizeof(TagState)) != 0) {
 +      ipc_tag_change_event(m->num, m->tagstate, new_state);
 +      m->tagstate = new_state;
 +    }
 +
 +    if (m->lastsel != m->sel) {
 +      ipc_client_focus_change_event(m->num, m->lastsel, m->sel);
 +      m->lastsel = m->sel;
 +    }
 +
 +    if (strcmp(m->ltsymbol, m->lastltsymbol) != 0 ||
 +        m->lastlt != m->lt[m->sellt]) {
 +      ipc_layout_change_event(m->num, m->lastltsymbol, m->lastlt, m->ltsymbol,
 +                              m->lt[m->sellt]);
 +      strcpy(m->lastltsymbol, m->ltsymbol);
 +      m->lastlt = m->lt[m->sellt];
 +    }
 +
 +    if (*lastselmon != selmon) {
 +      if (*lastselmon != NULL)
 +        ipc_monitor_focus_change_event((*lastselmon)->num, selmon->num);
 +      *lastselmon = selmon;
 +    }
 +
 +    Client *sel = m->sel;
 +    if (!sel) continue;
 +    ClientState *o = &m->sel->prevstate;
 +    ClientState n = {.oldstate = sel->oldstate,
 +                     .isfixed = sel->isfixed,
 +                     .isfloating = sel->isfloating,
 +                     .isfullscreen = sel->isfullscreen,
 +                     .isurgent = sel->isurgent,
 +                     .neverfocus = sel->neverfocus};
 +    if (memcmp(o, &n, sizeof(ClientState)) != 0) {
 +      ipc_focused_state_change_event(m->num, m->sel->win, o, &n);
 +      *o = n;
 +    }
 +  }
 +}
 +
 +int
 +ipc_handle_client_epoll_event(struct epoll_event *ev, Monitor *mons,
 +                              Monitor **lastselmon, Monitor *selmon,
 +                              const char *tags[], const int tags_len,
 +                              const Layout *layouts, const int layouts_len)
 +{
 +  int fd = ev->data.fd;
 +  IPCClient *c = ipc_get_client(fd);
 +
 +  if (ev->events & EPOLLHUP) {
 +    DEBUG("EPOLLHUP received from client at fd %d\n", fd);
 +    ipc_drop_client(c);
 +  } else if (ev->events & EPOLLOUT) {
 +    DEBUG("Sending message to client at fd %d...\n", fd);
 +    if (c->buffer_size) ipc_write_client(c);
 +  } else if (ev->events & EPOLLIN) {
 +    IPCMessageType msg_type = 0;
 +    uint32_t msg_size = 0;
 +    char *msg = NULL;
 +
 +    DEBUG("Received message from fd %d\n", fd);
 +    if (ipc_read_client(c, &msg_type, &msg_size, &msg) < 0) return -1;
 +
 +    if (msg_type == IPC_TYPE_GET_MONITORS)
 +      ipc_get_monitors(c, mons, selmon);
 +    else if (msg_type == IPC_TYPE_GET_TAGS)
 +      ipc_get_tags(c, tags, tags_len);
 +    else if (msg_type == IPC_TYPE_GET_LAYOUTS)
 +      ipc_get_layouts(c, layouts, layouts_len);
 +    else if (msg_type == IPC_TYPE_RUN_COMMAND) {
 +      if (ipc_run_command(c, msg) < 0) return -1;
 +      ipc_send_events(mons, lastselmon, selmon);
 +    } else if (msg_type == IPC_TYPE_GET_DWM_CLIENT) {
 +      if (ipc_get_dwm_client(c, msg, mons) < 0) return -1;
 +    } else if (msg_type == IPC_TYPE_SUBSCRIBE) {
 +      if (ipc_subscribe(c, msg) < 0) return -1;
 +    } else {
 +      fprintf(stderr, "Invalid message type received from fd %d", fd);
 +      ipc_prepare_reply_failure(c, msg_type, "Invalid message type: %d",
 +                                msg_type);
 +    }
 +    free(msg);
 +  } else {
 +    fprintf(stderr, "Epoll event returned %d from fd %d\n", ev->events, fd);
 +    return -1;
 +  }
 +
 +  return 0;
 +}
 +
 +int
 +ipc_handle_socket_epoll_event(struct epoll_event *ev)
 +{
 +  if (!(ev->events & EPOLLIN)) return -1;
 +
 +  // EPOLLIN means incoming client connection request
 +  fputs("Received EPOLLIN event on socket\n", stderr);
 +  int new_fd = ipc_accept_client();
 +
 +  return new_fd;
 +}
 diff --git a/ipc.h b/ipc.h
 new file mode 100644
 index 0000000..e3b5bba
 --- /dev/null
 +++ b/ipc.h
 @@ -0,0 +1,320 @@
 +#ifndef IPC_H_
 +#define IPC_H_
 +
 +#include <stdint.h>
 +#include <sys/epoll.h>
 +#include <yajl/yajl_gen.h>
 +
 +#include "IPCClient.h"
 +
 +// clang-format off
 +#define IPC_MAGIC "DWM-IPC"
 +#define IPC_MAGIC_ARR { 'D', 'W', 'M', '-', 'I', 'P', 'C'}
 +#define IPC_MAGIC_LEN 7 // Not including null char
 +
 +#define IPCCOMMAND(FUNC, ARGC, TYPES)                                          \
 +  { #FUNC, {FUNC }, ARGC, (ArgType[ARGC])TYPES }
 +// clang-format on
 +
 +typedef enum IPCMessageType {
 +  IPC_TYPE_RUN_COMMAND = 0,
 +  IPC_TYPE_GET_MONITORS = 1,
 +  IPC_TYPE_GET_TAGS = 2,
 +  IPC_TYPE_GET_LAYOUTS = 3,
 +  IPC_TYPE_GET_DWM_CLIENT = 4,
 +  IPC_TYPE_SUBSCRIBE = 5,
 +  IPC_TYPE_EVENT = 6
 +} IPCMessageType;
 +
 +typedef enum IPCEvent {
 +  IPC_EVENT_TAG_CHANGE = 1 << 0,
 +  IPC_EVENT_CLIENT_FOCUS_CHANGE = 1 << 1,
 +  IPC_EVENT_LAYOUT_CHANGE = 1 << 2,
 +  IPC_EVENT_MONITOR_FOCUS_CHANGE = 1 << 3,
 +  IPC_EVENT_FOCUSED_TITLE_CHANGE = 1 << 4,
 +  IPC_EVENT_FOCUSED_STATE_CHANGE = 1 << 5
 +} IPCEvent;
 +
 +typedef enum IPCSubscriptionAction {
 +  IPC_ACTION_UNSUBSCRIBE = 0,
 +  IPC_ACTION_SUBSCRIBE = 1
 +} IPCSubscriptionAction;
 +
 +/**
 + * Every IPC packet starts with this structure
 + */
 +typedef struct dwm_ipc_header {
 +  uint8_t magic[IPC_MAGIC_LEN];
 +  uint32_t size;
 +  uint8_t type;
 +} __attribute((packed)) dwm_ipc_header_t;
 +
 +typedef enum ArgType {
 +  ARG_TYPE_NONE = 0,
 +  ARG_TYPE_UINT = 1,
 +  ARG_TYPE_SINT = 2,
 +  ARG_TYPE_FLOAT = 3,
 +  ARG_TYPE_PTR = 4,
 +  ARG_TYPE_STR = 5
 +} ArgType;
 +
 +/**
 + * An IPCCommand function can have either of these function signatures
 + */
 +typedef union ArgFunction {
 +  void (*single_param)(const Arg *);
 +  void (*array_param)(const Arg *, int);
 +} ArgFunction;
 +
 +typedef struct IPCCommand {
 +  char *name;
 +  ArgFunction func;
 +  unsigned int argc;
 +  ArgType *arg_types;
 +} IPCCommand;
 +
 +typedef struct IPCParsedCommand {
 +  char *name;
 +  Arg *args;
 +  ArgType *arg_types;
 +  unsigned int argc;
 +} IPCParsedCommand;
 +
 +/**
 + * Initialize the IPC socket and the IPC module
 + *
 + * @param socket_path Path to create the socket at
 + * @param epoll_fd File descriptor for epoll
 + * @param commands Address of IPCCommands array defined in config.h
 + * @param commands_len Length of commands[] array
 + *
 + * @return int The file descriptor of the socket if it was successfully created,
 + *   -1 otherwise
 + */
 +int ipc_init(const char *socket_path, const int p_epoll_fd,
 +             IPCCommand commands[], const int commands_len);
 +
 +/**
 + * Uninitialize the socket and module. Free allocated memory and restore static
 + * variables to their state before ipc_init
 + */
 +void ipc_cleanup();
 +
 +/**
 + * Get the file descriptor of the IPC socket
 + *
 + * @return int File descriptor of IPC socket, -1 if socket not created.
 + */
 +int ipc_get_sock_fd();
 +
 +/**
 + * Get address to IPCClient with specified file descriptor
 + *
 + * @param fd File descriptor of IPC Client
 + *
 + * @return Address to IPCClient with specified file descriptor, -1 otherwise
 + */
 +IPCClient *ipc_get_client(int fd);
 +
 +/**
 + * Check if an IPC client exists with the specified file descriptor
 + *
 + * @param fd File descriptor
 + *
 + * @return int 1 if client exists, 0 otherwise
 + */
 +int ipc_is_client_registered(int fd);
 +
 +/**
 + * Disconnect an IPCClient from the socket and remove the client from the list
 + *   of known connected clients
 + *
 + * @param c Address of IPCClient
 + *
 + * @return 0 if the client's file descriptor was closed successfully, the
 + * result of executing close() on the file descriptor otherwise.
 + */
 +int ipc_drop_client(IPCClient *c);
 +
 +/**
 + * Accept an IPC Client requesting to connect to the socket and add it to the
 + *   list of clients
 + *
 + * @return File descriptor of new client, -1 on error
 + */
 +int ipc_accept_client();
 +
 +/**
 + * Read an incoming message from an accepted IPC client
 + *
 + * @param c Address of IPCClient
 + * @param msg_type Address to IPCMessageType variable which will be assigned
 + *   the message type of the received message
 + * @param msg_size Address to uint32_t variable which will be assigned the size
 + *   of the received message
 + * @param msg Address to char* variable which will be assigned the address of
 + *   the received message. This must be freed using free().
 + *
 + * @return 0 on success, -1 on error reading message, -2 if reading the message
 + * resulted in EAGAIN, EINTR, or EWOULDBLOCK.
 + */
 +int ipc_read_client(IPCClient *c, IPCMessageType *msg_type, uint32_t *msg_size,
 +                    char **msg);
 +
 +/**
 + * Write any pending buffer of the client to the client's socket
 + *
 + * @param c Client whose buffer to write
 + *
 + * @return Number of bytes written >= 0, -1 otherwise. errno will still be set
 + * from the write operation.
 + */
 +ssize_t ipc_write_client(IPCClient *c);
 +
 +/**
 + * Prepare a message in the specified client's buffer.
 + *
 + * @param c Client to prepare message for
 + * @param msg_type Type of message to prepare
 + * @param msg_size Size of the message in bytes. Should not exceed
 + *   MAX_MESSAGE_SIZE
 + * @param msg Message to prepare (not including header). This pointer can be
 + *   freed after the function invocation.
 + */
 +void ipc_prepare_send_message(IPCClient *c, const IPCMessageType msg_type,
 +                              const uint32_t msg_size, const char *msg);
 +
 +/**
 + * Prepare an error message in the specified client's buffer
 + *
 + * @param c Client to prepare message for
 + * @param msg_type Type of message
 + * @param format Format string following vsprintf
 + * @param ... Arguments for format string
 + */
 +void ipc_prepare_reply_failure(IPCClient *c, IPCMessageType msg_type,
 +                               const char *format, ...);
 +
 +/**
 + * Prepare a success message in the specified client's buffer
 + *
 + * @param c Client to prepare message for
 + * @param msg_type Type of message
 + */
 +void ipc_prepare_reply_success(IPCClient *c, IPCMessageType msg_type);
 +
 +/**
 + * Send a tag_change_event to all subscribers. Should be called only when there
 + * has been a tag state change.
 + *
 + * @param mon_num The index of the monitor (Monitor.num property)
 + * @param old_state The old tag state
 + * @param new_state The new (now current) tag state
 + */
 +void ipc_tag_change_event(const int mon_num, TagState old_state,
 +                          TagState new_state);
 +
 +/**
 + * Send a client_focus_change_event to all subscribers. Should be called only
 + * when the client focus changes.
 + *
 + * @param mon_num The index of the monitor (Monitor.num property)
 + * @param old_client The old DWM client selection (Monitor.oldsel)
 + * @param new_client The new (now current) DWM client selection
 + */
 +void ipc_client_focus_change_event(const int mon_num, Client *old_client,
 +                                   Client *new_client);
 +
 +/**
 + * Send a layout_change_event to all subscribers. Should be called only
 + * when there has been a layout change.
 + *
 + * @param mon_num The index of the monitor (Monitor.num property)
 + * @param old_symbol The old layout symbol
 + * @param old_layout Address to the old Layout
 + * @param new_symbol The new (now current) layout symbol
 + * @param new_layout Address to the new Layout
 + */
 +void ipc_layout_change_event(const int mon_num, const char *old_symbol,
 +                             const Layout *old_layout, const char *new_symbol,
 +                             const Layout *new_layout);
 +
 +/**
 + * Send a monitor_focus_change_event to all subscribers. Should be called only
 + * when the monitor focus changes.
 + *
 + * @param last_mon_num The index of the previously selected monitor
 + * @param new_mon_num The index of the newly selected monitor
 + */
 +void ipc_monitor_focus_change_event(const int last_mon_num,
 +                                    const int new_mon_num);
 +
 +/**
 + * Send a focused_title_change_event to all subscribers. Should only be called
 + * if a selected client has a title change.
 + *
 + * @param mon_num Index of the client's monitor
 + * @param client_id Window XID of client
 + * @param old_name Old name of the client window
 + * @param new_name New name of the client window
 + */
 +void ipc_focused_title_change_event(const int mon_num, const Window client_id,
 +                                    const char *old_name, const char *new_name);
 +
 +/**
 + * Send a focused_state_change_event to all subscribers. Should only be called
 + * if a selected client has a state change.
 + *
 + * @param mon_num Index of the client's monitor
 + * @param client_id Window XID of client
 + * @param old_state Old state of the client
 + * @param new_state New state of the client
 + */
 +void ipc_focused_state_change_event(const int mon_num, const Window client_id,
 +                                    const ClientState *old_state,
 +                                    const ClientState *new_state);
 +/**
 + * Check to see if an event has occured and call the *_change_event functions
 + * accordingly
 + *
 + * @param mons Address of Monitor pointing to start of linked list
 + * @param lastselmon Address of pointer to previously selected monitor
 + * @param selmon Address of selected Monitor
 + */
 +void ipc_send_events(Monitor *mons, Monitor **lastselmon, Monitor *selmon);
 +
 +/**
 + * Handle an epoll event caused by a registered IPC client. Read, process, and
 + * handle any received messages from clients. Write pending buffer to client if
 + * the client is ready to receive messages. Drop clients that have sent an
 + * EPOLLHUP.
 + *
 + * @param ev Associated epoll event returned by epoll_wait
 + * @param mons Address of Monitor pointing to start of linked list
 + * @param selmon Address of selected Monitor
 + * @param lastselmon Address of pointer to previously selected monitor
 + * @param tags Array of tag names
 + * @param tags_len Length of tags array
 + * @param layouts Array of available layouts
 + * @param layouts_len Length of layouts array
 + *
 + * @return 0 if event was successfully handled, -1 on any error receiving
 + * or handling incoming messages or unhandled epoll event.
 + */
 +int ipc_handle_client_epoll_event(struct epoll_event *ev, Monitor *mons,
 +                                  Monitor **lastselmon, Monitor *selmon,
 +                                  const char *tags[], const int tags_len,
 +                                  const Layout *layouts, const int layouts_len);
 +
 +/**
 + * Handle an epoll event caused by the IPC socket. This function only handles an
 + * EPOLLIN event indicating a new client requesting to connect to the socket.
 + *
 + * @param ev Associated epoll event returned by epoll_wait
 + *
 + * @return 0, if the event was successfully handled, -1 if not an EPOLLIN event
 + * or if a new IPC client connection request could not be accepted.
 + */
 +int ipc_handle_socket_epoll_event(struct epoll_event *ev);
 +
 +#endif /* IPC_H_ */
 diff --git a/util.c b/util.c
 index fe044fc..dca4794 100644
 --- a/util.c
 +++ b/util.c
 @@ -3,6 +3,8 @@
  #include <stdio.h>
  #include <stdlib.h>
  #include <string.h>
 +#include <errno.h>
 +#include <sys/stat.h>
  
  #include "util.h"
  
 @@ -33,3 +35,136 @@ die(const char *fmt, ...) {
  
  	exit(1);
  }
 +
 +int
 +normalizepath(const char *path, char **normal)
 +{
 +  size_t len = strlen(path);
 +  *normal = (char *)malloc((len + 1) * sizeof(char));
 +  const char *walk = path;
 +  const char *match;
 +  size_t newlen = 0;
 +
 +  while ((match = strchr(walk, '/'))) {
 +    // Copy everything between match and walk
 +    strncpy(*normal + newlen, walk, match - walk);
 +    newlen += match - walk;
 +    walk += match - walk;
 +
 +    // Skip all repeating slashes
 +    while (*walk == '/')
 +      walk++;
 +
 +    // If not last character in path
 +    if (walk != path + len)
 +      (*normal)[newlen++] = '/';
 +  }
 +
 +  (*normal)[newlen++] = '\0';
 +
 +  // Copy remaining path
 +  strcat(*normal, walk);
 +  newlen += strlen(walk);
 +
 +  *normal = (char *)realloc(*normal, newlen * sizeof(char));
 +
 +  return 0;
 +}
 +
 +int
 +parentdir(const char *path, char **parent)
 +{
 +  char *normal;
 +  char *walk;
 +
 +  normalizepath(path, &normal);
 +
 +  // Pointer to last '/'
 +  if (!(walk = strrchr(normal, '/'))) {
 +    free(normal);
 +    return -1;
 +  }
 +
 +  // Get path up to last '/'
 +  size_t len = walk - normal;
 +  *parent = (char *)malloc((len + 1) * sizeof(char));
 +
 +  // Copy path up to last '/'
 +  strncpy(*parent, normal, len);
 +  // Add null char
 +  (*parent)[len] = '\0';
 +
 +  free(normal);
 +
 +  return 0;
 +}
 +
 +int
 +mkdirp(const char *path)
 +{
 +  char *normal;
 +  char *walk;
 +  size_t normallen;
 +
 +  normalizepath(path, &normal);
 +  normallen = strlen(normal);
 +  walk = normal;
 +
 +  while (walk < normal + normallen + 1) {
 +    // Get length from walk to next /
 +    size_t n = strcspn(walk, "/");
 +
 +    // Skip path /
 +    if (n == 0) {
 +      walk++;
 +      continue;
 +    }
 +
 +    // Length of current path segment
 +    size_t curpathlen = walk - normal + n;
 +    char curpath[curpathlen + 1];
 +    struct stat s;
 +
 +    // Copy path segment to stat
 +    strncpy(curpath, normal, curpathlen);
 +    strcpy(curpath + curpathlen, "");
 +    int res = stat(curpath, &s);
 +
 +    if (res < 0) {
 +      if (errno == ENOENT) {
 +        DEBUG("Making directory %s\n", curpath);
 +        if (mkdir(curpath, 0700) < 0) {
 +          fprintf(stderr, "Failed to make directory %s\n", curpath);
 +          perror("");
 +          free(normal);
 +          return -1;
 +        }
 +      } else {
 +        fprintf(stderr, "Error statting directory %s\n", curpath);
 +        perror("");
 +        free(normal);
 +        return -1;
 +      }
 +    }
 +
 +    // Continue to next path segment
 +    walk += n;
 +  }
 +
 +  free(normal);
 +
 +  return 0;
 +}
 +
 +int
 +nullterminate(char **str, size_t *len)
 +{
 +  if ((*str)[*len - 1] == '\0')
 +    return 0;
 +
 +  (*len)++;
 +  *str = (char*)realloc(*str, *len * sizeof(char));
 +  (*str)[*len - 1] = '\0';
 +
 +  return 0;
 +}
 diff --git a/util.h b/util.h
 index f633b51..73a238e 100644
 --- a/util.h
 +++ b/util.h
 @@ -4,5 +4,15 @@
  #define MIN(A, B)               ((A) < (B) ? (A) : (B))
  #define BETWEEN(X, A, B)        ((A) <= (X) && (X) <= (B))
  
 +#ifdef _DEBUG
 +#define DEBUG(...) fprintf(stderr, __VA_ARGS__)
 +#else
 +#define DEBUG(...)
 +#endif
 +
  void die(const char *fmt, ...);
  void *ecalloc(size_t nmemb, size_t size);
 +int normalizepath(const char *path, char **normal);
 +int mkdirp(const char *path);
 +int parentdir(const char *path, char **parent);
 +int nullterminate(char **str, size_t *len);
 diff --git a/yajl_dumps.c b/yajl_dumps.c
 new file mode 100644
 index 0000000..8bf9688
 --- /dev/null
 +++ b/yajl_dumps.c
 @@ -0,0 +1,351 @@
 +#include "yajl_dumps.h"
 +
 +#include <stdint.h>
 +
 +int
 +dump_tag(yajl_gen gen, const char *name, const int tag_mask)
 +{
 +  // clang-format off
 +  YMAP(
 +    YSTR("bit_mask"); YINT(tag_mask);
 +    YSTR("name"); YSTR(name);
 +  )
 +  // clang-format on
 +
 +  return 0;
 +}
 +
 +int
 +dump_tags(yajl_gen gen, const char *tags[], int tags_len)
 +{
 +  // clang-format off
 +  YARR(
 +    for (int i = 0; i < tags_len; i++)
 +      dump_tag(gen, tags[i], 1 << i);
 +  )
 +  // clang-format on
 +
 +  return 0;
 +}
 +
 +int
 +dump_client(yajl_gen gen, Client *c)
 +{
 +  // clang-format off
 +  YMAP(
 +    YSTR("name"); YSTR(c->name);
 +    YSTR("tags"); YINT(c->tags);
 +    YSTR("window_id"); YINT(c->win);
 +    YSTR("monitor_number"); YINT(c->mon->num);
 +
 +    YSTR("geometry"); YMAP(
 +      YSTR("current"); YMAP (
 +        YSTR("x"); YINT(c->x);
 +        YSTR("y"); YINT(c->y);
 +        YSTR("width"); YINT(c->w);
 +        YSTR("height"); YINT(c->h);
 +      )
 +      YSTR("old"); YMAP(
 +        YSTR("x"); YINT(c->oldx);
 +        YSTR("y"); YINT(c->oldy);
 +        YSTR("width"); YINT(c->oldw);
 +        YSTR("height"); YINT(c->oldh);
 +      )
 +    )
 +
 +    YSTR("size_hints"); YMAP(
 +      YSTR("base"); YMAP(
 +        YSTR("width"); YINT(c->basew);
 +        YSTR("height"); YINT(c->baseh);
 +      )
 +      YSTR("step"); YMAP(
 +        YSTR("width"); YINT(c->incw);
 +        YSTR("height"); YINT(c->inch);
 +      )
 +      YSTR("max"); YMAP(
 +        YSTR("width"); YINT(c->maxw);
 +        YSTR("height"); YINT(c->maxh);
 +      )
 +      YSTR("min"); YMAP(
 +        YSTR("width"); YINT(c->minw);
 +        YSTR("height"); YINT(c->minh);
 +      )
 +      YSTR("aspect_ratio"); YMAP(
 +        YSTR("min"); YDOUBLE(c->mina);
 +        YSTR("max"); YDOUBLE(c->maxa);
 +      )
 +    )
 +
 +    YSTR("border_width"); YMAP(
 +      YSTR("current"); YINT(c->bw);
 +      YSTR("old"); YINT(c->oldbw);
 +    )
 +
 +    YSTR("states"); YMAP(
 +      YSTR("is_fixed"); YBOOL(c->isfixed);
 +      YSTR("is_floating"); YBOOL(c->isfloating);
 +      YSTR("is_urgent"); YBOOL(c->isurgent);
 +      YSTR("never_focus"); YBOOL(c->neverfocus);
 +      YSTR("old_state"); YBOOL(c->oldstate);
 +      YSTR("is_fullscreen"); YBOOL(c->isfullscreen);
 +    )
 +  )
 +  // clang-format on
 +
 +  return 0;
 +}
 +
 +int
 +dump_monitor(yajl_gen gen, Monitor *mon, int is_selected)
 +{
 +  // clang-format off
 +  YMAP(
 +    YSTR("master_factor"); YDOUBLE(mon->mfact);
 +    YSTR("num_master"); YINT(mon->nmaster);
 +    YSTR("num"); YINT(mon->num);
 +    YSTR("is_selected"); YBOOL(is_selected);
 +
 +    YSTR("monitor_geometry"); YMAP(
 +      YSTR("x"); YINT(mon->mx);
 +      YSTR("y"); YINT(mon->my);
 +      YSTR("width"); YINT(mon->mw);
 +      YSTR("height"); YINT(mon->mh);
 +    )
 +
 +    YSTR("window_geometry"); YMAP(
 +      YSTR("x"); YINT(mon->wx);
 +      YSTR("y"); YINT(mon->wy);
 +      YSTR("width"); YINT(mon->ww);
 +      YSTR("height"); YINT(mon->wh);
 +    )
 +
 +    YSTR("tagset"); YMAP(
 +      YSTR("current");  YINT(mon->tagset[mon->seltags]);
 +      YSTR("old"); YINT(mon->tagset[mon->seltags ^ 1]);
 +    )
 +
 +    YSTR("tag_state"); dump_tag_state(gen, mon->tagstate);
 +
 +    YSTR("clients"); YMAP(
 +      YSTR("selected"); YINT(mon->sel ? mon->sel->win : 0);
 +      YSTR("stack"); YARR(
 +        for (Client* c = mon->stack; c; c = c->snext)
 +          YINT(c->win);
 +      )
 +      YSTR("all"); YARR(
 +        for (Client* c = mon->clients; c; c = c->next)
 +          YINT(c->win);
 +      )
 +    )
 +
 +    YSTR("layout"); YMAP(
 +      YSTR("symbol"); YMAP(
 +        YSTR("current"); YSTR(mon->ltsymbol);
 +        YSTR("old"); YSTR(mon->lastltsymbol);
 +      )
 +      YSTR("address"); YMAP(
 +        YSTR("current"); YINT((uintptr_t)mon->lt[mon->sellt]);
 +        YSTR("old"); YINT((uintptr_t)mon->lt[mon->sellt ^ 1]);
 +      )
 +    )
 +
 +    YSTR("bar"); YMAP(
 +      YSTR("y"); YINT(mon->by);
 +      YSTR("is_shown"); YBOOL(mon->showbar);
 +      YSTR("is_top"); YBOOL(mon->topbar);
 +      YSTR("window_id"); YINT(mon->barwin);
 +    )
 +  )
 +  // clang-format on
 +
 +  return 0;
 +}
 +
 +int
 +dump_monitors(yajl_gen gen, Monitor *mons, Monitor *selmon)
 +{
 +  // clang-format off
 +  YARR(
 +    for (Monitor *mon = mons; mon; mon = mon->next) {
 +      if (mon == selmon)
 +        dump_monitor(gen, mon, 1);
 +      else
 +        dump_monitor(gen, mon, 0);
 +    }
 +  )
 +  // clang-format on
 +
 +  return 0;
 +}
 +
 +int
 +dump_layouts(yajl_gen gen, const Layout layouts[], const int layouts_len)
 +{
 +  // clang-format off
 +  YARR(
 +    for (int i = 0; i < layouts_len; i++) {
 +      YMAP(
 +        // Check for a NULL pointer. The cycle layouts patch adds an entry at
 +        // the end of the layouts array with a NULL pointer for the symbol
 +        YSTR("symbol"); YSTR((layouts[i].symbol ? layouts[i].symbol : ""));
 +        YSTR("address"); YINT((uintptr_t)(layouts + i));
 +      )
 +    }
 +  )
 +  // clang-format on
 +
 +  return 0;
 +}
 +
 +int
 +dump_tag_state(yajl_gen gen, TagState state)
 +{
 +  // clang-format off
 +  YMAP(
 +    YSTR("selected"); YINT(state.selected);
 +    YSTR("occupied"); YINT(state.occupied);
 +    YSTR("urgent"); YINT(state.urgent);
 +  )
 +  // clang-format on
 +
 +  return 0;
 +}
 +
 +int
 +dump_tag_event(yajl_gen gen, int mon_num, TagState old_state,
 +               TagState new_state)
 +{
 +  // clang-format off
 +  YMAP(
 +    YSTR("tag_change_event"); YMAP(
 +      YSTR("monitor_number"); YINT(mon_num);
 +      YSTR("old_state"); dump_tag_state(gen, old_state);
 +      YSTR("new_state"); dump_tag_state(gen, new_state);
 +    )
 +  )
 +  // clang-format on
 +
 +  return 0;
 +}
 +
 +int
 +dump_client_focus_change_event(yajl_gen gen, Client *old_client,
 +                               Client *new_client, int mon_num)
 +{
 +  // clang-format off
 +  YMAP(
 +    YSTR("client_focus_change_event"); YMAP(
 +      YSTR("monitor_number"); YINT(mon_num);
 +      YSTR("old_win_id"); old_client == NULL ? YNULL() : YINT(old_client->win);
 +      YSTR("new_win_id"); new_client == NULL ? YNULL() : YINT(new_client->win);
 +    )
 +  )
 +  // clang-format on
 +
 +  return 0;
 +}
 +
 +int
 +dump_layout_change_event(yajl_gen gen, const int mon_num,
 +                         const char *old_symbol, const Layout *old_layout,
 +                         const char *new_symbol, const Layout *new_layout)
 +{
 +  // clang-format off
 +  YMAP(
 +    YSTR("layout_change_event"); YMAP(
 +      YSTR("monitor_number"); YINT(mon_num);
 +      YSTR("old_symbol"); YSTR(old_symbol);
 +      YSTR("old_address"); YINT((uintptr_t)old_layout);
 +      YSTR("new_symbol"); YSTR(new_symbol);
 +      YSTR("new_address"); YINT((uintptr_t)new_layout);
 +    )
 +  )
 +  // clang-format on
 +
 +  return 0;
 +}
 +
 +int
 +dump_monitor_focus_change_event(yajl_gen gen, const int last_mon_num,
 +                                const int new_mon_num)
 +{
 +  // clang-format off
 +  YMAP(
 +    YSTR("monitor_focus_change_event"); YMAP(
 +      YSTR("old_monitor_number"); YINT(last_mon_num);
 +      YSTR("new_monitor_number"); YINT(new_mon_num);
 +    )
 +  )
 +  // clang-format on
 +
 +  return 0;
 +}
 +
 +int
 +dump_focused_title_change_event(yajl_gen gen, const int mon_num,
 +                                const Window client_id, const char *old_name,
 +                                const char *new_name)
 +{
 +  // clang-format off
 +  YMAP(
 +    YSTR("focused_title_change_event"); YMAP(
 +      YSTR("monitor_number"); YINT(mon_num);
 +      YSTR("client_window_id"); YINT(client_id);
 +      YSTR("old_name"); YSTR(old_name);
 +      YSTR("new_name"); YSTR(new_name);
 +    )
 +  )
 +  // clang-format on
 +
 +  return 0;
 +}
 +
 +int
 +dump_client_state(yajl_gen gen, const ClientState *state)
 +{
 +  // clang-format off
 +  YMAP(
 +    YSTR("old_state"); YBOOL(state->oldstate);
 +    YSTR("is_fixed"); YBOOL(state->isfixed);
 +    YSTR("is_floating"); YBOOL(state->isfloating);
 +    YSTR("is_fullscreen"); YBOOL(state->isfullscreen);
 +    YSTR("is_urgent"); YBOOL(state->isurgent);
 +    YSTR("never_focus"); YBOOL(state->neverfocus);
 +  )
 +  // clang-format on
 +
 +  return 0;
 +}
 +
 +int
 +dump_focused_state_change_event(yajl_gen gen, const int mon_num,
 +                                const Window client_id,
 +                                const ClientState *old_state,
 +                                const ClientState *new_state)
 +{
 +  // clang-format off
 +  YMAP(
 +    YSTR("focused_state_change_event"); YMAP(
 +      YSTR("monitor_number"); YINT(mon_num);
 +      YSTR("client_window_id"); YINT(client_id);
 +      YSTR("old_state"); dump_client_state(gen, old_state);
 +      YSTR("new_state"); dump_client_state(gen, new_state);
 +    )
 +  )
 +  // clang-format on
 +
 +  return 0;
 +}
 +
 +int
 +dump_error_message(yajl_gen gen, const char *reason)
 +{
 +  // clang-format off
 +  YMAP(
 +    YSTR("result"); YSTR("error");
 +    YSTR("reason"); YSTR(reason);
 +  )
 +  // clang-format on
 +
 +  return 0;
 +}
 diff --git a/yajl_dumps.h b/yajl_dumps.h
 new file mode 100644
 index 0000000..ee9948e
 --- /dev/null
 +++ b/yajl_dumps.h
 @@ -0,0 +1,65 @@
 +#ifndef YAJL_DUMPS_H_
 +#define YAJL_DUMPS_H_
 +
 +#include <string.h>
 +#include <yajl/yajl_gen.h>
 +
 +#define YSTR(str) yajl_gen_string(gen, (unsigned char *)str, strlen(str))
 +#define YINT(num) yajl_gen_integer(gen, num)
 +#define YDOUBLE(num) yajl_gen_double(gen, num)
 +#define YBOOL(v) yajl_gen_bool(gen, v)
 +#define YNULL() yajl_gen_null(gen)
 +#define YARR(body)                                                             \
 +  {                                                                            \
 +    yajl_gen_array_open(gen);                                                  \
 +    body;                                                                      \
 +    yajl_gen_array_close(gen);                                                 \
 +  }
 +#define YMAP(body)                                                             \
 +  {                                                                            \
 +    yajl_gen_map_open(gen);                                                    \
 +    body;                                                                      \
 +    yajl_gen_map_close(gen);                                                   \
 +  }
 +
 +int dump_tag(yajl_gen gen, const char *name, const int tag_mask);
 +
 +int dump_tags(yajl_gen gen, const char *tags[], int tags_len);
 +
 +int dump_client(yajl_gen gen, Client *c);
 +
 +int dump_monitor(yajl_gen gen, Monitor *mon, int is_selected);
 +
 +int dump_monitors(yajl_gen gen, Monitor *mons, Monitor *selmon);
 +
 +int dump_layouts(yajl_gen gen, const Layout layouts[], const int layouts_len);
 +
 +int dump_tag_state(yajl_gen gen, TagState state);
 +
 +int dump_tag_event(yajl_gen gen, int mon_num, TagState old_state,
 +                   TagState new_state);
 +
 +int dump_client_focus_change_event(yajl_gen gen, Client *old_client,
 +                                   Client *new_client, int mon_num);
 +
 +int dump_layout_change_event(yajl_gen gen, const int mon_num,
 +                             const char *old_symbol, const Layout *old_layout,
 +                             const char *new_symbol, const Layout *new_layout);
 +
 +int dump_monitor_focus_change_event(yajl_gen gen, const int last_mon_num,
 +                                    const int new_mon_num);
 +
 +int dump_focused_title_change_event(yajl_gen gen, const int mon_num,
 +                                    const Window client_id,
 +                                    const char *old_name, const char *new_name);
 +
 +int dump_client_state(yajl_gen gen, const ClientState *state);
 +
 +int dump_focused_state_change_event(yajl_gen gen, const int mon_num,
 +                                    const Window client_id,
 +                                    const ClientState *old_state,
 +                                    const ClientState *new_state);
 +
 +int dump_error_message(yajl_gen gen, const char *reason);
 +
 +#endif  // YAJL_DUMPS_H_
 -- 
 2.29.2