Fix salesforce actions (#75)

* Fix salesforce actions

* Convert id number to string

* Bump versino

* Rename camelcase to kebab case for actions files

* Rename queryBuilder to query-builder

Author: averyyip

package.json

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

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

@@ -9,7 +9,7 @@ export default action(
     resource: 'contacts',
     mutation: false,
     schema: z.object({
-      Id: z.number(),
+      Id: z.string(),
     }),
     scopes: [],
   },

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

@@ -11,7 +11,7 @@ export default action(
     resource: 'contacts',
     mutation: false,
     schema: z.object({
-      cursor: z.number(),
+      cursor: z.string().optional(),
     }),
     scopes: [],
   },

src/platforms/salesforce/actions/listViewResults/find.ts renamed to src/platforms/salesforce/actions/list-view-results/find.ts

@@ -9,7 +9,7 @@ export default action(
     resource: 'list-view-results',
     mutation: false,
     schema: z.object({
-      Id: z.number(),
+      Id: z.string(),
       objectType: z.string(),
     }),
     scopes: [],

src/platforms/salesforce/actions/listViews/find.ts renamed to src/platforms/salesforce/actions/list-views/find.ts

@@ -9,7 +9,7 @@ export default action(
     resource: 'list-views',
     mutation: false,
     schema: z.object({
-      Id: z.number(),
+      Id: z.string(),
     }),
     scopes: [],
   },

src/platforms/salesforce/actions/listViews/list.ts renamed to src/platforms/salesforce/actions/list-views/list.ts

@@ -11,7 +11,7 @@ export default action(
     resource: 'list-views',
     mutation: false,
     schema: z.object({
-      cursor: z.number(),
+      cursor: z.string().optional(),
       objectType: z.string().optional(),
     }),
     scopes: [],

src/platforms/salesforce/actions/pagination.ts

@@ -4,7 +4,7 @@ export const getNextCursor = ({
   records,
   limit,
 }: {
-  records: { Id: number }[];
+  records: { Id: string }[];
   limit: number;
 }) => {
   if (records.length < limit) {

src/platforms/salesforce/actions/query-builder.ts

@@ -0,0 +1,77 @@
+import { trim } from 'radash';
+import { MAX_QUERY_PAGE_SIZE } from '../constants';
+import { SalesforceSupportedObjectType } from '../schemas';
+
+declare const brand: unique symbol;
+
+type Brand<T, TBrand extends string> = T & {
+  [brand]: TBrand;
+};
+
+type SalesforceQuery = Brand<string, 'SalesforceQuery'>;
+
+const formatQuery = (query: string): SalesforceQuery => {
+  const cleanedQuery = trim(query.replace(/\n/g, ' '));
+  return cleanedQuery.replace(/ +/g, '+') as SalesforceQuery;
+};
+
+export const salesforceQueryBuilder: Record<
+  string,
+  (...args: any[]) => SalesforceQuery
+> = {
+  list: ({
+    objectType,
+    cursor,
+    relationalSelect,
+    limit = MAX_QUERY_PAGE_SIZE,
+  }: {
+    objectType: SalesforceSupportedObjectType;
+    cursor?: number;
+    relationalSelect?: string;
+    limit?: number;
+  }) => {
+    const select =
+      'SELECT FIELDS(ALL)' + (relationalSelect ? `, ${relationalSelect}` : '');
+    const getWhere = () => {
+      if (!cursor) {
+        return '';
+      }
+      return `WHERE Id < '${cursor}'`;
+    };
+    const where = getWhere();
+    return formatQuery(`
+      ${select}
+      FROM ${objectType}
+      ${where}
+      ORDER BY Id DESC
+      LIMIT ${limit}
+    `);
+  },
+  listListView: ({
+    objectType,
+    cursor,
+    limit = MAX_QUERY_PAGE_SIZE,
+  }: {
+    objectType?: string;
+    cursor?: number;
+    limit?: number;
+  }) => {
+    const getWhere = () => {
+      if (!cursor) {
+        return '';
+      }
+      return (
+        `WHERE Id < '${cursor}'` +
+        (objectType ? `AND SobjectType = '${objectType.toUpperCase()}'` : '')
+      );
+    };
+    const where = getWhere();
+    return formatQuery(`
+      SELECT FIELDS(ALL)
+      FROM ListView
+      ${where}
+      ORDER BY Id DESC
+      LIMIT ${limit}
+    `);
+  },
+};

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

@@ -9,7 +9,7 @@ export default action(
     resource: 'users',
     mutation: false,
     schema: z.object({
-      Id: z.number(),
+      Id: z.string(),
     }),
     scopes: [],
   },

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

@@ -11,7 +11,7 @@ export default action(
     resource: 'users',
     mutation: false,
     schema: z.object({
-      cursor: z.number().optional(),
+      cursor: z.string().optional(),
     }),
     scopes: [],
   },