feat(doctor): add doctor client code and doctor api call

Author: smothiki

api/swagger-spec/swagger.yml

@@ -52,6 +52,24 @@ paths:
           description: unexpected error
           schema:
             $ref: "#/definitions/error"
+  /v3/doctor/{uuid}:
+    parameters:
+      - $ref: "#/parameters/UUID"
+    post:
+      operationId: publishDoctorInfo
+      summary: "publish doctor info to Workflow Manager API"
+      parameters:
+        - name: body
+          in: body
+          schema:
+            $ref: "#/definitions/doctorInfo"
+      responses:
+        200:
+          description: publish doctorInfo response
+        default:
+          description: unexpected error
+          schema:
+            $ref: "#/definitions/error"
   /v3/versions/{train}/{component}:
     get:
       operationId: getComponentByName
@@ -255,6 +273,12 @@ parameters:
     in: path
     description: The release version of the deis component, eg., 2.0.0-beta2
     required: true
+  UUID:
+    name: uuid
+    type: string
+    in: path
+    description: A universal Id to represent a sepcific request or report
+    required: true
 definitions:
   cluster:
     type: object
@@ -275,6 +299,13 @@ definitions:
         type: array
         items:
           $ref: "#/definitions/componentVersion"
+  doctorInfo:
+    type: object
+    required:
+      - cluster
+    properties:
+      cluster:
+        $ref: "#/definitions/cluster"
   componentVersion:
     type: object
     properties:

boot.go

@@ -54,7 +54,7 @@ func main() {
 	defer close(ch)
 
 	// Get a new router, with handler functions
-	r := handlers.RegisterRoutes(mux.NewRouter(), secretInterface, rcInterface, availableVersion)
+	r := handlers.RegisterRoutes(mux.NewRouter(), secretInterface, rcInterface, availableVersion, apiClient)
 	// Bind to a port and pass our router in
 	hostStr := fmt.Sprintf(":%s", config.Spec.Port)
 	log.Printf("Serving on %s", hostStr)

data/data.go

@@ -151,6 +151,23 @@ func getRCItems(rcLister rc.Lister) ([]api.ReplicationController, error) {
 	return rcs.Items, nil
 }
 
+// GetDoctorInfo collects doctor info and return DoctorInfo struct
+func GetDoctorInfo(
+	c InstalledData,
+	i ClusterID,
+	v AvailableComponentVersion,
+	secretGetterCreator KubeSecretGetterCreator,
+) (models.DoctorInfo, error) {
+	cluster, err := GetCluster(c, i, v, secretGetterCreator)
+	if err != nil {
+		return nil, err
+	}
+	doctor := models.DoctorInfo{
+		cluster: &cluster,
+	}
+	return doctor, nil
+}
+
 // newestVersion is a temporary static implementation of a real "return newest version" function
 func newestVersion(v1 string, v2 string) string {
 	return v1

handlers/handlers.go

@@ -7,12 +7,15 @@ import (
 
 	"github.com/arschles/kubeapp/api/rc"
 	"github.com/deis/workflow-manager/data"
+	"github.com/deis/workflow-manager/pkg/swagger/client/operations"
 	"github.com/gorilla/mux"
+	"github.com/satori/go.uuid"
 )
 
 const (
 	componentsRoute = "/components" // resource value for components route
 	idRoute         = "/id"         // resource value for ID route
+	doctorRoute     = "/doctor"
 )
 
 // RegisterRoutes attaches handler functions to routes
@@ -21,6 +24,7 @@ func RegisterRoutes(
 	secretGetterCreator data.KubeSecretGetterCreator,
 	rcLister rc.Lister,
 	availableVersions data.AvailableVersions,
+	apiClient *apiclient.WorkflowManager,
 ) *mux.Router {
 
 	clusterID := data.NewClusterIDFromPersistentStorage(secretGetterCreator)
@@ -31,6 +35,13 @@ func RegisterRoutes(
 		secretGetterCreator,
 	))
 	r.Handle(idRoute, IDHandler(clusterID))
+	r.Handle(doctorRoute, DoctorHandler(
+		data.NewInstalledDeisData(rcLister),
+		clusterID,
+		data.NewLatestReleasedComponent(secretGetterCreator, rcLister, availableVersions),
+		secretGetterCreator,
+		apiclient,
+	))
 	return r
 }
 
@@ -53,6 +64,28 @@ func ComponentsHandler(
 	})
 }
 
