PamornT

import * as functions from "firebase-functions";
import * as dialogflow from "@google-cloud/dialogflow";
import axios from "axios";
const projectId = "<DIALOGFLOW PROJECTID>";

const LINE_HEADER_DEV = {
  "Content-Type": "application/json",
  "Authorization": "Bearer <DEV CHANNEL ACCESS TOKEN>",
};
const LINE_HEADER_PROD = {

PamornT

import * as functions from "firebase-functions";
import * as dialogflow from "@google-cloud/dialogflow";
const projectId = "multiple-env-pafg";
// // Start writing Firebase Functions
// // https://firebase.google.com/docs/functions/typescript
let dialogflowEnv = "";
//
export const webHook = functions.https.onRequest((request, response) => {
  if (request.body.destination === "U19476f0931c6ac37972a6b7f4b4321c6") {
    dialogflowEnv = "draft";

PamornT

import * as functions from "firebase-functions";
// // Start writing Firebase Functions
// // https://firebase.google.com/docs/functions/typescript
let dialogflowEnv = "";
//
export const webHook = functions.https.onRequest((request, response) => {
  if (request.body.destination === "U19476f0931c6ac37972a6b7f4b4321c6") {
    dialogflowEnv = "draft";
  } else if (request.body.destination === "U92a6f010a3fd78085b8763159a04772b") {
    dialogflowEnv = "production";

PamornT

import * as functions from "firebase-functions";
// // Start writing Firebase Functions
// // https://firebase.google.com/docs/functions/typescript
//
export const webHook = functions.https.onRequest((request, response) => {
  console.log(request.body);
  const events = request.body.events;
  events.forEach( async (event: any) => {
    console.log(event);
    if (event.type === "message") {

PamornT

  // Handle events
   events.forEach(async(event) => {
      if (event.type === 'videoPlayComplete') {
         await savePointVideoComplete(event)
      }
      console.log(event)
   })

PamornT

const admin = require("firebase-admin")
const functions = require("firebase-functions")

const region = 'asia-northeast1'
const channelSecret = ''
const channelAccessToken = ''

admin.initializeApp()

PamornT

const reply = async(replyToken, messages) => {
   const axios = require("axios")
   const data = { replyToken, messages }
   const headers = {
      'Authorization': `Bearer ${channelAccessToken}`,
      'Content-Type': 'application/json'
   }
   axios.post('https://api.line.me/v2/bot/message/reply', data, {
      headers: headers
   })

PamornT

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

PamornT

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

PamornT

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 คะแนน 🎉' }]
   }