LINE Messaging APIを利用して特定ユーザーにメッセージを送信する

package com.example.demo.config;

import jakarta.annotation.PostConstruct;

import org.springframework. boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

import lombok.Data;
import lombok.extern.slf4j.Slf4j;

@Slf4j
@Data
@Component
@ConfigurationProperties(prefix = "line")
public class LineProperties {
    
    private Login login = new Login();
    private Messaging messaging = new Messaging();
    private Api api = new Api();
    
    @PostConstruct
    public void init() {
        log.debug("=== LINE設定情報ロード開始 ===");
        log.debug("[LINEログイン] Channel ID: {}", maskChannelId(login.getChannelId()));
        log.debug("[LINEログイン] Channel Secret: {}", maskSecret(login.getChannelSecret()));
        log.debug("[LINEログイン] Callback URL: {}", login.getCallbackUrl());
        log.debug("[Messaging API] Channel ID: {}", maskChannelId(messaging.getChannelId()));
        log.debug("[Messaging API] Channel Secret: {}", maskSecret(messaging. getChannelSecret()));
        log.debug("[Messaging API] Access Token: {}", maskToken(messaging.getChannelAccessToken()));
        log.debug("=== LINE設定情報ロード完了 ===");
    }
    
    private String maskChannelId(String value) {
        if (value == null || value.length() < 4) return "****";
        return value.substring(0, 4) + "****";
    }
    
    private String maskSecret(String value) {
        if (value == null || value.length() < 8) return "****";
        return value.substring(0, 4) + "****" + value.substring(value.length() - 4);
    }
    
    private String maskToken(String value) {
        if (value == null || value.length() < 20) return "****";
        return value.substring(0, 10) + "****";
    }
    
    @Data
    public static class Login {
        private String channelId;
        private String channelSecret;
        private String callbackUrl;
    }
    
    @Data
    public static class Messaging {
        private String channelId;
        private String channelSecret;
        private String channelAccessToken;
    }
    
    @Data
    public static class Api {
        private String authorizeUrl;
        private String tokenUrl;
        private String friendshipUrl;
        private String pushMessageUrl;
    }
}

package com.example.demo.config;

import jakarta.annotation.PostConstruct;

import org.springframework. boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

import lombok.Data;
import lombok.extern.slf4j.Slf4j;

@Slf4j
@Data
@Component
@ConfigurationProperties(prefix = "line")
public class LineProperties {
    
    private Login login = new Login();
    private Messaging messaging = new Messaging();
    private Api api = new Api();
    
    @PostConstruct
    public void init() {
        log.debug("=== LINE設定情報ロード開始 ===");
        log.debug("[LINEログイン] Channel ID: {}", maskChannelId(login.getChannelId()));
        log.debug("[LINEログイン] Channel Secret: {}", maskSecret(login.getChannelSecret()));
        log.debug("[LINEログイン] Callback URL: {}", login.getCallbackUrl());
        log.debug("[Messaging API] Channel ID: {}", maskChannelId(messaging.getChannelId()));
        log.debug("[Messaging API] Channel Secret: {}", maskSecret(messaging. getChannelSecret()));
        log.debug("[Messaging API] Access Token: {}", maskToken(messaging.getChannelAccessToken()));
        log.debug("=== LINE設定情報ロード完了 ===");
    }
    
    private String maskChannelId(String value) {
        if (value == null || value.length() < 4) return "****";
        return value.substring(0, 4) + "****";
    }
    
    private String maskSecret(String value) {
        if (value == null || value.length() < 8) return "****";
        return value.substring(0, 4) + "****" + value.substring(value.length() - 4);
    }
    
    private String maskToken(String value) {
        if (value == null || value.length() < 20) return "****";
        return value.substring(0, 10) + "****";
    }
    
    @Data
    public static class Login {
        private String channelId;
        private String channelSecret;
        private String callbackUrl;
    }
    
    @Data
    public static class Messaging {
        private String channelId;
        private String channelSecret;
        private String channelAccessToken;
    }
    
    @Data
    public static class Api {
        private String authorizeUrl;
        private String tokenUrl;
        private String friendshipUrl;
        private String pushMessageUrl;
    }
}

package com.example.demo.config;

import org.springframework. context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.client.SimpleClientHttpRequestFactory;
import org.springframework.web.client.RestTemplate;

import lombok.extern.slf4j.Slf4j;

@Slf4j
@Configuration
public class RestTemplateConfig {
    
    @Bean
    public RestTemplate restTemplate() {
        log.debug("RestTemplate初期化開始");
        
        SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
        factory.setConnectTimeout(10000); // 10秒
        factory.setReadTimeout(10000);    // 10秒
        
        RestTemplate restTemplate = new RestTemplate(factory);
        
        log.debug("RestTemplate初期化完了");
        return restTemplate;
    }
}

package com.example.demo.config;

import org.springframework. context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.client.SimpleClientHttpRequestFactory;
import org.springframework.web.client.RestTemplate;

import lombok.extern.slf4j.Slf4j;

@Slf4j
@Configuration
public class RestTemplateConfig {
    
    @Bean
    public RestTemplate restTemplate() {
        log.debug("RestTemplate初期化開始");
        
        SimpleClientHttpRequestFactory factory = new SimpleClientHttpRequestFactory();
        factory.setConnectTimeout(10000); // 10秒
        factory.setReadTimeout(10000);    // 10秒
        
        RestTemplate restTemplate = new RestTemplate(factory);
        
        log.debug("RestTemplate初期化完了");
        return restTemplate;
    }
}

package com.example. demo.controller;

import jakarta.servlet.http.HttpSession;

import org.springframework.stereotype. Controller;
import org.springframework. web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web. bind.annotation.RequestParam;
import org.springframework.web.servlet.mvc.support.RedirectAttributes;

import com.example.demo.dto.LineTokenResponse;
import com.example.demo.service.LineAuthService;
import com.example.demo.service.LineFriendshipService;
import com.example.demo.service. LineMessageService;

import lombok. RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;

/**
 * LINE連携認証コントローラー
 * 
 * <p>LINEログインによる認証・認可フローを処理するコントローラーです。</p>
 * 
 * <h3>主な機能</h3>
 * <ul>
 *   <li>LINE認証開始（認証URLへのリダイレクト）</li>
 *   <li>LINEコールバック処理（認可コード受け取り、トークン取得）</li>
 *   <li>友だち状態確認</li>
 *   <li>プッシュメッセージ送信</li>
 *   <li>画面遷移制御</li>
 * </ul>
 * 
 * @version 1.0
 */
@Slf4j
@Controller
@RequestMapping("/line")
@RequiredArgsConstructor
public class LineAuthController {
    
    /**
     * セッションキー：LINE認証State
     * <p>CSRF対策用のStateをセッションに保存する際のキー名</p>
     */
    private static final String SESSION_KEY_LINE_AUTH_STATE = "lineAuthState";
    
    /** LINE認証サービス */
    private final LineAuthService lineAuthService;
    
    /** LINE友だち状態確認サービス */
    private final LineFriendshipService lineFriendshipService;
    
    /** LINEメッセージ送信サービス */
    private final LineMessageService lineMessageService;
    
    /**
     * LINE連携開始エンドポイント
     * 
     * <p>LINE認証フローを開始します。</p>
     * 
     * <h3>処理内容</h3>
     * <ol>
     *   <li>CSRF対策用のState（UUID）を生成</li>
     *   <li>Stateをセッションに保存</li>
     *   <li>LINE認証URLを生成（bot_prompt=normal指定）</li>
     *   <li>LINE認証画面にリダイレクト</li>
     * </ol>
     * 
     * <h3>LINE認証URLパラメータ</h3>
     * <ul>
     *   <li>response_type: code</li>
     *   <li>client_id: LINEログインチャネルID</li>
     *   <li>redirect_uri: コールバックURL</li>
     *   <li>state:  CSRF対策用UUID</li>
     *   <li>scope: profile openid</li>
     *   <li>bot_prompt:  normal（友だち追加チェックボックス表示）</li>
     * </ul>
     * 
     * @param session HTTPセッション（State保存用）
     * @return リダイレクト先（LINE認証URL または エラー画面）
     * 
     * @see LineAuthService#generateState()
     * @see LineAuthService#buildAuthorizationUrl(String)
     */
    @GetMapping("/auth/start")
    public String startLineAuth(HttpSession session) {
        log.debug("LINE認証開始リクエスト受信:  /line/auth/start");
        
        try {
            // State生成
            String state = lineAuthService.generateState();
            
            // Stateをセッションに保存
            session.setAttribute(SESSION_KEY_LINE_AUTH_STATE, state);
            
            // LINE認証URL生成
            String authUrl = lineAuthService. buildAuthorizationUrl(state);
            log.debug("リダイレクト先: {}", authUrl);
            
            return "redirect:" + authUrl;
            
        } catch (Exception e) {
            log.debug("LINE認証開始処理でエラーが発生しました", e);
            return "redirect:/error";
        }
    }
    
