20049962129

Committed 09 Dec 2025 02:37AM UTC coverage: 44.692% (-29.6%) from 74.284%

Build # 20049962129

Build Type

Pull #134

github

Committed by

web-flow

Commit Message

Merge 936545d57 into a9858f6b0

Pull Request Pull Request #134: Update nano

Run Details

282 of 716 branches covered (39.39%)

Branch coverage included in aggregate %.

2 of 3 new or added lines in 1 file covered. (66.67%)

422 existing lines in 5 files now uncovered.

640 of 1347 relevant lines covered (47.51%)

3.88 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

36.24

/lib/user.js

const bcrypt = require('bcryptjs');
const debug = require('debug')('lib:user');
const config = require('config');
const nano = require('nano');
const md5 = require('md5');
const url = require('url');
const {
  Connection,
} = require('fielddb/api/corpus/Connection');
const { User } = require('fielddb/api/user/User');
const DEFAULT_USER_PREFERENCES = require('fielddb/api/user/preferences.json');

const authServerVersion = require('../package.json').version;
const emailFunctions = require('./email');
const corpus = require('./corpus');
const corpusmanagement = require('./corpusmanagement');

emailFunctions.emailWhenServerStarts();
/* variable for permissions */
const commenter = 'commenter';
const collaborator = 'reader';
const contributor = 'writer';
const {
  NODE_ENV,
} = process.env;
if (!Connection || !Connection.knownConnections || !Connection.knownConnections.production) {
  throw new Error(`The app config for ${NODE_ENV} is missing app types to support. `);
}
/*
 * we are getting too many user signups from the Learn X users and the speech recognition trainer users,
 * they are starting to overpower the field linguist users. So if when we add the ability for them
 * to backup and share their languages lessions, then
 * we will create their dbs  with a non-anonymous username.
 */
const dontCreateDBsForLearnXUsersBecauseThereAreTooManyOfThem = true;

const parsed = url.parse(config.usersDbConnection.url);
const couchConnectUrl = `${parsed.protocol}//${config.couchKeys.username}:${config.couchKeys.password}@${parsed.host}`;

let sampleUsers = ['public'];
Object.keys(config.sampleUsers).forEach((userType) => {
  if (config.sampleUsers[userType].length > 0) {
    sampleUsers = sampleUsers.concat(config.sampleUsers[userType]);
  }
});
debug(`${new Date()}  Sample users will not recieve save preferences changes.`, sampleUsers);

function undoCorpusCreation({
  user,
  connection,
  docs,
} = {}) {
  debug(`${new Date()} TODO need to clean up a broken corpus.${JSON.stringify(connection)}`, docs);
  return emailFunctions.emailCorusCreationFailure({ connection, user });
}

function sortByUsername(a, b) {
  if (a.username < b.username) {
    return -1;
  }
  if (a.username > b.username) {
    return 1;
  }
  return 0;
}

function createCouchDBUser({
  req = {
    id: '',
    body: {},
    log: {
      // eslint-disable-next-line no-console
      warn: console.warn,
    },
  },
  user,
  password,
} = {}) {
  /*
   * Give the user access to other corpora so they can see what it is like
   * to collaborate
   */
  let whichUserGroup = 'normalusers';
  if (user.username.indexOf('test') > -1 || user.username.indexOf('anonymous') > -1) {
    whichUserGroup = 'betatesters';
  }
  debug('createCouchDBUser whichUserGroup', whichUserGroup);
  const couchdb = nano({
    agentOptions: {
      headers: {
        'x-request-id': req.id || '',
      },
    },
    url: couchConnectUrl,
  });

  const usersdb = couchdb.db.use('_users');

  const userid = `org.couchdb.user:${user.username}`;
  const userParamsForNewUser = {
    _id: userid,
    name: user.username,
    password,
    roles: [
      `${user.appbrand}_user`, // used to be connection.brandLowerCase
      'fielddbuser',
      `public-firstcorpus_${collaborator}`,
    // `${connection.dbname}_${admin}`,
      // `${connection.dbname}_${contributor}`,
      // `${connection.dbname}_${collaborator}`,
      // `${connection.dbname}_${commenter}`,
    ],
    type: 'user',
  };

  if (whichUserGroup === 'normalusers') {
    const sampleCorpus = 'lingllama-communitycorpus';
    userParamsForNewUser.roles.push(`${sampleCorpus}_${contributor}`);
    userParamsForNewUser.roles.push(`${sampleCorpus}_${collaborator}`);
    userParamsForNewUser.roles.push(`${sampleCorpus}_${commenter}`);
    debug('createCouchDBUser sampleCorpus', sampleCorpus);
  }

  userParamsForNewUser.roles = userParamsForNewUser.roles.sort();
  return usersdb.insert(userParamsForNewUser, userid)
    .then((couchUser) => ({
      // user,
      couchUser,
      whichUserGroup,
      // connection,
    }))
    .then(() => couchdb.db.replicate('new_corpus_activity_feed', `${user.username}-activity_feed`, {
      create_target: true,
    }))
    .catch((couchDBError) => {
      req.log.warn(`${new Date()} User activity feed replication failed.`, couchDBError);
    })
    .then((couchActivityFeedResponse) => {
      debug(`${new Date()} User activity feed successfully replicated.`, couchActivityFeedResponse);
      // Set up security on new user activity feed
      const activityDb = nano({
        agentOptions: {
          headers: {
            'x-request-id': req.id || '',
          },
        },
        url: `${couchConnectUrl}/${user.username}-activity_feed`,
      });
      return activityDb.insert({
        admins: {
          names: [],
          roles: [
            'fielddbadmin',
          ],
        },
        members: {
          names: [
            user.username,
          ],
          roles: [],
        },
        _id: '_security',
      }, '_security');
    })
    .catch((couchDBError) => {
      req.log.warn(`${new Date()} User activity feed replication failed.`, couchDBError);
      return {
        whichUserGroup,
      };
    });
}

/*
 * Looks returns a list of users ordered by role in that corpus
 */
