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

refactors

Browse Source
This commit is contained in:
Ettore Di Giacinto
2025-02-28 23:02:04 +01:00
parent 5b4f618ca3
commit 70c389ce0b
1 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
services/connectors/slack.go
View File

@@ -63,6 +63,11 @@ func (t *Slack) Start(a *agent.Agent) {
slack.OptionAppLevelToken(t.appToken), slack.OptionAppLevelToken(t.appToken),
) )
postMessageParams := slack.PostMessageParameters{
LinkNames: 1,
Markdown: true,
}
client := socketmode.New( client := socketmode.New(
api, api,
//socketmode.OptionDebug(true), //socketmode.OptionDebug(true),
@@ -113,7 +118,7 @@ func (t *Slack) Start(a *agent.Agent) {
message := cleanUpUsernameFromMessage(ev.Text, b) message := cleanUpUsernameFromMessage(ev.Text, b)
go func() { go func() {
ts := ev.ThreadTimeStamp //ts := ev.ThreadTimeStamp
res := a.Ask( res := a.Ask(
agent.WithText(message), agent.WithText(message),
@@ -123,8 +128,9 @@ func (t *Slack) Start(a *agent.Agent) {
_, _, 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, Markdown: true}), slack.MsgOptionPostMessageParameters(postMessageParams),
slack.MsgOptionTS(ts)) // slack.MsgOptionTS(ts),
)
if err != nil { if err != nil {
xlog.Error(fmt.Sprintf("Error posting message: %v", err)) xlog.Error(fmt.Sprintf("Error posting message: %v", err))
} }
@@ -185,12 +191,16 @@ func (t *Slack) Start(a *agent.Agent) {
if ts != "" { if ts != "" {
_, _, 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, Markdown: true}), slack.MsgOptionPostMessageParameters(
postMessageParams,
),
slack.MsgOptionTS(ts)) slack.MsgOptionTS(ts))
} else { } else {
_, _, 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, Markdown: true}), slack.MsgOptionPostMessageParameters(
postMessageParams,
),
slack.MsgOptionTS(ev.TimeStamp)) slack.MsgOptionTS(ev.TimeStamp))
} }
if err != nil { if err != nil {