webhooks.go

package main

import (
	"context"
	"fmt"
	"io"
	"net/http"

	"github.com/erda-project/erda-bot/handlers"
	"github.com/erda-project/erda-bot/handlers/issue/comment"
	"github.com/erda-project/erda-bot/handlers/issue/comment/instruction"
	"github.com/erda-project/erda-bot/handlers/issue/comment/instruction/approve"
	"github.com/erda-project/erda-bot/handlers/issue/comment/instruction/assign"
	"github.com/erda-project/erda-bot/handlers/issue/comment/instruction/cherrypick"
	"github.com/erda-project/erda-bot/handlers/issue/comment/instruction/erda/actions"
	"github.com/erda-project/erda-bot/handlers/issue/pr"
	"github.com/erda-project/erda-bot/handlers/issue/title"
	"github.com/erda-project/erda-bot/handlers/issue/title/label"
	"github.com/erda-project/erda-bot/handlers/star"
	"github.com/erda-project/erda/pkg/httpserver"
)

func Webhooks(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error) {
	// get event bytes
	eventBytes, err := io.ReadAll(r.Body)
	if err != nil {
		return httpserver.ErrResp(http.StatusBadRequest, "", fmt.Sprintf("%v", err))
	}

	// init request
	req := &handlers.Request{EventBytes: eventBytes, HTTPRequest: r}

	// init handlers chain of responsibility
	h :=
		handlers.NewRootHandler(
			handlers.NewEventTypeParseHandler(
				handlers.NewEventDispatchHandler(
					comment.NewIssueCommentHandler(
						instruction.NewPrCommentInstructionHandler(
							cherrypick.NewPrCommentInstructionCherryPickHandler(),
							approve.NewPrCommentInstructionApproveHandler(),
							assign.NewPrCommentInstructionAssignHandler(),
							actions.NewPrCommentInstructionActionHandler(),
						),
					),
					// other event type handler here
					star.NewStarHandler(),
					pr.NewPRHandler(
						title.NewPrTitleHandler(
							label.NewPrTitleLabelHandler(),
						),
						comment.NewIssueCommentHandler(
							instruction.NewPrCommentInstructionHandler(
								cherrypick.NewPrCommentInstructionCherryPickHandler(),
								assign.NewPrCommentInstructionAssignHandler(),
							),
						),
					),
				),
			),
		)

	// handle request
	go h.Execute(ctx, req)

	return httpserver.OkResp(nil)
}