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.
377 lines
14 KiB
Go
377 lines
14 KiB
Go
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
package commands
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/hanzoteam/server/server/public/model"
|
|
"github.com/hanzoteam/server/server/v8/channels/api4"
|
|
"github.com/hanzoteam/server/server/v8/channels/app"
|
|
"github.com/spf13/cobra"
|
|
|
|
"github.com/hanzoteam/server/server/v8/cmd/mmctl/client"
|
|
"github.com/hanzoteam/server/server/v8/cmd/mmctl/printer"
|
|
)
|
|
|
|
func (s *MmctlE2ETestSuite) TestChannelUsersAddCmdF() {
|
|
s.SetupTestHelper().InitBasic(s.T())
|
|
|
|
user, appErr := s.th.App.CreateUser(s.th.Context, &model.User{Email: s.th.GenerateTestEmail(), Username: model.NewUsername(), Password: model.NewId()})
|
|
s.Require().Nil(appErr)
|
|
|
|
_, _, appErr = s.th.App.AddUserToTeam(s.th.Context, s.th.BasicTeam.Id, user.Id, "")
|
|
s.Require().Nil(appErr)
|
|
|
|
channelName := api4.GenerateTestChannelName()
|
|
channel, appErr := s.th.App.CreateChannel(s.th.Context, &model.Channel{
|
|
TeamId: s.th.BasicTeam.Id,
|
|
Name: channelName,
|
|
DisplayName: "dn_" + channelName,
|
|
Type: model.ChannelTypeOpen,
|
|
}, false)
|
|
s.Require().Nil(appErr)
|
|
|
|
s.RunForSystemAdminAndLocal("Add user to nonexistent channel", func(c client.Client) {
|
|
printer.Clean()
|
|
|
|
nonexistentChannelName := "nonexistent"
|
|
err := channelUsersAddCmdF(c, &cobra.Command{}, []string{nonexistentChannelName, user.Id})
|
|
s.Require().NotNil(err)
|
|
s.Require().Equal(fmt.Sprintf("unable to find channel %q", nonexistentChannelName), err.Error())
|
|
s.Require().Len(printer.GetLines(), 0)
|
|
s.Require().Len(printer.GetErrorLines(), 0)
|
|
})
|
|
|
|
s.Run("Add user to nonexistent channel/Client", func() {
|
|
printer.Clean()
|
|
|
|
_, appErr := s.th.App.AddChannelMember(s.th.Context, s.th.BasicUser.Id, channel, app.ChannelMemberOpts{})
|
|
s.Require().Nil(appErr)
|
|
defer func() {
|
|
appErr := s.th.App.RemoveUserFromChannel(s.th.Context, s.th.BasicUser.Id, s.th.SystemAdminUser.Id, channel)
|
|
s.Require().Nil(appErr)
|
|
}()
|
|
|
|
nonexistentChannelName := "nonexistent"
|
|
err := channelUsersAddCmdF(s.th.Client, &cobra.Command{}, []string{nonexistentChannelName, user.Id})
|
|
s.Require().NotNil(err)
|
|
s.Require().Equal(fmt.Sprintf("unable to find channel %q", nonexistentChannelName), err.Error())
|
|
s.Require().Len(printer.GetLines(), 0)
|
|
s.Require().Len(printer.GetErrorLines(), 0)
|
|
})
|
|
|
|
s.RunForSystemAdminAndLocal("Add nonexistent user to channel", func(c client.Client) {
|
|
printer.Clean()
|
|
|
|
nonexistentUserName := "nonexistent"
|
|
err := channelUsersAddCmdF(c, &cobra.Command{}, []string{channel.Id, nonexistentUserName})
|
|
s.Require().ErrorContains(err, "unable to find user")
|
|
s.Require().ErrorContains(err, nonexistentUserName)
|
|
s.Require().Len(printer.GetLines(), 0)
|
|
s.Require().Len(printer.GetErrorLines(), 1)
|
|
})
|
|
|
|
s.Run("Add nonexistent user to channel/Client", func() {
|
|
printer.Clean()
|
|
|
|
_, appErr := s.th.App.AddChannelMember(s.th.Context, s.th.BasicUser.Id, channel, app.ChannelMemberOpts{})
|
|
s.Require().Nil(appErr)
|
|
defer func() {
|
|
appErr := s.th.App.RemoveUserFromChannel(s.th.Context, s.th.BasicUser.Id, s.th.SystemAdminUser.Id, channel)
|
|
s.Require().Nil(appErr)
|
|
}()
|
|
|
|
nonexistentUserName := "nonexistent"
|
|
err := channelUsersAddCmdF(s.th.Client, &cobra.Command{}, []string{channel.Id, nonexistentUserName})
|
|
s.Require().ErrorContains(err, "unable to find user")
|
|
s.Require().ErrorContains(err, nonexistentUserName)
|
|
s.Require().Len(printer.GetLines(), 0)
|
|
s.Require().Len(printer.GetErrorLines(), 1)
|
|
})
|
|
|
|
s.Run("Add user to channel without permission/Client", func() {
|
|
printer.Clean()
|
|
|
|
err := channelUsersAddCmdF(s.th.Client, &cobra.Command{}, []string{channel.Id, user.Id})
|
|
s.Require().ErrorContains(err, "unable to add")
|
|
s.Require().ErrorContains(err, user.Id)
|
|
s.Require().ErrorContains(err, channelName)
|
|
s.Require().ErrorContains(err, "You do not have the appropriate permissions")
|
|
s.Require().Len(printer.GetLines(), 0)
|
|
s.Require().Len(printer.GetErrorLines(), 1)
|
|
s.Require().Equal(fmt.Sprintf("unable to add %q to %q. Error: You do not have the appropriate permissions.", user.Id, channelName), printer.GetErrorLines()[0])
|
|
})
|
|
|
|
s.Run("Add user to channel/Client", func() {
|
|
printer.Clean()
|
|
|
|
_, appErr := s.th.App.AddChannelMember(s.th.Context, s.th.BasicUser.Id, channel, app.ChannelMemberOpts{})
|
|
s.Require().Nil(appErr)
|
|
defer func() {
|
|
appErr = s.th.App.RemoveUserFromChannel(s.th.Context, s.th.BasicUser.Id, s.th.SystemAdminUser.Id, channel)
|
|
s.Require().Nil(appErr)
|
|
}()
|
|
|
|
err := channelUsersAddCmdF(s.th.Client, &cobra.Command{}, []string{channel.Id, user.Id})
|
|
s.Require().Nil(err)
|
|
defer func() {
|
|
appErr = s.th.App.RemoveUserFromChannel(s.th.Context, user.Id, s.th.SystemAdminUser.Id, channel)
|
|
s.Require().Nil(appErr)
|
|
}()
|
|
s.Require().Len(printer.GetLines(), 0)
|
|
s.Require().Len(printer.GetErrorLines(), 0)
|
|
|
|
members, appErr := s.th.App.GetChannelMembersByIds(s.th.Context, channel.Id, []string{user.Id})
|
|
s.Require().Nil(appErr)
|
|
s.Require().Len(members, 1)
|
|
s.Require().Equal(user.Id, (members)[0].UserId)
|
|
})
|
|
|
|
s.RunForSystemAdminAndLocal("Add user to channel", func(c client.Client) {
|
|
printer.Clean()
|
|
|
|
err := channelUsersAddCmdF(c, &cobra.Command{}, []string{channel.Id, user.Id})
|
|
s.Require().Nil(err)
|
|
defer func() {
|
|
appErr := s.th.App.RemoveUserFromChannel(s.th.Context, user.Id, s.th.SystemAdminUser.Id, channel)
|
|
s.Require().Nil(appErr)
|
|
}()
|
|
s.Require().Len(printer.GetLines(), 0)
|
|
s.Require().Len(printer.GetErrorLines(), 0)
|
|
|
|
members, appErr := s.th.App.GetChannelMembersByIds(s.th.Context, channel.Id, []string{user.Id})
|
|
s.Require().Nil(appErr)
|
|
s.Require().Len(members, 1)
|
|
s.Require().Equal(user.Id, (members)[0].UserId)
|
|
})
|
|
}
|
|
|
|
func (s *MmctlE2ETestSuite) TestChannelUsersListCmd() {
|
|
s.SetupTestHelper().InitBasic(s.T())
|
|
|
|
user, appErr := s.th.App.CreateUser(s.th.Context, &model.User{Email: s.th.GenerateTestEmail(), Username: model.NewUsername(), Password: model.NewId()})
|
|
s.Require().Nil(appErr)
|
|
|
|
_, _, appErr = s.th.App.AddUserToTeam(s.th.Context, s.th.BasicTeam.Id, user.Id, "")
|
|
s.Require().Nil(appErr)
|
|
|
|
channelName := api4.GenerateTestChannelName()
|
|
channel, appErr := s.th.App.CreateChannel(s.th.Context, &model.Channel{
|
|
TeamId: s.th.BasicTeam.Id,
|
|
Name: channelName,
|
|
DisplayName: "dn_" + channelName,
|
|
Type: model.ChannelTypeOpen,
|
|
}, false)
|
|
s.Require().Nil(appErr)
|
|
|
|
_, appErr = s.th.App.AddChannelMember(s.th.Context, user.Id, channel, app.ChannelMemberOpts{})
|
|
s.Require().Nil(appErr)
|
|
|
|
s.RunForSystemAdminAndLocal("List users of a channel", func(c client.Client) {
|
|
printer.Clean()
|
|
|
|
err := channelUsersListCmdF(c, channelUsersListTestCmd(), []string{channel.Id})
|
|
s.Require().Nil(err)
|
|
s.Require().Len(printer.GetErrorLines(), 0)
|
|
s.Require().NotEmpty(printer.GetLines())
|
|
|
|
var found bool
|
|
for _, line := range printer.GetLines() {
|
|
out, ok := line.(channelUserOut)
|
|
s.Require().True(ok)
|
|
if out.Id == user.Id {
|
|
found = true
|
|
s.Require().Equal(user.Username, out.Username)
|
|
s.Require().Equal(user.Email, out.Email)
|
|
s.Require().NotEmpty(out.Roles)
|
|
}
|
|
}
|
|
s.Require().True(found, "expected the added user to be listed as a channel member")
|
|
})
|
|
|
|
s.RunForSystemAdminAndLocal("List all users of a channel with the --all flag", func(c client.Client) {
|
|
printer.Clean()
|
|
|
|
cmd := channelUsersListTestCmd()
|
|
err := cmd.Flags().Set("all", "true")
|
|
s.Require().NoError(err)
|
|
|
|
err = channelUsersListCmdF(c, cmd, []string{channel.Id})
|
|
s.Require().Nil(err)
|
|
s.Require().Len(printer.GetErrorLines(), 0)
|
|
|
|
var found bool
|
|
for _, line := range printer.GetLines() {
|
|
out, ok := line.(channelUserOut)
|
|
s.Require().True(ok)
|
|
if out.Id == user.Id {
|
|
found = true
|
|
s.Require().Equal(user.Username, out.Username)
|
|
s.Require().Equal(user.Email, out.Email)
|
|
s.Require().NotEmpty(out.Roles)
|
|
}
|
|
}
|
|
s.Require().True(found, "expected the added user to be listed as a channel member")
|
|
})
|
|
|
|
s.RunForSystemAdminAndLocal("List users of a nonexistent channel", func(c client.Client) {
|
|
printer.Clean()
|
|
|
|
nonexistentChannelName := "nonexistent"
|
|
err := channelUsersListCmdF(c, channelUsersListTestCmd(), []string{nonexistentChannelName})
|
|
s.Require().NotNil(err)
|
|
s.Require().Equal(fmt.Sprintf("unable to find channel %q", nonexistentChannelName), err.Error())
|
|
s.Require().Len(printer.GetLines(), 0)
|
|
})
|
|
}
|
|
|
|
func (s *MmctlE2ETestSuite) TestChannelUsersRemoveCmd() {
|
|
s.SetupTestHelper().InitBasic(s.T())
|
|
|
|
user, appErr := s.th.App.CreateUser(s.th.Context, &model.User{Email: s.th.GenerateTestEmail(), Username: model.NewUsername(), Password: model.NewId()})
|
|
s.Require().Nil(appErr)
|
|
|
|
_, _, appErr = s.th.App.AddUserToTeam(s.th.Context, s.th.BasicTeam.Id, user.Id, "")
|
|
s.Require().Nil(appErr)
|
|
|
|
channelName := api4.GenerateTestChannelName()
|
|
channel, appErr := s.th.App.CreateChannel(s.th.Context, &model.Channel{
|
|
TeamId: s.th.BasicTeam.Id,
|
|
Name: channelName,
|
|
DisplayName: "dn_" + channelName,
|
|
Type: model.ChannelTypeOpen,
|
|
}, false)
|
|
s.Require().Nil(appErr)
|
|
|
|
s.RunForSystemAdminAndLocal("Remove user from nonexistent channel", func(c client.Client) {
|
|
printer.Clean()
|
|
|
|
nonexistentChannelName := "nonexistent"
|
|
err := channelUsersRemoveCmdF(c, &cobra.Command{}, []string{nonexistentChannelName, user.Id})
|
|
s.Require().NotNil(err)
|
|
s.Require().Equal(fmt.Sprintf("unable to find channel %q", nonexistentChannelName), err.Error())
|
|
s.Require().Len(printer.GetLines(), 0)
|
|
s.Require().Len(printer.GetErrorLines(), 0)
|
|
})
|
|
|
|
s.Run("Remove user from nonexistent channel/Client", func() {
|
|
printer.Clean()
|
|
|
|
_, appErr = s.th.App.AddChannelMember(s.th.Context, s.th.BasicUser.Id, channel, app.ChannelMemberOpts{})
|
|
s.Require().Nil(appErr)
|
|
defer func() {
|
|
appErr = s.th.App.RemoveUserFromChannel(s.th.Context, s.th.BasicUser.Id, s.th.SystemAdminUser.Id, channel)
|
|
s.Require().Nil(appErr)
|
|
}()
|
|
|
|
nonexistentChannelName := "nonexistent"
|
|
err := channelUsersRemoveCmdF(s.th.Client, &cobra.Command{}, []string{nonexistentChannelName, user.Id})
|
|
s.Require().NotNil(err)
|
|
s.Require().Equal(fmt.Sprintf("unable to find channel %q", nonexistentChannelName), err.Error())
|
|
s.Require().Len(printer.GetLines(), 0)
|
|
s.Require().Len(printer.GetErrorLines(), 0)
|
|
})
|
|
|
|
s.RunForSystemAdminAndLocal("Remove nonexistent user from channel", func(c client.Client) {
|
|
printer.Clean()
|
|
|
|
nonexistentUserName := "nonexistent"
|
|
err := channelUsersRemoveCmdF(c, &cobra.Command{}, []string{channel.Id, nonexistentUserName})
|
|
s.Require().ErrorContains(err, "unable to find user")
|
|
s.Require().ErrorContains(err, nonexistentUserName)
|
|
s.Require().Len(printer.GetLines(), 0)
|
|
s.Require().Len(printer.GetErrorLines(), 1)
|
|
s.Require().Equal(fmt.Sprintf("unable to find user %q", nonexistentUserName), printer.GetErrorLines()[0])
|
|
})
|
|
|
|
s.Run("Remove nonexistent user from channel/Client", func() {
|
|
printer.Clean()
|
|
|
|
_, appErr = s.th.App.AddChannelMember(s.th.Context, s.th.BasicUser.Id, channel, app.ChannelMemberOpts{})
|
|
s.Require().Nil(appErr)
|
|
defer func() {
|
|
appErr = s.th.App.RemoveUserFromChannel(s.th.Context, s.th.BasicUser.Id, s.th.SystemAdminUser.Id, channel)
|
|
s.Require().Nil(appErr)
|
|
}()
|
|
|
|
nonexistentUserName := "nonexistent"
|
|
err := channelUsersRemoveCmdF(s.th.Client, &cobra.Command{}, []string{channel.Id, nonexistentUserName})
|
|
s.Require().ErrorContains(err, "unable to find user")
|
|
s.Require().ErrorContains(err, nonexistentUserName)
|
|
s.Require().Len(printer.GetLines(), 0)
|
|
s.Require().Len(printer.GetErrorLines(), 1)
|
|
s.Require().Equal(fmt.Sprintf("unable to find user %q", nonexistentUserName), printer.GetErrorLines()[0])
|
|
})
|
|
|
|
s.Run("Remove user from channel without permission/Client", func() {
|
|
printer.Clean()
|
|
|
|
var members model.ChannelMembers
|
|
_, appErr = s.th.App.AddChannelMember(s.th.Context, user.Id, channel, app.ChannelMemberOpts{})
|
|
s.Require().Nil(appErr)
|
|
members, appErr = s.th.App.GetChannelMembersByIds(s.th.Context, channel.Id, []string{user.Id})
|
|
s.Require().Nil(appErr)
|
|
s.Require().Len(members, 1)
|
|
s.Require().Equal(user.Id, (members)[0].UserId)
|
|
|
|
err := channelUsersRemoveCmdF(s.th.Client, &cobra.Command{}, []string{channel.Id, user.Id})
|
|
s.Require().ErrorContains(err, "unable to remove")
|
|
s.Require().ErrorContains(err, user.Id)
|
|
s.Require().ErrorContains(err, channelName)
|
|
s.Require().Len(printer.GetLines(), 0)
|
|
s.Require().Len(printer.GetErrorLines(), 1)
|
|
s.Require().Contains(printer.GetErrorLines()[0], fmt.Sprintf("unable to remove %q from %q", user.Id, channelName))
|
|
s.Require().Contains(printer.GetErrorLines()[0], "You do not have the appropriate permissions")
|
|
})
|
|
|
|
s.Run("Remove user from channel/Client", func() {
|
|
printer.Clean()
|
|
|
|
_, appErr = s.th.App.AddChannelMember(s.th.Context, s.th.BasicUser.Id, channel, app.ChannelMemberOpts{})
|
|
s.Require().Nil(appErr)
|
|
defer func() {
|
|
appErr = s.th.App.RemoveUserFromChannel(s.th.Context, s.th.BasicUser.Id, s.th.SystemAdminUser.Id, channel)
|
|
s.Require().Nil(appErr)
|
|
}()
|
|
|
|
var members model.ChannelMembers
|
|
_, appErr = s.th.App.AddChannelMember(s.th.Context, user.Id, channel, app.ChannelMemberOpts{})
|
|
s.Require().Nil(appErr)
|
|
members, appErr = s.th.App.GetChannelMembersByIds(s.th.Context, channel.Id, []string{user.Id})
|
|
s.Require().Nil(appErr)
|
|
s.Require().Len(members, 1)
|
|
s.Require().Equal(user.Id, (members)[0].UserId)
|
|
|
|
err := channelUsersRemoveCmdF(s.th.Client, &cobra.Command{}, []string{channel.Id, user.Id})
|
|
s.Require().Nil(err)
|
|
s.Require().Len(printer.GetLines(), 0)
|
|
s.Require().Len(printer.GetErrorLines(), 0)
|
|
|
|
members, appErr = s.th.App.GetChannelMembersByIds(s.th.Context, channel.Id, []string{user.Id})
|
|
s.Require().Nil(appErr)
|
|
s.Require().Len(members, 0)
|
|
})
|
|
|
|
s.RunForSystemAdminAndLocal("Remove user from channel", func(c client.Client) {
|
|
printer.Clean()
|
|
|
|
_, appErr = s.th.App.AddChannelMember(s.th.Context, user.Id, channel, app.ChannelMemberOpts{})
|
|
s.Require().Nil(appErr)
|
|
members, appErr := s.th.App.GetChannelMembersByIds(s.th.Context, channel.Id, []string{user.Id})
|
|
s.Require().Nil(appErr)
|
|
s.Require().Len(members, 1)
|
|
s.Require().Equal(user.Id, (members)[0].UserId)
|
|
|
|
err := channelUsersRemoveCmdF(c, &cobra.Command{}, []string{channel.Id, user.Id})
|
|
s.Require().Nil(err)
|
|
s.Require().Len(printer.GetLines(), 0)
|
|
s.Require().Len(printer.GetErrorLines(), 0)
|
|
|
|
members, appErr = s.th.App.GetChannelMembersByIds(s.th.Context, channel.Id, []string{user.Id})
|
|
s.Require().Nil(appErr)
|
|
s.Require().Len(members, 0)
|
|
})
|
|
}
|