    /**
     * LINEコールバックエンドポイント
     * 
     * <p>LINE認証後、認可コードを受け取り、アクセストークン取得とLINE連携処理を実行します。</p>
     * 
     * <h3>処理内容</h3>
     * <ol>
     *   <li>エラーチェック（LINEからのエラーレスポンス確認）</li>
     *   <li>パラメータチェック（code、state の存在確認）</li>
     *   <li>State検証（CSRF対策）
     *     <ul>
     *       <li>セッションからStateを取得</li>
     *       <li>リクエストパラメータのStateと照合</li>
     *       <li>一致したらStateを削除（使い捨て）</li>
     *     </ul>
     *   </li>
     *   <li>アクセストークン取得（LINE Token API呼び出し）</li>
     *   <li>LINE User ID抽出（IDトークンをデコード）</li>
     *   <li>友だち状態確認（LINE Friendship API呼び出し）</li>
     *   <li>友だち追加済みの場合
     *     <ul>
     *       <li>プッシュメッセージ送信</li>
     *       <li>成功画面へリダイレクト</li>
     *     </ul>
     *   </li>
     *   <li>友だち未追加の場合
     *     <ul>
     *       <li>友だち追加画面へリダイレクト</li>
     *     </ul>
     *   </li>
     * </ol>
     * 
     * <h3>エラーハンドリング</h3>
     * <ul>
     *   <li>LINEからエラーが返された場合 → エラー画面</li>
     *   <li>必須パラメータが不足している場合 → エラー画面</li>
     *   <li>State検証に失敗した場合 → エラー画面</li>
     *   <li>LINE API呼び出しでエラーが発生した場合 → エラー画面</li>
     * </ul>
     * 
     * @param code LINE認可コード（必須）
     * @param state CSRF対策用State（必須）
     * @param error LINEからのエラーコード（任意）
     * @param errorDescription LINEからのエラー詳細（任意）
     * @param session HTTPセッション（State検証用）
     * @param redirectAttributes リダイレクト時の属性（Flash Scope使用）
     * @return リダイレクト先（成功画面 / 友���ち追加画面 / エラー画面）
     * 
     * @see LineAuthService#getAccessToken(String)
     * @see LineAuthService#extractLineUserIdFromIdToken(String)
     * @see LineFriendshipService#checkFriendship(String)
     * @see LineMessageService#sendPushMessage(String, String)
     */
    @GetMapping("/auth/callback")
    public String handleCallback(
            @RequestParam(required = false) String code,
            @RequestParam(required = false) String state,
            @RequestParam(required = false) String error,
            @RequestParam(required = false) String errorDescription,
            HttpSession session,
            RedirectAttributes redirectAttributes) {
        
        log.debug("========================================");
        log.debug("LINEコールバックリクエスト受信: /line/auth/callback");
        log.debug("リクエストパラメータ:");
        log.debug("  - code: {}", code);
        log.debug("  - state: {}", state);
        log.debug("  - error: {}", error);
        log.debug("========================================");
        
        // エラーチェック
        if (error != null) {
            log.debug("LINE認証エラー: {}", error);
            log.debug("エラー詳細: {}", errorDescription);
            return "redirect:/error";
        }
        
        // パラメータチェック
        if (code == null || state == null) {
            log.debug("必須パラメータ不足:  code={}, state={}", code, state);
            return "redirect:/error";
        }
        
        // State検証
        String savedState = (String) session.getAttribute(SESSION_KEY_LINE_AUTH_STATE);
        
        if (savedState == null || ! savedState.equals(state)) {
            log.debug("State検証失敗");
            return "redirect:/error";
        }
        
        log.debug("State検証成功");
        
        // State削除（使い捨て）
        session.removeAttribute(SESSION_KEY_LINE_AUTH_STATE);
        
        try {
            // 1. アクセストークン取得
            log.debug("--- アクセストークン取得開始 ---");
            LineTokenResponse tokenResponse = lineAuthService.getAccessToken(code);
            String accessToken = tokenResponse.getAccessToken();
            log.debug("アクセストークン取得成功");
            
            // 2. IDトークンからLINE User ID抽出
            log. debug("--- LINE User ID抽出開始 ---");
            String lineUserId = lineAuthService.extractLineUserIdFromIdToken(tokenResponse.getIdToken());
            log.debug("LINE User ID抽出成功: {}", lineUserId);
            
            // 3. 友だち状態確認（アクセストークンのみで確認）
            log.debug("--- 友だち状態確認開始 ---");
            boolean isFriend = lineFriendshipService.checkFriendship(accessToken);
            log.debug("友だち状態: {}", isFriend ? "友だち追加済み" : "友だち未追加");
            
            if (isFriend) {
                // 4. プッシュメッセージ送信
                log.debug("--- プッシュメッセージ送信開始 ---");
                lineMessageService.sendPushMessage(lineUserId, "LINE連携が完了しました！\nご利用ありがとうございます。");
                log.debug("プッシュメッセージ送信完了");
                
                return "redirect:/line/success";
            } else {
                log.debug("--- 友だち未追加: 友だち追加画面へ遷移 ---");
                return "redirect:/line/add-friend";
            }
            
        } catch (Exception e) {
            log.debug("========================================");
            log.debug("LINE連携処理中にエラーが発生しました", e);
            log.debug("例外クラス: {}", e.getClass().getName());
            log.debug("例外メッセージ:  {}", e.getMessage());
            log.debug("========================================");
            return "redirect:/error";
        }
    }
    
    /**
     * LINE連携成功画面表示
     * 
     * <p>LINE連携が正常に完了した場合の成功画面を表示します。</p>
     * 
     * <h3>遷移元</h3>
     * <ul>
     *   <li>{@link #handleCallback} - 友だち追加済み、メッセージ送信成功時</li>
     * </ul>
     * 
     * @return ビュー名（line/success. html）
     */
    @GetMapping("/success")
    public String success() {
        log.debug("LINE連携成功画面リクエスト受信: /line/success");
        return "line/success";
    }
    
    /**
     * 友だち追加画面表示
     * 
     * <p>ユーザーがMessaging APIチャネルを友だち追加していない場合に表示される画面です。</p>
     * 
     * <h3>遷移元</h3>
     * <ul>
     *   <li>{@link #handleCallback} - 友だち未追加時</li>
     * </ul>
     * 
     * <h3>画面内容</h3>
     * <ul>
     *   <li>友だち追加を促すメッセージ</li>
     *   <li>QRコード表示</li>
     *   <li>友だち追加ボタン</li>
     * </ul>
     * 
     * @return ビュー名（line/add-friend.html）
     */
    @GetMapping("/add-friend")
    public String addFriend() {
        log.debug("友だち追加画面リクエスト受信: /line/add-friend");
        return "line/add-friend";
    }
}

package com.example. demo.controller;

import jakarta.servlet.http.HttpSession;

import org.springframework.stereotype. Controller;
import org.springframework. web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web. bind.annotation.RequestParam;
import org.springframework.web.servlet.mvc.support.RedirectAttributes;

import com.example.demo.dto.LineTokenResponse;
import com.example.demo.service.LineAuthService;
import com.example.demo.service.LineFriendshipService;
import com.example.demo.service. LineMessageService;

import lombok. RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;

/**
 * LINE連携認証コントローラー
 * 
 * <p>LINEログインによる認証・認可フローを処理するコントローラーです。</p>
 * 
 * <h3>主な機能</h3>
 * <ul>
 *   <li>LINE認証開始（認証URLへのリダイレクト）</li>
 *   <li>LINEコールバック処理（認可コード受け取り、トークン取得）</li>
 *   <li>友だち状態確認</li>
 *   <li>プッシュメッセージ送信</li>
 *   <li>画面遷移制御</li>
 * </ul>
 * 
 * @version 1.0
 */
@Slf4j
@Controller
@RequestMapping("/line")
@RequiredArgsConstructor
public class LineAuthController {
    
    /**
     * セッションキー：LINE認証State
     * <p>CSRF対策用のStateをセッションに保存する際のキー名</p>
     */
    private static final String SESSION_KEY_LINE_AUTH_STATE = "lineAuthState";
    
