mirror of
https://github.com/zitadel/zitadel.git
synced 2025-08-13 19:09:16 +00:00
fix(auth): read user if not found after create (#3835)
This commit is contained in:
@@ -18,6 +18,7 @@ import (
|
|||||||
query2 "github.com/zitadel/zitadel/internal/query"
|
query2 "github.com/zitadel/zitadel/internal/query"
|
||||||
"github.com/zitadel/zitadel/internal/repository/org"
|
"github.com/zitadel/zitadel/internal/repository/org"
|
||||||
user_repo "github.com/zitadel/zitadel/internal/repository/user"
|
user_repo "github.com/zitadel/zitadel/internal/repository/user"
|
||||||
|
usr_view "github.com/zitadel/zitadel/internal/user/repository/view"
|
||||||
view_model "github.com/zitadel/zitadel/internal/user/repository/view/model"
|
view_model "github.com/zitadel/zitadel/internal/user/repository/view/model"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -164,14 +165,44 @@ func (u *User) ProcessUser(event *es_models.Event) (err error) {
|
|||||||
user_repo.HumanPasswordlessInitCodeRequestedType:
|
user_repo.HumanPasswordlessInitCodeRequestedType:
|
||||||
user, err = u.view.UserByID(event.AggregateID, event.InstanceID)
|
user, err = u.view.UserByID(event.AggregateID, event.InstanceID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
if !errors.IsNotFound(err) {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
query, err := usr_view.UserByIDQuery(event.AggregateID, event.InstanceID, 0)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
events, err := u.es.FilterEvents(context.Background(), query)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
for _, e := range events {
|
||||||
|
if err = user.AppendEvent(e); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
err = user.AppendEvent(event)
|
err = user.AppendEvent(event)
|
||||||
case user_repo.UserDomainClaimedType,
|
case user_repo.UserDomainClaimedType,
|
||||||
user_repo.UserUserNameChangedType:
|
user_repo.UserUserNameChangedType:
|
||||||
user, err = u.view.UserByID(event.AggregateID, event.InstanceID)
|
user, err = u.view.UserByID(event.AggregateID, event.InstanceID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
if !errors.IsNotFound(err) {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
query, err := usr_view.UserByIDQuery(event.AggregateID, event.InstanceID, 0)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
events, err := u.es.FilterEvents(context.Background(), query)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
for _, e := range events {
|
||||||
|
if err = user.AppendEvent(e); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
err = user.AppendEvent(event)
|
err = user.AppendEvent(event)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
Reference in New Issue
Block a user