Workflow event capability

[ferglor]

The idea with this capability is that we want to be able to define custom events at the workflow level, using outputs of other capabilities in the event body. Some pseudo code to highlight what we think we'd need:

workflow := NewWorkflow()

httpTrigger := NewHTTPTrigger(workflow)

beholderCapability := NewBeholderCapabilitiy(workflow, map[string]any{
    "service":"httpTrigger",
    "result": httpTrigger.Output(),
})

Currently, I'm not able to define a structure in the schema that would let me construct an arbitrary map for the event data in this way; should I instead be using a compute capability to tie the event data together and feed that into the beholder capability?

Update

After some discussion with @nolag, we're now able to use an "any map" as input to the capability. This capability has been tested based on the steps outlined in this doc: https://smartcontract-it.atlassian.net/wiki/spaces/CAP/pages/1048478592/Testing+the+beholder+capability

Example workflow definition:

name: 'workfloe2'
owner: '0x00000000000000000000000000000000000000aa'
triggers:
 - id: 'cron-trigger@1.0.0'
   config:
     schedule: '*/10 * * * * *'

targets:
 - id: 'beholder-target@1.0.0'
   config:
     test: test
   inputs:
     payload:
       test: '$(trigger.outputs)'

Example use in integration/unit tests:

beholdertarget.TargetConfig{}.New(workflow, beholdertarget.TargetInput{
    Payload: sdk.AnyMap[beholdertarget.TargetInputsPayload](
        sdk.CapMap{
            "test": sdk.ConstantDefinition[string]("test"),
            "foo":  trigger.Body(),
        },
    ),
})

[cedric-cordenier]

You could simplify this with:

myStruct := &struct{Payload: *values.Map}{}
err := request.Inputs.UnwrapTo(myStruct)

[pkcll]

Please add beholder_domain, beholder_entity attributes
For more context https://chainlink-core.slack.com/archives/C06QQCU1SGH/p1729618194371929

[ferglor]

@pkcll Are these values correct for domain and entity? From the slack thread, it seems that the entity name is derived from the name of the .proto file that defines the type; the type used here (Map) is defined in this file: https://github.com/smartcontractkit/chainlink-common/blob/main/pkg/values/pb/values.proto#L30

[DeividasK]

A few minor comments, but overall LGTM. Happy to approve when Sonar is fixed (already pinged Alex).