MicrocontrollerCD/UpdaterWebLibrary
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Reducing number of awaits for speed

Browse Source
This commit is contained in:
chopster44
2025-11-30 21:20:33 +00:00
parent b13787b704
commit 5009b0c8d1
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/index.ts
View File

@@ -211,7 +211,7 @@ export default class Updater {
let packet = this.file.slice(this._fileProgress, this._fileProgress+this._packetSize); let packet = this.file.slice(this._fileProgress, this._fileProgress+this._packetSize);
this._fileProgress += this._packetSize; this._fileProgress += this._packetSize;
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
this.bleObject.write(this.bleDeviceId, this._updaterServiceUUID, this._updateFileCharacteristicUUID, packet.buffer, this.bleObject.writeWithoutResponse(this.bleDeviceId, this._updaterServiceUUID, this._updateFileCharacteristicUUID, packet.buffer,
() => { () => {
resolve(true); resolve(true);
}, },
@@ -239,15 +239,15 @@ export default class Updater {
// check for error // check for error
// write file length // write file length
return new Promise(async (resolve, reject) => { return new Promise((resolve, reject) => {
// start notify // start notify
this.bleObject.startNotification(this.bleDeviceId, this._updaterServiceUUID, this._updaterCommandCharacterisitcUUID, this.bleObject.startNotification(this.bleDeviceId, this._updaterServiceUUID, this._updaterCommandCharacterisitcUUID,
async (rawData: ArrayBuffer): Promise<void> => { (rawData: ArrayBuffer): void => {
let dataView = new Uint8Array(rawData); let dataView = new Uint8Array(rawData);
console.log(dataView); console.log(dataView);
if (dataView[0] == 1) { if (dataView[0] == 1) {
// send file // send file
await this.sendNextPacket(); this.sendNextPacket();
progressCallback(`Sending (${Math.floor((this._fileProgress *100)/this._fileSize)}%), ${this._fileProgress} / ${this._fileSize}`); progressCallback(`Sending (${Math.floor((this._fileProgress *100)/this._fileSize)}%), ${this._fileProgress} / ${this._fileSize}`);
} else if (dataView[0] == 2) { } else if (dataView[0] == 2) {
// done logic // done logic
@@ -255,7 +255,7 @@ export default class Updater {
if (this._fileProgress >= this._fileSize) { if (this._fileProgress >= this._fileSize) {
console.log("true"); console.log("true");
// send agree // send agree
await this.sendEndCmd(true); this.sendEndCmd(true);
progressCallback(`Complete!`); progressCallback(`Complete!`);
this.bleObject.stopNotification(this.bleDeviceId, this.bleObject.stopNotification(this.bleDeviceId,
this._updaterServiceUUID, this._updaterCommandCharacterisitcUUID, this._updaterServiceUUID, this._updaterCommandCharacterisitcUUID,
@@ -270,7 +270,7 @@ export default class Updater {
} else { } else {
console.log("False"); console.log("False");
// send disagree // send disagree
await this.sendEndCmd(false); this.sendEndCmd(false);
progressCallback(`Error, starting over: ${this._fileProgress} / ${this._fileSize}`); progressCallback(`Error, starting over: ${this._fileProgress} / ${this._fileSize}`);
this._fileProgress = 0; this._fileProgress = 0;
} }
@@ -294,7 +294,7 @@ export default class Updater {
const buffer = new ArrayBuffer(4) const buffer = new ArrayBuffer(4)
let view = new Int32Array(buffer); let view = new Int32Array(buffer);
view[0] = this._fileSize; view[0] = this._fileSize;
await this.bleObject.withPromises.write(this.bleDeviceId, this._updaterServiceUUID, this._updaterCommandCharacterisitcUUID, buffer); this.bleObject.withPromises.write(this.bleDeviceId, this._updaterServiceUUID, this._updaterCommandCharacterisitcUUID, buffer);
}); });
} }
} }