diff --git a/trigger/context.go b/trigger/context.go index 4df94fa..b3c098a 100644 --- a/trigger/context.go +++ b/trigger/context.go @@ -25,3 +25,22 @@ func HandlerFromContext(ctx context.Context) (*HandlerInfo, bool) { u, ok := ctx.Value(handlerKey).(*HandlerInfo) return u, ok } + +// This allows trigger developer to pass request parameters to handler w/o going through output mapper, e.g., +// ctx := trigger.NewContextWithValues(context.Background(), values) +// results, err := handler.Handle(ctx, triggerData.ToMap()) + +type valueKey string + +const contextValueKey valueKey = "values" + +// NewContextWithValues returns a new Context that carries specified request parameter values +func NewContextWithValues(ctx context.Context, values map[string]interface{}) context.Context { + return context.WithValue(ctx, contextValueKey, values) +} + +// ValuesFromContext extracts request parameters from a context +func ValuesFromContext(ctx context.Context) (map[string]interface{}, bool) { + values, ok := ctx.Value(contextValueKey).(map[string]interface{}) + return values, ok +} diff --git a/trigger/handler.go b/trigger/handler.go index a1e7576..0b25d98 100644 --- a/trigger/handler.go +++ b/trigger/handler.go @@ -192,6 +192,13 @@ func (h *handlerImpl) Handle(ctx context.Context, triggerData interface{}) (resu inputMap = triggerValues } + // extract request parameters from trigger context, and make them available in actions + if reqParams, ok := ValuesFromContext(ctx); ok { + for k, v := range reqParams { + inputMap[k] = v + } + } + if ioMd := act.act.IOMetadata(); ioMd != nil { for name, tv := range ioMd.Input { if val, ok := inputMap[name]; ok {