1package webhook
2
3import (
4 "context"
5 "fmt"
6
7 gitm "github.com/aymanbagabas/git-module"
8 "github.com/charmbracelet/soft-serve/git"
9 "github.com/charmbracelet/soft-serve/pkg/config"
10 "github.com/charmbracelet/soft-serve/pkg/db"
11 "github.com/charmbracelet/soft-serve/pkg/proto"
12 "github.com/charmbracelet/soft-serve/pkg/store"
13)
14
15// PushEvent is a push event.
16type PushEvent struct {
17 Common
18
19 // Ref is the branch or tag name.
20 Ref string `json:"ref" url:"ref"`
21 // Before is the previous commit SHA.
22 Before string `json:"before" url:"before"`
23 // After is the current commit SHA.
24 After string `json:"after" url:"after"`
25 // Commits is the list of commits.
26 Commits []Commit `json:"commits" url:"commits"`
27}
28
29// NewPushEvent sends a push event.
30func NewPushEvent(ctx context.Context, user proto.User, repo proto.Repository, ref, before, after string) (PushEvent, error) {
31 event := EventPush
32
33 payload := PushEvent{
34 Ref: ref,
35 Before: before,
36 After: after,
37 Common: Common{
38 EventType: event,
39 Repository: Repository{
40 ID: repo.ID(),
41 Name: repo.Name(),
42 Description: repo.Description(),
43 ProjectName: repo.ProjectName(),
44 Private: repo.IsPrivate(),
45 CreatedAt: repo.CreatedAt(),
46 UpdatedAt: repo.UpdatedAt(),
47 },
48 Sender: User{
49 ID: user.ID(),
50 Username: user.Username(),
51 },
52 },
53 }
54
55 cfg := config.FromContext(ctx)
56 payload.Repository.HTTPURL = repoURL(cfg.HTTP.PublicURL, repo.Name())
57 payload.Repository.SSHURL = repoURL(cfg.SSH.PublicURL, repo.Name())
58 payload.Repository.GitURL = repoURL(cfg.Git.PublicURL, repo.Name())
59
60 // Find repo owner.
61 dbx := db.FromContext(ctx)
62 datastore := store.FromContext(ctx)
63 owner, err := datastore.GetUserByID(ctx, dbx, repo.UserID())
64 if err != nil {
65 return PushEvent{}, db.WrapError(err) //nolint:wrapcheck
66 }
67
68 payload.Repository.Owner.ID = owner.ID
69 payload.Repository.Owner.Username = owner.Username
70
71 // Find commits.
72 r, err := repo.Open()
73 if err != nil {
74 return PushEvent{}, err //nolint:wrapcheck
75 }
76
77 payload.Repository.DefaultBranch, _ = getDefaultBranch(repo)
78
79 rev := after
80 if !git.IsZeroHash(before) {
81 rev = fmt.Sprintf("%s..%s", before, after)
82 }
83
84 commits, err := r.Log(rev, gitm.LogOptions{
85 // XXX: limit to 20 commits for now
86 // TODO: implement a commits api
87 MaxCount: 20,
88 })
89 if err != nil {
90 return PushEvent{}, err //nolint:wrapcheck
91 }
92
93 payload.Commits = make([]Commit, len(commits))
94 for i, c := range commits {
95 payload.Commits[i] = Commit{
96 ID: c.ID.String(),
97 Message: c.Message,
98 Title: c.Summary(),
99 Author: Author{
100 Name: c.Author.Name,
101 Email: c.Author.Email,
102 Date: c.Author.When,
103 },
104 Committer: Author{
105 Name: c.Committer.Name,
106 Email: c.Committer.Email,
107 Date: c.Committer.When,
108 },
109 Timestamp: c.Committer.When,
110 }
111 }
112
113 return payload, nil
114}