check errors in channels/api4/channel.go (#28376)

Co-authored-by: Ben Schumacher <ben.schumacher@mattermost.com>
Этот коммит содержится в:
Pradeep Murugesan
2024-10-15 09:30:12 +01:00
коммит произвёл GitHub
родитель e27867cec7
Коммит 3f6bc5084b
2 изменённых файлов: 27 добавлений и 10 удалений

Просмотреть файл

@@ -61,7 +61,6 @@ issues:
path: "\ path: "\
channels/api4/apitestlib.go|\ channels/api4/apitestlib.go|\
channels/api4/bot_test.go|\ channels/api4/bot_test.go|\
channels/api4/channel.go|\
channels/api4/channel_test.go|\ channels/api4/channel_test.go|\
channels/api4/cloud.go|\ channels/api4/cloud.go|\
channels/api4/cloud_test.go|\ channels/api4/cloud_test.go|\

Просмотреть файл

@@ -1067,7 +1067,9 @@ func getChannelsForUser(c *Context, w http.ResponseWriter, r *http.Request) {
// //
// Note that this means if an error occurs in mid-stream, the response won't be // Note that this means if an error occurs in mid-stream, the response won't be
// fully JSON. // fully JSON.
w.Write([]byte(`[`)) if _, err := w.Write([]byte(`[`)); err != nil {
c.Logger.Warn("Error while writing response", mlog.Err(err))
}
enc := json.NewEncoder(w) enc := json.NewEncoder(w)
for { for {
channels, err := c.App.GetChannelsForUser(c.AppContext, c.Params.UserId, c.Params.IncludeDeleted, lastDeleteAt, pageSize, fromChannelID) channels, err := c.App.GetChannelsForUser(c.AppContext, c.Params.UserId, c.Params.IncludeDeleted, lastDeleteAt, pageSize, fromChannelID)
@@ -1089,7 +1091,9 @@ func getChannelsForUser(c *Context, w http.ResponseWriter, r *http.Request) {
// intermediary comma between sets // intermediary comma between sets
if fromChannelID != "" { if fromChannelID != "" {
w.Write([]byte(`,`)) if _, err := w.Write([]byte(`,`)); err != nil {
c.Logger.Warn("Error while writing response", mlog.Err(err))
}
} }
for i, ch := range channels { for i, ch := range channels {
@@ -1097,7 +1101,9 @@ func getChannelsForUser(c *Context, w http.ResponseWriter, r *http.Request) {
c.Logger.Warn("Error while writing response", mlog.Err(err)) c.Logger.Warn("Error while writing response", mlog.Err(err))
} }
if i < len(channels)-1 { if i < len(channels)-1 {
w.Write([]byte(`,`)) if _, err := w.Write([]byte(`,`)); err != nil {
c.Logger.Warn("Error while writing response", mlog.Err(err))
}
} }
} }
@@ -1107,7 +1113,9 @@ func getChannelsForUser(c *Context, w http.ResponseWriter, r *http.Request) {
fromChannelID = channels[len(channels)-1].Id fromChannelID = channels[len(channels)-1].Id
} }
w.Write([]byte(`]`)) if _, err := w.Write([]byte(`]`)); err != nil {
c.Logger.Warn("Error while writing response", mlog.Err(err))
}
} }
func autocompleteChannelsForTeam(c *Context, w http.ResponseWriter, r *http.Request) { func autocompleteChannelsForTeam(c *Context, w http.ResponseWriter, r *http.Request) {
@@ -1489,7 +1497,9 @@ func getChannelMembersTimezones(c *Context, w http.ResponseWriter, r *http.Reque
return return
} }
w.Write([]byte(model.ArrayToJSON(membersTimezones))) if _, err := w.Write([]byte(model.ArrayToJSON(membersTimezones))); err != nil {
c.Logger.Warn("Error while writing response", mlog.Err(err))
}
} }
func getChannelMembersByIds(c *Context, w http.ResponseWriter, r *http.Request) { func getChannelMembersByIds(c *Context, w http.ResponseWriter, r *http.Request) {
@@ -2107,7 +2117,9 @@ func channelMembersMinusGroupMembers(c *Context, w http.ResponseWriter, r *http.
return return
} }
w.Write(b) if _, err := w.Write(b); err != nil {
c.Logger.Warn("Error while writing response", mlog.Err(err))
}
} }
func channelMemberCountsByGroup(c *Context, w http.ResponseWriter, r *http.Request) { func channelMemberCountsByGroup(c *Context, w http.ResponseWriter, r *http.Request) {
@@ -2140,7 +2152,9 @@ func channelMemberCountsByGroup(c *Context, w http.ResponseWriter, r *http.Reque
return return
} }
w.Write(b) if _, err := w.Write(b); err != nil {
c.Logger.Warn("Error while writing response", mlog.Err(err))
}
} }
func getChannelModerations(c *Context, w http.ResponseWriter, r *http.Request) { func getChannelModerations(c *Context, w http.ResponseWriter, r *http.Request) {
@@ -2177,7 +2191,9 @@ func getChannelModerations(c *Context, w http.ResponseWriter, r *http.Request) {
return return
} }
w.Write(b) if _, err := w.Write(b); err != nil {
c.Logger.Warn("Error while writing response", mlog.Err(err))
}
} }
func patchChannelModerations(c *Context, w http.ResponseWriter, r *http.Request) { func patchChannelModerations(c *Context, w http.ResponseWriter, r *http.Request) {
@@ -2227,7 +2243,9 @@ func patchChannelModerations(c *Context, w http.ResponseWriter, r *http.Request)
} }
auditRec.Success() auditRec.Success()
w.Write(b) if _, err := w.Write(b); err != nil {
c.Logger.Warn("Error while writing response", mlog.Err(err))
}
} }
func moveChannel(c *Context, w http.ResponseWriter, r *http.Request) { func moveChannel(c *Context, w http.ResponseWriter, r *http.Request) {