sra-analytics

# 1. Clone the repo
git clone git.soma.salesforce.com/chad-goldsmith/agentforce-debug-tools.git
cd agentforce-debug-tools

# 2. Copy skill into your Claude skills directory
mkdir -p ~/.claude/skills/sra-analytics
cp skills/sra-analytics/SKILL.md ~/.claude/skills/sra-analytics/SKILL.md

# 3. Verify sf CLI auth
sf org list

# Deploy the in-org dashboard to your target org
cd agentforce-debug-tools
sf project deploy start \
  --source-dir sra-analytics/force-app/main/default/classes/SRAAnalyticsController.cls \
  sra-analytics/force-app/main/default/classes/SRAAnalyticsController.cls-meta.xml \
  sra-analytics/force-app/main/default/lwc/sraAnalyticsDashboard \
  --target-org <ORG_ALIAS>

# Or run the local Python dashboard
python3 sra-analytics/scripts/analytics.py --org <ORG_ALIAS>

# From the cloned agentforce-debug-tools repo root:
sf project deploy start \
  --source-dir sra-analytics/force-app/main/default/classes/SRAAnalyticsController.cls \
  sra-analytics/force-app/main/default/classes/SRAAnalyticsController.cls-meta.xml \
  sra-analytics/force-app/main/default/lwc/sraAnalyticsDashboard \
  --target-org <ORG_ALIAS>

# From the cloned agentforce-debug-tools repo root:
python3 sra-analytics/scripts/analytics.py --org <ORG_ALIAS>
# Opens http://127.0.0.1:8090

ConnectApi.CdpQueryInput input = new ConnectApi.CdpQueryInput();
input.sql = '<YOUR SQL>';
ConnectApi.CdpQueryOutputV2 output = ConnectApi.CdpQuery.queryAnsiSqlV2(input);

   public class MyNewData {
       @AuraEnabled public String fieldA;
       @AuraEnabled public Integer fieldB;
   }

   @AuraEnabled(cacheable=true)
   public static List<MyNewData> getMyNewData(String startDate, String endDate, String agentName, String channelType) {
       String dateFilter = buildDateFilter(startDate, endDate, 's.startTimestamp__c');
       String agentFilter = buildAgentFilter(agentName);
       // Query uses: dateFilter + agentFilter + buildChannelFilter(channelType)
   }

   import getMyNewData from '@salesforce/apex/SRAAnalyticsController.getMyNewData';
   // Add @track property, add to Promise.allSettled array, add result handler

SELECT aiAgentSessionId__c, startTimestamp__c, endTimestamp__c,
       aiAgentChannelTypeId__c, aiAgentSessionEndTypeId__c
FROM AiAgentSession__dll
WHERE relatedRecordId__c = '<CASE_ID or MESSAGING_SESSION_ID or VOICECALL_ID>'
ORDER BY startTimestamp__c DESC

// Via ConnectApi in Apex
ConnectApi.CdpQueryInput input = new ConnectApi.CdpQueryInput();
input.sql = @
SELECT 
    s.aiAgentSessionId__c AS sessionId,
    s.startTimestamp__c,
    s.endTimestamp__c,
    s.aiAgentChannelTypeId__c AS channel,
    s.aiAgentSessionEndTypeId__c AS endType,
    s.relatedRecordId__c AS parentRecordId,
    p.aiAgentApiName__c AS agentName
FROM AiAgentSession__dll s
LEFT JOIN AiAgentSessionParticipant__dll p 
    ON s.aiAgentSessionId__c = p.aiAgentSessionId__c
WHERE s.aiAgentSessionId__c = '<SESSION_ID>'
@;
ConnectApi.CdpQueryOutputV2 output = ConnectApi.CdpQuery.queryAnsiSqlV2(input);
System.debug(output.data);

sf data query \
  --query "SELECT aiAgentSessionId__c, startTimestamp__c, endTimestamp__c, aiAgentChannelTypeId__c, relatedRecordId__c FROM AiAgentSession__dll WHERE relatedRecordId__c = '<CASE_ID>'" \
  --target-org <ALIAS> \
  --api-version 61.0

