added helper functions for programmatic use

Author: pk910

pkg/coordinator/scheduler/options.go

@@ -27,9 +27,9 @@ type TaskOptsSettings struct {
 	Timeout human.Duration `yaml:"timeout" json:"timeout"`
 }
 
-func (ts *TaskScheduler) NewTaskOptions(task *types.TaskDescriptor, config interface{}, settings *TaskOptsSettings) (*types.TaskOptions, error) {
+func (ts *TaskScheduler) NewTaskOptions(task string, config interface{}, settings *TaskOptsSettings) *types.TaskOptions {
 	options := &types.TaskOptions{
-		Name: task.Name,
+		Name: task,
 	}
 
 	if settings != nil {
@@ -41,14 +41,18 @@ func (ts *TaskScheduler) NewTaskOptions(task *types.TaskDescriptor, config inter
 	if config != nil {
 		configYaml, err := yaml.Marshal(config)
 		if err != nil {
-			return nil, fmt.Errorf("error serializing task config: %w", err)
-		}
-
-		err = yaml.Unmarshal(configYaml, options.Config)
-		if err != nil {
-			return nil, fmt.Errorf("error parsing task config: %w", err)
+			ts.logger.Errorf("failed marshalling task options: %v", err)
+		} else {
+			configRaw := helper.RawMessage{}
+
+			err = yaml.Unmarshal(configYaml, &configRaw)
+			if err != nil {
+				ts.logger.Errorf("failed unmarshalling task options: %v", err)
+			} else {
+				options.Config = &configRaw
+			}
 		}
 	}
 
-	return options, nil
+	return options
 }

pkg/coordinator/scheduler/services.go

@@ -0,0 +1,34 @@
+package scheduler
+
+import (
+	"github.com/ethpandaops/assertoor/pkg/coordinator/clients"
+	"github.com/ethpandaops/assertoor/pkg/coordinator/names"
+	"github.com/ethpandaops/assertoor/pkg/coordinator/types"
+	"github.com/ethpandaops/assertoor/pkg/coordinator/wallet"
+)
+
+type servicesProvider struct {
+	clientPool     *clients.ClientPool
+	walletManager  *wallet.Manager
+	validatorNames *names.ValidatorNames
+}
+
+func NewServicesProvider(clientPool *clients.ClientPool, walletManager *wallet.Manager, validatorNames *names.ValidatorNames) types.TaskServices {
+	return &servicesProvider{
+		clientPool:     clientPool,
+		walletManager:  walletManager,
+		validatorNames: validatorNames,
+	}
+}
+
+func (p *servicesProvider) ClientPool() *clients.ClientPool {
+	return p.clientPool
+}
+
+func (p *servicesProvider) WalletManager() *wallet.Manager {
+	return p.walletManager
+}
+
+func (p *servicesProvider) ValidatorNames() *names.ValidatorNames {
+	return p.validatorNames
+}