|
|
@ -3,7 +3,7 @@ const isFunction = require('lodash/isFunction');
|
|
|
|
const Message = require('./types/message');
|
|
|
|
const Message = require('./types/message');
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const processNext = async ({
|
|
|
|
exports.processNext = async ({
|
|
|
|
BackboneMessage,
|
|
|
|
BackboneMessage,
|
|
|
|
BackboneMessageCollection,
|
|
|
|
BackboneMessageCollection,
|
|
|
|
count,
|
|
|
|
count,
|
|
|
@ -92,8 +92,3 @@ const _fetchMessagesRequiringSchemaUpgrade =
|
|
|
|
resolve(messages);
|
|
|
|
resolve(messages);
|
|
|
|
}));
|
|
|
|
}));
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
module.exports = {
|
|
|
|
|
|
|
|
processNext,
|
|
|
|
|
|
|
|
};
|
|
|
|
|
|
|
|