alex/LocalAGI
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Slack: no need of serial messages. in this way can be interrupted

Browse Source
This commit is contained in:
mudler
2024-04-10 20:29:30 +02:00
parent 69cbcc5c88
commit 0dda705017
1 changed files with 22 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
example/webui/connector/slack.go
View File

@@ -101,6 +101,7 @@ func (t *Slack) Start(a *agent.Agent) {
} }
message := ev.Text message := ev.Text
go func() {
res := a.Ask( res := a.Ask(
agent.WithText(message), agent.WithText(message),
) )
@@ -111,6 +112,7 @@ func (t *Slack) Start(a *agent.Agent) {
if err != nil { if err != nil {
fmt.Printf("Error posting message: %v", err) fmt.Printf("Error posting message: %v", err)
} }
}()
case *slackevents.AppMentionEvent: case *slackevents.AppMentionEvent:
if b.UserID == ev.User { if b.UserID == ev.User {
@@ -123,6 +125,7 @@ func (t *Slack) Start(a *agent.Agent) {
message = strings.ReplaceAll(message, "<@"+b.UserID+"> ", "") message = strings.ReplaceAll(message, "<@"+b.UserID+"> ", "")
fmt.Println("Message", message) fmt.Println("Message", message)
go func() {
res := a.Ask( res := a.Ask(
agent.WithText(message), agent.WithText(message),
) )
@@ -133,6 +136,7 @@ func (t *Slack) Start(a *agent.Agent) {
if err != nil { if err != nil {
fmt.Printf("Error posting message: %v", err) fmt.Printf("Error posting message: %v", err)
} }
}()
case *slackevents.MemberJoinedChannelEvent: case *slackevents.MemberJoinedChannelEvent:
fmt.Printf("user %q joined to channel %q", ev.User, ev.Channel) fmt.Printf("user %q joined to channel %q", ev.User, ev.Channel)
} }