if this enum type has no constant with the specified name
Re-keys stored conversations onto the current channel set, and records it as the new baseline.
Conversations are keyed by channel index, so a slot that changes occupant shows the previous channel's history under the new channel until this runs. Idempotent: a second call with nothing changed does nothing.
Called explicitly after the handshake because the handshake streams channels in one slot at a time (and its LoRa config arrives as its own write). Reconciling on each of those would see a channel momentarily missing, retire it, and then see it come back.
Re-keys stored conversations onto the current channel set, and records it as the new baseline.
Conversations are keyed by channel index, so a slot that changes occupant shows the previous channel's history under the new channel until this runs. Idempotent: a second call with nothing changed does nothing.
Called explicitly after the handshake because the handshake streams channels in one slot at a time (and its LoRa config arrives as its own write). Reconciling on each of those would see a channel momentarily missing, retire it, and then see it come back.
Places channel's settings at its index, resizing with blank channels to fill any gap (parity with legacy).
Places channel's settings at its index, resizing with blank channels to fill any gap (parity with legacy).
Synchronously cancels the transport-aware handshake watchdog the moment Stage 2 completes (NODE_INFO_NONCE received). Does NOT replicate onNodeDbReady's post-NodeDB side effects (analytics, MQTT start, history replay, telemetry requests) — those remain gated on onNodeDbReady at the end of the async DB install block.
See MeshConnectionManager.onHandshakeComplete for the full rationale.
Synchronously cancels the transport-aware handshake watchdog the moment Stage 2 completes (NODE_INFO_NONCE received). Does NOT replicate onNodeDbReady's post-NodeDB side effects (analytics, MQTT start, history replay, telemetry requests) — those remain gated on onNodeDbReady at the end of the async DB install block.
See MeshConnectionManager.onHandshakeComplete for the full rationale.
Ceiling on entries in the in-memory node index. See NodeIndex.evictedToFit.
An order of magnitude above the largest NodeDB firmware exposes (MAX_NUM_NODES is 100–250 by target), so a legitimately busy mesh never reaches it and only sustained novel-from traffic does.
Ceiling on entries in the in-memory node index. See NodeIndex.evictedToFit.
An order of magnitude above the largest NodeDB firmware exposes (MAX_NUM_NODES is 100–250 by target), so a legitimately busy mesh never reaches it and only sustained novel-from traffic does.
Deletes only local stats telemetry logs for nodeNum, preserving other telemetry types. The bounded keyset scan and atomic deletion remain under one manager-tracked database lease, while protobuf parsing runs on the compute dispatcher.
Deletes only local stats telemetry logs for nodeNum, preserving other telemetry types. The bounded keyset scan and atomic deletion remain under one manager-tracked database lease, while protobuf parsing runs on the compute dispatcher.
Prunes the log database based on the configured retentionDays. The sentinel values are resolved by MeshLogRetention, so "never delete" is a no-op and "1 hour" trims to the last hour rather than scaling the sentinel by days.
Prunes the log database based on the configured retentionDays. The sentinel values are resolved by MeshLogRetention, so "never delete" is a no-op and "1 hour" trims to the last hour rather than scaling the sentinel by days.
Returns the cached MyNodeInfo from the system logs.
Returns the cached MyNodeInfo from the system logs.
Clears the local node's connection info.
Clears the local node's connection info.
Deletes all nodes from the database, optionally preserving favorites.
Deletes all nodes from the database, optionally preserving favorites.
Deletes a node and its metadata by num.
Deletes a node and its metadata by num.
Deletes multiple nodes and their metadata.
Deletes multiple nodes and their metadata.
Persists hardware metadata for a node.
Persists hardware metadata for a node.
Installs initial configuration data (local info and remote nodes) into the database.
Installs initial configuration data (local info and remote nodes) into the database.
Flow emitting the count of nodes currently considered "online".
Flow emitting the count of nodes currently considered "online".
Flow emitting the total number of nodes in the database.
Flow emitting the total number of nodes in the database.
Backfills longName and shortName columns from the user protobuf for nodes where these columns are NULL. This ensures search functionality works for all nodes. Skips placeholder/default users (hwModel == UNSET).
Backfills longName and shortName columns from the user protobuf for nodes where these columns are NULL. This ensures search functionality works for all nodes. Skips placeholder/default users (hwModel == UNSET).
Atomically deletes one node and its separately stored device metadata.
Atomically deletes one node and its separately stored device metadata.
Atomically deletes nodes and their metadata, chunking both IN queries below SQLite's bind-parameter limit. Every chunk participates in the same transaction, so cancellation or a query failure rolls back the whole batch.
Atomically deletes nodes and their metadata, chunking both IN queries below SQLite's bind-parameter limit. Every chunk participates in the same transaction, so cancellation or a query failure rolls back the whole batch.
Snapshot used by DatabaseMerger to carry per-node DeviceMetadata across transports (newest timestamp wins).
Snapshot used by DatabaseMerger to carry per-node DeviceMetadata across transports (newest timestamp wins).
Installs the config download from the connected device, reconciling any node-number change of the device itself (firmware 2.8 renumber, erase-and-reflash, manual re-key) before the new my_node row lands.
node numbers whose rows were removed by identity migration, so callers can evict them from in-memory caches.
Installs the config download from the connected device, reconciling any node-number change of the device itself (firmware 2.8 renumber, erase-and-reflash, manual re-key) before the new my_node row lands.
node numbers whose rows were removed by identity migration, so callers can evict them from in-memory caches.
Clears the unheard flag on every node. Called when the connected firmware cannot report NodeInfo.heard_on_current_lora, so a value written by a radio that could does not outlive it and leave nodes shown as unreachable. Normalizing in the database rather than in memory keeps every reader correct, including the repository-backed flows the node list renders from.
Clears the unheard flag on every node. Called when the connected firmware cannot report NodeInfo.heard_on_current_lora, so a value written by a radio that could does not outlive it and leave nodes shown as unreachable. Normalizing in the database rather than in memory keeps every reader correct, including the repository-backed flows the node list renders from.
One-shot snapshot of every node row in the CURRENTLY SELECTED database (not the process-wide stateIn cache). Used by session-safe cache loads (see NodeManagerImpl.loadCachedNodeDB) so a transport switch can't deliver a stale pre-switch map.
One-shot snapshot of every node row in the CURRENTLY SELECTED database (not the process-wide stateIn cache). Used by session-safe cache loads (see NodeManagerImpl.loadCachedNodeDB) so a transport switch can't deliver a stale pre-switch map.
Contact keys are "$channel$userId", so a suffix match rewrites just the DM threads of one node.
Contact keys are "$channel$userId", so a suffix match rewrites just the DM threads of one node.
Re-scopes stored messages from one owning node number to another (see Packet.myNodeNum).
Re-scopes stored messages from one owning node number to another (see Packet.myNodeNum).
OR IGNORE: myNodeNum is part of the reactions PK; drop the rare duplicate instead of aborting.
OR IGNORE: myNodeNum is part of the reactions PK; drop the rare duplicate instead of aborting.
Sets a single power-channel label (0-based channelIndex) atomically: the read-modify-write runs inside a transaction that reads the current labels from the DB, so concurrent edits to different channels can't clobber each other via a stale read. Earlier channels keep their slot (blank padding); trailing blanks are dropped.
Reads via getNodeByNum rather than a scalar SELECT power_channel_labels: Room reads a List<String> query result as one String per row (returning the raw JSON text), not as the column's converted List<String>.
Sets a single power-channel label (0-based channelIndex) atomically: the read-modify-write runs inside a transaction that reads the current labels from the DB, so concurrent edits to different channels can't clobber each other via a stale read. Earlier channels keep their slot (blank padding); trailing blanks are dropped.
Reads via getNodeByNum rather than a scalar SELECT power_channel_labels: Room reads a List<String> query result as one String per row (returning the raw JSON text), not as the column's converted List<String>.
Represents a log entry in the database.
Logs are used for auditing radio traffic, telemetry history, and debugging.
Represents a log entry in the database.
Logs are used for auditing radio traffic, telemetry history, and debugging.
True when the radio has heard this node over RF on the LoRa configuration it is using now (NodeInfo.heard_on_current_lora). The radio derives this from the slot each node was heard on rather than clearing it on a config change, so returning to a configuration restores the previous answers. Defaults true so nodes stored before this column existed, and nodes from firmware that does not report it, are never shown as unheard.
True when the radio has heard this node over RF on the LoRa configuration it is using now (NodeInfo.heard_on_current_lora). The radio derives this from the slot each node was heard on rather than clearing it on a config change, so returning to a configuration restores the previous answers. Defaults true so nodes stored before this column existed, and nodes from firmware that does not report it, are never shown as unheard.
False once a different public key has arrived for a node one is already stored for.
The stored key stands (first-wins) and this records the refusal, matching firmware — which drops the whole NodeInfo on a key mismatch rather than overwriting — and Meshtastic-Apple. Overwriting the trusted key instead would let any mesh or MQTT peer destroy it by broadcasting a NodeInfo under that node's number.
Defaults true so rows written before this column existed are not read as mismatched; those rows record a mismatch the old way, as ERROR_BYTE_STRING in publicKey.
False once a different public key has arrived for a node one is already stored for.
The stored key stands (first-wins) and this records the refusal, matching firmware — which drops the whole NodeInfo on a key mismatch rather than overwriting — and Meshtastic-Apple. Overwriting the trusted key instead would let any mesh or MQTT peer destroy it by broadcasting a NodeInfo under that node's number.
Defaults true so rows written before this column existed are not read as mismatched; those rows record a mismatch the old way, as ERROR_BYTE_STRING in publicKey.
The transport mechanism this node was last heard over (see MeshPacket.TransportMechanism).
The transport mechanism this node was last heard over (see MeshPacket.TransportMechanism).
The key that was refused, kept so the mismatch can be shown as more than a warning.
Null whenever keyMatch is true. Rows that recorded a mismatch the old way, as ERROR_BYTE_STRING in publicKey, have no rejected key to report and stay null.
The key that was refused, kept so the mismatch can be shown as more than a warning.
Null whenever keyMatch is true. Rows that recorded a mismatch the old way, as ERROR_BYTE_STRING in publicKey, have no rejected key to report and stay null.
True when this node signs its broadcasts via XEdDSA (NodeInfo.has_xeddsa_signed).
True when this node signs its broadcasts via XEdDSA (NodeInfo.has_xeddsa_signed).
Discovery scans capture the radio's pre-scan primary channel to restore after a custom-channel target.
Discovery scans capture the radio's pre-scan primary channel to restore after a custom-channel target.
Discovery scans capture the radio's pre-scan LoRa config so an interrupted scan can restore it later.
Discovery scans capture the radio's pre-scan LoRa config so an interrupted scan can restore it later.
Returns a representation of an immutable list of all enum entries, in the order they're declared.
This method may be used to iterate over the enum entries.
Returns a representation of an immutable list of all enum entries, in the order they're declared.
This method may be used to iterate over the enum entries.
How a received Mesh Beacon invitation can be joined, given the connected radio's current settings.
How a received Mesh Beacon invitation can be joined, given the connected radio's current settings.
Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)
if this enum type has no constant with the specified name
Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)
if this enum type has no constant with the specified name
Returns an array containing the constants of this enum type, in the order they're declared.
This method may be used to iterate over the constants.
Returns an array containing the constants of this enum type, in the order they're declared.
This method may be used to iterate over the constants.
Hex characters of the identity digest kept in a retired contact key.
64 bits rather than the 32 that eight slots would need: a collision would silently merge two archived conversations, and the key format is not released yet, so widening it now costs nothing and never has to be migrated later.
Hex characters of the identity digest kept in a retired contact key.
64 bits rather than the 32 that eight slots would need: a collision would silently merge two archived conversations, and the key format is not released yet, so widening it now costs nothing and never has to be migrated later.
Semantic channel identity based on the effective name and effective PSK.
Semantic channel identity based on the effective name and effective PSK.
Stable opaque token for this identity, used to key a retired conversation (see ContactKey).
Deliberately one-way and truncated: a contact key reaches logs and deep links, so it must never carry a PSK or be reversible into one. The name length is prefixed so ("ab", "c") and ("a", "bc") cannot collide.
Stable opaque token for this identity, used to key a retired conversation (see ContactKey).
Deliberately one-way and truncated: a contact key reaches logs and deep links, so it must never carry a PSK or be reversible into one. The name length is prefixed so ("ab", "c") and ("a", "bc") cannot collide.
Decides whether a beacon can be joined by simply adding its channel (no reboot) or requires a switch (retune + reboot). Adding works only when the offered mesh sits on the radio's current frequency slot — Meshtastic secondary channels ride the primary channel's frequency, so the offered channel must resolve (name-hash) to the same slot the radio's primary is on, under a matching preset and region. Mirrors the Apple 014-mesh-beacons FR-016/FR-017 logic.
The radio's current LoRaConfig (null → can't reason, so SWITCH).
The radio's current channel settings, index 0 = primary.
Decides whether a beacon can be joined by simply adding its channel (no reboot) or requires a switch (retune + reboot). Adding works only when the offered mesh sits on the radio's current frequency slot — Meshtastic secondary channels ride the primary channel's frequency, so the offered channel must resolve (name-hash) to the same slot the radio's primary is on, under a matching preset and region. Mirrors the Apple 014-mesh-beacons FR-016/FR-017 logic.
The radio's current LoRaConfig (null → can't reason, so SWITCH).
The radio's current channel settings, index 0 = primary.
Resolves this setting's semantic identity under loraConfig.
Resolves this setting's semantic identity under loraConfig.
Compares two User objects and returns a string detailing the differences.
Compares two User objects and returns a string detailing the differences.
Return a URL that represents the ChannelSet
portions of the URL can be upper case to make for more efficient QR codes
Return a URL that represents the ChannelSet
portions of the URL can be upper case to make for more efficient QR codes
Converts a SharedContact to its corresponding URI representation.
Converts a SharedContact to its corresponding URI representation.
True when this is a channel the radio already has configured (design#140 behavior 10). Null currentLora or an empty currentChannels means "can't tell" and returns false, never hiding a still-relevant invitation on missing data. Comparison uses resolved ChannelIdentity (effective name plus expanded PSK) so a blank-name primary or a short-code PSK still matches; differing PSK under an identical name is deliberately not a match, since same name with a different key is a different mesh. Secondary slots are skipped when isChannelPlaceholder (blank name, no PSK): SwitchingChannelSetDataSource pads a gap left by a removed channel with a bare ChannelSettings, and those placeholders are read back unfiltered here, so without this exclusion a beacon offering a genuinely blank/cleartext channel would misclassify a padding slot as a real match. The primary slot (index 0) is never skipped: it always represents a real channel, matching the same convention in normalizeReplacementSettings.
True when this beacon's offered channel is already configured on the radio; see ChannelSettings.isAlreadyJoined.
True when this is a channel the radio already has configured (design#140 behavior 10). Null currentLora or an empty currentChannels means "can't tell" and returns false, never hiding a still-relevant invitation on missing data. Comparison uses resolved ChannelIdentity (effective name plus expanded PSK) so a blank-name primary or a short-code PSK still matches; differing PSK under an identical name is deliberately not a match, since same name with a different key is a different mesh. Secondary slots are skipped when isChannelPlaceholder (blank name, no PSK): SwitchingChannelSetDataSource pads a gap left by a removed channel with a bare ChannelSettings, and those placeholders are read back unfiltered here, so without this exclusion a beacon offering a genuinely blank/cleartext channel would misclassify a padding slot as a real match. The primary slot (index 0) is never skipped: it always represents a real channel, matching the same convention in normalizeReplacementSettings.
True when this beacon's offered channel is already configured on the radio; see ChannelSettings.isAlreadyJoined.
True when these settings carry no name and no PSK, making them padding rather than an intended channel.
True when these settings carry no name and no PSK, making them padding rather than an intended channel.
Normalizes replacement settings so firmware only materializes real, distinct channels.
Slot zero is preserved as-is. Blank placeholder secondaries and semantic duplicates under loraConfig are removed, and the remaining secondaries compact into sequential slots.
Normalizes replacement settings so firmware only materializes real, distinct channels.
Slot zero is preserved as-is. Blank placeholder secondaries and semantic duplicates under loraConfig are removed, and the remaining secondaries compact into sequential slots.
Builds the ChannelSet to hand the QR channel-import dialog for a given option.
ADD omits lora_config so the dialog merges the offered channel into a free secondary slot with no reboot. SWITCH carries a fresh lora_config (not a copy of currentLora) with use_preset = true, the advertised preset+region applied, and every RF field left at its default — notably channel_num/override_frequency zeroed so firmware re-derives the frequency from the offered channel name (Apple FR-006). Starting blank guarantees no stale slot/frequency pin (channel_num, override_frequency, manual bandwidth/spread_factor/coding_rate) from the old mesh survives the retune. Only region is carried from currentLora when the beacon doesn't advertise one — this config is sent as a full LoRaConfig replacement, and a zero region disables transmit; hop_limit/tx_enabled fall back to the app's standard defaults. Returns null for NONE or a beacon with no offered channel.
Both paths strip position sharing from the offered channel (withoutPositionSharing) so joining a stranger's mesh never leaks our location — matching Apple's joinBeaconMesh/addBeaconChannel.
The radio's current LoRaConfig; a switch reuses only its region/preset as fallbacks.
Builds the ChannelSet to hand the QR channel-import dialog for a given option.
ADD omits lora_config so the dialog merges the offered channel into a free secondary slot with no reboot. SWITCH carries a fresh lora_config (not a copy of currentLora) with use_preset = true, the advertised preset+region applied, and every RF field left at its default — notably channel_num/override_frequency zeroed so firmware re-derives the frequency from the offered channel name (Apple FR-006). Starting blank guarantees no stale slot/frequency pin (channel_num, override_frequency, manual bandwidth/spread_factor/coding_rate) from the old mesh survives the retune. Only region is carried from currentLora when the beacon doesn't advertise one — this config is sent as a full LoRaConfig replacement, and a zero region disables transmit; hop_limit/tx_enabled fall back to the app's standard defaults. Returns null for NONE or a beacon with no offered channel.
Both paths strip position sharing from the offered channel (withoutPositionSharing) so joining a stranger's mesh never leaks our location — matching Apple's joinBeaconMesh/addBeaconChannel.
The radio's current LoRaConfig; a switch reuses only its region/preset as fallbacks.
Bridge extension for Android clients.
The SharedContact to encode for node.
isOwnContact marks it manually verified (design#149 point 2): you hold your own radio's key, and a QR shown in person is the in-person exchange. Relaying someone else's contact only passes on what was already recorded, it never asserts verification on their behalf.
Return a SharedContact that represents the contact encoded by the URL.
when not recognized as a valid Meshtastic URL
Bridge extension for Android clients.
The SharedContact to encode for node.
isOwnContact marks it manually verified (design#149 point 2): you hold your own radio's key, and a QR shown in person is the in-person exchange. Relaying someone else's contact only passes on what was already recorded, it never asserts verification on their behalf.
Return a SharedContact that represents the contact encoded by the URL.
when not recognized as a valid Meshtastic URL
Converts a User object to a string representation of its fields and values.
Converts a User object to a string representation of its fields and values.
Represents a log entry in shared repository/domain code.
Logs are used for auditing radio traffic, telemetry history, and debugging.
Represents a log entry in shared repository/domain code.
Logs are used for auditing radio traffic, telemetry history, and debugging.
Domain model representing a node in the mesh network.
This class aggregates user information, position data, and hardware metrics.
Domain model representing a node in the mesh network.
This class aggregates user information, position data, and hardware metrics.
Returns a representation of an immutable list of all enum entries, in the order they're declared.
This method may be used to iterate over the enum entries.
Returns a representation of an immutable list of all enum entries, in the order they're declared.
This method may be used to iterate over the enum entries.
Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)
if this enum type has no constant with the specified name
Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)
if this enum type has no constant with the specified name
Returns an array containing the constants of this enum type, in the order they're declared.
This method may be used to iterate over the constants.
Returns an array containing the constants of this enum type, in the order they're declared.
This method may be used to iterate over the constants.
Domain model representing a node in the mesh network.
Domain model representing a node in the mesh network.
Matches node search text (long/short name, hex id, decimal id) with Unicode-aware case folding.
Must run in Kotlin, not SQL: SQLite's LIKE/UPPER/LOWER only case-fold ASCII a-z/A-Z, so a query like "kolså" can never match a stored name of "KOLSÅS" via a SQL WHERE clause (#6750).
Matches node search text (long/short name, hex id, decimal id) with Unicode-aware case folding.
Must run in Kotlin, not SQL: SQLite's LIKE/UPPER/LOWER only case-fold ASCII a-z/A-Z, so a query like "kolså" can never match a stored name of "KOLSÅS" via a SQL WHERE clause (#6750).
A simulated radio, selected as "Demo Mode" in the Connections screen.
It answers the app's real two-stage want_config handshake and then feeds a small synthetic mesh — a populated node list with positions, signal readings and battery levels, one channel conversation, one direct-message thread, and telemetry that keeps accruing while the app is open. That makes the app fully explorable without any LoRa hardware, which is what an app-store reviewer and a first-time user both need.
Three properties of the real protocol have to be honoured or the app never leaves "Loading node list":
The handshake is two-stage (HandshakeConstants.CONFIG_NONCE then HandshakeConstants.NODE_INFO_NONCE). Each stage must answer with only its own frames and its own config_complete_id. Re-sending my_info on stage 2 resets the app's handshake state machine and the stage-2 completion is then rejected.
node_info frames are only accepted inside the handshake window, so every simulated node has to ship in stage 2.
Radio metrics (SNR/RSSI/hops) are only taken from packets that look like direct LoRa receptions — transport_mechanism = TRANSPORT_LORA and hop_start == hop_limit. Frames left at the proto defaults are treated as internal traffic and contribute no signal information at all.
A simulated radio, selected as "Demo Mode" in the Connections screen.
It answers the app's real two-stage want_config handshake and then feeds a small synthetic mesh — a populated node list with positions, signal readings and battery levels, one channel conversation, one direct-message thread, and telemetry that keeps accruing while the app is open. That makes the app fully explorable without any LoRa hardware, which is what an app-store reviewer and a first-time user both need.
Three properties of the real protocol have to be honoured or the app never leaves "Loading node list":
The handshake is two-stage (HandshakeConstants.CONFIG_NONCE then HandshakeConstants.NODE_INFO_NONCE). Each stage must answer with only its own frames and its own config_complete_id. Re-sending my_info on stage 2 resets the app's handshake state machine and the stage-2 completion is then rejected.
node_info frames are only accepted inside the handshake window, so every simulated node has to ship in stage 2.
Radio metrics (SNR/RSSI/hops) are only taken from packets that look like direct LoRa receptions — transport_mechanism = TRANSPORT_LORA and hop_start == hop_limit. Frames left at the proto defaults are treated as internal traffic and contribute no signal information at all.
~10 packets/sec, matching the burningmesh-replay steady-rate rig used for ingestion perf work.
~10 packets/sec, matching the burningmesh-replay steady-rate rig used for ingestion perf work.
true only for CONNACK reason codes where retrying can never help — the broker examined our credentials or client identity and refused them.
A MqttException.ConnectionRejected can still carry a transient broker verdict (SERVER_BUSY, SERVER_UNAVAILABLE, CONNECTION_RATE_EXCEEDED), which must stay in the retry loop rather than stop the proxy with a "check credentials" dialog. Public so MqttManagerImpl in :core:data can phrase its user-facing error from the same classification.
true only for CONNACK reason codes where retrying can never help — the broker examined our credentials or client identity and refused them.
A MqttException.ConnectionRejected can still carry a transient broker verdict (SERVER_BUSY, SERVER_UNAVAILABLE, CONNECTION_RATE_EXCEEDED), which must stay in the retry loop rather than stop the proxy with a "check credentials" dialog. Public so MqttManagerImpl in :core:data can phrase its user-facing error from the same classification.
Resolve a user-supplied broker address into an MqttEndpoint.
Address resolution rules:
If rawAddress already contains a URI scheme (scheme://…), parse it directly via MqttEndpoint.parse and respect whatever transport / port the user encoded.
Otherwise wrap it as a TCP endpoint using standard MQTT ports: port 8883 if tlsEnabled is true, port 1883 otherwise. This allows standard MQTT brokers to work out of the box.
Extracted as a top-level function so MQTTRepositoryImplTest can exercise every branch without spinning up the full repository, and so MqttManagerImpl (in :core:data) can reuse the same parsing rules for the probe API. Visibility is public because Kotlin's internal is scoped per Gradle module.
Resolve a user-supplied broker address into an MqttEndpoint.
Address resolution rules:
If rawAddress already contains a URI scheme (scheme://…), parse it directly via MqttEndpoint.parse and respect whatever transport / port the user encoded.
Otherwise wrap it as a TCP endpoint using standard MQTT ports: port 8883 if tlsEnabled is true, port 1883 otherwise. This allows standard MQTT brokers to work out of the box.
Extracted as a top-level function so MQTTRepositoryImplTest can exercise every branch without spinning up the full repository, and so MqttManagerImpl (in :core:data) can reuse the same parsing rules for the probe API. Visibility is public because Kotlin's internal is scoped per Gradle module.
First heartbeat nonce any sender emits; it sits past 1, the firmware's NodeInfo-ping trigger.
First heartbeat nonce any sender emits; it sits past 1, the firmware's NodeInfo-ping trigger.
Builds the device admin command for setting or removing a fixed position.
Builds the device admin command for setting or removing a fixed position.