无法拦截Azure Bot框架中的Bot响应

Question

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

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

要访问bot的响应，您可以更新bot.js文件(即定义了活动处理程序的文件)如下所示。

简而言之，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
  }
]

Logging ：显示从bot或用户传递的最后一项。

[
  {
    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'
  }
]

Answer 2

谢谢你拉杰什·梅诺思。张贴你的建议，作为一个答案，以帮助其他社区成员。

为了更新现有消息，我们可以将带有现有活动ID的NewActivityObject传递给TurnContext对象的UpdateActivity方法。

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

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

若要更新按钮选择上的现有卡，可以使用传入活动的ReplyToId。

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

有关更多信息，请查看更新消息。