2017-02-20 15:41:29 +00:00
|
|
|
package routing
|
|
|
|
|
|
|
|
import (
|
|
|
|
"net/http"
|
|
|
|
|
|
|
|
"github.com/gorilla/mux"
|
2017-03-10 11:32:53 +00:00
|
|
|
"github.com/matrix-org/dendrite/clientapi/config"
|
2017-03-15 13:36:26 +00:00
|
|
|
"github.com/matrix-org/dendrite/clientapi/producers"
|
2017-02-20 15:41:29 +00:00
|
|
|
"github.com/matrix-org/dendrite/clientapi/writers"
|
2017-03-15 11:22:40 +00:00
|
|
|
"github.com/matrix-org/dendrite/roomserver/api"
|
2017-02-20 15:41:29 +00:00
|
|
|
"github.com/matrix-org/util"
|
|
|
|
"github.com/prometheus/client_golang/prometheus"
|
|
|
|
)
|
|
|
|
|
|
|
|
const pathPrefixR0 = "/_matrix/client/r0"
|
|
|
|
|
|
|
|
// Setup registers HTTP handlers with the given ServeMux. It also supplies the given http.Client
|
|
|
|
// to clients which need to make outbound HTTP requests.
|
2017-03-15 13:36:26 +00:00
|
|
|
func Setup(servMux *http.ServeMux, httpClient *http.Client, cfg config.ClientAPI, producer *producers.RoomserverProducer, queryAPI api.RoomserverQueryAPI) {
|
2017-02-20 15:41:29 +00:00
|
|
|
apiMux := mux.NewRouter()
|
|
|
|
r0mux := apiMux.PathPrefix(pathPrefixR0).Subrouter()
|
2017-03-10 11:32:53 +00:00
|
|
|
r0mux.Handle("/createRoom", make("createRoom", util.NewJSONRequestHandler(func(req *http.Request) util.JSONResponse {
|
2017-03-10 16:19:23 +00:00
|
|
|
return writers.CreateRoom(req, cfg, producer)
|
2017-03-07 16:11:08 +00:00
|
|
|
})))
|
2017-03-15 11:22:40 +00:00
|
|
|
r0mux.Handle("/rooms/{roomID}/send/{eventType}/{txnID}",
|
2017-03-10 11:32:53 +00:00
|
|
|
make("send_message", util.NewJSONRequestHandler(func(req *http.Request) util.JSONResponse {
|
2017-02-20 15:41:29 +00:00
|
|
|
vars := mux.Vars(req)
|
2017-03-17 11:21:52 +00:00
|
|
|
return writers.SendEvent(req, vars["roomID"], vars["eventType"], vars["txnID"], nil, cfg, queryAPI, producer)
|
|
|
|
})),
|
|
|
|
)
|
|
|
|
r0mux.Handle("/rooms/{roomID}/state/{eventType}",
|
|
|
|
make("send_message", util.NewJSONRequestHandler(func(req *http.Request) util.JSONResponse {
|
|
|
|
vars := mux.Vars(req)
|
|
|
|
emptyString := ""
|
|
|
|
return writers.SendEvent(req, vars["roomID"], vars["eventType"], vars["txnID"], &emptyString, cfg, queryAPI, producer)
|
|
|
|
})),
|
|
|
|
)
|
|
|
|
r0mux.Handle("/rooms/{roomID}/state/{eventType}/{stateKey}",
|
|
|
|
make("send_message", util.NewJSONRequestHandler(func(req *http.Request) util.JSONResponse {
|
|
|
|
vars := mux.Vars(req)
|
|
|
|
stateKey := vars["stateKey"]
|
|
|
|
return writers.SendEvent(req, vars["roomID"], vars["eventType"], vars["txnID"], &stateKey, cfg, queryAPI, producer)
|
2017-02-20 15:41:29 +00:00
|
|
|
})),
|
|
|
|
)
|
|
|
|
|
|
|
|
servMux.Handle("/metrics", prometheus.Handler())
|
|
|
|
servMux.Handle("/api/", http.StripPrefix("/api", apiMux))
|
|
|
|
}
|
|
|
|
|
|
|
|
// make a util.JSONRequestHandler into an http.Handler
|
|
|
|
func make(metricsName string, h util.JSONRequestHandler) http.Handler {
|
|
|
|
return prometheus.InstrumentHandler(metricsName, util.MakeJSONAPI(h))
|
|
|
|
}
|