X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fclientapi%2Fcommon%2Fcommon_client.go;fp=pkg%2Fclientapi%2Fcommon%2Fcommon_client.go;h=e3642d48585eac7c1456c9a4ed7b905ebe3d1880;hb=c79bd0e1a4fe855b06c8f8131f162d0ee4a5f9f5;hp=de4a4d7985e74e57a8882479e621ac639218887c;hpb=9ea6c7860300c299b9fe68caaf8aff61b3ec71d2;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/clientapi/common/common_client.go b/pkg/clientapi/common/common_client.go index de4a4d7..e3642d4 100644 --- a/pkg/clientapi/common/common_client.go +++ b/pkg/clientapi/common/common_client.go @@ -6,13 +6,14 @@ package common // Editing this file might prove futile when you re-run the swagger generate command import ( - "github.com/go-openapi/runtime" + "fmt" - strfmt "github.com/go-openapi/strfmt" + "github.com/go-openapi/runtime" + "github.com/go-openapi/strfmt" ) // New creates a new common API client. -func New(transport runtime.ClientTransport, formats strfmt.Registry) *Client { +func New(transport runtime.ClientTransport, formats strfmt.Registry) ClientService { return &Client{transport: transport, formats: formats} } @@ -24,8 +25,19 @@ type Client struct { formats strfmt.Registry } +// ClientService is the interface for Client methods +type ClientService interface { + Subscribe(params *SubscribeParams) (*SubscribeCreated, error) + + Unsubscribe(params *UnsubscribeParams) (*UnsubscribeNoContent, error) + + GetAllSubscriptions(params *GetAllSubscriptionsParams) (*GetAllSubscriptionsOK, error) + + SetTransport(transport runtime.ClientTransport) +} + /* -Subscribe subscribes a list of x2 a p event triggers to receive messages sent by r a n + Subscribe subscribes a list of x2 a p event triggers to receive messages sent by r a n */ func (a *Client) Subscribe(params *SubscribeParams) (*SubscribeCreated, error) { // TODO: Validate the params before sending @@ -48,12 +60,18 @@ func (a *Client) Subscribe(params *SubscribeParams) (*SubscribeCreated, error) { if err != nil { return nil, err } - return result.(*SubscribeCreated), nil - + success, ok := result.(*SubscribeCreated) + if ok { + return success, nil + } + // unexpected success response + // safeguard: normally, absent a default response, unknown success responses return an error above: so this is a codegen issue + msg := fmt.Sprintf("unexpected success response for Subscribe: API contract not enforced by server. Client expected to get an error, but got: %T", result) + panic(msg) } /* -Unsubscribe unsubscribes x2 a p events from subscription manager + Unsubscribe unsubscribes x2 a p events from subscription manager */ func (a *Client) Unsubscribe(params *UnsubscribeParams) (*UnsubscribeNoContent, error) { // TODO: Validate the params before sending @@ -76,12 +94,18 @@ func (a *Client) Unsubscribe(params *UnsubscribeParams) (*UnsubscribeNoContent, if err != nil { return nil, err } - return result.(*UnsubscribeNoContent), nil - + success, ok := result.(*UnsubscribeNoContent) + if ok { + return success, nil + } + // unexpected success response + // safeguard: normally, absent a default response, unknown success responses return an error above: so this is a codegen issue + msg := fmt.Sprintf("unexpected success response for Unsubscribe: API contract not enforced by server. Client expected to get an error, but got: %T", result) + panic(msg) } /* -GetAllSubscriptions returns list of subscriptions + GetAllSubscriptions returns list of subscriptions */ func (a *Client) GetAllSubscriptions(params *GetAllSubscriptionsParams) (*GetAllSubscriptionsOK, error) { // TODO: Validate the params before sending @@ -94,7 +118,7 @@ func (a *Client) GetAllSubscriptions(params *GetAllSubscriptionsParams) (*GetAll Method: "GET", PathPattern: "/subscriptions", ProducesMediaTypes: []string{"application/json"}, - ConsumesMediaTypes: []string{""}, + ConsumesMediaTypes: []string{"application/json"}, Schemes: []string{"http"}, Params: params, Reader: &GetAllSubscriptionsReader{formats: a.formats}, @@ -104,8 +128,14 @@ func (a *Client) GetAllSubscriptions(params *GetAllSubscriptionsParams) (*GetAll if err != nil { return nil, err } - return result.(*GetAllSubscriptionsOK), nil - + success, ok := result.(*GetAllSubscriptionsOK) + if ok { + return success, nil + } + // unexpected success response + // safeguard: normally, absent a default response, unknown success responses return an error above: so this is a codegen issue + msg := fmt.Sprintf("unexpected success response for getAllSubscriptions: API contract not enforced by server. Client expected to get an error, but got: %T", result) + panic(msg) } // SetTransport changes the transport on the client