feat(tester): extend ListContests endpoint

This commit is contained in:
Vyacheslav1557 2025-03-02 14:13:58 +05:00
parent 251772a049
commit 52d38d07bb
8 changed files with 66 additions and 4 deletions

View file

@ -8,3 +8,10 @@ type Contest struct {
CreatedAt *time.Time `db:"created_at"`
UpdatedAt *time.Time `db:"updated_at"`
}
type ContestsListItem struct {
Id int32 `db:"id"`
Title string `db:"title"`
CreatedAt time.Time `db:"created_at"`
UpdatedAt time.Time `db:"updated_at"`
}

View file

@ -6,7 +6,7 @@ import (
)
type Handlers interface {
ListContests(c *fiber.Ctx) error
ListContests(c *fiber.Ctx, params testerv1.ListContestsParams) error
CreateContest(c *fiber.Ctx) error
DeleteContest(c *fiber.Ctx, id int32) error
GetContest(c *fiber.Ctx, id int32) error

View file

@ -19,8 +19,33 @@ func NewTesterHandlers(problemsUC tester.ProblemUseCase, contestsUC tester.Conte
}
}
func (h *TesterHandlers) ListContests(c *fiber.Ctx) error {
return c.SendStatus(fiber.StatusNotImplemented)
func (h *TesterHandlers) ListContests(c *fiber.Ctx, params testerv1.ListContestsParams) error {
contests, count, err := h.contestsUC.ListContests(c.Context(), params.Page, params.PageSize)
if err != nil {
return c.SendStatus(pkg.ToREST(err))
}
resp := testerv1.ListContestsResponse{
Contests: make([]testerv1.ContestsListItem, len(contests)),
Page: params.Page,
MaxPage: func() int32 {
if count%params.PageSize == 0 {
return count / params.PageSize
}
return count/params.PageSize + 1
}(),
}
for i, contest := range contests {
resp.Contests[i] = testerv1.ContestsListItem{
Id: contest.Id,
Title: contest.Title,
CreatedAt: contest.CreatedAt,
UpdatedAt: contest.UpdatedAt,
}
}
return c.JSON(resp)
}
func (h *TesterHandlers) ListProblems(c *fiber.Ctx, params testerv1.ListProblemsParams) error {

View file

@ -21,4 +21,5 @@ type ContestRepository interface {
AddParticipant(ctx context.Context, contestId int32, userId int32) (int32, error)
DeleteParticipant(ctx context.Context, participantId int32) error
ReadRichTasks(ctx context.Context, contestId int32) ([]*models.RichTask, error)
ListContests(ctx context.Context, page int32, pageSize int32) ([]*models.ContestsListItem, int32, error)
}

View file

@ -158,3 +158,27 @@ func (r *ContestRepository) ReadRichTasks(ctx context.Context, contestId int32)
}
return tasks, nil
}
const (
readContestsListQuery = `SELECT id, title, created_at, updated_at FROM contests LIMIT ? OFFSET ?`
countContestsQuery = "SELECT COUNT(*) FROM contests"
)
func (r *ContestRepository) ListContests(ctx context.Context, page int32, pageSize int32) ([]*models.ContestsListItem, int32, error) {
const op = "ContestRepository.ReadTasks"
var tasks []*models.ContestsListItem
query := r.db.Rebind(readContestsListQuery)
err := r.db.SelectContext(ctx, &tasks, query, pageSize, (page-1)*pageSize)
if err != nil {
return nil, 0, handlePgErr(err, op)
}
var count int32
err = r.db.GetContext(ctx, &count, countContestsQuery)
if err != nil {
return nil, 0, handlePgErr(err, op)
}
return tasks, count, nil
}

View file

@ -21,4 +21,5 @@ type ContestUseCase interface {
AddParticipant(ctx context.Context, contestId int32, userId int32) (int32, error)
DeleteParticipant(ctx context.Context, participantId int32) error
ReadRichTasks(ctx context.Context, contestId int32) ([]*models.RichTask, error)
ListContests(ctx context.Context, page int32, pageSize int32) ([]*models.ContestsListItem, int32, error)
}

View file

@ -49,3 +49,7 @@ func (uc *ContestUseCase) DeleteParticipant(ctx context.Context, participantId i
func (uc *ContestUseCase) ReadRichTasks(ctx context.Context, contestId int32) ([]*models.RichTask, error) {
return uc.contestRepo.ReadRichTasks(ctx, contestId)
}
func (uc *ContestUseCase) ListContests(ctx context.Context, page int32, pageSize int32) ([]*models.ContestsListItem, int32, error) {
return uc.contestRepo.ListContests(ctx, page, pageSize)
}

2
proto

@ -1 +1 @@
Subproject commit 55846c7a2b06b7dcd78fc001b322bdb96a5c8bca
Subproject commit ac0eb56bb9dee9f0933f858e16d61c9e40c89a29