无法拦截 Azure Bot Framework 中的机器人响应

Question

我想拦截用户和机器人之间交换的所有消息。我曾经拦截过的PFB代码。我正在使用 Bot Dialog 框架进行网络聊天。这里的问题是我无法从包含从机器人发送给用户的消息的活动对象中提取值。

adapter.use(async (turnContext, next) => {
// pre-processing of the current incoming activity
console.log("adapture use::turnContext::" + turnContext.activity.text);


// hook up a handler to process any outgoing activities sent during this turn
turnContext.onSendActivities(async (sendContext, activities, nextSend) => {
    // pre-processing of outgoing activities
    await nextSend();
    console.log("adapture use::activities::POST##::" + flat.stringify(activities));
    // post-processing outgoing activities
});

await next();

// post-processing of the current incoming activity 
console.log(`Processing activity ${turnContext.activity.id} finishing. `);

});

Answer 1

谢谢Rajeesh Menoth。将您的建议作为答案发布，以帮助其他社区成员。

为了更新现有消息，我们可以将 NewActivityObject 和现有 activity ID 传递给 TurnContext 对象

的 UpdateActivity 方法

下面是传递新对象 ID 的示例

const newActivity = MessageFactory.text('The new text for the activity');
newActivity.id = activityId;
await turnContext.updateActivity(newActivity);

要在按钮选择上更新现有卡片，您可以使用传入 activity 的 ReplyToId。

const message = MessageFactory.attachment(card);
message.id = context.activity.replyToId;
await context.updateActivity(message);

更多信息请查看Update Messages。

Answer 2

要访问机器人的响应，您可以将 bot.js 文件（即定义了 activity 处理程序的文件）更新为如下所示。

简而言之，onSendActivities() 方法保存已传入活动的数组。您可以循环遍历将它们推入数组的活动，然后对特定活动进行操作。或者，在每个到达时做出反应。下面是每个输出的示例。

const { ActivityHandler, MessageFactory } = require('botbuilder');

class EchoBot extends ActivityHandler {
    constructor() {
        super();

        [...]

        const transcript = [];
        this.onTurn(async (context, next1) => {
            let responses = {};

            logActivity(transcript, cloneActivity(context.activity));

            context.onSendActivities(async (ctx, activities, next2) => {
                responses = await next2();
                activities.forEach((a) => logActivity(transcript, cloneActivity(a)));
                console.log('TRANSCRIPT ', activities);
                return responses;
            });

            await next1();
        });
    }
}

const logActivity = (transcript, activity) => {
    if (!activity.timestamp) {
        activity.timestamp = new Date();
    }
    transcript.push(activity);
};

const cloneActivity = (activity) => {
    return Object.assign({}, activity);
};

module.exports.EchoBot = EchoBot;

记录 transcript 数组： 显示活动列表。

[
  {
    type: 'conversationUpdate',
    id: '1hEUP37Da8S',
    timestamp: 2021-09-07T23:01:04.910Z,
    serviceUrl: 'https://directline.botframework.com/',
    channelId: 'directline',
    from: { id: 'dl_16310556645490.nc93iu9jr1' },
    conversation: { id: '5JgOxxxxxxxxxxxxv6sw-g' },
    recipient: { id: 'somebot@QaeuoeEamLg', name: 'Some Bot' },
    membersAdded: [ [Object], [Object] ],
    rawTimestamp: '2021-09-07T23:01:04.9109865Z',
    callerId: 'urn:botframework:azure'
  },
  {
    type: 'message',
    text: 'Hello and welcome!',
    inputHint: 'acceptingInput',
    speak: 'Hello and welcome!',
    channelId: 'directline',
    locale: undefined,
    serviceUrl: 'https://directline.botframework.com/',
    conversation: { id: '5JgOxxxxxxxxxxxxv6sw-g' },
    from: { id: 'somebot@QaeuoeEamLg', name: 'Some Bot' },
    recipient: { id: 'dl_16310556645490.nc93iu9jr1' },
    timestamp: 2021-09-07T23:01:06.547Z
  },
  {
    type: 'message',
    id: '5JgOxxxxxxxxxxxxv6sw-g|0000001',
    timestamp: 2021-09-07T23:01:08.704Z,
    localTimestamp: 2021-09-07T23:01:08.527Z,
    localTimezone: 'America/Los_Angeles',
    serviceUrl: 'https://directline.botframework.com/',
    channelId: 'directline',
    from: { id: 'dl_16310556645490.nc93iu9jr1', name: '' },
    conversation: { id: '5JgOxxxxxxxxxxxxv6sw-g' },
    recipient: { id: 'somebot@QaeuoeEamLg', name: 'Some Bot' },
    textFormat: 'plain',
    locale: 'en-US',
    text: 'Hi',
    entities: [ [Object] ],
    channelData: {
      clientActivityID: '1631055668527tzwhm47a4qd',
      clientTimestamp: '2021-09-07T23:01:08.527Z'
    },
    rawTimestamp: '2021-09-07T23:01:08.704318Z',
    rawLocalTimestamp: '2021-09-07T16:01:08.527-07:00',
    callerId: 'urn:botframework:azure'
  },
  {
    type: 'message',
    text: 'Echo: Hi',
    inputHint: 'acceptingInput',
    speak: 'Echo: Hi',
    channelId: 'directline',
    locale: 'en-US',
    serviceUrl: 'https://directline.botframework.com/',
    conversation: { id: '5JgOxxxxxxxxxxxxv6sw-g' },
    from: { id: 'somebot@QaeuoeEamLg', name: 'Some Bot' },
    recipient: { id: 'dl_16310556645490.nc93iu9jr1', name: '' },
    replyToId: '5JgOxxxxxxxxxxxxv6sw-g|0000001',
    timestamp: 2021-09-07T23:01:09.147Z
  }
]

仅记录 activities： 显示机器人或用户传递的最后一个项目。

[
  {
    type: 'message',
    text: 'Echo: Hi',
    inputHint: 'acceptingInput',
    speak: 'Echo: Hi',
    channelId: 'directline',
    locale: 'en-US',
    serviceUrl: 'https://directline.botframework.com/',
    conversation: { id: 'AURKxxxxxxxxxJHpO-f' },
    from: { id: 'somebot@QaeuoeEamLg', name: 'Some Bot' },
    recipient: { id: 'dl_16310605730140.3nrm4evq6um', name: '' },
    replyToId: 'AURKxxxxxxxxxJHpO-f|0000001'
  }
]

无法拦截 Azure Bot Framework 中的机器人响应

Unable to Intercept Bot Response in Azure Bot Framework

azure

chatbot

node.js

botframework