Function getAuthScopeHandleCreateDB

rest/admin_api.go:185–221

getAuthScopeHandleCreateDB determines the auth scope for a PUT /{db}/ request. This is a special case because we don't have a database initialized yet, so we need to infer the bucket from db config.

(ctx context.Context, h *handler)

// getAuthScopeHandleCreateDB determines the auth scope for a PUT /{db}/ request.
// This is a special case because we don't have a database initialized yet, so we need to infer the bucket from db config.
func getAuthScopeHandleCreateDB(ctx context.Context, h *handler) (bucketName string, err error) {

	// grab a copy of the request body and restore body buffer for later handlers
	bodyJSON, readErr := h.readBody()
	if readErr != nil {
		return "", base.HTTPErrorf(http.StatusInternalServerError, "Unable to read body: %v", readErr)
	}
	// mark the body as already read to avoid double-counting bytes for stats once it gets read again
	h.requestBody.bodyRead = true
	h.requestBody.reader = io.NopCloser(bytes.NewReader(bodyJSON))

	var dbConfigBody struct {
		Bucket string `json:"bucket"`
	}

	bodyJSON, err = sanitiseConfig(ctx, bodyJSON, h.server.Config.Unsupported.AllowDbConfigEnvVars)
	if err != nil {
		return "", err
	}

	d := base.JSONDecoder(bytes.NewBuffer(bodyJSON))
	err = d.Decode(&dbConfigBody)
	if err != nil {
		return "", err
	}

	if dbConfigBody.Bucket == "" {
		dbName := h.PathVar("newdb")
		if dbName == "" {
			return "", base.HTTPErrorf(http.StatusBadRequest, "bucket or db name not specified in request")
		}
		// imply bucket name from db name in path if not in body
		return dbName, nil
	}

	return dbConfigBody.Bucket, nil
}

// Take a DB online, first reload the DB config
func (h *handler) handleDbOnline() error {