MFD_FILTER(midistrum)

#ifdef MX_TTF

	mflt:midistrum
	TTF_DEF("MIDI Strum", "MIDI Strum", ; atom:supports time:Position)
	, TTF_IPORT( 0, "bpmsrc",  "BPM source", 0, 1, 1,
			lv2:scalePoint [ rdfs:label "Control Port" ; rdf:value 0 ] ;
			lv2:scalePoint [ rdfs:label "Plugin Host (if available)" ; rdf:value 1 ] ;
			lv2:portProperty lv2:integer; lv2:portProperty lv2:enumeration;
			)
	, TTF_IPORT(1, "bpm",  "BPM", 1.0, 280.0,  120.0, units:unit units:bpm;
			rdfs:comment "base unit for the time (unless host provides BPM)")
	, TTF_IPORT( 2, "mode",  "Strum Direction", 0, 4, 2,
			lv2:scalePoint [ rdfs:label "Always Down (low notes first)" ; rdf:value 0 ] ;
			lv2:scalePoint [ rdfs:label "Always Up (high notes first)" ; rdf:value 1 ] ;
			lv2:scalePoint [ rdfs:label "Alternate" ; rdf:value 2 ] ;
			lv2:scalePoint [ rdfs:label "Up/Down Beat" ; rdf:value 3 ] ;
			lv2:scalePoint [ rdfs:label "Up/Down 8th" ; rdf:value 4 ] ;
			lv2:portProperty lv2:integer; lv2:portProperty lv2:enumeration;
			rdfs:comment ""
			)
	, TTF_IPORT(3, "collect", "Note Collect Timeout [ms]", 0.0, 300.0, 15.0,
			rdfs:comment "Time to wait for chord to be 'complete'. Keys pressed withing given timeframe will be combined into one chord.")
	, TTF_IPORT(4, "duration", "Strum Duration in Beats", 0.0, 4.0, .25,
			lv2:scalePoint [ rdfs:label "Immediate" ; rdf:value 0.0 ] ;
			lv2:scalePoint [ rdfs:label "32th" ; rdf:value 0.125 ] ;
			lv2:scalePoint [ rdfs:label "16th" ; rdf:value 0.25 ] ;
			lv2:scalePoint [ rdfs:label "Eighth" ; rdf:value 0.5 ] ;
			lv2:scalePoint [ rdfs:label "Quarter" ; rdf:value 1.0 ] ;
			lv2:scalePoint [ rdfs:label "Half Note" ; rdf:value 2.0 ] ;
			lv2:scalePoint [ rdfs:label "Whole Note" ; rdf:value 4.0 ] ;
			rdfs:comment "")
	, TTF_IPORT(5, "adjspeed", "Strum Acceleration", -1.0, 1.0,  0.0,
			rdfs:comment "Accellerate/Decelerate over the time of the strum. The total duration remains unchanged. If the value is greater than zero, early notes are further apart and later notes will be closer together.")
	, TTF_IPORT(6, "adjvelocity", "Velocity Change", -112.0, 112.0,  0.0,
			rdfs:comment "Modify velocity over stroke time. If the value is greater than zero, later notes will played louder.")
	, TTF_IPORT(7, "randspeed", "Randomize Acceleration", 0.0, 1.0,  0.0,
			rdfs:comment "Amount of randomization to apply to the accel/decel setting. A Value of 1.0 means to add a random-number of the full-range (-1..1) to the given value.")
	, TTF_IPORT(8, "randvelocity", "Randomize Velocity", 0.0, 1.0,  0.0,
			rdfs:comment "Amount of randomization to apply to the acceleation value. A value of 1.0 means to add a random-number of the full-range (-112..112) to the given value.")
	; rdfs:comment """A midi arpeggio effect intended to simulate strumming a stringed instrument (e.g. guitar). A chord is 'collected' and the single notes of the chord are played back spread out over time. The 'Note Collect Timeout' allows for the effect to be played live with midi-keyboard, it compensates for a human not pressing keys at the same point in time. If the effect is used with a sequencer that can send chords with all note-on at the exactly time, it should be set to zero."""
	.

#elif defined MX_CODE

#define MAX_STRUM_CHORDNOTES (12)

static void
filter_cleanup_midistrum(MidiFilter* self)
{
	free(self->memQ);
	free(self->memS);
}

