Method Run

cmd/sync.go:117–277

Run executes the command logic

(f factory.Factory)

// Run executes the command logic
func (cmd *SyncCmd) Run(f factory.Factory) error {
	if cmd.Ctx == nil {
		var cancelFn context.CancelFunc
		cmd.Ctx, cancelFn = context.WithCancel(context.Background())
		defer cancelFn()
	}

	// Switch working directory
	if cmd.ConfigPath != "" {
		_, err := os.Stat(cmd.ConfigPath)
		if err != nil {
			return errors.Errorf("--config is specified, but config %s cannot be loaded: %v", cmd.GlobalFlags.ConfigPath, err)
		}
	}

	// Load generated config if possible
	var err error
	var localCache localcache.Cache
	logger := f.GetLog()
	configOptions := cmd.ToConfigOptions()
	configLoader, err := f.NewConfigLoader(cmd.ConfigPath)
	if err != nil {
		return err
	}
	if configLoader.Exists() {
		if cmd.GlobalFlags.ConfigPath != "" {
			configExists, err := configLoader.SetDevSpaceRoot(logger)
			if err != nil {
				return err
			} else if !configExists {
				return errors.New(message.ConfigNotFound)
			}

			localCache, err = configLoader.LoadLocalCache()
			if err != nil {
				return err
			}
		} else {
			logger.Warnf("If you want to use the sync paths from `devspace.yaml`, use the `DEVSPACE_CONFIG=devspace.yaml` environment variable for this command.")
		}
	}

	// Get config with adjusted cluster config
	client, err := f.NewKubeClientFromContext(cmd.KubeContext, cmd.Namespace)
	if err != nil {
		return errors.Wrap(err, "new kube client")
	}

	// If the current kube context or namespace is different from old,
	// show warnings and reset kube client if necessary
	client, err = kubectl.CheckKubeContext(client, localCache, cmd.NoWarn, cmd.SwitchContext, false, logger)
	if err != nil {
		return err
	}

	var configInterface config.Config
	if configLoader.Exists() && cmd.GlobalFlags.ConfigPath != "" {
		configInterface, err = configLoader.LoadWithCache(context.Background(), localCache, client, configOptions, logger)