Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #15275 from influxdata/task/15258_remove_senstive_data_logging 

chore(http): remove logging of senstive data
pull/15276/head
Johnny Steenbergen 2019-09-25 10:13:10 -07:00 committed by GitHub
parent ff2747a728 fc955c5abe
commit 4da248ec30
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
17 changed files with 0 additions and 145 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
http/auth_service.go
View File

@ -186,8 +186,6 @@ func newAuthsResponse(as []*authResponse) *authsResponse {
func (h *AuthorizationHandler) handlePostAuthorization(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("create auth request", zap.String("r", fmt.Sprint(r)))
req, err := decodePostAuthorizationRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -327,8 +325,6 @@ func decodePostAuthorizationRequest(ctx context.Context, r *http.Request) (*post
// handleGetAuthorizations is the HTTP handler for the GET /api/v2/authorizations route.
func (h *AuthorizationHandler) handleGetAuthorizations(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("get auths request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetAuthorizationsRequest(ctx, r)
if err != nil {
h.Logger.Info("failed to decode request", zap.String("handler", "getAuthorizations"), zap.Error(err))
@ -426,8 +422,6 @@ func decodeGetAuthorizationsRequest(ctx context.Context, r *http.Request) (*getA
// handleGetAuthorization is the HTTP handler for the GET /api/v2/authorizations/:id route.
func (h *AuthorizationHandler) handleGetAuthorization(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("get auth request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetAuthorizationRequest(ctx, r)
if err != nil {
h.Logger.Info("failed to decode request", zap.String("handler", "getAuthorization"), zap.Error(err))
@ -495,8 +489,6 @@ func decodeGetAuthorizationRequest(ctx context.Context, r *http.Request) (*getAu
// handleUpdateAuthorization is the HTTP handler for the PATCH /api/v2/authorizations/:id route that updates the authorization's status and desc.
func (h *AuthorizationHandler) handleUpdateAuthorization(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("update auth request", zap.String("r", fmt.Sprint(r)))
req, err := decodeUpdateAuthorizationRequest(ctx, r)
if err != nil {
h.Logger.Info("failed to decode request", zap.String("handler", "updateAuthorization"), zap.Error(err))
@ -575,9 +567,6 @@ func decodeUpdateAuthorizationRequest(ctx context.Context, r *http.Request) (*up
// handleDeleteAuthorization is the HTTP handler for the DELETE /api/v2/authorizations/:id route.
func (h *AuthorizationHandler) handleDeleteAuthorization(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("delete auth request", zap.String("r", fmt.Sprint(r)))
req, err := decodeDeleteAuthorizationRequest(ctx, r)
if err != nil {
h.Logger.Info("failed to decode request", zap.String("handler", "deleteAuthorization"), zap.Error(err))

12
http/bucket_service.go
View File

@ -303,8 +303,6 @@ func newBucketsResponse(ctx context.Context, opts influxdb.FindOptions, f influx
// handlePostBucket is the HTTP handler for the POST /api/v2/buckets route.
func (h *BucketHandler) handlePostBucket(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("create bucket request", zap.String("r", fmt.Sprint(r)))
req, err := decodePostBucketRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -363,8 +361,6 @@ func decodePostBucketRequest(ctx context.Context, r *http.Request) (*postBucketR
func (h *BucketHandler) handleGetBucket(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("retrieve bucket request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetBucketRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -419,8 +415,6 @@ func decodeGetBucketRequest(ctx context.Context, r *http.Request) (*getBucketReq
// handleDeleteBucket is the HTTP handler for the DELETE /api/v2/buckets/:id route.
func (h *BucketHandler) handleDeleteBucket(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("delete bucket request", zap.String("r", fmt.Sprint(r)))
req, err := decodeDeleteBucketRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -468,8 +462,6 @@ func (h *BucketHandler) handleGetBuckets(w http.ResponseWriter, r *http.Request)
defer span.Finish()
ctx := r.Context()
h.Logger.Debug("retrieve buckets request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetBucketsRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -535,8 +527,6 @@ func decodeGetBucketsRequest(ctx context.Context, r *http.Request) (*getBucketsR
// handlePatchBucket is the HTTP handler for the PATCH /api/v2/buckets route.
func (h *BucketHandler) handlePatchBucket(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("update bucket request", zap.String("r", fmt.Sprint(r)))
req, err := decodePatchBucketRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -869,8 +859,6 @@ func bucketIDPath(id influxdb.ID) string {
// hanldeGetBucketLog retrieves a bucket log by the buckets ID.
func (h *BucketHandler) handleGetBucketLog(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("retrieve bucket log request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetBucketLogRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)

6
http/check_service.go
View File

@ -235,7 +235,6 @@ func decodeGetCheckRequest(ctx context.Context, r *http.Request) (i influxdb.ID,
func (h *CheckHandler) handleGetChecks(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("checks retrieve request", zap.String("r", fmt.Sprint(r)))
filter, opts, err := decodeCheckFilter(ctx, r)
if err != nil {
h.Logger.Debug("failed to decode request", zap.Error(err))
@ -291,7 +290,6 @@ func newFluxResponse(flux string) fluxResp {
func (h *CheckHandler) handleGetCheck(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("check retrieve request", zap.String("r", fmt.Sprint(r)))
id, err := decodeGetCheckRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -487,7 +485,6 @@ func decodePatchCheckRequest(ctx context.Context, r *http.Request) (*patchCheckR
// handlePostCheck is the HTTP handler for the POST /api/v2/checks route.
func (h *CheckHandler) handlePostCheck(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("check create request", zap.String("r", fmt.Sprint(r)))
chk, err := decodePostCheckRequest(ctx, r)
if err != nil {
h.Logger.Debug("failed to decode request", zap.Error(err))
@ -522,7 +519,6 @@ func (h *CheckHandler) handlePostCheck(w http.ResponseWriter, r *http.Request) {
// handlePutCheck is the HTTP handler for the PUT /api/v2/checks route.
func (h *CheckHandler) handlePutCheck(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("check replace request", zap.String("r", fmt.Sprint(r)))
chk, err := decodePutCheckRequest(ctx, r)
if err != nil {
h.Logger.Debug("failed to decode request", zap.Error(err))
@ -558,7 +554,6 @@ func (h *CheckHandler) handlePutCheck(w http.ResponseWriter, r *http.Request) {
// handlePatchCheck is the HTTP handler for the PATCH /api/v2/checks/:id route.
func (h *CheckHandler) handlePatchCheck(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("check patch request", zap.String("r", fmt.Sprint(r)))
req, err := decodePatchCheckRequest(ctx, r)
if err != nil {
h.Logger.Debug("failed to decode request", zap.Error(err))
@ -593,7 +588,6 @@ func (h *CheckHandler) handlePatchCheck(w http.ResponseWriter, r *http.Request)
func (h *CheckHandler) handleDeleteCheck(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("check delete request", zap.String("r", fmt.Sprint(r)))
i, err := decodeGetCheckRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)

24
http/dashboard_service.go
View File

@ -315,8 +315,6 @@ func newOperationLogEntryResponse(e *platform.OperationLogEntry) *operationLogEn
// handleGetDashboards returns all dashboards within the store.
func (h *DashboardHandler) handleGetDashboards(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("get dashboards request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetDashboardsRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -434,8 +432,6 @@ func newGetDashboardsResponse(ctx context.Context, dashboards []*platform.Dashbo
// handlePostDashboard creates a new dashboard.
func (h *DashboardHandler) handlePostDashboard(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("create dashboard request", zap.String("r", fmt.Sprint(r)))
req, err := decodePostDashboardRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -469,8 +465,6 @@ func decodePostDashboardRequest(ctx context.Context, r *http.Request) (*postDash
// hanldeGetDashboard retrieves a dashboard by ID.
func (h *DashboardHandler) handleGetDashboard(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("get dashboard request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetDashboardRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -524,8 +518,6 @@ func decodeGetDashboardRequest(ctx context.Context, r *http.Request) (*getDashbo
// hanldeGetDashboardLog retrieves a dashboard log by the dashboards ID.
func (h *DashboardHandler) handleGetDashboardLog(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("get dashboard log request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetDashboardLogRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -580,8 +572,6 @@ func decodeGetDashboardLogRequest(ctx context.Context, r *http.Request) (*getDas
// handleDeleteDashboard removes a dashboard by ID.
func (h *DashboardHandler) handleDeleteDashboard(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("delete dashboard request", zap.String("r", fmt.Sprint(r)))
req, err := decodeDeleteDashboardRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -625,8 +615,6 @@ func decodeDeleteDashboardRequest(ctx context.Context, r *http.Request) (*delete
// handlePatchDashboard updates a dashboard.
func (h *DashboardHandler) handlePatchDashboard(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("update dashboard request", zap.String("r", fmt.Sprint(r)))
req, err := decodePatchDashboardRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -744,8 +732,6 @@ func decodePostDashboardCellRequest(ctx context.Context, r *http.Request) (*post
// handlePostDashboardCell creates a dashboard cell.
func (h *DashboardHandler) handlePostDashboardCell(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("create dashboard cell request", zap.String("r", fmt.Sprint(r)))
req, err := decodePostDashboardCellRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -823,8 +809,6 @@ func decodePutDashboardCellRequest(ctx context.Context, r *http.Request) (*putDa
// handlePutDashboardCells replaces a dashboards cells.
func (h *DashboardHandler) handlePutDashboardCells(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("replace dashboard cell request", zap.String("r", fmt.Sprint(r)))
req, err := decodePutDashboardCellRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -908,8 +892,6 @@ func decodeGetDashboardCellViewRequest(ctx context.Context, r *http.Request) (*g
func (h *DashboardHandler) handleGetDashboardCellView(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("get dashboard cell view request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetDashboardCellViewRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -965,8 +947,6 @@ func decodePatchDashboardCellViewRequest(ctx context.Context, r *http.Request) (
func (h *DashboardHandler) handlePatchDashboardCellView(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("update dashboard cell view request", zap.String("r", fmt.Sprint(r)))
req, err := decodePatchDashboardCellViewRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -989,8 +969,6 @@ func (h *DashboardHandler) handlePatchDashboardCellView(w http.ResponseWriter, r
// handleDeleteDashboardCell deletes a dashboard cell.
func (h *DashboardHandler) handleDeleteDashboardCell(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("delete dashboard cell request", zap.String("r", fmt.Sprint(r)))
req, err := decodeDeleteDashboardCellRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -1054,8 +1032,6 @@ func decodePatchDashboardCellRequest(ctx context.Context, r *http.Request) (*pat
// handlePatchDashboardCell updates a dashboard cell.
func (h *DashboardHandler) handlePatchDashboardCell(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("update dashboard cell request", zap.String("r", fmt.Sprint(r)))
req, err := decodePatchDashboardCellRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)

12
http/document_service.go
View File

@ -110,8 +110,6 @@ func newDocumentsResponse(ns string, docs []*influxdb.Document) *documentsRespon
// handlePostDocument is the HTTP handler for the POST /api/v2/documents/:ns route.
func (h *DocumentHandler) handlePostDocument(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("document create request", zap.String("r", fmt.Sprint(r)))
req, err := decodePostDocumentRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -193,8 +191,6 @@ func decodePostDocumentRequest(ctx context.Context, r *http.Request) (*postDocum
// handleGetDocuments is the HTTP handler for the GET /api/v2/documents/:ns route.
func (h *DocumentHandler) handleGetDocuments(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("documents retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetDocumentsRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -279,7 +275,6 @@ func decodeGetDocumentsRequest(ctx context.Context, r *http.Request) (*getDocume
func (h *DocumentHandler) handlePostDocumentLabel(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("document label create request", zap.String("r", fmt.Sprint(r)))
_, _, err := h.getDocument(w, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -318,7 +313,6 @@ func (h *DocumentHandler) handlePostDocumentLabel(w http.ResponseWriter, r *http
// then remove that label.
func (h *DocumentHandler) handleDeleteDocumentLabel(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("document label delete request", zap.String("r", fmt.Sprint(r)))
req, err := decodeDeleteLabelMappingRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -354,7 +348,6 @@ func (h *DocumentHandler) handleDeleteDocumentLabel(w http.ResponseWriter, r *ht
func (h *DocumentHandler) handleGetDocumentLabel(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("document label retrieve request", zap.String("r", fmt.Sprint(r)))
d, _, err := h.getDocument(w, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -400,7 +393,6 @@ func (h *DocumentHandler) getDocument(w http.ResponseWriter, r *http.Request) (*
// handleGetDocument is the HTTP handler for the GET /api/v2/documents/:ns/:id route.
func (h *DocumentHandler) handleGetDocument(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("document retrieve request", zap.String("r", fmt.Sprint(r)))
d, namspace, err := h.getDocument(w, r)
if err != nil {
@ -455,8 +447,6 @@ func decodeGetDocumentRequest(ctx context.Context, r *http.Request) (*getDocumen
// handleDeleteDocument is the HTTP handler for the DELETE /api/v2/documents/:ns/:id route.
func (h *DocumentHandler) handleDeleteDocument(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("document delete request", zap.String("r", fmt.Sprint(r)))
req, err := decodeDeleteDocumentRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -525,8 +515,6 @@ func decodeDeleteDocumentRequest(ctx context.Context, r *http.Request) (*deleteD
// handlePutDocument is the HTTP handler for the PUT /api/v2/documents/:ns/:id route.
func (h *DocumentHandler) handlePutDocument(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("document update request", zap.String("r", fmt.Sprint(r)))
req, err := decodePutDocumentRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)

10
http/label_service.go
View File

@ -50,8 +50,6 @@ func NewLabelHandler(s influxdb.LabelService, he influxdb.HTTPErrorHandler) *Lab
// handlePostLabel is the HTTP handler for the POST /api/v2/labels route.
func (h *LabelHandler) handlePostLabel(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("label create request", zap.String("r", fmt.Sprint(r)))
req, err := decodePostLabelRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -110,8 +108,6 @@ func decodePostLabelRequest(ctx context.Context, r *http.Request) (*postLabelReq
// handleGetLabels is the HTTP handler for the GET /api/v2/labels route.
func (h *LabelHandler) handleGetLabels(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("labels retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetLabelsRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -153,8 +149,6 @@ func decodeGetLabelsRequest(ctx context.Context, r *http.Request) (*getLabelsReq
// handleGetLabel is the HTTP handler for the GET /api/v2/labels/id route.
func (h *LabelHandler) handleGetLabel(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("label retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetLabelRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -201,8 +195,6 @@ func decodeGetLabelRequest(ctx context.Context, r *http.Request) (*getLabelReque
// handleDeleteLabel is the HTTP handler for the DELETE /api/v2/labels/:id route.
func (h *LabelHandler) handleDeleteLabel(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("label delete request", zap.String("r", fmt.Sprint(r)))
req, err := decodeDeleteLabelRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -245,8 +237,6 @@ func decodeDeleteLabelRequest(ctx context.Context, r *http.Request) (*deleteLabe
// handlePatchLabel is the HTTP handler for the PATCH /api/v2/labels route.
func (h *LabelHandler) handlePatchLabel(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("label update request", zap.String("r", fmt.Sprint(r)))
req, err := decodePatchLabelRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)

6
http/notification_endpoint.go
View File

@ -213,7 +213,6 @@ func decodeGetNotificationEndpointRequest(ctx context.Context, r *http.Request)
func (h *NotificationEndpointHandler) handleGetNotificationEndpoints(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("notificationEndpoints retrieve request", zap.String("r", fmt.Sprint(r)))
filter, opts, err := decodeNotificationEndpointFilter(ctx, r)
if err != nil {
h.Logger.Debug("failed to decode request", zap.Error(err))
@ -235,7 +234,6 @@ func (h *NotificationEndpointHandler) handleGetNotificationEndpoints(w http.Resp
func (h *NotificationEndpointHandler) handleGetNotificationEndpoint(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("notificationEndpoint retrieve request", zap.String("r", fmt.Sprint(r)))
id, err := decodeGetNotificationEndpointRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -381,7 +379,6 @@ func decodePatchNotificationEndpointRequest(ctx context.Context, r *http.Request
// handlePostNotificationEndpoint is the HTTP handler for the POST /api/v2/notificationEndpoints route.
func (h *NotificationEndpointHandler) handlePostNotificationEndpoint(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("notificationEndpoint create request", zap.String("r", fmt.Sprint(r)))
edp, err := decodePostNotificationEndpointRequest(ctx, r)
if err != nil {
h.Logger.Debug("failed to decode request", zap.Error(err))
@ -423,7 +420,6 @@ func (h *NotificationEndpointHandler) handlePostNotificationEndpoint(w http.Resp
// handlePutNotificationEndpoint is the HTTP handler for the PUT /api/v2/notificationEndpoints route.
func (h *NotificationEndpointHandler) handlePutNotificationEndpoint(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("notificationEndpoint replace request", zap.String("r", fmt.Sprint(r)))
edp, err := decodePutNotificationEndpointRequest(ctx, r)
if err != nil {
h.Logger.Debug("failed to decode request", zap.Error(err))
@ -471,7 +467,6 @@ func (h *NotificationEndpointHandler) handlePutNotificationEndpoint(w http.Respo
// handlePatchNotificationEndpoint is the HTTP handler for the PATCH /api/v2/notificationEndpoints/:id route.
func (h *NotificationEndpointHandler) handlePatchNotificationEndpoint(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("notificationEndpoint patch request", zap.String("r", fmt.Sprint(r)))
req, err := decodePatchNotificationEndpointRequest(ctx, r)
if err != nil {
h.Logger.Debug("failed to decode request", zap.Error(err))
@ -500,7 +495,6 @@ func (h *NotificationEndpointHandler) handlePatchNotificationEndpoint(w http.Res
func (h *NotificationEndpointHandler) handleDeleteNotificationEndpoint(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("notificationEndpoint delete request", zap.String("r", fmt.Sprint(r)))
i, err := decodeGetNotificationEndpointRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)

6
http/notification_rule.go
View File

@ -238,7 +238,6 @@ func decodeGetNotificationRuleRequest(ctx context.Context, r *http.Request) (i i
func (h *NotificationRuleHandler) handleGetNotificationRules(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("notification rules retrieve request", zap.String("r", fmt.Sprint(r)))
filter, opts, err := decodeNotificationRuleFilter(ctx, r)
if err != nil {
h.Logger.Debug("failed to decode request", zap.Error(err))
@ -299,7 +298,6 @@ func (h *NotificationRuleHandler) handleGetNotificationRuleQuery(w http.Response
func (h *NotificationRuleHandler) handleGetNotificationRule(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("notification rule retrieve request", zap.String("r", fmt.Sprint(r)))
id, err := decodeGetNotificationRuleRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -514,7 +512,6 @@ func decodePatchNotificationRuleRequest(ctx context.Context, r *http.Request) (*
// handlePostNotificationRule is the HTTP handler for the POST /api/v2/notificationRules route.
func (h *NotificationRuleHandler) handlePostNotificationRule(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("notification rule create request", zap.String("r", fmt.Sprint(r)))
nr, err := decodePostNotificationRuleRequest(ctx, r)
if err != nil {
h.Logger.Debug("failed to decode request", zap.Error(err))
@ -549,7 +546,6 @@ func (h *NotificationRuleHandler) handlePostNotificationRule(w http.ResponseWrit
// handlePutNotificationRule is the HTTP handler for the PUT /api/v2/notificationRule route.
func (h *NotificationRuleHandler) handlePutNotificationRule(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("notification rule update request", zap.String("r", fmt.Sprint(r)))
nrc, err := decodePutNotificationRuleRequest(ctx, r)
if err != nil {
h.Logger.Debug("failed to decode request", zap.Error(err))
@ -590,7 +586,6 @@ func (h *NotificationRuleHandler) handlePutNotificationRule(w http.ResponseWrite
// handlePatchNotificationRule is the HTTP handler for the PATCH /api/v2/notificationRule/:id route.
func (h *NotificationRuleHandler) handlePatchNotificationRule(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("notification rule patch request", zap.String("r", fmt.Sprint(r)))
req, err := decodePatchNotificationRuleRequest(ctx, r)
if err != nil {
h.Logger.Debug("failed to decode request", zap.Error(err))
@ -625,7 +620,6 @@ func (h *NotificationRuleHandler) handlePatchNotificationRule(w http.ResponseWri
func (h *NotificationRuleHandler) handleDeleteNotificationRule(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("notification rule delete request", zap.String("r", fmt.Sprint(r)))
i, err := decodeGetNotificationRuleRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)

3
http/onboarding.go
View File

@ -62,8 +62,6 @@ type isOnboardingResponse struct {
// isOnboarding is the HTTP handler for the GET /api/v2/setup route.
func (h *SetupHandler) isOnboarding(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("onboarding eligibility request", zap.String("r", fmt.Sprint(r)))
result, err := h.OnboardingService.IsOnboarding(ctx)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -80,7 +78,6 @@ func (h *SetupHandler) isOnboarding(w http.ResponseWriter, r *http.Request) {
// isOnboarding is the HTTP handler for the POST /api/v2/setup route.
func (h *SetupHandler) handlePostSetup(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("onboarding setup request", zap.String("r", fmt.Sprint(r)))
req, err := decodePostSetupRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)

11
http/org_service.go
View File

@ -203,7 +203,6 @@ func newSecretsResponse(orgID influxdb.ID, ks []string) *secretsResponse {
// handlePostOrg is the HTTP handler for the POST /api/v2/orgs route.
func (h *OrgHandler) handlePostOrg(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("org create request", zap.String("r", fmt.Sprint(r)))
req, err := decodePostOrgRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -240,8 +239,6 @@ func decodePostOrgRequest(ctx context.Context, r *http.Request) (*postOrgRequest
// handleGetOrg is the HTTP handler for the GET /api/v2/orgs/:id route.
func (h *OrgHandler) handleGetOrg(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("org retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetOrgRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -290,8 +287,6 @@ func decodeGetOrgRequest(ctx context.Context, r *http.Request) (*getOrgRequest,
// handleGetOrgs is the HTTP handler for the GET /api/v2/orgs route.
func (h *OrgHandler) handleGetOrgs(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("orgs retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetOrgsRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -337,8 +332,6 @@ func decodeGetOrgsRequest(ctx context.Context, r *http.Request) (*getOrgsRequest
// handleDeleteOrganization is the HTTP handler for the DELETE /api/v2/orgs/:id route.
func (h *OrgHandler) handleDeleteOrg(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("org delete request", zap.String("r", fmt.Sprint(r)))
req, err := decodeDeleteOrganizationRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -386,8 +379,6 @@ func decodeDeleteOrganizationRequest(ctx context.Context, r *http.Request) (*del
// handlePatchOrg is the HTTP handler for the PATH /api/v2/orgs route.
func (h *OrgHandler) handlePatchOrg(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("org update request", zap.String("r", fmt.Sprint(r)))
req, err := decodePatchOrgRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -830,8 +821,6 @@ func organizationIDPath(id influxdb.ID) string {
// hanldeGetOrganizationLog retrieves a organization log by the organizations ID.
func (h *OrgHandler) handleGetOrgLog(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("org log retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetOrganizationLogRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)

10
http/scraper_service.go
View File

@ -125,8 +125,6 @@ func NewScraperHandler(b *ScraperBackend) *ScraperHandler {
// handlePostScraperTarget is HTTP handler for the POST /api/v2/scrapers route.
func (h *ScraperHandler) handlePostScraperTarget(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("scraper create request", zap.String("r", fmt.Sprint(r)))
req, err := decodeScraperTargetAddRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -159,8 +157,6 @@ func (h *ScraperHandler) handlePostScraperTarget(w http.ResponseWriter, r *http.
// handleDeleteScraperTarget is the HTTP handler for the DELETE /api/v2/scrapers/:id route.
func (h *ScraperHandler) handleDeleteScraperTarget(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("scraper delete request", zap.String("r", fmt.Sprint(r)))
id, err := decodeScraperTargetIDRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -179,8 +175,6 @@ func (h *ScraperHandler) handleDeleteScraperTarget(w http.ResponseWriter, r *htt
// handlePatchScraperTarget is the HTTP handler for the PATCH /api/v2/scrapers/:id route.
func (h *ScraperHandler) handlePatchScraperTarget(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("scraper update request", zap.String("r", fmt.Sprint(r)))
update, err := decodeScraperTargetUpdateRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -214,8 +208,6 @@ func (h *ScraperHandler) handlePatchScraperTarget(w http.ResponseWriter, r *http
func (h *ScraperHandler) handleGetScraperTarget(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("scraper retrieve request", zap.String("r", fmt.Sprint(r)))
id, err := decodeScraperTargetIDRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -278,8 +270,6 @@ func decodeScraperTargetsRequest(ctx context.Context, r *http.Request) (*getScra
// handleGetScraperTargets is the HTTP handler for the GET /api/v2/scrapers route.
func (h *ScraperHandler) handleGetScraperTargets(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("scrapers retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeScraperTargetsRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)

5
http/source_service.go
View File

@ -272,7 +272,6 @@ func decodeGetSourceBucketsRequest(ctx context.Context, r *http.Request) (*getSo
// handlePostSource is the HTTP handler for the POST /api/v2/sources route.
func (h *SourceHandler) handlePostSource(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("source create request", zap.String("r", fmt.Sprint(r)))
req, err := decodePostSourceRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -310,7 +309,6 @@ func decodePostSourceRequest(ctx context.Context, r *http.Request) (*postSourceR
// handleGetSource is the HTTP handler for the GET /api/v2/sources/:id route.
func (h *SourceHandler) handleGetSource(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("source retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetSourceRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -384,7 +382,6 @@ func decodeGetSourceRequest(ctx context.Context, r *http.Request) (*getSourceReq
// handleDeleteSource is the HTTP handler for the DELETE /api/v2/sources/:id route.
func (h *SourceHandler) handleDeleteSource(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("source delete request", zap.String("r", fmt.Sprint(r)))
req, err := decodeDeleteSourceRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -428,7 +425,6 @@ func decodeDeleteSourceRequest(ctx context.Context, r *http.Request) (*deleteSou
// handleGetSources is the HTTP handler for the GET /api/v2/sources route.
func (h *SourceHandler) handleGetSources(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("sources retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetSourcesRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -462,7 +458,6 @@ func decodeGetSourcesRequest(ctx context.Context, r *http.Request) (*getSourcesR
// handlePatchSource is the HTTP handler for the PATH /api/v2/sources route.
func (h *SourceHandler) handlePatchSource(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("source update request", zap.String("r", fmt.Sprint(r)))
req, err := decodePatchSourceRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)

6
http/task_service.go
View File

@ -269,7 +269,6 @@ func newRunsResponse(rs []*influxdb.Run, taskID influxdb.ID) runsResponse {
func (h *TaskHandler) handleGetTasks(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.logger.Debug("tasks retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetTasksRequest(ctx, r, h.OrganizationService)
if err != nil {
err = &influxdb.Error{
@ -370,8 +369,6 @@ func decodeGetTasksRequest(ctx context.Context, r *http.Request, orgs influxdb.O
func (h *TaskHandler) handlePostTask(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.logger.Debug("task create request", zap.String("r", fmt.Sprint(r)))
req, err := decodePostTaskRequest(ctx, r)
if err != nil {
err = &influxdb.Error{
@ -459,7 +456,6 @@ func decodePostTaskRequest(ctx context.Context, r *http.Request) (*postTaskReque
func (h *TaskHandler) handleGetTask(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.logger.Debug("task retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetTaskRequest(ctx, r)
if err != nil {
err = &influxdb.Error{
@ -526,7 +522,6 @@ func decodeGetTaskRequest(ctx context.Context, r *http.Request) (*getTaskRequest
func (h *TaskHandler) handleUpdateTask(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.logger.Debug("task update request", zap.String("r", fmt.Sprint(r)))
req, err := decodeUpdateTaskRequest(ctx, r)
if err != nil {
err = &influxdb.Error{
@ -603,7 +598,6 @@ func decodeUpdateTaskRequest(ctx context.Context, r *http.Request) (*updateTaskR
func (h *TaskHandler) handleDeleteTask(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.logger.Debug("task delete request", zap.String("r", fmt.Sprint(r)))
req, err := decodeDeleteTaskRequest(ctx, r)
if err != nil {
err = &influxdb.Error{

5
http/telegraf.go
View File

@ -236,7 +236,6 @@ func decodeGetTelegrafRequest(ctx context.Context, r *http.Request) (i platform.
func (h *TelegrafHandler) handleGetTelegrafs(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("telegrafs retrieve request", zap.String("r", fmt.Sprint(r)))
filter, err := decodeTelegrafConfigFilter(ctx, r)
if err != nil {
h.Logger.Debug("failed to decode request", zap.Error(err))
@ -258,7 +257,6 @@ func (h *TelegrafHandler) handleGetTelegrafs(w http.ResponseWriter, r *http.Requ
func (h *TelegrafHandler) handleGetTelegraf(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("telegraf retrieve request", zap.String("r", fmt.Sprint(r)))
id, err := decodeGetTelegrafRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -352,7 +350,6 @@ func decodePutTelegrafRequest(ctx context.Context, r *http.Request) (*platform.T
// handlePostTelegraf is the HTTP handler for the POST /api/v2/telegrafs route.
func (h *TelegrafHandler) handlePostTelegraf(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("telegraf create request", zap.String("r", fmt.Sprint(r)))
tc, err := decodePostTelegrafRequest(ctx, r)
if err != nil {
h.Logger.Debug("failed to decode request", zap.Error(err))
@ -380,7 +377,6 @@ func (h *TelegrafHandler) handlePostTelegraf(w http.ResponseWriter, r *http.Requ
// handlePutTelegraf is the HTTP handler for the POST /api/v2/telegrafs route.
func (h *TelegrafHandler) handlePutTelegraf(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("telegraf update request", zap.String("r", fmt.Sprint(r)))
tc, err := decodePutTelegrafRequest(ctx, r)
if err != nil {
h.Logger.Debug("failed to decode request", zap.Error(err))
@ -414,7 +410,6 @@ func (h *TelegrafHandler) handlePutTelegraf(w http.ResponseWriter, r *http.Reque
func (h *TelegrafHandler) handleDeleteTelegraf(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("telegraf delete request", zap.String("r", fmt.Sprint(r)))
i, err := decodeGetTelegrafRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)

5
http/user_resource_mapping_service.go
View File

@ -71,7 +71,6 @@ type MemberBackend struct {
func newPostMemberHandler(b MemberBackend) http.HandlerFunc {
return func(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
b.Logger.Debug("member/owner create request", zap.String("r", fmt.Sprint(r)))
req, err := decodePostMemberRequest(ctx, r)
if err != nil {
b.HandleHTTPError(ctx, err, w)
@ -146,8 +145,6 @@ func decodePostMemberRequest(ctx context.Context, r *http.Request) (*postMemberR
func newGetMembersHandler(b MemberBackend) http.HandlerFunc {
return func(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
b.Logger.Debug("members/owners retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetMembersRequest(ctx, r)
if err != nil {
b.HandleHTTPError(ctx, err, w)
@ -220,8 +217,6 @@ func decodeGetMembersRequest(ctx context.Context, r *http.Request) (*getMembersR
func newDeleteMemberHandler(b MemberBackend) http.HandlerFunc {
return func(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
b.Logger.Debug("member delete request", zap.String("r", fmt.Sprint(r)))
req, err := decodeDeleteMemberRequest(ctx, r)
if err != nil {
b.HandleHTTPError(ctx, err, w)

7
http/user_service.go
View File

@ -97,7 +97,6 @@ func (h *UserHandler) putPassword(ctx context.Context, w http.ResponseWriter, r
// handlePutPassword is the HTTP handler for the PUT /api/v2/users/:id/password
func (h *UserHandler) handlePutUserPassword(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("user update password request", zap.String("r", fmt.Sprint(r)))
_, err := h.putPassword(ctx, w, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -142,7 +141,6 @@ func decodePasswordResetRequest(ctx context.Context, r *http.Request) (*password
// handlePostUser is the HTTP handler for the POST /api/v2/users route.
func (h *UserHandler) handlePostUser(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("user create request", zap.String("r", fmt.Sprint(r)))
req, err := decodePostUserRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -206,7 +204,6 @@ func (h *UserHandler) handleGetMe(w http.ResponseWriter, r *http.Request) {
// handleGetUser is the HTTP handler for the GET /api/v2/users/:id route.
func (h *UserHandler) handleGetUser(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("user retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetUserRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -255,7 +252,6 @@ func decodeGetUserRequest(ctx context.Context, r *http.Request) (*getUserRequest
// handleDeleteUser is the HTTP handler for the DELETE /api/v2/users/:id route.
func (h *UserHandler) handleDeleteUser(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("user delete request", zap.String("r", fmt.Sprint(r)))
req, err := decodeDeleteUserRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -339,7 +335,6 @@ func newUserResponse(u *influxdb.User) *userResponse {
// handleGetUsers is the HTTP handler for the GET /api/v2/users route.
func (h *UserHandler) handleGetUsers(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("users retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetUsersRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -386,7 +381,6 @@ func decodeGetUsersRequest(ctx context.Context, r *http.Request) (*getUsersReque
// handlePatchUser is the HTTP handler for the PATCH /api/v2/users/:id route.
func (h *UserHandler) handlePatchUser(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("user update request", zap.String("r", fmt.Sprint(r)))
req, err := decodePatchUserRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -695,7 +689,6 @@ func userIDPath(id influxdb.ID) string {
// hanldeGetUserLog retrieves a user log by the users ID.
func (h *UserHandler) handleGetUserLog(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("user log retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetUserLogRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)

6
http/variable_service.go
View File

@ -143,7 +143,6 @@ func decodeGetVariablesRequest(ctx context.Context, r *http.Request) (*getVariab
func (h *VariableHandler) handleGetVariables(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("variables retrieve request", zap.String("r", fmt.Sprint(r)))
req, err := decodeGetVariablesRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -187,7 +186,6 @@ func requestVariableID(ctx context.Context) (platform.ID, error) {
func (h *VariableHandler) handleGetVariable(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("variable retrieve request", zap.String("r", fmt.Sprint(r)))
id, err := requestVariableID(ctx)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -244,7 +242,6 @@ func newVariableResponse(m *platform.Variable, labels []*platform.Label) variabl
func (h *VariableHandler) handlePostVariable(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("variable create request", zap.String("r", fmt.Sprint(r)))
req, err := decodePostVariableRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -298,7 +295,6 @@ func decodePostVariableRequest(ctx context.Context, r *http.Request) (*postVaria
func (h *VariableHandler) handlePatchVariable(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("variable update request", zap.String("r", fmt.Sprint(r)))
req, err := decodePatchVariableRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -366,7 +362,6 @@ func decodePatchVariableRequest(ctx context.Context, r *http.Request) (*patchVar
func (h *VariableHandler) handlePutVariable(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("variable replace request", zap.String("r", fmt.Sprint(r)))
req, err := decodePutVariableRequest(ctx, r)
if err != nil {
h.HandleHTTPError(ctx, err, w)
@ -427,7 +422,6 @@ func decodePutVariableRequest(ctx context.Context, r *http.Request) (*putVariabl
func (h *VariableHandler) handleDeleteVariable(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
h.Logger.Debug("variable delete request", zap.String("r", fmt.Sprint(r)))
id, err := requestVariableID(ctx)
if err != nil {
h.HandleHTTPError(ctx, err, w)