TheArchive/zitadel
1
0
Fork 0
mirror of https://github.com/zitadel/zitadel.git synced 2025-08-11 15:49:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

sql

Browse Source
This commit is contained in:
adlerhurst
2025-07-16 18:36:21 +02:00
parent d63fe8e227
commit a0329bd221
5 changed files with 133 additions and 80 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
backend/v3/domain/instance_domain.go
View File

@@ -2,6 +2,7 @@ package domain
import ( import (
"context" "context"
"time"
"github.com/zitadel/zitadel/backend/v3/storage/database" "github.com/zitadel/zitadel/backend/v3/storage/database"
) )
@@ -23,6 +24,13 @@ type AddInstanceDomain struct {
IsVerified bool `json:"isVerified,omitempty" db:"is_verified"` IsVerified bool `json:"isVerified,omitempty" db:"is_verified"`
IsPrimary bool `json:"isPrimary,omitempty" db:"is_primary"` IsPrimary bool `json:"isPrimary,omitempty" db:"is_primary"`
VerificationType DomainVerificationType `json:"verificationType,omitempty" db:"verification_type"` VerificationType DomainVerificationType `json:"verificationType,omitempty" db:"verification_type"`
// CreatedAt is the time when the domain was added.
// It is set by the repository and should not be set by the caller.
CreatedAt time.Time `json:"createdAt,omitzero" db:"created_at"`
// UpdatedAt is the time when the domain was last updated.
// It is set by the repository and should not be set by the caller.
UpdatedAt time.Time `json:"updatedAt,omitzero" db:"updated_at"`
} }
type instanceDomainColumns interface { type instanceDomainColumns interface {
@@ -47,7 +55,7 @@ type InstanceDomainRepository interface {
// Add adds a new domain to the instance. // Add adds a new domain to the instance.
Add(ctx context.Context, domain *AddInstanceDomain) error Add(ctx context.Context, domain *AddInstanceDomain) error
// Update updates an existing domain in the instance. // Update updates an existing domain in the instance.
Update(ctx context.Context, condition database.Condition, changes ...database.Change) error Update(ctx context.Context, condition database.Condition, changes ...database.Change) (int64, error)
// Remove removes a domain from the instance. // Remove removes a domain from the instance.
Remove(ctx context.Context, condition database.Condition) error Remove(ctx context.Context, condition database.Condition) (int64, error)
} }

12
backend/v3/domain/organization_domain.go
View File

@@ -2,6 +2,7 @@ package domain
import ( import (
"context" "context"
"time"
"github.com/zitadel/zitadel/backend/v3/storage/database" "github.com/zitadel/zitadel/backend/v3/storage/database"
) )
@@ -25,6 +26,13 @@ type AddOrganizationDomain struct {
IsVerified bool `json:"isVerified,omitempty" db:"is_verified"` IsVerified bool `json:"isVerified,omitempty" db:"is_verified"`
IsPrimary bool `json:"isPrimary,omitempty" db:"is_primary"` IsPrimary bool `json:"isPrimary,omitempty" db:"is_primary"`
VerificationType DomainVerificationType `json:"verificationType,omitempty" db:"verification_type"` VerificationType DomainVerificationType `json:"verificationType,omitempty" db:"verification_type"`
// CreatedAt is the time when the domain was added.
// It is set by the repository and should not be set by the caller.
CreatedAt time.Time `json:"createdAt,omitzero" db:"created_at"`
// UpdatedAt is the time when the domain was added.
// It is set by the repository and should not be set by the caller.
UpdatedAt time.Time `json:"updatedAt,omitzero" db:"updated_at"`
} }
type organizationDomainColumns interface { type organizationDomainColumns interface {
@@ -51,7 +59,7 @@ type OrganizationDomainRepository interface {
// Add adds a new domain to the organization. // Add adds a new domain to the organization.
Add(ctx context.Context, domain *AddOrganizationDomain) error Add(ctx context.Context, domain *AddOrganizationDomain) error
// Update updates an existing domain in the organization. // Update updates an existing domain in the organization.
Update(ctx context.Context, condition database.Condition, changes ...database.Change) error Update(ctx context.Context, condition database.Condition, changes ...database.Change) (int64, error)
// Remove removes a domain from the organization. // Remove removes a domain from the organization.
Remove(ctx context.Context, condition database.Condition) error Remove(ctx context.Context, condition database.Condition) (int64, error)
} }

88
backend/v3/storage/database/repository/instance_domain.go
View File

@@ -20,18 +20,38 @@ type instanceDomain struct {
// Add implements [domain.InstanceDomainRepository]. // Add implements [domain.InstanceDomainRepository].
func (i *instanceDomain) Add(ctx context.Context, domain *domain.AddInstanceDomain) error { func (i *instanceDomain) Add(ctx context.Context, domain *domain.AddInstanceDomain) error {
panic("unimplemented") var builder database.StatementBuilder
builder.WriteString(`INSERT INTO zitadel.instance_domains (instance_id, domain, is_verified, is_primary, verification_type) ` +
`VALUES ($1, $2, $3, $4, $5)` +
` RETURNING created_at, updated_at`)
builder.AppendArgs(domain.InstanceID, domain.Domain, domain.IsVerified, domain.IsPrimary, domain.VerificationType)
return i.client.QueryRow(ctx, builder.String(), builder.Args()...).Scan(&domain.CreatedAt, &domain.UpdatedAt)
} }
// Remove implements [domain.InstanceDomainRepository]. // Remove implements [domain.InstanceDomainRepository].
func (i *instanceDomain) Remove(ctx context.Context, condition database.Condition) error { func (i *instanceDomain) Remove(ctx context.Context, condition database.Condition) (int64, error) {
panic("unimplemented") var builder database.StatementBuilder
builder.WriteString(`DELETE FROM zitadel.instance_domains WHERE `)
writeCondition(&builder, condition)
return i.client.Exec(ctx, builder.String(), builder.Args()...)
} }
// Update implements [domain.InstanceDomainRepository]. // Update implements [domain.InstanceDomainRepository].
// Subtle: this method shadows the method (instance).Update of instanceDomain.instance. // Subtle: this method shadows the method (instance).Update of instanceDomain.instance.
func (i *instanceDomain) Update(ctx context.Context, condition database.Condition, changes ...database.Change) error { func (i *instanceDomain) Update(ctx context.Context, condition database.Condition, changes ...database.Change) (int64, error) {
panic("unimplemented") var builder database.StatementBuilder
builder.WriteString(`UPDATE zitadel.instance_domains SET `)
database.Changes(changes).Write(&builder)
writeCondition(&builder, condition)
return i.client.Exec(ctx, builder.String(), builder.Args()...)
} }
// ------------------------------------------------------------- // -------------------------------------------------------------
@@ -39,18 +59,18 @@ func (i *instanceDomain) Update(ctx context.Context, condition database.Conditio
// ------------------------------------------------------------- // -------------------------------------------------------------
// SetVerificationType implements [domain.InstanceDomainRepository]. // SetVerificationType implements [domain.InstanceDomainRepository].
func (i *instanceDomain) SetVerificationType(verificationType domain.DomainVerificationType) database.Change { func (i instanceDomain) SetVerificationType(verificationType domain.DomainVerificationType) database.Change {
panic("unimplemented") return database.NewChange(i.VerificationTypeColumn(), verificationType)
} }
// SetPrimary implements [domain.InstanceDomainRepository]. // SetPrimary implements [domain.InstanceDomainRepository].
func (i *instanceDomain) SetPrimary() database.Change { func (i instanceDomain) SetPrimary() database.Change {
panic("unimplemented") return database.NewChange(i.IsPrimaryColumn(), true)
} }
// SetVerified implements [domain.InstanceDomainRepository]. // SetVerified implements [domain.InstanceDomainRepository].
func (i *instanceDomain) SetVerified() database.Change { func (i instanceDomain) SetVerified() database.Change {
panic("unimplemented") return database.NewChange(i.IsVerifiedColumn(), true)
} }
// ------------------------------------------------------------- // -------------------------------------------------------------
@@ -58,23 +78,23 @@ func (i *instanceDomain) SetVerified() database.Change {
// ------------------------------------------------------------- // -------------------------------------------------------------
// DomainCondition implements [domain.InstanceDomainRepository]. // DomainCondition implements [domain.InstanceDomainRepository].
func (i *instanceDomain) DomainCondition(op database.TextOperation, domain string) database.Condition { func (i instanceDomain) DomainCondition(op database.TextOperation, domain string) database.Condition {
panic("unimplemented") return database.NewTextCondition(i.DomainColumn(), op, domain)
} }
// InstanceIDCondition implements [domain.InstanceDomainRepository]. // InstanceIDCondition implements [domain.InstanceDomainRepository].
func (i *instanceDomain) InstanceIDCondition(instanceID string) database.Condition { func (i instanceDomain) InstanceIDCondition(instanceID string) database.Condition {
panic("unimplemented") return database.NewTextCondition(i.InstanceIDColumn(), database.TextOperationEqual, instanceID)
} }
// IsPrimaryCondition implements [domain.InstanceDomainRepository]. // IsPrimaryCondition implements [domain.InstanceDomainRepository].
func (i *instanceDomain) IsPrimaryCondition(isPrimary bool) database.Condition { func (i instanceDomain) IsPrimaryCondition(isPrimary bool) database.Condition {
panic("unimplemented") return database.NewBooleanCondition(i.IsPrimaryColumn(), isPrimary)
} }
// IsVerifiedCondition implements [domain.InstanceDomainRepository]. // IsVerifiedCondition implements [domain.InstanceDomainRepository].
func (i *instanceDomain) IsVerifiedCondition(isVerified bool) database.Condition { func (i instanceDomain) IsVerifiedCondition(isVerified bool) database.Condition {
panic("unimplemented") return database.NewBooleanCondition(i.IsVerifiedColumn(), isVerified)
} }
// ------------------------------------------------------------- // -------------------------------------------------------------
@@ -83,43 +103,43 @@ func (i *instanceDomain) IsVerifiedCondition(isVerified bool) database.Condition
// CreatedAtColumn implements [domain.InstanceDomainRepository]. // CreatedAtColumn implements [domain.InstanceDomainRepository].
// Subtle: this method shadows the method (instance).CreatedAtColumn of instanceDomain.instance. // Subtle: this method shadows the method (instance).CreatedAtColumn of instanceDomain.instance.
func (i *instanceDomain) CreatedAtColumn() database.Column { func (instanceDomain) CreatedAtColumn() database.Column {
panic("unimplemented") return database.NewColumn("created_at")
} }
// DomainColumn implements [domain.InstanceDomainRepository]. // DomainColumn implements [domain.InstanceDomainRepository].
func (i *instanceDomain) DomainColumn() database.Column { func (instanceDomain) DomainColumn() database.Column {
panic("unimplemented") return database.NewColumn("domain")
} }
// InstanceIDColumn implements [domain.InstanceDomainRepository]. // InstanceIDColumn implements [domain.InstanceDomainRepository].
func (i *instanceDomain) InstanceIDColumn() database.Column { func (instanceDomain) InstanceIDColumn() database.Column {
panic("unimplemented") return database.NewColumn("instance_id")
} }
// IsPrimaryColumn implements [domain.InstanceDomainRepository]. // IsPrimaryColumn implements [domain.InstanceDomainRepository].
func (i *instanceDomain) IsPrimaryColumn() database.Column { func (instanceDomain) IsPrimaryColumn() database.Column {
panic("unimplemented") return database.NewColumn("is_primary")
} }
// IsVerifiedColumn implements [domain.InstanceDomainRepository]. // IsVerifiedColumn implements [domain.InstanceDomainRepository].
func (i *instanceDomain) IsVerifiedColumn() database.Column { func (instanceDomain) IsVerifiedColumn() database.Column {
panic("unimplemented") return database.NewColumn("is_verified")
} }
// UpdatedAtColumn implements [domain.InstanceDomainRepository]. // UpdatedAtColumn implements [domain.InstanceDomainRepository].
// Subtle: this method shadows the method (instance).UpdatedAtColumn of instanceDomain.instance. // Subtle: this method shadows the method (instance).UpdatedAtColumn of instanceDomain.instance.
func (i *instanceDomain) UpdatedAtColumn() database.Column { func (instanceDomain) UpdatedAtColumn() database.Column {
panic("unimplemented") return database.NewColumn("updated_at")
} }
// VerificationTypeColumn implements [domain.InstanceDomainRepository]. // VerificationTypeColumn implements [domain.InstanceDomainRepository].
func (i *instanceDomain) VerificationTypeColumn() database.Column { func (instanceDomain) VerificationTypeColumn() database.Column {
panic("unimplemented") return database.NewColumn("verification_type")
} }
// IsGeneratedColumn implements [domain.InstanceDomainRepository]. // IsGeneratedColumn implements [domain.InstanceDomainRepository].
func (i *instanceDomain) IsGeneratedColumn() database.Column { func (instanceDomain) IsGeneratedColumn() database.Column {
return database.NewColumn("is_generated") return database.NewColumn("is_generated")
} }

7
backend/v3/storage/database/repository/org.go
View File

@@ -113,7 +113,7 @@ func checkCreateOrgErr(err error) error {
} }
// Update implements [domain.OrganizationRepository]. // Update implements [domain.OrganizationRepository].
func (o org) Update(ctx context.Context, id domain.OrgIdentifierCondition, instanceID string, changes ...database.Change) (int64, error) { func (o *org) Update(ctx context.Context, id domain.OrgIdentifierCondition, instanceID string, changes ...database.Change) (int64, error) {
if changes == nil { if changes == nil {
return 0, errors.New("Update must contain a condition") // (otherwise ALL organizations will be updated) return 0, errors.New("Update must contain a condition") // (otherwise ALL organizations will be updated)
} }
@@ -133,7 +133,7 @@ func (o org) Update(ctx context.Context, id domain.OrgIdentifierCondition, insta
} }
// Delete implements [domain.OrganizationRepository]. // Delete implements [domain.OrganizationRepository].
func (o org) Delete(ctx context.Context, id domain.OrgIdentifierCondition, instanceID string) (int64, error) { func (o *org) Delete(ctx context.Context, id domain.OrgIdentifierCondition, instanceID string) (int64, error) {
builder := database.StatementBuilder{} builder := database.StatementBuilder{}
builder.WriteString(`DELETE FROM zitadel.organizations`) builder.WriteString(`DELETE FROM zitadel.organizations`)
@@ -230,9 +230,6 @@ func scanOrganization(ctx context.Context, querier database.Querier, builder *da
organization := &domain.Organization{} organization := &domain.Organization{}
if err := rows.(database.CollectableRows).CollectExactlyOneRow(organization); err != nil { if err := rows.(database.CollectableRows).CollectExactlyOneRow(organization); err != nil {
if err.Error() == "no rows in result set" {
return nil, ErrResourceDoesNotExist
}
return nil, err return nil, err
} }

94
backend/v3/storage/database/repository/org_domain.go
View File

@@ -20,18 +20,38 @@ type orgDomain struct {
// Add implements [domain.OrganizationDomainRepository]. // Add implements [domain.OrganizationDomainRepository].
func (o *orgDomain) Add(ctx context.Context, domain *domain.AddOrganizationDomain) error { func (o *orgDomain) Add(ctx context.Context, domain *domain.AddOrganizationDomain) error {
panic("unimplemented") var builder database.StatementBuilder
builder.WriteString(`INSERT INTO zitadel.organization_domains (instance_id, org_id, domain, is_verified, is_primary, verification_type) ` +
`VALUES ($1, $2, $3, $4, $5, $6)` +
` RETURNING created_at, updated_at`)
builder.AppendArgs(domain.InstanceID, domain.OrgID, domain.Domain, domain.IsVerified, domain.IsPrimary, domain.VerificationType)
return o.client.QueryRow(ctx, builder.String(), builder.Args()...).Scan(&domain.CreatedAt, &domain.UpdatedAt)
} }
// Update implements [domain.OrganizationDomainRepository]. // Update implements [domain.OrganizationDomainRepository].
// Subtle: this method shadows the method (*org).Update of orgDomain.org. // Subtle: this method shadows the method (*org).Update of orgDomain.org.
func (o *orgDomain) Update(ctx context.Context, condition database.Condition, changes ...database.Change) error { func (o *orgDomain) Update(ctx context.Context, condition database.Condition, changes ...database.Change) (int64, error) {
panic("unimplemented") var builder database.StatementBuilder
builder.WriteString(`UPDATE zitadel.organization_domains SET `)
database.Changes(changes).Write(&builder)
writeCondition(&builder, condition)
return o.client.Exec(ctx, builder.String(), builder.Args()...)
} }
// Remove implements [domain.OrganizationDomainRepository]. // Remove implements [domain.OrganizationDomainRepository].
func (o *orgDomain) Remove(ctx context.Context, condition database.Condition) error { func (o *orgDomain) Remove(ctx context.Context, condition database.Condition) (int64, error) {
panic("unimplemented") var builder database.StatementBuilder
builder.WriteString(`DELETE FROM zitadel.organization_domains `)
writeCondition(&builder, condition)
return o.client.Exec(ctx, builder.String(), builder.Args()...)
} }
// ------------------------------------------------------------- // -------------------------------------------------------------
@@ -39,18 +59,18 @@ func (o *orgDomain) Remove(ctx context.Context, condition database.Condition) er
// ------------------------------------------------------------- // -------------------------------------------------------------
// SetPrimary implements [domain.OrganizationDomainRepository]. // SetPrimary implements [domain.OrganizationDomainRepository].
func (o *orgDomain) SetPrimary() database.Change { func (o orgDomain) SetPrimary() database.Change {
panic("unimplemented") return database.NewChange(o.IsPrimaryColumn(), true)
} }
// SetVerificationType implements [domain.OrganizationDomainRepository]. // SetVerificationType implements [domain.OrganizationDomainRepository].
func (o *orgDomain) SetVerificationType(verificationType domain.DomainVerificationType) database.Change { func (o orgDomain) SetVerificationType(verificationType domain.DomainVerificationType) database.Change {
panic("unimplemented") return database.NewChange(o.VerificationTypeColumn(), verificationType)
} }
// SetVerified implements [domain.OrganizationDomainRepository]. // SetVerified implements [domain.OrganizationDomainRepository].
func (o *orgDomain) SetVerified() database.Change { func (o orgDomain) SetVerified() database.Change {
panic("unimplemented") return database.NewChange(o.IsVerifiedColumn(), true)
} }
// ------------------------------------------------------------- // -------------------------------------------------------------
@@ -58,29 +78,29 @@ func (o *orgDomain) SetVerified() database.Change {
// ------------------------------------------------------------- // -------------------------------------------------------------
// DomainCondition implements [domain.OrganizationDomainRepository]. // DomainCondition implements [domain.OrganizationDomainRepository].
func (o *orgDomain) DomainCondition(op database.TextOperation, domain string) database.Condition { func (o orgDomain) DomainCondition(op database.TextOperation, domain string) database.Condition {
panic("unimplemented") return database.NewTextCondition(o.DomainColumn(), op, domain)
} }
// InstanceIDCondition implements [domain.OrganizationDomainRepository]. // InstanceIDCondition implements [domain.OrganizationDomainRepository].
// Subtle: this method shadows the method (*org).InstanceIDCondition of orgDomain.org. // Subtle: this method shadows the method (*org).InstanceIDCondition of orgDomain.org.
func (o *orgDomain) InstanceIDCondition(instanceID string) database.Condition { func (o orgDomain) InstanceIDCondition(instanceID string) database.Condition {
panic("unimplemented") return database.NewTextCondition(o.InstanceIDColumn(), database.TextOperationEqual, instanceID)
} }
// IsPrimaryCondition implements [domain.OrganizationDomainRepository]. // IsPrimaryCondition implements [domain.OrganizationDomainRepository].
func (o *orgDomain) IsPrimaryCondition(isPrimary bool) database.Condition { func (o orgDomain) IsPrimaryCondition(isPrimary bool) database.Condition {
panic("unimplemented") return database.NewBooleanCondition(o.IsPrimaryColumn(), isPrimary)
} }
// IsVerifiedCondition implements [domain.OrganizationDomainRepository]. // IsVerifiedCondition implements [domain.OrganizationDomainRepository].
func (o *orgDomain) IsVerifiedCondition(isVerified bool) database.Condition { func (o orgDomain) IsVerifiedCondition(isVerified bool) database.Condition {
panic("unimplemented") return database.NewBooleanCondition(o.IsVerifiedColumn(), isVerified)
} }
// OrgIDCondition implements [domain.OrganizationDomainRepository]. // OrgIDCondition implements [domain.OrganizationDomainRepository].
func (o *orgDomain) OrgIDCondition(orgID string) database.Condition { func (o orgDomain) OrgIDCondition(orgID string) database.Condition {
panic("unimplemented") return database.NewTextCondition(o.OrgIDColumn(), database.TextOperationEqual, orgID)
} }
// ------------------------------------------------------------- // -------------------------------------------------------------
@@ -89,45 +109,45 @@ func (o *orgDomain) OrgIDCondition(orgID string) database.Condition {
// CreatedAtColumn implements [domain.OrganizationDomainRepository]. // CreatedAtColumn implements [domain.OrganizationDomainRepository].
// Subtle: this method shadows the method (*org).CreatedAtColumn of orgDomain.org. // Subtle: this method shadows the method (*org).CreatedAtColumn of orgDomain.org.
func (o *orgDomain) CreatedAtColumn() database.Column { func (orgDomain) CreatedAtColumn() database.Column {
panic("unimplemented") return database.NewColumn("created_at")
} }
// DomainColumn implements [domain.OrganizationDomainRepository]. // DomainColumn implements [domain.OrganizationDomainRepository].
func (o *orgDomain) DomainColumn() database.Column { func (orgDomain) DomainColumn() database.Column {
panic("unimplemented") return database.NewColumn("domain")
} }
// InstanceIDColumn implements [domain.OrganizationDomainRepository]. // InstanceIDColumn implements [domain.OrganizationDomainRepository].
// Subtle: this method shadows the method (*org).InstanceIDColumn of orgDomain.org. // Subtle: this method shadows the method (*org).InstanceIDColumn of orgDomain.org.
func (o *orgDomain) InstanceIDColumn() database.Column { func (orgDomain) InstanceIDColumn() database.Column {
panic("unimplemented") return database.NewColumn("instance_id")
} }
// IsPrimaryColumn implements [domain.OrganizationDomainRepository]. // IsPrimaryColumn implements [domain.OrganizationDomainRepository].
func (o *orgDomain) IsPrimaryColumn() database.Column { func (orgDomain) IsPrimaryColumn() database.Column {
panic("unimplemented") return database.NewColumn("is_primary")
} }
// IsVerifiedColumn implements [domain.OrganizationDomainRepository]. // IsVerifiedColumn implements [domain.OrganizationDomainRepository].
func (o *orgDomain) IsVerifiedColumn() database.Column { func (orgDomain) IsVerifiedColumn() database.Column {
panic("unimplemented") return database.NewColumn("is_verified")
} }
// OrgIDColumn implements [domain.OrganizationDomainRepository]. // OrgIDColumn implements [domain.OrganizationDomainRepository].
func (o *orgDomain) OrgIDColumn() database.Column { func (orgDomain) OrgIDColumn() database.Column {
panic("unimplemented") return database.NewColumn("org_id")
} }
// UpdatedAtColumn implements [domain.OrganizationDomainRepository]. // UpdatedAtColumn implements [domain.OrganizationDomainRepository].
// Subtle: this method shadows the method (*org).UpdatedAtColumn of orgDomain.org. // Subtle: this method shadows the method (*org).UpdatedAtColumn of orgDomain.org.
func (o *orgDomain) UpdatedAtColumn() database.Column { func (orgDomain) UpdatedAtColumn() database.Column {
panic("unimplemented") return database.NewColumn("updated_at")
} }
// VerificationTypeColumn implements [domain.OrganizationDomainRepository]. // VerificationTypeColumn implements [domain.OrganizationDomainRepository].
func (o *orgDomain) VerificationTypeColumn() database.Column { func (orgDomain) VerificationTypeColumn() database.Column {
panic("unimplemented") return database.NewColumn("verification_type")
} }
// ------------------------------------------------------------- // -------------------------------------------------------------