Method Execute

command/v7/create_service_command.go:64–110

(args []string)

}

func (cmd CreateServiceCommand) Execute(args []string) error {
	if err := cmd.SharedActor.CheckTarget(true, true); err != nil {
		return err
	}

	cmd.RequiredArgs.ServiceInstance = strings.TrimSpace(cmd.RequiredArgs.ServiceInstance)

	if err := cmd.displayCreatingMessage(); err != nil {
		return err
	}

	stream, warnings, err := cmd.Actor.CreateManagedServiceInstance(
		v7action.CreateManagedServiceInstanceParams{
			ServiceOfferingName: cmd.RequiredArgs.ServiceOffering,
			ServicePlanName:     cmd.RequiredArgs.ServicePlan,
			ServiceInstanceName: cmd.RequiredArgs.ServiceInstance,
			ServiceBrokerName:   cmd.ServiceBroker,
			SpaceGUID:           cmd.Config.TargetedSpace().GUID,
			Tags:                types.OptionalStringSlice(cmd.Tags),
			Parameters:          types.OptionalObject(cmd.ParametersAsJSON),
		},
	)
	cmd.UI.DisplayWarnings(warnings)
	switch err.(type) {
	case nil:
	case ccerror.ServiceInstanceNameTakenError:
		cmd.UI.DisplayOK()
		cmd.UI.DisplayTextWithFlavor("Service instance {{.ServiceInstanceName}} already exists", cmd.serviceInstanceName())
		return nil
	default:
		return err
	}

	cmd.UI.DisplayNewline()
	complete, err := shared.WaitForResult(stream, cmd.UI, cmd.Wait)
	switch {
	case err != nil:
		return err
	case complete:
		cmd.UI.DisplayTextWithFlavor("Service instance {{.ServiceInstanceName}} created.", cmd.serviceInstanceName())
	default:
		cmd.UI.DisplayTextWithFlavor("Create in progress. Use 'cf services' or 'cf service {{.ServiceInstanceName}}' to check operation status.", cmd.serviceInstanceName())
	}

	cmd.UI.DisplayOK()
	return nil
}

func (cmd CreateServiceCommand) displayCreatingMessage() error {
	user, err := cmd.Actor.GetCurrentUser()