Многозадачность с Nightmare js

const Nightmare = require('nightmare');
const dream = Nightmare({show: 'true'});
 
const EventEmitter = require('events');
class MyEmitter extends EventEmitter {}
const myEmitter = new MyEmitter();
 
myEmitter.on('error', (err) => {
  console.log('whoops! there was an error');
});
 
myEmitter.on('db_connect', function(){
  dbconn.connect(function(err){
      if(err){
        console.log('Database connection error');
      }else{
        console.log('Database connection successful');
      }
    });
});
 
dbconn.query('SELECT `id`, `operator`, `telefon`, `password`, `data` FROM `base` LIMIT 2', function (error, results, fields) {
    if (error) throw error;
    myEmitter.emit('db_connect');
    for (i = 0; i < results.length; i++) { 
        myEmitter.emit('beeline', results[i].id, results[i].telefon, results[i].password);
    }
});
 
myEmitter.on('beeline', function(base_id, login, pass){
    console.log('<=====RUN balance: '+login+'=====>');
    dream.goto('https://my.beeline.ru')
      .insert('input[name="loginFormB2C:loginForm:login"]', login)
      .insert('input[name="loginFormB2C:loginForm:passwordPwd"]', pass)
      .insert('input[name="loginFormB2C:loginForm:password"]', pass)
      .click('a[onclick="togglePasswordField(this)"]')
      .wait(5000)
      .end()
      .catch((error) => {
        console.error('Search failed:', error);
      });
  
});

for(let i = 0; i < 20; i++) {
  myEmitter.on('some_event', someFunction.bind(null, i));
}

myEmitter..setMaxListeners(20);

myEmitter.emit('db_connect');

dbconn.query('SELECT `id`, `op....);

myEmitter.on('beeline', function(base_id, login, pass){
    console.log('<=====RUN balance: '+login+'=====>');
    Nightmare({show: 'true'}).goto('https://my.beeline.ru')
      .insert('input[name="loginFormB2C:loginForm:login"]', login)
      .insert('input[name="loginFormB2C:loginForm:passwordPwd"]', pass)
      .insert('input[name="loginFormB2C:loginForm:password"]', pass)
      .click('a[onclick="togglePasswordField(this)"]')
      .wait(5000)
      .end()
      .catch((error) => {
        console.error('Search failed:', error);
      });
});

....
for (i = 0; i < results.length; i++) { 
        myEmitter.emit('beeline', results[i].id, results[i].telefon, results[i].password);
    }
myEmitter.emit('execute');
....
let promise = Promise.resolve();
myEmitter.on('beeline', function(base_id, login, pass){
    console.log('<=====RUN balance: '+login+'=====>');
    promise = promise.then(() => {
        return new Promise((resolve, reject) => {
            dream.goto('https://my.beeline.ru')
            .insert('input[name="loginFormB2C:loginForm:login"]', login)
            .insert('input[name="loginFormB2C:loginForm:passwordPwd"]', pass)
            .insert('input[name="loginFormB2C:loginForm:password"]', pass)
            .click('a[onclick="togglePasswordField(this)"]')
            .wait(5000)
            .then(resolve)
            .catch(reject);
        });
    });
});
 
myEmitter.on('execute', function() {
    console.log('Run everything...');
    promise.then(() => {
        console.log('All manipulations are done!');
        dream.end();
    });
});