feat(sdk): external plugins

Author: joe0BAB

pkg/adaptation/plugin.go

@@ -1,10 +1,16 @@
 package adaptation
 
 import (
+	"context"
+	"net"
+	"net/http"
+	"os/exec"
 	"sync"
 	"time"
 
 	"github.com/docker/secrets-engine/pkg/api"
+	"github.com/docker/secrets-engine/pkg/api/resolver/v1/resolverv1connect"
+	"github.com/docker/secrets-engine/pkg/secrets"
 )
 
 var (
@@ -24,3 +30,44 @@ func getPluginRegistrationTimeout() time.Duration {
 	defer timeoutCfgLock.RUnlock()
 	return pluginRegistrationTimeout
 }
+
+//var (
+//	_ = (secrets.Resolver)((*plugin)(nil))
+//)
+
+type plugin struct {
+	sync.Mutex
+	base           string
+	pattern        secrets.Pattern
+	version        string
+	cmd            *exec.Cmd
+	pluginClient   resolverv1connect.PluginServiceClient
+	resolverClient resolverv1connect.ResolverServiceClient
+	close          func() error
+}
+
+// Create a plugin (stub) for an accepted external plugin connection.
+func newExternalPlugin(conn net.Conn, v setupValidator) (*plugin, error) {
+	r, err := setup(conn, v)
+	if err != nil {
+		return nil, err
+	}
+	return &plugin{
+		base:           r.cfg.name,
+		pattern:        r.cfg.pattern,
+		version:        r.cfg.version,
+		pluginClient:   resolverv1connect.NewPluginServiceClient(newSocketClient(r.conn), "http://unix"),
+		resolverClient: resolverv1connect.NewResolverServiceClient(newSocketClient(r.conn), "http://unix"),
+		close:          r.close,
+	}, nil
+}
+
+func newSocketClient(conn net.Conn) *http.Client {
+	return &http.Client{
+		Transport: &http.Transport{
+			DialContext: func(ctx context.Context, _, _ string) (net.Conn, error) {
+				return conn, nil
+			},
+		},
+	}
+}

pkg/adaptation/plugin_test.go

@@ -0,0 +1 @@
+package adaptation

pkg/adaptation/setup.go

@@ -13,7 +13,7 @@ import (
 	"github.com/docker/secrets-engine/pkg/secrets"
 )
 
-type SetupResult struct {
+type setupResult struct {
 	conn  net.Conn
 	cfg   pluginCfgIn
 	close func() error
@@ -27,7 +27,7 @@ type setupValidator struct {
 	acceptPattern func(secrets.Pattern) error
 }
 
-func Setup(conn net.Conn, v setupValidator) (*SetupResult, error) {
+func setup(conn net.Conn, v setupValidator) (*setupResult, error) {
 	chRegistrationResult := make(chan registrationResult, 1)
 	httpMux := http.NewServeMux()
 	httpMux.HandleFunc("/health", func(w http.ResponseWriter, _ *http.Request) {
@@ -62,7 +62,7 @@ func Setup(conn net.Conn, v setupValidator) (*SetupResult, error) {
 		i.Close()
 		return nil, errors.New("plugin registration timed out")
 	}
-	return &SetupResult{
+	return &setupResult{
 		conn:  conn,
 		cfg:   out,
 		close: i.Close,