diff --git a/server/channels/api4/remote_cluster.go b/server/channels/api4/remote_cluster.go index e5b26d41b0..73967c6c46 100644 --- a/server/channels/api4/remote_cluster.go +++ b/server/channels/api4/remote_cluster.go @@ -655,6 +655,8 @@ func patchRemoteCluster(c *Context, w http.ResponseWriter, r *http.Request) { return } + updatedRC.Sanitize() + auditRec.Success() auditRec.AddEventResultState(updatedRC) diff --git a/server/channels/api4/remote_cluster_test.go b/server/channels/api4/remote_cluster_test.go index fcaa1f2c39..f02ca3cfe6 100644 --- a/server/channels/api4/remote_cluster_test.go +++ b/server/channels/api4/remote_cluster_test.go @@ -488,9 +488,10 @@ func TestGenerateRemoteClusterInvite(t *testing.T) { func TestGetRemoteCluster(t *testing.T) { mainHelper.Parallel(t) newRC := &model.RemoteCluster{ - Name: "remotecluster", - SiteURL: "http://example.com", - Token: model.NewId(), + Name: "remotecluster", + SiteURL: "http://example.com", + Token: model.NewId(), + RemoteToken: model.NewId(), } t.Run("Should not work if the remote cluster service is not enabled", func(t *testing.T) { @@ -541,6 +542,7 @@ func TestGetRemoteCluster(t *testing.T) { require.Equal(t, rc.RemoteId, fetchedRC.RemoteId) require.Equal(t, th.BasicTeam.Id, fetchedRC.DefaultTeamId) require.Empty(t, fetchedRC.Token) + require.Empty(t, fetchedRC.RemoteToken) }) } @@ -551,6 +553,7 @@ func TestPatchRemoteCluster(t *testing.T) { DisplayName: "initialvalue", SiteURL: "http://example.com", Token: model.NewId(), + RemoteToken: model.NewId(), } rcp := &model.RemoteClusterPatch{DisplayName: model.NewPointer("different value")} @@ -606,6 +609,8 @@ func TestPatchRemoteCluster(t *testing.T) { require.NoError(t, err) require.Equal(t, "patched!", patchedRC.DisplayName) require.Equal(t, newTeamId, patchedRC.DefaultTeamId) + require.Empty(t, patchedRC.Token) + require.Empty(t, patchedRC.RemoteToken) }) }