Read logs produced by dev plugin and print them to console

package.json

@@ -26,13 +26,15 @@
     "commander": "^11.1.0",
     "rollup": "^4.3.0",
     "simple-git": "^3.22.0",
+    "tail": "^2.2.6",
     "toml": "^3.0.0",
     "tslib": "^2.6.2",
     "zod": "^3.22.4"
   },
   "devDependencies": {
     "@rollup/plugin-json": "^6.1.0",
     "@types/node": "^18.17.1",
+    "@types/tail": "^2.2.3",
     "typescript": "^5.2.2"
   },
   "publishConfig": {

schema/backend.proto

@@ -8,4 +8,6 @@ message RpcSaveLocalPluginRequest {
   string path = 1;
 }
 message RpcSaveLocalPluginResponse {
+  string stdout_file_path = 1;
+  string stderr_file_path = 2;
 }

src/dev.ts

@@ -9,6 +9,7 @@ import {
 import { Plugin, RollupError, watch } from "rollup";
 import chalk from "chalk";
 import { setupGrpc } from "./grpc";
+import { Tail } from "tail";
 
 export async function dev() {
     const { SaveLocalPlugin } = await setupGrpc();
@@ -34,6 +35,9 @@ export async function dev() {
         output: rollupOutputOptions()
     });
 
+    let stdoutTail: Tail | undefined = undefined;
+    let stderrTail: Tail | undefined = undefined;
+
     watcher.on('event', async (event) => {
         switch (event.code) {
             case "START": {
@@ -54,7 +58,29 @@ export async function dev() {
                 await event.result.close()
 
                 try {
-                    await SaveLocalPlugin(process.cwd() + "/dist") // TODO: get dir which contains package.json
+                    let { stdoutFilePath, stderrFilePath } = await SaveLocalPlugin(process.cwd()); // TODO: get dir which contains package.json
+
+                    if (stdoutTail != undefined) {
+                        stdoutTail.unwatch()
+                    }
+                    stdoutTail = new Tail(stdoutFilePath)
+                    stdoutTail.on("line", function(data) {
+                        console.error(data);
+                    });
+                    stdoutTail.on("error", function(error) {
+                        console.error("ERROR: ", error);
+                    });
+
+                    if (stderrTail != undefined) {
+                        stderrTail.unwatch()
+                    }
+                    stderrTail = new Tail(stderrFilePath)
+                    stderrTail.on("line", function(data) {
+                        console.error(data);
+                    });
+                    stderrTail.on("error", function(error) {
+                        console.error("ERROR: ", error);
+                    });
                 } catch (e) {
                     console.error("Error returned by server");
                     console.error(e);

src/grpc.js

@@ -16,9 +16,9 @@ export async function setupGrpc() {
     return {
         async SaveLocalPlugin(path) {
             return new Promise((resolve, reject) => {
-                client.SaveLocalPlugin({ path }, (err, _) => {
+                client.SaveLocalPlugin({ path }, (err, response) => {
                     if (err) reject(err);
-                    else (resolve({}));
+                    else (resolve(response));
                 });
             });
         }