somehow working state

cmd/main.go

@@ -5,7 +5,6 @@ import (
 	"os"
 	"os/signal"
 	"syscall"
-	"time"
 
 	"net/http"
 
@@ -28,33 +27,28 @@ func main() {
 	http.Handle("/metrics", promhttp.Handler())
 	go http.ListenAndServe(":8080", nil)
 
+	// Create a deadline to wait for
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+
 	// Start the SIP server
 	go func() {
-		if err := sipServer.Start(); err != nil {
+		if err := sipServer.Start(ctx); err != nil {
 			log.Fatal("Failed to start SIP server: " + err.Error())
 		}
 	}()
 
-	// Initialize and connect components
-	sipServer.mediaGateway.SetTranscodingService(sipServer.transcodingService)
-
-	// Start DTMF handler
-	sipServer.dtmfHandler.Start()
-
 	// Wait for interrupt signal to gracefully shutdown the server
 	quit := make(chan os.Signal, 1)
 	signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)
 	<-quit
 
 	log.Info("Shutting down server...")
-
-	// Create a deadline to wait for
-	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
-	defer cancel()
+	cancel()
 
 	// Doesn't block if no connections, but will otherwise wait
 	// until the timeout deadline.
-	if err := sipServer.Shutdown(ctx); err != nil {
+	if err := sipServer.Shutdown(); err != nil {
 		log.Error("Server forced to shutdown: " + err.Error())
 	}
 

config.go

@@ -0,0 +1,8 @@
+package sipnexus
+
+type Config struct {
+	server ServerConfig
+}
+
+type ServerConfig struct {
+}

dtmf.go

@@ -12,7 +12,6 @@ import (
 type DTMFHandler struct {
 	logger        logger.Logger
 	dtmfPayload   uint8
-	eventChan     chan string
 	eventHandlers map[string]func(string)
 	mu            sync.RWMutex
 }
@@ -21,20 +20,13 @@ func NewDTMFHandler(logger logger.Logger, dtmfPayload uint8) *DTMFHandler {
 	return &DTMFHandler{
 		logger:        logger,
 		dtmfPayload:   dtmfPayload,
-		eventChan:     make(chan string, 100),
 		eventHandlers: map[string]func(string){},
 	}
 }
 
-func (d *DTMFHandler) Start() {
-	go d.processEvents()
-}
-
-func (d *DTMFHandler) processEvents() {
-	for event := range d.eventChan {
-		d.logger.Info(fmt.Sprintf("DTMF event received: %s", event))
-		d.notifyHandlers(event)
-	}
+func (d *DTMFHandler) processEvent(event string) {
+	d.logger.Info(fmt.Sprintf("DTMF event received: %s", event))
+	d.notifyHandlers(event)
 }
 
 func (d *DTMFHandler) HandleDTMF(packet *rtp.Packet) error {
@@ -52,7 +44,7 @@ func (d *DTMFHandler) HandleDTMF(packet *rtp.Packet) error {
 	char := d.mapDTMFEventToChar(event)
 
 	if endOfEvent {
-		d.eventChan <- char
+		go d.processEvent(char)
 	}
 
 	return nil
@@ -112,10 +104,7 @@ func (d *DTMFHandler) notifyHandlers(event string) {
 }
 
 func (d *DTMFHandler) IntegrateWithPion(pc *webrtc.PeerConnection) {
-	pc.OnDTMF(func(dtmf *webrtc.DTMFSender) {
-		d.logger.Info("DTMF tone received via pion/WebRTC")
-		// Process DTMF tones received via WebRTC
-	})
+	// TODO: need to find a way to get DTMF tone in a call
 }
 
 func (d *DTMFHandler) ProcessDTMFEvent(event string, sessionID string) {