    /** LINE認証サービス */
    private final LineAuthService lineAuthService;
    
    /** LINE友だち状態確認サービス */
    private final LineFriendshipService lineFriendshipService;
    
    /** LINEメッセージ送信サービス */
    private final LineMessageService lineMessageService;
    
    /**
     * LINE連携開始エンドポイント
     * 
     * <p>LINE認証フローを開始します。</p>
     * 
     * <h3>処理内容</h3>
     * <ol>
     *   <li>CSRF対策用のState（UUID）を生成</li>
     *   <li>Stateをセッションに保存</li>
     *   <li>LINE認証URLを生成（bot_prompt=normal指定）</li>
     *   <li>LINE認証画面にリダイレクト</li>
     * </ol>
     * 
     * <h3>LINE認証URLパラメータ</h3>
     * <ul>
     *   <li>response_type: code</li>
     *   <li>client_id: LINEログインチャネルID</li>
     *   <li>redirect_uri: コールバックURL</li>
     *   <li>state:  CSRF対策用UUID</li>
     *   <li>scope: profile openid</li>
     *   <li>bot_prompt:  normal（友だち追加チェックボックス表示）</li>
     * </ul>
     * 
     * @param session HTTPセッション（State保存用）
     * @return リダイレクト先（LINE認証URL または エラー画面）
     * 
     * @see LineAuthService#generateState()
     * @see LineAuthService#buildAuthorizationUrl(String)
     */
    @GetMapping("/auth/start")
    public String startLineAuth(HttpSession session) {
        log.debug("LINE認証開始リクエスト受信:  /line/auth/start");
        
        try {
            // State生成
            String state = lineAuthService.generateState();
            
            // Stateをセッションに保存
            session.setAttribute(SESSION_KEY_LINE_AUTH_STATE, state);
            
            // LINE認証URL生成
            String authUrl = lineAuthService. buildAuthorizationUrl(state);
            log.debug("リダイレクト先: {}", authUrl);
            
            return "redirect:" + authUrl;
            
        } catch (Exception e) {
            log.debug("LINE認証開始処理でエラーが発生しました", e);
            return "redirect:/error";
        }
    }
    
    /**
     * LINEコールバックエンドポイント
     * 
     * <p>LINE認証後、認可コードを受け取り、アクセストークン取得とLINE連携処理を実行します。</p>
     * 
     * <h3>処理内容</h3>
     * <ol>
     *   <li>エラーチェック（LINEからのエラーレスポンス確認）</li>
     *   <li>パラメータチェック（code、state の存在確認）</li>
     *   <li>State検証（CSRF対策）
     *     <ul>
     *       <li>セッションからStateを取得</li>
     *       <li>リクエストパラメータのStateと照合</li>
     *       <li>一致したらStateを削除（使い捨て）</li>
     *     </ul>
     *   </li>
     *   <li>アクセストークン取得（LINE Token API呼び出し）</li>
     *   <li>LINE User ID抽出（IDトークンをデコード）</li>
     *   <li>友だち状態確認（LINE Friendship API呼び出し）</li>
     *   <li>友だち追加済みの場合
     *     <ul>
     *       <li>プッシュメッセージ送信</li>
     *       <li>成功画面へリダイレクト</li>
     *     </ul>
     *   </li>
     *   <li>友だち未追加の場合
     *     <ul>
     *       <li>友だち追加画面へリダイレクト</li>
     *     </ul>
     *   </li>
     * </ol>
     * 
     * <h3>エラーハンドリング</h3>
     * <ul>
     *   <li>LINEからエラーが返された場合 → エラー画面</li>
     *   <li>必須パラメータが不足している場合 → エラー画面</li>
     *   <li>State検証に失敗した場合 → エラー画面</li>
     *   <li>LINE API呼び出しでエラーが発生した場合 → エラー画面</li>
     * </ul>
     * 
     * @param code LINE認可コード（必須）
     * @param state CSRF対策用State（必須）
     * @param error LINEからのエラーコード（任意）
     * @param errorDescription LINEからのエラー詳細（任意）
     * @param session HTTPセッション（State検証用）
     * @param redirectAttributes リダイレクト時の属性（Flash Scope使用）
     * @return リダイレクト先（成功画面 / 友���ち追加画面 / エラー画面）
     * 
     * @see LineAuthService#getAccessToken(String)
     * @see LineAuthService#extractLineUserIdFromIdToken(String)
     * @see LineFriendshipService#checkFriendship(String)
     * @see LineMessageService#sendPushMessage(String, String)
     */
    @GetMapping("/auth/callback")
    public String handleCallback(
            @RequestParam(required = false) String code,
            @RequestParam(required = false) String state,
            @RequestParam(required = false) String error,
            @RequestParam(required = false) String errorDescription,
            HttpSession session,
            RedirectAttributes redirectAttributes) {
        
        log.debug("========================================");
        log.debug("LINEコールバックリクエスト受信: /line/auth/callback");
        log.debug("リクエストパラメータ:");
        log.debug("  - code: {}", code);
        log.debug("  - state: {}", state);
        log.debug("  - error: {}", error);
        log.debug("========================================");
        
        // エラーチェック
        if (error != null) {
            log.debug("LINE認証エラー: {}", error);
            log.debug("エラー詳細: {}", errorDescription);
            return "redirect:/error";
        }
        
        // パラメータチェック
        if (code == null || state == null) {
            log.debug("必須パラメータ不足:  code={}, state={}", code, state);
            return "redirect:/error";
        }
        
        // State検証
        String savedState = (String) session.getAttribute(SESSION_KEY_LINE_AUTH_STATE);
        
        if (savedState == null || ! savedState.equals(state)) {
            log.debug("State検証失敗");
            return "redirect:/error";
        }
        
        log.debug("State検証成功");
        
        // State削除（使い捨て）
        session.removeAttribute(SESSION_KEY_LINE_AUTH_STATE);
        
        try {
            // 1. アクセストークン取得
            log.debug("--- アクセストークン取得開始 ---");
            LineTokenResponse tokenResponse = lineAuthService.getAccessToken(code);
            String accessToken = tokenResponse.getAccessToken();
            log.debug("アクセストークン取得成功");
            
            // 2. IDトークンからLINE User ID抽出
            log. debug("--- LINE User ID抽出開始 ---");
            String lineUserId = lineAuthService.extractLineUserIdFromIdToken(tokenResponse.getIdToken());
            log.debug("LINE User ID抽出成功: {}", lineUserId);
            
            // 3. 友だち状態確認（アクセストークンのみで確認）
            log.debug("--- 友だち状態確認開始 ---");
            boolean isFriend = lineFriendshipService.checkFriendship(accessToken);
            log.debug("友だち状態: {}", isFriend ? "友だち追加済み" : "友だち未追加");
            
            if (isFriend) {
                // 4. プッシュメッセージ送信
                log.debug("--- プッシュメッセージ送信開始 ---");
                lineMessageService.sendPushMessage(lineUserId, "LINE連携が完了しました！\nご利用ありがとうございます。");
                log.debug("プッシュメッセージ送信完了");
                
                return "redirect:/line/success";
            } else {
                log.debug("--- 友だち未追加: 友だち追加画面へ遷移 ---");
                return "redirect:/line/add-friend";
            }
            
        } catch (Exception e) {
            log.debug("========================================");
            log.debug("LINE連携処理中にエラーが発生しました", e);
            log.debug("例外クラス: {}", e.getClass().getName());
            log.debug("例外メッセージ:  {}", e.getMessage());
            log.debug("========================================");
            return "redirect:/error";
        }
    }
    
    /**
     * LINE連携成功画面表示
     * 
     * <p>LINE連携が正常に完了した場合の成功画面を表示します。</p>
     * 
     * <h3>遷移元</h3>
     * <ul>
     *   <li>{@link #handleCallback} - 友だち追加済み、メッセージ送信成功時</li>
     * </ul>
     * 
     * @return ビュー名（line/success. html）
     */
    @GetMapping("/success")
    public String success() {
        log.debug("LINE連携成功画面リクエスト受信: /line/success");
        return "line/success";
    }
    
    /**
     * 友だち追加画面表示
     * 
     * <p>ユーザーがMessaging APIチャネルを友だち追加していない場合に表示される画面です。</p>
     * 
     * <h3>遷移元</h3>
     * <ul>
     *   <li>{@link #handleCallback} - 友だち未追加時</li>
     * </ul>
     * 
     * <h3>画面内容</h3>
     * <ul>
     *   <li>友だち追加を促すメッセージ</li>
     *   <li>QRコード表示</li>
     *   <li>友だち追加ボタン</li>
     * </ul>
     * 
     * @return ビュー名（line/add-friend.html）
     */
    @GetMapping("/add-friend")
    public String addFriend() {
        log.debug("友だち追加画面リクエスト受信: /line/add-friend");
        return "line/add-friend";
    }
}

