[CLD-354]: feat(operation): support execution of dynamic operation

[graham-chainlink]

To enhance the flexibility of Operations API, we want to support dynamic execution of Operation.

Based on the operation definition, we can decide on run time what operations to execute and what input and deps to pass in to that operation. This can be quite powerful to allow users to dynamically construct a series of operation under a sequence.

Refer to this example code snippet:

func ExampleOperationRegistry() {
	type Deps1 struct{}
	type Deps2 struct{}

	// Create operations with different input/output types
	stringOp := NewOperation(
		"string-op",
		semver.MustParse("1.0.0"),
		"Echo string operation",
		func(e Bundle, deps Deps1, input string) (string, error) {
			return input, nil
		},
	)

	intOp := NewOperation(
		"int-op",
		semver.MustParse("1.0.0"),
		"Echo integer operation",
		func(e Bundle, deps Deps2, input int) (int, error) {
			return input, nil
		},
	)
	// Create registry with untyped operations by providing optional initial operation
	registry := NewOperationRegistry(stringOp.AsUntyped())

	// An alternative way to register additional operations without calling AsUntyped()
	RegisterOperation(registry, intOp)

	// Create execution environment
	b := NewBundle(context.Background, logger.Nop(), NewMemoryReporter(), WithOperationRegistry(registry))

	inputs := []any{"input1", 42}
	deps := []any{Deps1{}, Deps2{}}
	defs := []Definition{
		stringOp.Def(),
		intOp.Def(),
	}

	// dynamically retrieve and execute operations on different inputs
	for i, def := range defs {
		retrievedOp, err := registry.Retrieve(def)
		if err != nil {
			fmt.Println("error retrieving operation:", err)
			continue
		}

		report, err := ExecuteOperation(b, retrievedOp, deps[i], inputs[i])
		if err != nil {
			fmt.Println("error executing operation:", err)
			continue
		}

		fmt.Println("operation output:", report.Output)
	}

	// Output:
	// operation output: input1
	// operation output: 42
}

JIRA: https://smartcontract-it.atlassian.net/browse/CLD-354

[changeset-bot]

🦋 Changeset detected

Latest commit: f23f6b6

The changes in this PR will be included in the next version bump.

This PR includes changesets to release 1 package

Name	Type
chainlink-deployments-framework	Minor

Not sure what this means? Click here to learn what changesets are.

Click here if you're a maintainer who wants to add another changeset to this PR

[RodrigoAD]

Thanks @graham-chainlink ! LGTM :)

[DimitriosNaikopoulos]

This is more of a question.

Could NewOperationRegistry call AsUntyped() to any provided inputs? Then the user doesn't have to remember doing that for every input 🤔

[graham-chainlink]

Could NewOperationRegistry call AsUntyped() to any provided inputs?

haha well for NewOperationRegistry to accept any input in the first place, we have to call AsUntyped to convert it into any type.

so we cant do

r := NewOperationRegistry(stringOp, intOp)
// then call untype inside 

because the parameter NewOperationRegistry has to be any type in order to accept any operations as each operation has different types for input, output if that make sense

[graham-chainlink]

alright added a helper

         // Create registry with untyped operations by providing optional initial operation
	registry := NewOperationRegistry(stringOp.AsUntyped())

	// An alternative way to register additional operations without calling AsUntyped()
	RegisterOperation(registry, intOp)

[cl-sonarqube-production]

Quality Gate passed

Issues
0 New issues
0 Fixed issues
0 Accepted issues

Measures
0 Security Hotspots
100.0% Coverage on New Code
0.0% Duplication on New Code

See analysis details on SonarQube