HYPERFLEET-978 - feat: Include routes for PUT status updates (1/2)

Author: ma-hill

cmd/hyperfleet-api/server/api_server.go

@@ -80,6 +80,7 @@ func NewAPIServer(tracingEnabled bool) Server {
 			http.MethodGet,
 			http.MethodPatch,
 			http.MethodPost,
+			http.MethodPut,
 		}),
 		gorillahandlers.AllowedHeaders([]string{
 			"Authorization",

openapi/openapi.yaml

@@ -1,7 +1,7 @@
 openapi: 3.0.0
 info:
   title: HyperFleet API
-  version: 1.0.8
+  version: 1.0.9
   contact:
     name: HyperFleet Team
   license:
@@ -494,6 +494,7 @@ paths:
         - name: nodepool_id
           in: path
           required: true
+          description: Nodepool ID
           schema:
             type: string
       responses:
@@ -515,6 +516,45 @@ paths:
           application/json:
             schema:
               $ref: '#/components/schemas/AdapterStatusCreateRequest'
+      security:
+        - BearerAuth: []
+    put:
+      operationId: putNodePoolStatuses
+      summary: Adapter creates or updates resource nodepool status
+      parameters:
+        - name: cluster_id
+          in: path
+          required: true
+          description: Cluster ID
+          schema:
+            type: string
+        - name: nodepool_id
+          in: path
+          required: true
+          description: Nodepool ID
+          schema:
+            type: string
+      responses:
+        '201':
+          description: The request has succeeded and a new resource has been created as a result.
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/AdapterStatus'
+        '400':
+          description: The server could not understand the request due to invalid syntax.
+        '404':
+          description: The server cannot find the requested resource.
+        '409':
+          description: The request conflicts with the current state of the server.
+      requestBody:
+        required: true
+        content:
+          application/json:
+            schema:
+              $ref: '#/components/schemas/AdapterStatusCreateRequest'
+      security:
+        - BearerAuth: []
     get:
       operationId: getNodePoolsStatuses
       summary: List all adapter statuses for nodepools
@@ -589,6 +629,37 @@ paths:
               $ref: '#/components/schemas/AdapterStatusCreateRequest'
       security:
         - BearerAuth: []
+    put:
+      operationId: putClusterStatuses
+      summary: Adapter creates or updates resource cluster status
+      parameters:
+        - name: cluster_id
+          in: path
+          required: true
+          description: Cluster ID
+          schema:
+            type: string
+      responses:
+        '201':
+          description: The request has succeeded and a new resource has been created as a result.
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/AdapterStatus'
+        '400':
+          description: The server could not understand the request due to invalid syntax.
+        '404':
+          description: The server cannot find the requested resource.
+        '409':
+          description: The request conflicts with the current state of the server.
+      requestBody:
+        required: true
+        content:
+          application/json:
+            schema:
+              $ref: '#/components/schemas/AdapterStatusCreateRequest'
+      security:
+        - BearerAuth: []
     get:
       operationId: getClusterStatuses
       summary: List all adapter statuses for cluster

plugins/clusters/plugin.go

@@ -66,6 +66,7 @@ func init() {
 		clusterStatusHandler := handlers.NewClusterStatusHandler(adapterStatus.Service(envServices), Service(envServices))
 		clustersRouter.HandleFunc("/{id}/statuses", clusterStatusHandler.List).Methods(http.MethodGet)
 		clustersRouter.HandleFunc("/{id}/statuses", clusterStatusHandler.Create).Methods(http.MethodPost)
+		clustersRouter.HandleFunc("/{id}/statuses", clusterStatusHandler.Create).Methods(http.MethodPut)
 
 		// Nested resource: cluster nodepools
 		clusterNodePoolsHandler := handlers.NewClusterNodePoolsHandler(
@@ -83,6 +84,7 @@ func init() {
 		nodepoolStatusHandler := handlers.NewNodePoolStatusHandler(adapterStatus.Service(envServices), nodePools.Service(envServices))
 		clustersRouter.HandleFunc("/{id}/nodepools/{nodepool_id}/statuses", nodepoolStatusHandler.List).Methods(http.MethodGet)
 		clustersRouter.HandleFunc("/{id}/nodepools/{nodepool_id}/statuses", nodepoolStatusHandler.Create).Methods(http.MethodPost)
+		clustersRouter.HandleFunc("/{id}/nodepools/{nodepool_id}/statuses", nodepoolStatusHandler.Create).Methods(http.MethodPut)
 
 		clustersRouter.Use(authMiddleware.AuthenticateAccountJWT)
 		clustersRouter.Use(authzMiddleware.AuthorizeAPI)