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

trying file progress from remote, due to packet loss

Browse Source
This commit is contained in:
chopster44
2025-12-01 20:30:37 +00:00
parent a7d5880057
commit b471d0e20f
1 changed files with 58 additions and 64 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/index.ts
View File

@@ -208,14 +208,11 @@ export default class Updater {
}
private async sendNextPacket(): Promise<boolean> {
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;
return new Promise((resolve, reject) => {
this.bleObject.writeWithoutResponse(this.bleDeviceId, this._updaterServiceUUID, this._updateFileCharacteristicUUID, packet.buffer,
() => {
console.log("Wrote")
console.log(packet.length);
this._fileProgress += packet.length;
resolve(true);
},
(error) => {
@@ -244,19 +241,20 @@ export default class Updater {
// write file length
return new Promise(async (resolve, reject) => {
// set mtu
this.bleObject.requestMtu(this.bleDeviceId, this._packetSize, (mtu: number) => {
this._packetSize = mtu;
this._packetSize = await this.bleObject.withPromises.requestMtu(this.bleDeviceId, this._packetSize);
// start notify
this.bleObject.startNotification(this.bleDeviceId, this._updaterServiceUUID, this._updaterCommandCharacterisitcUUID,
(rawData: ArrayBuffer): void => {
let dataView = new Uint8Array(rawData);
console.log(dataView);
if (dataView[0] == 1) {
// send file
this.sendNextPacket();
progressCallback(`MTU: ${this._packetSize}; Sending (${Math.floor((this._fileProgress * 100) / this._fileSize)}%), ${this._fileProgress} / ${this._fileSize}`);
progressCallback(`MTU: ${this._packetSize}; Sending (${Math.floor((this._fileProgress *100)/this._fileSize)}%), ${this._fileProgress} / ${this._fileSize}`);
} else if (dataView[0] == 2) {
// done logic
console.log(`progress >= filesize: ${this._fileProgress} vs ${this._fileSize}`);
if (this._fileProgress >= this._fileSize) {
if (this._fileProgress >= (this._fileSize - this._packetSize)) {
console.log("true");
// send agree
this.sendEndCmd(true);
@@ -287,12 +285,12 @@ export default class Updater {
progressCallback(`Board is on`);
}
else {
// no command
progressCallback(`Error on remote`);
reject("Error: command does not exist");
// should be the file progress
let fileProgressView = new Uint32Array(rawData);
this._fileProgress += fileProgressView[0];
this.sendNextPacket();
}
}, (error) => {
reject("Error: Failed to start notify");
}, (error) => { reject("Error: Failed to start notify");
console.error(error);
}
);
@@ -301,10 +299,6 @@ export default class Updater {
view[0] = this._fileSize;
this.bleObject.withPromises.write(this.bleDeviceId, this._updaterServiceUUID, this._updaterCommandCharacterisitcUUID, buffer);
});
// start notify
});
}
}