LINEミニアプリからサービスメッセージを送信する方法

import liff from "@line/liff";

const sendServiceMessage = async (params: Record<string, string>) => {
  // LIFFアクセストークンを取得
+ const liffAccessToken = liff.getAccessToken();

  if (!liffAccessToken) {
    throw new Error("LIFFアクセストークンが取得できませんでした");
  }

  const response = await fetch("https://your-api-endpoint.com/send-message", {
    method: "POST",
    headers: {
      "Content-Type": "application/json",
+     "X-LIFF-Access-Token": liffAccessToken,
    },
    body: JSON.stringify({ params }),
  });

  if (!response.ok) {
    throw new Error("サービスメッセージの送信に失敗しました");
  }

  return response.json();
};

// 使用例
const SendMessageButton = () => {
  const handleClick = async () => {
    try {
      await sendServiceMessage({
        "1": "変数1の値",
        "2": "変数2の値",
      });
      alert("メッセージを送信しました");
    } catch (error) {
      console.error(error);
      alert("送信に失敗しました");
    }
  };

  return <button onClick={handleClick}>サービスメッセージを送信</button>;
};

import { ServiceNotificationTokenRepository } from "./service-notification-token-repository";

const CHANNEL_ID = process.env.LINE_CHANNEL_ID!;
const CHANNEL_SECRET = process.env.LINE_CHANNEL_SECRET!;
+const TEMPLATE_NAME = "restock_d_ja"; // LINE Developersコンソールで設定したテンプレート名

const tokenRepository = new ServiceNotificationTokenRepository();

/**
 * サービスメッセージ送信Lambda関数
 */
export const handler = async (event: APIGatewayProxyEvent): Promise<APIGatewayProxyResult> => {
  try {
    // リクエストからLIFFアクセストークンとパラメータを取得
+   const liffAccessToken = event.headers["x-liff-access-token"];
    if (!liffAccessToken) {
      return {
        statusCode: 401,
        body: JSON.stringify({ error: "LIFF access token is required" }),
      };
    }

    const body = JSON.parse(event.body || "{}");
+   const { userId, params } = body;

    // 1. チャネルアクセストークンを発行
+   const channelAccessToken = await getChannelAccessToken();

    // 2. サービス通知トークンを発行
+   const tokenResponse = await issueServiceNotificationToken(
+     channelAccessToken,
+     liffAccessToken
+   );
    console.log("サービス通知トークン発行完了", {
      remainingCount: tokenResponse.remainingCount,
    });

    // 3. サービスメッセージを送信
+   const sendResponse = await sendServiceMessage(
+     channelAccessToken,
+     tokenResponse.notificationToken,
+     TEMPLATE_NAME,
+     params
+   );
    console.log("サービスメッセージ送信完了", {
      remainingCount: sendResponse.remainingCount,
    });

    // 4. サービス通知トークンをDBに保存（次回以降の再利用のため）
+   await tokenRepository.save({
+     userId,
+     notificationToken: sendResponse.notificationToken,
+     remainingCount: sendResponse.remainingCount,
+   });

    return {
      statusCode: 200,
      body: JSON.stringify({
        success: true,
        remainingCount: sendResponse.remainingCount,
      }),
    };
  } catch (error) {
    console.error("サービスメッセージ送信エラー:", error);
    return {
      statusCode: 500,
      body: JSON.stringify({ error: "Internal server error" }),
    };
  }
};

/**
 * 1: チャネルアクセストークンを発行する
 * @see https://developers.line.biz/ja/reference/messaging-api/#issue-stateless-channel-access-token
 */
const getChannelAccessToken = async (): Promise<string> => {
  const response = await fetch("https://api.line.me/oauth2/v3/token", {
    method: "POST",
    headers: {
      "Content-Type": "application/x-www-form-urlencoded",
    },
    body: `grant_type=client_credentials&client_id=${CHANNEL_ID}&client_secret=${CHANNEL_SECRET}`,
  });

  if (!response.ok) {
    const errorText = await response.text();
    throw new Error(`チャネルアクセストークンの発行に失敗: ${response.status} ${errorText}`);
  }

  const data = await response.json();
  return data.access_token;
};

/**
 * 2: サービス通知トークンを発行する
 * @see https://developers.line.biz/ja/reference/line-mini-app/#issue-notification-token
 */
const issueServiceNotificationToken = async (
  channelAccessToken: string,
  liffAccessToken: string
): Promise<{
  notificationToken: string;
  expiresIn: number;
  remainingCount: number;
  sessionId: string;
}> => {
  const response = await fetch("https://api.line.me/message/v3/notifier/token", {
    method: "POST",
    headers: {
      "Content-Type": "application/json",
      Authorization: `Bearer ${channelAccessToken}`,
    },
    body: JSON.stringify({ liffAccessToken }),
  });

  if (!response.ok) {
    const errorText = await response.text();
    throw new Error(`サービス通知トークンの発行に失敗: ${response.status} ${errorText}`);
  }

  return await response.json();
};

/**
 * 3: サービスメッセージを送信する
 * @see https://developers.line.biz/ja/reference/line-mini-app/#send-service-message
 */
const sendServiceMessage = async (
  channelAccessToken: string,
  notificationToken: string,
  templateName: string,
  params: Record<string, string>
): Promise<{
  notificationToken: string;
  remainingCount: number;
  sessionId: string;
}> => {
  const response = await fetch(
    "https://api.line.me/message/v3/notifier/send?target=service",
    {
      method: "POST",
      headers: {
        "Content-Type": "application/json",
        Authorization: `Bearer ${channelAccessToken}`,
      },
      body: JSON.stringify({
        notificationToken,
        templateName,
        params,
      }),
    }
  );

  if (!response.ok) {
    const errorText = await response.text();
    throw new Error(`サービスメッセージの送信に失敗: ${response.status} ${errorText}`);
  }

  return await response.json();
};

POST https://api.line.me/oauth2/v3/token

POST https://api.line.me/message/v3/notifier/token

POST https://api.line.me/message/v3/notifier/send?target=service