mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-31 10:43:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix push server internal http wiring

Browse source
This commit is contained in:
Piotr Kozimor 2021-12-06 15:06:22 +01:00
parent b89da40cbd
commit c9e94b4751
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
pushserver/inthttp/server.go
View file

@ -54,22 +54,22 @@ func AddRoutes(r api.PushserverInternalAPI, internalAPIMux *mux.Router) {
}), }),
) )
internalAPIMux.Handle(QueryPushRulesPath, internalAPIMux.Handle(QueryPushersPath,
httputil.MakeInternalAPI("queryPushRules", func(req *http.Request) util.JSONResponse { httputil.MakeInternalAPI("queryPushers", func(req *http.Request) util.JSONResponse {
request := api.QueryPushRulesRequest{} request := api.QueryPushersRequest{}
response := api.QueryPushRulesResponse{} response := api.QueryPushersResponse{}
if err := json.NewDecoder(req.Body).Decode(&request); err != nil { if err := json.NewDecoder(req.Body).Decode(&request); err != nil {
return util.MessageResponse(http.StatusBadRequest, err.Error()) return util.MessageResponse(http.StatusBadRequest, err.Error())
} }
if err := r.QueryPushRules(req.Context(), &request, &response); err != nil { if err := r.QueryPushers(req.Context(), &request, &response); err != nil {
return util.ErrorResponse(err) return util.ErrorResponse(err)
} }
return util.JSONResponse{Code: http.StatusOK, JSON: &response} return util.JSONResponse{Code: http.StatusOK, JSON: &response}
}), }),
) )
internalAPIMux.Handle(PerformPusherDeletionPath, internalAPIMux.Handle(PerformPushRulesPutPath,
httputil.MakeInternalAPI("performPusherDeletion", func(req *http.Request) util.JSONResponse { httputil.MakeInternalAPI("performPushRulesPut", func(req *http.Request) util.JSONResponse {
request := api.PerformPushRulesPutRequest{} request := api.PerformPushRulesPutRequest{}
response := struct{}{} response := struct{}{}
if err := json.NewDecoder(req.Body).Decode(&request); err != nil { if err := json.NewDecoder(req.Body).Decode(&request); err != nil {