TheArchive/zitadel
1
0
Fork 0
mirror of https://github.com/zitadel/zitadel.git synced 2025-04-25 12:20:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: comments

Browse Source
This commit is contained in:
adlerhurst 2020-10-26 14:49:42 +01:00
parent dfb8c266d7
commit 936c88c6ed
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/eventstore/v2/example_test.go
View File

@ -217,10 +217,12 @@ func (rm *UsersReadModel) AppendEvents(events ...eventstore.Event) (err error) {
for _, event := range events { for _, event := range events {
switch e := event.(type) { switch e := event.(type) {
case *UserAddedEvent: case *UserAddedEvent:
//insert
user := NewUserReadModel(e.MetaData().AggregateID) user := NewUserReadModel(e.MetaData().AggregateID)
rm.Users = append(rm.Users, user) rm.Users = append(rm.Users, user)
err = user.AppendEvents(e) err = user.AppendEvents(e)
case *UserFirstNameChangedEvent, *UserPasswordCheckedEvent: case *UserFirstNameChangedEvent, *UserPasswordCheckedEvent:
//update
_, user := rm.userByID(e.MetaData().AggregateID) _, user := rm.userByID(e.MetaData().AggregateID)
if user == nil { if user == nil {
return errors.New("user not found") return errors.New("user not found")
@ -231,6 +233,10 @@ func (rm *UsersReadModel) AppendEvents(events ...eventstore.Event) (err error) {
return err return err
} }
} }
//begin
//for stmt range stmts; exec
//commit
return nil return nil
} }