migrateUsersRule.js

migrateUsersRule.js

function migrateUsers(user, context, cb) {
  if (needMigration(user)) {
    // Ignoring how the values are retrieved from the legacy database
    var legacyProfile = {
      family_name: 'alakus',
      given_name: 'saltuk',
      user_metadata: {
        'anotherMetadata' : '123'
      },
      app_metadata: {
        'migrated':true,
        'userId':'xyz'
      }
    };

    var ManagementClient = require('[email protected]').ManagementClient;
    var management = new ManagementClient({
      domain: auth0.domain,
      token: auth0.accessToken
    });

    management.updateUser(
      { id: user.user_id },
      legacyProfile,
      function (err, updatedUser) {
        if (err) {
          cb(err);
        } else {
          updateRuleUser(user, updatedUser);
          cb(null, user, context);
        }
      }
    );
  } else {
    cb(null, user, context);
  }

  function needMigration(user) {
    if (!user.app_metadata || (user.app_metadata && !user.app_metadata.migrated)) {
        return true;
    }

    return false;
  }

  function updateRuleUser(user, updatedUser) {
    for (var key in updatedUser) {
        user[key] = updatedUser[key];
    }
  }
}