5 #include <sys/socket.h>
11 #include "workspaces.h"
17 typedef void(*handler_t)(char*);
19 int get_ipc_fd(const char *socket_path) {
20 int sockfd = socket(AF_LOCAL, SOCK_STREAM, 0);
22 printf("ERROR: Could not create Socket!\n");
26 struct sockaddr_un addr;
27 memset(&addr, 0, sizeof(struct sockaddr_un));
28 addr.sun_family = AF_LOCAL;
29 strcpy(addr.sun_path, socket_path);
30 if (connect(sockfd, (const struct sockaddr*) &addr, sizeof(struct sockaddr_un)) < 0) {
31 printf("ERROR: Could not connct to i3\n");
37 void got_command_reply(char *reply) {
38 /* FIXME: Error handling for command-replies */
41 void got_workspace_reply(char *reply) {
42 printf("Got Workspace-Data!\n");
43 parse_workspaces_json(reply);
47 void got_subscribe_reply(char *reply) {
48 printf("Got Subscribe Reply: %s\n", reply);
49 /* FIXME: Error handling for subscribe-commands */
52 void got_output_reply(char *reply) {
53 printf("Got Outputs-Data!\nDestroying Windows...\n");
55 printf("Parsing JSON...\n");
56 parse_outputs_json(reply);
57 printf("Creating_Windows...\n");
61 handler_t reply_handlers[] = {
68 void got_workspace_event(char *event) {
69 printf("Got Workspace Event!\n");
70 i3_send_msg(I3_IPC_MESSAGE_TYPE_GET_WORKSPACES, NULL);
73 void got_output_event(char *event) {
74 printf("Got Output Event!\n");
75 i3_send_msg(I3_IPC_MESSAGE_TYPE_GET_OUTPUTS, NULL);
78 handler_t event_handlers[] = {
83 void got_data(struct ev_loop *loop, ev_io *watcher, int events) {
84 printf("Got data!\n");
86 uint32_t header_len = strlen(I3_IPC_MAGIC) + sizeof(uint32_t)*2;
87 char *header = malloc(header_len);
89 printf("ERROR: Could not allocate memory!\n");
94 while (rec < header_len) {
95 int n = read(fd, header + rec, header_len - rec);
97 printf("ERROR: read() failed!\n");
101 printf("ERROR: Nothing to read!\n");
107 if (strncmp(header, I3_IPC_MAGIC, strlen(I3_IPC_MAGIC))) {
108 printf("ERROR: Wrong magic code: %.*s\n Expected: %s\n",
109 (int) strlen(I3_IPC_MAGIC),
115 char *walk = header + strlen(I3_IPC_MAGIC);
116 uint32_t size = *((uint32_t*) walk);
117 walk += sizeof(uint32_t);
118 uint32_t type = *((uint32_t*) walk);
119 char *buffer = malloc(size + 1);
120 if (buffer == NULL) {
121 printf("ERROR: Could not allocate memory!\n");
127 int n = read(fd, buffer + rec, size - rec);
129 printf("ERROR: read() failed!\n");
133 printf("ERROR: Nothing to read!\n");
140 if (type & (1 << 31)) {
142 event_handlers[type](buffer);
144 reply_handlers[type](buffer);
150 int i3_send_msg(uint32_t type, const char *payload) {
152 if (payload != NULL) {
153 len = strlen(payload);
156 uint32_t to_write = strlen (I3_IPC_MAGIC) + sizeof(uint32_t)*2 + len;
157 char *buffer = malloc(to_write);
158 if (buffer == NULL) {
159 printf("ERROR: Could not allocate memory\n");
165 strncpy(buffer, I3_IPC_MAGIC, strlen(I3_IPC_MAGIC));
166 walk += strlen(I3_IPC_MAGIC);
167 memcpy(walk, &len, sizeof(uint32_t));
168 walk += sizeof(uint32_t);
169 memcpy(walk, &type, sizeof(uint32_t));
170 walk += sizeof(uint32_t);
172 strncpy(walk, payload, len);
174 uint32_t written = 0;
176 while (to_write > 0) {
177 int n = write(i3_connection->fd, buffer + written, to_write);
179 printf("ERROR: write() failed!\n");
192 int init_connection(const char *socket_path) {
193 int sockfd = get_ipc_fd(socket_path);
195 i3_connection = malloc(sizeof(ev_io));
196 ev_io_init(i3_connection, &got_data, sockfd, EV_READ);
197 ev_io_start(main_loop, i3_connection);
202 void subscribe_events() {
203 i3_send_msg(I3_IPC_MESSAGE_TYPE_SUBSCRIBE, "[ \"workspace\", \"output\" ]");