feat: connect over ssh and render shells in native terminal views

.github/workflows/ci.yml

@@ -28,6 +28,52 @@ jobs:
       - run: cargo clippy --all-targets -- -D warnings
       - run: cargo test
 
+  rust-integration:
+    name: Rust integration
+    runs-on: ubuntu-latest
+    defaults:
+      run:
+        working-directory: rust
+    steps:
+      - uses: actions/checkout@v4
+      - uses: dtolnay/rust-toolchain@stable
+      - uses: Swatinem/rust-cache@v2
+        with:
+          workspaces: rust
+
+      - name: Build the SSH test server
+        run: docker build -t ssh-core-test -f ssh-core/tests/docker/Dockerfile ssh-core/tests
+
+      - name: Start the SSH test servers
+        run: |
+          docker run -d --name ssh-core-password -p 2222:2222 ssh-core-test password
+          docker run -d --name ssh-core-twofactor -p 2223:2222 ssh-core-test two-factor
+          docker run -d --name ssh-core-silent -p 2224:2222 ssh-core-test silent
+          for port in 2222 2223 2224; do
+            for attempt in $(seq 1 30); do
+              if (exec 3<>"/dev/tcp/127.0.0.1/$port") 2>/dev/null; then break; fi
+              sleep 1
+            done
+          done
+
+      - name: Run the integration suite
+        env:
+          SSH_TEST_HOST: 127.0.0.1
+        run: cargo test --test integration
+
+      - name: Show the server logs on failure
+        if: failure()
+        run: |
+          for name in ssh-core-password ssh-core-twofactor ssh-core-silent; do
+            echo "== $name"
+            docker logs "$name" || true
+          done
+
+      - name: Stop the SSH test servers
+        if: always()
+        run: docker rm -f ssh-core-password ssh-core-twofactor ssh-core-silent
+
+
   android:
     name: Android
     runs-on: ubuntu-latest
@@ -154,5 +200,7 @@ jobs:
             -configuration Debug \
             -sdk iphonesimulator \
             -destination 'generic/platform=iOS Simulator' \
+            ARCHS=arm64 \
+            ONLY_ACTIVE_ARCH=YES \
             CODE_SIGNING_ALLOWED=NO \
             build

README.md

@@ -45,6 +45,17 @@ npx expo prebuild --platform android
 npx expo run:android
 ```
 
+## Terminal input
+
+Shell input and resize requests share one ordered queue. Shutdown stops accepting
+new input immediately, and remote closure stops the writer. A closed channel
+returns `ChannelClosed`; transport failures and writes through a closed or
+unbound Android terminal are reported through `onClosed` with an error message.
+
+The SSH integration tests run only when `SSH_TEST_HOST` is set. The
+`shell_preserves_rapid_single_byte_writes` test sends 16,384 individual writes,
+interleaves resizes, and compares the remote file byte for byte.
+
 ## License
 
 Apache-2.0. See [LICENSE](./LICENSE).

THIRD_PARTY_NOTICES.md

@@ -0,0 +1,18 @@
+# Third-party notices
+
+## Termux terminal-emulator and terminal-view
+
+`android/src/main/java/com/termux/**` and `android/src/main/res/{drawable,values}` contain source
+files copied from [termux/termux-app](https://github.com/termux/termux-app) tag `v0.118.0`
+(`terminal-emulator` and `terminal-view` modules), which are published under the Apache License 2.0
+as an exception to the repository's GPLv3 license. See the upstream `LICENSE.md`.
+
+Local changes: `TerminalSession` exchanges bytes through a `TerminalTransport` instead of spawning a
+local pty through JNI, `TerminalView` gained `getSelectedText()` and `setSelectionColor()`,
+`TerminalRenderer` paints a configurable selection background, and the two `textselection` files
+import this library's `R`.
+
+## SwiftTerm
+
+The iOS terminal view is built on [SwiftTerm](https://github.com/migueldeicaza/SwiftTerm)
+(`exactVersion 1.10.1`), MIT licensed.

android/build.gradle

@@ -20,4 +20,8 @@ android {
 dependencies {
   // The uniffi Kotlin bindings call into libssh_core.so through JNA direct mapping.
   implementation 'net.java.dev.jna:jna:5.17.0@aar'
+  // The bindings expose async functions and callback interfaces as coroutines.
+  implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.10.2'
+  implementation 'androidx.annotation:annotation:1.9.0'
+  implementation 'com.facebook.react:react-android'
 }

android/src/main/java/ai/kilo/reactnativessh/IdSequence.kt

@@ -0,0 +1,10 @@
+package ai.kilo.reactnativessh
+
+import java.util.concurrent.atomic.AtomicLong
+
+/** Process-local identifiers for sessions, shells and prompt requests. */
+internal class IdSequence(private val prefix: String) {
+  private val counter = AtomicLong()
+
+  fun next(): String = "$prefix${counter.incrementAndGet()}"
+}

android/src/main/java/ai/kilo/reactnativessh/JsSessionHandler.kt

@@ -0,0 +1,56 @@
+package ai.kilo.reactnativessh
+
+import ai.kilo.reactnativessh.uniffi.Prompt
+import ai.kilo.reactnativessh.uniffi.SessionHandler
+
+/**
+ * Bridges the core's session decisions to JavaScript events.
+ *
+ * Each request is registered before the event is emitted and removed as soon
+ * as the decision arrives, so `answerHostKey`/`answerPrompts` never see a stale
+ * id and a dropped connection releases the pending wait.
+ */
+internal class JsSessionHandler(
+  private val sessionId: String,
+  private val requestHostKey: suspend (HostKeyRequestRecord) -> Boolean,
+  private val requestPrompts: suspend (KeyboardInteractiveRequestRecord) -> List<String>?,
+  private val notifyDisconnect: (DisconnectRecord) -> Unit,
+) : SessionHandler {
+  override suspend fun verifyHostKey(
+    host: String,
+    port: UShort,
+    algorithm: String,
+    publicKeyBase64: String,
+    fingerprintSha256: String,
+  ): Boolean = requestHostKey(
+    HostKeyRequestRecord(
+      sessionId = sessionId,
+      requestId = requestIds.next(),
+      host = host,
+      port = port.toInt(),
+      algorithm = algorithm,
+      publicKeyBase64 = publicKeyBase64,
+      fingerprintSha256 = fingerprintSha256,
+    )
+  )
+
+  override suspend fun keyboardInteractive(
+    name: String,
+    instructions: String,
+    prompts: List<Prompt>,
+  ): List<String>? = requestPrompts(
+    KeyboardInteractiveRequestRecord(
+      sessionId = sessionId,
+      requestId = requestIds.next(),
+      name = name,
+      instructions = instructions,
+      prompts = prompts.map { PromptRecord(it.text, it.echo) },
+    )
+  )
+
+  override fun onDisconnect(reason: String) {
+    notifyDisconnect(DisconnectRecord(sessionId, reason))
+  }
+
+  private val requestIds = IdSequence("request-")
+}