-
Notifications
You must be signed in to change notification settings - Fork 10
/
WebhookHandler.go
127 lines (107 loc) · 3.98 KB
/
WebhookHandler.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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
/*
* Copyright (c) 2020 Devtron Labs
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
*/
package git
import (
"go.uber.org/zap"
"strings"
"time"
)
type WebhookHandler interface {
HandleWebhookEvent(webhookEvent *WebhookEvent) error
}
type WebhookHandlerImpl struct {
logger *zap.SugaredLogger
webhookEventService WebhookEventService
webhookEventParser WebhookEventParser
}
func NewWebhookHandlerImpl(logger *zap.SugaredLogger, webhookEventService WebhookEventService, webhookEventParser WebhookEventParser) *WebhookHandlerImpl {
return &WebhookHandlerImpl{
logger: logger,
webhookEventService: webhookEventService,
webhookEventParser: webhookEventParser,
}
}
func (impl WebhookHandlerImpl) HandleWebhookEvent(webhookEvent *WebhookEvent) error {
impl.logger.Debug("Webhook event came")
gitHostId := webhookEvent.GitHostId
eventType := webhookEvent.EventType
payloadJson := webhookEvent.RequestPayloadJson
payloadId := webhookEvent.PayloadId
impl.logger.Debugw("webhook event request data", "gitHostId", gitHostId, "eventType", eventType)
// get all configured events from database for given git host Id
events, err := impl.webhookEventService.GetAllGitHostWebhookEventByGitHostId(gitHostId)
if err != nil {
impl.logger.Errorw("error in getting webhook events from db", "err", err, "gitHostId", gitHostId)
return err
}
if len(events) == 0 {
impl.logger.Warnw("webhook events not found for given gitHostId ", "gitHostId", gitHostId)
return nil
}
// operate for all matching event (match for eventType)
impl.logger.Debug("Checking for event matching")
for _, event := range events {
if len(event.EventTypesCsv) > 0 {
eventTypes := strings.Split(event.EventTypesCsv, ",")
if !contains(eventTypes, eventType) {
continue
}
}
eventId := event.Id
// parse event data using selectors
webhookEventParsedData, fullDataMap, err := impl.webhookEventParser.ParseEvent(event.Selectors, payloadJson)
if err != nil {
impl.logger.Errorw("error in parsing webhook event data", "err", err)
return err
}
// set event details in webhook data (eventId and merged/non-merged etc..)
webhookEventParsedData.EventId = eventId
webhookEventParsedData.EventActionType = event.ActionType
webhookEventParsedData.PayloadDataId = payloadId
// fetch webhook parsed data from DB if unique id is not blank
webhookParsedEventGetData, err := impl.webhookEventService.GetWebhookParsedEventDataByEventIdAndUniqueId(eventId, webhookEventParsedData.UniqueId)
if err != nil {
impl.logger.Errorw("error in getting parsed webhook event data", "err", err)
return err
}
// save or update in DB
if webhookParsedEventGetData != nil {
webhookEventParsedData.Id = webhookParsedEventGetData.Id
webhookEventParsedData.CreatedOn = webhookParsedEventGetData.CreatedOn
webhookEventParsedData.UpdatedOn = time.Now()
impl.webhookEventService.UpdateWebhookParsedEventData(webhookEventParsedData)
} else {
webhookEventParsedData.CreatedOn = time.Now()
impl.webhookEventService.SaveWebhookParsedEventData(webhookEventParsedData)
}
// match ci trigger condition and notify
err = impl.webhookEventService.MatchCiTriggerConditionAndNotify(event, webhookEventParsedData, fullDataMap)
if err != nil {
impl.logger.Errorw("error in matching ci trigger condition for webhook after db save", "err", err)
return err
}
}
return nil
}
func contains(s []string, str string) bool {
for _, v := range s {
if v == str {
return true
}
}
return false
}