Function managedWarehouseUpsertColumns

controlplane/admin/api.go:405–457

()

// errOrgTeamExists distinguishes the (org, team) primary-key conflict from
// the schema-name conflict on the admin create endpoint — the admin surface
// never overwrites an existing row (that's the internal provisioning
// grandfather path), so an existing row is a 409, not an upsert.
var errOrgTeamExists = errors.New("team already exists in this org")

// orgTeamUpdate carries the admin-editable fields of one org team — every
// column, this is the operator break-glass surface. Pointer fields are
// presence-aware (nil = preserve). The *Set booleans distinguish an explicit
// JSON null (clear to unset/NULL) from an absent key for the nullable columns.
type orgTeamUpdate struct {
	// SchemaName: nil = preserve. A non-nil value is the operator override —
	// validated by the handler, refused with ErrOrgTeamSchemaConflict when
	// another team in the org already uses it. Changing it does NOT move any
	// warehouse data; tables under the old schema are not renamed.
	SchemaName *string
	Enabled    *bool
	// Backfill: nil = preserve. The column is NOT NULL (migration 000028), so
	// there is no clear path — the handler rejects an explicit null.
	Backfill *bool
	// Legacy explicit table names for grandfathered teams (NULL = derive from
	// schema_name). XSet + nil value clears the column back to NULL.
	EventsTableNameSet       bool
	EventsTableName          *string
	PersonsTableNameSet      bool
	PersonsTableName         *string
	SchemaDataImportsNameSet bool
	SchemaDataImportsName    *string
	// EarliestEventDate: PostHog's cached backfill floor (a cache owned by
	// PostHog's sensor — see configstore.OrgTeam.EarliestEventDate). Set + nil
	// clears the column back to NULL, making the sensor re-resolve it.
	EarliestEventDateSet bool
	EarliestEventDate    *configstore.EventDate
}

func (s *gormAPIStore) ListAllOrgTeams() ([]configstore.OrgTeam, error) {
	var teams []configstore.OrgTeam
	if err := s.db().Order("org_id, team_id").Find(&teams).Error; err != nil {
		return nil, err
	}
	return teams, nil
}

func (s *gormAPIStore) CreateOrgTeam(orgID string, team *configstore.OrgTeam) error {
	return s.db().Transaction(func(tx *gorm.DB) error {
		var orgCount int64
		if err := tx.Model(&configstore.Org{}).Where("name = ?", orgID).Count(&orgCount).Error; err != nil {
			return err
		}
		if orgCount == 0 {
			return gorm.ErrRecordNotFound
		}
		var dup int64
		if err := tx.Model(&configstore.OrgTeam{}).
			Where("org_id = ? AND team_id = ?", orgID, team.TeamID).Count(&dup).Error; err != nil {
			return err
		}