wehub-resource-sync
34 lines
622 B
Go
34 lines
622 B
Go
package migrator
|
|
|
|
import (
|
|
"github.com/segmentio/encoding/json"
|
|
|
|
"github.com/rs/zerolog/log"
|
|
)
|
|
|
|
func (migrator *Migrator) migratePendingActionsDataForDB130() error {
|
|
log.Info().Msg("Migrating pending actions data")
|
|
|
|
pendingActions, err := migrator.pendingActionsService.ReadAll()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
for _, pa := range pendingActions {
|
|
actionData, err := json.Marshal(pa.ActionData)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
pa.ActionData = string(actionData)
|
|
|
|
// Update the pending action
|
|
err = migrator.pendingActionsService.Update(pa.ID, &pa)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|