GlcoinCore/alby-hub
1
0
Fork 0
mirror of https://github.com/getAlby/hub.git synced 2026-08-13 12:33:39 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

chore: increase lnd wait time before retrying (#1444)

Browse source 
* chore: increase lnd wait time before retrying

* fix: os signal goroutine should not wait for service init

* chore: set max retries to 60 and wait time to 10s
This commit is contained in:
Adithya Vardhan 2025-06-26 15:09:27 +05:30 • committed by GitHub
parent 3e37d569f5
commit bce8b2103a
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 17 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

17
cmd/http/main.go
View file

@ -25,6 +25,15 @@ func main() {
signal.Notify(osSignalChannel, os.Interrupt, syscall.SIGTERM)
ctx, cancel := context.WithCancel(context.Background())
var signal os.Signal
go func() {
// wait for exit signal
signal = <-osSignalChannel
logger.Logger.WithField("signal", signal).Info("Received OS signal")
cancel()
}()
svc, err := service.NewService(ctx)
if err != nil {
log.WithError(err).Fatal("Failed to create service")
@ -44,14 +53,6 @@ func main() {
}
}()
var signal os.Signal
go func() {
// wait for exit signal
signal = <-osSignalChannel
logger.Logger.WithField("signal", signal).Info("Received OS signal")
cancel()
}()
//handle graceful shutdown
<-ctx.Done()
logger.Logger.WithField("signal", signal).Info("Context Done")

10
lnclient/lnd/lnd.go
View file

@ -60,7 +60,7 @@ func NewLNDService(ctx context.Context, eventPublisher events.EventPublisher, ln
}
var nodeInfo *lnclient.NodeInfo
maxRetries := 5
maxRetries := 60
for i := range maxRetries {
nodeInfo, err = fetchNodeInfo(ctx, lndClient)
if err == nil {
@ -69,7 +69,13 @@ func NewLNDService(ctx context.Context, eventPublisher events.EventPublisher, ln
logger.Logger.WithFields(logrus.Fields{
"iteration": i,
}).WithError(err).Error("Failed to connect to LND, retrying in 10s")
time.Sleep(10 * time.Second)
select {
case <-time.After(10 * time.Second):
case <-ctx.Done():
logger.Logger.WithError(ctx.Err()).Error("Context cancelled during LND connection retries")
return nil, ctx.Err()
}
}
if err != nil {