func handleGenericConnectorTask()

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
}