static void
filter_midistrum_enqueue(MidiFilter* self, uint8_t const* buf, int size, int tme)
{
	const int max_delay = self->memI[0];
	const int roff = self->memI[1];
	const int woff = self->memI[2];

	if ((woff + 1) % max_delay == roff) {
		return; // queue full
	}

	MidiEventQueue* qm = &(self->memQ[roff]);

	for (int idx = woff; idx != roff;) {
		/* move existing (later) events forward in the queue */
		const int pidx = (idx > 0) ? (idx - 1) : (max_delay - 1);
		memcpy (&(self->memQ[idx]), &(self->memQ[pidx]), sizeof (MidiEventQueue));

		if (self->memQ[idx].size != 0 && self->memQ[idx].reltime <= tme) {
			qm = &(self->memQ[idx]);
			break;
		}
		idx = pidx;
	}

	memcpy(qm->buf, buf, size);
	qm->size = size;
	qm->reltime = tme;
	self->memI[2] = (self->memI[2] + 1) % max_delay;
}

static void
filter_midistrum_process(MidiFilter* self, int tme)
{
	int i;
	const int max_collect = 1 + rintf(self->samplerate * (*self->cfg[3]) / 1000.0);
	if (self->memI[5] == 0) return; // no notes collected

	if (MSC_DIFF(self->memI[3], self->memI[4]) + tme < 0) {
		/* collection time not over */
		if (self->memI[5] < MAX_STRUM_CHORDNOTES) {
			/* buffer is not full, either */
			return;
		}
	}

	float bpm = (*self->cfg[1]);
	if (*self->cfg[0] && (self->available_info & NFO_BPM)) {
		bpm = self->bpm;
	}
	if (bpm <= 0) bpm = 60;
	const int strum_time = floor(self->samplerate * (*self->cfg[4]) * 60.0 / bpm);

	int dir = 0; // 0: down (low notes first), 1: up (high-notes first)
	switch ((int) floorf(*self->cfg[2])) {
		case 0: // always down
			break;
		case 1: // always up
			dir = 1;
			break;
		case 2: // alternate
			dir = (self->memI[6]) ? 1 : 0;
			break;
		case 3: // depending on beat.. 1,2,3,4 down ;; 1+,2+,3+,4+ up
			if ((self->available_info & NFO_BEAT)) {
				const double samples_per_beat = 60.0 / self->bpm * self->samplerate;
				if (ROUND_PARTIAL_BEATS(self->beat_beats + ((tme - max_collect) / samples_per_beat), 12.0) >= 0.5) {
					dir = 1;
				}
			}
			break;
		case 4: // depending on 8th
			if ((self->available_info & NFO_BEAT)) {
				const double samples_per_beat = 60.0 / self->bpm * self->samplerate;
				const float pos = ROUND_PARTIAL_BEATS(self->beat_beats + ((tme - max_collect) / samples_per_beat), 16.0) * 2.0;
				if ( pos - floorf(pos) >= 0.5) {
					dir = 1;
				}
			}
			break;
	}
	self->memI[6] = !dir;

	int reltime = MSC_DIFF(self->memI[4], self->memI[3]);
	int tdiff = strum_time / self->memI[5];

	float spdcfg = -(*self->cfg[5]);
	float velcfg = (*self->cfg[6]) / -112.0;

	spdcfg +=  (*self->cfg[7]) * (2.0 * random() / (float)RAND_MAX - 1.0);
	velcfg +=  (*self->cfg[8]) * (2.0 * random() / (float)RAND_MAX - 1.0);

	spdcfg = RAIL(spdcfg, -1.0, 1.0);

	const float veladj = RAIL(velcfg, -1.0, 1.0);
	const float spdadj = fabsf(spdcfg);
	const int   spddir = spdcfg < 0 ? 1 : 0;

	/* sort notes by strum direction.. */
	for (i=0; i < self->memI[5]; ++i) {
		int nextup = -1;
		int ii;
		for (ii=0; ii < self->memI[5]; ++ii) {
			if (self->memS[ii].size == 0) continue;
			if (nextup < 0) { nextup = ii; continue;}
			if (dir) {
				if (self->memS[nextup].buf[1] < self->memS[ii].buf[1] ) nextup = ii;
			} else {
				if (self->memS[nextup].buf[1] > self->memS[ii].buf[1] ) nextup = ii;
			}
		}

		if ((self->memI[2] + 1) % self->memI[0] == self->memI[1]) { break; }

		/* velocity adjustment */
		int vel = self->memS[nextup].buf[2] & 0x7f;
		const float p0 = (float)(i+1.0) / (float)(self->memI[5] + 1.0);

		vel -= fabsf(veladj) * 56.0;
		if (veladj < 0)
			vel += fabsf(veladj) * 112.0 * p0;
		else
			vel += fabsf(veladj) * 112.0 * (1.0 - p0);
		self->memS[nextup].buf[2] = RAIL(vel, 1, 127);

		/* speed adjustment */
		const float p1 = (float)(i+1.0) / (float)(self->memI[5]);
		float sfact = pow(spdadj+1.0, p1) - spdadj;
		if (spddir) {
			sfact = sfact ==0 ? 0 : 1.0 / sqrt(sfact);
		}

		filter_midistrum_enqueue (self, self->memS[nextup].buf, self->memS[nextup].size,
				reltime + rint((float)(tdiff * i) * sfact));

		self->memS[nextup].size = 0; // mark as processed
	}

	self->memI[5] = 0;
}