AiAgentSession__dll (session)
    └─ AiAgentInteraction__dll (interaction) 
           └─ AiAgentInteractionStep__dll (steps)

-- Get all steps for a session (via interaction join)
SELECT 
    step.name__c AS stepName,
    step.aiAgentInteractionStepTypeId__c AS stepType,
    step.startTimestamp__c,
    step.endTimestamp__c,
    step.inputValueText__c AS input,
    step.outputValueText__c AS output,
    step.subType__c
FROM AiAgentInteractionStep__dll step
JOIN AiAgentInteraction__dll interaction 
    ON step.aiAgentInteractionId__c = interaction.id__c
WHERE interaction.aiAgentSessionId__c = '<SESSION_ID>'
ORDER BY step.startTimestamp__c

SELECT name__c, aiAgentInteractionStepTypeId__c, 
       startTimestamp__c, endTimestamp__c,
       inputValueText__c, outputValueText__c
FROM AiAgentInteractionStep__dll
WHERE aiAgentInteractionId__c = '<INTERACTION_ID>'
ORDER BY startTimestamp__c

ConnectApi.CdpQueryInput input = new ConnectApi.CdpQueryInput();
input.sql = @
SELECT 
    step.stepType__c AS stepType,
    step.stepName__c AS stepName,
    step.topicName__c AS topic,
    step.startTimestamp__c,
    step.endTimestamp__c,
    step.statusCode__c AS status,
    step.input__c,
    step.output__c
FROM AiAgentInteractionStep__dll step
WHERE step.aiAgentSessionId__c = '<SESSION_ID>'
ORDER BY step.startTimestamp__c ASC
@;
ConnectApi.CdpQueryOutputV2 output = ConnectApi.CdpQuery.queryAnsiSqlV2(input);

SELECT aiAgentInteractionMessageTypeId__c AS messageType,
       contentText__c AS content,
       startTimestamp__c AS timestamp
FROM AiAgentInteractionMessage__dll
WHERE aiAgentSessionId__c = '<SESSION_ID>'
ORDER BY startTimestamp__c

SELECT aiAgentInteractionMessageTypeId__c AS messageType,
       contentText__c AS content,
       startTimestamp__c AS timestamp
FROM AiAgentInteractionMessage__dll
WHERE aiAgentInteractionId__c = '<INTERACTION_ID>'
ORDER BY startTimestamp__c

// In Apex
List<RecActorActionFeed> feed = [
    SELECT Id, ParentId, Type, Body, CreatedDate, 
           InsertedBy.Name, CommentCount, LikeCount
    FROM RecActorActionFeed
    WHERE Parent.AiAgentSession__c = '<SESSION_ID>'
    ORDER BY CreatedDate ASC
];

sf data query \
  --query "SELECT Id, Type, Body, CreatedDate FROM RecActorActionFeed WHERE Parent.AiAgentSession__c = '<SESSION_ID>' ORDER BY CreatedDate" \
  --target-org <ALIAS>

List<GenOpPlan> plans = [
    SELECT Id, AiAgentSession__c, Outcome, Intent, Topic, 
           ChannelType, CreatedDate
    FROM GenOpPlan
    WHERE AiAgentSession__c = '<SESSION_ID>'
];

sf data query \
  --query "SELECT Id, Outcome, Intent, Topic FROM GenOpPlan WHERE AiAgentSession__c = '<SESSION_ID>'" \
  --target-org <ALIAS>

ConnectApi.CdpQueryInput input = new ConnectApi.CdpQueryInput();
input.sql = @
SELECT 
    g.aiAgentSessionId__c AS sessionId,
    g.aiPromptTemplateApiName__c AS promptTemplate,
    g.aiModelName__c AS model,
    SUM(g.inputTokens__c) AS totalInputTokens,
    SUM(g.outputTokens__c) AS totalOutputTokens
FROM GenAIGatewayRequest__dll g
WHERE g.aiAgentSessionId__c = '<SESSION_ID>'
GROUP BY g.aiAgentSessionId__c, g.aiPromptTemplateApiName__c, g.aiModelName__c
@;
ConnectApi.CdpQueryOutputV2 output = ConnectApi.CdpQuery.queryAnsiSqlV2(input);

