mirror of
https://github.com/meshcore-dev/meshcore.js.git
synced 2026-04-20 22:13:49 +00:00
add helper function for resetting path
This commit is contained in:
parent
2e3ecdb15e
commit
e262772fe3
2 changed files with 32 additions and 1 deletions
|
|
@ -338,7 +338,7 @@
|
|||
async resetPath(contact) {
|
||||
|
||||
// remove contact from device
|
||||
await this.connection.sendCommandResetPath(contact.publicKey);
|
||||
await this.connection.resetPath(contact.publicKey);
|
||||
|
||||
// reload contacts
|
||||
await this.loadContacts();
|
||||
|
|
|
|||
|
|
@ -819,6 +819,37 @@ class Connection extends EventEmitter {
|
|||
});
|
||||
}
|
||||
|
||||
resetPath(pubKey) {
|
||||
return new Promise(async (resolve, reject) => {
|
||||
try {
|
||||
|
||||
// resolve promise when we receive ok
|
||||
const onOk = () => {
|
||||
this.off(Constants.ResponseCodes.Ok, onOk);
|
||||
this.off(Constants.ResponseCodes.Err, onErr);
|
||||
resolve();
|
||||
}
|
||||
|
||||
// reject promise when we receive err
|
||||
const onErr = () => {
|
||||
this.off(Constants.ResponseCodes.Ok, onOk);
|
||||
this.off(Constants.ResponseCodes.Err, onErr);
|
||||
reject();
|
||||
}
|
||||
|
||||
// listen for events
|
||||
this.once(Constants.ResponseCodes.Ok, onOk);
|
||||
this.once(Constants.ResponseCodes.Err, onErr);
|
||||
|
||||
// reset path
|
||||
await this.sendCommandResetPath(pubKey);
|
||||
|
||||
} catch(e) {
|
||||
reject(e);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
export default Connection;
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue