Function ExtractDeployBuild

backend/plugins/bamboo/tasks/deploy_build_extractor.go:31–62

(taskCtx plugin.SubTaskContext)

var _ plugin.SubTaskEntryPoint = ExtractDeployBuild

func ExtractDeployBuild(taskCtx plugin.SubTaskContext) errors.Error {
	rawDataSubTaskArgs, data := CreateRawDataSubTaskArgs(taskCtx, RAW_DEPLOY_BUILD_TABLE)
	extractor, err := helper.NewApiExtractor(helper.ApiExtractorArgs{
		RawDataSubTaskArgs: *rawDataSubTaskArgs,

		Extract: func(resData *helper.RawData) ([]interface{}, errors.Error) {
			res := &models.ApiBambooDeployBuild{}
			err := errors.Convert(json.Unmarshal(resData.Data, res))
			if err != nil {
				return nil, err
			}

			input := &InputForEnv{}
			err = errors.Convert(json.Unmarshal(resData.Input, input))
			if err != nil {
				return nil, err
			}

			builds := res.Convert(data.Options, input.Name)
			var result []interface{}
			for _, build := range builds {
				result = append(result, build)
			}
			return result, nil
		},
	})
	if err != nil {
		return err
	}

	return extractor.Execute()
}

var ExtractDeployBuildMeta = plugin.SubTaskMeta{
	Name:             "ExtractDeployBuild",