function fetchCorpusPermissions({
  req = {
    id: '',
    body: {},
  },
} = {}) {
  let dbConn;
  // If serverCode is present, request is coming from Spreadsheet app
  if (req.body.serverCode) {
    dbConn = Connection.defaultConnection(req.body.serverCode);
    dbConn.dbname = req.body.dbname;
  } else {
    dbConn = req.body.connection;
  }
  if (!req || !req.body.username || !req.body.username) {
    const err = new Error('Please provide a username, you must be a member of a corpus in order to find out who else is a member.');
    err.status = 412;
    return Promise.reject(err);
  }
  if (!dbConn) {
    const err = new Error('Client didn\'t define the database connection.');
    err.status = 412;
    err.userFriendlyErrors = ['This app has made an invalid request. Please notify its developer. missing: serverCode or connection'];
    return Promise.reject(err);
  }
  const dbname = dbConn.dbname || dbConn.pouchname;
  const requestingUser = req.body.username;
  let requestingUserIsAMemberOfCorpusTeam = false;
  if (dbConn && dbConn.domain && dbConn.domain.indexOf('iriscouch') > -1) {
    dbConn.port = '6984';
  }
  debug(`${new Date()} ${requestingUser} requested the team on ${dbname}`);
  const nanoforpermissions = nano({
    agentOptions: {
      headers: {
        'x-request-id': req.id || '',
      },
    },
    url: couchConnectUrl,
  });
  /*
   * Get user names and roles from the server
   *
   * https://127.0.0.1:6984/_users/_design/users/_view/userroles
   */
  const usersdb = nanoforpermissions.db.use('_users');
  let whichUserGroup = 'normalusers';
  if (requestingUser.indexOf('test') > -1 || requestingUser.indexOf('anonymous') > -1) {
    whichUserGroup = 'betatesters';
  }
  let userroles;
  return usersdb.view('users', whichUserGroup)
    .then((body) => {
      userroles = body.rows;
      /*
     * Get user masks from the server
     */
      const fieldDBUsersDB = nanoforpermissions.db.use(config.usersDbConnection.dbname);
      // Put the user in the database and callback
      return fieldDBUsersDB.view('users', 'usermasks');
    })
    .then((body) => {
      const usermasks = body.rows;
      const usersInThisGroup = {};
      const rolesAndUsers = {
        allusers: [],
        notonteam: [],
      };
      /*
       Convert the array into a hash to avoid n*m behavior (instead we have n+m+h)
       */
      userroles.forEach(({ key: username, value: roles }) => {
        usersInThisGroup[username] = { username, roles };
      });
      // Put the gravatars in for users who are in this category
      usermasks.forEach(({ value: { gravatar, gravatar_email: email, username } }) => {
        // if this usermask isnt in this category of users, skip them.
        if (!usersInThisGroup[username]) {
          return;
        }
        // debug(username, usersInThisGroup[username]);
        usersInThisGroup[username].gravatar = gravatar;
        // debug(new Date() + "  the value of this user ", usermasks[userIndex]);
        usersInThisGroup[username].email = email;
      });
      // Put the users into the list of roles and users
      Object.keys(usersInThisGroup).forEach((username) => {
        if (!usersInThisGroup[username]) {
          return;
        }
        // debug(new Date() + " Looking at " + username);
        let userIsOnTeam = false;
        const thisUsersMask = usersInThisGroup[username];
        if ((!thisUsersMask.gravatar || thisUsersMask.gravatar.indexOf('user_gravatar') > -1) && thisUsersMask.email) {
          debug(`${new Date()}  the gravtar of ${username} was missing/old `, thisUsersMask);
          thisUsersMask.gravatar = md5(thisUsersMask.email);
        }
        // Find out if this user is a member of the team
        if (!thisUsersMask.roles) {
          debug(`${new Date()} this is odd, ${username} doesnt have any roles defined, skipping this user, even for hte typeahead`);
          return;
        }
        // Add this user to the typeahead
        rolesAndUsers.allusers.push({
          username,
          gravatar: thisUsersMask.gravatar,
        });

        thisUsersMask.roles.forEach((role) => {
          if (role.indexOf(`${dbname}_`) !== 0) {
            return;
          }
          userIsOnTeam = true;
          // debug(new Date() + username + " is a member of this corpus: " + role);
          if (username === requestingUser) {
            requestingUserIsAMemberOfCorpusTeam = true;
          }
          /*
           * If the role is for this corpus, insert the users's mask into
           * the relevant roles, this permits the creation of new roles in the system
           */
          const roleType = `${role.replace(`${dbname}_`, '')}s`;
          rolesAndUsers[roleType] = rolesAndUsers[roleType] || [];
          rolesAndUsers[roleType].push({
            username,
            gravatar: thisUsersMask.gravatar,
          });
        });
        if (!userIsOnTeam) {
          rolesAndUsers.notonteam.push({
            username,
            gravatar: thisUsersMask.gravatar,
          });
        }
      });

      /* sort alphabetically the real roles (typeaheads dont matter) */
      if (rolesAndUsers.admins) {
        rolesAndUsers.admins.sort(sortByUsername);
      }
      if (rolesAndUsers.writers) {
        rolesAndUsers.writers.sort(sortByUsername);
      }
      if (rolesAndUsers.readers) {
        rolesAndUsers.readers.sort(sortByUsername);
      }
      if (rolesAndUsers.commenters) {
        rolesAndUsers.commenters.sort(sortByUsername);
      }
      /*
       * Send the results, if the user is part of the team
       */
      if (requestingUserIsAMemberOfCorpusTeam) {
        return {
          rolesAndUsers,
          info: {
            message: 'Look up successful.',
          },
        };
      }

      debug(`Requesting user \`${requestingUser}\` is not a member of the corpus team.${dbname}`);
      const err = new Error(`Requesting user \`${requestingUser}\` is not a member of the corpus team.`);
      err.status = 401;
      err.userFriendlyErrors = ['Unauthorized, you are not a member of this corpus team.'];
      throw err;
    // });
    })
    .catch((error) => {
      debug(`${new Date()} Error quering userroles: ${error}`);
      const err = {
        message: error.message,
        userFriendlyErrors: ['Server is not responding for request to query corpus permissions. Please report this 1289'],
        ...error,
      };
      throw err;
    });
}

function createNewCorpusesIfDontExist({
  user,
  corpora,
  req,
} = {}) {
  if (!corpora || corpora.length === 0) {
    return Promise.resolve([]);
  }

  const requestedDBCreation = {};
  debug(`${new Date()} Ensuring newCorpora are ready`, corpora);
  /*
   * Creates the user's new corpus databases
   */
  return Promise.all(corpora.map((potentialnewcorpusconnection) => {
    if (!potentialnewcorpusconnection || !potentialnewcorpusconnection.dbname
       || requestedDBCreation[potentialnewcorpusconnection.dbname]) {
      debug('Not creating this corpus ', potentialnewcorpusconnection);
      return Promise.resolve(potentialnewcorpusconnection);
    }

    if (potentialnewcorpusconnection.dbname.indexOf(`${user.username}-`) !== 0) {
      debug('Not creating a corpus which appears to belong ot another user.', potentialnewcorpusconnection);
      return Promise.resolve(potentialnewcorpusconnection);
    }
    requestedDBCreation[potentialnewcorpusconnection.dbname] = true;

    return corpus.createNewCorpus({
      req,
      user,
      title: potentialnewcorpusconnection.title,
      connection: potentialnewcorpusconnection,
    })
      .then(({ corpusDetails, info } = {}) => {
        debug('Create new corpus results', corpusDetails.description, info);
        // if (err.status === 302) {
        //   for (var connectionIndex = corpora.length - 1; connectionIndex >= 0; connectionIndex--) {
        //     if (info.message === "Your corpus " + corpora[connectionIndex].dbname +
        // " already exists, no need to create it.") {
        //       debug("Removing this from the new connections  has no effect." + info.message);
        //       corpora.splice(connectionIndex, 1);
        //     }
        //   }
        // }
        return potentialnewcorpusconnection;
      })
      .catch((err) => {
        if (err.corpusexisted) {
          return potentialnewcorpusconnection;
        }
        throw err;
      });
  }));
}

