mirror of
https://github.com/zitadel/zitadel.git
synced 2024-12-14 11:58:02 +00:00
d8e42744b4
* fix: move eventstore pkgs * fix: move eventstore pkgs * fix: remove v2 view * fix: remove v2 view
67 lines
1.5 KiB
Go
67 lines
1.5 KiB
Go
package eventstore
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/caos/zitadel/internal/api/authz"
|
|
)
|
|
|
|
type aggregateOpt func(*Aggregate)
|
|
|
|
//NewAggregate is the default constructor of an aggregate
|
|
// opts overwrite values calculated by given parameters
|
|
func NewAggregate(
|
|
ctx context.Context,
|
|
id string,
|
|
typ AggregateType,
|
|
version Version,
|
|
opts ...aggregateOpt,
|
|
) *Aggregate {
|
|
a := &Aggregate{
|
|
ID: id,
|
|
Typ: typ,
|
|
ResourceOwner: authz.GetCtxData(ctx).OrgID,
|
|
Version: version,
|
|
}
|
|
|
|
for _, opt := range opts {
|
|
opt(a)
|
|
}
|
|
|
|
return a
|
|
}
|
|
|
|
//WithResourceOwner overwrites the resource owner of the aggregate
|
|
// by default the resource owner is set by the context
|
|
func WithResourceOwner(resourceOwner string) aggregateOpt {
|
|
return func(aggregate *Aggregate) {
|
|
aggregate.ResourceOwner = resourceOwner
|
|
}
|
|
}
|
|
|
|
//AggregateFromWriteModel maps the given WriteModel to an Aggregate
|
|
func AggregateFromWriteModel(
|
|
wm *WriteModel,
|
|
typ AggregateType,
|
|
version Version,
|
|
) *Aggregate {
|
|
return &Aggregate{
|
|
ID: wm.AggregateID,
|
|
Typ: typ,
|
|
ResourceOwner: wm.ResourceOwner,
|
|
Version: version,
|
|
}
|
|
}
|
|
|
|
//Aggregate is the basic implementation of Aggregater
|
|
type Aggregate struct {
|
|
//ID is the unique identitfier of this aggregate
|
|
ID string `json:"-"`
|
|
//Typ is the name of the aggregate.
|
|
Typ AggregateType `json:"-"`
|
|
//ResourceOwner is the org this aggregates belongs to
|
|
ResourceOwner string `json:"-"`
|
|
//Version is the semver this aggregate represents
|
|
Version Version `json:"-"`
|
|
}
|