code.ivysaur.me/nmdc-telegramfrontend
1
0
Fork 0
Code Issues 26 Pull Requests Releases 2 Wiki Activity

add race delay for existing connections during startup

Browse Source
This commit is contained in:
mappu 2018-06-04 16:36:45 +12:00
parent 785d314cd1
commit a61dcc3cb0
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
NTFServer.go
View File

@ -110,6 +110,7 @@ func NewNTFServer(configFile string, verbose bool) (*NTFServer, error) {
} }
// Spawn upstream connections for all pre-existing known users // Spawn upstream connections for all pre-existing known users
launchedAny := false
for telegramUserId, telegramDisplayName := range ret.config.GroupChatMembers { for telegramUserId, telegramDisplayName := range ret.config.GroupChatMembers {
hubNick, ok := ret.config.KnownUsers[telegramUserId] hubNick, ok := ret.config.KnownUsers[telegramUserId]
if !ok { if !ok {
@ -120,6 +121,14 @@ func NewNTFServer(configFile string, verbose bool) (*NTFServer, error) {
if err != nil { if err != nil {
return nil, fmt.Errorf("Reconnecting upstream for '%s': %s", hubNick, err.Error()) // fatal return nil, fmt.Errorf("Reconnecting upstream for '%s': %s", hubNick, err.Error()) // fatal
} }
launchedAny = true
}
// We have some bad edge cases if a telegram message comes in while the upstream
// connection is offline. Wait a bit after startup, to minimise failure cases
if launchedAny {
time.Sleep(5 * time.Second)
} }
return &ret, nil return &ret, nil