/**
function is called back
 * with (error, user, info) where error contains the server's detailed error
 * (not to be shared with the client), and info contains a client readible error
 * message.
 *
 * @param user
 */
function saveUpdateUserToDatabase({
  user: fieldDBUser,
  req = {
    id: '',
    log: {
      // eslint-disable-next-line no-console
      error: console.error,
      // eslint-disable-next-line no-console
      warn: console.warn,
    },
  },
} = {}) {
  if (!fieldDBUser || !fieldDBUser.username) {
    return Promise.reject(new Error('Please provide a username 8933'));
  }

  if (process.env.INSTALABLE !== 'true' && sampleUsers.indexOf(fieldDBUser.username) > -1) {
    return Promise.resolve({
      user: fieldDBUser,
      info: {
        message: 'User is a reserved user and cannot be updated in this manner.',
      },
    });
  }
  const user = fieldDBUser.toJSON ? fieldDBUser.toJSON() : fieldDBUser;
  // dont need the salt
  delete user.salt;

  // Preparing the couch connection
  const usersdb = nano({
    agentOptions: {
      headers: {
        'x-request-id': req.id || '',
      },
    },
    url: couchConnectUrl,
  }).db.use(config.usersDbConnection.dbname);
  // Put the user in the database and callback
  return usersdb.insert(user, user.username)
    .then((resultuser) => {
      if (resultuser.ok) {
        debug(`${new Date()} No error saving a user: ${JSON.stringify(resultuser)}`);
        // eslint-disable-next-line no-underscore-dangle, no-param-reassign
        fieldDBUser._rev = resultuser.rev;
        return {
          user: fieldDBUser,
          info: {
            message: 'User details saved.',
          },
        };
      }
      throw new Error('Unknown server result, this might be a bug.');
    })
    .catch((error) => {
      const err = {
        message: error.message,
        status: error.status || error.statusCode,
        ...error,
      };
      let message = 'Error saving a user in the database. ';
      if (err.status === 409) {
        message = 'Conflict saving user in the database. Please try again.';
      }
      debug(`${new Date()} Error saving a user: ${JSON.stringify(error)}`);
      debug(`${new Date()} This is the user who was not saved: ${JSON.stringify(user)}`);
      err.userFriendlyErrors = [message];
      throw err;
    });
}

/**
 * connects to the usersdb, tries to retrieve the doc with the
 * provided id
 *
 * @param id
 */
function findByUsername({
  username,
  req = {
    id: '',
    log: {
      // eslint-disable-next-line no-console
      error: console.error,
      // eslint-disable-next-line no-console
      warn: console.warn,
    },
  },
} = {}) {
  if (!username) {
    return Promise.reject(new Error('username is required'));
  }

  const usersdb = nano({
    agentOptions: {
      headers: {
        'x-request-id': req.id || '',
      },
    },
    url: couchConnectUrl,
  }).db.use(config.usersDbConnection.dbname);
  return usersdb.get(username)
    .then((result) => {
      debug(`${new Date()} User found: ${result.username}`);
      if (result.serverlogs && result.serverlogs.disabled) {
        const err = new Error(`User ${username} has been disabled, probably because of a violation of the terms of service. ${result.serverlogs.disabled}`);
        err.status = 401;
        err.userFriendlyErrors = [`This username has been disabled. Please contact us at support@lingsync.org if you would like to reactivate this username. Reasons: ${result.serverlogs.disabled}`];
        throw err;
      }

      const user = new User(result);
      // const user = {
      //   ...result,
      // };
      // user.corpora = user.corpora || user.corpuses || [];
      if (result.corpuses) {
        debug(` Upgrading ${result.username} data structure to v3.0`);
        // delete user.corpuses;
      }

      return { user };
    })
    .catch((error) => {
      if (error.error === 'not_found') {
        debug(error, `${new Date()} No User found: ${username}`);
        const err = new Error(`User ${username} does not exist`);
        err.status = 404;
        // err.userFriendlyErrors = ['Username or password is invalid. Please try again.'];
        throw err;
      }

      if (error.error === 'unauthorized') {
        req.log.error(error, `${new Date()} Wrong admin username and password`);
        throw new Error('Server is mis-configured. Please report this error 8914.');
      }

      throw error;
    });
}

/**
 * uses tries to look up users by email
 * if optionallyRestrictToIncorrectLoginAttempts
 *  then it will look up users who might be calling forgotPassword
 */
function findByEmail({
  email,
  optionallyRestrictToIncorrectLoginAttempts,
  req = {
    id: '',
    log: {
      // eslint-disable-next-line no-console
      error: console.error,
      // eslint-disable-next-line no-console
      warn: console.warn,
    },
  },
} = {}) {
  if (!email) {
    return Promise.reject(new Error('Please provide an email'));
  }
  let usersQuery = 'usersByEmail';
  if (optionallyRestrictToIncorrectLoginAttempts) {
    usersQuery = 'userWhoHaveTroubleLoggingIn';
  }
  usersQuery = `${usersQuery}?key="${email}"`;
  const usersdb = nano({
    agentOptions: {
      headers: {
        'x-request-id': req.id || '',
      },
    },
    url: couchConnectUrl,
  }).db.use(config.usersDbConnection.dbname);
  // Query the database and callback with matching users
  return usersdb.view('users', usersQuery)
    .then((body) => {
      debug(`${new Date()} ${usersQuery} requested users who have this email ${email} from the server, and recieved results `);
      const users = body.rows.map((row) => row.value);
      debug(`${new Date()} users ${JSON.stringify(users)}`);
      if (users.length === 0) {
        const err = new Error(`No matching users for ${optionallyRestrictToIncorrectLoginAttempts}`);
        err.status = 401;
        err.userFriendlyErrors = [`Sorry, there are no users who have failed to login who have the email you provided ${email}. You cannot request a temporary password until you have at least tried to login once with your correct username. If you are not able to guess your username please contact us for assistance.`];
        throw err;
      }
      return ({
        users,
        info: {
          message: `Found ${users.length} users for ${optionallyRestrictToIncorrectLoginAttempts}`,
        },
      });
    })
    .catch((error) => {
      debug(`${new Date()} Error in findByEmail while quering ${usersQuery} ${JSON.stringify(error)}`);
      // const err = {
      //   message: error.message,
      //   status: error.status || error.statusCode,
      //   userFriendlyErrors: ['Server is not responding to request. Please report this 1609'],
      //   ...error,
      // };
      // error.userFriendlyErrors = error.userFriendlyErrors ||
      // ['Server is not responding to request. Please report this 1609'];
      throw error;
    });
}

