Method UpdateProjects

backend/store/project.go:275–324

UpdateProjects updates projects in a single transaction.

(ctx context.Context, patches ...*UpdateProjectMessage)

// UpdateProjects updates projects in a single transaction.
func (s *Store) UpdateProjects(ctx context.Context, patches ...*UpdateProjectMessage) error {
	if len(patches) == 0 {
		return nil
	}

	// Remove all projects from cache first
	for _, patch := range patches {
		s.removeProjectCache(patch.ResourceID)
	}

	// Prepare arrays for batch update
	resourceIDs := make([]string, len(patches))
	titles := make([]*string, len(patches))
	deleteds := make([]*bool, len(patches))
	settings := make([]*string, len(patches))

	for i, patch := range patches {
		resourceIDs[i] = patch.ResourceID
		titles[i] = patch.Title
		deleteds[i] = patch.Delete
		if patch.Setting != nil {
			payload, err := protojson.Marshal(patch.Setting)
			if err != nil {
				return err
			}
			settings[i] = new(string(payload))
		}
	}

	// Batch update using UPDATE FROM unnest
	q := qb.Q().Space(`
		UPDATE project AS p SET
			name = COALESCE(u.name, p.name),
			deleted = COALESCE(u.deleted, p.deleted),
			setting = COALESCE(u.setting::jsonb, p.setting)
		FROM unnest(?::text[], ?::text[], ?::bool[], ?::text[]) AS u(resource_id, name, deleted, setting)
		WHERE p.resource_id = u.resource_id AND p.workspace = ?
	`, resourceIDs, titles, deleteds, settings, patches[0].Workspace)

	query, args, err := q.ToSQL()
	if err != nil {
		return err
	}

	if _, err := s.GetDB().ExecContext(ctx, query, args...); err != nil {
		return err
	}

	return nil
}

func (s *Store) storeProjectCache(project *ProjectMessage) {
	s.projectCache.Add(project.ResourceID, project)