Вложенные транзакции с pg-promise

Улучшение собственного ответа Жана Филиппа:

// Columns
var tweetCols = ['id', 'created_at', 'userid', 'tweet', 'coordinates', 'favorite_count', 'retweet_count'];

var hashtagCols = ['name', 'relevancetraffic', 'relevancedisaster'];

//pgp Column Sets
var cs_tweets = new pgp.helpers.ColumnSet(tweetCols, {table: 'tweets'});

var cs_hashtags = new pgp.helpers.ColumnSet(hashtagCols, {table: 'hashtags'});

return {
    /* Tweets */
    // Add a new tweet and update the corresponding hash tags
    add: body =>
        db.tx(t => {
            return t.one(pgp.helpers.insert(body, cs_tweets) + ' ON CONFLICT(id) DO UPDATE SET coordinates = ' + body.coordinates + ' RETURNING id')
                .then(tweet => {
                    var queries = Object.keys(body.hashtags).map((_, idx) => {
                        return t.one(pgp.helpers.insert(body.hashtags[i], cs_hashtags) + 'ON CONFLICT(name) DO UPDATE SET fool = $1 RETURNING id', 'f')
                            .then(hash => {
                                return t.none('INSERT INTO hashtagmap(tweetid, hashtagid) VALUES($1, $2) ON CONFLICT DO NOTHING', [+tweet.id, +hash.id]);
                            });
                    });
                    return t.batch(queries);
                });
        })
            .then(data => {
                // transaction was committed;
                // data = [null, null,...] as per t.none('INSERT INTO hashtagmap...
            })
            .catch(error => {
                // transaction rolled back
            })
},

ПРИМЕЧАНИЯ:

• Согласно моим заметкам ранее, вы должны связать все запросы, иначе вы получите свободные обещания.
• Держитесь подальше от вложенных транзакций, если вы точно не понимаете, как они работают в PostgreSQL (прочитайте это и, в частности, раздел Limitations).
• Избегайте ручного форматирования запросов, это небезопасно, всегда полагайтесь на форматирование запросов в библиотеке.
• Если вы не передаете результат транзакции куда-то еще, вы должны как минимум предоставить обработчик .catch.

P.S. Для синтаксиса типа +tweet.id это то же самое, что и parseInt(tweet.id), только короче, если это строки ;)

Для тех, кто столкнется с подобной проблемой, я опубликую ответ.

Во-первых, мои ошибки:

1. В цикле for: body.hashtag.length не существует, потому что я имею дело с объектом (здесь очень простая ошибка). Изменено на Object.keys(body.hashtags).length
2. Зачем использовать так много транзакций? После ответа vitaly-t в: Взаимозависимые транзакции с pg-promise я удалил дополнительные транзакции. Мне пока непонятно, как можно открыть одну транзакцию и использовать результат одного запроса в другой в той же транзакции.

Вот окончательный код:

    // Columns
var tweetCols = ['id','created_at','userid','tweet','coordinates','favorite_count','retweet_count'];

var hashtagCols = ['name','relevancetraffic','relevancedisaster'];

//pgp Column Sets
var cs_tweets = new pgp.helpers.ColumnSet(tweetCols, {table: 'tweets'});

var cs_hashtags = new pgp.helpers.ColumnSet(hashtagCols, {table:'hashtags'});

return {
    /* Tweets */
    // Add a new tweet and update the corresponding hashtags
    add: body =>
        rep.tx(t => {
            return t.one(pgp.helpers.insert(body,cs_tweets)+" ON CONFLICT(id) DO UPDATE SET coordinates = "+body.coordinates+" RETURNING id")
                .then(tweet => {
                    var queries = [];
                    for(var i = 0; i < Object.keys(body.hashtags).length; i++){
                        queries.push(
                            t.one(pgp.helpers.insert(body.hashtags[i],cs_hashtags) + "ON CONFLICT(name) DO UPDATE SET fool ='f' RETURNING id")
                                .then(hash =>{
                                    t.none("INSERT INTO hashtagmap(tweetid,hashtagid) VALUES("+tweet.id+","+hash.id+") ON CONFLICT DO NOTHING");
                                })
                            );
                    }
                    return t.batch(queries);
                });
        }),