function addCorpusToUser({
  username,
  newConnection,
  userPermissionResult,
  req,
} = {}) {
  return findByUsername({ username, req })
    .then(({ user, info }) => {
      debug('Find by username ', info);

      let shouldEmailWelcomeToCorpusToUser = false;
      // eslint-disable-next-line no-param-reassign
      user.serverlogs = user.serverlogs || {};
      // eslint-disable-next-line no-param-reassign
      user.serverlogs.welcomeToCorpusEmails = user.serverlogs.welcomeToCorpusEmails || {};
      if (!userPermissionResult.after) {
        const err = new Error('userPermissionResult.after was undefined');
        err.userFriendlyErrors = ['The server has errored please report this. 724'];
        throw err;
      }

      if (userPermissionResult.after.length > 0 && !user.serverlogs.welcomeToCorpusEmails[newConnection.dbname]) {
        shouldEmailWelcomeToCorpusToUser = true;
        // eslint-disable-next-line no-param-reassign
        user.serverlogs.welcomeToCorpusEmails[newConnection.dbname] = [Date.now()];
      }
      /*
       * If corpus is already there
       */
      debug(`${new Date()} Here are the user ${user.username}'s known corpora ${JSON.stringify(user.corpora)}`);
      let alreadyAdded;
      user.corpora.forEach((connection) => {
        if (userPermissionResult.after.length === 0) {
          // removes from all servers, TODO this might be something we should ask the user about.
          if (connection.dbname === newConnection.dbname) {
            // console.log('User', user.clone)
            user.corpora.remove(connection, 1);
          }
          return;
        }
        if (alreadyAdded) {
          return;
        }
        if (connection.dbname === newConnection.dbname) {
          alreadyAdded = true;
        }
      });
      debug(`${user.username}, after ${JSON.stringify(userPermissionResult)}`);
      if (userPermissionResult.after.length > 0) {
        if (alreadyAdded) {
          const message = `User ${user.username} now has ${
            userPermissionResult.after.join(' ')} access to ${
            newConnection.dbname}, the user was already a member of this corpus team.`;
          return Promise.resolve({
            userPermissionResult: {
              status: 200,
              message,
              ...userPermissionResult,
            },
            info: {
              message,
            },
          });
        }
        /*
         * Add the new db connection to the user, save them and send them an
         * email telling them they they have access
         */
        // user.corpora = user.corpora || [];
        user.corpora.add(newConnection);
      } else {
        // console.log('corpora before', user);
        // user.corpora = user.corpora.filter(({ dbname }) => (dbname !== newConnection.dbname));
        // console.log('corpora after', user.corpora);
        debug('after removed new corpus from user ', newConnection, user.corpora);
      }
      debug(`${new Date()} Here are the user ${user.username}'s after corpora ${JSON.stringify(user.corpora)}`);

      // return done({
      //   error: "todo",
      //   status: 412
      // }, [userPermissionResult, user.corpora], {
      //   message: "TODO. save modifying the list of corpora in the user "
      // });
      return saveUpdateUserToDatabase({ user, req })
        .then(() => {
          // console.log('user after save', userPermissionResult);
          // If the user was removed we can exit now
          if (userPermissionResult.after.length === 0) {
            const message = `User ${user.username} was removed from the ${
              newConnection.dbname
            } team.`;
            return {
              userPermissionResult: {
                status: 200,
                message,
                ...userPermissionResult,
              },
              info: {
                message,
              },
            };
          }
          const message = `User ${user.username} now has ${
            userPermissionResult.after.join(' ')} access to ${
            newConnection.dbname}`;
          // send the user an email to welcome to this corpus team
          if (shouldEmailWelcomeToCorpusToUser) {
            emailFunctions.emailWelcomeToCorpus({
              user,
              newConnection,
            });
          }
          return {
            userPermissionResult: {
              status: 200,
              message,
              ...userPermissionResult,
            },
            info: {
              message,
            },
          };
        })
        .catch((error) => {
          debug('error saving user ', error);
          const err = {
            message: error.message,
            status: error.status || error.statusCode || 505,
            userFriendlyErrors: [`User ${user.username} now has ${
              userPermissionResult.after.join(' ')} access to ${
              newConnection.dbname}, but we weren't able to add this corpus to their account. This is most likely a bug, please report it.`],
            ...error,
          };

          throw err;
        });
    })
    .catch((error) => {
      debug('error looking up user ', error);
      const err = {
        message: error.message,
        status: error.status || error.statusCode,
        userFriendlyErrors: ['Username doesnt exist on this server. This is a bug.'],
        ...error,
      };

      throw err;

    // if (!user) {
    //   // This case is a server error, it should not happen.
    //   userPermissionResult.status = error.status;
    //   userPermissionResult.message = 'Server was unable to process you request. Please report this: 1292';
    //   return done({
    //     status: 500,
    //     error: 'There was no error from couch, but also no user.',
    //   }, false, {
    //     message: userPermissionResult.message,
    //   });
    // }
    });
}
const normalizeRolesToDBname = function normalizeRolesToDBname({ dbname, role }) {
  // if (!role) {
  //   return;
  // }
  if (role && role.indexOf('_') > -1) {
    return `${dbname}_${role.substring(role.lastIndexOf('_') + 1)}`;
  }
  return `${dbname}_${role}`;
};
/*
 * Ensures the requesting user to make the permissions
 * modificaitons. Then adds the role to the user if they exist
 */
