/* Apply an LV2 Audio Plugin to an Audio File
 *
 * Copyright (C) 2011-2022 Jeremy Salwen <jeremysalwen@gmail.com>
 * Copyright (C) 2017 Robin Gareus <robin@gareus.org>
 * Copyright (C) 2022 Dennis Braun <d_braun@kabelmail.de>
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */

#define _GNU_SOURCE // strdup

#include <argtable2.h>
#include <lilv/lilv.h>
#include <math.h>
#include <regex.h>
#include <sndfile.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

#include "lv2.h"
#include "lv2/lv2plug.in/ns/ext/atom/atom.h"
#include "lv2/lv2plug.in/ns/ext/buf-size/buf-size.h"
#include "lv2/lv2plug.in/ns/ext/options/options.h"
#include "lv2/lv2plug.in/ns/ext/presets/presets.h"
#include "lv2/lv2plug.in/ns/ext/uri-map/uri-map.h"
#include "lv2/lv2plug.in/ns/ext/urid/urid.h"
#include "lv2/lv2plug.in/ns/ext/worker/worker.h"

static const size_t atom_capacity = 32768;

/* ****************************************************************************
 * LV2 URI MAP
 */

static char**   urimap     = NULL;
static uint32_t urimap_len = 0;

static uint32_t
uri_to_id (LV2_URI_Map_Callback_Data unused, const char* uri)
{
	(void)unused;
	for (uint32_t i = 0; i < urimap_len; ++i) {
		if (!strcmp (urimap[i], uri)) {
			return i + 1;
		}
	}
	urimap             = (char**)realloc (urimap, (urimap_len + 1) * sizeof (char*));
	urimap[urimap_len] = strdup (uri);
	return ++urimap_len;
}

static void
free_uri_map ()
{
	for (uint32_t i = 0; i < urimap_len; ++i) {
		free (urimap[i]);
	}
	free (urimap);
}

/* ****************************************************************************
 * LV2 Worker
 */
static LV2_Worker_Interface* worker_iface = NULL;

static LV2_Worker_Status
lv2_worker_respond (LV2_Worker_Respond_Handle handle,
                    uint32_t                  size,
                    const void*               data)
{
	worker_iface->work_response (handle, size, data);
	return LV2_WORKER_SUCCESS;
}

static LV2_Worker_Status
lv2_worker_schedule (LV2_Worker_Schedule_Handle handle,
                     uint32_t                   size,
                     const void*                data)
{
	printf ("lv2_worker_schedule..\n");
	/* all processing is non-realtime, scheduled work can be executed immediately */
	worker_iface->work (handle, lv2_worker_respond, handle, size, data);
	return LV2_WORKER_SUCCESS;
}

/* ****************************************************************************
 * LV2 State
 */
struct statehelper {
	const LilvPlugin* plugin;
	uint32_t          numports;
	float*            params;
};

static void
set_port_value (const char* port_symbol,
                void*       user_data,
                const void* value,
                uint32_t    size,
                uint32_t    type)
{
	if (type != 0 && type != uri_to_id (NULL, "http://lv2plug.in/ns/ext/atom#Float")) {
		return;
	}
	(void)size; // unused
	float val = *(const float*)value;
	//printf ("STATE set %s to %f (t: %d)\n", port_symbol, val, type);
	struct statehelper* sh = (struct statehelper*)user_data;
	for (uint32_t port = 0; port < sh->numports; ++port) {
		const char* symbol = lilv_node_as_string (lilv_port_get_symbol (sh->plugin, lilv_plugin_get_port_by_index (sh->plugin, port)));
		if (!strcmp (symbol, port_symbol)) {
			//printf ("STATE actually set %d to %f\n", port, val);
			sh->params[port] = val;
			break;
		}
	}
}

//From lv2_simple_jack_host in slv2 (GPL code)
void
list_plugins (const LilvPlugins* list)
{
	int j = 1;
	LILV_FOREACH (plugins, i, list)
	{
		const LilvPlugin* p = lilv_plugins_get (list, i);
		printf ("%d\t%s\n", j++, lilv_node_as_uri (lilv_plugin_get_uri (p)));
	}
}

const LilvPlugin*
plugins_get_at (const LilvPlugins* plugins, unsigned int n)
{
	unsigned int j = 0;
	LILV_FOREACH (plugins, i, plugins)
	{
		if (j == n) {
			return lilv_plugins_get (plugins, i);
		}
		j++;
	}
	return NULL;
}

const LilvPlugin*
getplugin (const char* name, const LilvPlugins* plugins, LilvWorld* lilvworld)
{
	int index = atoi (name);
	if (index != 0) {
		return plugins_get_at (plugins, index - 1);
	} else {
		LilvNode* plugin_uri = lilv_new_uri (lilvworld, name);
		if (!plugin_uri) {
			return NULL;
		}
		const LilvPlugin* plugin = lilv_plugins_get_by_uri (plugins, plugin_uri);
		lilv_node_free (plugin_uri);
		return plugin;
	}
}

