Method getFunction

pkg/controller/invoke.go:116–178

(ctx *InvokeContext)

}

func (controller *Controller) getFunction(ctx *InvokeContext) (hitCache bool, err error) {
	if ctx.RunOptions.RecommendedOptions.Features.EnableMetrics {
		ctx.Metrics.StepStart(StageGetFunction)
		ctx.Metrics.StepStart(StageGetFunctionHitCache)
		defer func() {
			if hitCache {
				ctx.Metrics.StepDone(StageGetFunctionHitCache)
				ctx.Metrics.ScrapStage(StageGetFunction)
			} else {
				ctx.Metrics.StepDone(StageGetFunction)
				ctx.Metrics.ScrapStage(StageGetFunctionHitCache)
			}
			ctx.Metrics.SetLabel(getFunctionBrnLabel, ctx.FunctionBRN)
			ctx.Metrics.SetLabel(getFunctionHitCacheLabel, strconv.FormatBool(hitCache))
		}()
	}

	ctx.Logger.V(9).Info("get function configuration")
	hitCache = false

	input := api.GetFunctionInput{
		Authorization: ctx.Authorization,
		RequestID:     ctx.RequestID,
		AccountID:     ctx.AccountID,
		WithCache:     true,
	}

	if ctx.InvokeType == api.InvokeTypeEvent || ctx.InvokeType == api.InvokeTypeHttpTrigger || ctx.InvokeType == api.InvokeTypeMqhub {
		input.SimpleAuth = true
	}
	if ctx.TriggerType == api.TriggerTypeVscode {
		input.SimpleAuth = true
	}

	if ctx.FunctionBRN != "" {
		hitCache, err = controller.getFunctionByFunctionBrn(ctx, &input)
	} else {
		hitCache, err = controller.getFunctionByFunctionName(ctx, &input)
	}
	if err != nil {
		return false, err
	}

	ctx.OwnerUser = &api.User{
		ID: ctx.Function.Configuration.Uid,
	}

	// TODO: implement the authenticate policies

	// TODO: or caller user has access to invoke function？
	if controller.runOptions.SimpleAuth {
		if ctx.AccountID != ctx.OwnerUser.ID {
			ctx.Logger.Warnf("invalid caller id, owner id %s caller id %s", ctx.OwnerUser.ID, ctx.AccountID)
			err = innerErr.NewInvalidInvokeCallerException(fmt.Sprintf("owner id %s caller id %s", ctx.OwnerUser.ID, ctx.AccountID), nil)
			return
		}
	}