multi-source: Implement logic on planner

This commit implements the multi-source model in the planner.

Signed-off-by: Cosmin Tupangiu <[email protected]>

api/v1alpha1/agent/openapi.yaml

@@ -53,6 +53,12 @@ paths:
             application/json:
               schema:
                 $ref: '../openapi.yaml#/components/schemas/Error'
+        "500":
+          description: Internal Server Error
+          content:
+            application/json:
+              schema:
+                $ref: '../openapi.yaml#/components/schemas/Error'
   /api/v1/agents/{id}/status:
     put:
       tags:
@@ -77,6 +83,12 @@ paths:
           description: OK
         "201":
           description: OK
+        "400":
+          description: Bad Request
+          content:
+            application/json:
+              schema:
+                $ref: '../openapi.yaml#/components/schemas/Error'
         "401":
           description: Unauthorized
           content:
@@ -89,6 +101,12 @@ paths:
             application/json:
               schema:
                 $ref: '../openapi.yaml#/components/schemas/Error'
+        "500":
+          description: Internal Server Error
+          content:
+            application/json:
+              schema:
+                $ref: '../openapi.yaml#/components/schemas/Error'
   /health:
     get:
       tags:
@@ -104,18 +122,15 @@ components:
     SourceStatusUpdate:
       type: object
       properties:
-        status:
-          type: string
-        statusInfo:
+        agentId:
           type: string
+          format: uuid
         inventory:
           $ref: '../openapi.yaml#/components/schemas/Inventory'
-        credentialUrl:
-          type: string
       required:
-        - status
-        - statusInfo
-        - credentialUrl
+        - inventory
+        - agentId
+
     AgentStatusUpdate:
       type: object
       properties:

api/v1alpha1/common.go

@@ -1,22 +1,5 @@
 package v1alpha1
 
-func StringToSourceStatus(s string) SourceStatus {
-	switch s {
-	case string(SourceStatusError):
-		return SourceStatusError
-	case string(SourceStatusGatheringInitialInventory):
-		return SourceStatusGatheringInitialInventory
-	case string(SourceStatusUpToDate):
-		return SourceStatusUpToDate
-	case string(SourceStatusWaitingForCredentials):
-		return SourceStatusWaitingForCredentials
-	case string(SourceStatusNotConnected):
-		return SourceStatusNotConnected
-	default:
-		return SourceStatusNotConnected
-	}
-}
-
 func StringToAgentStatus(s string) AgentStatus {
 	switch s {
 	case string(AgentStatusError):

api/v1alpha1/openapi.yaml

@@ -27,36 +27,6 @@ paths:
             application/json:
               schema:
                 $ref: '#/components/schemas/Error'
-    post:
-      tags:
-        - source
-      description: create a source
-      operationId: createSource
-      requestBody:
-        content:
-          application/json:
-            schema:
-              $ref: '#/components/schemas/SourceCreate'
-        required: true
-      responses:
-        "201":
-          description: Created
-          content:
-            application/json:
-              schema:
-                $ref: '#/components/schemas/Source'
-        "400":
-          description: Bad Request
-          content:
-            application/json:
-              schema:
-                $ref: '#/components/schemas/Error'
-        "401":
-          description: Unauthorized
-          content:
-            application/json:
-              schema:
-                $ref: '#/components/schemas/Error'
     delete:
       tags:
         - source
@@ -243,6 +213,58 @@ paths:
             application/json:
               schema:
                 $ref: '#/components/schemas/Error'
+        "500":
+          description: Internal Server Error
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/Error'
+  /api/v1/agents/{id}:
+    delete:
+      tags:
+        - agent
+      description: delete an agent
+      operationId: deleteAgent
+      parameters:
+        - name: id
+          in: path
+          description: ID of the agent
+          required: true
+          schema:
+            type: string
+            format: uuid
+      responses:
+        "200":
+          description: OK
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/Agent"
+        "400":
+          description: Bad Request
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/Error'
+        "401":
+          description: Unauthorized
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/Error'
+        "404":
+          description: NotFound
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/Error'
+        "500":
+          description: Internal Server Error
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/Error'
+
   /health:
     get:
       tags:
@@ -280,6 +302,10 @@ components:
           format: date-time
         sshKey:
           type: string
+        agents:
+          type: array
+          items:
+            $ref: '#/components/schemas/SourceAgentItem'
       required:
         - id
         - name
@@ -303,6 +329,18 @@ components:
       items:
         $ref: '#/components/schemas/Source'
 
+    SourceAgentItem:
+      type: object
+      properties:
+        id:
+          type: string
+          format: uuid
+        associated:
+          type: boolean
+      required:
+        - id
+        - associated
+
     Error:
       properties:
         message: