index.js

/*
 * Copyright ©️ 2019 GaltProject Society Construction and Terraforming Company
 * (Founded by [Nikolai Popeka](https://github.com/npopeka)
 *
 * Copyright ©️ 2019 Galt•Core Blockchain Company
 * (Founded by [Nikolai Popeka](https://github.com/npopeka) by
 * [Basic Agreement](ipfs/QmaCiXUmSrP16Gz8Jdzq6AJESY1EAANmmwha15uR3c1bsS)).
 */

const OperationsQueue = require("./operationsQueue");

const xkcdPassword = require('xkcd-password')();
const _ = require("lodash");
const pIteration = require("p-iteration");

module.exports = class GeesomeEthManager {
  constructor(
    _database, 
    _chainService, 
    _geesomeClient
  ) {
    this.database = _database;
    this.chainService = _chainService;
    this.geesomeClient = _geesomeClient;
    
    this.operationsQueue = new OperationsQueue();
  }
  
  async registerUser(userAddress, userData, onCreate = null) {
    console.log('registerUser', userAddress);
    userAddress = userAddress.toLowerCase();
    
    const existLog = await this.database.getLog('registerUser', userAddress);
    if(existLog) {
      console.log('user', userAddress, 'already registered, found in logs');
      return onCreate ? onCreate(null) : null;
    }

    const existAccount = await this.geesomeClient.adminGetUserAccount('ethereum', userAddress);
    if(existAccount) {
      console.log('user', userAddress, 'already registered, found in geesome');
      await this.database.addLog('registerUser', userAddress);
      return onCreate ? onCreate(null) : null;
    }

    if(!userData.name) {
      const secretKey = (await xkcdPassword.generate({numWords: 2, minLength: 5, maxLength: 8})).map(s => _.upperFirst(s)).join(' ');
      const cutAddress = userAddress.slice(0, 7) + "..." + userAddress.slice(-4);
      userData.name = secretKey + " " + cutAddress;
    }
    
    const createdUser = await this.geesomeClient.adminCreateUser({
      name: userData.name,
      accounts: [{provider: 'ethereum', address: userAddress}],
      ...userData
    });

    await this.database.addLog('registerUser', userAddress);

    if(onCreate) {
      onCreate(createdUser);
    }

    if(userData.limits) {
      await pIteration.forEach(userData.limits, (userLimit) => {
        userLimit.userId = createdUser.id;
        userLimit.isActive = true;
        return this.geesomeClient.adminSetUserLimit(userLimit);
      })
    }
  }
  
  async registerUserOperation(userAddress, userData, onCreate = null) {
    this.operationsQueue.addOperation(async () => {
      return this.registerUser(userAddress, userData, onCreate);
    });
  }
};