feat(exthost): Types / handlers for MainThreadOutputService

ssyx02 · Jul 18, 2020 · f83f335 · f83f335
1 parent 1b9250b
commit f83f335
Show file tree

Hide file tree

Showing 3 changed files with 85 additions and 1 deletion.
diff --git a/src/Exthost/Exthost.rei b/src/Exthost/Exthost.rei
@@ -1055,6 +1055,31 @@ module Msg: {
         });
   };
 
+  module OutputService: {
+    [@deriving show]
+    type msg =
+      | Register({
+          label: string,
+          log: bool,
+          file: option(Oni_Core.Uri.t),
+        })
+      | Append({
+          channelId: string,
+          value: string,
+        })
+      | Update({channelId: string})
+      | Clear({
+          channelId: string,
+          till: int,
+        })
+      | Reveal({
+          channelId: string,
+          preserveFocus: bool,
+        })
+      | Close({channelId: string})
+      | Dispose({channelId: string});
+  };
+
   module StatusBar: {
     [@deriving show]
     type alignment =
@@ -1091,6 +1116,7 @@ module Msg: {
     | FileSystem(FileSystem.msg)
     | LanguageFeatures(LanguageFeatures.msg)
     | MessageService(MessageService.msg)
+    | OutputService(OutputService.msg)
     | SCM(SCM.msg)
     | StatusBar(StatusBar.msg)
     | Telemetry(Telemetry.msg)

diff --git a/src/Exthost/Handlers.re b/src/Exthost/Handlers.re
@@ -121,7 +121,11 @@ let handlers =
       ~mapper=msg => Msg.MessageService(msg),
       "MainThreadMessageService",
     ),
-    mainNotImplemented("MainThreadOutputService"),
+    main(
+      ~handler=Msg.OutputService.handle,
+      ~mapper=msg => Msg.OutputService(msg),
+      "MainThreadOutputService",
+    ),
     mainNotImplemented("MainThreadProgress"),
     mainNotImplemented("MainThreadQuickOpen"),
     main(

diff --git a/src/Exthost/Msg.re b/src/Exthost/Msg.re
@@ -837,6 +837,59 @@ module MessageService = {
     };
   };
 };
+
+module OutputService = {
+  [@deriving show]
+  type msg =
+    | Register({
+        label: string,
+        log: bool,
+        file: option(Oni_Core.Uri.t),
+      })
+    | Append({
+        channelId: string,
+        value: string,
+      })
+    | Update({channelId: string})
+    | Clear({
+        channelId: string,
+        till: int,
+      })
+    | Reveal({
+        channelId: string,
+        preserveFocus: bool,
+      })
+    | Close({channelId: string})
+    | Dispose({channelId: string});
+
+  let handle = (method, args: Yojson.Safe.t) => {
+    Base.Result.Let_syntax.(
+      Json.Decode.(
+        switch (method, args) {
+        | ("$register", `List([`String(label), `Bool(log), maybeUriJson])) =>
+          let%bind maybeUri =
+            maybeUriJson
+            |> Internal.decode_value(nullable(Oni_Core.Uri.decode));
+          Ok(Register({label, log, file: maybeUri}));
+        | ("$append", `List([`String(channelId), `String(value)])) =>
+          Ok(Append({channelId, value}))
+        | ("$update", `List([`String(channelId)])) =>
+          Ok(Update({channelId: channelId}))
+        | ("$clear", `List([`String(channelId), `Int(till)])) =>
+          Ok(Clear({channelId, till}))
+        | ("$reveal", `List([`String(channelId), `Bool(preserveFocus)])) =>
+          Ok(Reveal({channelId, preserveFocus}))
+        | ("$close", `List([`String(channelId)])) =>
+          Ok(Close({channelId: channelId}))
+        | ("$dispose", `List([`String(channelId)])) =>
+          Ok(Dispose({channelId: channelId}))
+        | _ => Error("Unable to parse OutputService method: " ++ method)
+        }
+      )
+    );
+  };
+};
+
 module StatusBar = {
   [@deriving show]
   type alignment =
@@ -1163,6 +1216,7 @@ type t =
   | FileSystem(FileSystem.msg)
   | LanguageFeatures(LanguageFeatures.msg)
   | MessageService(MessageService.msg)
+  | OutputService(OutputService.msg)
   | SCM(SCM.msg)
   | StatusBar(StatusBar.msg)
   | Telemetry(Telemetry.msg)