Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Did not send eth_unsubscribe to the node when unsubscribing #3992

Closed
samlior opened this issue Apr 7, 2021 · 5 comments · Fixed by #4058
Closed

Did not send eth_unsubscribe to the node when unsubscribing #3992

samlior opened this issue Apr 7, 2021 · 5 comments · Fixed by #4058
Labels
1.x 1.0 related issues 3.x 3.0 related issues Bug Addressing a bug P1 High severity bugs

Comments

@samlior
Copy link

samlior commented Apr 7, 2021

Expected behavior

Send eth_unsubscribe to the node when unsubscribing

Actual behavior

Did not send eth_unsubscribe to the node when unsubscribing

Steps to reproduce the behavior

const subscription = web3.eth.subscribe("newBlockHeaders", (err) => {
    if (err) {
        console.log('err:', err)
    }
})
subscription.on('connected', () => {
    subscription.unsubscribe();
})

Environment

npm 7.7.4
node 12.19.0
[email protected]
[email protected]

Reason

// web3-core-subscriptions/src/subscription.js line279 (function subscribe)
this.options.requestManager.send(payload, function (err, result) {
    if(!err && result) {
        _this.id = result;
        _this.method = payload.params[0];
        _this.emit('connected', result);

        // call callback on notifications
        _this.options.requestManager.addSubscription(_this, function(error, result) {
            //...
        });
    } else {
        //...
    }
});
// web3-core-requestmanager/src/index.js line249 (function removeSubscription)
if (this.subscriptions.has(id)) {
    var type = this.subscriptions.get(id).subscription.options.type;

    // remove subscription first to avoid reentry
    this.subscriptions.delete(id);

    // then, try to actually unsubscribe
    this.send({
        method: type + '_unsubscribe',
        params: [id]
    }, callback);

    return;
}

It seems that when removeSubscription, it will find the subscription object from the this.subscriptions according to the id, but when the connected event is emitted, the object has not been added to the this.subscriptions. Therefore, when unsubscribe is called in the connected event, eth_unsubscribe will not be sent.

Suggest

Call requestManager.addSubscription before emit connected event.

@spacesailor24 spacesailor24 added 1.x 1.0 related issues 3.x 3.0 related issues Bug Addressing a bug P1 High severity bugs labels May 11, 2021
@spacesailor24
Copy link
Contributor

Thank you for bringing this to our attention. Currently our focus is on rewriting the library (v4.x), so we may not get to fixing this soon enough for you. If possible, you are invited to open up a PR fixing this issue! Otherwise, we'll keep this in mind when doing the rewrite and will verify the issue doesn't persist

@github-actions
Copy link

This issue has been automatically marked as stale because it has not had recent activity. It will be closed in 7 days if no further activity occurs. Thank you for your contributions. If you believe this was a mistake, please comment.

@github-actions github-actions bot added the Stale Has not received enough activity label Jul 11, 2021
@samlior
Copy link
Author

samlior commented Jul 11, 2021

Can you review this pr? #4058 @spacesailor24

@github-actions github-actions bot removed the Stale Has not received enough activity label Jul 12, 2021
@philknows philknows linked a pull request Sep 2, 2021 that will close this issue
16 tasks
@philknows
Copy link

Hi, the actions are failing @samlior. If you can fix this, one of our team members will review. Thanks.

@nazarhussain
Copy link
Contributor

As the actual commit in the referenced PR is merge to 1.x. So I am closing this issue.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
1.x 1.0 related issues 3.x 3.0 related issues Bug Addressing a bug P1 High severity bugs
Projects
None yet
Development

Successfully merging a pull request may close this issue.

4 participants