feat: adding organization to pipedrive (#254)

Author: manas-vessel

package.json

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

src/platforms/pipedrive/client.ts

@@ -24,6 +24,10 @@ import {
   PipedriveNoteCreate,
   pipedriveNoteSchema,
   PipedriveNoteUpdate,
+  PipedriveOrganization,
+  PipedriveOrganizationCreate,
+  pipedriveOrganizationSchema,
+  PipedriveOrganizationUpdate,
   PipedrivePerson,
   PipedrivePersonCreate,
   PipedrivePersonUpdate,
@@ -193,6 +197,11 @@ const makeClient = () => {
       'notes',
       pipedriveNoteSchema,
     ),
+    organizations: crud<
+      PipedriveOrganizationCreate,
+      PipedriveOrganizationUpdate,
+      PipedriveOrganization
+    >('organizations', pipedriveOrganizationSchema),
     passthrough: request.passthrough(),
   };
 };

src/platforms/pipedrive/schemas.ts

@@ -217,6 +217,40 @@ export type PipedriveDealUpdate = z.infer<typeof pipedriveDealUpsertSchema> & {
   id: string;
 };
 
+// -
+// Organizations
+// -
+export const pipedriveOrganizationSchema = custom.addNativeToZodSchema(
+  z.object({
+    id: z.number(),
+    name: z.string(),
+    address_route: z.string(),
+    address_locality: z.string(),
+    address_admin_area_level_1: z.string(),
+    address_postal_code: z.string(),
+    address_country: z.string(),
+    update_time: custom.date(),
+    add_time: custom.date(),
+    active_flag: z.boolean(), // isDeleted
+    owner_id: z.object({ value: z.number() }),
+  }),
+);
+export type PipedriveOrganization = z.infer<typeof pipedriveOrganizationSchema>;
+export const pipedriveOrganizationUpsertSchema = z
+  .object({
+    name: z.string(),
+    address: z.string().optional(),
+    owner_id: z.number().optional(),
+    $native: z.record(z.any()),
+  })
+  .partial();
+export type PipedriveOrganizationCreate = z.infer<
+  typeof pipedriveOrganizationUpsertSchema
+>;
+export type PipedriveOrganizationUpdate = z.infer<
+  typeof pipedriveOrganizationUpsertSchema
+> & { id: string };
+
 // -
 // Notes
 // -