···
type InternalHandle struct {
func (h *InternalHandle) PushAllowed(w http.ResponseWriter, r *http.Request) {
···
-
if (line.NewSha.String() != line.OldSha.String()) && line.OldSha.IsZero() {
-
msg, err := h.replyCompare(line, repoDid, gitRelativeDir, repoName, r.Context())
-
l.Error("failed to reply with compare link", "err", err, "line", line, "did", gitUserDid, "repo", gitRelativeDir)
-
for msgLine := range msg {
-
resp.Messages = append(resp.Messages, msg[msgLine])
err = h.triggerPipeline(&resp.Messages, line, gitUserDid, repoDid, repoName, pushOptions)
···
-
func (h *InternalHandle) replyCompare(line git.PostReceiveLine, repoOwner string, gitRelativeDir string, repoName string, ctx context.Context) ([]string, error) {
-
l := h.l.With("handler", "replyCompare")
-
userIdent, err := idresolver.DefaultResolver().ResolveIdent(ctx, repoOwner)
-
l.Error("Failed to fetch user identity", "err", err)
-
user = userIdent.Handle.String()
-
gr, err := git.PlainOpen(gitRelativeDir)
-
l.Error("Failed to open git repository", "err", err)
-
defaultBranch, err := gr.FindMainBranch()
-
l.Error("Failed to fetch default branch", "err", err)
-
if line.Ref == plumbing.NewBranchReferenceName(defaultBranch).String() {
-
msg = append(msg, fmt.Sprintf("Create a PR pointing to %s", defaultBranch))
-
msg = append(msg, fmt.Sprintf("\t%s/%s/%s/compare/%s...%s", h.c.AppViewEndpoint, user, repoName, defaultBranch, strings.TrimPrefix(line.Ref, "refs/heads/")))
func (h *InternalHandle) insertRefUpdate(line git.PostReceiveLine, gitUserDid, repoDid, repoName string) error {
didSlashRepo, err := securejoin.SecureJoin(repoDid, repoName)
···
return errors.Join(errs, h.db.InsertEvent(event, h.n))
-
func (h *InternalHandle) triggerPipeline(clientMsgs *[]string, line git.PostReceiveLine, gitUserDid, repoDid, repoName string, pushOptions PushOptions) error {
···
return h.db.InsertEvent(event, h.n)
func Internal(ctx context.Context, c *config.Config, db *db.DB, e *rbac.Enforcer, n *notifier.Notifier) http.Handler {
l := log.FromContext(ctx)
l = log.SubLogger(l, "internal")
···
r.Get("/push-allowed", h.PushAllowed)
···
type InternalHandle struct {
+
res *idresolver.Resolver
func (h *InternalHandle) PushAllowed(w http.ResponseWriter, r *http.Request) {
···
+
err = h.emitCompareLink(&resp.Messages, line, repoDid, repoName)
+
l.Error("failed to reply with compare link", "err", err, "line", line, "did", gitUserDid, "repo", gitRelativeDir)
err = h.triggerPipeline(&resp.Messages, line, gitUserDid, repoDid, repoName, pushOptions)
···
func (h *InternalHandle) insertRefUpdate(line git.PostReceiveLine, gitUserDid, repoDid, repoName string) error {
didSlashRepo, err := securejoin.SecureJoin(repoDid, repoName)
···
return errors.Join(errs, h.db.InsertEvent(event, h.n))
+
func (h *InternalHandle) triggerPipeline(
+
line git.PostReceiveLine,
+
pushOptions PushOptions,
···
return h.db.InsertEvent(event, h.n)
+
func (h *InternalHandle) emitCompareLink(
+
line git.PostReceiveLine,
+
// this is a second push to a branch, don't reply with the link again
+
if !line.OldSha.IsZero() {
+
// the ref was not updated to a new hash, don't reply with the link
+
// NOTE: do we need this?
+
if line.NewSha.String() == line.OldSha.String() {
+
pushedRef := plumbing.ReferenceName(line.Ref)
+
userIdent, err := h.res.ResolveIdent(context.Background(), repoDid)
+
user = userIdent.Handle.String()
+
didSlashRepo, err := securejoin.SecureJoin(repoDid, repoName)
+
repoPath, err := securejoin.SecureJoin(h.c.Repo.ScanPath, didSlashRepo)
+
gr, err := git.PlainOpen(repoPath)
+
defaultBranch, err := gr.FindMainBranch()
+
// pushing to default branch
+
if pushedRef == plumbing.NewBranchReferenceName(defaultBranch) {
+
// pushing a tag, don't prompt the user the open a PR
+
*clientMsgs = append(*clientMsgs, ZWS)
+
*clientMsgs = append(*clientMsgs, fmt.Sprintf("Create a PR pointing to %s", defaultBranch))
+
*clientMsgs = append(*clientMsgs, fmt.Sprintf("\t%s/%s/%s/compare/%s...%s", h.c.AppViewEndpoint, user, repoName, defaultBranch, strings.TrimPrefix(line.Ref, "refs/heads/")))
+
*clientMsgs = append(*clientMsgs, ZWS)
func Internal(ctx context.Context, c *config.Config, db *db.DB, e *rbac.Enforcer, n *notifier.Notifier) http.Handler {
l := log.FromContext(ctx)
l = log.SubLogger(l, "internal")
+
res := idresolver.DefaultResolver()
···
r.Get("/push-allowed", h.PushAllowed)
oppi.li