Merge pull request #8 from zwolfson/support-uniuque-id

New properties to hold unique ids

Author: zman81988

prisma/schema.prisma

@@ -30,12 +30,15 @@ model Authorization {
 }
 
 model Properties {
-  name                   String               @db.VarChar(255)
-  label                  String?              @db.VarChar(255)
-  type                   PropertyType
-  object                 Objects
-  customerId             String               @db.VarChar(255)
-  modificationMetadata   Json
+
+  name       String       @db.VarChar(255)
+  label      String?      @db.VarChar(255)
+  type       PropertyType
+  object     Objects
+  customerId String       @db.VarChar(255)
+  unique     Boolean?
+modificationMetadata   Json
+
 
   @@unique([name, object, customerId])
 }

prisma/seed.ts

@@ -26,6 +26,25 @@ async function main(): Promise {
     },
   });
   console.log(firstname);
+  const contactIdentifier = await prisma.properties.upsert({
+    where: {
+      name_object_customerId: {
+        name: "native_system_contact_identifier",
+        object: "Contact",
+        customerId: "1",
+      },
+    },
+    update: {},
+    create: {
+      name: "native_system_contact_identifier",
+      label: "Native System Contact Identifier",
+      type: "String",
+      object: "Contact",
+      customerId: "1",
+      unique:true,
+    },
+  });
+  console.log(contactIdentifier);
 
   const lastname = await prisma.properties.upsert({
     where: {
@@ -96,6 +115,25 @@ async function main(): Promise {
     },
   });
   console.log(exampleRequired);
+  const companyIdentifier = await prisma.properties.upsert({
+    where: {
+      name_object_customerId: {
+        name: "native_system_company_identifier",
+        object: "Contact",
+        customerId: "1",
+      },
+    },
+    update: {},
+    create: {
+      name: "native_system_company_identifier",
+      label: "Native System Company Identifier",
+      type: "String",
+      object: "Company",
+      customerId: "1",
+      unique:true,
+    },
+  });
+  console.log(companyIdentifier);
   const customCompany = await prisma.properties.upsert({
     where: {
       name_object_customerId: {

src/app.ts

@@ -4,8 +4,11 @@ import { authUrl, redeemCode } from "./auth";
 import {
   getHubSpotProperties,
   getNativeProperties,
-  createPropertyGroup,
-  createRequiredProperty,
+  createPropertyGroupForContacts,
+  createRequiredContactProperty,
+  createPropertyGroupForCompanies,
+  createContactIdProperty,
+  createCompanyIdProperty
 } from "./properties";
 import { saveMapping, getMappings, deleteMapping } from "./mappings";
 import { PORT, getCustomerId } from "./utils";
@@ -26,8 +29,13 @@ app.get("/oauth-callback", async (req: Request, res: Response):Promise =>
     try {
       const authInfo = await redeemCode(code.toString());
       const accessToken = authInfo.accessToken;
-      await createPropertyGroup(accessToken);
-      await createRequiredProperty(accessToken);
+
+      createPropertyGroupForContacts(accessToken);
+      createPropertyGroupForCompanies(accessToken)
+      createRequiredContactProperty(accessToken);
+      createContactIdProperty(accessToken)
+      createCompanyIdProperty(accessToken)
+
       res.redirect(`http://localhost:${PORT - 1}/`);
     } catch (error: any) {
       res.redirect(`/?errMessage=${error.message}`);

src/properties.ts

@@ -5,7 +5,9 @@ import { PropertyCache } from 'default';
 
 const TTL = 5 * 60 * 1000; // 5 Minute TTL in milliseconds
 
-const createPropertyGroup = async (accessToken: string):Promise<void> => {
+
+export const createPropertyGroupForContacts = async (accessToken: string) => {
+
   hubspotClient.setAccessToken(accessToken);
   try {
       await hubspotClient.crm.properties.groupsApi.create("contact", {
@@ -18,7 +20,24 @@ const createPropertyGroup = async (accessToken: string):Promise => {
   }
 };
 
-const createRequiredProperty = async (accessToken: string): Promise<void> => {
+
+export const createPropertyGroupForCompanies = async (accessToken: string) => {
+  hubspotClient.setAccessToken(accessToken);
+  try {
+    const propertyGroupCreateResponse =
+      await hubspotClient.crm.properties.groupsApi.create("company", {
+        name: "integration_properties",
+        label: "Integration Properties",
+        displayOrder: 13,
+      });
+  } catch (error) {
+    console.error(error);
+  }
+};
+
+
+export const createRequiredContactProperty = async (accessToken: string) => {
+
   hubspotClient.setAccessToken(accessToken);
   try {
       await hubspotClient.crm.properties.coreApi.create("contact", {
@@ -34,8 +53,46 @@ const createRequiredProperty = async (accessToken: string): Promise => {
   }
 };
 
+export const createContactIdProperty = async (accessToken: string) => {
+  hubspotClient.setAccessToken(accessToken);
+  try {
+    const propertyCreateResponse =
+      await hubspotClient.crm.properties.coreApi.create("contact", {
+        name: "native_system_contact_identifier",
+        label: "Native System Contact Identifier",
+        type: "string",
+        description: "This can be used in place of email adress ot uniquely identify a contact",
+        fieldType: "text",
+        groupName: "integration_properties",
+        hasUniqueValue:true
+      });
+  } catch (error) {
+    console.error(error);
+  }
+};
+
+export const createCompanyIdProperty = async (accessToken: string) => {
+  hubspotClient.setAccessToken(accessToken);
+  try {
+    const propertyCreateResponse =
+      await hubspotClient.crm.properties.coreApi.create("company", {
+        name: "native_system_company_identifier",
+        label: "Native System Company Identifier",
+        type: "string",
+        description: "This can be used in place of email adress ot uniquely identify a contact",
+        fieldType: "text",
+        groupName: "integration_properties",
+        hasUniqueValue: true
+      });
+  } catch (error) {
+    console.error(error);
+  }
+};
+
+
 const checkPropertiesCache = async (customerId: string): Promise<PropertyCache | undefined> => {
   try{
+
   const cacheResults = await prisma.hubSpotPropertiesCache.findFirst({
     where: { customerId },
     select: { updatedAt: true, propertyData: true },
@@ -72,7 +129,9 @@ const saveHubSpotPropertiesToCache = async (
 }
 };
 
-const getHubSpotProperties = async (customerId: string, skipCache: boolean): Promise<{ contactProperties: any; companyProperties: any; } | undefined>  => {
+
+export const getHubSpotProperties = async (customerId: string, skipCache: boolean): Promise<{ contactProperties: any; companyProperties: any; } | undefined>  => {
+
   // const propertiesCacheIsValid = await checkPropertiesCache(customerId);
 
   const accessToken: string = await getAccessToken(customerId);
@@ -106,8 +165,10 @@ const getHubSpotProperties = async (customerId: string, skipCache: boolean): Pro
   }
 };
 
-const getNativeProperties = async (customerId: string): Promise<Properties[] | undefined>  => {
+
+export const getNativeProperties = async (customerId: string): Promise<Properties[] | undefined>  => {
   try{
+
   const properties = await prisma.properties.findMany({
     select: {
       name: true,
 }
 };
 
-export {
-  getHubSpotProperties,
-  getNativeProperties,
-  createPropertyGroup,
-  createRequiredProperty,
-};

types/common.d.ts

@@ -4,7 +4,9 @@ declare module "default" {
     label?: string | null;
     type?: string;
     object: Objects;
+    unique?: boolean;
     modificationMetadata: ModificationMetadata;
+
   }
   // interface Mapping {
   //   nativeName: string;