Files
zitadel/apps/api/internal/repository/org/aggregate.go
2025-08-05 15:20:32 -07:00

36 lines
672 B
Go

package org
import (
"context"
"github.com/zitadel/zitadel/internal/eventstore"
)
const (
orgEventTypePrefix = eventstore.EventType("org.")
)
const (
AggregateType = "org"
AggregateVersion = "v1"
)
type Aggregate struct {
eventstore.Aggregate
}
func NewAggregate(id string) *Aggregate {
return &Aggregate{
Aggregate: eventstore.Aggregate{
Type: AggregateType,
Version: AggregateVersion,
ID: id,
ResourceOwner: id,
},
}
}
func AggregateFromWriteModel(ctx context.Context, wm *eventstore.WriteModel) *eventstore.Aggregate {
return eventstore.AggregateFromWriteModelCtx(ctx, wm, AggregateType, AggregateVersion)
}