ใน Codelab นี้คุณจะได้เรียนรู้การสร้าง LINE Chatbot เพื่อตรวจสอบการดู Content ประเภท Video ใน LINE OA จนจบ ผ่าน Webhook event "videoPlayComplete"
จุดเริ่มต้นของการพัฒนา LINE Chatbot คือคุณจะต้องสร้าง LINE OA(LINE Official Account) และเปิดใช้งาน Messaging API
หลังจากที่เรามี LINE OA เรียบร้อยแล้ว ขั้นตอนนี้จะพาทุกคนไปเพิ่มความสามารถให้ LINE OA ของเรากลายเป็น LINE Chatbot ได้
ขั้นตอนนี้เราจะเข้าไปใช้งาน LINE Developers Console ซึ่งเป็นเว็บไซต์สำหรับการบริหารจัดการ LINE Chatbot(LINE OA ที่เปิดใช้งาน Messaging API แล้ว) ในส่วนของนักพัฒนา
เบื้องหลังของ Chatbot ตัวนี้ เราจะใช้บริการใน Firebase อย่าง Cloud Functions for Firebase และ Cloud Firestore ดังนั้นขั้นตอนนี้เราจะมาสร้างโปรเจค Firebase เพื่อใช้งานกัน
เนื่องจาก Cloud Functions for Firebase มีเงื่อนไขว่า หากต้องการไป request ตัว APIs ที่อยู่ภายนอก Google คุณจำเป็นจะต้องใช้ Blaze plan(เราจะต้องไปเรียก Messaging API ของ LINE)
Firebase CLI เป็นเครื่องมือที่จำเป็นสำหรับการ deploy ตัวฟังก์ชันที่เราพัฒนาขึ้น อีกทั้งยังสามารถจำลองการทำงานฟังก์ชัน(Emulate) ภายในเครื่องที่เราพัฒนาอยู่(Locally) ได้
npm install -g firebase-tools
Caution: หากคุณพบปัญหาในการติดตั้ง Firebase CLI แบบ globally คุณจำเป็นตัองตั้งค่า npm permission ซะก่อน
firebase --version
firebase login
mkdir bot
cd bot
firebase init functions
ขั้นตอนนี้เราจะสร้าง Webhook ขึ้นมาเพื่อให้ LINE Chatbot สามารถรับข้อมูลและโต้ตอบกับผู้ใช้งานได้ผ่าน Messaging API
ใน Codelab นี้เราจะใช้ axios มาเป็นตัวช่วยในการสร้าง request ซึ่งเราจะต้องทำการติดตั้ง dependency ตัวนี้ก่อน โดยให้เปิด command line แล้วเข้าไปที่ /functions จากนั้นใช้คำสั่ง
npm install axios –save
ถัดไปเราจะสร้าง Environment Variable โดยให้ไปสร้างไฟล์ .env ใน /functions แล้วให้ไป copy ค่า Channel Access Token ของ Messaging API Channel ที่ issue ไว้ก่อนหน้านี้มาระบุลงไป
CHANNEL_ACCESS_TOKEN=YOUR-CHANNEL-ACCESS-TOKEN
จากนั้นให้เปิดไฟล์ /functions/index.js แล้วให้ copy โค้ดด้านล่างนี้ไปแทนที่โค้ดเดิม เพื่อเตรียมรับ Webhook event ประเภท videoPlayComplete จาก LINE และตอบกลับผู้ใช้งาน
// Import dependencies
const {onRequest} = require("firebase-functions/v2/https");
const admin = require("firebase-admin")
const axios = require("axios");
admin.initializeApp()
// Create a webhook via HTTP requests
exports.webhookVideoComplete = onRequest(async (req, res) => {
if (req.method === "POST") {
const events = req.body.events;
for (const event of events) {
switch (event.type) {
case "videoPlayComplete":
if (event.message.type === "text") {
await savePointVideoComplete(event)
}
break;
}
}
}
res.send(req.method);
});
const savePointVideoComplete = async(event) => {
const replyToken = event.replyToken
let messages = ''
const pointExists = await checkPointExists(event)
if (pointExists) {
messages = [{ 'type': 'text', 'text': '🎉 ขอบคุณที่รับชมวีดีโอ คุณเคยได้รับคะแนนกิจกรรมนี้ไปแล้ว 🎉' }]
} else {
await collectPoint(event)
messages = [{ 'type': 'text', 'text': '🎉 ขอบคุณที่รับชมวีดีโอ รับคะแนนไปเลย 10 คะแนน 🎉' }]
}
await reply(replyToken, messages)
return true
}
const collectPoint = async(event) => {
try {
const userId = event.source.userId
const trackingId = event.videoPlayComplete.trackingId
const timestamp = event.timestamp
const params = {
userId, trackingId, timestamp
}
await admin.firestore().collection('collectPoint').add(params)
return true
} catch (error) {
console.error(error)
return false
}
}
const checkPointExists = async(event) => {
try {
const userId = event.source.userId
const trackingId = event.videoPlayComplete.trackingId
const data = await admin.firestore()
.collection('collectPoint')
.where('userId', '==', userId)
.where('trackingId', '==', trackingId)
.get()
return !data.empty
} catch (error) {
console.error(error)
return false
}
}
// Create a reply function with Messaging API
const reply = (token, payload) => {
return axios({
method: "post",
url: `https://api.line.me/v2/bot/message/reply`,
headers: {
"Content-Type": "application/json",
Authorization: `Bearer ${process.env.CHANNEL_ACCESS_TOKEN}`
},
data: { replyToken: token, messages: payload }
});
};
แล้วก็ให้เปิด command line ขึ้นมาอีกครั้ง และให้แน่ใจว่าเราอยู่ที่ functions/ จากนั้นใช้คำสั่งด้านล่างนี้เพื่อ deploy ตัว webhook ของเราขึ้น production
firebase deploy --only functions
เมื่อ deploy เสร็จเรียบร้อยเราจะเห็น Webhook URL โผล่อยู่ใน command line เลย ก็ให้เรา copy มา หรือกรณีที่ไม่พบก็ให้เข้าไปที่ Firebase console เลือกโปรเจคที่เราสร้างไว้ แล้วเลือกเมนู Build > Functions จะเจอชื่อฟังก์ชันและ Webhook URL ที่นั่น
เมื่อได้ Webhook URL มาแล้ว ก็ให้เอา URL นี้ไปอัพเดทที่ Messaging API Channel ใน LINE Developers console ตามที่ได้สร้างไว้ และให้มั่นใจว่าได้เปิดใช้ Use webhook แล้ว
ขั้นตอนนี้เราจะทดลองส่งข้อความประเภท Video ให้ User แล้วทดสอบเปิดดูวีดีโอให้จบ เพื่อทดสอบ Webhook ที่เราได้สร้างก่อนหน้า โดยเราจะส่งข้อความให้ User ผ่าน Curl
เปิด command line แล้ว Copy คำสั่งด้านล่าง แล้วเปลี่ยนค่าต่างๆ ตามนี้
curl --location 'https://api.line.me/v2/bot/message/push' \
--header 'Authorization: Bearer CHANNEL_ACCESS_TOKEN' \
--header 'Content-Type: application/json' \
--data '{
"to": "LINE_USER_ID",
"messages": [
{
"type": "video",
"originalContentUrl": "LINK_VIDEO",
"previewImageUrl": "LINK_IMAGE_PREVIEW",
"trackingId": "track-id"
}
]
}'
หลังจาก run คำสั่งเสร็จแล้วให้ลองเปิด LINE OA ดูจะได้ผลลัพธ์ประมาณนี้ครับ
ลองทดสอบเปิดดู Video จนจบเพื่อดูผลลัพธ์การทำงานของ Webhook
โดยจะได้รับ event ใน Webhook ลักษณะนี้
{
"destination": "xxxxxxxxxx",
"events": [
{
"replyToken": "nHuyWiB7yP5Zw52FIkcQobQuGDXCTA",
"type": "videoPlayComplete",
"mode": "active",
"timestamp": 1462629479859,
"source": {
"type": "user",
"userId": "U4af4980629..."
},
"webhookEventId": "01FZ74A0TDDPYRVKNK77XKC3ZR",
"deliveryContext": {
"isRedelivery": false
},
"videoPlayComplete": {
"trackingId": "track-id"
}
}
]
}
สังเกตุว่า event.type จะถูกส่งมาเป็น videoPlayComplete เลย โดยจะมีแนบค่า videoPlayComplete.trackingId มาด้วย เราสามารถใช้ค่านี้เพื่อตรวจสอบ Video ได้ด้วยว่า User ดู Video ตัวไหน
ผลลัพธ์หน้า LINE OA ก็จะมีข้อความตอบกลับ เมื่อ User ดู Video จนจบ ประมาณนี้เลยครับ
ยินดีด้วย! ถึงตรงนี้คุณก็มี LINE Chatbot ที่สามารถตรวจสอบสถานะการดู Video ของ User ได้แล้ว!!!