Function ExtractDeploy

backend/plugins/bamboo/tasks/deploy_extractor.go:31–61

(taskCtx plugin.SubTaskContext)

var _ plugin.SubTaskEntryPoint = ExtractDeploy

func ExtractDeploy(taskCtx plugin.SubTaskContext) errors.Error {
	rawDataSubTaskArgs, data := CreateRawDataSubTaskArgs(taskCtx, RAW_DEPLOY_TABLE)

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

			var results []interface{}
			if res.PlanKey.Key == data.Options.PlanKey {
				for _, apiEnv := range res.Environments {
					env := new(models.BambooDeployEnvironment)
					env.Convert(&apiEnv)
					env.ConnectionId = data.Options.ConnectionId
					env.PlanKey = res.PlanKey.Key
					results = append(results, env)
				}
			}
			return results, nil
		},
	})
	if err != nil {
		return err
	}

	return extractor.Execute()
}

var ExtractDeployMeta = plugin.SubTaskMeta{
	Name:             "ExtractDeploy",