Если утрировать:
function mainExecutionStream(connection){
//здесь ВЕСЬ код
}
postgresql.connect(connectionString).then(mainExecutionStream);
А так код должен быть разбит на методы и функции вызывающие друг друга.
Ну и ещё по новомодному можно так:
( async function mainExecutionStream(connection){
var connection = await postgresql.connect(connectionString);
//здесь ВЕСЬ код
}())
только следует помнить, что async/await - это не sleep никакой, а обёртка над промисами.