vedranjukic

export default client => {
  const create = user => {
    return new Promise((resolve, reject) => {
      client.put({
        TableName: 'users',
        Item: user
      }, (err, data) => {
        if (err) {
          return reject(err)
        }

vedranjukic

//
//  websocket implementation using deepstream client
//
const db = new Db('testdb')

const ds = deepstream( '<DEEPSTREAM SERVER URL>' )
ds.login()

const userRepository = UserRepositoryMongo(db)

vedranjukic

//
//  Email service interface implemented
//
async function updateUser ({userRepository, emailService, updateParams}) {
  const { userId, userName, userEmail } = updateParams

  //  validate params
  if (!userId || !userName || !userEmail) {
    throw new InvalidParamsException('Missing required params')
  }

vedranjukic

export default ses => {
  const send = params => {
    return new Promise((resolve, reject) => {
      const params = {
        Destination: {
          ToAddresses: [params.to]
        },
        Message: {
          Body: {
            Text: {

vedranjukic

//
//  Express controller
//  EmailServiceSES adapter
//
router.put('/user', async (req, res) => {
  const conn = req.conn
  //  ses - aws ses instance (AWS.SES)
  const ses = req.ses
  const { userId, userName, userEmail } = req.body