Gleipnir/nidus-sync
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Don't require systemd sockets in dev mode

Browse source 
Because otherwise I can't run the program on my dev server
This commit is contained in:
Eli Ribble 2026-04-29 13:54:48 +00:00
parent 5ac778ea53
commit 822dad5352
No known key found for this signature in database
1 changed files with 21 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

32
main.go
View file

@ -146,22 +146,32 @@ func main() {
log.Error().Err(err).Msg("Failed to start openAI client") log.Error().Err(err).Msg("Failed to start openAI client")
os.Exit(8) os.Exit(8)
} }
listeners, _ := activation.Listeners()
if len(listeners) != 1 {
log.Error().Int("len", len(listeners)).Msg("Unexpected number of socket activation FDs")
os.Exit(1)
}
server := &http.Server{ server := &http.Server{
Addr: config.Bind, Addr: config.Bind,
Handler: r, Handler: r,
} }
go func() { if config.IsProductionEnvironment() {
log.Info().Str("address", config.Bind).Msg("Serving HTTP requests") listeners, _ := activation.Listeners()
if err := server.Serve(listeners[0]); err != nil && err != http.ErrServerClosed { if len(listeners) != 1 {
log.Error().Str("err", err.Error()).Msg("HTTP Server Error") log.Error().Int("len", len(listeners)).Msg("Unexpected number of socket activation FDs")
os.Exit(1)
} }
log.Debug().Msg("Exiting listen-and-serve goroutine") go func() {
}() log.Info().Str("address", config.Bind).Msg("Serving HTTP requests")
if err := server.Serve(listeners[0]); err != nil && err != http.ErrServerClosed {
log.Error().Str("err", err.Error()).Msg("HTTP Server Error")
}
log.Debug().Msg("Exiting listen-and-serve goroutine")
}()
} else {
go func() {
log.Info().Str("address", config.Bind).Msg("Serving HTTP requests")
if err := server.ListenAndServe(); err != nil && err != http.ErrServerClosed {
log.Error().Str("err", err.Error()).Msg("HTTP Server Error")
}
log.Debug().Msg("Exiting listen-and-serve goroutine")
}()
}
chan_envelope := make(chan platform.Envelope, 10) chan_envelope := make(chan platform.Envelope, 10)
platform.SetEventChannel(chan_envelope) platform.SetEventChannel(chan_envelope)