1 files changed, 11 insertions, 3 deletions
diff --git a/src/server/comms.c b/src/server/comms.c
index 7b8001b..c96afa8 100644
--- a/src/server/comms.c
+++ b/src/server/comms.c
@@ -1,4 +1,5 @@
 #include <assert.h>
+#include "../ipc.c"
 
 struct str {
   char msg[126];
@@ -41,12 +42,19 @@ void add_str(struct strs* strs, char* str) {
   strs->count++;
 }
 
-struct strs handle_input(char* payload, int len) {
+struct strs handle_input(mqd_t tx, mqd_t rx, char* payload, int len) {
   printf("Message: %.*s\n", len, payload);
   struct strs output = init_strs();
 
-  add_str(&output, "nigga");
-  add_str(&output, "nigga2");
+  char* buf = read_queue(rx);
+  printf("%p\n", buf);
+  add_str(&output, buf);
+  if (buf) free(buf);
+
+  buf = read_queue(rx);
+  printf("%p\n", buf);
+  add_str(&output, buf);
+  if (buf) free(buf);
 
   return output;
 }