create-person.ts•3.85 kB
import { createAction, Property } from '@activepieces/pieces-framework';
import { CopperAuth, isNonEmptyStr } from '../common/constants';
import { CopperApiService } from '../common/requests';
export const createPerson = createAction({
auth: CopperAuth,
name: 'createPerson',
displayName: 'Create Person',
description: 'Adds a new person/contact.',
props: {
name: Property.ShortText({ displayName: 'Full Name', required: true }),
emails: Property.Array({
displayName: 'Emails',
required: true,
properties: {
email: Property.ShortText({
displayName: 'Email',
required: true,
}),
category: Property.ShortText({
displayName: 'Category (e.g., work, personal)',
required: true,
}),
},
defaultValue: [],
}),
phone_numbers: Property.Array({
displayName: 'Phone Numbers',
required: false,
properties: {
number: Property.ShortText({
displayName: 'Number',
required: true,
}),
category: Property.ShortText({
displayName: 'Category (e.g., mobile, work, personal)',
required: true,
}),
},
defaultValue: [],
}),
address_street: Property.ShortText({
displayName: 'Street',
required: false,
}),
address_city: Property.ShortText({ displayName: 'City', required: false }),
address_state: Property.ShortText({
displayName: 'State/Region',
required: false,
}),
address_postal_code: Property.ShortText({
displayName: 'Postal Code',
required: false,
}),
address_country: Property.ShortText({
displayName: 'Country',
required: false,
}),
},
async run(context) {
const {
name,
emails,
address_street,
address_city,
address_state,
address_postal_code,
address_country,
phone_numbers,
} = context.propsValue as any;
const normEmails = (Array.isArray(emails) ? emails : [])
.map((row) => ({
email: String(row?.email ?? '')
.trim()
.toLowerCase(),
category: isNonEmptyStr(row?.category)
? String(row.category).trim()
: undefined,
}))
.filter((e) => isNonEmptyStr(e.email));
if (normEmails.length === 0)
throw new Error('Please provide at least one valid email.');
const seen = new Set<string>();
const dedupedEmails = normEmails.filter(
(e) => !seen.has(e.email) && (seen.add(e.email), true)
);
const normPhones = (Array.isArray(phone_numbers) ? phone_numbers : [])
.map((p) => ({
number: String(p?.number ?? '').trim(),
category: isNonEmptyStr(p?.category)
? String(p.category).trim()
: undefined,
}))
.filter((p) => isNonEmptyStr(p.number));
const address = [
address_street,
address_city,
address_state,
address_postal_code,
address_country,
].some(isNonEmptyStr)
? {
street: isNonEmptyStr(address_street)
? address_street.trim()
: undefined,
city: isNonEmptyStr(address_city) ? address_city.trim() : undefined,
state: isNonEmptyStr(address_state)
? address_state.trim()
: undefined,
postal_code: isNonEmptyStr(address_postal_code)
? address_postal_code.trim()
: undefined,
country: isNonEmptyStr(address_country)
? address_country.trim()
: undefined,
}
: undefined;
const body: any = {
name,
emails: dedupedEmails,
...(normPhones.length ? { phone_numbers: normPhones } : {}),
...(address ? { address } : {}),
};
return await CopperApiService.createPerson(context.auth, body);
},
});