LocalAI/LocalAGI
1
0
Fork 0
mirror of https://github.com/mudler/LocalAGI.git synced 2026-07-24 03:10:46 -04:00
Code Issues Packages Projects Releases Wiki Activity

fix(slack): another attempt to fix markdown result display (#422)

Browse Source 
Signed-off-by: Ettore Di Giacinto <mudler@localai.io>
This commit is contained in:
Ettore Di Giacinto
2026-02-20 23:15:02 +01:00
committed by GitHub
parent 3828dd7ccc
commit 52e8df6599
1 changed files with 18 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
services/connectors/slack.go
+18 -15
View File
@@ -514,9 +514,8 @@ func (t *Slack) handleChannelMessage(
xlog.Debug("After adding message to conversation tracker", "conversation", a.SharedState().ConversationTracker.GetConversation(fmt.Sprintf("slack:%s", t.channelID)))
//res.Response = githubmarkdownconvertergo.Slack(res.Response)
replyWithPostMessage(res.Response, api, ev, postMessageParams, res)
convertedResponse := githubmarkdownconvertergo.Slack(res.Response)
replyWithPostMessage(convertedResponse, api, ev, postMessageParams, res)
}()
}
@@ -531,7 +530,7 @@ func replyWithPostMessage(finalResponse string, api *slack.Client, ev *slackeven
_, _, err := api.PostMessage(ev.Channel,
slack.MsgOptionLinkNames(true),
slack.MsgOptionEnableLinkUnfurl(),
slack.MsgOptionText(message, true),
slack.MsgOptionText(message, false),
slack.MsgOptionPostMessageParameters(postMessageParams),
slack.MsgOptionAttachments(generateAttachmentsFromJobResponse(res, api, ev.Channel, "")...),
)
@@ -543,7 +542,7 @@ func replyWithPostMessage(finalResponse string, api *slack.Client, ev *slackeven
_, _, err := api.PostMessage(ev.Channel,
slack.MsgOptionLinkNames(true),
slack.MsgOptionEnableLinkUnfurl(),
slack.MsgOptionText(res.Response, true),
slack.MsgOptionText(finalResponse, false),
slack.MsgOptionPostMessageParameters(postMessageParams),
slack.MsgOptionAttachments(generateAttachmentsFromJobResponse(res, api, ev.Channel, "")...),
// slack.MsgOptionTS(ts),
@@ -554,7 +553,7 @@ func replyWithPostMessage(finalResponse string, api *slack.Client, ev *slackeven
}
}
func replyToUpdateMessage(finalResponse string, api *slack.Client, ev *slackevents.AppMentionEvent, msgTs string, ts string, res *types.JobResult) {
func replyToUpdateMessage(finalResponse string, api *slack.Client, ev *slackevents.AppMentionEvent, msgTs string, ts string, postMessageParams slack.PostMessageParameters, res *types.JobResult) {
if len(finalResponse) > 3000 {
// split response in multiple messages, and update the first
@@ -565,7 +564,8 @@ func replyToUpdateMessage(finalResponse string, api *slack.Client, ev *slackeven
msgTs,
slack.MsgOptionLinkNames(true),
slack.MsgOptionEnableLinkUnfurl(),
slack.MsgOptionText(messages[0], true),
slack.MsgOptionText(messages[0], false),
slack.MsgOptionPostMessageParameters(postMessageParams),
slack.MsgOptionAttachments(generateAttachmentsFromJobResponse(res, api, ev.Channel, msgTs)...),
)
if err != nil {
@@ -579,7 +579,8 @@ func replyToUpdateMessage(finalResponse string, api *slack.Client, ev *slackeven
_, _, err = api.PostMessage(ev.Channel,
slack.MsgOptionLinkNames(true),
slack.MsgOptionEnableLinkUnfurl(),
slack.MsgOptionText(message, true),
slack.MsgOptionText(message, false),
slack.MsgOptionPostMessageParameters(postMessageParams),
slack.MsgOptionTS(ts),
)
if err != nil {
@@ -592,7 +593,8 @@ func replyToUpdateMessage(finalResponse string, api *slack.Client, ev *slackeven
msgTs,
slack.MsgOptionLinkNames(true),
slack.MsgOptionEnableLinkUnfurl(),
slack.MsgOptionText(finalResponse, true),
slack.MsgOptionText(finalResponse, false),
slack.MsgOptionPostMessageParameters(postMessageParams),
slack.MsgOptionAttachments(generateAttachmentsFromJobResponse(res, api, ev.Channel, msgTs)...),
)
if err != nil {
@@ -742,7 +744,7 @@ func (t *Slack) handleMention(
if res.Response == "" {
xlog.Debug(fmt.Sprintf("Empty response from agent"))
replyToUpdateMessage("there was an internal error. try again!", api, ev, msgTs, ts, res)
replyToUpdateMessage("there was an internal error. try again!", api, ev, msgTs, ts, postMessageParams, res)
// _, _, err := api.DeleteMessage(ev.Channel, msgTs)
// if err != nil {
@@ -757,12 +759,12 @@ func (t *Slack) handleMention(
xlog.Error(fmt.Sprintf("Error getting user info: %v", err))
}
// Format the final response
//finalResponse := githubmarkdownconvertergo.Slack(res.Response)
finalResponse := fmt.Sprintf("@%s %s", user.Name, res.Response)
// Format the final response (convert GitHub markdown to Slack mrkdwn)
convertedResponse := githubmarkdownconvertergo.Slack(res.Response)
finalResponse := fmt.Sprintf("@%s %s", user.Name, convertedResponse)
xlog.Debug("Send final response to slack", "response", finalResponse)
replyToUpdateMessage(finalResponse, api, ev, msgTs, ts, res)
replyToUpdateMessage(finalResponse, api, ev, msgTs, ts, postMessageParams, res)
// Clean up the placeholder map
t.placeholderMutex.Lock()
@@ -790,10 +792,11 @@ func (t *Slack) Start(a *agent.Agent) {
// handle new conversations
a.AddSubscriber(func(ccm *types.ConversationMessage) {
xlog.Debug("Subscriber(slack)", "message", ccm.Message.Content)
convertedContent := githubmarkdownconvertergo.Slack(ccm.Message.Content)
_, _, err := api.PostMessage(t.channelID,
slack.MsgOptionLinkNames(true),
slack.MsgOptionEnableLinkUnfurl(),
slack.MsgOptionText(ccm.Message.Content, true),
slack.MsgOptionText(convertedContent, false),
slack.MsgOptionPostMessageParameters(postMessageParams),
)
if err != nil {