154 lines
4.1 KiB
TypeScript
154 lines
4.1 KiB
TypeScript
export type CloseComLead = {
|
|
companyName?: string;
|
|
contactName?: string;
|
|
contactEmail?: string;
|
|
};
|
|
|
|
export type CloseComStatus = {
|
|
id: string;
|
|
organization_id: string;
|
|
label: string;
|
|
};
|
|
|
|
export default class CloseCom {
|
|
private apiUrl = "https://api.close.com/api/v1/";
|
|
private apiKey: string | undefined = undefined;
|
|
|
|
constructor() {
|
|
if (!process.env.CLOSECOM_API_KEY) throw Error("Close.com Api Key not present");
|
|
this.apiKey = process.env.CLOSECOM_API_KEY;
|
|
}
|
|
|
|
public static lead(): [CloseCom, CloseComLead] {
|
|
return [new this(), {} as CloseComLead];
|
|
}
|
|
|
|
public contact = {
|
|
search: async ({ emails }: { emails: string[] }) => {
|
|
return this._post({
|
|
url: `${this.apiUrl}/data/search/`,
|
|
data: closeComQueries.contact.getContactSearchQuery(emails),
|
|
});
|
|
},
|
|
};
|
|
|
|
public lead = {
|
|
status: async () => {
|
|
return this._get({ url: `${this.apiUrl}/status/lead/` });
|
|
},
|
|
create: async (data: CloseComLead) => {
|
|
return this._post({
|
|
url: `${this.apiUrl}/lead/`,
|
|
data: closeComQueries.lead.getCreateLeadQuery(data),
|
|
});
|
|
},
|
|
};
|
|
|
|
private _get = async ({ url, ...rest }: { url: string }) => {
|
|
return await this._request({ url, method: "get", ...rest });
|
|
};
|
|
private _post = async ({ url, data, ...rest }: { url: string; data: Record<string, unknown> }) => {
|
|
return this._request({ url, method: "post", data, ...rest });
|
|
};
|
|
private _delete = async ({ url, ...rest }: { url: string }) => {
|
|
return this._request({ url, method: "delete", ...rest });
|
|
};
|
|
private _request = async ({
|
|
url,
|
|
data,
|
|
...rest
|
|
}: {
|
|
url: string;
|
|
method: string;
|
|
data?: Record<string, unknown>;
|
|
}) => {
|
|
const credentials = Buffer.from(`${this.apiKey}:`).toString("base64");
|
|
const headers = {
|
|
Authorization: `Basic ${credentials}`,
|
|
"Content-Type": "application/json",
|
|
};
|
|
return await fetch(url, { headers, body: JSON.stringify(data), ...rest }).then(async (response) => {
|
|
if (!response.ok) {
|
|
const message = `An error has occured: ${response.status}`;
|
|
throw new Error(message);
|
|
}
|
|
return await response.json();
|
|
});
|
|
};
|
|
}
|
|
|
|
export const closeComQueries = {
|
|
contact: {
|
|
getContactSearchQuery(contactEmails: string[]) {
|
|
return {
|
|
limit: null,
|
|
_fields: {
|
|
contact: ["id", "name"],
|
|
},
|
|
query: {
|
|
negate: false,
|
|
queries: [
|
|
{
|
|
negate: false,
|
|
object_type: "contact",
|
|
type: "object_type",
|
|
},
|
|
{
|
|
negate: false,
|
|
queries: [
|
|
{
|
|
negate: false,
|
|
related_object_type: "contact_email",
|
|
related_query: {
|
|
negate: false,
|
|
queries: contactEmails.map((contactEmail) => ({
|
|
condition: {
|
|
mode: "full_words",
|
|
type: "text",
|
|
value: contactEmail,
|
|
},
|
|
field: {
|
|
field_name: "email",
|
|
object_type: "contact_email",
|
|
type: "regular_field",
|
|
},
|
|
negate: false,
|
|
type: "field_condition",
|
|
})),
|
|
type: "or",
|
|
},
|
|
this_object_type: "contact",
|
|
type: "has_related",
|
|
},
|
|
],
|
|
type: "and",
|
|
},
|
|
],
|
|
type: "and",
|
|
},
|
|
results_limit: null,
|
|
sort: [],
|
|
};
|
|
},
|
|
},
|
|
lead: {
|
|
getCreateLeadQuery({ companyName, contactEmail, contactName }: CloseComLead) {
|
|
return {
|
|
name: companyName,
|
|
contacts: [
|
|
{
|
|
name: contactName,
|
|
email: contactEmail,
|
|
emails: [
|
|
{
|
|
type: "office",
|
|
email: contactEmail,
|
|
},
|
|
],
|
|
},
|
|
],
|
|
};
|
|
},
|
|
},
|
|
};
|