static inline void filter_midistrum_panic(MidiFilter* self, const uint8_t c, const uint32_t tme) {
	int i,k;
	const int max_delay = self->memI[0];
	for (i=0; i < max_delay; ++i) {
		if (self->memQ[i].size == 3
				&& (self->memQ[i].buf[0] & 0xf0) != 0xf0
				&& (self->memQ[i].buf[0] & 0x0f) != c)
			continue;
		self->memQ[i].size = 0;
	}

	self->memI[4] = 0; // collection stattime
	self->memI[5] = 0; // collected notes
	self->memI[6] = 0; // stroke direction

	for (k=0; k < 127; ++k) {
		if (self->memCS[c][k]) {
			uint8_t buf[3];
			buf[0] = MIDI_NOTEOFF | c;
			buf[1] = k; buf[2] = 0;
			forge_midimessage(self, tme, buf, 3);
		}
		self->memCS[c][k] = 0; // count note-on per key
	}
}

void
filter_midi_midistrum(MidiFilter* self,
		const uint32_t tme,
		const uint8_t* const buffer,
		const uint32_t size)
{
	uint8_t mst = buffer[0] & 0xf0;

	if (size > 3) {
		/* This may result in out-of-order messages (!)
		 *
		 * However messages > 3 bytes (sysex) are not commonly sent to softsynths.
		 * Furthermore, LV2 requires normalized MIDI (no running status),
		 * so this should be safe.
		 */
		forge_midimessage(self, tme, buffer, size);
		return;
	}

	if (midi_is_panic(buffer, size)) {
		filter_midistrum_panic(self, buffer[0]&0x0f, tme);
	}

	if (size != 3 || !(mst == MIDI_NOTEON || mst == MIDI_NOTEOFF)) {
		filter_midistrum_enqueue (self, buffer, size, tme);
		return;
	}

	float bpm = (*self->cfg[1]);
	if (*self->cfg[0] && (self->available_info & NFO_BPM)) {
		bpm = self->bpm;
	}
	if (bpm <= 0) bpm = 60;

	const int strum_time = floor(self->samplerate * (*self->cfg[4]) * 60.0 / bpm);
	const int max_collect = 1 + rintf(self->samplerate * (*self->cfg[3]) / 1000.0);

	const uint8_t key = buffer[1] & 0x7f;
	const uint8_t vel = buffer[2] & 0x7f;

	if (mst == MIDI_NOTEON && vel ==0 ) {
		mst = MIDI_NOTEOFF;
	}

	// check if we're overdue -> process collected notes, reset collection mode
	filter_midistrum_process(self, tme);

	/* add note-ons to collection */
	if (mst == MIDI_NOTEON) {
		int i;
		if (self->memI[5] == 0) {
			self->memI[4] = (tme + max_collect + self->memI[3]) % MSC_MAX;
		}
#if 0
		if ((self->available_info & NFO_BEAT)) {
			const double samples_per_beat = 60.0 / self->bpm * self->samplerate;
			printf("NOTE ON: %ld, %f  || %f\n",
					self->pos_frame + tme,
					self->bar_beats + (float)tme / samples_per_beat,
					self->beat_beats + (float)tme / samples_per_beat);
		}
#endif

		// check if note-on for this key is already queued -> skip
		for (i=0; i < self->memI[5]; ++i) {
			if (self->memS[i].size == 3 && self->memS[i].buf[2] == key) {
				return;
			}
		}

		MidiEventQueue *qm = &(self->memS[self->memI[5]]);
		memcpy(qm->buf, buffer, size);
		qm->size = size;
		self->memI[5]++;
	}

	/* delay note-off by max-latency (= collection-time + strum-time) */
	else if (mst == MIDI_NOTEOFF) {
#if 0 // TODO -- shorten delay time IF possible
		int delay = strum_time + 1;
		if (self->memI[5] > 0) {
			delay += 1 + MSC_DIFF(self->memI[4], (self->memI[3] + tme)%MSC_MAX);
			printf("add.. %d\n" , MSC_DIFF(self->memI[4], (self->memI[3] + tme)%MSC_MAX));
		}
#else
		const int delay = strum_time + max_collect;
#endif
		// TODO filter out ignored dups from (ignored note-on) above
		filter_midistrum_enqueue(self, buffer, size, tme + delay);
	}
}

