Files
clide/test/pty/session_test.dart
T
Jeroen SchweitzerandClaude Opus 4.6 5aa0eb46e4
test / unit + widget + golden + a11y (push) Failing after 3m13s
test / integration_test (xvfb) (push) Has been skipped
test / bundle smoke (xvfb 5s) (push) Has been skipped
test / daemon subprocess + web WASM smoke (push) Has been skipped
replace ptyc with forkpty() via Dart FFI
NativePty calls forkpty() directly — no helper binary, no socketpair,
no SCM_RIGHTS. The master fd stays in-process. Reader isolate uses
poll() for clean shutdown.

Based on the pty-spike proof-of-concept. Platform-aware: macOS uses
libSystem (DynamicLibrary.process), Linux needs libutil.so.1.
TIOCSWINSZ platform-detected.

PaneRegistry updated to use NativePty. registerPaneCommands no longer
needs a Toolchain parameter. All ptyc references removed from the
daemon layer.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
2026-04-30 20:30:15 +02:00

95 lines
2.7 KiB
Dart

/// NativePty smoke tests.
///
/// Exercises forkpty() end-to-end: spawn → child output through the
/// reader isolate. Linux + macOS only; skipped elsewhere.
library;
import 'dart:async';
import 'dart:convert';
import 'dart:io';
import 'package:clide/src/pty/native_pty.dart';
import 'package:test/test.dart';
void main() {
if (!Platform.isLinux && !Platform.isMacOS) return;
final shell = Platform.environment['SHELL'] ?? '/bin/zsh';
group('NativePty', () {
test('spawns shell -c echo and reads output', () async {
final s = NativePty.start(
executable: shell,
arguments: ['-l', '-c', 'echo hello-pty'],
columns: 80,
rows: 24,
workingDirectory: Platform.environment['HOME'] ?? '/',
environment: {
...Platform.environment,
'TERM': 'xterm-256color',
},
);
addTearDown(s.close);
final buf = StringBuffer();
s.output.listen((bytes) => buf.write(utf8.decode(bytes, allowMalformed: true)));
// Shell exits quickly; give reader up to 3s.
for (var i = 0; i < 30 && !buf.toString().contains('hello-pty'); i++) {
await Future<void>.delayed(const Duration(milliseconds: 100));
}
expect(buf.toString(), contains('hello-pty'));
});
test('write sends keystrokes to child', () async {
final s = NativePty.start(
executable: shell,
arguments: ['-l'],
columns: 80,
rows: 24,
workingDirectory: Platform.environment['HOME'] ?? '/',
environment: {
...Platform.environment,
'TERM': 'xterm-256color',
},
);
addTearDown(s.close);
final buf = StringBuffer();
s.output.listen((bytes) => buf.write(utf8.decode(bytes, allowMalformed: true)));
// Wait for prompt.
await Future<void>.delayed(const Duration(seconds: 1));
// Type a command.
s.write(utf8.encode('echo write-test-ok\n'));
for (var i = 0; i < 30 && !buf.toString().contains('write-test-ok'); i++) {
await Future<void>.delayed(const Duration(milliseconds: 100));
}
expect(buf.toString(), contains('write-test-ok'));
});
test('close kills child and closes output', () async {
final s = NativePty.start(
executable: shell,
arguments: ['-l'],
columns: 80,
rows: 24,
workingDirectory: Platform.environment['HOME'] ?? '/',
environment: {
...Platform.environment,
'TERM': 'xterm-256color',
},
);
final done = Completer<void>();
s.output.listen((_) {}, onDone: () => done.complete());
await s.close();
await done.future.timeout(const Duration(seconds: 3));
expect(s.isClosed, isTrue);
});
});
}