How to use addPlugin method of plugin Package

1package main2import (3	"io/ioutil"4	"net"5	"strconv"6	"strings"7	"time"8	"github.com/alecthomas/kingpin"9	"github.com/jmoiron/sqlx"10	"github.com/sgt-kabukiman/kabukibot/bot"11	"github.com/sgt-kabukiman/kabukibot/plugin/acl"12	"github.com/sgt-kabukiman/kabukibot/plugin/banhammer_bot"13	"github.com/sgt-kabukiman/kabukibot/plugin/blacklist"14	"github.com/sgt-kabukiman/kabukibot/plugin/content"15	"github.com/sgt-kabukiman/kabukibot/plugin/custom_commands"16	"github.com/sgt-kabukiman/kabukibot/plugin/dictionary"17	"github.com/sgt-kabukiman/kabukibot/plugin/domain_ban"18	"github.com/sgt-kabukiman/kabukibot/plugin/echo"19	"github.com/sgt-kabukiman/kabukibot/plugin/emote_counter"20	"github.com/sgt-kabukiman/kabukibot/plugin/join"21	"github.com/sgt-kabukiman/kabukibot/plugin/log"22	"github.com/sgt-kabukiman/kabukibot/plugin/monitor"23	"github.com/sgt-kabukiman/kabukibot/plugin/ping"24	"github.com/sgt-kabukiman/kabukibot/plugin/plugin_control"25	"github.com/sgt-kabukiman/kabukibot/plugin/speedruncom"26	"github.com/sgt-kabukiman/kabukibot/plugin/subhype"27	"github.com/sgt-kabukiman/kabukibot/plugin/sysinfo"28	"github.com/sgt-kabukiman/kabukibot/plugin/troll"29	"github.com/sgt-kabukiman/kabukibot/twitch"30)31var (32	configFile   = kingpin.Flag("config", "Path to the config file to use").Required().String()33	channelsFile = kingpin.Flag("channels", "Path to a file of channels to join after connecting").String()34	debug        = kingpin.Flag("debug", "Enable debug output").Bool()35)36func main() {37	kingpin.Parse()38	// create logger39	level := bot.LogLevelInfo40	if *debug {41		level = bot.LogLevelDebug42	}43	logger := bot.NewLogger(level)44	// load configuration45	logger.Info("Loading configuration file @ " + *configFile + "...")46	config, err := bot.LoadConfiguration(*configFile)47	if err != nil {48		logger.Fatal(err.Error())49	}50	var channels []string51	if *channelsFile != "" {52		logger.Info("Reading initial channel list @ " + *channelsFile + "...")53		data, err := ioutil.ReadFile(*channelsFile)54		if err != nil {55			logger.Fatal(err.Error())56		}57		channels = strings.Split(string(data), "\n")58	}59	// connect to database60	logger.Info("Connecting to database...")61	db, err := sqlx.Connect("mysql", config.Database.DSN)62	if err != nil {63		logger.Fatal(err.Error())64	}65	// setup our TwitchClient66	server := net.JoinHostPort(config.IRC.Host, strconv.Itoa(config.IRC.Port))67	twitch := twitch.NewTwitchClient(server, config.Account.Username, config.Account.Password, 2*time.Second, logger)68	// build the bot69	kabukibot, err := bot.NewKabukibot(twitch, logger, db, config)70	if err != nil {71		logger.Fatal(err.Error())72	}73	// add plugins74	kabukibot.AddPlugin(blacklist.NewPlugin()) // load this as early as possible, because users will only be blacklisted for all following plugins75	kabukibot.AddPlugin(log.NewPlugin())76	kabukibot.AddPlugin(ping.NewPlugin())77	kabukibot.AddPlugin(join.NewPlugin())78	kabukibot.AddPlugin(acl.NewPlugin())79	kabukibot.AddPlugin(plugin_control.NewPlugin())80	kabukibot.AddPlugin(speedruncom.NewPlugin())81	kabukibot.AddPlugin(echo.NewPlugin())82	kabukibot.AddPlugin(sysinfo.NewPlugin())83	kabukibot.AddPlugin(dictionary.NewPlugin())84	kabukibot.AddPlugin(domain_ban.NewPlugin())85	kabukibot.AddPlugin(banhammer_bot.NewPlugin())86	kabukibot.AddPlugin(emote_counter.NewPlugin())87	kabukibot.AddPlugin(subhype.NewPlugin())88	kabukibot.AddPlugin(troll.NewPlugin())89	kabukibot.AddPlugin(monitor.NewPlugin())90	kabukibot.AddPlugin(custom_commands.NewPlugin())91	kabukibot.AddPlugin(content.NewGTAPlugin())92	kabukibot.AddPlugin(content.NewCrashPlugin())93	kabukibot.AddPlugin(content.NewChattyPlugin())94	kabukibot.AddPlugin(content.NewSDAPlugin())95	kabukibot.AddPlugin(content.NewESAPlugin())96	// here we go97	err = kabukibot.Connect()98	if err != nil {99		logger.Fatal(err.Error())100	}101	// do your thing, kabukibot102	logger.Info("Letting the magic happen...")103	go kabukibot.Work()104	for _, cn := range channels {105		<-kabukibot.Join(cn)106	}107	// wait for disconnect108	<-kabukibot.Alive()109}...

...30}31func cleanCacheDir(t *testing.T, cacheDir string) {32	_ = os.RemoveAll(cacheDir)33}34func addPlugin(t *testing.T) {35	addPlugin := rc.Calls.Get("pluginsctl/addPlugin")36	assert.NotNil(t, addPlugin)37	in := rc.Params{38		"url": testPluginURL,39	}40	out, err := addPlugin.Fn(context.Background(), in)41	if err != nil && strings.Contains(err.Error(), "bad HTTP status") {42		t.Skipf("skipping test as plugin download failed: %v", err)43	}44	require.Nil(t, err)45	assert.Nil(t, out)46}47func removePlugin(t *testing.T) {48	addPlugin := rc.Calls.Get("pluginsctl/removePlugin")49	assert.NotNil(t, addPlugin)50	in := rc.Params{51		"name": testPluginKey,52	}53	out, err := addPlugin.Fn(context.Background(), in)54	assert.NotNil(t, err)55	assert.Nil(t, out)56}57//func TestListTestPlugins(t *testing.T) {58//	addPlugin := rc.Calls.Get("pluginsctl/listTestPlugins")59//	assert.NotNil(t, addPlugin)60//	in := rc.Params{}61//	out, err := addPlugin.Fn(context.Background(), in)62//	assert.Nil(t, err)63//	expected := rc.Params{64//		"loadedTestPlugins": map[string]PackageJSON{},65//	}66//	assert.Equal(t, expected, out)67//}68//func TestRemoveTestPlugin(t *testing.T) {69//	addPlugin := rc.Calls.Get("pluginsctl/removeTestPlugin")70//	assert.NotNil(t, addPlugin)71//	in := rc.Params{72//		"name": "",73//	}74//	out, err := addPlugin.Fn(context.Background(), in)75//	assert.NotNil(t, err)76//	assert.Nil(t, out)77//}78func TestAddPlugin(t *testing.T) {79	cacheDir := setCacheDir(t)80	defer cleanCacheDir(t, cacheDir)81	addPlugin(t)82	_, ok := loadedPlugins.LoadedPlugins[testPluginKey]83	assert.True(t, ok)84	//removePlugin(t)85	//_, ok = loadedPlugins.LoadedPlugins[testPluginKey]86	//assert.False(t, ok)87}88func TestListPlugins(t *testing.T) {89	cacheDir := setCacheDir(t)90	defer cleanCacheDir(t, cacheDir)91	addPlugin := rc.Calls.Get("pluginsctl/listPlugins")92	assert.NotNil(t, addPlugin)93	in := rc.Params{}94	out, err := addPlugin.Fn(context.Background(), in)95	assert.Nil(t, err)96	expected := rc.Params{97		"loadedPlugins":     map[string]PackageJSON{},98		"loadedTestPlugins": map[string]PackageJSON{},99	}100	assert.Equal(t, expected, out)101}102func TestRemovePlugin(t *testing.T) {103	cacheDir := setCacheDir(t)104	defer cleanCacheDir(t, cacheDir)105	addPlugin(t)106	removePluginCall := rc.Calls.Get("pluginsctl/removePlugin")107	assert.NotNil(t, removePlugin)108	in := rc.Params{109		"name": testPluginKey,110	}111	out, err := removePluginCall.Fn(context.Background(), in)112	assert.Nil(t, err)113	assert.Nil(t, out)114	removePlugin(t)115	assert.Equal(t, len(loadedPlugins.LoadedPlugins), 0)116}117func TestPluginsForType(t *testing.T) {118	addPlugin := rc.Calls.Get("pluginsctl/getPluginsForType")119	assert.NotNil(t, addPlugin)120	in := rc.Params{121		"type":       "",122		"pluginType": "FileHandler",123	}124	out, err := addPlugin.Fn(context.Background(), in)125	assert.Nil(t, err)126	assert.NotNil(t, out)127	in = rc.Params{128		"type":       "video/mp4",129		"pluginType": "",130	}131	_, err = addPlugin.Fn(context.Background(), in)132	assert.Nil(t, err)133	assert.NotNil(t, out)134}...

