| 99 | } |
| 100 | |
| 101 | func runServer(ctx context.Context, log log15.Logger) error { |
| 102 | messagebusURL := viper.GetString("messagebus.url") |
| 103 | if messagebusURL == "" { |
| 104 | messagebusURL = viper.GetString("nats.url") //backward compatibility |
| 105 | } |
| 106 | if os.Getenv("NATS_SERVICE_HOST") != "" { |
| 107 | messagebusURL = "nats://" + os.Getenv("NATS_SERVICE_HOST") + ":" + os.Getenv("NATS_SERVICE_PORT_CLIENT") |
| 108 | } |
| 109 | |
| 110 | srv := server.New() |
| 111 | srv.Log = log |
| 112 | |
| 113 | log.Info("starting ari-proxy server", "version", version) |
| 114 | return srv.Listen(ctx, &native.Options{ |
| 115 | Application: viper.GetString("ari.application"), |
| 116 | Username: viper.GetString("ari.username"), |
| 117 | Password: viper.GetString("ari.password"), |
| 118 | URL: viper.GetString("ari.http_url"), |
| 119 | WebsocketURL: viper.GetString("ari.websocket_url"), |
| 120 | }, messagebusURL) |
| 121 | } |