124 lines
2.7 KiB
Dart
124 lines
2.7 KiB
Dart
import 'dart:async';
|
|
import 'dart:io';
|
|
|
|
import 'package:wolf_3d_dart/wolf_3d_engine.dart';
|
|
import 'package:wolf_3d_dart/wolf_3d_input.dart';
|
|
import 'package:wolf_3d_dart/wolf_3d_rasterizer.dart';
|
|
|
|
class CliGameLoop {
|
|
CliGameLoop({
|
|
required this.engine,
|
|
required this.onExit,
|
|
}) : input = CliInput(),
|
|
primaryRasterizer = SixelRasterizer(),
|
|
secondaryRasterizer = AsciiRasterizer(isTerminal: true) {
|
|
_rasterizer = primaryRasterizer;
|
|
}
|
|
|
|
final WolfEngine engine;
|
|
final CliRasterizer primaryRasterizer;
|
|
final CliRasterizer secondaryRasterizer;
|
|
final CliInput input;
|
|
final void Function(int code) onExit;
|
|
|
|
final Stopwatch _stopwatch = Stopwatch();
|
|
late CliRasterizer _rasterizer;
|
|
StreamSubscription<List<int>>? _stdinSubscription;
|
|
Timer? _timer;
|
|
bool _isRunning = false;
|
|
Duration _lastTick = Duration.zero;
|
|
|
|
void start() {
|
|
if (_isRunning) {
|
|
return;
|
|
}
|
|
|
|
stdin.echoMode = false;
|
|
stdin.lineMode = false;
|
|
|
|
stdout.write('\x1b[?25l\x1b[2J');
|
|
|
|
_stdinSubscription = stdin.listen(_handleInput);
|
|
_stopwatch.start();
|
|
_timer = Timer.periodic(const Duration(milliseconds: 33), _tick);
|
|
_isRunning = true;
|
|
}
|
|
|
|
void stop() {
|
|
if (!_isRunning) {
|
|
return;
|
|
}
|
|
|
|
_timer?.cancel();
|
|
_timer = null;
|
|
_stdinSubscription?.cancel();
|
|
_stdinSubscription = null;
|
|
|
|
if (_stopwatch.isRunning) {
|
|
_stopwatch.stop();
|
|
}
|
|
|
|
if (stdin.hasTerminal) {
|
|
stdin.echoMode = true;
|
|
stdin.lineMode = true;
|
|
}
|
|
|
|
if (stdout.hasTerminal) {
|
|
stdout.write('\x1b[0m\x1b[?25h');
|
|
}
|
|
|
|
_isRunning = false;
|
|
}
|
|
|
|
void _handleInput(List<int> bytes) {
|
|
if (bytes.contains(113) || bytes.contains(27)) {
|
|
stop();
|
|
onExit(0);
|
|
return;
|
|
}
|
|
|
|
if (bytes.contains(9)) {
|
|
_rasterizer = identical(_rasterizer, secondaryRasterizer)
|
|
? primaryRasterizer
|
|
: secondaryRasterizer;
|
|
stdout.write('\x1b[2J\x1b[H');
|
|
return;
|
|
}
|
|
|
|
input.handleKey(bytes);
|
|
}
|
|
|
|
void _tick(Timer timer) {
|
|
if (!_isRunning) {
|
|
return;
|
|
}
|
|
|
|
if (stdout.hasTerminal) {
|
|
final int cols = stdout.terminalColumns;
|
|
final int rows = stdout.terminalLines;
|
|
if (!_rasterizer.prepareTerminalFrame(
|
|
engine,
|
|
columns: cols,
|
|
rows: rows,
|
|
)) {
|
|
stdout.write('\x1b[2J\x1b[H');
|
|
stdout.write(
|
|
_rasterizer.buildTerminalSizeWarning(columns: cols, rows: rows),
|
|
);
|
|
|
|
_lastTick = _stopwatch.elapsed;
|
|
return;
|
|
}
|
|
}
|
|
|
|
final Duration currentTick = _stopwatch.elapsed;
|
|
final Duration elapsed = currentTick - _lastTick;
|
|
_lastTick = currentTick;
|
|
|
|
stdout.write('\x1b[H');
|
|
|
|
engine.tick(elapsed);
|
|
stdout.write(_rasterizer.render(engine));
|
|
}
|
|
}
|