ingest: fix for ingest type detection if site_it was used instead of …

…write key
jitsucom · Dec 3, 2024 · eae4800 · eae4800
1 parent 941d61a
commit eae4800
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/ingest/router.go b/ingest/router.go
@@ -561,10 +561,11 @@ func (r *Router) checkOrigin(c *gin.Context, loc *StreamCredentials, stream *Str
 	return nil
 }
 
-func (r *Router) WriteKeyStreamLocator(loc *StreamCredentials, _ bool) *StreamWithDestinations {
+func (r *Router) WriteKeyStreamLocator(loc *StreamCredentials, s2sEndpoint bool) *StreamWithDestinations {
 	if loc.WriteKey != "" {
 		parts := strings.Split(loc.WriteKey, ":")
 		if len(parts) == 1 {
+			loc.IngestType = utils.Ternary(s2sEndpoint, IngestTypeS2S, IngestTypeBrowser)
 			return r.repository.GetData().GetStreamById(loc.WriteKey)
 		} else {
 			binding := r.repository.GetData().getStreamByKeyId(parts[0])

diff --git a/jitsubase/appbase/abstract_repository.go b/jitsubase/appbase/abstract_repository.go
@@ -166,6 +166,7 @@ func (r *AbstractRepository[T]) refresh(notify bool) {
 		if r.cacheDir != "" {
 			r.storeCached()
 		}
+		r.Infof("Updated: %v previous: %v ms: %d", newTag, tag, time.Now().Sub(start).Milliseconds())
 		if notify {
 			select {
 			case r.changesChan <- true:

diff --git a/release.sh b/release.sh
@@ -1,4 +1,4 @@
 #!/usr/bin/env bash
 
-npx jitsu-build-scripts docker -t bulker,ingest,syncctl,sidecar,ingmgr --platform linux/amd64,linux/arm64 --push $@
+npx jitsu-build-scripts docker -t bulker,ingest,syncctl,sidecar,ingmgr,cfgkpr --platform linux/amd64,linux/arm64 --push $@