X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=pkg%2Frestapi%2Foperations%2Fcommon%2Fsubscribe.go;fp=pkg%2Frestapi%2Foperations%2Fcommon%2Fsubscribe.go;h=49bd6176aaed3316bed394558ce8d38b178dac81;hb=3602bf801fef17e317cb35a4c710118ec80908b9;hp=0000000000000000000000000000000000000000;hpb=060448c051013852d463bc13bfc5f0aa3696ac9c;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/restapi/operations/common/subscribe.go b/pkg/restapi/operations/common/subscribe.go new file mode 100644 index 0000000..49bd617 --- /dev/null +++ b/pkg/restapi/operations/common/subscribe.go @@ -0,0 +1,58 @@ +// Code generated by go-swagger; DO NOT EDIT. + +package common + +// This file was generated by the swagger tool. +// Editing this file might prove futile when you re-run the generate command + +import ( + "net/http" + + middleware "github.com/go-openapi/runtime/middleware" +) + +// SubscribeHandlerFunc turns a function with the right signature into a subscribe handler +type SubscribeHandlerFunc func(SubscribeParams) middleware.Responder + +// Handle executing the request and returning a response +func (fn SubscribeHandlerFunc) Handle(params SubscribeParams) middleware.Responder { + return fn(params) +} + +// SubscribeHandler interface for that can handle valid subscribe params +type SubscribeHandler interface { + Handle(SubscribeParams) middleware.Responder +} + +// NewSubscribe creates a new http.Handler for the subscribe operation +func NewSubscribe(ctx *middleware.Context, handler SubscribeHandler) *Subscribe { + return &Subscribe{Context: ctx, Handler: handler} +} + +/*Subscribe swagger:route POST /subscriptions common subscribe + +Subscribe a list of X2AP event triggers to receive messages sent by RAN + +*/ +type Subscribe struct { + Context *middleware.Context + Handler SubscribeHandler +} + +func (o *Subscribe) ServeHTTP(rw http.ResponseWriter, r *http.Request) { + route, rCtx, _ := o.Context.RouteInfo(r) + if rCtx != nil { + r = rCtx + } + var Params = NewSubscribeParams() + + if err := o.Context.BindValidRequest(r, route, &Params); err != nil { // bind params + o.Context.Respond(rw, r, route.Produces, route, err) + return + } + + res := o.Handler.Handle(Params) // actually handle the request + + o.Context.Respond(rw, r, route.Produces, route, res) + +}