feat: remove keep alive, add check for conn state

Signed-off-by: 1998-felix <[email protected]>

coap/client.go

@@ -70,6 +70,10 @@ func (c *client) Token() string {
 }
 
 func (c *client) Handle(msg *messaging.Message) error {
+	if err := c.conn.Ping(c.conn.Context()); err != nil {
+		return nil
+	}
+
 	pm := c.conn.AcquireMessage(c.conn.Context())
 	defer c.conn.ReleaseMessage(pm)
 	pm.SetCode(codes.Content)

internal/server/coap/coap.go

@@ -12,8 +12,6 @@ import (
 	"github.com/absmach/magistrala/internal/server"
 	gocoap "github.com/plgd-dev/go-coap/v3"
 	"github.com/plgd-dev/go-coap/v3/mux"
-	"github.com/plgd-dev/go-coap/v3/options"
-	udpServer "github.com/plgd-dev/go-coap/v3/udp/server"
 )
 
 const (
@@ -42,27 +40,13 @@ func New(ctx context.Context, cancel context.CancelFunc, name string, config ser
 	}
 }
 
-type udpNilMonitor struct{}
-
-func (u *udpNilMonitor) UDPServerApply(cfg *udpServer.Config) {
-	cfg.CreateInactivityMonitor = nil
-}
-
-var _ udpServer.Option = (*udpNilMonitor)(nil)
-
-func NewUDPNilMonitor() udpServer.Option {
-	return &udpNilMonitor{}
-}
-
 func (s *Server) Start() error {
 	errCh := make(chan error)
 	s.Logger.Info(fmt.Sprintf("%s service started using http, exposed port %s", s.Name, s.Address))
 	s.Logger.Info(fmt.Sprintf("%s service %s server listening at %s without TLS", s.Name, s.Protocol, s.Address))
 
-	opts := []any{}
-	opts = append(opts, options.WithMux(s.handler), NewUDPNilMonitor())
 	go func() {
-		errCh <- gocoap.ListenAndServeWithOptions("udp", s.Address, opts...)
+		errCh <- gocoap.ListenAndServe("udp", s.Address, s.handler)
 	}()
 
 	select {