mirror of
https://github.com/hanzoai/team.git
synced 2026-09-30 01:57:35 +00:00
zeekay
8feb24ea1f
The server module named github.com/hanzoai/team/server/v8 — a path that resolves to the retired workspace's repository, not this one — while server/public still published github.com/mattermost/mattermost/server/public. Both are github.com/hanzoteam/server/... now, which is where this code actually lives. That second half is what made the binary unbootable. Upstream's public path stayed claimed by upstream, mattermost-plugin-ai imported it, and the build linked public/model twice; public/plugin's gob.Register then ran twice under one name and panicked at init, before main. Reverting the rename traded the brand for a working binary. Rebranding the plugin alongside it needs no such trade: the agents fork is github.com/hanzoteam/agents/v2 against our public module, so no module named mattermost/mattermost is in the graph at all. Measured: `go list -deps ./cmd/mattermost` names exactly one public/model, and it is ours.
89 lines
3.1 KiB
Go
89 lines
3.1 KiB
Go
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
package sharedchannel
|
|
|
|
import (
|
|
"net/url"
|
|
"regexp"
|
|
"strings"
|
|
|
|
"github.com/hanzoteam/server/server/public/model"
|
|
"github.com/hanzoteam/server/server/public/shared/i18n"
|
|
"github.com/hanzoteam/server/server/public/shared/mlog"
|
|
"github.com/hanzoteam/server/server/public/shared/request"
|
|
)
|
|
|
|
var (
|
|
// Team name regex taken from model.IsValidTeamName
|
|
permaLinkRegex = regexp.MustCompile(`https?://[0-9.\-A-Za-z]+/[a-z0-9]+([a-z\-0-9]+|(__)?)[a-z0-9]+/pl/([a-zA-Z0-9]+)`)
|
|
permaLinkSharedRegex = regexp.MustCompile(`https?://[0-9.\-A-Za-z]+/[a-z0-9]+([a-z\-0-9]+|(__)?)[a-z0-9]+/plshared/([a-zA-Z0-9]+)`)
|
|
)
|
|
|
|
const (
|
|
permalinkMarker = "plshared"
|
|
)
|
|
|
|
// processPermalinkToRemote processes all permalinks going towards a remote site.
|
|
func (scs *Service) processPermalinkToRemote(p *model.Post) string {
|
|
// request.CTX is not widely used in the shared channels code.
|
|
// Just create a new request.CTX for now.
|
|
rctx := request.EmptyContext(scs.server.Log())
|
|
|
|
var sent bool
|
|
return permaLinkRegex.ReplaceAllStringFunc(p.Message, func(msg string) string {
|
|
// Extract the postID (This is simple enough not to warrant full-blown URL parsing.)
|
|
lastSlash := strings.LastIndexByte(msg, '/')
|
|
postID := msg[lastSlash+1:]
|
|
opts := model.GetPostsOptions{
|
|
SkipFetchThreads: true,
|
|
}
|
|
postList, err := scs.server.GetStore().Post().Get(rctx, postID, opts, "", map[string]bool{})
|
|
if err != nil {
|
|
scs.server.Log().LogM(mlog.MlvlSharedChannelServiceWarn, "Unable to get post during replacing permalinks", mlog.Err(err))
|
|
return msg
|
|
}
|
|
if len(postList.Order) == 0 {
|
|
scs.server.Log().LogM(mlog.MlvlSharedChannelServiceWarn, "No post found for permalink", mlog.String("postID", postID))
|
|
return msg
|
|
}
|
|
|
|
// If postID is for a different channel
|
|
if postList.Posts[postList.Order[0]].ChannelId != p.ChannelId {
|
|
// Send ephemeral message to OP (only once per message).
|
|
if !sent {
|
|
scs.sendEphemeralPost(p.ChannelId, p.UserId, i18n.T("sharedchannel.permalink.not_found"))
|
|
sent = true
|
|
}
|
|
// But don't modify msg
|
|
return msg
|
|
}
|
|
|
|
// Otherwise, modify pl to plshared as a marker to be replaced by remote sites
|
|
return strings.Replace(msg, "/pl/", "/"+permalinkMarker+"/", 1)
|
|
})
|
|
}
|
|
|
|
// processPermalinkFromRemote processes all permalinks coming from a remote site.
|
|
func (scs *Service) processPermalinkFromRemote(p *model.Post, team *model.Team) string {
|
|
return permaLinkSharedRegex.ReplaceAllStringFunc(p.Message, func(remoteLink string) string {
|
|
// Extract host name
|
|
parsed, err := url.Parse(remoteLink)
|
|
if err != nil {
|
|
scs.server.Log().LogM(mlog.MlvlSharedChannelServiceWarn, "Unable to parse the remote link during replacing permalinks", mlog.Err(err))
|
|
return remoteLink
|
|
}
|
|
|
|
// Replace with local SiteURL
|
|
parsed.Scheme = scs.siteURL.Scheme
|
|
parsed.Host = scs.siteURL.Host
|
|
|
|
// Replace team name with local team
|
|
teamEnd := strings.Index(parsed.Path, "/"+permalinkMarker)
|
|
parsed.Path = "/" + team.Name + parsed.Path[teamEnd:]
|
|
|
|
// Replace plshared with pl
|
|
return strings.Replace(parsed.String(), "/"+permalinkMarker+"/", "/pl/", 1)
|
|
})
|
|
}
|