1 // Package eventsapi provides primitives to interact with the openapi HTTP API.
3 // Code generated by github.com/deepmap/oapi-codegen version v1.10.1 DO NOT EDIT.
16 "github.com/deepmap/oapi-codegen/pkg/runtime"
17 "github.com/getkin/kin-openapi/openapi3"
18 "github.com/labstack/echo/v4"
21 // ServerInterface represents all server handlers.
22 type ServerInterface interface {
24 // (POST /{subscriberId}/subscriptions)
25 PostSubscriberIdSubscriptions(ctx echo.Context, subscriberId string) error
27 // (DELETE /{subscriberId}/subscriptions/{subscriptionId})
28 DeleteSubscriberIdSubscriptionsSubscriptionId(ctx echo.Context, subscriberId string, subscriptionId string) error
31 // ServerInterfaceWrapper converts echo contexts to parameters.
32 type ServerInterfaceWrapper struct {
33 Handler ServerInterface
36 // PostSubscriberIdSubscriptions converts echo context to params.
37 func (w *ServerInterfaceWrapper) PostSubscriberIdSubscriptions(ctx echo.Context) error {
39 // ------------- Path parameter "subscriberId" -------------
40 var subscriberId string
42 err = runtime.BindStyledParameterWithLocation("simple", false, "subscriberId", runtime.ParamLocationPath, ctx.Param("subscriberId"), &subscriberId)
44 return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter subscriberId: %s", err))
47 // Invoke the callback with all the unmarshalled arguments
48 err = w.Handler.PostSubscriberIdSubscriptions(ctx, subscriberId)
52 // DeleteSubscriberIdSubscriptionsSubscriptionId converts echo context to params.
53 func (w *ServerInterfaceWrapper) DeleteSubscriberIdSubscriptionsSubscriptionId(ctx echo.Context) error {
55 // ------------- Path parameter "subscriberId" -------------
56 var subscriberId string
58 err = runtime.BindStyledParameterWithLocation("simple", false, "subscriberId", runtime.ParamLocationPath, ctx.Param("subscriberId"), &subscriberId)
60 return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter subscriberId: %s", err))
63 // ------------- Path parameter "subscriptionId" -------------
64 var subscriptionId string
66 err = runtime.BindStyledParameterWithLocation("simple", false, "subscriptionId", runtime.ParamLocationPath, ctx.Param("subscriptionId"), &subscriptionId)
68 return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter subscriptionId: %s", err))
71 // Invoke the callback with all the unmarshalled arguments
72 err = w.Handler.DeleteSubscriberIdSubscriptionsSubscriptionId(ctx, subscriberId, subscriptionId)
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
91 // RegisterHandlers adds each server route to the EchoRouter.
92 func RegisterHandlers(router EchoRouter, si ServerInterface) {
93 RegisterHandlersWithBaseURL(router, si, "")
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) {
100 wrapper := ServerInterfaceWrapper{
104 router.POST(baseURL+"/:subscriberId/subscriptions", wrapper.PostSubscriberIdSubscriptions)
105 router.DELETE(baseURL+"/:subscriberId/subscriptions/:subscriptionId", wrapper.DeleteSubscriberIdSubscriptionsSubscriptionId)
109 // Base64 encoded, gzipped, json marshaled Swagger object
110 var swaggerSpec = []string{
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/",
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, ""))
155 return nil, fmt.Errorf("error base64 decoding spec: %s", err)
157 zr, err := gzip.NewReader(bytes.NewReader(zipped))
159 return nil, fmt.Errorf("error decompressing spec: %s", err)
162 _, err = buf.ReadFrom(zr)
164 return nil, fmt.Errorf("error decompressing spec: %s", err)
167 return buf.Bytes(), nil
170 var rawSpec = decodeSpecCached()
172 // a naive cached of a decoded swagger spec
173 func decodeSpecCached() func() ([]byte, error) {
174 data, err := decodeSpec()
175 return func() ([]byte, error) {
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
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("")
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]
205 err1 := fmt.Errorf("path not found: %s", pathToFile)
211 specData, err = rawSpec()
215 swagger, err = loader.LoadFromData(specData)