mosufy

export const insertUser = params => {
  return db.insert('username,email,password')
    ->values(params)
    ->table('users');
}

mosufy

export const insertUser = async (params) => {
  const userId = await db.insert('username,email,password')
    ->values(params)
    ->table('users');
    
  return userId;
}

mosufy

import EmailCheck from 'email-check-lib';

export const createAccount = params => {
  const emailCheck = new EmailCheck();
  const emailValidated = emailCheck.validate(params.email);
  
  if (emailValidated) {
    ...
  }
}

mosufy

import emailCheck from 'email-check-lib';

export const validateEmail = email => {
  const emailCheck = new EmailCheck();
  const emailValidated = emailCheck.validate(params.newEmail);
  
  if (!emailValidated) {
    throw new Error('Invalid email');
  }
}

mosufy

import { validateEmail } from './validateEmail';

export const createUser = async (params) => {
  validateEmail(params.email);
  
  await insertUser(params);
}

export const updateUser = params => {
  validateEmail(params.email);

mosufy

import { SQS } from 'aws-sdk';
import db from './utils/db';

export const sendQueue = async (payload, options) => {
  const sqs = new SQS(options);
  let queued;
  
  try {
    queued = await sqs.sendMessage(payload).promise();
    console.log('Message sent', queued);

mosufy

import { SQS } from 'aws-sdk';
import db from './utils/db';

export const sendQueue = await (payload, options) => {
  sqs.sendMessage(payload, (error, data) => {
    if (error) {
      console.log('Error sending message to queue', error);
      throw new Error(error.message);
    }
    

mosufy

import { SQS } from 'aws-sdk';

export const sendQueue = async (payload, options) => {
  const sqs = new SQS(options);
  
  try {
    await sqs.sendMessage(payload).promise();
    return 'messageSent';
  } catch (error) {
    throw new Error('Failed to send message');

mosufy

import { SQS } from 'aws-sdk';

export const sendQueue = (payload, options) => {
  const sqs = new SQS(options);
  
  sqs.sendMessage(payload, (error, data) => {
    return new Promise((resolve, reject) => {
      if (error) {
        reject(new Error('Failed to send message'));
      } else {

mosufy

try {
  const user = {
    username: 'JohnDoe',
    gender: 'male',
  }
  
  validateUsernameFormat(user.username);
  await checkUsernameExists(user.username);
  
  const userId = await insertNewUser(user);