Remove github actions, this project requires alsa and other packages that are not standard.

Dockerfile

@@ -0,0 +1,16 @@
+FROM golang:1.20
+
+# Build app
+WORKDIR /app
+COPY go.mod go.sum ./
+RUN go mod download
+COPY *.go ./
+RUN go build -o /midi-request-trigger
+WORKDIR /app
+RUN rm -Rf /app; mkdir /etc/midi-request-trigger
+
+# Configuration volume
+VOLUME ["/etc/midi-request-trigger"]
+
+# Command
+CMD ["/midi-request-trigger"]

README.md

@@ -110,7 +110,7 @@ On MacOS, there is an IAC Driver that can be enabled in Audio MIDI Setup.
 midi_routers:
   - name: service_notifications
     device: IAC Driver Bus 1
-    log_level: 1
+    log_level: 2
 ```
 
 ### Example note trigger configuration
@@ -120,7 +120,7 @@ midi_routers:
 midi_routers:
   - name: service_notifications
     device: IAC Driver Bus 1
-    log_level: 1
+    log_level: 2
     note_triggers:
       - channel: 0
         note: 0
@@ -136,7 +136,7 @@ midi_routers:
 midi_routers:
   - name: service_notifications
     device: IAC Driver Bus 1
-    log_level: 1
+    log_level: 2
     request_triggers:
       - channel: 0
         note: 0
@@ -152,7 +152,7 @@ midi_routers:
 midi_routers:
   - name: service_notifications
     device: IAC Driver Bus 1
-    log_level: 2
+    log_level: 3
     note_triggers:
       - channel: 0
         note: 0
@@ -190,7 +190,7 @@ midi_routers:
         user: mqtt
         password: password
         topic: midi/behringer_wing
-      log_level: 3
+      log_level: 4
       note_triggers:
         - channel: 0
           note: 1
@@ -243,13 +243,16 @@ midi_routers:
         - channel: 0
           match_all_notes: true
           match_all_velocities: true
+          delay_before: 200ms
           mqtt_topic: osc/behringer_wing/send/$ctl/user/2/2/bu/val
           mqtt_payload:
             - "1"
         - channel: 0
           match_all_notes: true
           match_all_velocities: true
+          delay_before: 200ms
           mqtt_topic: osc/behringer_wing/send/$ctl/user/2/2/bu/val
           mqtt_payload:
             - "0"
+          delay_after: 200ms
 ```

main.go

