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.
153 lines
4.5 KiB
Go
153 lines
4.5 KiB
Go
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
package slashcommands
|
|
|
|
import (
|
|
"strings"
|
|
|
|
"github.com/hanzoteam/server/server/public/model"
|
|
"github.com/hanzoteam/server/server/public/shared/i18n"
|
|
"github.com/hanzoteam/server/server/public/shared/request"
|
|
"github.com/hanzoteam/server/server/v8/channels/app"
|
|
)
|
|
|
|
type RemoveProvider struct {
|
|
}
|
|
|
|
type KickProvider struct {
|
|
}
|
|
|
|
const (
|
|
CmdRemove = "remove"
|
|
CmdKick = "kick"
|
|
)
|
|
|
|
func init() {
|
|
app.RegisterCommandProvider(&RemoveProvider{})
|
|
app.RegisterCommandProvider(&KickProvider{})
|
|
}
|
|
|
|
func (*RemoveProvider) GetTrigger() string {
|
|
return CmdRemove
|
|
}
|
|
|
|
func (*KickProvider) GetTrigger() string {
|
|
return CmdKick
|
|
}
|
|
|
|
func (*RemoveProvider) GetCommand(a *app.App, T i18n.TranslateFunc) *model.Command {
|
|
return &model.Command{
|
|
Trigger: CmdRemove,
|
|
AutoComplete: true,
|
|
AutoCompleteDesc: T("api.command_remove.desc"),
|
|
AutoCompleteHint: T("api.command_remove.hint"),
|
|
DisplayName: T("api.command_remove.name"),
|
|
}
|
|
}
|
|
|
|
func (*KickProvider) GetCommand(a *app.App, T i18n.TranslateFunc) *model.Command {
|
|
return &model.Command{
|
|
Trigger: CmdKick,
|
|
AutoComplete: true,
|
|
AutoCompleteDesc: T("api.command_remove.desc"),
|
|
AutoCompleteHint: T("api.command_remove.hint"),
|
|
DisplayName: T("api.command_kick.name"),
|
|
}
|
|
}
|
|
|
|
func (*RemoveProvider) DoCommand(a *app.App, rctx request.CTX, args *model.CommandArgs, message string) *model.CommandResponse {
|
|
return doCommand(a, rctx, args, message)
|
|
}
|
|
|
|
func (*KickProvider) DoCommand(a *app.App, rctx request.CTX, args *model.CommandArgs, message string) *model.CommandResponse {
|
|
return doCommand(a, rctx, args, message)
|
|
}
|
|
|
|
func doCommand(a *app.App, rctx request.CTX, args *model.CommandArgs, message string) *model.CommandResponse {
|
|
channel, err := a.GetChannel(rctx, args.ChannelId)
|
|
if err != nil {
|
|
return &model.CommandResponse{
|
|
Text: args.T("api.command_channel_remove.channel.app_error"),
|
|
ResponseType: model.CommandResponseTypeEphemeral,
|
|
}
|
|
}
|
|
|
|
switch channel.Type {
|
|
case model.ChannelTypeOpen:
|
|
if ok, _ := a.HasPermissionToChannel(rctx, args.UserId, args.ChannelId, model.PermissionManagePublicChannelMembers); !ok {
|
|
return &model.CommandResponse{
|
|
Text: args.T("api.command_remove.permission.app_error"),
|
|
ResponseType: model.CommandResponseTypeEphemeral,
|
|
}
|
|
}
|
|
case model.ChannelTypePrivate:
|
|
if ok, _ := a.HasPermissionToChannel(rctx, args.UserId, args.ChannelId, model.PermissionManagePrivateChannelMembers); !ok {
|
|
return &model.CommandResponse{
|
|
Text: args.T("api.command_remove.permission.app_error"),
|
|
ResponseType: model.CommandResponseTypeEphemeral,
|
|
}
|
|
}
|
|
default:
|
|
return &model.CommandResponse{
|
|
Text: args.T("api.command_remove.direct_group.app_error"),
|
|
ResponseType: model.CommandResponseTypeEphemeral,
|
|
}
|
|
}
|
|
|
|
if message == "" {
|
|
return &model.CommandResponse{
|
|
Text: args.T("api.command_remove.message.app_error"),
|
|
ResponseType: model.CommandResponseTypeEphemeral,
|
|
}
|
|
}
|
|
|
|
targetUsername := ""
|
|
|
|
targetUsername = strings.SplitN(message, " ", 2)[0]
|
|
targetUsername = strings.TrimPrefix(targetUsername, "@")
|
|
|
|
userProfile, nErr := a.Srv().Store().User().GetByUsername(targetUsername)
|
|
if nErr != nil {
|
|
rctx.Logger().Error(nErr.Error())
|
|
return &model.CommandResponse{
|
|
Text: args.T("api.command_remove.missing.app_error"),
|
|
ResponseType: model.CommandResponseTypeEphemeral,
|
|
}
|
|
}
|
|
if userProfile.DeleteAt != 0 {
|
|
return &model.CommandResponse{
|
|
Text: args.T("api.command_remove.missing.app_error"),
|
|
ResponseType: model.CommandResponseTypeEphemeral,
|
|
}
|
|
}
|
|
|
|
_, err = a.GetChannelMember(rctx, args.ChannelId, userProfile.Id)
|
|
if err != nil {
|
|
nameFormat := *a.Config().TeamSettings.TeammateNameDisplay
|
|
return &model.CommandResponse{
|
|
Text: args.T("api.command_remove.user_not_in_channel", map[string]any{
|
|
"Username": userProfile.GetDisplayName(nameFormat),
|
|
}),
|
|
ResponseType: model.CommandResponseTypeEphemeral,
|
|
}
|
|
}
|
|
|
|
if err = a.RemoveUserFromChannel(rctx, userProfile.Id, args.UserId, channel); err != nil {
|
|
var text string
|
|
if err.Id == "api.channel.remove_members.denied" {
|
|
text = args.T("api.command_remove.group_constrained_user_denied")
|
|
} else {
|
|
text = args.T(err.Id, map[string]any{
|
|
"Channel": model.DefaultChannelName,
|
|
})
|
|
}
|
|
return &model.CommandResponse{
|
|
Text: text,
|
|
ResponseType: model.CommandResponseTypeEphemeral,
|
|
}
|
|
}
|
|
|
|
return &model.CommandResponse{}
|
|
}
|