Updated

Author: djthorpe

cmd/server/main.go

@@ -18,6 +18,7 @@ import (
 
 type CLI struct {
 	ServiceCommands
+	Service2Commands
 
 	PG struct {
 		pgmanager.DatabaseCommands

cmd/server/service2.go

@@ -0,0 +1,51 @@
+package main
+
+import (
+	"fmt"
+
+	// Packages
+	server "github.com/mutablelogic/go-server"
+	"github.com/mutablelogic/go-server/pkg/parser"
+	provider "github.com/mutablelogic/go-server/pkg/provider"
+)
+
+///////////////////////////////////////////////////////////////////////////////
+// TYPES
+
+type Service2Commands struct {
+	//	Run  ServiceRunCommand  `cmd:"" group:"SERVICE" help:"Run the service"`
+	Run2 Service2RunCommand `cmd:"" group:"SERVICE" help:"Run the service with plugins"`
+}
+
+type Service2RunCommand struct {
+	Plugins []string `help:"Plugin paths" env:"PLUGIN_PATH"`
+	Args    []string `arg:"" help:"Configuration files"`
+}
+
+///////////////////////////////////////////////////////////////////////////////
+// PUBLIC METHODS
+
+func (cmd *Service2RunCommand) Run(app server.Cmd) error {
+	// Create a provider by loading the plugins
+	provider, err := provider.NewWithPlugins(cmd.Plugins...)
+	if err != nil {
+		return err
+	}
+
+	// Create a parser of the config files
+	parser, err := parser.New(provider.Plugins()...)
+	if err != nil {
+		return err
+	}
+
+	// Parse the configuration files
+	for _, path := range cmd.Args {
+		if err := parser.Parse(path); err != nil {
+			return err
+		}
+	}
+
+	fmt.Println(provider, parser)
+
+	return nil
+}

etc/testdata/httpserver.json

@@ -0,0 +1,8 @@
+{
+    "httpserver": {
+        "main": {
+            "port": 8080,
+            "host": "localhost"
+        }
+    }
+}

pkg/provider/provider.go

@@ -141,6 +141,15 @@ func (provider *provider) WriteConfig(w io.Writer) error {
 ////////////////////////////////////////////////////////////////////////////////
 // PUBLIC METHODS
 
+// Return all the plugins
+func (provider *provider) Plugins() []server.Plugin {
+	var result []server.Plugin
+	for _, meta := range provider.protos {
+		result = append(result, meta.New())
+	}
+	return result
+}
+
 // Return a task from a label
 func (provider *provider) Task(ctx context.Context, label string) server.Task {
 	provider.Debugf(ctx, "Called Task for %q", label)

plugin.go

@@ -43,6 +43,9 @@ type Provider interface {
 	// Write out the plugin configuration to a writer
 	WriteConfig(io.Writer) error
 
+	// Return the plugins registered with the provider
+	Plugins() []Plugin
+
 	// Load a plugin by name and label, and provide a resolver function
 	Load(string, string, PluginResolverFunc) error