From 8c9fbefbbea707ca62bc7f251371d84bdf7ff9f2 Mon Sep 17 00:00:00 2001 From: Fritz Larco Date: Fri, 10 Nov 2023 11:00:04 -0300 Subject: [PATCH] fix ds.Metadata.StreamURL [nt] --- iop/datastream.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/iop/datastream.go b/iop/datastream.go index fa9575c..56d94bd 100644 --- a/iop/datastream.go +++ b/iop/datastream.go @@ -658,8 +658,12 @@ func (ds *Datastream) Rows() chan []any { func (ds *Datastream) SetMetadata(jsonStr string) { if jsonStr != "" { + streamValue := ds.Metadata.StreamURL.Value g.Unmarshal(jsonStr, &ds.Metadata) ds.Metadata.LoadedAt.Value = cast.ToInt64(ds.Metadata.LoadedAt.Value) + if ds.Metadata.StreamURL.Value == nil { + ds.Metadata.StreamURL.Value = streamValue + } } }