1package main2import (3	"github.com/sgt-kabukiman/kabukibot/bot"4	"github.com/sgt-kabukiman/kabukibot/plugin/acl"5	"github.com/sgt-kabukiman/kabukibot/plugin/banhammer_bot"6	"github.com/sgt-kabukiman/kabukibot/plugin/blacklist"7	"github.com/sgt-kabukiman/kabukibot/plugin/content"8	"github.com/sgt-kabukiman/kabukibot/plugin/custom_commands"9	"github.com/sgt-kabukiman/kabukibot/plugin/dictionary"10	"github.com/sgt-kabukiman/kabukibot/plugin/domain_ban"11	"github.com/sgt-kabukiman/kabukibot/plugin/echo"12	"github.com/sgt-kabukiman/kabukibot/plugin/emote_counter"13	"github.com/sgt-kabukiman/kabukibot/plugin/join"14	"github.com/sgt-kabukiman/kabukibot/plugin/log"15	"github.com/sgt-kabukiman/kabukibot/plugin/monitor"16	"github.com/sgt-kabukiman/kabukibot/plugin/ping"17	"github.com/sgt-kabukiman/kabukibot/plugin/plugin_control"18	"github.com/sgt-kabukiman/kabukibot/plugin/speedruncom"19	"github.com/sgt-kabukiman/kabukibot/plugin/subhype"20	"github.com/sgt-kabukiman/kabukibot/plugin/sysinfo"21	"github.com/sgt-kabukiman/kabukibot/plugin/troll"22	"github.com/sgt-kabukiman/kabukibot/test"23)24func initTester(t *test.Tester) {25	t.AddPlugin("blacklist", func() bot.Plugin {26		return blacklist.NewPlugin()27	})28	t.AddPlugin("log", func() bot.Plugin {29		return log.NewPlugin()30	})31	t.AddPlugin("ping", func() bot.Plugin {32		return ping.NewPlugin()33	})34	t.AddPlugin("join", func() bot.Plugin {35		return join.NewPlugin()36	})37	t.AddPlugin("acl", func() bot.Plugin {38		return acl.NewPlugin()39	})40	t.AddPlugin("plugin_control", func() bot.Plugin {41		return plugin_control.NewPlugin()42	})43	t.AddPlugin("speedruncom", func() bot.Plugin {44		return speedruncom.NewPlugin()45	})46	t.AddPlugin("echo", func() bot.Plugin {47		return echo.NewPlugin()48	})49	t.AddPlugin("sysinfo", func() bot.Plugin {50		return sysinfo.NewPlugin()51	})52	t.AddPlugin("dictionary", func() bot.Plugin {53		return dictionary.NewPlugin()54	})55	t.AddPlugin("domain_ban", func() bot.Plugin {56		return domain_ban.NewPlugin()57	})58	t.AddPlugin("banhammer_bot", func() bot.Plugin {59		return banhammer_bot.NewPlugin()60	})61	t.AddPlugin("emote_counter", func() bot.Plugin {62		return emote_counter.NewPlugin()63	})64	t.AddPlugin("subhype", func() bot.Plugin {65		return subhype.NewPlugin()66	})67	t.AddPlugin("troll", func() bot.Plugin {68		return troll.NewPlugin()69	})70	t.AddPlugin("monitor", func() bot.Plugin {71		return monitor.NewPlugin()72	})73	t.AddPlugin("custom_commands", func() bot.Plugin {74		return custom_commands.NewPlugin()75	})76	t.AddPlugin("gta", func() bot.Plugin {77		return content.NewGTAPlugin()78	})79}...

