Дмитрий Беляев

Вы ничего не резолвите и не режектите, следовательно данный промис никогда не пойдет дальше по цепочке.
Очевидно, что db.query асинхронная, но так как она не получила колбэка, то выкидывает свое исключение в общий поток, к этому моменту функция-обработчик промиса уже успешно завершена, естественно она не ловит при этом ошибку.
Многое конечно зависит от драйвера БД, но подозреваю что нужно сделать так:

let userInsert = new Promise((resolve, reject) => {
  db.query('INSERT INTO users (email, password) VALUES (?, ?)', [user.email, user.password], err => {
    if(err) {
      reject(err);
      return;
    }
    resolve();
  });
});

ЧЯДНТ?

не дожидаетесь выполнения асинхронной задачи и завершаете процесс

cors - это мидлвар к express, библиотеке работающей на сервере и к ангуляру (работающему на клиенте) никакого отношения не имеющей
Если стороннее апи не отдает CORS заголовки с клиентской части Вы его никак не запросите, но можно проксировать запрос у себя на сервере

console.dir

yield можно использовать только в генераторе, у Вас он во вложенной функции
проще всего заменить forEach на обычный цикл:

exports.get=function* (next){
  const ctx=this;
  let sql = "SELECT * FROM clients_forums_knowledge_base ORDER BY orders ASC";
  let forumsKnowledgeBase = yield ctx.locals.db.query(sql);
  for(let idx = 0, n = forumsKnowledgeBase.length; idx < n; idx++) {
    let elem = forumsKnowledgeBase[idx];
    let sql='SELECT clients_knowledge_base.name, clients_knowledge_base.id,clients_knowledge_base.file FROM clients_knowledge_base,clients_forums_knowledge_base WHERE clients_forums_knowledge_base.id = clients_knowledge_base.forum AND clients_knowledge_base.forum = ? ORDER BY name ASC';
    let rows = yield ctx.locals.db.query(sql,elem.id);
    elem.items=rows ;
  }
};

Любые модули в js сделаны на замыканиях, поэтому и не видят переменные и функции друг друга
Главная задача, которую решают модули - как раз таки разграничение области видимости.

В node.js встроена модульная система CommonJS, вот ее основы:
1) Модули подключаются синхронно и отрабатывают 1 раз за время жизни приложения, после результат кэшируется
2) В качестве результата работы модуля используется значение module.exports, которое модуль может изменять
3) Если присвоить в module.exports новое значение, после того как модуль отработал - это никак не отразится на внешних подключениях модуля, однако если module.exports объект, можно менять поля этого объекта
4) По умолчанию module.exports содержит новый пустой объект, ссылка на этот объект содержится так же в переменной exports

https://nodejs.org/api/child_process.html#child_pr...
https://nodejs.org/api/child_process.html#child_pr...

const zlib = require('zlib');
const fs = require('fs');

/**
 * Read the gz compresed file
 * @param filename (string) full path to file
 * @return (Promise<Buffer>)
 */
function readGZipFile(filename) {
    return new Promise((resolve, reject) => {
        fs.readFile(filename, (err, buf) => {
            if(err) {
                reject(err);
                return;
            }
            zlib.gunzip(buf, (err, buf) => {
                if(err) {
                    reject(err);
                    return;
                }
                resolve(buf);
            });
        });
    });
}

//Использование
const path = require('path');
readGZipFile(path.resolve(__dirname, 'lib.txt.gz')).then(buf => JSON.parse(buf.toString())).then(data => {
    //Ваш код для работы с data
});

Вы отправляете каждого юзера отдельным сообщением, собирайте их в массив и отправляйте этот массив после .each()

UPD

io.sockets.on('connection', function(socket) {
  var group = 'fnatic';
  var url = 'http://steamcommunity.com/groups/' + group + '#members';
  request(url, function(err, resp, body){
    $ = cheerio.load(body);
    links = $('a');
    var users = [];
    $(links).each(function(i, link){
      // console.log($(link).attr('href'));
      users.push($(link).attr('href'));
    });
    socket.emit('hatler', users);
  });
});

Если все-таки хочется сделать самому, то спецификация в помощь: https://tools.ietf.org/html/rfc7233
А вообще настраиваем nginx-proxy и не заморачиваемся

Промисы в помощь:

checkPrice(items).then(console.log.bind(console, "Call result: "));

function checkPrice(items) {
  return Promise.all(items.map(function(item, index, array) {
    return new Promise(function(resolve) {
        market.getItemsPrice(730, item.market_hash_name, function(data) {
          var price = parseFloat(data[item.market_hash_name].lowest_price.replace("$",""));
          resolve(price);
          console.log("Function result: " + price);
        });
    });
  })).then(function(prices) {
    //сумма всех полученных цен
    return prices.reduce(function(result, price) {
        result += price;
        return result;
    }, 0);
  });
}