function addRoleToUser({
  req = {
    body: {},
    log: {
      // eslint-disable-next-line no-console
      error: console.error,
      // eslint-disable-next-line no-console
      warn: console.warn,
    },
  },
} = {}) {
  let dbConn = {};
  // If serverCode is present, request is coming from Spreadsheet app
  dbConn = req.body.connection;
  if (!dbConn || !dbConn.dbname || dbConn.dbname.indexOf('-') === -1) {
    debug(dbConn);
    const err = new Error('Client didnt define the dbname to modify.');
    err.status = 412;
    err.userFriendlyErrors = ['This app has made an invalid request. Please notify its developer. missing: corpusidentifier'];
    return Promise.reject(err);
  }
  if (!req || !req.body.username || !req.body.username) {
    const err = new Error('Please provide a username');
    err.status = 412;
    return Promise.reject(err);
  }
  if (!req || !req.body.users || req.body.users.length === 0 || !req.body.users[0].username) {
    const err = new Error('Client didnt define the username to modify.');
    err.status = 412;
    err.userFriendlyErrors = ['This app has made an invalid request. Please notify its developer. missing: user(s) to modify'];
    return Promise.reject(err);
  }
  if ((!req.body.users[0].add || req.body.users[0].add.length < 1)
    && (!req.body.users[0].remove || req.body.users[0].remove.length < 1)) {
    const err = new Error('Client didnt define the roles to add nor remove');
    err.status = 412;
    err.userFriendlyErrors = ['This app has made an invalid request. Please notify its developer. missing: roles to add or remove'];
    return Promise.reject(err);
  }

  return corpus.isRequestingUserAnAdminOnCorpus({
    connection: dbConn,
    req,
    username: req.body.username,
  }).then((result) => {
    debug(`${new Date()} User ${req.body.username} is admin and can modify permissions on ${dbConn.dbname}`, result);
    // convert roles into corpus specific roles
    const promises = req.body.users.map((userPermissionOriginal) => {
      const userPermission = {
        ...userPermissionOriginal,
      };
      if (userPermission.add && typeof userPermission.add.map === 'function') {
        userPermission.add = userPermission.add
          // TODO unify with corpus.addRoleToUserInfo
          .map((role) => normalizeRolesToDBname({ dbname: dbConn.dbname, role }));
      } else {
        userPermission.add = [];
      }

      if (userPermission.remove && typeof userPermission.remove.map === 'function') {
        userPermission.remove = userPermission.remove
          .map((role) => normalizeRolesToDBname({ dbname: dbConn.dbname, role }));
      } else {
        userPermission.remove = [];
      }
      debug('userPermission', userPermission);
      return userPermission;
    })
      /*
       * If they are admin, add the role to the user, then add the corpus to user if succesfull
       */
      .map((userPermission) => {
        debug('userPermission', userPermission);
        return corpus.addRoleToUserInfo({ connection: dbConn, userPermission })
          .then(({ userPermissionResult }) => {
            debug('corpus.addRoleToUserInfo result', userPermissionResult);
            return addCorpusToUser({
              username: userPermission.username, userPermissionResult, newConnection: dbConn, req,
            });
          })
          .then(({ userPermissionResult: userPermissionFinalResult }) => userPermissionFinalResult)
          .catch((error) => {
            const err = {
              message: error.message,
              status: error.status || error.statusCode || 412,
              userFriendlyErrors: [`Unable to add ${userPermission.username} to this corpus.${error.statusCode === 404 ? ' User not found.' : ''}`],
              ...error,
            };
            throw err;
          });
      });

    return Promise.all(promises);
    // .then((results) => {
    //   let thereWasAnError;
    //   debug(`${new Date()} recieved promises back ${results.length}`);
    //   // results.forEach((userPermis) => {
    //   //   if (userPermis && userPermis.status !== 200 && !thereWasAnError) {
    //   //     thereWasAnError = new Error(`One or more of the add roles requsts failed. ${userPermis.message}`);
    //   //     debug('one errored', thereWasAnError);
    //   //   }
    //   // });

    //   return results;

    //   // if (!thereWasAnError) {
    //   //   console.log('reeturning the results', results)
    //   //   return results;
    //   // } else {
    //   //   throw thereWasAnError;
    //   // }
    // });
    // .catch(reject);
    // .fail(function(error) {
    //       debug(" returning fail.");
    //       error.status = cleanErrorStatus(error.status) || req.body.users[0].status || 500;
    //       req.body.users[0].message = req.body.users[0].message ||
    //  " There was a problem processing your request. Please notify us of this error 320343";
    //       return done(error, req.body.users);
    //     });
  })
    .catch((err) => {
      debug(err, 'error isRequestingUserAnAdminOnCorpus');
      throw err;
    });
  // });
}

function verifyPassword({
  password,
  user,
} = {}) {
  return new Promise((resolve, reject) => {
    setTimeout(() => {
      try {
        /*
         * If the user didnt furnish a password, set a fake one. It will return
         * unauthorized.
         */
        bcrypt.compare(password || ' ', user.hash)
          .then((matches) => {
            if (matches) {
              return resolve({ user });
            }

            const err = new Error('Username or password is invalid. Please try again.');
            err.status = 401;
            return reject(err);
          })
          .catch(reject);
      } catch (err) {
        reject(err);
      }
    });
  });
}

/**
 * accepts an old and new password, a user and a function to be
 * called with (error, user, info)
 * TODO rename to changePassword
 *
 * @param oldpassword
 * @param newpassword
 * @param username
 */
function setPassword({
  oldpassword,
  newpassword,
  username,
  req,
} = {}) {
  if (!username) {
    const err = new Error('Please provide a username');
    err.status = 412;
    return Promise.reject(err);
  }
  if (!oldpassword) {
    const err = new Error('Please provide your old password');
    err.status = 412;
    return Promise.reject(err);
  }
  if (!newpassword) {
    const err = new Error('Please provide your new password');
    err.status = 412;
    return Promise.reject(err);
  }
  const safeUsernameForCouchDB = Connection.validateUsername(username);
  if (username !== safeUsernameForCouchDB.identifier) {
    const err = new Error('Username or password is invalid. Please try again.');
    err.status = 412;
    return Promise.reject(err);
  }

  return findByUsername({ username, req })
    .then(({ user }) => {
      debug(`${new Date()} Found user in setPassword: ${JSON.stringify(user)}`);

      return verifyPassword({
        user,
        password: oldpassword,
      });
    })
    // Save new password to couch too
    .then(({ user }) => corpusmanagement.changeUsersPassword({
      user,
      newpassword,
    })
      .catch((err) => {
        debug(`${new Date()} There was an error in creating changing the couchdb password ${JSON.stringify(err)}\n`);
        throw err;
      })
      .then((res) => {
        // dont save this if the email to change the password failed
        // const salt = bcrypt.genSaltSync(10);
        // user.hash = bcrypt.hashSync(newpassword, salt);
        debug(`${new Date()} There was success in creating changing the couchdb password: ${JSON.stringify(res)}\n`);
        return saveUpdateUserToDatabase({ user, req });
      }))
    .then(({ user, info }) => {
      // Change the success message to be more appropriate
      if (info.message === 'User details saved.') {
        // eslint-disable-next-line no-param-reassign
        info.message = 'Your password has succesfully been updated.';
      }
      return { user, info };
    })
    .catch((err) => {
      debug(`${new Date()} Error setPassword  ${username} : ${JSON.stringify(err.stack)}`);

      throw err;
    });
}

