Files
loop-etl-rocketchat/index.js
2026-05-13 20:03:28 +03:00

50 lines
763 B
JavaScript

const context = require('./context')
const log = require('./lib/log')
const {
start,
version,
team,
channels,
users,
posts,
directChannels,
directPosts,
end
} = require('./lib/modules')
//
// Common function log errors and
// terminate the process
//
const abort = function(err) {
log.error(err)
//
// We set a timeout here to
// allow the log streams to finish
// writing.
//
setTimeout(function() {
process.exit(1)
}, 3000)
}
//
// Ensure we trap uncaught exceptions
// and properly abort
//
process.on('uncaughtException', abort)
//
// Let's do it
//
start(context)
.then(version)
.then(team)
.then(channels)
.then(users)
.then(posts)
.then(directChannels)
.then(directPosts)
.then(end)
.catch(abort)