wip

internal/dinosaur/pkg/api/admin/private/api/openapi.yaml

@@ -337,6 +337,13 @@ paths:
         schema:
           type: string
         style: form
+      - explode: true
+        in: query
+        name: reason
+        required: true
+        schema:
+          type: string
+        style: form
       responses:
         "200":
           content:

internal/dinosaur/pkg/handlers/admin_dinosaur.go

@@ -7,13 +7,15 @@ import (
 	"net/http"
 	"time"
 
+	"github.com/golang/glog"
 	"github.com/gorilla/mux"
 	"github.com/stackrox/acs-fleet-manager/internal/dinosaur/pkg/api/admin/private"
 	"github.com/stackrox/acs-fleet-manager/internal/dinosaur/pkg/api/dbapi"
 	"github.com/stackrox/acs-fleet-manager/internal/dinosaur/pkg/api/public"
 	"github.com/stackrox/acs-fleet-manager/internal/dinosaur/pkg/config"
 	"github.com/stackrox/acs-fleet-manager/internal/dinosaur/pkg/presenters"
 	"github.com/stackrox/acs-fleet-manager/internal/dinosaur/pkg/services"
+	"github.com/stackrox/acs-fleet-manager/pkg/api"
 	"github.com/stackrox/acs-fleet-manager/pkg/errors"
 	"github.com/stackrox/acs-fleet-manager/pkg/handlers"
 	coreServices "github.com/stackrox/acs-fleet-manager/pkg/services"
@@ -238,16 +240,30 @@ func (h adminCentralHandler) RotateSecrets(w http.ResponseWriter, r *http.Reques
 func (h adminCentralHandler) SetExpiredAt(w http.ResponseWriter, r *http.Request) {
 	cfg := &handlers.HandlerConfig{
 		Action: func() (i interface{}, serviceError *errors.ServiceError) {
+			reason := r.PostFormValue("reason")
+			if reason == "" {
+				return nil, errors.New(errors.ErrorBadRequest, "No reason provided")
+			}
+
 			id := mux.Vars(r)["id"]
-			ts := r.PostForm.Get("timestamp")
-			central := &dbapi.CentralRequest{ClusterID: id}
-			expired_at, err := time.Parse(time.RFC3339, ts)
-			if err != nil {
-				return nil, errors.NewWithCause(errors.ErrorBadRequest, err, "Cannot parse timestamp: %s", err.Error())
+			ts := r.PostFormValue("timestamp")
+			expired_at := time.Now()
+			if ts != "" {
+				var err error
+				expired_at, err = time.Parse(time.RFC3339, ts)
+				if err != nil {
+					return nil, errors.NewWithCause(errors.ErrorBadRequest, err, "Cannot parse timestamp: %s", err.Error())
+				}
 			}
-			return nil, h.service.Updates(central, map[string]interface{}{
-				"expired_at": expired_at.UTC().Format(time.RFC3339),
+			glog.Warningf("Setting expired_at to %q for central %q: %s", ts, id, reason)
+			central := &dbapi.CentralRequest{Meta: api.Meta{ID: id}}
+			svcErr := h.service.Updates(central, map[string]interface{}{
+				"expired_at": &expired_at,
 			})
+			if svcErr != nil {
+				glog.Warningf("error: ", svcErr)
+			}
+			return nil, svcErr
 		},
 	}
 	handlers.Handle(w, r, cfg, http.StatusOK)

openapi/fleet-manager-private-admin.yaml

@@ -218,6 +218,11 @@ paths:
           schema:
             type: string
           required: false
+        - in: query
+          name: reason
+          schema:
+            type: string
+          required: true
       security:
         - Bearer: [ ]
       operationId: updateCentralExpiredAtById