画面フローを使ってHTTPコールアウトを実装してみよう

public class ApiIntegration {

    // 入力パラメータ（画面フロー→Apex）
    public class FlowInput {
        @InvocableVariable (required = true)
        public String accountId;
    }

    // 出力パラメータ（Apex→画面フロー）
    public class FlowOutput {
        // API連携成功フラグ
        @InvocableVariable
        public Boolean isSuccess;

        // 画面フロー上に表示するレスポンス値
        @InvocableVariable
        public Integer userId;
        @InvocableVariable
        public Integer id;
        @InvocableVariable
        public String title;
        @InvocableVariable
        public Boolean completed;

        // 失敗した時、画面に表示するメッセージ
        @InvocableVariable
        public String message;
    }

    @InvocableMethod (label = 'ApiIntegration')
    public static List<FlowOutput> apiIntegration(List<FlowInput> flowInputs) {
        // フロー上での出力パラメータ用リストを準備
        List<FlowOutput> results = new List<FlowOutput>();
        FlowOutput result = new FlowOutput();

        try {
            // レスポンスを受け取るための内部クラスのインスタンスを生成
            MyJsonData apiResponseData = new MyJsonData();

            // 入力パラメータから1つ目の取引先レコードIdを取得
            String accountId = flowInputs[0].accountId;

            // APIコールアウトを実行
            String responseBody = ApiService.callPublicApi();
            
            // JSONレスポンスの分解とオブジェクトへのマッピング
            apiResponseData = deserializeJSON(responseBody);

            // 分解した結果を出力パラメータに設定
            if (apiResponseData != null) {
                result.isSuccess = true;
                result.userId = apiResponseData.userId;
                result.id = apiResponseData.id;
                result.title = apiResponseData.title;
                result.completed = apiResponseData.completed;
            } else {
                result.isSuccess = false;
                result.message = 'APIレスポンスの分解に失敗しました。';
            }

        } catch (Exception e) {
            result.isSuccess = false;
            result.message = 'API連携中に予期せぬエラーが発生しました：' + e.getMessage();
        }

        results.add(result); // 処理結果をリストに追加して返す
        return results;
    }

    // JSONの構造に対応する内部クラスを定義
    private class MyJsonData {
        public Integer userId;
        public Integer id;
        public String title;
        public Boolean completed;
    }

    // JSON列分解メソッド
    private static MyJsonData deserializeJSON(String responseBody) {
        try {
            return (MyJsonData) JSON.deserializeStrict(responseBody, MyJsonData.class);
        } catch (JSONException e) {
            System.debug('JSONデシリアライズエラー: ' + e.getMessage());
            return null;
        }
    }
    
}

public class ApiService {

    public static String callPublicApi() {
        // HttpRequestオブジェクトを作成
        HttpRequest req = new HttpRequest();

        // エンドポイントURLを設定 (今回はJSONPlaceholderのサンプルAPIを使用)
        req.setEndpoint('https://jsonplaceholder.typicode.com/todos/1');
        // HTTPメソッドを設定 (GET)
        req.setMethod('GET');
        // タイムアウトをミリ秒で設定 (例: 10秒)
        req.setTimeout(10000);

        // Httpオブジェクトを作成
        Http http = new Http();
        HttpResponse res;

        try {
            // APIにリクエストを送信し、レスポンスを取得
            res = http.send(req);
            // レスポンスのステータスコードを確認
            if (res.getStatusCode() == 200) {
                // 成功した場合、レスポンスのボディ（JSON文字列）を返す
                return res.getBody();                
            } else {
                // エラーの場合、ステータスコードとメッセージを返す
                return 'callPublicApi Error: API request failed with status code ' + res.getStatusCode() + ' - ' + res.getStatus();
            }
        } catch (System.CalloutException e) {
            // コールアウト例外（接続できない、タイムアウトなど）をキャッチ
            // 呼び出し元で処理できるよう、例外を再スローするか、エラーメッセージを返す
            throw new AuraHandledException('APIへの接続に失敗しました: ' + e.getMessage());
        }
    }
    
}