-
Notifications
You must be signed in to change notification settings - Fork 4
/
merge_request.go
74 lines (61 loc) · 1.64 KB
/
merge_request.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
package service
import (
"github.com/pkg/errors"
"github.com/rs/zerolog/log"
"github.com/spatecon/gitlab-review-bot/internal/app/ds"
)
func (s *Service) mergeRequestsHandler(mr *ds.MergeRequest) error {
// fetch MR from repository
old, err := s.r.MergeRequestByID(mr.ID)
if err != nil {
return errors.Wrap(err, "failed to fetch merge request from repository")
}
// if no changes, do nothing
if old != nil && old.IsEqual(mr) {
log.Debug().
Int("project_id", mr.ProjectID).
Int("iid", mr.IID).
Msg("mr skipped")
return nil
}
// enrich MR with approves
approves, err := s.gitlab.MergeRequestApproves(mr.ProjectID, mr.IID)
if err != nil {
return errors.Wrap(err, "failed to fetch merge request approves")
}
mr.Approves = approves
// update (or create) it
err = s.r.UpsertMergeRequest(mr)
if err != nil {
return errors.Wrap(err, "failed to update merge request in repository")
}
log.Info().
Int("project_id", mr.ProjectID).
Int("iid", mr.IID).
Str("url", mr.URL).
Msg("mr updated or created")
// process MR
for _, team := range s.teams {
if mr.CreatedAt != nil && mr.CreatedAt.Before(team.CreatedAt) {
log.Info().Str("team_id", team.ID).Msg("skip team, mr created before team")
continue
}
policy, ok := s.policies[team.Policy]
if !ok {
log.Error().
Str("team", team.Name).
Str("policy", string(team.Policy)).
Msg("failed to process updates unknown policy")
continue
}
err = policy.ProcessChanges(team, mr)
if err != nil {
log.Error().
Err(err).
Str("team", team.Name).
Str("policy", string(team.Policy)).
Msg("failed to process merge request")
}
}
return nil
}