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

Add device protocol version tracking and error frame handling

Browse source 
Port from meshcore-open: parse protocol version from byte 1 of device
info frame, expose supportsFloodScope getter (version >= 8), handle
respCodeErr frames with debug logging. Reset on disconnect.

Co-authored-by: Cursor <cursoragent@cursor.com>
(cherry picked from commit a29bb9cdd7a02a85af26d94dd3c787cabd124629)
This commit is contained in:
Specter242 2026-02-18 04:06:45 -05:00
parent 5f2312e086
commit 1dc90d0e89
1 changed files with 21 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

22
lib/connector/meshcore_connector.dart
View file

@ -105,6 +105,8 @@ class MeshCoreConnector extends ChangeNotifier {
static const int _defaultMaxChannels = 8;
int _maxContacts = _defaultMaxContacts;
int _maxChannels = _defaultMaxChannels;
int? _deviceProtocolVersion;
String? _activeFloodScopeTag;
bool _isSyncingQueuedMessages = false;
bool _queuedMessageSyncInFlight = false;
bool _didInitialQueueSync = false;
@ -208,6 +210,8 @@ class MeshCoreConnector extends ChangeNotifier {
int? get batteryMillivolts => _batteryMillivolts;
int get maxContacts => _maxContacts;
int get maxChannels => _maxChannels;
int? get deviceProtocolVersion => _deviceProtocolVersion;
bool get supportsFloodScope => (_deviceProtocolVersion ?? 0) >= 8;
bool get isSyncingQueuedMessages => _isSyncingQueuedMessages;
bool get isSyncingChannels => _isSyncingChannels;
int get channelSyncProgress =>
@ -927,6 +931,8 @@ class MeshCoreConnector extends ChangeNotifier {
_awaitingSelfInfo = false;
_maxContacts = _defaultMaxContacts;
_maxChannels = _defaultMaxChannels;
_deviceProtocolVersion = null;
_activeFloodScopeTag = null;
_isSyncingQueuedMessages = false;
_queuedMessageSyncInFlight = false;
_didInitialQueueSync = false;
@ -1753,11 +1759,23 @@ class MeshCoreConnector extends ChangeNotifier {
break;
case respCodeCustomVars:
_handleCustomVars(frame);
break;
case respCodeErr:
_handleErrorFrame(frame);
break;
default:
debugPrint('Unknown frame code: $code');
}
}
void _handleErrorFrame(Uint8List frame) {
final errCode = frame.length > 1 ? frame[1] : -1;
_appDebugLogService?.warn(
'Firmware responded with error code: $errCode',
tag: 'Protocol',
);
}
void _handlePathUpdated(Uint8List frame) {
// Frame format: [0]=code, [1-32]=pub_key
if (frame.length >= 33 && _pathHistoryService != null) {
@ -1827,12 +1845,12 @@ class MeshCoreConnector extends ChangeNotifier {
void _handleDeviceInfo(Uint8List frame) {
if (frame.length < 4) return;
_firmwareVerCode = frame[1];
_deviceProtocolVersion = frame[1];
// Parse client_repeat from firmware v9+ (byte 80)
if (frame.length >= 81) {
_clientRepeat = frame[80] != 0;
}
// Firmware reports MAX_CONTACTS / 2 for v3+ device info.
final reportedContacts = frame[2];
final reportedChannels = frame[3];
@ -3240,6 +3258,8 @@ class MeshCoreConnector extends ChangeNotifier {
// They're only cleared on manual disconnect via disconnect() method
_maxContacts = _defaultMaxContacts;
_maxChannels = _defaultMaxChannels;
_deviceProtocolVersion = null;
_activeFloodScopeTag = null;
_isSyncingQueuedMessages = false;
_queuedMessageSyncInFlight = false;
_isSyncingChannels = false;