function getDbConnection()

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)
    }
  })
}