Add salesforce marketing cloud (#54)

* Add client and auth for sfmc

* Add changes

* Remove package-lock

* Update yarn.lock

* Add create and update for salesforce contact

* Fix types

* Fix typing for TOAuth2Answers and TAnswers

* Fix type

* Fix typing

* Remove changes from other file

* Hook up actions to platform

* Fix formatting

* Add listview and listviewresults

* Add to platforms

* Rename utils.ts to pagination.ts

* add default value

* Add categories to sfdc

* Change get to find

* Move marketing automation first

* Match end platform for Id

* Remove extra slash

* Bump version

Author: averyyip

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@vesselapi/integrations",
-  "version": "0.0.51",
+  "version": "0.0.52",
   "description": "Vessel integrations",
   "main": "dist/index.js",
   "module": "dist/index.mjs",

src/platforms/index.ts

@@ -3,6 +3,7 @@ import apollo from '@/platforms/apollo';
 import dialpad from '@/platforms/dialpad';
 import outreach from '@/platforms/outreach';
 import ringcentral from '@/platforms/ringcentral';
+import salesforce from '@/platforms/salesforce';
 import salesloft from '@/platforms/salesloft';
 import slack from '@/platforms/slack';
 import { Platform } from '@/sdk';
@@ -18,18 +19,23 @@ export {
   default as ringcentral,
   types as ringcentralTypes,
 } from '@/platforms/ringcentral';
+export {
+  default as salesforce,
+  types as salesforceTypes,
+} from '@/platforms/salesforce';
 export {
   default as salesloft,
   types as salesloftTypes,
 } from '@/platforms/salesloft';
 export { default as slack, types as slackTypes } from '@/platforms/slack';
 
-export const integrationsList: Platform<any, any, any>[] = Object.values([
+export const integrationsList: Platform<any, any, any, any, any>[] = [
   aircall,
   apollo,
   dialpad,
   outreach,
   ringcentral,
+  salesforce,
   salesloft,
   slack,
-]);
+];

src/platforms/salesforce/actions/contacts/create.ts

@@ -0,0 +1,17 @@
+import { client } from '@/platforms/salesforce/client';
+import { action } from '@/sdk';
+import { salesforceContactCreate } from '../../schemas';
+
+export default action(
+  'create-contact',
+  {
+    operation: 'create',
+    resource: 'contacts',
+    mutation: true,
+    schema: salesforceContactCreate,
+    scopes: [],
+  },
+  async ({ input, auth }) => {
+    return await client.contacts.create(auth, input);
+  },
+);

src/platforms/salesforce/actions/contacts/find.ts

@@ -0,0 +1,19 @@
+import { client } from '@/platforms/salesforce/client';
+import { action } from '@/sdk';
+import { z } from 'zod';
+
+export default action(
+  'find-contact',
+  {
+    operation: 'find',
+    resource: 'contacts',
+    mutation: false,
+    schema: z.object({
+      Id: z.number(),
+    }),
+    scopes: [],
+  },
+  async ({ input, auth }) => {
+    return await client.contacts.find(auth, { Id: input.Id });
+  },
+);

src/platforms/salesforce/actions/contacts/list.ts

@@ -0,0 +1,31 @@
+import { client } from '@/platforms/salesforce/client';
+import { action } from '@/sdk';
+import { z } from 'zod';
+import { MAX_QUERY_PAGE_SIZE } from '../../constants';
+import { getNextCursor } from '../pagination';
+
+export default action(
+  'list-contacts',
+  {
+    operation: 'list',
+    resource: 'contacts',
+    mutation: false,
+    schema: z.object({
+      cursor: z.number(),
+    }),
+    scopes: [],
+  },
+  async ({ input, auth }) => {
+    const resp = await client.contacts.list(auth, {
+      cursor: input.cursor,
+      limit: MAX_QUERY_PAGE_SIZE,
+    });
+    return {
+      ...resp,
+      cursor: getNextCursor({
+        records: resp.records,
+        limit: MAX_QUERY_PAGE_SIZE,
+      }),
+    };
+  },
+);

src/platforms/salesforce/actions/contacts/update.ts

@@ -0,0 +1,17 @@
+import { client } from '@/platforms/salesforce/client';
+import { action } from '@/sdk';
+import { salesforceContactUpdate } from '../../schemas';
+
+export default action(
+  'update-contact',
+  {
+    operation: 'update',
+    resource: 'contacts',
+    mutation: true,
+    schema: salesforceContactUpdate,
+    scopes: [],
+  },
+  async ({ input, auth }) => {
+    return await client.contacts.update(auth, input);
+  },
+);

src/platforms/salesforce/actions/listViewResults/find.ts

@@ -0,0 +1,23 @@
+import { client } from '@/platforms/salesforce/client';
+import { action } from '@/sdk';
+import { z } from 'zod';
+
+export default action(
+  'find-list-view-results',
+  {
+    operation: 'find',
+    resource: 'list-view-results',
+    mutation: false,
+    schema: z.object({
+      Id: z.number(),
+      objectType: z.string(),
+    }),
+    scopes: [],
+  },
+  async ({ input, auth }) => {
+    return await client.listViewResults.find(auth, {
+      Id: input.Id,
+      objectType: input.objectType,
+    });
+  },
+);

src/platforms/salesforce/actions/listViews/find.ts

@@ -0,0 +1,19 @@
+import { client } from '@/platforms/salesforce/client';
+import { action } from '@/sdk';
+import { z } from 'zod';
+
+export default action(
+  'find-list-view',
+  {
+    operation: 'find',
+    resource: 'list-views',
+    mutation: false,
+    schema: z.object({
+      Id: z.number(),
+    }),
+    scopes: [],
+  },
+  async ({ input, auth }) => {
+    return await client.listViews.find(auth, { Id: input.Id });
+  },
+);

src/platforms/salesforce/actions/listViews/list.ts

@@ -0,0 +1,33 @@
+import { client } from '@/platforms/salesforce/client';
+import { action } from '@/sdk';
+import { z } from 'zod';
+import { MAX_QUERY_PAGE_SIZE } from '../../constants';
+import { getNextCursor } from '../pagination';
+
+export default action(
+  'list-list-views',
+  {
+    operation: 'list',
+    resource: 'list-views',
+    mutation: false,
+    schema: z.object({
+      cursor: z.number(),
+      objectType: z.string().optional(),
+    }),
+    scopes: [],
+  },
+  async ({ input, auth }) => {
+    const resp = await client.listViews.list(auth, {
+      cursor: input.cursor,
+      objectType: input.objectType,
+      limit: MAX_QUERY_PAGE_SIZE,
+    });
+    return {
+      ...resp,
+      cursor: getNextCursor({
+        records: resp.records,
+        limit: MAX_QUERY_PAGE_SIZE,
+      }),
+    };
+  },
+);

src/platforms/salesforce/actions/pagination.ts

@@ -0,0 +1,14 @@
+import { last } from 'radash';
+
+export const getNextCursor = ({
+  records,
+  limit,
+}: {
+  records: { Id: number }[];
+  limit: number;
+}) => {
+  if (records.length < limit) {
+    return null;
+  }
+  return last(records)?.Id;
+};