mirror of
https://github.com/zitadel/zitadel.git
synced 2025-02-28 20:17:23 +00:00
ec5f18c168
# Which Problems Are Solved The membership fields migration timed out in certain cases. It also tried to migrate instances which were already removed. # How the Problems Are Solved Revert the previous fix that combined the repeatable step for multiple fill triggers. The membeship migration is now single-run as it might take a lot of time. It is not worth making it repeatable. Instance IDs of removed instances are skipped. # Additional Changes None # Additional Context Introduced in https://github.com/zitadel/zitadel/pull/9199
45 lines
1.1 KiB
Go
45 lines
1.1 KiB
Go
package setup
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/zitadel/zitadel/internal/api/authz"
|
|
"github.com/zitadel/zitadel/internal/eventstore"
|
|
"github.com/zitadel/zitadel/internal/query/projection"
|
|
"github.com/zitadel/zitadel/internal/repository/instance"
|
|
)
|
|
|
|
type FillFieldsForInstanceDomains struct {
|
|
eventstore *eventstore.Eventstore
|
|
}
|
|
|
|
func (mig *FillFieldsForInstanceDomains) Execute(ctx context.Context, _ eventstore.Event) error {
|
|
instances, err := mig.eventstore.InstanceIDs(
|
|
ctx,
|
|
eventstore.NewSearchQueryBuilder(eventstore.ColumnsInstanceIDs).
|
|
OrderDesc().
|
|
AddQuery().
|
|
AggregateTypes("instance").
|
|
EventTypes(instance.InstanceAddedEventType).
|
|
Builder(),
|
|
)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
for _, instance := range instances {
|
|
ctx := authz.WithInstanceID(ctx, instance)
|
|
if err := projection.InstanceDomainFields.Trigger(ctx); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (mig *FillFieldsForInstanceDomains) String() string {
|
|
return "repeatable_fill_fields_for_instance_domains"
|
|
}
|
|
|
|
func (f *FillFieldsForInstanceDomains) Check(lastRun map[string]interface{}) bool {
|
|
return true
|
|
}
|