main.go

package main

import (
	"context"
	"log"
	"os"
	"os/signal"
	"syscall"

	"github.com/streamcoreai/sip-server/internal/api"
	"github.com/streamcoreai/sip-server/internal/call"
	"github.com/streamcoreai/sip-server/internal/config"
	"github.com/streamcoreai/sip-server/internal/provider"
	sipserver "github.com/streamcoreai/sip-server/internal/sip"
)

func main() {
	configPath := "config.toml"
	if len(os.Args) > 1 {
		configPath = os.Args[1]
	}

	cfg, err := config.Load(configPath)
	if err != nil {
		log.Fatalf("failed to load config: %v", err)
	}

	// Register providers
	registry := provider.NewRegistry()
	for name, pc := range cfg.Providers {
		if !pc.Enabled {
			continue
		}
		switch name {
		case "twilio":
			registry.Register(&provider.Twilio{
				TrunkDomain: pc.TrunkDomain,
				Username:    pc.Username,
				Password:    pc.Password,
			})
		case "ringcentral":
			registry.Register(&provider.RingCentral{
				OutboundProxy: pc.OutboundProxy,
				Username:      pc.Username,
				Password:      pc.Password,
			})
		case "asterisk":
			registry.Register(&provider.Asterisk{
				Host:     pc.Host,
				Port:     pc.Port,
				Username: pc.Username,
				Password: pc.Password,
				Context:  pc.Context,
			})
		default:
			log.Printf("unknown provider %q, skipping", name)
		}
	}

	// Create call manager
	callMgr := call.NewManager(cfg)

	// Create SIP server
	sipSrv, err := sipserver.New(cfg, callMgr, registry)
	if err != nil {
		log.Fatalf("failed to create SIP server: %v", err)
	}

	// Create API server
	apiSrv := api.New(cfg.API.ListenAddr, callMgr, sipSrv, registry)

	// Setup graceful shutdown
	ctx, cancel := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGTERM)
	defer cancel()

	// Start API server
	go func() {
		if err := apiSrv.ListenAndServe(); err != nil {
			log.Printf("[api] server stopped: %v", err)
		}
	}()

	// Start SIP server (blocks until context is cancelled)
	log.Println("SIP server starting...")
	if err := sipSrv.ListenAndServe(ctx); err != nil {
		log.Printf("[sip] server stopped: %v", err)
	}

	// Shutdown API
	apiSrv.Shutdown(context.Background())
	log.Println("shutdown complete")
}