feat(remote-shell): PTY-over-mesh terminal with retro-CRT UI

Adds a full RemoteShell (portnum=13) implementation matching Jonathan's
dmshell_client.py protocol:

Protocol layer:
- Seq/ack reliability: incrementing seq on every non-ACK frame, piggybacked
  ack_seq, out-of-order frame buffering, gap detection and replay requests
- TX history ring buffer (last 50 frames) for retransmission on request
- ACK frames carry optional 4-byte big-endian REPLAY_REQUEST payload
- PING/PONG heartbeat with 8-byte status payload (lastTxSeq, lastRxSeq);
  PONG handler triggers replay if peer is behind
- PKI: DataPacket.PKC_CHANNEL_INDEX so CommandSenderImpl applies
  Curve25519 encryption (firmware rejects non-PKI DMShell packets)
- Input batching: 500ms debounce (matches Python client), immediate flush
  on \r, \t, buffer-full (64 bytes), or Enter

Terminal UI:
- Retro-CRT composables: TerminalCanvas (phosphor glow, two-pass bloom),
  ScanlinesOverlay, FlickerEffect (animated brightness variation),
  CrtCurvatureModifier (AGSL barrel distortion on Android 12+, no-op on JVM)
- PhosphorPreset enum: GREEN (P1), AMBER (P3), WHITE (P4)
- Pending-input rendered inline in preset.dim colour; snaps to confirmed on flush
- Hidden zero-size BasicTextField captures soft and hardware keyboard input
- Phosphor colour picker dropdown in top bar

Capabilities gate:
- supportsRemoteShell gated to UNRELEASED (9.9.9)
- Entry only visible in AdministrationSection when node.capabilities.supportsRemoteShell

Author: jamesarich

core/data/src/commonMain/kotlin/org/meshtastic/core/data/manager/MeshDataHandlerImpl.kt

@@ -48,6 +48,7 @@ import org.meshtastic.core.repository.PacketHandler
 import org.meshtastic.core.repository.PacketRepository
 import org.meshtastic.core.repository.PlatformAnalytics
 import org.meshtastic.core.repository.RadioConfigRepository
+import org.meshtastic.core.repository.RemoteShellHandler
 import org.meshtastic.core.repository.ServiceBroadcasts
 import org.meshtastic.core.repository.ServiceRepository
 import org.meshtastic.core.repository.StoreForwardPacketHandler
