mirror of
https://github.com/zitadel/zitadel.git
synced 2025-04-29 21:50:49 +00:00
33a4802425
* start org * refactor(eventstore): filter in sql for querier * feat(eventstore): Aggregate precondition preconditions are checked right before insert. Insert is still transaction save * feat(eventstore): check preconditions in repository * test(eventstore): test precondition in models * test(eventstore): precondition-tests * refactor(eventstore): querier as type * fix(precondition): rename validation from precondition to validation * test(eventstore): isErr func instead of wantErr bool * fix: delete org files * remove comment Co-authored-by: Livio Amstutz <livio.a@gmail.com>
94 lines
2.3 KiB
Go
94 lines
2.3 KiB
Go
package models
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/caos/zitadel/internal/errors"
|
|
)
|
|
|
|
type AggregateType string
|
|
|
|
func (at AggregateType) String() string {
|
|
return string(at)
|
|
}
|
|
|
|
type Aggregates []*Aggregate
|
|
|
|
type Aggregate struct {
|
|
id string
|
|
typ AggregateType
|
|
PreviousSequence uint64
|
|
version Version
|
|
|
|
editorService string
|
|
editorUser string
|
|
resourceOwner string
|
|
Events []*Event
|
|
Precondition *precondition
|
|
}
|
|
|
|
type precondition struct {
|
|
Query *SearchQuery
|
|
Validation func(...*Event) error
|
|
}
|
|
|
|
func (a *Aggregate) AppendEvent(typ EventType, payload interface{}) (*Aggregate, error) {
|
|
if string(typ) == "" {
|
|
return a, errors.ThrowInvalidArgument(nil, "MODEL-TGoCb", "no event type")
|
|
}
|
|
data, err := eventData(payload)
|
|
if err != nil {
|
|
return a, err
|
|
}
|
|
|
|
e := &Event{
|
|
CreationDate: time.Now(),
|
|
Data: data,
|
|
Type: typ,
|
|
AggregateID: a.id,
|
|
AggregateType: a.typ,
|
|
AggregateVersion: a.version,
|
|
EditorService: a.editorService,
|
|
EditorUser: a.editorUser,
|
|
ResourceOwner: a.resourceOwner,
|
|
}
|
|
|
|
a.Events = append(a.Events, e)
|
|
return a, nil
|
|
}
|
|
|
|
func (a *Aggregate) SetPrecondition(query *SearchQuery, validateFunc func(...*Event) error) *Aggregate {
|
|
a.Precondition = &precondition{Query: query, Validation: validateFunc}
|
|
return a
|
|
}
|
|
|
|
func (a *Aggregate) Validate() error {
|
|
if a == nil {
|
|
return errors.ThrowPreconditionFailed(nil, "MODEL-yi5AC", "aggregate is nil")
|
|
}
|
|
if a.id == "" {
|
|
return errors.ThrowPreconditionFailed(nil, "MODEL-FSjKV", "id not set")
|
|
}
|
|
if string(a.typ) == "" {
|
|
return errors.ThrowPreconditionFailed(nil, "MODEL-aj4t2", "type not set")
|
|
}
|
|
if err := a.version.Validate(); err != nil {
|
|
return errors.ThrowPreconditionFailed(err, "MODEL-PupjX", "invalid version")
|
|
}
|
|
|
|
if a.editorService == "" {
|
|
return errors.ThrowPreconditionFailed(nil, "MODEL-clYbY", "editor service not set")
|
|
}
|
|
if a.editorUser == "" {
|
|
return errors.ThrowPreconditionFailed(nil, "MODEL-Xcssi", "editor user not set")
|
|
}
|
|
if a.resourceOwner == "" {
|
|
return errors.ThrowPreconditionFailed(nil, "MODEL-eBYUW", "resource owner not set")
|
|
}
|
|
if a.Precondition != nil && (a.Precondition.Query == nil || a.Precondition.Query.Validate() != nil || a.Precondition.Validation == nil) {
|
|
return errors.ThrowPreconditionFailed(nil, "MODEL-EEUvA", "invalid precondition")
|
|
}
|
|
|
|
return nil
|
|
}
|