baize/framework/gateway/builder_params.go

package gateway

import (
	"git.sxidc.com/go-framework/baize/framework/core/api"
	"git.sxidc.com/go-framework/baize/framework/core/infrastructure/logger"
	"git.sxidc.com/service-supports/fserr"
	"net/http"
)

type builderParams struct {
	httpMethod                string
	relativePath              string
	requestItems              []*builderRequestItem
	requestParamsBindCallback RequestParamsBindCallback
	globalRequestCallback     GlobalRequestCallback
	responseSuccessCallback   ResponseSuccessCallback
	responseErrorCallback     ResponseErrorCallback
}

func newBuilderParams() *builderParams {
	return &builderParams{
		httpMethod:            "",
		relativePath:          "",
		requestItems:          make([]*builderRequestItem, 0),
		globalRequestCallback: nil,
		responseSuccessCallback: func(c *api.Context, historyRequests []BuilderRequest, customResultMap map[string]any) {
			c.Status(http.StatusOK)

			if historyRequests != nil && len(historyRequests) != 0 {
				_, err := c.Writer.Write(historyRequests[len(historyRequests)-1].Response().Body())
				if err != nil {
					logger.GetInstance().Error(fserr.New(err.Error()))
					c.AbortWithStatus(http.StatusInternalServerError)
					return
				}
			}

			c.Writer.Flush()
		},
		responseErrorCallback: func(c *api.Context, err error) {
			if err == nil {
				return
			}

			resp := make(map[string]any)
			logger.GetInstance().Error(err)
			serviceErr := fserr.ParseCode(err)

			resp["success"] = false
			resp["errCode"] = serviceErr.BusinessCode
			resp["msg"] = serviceErr.Msg

			c.JSON(http.StatusOK, resp)
		},
	}
}

func (params *builderParams) copy() *builderParams {
	return &builderParams{
		httpMethod:              params.httpMethod,
		relativePath:            params.relativePath,
		requestItems:            params.requestItems,
		globalRequestCallback:   params.globalRequestCallback,
		responseSuccessCallback: params.responseSuccessCallback,
		responseErrorCallback:   params.responseErrorCallback,
	}
}