1 | |
2 |
|
3 | export type DynSelect_object_type = string |
4 |
|
5 | |
6 | export async function object_type(auth: RT.Hubspot) { |
7 | const standard = [ |
8 | "contacts", |
9 | "companies", |
10 | "deals", |
11 | "tickets", |
12 | "line_items", |
13 | "products", |
14 | "quotes", |
15 | "leads", |
16 | "notes", |
17 | "tasks", |
18 | "meetings", |
19 | "calls", |
20 | "emails", |
21 | "communications", |
22 | ].map((o) => ({ value: o, label: o })) |
23 | const response = await fetch("https://api.hubapi.com/crm/v3/schemas", { |
24 | headers: { |
25 | Authorization: `Bearer ${auth.token}`, |
26 | Accept: "application/json", |
27 | }, |
28 | }) |
29 | |
30 | if (!response.ok) return standard |
31 | const { results } = (await response.json()) as { |
32 | results: { fullyQualifiedName: string; labels: { plural: string } }[] |
33 | } |
34 | return [ |
35 | ...standard, |
36 | ...results.map((s) => ({ |
37 | value: s.fullyQualifiedName, |
38 | label: `${s.labels.plural} (custom)`, |
39 | })), |
40 | ] |
41 | } |
42 |
|
43 | export type DynMultiselect_properties = string[] |
44 |
|
45 | |
46 | export async function properties( |
47 | auth: RT.Hubspot, |
48 | object_type: DynSelect_object_type |
49 | ) { |
50 | if (!object_type) return [] |
51 | const response = await fetch( |
52 | `https://api.hubapi.com/crm/v3/properties/${object_type}`, |
53 | { |
54 | headers: { |
55 | Authorization: `Bearer ${auth.token}`, |
56 | Accept: "application/json", |
57 | }, |
58 | } |
59 | ) |
60 | if (!response.ok) { |
61 | throw new Error(`${response.status} ${await response.text()}`) |
62 | } |
63 | const { results } = (await response.json()) as { |
64 | results: { name: string; label: string }[] |
65 | } |
66 | return results.map((p) => ({ |
67 | value: p.name, |
68 | label: `${p.label} (${p.name})`, |
69 | })) |
70 | } |
71 |
|
72 | |
73 | * Get CRM Object |
74 | * Retrieve one CRM record by ID (or by a unique property via `id_property`), with the properties and associated object types you choose. Object types other than contacts, companies and deals need their own scope on the connection (e.g. tickets, crm.objects.line_items.read, crm.objects.custom.read). |
75 | */ |
76 | export async function main( |
77 | auth: RT.Hubspot, |
78 | object_type: DynSelect_object_type, |
79 | object_id: string, |
80 | properties: DynMultiselect_properties | undefined, |
81 | properties_with_history: string[] | undefined, |
82 | associations: string[] | undefined, |
83 | id_property: string | undefined, |
84 | archived: boolean | undefined |
85 | ) { |
86 | const url = new URL( |
87 | `https://api.hubapi.com/crm/v3/objects/${object_type}/${object_id}` |
88 | ) |
89 | if (properties?.length) |
90 | url.searchParams.append("properties", properties.join(",")) |
91 | if (properties_with_history?.length) |
92 | url.searchParams.append( |
93 | "propertiesWithHistory", |
94 | properties_with_history.join(",") |
95 | ) |
96 | if (associations?.length) |
97 | url.searchParams.append("associations", associations.join(",")) |
98 | if (id_property != null && id_property !== "") |
99 | url.searchParams.append("idProperty", id_property) |
100 | if (archived) url.searchParams.append("archived", String(archived)) |
101 |
|
102 | const response = await fetch(url, { |
103 | headers: { |
104 | Authorization: `Bearer ${auth.token}`, |
105 | Accept: "application/json", |
106 | }, |
107 | }) |
108 |
|
109 | if (!response.ok) { |
110 | throw new Error(`${response.status} ${await response.text()}`) |
111 | } |
112 |
|
113 | return await response.json() |
114 | } |
115 |
|