Include plugins at build time

include_plugins.go

@@ -0,0 +1,100 @@
+package main
+
+import (
+	"bufio"
+	"fmt"
+	"os"
+	"path/filepath"
+	"strings"
+)
+
+var newPlugins []string
+
+func main() {
+	findPlugins()
+	pluginsGo := "pkg/plugins/plugins.go"
+	os.MkdirAll(filepath.Dir(pluginsGo), os.ModePerm)
+	file, err := os.Create(pluginsGo)
+	if err != nil {
+		fmt.Printf("error creating file: %s %s\n", pluginsGo, err)
+		return
+	}
+
+	file.WriteString("package plugins\n\n")
+	file.WriteString("import (\n")
+	file.WriteString("\t\"sync\"\n\n")
+	file.WriteString("\t\"github.com/kiwiirc/webircgateway/pkg/webircgateway\"\n")
+
+	if len(newPlugins) > 0 {
+		file.WriteString("\n")
+	}
+
+	for _, v := range newPlugins {
+		dir := filepath.Dir(v)
+		file.WriteString("\tplugin" + strings.Title(filepath.Base(dir)) + " \"github.com/kiwiirc/webircgateway/" + strings.ReplaceAll(dir, "\\", "/") + "\"\n")
+	}
+
+	file.WriteString(")\n\n")
+	file.WriteString("func LoadInternalPlugins(gateway *webircgateway.Gateway, pluginsQuit *sync.WaitGroup) {\n")
+
+	if len(newPlugins) == 0 {
+		file.WriteString("\t// No internal plugins to load\n")
+	}
+
+	for _, v := range newPlugins {
+		dir := filepath.Dir(v)
+		file.WriteString("\tif arrayContains(gateway.Config.InternalPlugins, \"" + filepath.Base(dir) + "\") {\n")
+		file.WriteString("\t\tplugin" + strings.Title(filepath.Base(dir)) + ".Start(gateway, pluginsQuit)\n")
+		file.WriteString("\t}\n")
+	}
+	file.WriteString("}\n\n")
+
+	file.WriteString("func arrayContains(a []string, v string) bool {\n")
+	file.WriteString("\tfor _, s := range a {\n")
+	file.WriteString("\t\tif s == v {\n")
+	file.WriteString("\t\t\treturn true\n")
+	file.WriteString("\t\t}\n")
+	file.WriteString("\t}\n")
+	file.WriteString("\treturn false\n")
+	file.WriteString("}\n")
+}
+
+func findPlugins() {
+	err := filepath.Walk("./plugins", func(path string, info os.FileInfo, err error) error {
+		if err != nil {
+			fmt.Printf("failure accessing path %q: %v\n", path, err)
+			return err
+		}
+		if strings.HasSuffix(path, "plugin.go") {
+			foundPlugin(path)
+		}
+		return nil
+	})
+	if err != nil {
+		fmt.Printf("error walking the path: %v\n", err)
+		return
+	}
+}
+
+func foundPlugin(path string) {
+	file, err := os.Open(path)
+	if err != nil {
+		fmt.Printf("error reading file: %s %s\n", path, err)
+		return
+	}
+	isMain := false
+	scanner := bufio.NewScanner(file)
+	for scanner.Scan() {
+		if scanner.Text() == "package main" {
+			isMain = true
+			break
+		}
+	}
+
+	newPath := strings.ReplaceAll(path, "\\", "/")
+
+	if !isMain {
+		fmt.Printf("adding: %s\n", newPath)
+		newPlugins = append(newPlugins, newPath)
+	}
+}

main.go

@@ -10,6 +10,7 @@ import (
 	"sync"
 	"syscall"
 
+	"github.com/kiwiirc/webircgateway/pkg/plugins"
 	"github.com/kiwiirc/webircgateway/pkg/webircgateway"
 )
 
@@ -95,6 +96,7 @@ func printLogOutput(gateway *webircgateway.Gateway) {
 }
 
 func loadPlugins(gateway *webircgateway.Gateway, pluginsQuit *sync.WaitGroup) {
+	plugins.LoadInternalPlugins(gateway, pluginsQuit)
 	for _, pluginPath := range gateway.Config.Plugins {
 		pluginFullPath := gateway.Config.ResolvePath(pluginPath)
 

pkg/plugins/plugins.go

@@ -0,0 +1,20 @@
+package plugins
+
+import (
+	"sync"
+
+	"github.com/kiwiirc/webircgateway/pkg/webircgateway"
+)
+
+func LoadInternalPlugins(gateway *webircgateway.Gateway, pluginsQuit *sync.WaitGroup) {
+	// No internal plugins to load
+}
+
+func arrayContains(a []string, v string) bool {
+	for _, s := range a {
+		if s == v {
+			return true
+		}
+	}
+	return false
+}

pkg/webircgateway/config.go

@@ -77,6 +77,7 @@ type Config struct {
 	ReCaptchaKey          string
 	Secret                string
 	Plugins               []string
+	InternalPlugins       []string
 }
 
 func NewConfig(gateway *Gateway) *Config {
@@ -273,6 +274,12 @@ func (c *Config) Load() error {
 			}
 		}
 
+		if strings.Index(section.Name(), "internal_plugins") == 0 {
+			for _, plugin := range section.KeyStrings() {
+				c.InternalPlugins = append(c.InternalPlugins, strings.Trim(plugin, "\n"))
+			}
+		}
+
 		if strings.Index(section.Name(), "allowed_origins") == 0 {
 			for _, origin := range section.KeyStrings() {
 				match, err := glob.Compile(origin)