Unit package holds all unit logic

core/units.go

@@ -1,39 +0,0 @@
-package core
-
-import (
-	"encoding/json"
-	"io/ioutil"
-	"os"
-
-	"github.com/localhots/yeast/impl"
-	"github.com/localhots/yeast/unit"
-)
-
-var (
-	Units = map[string]Caller{}
-)
-
-func LoadUnits() {
-	f, err := os.Open(Conf().UnitsConfig)
-	if err != nil {
-		panic("Failed to open units config: " + Conf().UnitsConfig)
-	}
-	b, err := ioutil.ReadAll(f)
-	if err != nil {
-		panic("Failed to parse units config: " + Conf().UnitsConfig)
-	}
-
-	var conf map[string]map[string]interface{}
-	json.Unmarshal(b, &conf)
-
-	for name, meta := range conf {
-		// Check for unit implementation and create a unit if there is none
-		if imp := impl.New(meta["impl"].(string)); imp != nil {
-			Units[name] = imp
-		} else {
-			Units[name] = &unit.Unit{
-				Name: name,
-			}
-		}
-	}
-}

unit/parser.go

@@ -0,0 +1,41 @@
+package unit
+
+import (
+	"encoding/json"
+	"io/ioutil"
+	"os"
+)
+
+var (
+	units = map[string]*Unit{}
+)
+
+func LoadUnits(path string) {
+	f, err := os.Open(path)
+	if err != nil {
+		panic("Failed to open units config: " + path)
+	}
+	b, err := ioutil.ReadAll(f)
+	if err != nil {
+		panic("Failed to parse units config: " + path)
+	}
+
+	var conf map[string]map[string]interface{}
+	json.Unmarshal(b, &conf)
+
+	for name, meta := range conf {
+		units[name] = &Unit{
+			Name:   name,
+			Impl:   meta["impl"].(string),
+			Config: meta["config"],
+		}
+	}
+}
+
+func Units() []string {
+	list := []string{}
+	for name, _ := range units {
+		list = append(list, name)
+	}
+	return list
+}

unit/unit.go

@@ -5,17 +5,32 @@ import (
 	"fmt"
 	"net"
 	"strings"
+
+	"github.com/localhots/yeast/impl"
 )
 
 type (
 	Unit struct {
 		Name   string
+		Impl   string
+		Config interface{}
+	}
+	Caller interface {
+		Call([]byte) ([]byte, error)
+		Units() []string
 	}
 )
 
-func New(name string) *Unit {
-	return &Unit{
-		Name: name,
+func New(name string) Caller {
+	if u, ok := units[name]; ok {
+		// Check for unit implementation and create a unit if there is none
+		if imp := impl.New(u.Impl); imp != nil {
+			return imp
+		} else {
+			return u
+		}
+	} else {
+		return nil
 	}
 }