meshcore-dev/meshcore.js
1
0
Fork 0
mirror of https://github.com/meshcore-dev/meshcore.js.git synced 2026-04-20 22:13:49 +00:00
Code Issues Projects Releases Packages Wiki Activity

add helper functions that wait for ok or error response

Browse source
This commit is contained in:
liamcottle 2025-02-14 12:35:10 +13:00
parent 904c99d018
commit 17cc2b9834
1 changed files with 93 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

93
src/connection/connection.js
View file

@ -334,6 +334,99 @@ class Connection extends EventEmitter {
await this.sendCommandSendSelfAdvert(Constants.SelfAdvertTypes.ZeroHop);
}
setAdvertName(name) {
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);
// set advert name
await this.sendCommandSetAdvertName(name);
} catch(e) {
reject(e);
}
});
}
setTxPower(txPower) {
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);
// set tx power
await this.sendCommandSetTxPower(txPower);
} catch(e) {
reject(e);
}
});
}
setRadioParams(radioFreq, radioBw, radioSf, radioCr) {
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);
// set tx power
await this.sendCommandSetRadioParams(radioFreq, radioBw, radioSf, radioCr);
} catch(e) {
reject(e);
}
});
}
getContacts() {
return new Promise(async (resolve, reject) => {