From b299bc89999818da07fdec323a74ff29819aaf65 Mon Sep 17 00:00:00 2001 From: Carlos Tadeu Panato Junior Date: Mon, 13 Mar 2017 14:24:30 +0100 Subject: add update channel endpoint for APIv4 (#5624) --- api4/channel.go | 89 ++++++++++++++++++++++++++++++++++++++++++++++++++++ api4/channel_test.go | 72 ++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 161 insertions(+) (limited to 'api4') diff --git a/api4/channel.go b/api4/channel.go index d86e54039..80ae9fa30 100644 --- a/api4/channel.go +++ b/api4/channel.go @@ -21,6 +21,7 @@ func InitChannel() { BaseRoutes.Team.Handle("/channels", ApiSessionRequired(getPublicChannelsForTeam)).Methods("GET") BaseRoutes.Channel.Handle("", ApiSessionRequired(getChannel)).Methods("GET") + BaseRoutes.Channel.Handle("", ApiSessionRequired(updateChannel)).Methods("PUT") BaseRoutes.ChannelByName.Handle("", ApiSessionRequired(getChannelByName)).Methods("GET") BaseRoutes.ChannelByNameForTeamName.Handle("", ApiSessionRequired(getChannelByNameForTeamName)).Methods("GET") @@ -59,6 +60,94 @@ func createChannel(c *Context, w http.ResponseWriter, r *http.Request) { } } +func updateChannel(c *Context, w http.ResponseWriter, r *http.Request) { + c.RequireChannelId() + if c.Err != nil { + return + } + + channel := model.ChannelFromJson(r.Body) + + if channel == nil { + c.SetInvalidParam("channel") + return + } + + var oldChannel *model.Channel + var err *model.AppError + if oldChannel, err = app.GetChannel(channel.Id); err != nil { + c.Err = err + return + } + + if _, err = app.GetChannelMember(channel.Id, c.Session.UserId); err != nil { + c.Err = err + return + } + + if !CanManageChannel(c, channel) { + return + } + + if oldChannel.DeleteAt > 0 { + c.Err = model.NewLocAppError("updateChannel", "api.channel.update_channel.deleted.app_error", nil, "") + c.Err.StatusCode = http.StatusBadRequest + return + } + + if oldChannel.Name == model.DEFAULT_CHANNEL { + if (len(channel.Name) > 0 && channel.Name != oldChannel.Name) || (len(channel.Type) > 0 && channel.Type != oldChannel.Type) { + c.Err = model.NewLocAppError("updateChannel", "api.channel.update_channel.tried.app_error", map[string]interface{}{"Channel": model.DEFAULT_CHANNEL}, "") + c.Err.StatusCode = http.StatusBadRequest + return + } + } + + oldChannel.Header = channel.Header + oldChannel.Purpose = channel.Purpose + + oldChannelDisplayName := oldChannel.DisplayName + + if len(channel.DisplayName) > 0 { + oldChannel.DisplayName = channel.DisplayName + } + + if len(channel.Name) > 0 { + oldChannel.Name = channel.Name + } + + if len(channel.Type) > 0 { + oldChannel.Type = channel.Type + } + + if _, err := app.UpdateChannel(oldChannel); err != nil { + c.Err = err + return + } else { + if oldChannelDisplayName != channel.DisplayName { + if err := app.PostUpdateChannelDisplayNameMessage(c.Session.UserId, channel.Id, c.Params.TeamId, oldChannelDisplayName, channel.DisplayName); err != nil { + l4g.Error(err.Error()) + } + } + c.LogAudit("name=" + channel.Name) + w.Write([]byte(oldChannel.ToJson())) + } +} + +func CanManageChannel(c *Context, channel *model.Channel) bool { + if channel.Type == model.CHANNEL_OPEN && !app.SessionHasPermissionToChannel(c.Session, channel.Id, model.PERMISSION_MANAGE_PUBLIC_CHANNEL_PROPERTIES) { + c.SetPermissionError(model.PERMISSION_MANAGE_PUBLIC_CHANNEL_PROPERTIES) + return false + } + + if channel.Type == model.CHANNEL_PRIVATE && !app.SessionHasPermissionToChannel(c.Session, channel.Id, model.PERMISSION_MANAGE_PRIVATE_CHANNEL_PROPERTIES) { + c.SetPermissionError(model.PERMISSION_MANAGE_PRIVATE_CHANNEL_PROPERTIES) + return false + } + + return true +} + func createDirectChannel(c *Context, w http.ResponseWriter, r *http.Request) { userIds := model.ArrayFromJson(r.Body) allowed := false diff --git a/api4/channel_test.go b/api4/channel_test.go index a7dbb958b..27fe5aa44 100644 --- a/api4/channel_test.go +++ b/api4/channel_test.go @@ -171,6 +171,78 @@ func TestCreateChannel(t *testing.T) { } } +func TestUpdateChannel(t *testing.T) { + th := Setup().InitBasic().InitSystemAdmin() + defer TearDown() + Client := th.Client + team := th.BasicTeam + + channel := &model.Channel{DisplayName: "Test API Name", Name: GenerateTestChannelName(), Type: model.CHANNEL_OPEN, TeamId: team.Id} + private := &model.Channel{DisplayName: "Test API Name", Name: GenerateTestChannelName(), Type: model.CHANNEL_PRIVATE, TeamId: team.Id} + + channel, resp := Client.CreateChannel(channel) + private, resp = Client.CreateChannel(private) + + //Update a open channel + channel.DisplayName = "My new display name" + channel.Header = "My fancy header" + channel.Purpose = "Mattermost ftw!" + + newChannel, resp := Client.UpdateChannel(channel) + CheckNoError(t, resp) + + if newChannel.DisplayName != channel.DisplayName { + t.Fatal("Update failed for DisplayName") + } + + if newChannel.Header != channel.Header { + t.Fatal("Update failed for Header") + } + + if newChannel.Purpose != channel.Purpose { + t.Fatal("Update failed for Purpose") + } + + //Update a private channel + private.DisplayName = "My new display name for private channel" + private.Header = "My fancy private header" + private.Purpose = "Mattermost ftw! in private mode" + + newPrivateChannel, resp := Client.UpdateChannel(private) + CheckNoError(t, resp) + + if newPrivateChannel.DisplayName != private.DisplayName { + t.Fatal("Update failed for DisplayName in private channel") + } + + if newPrivateChannel.Header != private.Header { + t.Fatal("Update failed for Header in private channel") + } + + if newPrivateChannel.Purpose != private.Purpose { + t.Fatal("Update failed for Purpose in private channel") + } + + //Non existing channel + channel1 := &model.Channel{DisplayName: "Test API Name for apiv4", Name: GenerateTestChannelName(), Type: model.CHANNEL_OPEN, TeamId: team.Id} + _, resp = Client.UpdateChannel(channel1) + CheckNotFoundStatus(t, resp) + + //Try to update with not logged user + Client.Logout() + _, resp = Client.UpdateChannel(channel) + CheckUnauthorizedStatus(t, resp) + + //Try to update using another user + user := th.CreateUser() + Client.Login(user.Email, user.Password) + + channel.DisplayName = "Should not update" + _, resp = Client.UpdateChannel(channel) + CheckNotFoundStatus(t, resp) + +} + func TestCreateDirectChannel(t *testing.T) { th := Setup().InitBasic().InitSystemAdmin() defer TearDown() -- cgit v1.2.3-1-g7c22