WIP: stdout output

agent.go

@@ -3,15 +3,16 @@ package main
 import (
 	"context"
 	"errors"
-	"fmt"
 	"time"
 
+	"github.com/nsmith5/rekor-sidekick/outputs"
 	"github.com/nsmith5/rekor-sidekick/rekor"
 )
 
 type agent struct {
 	rc       *rekor.Client
 	policies []policy
+	outs     []outputs.Output
 
 	quit chan struct{}
 }
@@ -25,9 +26,19 @@ func newAgent(c config) (*agent, error) {
 
 	policies := c.Policies
 
+	var outs []outputs.Output
+	for name, conf := range c.Outputs {
+		output, err := outputs.LoadDriver(name, conf)
+		if err != nil {
+			// Huh... log this issue I guess?
+			continue
+		}
+		outs = append(outs, output)
+	}
+
 	quit := make(chan struct{})
 
-	return &agent{rc, policies, quit}, nil
+	return &agent{rc, policies, outs, quit}, nil
 }
 
 // run starts off the agent. The call blocks or exits returning an error
@@ -77,9 +88,17 @@ func (a *agent) run() error {
 				}
 
 				if violation {
-					// TODO: Send to outputs!
-					fmt.Printf("Entry %#v violated policy %s\n", entry, p.Name)
-					time.Sleep(5 * time.Second)
+					for _, out := range a.outs {
+						// TODO: Populate the rekor URL!
+						e := outputs.Event{
+							Name:        p.Name,
+							Description: p.Description,
+							RekorURL:    `dunno...`,
+						}
+
+						// TODO: Do something on send failure
+						out.Send(e)
+					}
 				}
 			}
 		}

config.go

@@ -1,6 +1,7 @@
 package main
 
 type config struct {
-	RekorServerURL string   `yaml:"rekorServerURL"`
-	Policies       []policy `yaml:"policies"`
+	RekorServerURL string                            `yaml:"rekorServerURL"`
+	Policies       []policy                          `yaml:"policies"`
+	Outputs        map[string]map[string]interface{} `yaml:"outputs"`
 }

etc/config.yaml

@@ -1,4 +1,5 @@
 rekorServerURL: https://rekor.sigstore.dev
+
 policies:
 - name: x509-used
   description: |-
@@ -17,3 +18,5 @@ policies:
     package auth
     default allow = true
 
+outputs:
+  stdout: {}

main.go

@@ -1,5 +1,10 @@
 package main
 
+import (
+	// Loading output drivers
+	_ "github.com/nsmith5/rekor-sidekick/outputs/stdout"
+)
+
 func main() {
 	cmd := newCLI()
 	cmd.Execute()

outputs/interface.go

@@ -0,0 +1,11 @@
+package outputs
+
+type Event struct {
+	Name        string
+	Description string
+	RekorURL    string
+}
+
+type Output interface {
+	Send(Event) error
+}

outputs/registry.go

@@ -0,0 +1,24 @@
+package outputs
+
+import "errors"
+
+type CreatorFunc func(map[string]interface{}) (Output, error)
+
+var drivers map[string]CreatorFunc
+
+func init() {
+	drivers = make(map[string]CreatorFunc)
+}
+
+func RegisterDriver(name string, maker CreatorFunc) {
+	drivers[name] = maker
+}
+
+func LoadDriver(name string, conf map[string]interface{}) (Output, error) {
+	f, ok := drivers[name]
+	if !ok {
+		return nil, errors.New(`driver doesn't exist or wasn't loaded`)
+	}
+
+	return f(conf)
+}

outputs/stdout/stdout.go

@@ -0,0 +1,28 @@
+package stdout
+
+import (
+	"fmt"
+
+	"github.com/nsmith5/rekor-sidekick/outputs"
+)
+
+type impl struct{}
+
+func (i impl) Send(e outputs.Event) error {
+	fmt.Printf(
+		`{"name": "%s", "description": "%s", rekorURL: "%s"}`,
+		e.Name,
+		e.Description,
+		e.RekorURL,
+	)
+	fmt.Println()
+	return nil
+}
+
+func New(map[string]interface{}) (outputs.Output, error) {
+	return &impl{}, nil
+}
+
+func init() {
+	outputs.RegisterDriver("stdout", outputs.CreatorFunc(New))
+}