bot

type BasicBot interface {
	// a bot that is capable of spawning remote actors
	Remotable
	// ability to plug in functionality
	Pluggable
	// ability to subscribe/ unsubscribe to messages
	Subscribable
	// a bot must have an repository from which to download plugins
	PluggableRepository
	// a bot is an actor so it must have a Receive method
	Receive(ctx actor.Context)
	// a bot's lifecycle should be observable
	LifetimeObservable
}

type Bot struct {
	// contains filtered or unexported fields
}

type FinishedFunc func()

type LifetimeObservable interface {
	// contains filtered or unexported methods
}

type Pluggable interface {
	// Get logger for plugins
	PluginLogger() *log.Logger
	// Get active plugins
	ActivePlugins() []*plgn.PluginIdentifier
	// Add a plugin to active plugins
	AddActivePlugin(plugin *plgn.PluginIdentifier)
	// Remove a plugin from active plugins
	RemoveActivePlugin(plugin *plgn.PluginIdentifier)
	// contains filtered or unexported methods
}

type PluggableRepository interface {
	// remote repository url
	RemoteRepoUrl() string
	// getter and setter
	SetRemoteRepoUrl(url string)
}

type PluginContract struct {
	OnActivated   func(bot *Bot, ctx actor.Context, plugin plgn.Plugin)
	OnDeactivated func(bot *Bot, ctx actor.Context, plugin plgn.Plugin)
	Receive       func(bot *Bot, ctx actor.Context, plugin plgn.Plugin, finished FinishedFunc)
}

type Remotable interface {
	// Get remotes
	Remotes() sets.Set
	// Set remotes
	SetRemotes(remotes sets.Set)
	// Get peers
	// Adds a remote location
	AddRemote(host ...string)
	// Remove a remote location
	RemoveRemote(host ...string)
	// Get peers
	Peers(pid *actor.PID) *actor.PIDSet
	// Set peers
	SetPeers(peers *actor.PIDSet)
	// Add peer
	AddPeer(pid ...*actor.PID)
	// Remove peer
	RemovePeer(pid ...*actor.PID)
	// Spawn a bot on a given node
	SpawnBot(ctx actor.Context, host string, port int) (*actor.PID, error)
	// Kill a bot
	KillBot(ctx actor.Context, pid *actor.PID)
	// contains filtered or unexported methods
}

type Remote struct {
	Host string
	Port int
}

type Subscribable interface {
	// Get subscribers
	Subscribers() map[msg.MessageType]*actor.PIDSet
	// Adds a new subscriber to for a certain messaget type
	// If no message type is specified, a subscription for all messages is created
	AddSubscriber(subscriber *actor.PID, messageTypes ...msg.MessageType)
	// Handle *msg.Unsubscribe message
	RemoveSubscriber(unsubscriber *actor.PID, messageTypes ...msg.MessageType)
	// Notify subscribers about an event
	NotifySubscribers(ctx actor.Context, message interface{})
	// contains filtered or unexported methods
}