package server
import (
"net/http"
"strconv"
"strings"
"github.com/keys-pub/keys"
"github.com/keys-pub/keys-ext/http/api"
"github.com/keys-pub/keys/user"
"github.com/keys-pub/keys/users"
"github.com/labstack/echo/v4"
"github.com/pkg/errors"
)
func (s *Server) getUserSearch(c echo.Context) error {
s.logger.Infof("Server %s %s", c.Request().Method, c.Request().URL.String())
ctx := c.Request().Context()
q := c.QueryParam("q")
plimit := c.QueryParam("limit")
if plimit == "" {
plimit = "100"
}
limit, err := strconv.Atoi(plimit)
if err != nil {
return s.ErrBadRequest(c, errors.Wrapf(err, "invalid limit"))
}
results, err := s.users.Search(ctx, &users.SearchRequest{Query: q, Limit: limit})
if err != nil {
return s.ErrInternalServer(c, err)
}
usrs := make([]*api.User, 0, len(results))
for _, res := range results {
usrs = append(usrs, api.UserFromSearchResult(res))
}
resp := api.UserSearchResponse{
Users: usrs,
}
return JSON(c, http.StatusOK, resp)
}
func (s *Server) getUser(c echo.Context) error {
s.logger.Infof("Server %s %s", c.Request().Method, c.Request().URL.String())
ctx := c.Request().Context()
param := strings.TrimSpace(c.Param("user"))
var userResult *user.Result
if strings.Contains(param, "@") {
ur, err := s.users.User(ctx, param)
if err != nil {
return s.ErrInternalServer(c, err)
}
userResult = ur
} else {
kid, err := keys.ParseID(param)
if err != nil {
return s.ErrNotFound(c, errors.Errorf("user not found"))
}
ur, err := s.users.Find(ctx, kid)
if err != nil {
return s.ErrInternalServer(c, err)
}
userResult = ur
}
if userResult == nil {
return s.ErrNotFound(c, errors.Errorf("user not found"))
}
resp := api.UserResponse{
User: api.UserFromResult(userResult),
}
return JSON(c, http.StatusOK, resp)
}