capifcore/internal/eventsapi/eventsapi-server.gen.go

   1 // Package eventsapi provides primitives to interact with the openapi HTTP API.
   2 //
   3 // Code generated by github.com/deepmap/oapi-codegen version v1.10.1 DO NOT EDIT.
   4 package eventsapi
   5
   6 import (
   7         "bytes"
   8         "compress/gzip"
   9         "encoding/base64"
  10         "fmt"
  11         "net/http"
  12         "net/url"
  13         "path"
  14         "strings"
  15
  16         "github.com/deepmap/oapi-codegen/pkg/runtime"
  17         "github.com/getkin/kin-openapi/openapi3"
  18         "github.com/labstack/echo/v4"
  19 )
  20
  21 // ServerInterface represents all server handlers.
  22 type ServerInterface interface {
  23
  24         // (POST /{subscriberId}/subscriptions)
  25         PostSubscriberIdSubscriptions(ctx echo.Context, subscriberId string) error
  26
  27         // (DELETE /{subscriberId}/subscriptions/{subscriptionId})
  28         DeleteSubscriberIdSubscriptionsSubscriptionId(ctx echo.Context, subscriberId string, subscriptionId string) error
  29 }
  30
  31 // ServerInterfaceWrapper converts echo contexts to parameters.
  32 type ServerInterfaceWrapper struct {
  33         Handler ServerInterface
  34 }
  35
  36 // PostSubscriberIdSubscriptions converts echo context to params.
  37 func (w *ServerInterfaceWrapper) PostSubscriberIdSubscriptions(ctx echo.Context) error {
  38         var err error
  39         // ------------- Path parameter "subscriberId" -------------
  40         var subscriberId string
  41
  42         err = runtime.BindStyledParameterWithLocation("simple", false, "subscriberId", runtime.ParamLocationPath, ctx.Param("subscriberId"), &subscriberId)
  43         if err != nil {
  44                 return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter subscriberId: %s", err))
  45         }
  46
  47         // Invoke the callback with all the unmarshalled arguments
  48         err = w.Handler.PostSubscriberIdSubscriptions(ctx, subscriberId)
  49         return err
  50 }
  51
  52 // DeleteSubscriberIdSubscriptionsSubscriptionId converts echo context to params.
  53 func (w *ServerInterfaceWrapper) DeleteSubscriberIdSubscriptionsSubscriptionId(ctx echo.Context) error {
  54         var err error
  55         // ------------- Path parameter "subscriberId" -------------
  56         var subscriberId string
  57
  58         err = runtime.BindStyledParameterWithLocation("simple", false, "subscriberId", runtime.ParamLocationPath, ctx.Param("subscriberId"), &subscriberId)
  59         if err != nil {
  60                 return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter subscriberId: %s", err))
  61         }
  62
  63         // ------------- Path parameter "subscriptionId" -------------
  64         var subscriptionId string
  65
  66         err = runtime.BindStyledParameterWithLocation("simple", false, "subscriptionId", runtime.ParamLocationPath, ctx.Param("subscriptionId"), &subscriptionId)
  67         if err != nil {
  68                 return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter subscriptionId: %s", err))
  69         }
  70
  71         // Invoke the callback with all the unmarshalled arguments
  72         err = w.Handler.DeleteSubscriberIdSubscriptionsSubscriptionId(ctx, subscriberId, subscriptionId)
  73         return err
  74 }
  75
  76 // This is a simple interface which specifies echo.Route addition functions which
  77 // are present on both echo.Echo and echo.Group, since we want to allow using
  78 // either of them for path registration
  79 type EchoRouter interface {
  80         CONNECT(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
  81         DELETE(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
  82         GET(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
  83         HEAD(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
  84         OPTIONS(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
  85         PATCH(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
  86         POST(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
  87         PUT(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
  88         TRACE(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
  89 }
  90
  91 // RegisterHandlers adds each server route to the EchoRouter.
  92 func RegisterHandlers(router EchoRouter, si ServerInterface) {
  93         RegisterHandlersWithBaseURL(router, si, "")
  94 }
  95
  96 // Registers handlers, and prepends BaseURL to the paths, so that the paths
  97 // can be served under a prefix.
  98 func RegisterHandlersWithBaseURL(router EchoRouter, si ServerInterface, baseURL string) {
  99
 100         wrapper := ServerInterfaceWrapper{
 101                 Handler: si,
 102         }
 103
 104         router.POST(baseURL+"/:subscriberId/subscriptions", wrapper.PostSubscriberIdSubscriptions)
 105         router.DELETE(baseURL+"/:subscriberId/subscriptions/:subscriptionId", wrapper.DeleteSubscriberIdSubscriptionsSubscriptionId)
 106
 107 }
 108
 109 // Base64 encoded, gzipped, json marshaled Swagger object
 110 var swaggerSpec = []string{
 111
 112         "H4sIAAAAAAAC/+xZ4Y7iOPJ/Fcv7/zAjZaFhpv+zzbcM0DPRoQYRek57sy1kkgp4J9hZ26GbayHdO9xT",
 113         "3Gvco9yTnGyHEEICdHMrre5mtdptOa5fVbmqflU2zzjgy4QzYErizjOWwQKWxPzpBgFI2eVMCR6PeEyD",
 114         "9YBK1X9S+iuJ42GEO1+f8f8JiHAHT/z2TbvdnnbdkXc7tcLTTHpqxafuyGusyTL+obnT2sxUNmv04Y3z",
 115         "jBPBExCKgrGMJNQL9R9qnQDuYKkEZXO82TjbFT77FQKFNw8ODkEGgiaKcoY7eAyJAKn1IrUABE8KmKSc",
 116         "oYgLRIwFKLAmoETbQEE2sIMF/JZSASHufM3UP2wcbHztr4CZI9nXNOJS0lkMaEXiFCQiAjq/sB+R3x9/",
 117         "8bp9fRZT94vrDdyPg34HGRSJBMREQYgUN/aRFaExmdGYqjXiEZIgVjQA5I48iUikQJht+8sCUJLOYioX",
 118         "EDbKKu/vTipN2WvVpuyI4lHPnVTqDBaEzQFRVgRElEVcLIk+TYOlMby7L8M/9cfT4d3HoTvu9XtVcFZ4",
 119         "xb+BQJzNOBGh/WCidYh1e3suWBRt0SLBlwW8op8at+tOvOHd1L/vdvu+X3fOMjX5FqWxUREYX8vHfQz/",
 120         "1vUG9+PaOEaExhCewnaNjdPu8G4yHg6mo+HA6/58JFomQ5KQKDA1Y7K0om7WB96eqfg1+XmBEYVMcO8n",
 121         "n4dj7y/2cMd9vdqrM0JA8VSNAalacEH/mi8WckdqsczCk3bYsz+ZjongEY23wajI8MlwNBwMP/08/ez1",
 122         "vLtP0+64X4erbQoEZKaLbYAzz7RWxRMe8/kaLWhI2bxYntttryOnKktffPb/YQv3eQw7GFi61NRfSd7Y",
 123         "wTUMW/5iAosdXMll5fWcl0oohwRTvyFjCA19pMzrP++5crJWSnuyPM5Wa7Kx5usW8cEpN/li1+2BIjQ+",
 124         "7L2FLk9sUSDQ+1FoBExHL40UQdBVQo8dZubo5GPNS0YVPRptHDsfyEOrvBCYohE1raSceNjBVMFSVow1",
 125         "Dl5S5tmPrfw8iBBkvVVnKeGI1h1PFijkIp0TnvDPNIRTZzXJyvKzqUotvGtIAz6vsnjXsGI+N8HKzawc",
 126         "Ngd8PqdsbpM/Fz4+bXpFI076mwXKHXm9nakVphe+VsQYEbkjPzRbZ/G4Pe3hyEpNfQt23DW/ytgTLh6O",
 127         "zsU6u6WxAvGCOouMQEWZQXRmaejjgqeES03lUcoCs/OiIvmvrsmqAJrY3XHtn0314xFkiLKQrmiYkjiL",
 128         "pkFArABxGFPYZ+JjXHDA3BvHisvzJU05prPcCXsTPBnVggQSIHkqAtDzxOOCBguzpegloruh419/+3t2",
 129         "GrkczfHNdHB4DS1eF0vG5h4/1EXMLwi8MmJ+lbs1obPFXZGlGcgMwr2qlhVsdSJmGX+cqhqjZQy/FYC7",
 130         "fLnkrEcUqee7MSRcKMrm3m7i28+s4369wqGTrhSTqQdSUZYXYIHgW5rgz/DwXlCcZRVINQF5oqp9UGZW",
 131         "FinoNpM7LPRqhmJy3uZMwAXkHKu3SGAhIkjpbXtlQSQKIaLMXCv1v0FMUgnoQ+P/GyjTGpFYgr5E8CVV",
 132         "uoC4WoB4pBIaxWqZcR4DYbacEx1BCG+BqFRAuQ9ef2iddUz+Ac7GwY8wkzz4Zg6sy1lE568Mwp8Pgcql",
 133         "nqdTXfirar40IB0reHP54anOdSTSGGT5kkOK7aui/dY8nDk4Qx1rUL3h+DgytrunuuCOzyLjHe7pBnb4",
 134         "yFYy7PD4tBg8KRCMxD0eVFT7u0+jEZr4qH3TaLfb6EvrQ+O6cYVsxE3nvRVkCY9cfDMPGmb/HRdqMeMp",
 135         "C82lEDs4FTHu4IVSiew0m4+Pj4138yRpcDFvRipp+gkEsklEsKAraLZvphIEBdm0Wpt27I34oXnaAK3W",
 136         "Muxem1oSRuawBKYaCP3C/vkP1L5qtx1r4VDMCcseG0iMRkQoBkKiN+7Y++ggd+L5Dup2fddB/YnvOWji",
 137         "98z/Jq7+T/etwXTjGAk6X5g7tk6d7YVXURXrc7bxttfwqR2JViCktb3VaDeutGs8AUYSqk+7cdW40nlH",
 138         "1MIEo/ksc/bxwk2z6KHZkHB73wpIHM9I8M0sHqHP54y/GjMern9o1uzcFKEziY88XBtNnKnsyZYkSZwJ",
 139         "N3+VVoFN3VO94HC22uynsCZfsyATzqStqvbV+8MMuOOoay1CbwpPgkXH3upDfnf14YXMletualkD8dMF",
 140         "ED9piPdXV6+G0LIGonUBRMtCvLsA4p2FeH8BxHsD0brAkZZ1pHWBIy3rSOv6AohrA9G+eT1E+0ZDXF+Q",
 141         "F9c2L64vCOq1DWoIEUlj9WqYrfzG/FP+8agrgCjQd10Gj+eM3roD6/5LthcVPOJS+QVC9PfoUPOmbkZ2",
 142         "Hv96+lqzg9IzrN6jiVcPIGRpGnxBFS6zk1OguvIV5sH5/Vhz735zFmu2fm8DquIcojf+jo53r+PRXpd+",
 143         "ix28ABJmN6gBr5vJNccTyuwQdz/2tiFk8BivLTyE+V3NQSQIuDAP2dvfLpRIAz3WomeS0DHnatMMSEKj",
 144         "H+3Y2Vy1jjbb/GN2E92YRn9+Smy+s/939v+fYX8Hv6yYbMHHoKDqVVivn/tec9g0rHxt2/DLD0x/lCbi",
 145         "HNe9fxzZT3173HzMnJ27L+xqp+bxyQJqwrRvHVoSFSwMQZceGL0QUYlsNpj71Pfp/Y/I399pr2Lotb91",
 146         "banDvnrUzhvYwSsiKJnF+fuS3mdrKjMqfzOBJ7JMYmgEfInLE1cmWHpfzB8XrzVd7D/kaGsfNv8OAAD/",
 147         "//oDEyW/JgAA",
 148 }
 149
 150 // GetSwagger returns the content of the embedded swagger specification file
 151 // or error if failed to decode
 152 func decodeSpec() ([]byte, error) {
 153         zipped, err := base64.StdEncoding.DecodeString(strings.Join(swaggerSpec, ""))
 154         if err != nil {
 155                 return nil, fmt.Errorf("error base64 decoding spec: %s", err)
 156         }
 157         zr, err := gzip.NewReader(bytes.NewReader(zipped))
 158         if err != nil {
 159                 return nil, fmt.Errorf("error decompressing spec: %s", err)
 160         }
 161         var buf bytes.Buffer
 162         _, err = buf.ReadFrom(zr)
 163         if err != nil {
 164                 return nil, fmt.Errorf("error decompressing spec: %s", err)
 165         }
 166
 167         return buf.Bytes(), nil
 168 }
 169
 170 var rawSpec = decodeSpecCached()
 171
 172 // a naive cached of a decoded swagger spec
 173 func decodeSpecCached() func() ([]byte, error) {
 174         data, err := decodeSpec()
 175         return func() ([]byte, error) {
 176                 return data, err
 177         }
 178 }
 179
 180 // Constructs a synthetic filesystem for resolving external references when loading openapi specifications.
 181 func PathToRawSpec(pathToFile string) map[string]func() ([]byte, error) {
 182         var res = make(map[string]func() ([]byte, error))
 183         if len(pathToFile) > 0 {
 184                 res[pathToFile] = rawSpec
 185         }
 186
 187         return res
 188 }
 189
 190 // GetSwagger returns the Swagger specification corresponding to the generated code
 191 // in this file. The external references of Swagger specification are resolved.
 192 // The logic of resolving external references is tightly connected to "import-mapping" feature.
 193 // Externally referenced files must be embedded in the corresponding golang packages.
 194 // Urls can be supported but this task was out of the scope.
 195 func GetSwagger() (swagger *openapi3.T, err error) {
 196         var resolvePath = PathToRawSpec("")
 197
 198         loader := openapi3.NewLoader()
 199         loader.IsExternalRefsAllowed = true
 200         loader.ReadFromURIFunc = func(loader *openapi3.Loader, url *url.URL) ([]byte, error) {
 201                 var pathToFile = url.String()
 202                 pathToFile = path.Clean(pathToFile)
 203                 getSpec, ok := resolvePath[pathToFile]
 204                 if !ok {
 205                         err1 := fmt.Errorf("path not found: %s", pathToFile)
 206                         return nil, err1
 207                 }
 208                 return getSpec()
 209         }
 210         var specData []byte
 211         specData, err = rawSpec()
 212         if err != nil {
 213                 return
 214         }
 215         swagger, err = loader.LoadFromData(specData)
 216         if err != nil {
 217                 return
 218         }
 219         return
 220 }