unsigned int
popcount (bool* connections, unsigned int numchannels)
{
	unsigned int result = 0;
	for (unsigned int i = 0; i < numchannels; i++) {
		result += connections[i];
	}
	return result;
}

void
mix (float* buffer, sf_count_t framesread, unsigned int numchannels, unsigned int numplugins, unsigned int numin, bool connections[numplugins][numin][numchannels], unsigned int blocksize, float pluginbuffers[numplugins][numin][blocksize])
{
	for (unsigned int i = 0; i < framesread; i++) {
		for (unsigned int plugnum = 0; plugnum < numplugins; plugnum++) {
			for (unsigned int port = 0; port < numin; port++) {
				unsigned int nummixed           = 0;
				pluginbuffers[plugnum][port][i] = 0;
				for (unsigned int channel = 0; channel < numchannels; channel++) {
					if (connections[plugnum][port][channel]) {
						nummixed++;
						pluginbuffers[plugnum][port][i] += buffer[i * numchannels + channel];
					}
				}
				if (nummixed) {
					pluginbuffers[plugnum][port][i] /= nummixed;
				}
			}
		}
	}
}

void
interleaveoutput (sf_count_t numread, unsigned int numplugins, unsigned int numout, unsigned int blocksize, float outputbuffers[numplugins][numout][blocksize], float sndfilebuffer[numout * blocksize])
{
	for (unsigned int plugin = 0; plugin < numplugins; plugin++) {
		for (unsigned int port = 0; port < numout; port++) {
			for (unsigned int i = 0; i < numread; i++) {
				sndfilebuffer[plugin * numout * blocksize + i * numout + port] = outputbuffers[plugin][port][i];
			}
		}
	}
}

float
getstartingvalue (float dflt, float min, float max)
{
	if (!isnan (dflt)) {
		return dflt;
	} else {
		if (isnan (min)) {
			if (isnan (max)) {
				return 0;
			} else {
				return fmin (max, 0);
			}
		} else {
			if (isnan (max)) {
				return fmax (min, 0);
			} else {
				return (min + max) / 2;
			}
		}
	}
}

inline char
clipOutput (unsigned long size, float* buffer)
{
	char clipped = 0;
	for (unsigned int i = 0; i < size; i++) {
		if (buffer[i] > 1) {
			clipped   = true;
			buffer[i] = 1;
		}
	}
	for (unsigned int i = 0; i < size; i++) {
		if (buffer[i] < -1) {
			clipped   = true;
			buffer[i] = -1;
		}
	}
	return clipped;
}
void
list_names (LilvWorld* lilvworld, const LilvPlugins* plugins, const char* plugin_name)
{
	const LilvPlugin* plugin = getplugin (plugin_name, plugins, lilvworld);
	if (!plugin) {
		fprintf (stderr, "No such plugin %s\n", plugin_name);
		return;
	}
	LilvNode* input_class   = lilv_new_uri (lilvworld, LILV_URI_INPUT_PORT);
	LilvNode* control_class = lilv_new_uri (lilvworld, LILV_URI_CONTROL_PORT);
	LilvNode* audio_class   = lilv_new_uri (lilvworld, LILV_URI_AUDIO_PORT);
	uint32_t  numports      = lilv_plugin_get_num_ports (plugin);
	printf ("==Audio Ports==\n");
	for (uint32_t port = 0; port < numports; port++) {
		const LilvPort* p = lilv_plugin_get_port_by_index (plugin, port);
		if (lilv_port_is_a (plugin, p, input_class) && lilv_port_is_a (plugin, p, audio_class)) {
			printf ("%s: %s\n", lilv_node_as_string (lilv_port_get_symbol (plugin, p)), lilv_node_as_string (lilv_port_get_name (plugin, p)));
		}
	}
	printf ("==Control Ports==\n");
	for (uint32_t port = 0; port < numports; port++) {
		const LilvPort* p = lilv_plugin_get_port_by_index (plugin, port);
		if (lilv_port_is_a (plugin, p, input_class) && lilv_port_is_a (plugin, p, control_class)) {
			printf ("%s: %s\n", lilv_node_as_string (lilv_port_get_symbol (plugin, p)), lilv_node_as_string (lilv_port_get_name (plugin, p)));
		}
	}
	lilv_node_free (audio_class);
	lilv_node_free (input_class);
	lilv_node_free (control_class);
}

/* TODO Notes:
 * - properly zero (silence pad to blocksize) buffer at EOF
 * - verify mix/interleave with replicated buffers (numplugins * numout == numchannels)
 * - (do a latency compute run, set _plugin_latency_samples)
 * - skip writing first _plugin_latency_samples to file
 * - zero-pad _plugin_latency_samples input frames and keep processing
 */