package com.example. demo.service;

import java. nio.charset.StandardCharsets;
import java.util.Base64;
import java.util. UUID;

import org. springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework. http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;
import org. springframework.web.util.UriComponentsBuilder;

import com. example.demo.config.LineProperties;
import com.example.demo.dto.LineTokenResponse;

import lombok.RequiredArgsConstructor;
import lombok.extern. slf4j.Slf4j;

/**
 * LINE認証サービス
 * 
 * <p>LINEログインの認証・認可フローに必要な処理を提供するサービスクラスです。</p>
 * 
 * <h3>主な機能</h3>
 * <ul>
 *   <li>CSRF対策用State生成</li>
 *   <li>LINE認証URL生成</li>
 *   <li>アクセストークン取得（LINE Token API呼び出し）</li>
 *   <li>IDトークンからLINE User ID抽出</li>
 * </ul>
 * 
 * <h3>LINE API連携</h3>
 * <ul>
 *   <li>認証エンドポイント: https://access.line.me/oauth2/v2.1/authorize</li>
 *   <li>トークンエンドポイント:  https://api.line.me/oauth2/v2.1/token</li>
 * </ul>
 * 
 * <h3>OAuth 2.0 フロー</h3>
 * <ol>
 *   <li>State生成（CSRF対策）</li>
 *   <li>認証URL生成（認証エンドポイントへのリダイレクトURL）</li>
 *   <li>ユーザー認証後、認可コードを受け取る</li>
 *   <li>認可コードをアクセストークンに交換（トークンエンドポイント）</li>
 *   <li>IDトークンからユーザー情報（LINE User ID）を抽出</li>
 * </ol>
 */
@Slf4j
@Service
@RequiredArgsConstructor
public class LineAuthService {
    
    /** LINE設定プロパティ */
    private final LineProperties lineProperties;
    
    /** REST APIクライアント */
    private final RestTemplate restTemplate;
    
    
    /**
     * UUIDを使用してランダムなStateを生成
     * 
     * @return 生成されたState（UUID文字列）
     */
    public String generateState() {
        String state = UUID.randomUUID().toString();
        log.debug("State生成:  {}", state);
        return state;
    }
    
    /**
     * LINE認証URL生成
     * 
     * <p>LINEログイン画面へリダイレクトするためのURLを生成します。</p>
     * 
     * <h3>URLパラメータ</h3>
     * <ul>
     *   <li>response_type: code（認可コードフロー）</li>
     *   <li>client_id: LINEログインチャネルID</li>
     *   <li>redirect_uri: 認証後のコールバックURL</li>
     *   <li>state:  CSRF対策用のランダム文字列</li>
     *   <li>scope: profile openid（プロフィール情報とOpenID）</li>
     *   <li>bot_prompt: normal（友だち追加チェックボックスを表示）</li>
     * </ul>
     * 
     * @param state CSRF対策用State
     * @return LINE認証URL
     * @throws IllegalStateException LINE設定が読み込まれていない場合
     */
    public String buildAuthorizationUrl(String state) {
        log.debug("LINE認証URL生成開始:  state={}", state);
        
        String authorizeUrl = lineProperties.getApi().getAuthorizeUrl();
        String authUrl = UriComponentsBuilder
                .fromUriString(authorizeUrl)
                .queryParam("response_type", "code")
                .queryParam("client_id", lineProperties.getLogin().getChannelId())
                .queryParam("redirect_uri", lineProperties.getLogin().getCallbackUrl())
                .queryParam("state", state)
                .queryParam("scope", "profile openid")
                .queryParam("bot_prompt", "normal")
                .build()
                .toUriString();
        
        log. debug("LINE認証URL生成完了");
        return authUrl;
    }
    
    /**
     * アクセストークン取得
     * 
     * <p>LINE認可コードをアクセストークンに交換します。</p>
     * 
     * @param code LINE認可コード
     * @return トークンレスポンス（アクセストークン、IDトークン等）
     * @throws RuntimeException トークン取得に失敗した場合
     */
    public LineTokenResponse getAccessToken(String code) {
        log.debug("アクセストークン取得開始");
        
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
        
        MultiValueMap<String, String> params = new LinkedMultiValueMap<>();
        params.add("grant_type", "authorization_code");
        params.add("code", code);
        params.add("redirect_uri", lineProperties.getLogin().getCallbackUrl());
        params.add("client_id", lineProperties.getLogin().getChannelId());
        params.add("client_secret", lineProperties.getLogin().getChannelSecret());
        
        HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(params, headers);
        
        try {
            ResponseEntity<LineTokenResponse> response = restTemplate.postForEntity(
                    lineProperties.getApi().getTokenUrl(),
                    request,
                    LineTokenResponse.class
            );
            
            if (response.getStatusCode() == HttpStatus.OK && response.getBody() != null) {
                log.debug("アクセストークン取得成功");
                return response.getBody();
            } else {
                log.error("アクセストークン取得失敗: statusCode={}", response.getStatusCode());
                throw new RuntimeException("アクセストークン取得失敗:  " + response.getStatusCode());
            }
        } catch (Exception e) {
            log.error("LINE Token API呼び出しエラー:  {}", e.getMessage());
            throw new RuntimeException("アクセストークン取得エラー", e);
        }
    }
    
    /**
     * IDトークンからLINE User ID抽出
     * 
     * <p>JWT形式のIDトークンをデコードし、LINE User ID（sub）を抽出します。</p>
     * 
     * <h3>処理手順</h3>
     * <ol>
     *   <li>IDトークンを"."で分割（header, payload, signature）</li>
     *   <li>payload部分をBase64URLデコード</li>
     *   <li>JSON形式のpayloadから"sub"フィールドを抽出</li>
     * </ol>
     * 
     * <h3>payload例</h3>
     * <pre>
     * {
     *   "iss":  "https://access.line.me",
     *   "sub": "U1234567890abcdef.. .",
     *   "aud": "2008779582",
     *   "exp":  1234567890,
     *   "iat": 1234567890
     * }
     * </pre>
     * 
     * @param idToken IDトークン（JWT形式）
     * @return LINE User ID（sub）
     * @throws RuntimeException IDトークンの形式が不正、またはsubが含まれていない場合
     */
    public String extractLineUserIdFromIdToken(String idToken) {
        log.debug("LINE User ID抽出開始");
        
        try {
            // JWTを分割
            String[] parts = idToken.split("\\.");
            if (parts.length != 3) {
                log.error("IDトークンの形式が不正です:  parts.length={}", parts.length);
                throw new RuntimeException("IDトークンの形式が不正です");
            }
            
            // payloadをBase64デコード
            String payload = parts[1];
            byte[] decodedBytes = Base64.getUrlDecoder().decode(payload);
            String decodedPayload = new String(decodedBytes, StandardCharsets.UTF_8);
            
            log.debug("IDトークンデコード成功");
            
            // subフィールドを抽出
            String lineUserId = extractSubFromJson(decodedPayload);
            
            if (lineUserId == null || lineUserId.isEmpty()) {
                log.error("IDトークンにsubが含まれていません");
                throw new RuntimeException("IDトークンにsubが含まれていません");
            }
            
            log.debug("LINE User ID抽出成功: {}", lineUserId);
            return lineUserId;
            
        } catch (Exception e) {
            log.error("IDトークンパースエラー: {}", e. getMessage());
            throw new RuntimeException("IDトークンパースエラー", e);
        }
    }
    
    /**
     * JSON文字列からsubフィールドを抽出
     * 
     * <p>簡易的なJSON解析により"sub"フィールドの値を抽出します。</p>
     * 
     * <h3>抽出パターン</h3>
     * <pre>
     * "sub":"U1234567890abcdef..."
     * </pre>
     * 
     * <h3>制約</h3>
     * <ul>
     *   <li>正式なJSONパーサーは使用せず、文字列検索で抽出</li>
     *   <li>subフィールドが存在しない場合はnullを返す</li>
     * </ul>
     * 
     * @param json JSON文字列（デコード済みpayload）
     * @return subフィールドの値（LINE User ID）、存在しない場合はnull
     */
    private String extractSubFromJson(String json) {
        String subKey = "\"sub\": \"";
        int startIndex = json.indexOf(subKey);
        
        if (startIndex == -1) {
            log.error("JSON内にsubフィールドが見つかりません");
            return null;
        }
        
        startIndex += subKey.length();
        int endIndex = json.indexOf("\"", startIndex);
        
        if (endIndex == -1) {
            log.error("JSON内のsubフィールドの終端が見つかりません");
            return null;
        }
        
        String sub = json.substring(startIndex, endIndex);
        log.debug("sub抽出成功: {}", sub);
        return sub;
    }
}

