Files
core/main.go
Jan Stabenow eb1cc37456 Add GoSRT & improvements (repo-merge)
Commits (Ingo Oppermann):
- Add experimental SRT connection stats and logs
- Hide /config/reload endpoint in reade-only mode
- Add SRT server
- Create v16 in go.mod
- Fix data races, tests, lint, and update dependencies
- Add trailing slash for routed directories (datarhei/restreamer#340)
- Allow relative URLs in content in static routes

Co-Authored-By: Ingo Oppermann <57445+ioppermann@users.noreply.github.com>
2022-06-23 22:13:58 +02:00

57 lines
1.1 KiB
Go

package main
import (
"os"
"os/signal"
"github.com/datarhei/core/v16/app/api"
"github.com/datarhei/core/v16/log"
_ "github.com/joho/godotenv/autoload"
)
func main() {
logger := log.New("Core").WithOutput(log.NewConsoleWriter(os.Stderr, log.Lwarn, true))
app, err := api.New(os.Getenv("CORE_CONFIGFILE"), os.Stderr)
if err != nil {
logger.Error().WithError(err).Log("Failed to create new API")
os.Exit(1)
}
go func() {
defer func() {
if proc, err := os.FindProcess(os.Getpid()); err == nil {
proc.Signal(os.Interrupt)
}
}()
for {
if err := app.Start(); err != api.ErrConfigReload {
if err != nil {
logger.Error().WithError(err).Log("Failed to start API")
}
break
} else {
logger.Warn().WithError(err).Log("Config reload requested")
}
app.Stop()
if err := app.Reload(); err != nil {
logger.Error().WithError(err).Log("Failed to reload config")
break
}
}
}()
// Wait for interrupt signal to gracefully shutdown the app
quit := make(chan os.Signal, 1)
signal.Notify(quit, os.Interrupt)
<-quit
// Stop the app
app.Destroy()
}