freshlybakedca.ke
forked from
tangled.org/core
A fork of tangled.org/core to hack on
knotserver/internal: add create PR message on git push
Respond to a successful push with a URL to create a PR pointing to the
default branch. This behavior is made to mimic other Git forges.
Signed-off-by: Samuel Shuert <me@thecoded.prof>
thecoded.prof
+45
+45
knotserver/internal.go
+45
knotserver/internal.go
···
15
15
"github.com/go-chi/chi/v5/middleware"
16
16
"tangled.org/core/api/tangled"
17
17
"tangled.org/core/hook"
18
+
"tangled.org/core/idresolver"
18
19
"tangled.org/core/knotserver/config"
19
20
"tangled.org/core/knotserver/db"
20
21
"tangled.org/core/knotserver/git"
···
118
119
// non-fatal
119
120
}
120
121
122
+
if (line.NewSha.String() != line.OldSha.String()) && line.OldSha.IsZero() {
123
+
msg, err := h.replyCompare(line, gitUserDid, gitRelativeDir, repoName, r.Context())
124
+
if err != nil {
125
+
l.Error("failed to reply with compare link", "err", err, "line", line, "did", gitUserDid, "repo", gitRelativeDir)
126
+
// non-fatal
127
+
} else {
128
+
for msgLine := range msg {
129
+
resp.Messages = append(resp.Messages, msg[msgLine])
130
+
}
131
+
}
132
+
}
133
+
121
134
err = h.triggerPipeline(&resp.Messages, line, gitUserDid, repoDid, repoName, pushOptions)
122
135
if err != nil {
123
136
l.Error("failed to trigger pipeline", "err", err, "line", line, "did", gitUserDid, "repo", gitRelativeDir)
···
126
139
}
127
140
128
141
writeJSON(w, resp)
142
+
}
143
+
144
+
func (h *InternalHandle) replyCompare(line git.PostReceiveLine, gitUserDid string, gitRelativeDir string, repoName string, ctx context.Context) ([]string, error) {
145
+
l := h.l.With("handler", "replyCompare")
146
+
userIdent, err := idresolver.DefaultResolver().ResolveIdent(ctx, gitUserDid)
147
+
user := gitUserDid
148
+
if err != nil {
149
+
l.Error("Failed to fetch user identity", "err", err)
150
+
// non-fatal
151
+
} else {
152
+
user = userIdent.Handle.String()
153
+
}
154
+
gr, err := git.PlainOpen(gitRelativeDir)
155
+
if err != nil {
156
+
l.Error("Failed to open git repository", "err", err)
157
+
return []string{}, err
158
+
}
159
+
defaultBranch, err := gr.FindMainBranch()
160
+
if err != nil {
161
+
l.Error("Failed to fetch default branch", "err", err)
162
+
return []string{}, err
163
+
}
164
+
if line.Ref == fmt.Sprintf("refs/heads/%s", defaultBranch) {
165
+
return []string{}, nil
166
+
}
167
+
ZWS := ""
168
+
var msg []string
169
+
msg = append(msg, ZWS)
170
+
msg = append(msg, fmt.Sprintf("Create a PR pointing to %s", defaultBranch))
171
+
msg = append(msg, fmt.Sprintf("\t%s/%s/%s/compare/%s...%s", h.c.AppViewEndpoint, user, repoName, defaultBranch, strings.TrimPrefix(line.Ref, "refs/heads/")))
172
+
msg = append(msg, ZWS)
173
+
return msg, nil
129
174
}
130
175
131
176
func (h *InternalHandle) insertRefUpdate(line git.PostReceiveLine, gitUserDid, repoDid, repoName string) error {