package com.example. demo.service;

import java. nio.charset.StandardCharsets;
import java.util.Base64;
import java.util. UUID;

import org. springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework. http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;
import org. springframework.web.util.UriComponentsBuilder;

import com. example.demo.config.LineProperties;
import com.example.demo.dto.LineTokenResponse;

import lombok.RequiredArgsConstructor;
import lombok.extern. slf4j.Slf4j;

/**
 * LINE認証サービス
 * 
 * <p>LINEログインの認証・認可フローに必要な処理を提供するサービスクラスです。</p>
 * 
 * <h3>主な機能</h3>
 * <ul>
 *   <li>CSRF対策用State生成</li>
 *   <li>LINE認証URL生成</li>
 *   <li>アクセストークン取得（LINE Token API呼び出し）</li>
 *   <li>IDトークンからLINE User ID抽出</li>
 * </ul>
 * 
 * <h3>LINE API連携</h3>
 * <ul>
 *   <li>認証エンドポイント: https://access.line.me/oauth2/v2.1/authorize</li>
 *   <li>トークンエンドポイント:  https://api.line.me/oauth2/v2.1/token</li>
 * </ul>
 * 
 * <h3>OAuth 2.0 フロー</h3>
 * <ol>
 *   <li>State生成（CSRF対策）</li>
 *   <li>認証URL生成（認証エンドポイントへのリダイレクトURL）</li>
 *   <li>ユーザー認証後、認可コードを受け取る</li>
 *   <li>認可コードをアクセストークンに交換（トークンエンドポイント）</li>
 *   <li>IDトークンからユーザー情報（LINE User ID）を抽出</li>
 * </ol>
 */
@Slf4j
@Service
@RequiredArgsConstructor
public class LineAuthService {
    
    /** LINE設定プロパティ */
    private final LineProperties lineProperties;
    
    /** REST APIクライアント */
    private final RestTemplate restTemplate;
    
    
    /**
     * UUIDを使用してランダムなStateを生成
     * 
     * @return 生成されたState（UUID文字列）
     */
    public String generateState() {
        String state = UUID.randomUUID().toString();
        log.debug("State生成:  {}", state);
        return state;
    }
    
    /**
     * LINE認証URL生成
     * 
     * <p>LINEログイン画面へリダイレクトするためのURLを生成します。</p>
     * 
     * <h3>URLパラメータ</h3>
     * <ul>
     *   <li>response_type: code（認可コードフロー）</li>
     *   <li>client_id: LINEログインチャネルID</li>
     *   <li>redirect_uri: 認証後のコールバックURL</li>
     *   <li>state:  CSRF対策用のランダム文字列</li>
     *   <li>scope: profile openid（プロフィール情報とOpenID）</li>
     *   <li>bot_prompt: normal（友だち追加チェックボックスを表示）</li>
     * </ul>
     * 
     * @param state CSRF対策用State
     * @return LINE認証URL
     * @throws IllegalStateException LINE設定が読み込まれていない場合
     */
    public String buildAuthorizationUrl(String state) {
        log.debug("LINE認証URL生成開始:  state={}", state);
        
        String authorizeUrl = lineProperties.getApi().getAuthorizeUrl();
        String authUrl = UriComponentsBuilder
                .fromUriString(authorizeUrl)
                .queryParam("response_type", "code")
                .queryParam("client_id", lineProperties.getLogin().getChannelId())
                .queryParam("redirect_uri", lineProperties.getLogin().getCallbackUrl())
                .queryParam("state", state)
                .queryParam("scope", "profile openid")
                .queryParam("bot_prompt", "normal")
                .build()
                .toUriString();
        
        log. debug("LINE認証URL生成完了");
        return authUrl;
    }
    
    /**
     * アクセストークン取得
     * 
     * <p>LINE認可コードをアクセストークンに交換します。</p>
     * 
     * @param code LINE認可コード
     * @return トークンレスポンス（アクセストークン、IDトークン等）
     * @throws RuntimeException トークン取得に失敗した場合
     */
    public LineTokenResponse getAccessToken(String code) {
        log.debug("アクセストークン取得開始");
        
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
        
        MultiValueMap<String, String> params = new LinkedMultiValueMap<>();
        params.add("grant_type", "authorization_code");
        params.add("code", code);
        params.add("redirect_uri", lineProperties.getLogin().getCallbackUrl());
        params.add("client_id", lineProperties.getLogin().getChannelId());
        params.add("client_secret", lineProperties.getLogin().getChannelSecret());
        
        HttpEntity<MultiValueMap<String, String>> request = new HttpEntity<>(params, headers);
        
        try {
            ResponseEntity<LineTokenResponse> response = restTemplate.postForEntity(
                    lineProperties.getApi().getTokenUrl(),
                    request,
                    LineTokenResponse.class
            );
            
            if (response.getStatusCode() == HttpStatus.OK && response.getBody() != null) {
                log.debug("アクセストークン取得成功");
                return response.getBody();
            } else {
                log.error("アクセストークン取得失敗: statusCode={}", response.getStatusCode());
                throw new RuntimeException("アクセストークン取得失敗:  " + response.getStatusCode());
            }
        } catch (Exception e) {
            log.error("LINE Token API呼び出しエラー:  {}", e.getMessage());
            throw new RuntimeException("アクセストークン取得エラー", e);
        }
    }
    
    /**
     * IDトークンからLINE User ID抽出
     * 
     * <p>JWT形式のIDトークンをデコードし、LINE User ID（sub）を抽出します。</p>
     * 
     * <h3>処理手順</h3>
     * <ol>
     *   <li>IDトークンを"."で分割（header, payload, signature）</li>
     *   <li>payload部分をBase64URLデコード</li>
     *   <li>JSON形式のpayloadから"sub"フィールドを抽出</li>
     * </ol>
     * 
     * <h3>payload例</h3>
     * <pre>
     * {
     *   "iss":  "https://access.line.me",
     *   "sub": "U1234567890abcdef.. .",
     *   "aud": "2008779582",
     *   "exp":  1234567890,
     *   "iat": 1234567890
     * }
     * </pre>
     * 
     * @param idToken IDトークン（JWT形式）
     * @return LINE User ID（sub）
     * @throws RuntimeException IDトークンの形式が不正、またはsubが含まれていない場合
     */
    public String extractLineUserIdFromIdToken(String idToken) {
        log.debug("LINE User ID抽出開始");
        
        try {
            // JWTを分割
            String[] parts = idToken.split("\\.");
            if (parts.length != 3) {
                log.error("IDトークンの形式が不正です:  parts.length={}", parts.length);
                throw new RuntimeException("IDトークンの形式が不正です");
            }
            
            // payloadをBase64デコード
            String payload = parts[1];
            byte[] decodedBytes = Base64.getUrlDecoder().decode(payload);
            String decodedPayload = new String(decodedBytes, StandardCharsets.UTF_8);
            
            log.debug("IDトークンデコード成功");
            
            // subフィールドを抽出
            String lineUserId = extractSubFromJson(decodedPayload);
            
            if (lineUserId == null || lineUserId.isEmpty()) {
                log.error("IDトークンにsubが含まれていません");
                throw new RuntimeException("IDトークンにsubが含まれていません");
            }
            
            log.debug("LINE User ID抽出成功: {}", lineUserId);
            return lineUserId;
            
        } catch (Exception e) {
            log.error("IDトークンパースエラー: {}", e. getMessage());
            throw new RuntimeException("IDトークンパースエラー", e);
        }
    }
    
    /**
     * JSON文字列からsubフィールドを抽出
     * 
     * <p>簡易的なJSON解析により"sub"フィールドの値を抽出します。</p>
     * 
     * <h3>抽出パターン</h3>
     * <pre>
     * "sub":"U1234567890abcdef..."
     * </pre>
     * 
     * <h3>制約</h3>
     * <ul>
     *   <li>正式なJSONパーサーは使用せず、文字列検索で抽出</li>
     *   <li>subフィールドが存在しない場合はnullを返す</li>
     * </ul>
     * 
     * @param json JSON文字列（デコード済みpayload）
     * @return subフィールドの値（LINE User ID）、存在しない場合はnull
     */
    private String extractSubFromJson(String json) {
        String subKey = "\"sub\": \"";
        int startIndex = json.indexOf(subKey);
        
        if (startIndex == -1) {
            log.error("JSON内にsubフィールドが見つかりません");
            return null;
        }
        
        startIndex += subKey.length();
        int endIndex = json.indexOf("\"", startIndex);
        
        if (endIndex == -1) {
            log.error("JSON内のsubフィールドの終端が見つかりません");
            return null;
        }
        
        String sub = json.substring(startIndex, endIndex);
        log.debug("sub抽出成功: {}", sub);
        return sub;
    }
}

