|
|
@@ -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, |
|
|
|