in internal/client/integrations/overrides.go [462:499]
func handleGenericConnectorTask(taskConfig taskconfig, taskOverrides *overrides, iconfigParam []parameterConfig) error {
co := connectionoverrides{}
co.TaskId = taskConfig.TaskId
co.Task = taskConfig.Task
cparams, ok := taskConfig.Parameters["config"]
connectionNameparams, okConnectionName := taskConfig.Parameters["connectionName"]
if !ok && !okConnectionName {
return nil
}
if connectionNameparams.Key == "connectionName" {
if connectionNameparams.Value.StringValue != nil {
connectionName, err := getConnectionStringFromConnectionName(*connectionNameparams.Value.StringValue, iconfigParam)
if err != nil {
return err
}
parts := strings.Split(connectionName, "/")
connName := parts[len(parts)-1]
co.Parameters.ConnectionName = connName
}
} else if (eventparameter{}) != cparams && ok {
if cparams.Value.JsonValue != nil {
cd, err := getConnectionDetails(*cparams.Value.JsonValue)
if err != nil {
return err
}
parts := strings.Split(cd.Connection.ConnectionName, "/")
connName := parts[len(parts)-1]
co.Parameters.ConnectionName = connName
}
}
taskOverrides.ConnectionOverrides = append(taskOverrides.ConnectionOverrides, co)
return nil
}