midizap/midizap.c

1928 lines
56 KiB
C

/*
Copyright 2013 Eric Messick (FixedImagePhoto.com/Contact)
Copyright 2018 Albert Graef <aggraef@gmail.com>
Based on a version (c) 2006 Trammell Hudson <hudson@osresearch.net>
which was in turn
Based heavily on code by Arendt David <admin@prnet.org>
*/
#include "midizap.h"
#include "jackdriver.h"
typedef struct input_event EV;
Display *display;
JACK_SEQ seq;
int jack_num_outputs = 0, debug_jack = 0;
int auto_feedback = 1;
int passthrough[2] = {-1, -1}, system_passthrough[2] = {-1, -1};
int shift = 0;
void
initdisplay(void)
{
int event, error, major, minor;
display = XOpenDisplay(0);
if (!display) {
fprintf(stderr, "unable to open X display\n");
exit(1);
}
if (!XTestQueryExtension(display, &event, &error, &major, &minor)) {
fprintf(stderr, "Xtest extensions not supported\n");
XCloseDisplay(display);
exit(1);
}
}
void
send_button(unsigned int button, int press)
{
XTestFakeButtonEvent(display, button, press ? True : False, DELAY);
}
void
send_key(KeySym key, int press)
{
KeyCode keycode;
if (key >= XK_Button_1 && key <= XK_Scroll_Down) {
send_button((unsigned int)key - XK_Button_0, press);
return;
}
keycode = XKeysymToKeycode(display, key);
XTestFakeKeyEvent(display, keycode, press ? True : False, DELAY);
}
// cached controller and pitch bend values
static int16_t notevalue[2][16][128];
static int16_t ccvalue[2][16][128];
static int16_t kpvalue[2][16][128];
static int16_t cpvalue[2][16];
static int16_t pbvalue[2][16] =
{{8192, 8192, 8192, 8192, 8192, 8192, 8192, 8192,
8192, 8192, 8192, 8192, 8192, 8192, 8192, 8192},
{8192, 8192, 8192, 8192, 8192, 8192, 8192, 8192,
8192, 8192, 8192, 8192, 8192, 8192, 8192, 8192}};
static int dataval(int val, int min, int max)
{
if (!val || val > max)
return max;
else if (val < min)
return min;
else
return val;
}
static int datavals(int val, int step, int *steps, int n_steps)
{
if (val < 0)
return -datavals(-val, step, steps, n_steps);
else if (val < n_steps)
return steps[val];
else if (n_steps)
return steps[n_steps-1];
else if (step)
return step*val;
else
return val;
}
void
handle_event(uint8_t *msg, uint8_t portno, int depth, int recursive);
void
send_midi(uint8_t portno, stroke *s, int index, int dir,
int mod, int mod_step, int mod_n_steps, int *mod_steps,
int val, int depth, uint8_t ret_msg[3])
{
int status = s->status, data = s->data, swap = s->swap,
recursive = s->recursive;
int step = s->step, n_steps = s->n_steps, *steps = s->steps;
if (!recursive && !jack_num_outputs) return; // MIDI output not enabled
uint8_t msg[3];
int chan = status & 0x0f;
msg[0] = status;
msg[1] = data;
switch (status & 0xf0) {
case 0x90:
if (dir) {
// increment (dir==1) or decrement (dir==-1) the current value,
// clamping it to the 0..127 data byte range
if (!step) step = 1;
dir *= step;
if (dir > 0) {
if (notevalue[portno][chan][data] >= 127) return;
notevalue[portno][chan][data] += dir;
if (notevalue[portno][chan][data] > 127) notevalue[portno][chan][data] = 127;
} else {
if (notevalue[portno][chan][data] == 0) return;
notevalue[portno][chan][data] += dir;
if (notevalue[portno][chan][data] < 0) notevalue[portno][chan][data] = 0;
}
msg[2] = notevalue[portno][chan][data];
} else if (mod) {
int q = swap?val%mod:val/mod, r = swap?val/mod:val%mod;
int d = msg[1] + datavals(q, mod_step, mod_steps, mod_n_steps);
int v = datavals(r, step, steps, n_steps);
if (d > 127 || d < 0) return;
if (v > 127 || v < 0) return;
if (s->change) {
if (s->change > 1 && s->d == d && s->v == v) return; // unchanged value
s->d = d; s->v = v; s->change = 2; // >1 => initialized
}
msg[1] = d;
msg[2] = v;
} else if (!index) {
msg[2] = dataval(step, 0, 127);
} else {
msg[2] = 0;
}
break;
case 0xb0:
if (dir) {
if (s->incr) {
// incremental controller, simply spit out a relative sign bit value
if (!step) step = 1;
dir *= step;
if (dir < -63) dir = -63;
if (dir > 63) dir = 63;
msg[2] = dir>0?dir:dir<0?64-dir:0;
} else {
// increment (dir==1) or decrement (dir==-1) the current value,
// clamping it to the 0..127 data byte range
if (!step) step = 1;
dir *= step;
if (dir > 0) {
if (ccvalue[portno][chan][data] >= 127) return;
ccvalue[portno][chan][data] += dir;
if (ccvalue[portno][chan][data] > 127) ccvalue[portno][chan][data] = 127;
} else {
if (ccvalue[portno][chan][data] == 0) return;
ccvalue[portno][chan][data] += dir;
if (ccvalue[portno][chan][data] < 0) ccvalue[portno][chan][data] = 0;
}
msg[2] = ccvalue[portno][chan][data];
}
} else if (mod) {
int m = (data>=128)*128;
int q = swap?val%mod:val/mod, r = swap?val/mod:val%mod;
int d = msg[1] + datavals(q, mod_step, mod_steps, mod_n_steps);
int v = datavals(r, step, steps, n_steps);
if (d-m > 127 || d-m < 0) return;
if (v > 127 || v < 0) return;
if (s->change) {
if (s->change > 1 && s->d == d && s->v == v) return; // unchanged value
s->d = d; s->v = v; s->change = 2; // >1 => initialized
}
msg[1] = d;
msg[2] = v;
} else if (!index) {
msg[2] = dataval(step, 0, 127);
} else {
msg[2] = 0;
}
break;
case 0xa0:
if (dir) {
// increment (dir==1) or decrement (dir==-1) the current value,
// clamping it to the 0..127 data byte range
if (!step) step = 1;
dir *= step;
if (dir > 0) {
if (kpvalue[portno][chan][data] >= 127) return;
kpvalue[portno][chan][data] += dir;
if (kpvalue[portno][chan][data] > 127) kpvalue[portno][chan][data] = 127;
} else {
if (kpvalue[portno][chan][data] == 0) return;
kpvalue[portno][chan][data] += dir;
if (kpvalue[portno][chan][data] < 0) kpvalue[portno][chan][data] = 0;
}
msg[2] = kpvalue[portno][chan][data];
} else if (mod) {
int q = swap?val%mod:val/mod, r = swap?val/mod:val%mod;
int d = msg[1] + datavals(q, mod_step, mod_steps, mod_n_steps);
int v = datavals(r, step, steps, n_steps);
if (d > 127 || d < 0) return;
if (v > 127 || v < 0) return;
if (s->change) {
if (s->change > 1 && s->d == d && s->v == v) return; // unchanged value
s->d = d; s->v = v; s->change = 2; // >1 => initialized
}
msg[1] = d;
msg[2] = v;
} else if (!index) {
msg[2] = dataval(step, 0, 127);
} else {
msg[2] = 0;
}
break;
case 0xd0:
if (dir) {
// increment (dir==1) or decrement (dir==-1) the current value,
// clamping it to the 0..127 data byte range
if (!step) step = 1;
dir *= step;
if (dir > 0) {
if (cpvalue[portno][chan] >= 127) return;
cpvalue[portno][chan] += dir;
if (cpvalue[portno][chan] > 127) cpvalue[portno][chan] = 127;
} else {
if (cpvalue[portno][chan] == 0) return;
cpvalue[portno][chan] += dir;
if (cpvalue[portno][chan] < 0) cpvalue[portno][chan] = 0;
}
msg[1] = cpvalue[portno][chan];
} else if (mod) {
int v = datavals(swap?val/mod:val%mod, step, steps, n_steps);
if (v > 127 || v < 0) return;
if (s->change) {
if (s->change > 1 && s->v == v) return; // unchanged value
s->v = v; s->change = 2; // >1 => initialized
}
msg[1] = v;
} else if (!index) {
msg[1] = dataval(step, 0, 127);
} else {
msg[1] = 0;
}
break;
case 0xe0: {
// pitch bends are treated similarly to a controller, but with a 14 bit
// range (0..16383, with 8192 being the center value)
int pbval = 0;
if (dir) {
if (!step) step = 1;
dir *= step;
if (dir > 0) {
if (pbvalue[portno][chan] >= 16383) return;
pbvalue[portno][chan] += dir;
if (pbvalue[portno][chan] > 16383) pbvalue[portno][chan] = 16383;
} else {
if (pbvalue[portno][chan] == 0) return;
pbvalue[portno][chan] += dir;
if (pbvalue[portno][chan] < 0) pbvalue[portno][chan] = 0;
}
pbval = pbvalue[portno][chan];
} else if (mod) {
int v = datavals(swap?val/mod:val%mod, step, steps, n_steps);
if (v > 16383 || v < 0) return;
if (s->change) {
if (s->change > 1 && s->v == v) return; // unchanged value
s->v = v; s->change = 2; // >1 => initialized
}
pbval = v;
} else if (!index) {
pbval = 8192+dataval(step, -8192, 8191);
} else {
// we use 8192 (center) as the "home" (a.k.a. "off") value, so the pitch
// will only bend up, never down below the center value
pbval = 8192;
}
// the result is a 14 bit value which gets encoded as a combination of two
// 7 bit values which become the data bytes of the message
msg[1] = pbval & 0x7f; // LSB (lower 7 bits)
msg[2] = pbval >> 7; // MSB (upper 7 bits)
break;
}
case 0xc0:
if (mod) {
int d = msg[1] + datavals(swap?val%mod:val/mod, mod_step, mod_steps, mod_n_steps);
if (d > 127 || d < 0) return;
if (s->change) {
if (s->change > 1 && s->d == d) return; // unchanged value
s->d = d; s->change = 2; // >1 => initialized
}
msg[1] = d;
}
// just send the message
break;
default:
return;
}
if (ret_msg) memcpy(ret_msg, msg, 3);
if (recursive) {
// As these values may be mutated, we need to save and restore them, in
// case a macro calls itself recursively.
uint8_t change = s->change;
int d = s->d, v = s->v;
s->change = change>0;
handle_event(msg, portno, depth+1, recursive);
s->change = change;
s->d = d; s->v = v;
} else
queue_midi(&seq, msg, portno);
}
static int stroke_data_cmp(const void *a, const void *b)
{
const stroke_data *ad = (const stroke_data*)a;
const stroke_data *bd = (const stroke_data*)b;
if (ad->chan == bd->chan)
return ad->data - bd->data;
else
return ad->chan - bd->chan;
}
static stroke *find_stroke_data(stroke_data *sd,
int chan, int data, int index,
int *step, int *n_steps, int **steps,
int *incr, int *mod,
uint16_t n)
{
if (n < 16) {
// Linear search is presumably faster for small arrays, and we also avoid
// function calls for doing the comparisons here. Not sure where it breaks
// even with glibc's bsearch(), though (TODO: measure).
uint16_t i;
for (i = 0; i < n; i++) {
if (sd[i].chan == chan && sd[i].data == data) {
if (step) *step = sd[i].step[index];
if (n_steps) *n_steps = sd[i].n_steps[index];
if (steps) *steps = sd[i].steps[index];
if (incr) *incr = sd[i].is_incr;
if (mod) *mod = sd[i].mod;
return sd[i].s[index];
} else if (sd[i].chan > chan ||
(sd[i].chan == chan && sd[i].data > data)) {
return NULL;
}
}
return NULL;
} else {
// binary search from libc
stroke_data *ret, key;
key.chan = chan; key.data = data;
ret = bsearch(&key, sd, n, sizeof(stroke_data), stroke_data_cmp);
if (ret) {
if (step) *step = ret->step[index];
if (n_steps) *n_steps = ret->n_steps[index];
if (steps) *steps = ret->steps[index];
if (incr) *incr = ret->is_incr;
if (mod) *mod = ret->mod;
return ret->s[index];
} else
return NULL;
}
}
static stroke *find_note(translation *tr, int shift,
int chan, int data, int index, int *mod,
int *step, int *n_steps, int **steps)
{
return find_stroke_data(tr->note[shift], chan, data, index,
step, n_steps, steps, 0, mod,
tr->n_note[shift]);
}
static stroke *find_notes(translation *tr, int shift,
int chan, int data, int index, int *step)
{
return find_stroke_data(tr->notes[shift], chan, data, index, step,
0, 0, 0, 0,
tr->n_notes[shift]);
}
static stroke *find_pc(translation *tr, int shift,
int chan, int data, int index)
{
return find_stroke_data(tr->pc[shift], chan, data, index, 0, 0, 0, 0, 0,
tr->n_pc[shift]);
}
static stroke *find_cc(translation *tr, int shift,
int chan, int data, int index, int *mod,
int *step, int *n_steps, int **steps)
{
return find_stroke_data(tr->cc[shift], chan, data, index,
step, n_steps, steps, 0, mod,
tr->n_cc[shift]);
}
static stroke *find_ccs(translation *tr, int shift,
int chan, int data, int index, int *step, int *incr)
{
return find_stroke_data(tr->ccs[shift], chan, data, index, step, 0, 0,
incr, 0,
tr->n_ccs[shift]);
}
static stroke *find_kp(translation *tr, int shift,
int chan, int data, int index, int *mod,
int *step, int *n_steps, int **steps)
{
return find_stroke_data(tr->kp[shift], chan, data, index,
step, n_steps, steps, 0, mod,
tr->n_kp[shift]);
}
static stroke *find_kps(translation *tr, int shift,
int chan, int data, int index, int *step)
{
return find_stroke_data(tr->kps[shift], chan, data, index, step,
0, 0, 0, 0,
tr->n_kps[shift]);
}
static stroke *find_cp(translation *tr, int shift,
int chan, int index, int *mod,
int *step, int *n_steps, int **steps)
{
return find_stroke_data(tr->cp[shift], chan, 0, index,
step, n_steps, steps, 0, mod,
tr->n_cp[shift]);
}
static stroke *find_cps(translation *tr, int shift,
int chan, int index, int *step)
{
return find_stroke_data(tr->cps[shift], chan, 0, index, step,
0, 0, 0, 0,
tr->n_cps[shift]);
}
static stroke *find_pb(translation *tr, int shift,
int chan, int index, int *mod,
int *step, int *n_steps, int **steps)
{
return find_stroke_data(tr->pb[shift], chan, 0, index,
step, n_steps, steps, 0, mod,
tr->n_pb[shift]);
}
static stroke *find_pbs(translation *tr, int shift,
int chan, int index, int *step)
{
return find_stroke_data(tr->pbs[shift], chan, 0, index, step, 0, 0, 0, 0,
tr->n_pbs[shift]);
}
stroke *
fetch_stroke(translation *tr, uint8_t portno, int status, int chan, int data,
int index, int dir, int *step, int *n_steps, int **steps,
int *incr, int *mod)
{
if (tr && tr->portno == portno) {
switch (status) {
case 0x90:
if (dir)
return find_notes(tr, shift, chan, data, dir>0, step);
else
return find_note(tr, shift, chan, data, index, mod, step, n_steps, steps);
case 0xc0:
return find_pc(tr, shift, chan, data, index);
case 0xb0:
if (dir)
return find_ccs(tr, shift, chan, data, dir>0, step, incr);
else
return find_cc(tr, shift, chan, data, index, mod, step, n_steps, steps);
case 0xa0:
if (dir)
return find_kps(tr, shift, chan, data, dir>0, step);
else
return find_kp(tr, shift, chan, data, index, mod, step, n_steps, steps);
case 0xd0:
if (dir)
return find_cps(tr, shift, chan, dir>0, step);
else
return find_cp(tr, shift, chan, index, mod, step, n_steps, steps);
case 0xe0:
if (dir)
return find_pbs(tr, shift, chan, dir>0, step);
else
return find_pb(tr, shift, chan, index, mod, step, n_steps, steps);
default:
return NULL;
}
} else
return NULL;
}
#define MAX_WINNAME_SIZE 1024
static char last_window_name[MAX_WINNAME_SIZE];
static char last_window_class[MAX_WINNAME_SIZE];
static Window last_focused_window = 0;
static translation *last_window_translation = NULL, *last_translation = NULL;
static int last_window = 0;
void reload_callback(void)
{
last_focused_window = 0;
last_window_translation = last_translation = NULL;
last_window = 0;
}
static void debug_section(translation *tr)
{
// we do some caching of the last printed translation here, so that we don't
// print the same message twice
if (debug_regex && (!last_window || tr != last_translation)) {
last_translation = tr;
last_window = 1;
if (tr) {
printf("translation: %s for %s (class %s)\n",
tr->name, last_window_name, last_window_class);
} else {
printf("no translation found for %s (class %s)\n",
last_window_name, last_window_class);
}
}
}
static char *note_name(int n)
{
static char *note_names[] = { "C", "C#", "D", "Eb", "E", "F", "F#", "G", "G#", "A", "Bb", "B" };
if (n < 0 && n%12)
return note_names[12+n%12];
else
return note_names[n%12];
}
static int note_octave(int n)
{
if (n < 0 && n%12)
return n/12-1 + midi_octave;
else
return n/12 + midi_octave;
}
static char *debug_key(translation *tr, char *name,
int status, int chan, int data, int dir)
{
char prefix[10] = "";
if (shift) sprintf(prefix, "%d^", shift);
char *suffix = "";
strcpy(name, "??");
switch (status) {
case 0x90: {
int mod = 0, step, n_steps, *steps;
if (tr) {
if (dir) {
step = 1;
(void)find_notes(tr, shift, chan, data, dir>0, &step);
} else
(void)find_note(tr, shift, chan, data, 0, &mod, &step, &n_steps, &steps);
}
if (dir)
suffix = (dir<0)?"-":"+";
else
suffix = "";
if (dir && step != 1)
sprintf(name, "%s%s%d[%d]-%d%s", prefix, note_name(data),
note_octave(data), step, chan+1, suffix);
else if (!dir && mod)
if (step != 1)
sprintf(name, "%s%s%d[%d][%d]-%d%s", prefix, note_name(data),
note_octave(data), mod, step, chan+1, suffix);
else if (n_steps) {
sprintf(name, "%s%s%d[%d]{", prefix, note_name(data),
note_octave(data), mod);
int l = strlen(name);
for (int i = 0; i < n_steps; i++, (l = strlen(name)))
sprintf(name+l, "%s%d", i?",":"", steps[i]);
sprintf(name+l, "}-%d%s", chan+1, suffix);
} else
sprintf(name, "%s%s%d[%d]-%d%s", prefix, note_name(data),
note_octave(data), mod, chan+1, suffix);
else
sprintf(name, "%s%s%d-%d%s", prefix, note_name(data),
note_octave(data), chan+1, suffix);
break;
}
case 0xa0: {
int step = 0, n_steps = 0, *steps = 0, mod = 0;
if (tr) {
if (dir) {
step = 1;
(void)find_kps(tr, shift, chan, data, dir>0, &step);
} else
(void)find_kp(tr, shift, chan, data, 0, &mod, &step, &n_steps, &steps);
}
if (dir)
suffix = (dir<0)?"-":"+";
else
suffix = "";
if (dir && step != 1)
sprintf(name, "%sKP:%s%d[%d]-%d%s", prefix, note_name(data),
note_octave(data), step, chan+1, suffix);
else if (!dir && mod)
if (step != 1)
sprintf(name, "%sKP:%s%d[%d][%d]-%d%s", prefix, note_name(data),
note_octave(data), mod, step, chan+1, suffix);
else if (n_steps) {
sprintf(name, "%sKP:%s%d[%d]{", prefix, note_name(data),
note_octave(data), mod);
int l = strlen(name);
for (int i = 0; i < n_steps; i++, (l = strlen(name)))
sprintf(name+l, "%s%d", i?",":"", steps[i]);
sprintf(name+l, "}-%d%s", chan+1, suffix);
} else
sprintf(name, "%sKP:%s%d[%d]-%d%s", prefix, note_name(data),
note_octave(data), mod, chan+1, suffix);
else
sprintf(name, "%sKP:%s%d-%d%s", prefix, note_name(data),
note_octave(data), chan+1, suffix);
break;
}
case 0xb0: {
int step = 0, n_steps = 0, *steps = 0, mod = 0, is_incr = 0;
if (tr) {
if (dir) {
step = 1;
(void)find_ccs(tr, shift, chan, data, dir>0, &step, &is_incr);
} else
(void)find_cc(tr, shift, chan, data, 0, &mod, &step, &n_steps, &steps);
}
if (is_incr)
suffix = (dir<0)?"<":">";
else if (dir)
suffix = (dir<0)?"-":"+";
else
suffix = "";
// check for pseudo CC messages denoting a macro
char *tok = data>=128?"M":"CC";
data %= 128;
if (dir && step != 1)
sprintf(name, "%s%s%d[%d]-%d%s", prefix, tok, data, step, chan+1, suffix);
else if (!dir && mod)
if (step != 1)
sprintf(name, "%s%s%d[%d][%d]-%d%s", prefix, tok, data, mod, step, chan+1, suffix);
else if (n_steps) {
sprintf(name, "%s%s%d[%d]{", prefix, tok, data, mod);
int l = strlen(name);
for (int i = 0; i < n_steps; i++, (l = strlen(name)))
sprintf(name+l, "%s%d", i?",":"", steps[i]);
sprintf(name+l, "}-%d%s", chan+1, suffix);
} else
sprintf(name, "%s%s%d[%d]-%d%s", prefix, tok, data, mod, chan+1, suffix);
else
sprintf(name, "%s%s%d-%d%s", prefix, tok, data, chan+1, suffix);
break;
}
case 0xc0:
sprintf(name, "%sPC%d-%d", prefix, data, chan+1);
break;
case 0xd0: {
int step = 0, n_steps = 0, *steps = 0, mod = 0;
if (tr) {
if (dir) {
step = 1;
(void)find_cps(tr, shift, chan, dir>0, &step);
} else
(void)find_cp(tr, shift, chan, 0, &mod, &step, &n_steps, &steps);
}
if (!dir)
suffix = "";
else
suffix = (dir<0)?"-":"+";
if (dir && step != 1)
sprintf(name, "%sCP[%d]-%d%s", prefix, step, chan+1, suffix);
else if (!dir && mod)
if (step != 1)
sprintf(name, "%sCP[%d][%d]-%d", prefix, mod, step, chan+1);
else if (n_steps) {
sprintf(name, "%sCP[%d]{", prefix, mod);
int l = strlen(name);
for (int i = 0; i < n_steps; i++, (l = strlen(name)))
sprintf(name+l, "%s%d", i?",":"", steps[i]);
sprintf(name+l, "}-%d", chan);
} else
sprintf(name, "%sCP[%d]-%d", prefix, mod, chan+1);
else
sprintf(name, "%sCP-%d%s", prefix, chan+1, suffix);
break;
}
case 0xe0: {
int step = 1;
if (tr) (void)find_pbs(tr, shift, chan, dir>0, &step);
if (!dir)
suffix = "";
else
suffix = (dir<0)?"-":"+";
if (dir && step != 1)
sprintf(name, "%sPB[%d]-%d%s", prefix, step, chan+1, suffix);
else
sprintf(name, "%sPB-%d%s", prefix, chan+1, suffix);
break;
}
default: // this can't happen
break;
}
return name;
}
static void debug_input(int portno,
int status, int chan, int data, int data2)
{
char name[100];
if (status == 0xe0)
// translate LSB,MSB to a pitch bend value in the range -8192..8191
data2 = ((data2 << 7) | data) - 8192;
else if (status == 0xd0)
data2 = data;
if (status == 0xc0)
printf("[%d] %s\n", portno,
debug_key(0, name, status, chan, data, 0));
else if (status != 0xf0) // system messages ignored for now
printf("[%d] %s value = %d\n", portno,
debug_key(0, name, status, chan, data, 0), data2);
}
// Some machinery to handle the debugging of section matches. This is
// necessary since some inputs may generate a lot of calls to send_strokes()
// without ever actually matching any output sequence at all. In such cases we
// want to prevent a cascade of useless debugging messages by handling the
// message printing in a lazy manner.
static int debug_state = 0, debug_count = 0;
static translation *debug_tr = NULL;
static void start_debug()
{
// start a debugging section
debug_state = debug_regex;
debug_tr = NULL;
debug_count = 0;
}
static void end_debug()
{
// end a debugging section; if we still haven't matched an output sequence,
// but processed any input at all, we print the last matched translation
// section now anyway
if (debug_state && debug_count) debug_section(debug_tr);
debug_state = 0;
}
// maximum recursion depth
#define MAX_DEPTH 32
// shift feedback
uint8_t shift_fb[N_SHIFTS][3];
static int toggle_msg(uint8_t msg[3])
{
if (msg[0] < 0x80) return 0;
switch (msg[0]&0xf0) {
case 0xc0:
return 0;
case 0xd0:
msg[1] = 0;
break;
case 0xe0:
msg[1] = 0x40;
msg[2] = 0;
break;
default:
msg[2] = 0;
break;
}
return 1;
}
int
check_strokes(translation *tr, uint8_t portno, int status, int chan, int data)
{
for (int i = 0; i < 2; i++)
if (fetch_stroke(tr, portno, status, chan, data, i, 0, 0,0,0,0,0) ||
fetch_stroke(tr, portno, status, chan, data, 0, i?1:-1, 0,0,0,0,0))
return 1;
if (jack_num_outputs) {
// fall back to default MIDI translation
tr = default_midi_translation[portno];
for (int i = 0; i < 2; i++)
if (fetch_stroke(tr, portno, status, chan, data, i, 0, 0,0,0,0,0) ||
fetch_stroke(tr, portno, status, chan, data, 0, i?1:-1, 0,0,0,0,0))
return 1;
// Ignore all MIDI input on the second port if no translation was found in
// the [MIDI2] section (or the section is missing altogether).
if (portno) return 0;
}
// fall back to the default translation
tr = default_translation;
for (int i = 0; i < 2; i++)
if (fetch_stroke(tr, portno, status, chan, data, i, 0, 0,0,0,0,0) ||
fetch_stroke(tr, portno, status, chan, data, 0, i?1:-1, 0,0,0,0,0))
return 1;
return 0;
}
void
send_strokes(translation *tr, uint8_t portno, int status, int chan,
int data, int data2, int index, int dir, int depth)
{
int nkeys = 0, step = 0, n_steps = 0, *steps = 0, is_incr = 0, mod = 0;
stroke *s = fetch_stroke(tr, portno, status, chan, data, index, dir,
&step, &n_steps, &steps, &is_incr, &mod);
// If there's no press/release translation, check whether we have got at
// least the corresponding release/press translation, in order to prevent
// spurious error messages if either the press or release translation just
// happens to be empty.
int chk = s ||
(!dir && fetch_stroke(tr, portno, status, chan, data, !index, dir, 0, 0, 0, 0, 0));
if (!s && jack_num_outputs) {
// fall back to default MIDI translation
tr = default_midi_translation[portno];
s = fetch_stroke(tr, portno, status, chan, data, index, dir,
&step, &n_steps, &steps, &is_incr, &mod);
chk = chk || s ||
(!dir && fetch_stroke(tr, portno, status, chan, data, !index, dir, 0, 0, 0, 0, 0));
// Ignore all MIDI input on the second port if no translation was found in
// the [MIDI2] section (or the section is missing altogether).
if (portno && !s) return;
}
if (!s) {
// fall back to the default translation
tr = default_translation;
s = fetch_stroke(tr, portno, status, chan, data, index, dir,
&step, &n_steps, &steps, &is_incr, &mod);
chk = chk || s ||
(!dir && fetch_stroke(tr, portno, status, chan, data, !index, dir, 0, 0, 0, 0, 0));
}
if (debug_regex) {
if (s) {
// found a sequence, print the matching section now
debug_section(tr);
debug_state = 0;
} else if (!chk) {
// No matches yet. To prevent a cascade of spurious messages, we defer
// printing the matched section for now and just record it instead; it
// may then be printed later.
debug_tr = tr;
// record that we actually tried to process some input
debug_count = 1;
}
}
if (s && debug_keys) {
char name[100];
print_stroke_sequence(debug_key(tr, name, status, chan, data, dir),
(dir||mod)?"":index?"U":"D", s,
mod, step, n_steps, steps, data2);
}
while (s) {
if (s->keysym) {
send_key(s->keysym, s->press);
nkeys++;
} else if (s->shift) {
// toggle shift status
if (shift != s->shift) {
if (shift) {
// reset current shift feedback
if (toggle_msg(shift_fb[shift-1]))
queue_midi(&seq, shift_fb[shift-1], 1);
memset(shift_fb[shift-1], 0, 3);
}
shift = s->shift;
} else
shift = 0;
} else if (!s->status) {
// do nothing (NOP)
;
} else {
if (s->recursive && depth >= MAX_DEPTH) {
char name[100];
if (tr && tr->name)
fprintf(stderr, "Error: [%s]$%s: recursion too deep\n",
tr->name, debug_key(tr, name, status, chan, data, dir));
else
fprintf(stderr, "Error: $%s: recursion too deep\n",
debug_key(tr, name, status, chan, data, dir));
} else if (s->feedback) {
if (!s->recursive && jack_num_outputs > 1) {
if (s->feedback == 1)
// direct feedback, simply flip the port number
send_midi(!portno, s, index, dir, mod,
step, n_steps, steps, data2, depth, 0);
else if (portno == 0 && !mod && !dir)
// shift feedback, this only works with key translations right
// now, and portno *must* be zero
send_midi(1, s, !shift, 0, 0,
step, n_steps, steps, data2, depth,
shift?shift_fb[shift-1]:0);
}
} else {
send_midi(portno, s, index, dir, mod,
step, n_steps, steps, data2, depth, 0);
}
}
s = s->next;
}
// no need to flush the display if we didn't send any keys
if (nkeys) {
XFlush(display);
}
}
char *
get_window_name(Window win)
{
Atom prop = XInternAtom(display, "WM_NAME", False);
Atom type;
int form;
unsigned long remain, len;
unsigned char *list;
if (XGetWindowProperty(display, win, prop, 0, 1024, False,
AnyPropertyType, &type, &form, &len, &remain,
&list) != Success) {
fprintf(stderr, "XGetWindowProperty failed for window 0x%x\n", (int)win);
return NULL;
}
return (char*)list;
}
char *
get_window_class(Window win)
{
Atom prop = XInternAtom(display, "WM_CLASS", False);
Atom type;
int form;
unsigned long remain, len;
unsigned char *list;
if (XGetWindowProperty(display, win, prop, 0, 1024, False,
AnyPropertyType, &type, &form, &len, &remain,
&list) != Success) {
fprintf(stderr, "XGetWindowProperty failed for window 0x%x\n", (int)win);
return NULL;
}
return (char*)list;
}
char *
walk_window_tree(Window win, char **window_class)
{
char *window_name;
Window root = 0;
Window parent;
Window *children;
unsigned int nchildren;
while (win != root) {
window_name = get_window_name(win);
if (window_name != NULL) {
*window_class = get_window_class(win);
return window_name;
}
if (XQueryTree(display, win, &root, &parent, &children, &nchildren)) {
win = parent;
XFree(children);
} else {
fprintf(stderr, "XQueryTree failed for window 0x%x\n", (int)win);
return NULL;
}
}
return NULL;
}
translation *
get_focused_window_translation()
{
Window focus;
int revert_to;
char *window_name = NULL, *window_class = NULL;
XGetInputFocus(display, &focus, &revert_to);
if (focus != last_focused_window) {
last_window = 0;
last_focused_window = focus;
window_name = walk_window_tree(focus, &window_class);
last_window_translation = get_translation(window_name, window_class);
if (window_name && *window_name) {
strncpy(last_window_name, window_name, MAX_WINNAME_SIZE);
last_window_name[MAX_WINNAME_SIZE-1] = 0;
} else {
strcpy(last_window_name, "Unnamed");;
}
if (window_class && *window_class) {
strncpy(last_window_class, window_class, MAX_WINNAME_SIZE);
last_window_class[MAX_WINNAME_SIZE-1] = 0;
} else {
strcpy(last_window_name, "Unnamed");;
}
if (window_name != NULL) {
XFree(window_name);
}
if (window_class != NULL) {
XFree(window_class);
}
}
return last_window_translation;
}
static int8_t innotevalue[2][16][128];
static int8_t inccvalue[2][16][128];
static int8_t inkpvalue[2][16][128];
static int8_t incpvalue[2][16];
static int16_t inpbvalue[2][16] =
{{8192, 8192, 8192, 8192, 8192, 8192, 8192, 8192,
8192, 8192, 8192, 8192, 8192, 8192, 8192, 8192},
{8192, 8192, 8192, 8192, 8192, 8192, 8192, 8192,
8192, 8192, 8192, 8192, 8192, 8192, 8192, 8192}};
// If this option is enabled (-k on the command line), we make sure that each
// "key" (note, cc, pb) is "off" before we allow it to go "on" again. This is
// useful to eliminate double note-ons and the like, but interferes with the
// way some controllers work, so it is disabled by default.
static int keydown_tracker = 0;
static uint8_t innotedown[2][16][128];
static uint8_t inccdown[2][16][128];
static uint8_t inpbdown[2][16];
static uint8_t inkpdown[2][16][128];
static uint8_t incpdown[2][16];
int
check_notes(translation *tr, uint8_t portno, int chan, int data)
{
if (tr && tr->portno == portno &&
(find_notes(tr, shift, chan, data, 0, 0) ||
find_notes(tr, shift, chan, data, 1, 0)))
return 1;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
(find_notes(tr, shift, chan, data, 0, 0) ||
find_notes(tr, shift, chan, data, 1, 0)))
return 1;
tr = default_translation;
if (tr && tr->portno == portno &&
(find_notes(tr, shift, chan, data, 0, 0) ||
find_notes(tr, shift, chan, data, 1, 0)))
return 1;
return 0;
}
int
get_note_step(translation *tr, uint8_t portno, int chan, int data, int dir)
{
int step;
if (tr && tr->portno == portno &&
find_notes(tr, shift, chan, data, dir>0, &step))
return step;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
find_notes(tr, shift, chan, data, dir>0, &step))
return step;
tr = default_translation;
if (tr && tr->portno == portno &&
find_notes(tr, shift, chan, data, dir>0, &step))
return step;
return 1;
}
int
get_note_mod(translation *tr, uint8_t portno, int chan, int data)
{
int mod;
if (tr && tr->portno == portno &&
find_note(tr, shift, chan, data, 0, &mod, 0, 0, 0))
return mod;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
find_note(tr, shift, chan, data, 0, &mod, 0, 0, 0))
return mod;
tr = default_translation;
if (tr && tr->portno == portno &&
find_note(tr, shift, chan, data, 0, &mod, 0, 0, 0))
return mod;
return 0;
}
int
check_incr(translation *tr, uint8_t portno, int chan, int data)
{
int is_incr;
if (tr && tr->portno == portno &&
(find_ccs(tr, shift, chan, data, 0, 0, &is_incr) ||
find_ccs(tr, shift, chan, data, 1, 0, &is_incr)))
return is_incr;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
(find_ccs(tr, shift, chan, data, 0, 0, &is_incr) ||
find_ccs(tr, shift, chan, data, 1, 0, &is_incr)))
return is_incr;
tr = default_translation;
if (tr && tr->portno == portno &&
(find_ccs(tr, shift, chan, data, 0, 0, &is_incr) ||
find_ccs(tr, shift, chan, data, 1, 0, &is_incr)))
return is_incr;
return 0;
}
int
check_ccs(translation *tr, uint8_t portno, int chan, int data)
{
if (tr && tr->portno == portno &&
(find_ccs(tr, shift, chan, data, 0, 0, 0) ||
find_ccs(tr, shift, chan, data, 1, 0, 0)))
return 1;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
(find_ccs(tr, shift, chan, data, 0, 0, 0) ||
find_ccs(tr, shift, chan, data, 1, 0, 0)))
return 1;
tr = default_translation;
if (tr && tr->portno == portno &&
(find_ccs(tr, shift, chan, data, 0, 0, 0) ||
find_ccs(tr, shift, chan, data, 1, 0, 0)))
return 1;
return 0;
}
int
get_cc_step(translation *tr, uint8_t portno, int chan, int data, int dir)
{
int step;
if (tr && tr->portno == portno &&
find_ccs(tr, shift, chan, data, dir>0, &step, 0))
return step;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
find_ccs(tr, shift, chan, data, dir>0, &step, 0))
return step;
tr = default_translation;
if (tr && tr->portno == portno &&
find_ccs(tr, shift, chan, data, dir>0, &step, 0))
return step;
return 1;
}
int
get_cc_mod(translation *tr, uint8_t portno, int chan, int data)
{
int mod;
if (tr && tr->portno == portno &&
find_cc(tr, shift, chan, data, 0, &mod, 0, 0, 0))
return mod;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
find_cc(tr, shift, chan, data, 0, &mod, 0, 0, 0))
return mod;
tr = default_translation;
if (tr && tr->portno == portno &&
find_cc(tr, shift, chan, data, 0, &mod, 0, 0, 0))
return mod;
return 0;
}
int
check_kps(translation *tr, uint8_t portno, int chan, int data)
{
if (tr && tr->portno == portno &&
(find_kps(tr, shift, chan, data, 0, 0) ||
find_kps(tr, shift, chan, data, 1, 0)))
return 1;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
(find_kps(tr, shift, chan, data, 0, 0) ||
find_kps(tr, shift, chan, data, 1, 0)))
return 1;
tr = default_translation;
if (tr && tr->portno == portno &&
(find_kps(tr, shift, chan, data, 0, 0) ||
find_kps(tr, shift, chan, data, 1, 0)))
return 1;
return 0;
}
int
get_kp_step(translation *tr, uint8_t portno, int chan, int data, int dir)
{
int step;
if (tr && tr->portno == portno &&
find_kps(tr, shift, chan, data, dir>0, &step))
return step;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
find_kps(tr, shift, chan, data, dir>0, &step))
return step;
tr = default_translation;
if (tr && tr->portno == portno &&
find_kps(tr, shift, chan, data, dir>0, &step))
return step;
return 1;
}
int
get_kp_mod(translation *tr, uint8_t portno, int chan, int data)
{
int mod;
if (tr && tr->portno == portno &&
find_kp(tr, shift, chan, data, 0, &mod, 0, 0, 0))
return mod;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
find_kp(tr, shift, chan, data, 0, &mod, 0, 0, 0))
return mod;
tr = default_translation;
if (tr && tr->portno == portno &&
find_kp(tr, shift, chan, data, 0, &mod, 0, 0, 0))
return mod;
return 0;
}
int
check_cps(translation *tr, uint8_t portno, int chan)
{
if (tr && tr->portno == portno &&
(find_cps(tr, shift, chan, 0, 0) ||
find_cps(tr, shift, chan, 1, 0)))
return 1;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
(find_cps(tr, shift, chan, 0, 0) ||
find_cps(tr, shift, chan, 1, 0)))
return 1;
tr = default_translation;
if (tr && tr->portno == portno &&
(find_cps(tr, shift, chan, 0, 0) ||
find_cps(tr, shift, chan, 1, 0)))
return 1;
return 0;
}
int
get_cp_step(translation *tr, uint8_t portno, int chan, int dir)
{
int step;
if (tr && tr->portno == portno &&
find_cps(tr, shift, chan, dir>0, &step))
return step;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
find_cps(tr, shift, chan, dir>0, &step))
return step;
tr = default_translation;
if (tr && tr->portno == portno &&
find_cps(tr, shift, chan, dir>0, &step))
return step;
return 1;
}
int
get_cp_mod(translation *tr, uint8_t portno, int chan)
{
int mod;
if (tr && tr->portno == portno &&
find_cp(tr, shift, chan, 0, &mod, 0, 0, 0))
return mod;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
find_cp(tr, shift, chan, 0, &mod, 0, 0, 0))
return mod;
tr = default_translation;
if (tr && tr->portno == portno &&
find_cp(tr, shift, chan, 0, &mod, 0, 0, 0))
return mod;
return 0;
}
int
check_pbs(translation *tr, uint8_t portno, int chan)
{
if (tr && tr->portno == portno &&
(find_pbs(tr, shift, chan, 0, 0) ||
find_pbs(tr, shift, chan, 1, 0)))
return 1;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
(find_pbs(tr, shift, chan, 0, 0) ||
find_pbs(tr, shift, chan, 1, 0)))
return 1;
tr = default_translation;
if (tr && tr->portno == portno &&
(find_pbs(tr, shift, chan, 0, 0) ||
find_pbs(tr, shift, chan, 1, 0)))
return 1;
return 0;
}
int
get_pb_step(translation *tr, uint8_t portno, int chan, int dir)
{
int step;
if (tr && tr->portno == portno &&
find_pbs(tr, shift, chan, dir>0, &step))
return step;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
find_pbs(tr, shift, chan, dir>0, &step))
return step;
tr = default_translation;
if (tr && tr->portno == portno &&
find_pbs(tr, shift, chan, dir>0, &step))
return step;
return 1;
}
int
get_pb_mod(translation *tr, uint8_t portno, int chan)
{
int mod;
if (tr && tr->portno == portno &&
find_pb(tr, shift, chan, 0, &mod, 0, 0, 0))
return mod;
tr = default_midi_translation[portno];
if (tr && tr->portno == portno &&
find_pb(tr, shift, chan, 0, &mod, 0, 0, 0))
return mod;
tr = default_translation;
if (tr && tr->portno == portno &&
find_pb(tr, shift, chan, 0, &mod, 0, 0, 0))
return mod;
return 0;
}
static int
check_recursive(int status, int chan, int data, int recursive)
{
// only mod translations can be used in recursive calls
if (recursive) {
char name[100];
fprintf(stderr, "Warning: $%s: undefined macro\n",
debug_key(0, name, status, chan, data, 0));
}
return recursive;
}
void
handle_event(uint8_t *msg, uint8_t portno, int depth, int recursive)
{
translation *tr = get_focused_window_translation();
//fprintf(stderr, "midi [%d]: %0x %0x %0x\n", portno, msg[0], msg[1], msg[2]);
int status = msg[0] & 0xf0, chan = msg[0] & 0x0f;
if (status == 0x80) {
// convert proper note-off to note-on with vel. 0
status = 0x90;
msg[0] = status | chan;
msg[2] = 0;
}
if (debug_midi && depth == 0)
debug_input(portno, status, chan, msg[1], msg[2]);
if (passthrough[portno] &&
!check_strokes(tr, portno, status, chan, status>=0xd0?0:msg[1])) {
queue_midi(&seq, msg, portno);
return;
}
switch (status) {
case 0xc0:
start_debug();
if (check_recursive(status, chan, msg[1], recursive)) break;
send_strokes(tr, portno, status, chan, msg[1], 0, 0, 0, depth);
send_strokes(tr, portno, status, chan, msg[1], 0, 1, 0, depth);
end_debug();
break;
case 0xb0:
if (auto_feedback) ccvalue[!portno][chan][msg[1]] = msg[2];
start_debug();
if (get_cc_mod(tr, portno, chan, msg[1])) {
send_strokes(tr, portno, status, chan, msg[1], msg[2], 0, 0, depth);
end_debug();
break;
}
if (check_recursive(status, chan, msg[1], recursive)) break;
if (msg[2]) {
if (!keydown_tracker || !inccdown[portno][chan][msg[1]]) {
send_strokes(tr, portno, status, chan, msg[1], msg[2], 0, 0, depth);
inccdown[portno][chan][msg[1]] = 1;
}
} else {
if (!keydown_tracker || inccdown[portno][chan][msg[1]]) {
send_strokes(tr, portno, status, chan, msg[1], msg[2], 1, 0, depth);
inccdown[portno][chan][msg[1]] = 0;
}
}
if (check_incr(tr, portno, chan, msg[1])) {
debug_count = 0;
// Incremental controller a la MCU. NB: This assumes a signed bit
// representation (values above 0x40 indicate counter-clockwise
// rotation), which seems to be what most DAWs expect nowadays.
if (msg[2] < 64) {
int step = get_cc_step(tr, portno, chan, msg[1], -1);
if (step) {
int d = msg[2]/step;
while (d) {
send_strokes(tr, portno, status, chan, msg[1], 0, 0, 1, depth);
d--;
}
}
} else if (msg[2] > 64) {
int step = get_cc_step(tr, portno, chan, msg[1], -1);
if (step) {
int d = (msg[2]-64)/step;
while (d) {
send_strokes(tr, portno, status, chan, msg[1], 0, 0, -1, depth);
d--;
}
}
}
} else if (check_ccs(tr, portno, chan, msg[1]) &&
inccvalue[portno][chan][msg[1]] != msg[2]) {
debug_count = 0;
int dir = inccvalue[portno][chan][msg[1]] > msg[2] ? -1 : 1;
int step = get_cc_step(tr, portno, chan, msg[1], dir);
if (step) {
while (inccvalue[portno][chan][msg[1]] != msg[2]) {
int d = abs(inccvalue[portno][chan][msg[1]] - msg[2]);
if (d > step) d = step;
if (d < step) break;
send_strokes(tr, portno, status, chan, msg[1], 0, 0, dir, depth);
inccvalue[portno][chan][msg[1]] += dir*d;
}
}
}
end_debug();
break;
case 0x90:
if (auto_feedback) notevalue[!portno][chan][msg[1]] = msg[2];
start_debug();
if (get_note_mod(tr, portno, chan, msg[1])) {
send_strokes(tr, portno, status, chan, msg[1], msg[2], 0, 0, depth);
end_debug();
break;
}
if (check_recursive(status, chan, msg[1], recursive)) break;
if (msg[2]) {
if (!keydown_tracker || !innotedown[portno][chan][msg[1]]) {
send_strokes(tr, portno, status, chan, msg[1], msg[2], 0, 0, depth);
innotedown[portno][chan][msg[1]] = 1;
}
} else {
if (!keydown_tracker || innotedown[portno][chan][msg[1]]) {
send_strokes(tr, portno, status, chan, msg[1], msg[2], 1, 0, depth);
innotedown[portno][chan][msg[1]] = 0;
}
}
if (check_notes(tr, portno, chan, msg[1]) &&
innotevalue[portno][chan][msg[1]] != msg[2]) {
debug_count = 0;
int dir = innotevalue[portno][chan][msg[1]] > msg[2] ? -1 : 1;
int step = get_note_step(tr, portno, chan, msg[1], dir);
if (step) {
while (innotevalue[portno][chan][msg[1]] != msg[2]) {
int d = abs(innotevalue[portno][chan][msg[1]] - msg[2]);
if (d > step) d = step;
if (d < step) break;
send_strokes(tr, portno, status, chan, msg[1], 0, 0, dir, depth);
innotevalue[portno][chan][msg[1]] += dir*d;
}
}
}
end_debug();
break;
case 0xa0:
if (auto_feedback) kpvalue[!portno][chan][msg[1]] = msg[2];
start_debug();
if (get_kp_mod(tr, portno, chan, msg[1])) {
send_strokes(tr, portno, status, chan, msg[1], msg[2], 0, 0, depth);
end_debug();
break;
}
if (check_recursive(status, chan, msg[1], recursive)) break;
if (msg[2]) {
if (!keydown_tracker || !inkpdown[portno][chan][msg[1]]) {
send_strokes(tr, portno, status, chan, msg[1], msg[2], 0, 0, depth);
inkpdown[portno][chan][msg[1]] = 1;
}
} else {
if (!keydown_tracker || inkpdown[portno][chan][msg[1]]) {
send_strokes(tr, portno, status, chan, msg[1], msg[2], 1, 0, depth);
inkpdown[portno][chan][msg[1]] = 0;
}
}
if (check_kps(tr, portno, chan, msg[1]) &&
inkpvalue[portno][chan][msg[1]] != msg[2]) {
debug_count = 0;
int dir = inkpvalue[portno][chan][msg[1]] > msg[2] ? -1 : 1;
int step = get_kp_step(tr, portno, chan, msg[1], dir);
if (step) {
while (inkpvalue[portno][chan][msg[1]] != msg[2]) {
int d = abs(inkpvalue[portno][chan][msg[1]] - msg[2]);
if (d > step) d = step;
if (d < step) break;
send_strokes(tr, portno, status, chan, msg[1], 0, 0, dir, depth);
inkpvalue[portno][chan][msg[1]] += dir*d;
}
}
}
end_debug();
break;
case 0xd0:
if (auto_feedback) cpvalue[!portno][chan] = msg[1];
start_debug();
if (get_cp_mod(tr, portno, chan)) {
send_strokes(tr, portno, status, chan, 0, msg[1], 0, 0, depth);
end_debug();
break;
}
if (check_recursive(status, chan, msg[1], recursive)) break;
if (msg[1]) {
if (!keydown_tracker || !incpdown[portno][chan]) {
send_strokes(tr, portno, status, chan, 0, 0, 0, 0, depth);
incpdown[portno][chan] = 1;
}
} else {
if (!keydown_tracker || incpdown[portno][chan]) {
send_strokes(tr, portno, status, chan, 0, 0, 1, 0, depth);
incpdown[portno][chan] = 0;
}
}
if (check_cps(tr, portno, chan) &&
incpvalue[portno][chan] != msg[1]) {
debug_count = 0;
int dir = incpvalue[portno][chan] > msg[1] ? -1 : 1;
int step = get_cp_step(tr, portno, chan, dir);
if (step) {
while (incpvalue[portno][chan] != msg[1]) {
int d = abs(incpvalue[portno][chan] - msg[1]);
if (d > step) d = step;
if (d < step) break;
send_strokes(tr, portno, status, chan, 0, 0, 0, dir, depth);
incpvalue[portno][chan] += dir*d;
}
}
}
end_debug();
break;
case 0xe0: {
int bend = ((msg[2] << 7) | msg[1]) - 8192;
if (auto_feedback) pbvalue[!portno][chan] = bend+8192;
start_debug();
if (get_pb_mod(tr, portno, chan)) {
send_strokes(tr, portno, status, chan, 0, bend+8192, 0, 0, depth);
end_debug();
break;
}
if (check_recursive(status, chan, msg[1], recursive)) break;
if (bend) {
if (!keydown_tracker || !inpbdown[portno][chan]) {
send_strokes(tr, portno, status, chan, 0, 0, 0, 0, depth);
inpbdown[portno][chan] = 1;
}
} else {
if (!keydown_tracker || inpbdown[portno][chan]) {
send_strokes(tr, portno, status, chan, 0, 0, 1, 0, depth);
inpbdown[portno][chan] = 0;
}
}
if (check_pbs(tr, portno, chan) && inpbvalue[portno][chan] - 8192 != bend) {
debug_count = 0;
int dir = inpbvalue[portno][chan] - 8192 > bend ? -1 : 1;
int step = get_pb_step(tr, portno, chan, dir);
if (step) {
while (inpbvalue[portno][chan] - 8192 != bend) {
int d = abs(inpbvalue[portno][chan] - 8192 - bend);
if (d > step) d = step;
if (d < step) break;
send_strokes(tr, portno, status, chan, 0, 0, 0, dir, depth);
inpbvalue[portno][chan] += dir*d;
}
}
}
end_debug();
break;
}
default:
// ignore everything else for now, specifically system messages
break;
}
}
void help(char *progname)
{
fprintf(stderr, "Usage: %s [-hkn] [-d[rskmj]] [-ost[n]] [-j name] [-P[prio]] [[-r] rcfile]\n", progname);
fprintf(stderr, "-h print this message\n");
fprintf(stderr, "-d debug (r = regex, s = strokes, k = keys, m = midi, j = jack; default: all)\n");
fprintf(stderr, "-j jack client name (default: midizap)\n");
fprintf(stderr, "-k keep track of key status (ignore double on/off messages)\n");
fprintf(stderr, "-n no automatic feedback from the second port (-o2)\n");
fprintf(stderr, "-o set number of MIDI output ports (n = 0-2, default: 1)\n");
fprintf(stderr, "-P set real-time priority (default: 90)\n");
fprintf(stderr, "-r config file name (default: MIDIZAP_CONFIG_FILE variable or ~/.midizaprc)\n");
fprintf(stderr, "-s pass-through of system messages (n = 0-2; default: all ports)\n");
fprintf(stderr, "-t pass-through of untranslated messages (n = 0-2; default: all ports)\n");
}
uint8_t quit = 0;
void quitter()
{
quit = 1;
}
// Helper functions to process the command line, so that we can pass it to
// Jack session management.
static char *command_line;
static size_t len;
static void add_command(char *arg, int sep)
{
char *a = arg;
// Do some simplistic quoting if the argument contains blanks. This won't do
// the right thing if the argument also contains quotes. Oh well.
if ((strchr(a, ' ') || strchr(a, '\t')) && !strchr(a, '"')) {
a = malloc(strlen(arg)+3);
sprintf(a, "\"%s\"", arg);
}
if (!command_line) {
len = strlen(a);
command_line = malloc(len+1);
strcpy(command_line, a);
} else {
size_t l = strlen(a)+sep;
command_line = realloc(command_line, len+l+1);
if (sep) command_line[len] = ' ';
strcpy(command_line+len+sep, a);
len += l;
}
if (a != arg) free(a);
}
static char *absolute_path(char *name)
{
if (*name == '/') {
return name;
} else {
// This is a relative pathname, we turn it into a canonicalized absolute
// path. NOTE: This requires glibc. We should probably rewrite this code
// to be more portable.
char *pwd = getcwd(NULL, 0);
if (!pwd) {
perror("getcwd");
return name;
} else {
char *path = malloc(strlen(pwd)+strlen(name)+2);
static char abspath[PATH_MAX];
sprintf(path, "%s/%s", pwd, name);
if (!realpath(path, abspath)) strcpy(abspath, path);
free(path); free(pwd);
return abspath;
}
}
}
// poll interval in microsec (this shouldn't be too large to avoid jitter)
#define POLL_INTERVAL 1000
#include <time.h>
#include <pthread.h>
int
main(int argc, char **argv)
{
uint8_t msg[3];
int opt, prio = 0;
// Start recording the command line to be passed to Jack session management.
add_command(argv[0], 0);
while ((opt = getopt(argc, argv, "hkno::d::j:r:P::s::t::")) != -1) {
switch (opt) {
case 'h':
help(argv[0]);
exit(0);
case 'k':
keydown_tracker = 1;
add_command("-k", 1);
break;
case 'n':
auto_feedback = 0;
add_command("-n", 1);
break;
case 'o':
jack_num_outputs = 1;
if (optarg && *optarg) {
const char *a = optarg;
if (!strcmp(a, "2")) {
jack_num_outputs = 2;
add_command("-o2", 1);
} else if (!strcmp(a, "1")) {
add_command("-o1", 1);
} else if (!strcmp(a, "0")) {
jack_num_outputs = -1; // override config setting
add_command("-o0", 1);
} else {
fprintf(stderr, "%s: wrong port number (-o), must be 0, 1 or 2\n", argv[0]);
fprintf(stderr, "Try -h for help.\n");
exit(1);
}
} else
add_command("-o", 1);
break;
case 'd':
if (optarg && *optarg) {
const char *a = optarg;
add_command("-d", 1);
add_command(optarg, 0);
while (*a) {
switch (*a) {
case 'r':
default_debug_regex = 1;
break;
case 's':
default_debug_strokes = 1;
break;
case 'k':
default_debug_keys = 1;
break;
case 'm':
default_debug_midi = 1;
break;
case 'j':
debug_jack = 1;
break;
default:
fprintf(stderr, "%s: unknown debugging option (-d), must be r, s, k or j\n", argv[0]);
fprintf(stderr, "Try -h for help.\n");
exit(1);
}
++a;
}
} else {
default_debug_regex = default_debug_strokes = default_debug_keys =
default_debug_midi = 1;
debug_jack = 1;
add_command("-d", 1);
}
break;
case 'j':
jack_client_name = optarg;
add_command("-j", 1);
add_command(optarg, 1);
break;
case 'r':
config_file_name = optarg;
add_command("-r", 1);
// We need to convert this to an absolute pathname for Jack session
// management.
add_command(absolute_path(optarg), 1);
break;
case 'P':
prio = (optarg&&*optarg)?atoi(optarg):90;
if (prio > 0) {
add_command("-P", 1);
if (optarg&&*optarg) add_command(optarg, 0);
} else {
fprintf(stderr, "%s: invalid real-time priority (-P), must be a positive integer\n", argv[0]);
fprintf(stderr, "Try -h for help.\n");
exit(1);
}
break;
case 's':
if (optarg && *optarg) {
const char *a = optarg;
if (!strcmp(a, "2")) {
system_passthrough[0] = 0;
system_passthrough[1] = 1;
add_command("-s2", 1);
} else if (!strcmp(a, "1")) {
system_passthrough[0] = 1;
system_passthrough[1] = 0;
add_command("-s1", 1);
} else if (!strcmp(a, "0")) {
system_passthrough[0] = system_passthrough[1] = 0;
add_command("-s0", 1);
} else {
fprintf(stderr, "%s: wrong port number (-s), must be 0, 1 or 2\n", argv[0]);
fprintf(stderr, "Try -h for help.\n");
exit(1);
}
} else {
system_passthrough[0] = system_passthrough[1] = 1;
add_command("-s", 1);
}
break;
case 't':
if (optarg && *optarg) {
const char *a = optarg;
if (!strcmp(a, "2")) {
passthrough[0] = 0;
passthrough[1] = 1;
add_command("-t2", 1);
} else if (!strcmp(a, "1")) {
passthrough[0] = 1;
passthrough[1] = 0;
add_command("-t1", 1);
} else if (!strcmp(a, "0")) {
passthrough[0] = passthrough[1] = 0;
add_command("-t0", 1);
} else {
fprintf(stderr, "%s: wrong port number (-t), must be 0, 1 or 2\n", argv[0]);
fprintf(stderr, "Try -h for help.\n");
exit(1);
}
} else {
passthrough[0] = passthrough[1] = 1;
add_command("-t", 1);
}
break;
default:
fprintf(stderr, "Try -h for help.\n");
exit(1);
}
}
if (optind+1 < argc) {
help(argv[0]);
exit(1);
}
if (optind < argc) {
config_file_name = argv[optind];
add_command(absolute_path(argv[optind]), 1);
}
if (command_line) jack_command_line = command_line;
initdisplay();
// Force the config file to be loaded initially, so that we pick up the Jack
// client name and number of output ports (if not set from the command
// line). This cannot be changed later, so if you want to make changes to
// the client name or number of ports take effect, you need to restart the
// program.
read_config_file();
seq.client_name = jack_client_name;
seq.n_in = jack_num_outputs>1?jack_num_outputs:1;
seq.n_out = jack_num_outputs>0?jack_num_outputs:0;
seq.passthrough[0] = jack_num_outputs>0?system_passthrough[0]>0:0;
seq.passthrough[1] = jack_num_outputs>1?system_passthrough[1]>0:0;
seq.in[0] = jack_in_regex[0];
seq.in[1] = jack_num_outputs>1?jack_in_regex[1]:0;
seq.out[0] = jack_num_outputs>0?jack_out_regex[0]:0;
seq.out[1] = jack_num_outputs>1?jack_out_regex[1]:0;
if (!init_jack(&seq, debug_jack)) {
exit(1);
}
passthrough[0] = jack_num_outputs>0?passthrough[0]>0:0;
passthrough[1] = jack_num_outputs>1?passthrough[1]>0:0;
// set real-time scheduling priority if requested
if (prio) {
int pol = SCHED_RR; // other options: SCHED_FIFO, SCHED_OTHER
struct sched_param param;
memset(&param, 0, sizeof(param));
param.sched_priority = prio;
if (pthread_setschedparam(pthread_self(), pol, &param))
perror("pthread_setschedparam");
}
int do_flush = debug_regex || debug_strokes || debug_keys || debug_midi ||
debug_jack;
signal(SIGINT, quitter);
time_t t0 = time(0);
while (!quit) {
uint8_t portno;
if (jack_quit) {
printf("[jack %s, exiting]\n",
(jack_quit>0)?"asked us to quit":"shutting down");
close_jack(&seq);
exit(0);
}
process_connections(&seq);
while (pop_midi(&seq, msg, &portno)) {
handle_event(msg, portno, 0, 0);
time_t t = time(0);
if (t > t0) {
// Check whether to reload the config file every sec.
if (read_config_file()) last_focused_window = 0;
t0 = t;
}
}
usleep(POLL_INTERVAL);
time_t t = time(0);
if (t > t0) {
// Check again when polling.
if (read_config_file()) last_focused_window = 0;
t0 = t;
}
// Make sure that debugging output gets flushed every once in a while (may
// be buffered when midizap is running inside a QjackCtl session).
if (do_flush) fflush(NULL);
}
printf(" [exiting]\n");
close_jack(&seq);
}