aarifullin/neoneo-go
1
0
Fork 0
forked from TrueCloudLab/neoneo-go
Code Pull requests Activity

rpcclient: copy subscription params, fix #2890

Browse source 
Clients can change things and we better be safe here.
This commit is contained in:
Roman Khimov 2023-03-16 23:50:56 +03:00
parent 1a4da8c462
commit e197f3faef
1 changed files with 15 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
pkg/rpcclient/wsclient.go
View file

@ -647,7 +647,8 @@ func (c *WSClient) performSubscription(params []interface{}, rcvr notificationRe
func (c *WSClient) SubscribeForNewBlocks(primary *int) (string, error) { func (c *WSClient) SubscribeForNewBlocks(primary *int) (string, error) {
var flt interface{} var flt interface{}
if primary != nil { if primary != nil {
flt = neorpc.BlockFilter{Primary: primary} var f = neorpc.BlockFilter{Primary: primary}
flt = *f.Copy()
} }
params := []interface{}{"block_added"} params := []interface{}{"block_added"}
if flt != nil { if flt != nil {
@ -678,6 +679,7 @@ func (c *WSClient) ReceiveBlocks(flt *neorpc.BlockFilter, rcvr chan<- *block.Blo
} }
params := []interface{}{"block_added"} params := []interface{}{"block_added"}
if flt != nil { if flt != nil {
flt = flt.Copy()
params = append(params, *flt) params = append(params, *flt)
} }
r := &blockReceiver{ r := &blockReceiver{
@ -695,7 +697,8 @@ func (c *WSClient) ReceiveBlocks(flt *neorpc.BlockFilter, rcvr chan<- *block.Blo
func (c *WSClient) SubscribeForNewTransactions(sender *util.Uint160, signer *util.Uint160) (string, error) { func (c *WSClient) SubscribeForNewTransactions(sender *util.Uint160, signer *util.Uint160) (string, error) {
var flt interface{} var flt interface{}
if sender != nil || signer != nil { if sender != nil || signer != nil {
flt = neorpc.TxFilter{Sender: sender, Signer: signer} var f = neorpc.TxFilter{Sender: sender, Signer: signer}
flt = *f.Copy()
} }
params := []interface{}{"transaction_added"} params := []interface{}{"transaction_added"}
if flt != nil { if flt != nil {
@ -726,6 +729,7 @@ func (c *WSClient) ReceiveTransactions(flt *neorpc.TxFilter, rcvr chan<- *transa
} }
params := []interface{}{"transaction_added"} params := []interface{}{"transaction_added"}
if flt != nil { if flt != nil {
flt = flt.Copy()
params = append(params, *flt) params = append(params, *flt)
} }
r := &txReceiver{ r := &txReceiver{
@ -744,7 +748,8 @@ func (c *WSClient) ReceiveTransactions(flt *neorpc.TxFilter, rcvr chan<- *transa
func (c *WSClient) SubscribeForExecutionNotifications(contract *util.Uint160, name *string) (string, error) { func (c *WSClient) SubscribeForExecutionNotifications(contract *util.Uint160, name *string) (string, error) {
var flt interface{} var flt interface{}
if contract != nil || name != nil { if contract != nil || name != nil {
flt = neorpc.NotificationFilter{Contract: contract, Name: name} var f = neorpc.NotificationFilter{Contract: contract, Name: name}
flt = *f.Copy()
} }
params := []interface{}{"notification_from_execution"} params := []interface{}{"notification_from_execution"}
if flt != nil { if flt != nil {
@ -774,6 +779,7 @@ func (c *WSClient) ReceiveExecutionNotifications(flt *neorpc.NotificationFilter,
} }
params := []interface{}{"notification_from_execution"} params := []interface{}{"notification_from_execution"}
if flt != nil { if flt != nil {
flt = flt.Copy()
params = append(params, *flt) params = append(params, *flt)
} }
r := &executionNotificationReceiver{ r := &executionNotificationReceiver{
@ -795,7 +801,8 @@ func (c *WSClient) SubscribeForTransactionExecutions(state *string) (string, err
if *state != "HALT" && *state != "FAULT" { if *state != "HALT" && *state != "FAULT" {
return "", errors.New("bad state parameter") return "", errors.New("bad state parameter")
} }
flt = neorpc.ExecutionFilter{State: state} var f = neorpc.ExecutionFilter{State: state}
flt = *f.Copy()
} }
params := []interface{}{"transaction_executed"} params := []interface{}{"transaction_executed"}
if flt != nil { if flt != nil {
@ -832,6 +839,7 @@ func (c *WSClient) ReceiveExecutions(flt *neorpc.ExecutionFilter, rcvr chan<- *s
return "", errors.New("bad state parameter") return "", errors.New("bad state parameter")
} }
} }
flt = flt.Copy()
params = append(params, *flt) params = append(params, *flt)
} }
r := &executionReceiver{ r := &executionReceiver{
@ -850,7 +858,8 @@ func (c *WSClient) ReceiveExecutions(flt *neorpc.ExecutionFilter, rcvr chan<- *s
func (c *WSClient) SubscribeForNotaryRequests(sender *util.Uint160, mainSigner *util.Uint160) (string, error) { func (c *WSClient) SubscribeForNotaryRequests(sender *util.Uint160, mainSigner *util.Uint160) (string, error) {
var flt interface{} var flt interface{}
if sender != nil || mainSigner != nil { if sender != nil || mainSigner != nil {
flt = neorpc.TxFilter{Sender: sender, Signer: mainSigner} var f = neorpc.TxFilter{Sender: sender, Signer: mainSigner}
flt = *f.Copy()
} }
params := []interface{}{"notary_request_event"} params := []interface{}{"notary_request_event"}
if flt != nil { if flt != nil {
@ -883,6 +892,7 @@ func (c *WSClient) ReceiveNotaryRequests(flt *neorpc.TxFilter, rcvr chan<- *resu
} }
params := []interface{}{"notary_request_event"} params := []interface{}{"notary_request_event"}
if flt != nil { if flt != nil {
flt = flt.Copy()
params = append(params, *flt) params = append(params, *flt)
} }
r := &notaryRequestReceiver{ r := &notaryRequestReceiver{