/***** jack.scope.c - (c) rohan drape, 1998-2006 *****/

#include <stdio.h>
#include <errno.h>
#include <sys/types.h>
#include <unistd.h>
#include <stdlib.h>
#include <stdbool.h>
#include <string.h>
#include <pthread.h>
#include <semaphore.h>
#include <getopt.h>
#include <math.h>

#include "common/byte-order.h"
#include "common/failure.h"
#include "common/file.h"
#include "common/img.h"
#include "common/img-ppm.h"
#include "common/jack-client.h"
#include "common/jack-port.h"
#include "common/memory.h"
#include "common/network.h"
#include "common/observe-signal.h"
#include "common/osc.h"
#include "common/print.h"
#include "common/signal-copy.h"
#include "common/signal-clip.h"
#include "common/signal-interleave.h"
#include "common/signal-interpolate.h"
#include "common/ximg.h"

typedef void (*draw_fn_t) (u8 *, i32, 
			   const f32 *, i32, i32, i32, 
			   void *);

typedef bool (*control_fn_t) (const u8 *, i32, void *);

#define SIGNAL_MODE  0
#define EMBED_MODE   1
#define MODE_COUNT   2

#define MAX_CHANNELS 4

struct scope
{
  int channels;
  int window_size;
  int data_frames;
  int data_samples;
  int draw_frames;
  int data_location;
  float *data;
  float *share;
  jack_port_t *port[MAX_CHANNELS];
  pthread_t draw_thread;
  pthread_t osc_thread;
  float fps;
  float delay_msec;
  int delay_frames;
  int delay_location;
  int mode;
  int pipe[2];
  char *image_directory;
  int image_cnt;
  int fd;
  draw_fn_t child_draw[MODE_COUNT];
  control_fn_t child_control[MODE_COUNT];
  void *child_data[MODE_COUNT];
};

void
jackscope_print(struct scope *d)
{
  eprintf("Channels        : %d\n", d->channels);
  eprintf("WindowSize      : %d\n", d->window_size);
  eprintf("DataFrames      : %d\n", d->data_frames);
  eprintf("DataSamples     : %d\n", d->data_samples);
  eprintf("DrawFrames      : %d\n", d->draw_frames);
  eprintf("DataLocation    : %d\n", d->data_location);
  eprintf("FramesPerSecond : %f\n", d->fps);
  eprintf("DelayMSecs      : %f\n", d->delay_msec);
  eprintf("DelayFrames     : %d\n", d->delay_frames);
  eprintf("DelayLocation   : %d\n", d->delay_location);
  eprintf("Mode            : %d\n", d->mode);
}

#define OSC_PARSE_MSG(command,types)				\
  osc_parse_message(command, types, packet, packet_sz, o)

#include "draw/embed.c"
#include "draw/signal.c"

void
set_mode(struct scope *d, const char *mode)
{
  if(strncmp("signal", mode, 6)== 0) {
    d->mode = SIGNAL_MODE;
  } else if(strncmp("embed", mode, 5)== 0) {
    d->mode = EMBED_MODE;
  } else {
    eprintf("jack.scope: illegal mode, %s\n", mode);
  }
}

void *
jackscope_osc_thread_procedure(void *PTR)
{
  struct scope *d = (struct scope *) PTR;
  while(1) {
    const int packet_extent = 32;
    uint8_t packet[packet_extent];
    int packet_sz = xrecv(d->fd, packet, 32, 0);
    osc_data_t o[1];
    if(!(d->child_control[0](packet, packet_sz, d->child_data[0])|| 
	 d->child_control[1](packet, packet_sz, d->child_data[1]))) {
      if(OSC_PARSE_MSG("/frames", ",i")) {
	d->draw_frames = o[0].i > d->data_frames ? d->data_frames : o[0].i;
      } else if(OSC_PARSE_MSG("/mode", ",s")) {
	set_mode(d, o[0].s);
      } else if(OSC_PARSE_MSG("/delay", ",f")) {
	d->delay_msec = o[0].f;
	d->delay_frames = floorf(( d->delay_msec / 1000.0)* d->fps);
      } else {
	eprintf("jack.scope: dropped packet: %8s\n", packet); 
      }
    }
  }
  return NULL;
}
    
/* The data is channel separated into a local buffer, 'local'.  The
   image data 'image' is cleared and a user selected drawing procedure
   is invoked.  The draw procedure must accept any combination of
   window size and frame count, and any number of channels.  */

void *
jackscope_draw_thread_procedure(void *PTR)
{
  struct scope *d = (struct scope *) PTR;
  Ximg_t *x = ximg_open(d->window_size, d->window_size, "jack.scope");
  int image_n = d->window_size * d->window_size * 3;
  uint8_t *image = xmalloc(image_n);
  float *local = xmalloc(d->data_samples * sizeof(float));
  while(! observe_end_of_process ()) {
    char b;
    xread(d->pipe[0], &b, 1);
    signal_uninterleave(local, d->share, d->data_frames, d->channels);
    signal_clip(local, d->data_frames * d->channels, -1.0, 1.0);
    memset(image, 255, image_n);
    d->child_draw[d->mode](image, d->window_size, 
			   local, d->data_frames, 
			   d->draw_frames, d->channels, 
			   d->child_data[d->mode]);
    ximg_blit(x, image);
    if(d->image_directory) {
      char name[256];
      snprintf(name, 256, 
	       "%s/jack.scope.%06d.ppm", 
	       d->image_directory, d->image_cnt);
      img_write_ppm_file(image, d->window_size, d->window_size, name);
    }
    d->image_cnt++;
  }
  ximg_close(x);
  free(image);
  free(local);
  return NULL;
}

