summaryrefslogtreecommitdiffstats
path: root/api4/webhook.go
diff options
context:
space:
mode:
authorJoram Wilander <jwawilander@gmail.com>2018-05-14 10:24:58 -0400
committerGitHub <noreply@github.com>2018-05-14 10:24:58 -0400
commit47250c6629416b628a19e5571ac89f7b4646418c (patch)
tree0ccfd50e06af7293e0f9e27c2d1c1200efa78a6a /api4/webhook.go
parent7e7c55198719337e7cb39b07c0d5a48c0a6908de (diff)
downloadchat-47250c6629416b628a19e5571ac89f7b4646418c.tar.gz
chat-47250c6629416b628a19e5571ac89f7b4646418c.tar.bz2
chat-47250c6629416b628a19e5571ac89f7b4646418c.zip
Refactor context out of API packages (#8755)
* Refactor context out of API packages * Update function names per feedback * Move webhook handlers to web and fix web tests * Move more webhook tests out of api package * Fix static handler
Diffstat (limited to 'api4/webhook.go')
-rw-r--r--api4/webhook.go91
1 files changed, 0 insertions, 91 deletions
diff --git a/api4/webhook.go b/api4/webhook.go
index fadc3fbf3..ec90c6f3a 100644
--- a/api4/webhook.go
+++ b/api4/webhook.go
@@ -4,14 +4,8 @@
package api4
import (
- "fmt"
- "io"
"net/http"
- "strings"
- "github.com/gorilla/mux"
- "github.com/gorilla/schema"
- "github.com/mattermost/mattermost-server/mlog"
"github.com/mattermost/mattermost-server/model"
)
@@ -28,12 +22,6 @@ func (api *API) InitWebhook() {
api.BaseRoutes.OutgoingHook.Handle("", api.ApiSessionRequired(updateOutgoingHook)).Methods("PUT")
api.BaseRoutes.OutgoingHook.Handle("", api.ApiSessionRequired(deleteOutgoingHook)).Methods("DELETE")
api.BaseRoutes.OutgoingHook.Handle("/regen_token", api.ApiSessionRequired(regenOutgoingHookToken)).Methods("POST")
-
- api.BaseRoutes.Root.Handle("/hooks/commands/{id:[A-Za-z0-9]+}", api.ApiHandler(commandWebhook)).Methods("POST")
- api.BaseRoutes.Root.Handle("/hooks/{id:[A-Za-z0-9]+}", api.ApiHandler(incomingWebhook)).Methods("POST")
-
- // Old endpoint for backwards compatibility
- api.BaseRoutes.Root.Handle("/api/v3/teams/{team_id:[A-Za-z0-9]+}/hooks/{id:[A-Za-z0-9]+}", api.ApiHandler(incomingWebhook)).Methods("POST")
}
func createIncomingHook(c *Context, w http.ResponseWriter, r *http.Request) {
@@ -454,82 +442,3 @@ func deleteOutgoingHook(c *Context, w http.ResponseWriter, r *http.Request) {
c.LogAudit("success")
ReturnStatusOK(w)
}
-
-func incomingWebhook(c *Context, w http.ResponseWriter, r *http.Request) {
- params := mux.Vars(r)
- id := params["id"]
-
- r.ParseForm()
-
- var err *model.AppError
- incomingWebhookPayload := &model.IncomingWebhookRequest{}
- contentType := r.Header.Get("Content-Type")
- if strings.Split(contentType, "; ")[0] == "application/x-www-form-urlencoded" {
- payload := strings.NewReader(r.FormValue("payload"))
-
- incomingWebhookPayload, err = decodePayload(payload)
- if err != nil {
- c.Err = err
- return
- }
- } else if strings.HasPrefix(contentType, "multipart/form-data") {
- r.ParseMultipartForm(0)
-
- decoder := schema.NewDecoder()
- err := decoder.Decode(incomingWebhookPayload, r.PostForm)
-
- if err != nil {
- c.Err = model.NewAppError("incomingWebhook", "api.webhook.incoming.error", nil, err.Error(), http.StatusBadRequest)
- return
- }
- } else {
- incomingWebhookPayload, err = decodePayload(r.Body)
- if err != nil {
- c.Err = err
- return
- }
- }
-
- if c.App.Config().LogSettings.EnableWebhookDebugging {
- mlog.Debug(fmt.Sprint("Incoming webhook received. Content=", incomingWebhookPayload.ToJson()))
- }
-
- err = c.App.HandleIncomingWebhook(id, incomingWebhookPayload)
- if err != nil {
- c.Err = err
- return
- }
-
- w.Header().Set("Content-Type", "text/plain")
- w.Write([]byte("ok"))
-}
-
-func commandWebhook(c *Context, w http.ResponseWriter, r *http.Request) {
- params := mux.Vars(r)
- id := params["id"]
-
- response, err := model.CommandResponseFromHTTPBody(r.Header.Get("Content-Type"), r.Body)
- if err != nil {
- c.Err = model.NewAppError("commandWebhook", "web.command_webhook.parse.app_error", nil, err.Error(), http.StatusBadRequest)
- return
- }
-
- appErr := c.App.HandleCommandWebhook(id, response)
- if appErr != nil {
- c.Err = appErr
- return
- }
-
- w.Header().Set("Content-Type", "text/plain")
- w.Write([]byte("ok"))
-}
-
-func decodePayload(payload io.Reader) (*model.IncomingWebhookRequest, *model.AppError) {
- incomingWebhookPayload, decodeError := model.IncomingWebhookRequestFromJson(payload)
-
- if decodeError != nil {
- return nil, decodeError
- }
-
- return incomingWebhookPayload, nil
-}