-
Notifications
You must be signed in to change notification settings - Fork 81
/
detect.go
63 lines (56 loc) · 2.16 KB
/
detect.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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
package gitlab
import (
"encoding/json"
"fmt"
"net/http"
"github.com/openshift-pipelines/pipelines-as-code/pkg/provider"
"github.com/xanzy/go-gitlab"
"go.uber.org/zap"
)
// Detect processes event and detect if it is a gitlab event, whether to process or reject it
// returns (if is a GL event, whether to process or reject, logger with event metadata,, error if any occurred)
func (v *Provider) Detect(req *http.Request, payload string, logger *zap.SugaredLogger) (bool, bool, *zap.SugaredLogger, string, error) {
isGL := false
event := req.Header.Get("X-Gitlab-Event")
if event == "" {
return false, false, logger, "no gitlab event", nil
}
// it is a Gitlab event
isGL = true
setLoggerAndProceed := func(processEvent bool, reason string, err error) (bool, bool, *zap.SugaredLogger,
string, error,
) {
logger = logger.With("provider", "gitlab", "event-id", req.Header.Get("X-Request-Id"))
return isGL, processEvent, logger, reason, err
}
eventInt, err := gitlab.ParseWebhook(gitlab.EventType(event), []byte(payload))
if err != nil {
return setLoggerAndProceed(false, "", err)
}
_ = json.Unmarshal([]byte(payload), &eventInt)
switch gitEvent := eventInt.(type) {
case *gitlab.MergeEvent:
if provider.Valid(gitEvent.ObjectAttributes.Action, []string{"open", "update", "reopen"}) {
return setLoggerAndProceed(true, "", nil)
}
return setLoggerAndProceed(false, fmt.Sprintf("not a merge event we care about: \"%s\"",
gitEvent.ObjectAttributes.Action), nil)
case *gitlab.PushEvent:
return setLoggerAndProceed(true, "", nil)
case *gitlab.MergeCommentEvent:
if gitEvent.MergeRequest.State == "opened" {
if provider.IsTestRetestComment(gitEvent.ObjectAttributes.Note) {
return setLoggerAndProceed(true, "", nil)
}
if provider.IsOkToTestComment(gitEvent.ObjectAttributes.Note) {
return setLoggerAndProceed(true, "", nil)
}
if provider.IsCancelComment(gitEvent.ObjectAttributes.Note) {
return setLoggerAndProceed(true, "", nil)
}
}
return setLoggerAndProceed(false, "not a gitops style merge comment event", nil)
default:
return setLoggerAndProceed(false, "", fmt.Errorf("gitlab: event \"%s\" is not supported", event))
}
}