@@ -263,64 +263,64 @@ func GetEnvironments(cxt context.Context, rpc *coconut.RpcClient, cmd *cobra.Com
263263}
264264
265265func CreateEnvironment (cxt context.Context , rpc * coconut.RpcClient , cmd * cobra.Command , args []string , o io.Writer ) (err error ) {
266- configPayload , err := cmd .Flags ().GetString ("configuration" )
266+ configPayloadPath , err := cmd .Flags ().GetString ("configuration" )
267267 if err != nil {
268- return fmt .Errorf ("cannot get configuration payload value: %w" , err )
268+ return fmt .Errorf ("cannot get configuration payload path value: %w" , err )
269269 }
270270 userWfPath , err := cmd .Flags ().GetString ("workflow-template" )
271271 if err != nil {
272- return fmt .Errorf ("cannot get workflow template value: %w" , err )
272+ return fmt .Errorf ("cannot get workflow template path value: %w" , err )
273273 }
274- if cmd .Flags ().Changed ("configuration" ) && len (configPayload ) == 0 && cmd .Flags ().Changed ("workflow-template" ) && len (userWfPath ) == 0 {
275- return fmt .Errorf ("no configuration payload or workflow template provided: %w" , err )
274+ if cmd .Flags ().Changed ("configuration" ) && len (configPayloadPath ) == 0 && cmd .Flags ().Changed ("workflow-template" ) && len (userWfPath ) == 0 {
275+ return fmt .Errorf ("no configuration payload path or workflow template path provided: %w" , err )
276276 }
277277
278278 payloadData := new (ConfigurationPayload )
279279 var wfPath string
280- if cmd .Flags ().Changed ("configuration" ) && len (configPayload ) > 0 {
281- if strings .HasSuffix (strings .ToLower (configPayload ), ".json" ) {
282- configPayloadDoc , err := os .ReadFile (configPayload )
280+ if cmd .Flags ().Changed ("configuration" ) && len (configPayloadPath ) > 0 {
281+ if strings .HasSuffix (strings .ToLower (configPayloadPath ), ".json" ) {
282+ configPayloadDoc , err := os .ReadFile (configPayloadPath )
283283 if err != nil {
284- return fmt .Errorf ("cannot read local configuration payload : %w" , err )
284+ return fmt .Errorf ("cannot read local configuration file %v : %w" , configPayloadPath , err )
285285 }
286286 err = json .Unmarshal (configPayloadDoc , & payloadData )
287287 if err != nil {
288- return fmt .Errorf ("cannot unmarshal local configuration payload : %w" , err )
288+ return fmt .Errorf ("cannot unmarshal local configuration file %v : %w" , configPayloadPath , err )
289289 }
290290 } else {
291- if strings .HasPrefix (configPayload , HLCONFIG_PATH_PREFIX + HLCONFIG_COMPONENT_PREFIX ) {
292- configPayload = strings .TrimPrefix (configPayload , HLCONFIG_PATH_PREFIX + HLCONFIG_COMPONENT_PREFIX )
291+ if strings .HasPrefix (configPayloadPath , HLCONFIG_PATH_PREFIX + HLCONFIG_COMPONENT_PREFIX ) {
292+ configPayloadPath = strings .TrimPrefix (configPayloadPath , HLCONFIG_PATH_PREFIX + HLCONFIG_COMPONENT_PREFIX )
293293 }
294- configPayloadDoc , err := apricot .Instance ().GetRuntimeEntry (HLCONFIG_COMPONENT_PREFIX , configPayload )
294+ configPayloadDoc , err := apricot .Instance ().GetRuntimeEntry (HLCONFIG_COMPONENT_PREFIX , configPayloadPath )
295295 if err != nil {
296- return fmt .Errorf ("cannot retrieve file from " + HLCONFIG_PATH_PREFIX + HLCONFIG_COMPONENT_PREFIX + ": %w" , err )
296+ return fmt .Errorf ("cannot retrieve file %v from " + HLCONFIG_PATH_PREFIX + HLCONFIG_COMPONENT_PREFIX + ": %w" , configPayloadPath , err )
297297 }
298298 err = json .Unmarshal ([]byte (configPayloadDoc ), & payloadData )
299299 if err != nil {
300- return fmt .Errorf ("cannot unmarshal remote configuration payload: %w" , err )
300+ return fmt .Errorf ("cannot unmarshal remote configuration payload %v : %w" , configPayloadPath , err )
301301 }
302302 }
303303
304304 if cmd .Flags ().Changed ("workflow-template" ) && len (userWfPath ) == 0 {
305305 if len (payloadData .Workflow ) > 0 {
306306 wfPath = payloadData .Workflow
307307 } else {
308- return errors .New ("empty workflow template provided" )
308+ return errors .New ("empty workflow template in configuration payload, and empty workflow template path provided" )
309309 }
310310 } else if cmd .Flags ().Changed ("workflow-template" ) && len (userWfPath ) > 0 {
311311 wfPath = userWfPath
312312 } else {
313313 if len (payloadData .Workflow ) > 0 {
314314 wfPath = payloadData .Workflow
315315 } else {
316- return errors .New ("no workflow template provided in config file " )
316+ return errors .New ("no workflow template provided in configuration payload " )
317317 }
318318 }
319319 } else {
320320 if cmd .Flags ().Changed ("workflow-template" ) && len (userWfPath ) > 0 {
321321 wfPath = userWfPath
322322 } else {
323- return errors .New ("empty workflow template provided" )
323+ return errors .New ("empty workflow template path provided" )
324324 }
325325 }
326326
@@ -345,7 +345,7 @@ func CreateEnvironment(cxt context.Context, rpc *coconut.RpcClient, cmd *cobra.C
345345 for k , v := range userExtraVarsMap {
346346 extraVarsMap [k ] = v
347347 }
348- if cmd .Flags ().Changed ("configuration" ) && len (configPayload ) > 0 {
348+ if cmd .Flags ().Changed ("configuration" ) && len (configPayloadPath ) > 0 {
349349 for k , v := range payloadData .Vars {
350350 if _ , exists := extraVarsMap [k ]; ! exists {
351351 extraVarsMap [k ] = v
0 commit comments