diff --git a/internal/module/http-client.go b/internal/module/http-client.go index bf5c7a9..9ef7d95 100644 --- a/internal/module/http-client.go +++ b/internal/module/http-client.go @@ -39,6 +39,7 @@ func (hc *HTTPClient) Type() string { } func (hc *HTTPClient) Run(ctx context.Context) error { + hc.logger.Debug("running") router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) if !ok { diff --git a/internal/module/http-server.go b/internal/module/http-server.go index 76ea8cb..ae1326a 100644 --- a/internal/module/http-server.go +++ b/internal/module/http-server.go @@ -148,6 +148,7 @@ func (hs *HTTPServer) ServeHTTP(w http.ResponseWriter, r *http.Request) { } func (hs *HTTPServer) Run(ctx context.Context) error { + hs.logger.Debug("running") router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) if !ok { diff --git a/internal/module/midi-input.go b/internal/module/midi-input.go index 24b2873..71e4c13 100644 --- a/internal/module/midi-input.go +++ b/internal/module/midi-input.go @@ -55,6 +55,7 @@ func (mi *MIDIInput) Type() string { } func (mi *MIDIInput) Run(ctx context.Context) error { + mi.logger.Debug("running") defer midi.CloseDriver() router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) diff --git a/internal/module/midi-output.go b/internal/module/midi-output.go index 70a1972..32563ca 100644 --- a/internal/module/midi-output.go +++ b/internal/module/midi-output.go @@ -56,6 +56,7 @@ func (mo *MIDIOutput) Type() string { } func (mo *MIDIOutput) Run(ctx context.Context) error { + mo.logger.Debug("running") defer midi.CloseDriver() router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) diff --git a/internal/module/mqtt-client.go b/internal/module/mqtt-client.go index 21caaa9..888fa3a 100644 --- a/internal/module/mqtt-client.go +++ b/internal/module/mqtt-client.go @@ -77,6 +77,7 @@ func (mc *MQTTClient) Type() string { } func (mc *MQTTClient) Run(ctx context.Context) error { + mc.logger.Debug("running") router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) if !ok { diff --git a/internal/module/nats-client.go b/internal/module/nats-client.go index 3f5f100..aa1eb6d 100644 --- a/internal/module/nats-client.go +++ b/internal/module/nats-client.go @@ -65,6 +65,7 @@ func (nc *NATSClient) Type() string { } func (nc *NATSClient) Run(ctx context.Context) error { + nc.logger.Debug("running") router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) if !ok { diff --git a/internal/module/psn-client.go b/internal/module/psn-client.go index 2255daa..d475f5e 100644 --- a/internal/module/psn-client.go +++ b/internal/module/psn-client.go @@ -42,6 +42,7 @@ func (pc *PSNClient) Type() string { } func (pc *PSNClient) Run(ctx context.Context) error { + pc.logger.Debug("running") router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) if !ok { diff --git a/internal/module/serial-client.go b/internal/module/serial-client.go index 50f8a11..8a0fe91 100644 --- a/internal/module/serial-client.go +++ b/internal/module/serial-client.go @@ -102,6 +102,7 @@ func (sc *SerialClient) SetupPort() error { } func (sc *SerialClient) Run(ctx context.Context) error { + sc.logger.Debug("running") router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) if !ok { diff --git a/internal/module/sip-call-server.go b/internal/module/sip-call-server.go index 0852b7d..ab78edc 100644 --- a/internal/module/sip-call-server.go +++ b/internal/module/sip-call-server.go @@ -113,6 +113,7 @@ func (scs *SIPCallServer) Type() string { } func (scs *SIPCallServer) Run(ctx context.Context) error { + scs.logger.Debug("running") router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) if !ok { diff --git a/internal/module/sip-dtmf-server.go b/internal/module/sip-dtmf-server.go index 4c332b6..8067cdf 100644 --- a/internal/module/sip-dtmf-server.go +++ b/internal/module/sip-dtmf-server.go @@ -115,6 +115,7 @@ func (sds *SIPDTMFServer) Type() string { } func (sds *SIPDTMFServer) Run(ctx context.Context) error { + sds.logger.Debug("running") router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) if !ok { diff --git a/internal/module/tcp-client.go b/internal/module/tcp-client.go index 8060d7a..9d6450f 100644 --- a/internal/module/tcp-client.go +++ b/internal/module/tcp-client.go @@ -88,7 +88,7 @@ func (tc *TCPClient) Type() string { } func (tc *TCPClient) Run(ctx context.Context) error { - + tc.logger.Debug("running") router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) if !ok { diff --git a/internal/module/tcp-server.go b/internal/module/tcp-server.go index fbeb90e..de4854d 100644 --- a/internal/module/tcp-server.go +++ b/internal/module/tcp-server.go @@ -169,7 +169,7 @@ ClientRead: } func (ts *TCPServer) Run(ctx context.Context) error { - + ts.logger.Debug("running") router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) if !ok { diff --git a/internal/module/time-interval.go b/internal/module/time-interval.go index 0c1c2a2..f62716c 100644 --- a/internal/module/time-interval.go +++ b/internal/module/time-interval.go @@ -50,7 +50,7 @@ func (i *TimeInterval) Type() string { } func (i *TimeInterval) Run(ctx context.Context) error { - + i.logger.Debug("running") router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) if !ok { diff --git a/internal/module/time-timer.go b/internal/module/time-timer.go index 1cc9539..45d5bf9 100644 --- a/internal/module/time-timer.go +++ b/internal/module/time-timer.go @@ -51,7 +51,7 @@ func (t *TimeTimer) Type() string { } func (t *TimeTimer) Run(ctx context.Context) error { - + t.logger.Debug("running") router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) if !ok { diff --git a/internal/module/udp-client.go b/internal/module/udp-client.go index b90a36d..10418f0 100644 --- a/internal/module/udp-client.go +++ b/internal/module/udp-client.go @@ -74,7 +74,7 @@ func (uc *UDPClient) SetupConn() error { } func (uc *UDPClient) Run(ctx context.Context) error { - + uc.logger.Debug("running") router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) if !ok { diff --git a/internal/module/udp-multicast.go b/internal/module/udp-multicast.go index 0c76853..327f166 100644 --- a/internal/module/udp-multicast.go +++ b/internal/module/udp-multicast.go @@ -68,7 +68,7 @@ func (um *UDPMulticast) Type() string { } func (um *UDPMulticast) Run(ctx context.Context) error { - + um.logger.Debug("running") router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) if !ok { diff --git a/internal/module/udp-server.go b/internal/module/udp-server.go index 82aebbe..56af415 100644 --- a/internal/module/udp-server.go +++ b/internal/module/udp-server.go @@ -82,7 +82,7 @@ func (us *UDPServer) Type() string { } func (us *UDPServer) Run(ctx context.Context) error { - + us.logger.Debug("running") router, ok := ctx.Value(route.RouterContextKey).(route.RouteIO) if !ok {