Вызов OpenSearch в ответе намерения Webhook Dialogflow не возвращает данные

Question

Я работаю над приложением для извлечения данных из каталога библиотеки из чата Dialogflow. Я не получаю никаких ошибок, и у меня есть платежный аккаунт, прикрепленный к сервису. Код намерения здесь:

const {WebhookClient} = require('dialogflow-fulfillment');
const function = require('firebase-functions');
const agent = new WebhookClient({ request: request, response: response });
const catalogSearch = require("rss-to-json");  

exports.libraryChat = functions.https.onRequest(request, response) => {  

    function catalog_search(agent) {
        var itemSubject = agent.parameters["item-subject"] ? "+" + agent.parameters["item-subject"] : "";
        var itemTitle = agent.parameters["item-title"] ? "+" + agent.parameters["item-title"] : "";
        var chatResponse = "";
        var itemList = new Array();
        if (agent.parameters["author-name"]) {
            var authorName = agent.parameters["author-name"]["name"] ? "+" + agent.parameters["author-name"]["name"] + " " + agent.parameters["author-name"]["last-name"] : "+" + agent.parameters["author-name"]["last-name"];
        }
        var searchString = "";
        if (itemSubject.length > 0) { searchString = searchString  + itemSubject; }
        if (itemTitle.length > 0 ) { searchString = searchString + itemTitle; }
        if (authorName.length > 0) { searchString = searchString + authorName; }
        var url = "https://gapines.org/opac/extras/opensearch/1.1/-/rss2-full?searchTerms=site(GCHR-CCO)" + searchString + "&searchClass=keyword";
        console.log(url);
        catalogSearch.load(url, (err, jsonResponse) => {
            if (!err) {
                itemList = jsonResponse.items;
                chatResponse = "The first ten items returned for your search are: ";
            }
            else {
                chatResponse = "I'm sorry! I've encountered an error while retrieving that data!";
            }
        });
        itemList.forEach( (title, index) => {
            chatResponse = chatResponse + (index + 1).toString() + title.title;
        });
        agent.add(chatResponse);
    }

    let intentMap = new Map();
    intentMap.set("Catalog Search", catalog_search);
}

Ответ JSON от намерения:

{
  "responseId": "958f0d66-13ba-4bf5-bed8-83480da4c37e",
  "queryResult": {
    "queryText": "Do you have any books about goats?",
    "parameters": {
      "item-subject": "goats",
      "item-title": "",
      "author-name": ""
    },
    "allRequiredParamsPresent": true,
    "fulfillmentMessages": [
      {
        "text": {
          "text": [
            ""
          ]
        }
      }
    ],
    "intent": {
      "name": "projects/library-chatbot/agent/intents/a5f8ad9b-ff73-49f7-a8c0-351da3bf4802",
      "displayName": "Catalog Search"
    },
    "intentDetectionConfidence": 1,
    "diagnosticInfo": {
      "webhook_latency_ms": 3591
    },
    "languageCode": "en"
  },
  "webhookStatus": {
    "message": "Webhook execution successful"
  }
}

Через отдельную функцию я убедился, что вызов Opensearch работает и выдает список заголовков, однако при доступе через намерение Dialogflow ничего не возвращается. Я думал, что это может быть связано с ограничениями бесплатного аккаунта, но ошибка продолжает добавляться после добавления платежной информации и обновления.

Или, скорее, отсутствие ошибки без ответа. Здесь что-то мне не хватает?

Answer 1

Проблема: агент DialogFlow возвращал ответ до обработки результатов Opensearch.

Решение: во-первых, маршрутизируйте намерения чата без использования встроенного .handleRequest метод для намерения, который делает вызов Opensearch, возвращая обещание.

function chooseHandler(agent) {
    var intentRoute = "";
    switch (agent.intent) {
        case "Default Welcome Intent": 
            intentRoute = "welcome";
            break;
        case "Default Fallback Intent": 
            intentRoute = "fallback";
            break;
        case "Catalog Search":
            intentRoute = "catalog";
            break;
    }
    return new Promise ((resolve, reject) => {
        if (intentRoute.length > 0) {
            resolve(intentRoute);
        }
        else {
            reject(Error("Route Not Found"));
        }
    });
}

function assignResponse(intentRoute, agent) {
    switch (intentRoute) {
        case "welcome":
            agent.handleRequest(welcome);
            break;
        case "fallback":
            agent.handleRequest(fallback);
            break;
        case "catalog":
            catalog_response();
            break;
        default:
            Error("Intent not found");
    }

} 

Затем извлеките данные из API OpenSearch, вернув обещание.

function catalog_search(agent) {
    var itemSubject = agent.parameters["item-subject"] ? "+" + agent.parameters["item-subject"] : "";
    var itemTitle = agent.parameters["item-title"] ? "+" + agent.parameters["item-title"] : "";
    var itemType = agent.parameters["item-type"] ? "+" + agent.parameters["item-type"] : "";
    var authorName = "";
    if (agent.parameters["author-name"]) {
       authorName = agent.parameters["author-name"]["name"] ? "+" + agent.parameters["author-name"]["name"] + " " + agent.parameters["author-name"]["last-name"] : "+" + agent.parameters["author-name"]["last-name"];
    }
    var searchString = "";
    if (itemSubject.length > 0) { searchString += itemSubject; }
    if (itemTitle.length > 0 ) { searchString += itemTitle; }
    if (authorName.length > 0) { searchString += authorName; }
    if (itemType.length > 0) { searchString += itemType; }
    var url = "https://gapines.org/opac/extras/opensearch/1.1/-/rss2-full?searchTerms=site(GCHR-CCO)" + encodeURIComponent(searchString) + "&searchClass=keyword";
    console.log(url);
    console.log(encodeURIComponent(searchString));

    var itemList = [];
    var chatResponse = "this was untouched";

    return new Promise((resolve, reject) => {
        catalogSearch.load(url, (err, rss) => {
            if (err) {
                reject(Error("url failed!"));
            }
            else {
                itemList = rss;
                if (itemList.items.length > 0) {
                    if (itemList.items.length === 1) {
                        chatResponse = "The only item found for that search is ";
                    }
                    else if (itemList.items.length < 10) {
                        chatResponse = "The first few items in your search are ";
                    }
                    else {
                        chatResponse = "The first ten items in your search are ";
                    }
                    itemList.items.forEach( (item, index) => {
                       chatResponse = chatResponse + item.title.replace(/\//g, "").trim();
                       if (index + 1 < itemList.items.length) {
                           chatResponse += ", ";
                       } else {
                           chatResponse += ".";
                       }
                    });
                }
                else {
                    chatResponse = "We're sorry, there are no items matching that search at our library!";
                }
                console.log(rss);
                resolve(chatResponse);
            }
        });
    });
}

Создайте правильно отформатированный JSON-ответ на намерение и отправьте его обратно.

function catalog_response() {
    catalog_search(agent).then((response) => {
        res.json({ "fulfillmentText": response });
        res.status(200).send();
        return 1;
    }), (error) => {
        console.log("failed", error);
    };
}

Answer 2

Ваша третья строка:

const agent = new WebhookClient({ request: request, response: response });

Пытается создать экземпляр нового агента, но запрос и ответ не определены в этой области. Попробуйте переместить эту строку в теле функции libraryChat.