/* clang-format off */
#define DEFINE_PROCESS                                                                            \
  (unsigned int blocksize,                                                                        \
   unsigned int numchannels,                                                                      \
   unsigned int numin, unsigned int numout,                                                       \
   unsigned int       numplugins,                                                                 \
   bool               connections[numplugins][numin][numchannels],                                \
   float              pluginbuffers[numplugins][numin][blocksize],                                \
   float              outputbuffers[numplugins][numout][blocksize],                               \
   LilvInstance*      instances[numplugins],                                                      \
   LV2_Atom_Sequence* seq_in,                                                                     \
   LV2_Atom_Sequence* seq_out,                                                                    \
   SNDFILE*           insndfile,                                                                  \
   SNDFILE*           outsndfile)                                                                 \
{                                                                                                 \
  float sndfilebuffer[numplugins * numout * blocksize];                                           \
  float buffer[numchannels * blocksize];                                                          \
  INITIALIZE_CLIPPED ()                                                                           \
  sf_count_t numread;                                                                             \
  while ((numread = sf_readf_float (insndfile, buffer, blocksize))) {                             \
    mix (buffer, numread, numchannels, numplugins, numin, connections, blocksize, pluginbuffers); \
    for (unsigned int plugnum = 0; plugnum < numplugins; plugnum++) {                             \
      seq_in->atom.size  = sizeof (LV2_Atom_Sequence_Body);                                       \
      seq_in->atom.type  = uri_to_id (NULL, LV2_ATOM__Sequence);                                  \
      seq_out->atom.size = atom_capacity;                                                         \
      seq_out->atom.type = uri_to_id (NULL, LV2_ATOM__Chunk);                                     \
      lilv_instance_run (instances[plugnum], blocksize);                                          \
    }                                                                                             \
    interleaveoutput (numread, numplugins, numout, blocksize, outputbuffers, sndfilebuffer);      \
    CHECK_CLIPPED ()                                                                              \
    sf_writef_float (outsndfile, sndfilebuffer, numread);                                         \
  }                                                                                               \
}
/* clang-format on */

#define INITIALIZE_CLIPPED()
#define CHECK_CLIPPED()

void process_no_check_clipping DEFINE_PROCESS

#undef INITIALIZE_CLIPPED
#define INITIALIZE_CLIPPED() bool clipped = 0;