static void
filter_preproc_midistrum(MidiFilter* self)
{
	self->latency = 1 + rint(self->samplerate * (*self->cfg[3]) / 1000.0);
}

static void
filter_postproc_midistrum(MidiFilter* self)
{
	const int max_delay = self->memI[0];
	const int roff = self->memI[1];
	const int woff = self->memI[2];
	const uint32_t n_samples = self->n_samples;
	int skipped = 0;

	filter_midistrum_process(self, n_samples);

	for (int i = 0; i < max_delay; ++i) {
		const int off = (i + roff) % max_delay;

		if (off == woff) {
			if (!skipped) { self->memI[1] = off; }
			break;
		}

		if (self->memQ[off].size == 0) {
			if (!skipped) { self->memI[1] = off; }
			continue;
		}

		if (self->memQ[off].reltime >= n_samples) {
			self->memQ[off].reltime -= n_samples;
			skipped = 1;
			continue;
		}

		assert (!skipped);

		if (self->memQ[off].size == 3 && (self->memQ[off].buf[0] & 0xf0) == MIDI_NOTEON) {
			const uint8_t chn = self->memQ[off].buf[0] & 0x0f;
			const uint8_t key = self->memQ[off].buf[1] & 0x7f;
			self->memCS[chn][key]++;
			if (self->memCS[chn][key] > 1) { // send a note-off first
				uint8_t buf[3];
				buf[0] = MIDI_NOTEOFF | chn;
				buf[1] = key; buf[2] = 0;
				forge_midimessage(self, self->memQ[off].reltime, buf, 3);
			}
			forge_midimessage(self, self->memQ[off].reltime, self->memQ[off].buf, self->memQ[off].size);
		}
		else if (self->memQ[off].size == 3 && (self->memQ[off].buf[0] & 0xf0) == MIDI_NOTEOFF) {
			const uint8_t chn = self->memQ[off].buf[0] & 0x0f;
			const uint8_t key = self->memQ[off].buf[1] & 0x7f;
			if (self->memCS[chn][key] > 0) {
				self->memCS[chn][key]--;
				if (self->memCS[chn][key] == 0) {
					forge_midimessage(self, self->memQ[off].reltime, self->memQ[off].buf, self->memQ[off].size);
				}
			}
		} else {
			forge_midimessage(self, self->memQ[off].reltime, self->memQ[off].buf, self->memQ[off].size);
		}

		self->memQ[off].size = 0;
		self->memI[1] = off;
	}

	self->memI[3] = (self->memI[3] + n_samples)%MSC_MAX;
}

void filter_init_midistrum(MidiFilter* self) {
	int c,k;
	srandom ((unsigned int) time (NULL));

	self->memI[0] = MAX(self->samplerate / 16.0, 16);
	self->memI[1] = 0; // read-pointer
	self->memI[2] = 0; // write-pointer
	self->memQ = calloc(self->memI[0], sizeof(MidiEventQueue));
	self->memS = calloc(MAX_STRUM_CHORDNOTES, sizeof(MidiEventQueue));

	self->memI[3] = 0; // monotonic time
	self->memI[4] = 0; // collection stattime
	self->memI[5] = 0; // collected notes
	self->memI[6] = 0; // stroke direction

	self->preproc_fn = filter_preproc_midistrum;
	self->postproc_fn = filter_postproc_midistrum;
	self->cleanup_fn = filter_cleanup_midistrum;

	for (c=0; c < 16; ++c) for (k=0; k < 127; ++k) {
		self->memCS[c][k] = 0; // count note-on per key
	}
}

#endif