ConnectApi.CdpQueryInput input = new ConnectApi.CdpQueryInput();
input.sql = @
SELECT 
    resp.aiRetrieverRequestId__c AS requestId,
    resp.retrievedRecordName__c AS articleTitle,
    resp.retrievedRecordId__c AS articleId,
    resp.qualityScore__c AS quality,
    resp.relevanceScore__c AS relevance,
    resp.orderNumber__c AS rank
FROM AIRetrieverResponse__dll resp
JOIN AIRetrieverRequest__dll req 
    ON resp.aiRetrieverRequestId__c = req.id__c
WHERE req.aiAgentSessionId__c = '<SESSION_ID>'
ORDER BY resp.orderNumber__c ASC
@;
ConnectApi.CdpQueryOutputV2 output = ConnectApi.CdpQuery.queryAnsiSqlV2(input);

ConnectApi.CdpQueryInput input = new ConnectApi.CdpQueryInput();
input.sql = @
SELECT 
    span.name__c AS operation,
    span.startTimestamp__c,
    span.endTimestamp__c,
    span.durationInMilliseconds__c AS duration,
    span.parentSpanId__c AS parentSpan
FROM ObservabilitySpan__dll span
WHERE span.aiAgentSessionId__c = '<SESSION_ID>'
ORDER BY span.startTimestamp__c ASC
@;
ConnectApi.CdpQueryOutputV2 output = ConnectApi.CdpQuery.queryAnsiSqlV2(input);

// Step 1: Get session metadata
String sessionId = '<SESSION_ID>';
ConnectApi.CdpQueryInput input = new ConnectApi.CdpQueryInput();

// Session overview
input.sql = 'SELECT s.id__c, s.startTimestamp__c, s.endTimestamp__c, s.aiAgentChannelTypeId__c, p.aiAgentApiName__c FROM AiAgentSession__dll s LEFT JOIN AiAgentSessionParticipant__dll p ON s.id__c = p.aiAgentSessionId__c WHERE s.id__c = \'' + sessionId + '\'';
ConnectApi.CdpQueryOutputV2 sessionData = ConnectApi.CdpQuery.queryAnsiSqlV2(input);
System.debug('Session: ' + sessionData.data);

// All steps
input.sql = 'SELECT step.id__c, step.aiAgentInteractionStepTypeId__c, step.orderNumber__c, step.durationInMilliseconds__c FROM AiAgentInteractionStep__dll step JOIN AiAgentInteraction__dll interaction ON step.aiAgentInteractionId__c = interaction.id__c WHERE interaction.aiAgentSessionId__c = \'' + sessionId + '\' ORDER BY step.orderNumber__c ASC';
ConnectApi.CdpQueryOutputV2 stepsData = ConnectApi.CdpQuery.queryAnsiSqlV2(input);
System.debug('Steps: ' + stepsData.data);

// Step 2: Get RecActorActionFeed (core SOQL)
List<RecActorActionFeed> feed = [SELECT Id, Type, Body, CreatedDate FROM RecActorActionFeed WHERE Parent.AiAgentSession__c = :sessionId ORDER BY CreatedDate];
System.debug('Feed: ' + feed);

// Step 3: Get plan outcome
List<GenOpPlan> plans = [SELECT Id, Outcome, Intent, Topic FROM GenOpPlan WHERE AiAgentSession__c = :sessionId];
System.debug('Plan: ' + plans);

// Step 4: Token usage
input.sql = 'SELECT SUM(g.inputTokens__c) AS inputTokens, SUM(g.outputTokens__c) AS outputTokens FROM GenAIGatewayRequest__dll g WHERE g.aiAgentSessionId__c = \'' + sessionId + '\'';
ConnectApi.CdpQueryOutputV2 tokenData = ConnectApi.CdpQuery.queryAnsiSqlV2(input);
System.debug('Tokens: ' + tokenData.data);

