Adds notify event log for console.

app/Modules/Ray/Console/Handlers/DebugHandler.php

@@ -5,13 +5,15 @@
 
 class DebugHandler extends AbstractHandler
 {
-
  protected function makeData(array $payload): array
  {
- return [];
- }
- public function handle(array $payload): void
- {
- dump($payload);
+ $len = strlen($payload['content']['value']);
+ return [
+ 'message' => [
+ str_pad('', $len, '='),
+ $payload['content']['value'],
+ str_pad('', $len, '=')
+ ]
+ ];
  }
 }

app/Modules/Ray/Console/Handlers/NotifyHandler.php

@@ -0,0 +1,19 @@
+<?php
+declare(strict_types=1);
+
+namespace Modules\Ray\Console\Handlers;
+
+class NotifyHandler extends AbstractHandler
+{
+ protected function makeData(array $payload): array
+ {
+ $len = strlen($payload['content']['value']);
+ return [
+ 'message' => [
+ str_pad('', $len, '.'),
+ $payload['content']['value'],
+ str_pad('', $len, '.')
+ ]
+ ];
+ }
+}

app/Modules/Ray/Console/StreamHandler.php

@@ -28,7 +28,7 @@ public function handle(array $stream): void
  if (!isset($this->payloadHandlers[$payload['type']])) {
  continue;
 
- //$handler = new DebugHandler($this->output);
+ //$handler = new DebugHandler($this->renderer);
  } else {
  $handler = $this->payloadHandlers[$payload['type']];
  $handler = new $handler($this->renderer);

app/Modules/Ray/resources/views/console/notify.blade.php

@@ -0,0 +1,5 @@
+@foreach($message as $line)
+<div class="bg-magenta text-white px-3">
+ {{ $line }}
+</div>
+@endforeach

config/server.php

@@ -21,6 +21,7 @@
  'job_event' => Handlers\JobEventHandler::class,
  'event' => Handlers\EventHandler::class,
  'view' => Handlers\ViewHandler::class,
+ 'notify' => Handlers\NotifyHandler::class
  ]
  ]
  ],

public/mix-manifest.json

@@ -1,4 +1,4 @@
 {
- "/js/app.js": "/js/app.js?id=b99e3b61ad7bb3362d67",
+ "/js/app.js": "/js/app.js?id=d762b709b0acee0bebf1",
  "/css/app.css": "/css/app.css?id=2bf686066fc03b0cc56a"
 }

resources/js/Pages/Terminal/Index.vue

@@ -69,9 +69,10 @@ export default {
  setup() {
  const store = useStore();
  const messages = computed(() => store.state.terminal.messages)
+ const terminalInit = false
 
  return {
- messages, store
+ messages, store, terminalInit
  }
  },
  destroyed() {
@@ -106,7 +107,7 @@ export default {
  this.prompt();
  break;
  case '\r': // Enter
- this.runCommand( command);
+ this.runCommand(command);
  command = '';
  break;
  case '\u007F': // Backspace (DEL)
@@ -150,8 +151,16 @@ export default {
  this.term.write('\r\n$ ');
  },
  sendMessages(messages) {
- messages.forEach(msg => this.term.writeln(msg))
- this.prompt()
+ const isEmpty = messages.filter(line => line !== '').length === 0
+
+ messages.forEach(msg => {
+ this.term.write('\b\b')
+ this.term.writeln(msg)
+ })
+
+ if (!isEmpty) {
+ this.prompt()
+ }
  }
  }
 }