mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-11 18:16:24 +05:00
Migrator - create indexes together with attribute profiles out of users and aliases
This commit is contained in:
@@ -139,7 +139,7 @@ func (m *Migrator) migrateAlias2Attributes() (err error) {
|
||||
if err := m.dmIN.remV1Alias(alias.GetId()); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := m.dmOut.DataManager().DataDB().SetAttributeProfileDrv(attr); err != nil {
|
||||
if err := m.dmOut.DataManager().SetAttributeProfile(attr, true); err != nil {
|
||||
return err
|
||||
}
|
||||
m.stats[Alias] += 1
|
||||
|
||||
@@ -69,13 +69,16 @@ func userProfile2attributeProfile(user *v1UserProfile) (attr *engine.AttributePr
|
||||
Append: true,
|
||||
})
|
||||
}
|
||||
for fieldname, substitute := range user.Profile {
|
||||
if utils.IsSliceMember(usrFltr, fieldname) {
|
||||
attr.FilterIDs = append(attr.FilterIDs, fmt.Sprintf("*string:%s:%s", fieldname, substitute))
|
||||
for fieldName, substitute := range user.Profile {
|
||||
if fieldName == "ReqType" { // old style
|
||||
fieldName = utils.RequestType
|
||||
}
|
||||
if utils.IsSliceMember(usrFltr, fieldName) {
|
||||
attr.FilterIDs = append(attr.FilterIDs, fmt.Sprintf("*string:%s:%s", fieldName, substitute))
|
||||
continue
|
||||
}
|
||||
attr.Attributes = append(attr.Attributes, &engine.Attribute{
|
||||
FieldName: fieldname,
|
||||
FieldName: fieldName,
|
||||
Initial: utils.META_ANY,
|
||||
Substitute: config.NewRSRParsersMustCompile(substitute, true, utils.INFIELD_SEP),
|
||||
Append: true,
|
||||
@@ -103,7 +106,7 @@ func (m *Migrator) migrateV1User2AttributeProfile() (err error) {
|
||||
if err := m.dmIN.remV1User(user.GetId()); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := m.dmOut.DataManager().DataDB().SetAttributeProfileDrv(attr); err != nil {
|
||||
if err := m.dmOut.DataManager().SetAttributeProfile(attr, true); err != nil {
|
||||
return err
|
||||
}
|
||||
m.stats[utils.User] += 1
|
||||
|
||||
Reference in New Issue
Block a user