1import (2func main() {3    p, err := plugin.Open("plugin.so")4    if err != nil {5        panic(err)6    }7    add, err := p.Lookup("Add")8    if err != nil {9        panic(err)10    }11    fmt.Println(add.(func(int, int) int)(2, 3))12}13Golang | plugin.Open()14Golang | plugin.Lookup()15Golang | plugin.Open() vs plugin.OpenFile()16Golang | plugin.Close()17Golang | plugin.Lookup() vs plugin.LookupSymbol()18Golang | plugin.UnsafeSymbols()19Golang | plugin.UnsafeSymbol()

1import (2func main() {3    p, err := plugin.Open("plugin.so")4    if err != nil {5        panic(err)6    }7    addPlugin, err := p.Lookup("AddPlugin")8    if err != nil {9        panic(err)10    }11    removePlugin, err := p.Lookup("RemovePlugin")12    if err != nil {13        panic(err)14    }15    addPlugin.(func(string, string))(pluginName, pluginPath)16    removePlugin.(func(string))(pluginName)17}18import (19func main() {20    p, err := plugin.Open("plugin.so")21    if err != nil {22        panic(err)23    }24    addPlugin, err := p.Lookup("AddPlugin")25    if err != nil {26        panic(err)27    }28    removePlugin, err := p.Lookup("RemovePlugin")29    if err != nil {30        panic(err)31    }32    addPlugin.(func(string, string))(pluginName, pluginPath)33    removePlugin.(func(string))(pluginName)34}35import (36func main() {37    p, err := plugin.Open("plugin.so")38    if err != nil {39        panic(err)40    }41    addPlugin, err := p.Lookup("AddPlugin")42    if err != nil {43        panic(err)44    }45    removePlugin, err := p.Lookup("RemovePlugin")46    if err != nil {47        panic(err)48    }49    addPlugin.(func(string, string))(pluginName, pluginPath)

1var plugin = new Plugin();2plugin.removePlugin("pluginName");3var plugin = new Plugin();4plugin.removePlugin("pluginName");5var plugin = new Plugin();6plugin.removePlugin("pluginName");