Add slack connector

example/webui/agentpool.go

@@ -120,6 +120,7 @@ func (a *AgentPool) List() []string {
 
 const (
 	ConnectorTelegram = "telegram"
+	ConnectorSlack    = "slack"
 	ActionSearch      = "search"
 )
 
@@ -153,7 +154,7 @@ type Connector interface {
 	Start(a *Agent)
 }
 
-var AvailableConnectors = []string{ConnectorTelegram}
+var AvailableConnectors = []string{ConnectorTelegram, ConnectorSlack}
 
 func (a *AgentConfig) availableConnectors() []Connector {
 	connectors := []Connector{}
@@ -177,6 +178,8 @@ func (a *AgentConfig) availableConnectors() []Connector {
 			}
 
 			connectors = append(connectors, cc)
+		case ConnectorSlack:
+			connectors = append(connectors, connector.NewSlack(config))
 		}
 	}
 	return connectors

example/webui/connector/slack.go

@@ -0,0 +1,132 @@
+package connector
+
+import (
+	"fmt"
+	"log"
+	"os"
+
+	"github.com/mudler/local-agent-framework/agent"
+
+	"github.com/slack-go/slack/socketmode"
+
+	"github.com/slack-go/slack"
+	"github.com/slack-go/slack/slackevents"
+)
+
+type Slack struct {
+	appToken string
+	botToken string
+}
+
+func NewSlack(config map[string]string) *Slack {
+	return &Slack{
+		appToken: config["appToken"],
+		botToken: config["botToken"],
+	}
+}
+
+func (t *Slack) AgentResultCallback() func(state agent.ActionState) {
+	return func(state agent.ActionState) {
+		// Send the result to the bot
+	}
+}
+
+func (t *Slack) AgentReasoningCallback() func(state agent.ActionCurrentState) bool {
+	return func(state agent.ActionCurrentState) bool {
+		// Send the reasoning to the bot
+		return true
+	}
+}
+
+func (t *Slack) Start(a *agent.Agent) {
+	api := slack.New(
+		t.botToken,
+		slack.OptionDebug(true),
+		slack.OptionLog(log.New(os.Stdout, "api: ", log.Lshortfile|log.LstdFlags)),
+		slack.OptionAppLevelToken(t.appToken),
+	)
+
+	client := socketmode.New(
+		api,
+		socketmode.OptionDebug(true),
+		socketmode.OptionLog(log.New(os.Stdout, "socketmode: ", log.Lshortfile|log.LstdFlags)),
+	)
+	go func() {
+		for evt := range client.Events {
+			switch evt.Type {
+			case socketmode.EventTypeConnecting:
+				fmt.Println("Connecting to Slack with Socket Mode...")
+			case socketmode.EventTypeConnectionError:
+				fmt.Println("Connection failed. Retrying later...")
+			case socketmode.EventTypeConnected:
+				fmt.Println("Connected to Slack with Socket Mode.")
+			case socketmode.EventTypeEventsAPI:
+				eventsAPIEvent, ok := evt.Data.(slackevents.EventsAPIEvent)
+				if !ok {
+					fmt.Printf("Ignored %+v\n", evt)
+
+					continue
+				}
+
+				fmt.Printf("Event received: %+v\n", eventsAPIEvent)
+
+				client.Ack(*evt.Request)
+
+				switch eventsAPIEvent.Type {
+				case slackevents.CallbackEvent:
+					innerEvent := eventsAPIEvent.InnerEvent
+
+					b, err := api.AuthTest()
+					if err != nil {
+						fmt.Printf("Error getting auth test: %v", err)
+					}
+
+					switch ev := innerEvent.Data.(type) {
+					case *slackevents.MessageEvent:
+
+						if b.UserID == ev.User {
+							// Skip messages from ourselves
+							return
+						}
+						message := ev.Text
+						res := a.Ask(
+							agent.WithText(message),
+						)
+						_, _, err = api.PostMessage(ev.Channel,
+							slack.MsgOptionText(res.Response, false),
+							slack.MsgOptionPostMessageParameters(slack.PostMessageParameters{LinkNames: 1}))
+						if err != nil {
+							fmt.Printf("Error posting message: %v", err)
+						}
+					case *slackevents.AppMentionEvent:
+
+						if b.UserID == ev.User {
+							// Skip messages from ourselves
+							return
+						}
+						message := ev.Text
+
+						res := a.Ask(
+							agent.WithText(message),
+						)
+
+						_, _, err = api.PostMessage(ev.Channel,
+							slack.MsgOptionText(res.Response, false),
+							slack.MsgOptionPostMessageParameters(slack.PostMessageParameters{LinkNames: 1}))
+						if err != nil {
+							fmt.Printf("Error posting message: %v", err)
+						}
+					case *slackevents.MemberJoinedChannelEvent:
+						fmt.Printf("user %q joined to channel %q", ev.User, ev.Channel)
+					}
+				default:
+					client.Debugf("unsupported Events API event received")
+				}
+			default:
+				fmt.Fprintf(os.Stderr, "Unexpected event type received: %s\n", evt.Type)
+			}
+		}
+	}()
+
+	client.RunContext(a.Context())
+}