Your CRM. Your Intelligence. Connected in 15 Minutes.

@RestResource(urlMapping='/cognize/webhook')
global class CognizeWebhookHandler {

  @HttpPost
  global static void handlePost() {
    // Parse Cognize payload
    String body = RestContext.request.requestBody.toString();
    Map<String, Object> payload = (Map<String, Object>)
      JSON.deserializeUntyped(body);

    // Extract deal intelligence
    String oppId = (String) payload.get('crm_opportunity_id');
    Decimal dealScore = (Decimal) payload.get('deal_score');
    String riskLevel = (String) payload.get('risk_level');
    List<Object> actions = (List<Object>)
      payload.get('action_items');

    // Update Opportunity
    Opportunity opp = new Opportunity(
      Id = oppId,
      Cognize_Deal_Score__c = dealScore,
      Cognize_Risk_Level__c = riskLevel,
      Cognize_Last_Analyzed__c = Datetime.now()
    );
    update opp;

    // Create Tasks from action items
    List<Task> tasks = new List<Task>();
    for (Object item : actions) {
      Map<String, Object> ai =
        (Map<String, Object>) item;
      tasks.add(new Task(
        WhatId = oppId,
        Subject = (String) ai.get('action'),
        ActivityDate = Date.valueOf(
          (String) ai.get('due')),
        Status = 'Not Started'
      ));
    }
    insert tasks;
  }
}

const hubspot = require('@hubspot/api-client');
const client = new hubspot.Client({
  accessToken: process.env.HUBSPOT_TOKEN
});

// Cognize webhook handler
async function handleCognizeWebhook(payload) {
  const {
    crm_deal_id,
    deal_score,
    risk_level,
    action_items,
    summary
  } = payload;

  // Update Deal properties
  await client.crm.deals.basicApi.update(
    crm_deal_id,
    {
      properties: {
        'cognize_deal_score': deal_score,
        'cognize_risk_level': risk_level,
        'cognize_last_analyzed': new Date()
          .toISOString()
      }
    }
  );

  // Create Timeline event
  await client.crm.timeline.eventsApi.create({
    eventTemplateId: process.env.TIMELINE_TPL,
    objectId: crm_deal_id,
    tokens: {
      'callSummary': summary,
      'dealScore': deal_score.toString(),
      'actionCount': action_items.length
        .toString()
    }
  });

  // Create tasks for action items
  for (const item of action_items) {
    await client.crm.objects.basicApi.create(
      'tasks',
      {
        properties: {
          hs_task_subject: item.action,
          hs_task_status: 'NOT_STARTED',
          hs_timestamp: Date.now()
        }
      }
    );
  }
}