get_usage.go 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. package project
  2. import (
  3. "net/http"
  4. "github.com/porter-dev/porter/api/server/handlers"
  5. "github.com/porter-dev/porter/api/server/shared"
  6. "github.com/porter-dev/porter/api/server/shared/apierrors"
  7. "github.com/porter-dev/porter/api/server/shared/config"
  8. "github.com/porter-dev/porter/api/types"
  9. "github.com/porter-dev/porter/internal/models"
  10. "github.com/porter-dev/porter/internal/usage"
  11. )
  12. type ProjectGetUsageHandler struct {
  13. handlers.PorterHandlerWriter
  14. }
  15. func NewProjectGetUsageHandler(
  16. config *config.Config,
  17. writer shared.ResultWriter,
  18. ) *ProjectGetUsageHandler {
  19. return &ProjectGetUsageHandler{
  20. PorterHandlerWriter: handlers.NewDefaultPorterHandler(config, nil, writer),
  21. }
  22. }
  23. func (p *ProjectGetUsageHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
  24. proj, _ := r.Context().Value(types.ProjectScope).(*models.Project)
  25. res := &types.GetProjectUsageResponse{}
  26. currUsage, limit, usageCache, err := usage.GetUsage(p.Config(), proj)
  27. if err != nil {
  28. p.HandleAPIError(w, r, apierrors.NewErrInternal(err))
  29. return
  30. }
  31. res.Current = *currUsage
  32. res.Limit = *limit
  33. res.IsExceeded = usageCache.Exceeded
  34. res.ExceededSince = usageCache.ExceededSince
  35. p.WriteResult(w, r, res)
  36. }