#undef CHECK_CLIPPED
/* clang-format off */
#define CHECK_CLIPPED()                                                                        \
if(!clipped && clipOutput (numread * numout, sndfilebuffer)) {                                 \
  clipped = true;                                                                              \
  printf (                                                                                     \
      "WARNING: Clipping output.\n"                                                            \
      "Try changing parameters of the plugin to lower the output volume, "                     \
      "or if that's not possible, try lowering the volume of the input before processing.\n"); \
}
    /* clang-format on */

    void process_check_clipping DEFINE_PROCESS

    int
    main (int argc, char** argv)
{
	struct arg_lit* listopt     = arg_lit1 ("l", "list", "Lists all available LV2 plugins");
	struct arg_end* listend     = arg_end (20);
	void*           listtable[] = { listopt, listend };

	bool list_presets_only = false;
	// Return code for the program.
	bool errorcode = 0;

	if (arg_nullcheck (listtable) != 0) {
		printf ("Error: insufficient memory\n");
		errorcode = 1;
		goto cleanup_listtable;
	}

	LilvWorld* lilvworld = lilv_world_new ();
	if (lilvworld == NULL) {
		printf ("Error: failed to instantiate Lilv World\n");
		errorcode = 2;
		goto cleanup_listtable;
	}
	lilv_world_load_all (lilvworld);
	const LilvPlugins* plugins = lilv_world_get_all_plugins (lilvworld);

	if (!arg_parse (argc, argv, listtable)) {
		list_plugins (plugins);
		errorcode = 3;
		goto cleanup_lilvworld;
	}

	struct arg_lit* preslistopt      = arg_lit1 ("L", "list-presets", "Lists presets for given plugin LV2 plugins");
	struct arg_lit* portnames        = arg_lit1 ("n", "nameports", "List the names of the input ports of a given plugin");
	struct arg_str* pluginname       = arg_str1 (NULL, NULL, "plugin", NULL);
	struct arg_end* nameend          = arg_end (20);
	void*           listnamestable[] = { portnames, pluginname, nameend };
	if (arg_nullcheck (listnamestable) != 0) {
		fprintf (stderr, "Error: insufficient memory\n");
		errorcode = 4;
		goto cleanup_listnamestable;
	}
	if (!arg_parse (argc, argv, listnamestable)) {
		list_names (lilvworld, plugins, pluginname->sval[0]);
		errorcode = 5;
		goto cleanup_listnamestable;
	}

	void* listpresettable[] = { preslistopt, pluginname, nameend };
	if (arg_nullcheck (listpresettable) != 0) {
		fprintf (stderr, "Error: insufficient memory\n");
		errorcode = 6;
		goto cleanup_listnamestable;
	}

	if (!arg_parse (argc, argv, listpresettable)) {
		list_presets_only = true;
	}

	struct arg_rex* connectargs = arg_rexn ("c", "connect", "(\\d+:(\\d+\\.)?\\w+,?)*", "<int>:<audioport>", 0, 200, REG_EXTENDED, "Connect between audio file channels and plugin input channels.");

	struct arg_file* infile         = arg_file1 ("i", NULL, "input", "Input sound file");
	struct arg_file* outfile        = arg_file1 ("o", NULL, "output", "Output sound file");
	struct arg_int* rate            = arg_int0("r", "--rate", "<int>", "sample rate for raw float data");
	struct arg_int* channels        = arg_int0("n", "--channels", "<int>", "channel count for raw float data");
	struct arg_rex*  controls       = arg_rexn ("p", "parameters", "(\\w+:\\w+,?)*", "<controlport>:<float>", 0, 200, REG_EXTENDED, "Pass a value to a plugin control port.");
	pluginname                      = arg_str1 (NULL, NULL, "plugin", "The LV2 URI of the plugin");
	struct arg_int* blksize         = arg_int0 ("b", "blocksize", "<int>", "Chunk size in which the sound is processed. This is frames, not samples.");
	struct arg_str* presetname      = arg_str0 ("P", "preset", "<name>", "Plugin-preset to load (before applying custom ctrl-port values)");
	struct arg_lit* mono            = arg_lit0 ("m", "mono", "Mix all of the channels together before processing.");
	struct arg_lit* ignore_clipping = arg_lit0 (NULL, "ignore-clipping", "Do not check for clipping.  This option is slightly faster");
	blksize->ival[0]                = 512;
	rate->ival[0]                   = -1;
    channels->ival[0]               = -1; 
	struct arg_end* endarg          = arg_end (20);
	void*           argtable[]      = { infile, outfile, rate, channels, presetname, controls, connectargs, blksize, mono, ignore_clipping, pluginname, endarg };
	if (arg_nullcheck (argtable) != 0) {
		fprintf (stderr, "Error: insufficient memory\n");
		errorcode = 7;
		goto cleanup_argtable;
	}
	int nerrors = arg_parse (argc, argv, argtable);
	if (nerrors && !list_presets_only) {
		arg_print_errors (stderr, endarg, "lv2file");
		fprintf (stderr, "usage:\nlv2file\t");
		arg_print_syntaxv (stderr, listtable, "\n\t");
		arg_print_syntaxv (stderr, listpresettable, "\n\t");
		arg_print_syntaxv (stderr, listnamestable, "\n\t");
		arg_print_syntaxv (stderr, argtable, "\n");
		arg_print_glossary_gnu (stderr, listtable);
		arg_print_glossary_gnu (stderr, listnamestable);
		arg_print_glossary_gnu (stderr, argtable);
		errorcode = 8;
		goto cleanup_argtable;
	}
    bool dopipe=(rate->ival[0]>0 && channels->ival[0]>0);
    if ((rate->ival[0]<0) != (channels->ival[0]<0)) {
        fprintf(stderr,"--rate/-r and --channels/-n must both be specified or not at all");
		errorcode = 9;
        goto cleanup_argtable;
    }

	bool mixdown = mono->count;

	const LilvPlugin* plugin = getplugin (pluginname->sval[0], plugins, lilvworld);
	if (!plugin) {
		fprintf (stderr, "No such plugin %s\n", pluginname->sval[0]);
		errorcode = 10;
		goto cleanup_argtable;
	}
	LilvNode* input_class      = lilv_new_uri (lilvworld, LILV_URI_INPUT_PORT);
	LilvNode* output_class     = lilv_new_uri (lilvworld, LILV_URI_OUTPUT_PORT);
	LilvNode* control_class    = lilv_new_uri (lilvworld, LILV_URI_CONTROL_PORT);
	LilvNode* audio_class      = lilv_new_uri (lilvworld, LILV_URI_AUDIO_PORT);
	LilvNode* event_class      = lilv_new_uri (lilvworld, LILV_URI_EVENT_PORT);
	LilvNode* midi_class       = lilv_new_uri (lilvworld, LILV_URI_MIDI_EVENT);
	LilvNode* preset_class     = lilv_new_uri (lilvworld, LV2_PRESETS__Preset);
	LilvNode* optional         = lilv_new_uri (lilvworld, LILV_NS_LV2 "connectionOptional");
	LilvNode* freewheel_port   = lilv_new_uri (lilvworld, LV2_CORE__freeWheeling);
	LilvNode* latency_port     = lilv_new_uri (lilvworld, LV2_CORE__reportsLatency);
	LilvNode* label_pred       = lilv_new_uri (lilvworld, LILV_NS_RDFS "label");
	LilvNode* atom_AtomPort    = lilv_new_uri (lilvworld, LV2_ATOM__AtomPort);
	LilvNode* atom_Sequence    = lilv_new_uri (lilvworld, LV2_ATOM__Sequence);
	LilvNode* worker_schedule  = lilv_new_uri (lilvworld, LV2_WORKER__schedule);
	LilvNode* worker_iface_uri = lilv_new_uri (lilvworld, LV2_WORKER__interface);

	/* get plugin presets */
	LilvState* state   = NULL;
	LilvNodes* presets = lilv_plugin_get_related (plugin, preset_class);
	if (presets) {
		LILV_FOREACH (nodes, i, presets)
		{
			const LilvNode* preset = lilv_nodes_get (presets, i);
			lilv_world_load_resource (lilvworld, preset);
			LilvNodes* titles = lilv_world_find_nodes (lilvworld, preset, label_pred, NULL);
			if (titles) {
				const char* title = lilv_node_as_string (lilv_nodes_get_first (titles));
				if (list_presets_only) {
					printf ("Preset: %s\n", title);
				} else if (presetname->count > 0 && !strcmp (presetname->sval[0], title)) {
					LV2_URID_Map uri_map = { NULL, &uri_to_id };
					state                = lilv_state_new_from_world (lilvworld, &uri_map, preset);
					lilv_nodes_free (titles);
					break;
				}
				lilv_nodes_free (titles);
			}
		}
	}
	lilv_nodes_free (presets);
	if (list_presets_only) {
		goto cleanup_lilvnodes;
	}

	if (presetname->count > 0 && !state) {
		fprintf (stderr, "Preset '%s' was not found.\n", presetname->sval[0]);
		errorcode = 11;
		goto cleanup_lilvnodes;
	}

	SF_INFO formatinfo;
	formatinfo.format   = 0;
	SNDFILE* insndfile;
	if (dopipe) {
		memset(&formatinfo, 0, sizeof(SF_INFO));
		formatinfo.format=SF_FORMAT_FLOAT | SF_FORMAT_RAW | SF_ENDIAN_CPU;
		formatinfo.samplerate=rate->ival[0];
		formatinfo.channels=channels->ival[0];
	}
	if (dopipe && !strcmp(*(infile->filename),"-")) {
		insndfile=sf_open_fd(STDIN_FILENO, SFM_READ, &formatinfo, 0);
	} else {
		insndfile=sf_open(*(infile->filename), SFM_READ, &formatinfo);
	}
	int      sndfileerr = sf_error (insndfile);
	if (sndfileerr) {
		fprintf (stderr, "Error reading input file: %s\n", sf_error_number (sndfileerr));
		errorcode = 12;
		goto cleanup_sndfile;
	}

	unsigned int numchannels = formatinfo.channels;
	unsigned int blocksize   = blksize->ival[0];

	{
		uint32_t     numports = lilv_plugin_get_num_ports (plugin);
		unsigned int numout   = 0;
		uint32_t     outindices[numports];
		unsigned int numin = 0;
		uint32_t     inindices[numports];
		unsigned int numcontrol = 0;
		uint32_t     controlindices[numports];
		unsigned int numcontrolout = 0;
		uint32_t     controloutindices[numports];

		int  fwheelportidx = -1;
		for (uint32_t i = 0; i < numports; i++) {
			const LilvPort* porti = lilv_plugin_get_port_by_index (plugin, i);
			if (lilv_port_is_a (plugin, porti, audio_class)) {
				if (lilv_port_is_a (plugin, porti, input_class)) {
					inindices[numin++] = i;
				} else if (lilv_port_is_a (plugin, porti, output_class)) {
					outindices[numout++] = i;
				} else {
					fprintf (stderr, "Audio port not input or output\n");
					errorcode = 13;
					goto cleanup_sndfile;
				}
			} else if (lilv_port_is_a (plugin, porti, control_class)) {
				//We really only care about *input* control ports.
				if (lilv_port_is_a (plugin, porti, input_class)) {
					controlindices[numcontrol++] = i;
					if (lilv_port_has_property (plugin, porti, freewheel_port)) {
						fwheelportidx = i;
					}
				} else if (lilv_port_is_a (plugin, porti, output_class)) {
					if (lilv_port_has_property (plugin, porti, latency_port)) {
						// TODO: remember this port, use its value later (ignore first N output samples)
					}
					controloutindices[numcontrolout++] = i;
				} else {
					fprintf (stderr, "Control port not input or output\n");
					errorcode = 14;
					goto cleanup_sndfile;
				}
			} else if (lilv_port_is_a (plugin, porti, atom_AtomPort)) {
				/* OK, handled later */
			} else if (!lilv_port_has_property (plugin, porti, optional)) {
				fprintf (stderr, "Error!  Unable to handle a required port \n");
				errorcode = 15;
				goto cleanup_sndfile;
			}
		}

		formatinfo.channels = numout;
		SNDFILE* outsndfile;
		if (dopipe && !strcmp(*(outfile->filename),"-")) {
			outsndfile=sf_open_fd(STDOUT_FILENO, SFM_WRITE, &formatinfo, 0);
		} else {
			outsndfile=sf_open(*(outfile->filename), SFM_WRITE, &formatinfo);
		}
		
		sndfileerr = sf_error (outsndfile);
		if (sndfileerr) {
			fprintf (stderr, "Error reading output file: %s\n", sf_error_number (sndfileerr));
			errorcode = 16;
			goto cleanup_outfile;
		}

		{
			unsigned int numplugins = 1;
			if (connectargs->count) {
				for (int i = 0; i < connectargs->count; i++) {
					const char* connectionlist = connectargs->sval[i];
					while (*connectionlist) {
						char* nextcomma = strchr (connectionlist, ',');
						char* nextcolon;
						if (nextcomma) {
							nextcolon = memchr (connectionlist, ':', nextcomma - connectionlist);
						} else {
							nextcolon = strchr (connectionlist, ':');
						}
						if (!nextcolon) {
							fprintf (stderr, "Error parsing connection:  Expected colon between channel and port.\n");
							errorcode = 17;
							goto cleanup_outfile;
						}
						nextcolon++;
						int   pluginstance = 0;
						char* nextperiod   = strchr (nextcolon, '.');
						if (nextperiod) {
							char tmpbuffer[nextperiod - nextcolon + 1];
							memcpy (tmpbuffer, nextcolon, sizeof (char) * (nextperiod - nextcolon));
							tmpbuffer[nextperiod - nextcolon] = 0;
							pluginstance                      = atoi (tmpbuffer) - 1;
							if (pluginstance < 0) {
								fprintf (stderr, "Invalid plugin instance specified");
								errorcode = 18;
								goto cleanup_outfile;
							}
						} else {
							nextperiod = nextcolon;
						}
						if (((unsigned)pluginstance) >= numplugins) {
							//Make sure we are instantiating enough instances of the plugin.
							numplugins = pluginstance + 1;
						}
						if (nextcomma) {
							connectionlist = nextcomma + 1;
						} else {
							break;
						}
					}
				}
			} else if (numin == 1 && !mixdown) {
				numplugins = numchannels;
			}
			printf ("Note: Running %i instances of the plugin.\n", numplugins);
			bool connections[numplugins][numin][numchannels];
			memset (connections, 0, sizeof (connections));

			if (connectargs->count) {
				for (int i = 0; i < connectargs->count; i++) {
					const char* connectionlist = connectargs->sval[i];
					while (*connectionlist) {
						int channel = atoi (connectionlist) - 1;
						if (channel < 0 || ((unsigned)channel) >= numchannels) {
							fprintf (stderr, "Input sound file does not have channel %u.  It has %u channels.\n", channel + 1, numchannels);
							errorcode = 19;
							goto cleanup_outfile;
						}

						char* nextcomma = strchr (connectionlist, ',');
						if (nextcomma) {
							*nextcomma = 0;
						}
						char* nextcolon = strchr (connectionlist, ':');
						//Will not be nill otherwise it would have been caught when counting plugin instances
						*nextcolon = 0;
						nextcolon++;
						unsigned int pluginstance = 0;
						char*        nextperiod   = strchr (nextcolon, '.');
						if (nextperiod) {
							*nextperiod  = 0;
							pluginstance = atoi (nextcolon + 1) - 1;
						} else {
							nextperiod = nextcolon;
						}
						bool foundmatch = false;
						for (uint32_t port = 0; port < numin; port++) {
							//Do not need to free, kept internally.
							const char* symbol = lilv_node_as_string (lilv_port_get_symbol (plugin, lilv_plugin_get_port_by_index (plugin, inindices[port])));
							if (!strcmp (symbol, nextperiod)) {
								connections[pluginstance][port][channel] = true;
								foundmatch                               = true;
								break;
							}
						}
						if (!foundmatch) {
							fprintf (stderr, "Port with symbol %s does not exist.\n", nextcolon);
							errorcode = 20;
							goto cleanup_outfile;
						}
						if (nextcomma) {
							connectionlist = nextcomma + 1;
						} else {
							break;
						}
					}
				}
				printf ("Note: Only making user specified connections.\n");
			} else {
				if (numin == numchannels) {
					printf ("Note: Mapping audio channels to plugin ports based on ordering\n");
					for (unsigned int i = 0; i < numin; i++) {
						connections[0][i][i] = true;
					}
				} else if (numin == 1) {
					if (mixdown) {
						printf ("Note: Down mixing all channels to a single plugin input\n");
						for (unsigned int i = 0; i < numin; i++) {
							connections[0][0][i] = true;
						}
					} else {
						printf ("Note: Running an instance of the plugin per channel\n");
						for (unsigned int i = 0; i < numchannels; i++) {
							connections[i][0][i] = true;
						}
					}
				} else if (numchannels > numin) {
					printf ("Note: Extra channels ignored when mapping channels to plugin ports\n");
					for (unsigned int i = 0; i < numin; i++) {
						connections[0][i][i] = true;
					}
				} else {
					fprintf (stderr, "Error: Not enough input channels to connect all of the plugin's ports.  Please manually specify connections\n");
					errorcode = 21;
					goto cleanup_outfile;
				}
			}

			float defaultvalues[numports];

			float minvalues[numports];
			float maxvalues[numports];
			lilv_plugin_get_port_ranges_float (plugin, minvalues, maxvalues, defaultvalues);

			struct statehelper sh = { plugin, numports, defaultvalues };

			bool has_worker = lilv_plugin_has_feature (plugin, worker_schedule) && lilv_plugin_has_extension_data (plugin, worker_iface_uri);

			LV2_URID           atom_Int  = uri_to_id (NULL, LV2_ATOM__Int);
			LV2_Options_Option options[] = {
				{ LV2_OPTIONS_INSTANCE, 0, uri_to_id (NULL, LV2_BUF_SIZE__minBlockLength),
				  sizeof (int32_t), atom_Int, &blocksize },
				{ LV2_OPTIONS_INSTANCE, 0, uri_to_id (NULL, LV2_BUF_SIZE__maxBlockLength),
				  sizeof (int32_t), atom_Int, &blocksize },
				{ LV2_OPTIONS_INSTANCE, 0, uri_to_id (NULL, LV2_BUF_SIZE__sequenceSize),
				  sizeof (int32_t), atom_Int, &atom_capacity },
				{ LV2_OPTIONS_INSTANCE, 0, uri_to_id (NULL, "http://lv2plug.in/ns/ext/buf-size#nominalBlockLength"),
				  sizeof (int32_t), atom_Int, &blocksize },
				{ LV2_OPTIONS_INSTANCE, 0, 0, 0, 0, NULL }
			};

			LilvInstance* instances[numplugins];
			
			LV2_URID_Map      uri_map         = { NULL, &uri_to_id };
			const LV2_Feature map_feature     = { LV2_URID__map, &uri_map };
			const LV2_Feature unmap_feature   = { LV2_URID__unmap, NULL };
			const LV2_Feature options_feature = { LV2_OPTIONS__options, options };

			for (unsigned int i = 0; i < numplugins; i++) {
				int                n_features = 3;
				const LV2_Feature* features[5];
				features[0] = &map_feature;
				features[1] = &unmap_feature;
				features[2] = &options_feature;

				LV2_Worker_Schedule* schedule = NULL;
				LV2_Feature schedule_feature = { LV2_WORKER__schedule, NULL };
				if (has_worker) {
					schedule                = (LV2_Worker_Schedule*)malloc (sizeof (LV2_Worker_Schedule));
					schedule->handle        = NULL;
					schedule->schedule_work = lv2_worker_schedule;

					schedule_feature.data  = schedule;
					features[n_features++] = &schedule_feature;
				}

				features[n_features] = NULL;

				instances[i] = lilv_plugin_instantiate (plugin, formatinfo.samplerate, features);

				if (!instances[i]) {
					fprintf (stderr, "Failed to instantiate plugin!\n");
					errorcode = 22;
					goto cleanup_outfile;
				}

				if (has_worker) {
					worker_iface = (LV2_Worker_Interface*)lilv_instance_get_extension_data (instances[i], LV2_WORKER__interface);
					// XXX store handle + iface per instance ?!
					schedule->handle = instances[i]->lv2_handle;
				}

				if (state) {
					lilv_state_restore (state, instances[i], set_port_value, &sh, 0, NULL);
				}

				lilv_instance_activate (instances[i]);
			}
			lilv_state_free (state);

			{
				float pluginbuffers[numplugins][numin][blocksize];
				memset (pluginbuffers, 0, sizeof (pluginbuffers));
				float outputbuffers[numplugins][numout][blocksize];
				memset (outputbuffers, 0, sizeof (outputbuffers));

				float controlports[numcontrol];
				memset (controlports, 0, sizeof (controlports));
				float controloutports[numcontrolout];

				for (unsigned int port = 0; port < numcontrol; port++) {
					unsigned int portindex = controlindices[port];
					controlports[port]     = getstartingvalue (defaultvalues[portindex], minvalues[portindex], maxvalues[portindex]);
				}

				if (fwheelportidx >= 0) {
					controlports[fwheelportidx] = 1;
				}

				if (controls->count) {
					for (int i = 0; i < controls->count; i++) {
						const char* parameters = controls->sval[i];
						while (*parameters) {
							char* nextcomma = strchr (parameters, ',');
							if (nextcomma) {
								*nextcomma = 0;
							}
							char* nextcolon = strchr (parameters, ':');
							if (nextcolon) {
								*nextcolon = 0;
							} else {
								fprintf (stderr, "Error parsing parameters:  Expected colon between port and value.\n");
								errorcode = 23;
								goto cleanup_lv2;
							}
							nextcolon++;
							float value      = strtof (nextcolon, NULL);
							bool  foundmatch = false;
							for (uint32_t port = 0; port < numcontrol; port++) {
								//Do not need to free, kept internally.
								const char* symbol = lilv_node_as_string (lilv_port_get_symbol (plugin, lilv_plugin_get_port_by_index (plugin, controlindices[port])));
								if (!strcmp (symbol, parameters)) {
									controlports[port] = value;
									foundmatch         = true;
									break;
								}
							}
							if (!foundmatch) {
								fprintf (stderr, "Error: Port with symbol %s does not exist.\n", parameters);
								errorcode = 24;
								goto cleanup_lv2;
							}
							if (nextcomma) {
								parameters = nextcomma + 1;
							} else {
								break;
							}
						}
					}
				}

				LV2_Atom_Sequence seq_in = {
					{ sizeof (LV2_Atom_Sequence_Body),
					  uri_to_id (NULL, LV2_ATOM__Sequence) },
					{ 0, 0 }
				};

				LV2_Atom_Sequence* seq_out = (LV2_Atom_Sequence*)malloc (sizeof (LV2_Atom_Sequence) + atom_capacity);

				for (unsigned int i = 0; i < numplugins; i++) {
					for (unsigned int port = 0; port < numin; port++) {
						lilv_instance_connect_port (instances[i], inindices[port], pluginbuffers[i][port]);
					}
					for (unsigned int port = 0; port < numout; port++) {
						lilv_instance_connect_port (instances[i], outindices[port], outputbuffers[i][port]);
					}
					for (unsigned int port = 0; port < numcontrol; port++) {
						lilv_instance_connect_port (instances[i], controlindices[port], &controlports[port]);
					}
					for (unsigned int port = 0; port < numcontrolout; port++) {
						lilv_instance_connect_port (instances[i], controloutindices[port], &controloutports[port]);
					}

					for (uint32_t j = 0; j < numports; j++) {
						const LilvPort* porti = lilv_plugin_get_port_by_index (plugin, j);
						if (lilv_port_is_a (plugin, porti, atom_AtomPort)) {
							if (lilv_port_is_a (plugin, porti, input_class)) {
								lilv_instance_connect_port (instances[i], j, &seq_in);
							} else {
								lilv_instance_connect_port (instances[i], j, seq_out);
							}
						}
					}
				}
				if (ignore_clipping->count) {
					process_no_check_clipping (blocksize, numchannels, numin, numout, numplugins, connections, pluginbuffers, outputbuffers, instances, &seq_in, seq_out, insndfile, outsndfile);
				} else {
					process_check_clipping (blocksize, numchannels, numin, numout, numplugins, connections, pluginbuffers, outputbuffers, instances, &seq_in, seq_out, insndfile, outsndfile);
				}
			}

			cleanup_lv2:
			for (unsigned int i = 0; i < numplugins; i++) {
				lilv_instance_deactivate (instances[i]);
				lilv_instance_free (instances[i]);
			}
		}
	cleanup_outfile:
		if (sf_close (outsndfile)) {
			fprintf (stderr, "Error closing output file!\n");
		}
	}

cleanup_sndfile:
	if (sf_close (insndfile)) {
		fprintf (stderr, "Error closing input file!\n");
	}

cleanup_lilvnodes:
	lilv_node_free (input_class);
	lilv_node_free (output_class);
	lilv_node_free (control_class);
	lilv_node_free (audio_class);
	lilv_node_free (event_class);
	lilv_node_free (midi_class);
	lilv_node_free (preset_class);
	lilv_node_free (optional);
	lilv_node_free (freewheel_port);
	lilv_node_free (latency_port);
	lilv_node_free (label_pred);
	lilv_node_free (atom_AtomPort);
	lilv_node_free (atom_Sequence);
	lilv_node_free (worker_schedule);
	lilv_node_free (worker_iface_uri);

cleanup_argtable:
	arg_freetable (argtable, sizeof (argtable) / sizeof (argtable[0]));
cleanup_listnamestable:
	arg_freetable (listnamestable, sizeof (listnamestable) / sizeof (listnamestable[0]));
cleanup_lilvworld:
	lilv_world_free (lilvworld);
cleanup_listtable:
	arg_freetable (listtable, sizeof (listtable) / sizeof (listtable[0]));

	free_uri_map ();
	return errorcode;
}