Method pullEnv

runtime/runtime.go:279–344

(ctx context.Context, instanceID string)

}

func (r *Runtime) pullEnv(ctx context.Context, instanceID string) (int, bool, error) {
	inst, err := r.Instance(ctx, instanceID)
	if err != nil {
		return 0, false, err
	}

	repo, release, err := r.Repo(ctx, instanceID)
	if err != nil {
		return 0, false, err
	}
	defer release()

	// Fetch cloud variables if an admin connector is configured (not configured only for tests)
	var cloudPerEnv map[string]map[string]string
	if inst.AdminConnector != "" {
		admin, release, err := r.Admin(ctx, instanceID)
		if err != nil {
			return 0, false, err
		}
		defer release()

		cfg, err := admin.GetConfig(ctx)
		if err != nil && !errors.Is(err, drivers.ErrNotAuthenticated) {
			return 0, false, fmt.Errorf("failed to get project variables: %w", err)
		}
		if cfg != nil {
			cloudPerEnv = cfg.Variables
		}
	}

	// Parse local .env files
	p, err := parser.Parse(ctx, repo, instanceID, inst.Environment, inst.OLAPConnector, false)
	if err != nil {
		return 0, false, fmt.Errorf("failed to parse project: %w", err)
	}

	localPerEnv := p.GetDotEnvPerEnvironment()

	// Check if all environments are already up to date
	equal := true
	totalCount := 0
	for env, cloudVars := range cloudPerEnv {
		totalCount += len(cloudVars)
		if !maps.Equal(cloudVars, localPerEnv[env]) {
			equal = false
			break
		}
	}

	if equal {
		return totalCount, false, nil
	}

	// Write merged variables per environment
	for env, cloudVars := range cloudPerEnv {
		merged := make(map[string]string)
		maps.Copy(merged, localPerEnv[env])
		maps.Copy(merged, cloudVars)