/**
 * accepts an email, finds associated users who have had incorrect login
 *
 *
 * @param email
 */
function forgotPassword({
  email,
  req,
} = {}) {
  if (!email) {
    const err = new Error('Please provide an email.');
    err.status = 412;
    return Promise.reject(err);
  }
  return findByEmail({
    email,
    optionallyRestrictToIncorrectLoginAttempts: 'onlyUsersWithIncorrectLogins',
    req,
  })
    .then(({ users }) => {
      const sameTempPasswordForAllTheirUsers = emailFunctions.makeRandomPassword();
      const promises = users.map((userToReset) => emailFunctions.emailTemporaryPasswordToTheUserIfTheyHavAnEmail({
        user: userToReset,
        temporaryPassword: sameTempPasswordForAllTheirUsers,
        successMessage: `A temporary password has been sent to your email ${email}`,
      }).then(({ user }) => {
        debug(`${new Date()} Saving new hash to the user ${user.username} after setting it to a temp password.`);
        return saveUpdateUserToDatabase({ user, req });
      }));
      let passwordChangeResults = '';
      const forgotPasswordResults = {
        status_codes: '',
        error: {
          status: 200,
          error: '',
        },
        info: {
          message: '',
        },
      };

      return Promise.all(promises).then((results) => {
        debug(`${new Date()} recieved promises back ${results.length}`);
        results.forEach((result) => {
          if (result.state === 'fulfilled') {
            const { value } = result;
            if (value.source && value.source.exception) {
              passwordChangeResults = `${passwordChangeResults} ${value.source.exception}`;
            } else {
              passwordChangeResults = `${passwordChangeResults} Success`;
            }
          } else {
          // not fulfilled,happens rarely
            const { reason } = result;
            passwordChangeResults = `${passwordChangeResults} ${reason}`;
          }
        });
        debug(`${new Date()} passwordChangeResults ${passwordChangeResults}`);
        results.forEach((result) => {
          debug('passwordChangeResults results', result);
          if (result.error) {
            forgotPasswordResults.status_codes = `${forgotPasswordResults.status_codes} ${result.error.status}`;
            if (result.error.status > forgotPasswordResults.error.status) {
              forgotPasswordResults.error.status = result.error.status;
            }
            forgotPasswordResults.error.error = `${forgotPasswordResults.error.error} ${result.error.error}`;
          }
          forgotPasswordResults.info.message = `${forgotPasswordResults.info.message} ${result.info.message}`;
        });
        if (passwordChangeResults.indexOf('Success') > -1) {
          // At least one email was sent, this will be considered a success
          // since the user just needs one of the emails to login to his/her username(s)
          return {
            forgotPasswordResults,
            info: forgotPasswordResults.info,
          };
        }
        // forgotPasswordResults.status_codes = forgotPasswordResults.status_codes;
        // , forgotPasswordResults, forgotPasswordResults.info);
        throw forgotPasswordResults.error;
      });
    })
    .catch((error) => {
      debug('forgotPassword', error.status);
      const err = {
        message: error.message,
        status: error.status || error.statusCode,
        // userFriendlyErrors: error.userFriendlyErrors,
        ...error,
      };
      throw err;
    });
}

function handleInvalidPasswordAttempt({ user, req }) {
  debug(`${new Date()} User found, but they have entered the wrong password ${user.username}`);
  /*
   * Log this unsucessful password attempt
   */
  // eslint-disable-next-line no-param-reassign
  user.serverlogs = user.serverlogs || {};
  // eslint-disable-next-line no-param-reassign
  user.serverlogs.incorrectPasswordAttempts = user.serverlogs.incorrectPasswordAttempts || [];
  user.serverlogs.incorrectPasswordAttempts.push(new Date());
  // eslint-disable-next-line no-param-reassign
  user.serverlogs.incorrectPasswordEmailSentCount = user.serverlogs.incorrectPasswordEmailSentCount || 0;
  const incorrectPasswordAttemptsCount = user.serverlogs.incorrectPasswordAttempts.length;
  // console.log('incorrectPasswordAttempts', user.serverlogs)
  const timeToSendAnEmailEveryXattempts = incorrectPasswordAttemptsCount >= 5;
  /* Dont reset the public user or lingllama's passwords */
  if (user.username === 'public' || user.username === 'lingllama') {
    return Promise.resolve({
      user,
    });
  }
  if (!timeToSendAnEmailEveryXattempts) {
    let countDownUserToPasswordReset = '';
    if (incorrectPasswordAttemptsCount > 1) {
      // TOOD this isnt executing
      countDownUserToPasswordReset = ` You have ${5 - incorrectPasswordAttemptsCount} more attempts before a temporary password will be emailed to your registration email (if you provided one).`;
    }
    return saveUpdateUserToDatabase({ user, req })
      .then(() => {
        debug(`${new Date()} Server logs updated in user. countDownUserToPasswordReset`, countDownUserToPasswordReset);
        return {
          user,
          info: {
            message: `Username or password is invalid. Please try again.${countDownUserToPasswordReset}`,
          },
        };
      });
  }

  debug(`${new Date()} User ${user.username} found, but they have entered the wrong password ${incorrectPasswordAttemptsCount} times. `);
  /*
   * This emails the user, if the user has an email, if the
   * email is 'valid' TODO do better email validation. and if
   * the config has a valid user. For the dev and local
   * versions of the app, this wil never be fired because the
   * config doesnt have a valid user. But the production
   * config does, and it is working.
   */
  if (!user.email || user.email.length < 5) {
    debug(`${new Date()}User didn't not provide a valid email, so their temporary password was not sent by email.`);
    return saveUpdateUserToDatabase({ user, req })
      .then(() => {
        debug(`${new Date()} Email doesnt appear to be vaild. ${user.email}`);
        return {
          info: {
            message: 'You have tried to log in too many times and you dont seem to have a valid email so we cant send you a temporary password.',
          },
        };
      });
  }

  const temporaryPassword = emailFunctions.makeRandomPassword();
  return emailFunctions.emailTemporaryPasswordToTheUserIfTheyHavAnEmail({
    user,
    temporaryPassword,
    successMessage: 'You have tried to log in too many times. We are sending a temporary password to your email.',
  })
    .then(({ user: userFromPasswordEmail, info }) => {
      debug(`${new Date()} Reset User ${user.username} password to a temp password.`);
      return saveUpdateUserToDatabase({ user: userFromPasswordEmail, req })
        .then(() => ({
          user: userFromPasswordEmail,
          info,
        }));
    }).catch((emailError) => ({
      info: {
        message: `Username or password is invalid. Please try again. You have tried to log in too many times. ${emailError.userFriendlyErrors[0]}`,
      },
    }));
}