package com.example.demo.service;

import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework. http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org. springframework.stereotype.Service;
import org.springframework.web.client. RestTemplate;

import com.example.demo.config.LineProperties;
import com.example.demo. dto.LineFriendshipResponse;

import lombok.RequiredArgsConstructor;
import lombok. extern.slf4j.Slf4j;

/**
 * LINE友だち状態確認サービス
 * 
 * <p>LINE Friendship APIを使用して、ユーザーがMessaging APIチャネルを
 * 友だち追加しているかを確認するサービスクラスです。</p>
 * 
 * <h3>前提条件</h3>
 * <ul>
 *   <li>LINEログインチャネルとMessaging APIチャネルが同じプロバイダー内に存在すること</li>
 *   <li>ユーザーがLINE認証時に"profile"スコープを許可していること</li>
 * </ul>
 */
@Slf4j
@Service
@RequiredArgsConstructor
public class LineFriendshipService {
    
    /** LINE設定プロパティ */
    private final LineProperties lineProperties;
    
    /** REST APIクライアント */
    private final RestTemplate restTemplate;
    
    /**
     * 友だち状態確認
     * 
     * <p>LINE Friendship APIを呼び出し、ユーザーがMessaging APIチャネルを
     * 友だち追加しているかを確認します。</p>
     * 
     * @param accessToken ユーザーのアクセストークン（LINE認証で取得）
     * @return 友だち追加済みの場合true、それ以外false
     * @throws RuntimeException API呼び出しに失敗した場合
     * 
     * @see LineAuthService#getAccessToken(String)
     */
    public boolean checkFriendship(String accessToken) {
        log.debug("友だち状態確認開始");
        
        String url = lineProperties.getApi().getFriendshipUrl();
        
        HttpHeaders headers = new HttpHeaders();
        headers.setBearerAuth(accessToken);
        headers.setContentType(MediaType.APPLICATION_JSON);
        
        HttpEntity<Void> request = new HttpEntity<>(headers);
        
        try {
            ResponseEntity<LineFriendshipResponse> response = restTemplate.exchange(
                    url,
                    HttpMethod.GET,
                    request,
                    LineFriendshipResponse.class
            );
            
            if (response.getStatusCode() == HttpStatus.OK && response.getBody() != null) {
                LineFriendshipResponse friendshipResponse = response.getBody();
                boolean isFriend = Boolean. TRUE.equals(friendshipResponse. getFriendFlag());
                
                log.debug("友だち状態確認成功:  friendFlag={}", isFriend);
                return isFriend;
            } else {
                log.error("友だち状態確認失敗: statusCode={}", response.getStatusCode());
                throw new RuntimeException("友だち状態確認失敗: " + response.getStatusCode());
            }
        } catch (Exception e) {
            log.error("LINE Friendship API呼び出しエラー:  {}", e.getMessage());
            throw new RuntimeException("友だち状態確認エラー", e);
        }
    }
}

package com.example.demo.service;

import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework. http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org. springframework.stereotype.Service;
import org.springframework.web.client. RestTemplate;

import com.example.demo.config.LineProperties;
import com.example.demo. dto.LineFriendshipResponse;

import lombok.RequiredArgsConstructor;
import lombok. extern.slf4j.Slf4j;

/**
 * LINE友だち状態確認サービス
 * 
 * <p>LINE Friendship APIを使用して、ユーザーがMessaging APIチャネルを
 * 友だち追加しているかを確認するサービスクラスです。</p>
 * 
 * <h3>前提条件</h3>
 * <ul>
 *   <li>LINEログインチャネルとMessaging APIチャネルが同じプロバイダー内に存在すること</li>
 *   <li>ユーザーがLINE認証時に"profile"スコープを許可していること</li>
 * </ul>
 */
@Slf4j
@Service
@RequiredArgsConstructor
public class LineFriendshipService {
    
    /** LINE設定プロパティ */
    private final LineProperties lineProperties;
    
    /** REST APIクライアント */
    private final RestTemplate restTemplate;
    
    /**
     * 友だち状態確認
     * 
     * <p>LINE Friendship APIを呼び出し、ユーザーがMessaging APIチャネルを
     * 友だち追加しているかを確認します。</p>
     * 
     * @param accessToken ユーザーのアクセストークン（LINE認証で取得）
     * @return 友だち追加済みの場合true、それ以外false
     * @throws RuntimeException API呼び出しに失敗した場合
     * 
     * @see LineAuthService#getAccessToken(String)
     */
    public boolean checkFriendship(String accessToken) {
        log.debug("友だち状態確認開始");
        
        String url = lineProperties.getApi().getFriendshipUrl();
        
        HttpHeaders headers = new HttpHeaders();
        headers.setBearerAuth(accessToken);
        headers.setContentType(MediaType.APPLICATION_JSON);
        
        HttpEntity<Void> request = new HttpEntity<>(headers);
        
        try {
            ResponseEntity<LineFriendshipResponse> response = restTemplate.exchange(
                    url,
                    HttpMethod.GET,
                    request,
                    LineFriendshipResponse.class
            );
            
            if (response.getStatusCode() == HttpStatus.OK && response.getBody() != null) {
                LineFriendshipResponse friendshipResponse = response.getBody();
                boolean isFriend = Boolean. TRUE.equals(friendshipResponse. getFriendFlag());
                
                log.debug("友だち状態確認成功:  friendFlag={}", isFriend);
                return isFriend;
            } else {
                log.error("友だち状態確認失敗: statusCode={}", response.getStatusCode());
                throw new RuntimeException("友だち状態確認失敗: " + response.getStatusCode());
            }
        } catch (Exception e) {
            log.error("LINE Friendship API呼び出しエラー:  {}", e.getMessage());
            throw new RuntimeException("友だち状態確認エラー", e);
        }
    }
}

package com. example.demo.service;

import org.springframework.stereotype.Service;

import com.example.demo. dto.LineTokenResponse;

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;

/**
 * LINE連携統合サービス
 * 
 * <p>LINE連携に関する一連の処理を統合的に実行するサービスクラスです。</p>
 * 
 * <h3>主な機能</h3>
 * <ul>
 *   <li>アクセストークン取得</li>
 *   <li>LINE User ID抽出</li>
 *   <li>友だち状態確認</li>
 *   <li>ウェルカムメッセージ送信（友だち追加済みの場合）</li>
 * </ul>
 */
@Slf4j
@Service
@RequiredArgsConstructor
public class LineIntegrationService {
    
    /** LINE認証サービス */
    private final LineAuthService lineAuthService;
    
    /** LINE友だち状態確認サービス */
    private final LineFriendshipService lineFriendshipService;
    
    /** LINEメッセージ送信サービス */
    private final LineMessageService lineMessageService;
    
