Added a 'posted' event to TumblrBee

bees/tumblrbee/tumblrbee.go

@@ -40,6 +40,8 @@ type TumblrBee struct {
 	consumerSecret string
 	token          string
 	tokenSecret    string
+
+	evchan chan bees.Event
 }
 
 // Action triggers the action passed to it.
@@ -57,7 +59,14 @@ func (mod *TumblrBee) Action(action bees.Action) []bees.Placeholder {
 			"state": state})
 		if err != nil {
 			mod.LogErrorf("Failed to post text: %v", err)
+			return outs
+		}
+		ev := bees.Event{
+			Bee:     mod.Name(),
+			Name:    "posted",
+			Options: []bees.Placeholder{},
 		}
+		mod.evchan <- ev
 
 	case "post_quote":
 		quote := ""
@@ -72,14 +81,22 @@ func (mod *TumblrBee) Action(action bees.Action) []bees.Placeholder {
 			"state":  state})
 		if err != nil {
 			mod.LogErrorf("Failed to post quote: %v", err)
+			return outs
 		}
+		ev := bees.Event{
+			Bee:     mod.Name(),
+			Name:    "posted",
+			Options: []bees.Placeholder{},
+		}
+		mod.evchan <- ev
 
 	case "follow":
 		blogname := ""
 		action.Options.Bind("blogname", &blogname)
 
 		if err := mod.client.Follow(blogname); err != nil {
 			mod.LogErrorf("Failed to follow blog: %v", err)
+			return outs
 		}
 
 	case "unfollow":
@@ -88,6 +105,7 @@ func (mod *TumblrBee) Action(action bees.Action) []bees.Placeholder {
 
 		if err := mod.client.Unfollow(blogname); err != nil {
 			mod.LogErrorf("Failed to unfollow blog: %v", err)
+			return outs
 		}
 
 	default:
@@ -97,6 +115,16 @@ func (mod *TumblrBee) Action(action bees.Action) []bees.Placeholder {
 	return outs
 }
 
+// Run executes the Bee's event loop.
+func (mod *TumblrBee) Run(eventChan chan bees.Event) {
+	mod.evchan = eventChan
+
+	select {
+	case <-mod.SigChan:
+		return
+	}
+}
+
 // ReloadOptions parses the config options and initializes the Bee.
 func (mod *TumblrBee) ReloadOptions(options bees.BeeOptions) {
 	mod.SetOptions(options)

bees/tumblrbee/tumblrbeefactory.go

@@ -107,6 +107,19 @@ func (factory *TumblrBeeFactory) Options() []bees.BeeOptionDescriptor {
 	return opts
 }
 
+// Events describes the available events provided by this Bee.
+func (factory *TumblrBeeFactory) Events() []bees.EventDescriptor {
+	events := []bees.EventDescriptor{
+		{
+			Namespace:   factory.Name(),
+			Name:        "posted",
+			Description: "is triggered when you posted something",
+			Options:     []bees.PlaceholderDescriptor{},
+		},
+	}
+	return events
+}
+
 // Actions describes the available actions provided by this Bee.
 func (factory *TumblrBeeFactory) Actions() []bees.ActionDescriptor {
 	actions := []bees.ActionDescriptor{