#include <spa/param/latency-utils.h>

#include <pipewire/pipewire.h>

struct data;

struct port {
	struct data *data;
};

struct data {
  struct pw_main_loop *loop;
  struct pw_filter *filter;
  struct port *in_port_one;
  struct port *in_port_two;
  struct port *in_port_three;
  struct port *in_port_four;
  struct port *in_port_five;
  struct port *in_port_six;
  struct port *in_port_seven;
  struct port *in_port_eight;
  struct port *out_port;
};

static void on_process(void *userdata, struct spa_io_position *position) {}

static void do_quit(void *userdata, int signal_number) {
  struct data *data = userdata;
  pw_main_loop_quit(data->loop);
}

static const struct pw_filter_events filter_events = {
	PW_VERSION_FILTER_EVENTS,
	.process = on_process,
};

struct port* add_port(char* name, struct data data) {
  return  pw_filter_add_port(data.filter,
			     PW_DIRECTION_INPUT,
			     PW_FILTER_PORT_FLAG_MAP_BUFFERS,
			     sizeof(struct port),
			     pw_properties_new(
					       PW_KEY_FORMAT_DSP, "32 bit float mono audio",
					       PW_KEY_PORT_NAME, name,
					       NULL),
			     NULL, 0);
}

int main(int argc, char *argv[]) {
  struct data data = { 0, };
  const struct spa_pod *params[1];
  uint8_t buffer[1024];
  struct spa_pod_builder b = SPA_POD_BUILDER_INIT(buffer, sizeof(buffer));
  
  pw_init(&argc, &argv);

  data.loop = pw_main_loop_new(NULL);

  pw_loop_add_signal(pw_main_loop_get_loop(data.loop), SIGINT, do_quit, &data);
  pw_loop_add_signal(pw_main_loop_get_loop(data.loop), SIGTERM, do_quit, &data);

  data.filter = pw_filter_new_simple(
				     pw_main_loop_get_loop(data.loop),
				     "ES-5",
				     pw_properties_new(
						       PW_KEY_MEDIA_TYPE, "Audio",
						       PW_KEY_MEDIA_CATEGORY, "Filter",
						       PW_KEY_MEDIA_ROLE, "DSP",
						       NULL),
				     &filter_events,
				     &data);

  data.in_port_one = add_port("input_1", data);
  data.in_port_two = add_port("input_2", data);
  data.in_port_three = add_port("input_3", data);
  data.in_port_four = add_port("input_4", data);
  data.in_port_five = add_port("input_5", data);
  data.in_port_six = add_port("input_6", data);
  data.in_port_seven = add_port("input_7", data);
  data.in_port_eight = add_port("input_8", data);

  data.out_port = pw_filter_add_port(data.filter,
				     PW_DIRECTION_OUTPUT,
				     PW_FILTER_PORT_FLAG_MAP_BUFFERS,
				     sizeof(struct port),
				     pw_properties_new(
						       PW_KEY_FORMAT_DSP, "32 bit float mono audio",
						       PW_KEY_PORT_NAME, "output",
						       NULL),
				     NULL, 0);

  params[0] = spa_process_latency_build(&b,
					SPA_PARAM_ProcessLatency,
					&SPA_PROCESS_LATENCY_INFO_INIT(
								       .ns = 10 * SPA_NSEC_PER_MSEC
								       ));

  if (pw_filter_connect(data.filter,
			PW_FILTER_FLAG_RT_PROCESS,
			params, 1) < 0) {
    fprintf(stderr, "can't connect\n");
    return -1;
  }

  pw_main_loop_run(data.loop);

  pw_filter_destroy(data.filter);
  pw_main_loop_destroy(data.loop);
  return 0;
}