Added exception handling to run()

This commit is contained in:
Chris 2016-11-21 01:26:06 +01:00
parent bdec60717f
commit 0e5a25567c
2 changed files with 61 additions and 44 deletions

View File

@ -0,0 +1,12 @@
NoccyLabs Shell Core
====================
This library helps make elegant command line applications that spawn an isolated shell.
It uses a standalone implementation for buffered input with support for arrow keys to
navigate the history and more.
Note that this library requirements a fully ANSI compatible terminal with UTF-8 support
in order to use colors, control the cursor position etc. As it uses `stty` to configure
input buffering, it will likely not work on Windows.

View File

@ -321,57 +321,62 @@ class Shell
public function run() public function run()
{ {
$this->lineReader = new LineRead(); try {
$this->lineReader = new LineRead();
$this->lineReader->setPromptText($this->prompt); $this->lineReader->setPromptText($this->prompt);
$this->lineReader->setPromptStyle(new Style(Style::BR_GREEN)); $this->lineReader->setPromptStyle(new Style(Style::BR_GREEN));
$this->lineReader->setCommandStyle(new Style(Style::GREEN)); $this->lineReader->setCommandStyle(new Style(Style::GREEN));
$this->running = true; $this->running = true;
$this->dispatchEvent("prompt", [ "context"=>$this->context ]); $this->dispatchEvent("prompt", [ "context"=>$this->context ]);
while ($this->running) { while ($this->running) {
// Update the input stuff, sleep if nothing to do. // Update the input stuff, sleep if nothing to do.
if (!($buffer = $this->lineReader->update())) { if (!($buffer = $this->lineReader->update())) {
usleep(10000); usleep(10000);
} }
// Escape is handy too... // Escape is handy too...
if ($buffer == "\e") { if ($buffer == "\e") {
$this->dispatchEvent("shell.abort"); $this->dispatchEvent("shell.abort");
continue; continue;
} }
// we get a ^C on ^C, so deal with the ^C. // we get a ^C on ^C, so deal with the ^C.
if ($buffer == "\x03") { if ($buffer == "\x03") {
$this->dispatchEvent("shell.stop"); $this->dispatchEvent("shell.stop");
$this->stop(); $this->stop();
continue; continue;
} }
// Execute the buffer // Execute the buffer
ob_start(); ob_start();
$this->dispatchEvent("update"); $this->dispatchEvent("update");
foreach ($this->timers as $timer) { foreach ($this->timers as $timer) {
$timer->update(); $timer->update();
} }
if ($buffer) { if ($buffer) {
$this->executeBuffer($buffer); $this->executeBuffer($buffer);
} }
$output = ob_get_contents(); $output = ob_get_contents();
ob_end_clean(); ob_end_clean();
if (trim($output)) { if (trim($output)) {
$this->lineReader->erase(); $this->lineReader->erase();
echo rtrim($output)."\n"; echo rtrim($output)."\n";
$this->lineReader->redraw(); $this->lineReader->redraw();
}
if (!$this->context) {
$this->stop();
}
if ($buffer) {
$this->dispatchEvent("prompt", [ "context"=>$this->context ]);
}
} }
if (!$this->context) { } catch (\Exception $e) {
$this->stop(); fprintf(STDERR, "\e[31;1mFatal: Unhandled exception\e[0m\n\n%s\n", $e);
}
if ($buffer) {
$this->dispatchEvent("prompt", [ "context"=>$this->context ]);
}
} }
$this->lineReader = null; $this->lineReader = null;