package module import ( "context" "encoding/json" "errors" "fmt" "io" "log/slog" "os" "sync" "time" "github.com/emiago/diago" "github.com/emiago/diago/media" "github.com/emiago/sipgo" "github.com/emiago/sipgo/sip" "github.com/google/jsonschema-go/jsonschema" "github.com/jwetzell/showbridge-go/internal/common" "github.com/jwetzell/showbridge-go/internal/config" "github.com/jwetzell/showbridge-go/internal/processor" ) type SIPCallServer struct { config config.ModuleConfig ctx context.Context router common.RouteIO IP string Port int Transport string UserAgent string dg *diago.Diago logger *slog.Logger cancel context.CancelFunc } type SIPCallMessage struct { To string } type SIPCall struct { inDialog *diago.DialogServerSession lock sync.Mutex } type sipCallContextKey string func init() { RegisterModule(ModuleRegistration{ Type: "sip.call.server", Title: "SIP Call Server", ParamsSchema: &jsonschema.Schema{ Type: "object", Properties: map[string]*jsonschema.Schema{ "ip": { Title: "IP", Type: "string", Default: json.RawMessage(`"0.0.0.0"`), }, "port": { Title: "Port", Type: "integer", Minimum: jsonschema.Ptr[float64](1024), Maximum: jsonschema.Ptr[float64](65535), Default: json.RawMessage(`5060`), }, "transport": { Title: "Transport", Type: "string", Enum: []any{"udp", "tcp", "ws", "udp4", "tcp4"}, Default: json.RawMessage(`"udp"`), }, "userAgent": { Title: "User Agent", Type: "string", Default: json.RawMessage(`"showbridge"`), }, }, Required: []string{}, AdditionalProperties: &jsonschema.Schema{Not: &jsonschema.Schema{}}, }, New: func(moduleConfig config.ModuleConfig) (common.Module, error) { params := moduleConfig.Params portNum, err := params.GetInt("port") if err != nil { if errors.Is(err, config.ErrParamNotFound) { portNum = 5060 } else { return nil, fmt.Errorf("sip.call.server port error: %w", err) } } ipString, err := params.GetString("ip") if err != nil { if errors.Is(err, config.ErrParamNotFound) { ipString = "0.0.0.0" } else { return nil, fmt.Errorf("sip.call.server ip error: %w", err) } } transportString, err := params.GetString("transport") if err != nil { if errors.Is(err, config.ErrParamNotFound) { transportString = "udp" } else { return nil, fmt.Errorf("sip.call.server transport error: %w", err) } } userAgentString, err := params.GetString("userAgent") if err != nil { if errors.Is(err, config.ErrParamNotFound) { userAgentString = "showbridge" } else { return nil, fmt.Errorf("sip.call.server userAgent error: %w", err) } } return &SIPCallServer{config: moduleConfig, IP: ipString, Port: int(portNum), Transport: transportString, UserAgent: userAgentString, logger: CreateLogger(moduleConfig)}, nil }, }) } func (scs *SIPCallServer) Id() string { return scs.config.Id } func (scs *SIPCallServer) Type() string { return scs.config.Type } func (scs *SIPCallServer) Start(ctx context.Context) error { scs.logger.Debug("running") router, ok := ctx.Value(common.RouterContextKey).(common.RouteIO) if !ok { return errors.New("sip.call.server unable to get router from context") } scs.router = router moduleContext, cancel := context.WithCancel(ctx) scs.ctx = moduleContext scs.cancel = cancel diagoLogger := slog.New(slog.NewJSONHandler(io.Discard, nil)) ua, _ := sipgo.NewUA( sipgo.WithUserAgent(scs.UserAgent), sipgo.WithUserAgentTransportLayerOptions(sip.WithTransportLayerLogger(diagoLogger)), sipgo.WithUserAgentTransactionLayerOptions(sip.WithTransactionLayerLogger(diagoLogger)), ) defer ua.Close() sip.SetDefaultLogger(diagoLogger) media.SetDefaultLogger(diagoLogger) dg := diago.NewDiago(ua, diago.WithLogger(diagoLogger), diago.WithTransport( diago.Transport{ Transport: scs.Transport, BindHost: scs.IP, BindPort: scs.Port, }, )) go func() { dg.Serve(scs.ctx, func(inDialog *diago.DialogServerSession) { scs.HandleCall(inDialog) }) }() scs.dg = dg <-scs.ctx.Done() scs.logger.Debug("done") return nil } func (scs *SIPCallServer) HandleCall(inDialog *diago.DialogServerSession) { inDialog.Trying() inDialog.Ringing() inDialog.Answer() dialogContext := context.WithValue(scs.ctx, sipCallContextKey("call"), &SIPCall{ inDialog: inDialog, }) scs.router.HandleInput(dialogContext, scs.Id(), SIPCallMessage{ To: inDialog.ToUser(), }) } func (scs *SIPCallServer) Output(ctx context.Context, payload any) error { call, ok := ctx.Value(sipCallContextKey("call")).(*SIPCall) if !ok { return errors.New("sip.call.server output must originate from sip.call.server input") } gotLock := call.lock.TryLock() if !gotLock { return errors.New("sip.call.server call is already locked") } if call.inDialog.LoadState() == sip.DialogStateEnded { return errors.New("sip.call.server inDialog already ended") } payloadDTMFResponse, ok := common.GetAnyAs[processor.SipDTMFResponse](payload) if ok { dtmfWriter := call.inDialog.AudioWriterDTMF() time.Sleep(time.Millisecond * time.Duration(payloadDTMFResponse.PreWait)) for i, dtmfRune := range payloadDTMFResponse.Digits { err := dtmfWriter.WriteDTMF(dtmfRune) if err != nil { return fmt.Errorf("sip.dtmf.server error output dtmf digit at index %d", i) } } time.Sleep(time.Millisecond * time.Duration(payloadDTMFResponse.PostWait)) return nil } payloadAudioFileResponse, ok := common.GetAnyAs[processor.SipAudioFileResponse](payload) if ok { audioFile, err := os.Open(payloadAudioFileResponse.AudioFile) if err != nil { return err } defer audioFile.Close() playback, err := call.inDialog.PlaybackCreate() if err != nil { return err } time.Sleep(time.Millisecond * time.Duration(payloadAudioFileResponse.PreWait)) _, err = playback.Play(audioFile, "audio/wav") time.Sleep(time.Millisecond * time.Duration(payloadAudioFileResponse.PostWait)) if err != nil { return err } return nil } return errors.New("sip.dtmf.server can only output SipDTMFResponse or SipAudioFileResponse") } func (scs *SIPCallServer) Stop() { scs.cancel() }