#include <assert.h>
#include <string.h>
#include "../ipc.c"
#include "../logger/logger.h"

struct str {
  char msg[1023];
  int len;
};

void set_output(struct str* output, char* msg) {
  int i = 0;
  while (msg[i] != 0) {
    assert(i < 1023);
    output->msg[i] = msg[i];
    i++;
  }
  output->len = i;
}

struct strs {
  struct str* data;
  int capacity;
  int count;
};

struct strs init_strs() {
  return (struct strs) {
    .data = malloc(sizeof(struct str) * 10),
    .count = 0,
    .capacity = 10,
  };
}
void add_str(struct strs* strs, char* str) {
  if (strs->count + 1 > strs->capacity) {
    strs->capacity += 30;
    strs->data = realloc(strs->data, sizeof(struct str) * strs->capacity);
  }
  
  struct str item;
  set_output(&item, str);

  strs->data[strs->count] = item;
  strs->count++;
}

struct strs handle_input(mqd_t logging, mqd_t tx, mqd_t rx, char* payload, int len) {
  log_infof("after: %d", payload[len]);
  send_queue(tx, payload, len + 1);
  char* buf = read_queue(rx);

  struct strs output = init_strs();

  if (strcmp(buf, "Sending") != 0) {
    return output;
  }

  int n = get_num_messages(rx);
  while (n > 0) {
    char* buf = read_queue(rx);
    add_str(&output, buf);
    free(buf);
    n--;
    if (n == 0) n = get_num_messages(rx);
  }
  return output;
}