    /**
     * LINE連携処理
     * 
     * <p>LINE認可コードを受け取り、アクセストークン取得から友だち状態確認、
     * メッセージ送信までの一連の処理を実行します。</p>
     * 
     * <h3>処理ステップ</h3>
     * <ol>
     *   <li><strong>アクセストークン取得</strong>
     *     <ul>
     *       <li>LINE認可コードをアクセストークンに交換</li>
     *       <li>IDトークン、リフレッシュトークンも同時に取得</li>
     *     </ul>
     *   </li>
     *   <li><strong>LINE User ID抽出</strong>
     *     <ul>
     *       <li>IDトークン（JWT）をデコード</li>
     *       <li>subフィールドからLINE User IDを抽出</li>
     *     </ul>
     *   </li>
     *   <li><strong>友だち状態確認</strong>
     *     <ul>
     *       <li>LINE Friendship APIを呼び出し</li>
     *       <li>ユーザーがMessaging APIチャネルを友だち追加済みか確認</li>
     *     </ul>
     *   </li>
     *   <li><strong>ウェルカムメッセージ送信</strong>（友だち追加済みの場合のみ）
     *     <ul>
     *       <li>LINE Push Message APIを呼び出し</li>
     *       <li>ウェルカムメッセージを送信</li>
     *     </ul>
     *   </li>
     * </ol>
     * 
     * <h3>戻り値</h3>
     * <ul>
     *   <li>success: 処理が正常に完了したかどうか（常にtrue、例外の場合はthrow）</li>
     *   <li>isFriend:  友だち追加済みかどうか</li>
     *   <li>lineUserId: LINE User ID</li>
     * </ul>
     * 
     * @param userId システム内のユーザーID（将来的なDB連携用、現在は未使用）
     * @param code LINE認可コード
     * @return LINE連携処理結果
     * @throws RuntimeException LINE API呼び出しに失敗した場合
     * 
     * @see LineAuthService#getAccessToken(String)
     * @see LineAuthService#extractLineUserIdFromIdToken(String)
     * @see LineFriendshipService#checkFriendship(String)
     * @see LineMessageService#sendPushMessage(String, String)
     */
    public LineIntegrationResult integrateLineAccount(Long userId, String code) {
        log.info("LINE連携処理開始:  userId={}", userId);
        
        try {
            // 1. アクセストークン取得
            log.debug("アクセストークン取得開始");
            LineTokenResponse tokenResponse = lineAuthService.getAccessToken(code);
            log.debug("アクセストークン取得成功");
            
            // 2. LINE User ID抽出
            log.debug("LINE User ID抽出開始");
            String lineUserId = lineAuthService.extractLineUserIdFromIdToken(tokenResponse. getIdToken());
            log.debug("LINE User ID抽出成功: lineUserId={}", lineUserId);
            
            // 3. 友だち状態確認
            log. debug("友だち状態確認開始");
            boolean isFriend = lineFriendshipService.checkFriendship(tokenResponse.getAccessToken());
            log.debug("友だち状態確認完了: isFriend={}", isFriend);
            
            // 4. 友だちの場合、メッセージ送信
            if (isFriend) {
                log.debug("ウェルカムメッセージ送信開始");
                String message = "LINE連携が完了しました！\nこれからお役立ち情報をお届けします。";
                lineMessageService.sendPushMessage(lineUserId, message);
                log.debug("ウェルカムメッセージ送信完了");
                
                log.info("LINE連携処理完了（友だち追加済み）:  userId={}, lineUserId={}", userId, lineUserId);
                return new LineIntegrationResult(true, true, lineUserId);
            } else {
                log. info("LINE連携処理完了（友だち未追加）: userId={}, lineUserId={}", userId, lineUserId);
                return new LineIntegrationResult(true, false, lineUserId);
            }
            
        } catch (Exception e) {
            log.error("LINE連携処理失敗: userId={}, error={}", userId, e.getMessage(), e);
            throw e;
        }
    }
    
    /**
     * LINE連携処理結果
     * 
     * <p>LINE連携処理の実行結果を保持するレコードクラスです。</p>
     * 
     * @param success 処理が正常に完了したかどうか
     * @param isFriend 友だち追加済みかどうか
     * @param lineUserId LINE User ID
     */
    public record LineIntegrationResult(
            boolean success,
            boolean isFriend,
            String lineUserId
    ) {}
}

package com. example.demo.service;

import org.springframework.stereotype.Service;

import com.example.demo. dto.LineTokenResponse;

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;

/**
 * LINE連携統合サービス
 * 
 * <p>LINE連携に関する一連の処理を統合的に実行するサービスクラスです。</p>
 * 
 * <h3>主な機能</h3>
 * <ul>
 *   <li>アクセストークン取得</li>
 *   <li>LINE User ID抽出</li>
 *   <li>友だち状態確認</li>
 *   <li>ウェルカムメッセージ送信（友だち追加済みの場合）</li>
 * </ul>
 */
@Slf4j
@Service
@RequiredArgsConstructor
public class LineIntegrationService {
    
    /** LINE認証サービス */
    private final LineAuthService lineAuthService;
    
    /** LINE友だち状態確認サービス */
    private final LineFriendshipService lineFriendshipService;
    
    /** LINEメッセージ送信サービス */
    private final LineMessageService lineMessageService;
    
    /**
     * LINE連携処理
     * 
     * <p>LINE認可コードを受け取り、アクセストークン取得から友だち状態確認、
     * メッセージ送信までの一連の処理を実行します。</p>
     * 
     * <h3>処理ステップ</h3>
     * <ol>
     *   <li><strong>アクセストークン取得</strong>
     *     <ul>
     *       <li>LINE認可コードをアクセストークンに交換</li>
     *       <li>IDトークン、リフレッシュトークンも同時に取得</li>
     *     </ul>
     *   </li>
     *   <li><strong>LINE User ID抽出</strong>
     *     <ul>
     *       <li>IDトークン（JWT）をデコード</li>
     *       <li>subフィールドからLINE User IDを抽出</li>
     *     </ul>
     *   </li>
     *   <li><strong>友だち状態確認</strong>
     *     <ul>
     *       <li>LINE Friendship APIを呼び出し</li>
     *       <li>ユーザーがMessaging APIチャネルを友だち追加済みか確認</li>
     *     </ul>
     *   </li>
     *   <li><strong>ウェルカムメッセージ送信</strong>（友だち追加済みの場合のみ）
     *     <ul>
     *       <li>LINE Push Message APIを呼び出し</li>
     *       <li>ウェルカムメッセージを送信</li>
     *     </ul>
     *   </li>
     * </ol>
     * 
     * <h3>戻り値</h3>
     * <ul>
     *   <li>success: 処理が正常に完了したかどうか（常にtrue、例外の場合はthrow）</li>
     *   <li>isFriend:  友だち追加済みかどうか</li>
     *   <li>lineUserId: LINE User ID</li>
     * </ul>
     * 
     * @param userId システム内のユーザーID（将来的なDB連携用、現在は未使用）
     * @param code LINE認可コード
     * @return LINE連携処理結果
     * @throws RuntimeException LINE API呼び出しに失敗した場合
     * 
     * @see LineAuthService#getAccessToken(String)
     * @see LineAuthService#extractLineUserIdFromIdToken(String)
     * @see LineFriendshipService#checkFriendship(String)
     * @see LineMessageService#sendPushMessage(String, String)
     */
    public LineIntegrationResult integrateLineAccount(Long userId, String code) {
        log.info("LINE連携処理開始:  userId={}", userId);
        
        try {
            // 1. アクセストークン取得
            log.debug("アクセストークン取得開始");
            LineTokenResponse tokenResponse = lineAuthService.getAccessToken(code);
            log.debug("アクセストークン取得成功");
            
            // 2. LINE User ID抽出
            log.debug("LINE User ID抽出開始");
            String lineUserId = lineAuthService.extractLineUserIdFromIdToken(tokenResponse. getIdToken());
            log.debug("LINE User ID抽出成功: lineUserId={}", lineUserId);
            
            // 3. 友だち状態確認
            log. debug("友だち状態確認開始");
            boolean isFriend = lineFriendshipService.checkFriendship(tokenResponse.getAccessToken());
            log.debug("友だち状態確認完了: isFriend={}", isFriend);
            
            // 4. 友だちの場合、メッセージ送信
            if (isFriend) {
                log.debug("ウェルカムメッセージ送信開始");
                String message = "LINE連携が完了しました！\nこれからお役立ち情報をお届けします。";
                lineMessageService.sendPushMessage(lineUserId, message);
                log.debug("ウェルカムメッセージ送信完了");
                
                log.info("LINE連携処理完了（友だち追加済み）:  userId={}, lineUserId={}", userId, lineUserId);
                return new LineIntegrationResult(true, true, lineUserId);
            } else {
                log. info("LINE連携処理完了（友だち未追加）: userId={}, lineUserId={}", userId, lineUserId);
                return new LineIntegrationResult(true, false, lineUserId);
            }
            
        } catch (Exception e) {
            log.error("LINE連携処理失敗: userId={}, error={}", userId, e.getMessage(), e);
            throw e;
        }
    }
    
    /**
     * LINE連携処理結果
     * 
     * <p>LINE連携処理の実行結果を保持するレコードクラスです。</p>
     * 
     * @param success 処理が正常に完了したかどうか
     * @param isFriend 友だち追加済みかどうか
     * @param lineUserId LINE User ID
     */
    public record LineIntegrationResult(
            boolean success,
            boolean isFriend,
            String lineUserId
    ) {}
}

package com.example. demo.service;

import java. util.Collections;

import org. springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework. http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import com.example. demo.config.LineProperties;
import com.example.demo.dto.LinePushMessageRequest;

