Не всегда резолвится промис

[monolithed]

При невыясненных обстоятельствах у меня бывают случаи когда промис не резолвится.

tarantool.insert(...)
    .then(result => { /* Не вызывается */  })
    .catch(error => { /* Не вызывается */  })

При этом, записи в базу добавляются.

Бегло нашел множество мест где как мне кажется такое возможно, например
Возможно из-за того, что условие в этом месте может не выполниться

PS: Кстати, почему бы не заменить vow на стандартные Promise, которые уже есть в ноде?

[KlonD90]

Понял, гляну.
PS: Перепишу.

[KlonD90]

Нету еще каких-то подробностей новых?

[monolithed]

Повторяется стабильно.
У меня вызов операции insert завернут в десяток других промисов, но как они могут влиять на поведение не понимаю.

Весь код транслируется из ES6 через babel-node

// ... Куча промисов
// .. Тут стоит метка профайлера с логом
tarantool.insert(...)
    .then(result => { /* Не вызывается */  })
    .catch(error => { /* Не вызывается */  })
// .. Тут стоит метка профайлера  с логом 
// Данные в базу добавляются, 100%

Операцию insert выполняю в цикле из более чем 3000 итераций без каких-либо задержек (хотя я пробовал добавлять один элемент, колбек также не сработал).

Если вызвать insert отдельно от моего кода, то все работает.

Структура индексов такая:

return function (space)
    local name, city, host, rank, rate =
        1, 2, 3, 4, 5

    space:create_index('primary', {
        parts = {
            name, 'str',
            city, 'str'
        }
    })

    space:create_index('secondary', {
        type = 'tree',
        unique = false,
        parts = {
            host, 'str',
            rank, 'num',
            rate, 'num',
        }
    })
end

Пример массива данных:

[
    'google.com', 
    'Mountain View', 
    'google.com', 
    100, 
    2000, 
    [
          'YouTube',
          'Nest Labs',
          'FeedBurner', 
          'Songza'
    ],
    'Technologies'
]

[KlonD90]

@monolithed а что значит 3000 операций? Ты их паралельно записываешь через Promise.all или последовательно?
Понял ща проверю 10к записей подобных что будет.

[monolithed]

Я получаю данные, затем в Promise.all мне приходит массив из 3000 элементов, затем в цикле я последовательно выполняю операцию вставки.
Все элементы попадают в базу, но зарезолвить их не получается (

[monolithed]

Дебажить мне это дело очень проблематично, потому что код сперва транслируется препроцессором и брейкпоинты теряются.

[KlonD90]

@monolithed а эти данные совпадают для #11 ?

[monolithed]

Данные те же, но там проблема пока ушла.

[monolithed]

Вот часть кода, который отвечает за вставку данных:

/**
 * Устанавливает соединение с сервером приложения Tarantool
 *
 * @return {Promise}
 */
get connection () {
    return new Promise((resolve, reject) => {
        this.config.then(({ host, port, user, space_id }) => {
            let tarantool = new Tarantool({ host, port });

            // Прокидываем space_id в инстансе для комфортного доступа
            tarantool.space_id = space_id;

            tarantool.connect()
                .then(status => {
                    return tarantool.auth(user.name, user.password);
                })
                .then(status => {
                    resolve(tarantool);
                })
                .catch(error => {
                    reject('Failed to connect with Tarantool');
                })
            ;
        }, reject);
    });
}


/**
 * Записывает переданные данные в базу
 *
 * @param {Object} tarantool — Ссылка на открытое соединение
 * @param {Object} data — Данные фермы
 * @param {boolean} replace — Использовать операцию "replace"
 * @see normalize
 * @return {Promise}
 */
insert (tarantool, data, replace) {
    let tuple = this.normalize(data);

    return new Promise((resolve, reject) => {
        this.validate(tuple)
            .then(status => {
                let operation = replace ? 'replace' : 'insert';

                tarantool[operation](tarantool.space_id, tuple)
                    .then(resolve, error => {
                        Log.error('Insert operation error:',
                            error.message, '\n', tuple);

                        reject(error);
                    })
                ;
            })
            .catch(error => {
                Log.error('Validation error:',
                    error.message, '\n', tuple);

                reject(error);
            })
        ;
    });
}

[KlonD90]

@monolithed

[
    'google.com', 
    'Mountain View', 
    'google.com', 
    100, 
    2000, 
    [
          'YouTube',
          'Nest Labs',
          'FeedBurner', 
          'Songza'
    ],
    'Technologies'
]

вот конкретно этот кусок данных 10к раз вставленных отрабатывает но видимо там есть куски гораздо больше или как-то msgpack не справляется с дешифровкой или я где-то не правильно мержу куски данных или неправильно читаю их.

А сам по себе тарантул об ошибках не сообщает?

[KlonD90]

@monolithed хотя я не правильно сделал ща еще раз поправлю.
Вот когда поправил такая же байда. Это хорошо, теперь поисследую что там.
Хотя все равно не воспроизвелось просто оно 11 секунд у меня вставляется :( может и там у тебя где-то стоит таймаут?

[monolithed]

А сам по себе тарантул об ошибках не сообщает?

Тарантул молчит.

msgpack не справляется с дешифровкой

Хм, а как это должно влиять на резолвинг промиса?

Вот когда поправил такая же байда. Это хорошо, теперь поисследую что там.

Это хорошая новость!

[KlonD90]

@monolithed так не воспроизвелось все таки. Просто у меня тупит машина, на ней еще всякое веселье крутится ._.
Если msgpack не справится то он не поймет к какому промису оно относится. Там оно по requestId расшифровывает ответ.

[KlonD90]

var dataSample = function(_, x){
                return [
    'google.com'+x,
    'Mountain View'+x,
    'google.com',
    100,
    2000,
    [
          'YouTube',
          'Nest Labs',
          'FeedBurner',
          'Songza'
    ],
    'Technologies'
];
            };
        var arr =[];
        for (var i=0; i<10000; i++)
            arr.push(dataSample(i, i));

Таким образом формирую данные для вставки.

[monolithed]

Из-за того что msgpack синхронный?