/*
 * Looks up the user by username, gets the user, confirms this is the right
 * password. Takes user details from the request and saves them into the user,
 *
 * If its not the right password does some logging to find out how many times
 * they have attempted, if its too many it emails them a temp password if they
 * have given us a valid email. If this is a local or dev server config, it
 * doesn't email, or change their password.
 */
function authenticateUser({
  username,
  password,
  syncDetails,
  syncUserDetails,
  req = {
    id: '',
    log: {
      // eslint-disable-next-line no-console
      error: console.error,
      // eslint-disable-next-line no-console
      warn: console.warn,
    },
  },
} = {}) {
  if (!username) {
    const err = new Error(`Username was not specified. ${username}`);
    err.status = 412;
    err.userFriendlyErrors = ['Please supply a username.'];
    return Promise.reject(err);
  }

  if (!password) {
    const err = new Error(`Password was not specified. ${password}`);
    err.status = 412;
    err.userFriendlyErrors = ['Please supply a password.'];
    return Promise.reject(err);
  }

  const safeUsernameForCouchDB = Connection.validateUsername(username.trim());
  if (username !== safeUsernameForCouchDB.identifier) {
    const err = new Error('username is not safe for db names');
    err.status = 406;
    err.userFriendlyErrors = [`Username or password is invalid. Maybe your username is ${safeUsernameForCouchDB.identifier}?`];
    return Promise.reject(err);
  }

  return findByUsername({ username, req })
    .then(({ user }) => verifyPassword({ password, user })
      .catch((error) => handleInvalidPasswordAttempt({ user, req })
        .then(({ info }) => {
          // Don't tell them its because the password is wrong.
          debug(`${new Date()} Returning: Username or password is invalid. Please try again.`);
          const err = {
            message: error.message,
            userFriendlyErrors: [info.message],
            status: error.status || 401,
            ...error,
          };
          throw err;
        })))
    .then(({ user }) => {
      debug(`${new Date()} User found, and password verified ${username} user.toJSON ${typeof user.toJSON}`);
      /*
       * Save the users' updated details, and return to caller TODO Add
       * more attributes from the req.body below
       */
      if (syncDetails !== 'true' && syncDetails !== true) {
        return { user };
      }
      debug(`${new Date()} Here is syncUserDetails: ${JSON.stringify(syncUserDetails)}`);
      let userToSave;
      try {
        userToSave = new User(syncUserDetails);
        userToSave.newCorpora = userToSave.newCorpora || userToSave.newCorpusConnections;
      } catch (e) {
        req.log.error(e, "Couldnt convert the users' sync details into a user.");
      }
      if (!userToSave || !userToSave.newCorpora) {
        return { user };
      }
      debug(`${new Date()} It looks like the user has created some new local offline newCorpora. Attempting to make new corpus on the team server so the user can download them.`);
      return createNewCorpusesIfDontExist({ user, corpora: userToSave.newCorpora, req })
        .then((corpora) => {
          // TODO this corpora is not written into the user?
          debug('createNewCorpusesIfDontExist corpora', corpora);
          // user = new User(user);
          // TODO remove newCorpora?
          user.merge('self', userToSave, 'overwrite');
          // user = user.toJSON();
          /* Users details which can come from a client side must be added here,
          otherwise they are not saved on sync. */
          // user.corpora = syncUserDetails.corpora;
          // user.corpora = syncUserDetails.corpora;
          // user.email = syncUserDetails.email;
          // user.gravatar = syncUserDetails.gravatar;
          // user.researchInterest = syncUserDetails.researchInterest;
          // user.affiliation = syncUserDetails.affiliation;
          // user.appVersionWhenCreated = syncUserDetails.appVersionWhenCreated;
          // user.authUrl = syncUserDetails.authUrl;
          // user.description = syncUserDetails.description;
          // user.subtitle = syncUserDetails.subtitle;
          // user.dataLists = syncUserDetails.dataLists;
          // user.prefs = syncUserDetails.prefs;
          // user.mostRecentIds = syncUserDetails.mostRecentIds;
          // user.firstname = syncUserDetails.firstname;
          // user.lastname = syncUserDetails.lastname;
          // user.sessionHistory = syncUserDetails.sessionHistory;
          // user.hotkeys = syncUserDetails.hotkeys;
          return { user };
        });
      // .catch((err) => {
      //   if (err.corpusexisted) {
      //     return { user };
      //   }
      //   throw err;
      // });
    })
    .then(({ user }) => {
      // if we avoid assign into the arg, we loose the _rev and get a document update conflict
      // const user = userToSave.clone();
      // user._rev = userToSave._rev;
      // eslint-disable-next-line no-param-reassign
      user.dateModified = new Date();
      // eslint-disable-next-line no-param-reassign
      user.serverlogs = user.serverlogs || {};
      // eslint-disable-next-line no-param-reassign
      user.serverlogs.successfulLogins = user.serverlogs.successfulLogins || [];
      user.serverlogs.successfulLogins.push(new Date());
      if (user.serverlogs.incorrectPasswordAttempts && user.serverlogs.incorrectPasswordAttempts.length > 0) {
        // eslint-disable-next-line no-param-reassign
        user.serverlogs.oldIncorrectPasswordAttempts = user.serverlogs.oldIncorrectPasswordAttempts || [];
        // eslint-disable-next-line no-param-reassign
        user.serverlogs.oldIncorrectPasswordAttempts = user.serverlogs.oldIncorrectPasswordAttempts
          .concat(user.serverlogs.incorrectPasswordAttempts);
        // eslint-disable-next-line no-param-reassign
        user.serverlogs.incorrectPasswordAttempts = [];
      }
      return saveUpdateUserToDatabase({ user, req });
    })
    .catch((error) => {
      debug('error', error);
      // Don't tell them its because the user doesnt exist
      const err = {
        message: error.message,
        status: error.status,
        ...error,
      };
      if (err.message === `User ${username} does not exist`) {
        err.status = 401;
        err.userFriendlyErrors = ['Username or password is invalid. Please try again.'];
      }
      throw err;
    });
}
/**
 * Takes parameters from the request and creates a new user json, salts and
 * hashes the password, has the corpusmanagement library create a new couchdb
 * user, permissions and couches for the new user. The returns the save of the
 * user to the users database.
 */
