mosufy

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Sid": "PublicReadGetObject",
            "Effect": "Allow",
            "Principal": "*",
            "Action": [
                "s3:GetObject"
            ],

mosufy

import db from 'db';

const checkUsernameExists = async (username: string):Promise<boolean> => {
  const user = await db.select('id')
    ->from('users')
    ->where('username', username)
    ->first();
  
  return Object.keys(user).length > 0;
}

mosufy

try {
  await insertNewUser(user);
} catch (error) {
  return {
    error: {
      message: error.message,
      code: 'FAILED_INSERT_USER',
    }
  }
}

mosufy

try {
  await sendMessage('User created', { userId, user });
} catch (error) {
  console.log('Failed to send message, but it is ok', error);
}

mosufy

try {
  validateUsernameFormat(user.username);
  await checkUsernameExists(user.username);
} catch (error) {
  return {
    // a better approach is to have a response success/error function
    error: {
      message: error.message,
      code: 'FAILED_USERNAME_VALIDATION',
    }

mosufy

const user = {
  username: 'JohnDoe',
  gender: 'male',
}

mosufy

const user = {
  username: 'JohnDoe',
  gender: 'male',
}

try {
  validateUsernameFormat(user.username);
  await checkUsernameExists(user.username);
} catch (error) {
  return {

mosufy

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

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

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');