controller.go

package nucleus

import (
	"code.fbi.h-da.de/cocsn/gosdn/database"
	"context"
	"github.com/google/uuid"
	log "github.com/sirupsen/logrus"
	"time"
)

// Core is the representation of the controllers core
type Core struct {
	// deprecated
	database database.Database

	pndc pndStore
	sbic sbiStore
}

var c *Core

//Initialize does start-up housekeeping like reading controller config files
func initialize(ctx context.Context) error {
	c = &Core{
		database: database.Database{},
		pndc:     pndStore{},
		sbic:     sbiStore{},
	}
	c.sbic = sbiStore{
		store{},
	}
	c.pndc = pndStore{
		store{},
	}

	if err := createSouthboundInterfaces(); err != nil {
		return err
	}
	// TODO: Start grpc listener here

	if err := httpApi(ctx); err != nil {
		return err
	}

	attachDatabase()

	return nil
}

// deprecated
// AttachDatabase connects to the database and passes the connection to the controller core
func attachDatabase() {
	c.database = database.NewDatabaseClient()
}

// CreateSouthboundInterfaces initializes the controller with its supported SBIs
func createSouthboundInterfaces() error {
	if err := c.sbic.add(&OpenConfig{id: uuid.New()}); err != nil {
		return err
	}
	return nil
}

func Run(ctx context.Context) error {
	if err := initialize(ctx); err != nil {
		log.WithFields(log.Fields{}).Error(err)
		return err
	}
	log.WithFields(log.Fields{}).Info("initialisation finished")
	for {
		select {
		case <-ctx.Done():
			return nil
		case <-time.Tick(time.Minute):
			log.Debug("up and running")
		}
	}
}