34 строки
1.0 KiB
JavaScript
34 строки
1.0 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/. */
|
||
|
|
|
||
|
|
var config = require('../config').getProperties()
|
||
|
|
var log = require('../lib/log')(config.log.level, 'profile-server-messaging')
|
||
|
|
var error = require('../lib/error')
|
||
|
|
var Token = require('../lib/tokens')(log, config)
|
||
|
|
var SQSReceiver = require('../lib/sqs')(log)
|
||
|
|
var profileUpdates = require('../lib/profile/updates')(log)
|
||
|
|
var push = require('../lib/push')
|
||
|
|
|
||
|
|
var DB = require('../lib/db')(
|
||
|
|
config,
|
||
|
|
log,
|
||
|
|
error,
|
||
|
|
Token.SessionToken,
|
||
|
|
Token.KeyFetchToken,
|
||
|
|
Token.AccountResetToken,
|
||
|
|
Token.PasswordForgotToken,
|
||
|
|
Token.PasswordChangeToken
|
||
|
|
)
|
||
|
|
|
||
|
|
var profileUpdatesQueue = new SQSReceiver(config.profileServerMessaging.region, [
|
||
|
|
config.profileServerMessaging.profileUpdatesQueueUrl
|
||
|
|
])
|
||
|
|
|
||
|
|
DB.connect(config[config.db.backend])
|
||
|
|
.then(
|
||
|
|
function (db) {
|
||
|
|
profileUpdates(profileUpdatesQueue, push(log, db, config))
|
||
|
|
}
|
||
|
|
)
|