TrueCloudLab/neo-go
8
0
Fork 0
mirror of https://github.com/nspcc-dev/neo-go.git synced 2024-11-25 03:47:18 +00:00
Code Issues Projects Releases Packages Wiki Activity

Merge pull request #3397 from nspcc-dev/fix-TestWSClient_SubscriptionsCompat

Browse source
This commit is contained in:
Roman Khimov 2024-04-04 12:02:20 +03:00 committed by GitHub
commit 22af33a14e
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
pkg/services/rpcsrv/client_test.go
View file

@ -2124,19 +2124,20 @@ func TestWSClient_SubscriptionsCompat(t *testing.T) {
blocks := getTestBlocks(t) blocks := getTestBlocks(t)
bCount := uint32(0) bCount := uint32(0)
getData := func(t *testing.T) (*block.Block, byte, util.Uint160, string, string) { getData := func(t *testing.T) (*block.Block, *block.Block, byte, util.Uint160, string, string) {
b1 := blocks[bCount] b1 := blocks[bCount]
primary := b1.PrimaryIndex primary := b1.PrimaryIndex
tx := b1.Transactions[0] tx := b1.Transactions[0]
sender := tx.Sender() sender := tx.Sender()
ntfName := "Transfer" ntfName := "Transfer"
st := vmstate.Halt.String() st := vmstate.Halt.String()
bCount++ b2 := blocks[bCount+1]
return b1, primary, sender, ntfName, st bCount += 2
return b1, b2, primary, sender, ntfName, st
} }
checkRelevant := func(t *testing.T, filtered bool) { checkRelevant := func(t *testing.T, filtered bool) {
b, primary, sender, ntfName, st := getData(t) b, bNext, primary, sender, ntfName, st := getData(t)
var ( var (
bID, txID, ntfID, aerID string bID, txID, ntfID, aerID string
blockCh = make(chan *block.Block) blockCh = make(chan *block.Block)
@ -2212,6 +2213,10 @@ func TestWSClient_SubscriptionsCompat(t *testing.T) {
// Accept the next block and wait for events. // Accept the next block and wait for events.
require.NoError(t, chain.AddBlock(b)) require.NoError(t, chain.AddBlock(b))
// Blockchain's events channel is not buffered, and thus, by adding one more extra block
// we're ensuring that the previous block event receiving was successfully handled by Blockchain's
// notificationDispatcher loop. Once we're sure in that, we may start to check the actual notifications.
require.NoError(t, chain.AddBlock(bNext))
assert.Eventually(t, func() bool { assert.Eventually(t, func() bool {
lock.RLock() lock.RLock()
defer lock.RUnlock() defer lock.RUnlock()