@@ -15,7 +15,7 @@ import (
 const (
 	serviceName        = "midi-request-trigger"
 	serviceDescription = "Takes trigger MIDI messages by HTTP or MQTT requests and trigger HTTP or MQTT requests by MIDI messages"
-	serviceVersion     = "0.2.1"
+	serviceVersion     = "0.3"
 )
 
 // App is the global application structure for communicating between servers and storing information.

midiRouter.go

@@ -11,6 +11,7 @@ import (
 	"regexp"
 	"strconv"
 	"strings"
+	"time"
 
 	mqtt "github.com/eclipse/paho.mqtt.golang"
 	"gitlab.com/gomidi/midi/v2"
@@ -21,8 +22,10 @@ import (
 type LogLevel int
 
 const (
-	// Logs only errors.
-	ErrorLog LogLevel = iota
+	// Logs info messages.
+	InfoLog LogLevel = iota
+	// Log only errors.
+	ErrorLog
 	// MQTT, HTTP, and MIDI receive logging.
 	ReceiveLog
 	// MQTT, HTTP, and MIDI send logging.
@@ -33,7 +36,7 @@ const (
 
 // Provides a string value for a log level.
 func (l LogLevel) String() string {
-	return [...]string{"Error", "Receive", "Send", "Debug"}[l]
+	return [...]string{"Info", "Error", "Receive", "Send", "Debug"}[l]
 }
 
 // Configurations relating to MQTT connection.
@@ -82,6 +85,9 @@ type NoteTrigger struct {
 	Velocity uint8 `fig:"velocity"`
 	// If we should match all velocity values.
 	MatchAllVelocities bool `fig:"match_all_velocities"`
+	// Allow delaying the request.
+	DelayBefore time.Duration `fig:"delay_before"`
+	DelayAfter  time.Duration `fig:"deplay_after"`
 	// Custom MQTT message. Do not set to ignore MQTT.
 	MqttTopic string `fig:"mqtt_topic"`
 	// Nil payload will generate a payload with midi info.
@@ -134,10 +140,11 @@ type MidiRouter struct {
 	RequestTriggers []RequestTrigger `fig:"request_triggers"`
 
 	// How much logging.
-	// 0 - Errors
-	// 1 - MQTT, HTTP, and MIDI receive logging.
-	// 2 - MQTT, HTTP, and MIDI send logging.
-	// 3 - Debug
+	// 0 - Info
+	// 1 - Errors
+	// 2 - MQTT, HTTP, and MIDI receive logging.
+	// 3 - MQTT, HTTP, and MIDI send logging.
+	// 4 - Debug
 	LogLevel LogLevel `fig:"log_level"`
 
 	// Connection to MIDI device.
@@ -183,7 +190,12 @@ func (r *MidiRouter) sendRequest(channel, note, velocity uint8) {
 			// For all logging, we want to print the message so setup a common string to print.
 			logInfo := fmt.Sprintf("note %s(%d) on channel %v with velocity %v", midi.Note(note), note, channel, velocity)
 
+			// Delay before.
+			time.Sleep(trig.DelayBefore)
+
+			// If MQTT trigger, send the MQTT request.
 			if trig.MqttTopic != "" && r.MqttClient != nil {
+				// If payload provided, send the defined payload.
 				if trig.MqttPayload != nil {
 					data, err := json.Marshal(trig.MqttPayload)
 					if err != nil {
@@ -193,6 +205,7 @@ func (r *MidiRouter) sendRequest(channel, note, velocity uint8) {
 						r.Log(SendLog, "-> [MQTT] %s: %s", trig.MqttTopic, string(data))
 					}
 				} else {
+					// If no payload provided, send the note information as JSON.
 					payload := MQTTPayload{
 						Channel:  channel,
 						Note:     note,
@@ -208,6 +221,7 @@ func (r *MidiRouter) sendRequest(channel, note, velocity uint8) {
 				}
 			}
 
+			// If URL trigger defined, perform a HTTP request.
 			if trig.URL != "" {
 				// Default method to GET if nothing is defined.
 				if trig.Method == "" {
@@ -276,6 +290,9 @@ func (r *MidiRouter) sendRequest(channel, note, velocity uint8) {
 					r.Log(DebugLog, "Trigger response: %s\n%s", logInfo, string(body))
 				}
 			}
+
+			// Delay after.
+			time.Sleep(trig.DelayAfter)
 		}
 	}
 }
@@ -462,81 +479,105 @@ func (r *MidiRouter) MqttSubscribe(topic string) {
 func (r *MidiRouter) Connect() {
 	// If request triggers defined, find the out port.
 	if len(r.RequestTriggers) != 0 {
-		out, err := midi.FindOutPort(r.Device)
-		if err != nil {
-			log.Println("Can't find output device:", r.Device)
-		} else {
-			r.MidiOut = out
-		}
+		go func() {
+			for {
+				out, err := midi.FindOutPort(r.Device)
+				if err != nil {
+					r.Log(ErrorLog, "Can't find output device: %s", r.Device)
+				} else {
+					r.MidiOut = out
+					break
+				}
+
+				r.Log(ErrorLog, "Retrying in 1 minute.")
+				time.Sleep(time.Minute)
+			}
+		}()
 	}
+
 	// If listener is disabled, stop here.
-	if r.DisableListener {
-		return
+	if !r.DisableListener {
+		go func() {
+			for {
+				// Try finding input port.
+				r.Log(InfoLog, "Connecting to input device: %s", r.Device)
+				in, err := midi.FindInPort(r.Device)
+				if err != nil {
+					r.Log(ErrorLog, "Can't find input device: %s", r.Device)
+					r.Log(ErrorLog, "Retrying in 1 minute.")
+					time.Sleep(time.Minute)
+					continue
+				}
+
+				// Start listening to MIDI messages.
+				stop, err := midi.ListenTo(in, func(msg midi.Message, timestampms int32) {
+					var channel, note, velocity uint8
+					switch {
+					// Get notes with an velocity set.
+					case msg.GetNoteStart(&channel, &note, &velocity):
+						r.Log(ReceiveLog, "starting note %s(%d) on channel %v with velocity %v", midi.Note(note), note, channel, velocity)
+						// Process request.
+						r.sendRequest(channel, note, velocity)
+
+						// If no velocity is set, an note end message is received.
+					case msg.GetNoteEnd(&channel, &note):
+						r.Log(ReceiveLog, "ending note %s(%d) on channel %v", midi.Note(note), note, channel)
+						// Process request.
+						r.sendRequest(channel, note, 0)
+					default:
+						// ignore
+					}
+				})
+				if err != nil {
+					r.Log(ErrorLog, "Error listening to device: %s", err)
+					r.Log(ErrorLog, "Retrying in 1 minute.")
+					time.Sleep(time.Minute)
+					continue
+				}
+				r.Log(InfoLog, "Connected to input device: %s", r.Device)
+
+				// Update stop function for disconnects.
+				r.ListenerStop = stop
+				break
+			}
+		}()
 	}
 
-	// Try finding input port.
-	log.Println("Connecting to device:", r.Device)
-	in, err := midi.FindInPort(r.Device)
-	if err != nil {
-		log.Println("Can't find device:", r.Device)
-		return
-	}
-
-	// Start listening to MIDI messages.
-	stop, err := midi.ListenTo(in, func(msg midi.Message, timestampms int32) {
-		var channel, note, velocity uint8
-		switch {
-		// Get notes with an velocity set.
-		case msg.GetNoteStart(&channel, &note, &velocity):
-			r.Log(ReceiveLog, "starting note %s(%d) on channel %v with velocity %v", midi.Note(note), note, channel, velocity)
-			// Process request.
-			r.sendRequest(channel, note, velocity)
-
-		// If no velocity is set, an note end message is received.
-		case msg.GetNoteEnd(&channel, &note):
-			r.Log(ReceiveLog, "ending note %s(%d) on channel %v", midi.Note(note), note, channel)
-			// Process request.
-			r.sendRequest(channel, note, 0)
-		default:
-			// ignore
-		}
-	})
-	if err != nil {
-		r.Log(ErrorLog, "Error listening to device: %s", err)
-		return
-	}
-
-	// Update stop function for disconnects.
-	r.ListenerStop = stop
-
 	if r.MQTT.Host != "" && r.MQTT.Port != 0 {
-		// Connect to MQTT.
-		mqtt_opts := mqtt.NewClientOptions()
-		mqtt_opts.AddBroker(fmt.Sprintf("tcp://%s:%d", r.MQTT.Host, r.MQTT.Port))
-		mqtt_opts.SetClientID(r.MQTT.ClientId)
-		mqtt_opts.SetUsername(r.MQTT.User)
-		mqtt_opts.SetPassword(r.MQTT.Password)
-		r.MqttClient = mqtt.NewClient(mqtt_opts)
+		go func() {
+			for {
+				// Connect to MQTT.
+				mqtt_opts := mqtt.NewClientOptions()
+				mqtt_opts.AddBroker(fmt.Sprintf("tcp://%s:%d", r.MQTT.Host, r.MQTT.Port))
+				mqtt_opts.SetClientID(r.MQTT.ClientId)
+				mqtt_opts.SetUsername(r.MQTT.User)
+				mqtt_opts.SetPassword(r.MQTT.Password)
+				r.MqttClient = mqtt.NewClient(mqtt_opts)
 
-		// Connect and failures are fatal exiting service.
-		r.Log(DebugLog, "Connecting to MQTT")
-		if t := r.MqttClient.Connect(); t.Wait() && t.Error() != nil {
-			log.Fatalf("MQTT error: %s", t.Error())
-			return
-		}
+				// Connect and failures are fatal exiting service.
+				r.Log(DebugLog, "Connecting to MQTT")
+				if t := r.MqttClient.Connect(); t.Wait() && t.Error() != nil {
+					log.Fatalf("MQTT error: %s", t.Error())
+					r.Log(ErrorLog, "Retrying in 1 minute.")
+					time.Sleep(time.Minute)
+					continue
+				}
 
-		// Subscribe to MQTT topics.
-		r.MqttSubscribe(r.MQTT.Topic + "/send")
-		r.MqttSubscribe(r.MQTT.Topic + "/status/check")
-		// Subscribe to command topics configured.
-		for _, trig := range r.RequestTriggers {
-			if trig.MqttTopic != "" {
-				r.MqttSubscribe(trig.MqttTopic)
+				// Subscribe to MQTT topics.
+				r.MqttSubscribe(r.MQTT.Topic + "/send")
+				r.MqttSubscribe(r.MQTT.Topic + "/status/check")
+				// Subscribe to command topics configured.
+				for _, trig := range r.RequestTriggers {
+					if trig.MqttTopic != "" {
+						r.MqttSubscribe(trig.MqttTopic)
+					}
+					if trig.MqttSubTopic != "" {
+						r.MqttSubscribe(r.MQTT.Topic + "/" + trig.MqttSubTopic)
+					}
+				}
+				break
 			}
-			if trig.MqttSubTopic != "" {
-				r.MqttSubscribe(r.MQTT.Topic + "/" + trig.MqttSubTopic)
-			}
-		}
+		}()
 	}
 }
 
@@ -546,4 +587,5 @@ func (r *MidiRouter) Disconnect() {
 	if r.ListenerStop != nil {
 		r.ListenerStop()
 	}
+	r.MqttClient.Disconnect(0)
 }