import lombok.RequiredArgsConstructor;
import lombok.extern. slf4j.Slf4j;

/**
 * LINEメッセージ送信サービス
 */
@Slf4j
@Service
@RequiredArgsConstructor
public class LineMessageService {
    
    /** LINE設定プロパティ */
    private final LineProperties lineProperties;
    
    /** REST APIクライアント */
    private final RestTemplate restTemplate;
    
    /**
     * プッシュメッセージ送信
     * 
     * <p>LINE Push Message APIを呼び出し、指定されたユーザーにテキストメッセージを送信します。</p>
     * 
     * <h3>API仕様</h3>
     * <pre>
     * POST https://api.line.me/v2/bot/message/push
     * Authorization: Bearer {チャネルアクセストークン}
     * Content-Type: application/json
     * 
     * リクエストボディ: 
     * {
     *   "to": "{lineUserId}",
     *   "messages": [
     *     {
     *       "type":  "text",
     *       "text": "{message}"
     *     }
     *   ]
     * }
     * </pre>
     * @param lineUserId LINE User ID（送信先）
     * @param message 送信するメッセージ本文
     * @throws RuntimeException メッセージ送信に失敗した場合
     * 
     * @see LinePushMessageRequest
     */
    public void sendPushMessage(String lineUserId, String message) {
        log.debug("プッシュメッセージ送信開始: lineUserId={}", lineUserId);
        
        String url = lineProperties.getApi().getPushMessageUrl();
        
        HttpHeaders headers = new HttpHeaders();
        headers.setBearerAuth(lineProperties.getMessaging().getChannelAccessToken());
        headers.setContentType(MediaType. APPLICATION_JSON);
        
        LinePushMessageRequest.Message messageObj = LinePushMessageRequest. Message.builder()
                .type("text")
                .text(message)
                .build();
        
        LinePushMessageRequest requestBody = LinePushMessageRequest.builder()
                .to(lineUserId)
                .messages(Collections.singletonList(messageObj))
                .build();
        
        HttpEntity<LinePushMessageRequest> request = new HttpEntity<>(requestBody, headers);
        
        try {
            ResponseEntity<String> response = restTemplate.postForEntity(
                    url,
                    request,
                    String. class
            );
            
            if (response.getStatusCode() == HttpStatus.OK) {
                log.debug("プッシュメッセージ送信成功:  lineUserId={}", lineUserId);
            } else {
                log.error("メッセージ送信失敗: statusCode={}, lineUserId={}", 
                    response.getStatusCode(), lineUserId);
                throw new RuntimeException("メッセージ送信失敗: " + response.getStatusCode());
            }
        } catch (Exception e) {
            log.error("LINE Push Message API呼び出しエラー:  lineUserId={}, error={}", 
                lineUserId, e.getMessage());
            throw new RuntimeException("メッセージ送信エラー", e);
        }
    }
}

package com.example. demo.service;

import java. util.Collections;

import org. springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework. http.HttpStatus;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import com.example. demo.config.LineProperties;
import com.example.demo.dto.LinePushMessageRequest;

import lombok.RequiredArgsConstructor;
import lombok.extern. slf4j.Slf4j;

/**
 * LINEメッセージ送信サービス
 */
@Slf4j
@Service
@RequiredArgsConstructor
public class LineMessageService {
    
    /** LINE設定プロパティ */
    private final LineProperties lineProperties;
    
    /** REST APIクライアント */
    private final RestTemplate restTemplate;
    
    /**
     * プッシュメッセージ送信
     * 
     * <p>LINE Push Message APIを呼び出し、指定されたユーザーにテキストメッセージを送信します。</p>
     * 
     * <h3>API仕様</h3>
     * <pre>
     * POST https://api.line.me/v2/bot/message/push
     * Authorization: Bearer {チャネルアクセストークン}
     * Content-Type: application/json
     * 
     * リクエストボディ: 
     * {
     *   "to": "{lineUserId}",
     *   "messages": [
     *     {
     *       "type":  "text",
     *       "text": "{message}"
     *     }
     *   ]
     * }
     * </pre>
     * @param lineUserId LINE User ID（送信先）
     * @param message 送信するメッセージ本文
     * @throws RuntimeException メッセージ送信に失敗した場合
     * 
     * @see LinePushMessageRequest
     */
    public void sendPushMessage(String lineUserId, String message) {
        log.debug("プッシュメッセージ送信開始: lineUserId={}", lineUserId);
        
        String url = lineProperties.getApi().getPushMessageUrl();
        
        HttpHeaders headers = new HttpHeaders();
        headers.setBearerAuth(lineProperties.getMessaging().getChannelAccessToken());
        headers.setContentType(MediaType. APPLICATION_JSON);
        
        LinePushMessageRequest.Message messageObj = LinePushMessageRequest. Message.builder()
                .type("text")
                .text(message)
                .build();
        
        LinePushMessageRequest requestBody = LinePushMessageRequest.builder()
                .to(lineUserId)
                .messages(Collections.singletonList(messageObj))
                .build();
        
        HttpEntity<LinePushMessageRequest> request = new HttpEntity<>(requestBody, headers);
        
        try {
            ResponseEntity<String> response = restTemplate.postForEntity(
                    url,
                    request,
                    String. class
            );
            
            if (response.getStatusCode() == HttpStatus.OK) {
                log.debug("プッシュメッセージ送信成功:  lineUserId={}", lineUserId);
            } else {
                log.error("メッセージ送信失敗: statusCode={}, lineUserId={}", 
                    response.getStatusCode(), lineUserId);
                throw new RuntimeException("メッセージ送信失敗: " + response.getStatusCode());
            }
        } catch (Exception e) {
            log.error("LINE Push Message API呼び出しエラー:  lineUserId={}, error={}", 
                lineUserId, e.getMessage());
            throw new RuntimeException("メッセージ送信エラー", e);
        }
    }
}

package com.example.demo.dto;

import com.fasterxml.jackson.annotation.JsonProperty;

import lombok.Data;
import lombok.ToString;

@Data
@ToString
public class LineFriendshipResponse {
    
    @JsonProperty("friendFlag")
    private Boolean friendFlag;
}

package com.example.demo.dto;

import com.fasterxml.jackson.annotation.JsonProperty;

import lombok.Data;
import lombok.ToString;

@Data
@ToString
public class LineFriendshipResponse {
    
    @JsonProperty("friendFlag")
    private Boolean friendFlag;
}

package com.example.demo.dto;

import java.util.List;

import com.fasterxml.jackson. annotation.JsonProperty;

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;

@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@ToString
public class LinePushMessageRequest {
    
    @JsonProperty("to")
    private String to;
    
    @JsonProperty("messages")
    private List<Message> messages;
    
    @Data
    @Builder
    @NoArgsConstructor
    @AllArgsConstructor
    @ToString
    public static class Message {
        @JsonProperty("type")
        private String type;
        
        @JsonProperty("text")
        private String text;
    }
}

package com.example.demo.dto;

import java.util.List;

import com.fasterxml.jackson. annotation.JsonProperty;

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;

@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@ToString
public class LinePushMessageRequest {
    
    @JsonProperty("to")
    private String to;
    
    @JsonProperty("messages")
    private List<Message> messages;
    
    @Data
    @Builder
    @NoArgsConstructor
    @AllArgsConstructor
    @ToString
    public static class Message {
        @JsonProperty("type")
        private String type;
        
        @JsonProperty("text")
        private String text;
    }
}

package com.example.demo.dto;

import com.fasterxml.jackson.annotation.JsonProperty;

import lombok.Data;
import lombok.ToString;

@Data
@ToString
public class LineTokenResponse {
    
    @JsonProperty("access_token")
    private String accessToken;
    
    @JsonProperty("expires_in")
    private Integer expiresIn;
    
    @JsonProperty("id_token")
    private String idToken;
    
    @JsonProperty("refresh_token")
    private String refreshToken;
    
    @JsonProperty("scope")
    private String scope;
    
    @JsonProperty("token_type")
    private String tokenType;
}

package com.example.demo.dto;

import com.fasterxml.jackson.annotation.JsonProperty;

import lombok.Data;
import lombok.ToString;

@Data
@ToString
public class LineTokenResponse {
    
    @JsonProperty("access_token")
    private String accessToken;
    
    @JsonProperty("expires_in")
    private Integer expiresIn;
    
    @JsonProperty("id_token")
    private String idToken;
    
    @JsonProperty("refresh_token")
    private String refreshToken;
    
    @JsonProperty("scope")
    private String scope;
    
    @JsonProperty("token_type")
    private String tokenType;
}