This repository has been archived on 2022-09-04. You can view files and clone it, but cannot push or open issues or pull requests.
api/server/usecase/server_usecase.go

50 lines
1.1 KiB
Go
Raw Normal View History

2020-06-02 15:45:21 +00:00
package usecase
import (
"context"
"fmt"
2020-08-09 12:32:46 +00:00
"github.com/tribalwarshelp/api/middleware"
2020-06-02 15:45:21 +00:00
"github.com/tribalwarshelp/api/server"
2020-06-04 13:06:32 +00:00
"github.com/tribalwarshelp/api/utils"
2020-06-02 15:45:21 +00:00
"github.com/tribalwarshelp/shared/models"
)
type usecase struct {
repo server.Repository
}
func New(repo server.Repository) server.Usecase {
return &usecase{repo}
}
func (ucase *usecase) Fetch(ctx context.Context, filter *models.ServerFilter) ([]*models.Server, int, error) {
if filter == nil {
filter = &models.ServerFilter{}
}
2020-08-09 12:32:46 +00:00
if !middleware.MayExceedLimit(ctx) && (filter.Limit > server.PaginationLimit || filter.Limit <= 0) {
2020-06-02 15:45:21 +00:00
filter.Limit = server.PaginationLimit
}
2020-06-04 13:06:32 +00:00
filter.Sort = utils.SanitizeSort(filter.Sort)
return ucase.repo.Fetch(ctx, server.FetchConfig{
Count: true,
Filter: filter,
})
2020-06-02 15:45:21 +00:00
}
func (ucase *usecase) GetByKey(ctx context.Context, key string) (*models.Server, error) {
servers, _, err := ucase.repo.Fetch(ctx, server.FetchConfig{
Filter: &models.ServerFilter{
Key: []string{key},
Limit: 1,
},
2020-06-02 15:45:21 +00:00
})
if err != nil {
return nil, err
}
if len(servers) == 0 {
return nil, fmt.Errorf("Server (key: %s) not found.", key)
2020-06-02 15:45:21 +00:00
}
return servers[0], nil
}