alice.mosphere.at / indigo
this repo has no description
0
fork

Configure Feed

Select the types of activity you want to include in your feed.

PR tweaks and fixes

authored by

Brian Olson and committed by
Brian Olson 6edaedd1 c6370ea6

+4 -4
+4 -4
splitter/splitter.go
··· 76 76 } 77 77 78 78 func (sc *SplitterConfig) UpstreamUrl() string { 79 - if strings.HasPrefix(sc.UpstreamHost, "http://") { 79 + if strings.HasPrefix(sc.UpstreamHost, "ws://") { 80 80 return "http://" + sc.UpstreamHost[7:] 81 81 } 82 - if strings.HasPrefix(sc.UpstreamHost, "https://") { 82 + if strings.HasPrefix(sc.UpstreamHost, "wss://") { 83 83 return "https://" + sc.UpstreamHost[8:] 84 84 } 85 85 if strings.HasPrefix(sc.UpstreamHost, "ws://") { ··· 622 622 } 623 623 con, res, err := d.DialContext(ctx, uurl, header) 624 624 if err != nil { 625 - s.log.Warn("dialing failed", "host", uurl, "err", err, "backoff", backoff) 625 + s.log.Warn("dialing failed", "url", uurl, "err", err, "backoff", backoff) 626 626 time.Sleep(sleepForBackoff(backoff)) 627 627 backoff++ 628 628 ··· 632 632 s.log.Info("event subscription response", "code", res.StatusCode) 633 633 634 634 if err := s.handleConnection(ctx, con, &cursor); err != nil { 635 - s.log.Warn("connection failed", "host", uurl, "err", err) 635 + s.log.Warn("connection failed", "url", uurl, "err", err) 636 636 } 637 637 } 638 638 }