Node.jsとMessaging APIでプッシュメッセージを送ろう

Posted at 2024-03-30

はじめに

前回に引き続き、MessagingAPIの練習です。
今回はボット側から任意のタイミングでメッセージを送ることができるプッシュメッセージに挑戦します。

Node.jsとMessaging API、そしてボットのサーバーとしてRenderを使用します。
構築手順については前回の記事を参考にしてください。

また、本記事は以下のソースコードをベースにし、以降で紹介する処理を追加していくことで実装を進めます。

ソースコードを確認する

app.js

// モジュールのインポート
const https = require("https");
const express = require("express");
const fs = require("fs");

// 環境変数の取得
// ポート番号
const PORT = process.env.PORT || 3000;
// Messaging APIを呼び出すためのトークン
const TOKEN = process.env.LINE_ACCESS_TOKEN;

// Expressアプリケーションオブジェクトの生成
const app = express();

// ミドルウェアの設定
app.use(express.json());
app.use(express.urlencoded({ extended: true, }));

// ルーティングの設定-ドメインのルート
app.get("/", (_, res) => {
  res.sendStatus(200);
});

//ルーティングの設定-MessaginAPI
app.post("/webhook", (req, res) => {
  res.send("HTTP POST request sent to the webhook URL!");
});

// リスナーの設定
app.listen(PORT, () => {
    console.log(`Example app listening at http://localhost:${PORT}`);
});

ユーザーIDを取得する

プッシュメッセージの送信には、送信対象のユーザーIDが必要です。

ユーザーIDを取得する方法はいくつかありますが、今回はリクエストから取得することにします。
処理は以下のようになります。

//ルーティングの設定-MessaginAPI
app.post("/webhook", (req, res) => {
    res.send("HTTP POST request sent to the webhook URL!");
    switch (req.body.events[0].type) {
        case "follow":
            const userData = { userId: req.body.events[0].source.userId }
            fs.writeFileSync('./user_data.json', JSON.stringify(userData));
    }
});

友達追加の判定

/webhookの処理にswitch文を追加しました。
ユーザーがボットアカウントを友だち追加したタイミングでユーザーIDを取得するようにしています。
友だち追加の判定はリクエストのeventsのtypeプロパティで行います。友達追加の場合はfollowが設定されています。

ユーザーIDの取得

ユーザーIDはeventsのsourceプロパティにuserIdとして設定されています。
取得したユーザーIDはJSON形式のデータとしてファイルに保存しています。

本来はDBに保管するのでしょうが、簡易化のためファイルで管理します。

作成したファイルはRenderがデプロイされるたびに削除されるようです。
そのため、ファイルを使うためにはデプロイのたびに友達追加をする必要があります。

プッシュメッセージ送信処理を作成する

前回の自動応答メッセージとは異なり、任意のタイミングでメッセージを送るので、送信のトリガーが必要です。
/pushというURLにアクセスがあった場合にメッセージを送るようにします。

リクエストを受け取る

app.get("/push", (req, res) => {
    res.send("HTTP POST request sent to the push URL!");
    const messages = [{ type: "text", text: "push message!", }];
    pushMessage(messages);
});

/pushにアクセスがあった場合の処理を記述します。
URLを直接叩くので、getメソッドを呼び、その中に処理を書いていきます。
送信したい任意のメッセージを用意し、送信用のメソッドを呼んでいます。
pushMessageは後で用意するメソッドです。

プッシュメッセージ送信処理を書く

実際にプッシュメッセージを送信する処理は以下のとおりです。

function pushMessage(messages) {
    const HEADERS = {
        "Content-Type": "application/json",
        Authorization: "Bearer " + TOKEN,
    };

    const userData = JSON.parse(fs.readFileSync('./user_data.json', 'utf-8'));
    const userId = userData.userId;
    const dataString = JSON.stringify({
        to: userId,
        messages: messages,
    });

    const webhookOptions = {
        hostname: "api.line.me",
        path: "/v2/bot/message/push",
        method: "POST",
        headers: HEADERS,
        body: dataString,
    }
    const request = https.request(webhookOptions, res => {
        res.on("data", d => {
            process.stdout.write(d);
        });
    });
    request.on("error", err => {
        console.error(err);
    });

    request.write(dataString);
    request.end();
}

大まかに、
・リクエストヘッダーの設定
・リクエストボディの設定
・リクエスト送信に必要な情報の設定
・リクエストの送信からエラー設定まで
で成り立っており、基本的には前回のルーティングの設定-MessaginAPIと同じです。

リクエストボディの設定、リクエスト送信に必要な情報の設定が異なるのでそれぞれ確認します

リクエストボディの設定

リクエストボディに必要な情報は2つです。

to

ユーザーIDを設定します。

messages

送信したいメッセージを配列で設定します。

リクエスト送信に必要な情報

応答メッセージで設定したときとはpathのみが異なります。
あとは同じです。

path

"/v2/bot/message/push"を設定します。

ここまでできれば、送信処理は一通り完成しました。

完成したソースコードは以下のようになっているはずです。

完成形のコードを確認する

app.js

// モジュールのインポート
const https = require("https");
const express = require("express");
const fs = require("fs");

// 環境変数の取得
// ポート番号
const PORT = process.env.PORT || 3000;
// Messaging APIを呼び出すためのトークン
const TOKEN = process.env.LINE_ACCESS_TOKEN;

// Expressアプリケーションオブジェクトの生成
const app = express();

// ミドルウェアの設定
app.use(express.json());
app.use(express.urlencoded({ extended: true, }));

// ルーティングの設定-ドメインのルート
app.get("/", (_, res) => {
    res.sendStatus(200);
});

//ルーティングの設定-MessaginAPI
app.post("/webhook", (req, res) => {
    res.send("HTTP POST request sent to the webhook URL!");
    switch (req.body.events[0].type) {
        case "follow":
            const userData = { userId: req.body.events[0].source.userId }
            fs.writeFileSync('./user_data.json', JSON.stringify(userData));
    }
});

// リスナーの設定
app.listen(PORT, () => {
    console.log(`Example app listening at http://localhost:${PORT}`);
});

app.get("/push", (req, res) => {
    res.send("HTTP POST request sent to the push URL!");
    const messages = [{ type: "text", text: "push message!", }];
    pushMessage(messages);
});

function pushMessage(messages) {
    const HEADERS = {
        "Content-Type": "application/json",
        Authorization: "Bearer " + TOKEN,
    };

    const userData = JSON.parse(fs.readFileSync('./user_data.json', 'utf-8'));
    const userId = userData.userId;
    const dataString = JSON.stringify({
        to: userId,
        messages: messages,
    });

    const webhookOptions = {
        hostname: "api.line.me",
        path: "/v2/bot/message/push",
        method: "POST",
        headers: HEADERS,
        body: dataString,
    }
    const request = https.request(webhookOptions, res => {
        res.on("data", d => {
            process.stdout.write(d);
        });
    });
    request.on("error", err => {
        console.error(err);
    });

    request.write(dataString);
    request.end();
}