feat(bot): berty-bot-example automatically replies to incoming messages

client/go/bot/examples/berty-bot-example/main.go

@@ -2,9 +2,11 @@ package main
 
 import (
 	"flag"
+	"fmt"
 	"log"
 
 	"berty.tech/client/go/bot"
+	"berty.tech/core/entity"
 )
 
 var addr = flag.String("addr", "127.0.0.1:1337", "daemon gRPC address")
@@ -21,18 +23,8 @@ func main() {
 		panic(err)
 	}
 
-	b.AddHandlerFunc(func(b *bot.Bot, e *bot.Event) error {
-		// do stuff
-		return nil
-	})
-	b.AddHandler(bot.Trigger{
-		If: func(b *bot.Bot, e *bot.Event) bool {
-			return true
-		},
-		Then: func(b *bot.Bot, e *bot.Event) error {
-			// do stuff
-			return nil
-		},
+	b.AddMessageHandlerFunc(func(b *bot.Bot, e *bot.Event, msg *entity.Message) error {
+		return b.Reply(e, &entity.Message{Text: fmt.Sprintf("hello! (%s)", msg.Text)})
 	})
 
 	log.Println("starting bot...")

client/go/bot/handler.go

@@ -1,5 +1,10 @@
 package bot
 
+import (
+	"berty.tech/core/api/p2p"
+	"berty.tech/core/entity"
+)
+
 //
 // Handler
 //
@@ -45,3 +50,24 @@ func (t Trigger) Handle(bot *Bot, event *Event) error {
 	}
 	return nil
 }
+
+//
+// MessageHandler
+//
+
+type MessageHandlerFunc func(*Bot, *Event, *entity.Message) error
+
+func (b *Bot) AddMessageHandlerFunc(f MessageHandlerFunc) {
+	b.AddHandler(Trigger{
+		If: func(b *Bot, e *Event) bool {
+			return e.Kind == p2p.Kind_ConversationNewMessage
+		},
+		Then: func(b *Bot, e *Event) error {
+			nm, err := e.GetConversationNewMessageAttrs()
+			if err != nil {
+				return err
+			}
+			return f(b, e, nm.Message)
+		},
+	})
+}

client/go/bot/message.go

@@ -0,0 +1,14 @@
+package bot
+
+import (
+	"berty.tech/core/api/node"
+	"berty.tech/core/entity"
+)
+
+func (b *Bot) Reply(e *Event, m *entity.Message) error {
+	_, err := b.client.Node().ConversationAddMessage(e.ctx, &node.ConversationAddMessageInput{
+		Conversation: &entity.Conversation{ID: e.ConversationID},
+		Message:      m,
+	})
+	return err
+}

client/go/bot/option.go

@@ -47,7 +47,6 @@ func WithAutoAcceptInvites() Option {
 			if e.Kind != p2p.Kind_ContactRequest {
 				return nil
 			}
-
 			_, err := b.client.Node().ContactAcceptRequest(e.ctx, &entity.Contact{
 				ID: e.SenderID,
 			})