get_thing.go 1.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950
  1. package thing
  2. import (
  3. "database/sql"
  4. "errors"
  5. "git.dmitriygnatenko.ru/dima/go-common/logger"
  6. "github.com/gofiber/fiber/v2"
  7. "git.dmitriygnatenko.ru/dima/homethings/internal/helpers/location"
  8. "git.dmitriygnatenko.ru/dima/homethings/internal/helpers/request"
  9. "git.dmitriygnatenko.ru/dima/homethings/internal/mappers"
  10. )
  11. // @Router /api/v1/things/{thingId} [get]
  12. // @Param thingId path int true "Thing ID"
  13. // @Success 200 {object} dto.ThingResponse
  14. // @Failure 404 {object} dto.EmptyResponse
  15. // @Failure 400 {object} dto.ErrorResponse
  16. // @Failure 500 {object} dto.ErrorResponse
  17. // @Summary Get one thing
  18. // @Tags Things
  19. // @security APIKey
  20. // @Accept json
  21. // @Produce json
  22. func GetThingHandler(thingRepository ThingRepository) fiber.Handler {
  23. return func(fctx *fiber.Ctx) error {
  24. ctx := fctx.Context()
  25. id, err := request.ConvertToUint64(fctx, "thingId")
  26. if err != nil {
  27. logger.Info(ctx, err.Error())
  28. return fiber.NewError(fiber.StatusBadRequest, err.Error())
  29. }
  30. res, err := thingRepository.Get(ctx, id)
  31. if err != nil {
  32. if errors.Is(err, sql.ErrNoRows) {
  33. logger.Info(ctx, err.Error())
  34. return fiber.NewError(fiber.StatusNotFound, "")
  35. }
  36. logger.Error(ctx, err.Error())
  37. return fiber.NewError(fiber.StatusInternalServerError, err.Error())
  38. }
  39. res = location.ApplyLocation(fctx, res)
  40. return fctx.JSON(mappers.ToThingResponse(*res))
  41. }
  42. }