feat: add plugin logging

Author: christophwitzko

pkg/plugin/client.go

@@ -1,7 +1,13 @@
 package plugin
 
 import (
+	"bufio"
+	"fmt"
+	"io"
+	"log"
+	"os"
 	"os/exec"
+	"strings"
 	"sync"
 
 	"github.com/go-semantic-release/semantic-release/v2/pkg/analyzer"
@@ -15,8 +21,9 @@ import (
 )
 
 type PluginOpts struct {
-	Type string
-	Cmd  *exec.Cmd
+	Type       string
+	PluginName string
+	Cmd        *exec.Cmd
 }
 
 var runningClientsMx sync.Mutex
@@ -33,6 +40,19 @@ func KillAllPlugins() {
 func startPlugin(opts *PluginOpts) (interface{}, error) {
 	runningClientsMx.Lock()
 	defer runningClientsMx.Unlock()
+	logR, logW := io.Pipe()
+	pluginLogger := log.New(os.Stderr, fmt.Sprintf("[%s]: ", opts.PluginName), 0)
+	go func() {
+		logLineScanner := bufio.NewScanner(logR)
+		for logLineScanner.Scan() {
+			line := logLineScanner.Text()
+			// skip JSON logging
+			if strings.HasPrefix(line, "{") {
+				continue
+			}
+			pluginLogger.Println(line)
+		}
+	}()
 	client := plugin.NewClient(&plugin.ClientConfig{
 		HandshakeConfig: Handshake,
 		VersionedPlugins: map[int]plugin.PluginSet{
@@ -45,6 +65,7 @@ func startPlugin(opts *PluginOpts) (interface{}, error) {
 		Cmd:              opts.Cmd,
 		AllowedProtocols: []plugin.Protocol{plugin.ProtocolGRPC},
 		Logger:           hclog.NewNullLogger(),
+		Stderr:           logW,
 	})
 
 	rpcClient, err := client.Client()

pkg/plugin/discovery/discovery.go

@@ -262,7 +262,8 @@ func FindPlugin(t, name string) (*plugin.PluginOpts, error) {
 	}
 
 	return &plugin.PluginOpts{
-		Type: t,
-		Cmd:  exec.Command(binPath),
+		Type:       t,
+		PluginName: pName,
+		Cmd:        exec.Command(binPath),
 	}, nil
 }