in src/rds/create.js [30:52]
function getDbConnection(dbConfig, ids, cb) {
var conn = mysql.createConnection({
host: dbConfig.host,
port: dbConfig.port,
user: dbConfig.dbuser,
password: dbConfig.token,
database: dbConfig.db,
ssl: 'Amazon RDS',
authPlugins: {
mysql_clear_password: () => () => Buffer.from(dbConfig.token + '\0')
}
});
conn.connect((err) => {
if (err) {
logger.error(`RequestId: ${ids.requestId} - MessageId: ${ids.messageId} - OrderId: ${ids.orderId} - Database connection failed - ${err.code} ${err.message}`)
cb(err, null)
} else {
logger.info(`RequestId: ${ids.requestId} - MessageId: ${ids.messageId} - OrderId: ${ids.orderId} - Database connected.`)
cb(null, conn)
}
})
}