116 lines
2.5 KiB
Go
116 lines
2.5 KiB
Go
package service
|
|
|
|
import (
|
|
"context"
|
|
"strings"
|
|
|
|
"git.itzana.me/strafesnet/go-grpc/maps"
|
|
"git.itzana.me/strafesnet/maps-service/pkg/api"
|
|
"git.itzana.me/strafesnet/maps-service/pkg/roblox"
|
|
)
|
|
|
|
// ListMaps implements listMaps operation.
|
|
//
|
|
// Get list of maps.
|
|
//
|
|
// GET /maps
|
|
func (svc *Service) ListMaps(ctx context.Context, params api.ListMapsParams) ([]api.Map, error) {
|
|
filter := maps.MapFilter{}
|
|
|
|
if params.DisplayName.IsSet(){
|
|
filter.DisplayName = ¶ms.DisplayName.Value
|
|
}
|
|
if params.Creator.IsSet(){
|
|
filter.Creator = ¶ms.Creator.Value
|
|
}
|
|
if params.GameID.IsSet(){
|
|
filter.GameID = ¶ms.GameID.Value
|
|
}
|
|
|
|
mapList, err := svc.Maps.List(ctx, &maps.ListRequest{
|
|
Filter: &filter,
|
|
Page: &maps.Pagination{
|
|
Size: params.Limit,
|
|
Number: params.Page,
|
|
},
|
|
})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
var resp []api.Map
|
|
for _, item := range mapList.Maps {
|
|
resp = append(resp, api.Map{
|
|
ID: item.ID,
|
|
DisplayName: item.DisplayName,
|
|
Creator: item.Creator,
|
|
GameID: item.GameID,
|
|
Date: item.Date,
|
|
})
|
|
}
|
|
|
|
return resp, nil
|
|
}
|
|
|
|
// GetMap implements getScript operation.
|
|
//
|
|
// Get the specified script by ID.
|
|
//
|
|
// GET /maps/{MapID}
|
|
func (svc *Service) GetMap(ctx context.Context, params api.GetMapParams) (*api.Map, error) {
|
|
mapResponse, err := svc.Maps.Get(ctx, &maps.IdMessage{
|
|
ID: params.MapID,
|
|
})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &api.Map{
|
|
ID: mapResponse.ID,
|
|
DisplayName: mapResponse.DisplayName,
|
|
Creator: mapResponse.Creator,
|
|
GameID: mapResponse.GameID,
|
|
Date: mapResponse.Date,
|
|
}, nil
|
|
}
|
|
|
|
// GetMapAssetLocation invokes getMapAssetLocation operation.
|
|
//
|
|
// Get location of map asset.
|
|
//
|
|
// GET /maps/{MapID}/location
|
|
func (svc *Service) GetMapAssetLocation(ctx context.Context, params api.GetMapAssetLocationParams) (ok api.GetMapAssetLocationOK, err error) {
|
|
userInfo, success := ctx.Value("UserInfo").(UserInfoHandle)
|
|
if !success {
|
|
return ok, ErrUserInfo
|
|
}
|
|
|
|
has_role, err := userInfo.HasRoleMapDownload()
|
|
if err != nil {
|
|
return ok, err
|
|
}
|
|
|
|
if !has_role {
|
|
return ok, ErrPermissionDeniedNeedRoleMapDownload
|
|
}
|
|
|
|
// Ensure map exists in the db!
|
|
// This could otherwise be used to access any asset
|
|
_, err = svc.Maps.Get(ctx, &maps.IdMessage{
|
|
ID: params.MapID,
|
|
})
|
|
if err != nil {
|
|
return ok, err
|
|
}
|
|
|
|
info, err := svc.Roblox.GetAssetLocation(roblox.GetAssetLatestRequest{
|
|
AssetID: uint64(params.MapID),
|
|
})
|
|
if err != nil{
|
|
return ok, err
|
|
}
|
|
|
|
ok.Data = strings.NewReader(info.Location)
|
|
return ok, nil
|
|
}
|