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

Reply to mentions in threads

Browse Source
This commit is contained in:
mudler
2025-02-28 19:30:12 +01:00
parent 094580724f
commit fbcc618355
1 changed files with 16 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
services/connectors/slack.go
View File

@@ -107,10 +107,12 @@ func (t *Slack) Start(a *agent.Agent) {
res := a.Ask( res := a.Ask(
agent.WithText(message), agent.WithText(message),
) )
ts := ev.ThreadTimeStamp
_, _, err = api.PostMessage(ev.Channel, _, _, err = api.PostMessage(ev.Channel,
slack.MsgOptionText(res.Response, false), slack.MsgOptionText(res.Response, false),
slack.MsgOptionPostMessageParameters(slack.PostMessageParameters{LinkNames: 1})) slack.MsgOptionPostMessageParameters(slack.PostMessageParameters{LinkNames: 1}),
slack.MsgOptionTS(ts))
if err != nil { if err != nil {
fmt.Printf("Error posting message: %v", err) fmt.Printf("Error posting message: %v", err)
} }
@@ -132,9 +134,19 @@ func (t *Slack) Start(a *agent.Agent) {
agent.WithText(message), agent.WithText(message),
) )
_, _, err = api.PostMessage(ev.Channel, ts := ev.ThreadTimeStamp
slack.MsgOptionText(res.Response, false),
slack.MsgOptionPostMessageParameters(slack.PostMessageParameters{LinkNames: 1})) if ts != "" {
_, _, err = api.PostMessage(ev.Channel,
slack.MsgOptionText(res.Response, false),
slack.MsgOptionPostMessageParameters(slack.PostMessageParameters{LinkNames: 1}),
slack.MsgOptionTS(ts))
} else {
_, _, err = api.PostMessage(ev.Channel,
slack.MsgOptionText(res.Response, false),
slack.MsgOptionPostMessageParameters(slack.PostMessageParameters{LinkNames: 1}),
slack.MsgOptionTS(ev.TimeStamp))
}
if err != nil { if err != nil {
fmt.Printf("Error posting message: %v", err) fmt.Printf("Error posting message: %v", err)
} }