Files
cgrates/migrator/accounts.go
2025-10-19 13:15:57 +02:00

109 lines
2.8 KiB
Go

/*
Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments
Copyright (C) ITsysCOM GmbH
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License
along with this program. If not, see <https://www.gnu.org/licenses/>
*/
package migrator
import (
"fmt"
"strings"
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/utils"
)
func (m *Migrator) migrateCurrentAccounts() (err error) {
mInDB, err := m.GetINConn(utils.MetaAccounts)
if err != nil {
return err
}
dataDB, _, err := mInDB.DataManager().DBConns().GetConn(utils.MetaAccounts)
if err != nil {
return err
}
var ids []string
ids, err = dataDB.GetKeysForPrefix(context.TODO(), utils.AccountPrefix)
if err != nil {
return err
}
for _, id := range ids {
tntID := strings.SplitN(strings.TrimPrefix(id, utils.AccountPrefix), utils.InInFieldSep, 2)
if len(tntID) < 2 {
return fmt.Errorf("Invalid key <%s> when migrating from account ", id)
}
ap, err := mInDB.DataManager().GetAccount(context.TODO(), tntID[0], tntID[1])
if err != nil {
return err
}
if ap == nil || m.dryRun {
continue
}
mOutDB, err := m.GetOUTConn(utils.MetaAccounts)
if err != nil {
return err
}
if err := mOutDB.DataManager().SetAccount(context.TODO(), ap, true); err != nil {
return err
}
if err := mInDB.DataManager().RemoveAccount(context.TODO(), tntID[0], tntID[1], false); err != nil {
return err
}
m.stats[utils.AccountsString]++
}
return
}
func (m *Migrator) migrateAccounts() (err error) {
var vrs engine.Versions
current := engine.CurrentDataDBVersions()
if vrs, err = m.getVersions(utils.AccountsString); err != nil {
return
}
migrated := true
for {
version := vrs[utils.AccountsString]
for {
switch version {
default:
return fmt.Errorf("Unsupported version %v", version)
case current[utils.AccountsString]:
migrated = false
if m.sameDataDB {
break
}
if err = m.migrateCurrentAccounts(); err != nil {
return
}
}
if version == current[utils.AccountsString] || err == utils.ErrNoMoreData {
break
}
}
if err == utils.ErrNoMoreData || !migrated {
break
}
m.stats[utils.AccountsString]++
}
//All done, update version with current one
if err = m.setVersions(utils.AccountsString); err != nil {
return
}
return m.ensureIndexesDataDB(engine.ColApp)
}