Skip to content
Snippets Groups Projects

Add a file storage to plugin registry

Merged Ghost User requested to merge plugin-registry-store-to-file into master
4 files
+ 45
271
Compare changes
  • Side-by-side
  • Inline
Files
4
+ 33
19
@@ -9,13 +9,15 @@ import (
pb "code.fbi.h-da.de/danet/gosdn/api/go/gosdn/plugin-registry"
"code.fbi.h-da.de/danet/gosdn/controller/interfaces/plugin"
"code.fbi.h-da.de/danet/gosdn/controller/nucleus/util"
"github.com/google/uuid"
"golang.org/x/mod/sumdb/dirhash"
"google.golang.org/grpc"
)
const (
pluginFilePath = "plugins"
pluginName = "bundled_plugin.zip"
pluginFilePath = "plugins"
pluginStorePath = "plugin-store.json"
)
func main() {
@@ -41,37 +43,45 @@ func main() {
// after reboot. Therefore it would make sense to use a database. For a simple
// prototype this is currently hardcoded.
func registerPlugins() *PluginRegistry {
files, err := os.ReadDir(pluginFilePath)
dirs, err := os.ReadDir(pluginFilePath)
if err != nil {
panic(err)
}
pr := &PluginRegistry{}
pluginStore := NewStore(pluginStorePath)
for i, file := range files {
fmt.Printf("File %+v\n", file)
for _, dir := range dirs {
fmt.Printf("File %+v\n", dir)
if file.IsDir() {
manifest, err := plugin.ReadManifestFromFile(filepath.Join(pluginFilePath, file.Name()))
if dir.IsDir() {
dirPath := filepath.Join(pluginFilePath, dir.Name())
manifest, err := plugin.ReadManifestFromFile(dirPath)
if err != nil {
panic(err)
}
var id uuid.UUID
switch i {
case 0:
id = uuid.MustParse("e2c358b3-6482-4010-b0d8-679dff73153b")
case 1:
id = uuid.MustParse("d1c269a2-6482-4010-b0d8-679dff73153b")
case 2:
id = uuid.MustParse("f3b474c2-6482-4010-b0d8-679dff73153b")
default:
break
dirHashed, err := dirhash.HashDir(dirPath, dir.Name()+manifest.Firmware, dirhash.DefaultHash)
if err != nil {
panic(err)
}
//var id uuid.UUID
//switch i {
//case 0:
// id = uuid.MustParse("e2c358b3-6482-4010-b0d8-679dff73153b")
//case 1:
// id = uuid.MustParse("d1c269a2-6482-4010-b0d8-679dff73153b")
//case 2:
// id = uuid.MustParse("f3b474c2-6482-4010-b0d8-679dff73153b")
//default:
// break
//}
plugin := &Plugin{
ID: id,
Path: filepath.Join(pluginFilePath, file.Name(), pluginName),
ID: uuid.New(),
Path: filepath.Join(dirPath, util.BundledPluginName),
Hash: dirHashed,
Manifest: manifest,
}
@@ -79,5 +89,9 @@ func registerPlugins() *PluginRegistry {
}
}
if err := pluginStore.Update(pr.Plugins); err != nil {
fmt.Println(err)
}
return pr
}
Loading