42 строки
1.2 KiB
JavaScript
42 строки
1.2 KiB
JavaScript
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
|
|
|
|
'use strict'
|
|
|
|
// This MUST be the first require in the program.
|
|
// Only `require()` the newrelic module if explicity enabled.
|
|
// If required, modules will be instrumented.
|
|
require('../lib/newrelic')()
|
|
|
|
var config = require('../config').getProperties()
|
|
var log = require('../lib/log')(config.log.level, 'fxa-email-bouncer')
|
|
var error = require('../lib/error')
|
|
var Token = require('../lib/tokens')(log, config)
|
|
var SQSReceiver = require('../lib/sqs')(log)
|
|
var bounces = require('../lib/email/bounces')(log, error)
|
|
var delivery = require('../lib/email/delivery')(log)
|
|
|
|
var DB = require('../lib/db')(
|
|
config,
|
|
log,
|
|
Token
|
|
)
|
|
|
|
var bounceQueue = new SQSReceiver(config.emailNotifications.region, [
|
|
config.emailNotifications.bounceQueueUrl,
|
|
config.emailNotifications.complaintQueueUrl
|
|
])
|
|
|
|
var deliveryQueue = new SQSReceiver(config.emailNotifications.region, [
|
|
config.emailNotifications.deliveryQueueUrl
|
|
])
|
|
|
|
DB.connect(config[config.db.backend])
|
|
.then(
|
|
function (db) {
|
|
bounces(bounceQueue, db)
|
|
delivery(deliveryQueue)
|
|
}
|
|
)
|