chore(clbot): Add signal handler to make clbot shutdown cleanly on SIGINT.

Change-Id: I3c6eeeb99f9d81cdbcb10880c9075ac94c4f5d19
Reviewed-on: https://cl.tvl.fyi/c/depot/+/341
Reviewed-by: tazjin <mail@tazj.in>
This commit is contained in:
Luke Granger-Brown 2020-06-14 20:17:50 +01:00 committed by lukegb
parent a577fd83d6
commit 5acd03817a

View file

@ -5,6 +5,7 @@ import (
"flag"
"io/ioutil"
"os"
"os/signal"
"time"
"code.tvl.fyi/fun/clbot/gerrit"
@ -55,11 +56,27 @@ func checkRequired(fs *flag.FlagSet) {
}
}
var shutdownFuncs []func()
func callOnShutdown(f func()) {
shutdownFuncs = append(shutdownFuncs, f)
}
func main() {
flag.Parse()
checkRequired(required)
ctx := context.Background()
shutdownCh := make(chan os.Signal)
signal.Notify(shutdownCh, os.Interrupt)
go func() {
<-shutdownCh
for n := len(shutdownFuncs); n >= 0; n-- {
shutdownFuncs[n]()
}
}()
ctx, cancel := context.WithCancel(context.Background())
callOnShutdown(cancel)
cfg := &ssh.ClientConfig{
User: *gerritAuthUsername,
Auth: []ssh.AuthMethod{mustPrivateKey(*gerritAuthKeyPath)},
@ -67,10 +84,16 @@ func main() {
Timeout: *gerritSSHTimeout,
}
cfg.SetDefaults()
gw, err := gerrit.New(ctx, "tcp", *gerritAddr, cfg)
if err != nil {
log.Errorf("gerrit.New(%q): %v", *gerritAddr, err)
}
callOnShutdown(func() {
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
gw.Close(ctx)
})
for e := range gw.Events() {
log.Infof("hello: %v", spew.Sdump(e))