Initialize Package

Signed-off-by: Maia Iyer <[email protected]>

api/agent/config.go

@@ -14,6 +14,7 @@ import (
 	"github.com/spiffe/tornjak/pkg/agent/authentication/authenticator"
 	"github.com/spiffe/tornjak/pkg/agent/authorization"
 	agentdb "github.com/spiffe/tornjak/pkg/agent/db"
+	"github.com/spiffe/tornjak/pkg/agent/spirecrd"
 )
 
 func stringFromToken(keyToken token.Token) (string, error) {
@@ -86,7 +87,7 @@ func NewAgentsDB(dbPlugin *ast.ObjectItem) (agentdb.AgentDB, error) {
 }
 
 // NewCRDManager returns ...
-func NewCRDManager(crdPlugin *ast.ObjectItem) (string, error) {
+func NewCRDManager(crdPlugin *ast.ObjectItem) (spirecrd.CRDManager, error) {
 	_, data, _ := getPluginConfig(crdPlugin)
 
 	// check if data is defined
@@ -101,7 +102,12 @@ func NewCRDManager(crdPlugin *ast.ObjectItem) (string, error) {
 
 	fmt.Println("CRD Controller configured. WARNING: This is currently a no-op")
 
-	return "CRD config string", nil
+	crdManager, err := spirecrd.NewSPIRECRDManager(config.Classname)
+	if err != nil {
+		return nil, errors.Errorf("Could not initialize CRD manager: %v", err)
+	}
+
+	return crdManager, nil
 }
 
 // NewAuthenticator returns a new Authenticator

api/agent/server.go

@@ -18,6 +18,7 @@ import (
 	"github.com/spiffe/tornjak/pkg/agent/authentication/authenticator"
 	"github.com/spiffe/tornjak/pkg/agent/authorization"
 	agentdb "github.com/spiffe/tornjak/pkg/agent/db"
+	"github.com/spiffe/tornjak/pkg/agent/spirecrd"
 )
 
 type Server struct {
@@ -32,7 +33,7 @@ type Server struct {
 
 	// Plugins
 	Db            agentdb.AgentDB
-	CRDManager		string // TODO create plugin for this
+	CRDManager		spirecrd.CRDManager
 	Authenticator authenticator.Authenticator
 	Authorizer    authorization.Authorizer
 }

pkg/agent/spirecrd/crdmanager.go

@@ -0,0 +1,17 @@
+package spirecrd
+
+// CRDManager defines the interface for managing CRDs
+type CRDManager interface {
+	// TODO add List/Create/Update/Delete functions for Federation CRD
+}
+
+type SPIRECRDManager struct {
+	className string
+}
+
+// NewSPIRECRDManager initializes new SPIRECRDManager
+func NewSPIRECRDManager(className string) (*SPIRECRDManager, error) {
+	return &SPIRECRDManager{
+		className: className,
+	}, nil
+}