feat: updating hubspot client to include info data (#292)

Author: manas-vessel

package.json

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

src/platforms/hubspot/client.ts

@@ -51,6 +51,7 @@ import {
   HubspotMeetingCreate,
   hubspotMeetingSchema,
   HubspotMeetingUpdate,
+  hubspotMeOutputSchema,
   HubspotModule,
   HubspotNote,
   HubspotNoteCreate,
@@ -448,6 +449,11 @@ const makeClient = () => {
       method: 'GET',
       schema: hubspotAccessTokenOutputSchema,
     })),
+    me: request(({}) => ({
+      url: `/integrations/v1/me`,
+      method: 'GET',
+      schema: hubspotMeOutputSchema,
+    })),
     passthrough: request.passthrough(),
   };
 };

src/platforms/hubspot/schemas.ts

@@ -214,6 +214,7 @@ const dealPropertiesSchema = z.object({
     )
     .nullable(),
   dealstage: z.string().nullable(),
+  deal_currency_code: z.string().nullable().optional(),
   hs_deal_stage_probability: z.union([z.string(), z.number()]).nullable(),
   hs_projected_amount: z.union([z.string(), z.number()]).nullable(),
   hs_is_closed_won: hubspotBooleanSchema.nullable(),
@@ -715,3 +716,11 @@ export const hubspotAccessTokenOutputSchema = z.object({
 export type HubspotAccessTokenOutputSchema = z.infer<
   typeof hubspotAccessTokenOutputSchema
 >;
+
+export const hubspotMeOutputSchema = z.object({
+  portalId: hubspotIdSchema.nullable(),
+  timeZone: z.string().nullable(),
+  currency: z.string().nullable(),
+  utcOffsetMilliseconds: z.number().nullable(),
+  utcOffset: z.string().nullable(),
+});

src/platforms/pipedrive/schemas.ts

@@ -196,6 +196,7 @@ export const pipedriveDealSchema = custom.addNativeToZodSchema(
     update_time: custom.date(),
     add_time: custom.date(),
     deleted: z.boolean().nullable(),
+    currency: z.string().nullable(),
     person_id: z.object({ value: z.number() }).nullable(),
     org_id: z.object({ value: z.number() }).nullable(),
     user_id: z.object({ value: z.number() }).nullable(),

src/platforms/salesforce/client.ts

@@ -10,6 +10,7 @@ import {
   salesforceAccountCreateResponse,
   salesforceAccountRelationalSelect,
   SalesforceAccountUpdate,
+  salesforceConnectOrganizationResponse,
   salesforceContact,
   SalesforceContactCreate,
   salesforceContactCreateResponse,
@@ -238,6 +239,13 @@ export const client = {
       }),
     ),
   },
+  connect: {
+    organization: request(({}) => ({
+      url: `/connect/organization`,
+      method: 'GET',
+      schema: salesforceConnectOrganizationResponse,
+    })),
+  },
   query: request(({ query }: { query: string }) => ({
     url: `/query/`,
     method: 'GET',

src/platforms/salesforce/schemas.ts

@@ -24,6 +24,19 @@ export const salesforceSObject = z.object({
   sobjects: z.array(z.object({ name: z.string() })),
 });
 
+// -
+// Connect Organization
+// -
+export const salesforceConnectOrganizationResponse = z
+  .object({
+    features: z
+      .object({
+        defaultCurrencyIsoCode: z.string().nullable(),
+      })
+      .partial(),
+  })
+  .partial();
+
 // -
 // SObject Describe
 //  -
@@ -35,6 +48,11 @@ export const salesforceField = z.object({
   custom: z.boolean(),
   createable: z.boolean(),
   updateable: z.boolean(),
+  defaultValue: z
+    .object({
+      value: z.string().nullish(),
+    })
+    .nullish(),
   picklistValues: z
     .array(
       z.object({
@@ -269,6 +287,7 @@ export const salesforceOpportunity = custom.addNativeToZodSchema(
       IsClosed: z.boolean().nullable(),
       ContactId: z.string().nullable(),
       AccountId: z.string().nullable(),
+      CurrencyIsoCode: z.string().nullable(),
       CreatedDate: custom.date(),
       OwnerId: z.string().nullable(),
       LastModifiedDate: custom.date(),