fix: read stream object using nonce from filter state

Signed-off-by: Dhi Aurrahman <dio@rockybars.com>

Author: dio

up/stream_key_test.go

@@ -75,6 +75,19 @@ func TestStreamKey_getFromCtx(t *testing.T) {
 	require.Equal(t, "sess-abc", got)
 }
 
+func TestStreamKey_getFromLaterWriterUsingFilterStateNonce(t *testing.T) {
+	first, h := newTestWriter(t)
+	defer func() { dropBag(first.f.streamObjectNonce) }()
+
+	k := NewStreamKey[string]("plum.target")
+	k.Set(first, "selected-target")
+
+	second := NewWriter(h)
+	got, ok := k.Get(second)
+	require.True(t, ok, "later writer could not read stream object using nonce from filter state")
+	require.Equal(t, "selected-target", got)
+}
+
 // TestStreamKey_getFromCtxNoValue: GetFromCtx returns (zero, false) when no
 // bag exists (Writer never called SetStreamObject).
 func TestStreamKey_getFromCtxNoValue(t *testing.T) {

up/writer.go

@@ -377,7 +377,11 @@ func (w *Writer) SetStreamObject(key string, v any) {
 // no nonce is minted.
 func (w *Writer) GetStreamObject(key string) (any, bool) {
 	if w.f.streamObjectNonce == "" {
-		return nil, false
+		nonce, ok := w.GetFilterState(streamObjectIDKey)
+		if !ok || nonce == "" {
+			return nil, false
+		}
+		w.f.streamObjectNonce = nonce
 	}
 	bag, ok := lookupBag(w.f.streamObjectNonce)
 	if !ok {