# Get session ID from recent sessions
sf data query --query "SELECT Id, Name FROM Case WHERE Subject LIKE '%<CUSTOMER_NAME>%' ORDER BY CreatedDate DESC LIMIT 1" --target-org <ALIAS>

# Use session ID to query history
sf data query --query "SELECT Id, Type, Body FROM RecActorActionFeed WHERE Parent.AiAgentSession__c = '<SESSION_ID>'" --target-org <ALIAS>

// Step 1: Get the parent record ID from GenOpPlan
List<GenOpPlan> plans = [
    SELECT Id, ParentId, CreatedBy.Name, ChannelType 
    FROM GenOpPlan 
    WHERE AiAgentSession__c = :sessionId
];

String parentId = plans[0].ParentId; // Case, MessagingSession, or VoiceCall Id
String channelType = plans[0].ChannelType;

// Step 2: Query parent record based on channel
if (channelType == 'Case') {
    // Case channel - get case owner
    List<Case> cases = [
        SELECT Id, Owner.Name, Owner.Email, OwnerId 
        FROM Case 
        WHERE Id = :parentId
    ];
    System.debug('Employee: ' + cases[0].Owner.Name);
    
} else if (channelType == 'Messaging') {
    // Messaging channel - get agent from MessagingSession
    List<MessagingSession> sessions = [
        SELECT Id, AgentId, Agent.Name, Agent.Email 
        FROM MessagingSession 
        WHERE Id = :parentId
    ];
    System.debug('Employee: ' + sessions[0].Agent.Name);
    
} else if (channelType == 'Voice') {
    // Voice channel - get agent from VoiceCall
    List<VoiceCall> calls = [
        SELECT Id, UserId, User.Name, User.Email 
        FROM VoiceCall 
        WHERE Id = :parentId
    ];
    System.debug('Employee: ' + calls[0].User.Name);
}

# Step 1: Get parent record ID
sf data query --query "SELECT ParentId, ChannelType FROM GenOpPlan WHERE AiAgentSession__c = '<SESSION_ID>'" --target-org <ALIAS>

# Step 2: Query based on channel type
# For Case:
sf data query --query "SELECT Owner.Name, Owner.Email FROM Case WHERE Id = '<PARENT_ID>'" --target-org <ALIAS>

# For Messaging:
sf data query --query "SELECT Agent.Name, Agent.Email FROM MessagingSession WHERE Id = '<PARENT_ID>'" --target-org <ALIAS>

# For Voice:
sf data query --query "SELECT User.Name, User.Email FROM VoiceCall WHERE Id = '<PARENT_ID>'" --target-org <ALIAS>

List<RecActorActionFeed> feed = [
    SELECT InsertedBy.Name, InsertedBy.Email, Type, CreatedDate
    FROM RecActorActionFeed 
    WHERE Parent.AiAgentSession__c = :sessionId
    ORDER BY CreatedDate ASC
    LIMIT 1
];
System.debug('Employee: ' + feed[0].InsertedBy.Name);

// Query AiAgentInteractionStep__dll WHERE stepType = 'ExecuteAction'
input.sql = 'SELECT step.aiAgentInteractionStepOutput__c FROM AiAgentInteractionStep__dll step JOIN AiAgentInteraction__dll interaction ON step.aiAgentInteractionId__c = interaction.id__c WHERE interaction.aiAgentSessionId__c = \'' + sessionId + '\' AND step.aiAgentInteractionStepTypeId__c = \'ExecuteAction\'';

// Query AIRetrieverResponse__dll with article names
input.sql = 'SELECT resp.retrievedRecordName__c, resp.qualityScore__c FROM AIRetrieverResponse__dll resp JOIN AIRetrieverRequest__dll req ON resp.aiRetrieverRequestId__c = req.id__c WHERE req.aiAgentSessionId__c = \'' + sessionId + '\'';

// Query GenOpPlan for outcome + last RecActorActionFeed for error message
List<GenOpPlan> plans = [SELECT Outcome FROM GenOpPlan WHERE AiAgentSession__c = :sessionId];
List<RecActorActionFeed> lastFeed = [SELECT Body FROM RecActorActionFeed WHERE Parent.AiAgentSession__c = :sessionId ORDER BY CreatedDate DESC LIMIT 1];

