✨ Tested Tasks, Deals, Users

packages/api/src/crm/company/services/attio/mappers.ts

@@ -145,6 +145,7 @@ export class AttioCompanyMapper implements ICompanyMapper {
 
     return {
       remote_id: company.id.record_id,
+      remote_data: company,
       name: company.values.name[0]?.value,
       industry:
         typeof company.values.categories[0]?.option === 'string'

packages/api/src/crm/company/services/close/index.ts

@@ -1,19 +1,18 @@
-import { Injectable } from '@nestjs/common';
-import { ICompanyService } from '@crm/company/types';
-import { CrmObject } from '@crm/@lib/@types';
-import axios from 'axios';
-import { PrismaService } from '@@core/@core-services/prisma/prisma.service';
-import { LoggerService } from '@@core/@core-services/logger/logger.service';
-import { ActionType, handle3rdPartyServiceError } from '@@core/utils/errors';
 import { EncryptionService } from '@@core/@core-services/encryption/encryption.service';
+import { LoggerService } from '@@core/@core-services/logger/logger.service';
+import { PrismaService } from '@@core/@core-services/prisma/prisma.service';
 import { ApiResponse } from '@@core/utils/types';
+import { SyncParam } from '@@core/utils/types/interface';
+import { CrmObject } from '@crm/@lib/@types';
+import { ICompanyService } from '@crm/company/types';
+import { Injectable } from '@nestjs/common';
+import axios from 'axios';
 import { ServiceRegistry } from '../registry.service';
 import {
-  commonCompanyCloseProperties,
   CloseCompanyInput,
   CloseCompanyOutput,
+  commonCompanyCloseProperties,
 } from './types';
-import { SyncParam } from '@@core/utils/types/interface';
 
 @Injectable()
 export class CloseService implements ICompanyService {

packages/api/src/crm/company/services/close/mappers.ts

@@ -103,6 +103,7 @@ export class CloseCompanyMapper implements ICompanyMapper {
     }
     return {
       remote_id: company.id,
+      remote_data: company,
       name: company.name,
       number_of_employees: company?.custom?.employees || null,
       addresses: company?.addresses?.map((address) => ({

packages/api/src/crm/company/services/hubspot/mappers.ts

@@ -122,6 +122,7 @@ export class HubspotCompanyMapper implements ICompanyMapper {
 
     return {
       remote_id: company.id,
+      remote_data: company,
       name: company.properties.name,
       industry: company.properties.industry,
       number_of_employees: company.properties.numberofemployees,

packages/api/src/crm/company/services/pipedrive/mappers.ts

@@ -136,6 +136,7 @@ export class PipedriveCompanyMapper implements ICompanyMapper {
     }
     return {
       name: company.name,
+      remote_data: company,
       industry: null,
       number_of_employees: company.people_count ?? null,
       field_mappings,

packages/api/src/crm/company/services/zendesk/mappers.ts

@@ -156,6 +156,7 @@ export class ZendeskCompanyMapper implements ICompanyMapper {
 
     return {
       remote_id: String(company.id),
+      remote_data: company,
       name: company.name,
       email_addresses,
       phone_numbers,

packages/api/src/crm/company/services/zoho/mappers.ts

@@ -42,9 +42,9 @@ export class ZohoCompanyMapper implements ICompanyMapper {
     }
 
     if (source.user_id) {
-      result.Owner.id = await this.utils.getRemoteIdFromUserUuid(
-        source.user_id,
-      );
+      result.Owner = {
+        id: await this.utils.getRemoteIdFromUserUuid(source.user_id),
+      };
     }
 
     if (customFieldMappings && source.field_mappings) {
@@ -112,6 +112,7 @@ export class ZohoCompanyMapper implements ICompanyMapper {
 
     return {
       remote_id: company.id,
+      remote_data: company,
       name: company.Account_Name,
       phone_numbers: [
         {

packages/api/src/crm/company/services/zoho/types.ts

@@ -1,5 +1,5 @@
 interface ZohoCompany {
-  Owner: PersonDetail;
+  Owner: Partial<PersonDetail>;
   $currency_symbol: string;
   Account_Type: string;
   SIC_Code: string | null;

packages/api/src/crm/contact/services/attio/mappers.ts

@@ -154,6 +154,7 @@ export class AttioContactMapper implements IContactMapper {
 
     return {
       remote_id: contact.id.record_id,
+      remote_data: contact,
       first_name: contact.values.name[0]?.first_name,
       last_name: contact.values.name[0]?.last_name,
       email_addresses: contact.values.email_addresses?.map((e) => ({

packages/api/src/crm/contact/services/close/mappers.ts

@@ -102,6 +102,7 @@ export class CloseContactMapper implements IContactMapper {
 
     return {
       remote_id: contact.id,
+      remote_data: contact,
       first_name: contact.name,
       last_name: null,
       email_addresses: contact.emails?.map(({ email, type }) => ({

packages/api/src/crm/contact/services/hubspot/mappers.ts

@@ -137,6 +137,7 @@ export class HubspotContactMapper implements IContactMapper {
 
     return {
       remote_id: contact.id,
+      remote_data: contact,
       first_name: contact.properties.firstname,
       last_name: contact.properties.lastname,
       email_addresses: [

packages/api/src/crm/contact/services/pipedrive/mappers.ts

@@ -131,6 +131,7 @@ export class PipedriveContactMapper implements IContactMapper {
 
     return {
       remote_id: String(contact.id),
+      remote_data: contact,
       first_name: contact.first_name,
       last_name: contact.last_name,
       email_addresses: contact.email.map((e) => ({

packages/api/src/crm/contact/services/zendesk/mappers.ts

@@ -150,6 +150,7 @@ export class ZendeskContactMapper implements IContactMapper {
 
     return {
       remote_id: String(contact.id),
+      remote_data: contact,
       first_name: contact.first_name,
       last_name: contact.last_name,
       email_addresses,

packages/api/src/crm/contact/services/zoho/mappers.ts

@@ -152,6 +152,7 @@ export class ZohoContactMapper implements IContactMapper {
 
     return {
       remote_id: String(contact.id),
+      remote_data: contact,
       first_name: contact.First_Name ?? null,
       last_name: contact.Last_Name ?? null,
       email_addresses,

packages/api/src/crm/deal/services/attio/mappers.ts

@@ -161,6 +161,7 @@ export class AttioDealMapper implements IDealMapper {
 
     return {
       remote_id: deal.id.record_id,
+      remote_data: deal,
       name: deal.values.name.length > 0 ? deal.values.name[0].value : null,
       description: '',
       field_mappings,

packages/api/src/crm/deal/services/close/mappers.ts

@@ -149,6 +149,7 @@ export class CloseDealMapper implements IDealMapper {
     }
     return {
       remote_id: deal.id,
+      remote_data: deal,
       name: deal.note,
       description: deal.note || '',
       amount: parseFloat(`${deal.value || 0}`),

packages/api/src/crm/deal/services/hubspot/mappers.ts

@@ -131,6 +131,7 @@ export class HubspotDealMapper implements IDealMapper {
 
     return {
       remote_id: deal.id,
+      remote_data: deal,
       name: deal.properties.dealname,
       description: '',
       field_mappings,

packages/api/src/crm/deal/services/pipedrive/mappers.ts

@@ -131,6 +131,7 @@ export class PipedriveDealMapper implements IDealMapper {
 
     return {
       remote_id: String(deal.id),
+      remote_data: deal,
       name: deal.title,
       amount: deal.value,
       description: '', //todo null

packages/api/src/crm/deal/services/zendesk/mappers.ts

@@ -140,6 +140,7 @@ export class ZendeskDealMapper implements IDealMapper {
 
     return {
       remote_id: String(deal.id),
+      remote_data: deal,
       name: deal.name,
       amount:
         typeof deal.value === 'string' ? parseFloat(deal.value) : deal.value,

packages/api/src/crm/deal/services/zoho/mappers.ts

@@ -104,6 +104,7 @@ export class ZohoDealMapper implements IDealMapper {
     }
     const res: UnifiedDealOutput = {
       remote_id: deal.id,
+      remote_data: deal,
       name: deal.Deal_Name,
       description: deal.Description ?? '', // todo null
       amount: deal.Amount,

packages/api/src/crm/engagement/services/close/index.ts

@@ -1,12 +1,12 @@
-import { Injectable } from '@nestjs/common';
-import { IEngagementService } from '@crm/engagement/types';
-import { CrmObject } from '@crm/@lib/@types';
-import axios from 'axios';
-import { PrismaService } from '@@core/@core-services/prisma/prisma.service';
-import { LoggerService } from '@@core/@core-services/logger/logger.service';
-import { ActionType, handle3rdPartyServiceError } from '@@core/utils/errors';
 import { EncryptionService } from '@@core/@core-services/encryption/encryption.service';
+import { LoggerService } from '@@core/@core-services/logger/logger.service';
+import { PrismaService } from '@@core/@core-services/prisma/prisma.service';
 import { ApiResponse } from '@@core/utils/types';
+import { SyncParam } from '@@core/utils/types/interface';
+import { CrmObject } from '@crm/@lib/@types';
+import { IEngagementService } from '@crm/engagement/types';
+import { Injectable } from '@nestjs/common';
+import axios from 'axios';
 import { ServiceRegistry } from '../registry.service';
 import {
   CloseEngagementCallInput,
@@ -18,7 +18,6 @@ import {
   CloseEngagementMeetingOutput,
   CloseEngagementOutput,
 } from './types';
-import { SyncParam } from '@@core/utils/types/interface';
 
 @Injectable()
 export class CloseService implements IEngagementService {

packages/api/src/crm/engagement/services/close/mappers.ts

@@ -77,13 +77,11 @@ export class CloseEngagementMapper implements IEngagementMapper {
           new Date(source.start_at).getTime()
         : 0;
     const result: CloseEngagementCallInput = {
-      note_html: source.content || null,
+      note: source.content || null,
       duration: Math.floor(diffInMilliseconds / (1000 * 60)),
     };
     if (source.direction) {
-      result.direction = this.reverseMapToTaskDirection(
-        source.direction as EngagementDirection,
-      );
+      result.direction = source.direction.toLowerCase();
     }
 
     // Map HubSpot owner ID from user ID
@@ -99,8 +97,8 @@ export class CloseEngagementMapper implements IEngagementMapper {
         source.company_id,
       );
     }
-    if (source?.contacts && source?.contacts?.length) {
-      const contactId = await this.utils.getRemoteIdFromUserUuid(
+    if (source?.contacts && source?.contacts?.length > 0) {
+      const contactId = await this.utils.getRemoteIdFromContactUuid(
         source.contacts[0],
       );
       if (contactId) {
@@ -348,10 +346,11 @@ export class CloseEngagementMapper implements IEngagementMapper {
       }
     }
     if (engagement.direction) {
-      opts.direction = this.mapToTaskDirection(engagement.direction as any);
+      opts.direction = engagement.direction.toUpperCase();
     }
     return {
       remote_id: engagement.id,
+      remote_data: engagement,
       content: engagement.note_html || engagement.note,
       subject: engagement.note,
       start_at: new Date(engagement.date_created),
@@ -428,6 +427,7 @@ export class CloseEngagementMapper implements IEngagementMapper {
     }
     return {
       remote_id: engagement.id,
+      remote_data: engagement,
       content: engagement.note,
       subject: engagement.title,
       start_at: new Date(engagement.starts_at),
@@ -497,6 +497,7 @@ export class CloseEngagementMapper implements IEngagementMapper {
 
     return {
       remote_id: engagement.id,
+      remote_data: engagement,
       content: engagement.body_html,
       subject: engagement.subject,
       start_at: new Date(engagement.date_created),

packages/api/src/crm/engagement/services/close/types.ts

@@ -5,7 +5,8 @@ interface Call {
   user_id: string;
   direction: string;
   status: string;
-  note_html: string;
+  note_html?: string;
+  note: string;
   duration: number;
   phone: string;
 }

packages/api/src/crm/engagement/services/engagement.service.ts

@@ -1,5 +1,7 @@
 import { LoggerService } from '@@core/@core-services/logger/logger.service';
 import { PrismaService } from '@@core/@core-services/prisma/prisma.service';
+import { CoreUnification } from '@@core/@core-services/unification/core-unification.service';
+import { IngestDataService } from '@@core/@core-services/unification/ingest-data.service';
 import { WebhookService } from '@@core/@core-services/webhooks/panora-webhooks/webhook.service';
 import { FieldMappingService } from '@@core/field-mapping/field-mapping.service';
 import { ApiResponse } from '@@core/utils/types';
@@ -9,14 +11,10 @@ import { Injectable } from '@nestjs/common';
 import { v4 as uuidv4 } from 'uuid';
 import { IEngagementService } from '../types';
 import {
-  EngagementDirection,
-  EngagementType,
   UnifiedEngagementInput,
   UnifiedEngagementOutput,
 } from '../types/model.unified';
 import { ServiceRegistry } from './registry.service';
-import { CoreUnification } from '@@core/@core-services/unification/core-unification.service';
-import { IngestDataService } from '@@core/@core-services/unification/ingest-data.service';
 
 @Injectable()
 export class EngagementService {

packages/api/src/crm/engagement/services/hubspot/index.ts

@@ -1,12 +1,12 @@
-import { Injectable } from '@nestjs/common';
-import { IEngagementService } from '@crm/engagement/types';
-import { CrmObject } from '@crm/@lib/@types';
-import axios from 'axios';
-import { PrismaService } from '@@core/@core-services/prisma/prisma.service';
-import { LoggerService } from '@@core/@core-services/logger/logger.service';
-import { ActionType, handle3rdPartyServiceError } from '@@core/utils/errors';
 import { EncryptionService } from '@@core/@core-services/encryption/encryption.service';
+import { LoggerService } from '@@core/@core-services/logger/logger.service';
+import { PrismaService } from '@@core/@core-services/prisma/prisma.service';
 import { ApiResponse } from '@@core/utils/types';
+import { SyncParam } from '@@core/utils/types/interface';
+import { CrmObject } from '@crm/@lib/@types';
+import { IEngagementService } from '@crm/engagement/types';
+import { Injectable } from '@nestjs/common';
+import axios from 'axios';
 import { ServiceRegistry } from '../registry.service';
 import {
   HubspotEngagementCallInput,
@@ -21,7 +21,6 @@ import {
   commonEmailHubspotProperties,
   commonMeetingHubspotProperties,
 } from './types';
-import { SyncParam } from '@@core/utils/types/interface';
 
 @Injectable()
 export class HubspotService implements IEngagementService {
@@ -119,7 +118,7 @@ export class HubspotService implements IEngagementService {
         properties: engagementData,
       };
       const resp = await axios.post(
-        `${connection.account_url}/objects/calls`,
+        `${connection.account_url}/objects/meetings`,
         JSON.stringify(dataBody),
         {
           headers: {
@@ -156,7 +155,7 @@ export class HubspotService implements IEngagementService {
         properties: engagementData,
       };
       const resp = await axios.post(
-        `https://api.hubapi.com/crm/v3/objects/emails`,
+        `${connection.account_url}/objects/emails`,
         JSON.stringify(dataBody),
         {
           headers: {