Skip to content

Commit

Permalink
minor change to validation
Browse files Browse the repository at this point in the history
  • Loading branch information
@joe-ayoub-segment
joe-ayoub-segment committed Oct 21, 2024
1 parent b7e70a1 commit ed479d9
Showing 1 changed file with 85 additions and 72 deletions.
157 changes: 85 additions & 72 deletions packages/destination-actions/src/destinations/sendgrid/sendEmail/utils.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,91 +4,104 @@ import { sendEmailReq } from './types'
import { RESERVED_HEADERS, MAX_CATEGORY_LENGTH, MIN_IP_POOL_NAME_LENGTH, MAX_IP_POOL_NAME_LENGTH } from './constants'

export async function send(request: RequestClient, payload: Payload) {
validate(payload)

const json: sendEmailReq = {
personalizations: [{
validate(payload)

const json: sendEmailReq = {
personalizations: [
{
from: { email: payload.from.email, name: payload.from?.name ?? undefined },
to: payload.to.map(to => ({ email: to.email, name: to?.name ?? undefined })),
cc: payload.cc?.map(cc => ({ email: cc.email, name: cc?.name ?? undefined })) ?? undefined,
bcc: payload.bcc?.map(bcc => ({ email: bcc.email, name: bcc?.name ?? undefined })) ?? undefined,
to: payload.to.map((to) => ({ email: to.email, name: to?.name ?? undefined })),
cc: payload.cc?.map((cc) => ({ email: cc.email, name: cc?.name ?? undefined })) ?? undefined,
bcc: payload.bcc?.map((bcc) => ({ email: bcc.email, name: bcc?.name ?? undefined })) ?? undefined,
subject: payload.subject,
headers: Object.entries(payload?.headers ?? {}).reduce((acc, [key, value]) => {
acc[key] = String(value)
return acc
}, {} as Record<string, string>) || undefined,
headers:
Object.entries(payload?.headers ?? {}).reduce((acc, [key, value]) => {
acc[key] = String(value)
return acc
}, {} as Record<string, string>) || undefined,
dynamic_template_data: payload.dynamic_template_data?.reduce((acc, item) => {
acc[item.key] = item.value ?? item.default
return acc
}, {} as { [key: string]: string }),
custom_args: Object.entries(payload?.custom_args ?? {}).reduce((acc, [key, value]) => {
acc[key] = String(value)
return acc
}, {} as Record<string, string>) || undefined,
custom_args:
Object.entries(payload?.custom_args ?? {}).reduce((acc, [key, value]) => {
acc[key] = String(value)
return acc
}, {} as Record<string, string>) || undefined,
send_at: toUnixTS(payload.send_at) ?? undefined
}],
reply_to: {
email: (payload.reply_to.reply_to_equals_from ? payload.from.email : payload.reply_to.email) as string,
name: payload.reply_to.reply_to_equals_from ? payload.from.name : payload.reply_to.name
},
template_id: payload.template_id,
categories: payload.categories?.map(category => category.category),
asm: payload.ASM ? { group_id: payload.ASM.groupId as number } : undefined,
ip_pool_name: payload.ip_pool_name,
tracking_settings: {
click_tracking: payload.click_tracking ?? undefined,
open_tracking: payload.open_tracking ?? undefined,
subscription_tracking: payload.subscription_tracking ?? undefined,
ganalytics: payload.google_analytics ?? undefined
},
mail_settings: payload.mail_settings ?? undefined
}

return await request('https://api.sendgrid.com/v3/mail/send', {
method: 'post',
json
})
}
],
reply_to: {
email: (payload.reply_to.reply_to_equals_from ? payload.from.email : payload.reply_to.email) as string,
name: payload.reply_to.reply_to_equals_from ? payload.from.name : payload.reply_to.name
},
template_id: payload.template_id,
categories: payload.categories?.map((category) => category.category),
asm: payload.ASM ? { group_id: payload.ASM.groupId as number } : undefined,
ip_pool_name: payload.ip_pool_name,
tracking_settings: {
click_tracking: payload.click_tracking ?? undefined,
open_tracking: payload.open_tracking ?? undefined,
subscription_tracking: payload.subscription_tracking ?? undefined,
ganalytics: payload.google_analytics ?? undefined
},
mail_settings: payload.mail_settings ?? undefined
}

return await request('https://api.sendgrid.com/v3/mail/send', {
method: 'post',
json
})
}

