Function ValidateJobV2

api/handler/v2/validation.go:28–68

@Id ValidateJobV2 @Description validate job config. @Tags validation @Accept application/json @Security ApiKeyAuth @Param job_config body models.ValidateJobReqV2 true "validate job config" @Success 200 {object} models.ValidateJobRespV2 @Router /v2/validation/job [post]

(c echo.Context)

// @Success 200 {object} models.ValidateJobRespV2
// @Router /v2/validation/job [post]
func ValidateJobV2(c echo.Context) error {
	logger := handler.NewLogger().Named("ValidateJobV2")
	reqParam := new(models.ValidateJobReqV2)
	if err := handler.BindAndValidate(logger, c, reqParam); err != nil {
		return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(err))
	}

	reqJson, err := apiJobConfigToNomadJobJson(reqParam)
	if nil != err {
		return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("convert param failed: %v", err)))
	}

	url := handler.BuildUrl("/v1/validate/job")
	logger.Info("invoke nomad api begin", "url", url)
	nomadValidateResp := nomadApi.JobValidateResponse{}
	if err := handler.InvokePostApiWithJson(url, reqJson, &nomadValidateResp); nil != err {
		return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("invoke nomad api %v failed: %v", url, err)))
	}
	logger.Info("invoke nomad api finished")
	logger.Info("validate task config")
	// decrypt mysql password
	if reqParam.IsPasswordEncrypted {
		err := decryptMySQLPwd(reqParam.SrcTaskConfig, reqParam.DestTaskConfig)
		if nil != err {
			return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(err))
		}
	}

	validationTasks, err := validateTaskConfig(reqParam.SrcTaskConfig, reqParam.DestTaskConfig)
	if nil != err {
		return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("validate task config failed: %v", err)))
	}

	return c.JSON(http.StatusOK, &models.ValidateJobRespV2{
		DriverConfigValidated: nomadValidateResp.DriverConfigValidated,
		MysqlValidationTasks:  validationTasks,
		JobValidationError:    nomadValidateResp.Error,
		JobValidationWarning:  nomadValidateResp.Warnings,
		BaseResp:              models.BuildBaseResp(nil),
	})
}

func apiJobConfigToNomadJobJson(apiJobConfig *models.ValidateJobReqV2) (resJson []byte, err error) {
	nomadJob, err := convertJobToNomadJob(true, &models.CreateOrUpdateMysqlToMysqlJobParamV2{JobId: apiJobConfig.JobId, SrcTask: apiJobConfig.SrcTaskConfig, DestTask: apiJobConfig.DestTaskConfig})