magpie.lua

-- Magpie
-- modulated note echo for
-- midi and cv
-- 
-- no keys or encoders
-- only signal and params

local Display = include('lib/display')
local Inputs = include('lib/inputs')
local Lfos = include('lib/lfos')
local Outputs = include('lib/outputs')
local Parameters = include('lib/parameters')
local Relayer = include('lib/relayer')

local display = nil
local emitters = nil
local inputs = nil
local lfos = nil
local midi_connections = nil
local midi_devices = nil
local observable = require('container.observable')
local outputs = nil
local parameters = nil
local relayer = nil
local shift = false

local function midi_panic()
  for note = 0, 127 do
    for ch = 1, 16 do
      for _, connection in pairs(midi_connections) do
        connection:note_off(note, 0, ch)
      end
    end
  end
end

local function init_display(emitters)
  display = Display:new()
  display:init(emitters)
end

local function init_emitters()
  emitters = {}
end

local function init_inputs()
  emitters.input = observable.new()
  inputs = Inputs:new()
  inputs:init(emitters.input, midi_connections)
end

local function init_lfos()
  lfos = Lfos:new()
  lfos:init()
end

local function init_midi()
  midi_connections, midi_devices = {}, {}

  for i = 1, #midi.vports do
    if midi.vports[i].name ~= 'none' then
      local device = midi.vports[i].device
      if device then 
        midi_devices[i] = {name = device.name, port = device.port}
        table.insert(midi_connections, midi.connect(device.port))
      end
    end
  end
end

local function init_outputs()
  emitters.output = observable.new()
  outputs = Outputs:new()
  outputs:init(emitters.output, midi_connections)
end

local function init_parameters()
  parameters = Parameters:new()
  parameters:init(lfos:get('list'), midi_devices, midi_panic)
end

local function init_relayer()
  relayer = Relayer:new()
end

local function init_subscribers()
  emitters.input:register('relayer_process', function(e)
    local message = e[1]
    local input_id = e[2]
    local lfo_state = lfos:poll(input_id)
    relayer:process(message, input_id, lfo_state, parameters:get('destinations'), outputs)
  end)
  emitters.output:register('output_test', function(message) test_message = message end)
end

function init()
  init_midi()
  init_emitters()
  init_inputs()
  init_lfos()
  init_outputs()
  init_parameters()
  init_relayer()
  init_subscribers()
  init_display(emitters)
end

function enc(e, d)
end

function key(k, z)
  if k == 1 then
    if z == 1 then
      shift = true
    else
      shift = false
    end
  end
end

function redraw()
  screen.clear()
  parameters:refresh(lfos)
  display:render()
  screen.update()
end

function refresh()
  redraw()
end