From 70c389ce0b047e5d6c3543babce741485a03853f Mon Sep 17 00:00:00 2001 From: Ettore Di Giacinto Date: Fri, 28 Feb 2025 23:02:04 +0100 Subject: [PATCH] refactors --- services/connectors/slack.go | 20 +++++++++++++++----- 1 file changed, 15 insertions(+), 5 deletions(-) diff --git a/services/connectors/slack.go b/services/connectors/slack.go index 8ed44df..0046238 100644 --- a/services/connectors/slack.go +++ b/services/connectors/slack.go @@ -63,6 +63,11 @@ func (t *Slack) Start(a *agent.Agent) { slack.OptionAppLevelToken(t.appToken), ) + postMessageParams := slack.PostMessageParameters{ + LinkNames: 1, + Markdown: true, + } + client := socketmode.New( api, //socketmode.OptionDebug(true), @@ -113,7 +118,7 @@ func (t *Slack) Start(a *agent.Agent) { message := cleanUpUsernameFromMessage(ev.Text, b) go func() { - ts := ev.ThreadTimeStamp + //ts := ev.ThreadTimeStamp res := a.Ask( agent.WithText(message), @@ -123,8 +128,9 @@ func (t *Slack) Start(a *agent.Agent) { _, _, err = api.PostMessage(ev.Channel, slack.MsgOptionText(res.Response, false), - slack.MsgOptionPostMessageParameters(slack.PostMessageParameters{LinkNames: 1, Markdown: true}), - slack.MsgOptionTS(ts)) + slack.MsgOptionPostMessageParameters(postMessageParams), + // slack.MsgOptionTS(ts), + ) if err != nil { xlog.Error(fmt.Sprintf("Error posting message: %v", err)) } @@ -185,12 +191,16 @@ func (t *Slack) Start(a *agent.Agent) { if ts != "" { _, _, err = api.PostMessage(ev.Channel, slack.MsgOptionText(res.Response, false), - slack.MsgOptionPostMessageParameters(slack.PostMessageParameters{LinkNames: 1, Markdown: true}), + slack.MsgOptionPostMessageParameters( + postMessageParams, + ), slack.MsgOptionTS(ts)) } else { _, _, err = api.PostMessage(ev.Channel, slack.MsgOptionText(res.Response, false), - slack.MsgOptionPostMessageParameters(slack.PostMessageParameters{LinkNames: 1, Markdown: true}), + slack.MsgOptionPostMessageParameters( + postMessageParams, + ), slack.MsgOptionTS(ev.TimeStamp)) } if err != nil {