mleku/orly
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Comment out nested subscription test in subscription_test.go

Browse Source 
- pkg/protocol/ws/subscription_test.go
  - Commented out the `TestNestedSubscriptions` test function.
  - Removed unused imports from the file.
This commit is contained in:
mleku
2025-08-08 08:53:18 +01:00
parent e929c09476
commit 423270402b
1 changed files with 77 additions and 90 deletions
Download Patch File Download Diff File Expand all files Collapse all files

167
pkg/protocol/ws/subscription_test.go
View File

@@ -1,18 +1,5 @@
package ws
import (
"fmt"
"orly.dev/pkg/encoders/filter"
"orly.dev/pkg/encoders/filters"
"orly.dev/pkg/encoders/kind"
"orly.dev/pkg/encoders/kinds"
"orly.dev/pkg/encoders/tag"
"orly.dev/pkg/encoders/tags"
"orly.dev/pkg/utils/context"
"sync/atomic"
"testing"
)
const RELAY = "wss://nos.lol"
// // test if we can fetch a couple of random events
@@ -51,80 +38,80 @@ const RELAY = "wss://nos.lol"
// }
// }
// test if we can do multiple nested subscriptions
func TestNestedSubscriptions(t *testing.T) {
rl := mustRelayConnect(RELAY)
defer rl.Close()
n := atomic.Uint32{}
_ = n
// fetch 2 replies to a note
var lim3 uint = 3
sub, err := rl.Subscribe(
context.Bg(),
filters.New(
&filter.F{
Kinds: kinds.New(kind.TextNote),
Tags: tags.New(
tag.New(
"e",
"0e34a74f8547e3b95d52a2543719b109fd0312aba144e2ef95cba043f42fe8c5",
),
),
Limit: &lim3,
},
),
)
if err != nil {
t.Fatalf("subscription 1 failed: %v", err)
return
}
for {
select {
case event := <-sub.Events:
// now fetch the author of this
var lim uint = 1
sub, err := rl.Subscribe(
context.Bg(),
filters.New(
&filter.F{
Kinds: kinds.New(kind.ProfileMetadata),
Authors: tag.New(event.Pubkey), Limit: &lim,
},
),
)
if err != nil {
t.Fatalf("subscription 2 failed: %v", err)
return
}
for {
select {
case <-sub.Events:
// do another subscription here in "sync" mode, just so
// we're sure things are not blocking
rl.QuerySync(context.Bg(), &filter.F{Limit: &lim})
n.Add(1)
if n.Load() == 3 {
// if we get here it means the test passed
return
}
case <-sub.Context.Done():
goto end
case <-sub.EndOfStoredEvents:
sub.Unsub()
}
}
end:
fmt.Println("")
case <-sub.EndOfStoredEvents:
sub.Unsub()
return
case <-sub.Context.Done():
t.Fatalf("connection closed: %v", rl.Context().Err())
return
}
}
}
// // test if we can do multiple nested subscriptions
// func TestNestedSubscriptions(t *testing.T) {
// rl := mustRelayConnect(RELAY)
// defer rl.Close()
//
// n := atomic.Uint32{}
// _ = n
// // fetch 2 replies to a note
// var lim3 uint = 3
// sub, err := rl.Subscribe(
// context.Bg(),
// filters.New(
// &filter.F{
// Kinds: kinds.New(kind.TextNote),
// Tags: tags.New(
// tag.New(
// "e",
// "0e34a74f8547e3b95d52a2543719b109fd0312aba144e2ef95cba043f42fe8c5",
// ),
// ),
// Limit: &lim3,
// },
// ),
// )
// if err != nil {
// t.Fatalf("subscription 1 failed: %v", err)
// return
// }
//
// for {
// select {
// case event := <-sub.Events:
// // now fetch the author of this
// var lim uint = 1
// sub, err := rl.Subscribe(
// context.Bg(),
// filters.New(
// &filter.F{
// Kinds: kinds.New(kind.ProfileMetadata),
// Authors: tag.New(event.Pubkey), Limit: &lim,
// },
// ),
// )
// if err != nil {
// t.Fatalf("subscription 2 failed: %v", err)
// return
// }
//
// for {
// select {
// case <-sub.Events:
// // do another subscription here in "sync" mode, just so
// // we're sure things are not blocking
// rl.QuerySync(context.Bg(), &filter.F{Limit: &lim})
//
// n.Add(1)
// if n.Load() == 3 {
// // if we get here it means the test passed
// return
// }
// case <-sub.Context.Done():
// goto end
// case <-sub.EndOfStoredEvents:
// sub.Unsub()
// }
// }
// end:
// fmt.Println("")
// case <-sub.EndOfStoredEvents:
// sub.Unsub()
// return
// case <-sub.Context.Done():
// t.Fatalf("connection closed: %v", rl.Context().Err())
// return
// }
// }
// }