ingest: fix for npe

jitsucom · Sep 7, 2024 · 73d6600 · 73d6600
1 parent e834c8f
commit 73d6600
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ingest/router.go b/ingest/router.go
@@ -575,7 +575,7 @@ func (r *Router) WriteKeyStreamLocator(loc *StreamCredentials, _ bool) *StreamWi
 func (r *Router) SlugStreamLocator(loc *StreamCredentials, s2sEndpoint bool) *StreamWithDestinations {
 	if loc.Slug != "" {
 		stream := r.repository.GetData().GetStreamById(loc.Slug)
-		if !stream.Stream.Strict {
+		if stream != nil && !stream.Stream.Strict {
 			loc.IngestType = utils.Ternary(s2sEndpoint, IngestTypeS2S, IngestTypeBrowser)
 			return stream
 		}