Создание чата на Facebook с Node и Heroku

Вам нужно знать об этом, только если ваш бот обслуживает разные страницы (да, бот может обслуживать несколько страниц ). Таким образом, если ваш бот обслуживает несколько страниц, возможно, будет неправильно идентифицировать пользователей только по их идентификаторам, а также будет неправильно использовать идентификатор пользователя для поля _id записи, поскольку это должно быть уникальным, и вы не будете в состоянии гарантировать эту уникальность на всех страницах.

Собираем все вместе

Теперь, когда база данных и модель настроены, мы можем завершить чат-бота. Код будет представлен по частям, но если вы хотите вставить весь код в свой проект, вот ссылка на файл app.js

Начните с настройки соединения с базой данных. Mongoose уже должен был быть установлен ранее с другими модулями.

 var mongoose = require("mongoose"); var db = mongoose.connect(process.env.MONGODB_URI); var Movie = require("./models/movie"); 

Измените обработчик POST webhook, как показано на рисунке.

 // All callbacks for Messenger will be POST-ed here app.post("/webhook", function (req, res) { // Make sure this is a page subscription if (req.body.object == "page") { // Iterate over each entry // There may be multiple entries if batched req.body.entry.forEach(function(entry) { // Iterate over each messaging event entry.messaging.forEach(function(event) { if (event.postback) { processPostback(event); } else if (event.message) { processMessage(event); } }); }); res.sendStatus(200); } }); 

Мы добавили проверку событий типа message , передав их в функцию processMessage() .

 function processMessage(event) { if (!event.message.is_echo) { var message = event.message; var senderId = event.sender.id; console.log("Received message from senderId: " + senderId); console.log("Message is: " + JSON.stringify(message)); // You may get a text or attachment but not both if (message.text) { var formattedMsg = message.text.toLowerCase().trim(); // If we receive a text message, check to see if it matches any special // keywords and send back the corresponding movie detail. // Otherwise, search for new movie. switch (formattedMsg) { case "plot": case "date": case "runtime": case "director": case "cast": case "rating": getMovieDetail(senderId, formattedMsg); break; default: findMovie(senderId, formattedMsg); } } else if (message.attachments) { sendMessage(senderId, {text: "Sorry, I don't understand your request."}); } } } 

Здесь мы сначала проверяем, было ли сообщение отправлено с помощью функции обратного вызова. Этот обратный вызов произойдет, когда ваша страница отправит сообщение. Например, первое сообщение, которое мы отправили пользователю (приветствие), будет отправлено обратно в наш Webhook. Мы не хотим обрабатывать какие-либо наши собственные сообщения, поэтому мы ставим проверку для этого.

Затем мы проверяем, является ли сообщение текстом или вложением (изображение, видео, аудио). В случае последнего мы отправляем сообщение об ошибке пользователю. Для текстовых сообщений мы проверяем, соответствует ли ввод определенным ключевым словам, которые укажут, какие детали фильма хочет пользователь. На данный момент пользователь уже сделал запрос фильма, и фильм будет сохранен в базе данных. Функция getMovieDetail() запрашивает базу данных и возвращает конкретную запись.

 function getMovieDetail(userId, field) { Movie.findOne({user_id: userId}, function(err, movie) { if(err) { sendMessage(userId, {text: "Something went wrong. Try again"}); } else { sendMessage(userId, {text: movie[field]}); } }); } 

Если пользовательский запрос не соответствует ни одному из заданных ключевых слов, бот предполагает, что входные данные предназначены для запроса фильма, поэтому он передается функции findMovie() которая вызывает API-интерфейс Open Movie Database с входными findMovie() .

 function findMovie(userId, movieTitle) { request("http://www.omdbapi.com/?type=movie&t=" + movieTitle, function (error, response, body) { if (!error && response.statusCode === 200) { var movieObj = JSON.parse(body); if (movieObj.Response === "True") { var query = {user_id: userId}; var update = { user_id: userId, title: movieObj.Title, plot: movieObj.Plot, date: movieObj.Released, runtime: movieObj.Runtime, director: movieObj.Director, cast: movieObj.Actors, rating: movieObj.imdbRating, poster_url:movieObj.Poster }; var options = {upsert: true}; Movie.findOneAndUpdate(query, update, options, function(err, mov) { if (err) { console.log("Database error: " + err); } else { message = { attachment: { type: "template", payload: { template_type: "generic", elements: [{ title: movieObj.Title, subtitle: "Is this the movie you are looking for?", image_url: movieObj.Poster === "N/A" ? "http://placehold.it/350x150" : movieObj.Poster, buttons: [{ type: "postback", title: "Yes", payload: "Correct" }, { type: "postback", title: "No", payload: "Incorrect" }] }] } } }; sendMessage(userId, message); } }); } else { console.log(movieObj.Error); sendMessage(userId, {text: movieObj.Error}); } } else { sendMessage(userId, {text: "Something went wrong. Try again."}); } }); } 

Если фильм найден, его данные сохраняются вместе с идентификатором пользователя. Если запись с таким идентификатором пользователя была создана ранее, она будет обновлена. Затем мы создаем структурированное сообщение и отправляем его пользователю.

Помимо текста, Messenger Platform позволяет отправлять обратно изображения, видео, аудио, файлы и структурированные сообщения. Структурированные сообщения — это шаблоны, которые поддерживают различные варианты использования. Шаблон кнопки позволяет отправлять текст и кнопки. Общий шаблон позволяет определять изображение, заголовок, подзаголовок и кнопки. В нашем приложении мы используем общий шаблон.

Измените processPostback() как показано.

 function processPostback(event) { var senderId = event.sender.id; var payload = event.postback.payload; if (payload === "Greeting") { // Get user's first name from the User Profile API // and include it in the greeting request({ url: "https://graph.facebook.com/v2.6/" + senderId, qs: { access_token: process.env.PAGE_ACCESS_TOKEN, fields: "first_name" }, method: "GET" }, function(error, response, body) { var greeting = ""; if (error) { console.log("Error getting user's name: " + error); } else { var bodyObj = JSON.parse(body); name = bodyObj.first_name; greeting = "Hi " + name + ". "; } var message = greeting + "My name is SP Movie Bot. I can tell you various details regarding movies. What movie would you like to know about?"; sendMessage(senderId, {text: message}); }); } else if (payload === "Correct") { sendMessage(senderId, {text: "Awesome! What would you like to find out? Enter 'plot', 'date', 'runtime', 'director', 'cast' or 'rating' for the various details."}); } else if (payload === "Incorrect") { sendMessage(senderId, {text: "Oops! Sorry about that. Try using the exact title of the movie"}); } } 

Здесь мы добавляем две проверки для Correct и Incorrect сообщений полезной нагрузки. Они будут прикреплены к кнопкам, которые пользователь будет использовать, чтобы сообщить боту, представил ли он правильный фильм.

Зафиксируйте свой код и отправьте его в Heroku, затем попробуйте отправить сообщения боту.