feat(ai-assistant): schedule meeting message handling (#4584)

Coread · web-flow · commit 61e8218343b1 · 2025-11-24T11:25:00.000Z
diff --git a/packages/@webex/internal-plugin-ai-assistant/src/ai-assistant.ts b/packages/@webex/internal-plugin-ai-assistant/src/ai-assistant.ts
@@ -27,7 +27,13 @@ import {
   CONTEXT_RESOURCE_TYPES,
   RESPONSE_NAMES,
 } from './constants';
-import {decryptCitedAnswer, decryptMessage, decryptToolUse, decryptWorkspace} from './utils';
+import {
+  decryptCitedAnswer,
+  decryptMessage,
+  decryptScheduleMeeting,
+  decryptToolUse,
+  decryptWorkspace,
+} from './utils';
 
 const AIAssistant = WebexPlugin.extend({
   namespace: 'AIAssistant',
@@ -169,6 +175,10 @@ const AIAssistant = WebexPlugin.extend({
         await decryptCitedAnswer(responseContent, this.webex);
         break;
       }
+      case RESPONSE_NAMES.SCHEDULE_MEETING: {
+        await decryptScheduleMeeting(responseContent, this.webex);
+        break;
+      }
       case RESPONSE_NAMES.TOOL_RESULT: {
         // No encrypted content in tool_result
         break;
@@ -280,6 +290,7 @@ const AIAssistant = WebexPlugin.extend({
    * @param {Object} options.assistant optional parameter to specify the assistant to use
    * @param {Object} options.locale optional locale to use for the request, defaults to 'en_US'
    * @param {string} options.requestId optional request ID to use for this request, if not provided a new UUID will be generated
+   * @param {string} options.entryPoint optional entryPoint to use for this request
    * @returns {Promise<Object>} Resolves with an object containing the requestId, sessionId and streamEventName
    * @public
    * @memberof AIAssistant
@@ -313,6 +324,7 @@ const AIAssistant = WebexPlugin.extend({
         async: 'chunked',
         locale: options.locale || 'en_US',
         content,
+        ...(options.entryPoint ? {entryPoint: options.entryPoint} : {}),
         ...(options.assistant ? {assistant: options.assistant} : {}),
       },
       ...(options.requestId ? {requestId: options.requestId} : {}),
diff --git a/packages/@webex/internal-plugin-ai-assistant/src/constants.ts b/packages/@webex/internal-plugin-ai-assistant/src/constants.ts
@@ -43,4 +43,5 @@ export enum RESPONSE_NAMES {
   MESSAGE = 'message',
   TOOL_RESULT = 'tool_result',
   WORKSPACE = 'workspace',
+  SCHEDULE_MEETING = 'schedule_meeting',
 }
diff --git a/packages/@webex/internal-plugin-ai-assistant/src/types.ts b/packages/@webex/internal-plugin-ai-assistant/src/types.ts
@@ -51,4 +51,5 @@ export interface AiAssistantRequestOptions {
   assistant?: string;
   locale?: string;
   requestId?: string;
+  entryPoint?: string;
 }
diff --git a/packages/@webex/internal-plugin-ai-assistant/src/utils.ts b/packages/@webex/internal-plugin-ai-assistant/src/utils.ts
@@ -31,6 +31,35 @@ export const decryptCitedAnswer = async (data, webex) => {
 
   await decryptInPlace(data, 'value.value', 'encryptionKeyUrl', webex);
 };
+export const decryptScheduleMeeting = async (data, webex) => {
+  // Decrypt commentary in parameters
+  await decryptInPlace(data, 'parameters.commentary', 'encryptionKeyUrl', webex);
+
+  const meetingData = data.value?.results?.data;
+  if (meetingData) {
+    // Decrypt attendee emails
+    if (meetingData.attendees) {
+      await Promise.all(
+        meetingData.attendees.map((attendee, index) => {
+          return decryptInPlace(
+            data,
+            `value.results.data.attendees.${index}.email`,
+            'encryptionKeyUrl',
+            webex
+          );
+        })
+      );
+    }
+
+    // Decrypt other fields in the meeting data
+    await Promise.all([
+      decryptInPlace(data, 'value.results.data.title', 'encryptionKeyUrl', webex),
+      decryptInPlace(data, 'value.results.data.inScopeReply', 'encryptionKeyUrl', webex),
+      decryptInPlace(data, 'value.results.data.meetingLink', 'encryptionKeyUrl', webex),
+      decryptInPlace(data, 'value.results.data.description', 'encryptionKeyUrl', webex),
+    ]);
+  }
+};
 
 export const decryptMessage = async (data, webex) => {
   await decryptInPlace(data, 'value', 'encryptionKeyUrl', webex);
diff --git a/packages/@webex/internal-plugin-ai-assistant/test/unit/data/messages.ts b/packages/@webex/internal-plugin-ai-assistant/test/unit/data/messages.ts
@@ -656,4 +656,65 @@ export const workspaceResponse = [
       },
     },
   },
+];
+
+export const scheduleMeetingResponse = [
+  {
+    eventType: 'assistant-api.response',
+    sequence: 1,
+    finished: true,
+    clientRequestId: 'test-request-id',
+    responseId: 'b6893a00-c6cc-11f0-adb9-f9fe7ea2ec69',
+    responseType: 'response',
+    response: {
+      sessionId: 'a64345a0-c6cc-11f0-8c21-a7bce84cd4be',
+      sessionUrl:
+        'https://assistant-api-a.wbx2.com:443/assistant-api/api/v1/sessions/a64345a0-c6cc-11f0-8c21-a7bce84cd4be',
+      messageId: 'b688c4d0-c6cc-11f0-adb9-f9fe7ea2ec69',
+      messageUrl:
+        'https://assistant-api-a.wbx2.com:443/assistant-api/api/v1/sessions/a64345a0-c6cc-11f0-8c21-a7bce84cd4be/messages/b688c4d0-c6cc-11f0-adb9-f9fe7ea2ec69',
+      responseId: 'b6893a00-c6cc-11f0-adb9-f9fe7ea2ec69',
+      responseUrl:
+        'https://assistant-api-a.wbx2.com:443/assistant-api/api/v1/sessions/a64345a0-c6cc-11f0-8c21-a7bce84cd4be/messages/b6893a00-c6cc-11f0-adb9-f9fe7ea2ec69',
+      content: {
+        name: 'schedule_meeting',
+        type: 'json',
+        encryptionKeyUrl: 'kms://kms-cisco.wbx2.com/keys/dd6053f0-a1b3-428d-8104-317527d73630',
+        parameters: {
+          commentary: 'schedule_meeting_encrypted_commentary',
+        },
+        value: {
+          results: {
+            category: 'schedule_meeting',
+            data: {
+              success: true,
+              status: 'created',
+              attendees: [
+                {
+                  email: 'schedule_meeting_encrypted_email_0',
+                  status: 'available',
+                },
+                {
+                  email: 'schedule_meeting_encrypted_email_1',
+                  status: 'available',
+                },
+              ],
+              startTime: '2025-11-26T09:00:00Z',
+              duration: '1800000',
+              title: 'schedule_meeting_encrypted_title',
+              description: 'schedule_meeting_encrypted_description',
+              timeZone: 'Europe/London',
+              inScopeReply: 'schedule_meeting_encrypted_inScopeReply',
+              meetingLink: 'schedule_meeting_encrypted_meetingLink',
+              schedulerUUID: '21e53358f00b46bda778d9e7124f6f1e',
+              meetingUUID: '920eab08068b4382a31d26ddecc9ec8b',
+              meetingId: '837dc916-2259-6c04-9b51-d4dcfc7c4557',
+            },
+          },
+        },
+      },
+      createdAt: '2025-11-21T11:25:01.670071069Z',
+      creator: {role: 'assistant'},
+    },
+  },
 ];
diff --git a/packages/@webex/internal-plugin-ai-assistant/test/unit/spec/ai-assistant.ts b/packages/@webex/internal-plugin-ai-assistant/test/unit/spec/ai-assistant.ts
@@ -16,7 +16,7 @@ import {
   AI_ASSISTANT_ERROR_CODES,
   AI_ASSISTANT_ERRORS,
 } from '@webex/internal-plugin-ai-assistant/src/constants';
-import {jsonResponse, messageResponse, workspaceResponse} from '../data/messages';
+import {jsonResponse, messageResponse, workspaceResponse, scheduleMeetingResponse} from '../data/messages';
 
 const waitForAsync = () =>
   new Promise<void>((resolve) =>
@@ -606,6 +606,49 @@ describe('plugin-ai-assistant', () => {
         expect(triggerSpy.getCall(2).args[1]).to.deep.equal(expectedResult);
       });      
 
+      it('handles a schedule meeting response', async () => {
+        const triggerSpy = sinon.spy(webex.internal.aiAssistant, 'trigger');
+        webex.internal.encryption.decryptText.callsFake(async (keyUrl, value) => {
+          return `decrypted-with-${keyUrl}-${value}`;
+        });
+
+        await webex.internal.aiAssistant._request({
+          resource: 'test-resource',
+          params: {param1: 'value1'},
+        });
+
+        // Handle schedule meeting event with encrypted fields
+        const event = cloneDeep(scheduleMeetingResponse[0]);
+        event.clientRequestId = 'test-request-id';
+        
+        await webex.internal.aiAssistant._handleEvent(event);
+
+        expect(triggerSpy.getCall(0).args[0]).to.equal(
+          `aiassistant:result:test-request-id`
+        );
+
+        await waitForAsync();
+
+        // Verify all encrypted fields were decrypted
+        const expectedResult = cloneDeep(event);
+        expectedResult.response.content.parameters.commentary = 
+          'decrypted-with-kms://kms-cisco.wbx2.com/keys/dd6053f0-a1b3-428d-8104-317527d73630-schedule_meeting_encrypted_commentary';
+        expectedResult.response.content.value.results.data.attendees[0].email = 
+          'decrypted-with-kms://kms-cisco.wbx2.com/keys/dd6053f0-a1b3-428d-8104-317527d73630-schedule_meeting_encrypted_email_0';
+        expectedResult.response.content.value.results.data.attendees[1].email = 
+          'decrypted-with-kms://kms-cisco.wbx2.com/keys/dd6053f0-a1b3-428d-8104-317527d73630-schedule_meeting_encrypted_email_1';
+        expectedResult.response.content.value.results.data.title = 
+          'decrypted-with-kms://kms-cisco.wbx2.com/keys/dd6053f0-a1b3-428d-8104-317527d73630-schedule_meeting_encrypted_title';
+        expectedResult.response.content.value.results.data.description = 
+          'decrypted-with-kms://kms-cisco.wbx2.com/keys/dd6053f0-a1b3-428d-8104-317527d73630-schedule_meeting_encrypted_description';
+        expectedResult.response.content.value.results.data.inScopeReply = 
+          'decrypted-with-kms://kms-cisco.wbx2.com/keys/dd6053f0-a1b3-428d-8104-317527d73630-schedule_meeting_encrypted_inScopeReply';
+        expectedResult.response.content.value.results.data.meetingLink = 
+          'decrypted-with-kms://kms-cisco.wbx2.com/keys/dd6053f0-a1b3-428d-8104-317527d73630-schedule_meeting_encrypted_meetingLink';
+
+        expect(triggerSpy.getCall(0).args[1]).to.deep.equal(expectedResult);
+      });
+
       it('decrypts and emits data when receiving event data', async () => {
         const triggerSpy = sinon.spy(webex.internal.aiAssistant, 'trigger');
 
@@ -980,6 +1023,37 @@ describe('plugin-ai-assistant', () => {
         expect(requestArgs.body.assistant).to.be.undefined;
       });
 
+      it('includes entryPoint in request when provided', async () => {
+        const options = {
+          sessionId: 'test-session-id',
+          encryptionKeyUrl: 'test-key-url',
+          contextResources: [],
+          contentType: 'action' as const,
+          contentValue: 'test_action',
+          entryPoint: 'custom-entry-point',
+        };
+
+        await webex.internal.aiAssistant.makeAiAssistantRequest(options);
+
+        const requestArgs = webex.request.getCall(0).args[0];
+        expect(requestArgs.body.entryPoint).to.equal('custom-entry-point');
+      });
+
+      it('does not include entryPoint in request when not provided', async () => {
+        const options = {
+          sessionId: 'test-session-id',
+          encryptionKeyUrl: 'test-key-url',
+          contextResources: [],
+          contentType: 'action' as const,
+          contentValue: 'test_action',
+        };
+
+        await webex.internal.aiAssistant.makeAiAssistantRequest(options);
+
+        const requestArgs = webex.request.getCall(0).args[0];
+        expect(requestArgs.body.entryPoint).to.be.undefined;
+      });
+
       it('handles request rejection', async () => {
         webex.request.rejects(new Error('Network error'));
 

Original file line number	Diff line number	Diff line change
`@@ -43,4 +43,5 @@ export enum RESPONSE_NAMES {`
`43`	`43`	`MESSAGE = 'message',`
`44`	`44`	`TOOL_RESULT = 'tool_result',`
`45`	`45`	`WORKSPACE = 'workspace',`
	`46`	`+ SCHEDULE_MEETING = 'schedule_meeting',`
`46`	`47`	`}`
Original file line number	Diff line number	Diff line change
`@@ -51,4 +51,5 @@ export interface AiAssistantRequestOptions {`
`51`	`51`	`assistant?: string;`
`52`	`52`	`locale?: string;`
`53`	`53`	`requestId?: string;`
	`54`	`+ entryPoint?: string;`
`54`	`55`	`}`