diff --git a/main.go b/main.go index f516847..1e6d04e 100644 --- a/main.go +++ b/main.go @@ -58,10 +58,7 @@ func (that *ProjectBackfeedManager) RedisConfigDiffers(new *ProjectRedisConfig) if that.ProjectConfig.RedisConfig == nil && new == nil { return false } - if that.ProjectConfig.RedisConfig == nil || new == nil || that.ProjectConfig.RedisConfig.Host != new.Host || that.ProjectConfig.RedisConfig.Port != new.Port || that.ProjectConfig.RedisConfig.Pass != new.Pass { - return true - } - return false + return that.ProjectConfig.RedisConfig == nil || new == nil || *that.ProjectConfig.RedisConfig != *new } func (that *ProjectBackfeedManager) PushItem(ctx context.Context, item *BackfeedItem) bool { @@ -196,7 +193,7 @@ func (that *ProjectBackfeedManager) Do() { log.Printf("unable to dedupe against %s legacy backfeed: %s", that.Name, err) } else { rawResArray, ok := rawRes.([]interface{}) - if ok && len(sAddItems) != len(rawResArray) { + if ok && len(sAddItems) == len(rawResArray) { var filteredSAddItems []interface{} for i, vi := range rawResArray { v, ok := vi.(int64) @@ -520,7 +517,7 @@ func main() { serveErrChan := make(chan error) go func() { s := &http.Server{ - Addr: ":21581", + Addr: os.Getenv("HTTP_ADDR"), IdleTimeout: 1 * time.Hour, MaxHeaderBytes: 1 * 1024 * 1024, Handler: r,