// Query AiAgentInteractionStep__dll with duration
input.sql = 'SELECT step.aiAgentInteractionStepTypeId__c, step.durationInMilliseconds__c FROM AiAgentInteractionStep__dll step JOIN AiAgentInteraction__dll interaction ON step.aiAgentInteractionId__c = interaction.id__c WHERE interaction.aiAgentSessionId__c = \'' + sessionId + '\' ORDER BY step.orderNumber__c';

// Find all sessions on a Case
String caseId = '<CASE_ID>';
ConnectApi.CdpQueryInput input = new ConnectApi.CdpQueryInput();

// Option A: For Case channel (uses GenOpPlan.ParentId)
List<GenOpPlan> plans = [
    SELECT Id, AiAgentSession__c, CreatedDate, CreatedBy.Name
    FROM GenOpPlan 
    WHERE ParentId = :caseId
    ORDER BY CreatedDate DESC
];

// Get unique session IDs
Set<String> sessionIds = new Set<String>();
for (GenOpPlan p : plans) {
    if (p.AiAgentSession__c != null) {
        sessionIds.add(p.AiAgentSession__c);
    }
}

// Option B: For Messaging/Voice (uses AiAgentSession__dll.relatedRecordId__c)
// (Only if Case was ALSO a MessagingSession or VoiceCall parent)
input.sql = 'SELECT id__c, startTimestamp__c, endTimestamp__c FROM AiAgentSession__dll WHERE relatedRecordId__c = \'' + caseId + '\'';
ConnectApi.CdpQueryOutputV2 sessions = ConnectApi.CdpQuery.queryAnsiSqlV2(input);

// Get all unique users from RecActorActionFeed for these sessions
List<RecActorActionFeed> allFeed = [
    SELECT Id, InsertedById, InsertedBy.Name, InsertedBy.Email, 
           Type, CreatedDate, Body
    FROM RecActorActionFeed
    WHERE ParentId = :caseId
    ORDER BY CreatedDate ASC
];

// Dedupe users
Map<Id, String> userMap = new Map<Id, String>();
for (RecActorActionFeed f : allFeed) {
    if (!userMap.containsKey(f.InsertedById)) {
        userMap.put(f.InsertedById, f.InsertedBy.Name + ' (' + f.InsertedBy.Email + ')');
    }
}

System.debug('Users who interacted: ' + userMap.values());

// Filter feed items by selected user
String selectedUserId = '<USER_ID>'; // From dropdown selection

List<RecActorActionFeed> userActions = [
    SELECT Id, Type, Body, CreatedDate, 
           Status, CommentCount, LikeCount,
           RelatedRecordId // The specific action/CLT/step this relates to
    FROM RecActorActionFeed
    WHERE ParentId = :caseId
      AND InsertedById = :selectedUserId
    ORDER BY CreatedDate ASC
];

// Parse each action type
for (RecActorActionFeed action : userActions) {
    if (action.Type == 'TextPost') {
        System.debug('User asked: ' + action.Body);
    } else if (action.Type == 'ContentPost') {
        System.debug('User received CLT: ' + action.Body); // JSON rendering data
    } else if (action.Type == 'TrackedChange') {
        System.debug('Status update: ' + action.Body);
    } else if (action.Type == 'ActionConfirm') {
        System.debug('User approved action: ' + action.RelatedRecordId);
    }
}

// Get action details from GenAiFunction (action definition)
String actionId = action.RelatedRecordId;
List<GenAiFunction> actions = [
    SELECT Id, DeveloperName, Description 
    FROM GenAiFunction 
    WHERE Id = :actionId
];
System.debug('User approved: ' + actions[0].DeveloperName);

// Parse ContentPost body (JSON format)
if (action.Type == 'ContentPost') {
    Map<String, Object> cltData = (Map<String, Object>) JSON.deserializeUntyped(action.Body);
    String cltType = (String) cltData.get('complex_data_type_name');
    System.debug('CLT Type: ' + cltType); // e.g., "solutionCard", "orderSummary"
}

// Body is plain text
System.debug('User said: ' + action.Body);

// Get session metadata for these actions
List<GenOpPlan> planContext = [
    SELECT Id, Topic, Intent, Outcome, AiAgentSession__c
    FROM GenOpPlan
    WHERE ParentId = :caseId
];

// Map session IDs to topics
Map<String, String> sessionToTopic = new Map<String, String>();
for (GenOpPlan p : planContext) {
    sessionToTopic.put(p.AiAgentSession__c, p.Topic);
}

// Now annotate user actions with plan context
for (RecActorActionFeed action : userActions) {
    // Find which session this action belongs to (infer from CreatedDate vs session start/end)
    // Or: use GenOpPlan.CreatedDate range to bucket actions into sessions
}

Case-00001234 — Customer Refund Request
Case-00001235 — Product Issue Escalation
Case-00001236 — Billing Dispute

John Smith (john.smith@example.com) — 12 interactions
Jane Doe (jane.doe@example.com) — 7 interactions
System Agent (system@salesforce.com) — 23 interactions [filter out?]

2026-07-23 10:15:32 — User asked: "Can we issue a refund?"
2026-07-23 10:15:45 — SRA showed CLT: Solution Card (Refund Policy)
2026-07-23 10:16:02 — User approved action: "Create Refund Case"
2026-07-23 10:16:10 — Status update: "Action completed successfully"
2026-07-23 10:17:22 — User asked: "What's the refund timeline?"

// Input: caseId (String), selectedUserId (String, optional)

// Step 1: Get all sessions for Case
List<GenOpPlan> plans = [
    SELECT Id, AiAgentSession__c, Topic, CreatedDate
    FROM GenOpPlan 
    WHERE ParentId = :caseId
    ORDER BY CreatedDate DESC
];

// Step 2: Get all users who interacted
List<RecActorActionFeed> allFeed = [
    SELECT InsertedById, InsertedBy.Name, InsertedBy.Email, 
           COUNT(Id) interactionCount
    FROM RecActorActionFeed
    WHERE ParentId = :caseId
    GROUP BY InsertedById, InsertedBy.Name, InsertedBy.Email
];

// Step 3: If user selected, get their actions
if (selectedUserId != null) {
    List<RecActorActionFeed> userActions = [
        SELECT Id, Type, Body, CreatedDate, Status, RelatedRecordId
        FROM RecActorActionFeed
        WHERE ParentId = :caseId
          AND InsertedById = :selectedUserId
        ORDER BY CreatedDate ASC
    ];
    
    // Step 4: Enrich with action metadata
    Set<Id> actionIds = new Set<Id>();
    for (RecActorActionFeed a : userActions) {
        if (a.RelatedRecordId != null && a.Type == 'ActionConfirm') {
            actionIds.add(a.RelatedRecordId);
        }
    }
    
    Map<Id, GenAiFunction> actionMap = new Map<Id, GenAiFunction>([
        SELECT Id, DeveloperName, Description
        FROM GenAiFunction
        WHERE Id IN :actionIds
    ]);
    
    // Return enriched data
    for (RecActorActionFeed a : userActions) {
        if (actionMap.containsKey(a.RelatedRecordId)) {
            System.debug(a.CreatedDate + ' — User ' + a.Type + ': ' + actionMap.get(a.RelatedRecordId).DeveloperName);
        } else {
            System.debug(a.CreatedDate + ' — ' + a.Type + ': ' + a.Body);
        }
    }
}

WHERE ParentId = :caseId
  AND InsertedById = :selectedUserId
  AND CreatedDate >= :startDate
  AND CreatedDate <= :endDate

// First get session date ranges from GenOpPlan
List<GenOpPlan> sessionPlans = [
    SELECT AiAgentSession__c, CreatedDate
    FROM GenOpPlan
    WHERE ParentId = :caseId
];

// Then filter feed items by date range of selected session
// (Since RecActorActionFeed doesn't directly store session ID)