function registerNewUser({
  req = {
    body: {},
    id: '',
    log: {
      // eslint-disable-next-line no-console
      error: console.error,
      // eslint-disable-next-line no-console
      warn: console.warn,
    },
  },
} = {}) {
  if (req.body.username === 'yourusernamegoeshere') {
    const err = new Error('Username is the default username');
    err.status = 412;
    err.userFriendlyErrors = ['Please type a username instead of yourusernamegoeshere.'];
    return Promise.reject(err);
  }
  if (!req || !req.body.username || !req.body.username) {
    const err = new Error('Please provide a username');
    err.status = 412;
    return Promise.reject(err);
  }
  if (req.body.username.length < 3) {
    const err = new Error(`Please choose a longer username \`${req.body.username}\` is too short.`);
    err.status = 412;
    return Promise.reject(err);
  }
  const safeUsernameForCouchDB = Connection.validateUsername(req.body.username);
  if (req.body.username !== safeUsernameForCouchDB.identifier) {
    const err = new Error('username is not safe for db names');
    err.status = 406;
    err.userFriendlyErrors = [`Please use '${safeUsernameForCouchDB.identifier}' instead (the username you have chosen isn't very safe for urls, which means your corpora would be potentially inaccessible in old browsers)`];
    return Promise.reject(err);
  }
  // Make sure the username doesn't exist.
  return findByUsername({
    username: req.body.username,
    req,
    // req: {
    //   id: `pre-${req.id}`,
    //   log: req.log
    // },
  })
    .then(() => {
      const err = new Error(`Username ${req.body.username} already exists, try a different username.`);
      err.status = err.status || err.statusCode || 409;
      throw err;
    })
    .catch((err) => {
      if (err.message !== `User ${req.body.username} does not exist`) {
        throw err;
      }

      debug(`${new Date()} Registering new user: ${req.body.username}`);
      const user = new User(req.body);
      const salt = bcrypt.genSaltSync(10);
      user.hash = bcrypt.hashSync(req.body.password, salt);
      user.dateCreated = user.dateCreated || Date.now();
      user.authServerVersionWhenCreated = authServerVersion;
      user.prefs = JSON.parse(JSON.stringify(DEFAULT_USER_PREFERENCES));
      // FieldDB.User is not setting the gravatar from the username
      if (!user.gravatar) {
        user.gravatar = md5(user.username);
      }
      let { appbrand } = req.body;
      if (!appbrand) {
        if (req.body.username.indexOf('test') > -1) {
          appbrand = 'beta';
        } else if (req.body.username.indexOf('anonymouskartulispeechrecognition') === 0) {
          appbrand = 'kartulispeechrecognition';
        } else if (req.body.username.search(/anonymous[0-9]/) === 0) {
          appbrand = 'georgiantogether';
        } else if (req.body.username.search(/anonymouswordcloud/) === 0) {
          appbrand = 'wordcloud';
        } else {
          appbrand = 'lingsync';
        }
      }
      user.appbrand = appbrand;
      debug('createCouchDBUser appbrand', appbrand);

      if (dontCreateDBsForLearnXUsersBecauseThereAreTooManyOfThem
      && req.body.username.indexOf('anonymous') === 0) {
        debug(`${new Date()}  delaying creation of the dbs for ${req.body.username} until they can actually use them.`);
        // user.newCorpora = user.corpora;
        return emailFunctions.emailWelcomeToTheUser({ user })
          .then(() => {
            debug(`${new Date()} Sent command to save user to couch`);
            /*
           * The user was built correctly, saves the new user into the users database
           */
            return saveUpdateUserToDatabase({ user, req });
          });
      }

      const connection = req.body.connection
        || req.body.couchConnection ? new Connection(req.body.connection
        || req.body.couchConnection) : Connection.defaultConnection(user.appbrand);
      connection.appbrand = connection.appbrand || user.appbrand;
      // TODO this has to be come asynchonous if this design is a central server who can register users on other servers
      if (!connection.dbname || connection.dbname === `${user.username}-firstcorpus`) {
        connection.dbname = `${user.username}-firstcorpus`;
        if (connection.appbrand === 'phophlo') {
          connection.dbname = `${user.username}-phophlo`;
        }
        if (connection.appbrand === 'kartulispeechrecognition') {
          connection.dbname = `${user.username}-kartuli`;
        }
        if (connection.appbrand === 'georgiantogether') {
          connection.dbname = `${user.username}-kartuli`;
        }
      }

      return createCouchDBUser({
        req,
        user,
        password: req.body.password,
        // connection: corpusDetails.connection,
      })
        .then(({ couchUser, whichUserGroup }) => {
          debug('user created', couchUser, whichUserGroup);

          return corpus.createNewCorpus({
            connection,
            req,
            user,
            whichUserGroup,
          });
        })
        // .then((result) => {
        //   debug(`${new Date()} There was success in creating the corpus: ${JSON.stringify(result.info)}\n`);
        //   /* Save corpus, datalist and session docs so that apps can load the dashboard for the user */
        //   const db = nano({
        //     agentOptions: {
        //       headers: {
        //         'x-request-id': req.id,
        //       },
        //     },
        //     url: `${couchConnectUrl}/${corpusDetails.dbname}`,
        //   });
        //   return db.bulk({
        //     docs: docsNeededForAProperFieldDBDatabase,
        //   });
        // })
        .then((couchresponse) => {
          debug(`${new Date()} Created corpus for ${connection.dbname}\n`, couchresponse);
          user.corpora = [connection];
          return emailFunctions.emailWelcomeToTheUser({ user })
            .then(() => {
              debug(`${new Date()} Sent command to save user to couch`);
              /*
             * The user was built correctly, saves the new user into the users database
             */
              return saveUpdateUserToDatabase({ user, req });
            });
        })
        .catch((couchErr) => {
          debug(couchErr, `${new Date()} There was an couchError in creating the docs for the users first corpus`);
          undoCorpusCreation({ user, connection });
          const error = {
            message: couchErr.message,
            status: couchErr.status || couchErr.statusCode,
            userFriendlyErrors: [`Server is not responding for request to create user \`${user.username}\`. Please report this.`],
            ...couchErr,
          };
          throw error;
          // debug(`${new Date()} There was an couchError in creating the corpus
          // database: ${JSON.stringify(couchErr)}\n`);
          // undoCorpusCreation(user, corpusDetails.connection, docsNeededForAProperFieldDBDatabase);
          // couchErr.status = couchErr.status || couchErr.statusCode || 500;
          // couchErr.userFriendlyErrors = [`Server is not responding for request
          // to create user \`${user.username}\`. Please report this.`];
          // reject(couchErr);
        });
    });
}

module.exports = {
  addCorpusToUser,
  addRoleToUser,
  authenticateUser,
  createNewCorpusesIfDontExist,
  fetchCorpusPermissions,
  findByEmail,
  findByUsername,
  forgotPassword,
  registerNewUser,
  sampleUsers,
  saveUpdateUserToDatabase,
  setPassword,
  sortByUsername,
  undoCorpusCreation,
  verifyPassword,
};

FieldDB / AuthenticationWebService / 20049962129

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous