トピックベースのメッセージング

/**
 * セキュリティプロファイルをTopicBasedMessagingに登録するようADMにリクエストします。
 */
public void tbmRegistration(String clientSecret, String accessToken) throws Exception
{
    // メッセージのJSONペイロード表現。
    JSONObject payload = new JSONObject();

    // ヘッダーに指定されたaccessTokenを作成するために使用するclientSecret値を追加します。
    payload.put("clientSecret", clientSecret);


    // メッセージをJSONオブジェクトから文字列に変換します。
    String payloadString = payload.toString();

    // ベースURLを設定します。
    String admUrlTemplate = "https://api.amazon.com/v1/messaging/topic/registrations";

    URL admUrl = new URL(admUrlTemplate);

    // POSTリクエスト用のHTTPS接続を生成します。HTTP接続は
    // 行えません。
    HttpsURLConnection conn = (HttpsURLConnection) admUrl.openConnection();
    conn.setRequestMethod("POST");
    conn.setDoOutput(true);

    // コンテンツタイプを設定し、ヘッダーを受け取ります。
    conn.setRequestProperty("content-type", "application/json");
    conn.setRequestProperty("accept", "application/json");
    
    // ヘッダーとして認証トークンを追加します。
    conn.setRequestProperty("Authorization", "Bearer " + accessToken);

    // 接続の出力ストリームを取得し、メッセージペイロードを書き込みます。
    OutputStream os = conn.getOutputStream();
    os.write(payloadString.getBytes(), 0, payloadString.getBytes().length);
    os.flush();
    conn.connect();

    // 接続からレスポンスコードを取得します。
    int responseCode = conn.getResponseCode();

    // 失敗のレスポンスを受信したかどうか確認し、受信した場合は失敗の理由を取得します。
    if( responseCode != 200)
    {
        if( responseCode == 401 )
        {
            // レスポンスコード401を受信した場合は、アクセストークンの期限が切れていることを意味します。トークンを更新してください。
            // このリクエストは再試行できます。
        }

        String errorContent = parseResponse(conn.getErrorStream());
        throw new RuntimeException(String.format("ERROR: The request to register the security profile with TBM has failed with a " +
                                         "%d response code, with the following message: %s",
                                         responseCode, errorContent));
    }
    else
    {
        // リクエストに成功しました。レスポンスには、TopicBasedMessagingに登録されているセキュリティプロファイルが記載されています。
        String responseContent = parseResponse(conn.getInputStream());
        JSONObject parsedObject = new JSONObject(responseContent);

        String message = parsedObject.getString("message");
        
        // メッセージからセキュリティプロファイルを抽出して、それがリクエストヘッダーで使用されている
        // accessTokenの作成に使用したものと同じかどうかを確認できます。
        
    }

}

private String parseResponse(InputStream in) throws Exception
{
    // 入力ストリームから読み取り、文字列に変換します。
    InputStreamReader inputStream = new InputStreamReader(in);
    BufferedReader buff = new BufferedReader(inputStream);

    StringBuilder sb = new StringBuilder();
    String line = buff.readLine();
    while(line != null)
   {
      sb.append(line);
      line = buff.readLine();
    }

    return sb.toString();
}

final ADM adm = new ADM(this);
// subscribeToTopic()は非同期です。subscribeToTopic()が成功した場合、
// アプリはonSubscribe()コールバックを介して通知を受け取ります。
// subscribeToTopic()が失敗した場合はonSubscribeError()になります。
adm.subscribeToTopic("weather");

final ADM adm = new ADM(this);
// unsubscribeFromTopic()は非同期です。unsubscribeFromTopic()が成功した場合、
// アプリはonUnsubscribe()コールバックを介して通知を受け取ります。
// unsubscribeFromTopic()が失敗した場合はonUnsubscribeError()になります。
adm.unsubscribeFromTopic("weather");

try {
    Log.d(TAG, "subscribeToTopic: Trying to subscribe to topic: " + topic);
    adm.subscribeToTopic(topic);
} catch (Error e) {
    Log.d(TAG, "subscribeToTopic: Error Caught and Error Message is " + e.getMessage());
}

public class MyADMMessageHandler extends ADMMessageHandlerJobBase{
    @Override
    protected void onSubscribe(final Context context, final String topic) {
        // サブスクリプションが成功した場合のロジックをここに記述します
        // 例：ユーザーに通知する、
        // サーバーに詳細情報を送信する
    }

    @Override
    protected void onSubscribeError(final Context context, final String topic, final String errorId) {
        // エラーIDに基づいてサブスクリプションがエラーになった場合のロジックをここに記述します
    }

    @Override
    protected void onUnsubscribe(final Context context, final String topic) {
        // サブスクリプション解除が成功した場合のロジックをここに記述します
        // 例：ユーザーに通知する、
        // サーバーに詳細情報を送信する
    }

    @Override
    protected void onUnsubscribeError(final Context context, final String topic, final String errorId) {
        // エラーIDに基づいてサブスクリプション解除がエラーになった場合のロジックをここに記述します
    }

}

/**
 * 特定のトピックをサブスクライブしているアプリインスタンスにメッセージを配信するようADMにリクエストします。
 */
public void sendMessageToTopic(String topic, String accessToken) throws Exception
{
    // メッセージのJSONペイロード表現。
    JSONObject payload = new JSONObject();

    // データメッセージ内容のキーと値のペアを定義し、メッセージペイロードに
    // 追加します。
    JSONObject data = new JSONObject();
    data.put("firstKey", "firstValue");
    data.put("secondKey", "secondValue");
    payload.put("data", data);
    
    // 通知メッセージ内容のキーと値のペアを定義し、メッセージペイロードに
    // 追加します。
    // 通知メッセージでは、事前に定義されたキーと値のペアのみを使用できます。
    // ADM通知でサポートされているキーと値のペアについては、ドキュメント
    //（https://developer.amazon.com/ja/docs/adm/message-types.html#notification）を参照してください。
    JSONObject notification = new JSONObject();
    notification.put("title", "ADM Message Notification");
    notification.put("body", "We have a new offer for you!");
    payload.put("notification", notification);

    // 連結キーを追加します。アプリインスタンスに対して、同じ連結キーを持つ
    // 複数のメッセージの配信が保留になっている場合、ADMでは最後に追加されたメッセージの
    // 配信が試行されます。
    payload.put("consolidationKey", "ADM_Enqueue_Sample");

    // メッセージに、expiresAfter値（1日間）を追加します。ターゲットのアプリインスタンスが
    // expiresAfter期間内にオンラインにならなかった場合、メッセージは配信されません。
    payload.put("expiresAfter", 86400);

    // メッセージにpriorityを追加します。priorityの値によって、デバイスがDoze／アイドルモードの場合に
    // メッセージが配信されるかどうかが決まります。
    payload.put("priority", "high");
    
    // メッセージ本文にトピックを追加します。これを使用してメッセージをアプリインスタンスに配信します。
    payload.put("topic", topic);


    // メッセージをJSONオブジェクトから文字列に変換します。
    String payloadString = payload.toString();

    // ベースURLを設定します
    String admUrlTemplate = "https://api.amazon.com/v1/messaging/topic/messages";

    URL admUrl = new URL(admUrlTemplate);

    // POSTリクエスト用のHTTPS接続を生成します。HTTP接続は
    // 行えません。
    HttpsURLConnection conn = (HttpsURLConnection) admUrl.openConnection();
    conn.setRequestMethod("POST");
    conn.setDoOutput(true);

    // コンテンツタイプを設定し、ヘッダーを受け取ります。
    conn.setRequestProperty("content-type", "application/json");
    conn.setRequestProperty("accept", "application/json");
    conn.setRequestProperty("X-Amzn-Type-Version", "com.amazon.device.messaging.ADMMessage@1.0");
    conn.setRequestProperty("X-Amzn-Accept-Type", "com.amazon.device.messaging.ADMSendResult@1.0");

    // ヘッダーとして認証トークンを追加します。
    conn.setRequestProperty("Authorization", "Bearer " + accessToken);

    // 接続の出力ストリームを取得し、メッセージペイロードを書き込みます。
    OutputStream os = conn.getOutputStream();
    os.write(payloadString.getBytes(), 0, payloadString.getBytes().length);
    os.flush();
    conn.connect();

    // 接続からレスポンスコードを取得します。
    int responseCode = conn.getResponseCode();

    // 失敗のレスポンスを受信したかどうか確認し、受信した場合は失敗の理由を取得します。
    if( responseCode != 200)
    {
        if( responseCode == 401 )
        {
            // レスポンスコード401を受信した場合は、アクセストークンの期限が切れていることを意味します。トークンを更新してください。
            // このリクエストは再試行できます。
        }

        String errorContent = parseResponse(conn.getErrorStream());
        throw new RuntimeException(String.format("ERROR: The send message to the topic %s request failed with a " +
                                         "%d response code, with the following message: %s",
                                         topic, responseCode, errorContent));
    }
    else
    {
        // リクエストに成功しました。レスポンスに、送信メッセージと 
        // その送信先のトピックに関連付けられたmessageIdが記載されます。

        String responseContent = parseResponse(conn.getInputStream());
        JSONObject parsedObject = new JSONObject(responseContent);

        String messageId = parsedObject.getString("messageId");
        // メッセージがアプリインスタンスに配信されない場合、messageIdをADMに通知して
        // 問題のトラブルシューティングを行えます。
}

private String parseResponse(InputStream in) throws Exception
{
    // 入力ストリームから読み取り、文字列に変換します。
    InputStreamReader inputStream = new InputStreamReader(in);
    BufferedReader buff = new BufferedReader(inputStream);

    StringBuilder sb = new StringBuilder();
    String line = buff.readLine();
    while(line != null)
   {
      sb.append(line);
      line = buff.readLine();
    }

    return sb.toString();
}