สร้างการแจ้งเตือนด้วย Node เข้า LINE ผ่าน LINE Notify

const axios = require('axios');
const qs = require('qs');

const url_line_token = "https://notify-bot.line.me/oauth/token";

//Get Token
exports.token =  async (code,username) => {
    axios.post(
        url_line_token,
        qs.stringify({
            grant_type : 'authorization_code',
            code : code,
            redirect_uri : 'http://localhost:4000/line/redirect',
            client_id : 'client id',
            client_secret : 'client secret'
        }),
        {
            headers : {
                'Content-Type': 'application/x-www-form-urlencoded',
            }
        }
    ).then( (response) => {
        console.log('Get Token : 'response.data.access_token);

        //Logic process save or update access token

        return response.data;
    })
    .catch(function (error) {
        console.error('Error : ',error.response.data.message);
        return error;
    });
}

const line = require("../services/line")
const path = require("path")

exports.redirect = async (req, res) => {
  try {
    await line.token(req.query.code, req.query.state)
    res.sendFile(path.join(__dirname, "../../views", "line-connected.html"))
  } catch (error) {
    return res.json(error)
  }
}

const controller = require("../controllers/line.controller")

module.exports = function (app) {
  app.get("/line/redirect", controller.redirect)
}

<template>
    <a target="_blank" :href="urlAuth">เชื่อมต่อ LINE</a>
</template>

<script>
      export default {
        computed : {
            urlAuth(){
                    const clientId = //client id ใน line notify service
                    const engine = // url backend สำหรับ redirect
                    const username = // ผมใช้เป็น username เพื่อในไปใช้หา user ต่อที่ backend
                    return `https://notify-bot.line.me/oauth/authorize?response_type=code&client_id=${clientId}&redirect_uri=${engine}/line/redirect&scope=notify&state=${username}`
                }
            }
      }
</script>

Get Token :  {
  status: 200,
  message: 'access_token is issued',
  access_token: 'DmaTHALb0Sydbfsm4aI6Ll0I2YICaBxd8xxxxxxxxxx'
}

...

const url_line_notification = "https://notify-api.line.me/api/notify";

//Notification to Line
exports.notify = async (text,token) => {
    await axios.post(
        url_line_notification,
        qs.stringify({message:text}),
        {
            headers: {
                'Content-Type': 'application/x-www-form-urlencoded',
                'Authorization' : 'Bearer ' + token
            }
        },
        ).then(function (response) {
            console.log('Notify Successfully : ',response.data);
            //Logic process save notification logs
            return response.data;
        })
        .catch(function (error) {
            console.error('Notification Error : ',error);
        });
}

...

exports.notify = async (req, res) => {
  try {
    await line.notify(req.body.message,req.body.lineToken)
    return res.status(200).send({ message: "Notify Successfully." });
  } catch (error) {
    return res.json({ error: error.response.data.message });
  }
};

...

module.exports = function(app) {
    ...
    app.post("/line/notify",controller.notify);
};