feat(streaming): refactor

hekike · GAlexIHU · commit 840dfbd6e117 · 2025-11-18T11:08:20.000+01:00
diff --git a/openmeter/streaming/clickhouse/queryhelper.go b/openmeter/streaming/clickhouse/queryhelper.go
@@ -84,9 +84,7 @@ func customersWhere(eventsTableName string, customers []streaming.Customer, quer
 		}
 
 		// Add each subject key to the filter
-		for _, subjectKey := range customer.GetUsageAttribution().SubjectKeys {
-			subjects = append(subjects, subjectKey)
-		}
+		subjects = append(subjects, customer.GetUsageAttribution().SubjectKeys...)
 	}
 
 	// If there are no subjects, we return an empty subject filter

Original file line number	Diff line number	Diff line change
`@@ -84,9 +84,7 @@ func customersWhere(eventsTableName string, customers []streaming.Customer, quer`
`84`	`84`	`}`
`85`	`85`
`86`	`86`	`// Add each subject key to the filter`
`87`		`- for _, subjectKey := range customer.GetUsageAttribution().SubjectKeys {`
`88`		`- subjects = append(subjects, subjectKey)`
`89`		`- }`
	`87`	`+ subjects = append(subjects, customer.GetUsageAttribution().SubjectKeys...)`
`90`	`88`	`}`
`91`	`89`
`92`	`90`	`// If there are no subjects, we return an empty subject filter`