uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 10:06:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Removing accounts (build.sh runs)

Browse Source
This commit is contained in:
andronache
2021-03-31 09:26:39 +03:00
committed by Dan Christian Bogos
parent 06f648b987
commit 51c201e50e
42 changed files with 236 additions and 2594 deletions
Download Patch File Download Diff File Expand all files Collapse all files

95
migrator/account_profiles.go
View File

@@ -1,95 +0,0 @@
/*
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 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 General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>
*/
package migrator
import (
"fmt"
"strings"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/utils"
)
func (m *Migrator) migrateCurrentAccountProfiles() (err error) {
var ids []string
ids, err = m.dmIN.DataManager().DataDB().GetKeysForPrefix(utils.AccountProfilePrefix)
if err != nil {
return err
}
for _, id := range ids {
tntID := strings.SplitN(strings.TrimPrefix(id, utils.AccountProfilePrefix), utils.InInFieldSep, 2)
if len(tntID) < 2 {
return fmt.Errorf("Invalid key <%s> when migrating from account profiles", id)
}
ap, err := m.dmIN.DataManager().GetAccountProfile(tntID[0], tntID[1])
if err != nil {
return err
}
if ap == nil || m.dryRun {
continue
}
if err := m.dmOut.DataManager().SetAccountProfile(ap, true); err != nil {
return err
}
if err := m.dmIN.DataManager().RemoveAccountProfile(tntID[0], tntID[1], utils.NonTransactional, false); err != nil {
return err
}
m.stats[utils.AccountProfilesString]++
}
return
}
func (m *Migrator) migrateAccountProfiles() (err error) {
var vrs engine.Versions
current := engine.CurrentDataDBVersions()
if vrs, err = m.getVersions(utils.AccountProfilesString); err != nil {
return
}
migrated := true
for {
version := vrs[utils.AccountProfilesString]
for {
switch version {
default:
return fmt.Errorf("Unsupported version %v", version)
case current[utils.AccountProfilesString]:
migrated = false
if m.sameDataDB {
break
}
if err = m.migrateCurrentAccountProfiles(); err != nil {
return
}
}
if version == current[utils.AccountProfilesString] || err == utils.ErrNoMoreData {
break
}
}
if err == utils.ErrNoMoreData || !migrated {
break
}
m.stats[utils.AccountProfilesString]++
}
//All done, update version with current one
if err = m.setVersions(utils.AccountProfilesString); err != nil {
return
}
return m.ensureIndexesDataDB(engine.ColApp)
}

3
migrator/migrator.go
View File

@@ -129,9 +129,6 @@ func (m *Migrator) Migrate(taskIDs []string) (err error, stats map[string]int) {
err = m.migrateFilters()
case utils.MetaRoutes:
err = m.migrateRouteProfiles()
case utils.MetaAccountProfiles:
err = m.migrateAccountProfiles()
//only Move
case utils.MetaRatingPlans:
err = m.migrateRatingPlans()
case utils.MetaRatingProfiles: