4ee647a951
This change adds request IDs to requests, logs them as part of audit logs and sends to the client on error. This is to improve debugging of customer issues. Issue: https://github.com/storj/storj/issues/5898 Change-Id: I801514b547d28d810552d91aa7c8502051e552bf
88 lines
2.2 KiB
Go
88 lines
2.2 KiB
Go
// Copyright (C) 2020 Storj Labs, Inc.
|
|
// See LICENSE for copying information.
|
|
|
|
package consoleapi
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"net/http"
|
|
|
|
"github.com/zeebo/errs"
|
|
"go.uber.org/zap"
|
|
|
|
"storj.io/common/uuid"
|
|
"storj.io/storj/private/web"
|
|
"storj.io/storj/satellite/console"
|
|
)
|
|
|
|
var (
|
|
// ErrBucketsAPI - console buckets api error type.
|
|
ErrBucketsAPI = errs.Class("console api buckets")
|
|
)
|
|
|
|
// Buckets is an api controller that exposes all buckets related functionality.
|
|
type Buckets struct {
|
|
log *zap.Logger
|
|
service *console.Service
|
|
}
|
|
|
|
// NewBuckets is a constructor for api buckets controller.
|
|
func NewBuckets(log *zap.Logger, service *console.Service) *Buckets {
|
|
return &Buckets{
|
|
log: log,
|
|
service: service,
|
|
}
|
|
}
|
|
|
|
// AllBucketNames returns all bucket names for a specific project.
|
|
func (b *Buckets) AllBucketNames(w http.ResponseWriter, r *http.Request) {
|
|
ctx := r.Context()
|
|
var err error
|
|
defer mon.Task()(&ctx)(&err)
|
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
|
|
projectIDString := r.URL.Query().Get("projectID")
|
|
publicIDString := r.URL.Query().Get("publicID")
|
|
|
|
var projectID uuid.UUID
|
|
if projectIDString != "" {
|
|
projectID, err = uuid.FromString(projectIDString)
|
|
if err != nil {
|
|
b.serveJSONError(ctx, w, http.StatusBadRequest, err)
|
|
return
|
|
}
|
|
} else if publicIDString != "" {
|
|
projectID, err = uuid.FromString(publicIDString)
|
|
if err != nil {
|
|
b.serveJSONError(ctx, w, http.StatusBadRequest, err)
|
|
return
|
|
}
|
|
} else {
|
|
b.serveJSONError(ctx, w, http.StatusBadRequest, errs.New("Project ID was not provided."))
|
|
return
|
|
}
|
|
|
|
bucketNames, err := b.service.GetAllBucketNames(ctx, projectID)
|
|
if err != nil {
|
|
if console.ErrUnauthorized.Has(err) {
|
|
b.serveJSONError(ctx, w, http.StatusUnauthorized, err)
|
|
return
|
|
}
|
|
|
|
b.serveJSONError(ctx, w, http.StatusInternalServerError, err)
|
|
return
|
|
}
|
|
|
|
err = json.NewEncoder(w).Encode(bucketNames)
|
|
if err != nil {
|
|
b.log.Error("failed to write json all bucket names response", zap.Error(ErrBucketsAPI.Wrap(err)))
|
|
}
|
|
}
|
|
|
|
// serveJSONError writes JSON error to response output stream.
|
|
func (b *Buckets) serveJSONError(ctx context.Context, w http.ResponseWriter, status int, err error) {
|
|
web.ServeJSONError(ctx, b.log, w, status, err)
|
|
}
|