Fixed errcheck issues in server/channels/app/slashcommands/command_loadtest.go (#29169)
Co-authored-by: Ben Schumacher <ben.schumacher@mattermost.com>
Этот коммит содержится в:
коммит произвёл
GitHub
родитель
45235a0ef6
Коммит
38e2f67583
@@ -139,7 +139,6 @@ issues:
|
|||||||
channels/app/server_test.go|\
|
channels/app/server_test.go|\
|
||||||
channels/app/slack.go|\
|
channels/app/slack.go|\
|
||||||
channels/app/slashcommands/auto_environment.go|\
|
channels/app/slashcommands/auto_environment.go|\
|
||||||
channels/app/slashcommands/command_loadtest.go|\
|
|
||||||
channels/app/slashcommands/command_test.go|\
|
channels/app/slashcommands/command_test.go|\
|
||||||
channels/app/slashcommands/helper_test.go|\
|
channels/app/slashcommands/helper_test.go|\
|
||||||
channels/app/status.go|\
|
channels/app/status.go|\
|
||||||
|
|||||||
@@ -277,7 +277,7 @@ func (*LoadTestProvider) SetupCommand(a *app.App, rctx request.CTX, args *model.
|
|||||||
return &model.CommandResponse{Text: "Failed to create testing environment", ResponseType: model.CommandResponseTypeEphemeral}, err
|
return &model.CommandResponse{Text: "Failed to create testing environment", ResponseType: model.CommandResponseTypeEphemeral}, err
|
||||||
}
|
}
|
||||||
|
|
||||||
CreateTestEnvironmentInTeam(
|
_, err = CreateTestEnvironmentInTeam(
|
||||||
a,
|
a,
|
||||||
rctx,
|
rctx,
|
||||||
client,
|
client,
|
||||||
@@ -286,6 +286,9 @@ func (*LoadTestProvider) SetupCommand(a *app.App, rctx request.CTX, args *model.
|
|||||||
utils.Range{Begin: numUsers, End: numUsers},
|
utils.Range{Begin: numUsers, End: numUsers},
|
||||||
utils.Range{Begin: numPosts, End: numPosts},
|
utils.Range{Begin: numPosts, End: numPosts},
|
||||||
doFuzz)
|
doFuzz)
|
||||||
|
if err != nil {
|
||||||
|
return &model.CommandResponse{Text: "Failed to create testing environment", ResponseType: model.CommandResponseTypeEphemeral}, err
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return &model.CommandResponse{Text: "Created environment", ResponseType: model.CommandResponseTypeEphemeral}, nil
|
return &model.CommandResponse{Text: "Created environment", ResponseType: model.CommandResponseTypeEphemeral}, nil
|
||||||
@@ -474,8 +477,9 @@ func (*LoadTestProvider) ThreadedPostCommand(a *app.App, c request.CTX, args *mo
|
|||||||
}
|
}
|
||||||
|
|
||||||
var usernames []string
|
var usernames []string
|
||||||
|
var profileUsers []*model.User
|
||||||
options := &model.UserGetOptions{InTeamId: args.TeamId, Page: 0, PerPage: 1000}
|
options := &model.UserGetOptions{InTeamId: args.TeamId, Page: 0, PerPage: 1000}
|
||||||
if profileUsers, err := a.Srv().Store().User().GetProfiles(options); err == nil {
|
if profileUsers, err = a.Srv().Store().User().GetProfiles(options); err == nil {
|
||||||
usernames = make([]string, len(profileUsers))
|
usernames = make([]string, len(profileUsers))
|
||||||
i := 0
|
i := 0
|
||||||
for _, userprof := range profileUsers {
|
for _, userprof := range profileUsers {
|
||||||
@@ -494,7 +498,10 @@ func (*LoadTestProvider) ThreadedPostCommand(a *app.App, c request.CTX, args *mo
|
|||||||
}
|
}
|
||||||
numPosts := utils.RandIntFromRange(rng)
|
numPosts := utils.RandIntFromRange(rng)
|
||||||
for i := 0; i < numPosts; i++ {
|
for i := 0; i < numPosts; i++ {
|
||||||
testPoster.CreateRandomPostNested(c, rpost.Id)
|
_, err = testPoster.CreateRandomPostNested(c, rpost.Id)
|
||||||
|
if err != nil {
|
||||||
|
return &model.CommandResponse{Text: "Failed to create nested post", ResponseType: model.CommandResponseTypeEphemeral}, err
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return &model.CommandResponse{Text: "Added threaded post", ResponseType: model.CommandResponseTypeEphemeral}, nil
|
return &model.CommandResponse{Text: "Added threaded post", ResponseType: model.CommandResponseTypeEphemeral}, nil
|
||||||
@@ -636,7 +643,10 @@ func (*LoadTestProvider) URLCommand(a *app.App, c request.CTX, args *model.Comma
|
|||||||
return &model.CommandResponse{Text: "Unable to get file", ResponseType: model.CommandResponseTypeEphemeral}, err
|
return &model.CommandResponse{Text: "Unable to get file", ResponseType: model.CommandResponseTypeEphemeral}, err
|
||||||
}
|
}
|
||||||
defer func() {
|
defer func() {
|
||||||
io.Copy(io.Discard, r.Body)
|
_, err := io.Copy(io.Discard, r.Body)
|
||||||
|
if err != nil {
|
||||||
|
c.Logger().Warn("Error discarding request body", mlog.Err(err))
|
||||||
|
}
|
||||||
r.Body.Close()
|
r.Body.Close()
|
||||||
}()
|
}()
|
||||||
|
|
||||||
@@ -694,7 +704,10 @@ func (*LoadTestProvider) JSONCommand(a *app.App, c request.CTX, args *model.Comm
|
|||||||
return &model.CommandResponse{Text: "Unable to get file", ResponseType: model.CommandResponseTypeEphemeral}, errors.Errorf("unexpected status code %d", r.StatusCode)
|
return &model.CommandResponse{Text: "Unable to get file", ResponseType: model.CommandResponseTypeEphemeral}, errors.Errorf("unexpected status code %d", r.StatusCode)
|
||||||
}
|
}
|
||||||
defer func() {
|
defer func() {
|
||||||
io.Copy(io.Discard, r.Body)
|
_, err := io.Copy(io.Discard, r.Body)
|
||||||
|
if err != nil {
|
||||||
|
c.Logger().Warn("Error discarding request body", mlog.Err(err))
|
||||||
|
}
|
||||||
r.Body.Close()
|
r.Body.Close()
|
||||||
}()
|
}()
|
||||||
|
|
||||||
|
|||||||
Ссылка в новой задаче
Block a user