Method PushEnv

runtime/server/env.go:16–98

(ctx context.Context, req *runtimev1.PushEnvRequest)

)

func (s *Server) PushEnv(ctx context.Context, req *runtimev1.PushEnvRequest) (*runtimev1.PushEnvResponse, error) {
	if !auth.GetClaims(ctx, req.InstanceId).Can(runtime.EditRepo) {
		return nil, ErrForbidden
	}

	inst, err := s.runtime.Instance(ctx, req.InstanceId)
	if err != nil {
		return nil, err
	}

	repo, release, err := s.runtime.Repo(ctx, req.InstanceId)
	if err != nil {
		return nil, err
	}
	defer release()

	admin, release, err := s.runtime.Admin(ctx, req.InstanceId)
	if err != nil {
		return nil, err
	}
	defer release()

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

	localPerEnv := p.GetDotEnvPerEnvironment()

	// Fetch existing cloud variables
	cfg, err := admin.GetConfig(ctx)
	if err != nil && !errors.Is(err, drivers.ErrNotAuthenticated) {
		return nil, fmt.Errorf("failed to get project variables: %w", err)
	}
	var cloudPerEnv map[string]map[string]string
	if cfg != nil {
		cloudPerEnv = cfg.Variables
	}
	if cloudPerEnv == nil {
		cloudPerEnv = make(map[string]map[string]string)
	}

	var addedCount, changedCount int32

	for env, local := range localPerEnv {
		if env != "" && env != inst.Environment {
			// only allow pushing base variables or variables for the current environment
			continue
		}
		cloud := cloudPerEnv[env]

		// Merge: start with cloud, overlay local; track what changed
		merged := make(map[string]string)
		maps.Copy(merged, cloud)
		var added, changed int32
		for k, v := range local {
			if _, exists := cloud[k]; !exists {