forked from kyma-incubator/compass
/
server.go
46 lines (37 loc) · 2.11 KB
/
server.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
package broker
import (
"code.cloudfoundry.org/lager"
"github.com/gorilla/mux"
"github.com/pivotal-cf/brokerapi/v7/auth"
"github.com/pivotal-cf/brokerapi/v7/domain"
"github.com/pivotal-cf/brokerapi/v7/handlers"
"github.com/pivotal-cf/brokerapi/v7/middlewares"
)
type Credentials struct {
Username string
Password string
}
// copied from github.com/pivotal-cf/brokerapi/api.go
func AttachRoutes(router *mux.Router, serviceBroker domain.ServiceBroker, logger lager.Logger, brokerCredentials *Credentials) *mux.Router {
apiHandler := handlers.NewApiHandler(serviceBroker, logger)
router.HandleFunc("/v2/catalog", apiHandler.Catalog).Methods("GET")
router.HandleFunc("/v2/service_instances/{instance_id}", apiHandler.GetInstance).Methods("GET")
router.HandleFunc("/v2/service_instances/{instance_id}", apiHandler.Provision).Methods("PUT")
router.HandleFunc("/v2/service_instances/{instance_id}", apiHandler.Deprovision).Methods("DELETE")
router.HandleFunc("/v2/service_instances/{instance_id}/last_operation", apiHandler.LastOperation).Methods("GET")
router.HandleFunc("/v2/service_instances/{instance_id}", apiHandler.Update).Methods("PATCH")
router.HandleFunc("/v2/service_instances/{instance_id}/service_bindings/{binding_id}", apiHandler.GetBinding).Methods("GET")
router.HandleFunc("/v2/service_instances/{instance_id}/service_bindings/{binding_id}", apiHandler.Bind).Methods("PUT")
router.HandleFunc("/v2/service_instances/{instance_id}/service_bindings/{binding_id}", apiHandler.Unbind).Methods("DELETE")
router.HandleFunc("/v2/service_instances/{instance_id}/service_bindings/{binding_id}/last_operation", apiHandler.LastBindingOperation).Methods("GET")
router.Use(middlewares.AddCorrelationIDToContext)
if brokerCredentials != nil {
authMiddleware := auth.NewWrapper(brokerCredentials.Username, brokerCredentials.Password).Wrap
router.Use(authMiddleware)
}
apiVersionMiddleware := middlewares.APIVersionMiddleware{LoggerFactory: logger}
router.Use(middlewares.AddOriginatingIdentityToContext)
router.Use(apiVersionMiddleware.ValidateAPIVersionHdr)
router.Use(middlewares.AddInfoLocationToContext)
return router
}