bulker: add keepOriginalNames to known options

jitsucom · Nov 6, 2024 · 030636a · 030636a
1 parent 527fe72
commit 030636a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/bulkerlib/options.go b/bulkerlib/options.go
@@ -14,7 +14,7 @@ type StreamOption func(*StreamOptions)
 var optionsRegistry = make(map[string]ParseableOption)
 
 // Not used by bulker. Just added here to be treated as known options and don't print errors
-var ignoredOptions = []string{"functions", "streams", "dataLayout", "events", "debugTill", "hosts", "schedule", "timezone", "storageKey", "tableNamePrefix", "multithreading"}
+var ignoredOptions = []string{"functions", "streams", "dataLayout", "events", "debugTill", "hosts", "schedule", "timezone", "storageKey", "tableNamePrefix", "multithreading", "keepOriginalNames"}
 
 var (
 	BatchSizeOption = ImplementationOption[int]{

diff --git a/ingest/router.go b/ingest/router.go
@@ -478,6 +478,10 @@ func hashApiKey(token string, salt string, secret string) string {
 
 func (r *Router) checkHash(hash string, secret string) bool {
 	pk := strings.SplitN(hash, ".", 2)
+	if len(pk) < 2 {
+		r.Errorf("invalid hash format: %s", hash)
+		return false
+	}
 	salt := pk[0]
 	hashPart := pk[1]
 	for _, globalSecret := range r.config.GlobalHashSecrets {