Add optional subscription ID

[ric-plt/xapp-frame.git] / pkg / clientapi / common / common_client.go

diff --git a/pkg/clientapi/common/common_client.go b/pkg/clientapi/common/common_client.go
index de4a4d7..e3642d4 100644 (file)
--- 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