Method InvokeHandler

pkg/controller/handler.go:43–121

(c *routing.Context)

}

func (controller *Controller) InvokeHandler(c *routing.Context) error {
	externalRequestID := string(c.Request.Header.Peek(api.HeaderXRequestID))
	invokeType := strings.ToLower(string(c.Request.Header.Peek(api.HeaderInvokeType)))
	triggerType := strings.ToLower(string(c.Request.Header.Peek(api.BceFaasTriggerKey)))
	accountID := string(c.Request.Header.Peek(api.HeaderXAccountID))
	authorization := string(c.Request.Header.Peek(api.HeaderAuthorization))
	requestID := id.GetRequestID()
	if externalRequestID == "" {
		externalRequestID = requestID
	}

	if invokeType == "" {
		invokeType = api.InvokeTypeCommon
	}
	if triggerType == "" {
		triggerType = api.TriggerTypeGeneric
	}

	var clientMode string
	if invokeType == api.InvokeTypeEvent || invokeType == api.InvokeTypeMqhub {
		clientMode = ClientModeInside
	}
	if triggerType == api.TriggerTypeVscode {
		clientMode = ClientModeInside
	}

	ctx := InvokeContext{
		RunOptions:        controller.runOptions,
		ExternalRequestID: externalRequestID,
		RequestID:         requestID,
		AccountID:         accountID,
		Authorization:     authorization,
		CallerUser: &api.User{
			ID: accountID,
		},
		Clients:  controller.NewClients(clientMode),
		Request:  generateInvokeRequest(c),
		Response: api.NewInvokeProxyResponseWithRequestID(externalRequestID),
		Logger: logs.NewLogger().WithField("request_id", requestID).
			WithField("external_request_id", externalRequestID).WithField("invoke-type", invokeType),
		LogType:     api.GetLogType(c),
		LogToBody:   api.GetLogToBody(c),
		InvokeType:  invokeType,
		TriggerType: triggerType,
	}

	funcName := c.Param("functionName")
	if !api.RegfunctionName.MatchString(funcName) {
		ctx.FunctionBRN = funcName
	} else {
		qualifier := string(c.QueryArgs().Peek("Qualifier"))
		if qualifier == "" {
			c.Response.SetStatusCode(http.StatusBadRequest)
			err := innerErr.NewInvalidParameterValueException("missing query parameter Qualifier", nil)
			bodyData, _ := json.Marshal(err)
			c.Response.SetBody(bodyData)
			return err
		}