function toUnixTS(date: string | undefined): number | undefined {
if(typeof date === 'undefined') {
return undefined
}
return new Date(date).getTime()
if (typeof date === 'undefined' || date === null || date === '') {
return undefined
}
return new Date(date).getTime()
}

function validate(payload: Payload){
if(!payload.reply_to.reply_to_equals_from && !payload.reply_to.email) {
throw new PayloadValidationError("'Reply To >> Email' must be provided if 'Reply To Equals From' is set to true")
}

if(Object.keys(payload?.headers ?? {}).some(key => RESERVED_HEADERS.includes(key))) {
throw new PayloadValidationError(`Headers cannot contain any of the following reserved headers: ${RESERVED_HEADERS.join(', ')}`)
function validate(payload: Payload) {
if (!payload.reply_to.reply_to_equals_from && !payload.reply_to.email) {
throw new PayloadValidationError("'Reply To >> Email' must be provided if 'Reply To Equals From' is set to true")
}

if (Object.keys(payload?.headers ?? {}).some((key) => RESERVED_HEADERS.includes(key))) {
throw new PayloadValidationError(
`Headers cannot contain any of the following reserved headers: ${RESERVED_HEADERS.join(', ')}`
)
}

payload.dynamic_template_data?.forEach((item) => {
if (item.required && !item.value && !item.default) {
throw new PayloadValidationError(`Dynamic Template Data with key '${item.key}' is required and cannot be empty`)
}

payload.dynamic_template_data?.forEach(item => {
if(item.required && !item.value && !item.default) {
throw new PayloadValidationError(`Dynamic Template Data with key '${item.key}' is required and cannot be empty`)
}
})

payload?.categories?.forEach(category => {
if(category.category.length >= MAX_CATEGORY_LENGTH) {
throw new PayloadValidationError(`Category with name ${category.category} exceeds the max length of ${MAX_CATEGORY_LENGTH} characters`)
}
})

if(payload.send_at) {
const sendAt = new Date(payload.send_at)
const now = new Date()
if(sendAt.getTime() < now.getTime() || sendAt.getTime() > now.getTime() + 72 * 60 * 60 * 1000) {
throw new PayloadValidationError('send_at should be less than 72 hours from now')
}
})

payload?.categories?.forEach((category) => {
if (category.category.length >= MAX_CATEGORY_LENGTH) {
throw new PayloadValidationError(
`Category with name ${category.category} exceeds the max length of ${MAX_CATEGORY_LENGTH} characters`
)
}

if(payload.ip_pool_name && (payload.ip_pool_name.length >= MAX_IP_POOL_NAME_LENGTH || payload.ip_pool_name.length <= MIN_IP_POOL_NAME_LENGTH)) {
throw new PayloadValidationError(`IP Pool Name should at least ${MIN_IP_POOL_NAME_LENGTH} characters and at most ${MAX_IP_POOL_NAME_LENGTH} characters in length`)
})

if (payload.send_at) {
const sendAt = new Date(payload.send_at)
const now = new Date()
if (sendAt.getTime() < now.getTime() || sendAt.getTime() > now.getTime() + 72 * 60 * 60 * 1000) {
throw new PayloadValidationError('send_at should be less than 72 hours from now')
}
}

return
}
if (
payload.ip_pool_name &&
(payload.ip_pool_name.length >= MAX_IP_POOL_NAME_LENGTH || payload.ip_pool_name.length <= MIN_IP_POOL_NAME_LENGTH)
) {
throw new PayloadValidationError(
`IP Pool Name should at least ${MIN_IP_POOL_NAME_LENGTH} characters and at most ${MAX_IP_POOL_NAME_LENGTH} characters in length`
)
}

return
}

0 comments on commit ed479d9

Please sign in to comment.