+// DoctorHandler route handler
+func DoctorHandler(
+	c data.InstalledData,
+	i data.ClusterID,
+	v data.AvailableComponentVersion,
+	secretGetterCreator data.KubeSecretGetterCreator,
+	apiClient *apiclient.WorkflowManager,
+) http.Handler {
+	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		doctor, err := data.GetDoctorInfo(c, i, v, secretGetterCreator)
+		if err != nil {
+			http.Error(w, err.Error(), http.StatusInternalServerError)
+			return
+		}
+		_, err = apiClient.Operations.PublishDoctorInfo(&operations.PublishDoctorInfoParams{Body: doctor, UUID: uuid.NewV4().String()})
+		if err != nil {
+			http.Error(w, err.Error(), http.StatusInternalServerError)
+			return
+		}
+	})
+}
+
 // IDHandler route handler
 func IDHandler(getter data.ClusterID) http.Handler {
 	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {

pkg/swagger/client/operations/operations_client.go

@@ -297,6 +297,31 @@ func (a *Client) PublishComponentRelease(params *PublishComponentReleaseParams)
 	return result.(*PublishComponentReleaseOK), nil
 }
 
+/*
+PublishDoctorInfo publishes doctor info to workflow manager API
+*/
+func (a *Client) PublishDoctorInfo(params *PublishDoctorInfoParams) (*PublishDoctorInfoOK, error) {
+	// TODO: Validate the params before sending
+	if params == nil {
+		params = NewPublishDoctorInfoParams()
+	}
+
+	result, err := a.transport.Submit(&client.Operation{
+		ID:                 "publishDoctorInfo",
+		Method:             "POST",
+		PathPattern:        "/v3/doctor/{uuid}",
+		ProducesMediaTypes: []string{"application/json"},
+		ConsumesMediaTypes: []string{"application/json"},
+		Schemes:            []string{"http"},
+		Params:             params,
+		Reader:             &PublishDoctorInfoReader{formats: a.formats},
+	})
+	if err != nil {
+		return nil, err
+	}
+	return result.(*PublishDoctorInfoOK), nil
+}
+
 // SetTransport changes the transport on the client
 func (a *Client) SetTransport(transport client.Transport) {
 	a.transport = transport

pkg/swagger/client/operations/publish_doctor_info_parameters.go

@@ -0,0 +1,70 @@
+package operations
+
+// This file was generated by the swagger tool.
+// Editing this file might prove futile when you re-run the swagger generate command
+
+import (
+	"github.com/go-swagger/go-swagger/client"
+	"github.com/go-swagger/go-swagger/errors"
+
+	strfmt "github.com/go-swagger/go-swagger/strfmt"
+
+	"github.com/deis/workflow-manager/pkg/swagger/models"
+)
+
+// NewPublishDoctorInfoParams creates a new PublishDoctorInfoParams object
+// with the default values initialized.
+func NewPublishDoctorInfoParams() *PublishDoctorInfoParams {
+	var ()
+	return &PublishDoctorInfoParams{}
+}
+
+/*PublishDoctorInfoParams contains all the parameters to send to the API endpoint
+for the publish doctor info operation typically these are written to a http.Request
+*/
+type PublishDoctorInfoParams struct {
+
+	/*Body*/
+	Body *models.DoctorInfo
+	/*UUID
+	  A universal Id to represent a sepcific request or report
+
+	*/
+	UUID string
+}
+
+// WithBody adds the body to the publish doctor info params
+func (o *PublishDoctorInfoParams) WithBody(body *models.DoctorInfo) *PublishDoctorInfoParams {
+	o.Body = body
+	return o
+}
+
+// WithUUID adds the uuid to the publish doctor info params
+func (o *PublishDoctorInfoParams) WithUUID(uuid string) *PublishDoctorInfoParams {
+	o.UUID = uuid
+	return o
+}
+
+// WriteToRequest writes these params to a swagger request
+func (o *PublishDoctorInfoParams) WriteToRequest(r client.Request, reg strfmt.Registry) error {
+
+	var res []error
+
+	if o.Body == nil {
+		o.Body = new(models.DoctorInfo)
+	}
+
+	if err := r.SetBodyParam(o.Body); err != nil {
+		return err
+	}
+
+	// path param uuid
+	if err := r.SetPathParam("uuid", o.UUID); err != nil {
+		return err
+	}
+
+	if len(res) > 0 {
+		return errors.CompositeValidationError(res...)
+	}
+	return nil
+}

pkg/swagger/client/operations/publish_doctor_info_responses.go

@@ -0,0 +1,100 @@
+package operations
+
+// This file was generated by the swagger tool.
+// Editing this file might prove futile when you re-run the swagger generate command
+
+import (
+	"fmt"
+	"io"
+
+	"github.com/go-swagger/go-swagger/client"
+	"github.com/go-swagger/go-swagger/httpkit"
+
+	strfmt "github.com/go-swagger/go-swagger/strfmt"
+
+	"github.com/deis/workflow-manager/pkg/swagger/models"
+)
+
+// PublishDoctorInfoReader is a Reader for the PublishDoctorInfo structure.
+type PublishDoctorInfoReader struct {
+	formats strfmt.Registry
+}
+
+// ReadResponse reads a server response into the recieved o.
+func (o *PublishDoctorInfoReader) ReadResponse(response client.Response, consumer httpkit.Consumer) (interface{}, error) {
+	switch response.Code() {
+
+	case 200:
+		result := NewPublishDoctorInfoOK()
+		if err := result.readResponse(response, consumer, o.formats); err != nil {
+			return nil, err
+		}
+		return result, nil
+
+	default:
+		result := NewPublishDoctorInfoDefault(response.Code())
+		if err := result.readResponse(response, consumer, o.formats); err != nil {
+			return nil, err
+		}
+		return nil, result
+	}
+}
+
+// NewPublishDoctorInfoOK creates a PublishDoctorInfoOK with default headers values
+func NewPublishDoctorInfoOK() *PublishDoctorInfoOK {
+	return &PublishDoctorInfoOK{}
+}
+
+/*PublishDoctorInfoOK handles this case with default header values.
+
+publish doctorInfo response
+*/
+type PublishDoctorInfoOK struct {
+}
+
+func (o *PublishDoctorInfoOK) Error() string {
+	return fmt.Sprintf("[POST /v3/doctor/{uuid}][%d] publishDoctorInfoOK ", 200)
+}
+
+func (o *PublishDoctorInfoOK) readResponse(response client.Response, consumer httpkit.Consumer, formats strfmt.Registry) error {
+
+	return nil
+}
+
+// NewPublishDoctorInfoDefault creates a PublishDoctorInfoDefault with default headers values
+func NewPublishDoctorInfoDefault(code int) *PublishDoctorInfoDefault {
+	return &PublishDoctorInfoDefault{
+		_statusCode: code,
+	}
+}
+
+/*PublishDoctorInfoDefault handles this case with default header values.
+
+unexpected error
+*/
+type PublishDoctorInfoDefault struct {
+	_statusCode int
+
+	Payload *models.Error
+}
+
+// Code gets the status code for the publish doctor info default response
+func (o *PublishDoctorInfoDefault) Code() int {
+	return o._statusCode
+}
+
+func (o *PublishDoctorInfoDefault) Error() string {
+	return fmt.Sprintf("[POST /v3/doctor/{uuid}][%d] publishDoctorInfo default  %+v", o._statusCode, o.Payload)
+}
+
+func (o *PublishDoctorInfoDefault) readResponse(response client.Response, consumer httpkit.Consumer, formats strfmt.Registry) error {
+
+	o.Payload = new(models.Error)
+
+	// response payload
+	if err := consumer.Consume(response.Body(), o.Payload); err != nil && err != io.EOF {
+		return err
+	}
+
+	return nil
+}

pkg/swagger/models/data.go

@@ -4,11 +4,10 @@ package models
 // Editing this file might prove futile when you re-run the swagger generate command
 
 import (
-	strfmt "github.com/go-swagger/go-swagger/strfmt"
-	"github.com/go-swagger/go-swagger/swag"
-
 	"github.com/go-swagger/go-swagger/errors"
 	"github.com/go-swagger/go-swagger/httpkit/validate"
+	strfmt "github.com/go-swagger/go-swagger/strfmt"
+	"github.com/go-swagger/go-swagger/swag"
 )
 
 /*Data data