Your organization,
AI Ready.

1import { z } from 'zod';

2

3export const schema = {

4 create_lead: {

5 description: 'Create a new lead in Salesforce',

6 input: z.object({

7 firstName: z.string(),

8 lastName: z.string(),

9 company: z.string(),

10 email: z.string().email(),

11 }),

12 },

13};

14

15// --- Salesforce client ----------------------------------------------

16

17async function connect(session) {

18 const creds = session?.apikeys ?? {};

19 const instanceUrl = creds.SF_INSTANCE_URL || 'https://acme-corp.my.salesforce.com';

20 console.log(`[salesforce] authenticating as ${session?.gatanaUserEmail ?? 'integration'}`);

21 await delay(120);

22 return { instanceUrl, accessToken: creds.SF_ACCESS_TOKEN };

23}

24

25async function soql(conn, query) {

26 const url = `${conn.instanceUrl}/services/data/${SF_API_VERSION}/query?q=${encodeURIComponent(query)}`;

27 const res = await fetch(url, { headers: { Authorization: `Bearer ${conn.accessToken}` } });

28 return res.json();

29}

30

31// --- Tools ----------------------------------------------------------

32

33export async function create_lead(input, session) {

34 const conn = await connect(session);