@@ -96,6 +97,7 @@ class MeshDataHandlerImpl(
     private val storeForwardHandler: StoreForwardPacketHandler,
     private val telemetryHandler: TelemetryPacketHandler,
     private val adminPacketHandler: AdminPacketHandler,
+    private val remoteShellHandler: RemoteShellHandler,
     @Named("ServiceScope") private val scope: CoroutineScope,
 ) : MeshDataHandler {
 
@@ -181,6 +183,12 @@ class MeshDataHandlerImpl(
                 adminPacketHandler.handleAdminMessage(packet, myNodeNum)
             }
 
+            PortNum.REMOTE_SHELL_APP -> {
+                remoteShellHandler.handleRemoteShell(packet)
+                // Do not broadcast — RemoteShell frames are point-to-point PTY I/O
+                shouldBroadcast = false
+            }
+
             PortNum.NEIGHBORINFO_APP -> {
                 neighborInfoHandler.handleNeighborInfo(packet)
                 shouldBroadcast = true

core/data/src/commonMain/kotlin/org/meshtastic/core/data/manager/RemoteShellPacketHandlerImpl.kt

@@ -0,0 +1,55 @@
+/*
+ * Copyright (c) 2025-2026 Meshtastic LLC
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+package org.meshtastic.core.data.manager
+
+import co.touchlab.kermit.Logger
+import kotlinx.coroutines.flow.MutableSharedFlow
+import kotlinx.coroutines.flow.SharedFlow
+import kotlinx.coroutines.flow.asSharedFlow
+import org.koin.core.annotation.Single
+import org.meshtastic.core.model.util.decodeOrNull
+import org.meshtastic.core.repository.ReceivedShellFrame
+import org.meshtastic.core.repository.RemoteShellHandler
+import org.meshtastic.proto.MeshPacket
+import org.meshtastic.proto.RemoteShell
+
+/**
+ * Handles incoming [RemoteShell] packets (REMOTE_SHELL_APP portnum = 13).
+ *
+ * This is a scaffold implementation. The RemoteShell firmware feature is currently unreleased (gated to
+ * [org.meshtastic.core.model.Capabilities.supportsRemoteShell]). When the firmware ships, this handler should be
+ * expanded to manage PTY session state and relay I/O to the UI.
+ */
+@Single
+class RemoteShellPacketHandlerImpl : RemoteShellHandler {
+
+    /**
+     * Emits every received [ReceivedShellFrame] (decoded frame + sender node number).
+     *
+     * Uses [MutableSharedFlow] with a buffer so that rapid or structurally-identical frames are never silently dropped
+     * (unlike `StateFlow` which conflates by equality).
+     */
+    private val _lastFrame = MutableSharedFlow<ReceivedShellFrame>(extraBufferCapacity = 16)
+    override val lastFrame: SharedFlow<ReceivedShellFrame> = _lastFrame.asSharedFlow()
+
+    override fun handleRemoteShell(packet: MeshPacket) {
+        val payload = packet.decoded?.payload ?: return
+        val frame = RemoteShell.ADAPTER.decodeOrNull(payload, Logger) ?: return
+        Logger.d { "RemoteShell frame from ${packet.from}: op=${frame.op} sessionId=${frame.session_id}" }
+        _lastFrame.tryEmit(ReceivedShellFrame(from = packet.from, frame = frame))
+    }
+}

core/model/src/commonMain/kotlin/org/meshtastic/core/model/Capabilities.kt

@@ -34,8 +34,8 @@ data class Capabilities(val firmwareVersion: String?, internal val forceEnableAl
     /** Ability to mute notifications from specific nodes via admin messages. */
     val canMuteNode = atLeast(V2_7_18)
 
-    /** Ability to request neighbor information from other nodes. Gated to [UNRELEASED] until working reliably. */
-    val canRequestNeighborInfo = atLeast(UNRELEASED)
+    /** Ability to request neighbor information from other nodes on demand. Supported since firmware v2.7.15. */
+    val canRequestNeighborInfo = atLeast(V2_7_15)
 
     /** Ability to send verified shared contacts. Supported since firmware v2.7.12. */
     val canSendVerifiedContacts = atLeast(V2_7_12)
@@ -49,11 +49,11 @@ data class Capabilities(val firmwareVersion: String?, internal val forceEnableAl
     /** Support for sharing contact information via QR codes. Supported since firmware v2.6.8. */
     val supportsQrCodeSharing = atLeast(V2_6_8)
 
-    /** Support for Status Message module. Supported since firmware v2.8.0. */
-    val supportsStatusMessage = atLeast(V2_8_0)
+    /** Support for Status Message module. Supported since firmware v2.7.19. */
+    val supportsStatusMessage = atLeast(V2_7_19)
 
-    /** Support for Traffic Management module. Supported since firmware v3.0.0. */
-    val supportsTrafficManagementConfig = atLeast(V3_0_0)
+    /** Support for Traffic Management module. Supported since firmware v2.7.20. */
+    val supportsTrafficManagementConfig = atLeast(V2_7_20)
 
     /** Support for TAK (ATAK) module configuration. Supported since firmware v2.7.19. */
     val supportsTakConfig = atLeast(V2_7_19)
@@ -64,15 +64,27 @@ data class Capabilities(val firmwareVersion: String?, internal val forceEnableAl
     /** Support for ESP32 Unified OTA. Supported since firmware v2.7.18. */
     val supportsEsp32Ota = atLeast(V2_7_18)
 
+    /**
+     * Support for ATAK Plugin V2 (TAKPacketV2 + ATAK_PLUGIN_V2 portnum, zstd dictionary compression). Defined in
+     * protobufs HEAD (post-v2.7.21); gated to [UNRELEASED] until a firmware release ships the AtakPluginV2 module.
+     */
+    val supportsTakV2 = atLeast(UNRELEASED)
+
+    /**
+     * Support for the RemoteShell module (PTY-over-mesh, REMOTE_SHELL_APP portnum). Defined in protobufs HEAD
+     * (post-v2.7.21); gated to [UNRELEASED] until a firmware release ships it.
+     */
+    val supportsRemoteShell = atLeast(UNRELEASED)
+
     companion object {
         private val V2_6_8 = DeviceVersion("2.6.8")
         private val V2_6_9 = DeviceVersion("2.6.9")
         private val V2_6_10 = DeviceVersion("2.6.10")
         private val V2_7_12 = DeviceVersion("2.7.12")
+        private val V2_7_15 = DeviceVersion("2.7.15")
         private val V2_7_18 = DeviceVersion("2.7.18")
         private val V2_7_19 = DeviceVersion("2.7.19")
-        private val V2_8_0 = DeviceVersion("2.8.0")
-        private val V3_0_0 = DeviceVersion("3.0.0")
+        private val V2_7_20 = DeviceVersion("2.7.20")
         private val UNRELEASED = DeviceVersion("9.9.9")
     }
 }

core/model/src/commonTest/kotlin/org/meshtastic/core/model/CapabilitiesTest.kt

@@ -32,9 +32,10 @@ class CapabilitiesTest {
     }
 
     @Test
-    fun canRequestNeighborInfo_is_currently_disabled() {
+    fun canRequestNeighborInfo_requires_V2_7_15() {
         assertFalse(caps("2.7.14").canRequestNeighborInfo)
-        assertFalse(caps("3.0.0").canRequestNeighborInfo)
+        assertTrue(caps("2.7.15").canRequestNeighborInfo)
+        assertTrue(caps("3.0.0").canRequestNeighborInfo)
     }
 
     @Test
@@ -68,14 +69,16 @@ class CapabilitiesTest {
     }
 
     @Test
-    fun supportsStatusMessage_requires_V2_8_0() {
-        assertFalse(caps("2.7.21").supportsStatusMessage)
+    fun supportsStatusMessage_requires_V2_7_19() {
+        assertFalse(caps("2.7.18").supportsStatusMessage)
+        assertTrue(caps("2.7.19").supportsStatusMessage)
         assertTrue(caps("2.8.0").supportsStatusMessage)
     }
 
     @Test
-    fun supportsTrafficManagementConfig_requires_V3_0_0() {
-        assertFalse(caps("2.7.18").supportsTrafficManagementConfig)
+    fun supportsTrafficManagementConfig_requires_V2_7_20() {
+        assertFalse(caps("2.7.19").supportsTrafficManagementConfig)
+        assertTrue(caps("2.7.20").supportsTrafficManagementConfig)
         assertTrue(caps("3.0.0").supportsTrafficManagementConfig)
     }
 
@@ -85,6 +88,18 @@ class CapabilitiesTest {
         assertTrue(caps("2.7.19").supportsTakConfig)
     }
 
+    @Test
+    fun supportsTakV2_is_currently_unreleased() {
+        assertFalse(caps("2.7.22").supportsTakV2)
+        assertFalse(caps("3.0.0").supportsTakV2)
+    }
+
+    @Test
+    fun supportsRemoteShell_is_currently_unreleased() {
+        assertFalse(caps("2.7.22").supportsRemoteShell)
+        assertFalse(caps("3.0.0").supportsRemoteShell)
+    }
+
     @Test
     fun supportsEsp32Ota_requires_V2_7_18() {
         assertFalse(caps("2.7.17").supportsEsp32Ota)
@@ -104,6 +119,8 @@ class CapabilitiesTest {
         assertFalse(c.supportsStatusMessage)
         assertFalse(c.supportsTrafficManagementConfig)
         assertFalse(c.supportsTakConfig)
+        assertFalse(c.supportsTakV2)
+        assertFalse(c.supportsRemoteShell)
         assertFalse(c.supportsEsp32Ota)
     }
 
@@ -115,5 +132,7 @@ class CapabilitiesTest {
         assertTrue(c.supportsStatusMessage)
         assertTrue(c.supportsTrafficManagementConfig)
         assertTrue(c.supportsTakConfig)
+        assertTrue(c.supportsTakV2)
+        assertTrue(c.supportsRemoteShell)
     }
 }

core/navigation/src/commonMain/kotlin/org/meshtastic/core/navigation/Routes.kt

@@ -92,6 +92,8 @@ sealed interface NodeDetailRoute : Route {
     @Serializable data class PaxMetrics(val destNum: Int) : NodeDetailRoute
 
     @Serializable data class NeighborInfoLog(val destNum: Int) : NodeDetailRoute
+
+    @Serializable data class RemoteShell(val destNum: Int) : NodeDetailRoute
 }
 
 @Serializable

core/repository/src/commonMain/kotlin/org/meshtastic/core/repository/RemoteShellHandler.kt

@@ -0,0 +1,54 @@
+/*
+ * Copyright (c) 2025-2026 Meshtastic LLC
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+package org.meshtastic.core.repository
+
+import kotlinx.coroutines.flow.SharedFlow
+import org.meshtastic.proto.MeshPacket
+import org.meshtastic.proto.RemoteShell
+
+/**
+ * A decoded [RemoteShell] frame together with the node number that sent it.
+ *
+ * Propagating [from] allows downstream consumers (e.g. the ViewModel) to verify that a frame
+ * actually originated from the expected peer rather than relying solely on [RemoteShell.session_id].
+ */
+data class ReceivedShellFrame(
+    val from: Int,
+    val frame: RemoteShell,
+)
+
+/**
+ * Interface for handling RemoteShell packets (REMOTE_SHELL_APP portnum = 13).
+ *
+ * RemoteShell is a PTY-over-mesh feature that relays a shell session across the mesh network. The firmware-side
+ * implementation is currently unreleased (gated to [Capabilities.supportsRemoteShell]).
+ */
+interface RemoteShellHandler {
+    /**
+     * The most recently received [ReceivedShellFrame], emitted to collectors.
+     *
+     * Uses [SharedFlow] (not `StateFlow`) so that rapid or identical frames are never silently dropped.
+     */
+    val lastFrame: SharedFlow<ReceivedShellFrame>
+
+    /**
+     * Processes an incoming RemoteShell packet.
+     *
+     * @param packet The received mesh packet carrying a [RemoteShell] payload.
+     */
+    fun handleRemoteShell(packet: MeshPacket)
+}

core/resources/src/commonMain/composeResources/values/strings.xml

@@ -843,6 +843,8 @@
     <string name="modules_unlocked">Modules unlocked</string>
     <string name="modules_already_unlocked">Modules already unlocked</string>
     <string name="remote">Remote</string>
+    <string name="remote_shell">Remote Shell</string>
+    <string name="phosphor_colour">Phosphor colour</string>
     <string name="node_count_template">(%1$d online / %2$d shown / %3$d total)</string>
     <string name="react">React</string>
     <string name="disconnect">Disconnect</string>

feature/node/src/androidMain/kotlin/org/meshtastic/feature/node/metrics/terminal/CrtCurvatureModifier.kt

@@ -0,0 +1,70 @@
+/*
+ * Copyright (c) 2025-2026 Meshtastic LLC
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+package org.meshtastic.feature.node.metrics.terminal
+
+import android.graphics.RenderEffect
+import android.graphics.RuntimeShader
+import android.os.Build
+import androidx.compose.runtime.Composable
+import androidx.compose.runtime.remember
+import androidx.compose.ui.Modifier
+import androidx.compose.ui.graphics.asComposeRenderEffect
+import androidx.compose.ui.graphics.graphicsLayer
+
+/**
+ * AGSL barrel-distortion shader that simulates the curved screen of a CRT monitor.
+ *
+ * The UV coordinates are shifted from [0,1] into [-0.5, 0.5], squared, scaled by [strength], then used to warp the
+ * sample position — producing the classic pincushion/barrel look.
+ *
+ * Only applied on Android 12+ (API 31+); older devices get the no-op pass-through.
+ */
+@Suppress("MagicNumber")
+private val CRT_AGSL =
+    """
+    uniform shader image;
+    uniform float2 resolution;
+    uniform float strength;
+
+    half4 main(float2 fragCoord) {
+        float2 uv = fragCoord / resolution;
+        // Centre UV on (0,0)
+        float2 c = uv - 0.5;
+        // Barrel distortion — shift by c^2 * strength
+        float2 distorted = uv + c * dot(c, c) * strength;
+        // Clamp to avoid edge bleeding
+        distorted = clamp(distorted, float2(0.0, 0.0), float2(1.0, 1.0));
+        return image.eval(distorted * resolution);
+    }
+    """
+        .trimIndent()
+
+@Composable
+actual fun Modifier.crtCurvature(strength: Float): Modifier = if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.S) {
+    val shader = remember { RuntimeShader(CRT_AGSL) }
+    graphicsLayer {
+        val w = size.width
+        val h = size.height
+        if (w > 0f && h > 0f) {
+            shader.setFloatUniform("resolution", w, h)
+            shader.setFloatUniform("strength", strength * 4f) // scale for visible effect
+            renderEffect = RenderEffect.createRuntimeShaderEffect(shader, "image").asComposeRenderEffect()
+        }
+    }
+} else {
+    this
+}

feature/node/src/commonMain/kotlin/org/meshtastic/feature/node/component/AdministrationSection.kt

@@ -22,20 +22,24 @@ import androidx.compose.runtime.Composable
 import androidx.compose.ui.Modifier
 import androidx.compose.ui.graphics.Color
 import org.jetbrains.compose.resources.stringResource
+import org.jetbrains.compose.resources.vectorResource
 import org.meshtastic.core.database.entity.FirmwareRelease
 import org.meshtastic.core.database.entity.asDeviceVersion
 import org.meshtastic.core.model.DeviceVersion
 import org.meshtastic.core.model.Node
 import org.meshtastic.core.model.service.ServiceAction
+import org.meshtastic.core.navigation.NodeDetailRoute
 import org.meshtastic.core.navigation.SettingsRoute
 import org.meshtastic.core.resources.Res
 import org.meshtastic.core.resources.administration
 import org.meshtastic.core.resources.firmware
 import org.meshtastic.core.resources.firmware_edition
+import org.meshtastic.core.resources.ic_terminal
 import org.meshtastic.core.resources.installed_firmware_version
 import org.meshtastic.core.resources.latest_alpha_firmware
 import org.meshtastic.core.resources.latest_stable_firmware
 import org.meshtastic.core.resources.remote_admin
+import org.meshtastic.core.resources.remote_shell
 import org.meshtastic.core.resources.request_metadata
 import org.meshtastic.core.ui.component.ListItem
 import org.meshtastic.core.ui.icon.ForkLeft
@@ -79,6 +83,17 @@ fun AdministrationSection(
             ) {
                 onAction(NodeDetailAction.Navigate(SettingsRoute.Settings(node.num)))
             }
+
+            if (node.capabilities.supportsRemoteShell) {
+                SectionDivider()
+
+                ListItem(
+                    text = stringResource(Res.string.remote_shell),
+                    leadingIcon = vectorResource(Res.drawable.ic_terminal),
+                ) {
+                    onAction(NodeDetailAction.Navigate(NodeDetailRoute.RemoteShell(node.num)))
+                }
+            }
         }
     }