/* Accumulate the input signal at `d->data'.  When an image is due to
   be displayed copy the accumulator into `d->share' and poke the
   drawing routine. */

int
jackscope_process(jack_nframes_t nframes, void *PTR)
{
  struct scope *d = (struct scope *) PTR;
  float *in[MAX_CHANNELS];
  int i;
  for(i = 0; i < d->channels; i++) {
    in[i] = (float *) jack_port_get_buffer(d->port[i], nframes);
  }
  int k = d->data_location;
  int l = d->delay_location;
  for(i = 0; i < nframes; i++) {
    int j;
    for(j = 0; j < d->channels; j++) {
      d->data[k++] = (float) in[j][i];
      if(k >= d->data_samples) {
	k = 0;
      }
    }
    l++;
    if(l >= d->delay_frames) {
      signal_copy_circular(d->share, d->data, d->data_samples, k);
      l = 0;
      char b = 1;
      xwrite(d->pipe[1], &b, 1);
    }
  }
  d->data_location = k;
  d->delay_location = l;
  return 0;
}

void
jackscope_usage (void)
{
  eprintf("Usage: jack.scope [ options ] sound-file\n");
  eprintf("   -b  Scope size in frames (default=512).\n");
  eprintf("   -d  Delay time in ms between scope udpates (default=100.0).\n");
  eprintf("   -f  Request images be stored at location (default=NULL).\n");
  eprintf("   -m  Scope operating mode (default=signal).\n");
  eprintf("   -n  Number of channels (default=1).\n");
  eprintf("   -p  Port number to listen for OSC packets (default=57140).\n");
  eprintf("   -w  Scope size in pixels (default=512).\n");
  FAILURE;
}

int
main(int argc, char **argv)
{
  observe_signals ();
  struct scope d;
  d.window_size = 512;
  d.data_frames = 512;
  d.data_samples = 0;
  d.data_location = 0;
  d.draw_frames = 0;
  d.delay_msec = 100.0;
  d.delay_location = 0;
  d.channels = 1;
  d.mode = SIGNAL_MODE;
  d.child_data[0] = signal_init ();
  d.child_draw[0] = signal_draw;
  d.child_control[0] = signal_control;
  d.child_data[1] = embed_init ();
  d.child_draw[1] = embed_draw;
  d.child_control[1] = embed_control;
  d.image_directory = NULL;
  d.image_cnt = 0;
  int port_n = 57140;
  int c;
  while ((c = getopt (argc, argv, "b:d:e:f:hi:m:n:s:w:")) != -1) {
    switch (c) {
    case 'b':
      d.data_frames = strtol(optarg, NULL, 0);
      break;
    case 'd':
      d.delay_msec = strtod(optarg, NULL);
      break;
    case 'f':
      d.image_directory = optarg;
      break;
    case 'h':
      jackscope_usage ();
      break;
    case 'm':
      set_mode(&d, optarg);
      break;
    case 'n':
      d.channels = strtol(optarg, NULL, 0);
      if (d.channels > MAX_CHANNELS) {
	eprintf("illegal channel count: %d", d.channels);
	FAILURE;
      }
      break;
    case 'p':
      port_n = strtol(optarg, NULL, 0);
      break;
    case 'w':
      d.window_size = strtol(optarg, NULL, 0);
      break;
    default:
      eprintf("jack.scope: illegal option, %c\n", (char)c);
      jackscope_usage ();
      break;
    }
  }
  d.draw_frames = d.data_frames;
  d.data_samples = d.data_frames * d.channels;
  d.data = xmalloc(d.data_samples * sizeof (float));
  d.share = xmalloc(d.data_samples * sizeof (float));
  d.fd = socket_udp(0);
  bind_inet(d.fd, NULL, port_n);
  xpipe(d.pipe);
  pthread_create(&(d.osc_thread), NULL, 
		 jackscope_osc_thread_procedure, &d);
  pthread_create(&(d.draw_thread), NULL, 
		 jackscope_draw_thread_procedure, &d);
  jack_client_t *client = jack_client_unique("jack.scope");
  jack_set_process_callback(client, jackscope_process, &d);
  jack_set_error_function(jack_client_minimal_error_handler);
  jack_on_shutdown(client, jack_client_minimal_shutdown_handler, 0);
  d.fps = (float) jack_get_sample_rate(client);
  d.delay_frames = floorf(( d.delay_msec / 1000.0)* d.fps);
  jack_port_make_standard(client, d.port, d.channels, 0);
  jack_client_activate(client);
  pthread_join(d.draw_thread, NULL);
  jack_client_close (client);
  close(d.pipe[0]);
  close(d.pipe[1]);
  free(d.data);
  free(d.share);
  return EXIT_SUCCESS;
}