Skip to content
Snippets Groups Projects
Verified Commit 369f7b50 authored by Jonas Leder's avatar Jonas Leder
Browse files

call plugin setup

parent 3008a3ae
Branches
Tags
1 merge request!6Implement Plugin interface for alarming
...@@ -6,14 +6,16 @@ import ( ...@@ -6,14 +6,16 @@ import (
"plugin" "plugin"
"strings" "strings"
"jonasled.dev/firehouse-smokedetection/backend/database"
plugininterface "jonasled.dev/firehouse-smokedetection/plugin-interface" plugininterface "jonasled.dev/firehouse-smokedetection/plugin-interface"
"jonasled.dev/jonasled/go-libs/config" "jonasled.dev/jonasled/go-libs/config"
"jonasled.dev/jonasled/go-libs/log" "jonasled.dev/jonasled/go-libs/log"
) )
var plugins []plugininterface.Plugin var plugins map[string]plugininterface.Plugin
func Init() { func Init() {
plugins = make(map[string]plugininterface.Plugin)
err := filepath.Walk(config.GetOrDefault("PLUGIN_DIR", "./plugins"), func(path string, info os.FileInfo, err error) error { err := filepath.Walk(config.GetOrDefault("PLUGIN_DIR", "./plugins"), func(path string, info os.FileInfo, err error) error {
if err != nil { if err != nil {
log.Log.Fatal("Failed reading plugin dir: ", err.Error()) log.Log.Fatal("Failed reading plugin dir: ", err.Error())
...@@ -34,9 +36,11 @@ func Init() { ...@@ -34,9 +36,11 @@ func Init() {
log.Log.Fatalf("Failed parsing plugin %s as Plugin Interface", path) log.Log.Fatalf("Failed parsing plugin %s as Plugin Interface", path)
} }
plugin.Setup(database.Db)
log.Log.Infof("Initialized Plugin %s (v%s)", plugin.GetMetadata().Name, plugin.GetMetadata().Version) log.Log.Infof("Initialized Plugin %s (v%s)", plugin.GetMetadata().Name, plugin.GetMetadata().Version)
plugins = append(plugins, plugin) plugins[plugin.GetMetadata().Name] = plugin
} }
return nil return nil
}) })
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment