これは何
AWS Amplifyを用いて、ログイン、画像アップロード、push通知シリーズ第三弾の投稿です。
第二弾の投稿は以下をご覧ください。
第二弾ではCognitoから取得したcredentialを利用してS3に画像をアップロードするところまで終了しました。
今回は、S3に画像をアップロードしたタイミングで、push通知配信先に登録されている全てのデバイスに対してpush通知を送信する機能を追加したいと思います。
前回に引き続きAmplifyTutorialアプリに機能を追加していきます。
firebaseプロジェクトを作成
Androidでpush通知を実現するためには、Firebase Cloud Messagingというサービスにpush通知を依頼する必要があります。
そのためにまずは、アプリに固有のfirebaseプロジェクトを作成しましょう。firebaseプロジェクトの作成方法については以下のサイトが参考になります。
Firebase プロジェクトについて理解する
Android プロジェクトに Firebase を追加する
全ての設定が終了した後、アプリをビルドすると、Firebaseコンソール画面のアナリティクスのDashboadにてエンドポイントの情報が登録されていることが確認できます。
AmplifyにAnalytics機能を追加
AmplifyにAnalyticsカテゴリを追加すると、AWSのバックエンドにPinpointというサービスのリソースが作成されます。
AWSの公式ドキュメントではPinpointを以下のように説明しています。
Amazon Pinpoint は、複数のメッセージングチャネルをまたがってお客様とやり取りするための AWS 製品です。Amazon Pinpoint を使用して、プッシュ通知、E メール、SMS テキストメッセージ、または音声メッセージを送信できます。
AWS Simple Notification ServcieもAWSのプッシュ通知配信サービスとして知られていますが、Pinpointはメッセージテンプレートや、配信スケジュール、セグメント、などユーザーにメッセージを送るためのより高度な機能が追加されています。
AmplifyにAnalytics機能を追加するために以下のコマンドを実行しましょう。
$ amplify add analytics
Using service: Pinpoint, provided by: awscloudformation
? Provide your pinpoint resource name: amplifytutorial
Adding analytics would add the Auth category to the project if not already added.
? Apps need authorization to send analytics events. Do you want to allow guests and unauthenticated users to send analytics events? (we recommend you allow this when getting started) Yes
次に、AmplifyにNotificationカテゴリを追加し、FCMをpush通知先として設定します。
ApiKeyの取得方法は以下のサイトが参考になります。
Android SDK - Setting Up FCM/GCM for Push Notifications
以下のコマンドを実行しましょう。
$ amplify add notifications
? Choose the push notification channel to enable. FCM
? ApiKey <server key>
変更をクラウド側にpushします。
$ amplify push
Pinpointのtokyoリージョンでのサービスが、この記事の投稿時点ではまだ開始されていないので、us-west-2にリソースが作成されると思います。
以下のコマンドでコンソールを開くことができます。
$ amplify analytics console
Android側の実装
次はandroid側の実装に移ります。
gradleに依存関係を追加
適当なライブラリを依存関係に含めます。
dependencies {
implementation 'com.amplifyframework:aws-analytics-pinpoint:0.9.0'
implementation "com.amazonaws:aws-android-sdk-pinpoint:$aws_sdk_version"
implementation 'com.google.firebase:firebase-core:17.2.0'
implementation 'com.google.firebase:firebase-messaging:20.1.0'
}
AndroidManifestファイルに設定を追加
AndroidManifestファイルにServiceとReceiverを追加します。
ServiceはFCMから送られてきたメッセージを受け取るための、Receiverはアプリがバックグラウンド状態時にpush通知がタップされた場合にアプリが起動されるためのものです。
<application>
<service
android:name=".PushListenerService"
android:exported="false">
<intent-filter>
<action android:name="com.google.firebase.MESSAGING_EVENT" />
</intent-filter>
</service>
<receiver
android:name="com.amazonaws.mobileconnectors.pinpoint.targeting.notification.PinpointNotificationReceiver"
android:exported="false">
<intent-filter>
<action android:name="com.amazonaws.intent.fcm.NOTIFICATION_OPEN" />
</intent-filter>
</receiver>
</application>
AWSUtilsクラスを変更
AWSUtilsクラスを変更し、AmplifyにAmazonPipointPluginを追加します。
また後々、PushListenerServiceクラスからPinpointManagerにアクセスする必要が出てくるので、そのためのメソッドも追加します。
変更後のAWSUtilsクラスは以下の通りです。
package com.example.amplifytutorial
import android.content.Context
import android.util.Log
import com.amazonaws.mobile.client.AWSMobileClient
import com.amazonaws.mobile.client.Callback
import com.amazonaws.mobile.client.UserStateDetails
import com.amazonaws.mobile.config.AWSConfiguration
import com.amazonaws.mobileconnectors.pinpoint.PinpointConfiguration
import com.amazonaws.mobileconnectors.pinpoint.PinpointManager
import com.amplifyframework.analytics.pinpoint.AmazonPinpointAnalyticsPlugin
import com.amplifyframework.core.Amplify
import com.amplifyframework.storage.s3.AWSS3StoragePlugin
import java.util.concurrent.CountDownLatch
import java.util.concurrent.TimeUnit
object AWSUtils {
private const val INITIALIZATION_TIMEOUT_MS = 2000L
private const val TAG = "AWSUtils"
private val LOCK = Object()
private var configured = false
private var pinpointManager: PinpointManager? = null
fun initAWSMobileClient(applicationContext: Context) {
synchronized(LOCK) {
if (configured) {
Log.d(TAG, "already configured")
return
}
val mobileClientLatch = CountDownLatch(1)
AWSMobileClient.getInstance()
.initialize(applicationContext, object : Callback<UserStateDetails> {
override fun onResult(userStateDetails: UserStateDetails?) {
mobileClientLatch.countDown()
}
override fun onError(e: Exception?) {
Log.e(TAG, "Initialization error.", e)
}
})
try {
if (!mobileClientLatch.await(
INITIALIZATION_TIMEOUT_MS,
TimeUnit.MILLISECONDS
)
) {
throw Exception("Failed to initialize mobile client.")
}
} catch (exception: Exception) {
Log.d(TAG, "${exception.message}")
}
configured = true
}
}
fun configureAmplifyPlugin(applicationContext: Context) {
try {
Amplify.addPlugin(AWSS3StoragePlugin())
Amplify.addPlugin(AmazonPinpointAnalyticsPlugin())
Amplify.configure(applicationContext)
Log.i(TAG, "aws mobile client init done!")
} catch (e: Throwable) {
e.printStackTrace()
Log.e(TAG, "initialize onResult exception: ${e.message}")
}
Amplify.Analytics.recordEvent("amplfiy configured")
}
fun getPinpointManager(applicationContext: Context): PinpointManager {
pinpointManager?.let {
return it
}
initAWSMobileClient(applicationContext)
val pinpointConfig = PinpointConfiguration(
applicationContext,
AWSMobileClient.getInstance(),
AWSConfiguration(applicationContext)
)
val pm = PinpointManager(pinpointConfig)
return pm.also { pinpointManager = it }
}
}
SplashActivityを変更
アプリを起動すると、firebaseにデバイスごとのinstance idとtokenが作成されます。
PinpointからPush通知を配信するためにはtokenをPinpointに登録する必要があるのでその処理をSplashActivityに追加します。
package com.example.amplifytutorial
import android.content.Intent
import androidx.appcompat.app.AppCompatActivity
import android.os.Bundle
import android.util.Log
import com.amazonaws.mobileconnectors.s3.transferutility.TransferNetworkLossHandler
import com.google.firebase.iid.FirebaseInstanceId
import kotlinx.coroutines.*
class SplashActivity : AppCompatActivity(), CoroutineScope by MainScope() {
companion object {
const val TAG = "SplashActivity"
}
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_splash)
initializeAWS()
}
override fun onDestroy() {
super.onDestroy()
cancel()
}
private fun initializeAWS() {
launch(Dispatchers.Default) {
AWSUtils.initAWSMobileClient(applicationContext)
AWSUtils.configureAmplifyPlugin(applicationContext)
val pinpointManager = AWSUtils.getPinpointManager(applicationContext)
TransferNetworkLossHandler.getInstance(applicationContext)
FirebaseInstanceId.getInstance().instanceId.addOnCompleteListener { task ->
if (!task.isSuccessful) {
Log.e(TAG, "getInstanceId failed", task.exception)
}
task.result?.let {
val id = it.id
val token = it.token
Log.d(TAG, "id: $id")
Log.d(TAG, "token: $token")
pinpointManager.notificationClient.registerDeviceToken(token)
}
val intent = Intent(this@SplashActivity, MainActivity::class.java)
startActivity(intent)
}
}
}
}
PushListenerServiceクラスを作成
PushListenerServiceを新しく作成し、PushListenerServie.ktを以下のように変更します。
package com.example.amplifytutorial
import android.app.NotificationChannel
import android.app.NotificationManager
import android.content.Context
import android.os.Build
import android.util.Log
import androidx.core.app.NotificationCompat
import androidx.core.app.NotificationManagerCompat
import com.amazonaws.mobileconnectors.pinpoint.targeting.notification.NotificationClient
import com.amazonaws.mobileconnectors.pinpoint.targeting.notification.NotificationClient.CampaignPushResult
import com.amazonaws.mobileconnectors.pinpoint.targeting.notification.NotificationDetails
import com.google.firebase.messaging.FirebaseMessagingService
import com.google.firebase.messaging.RemoteMessage
class PushListenerService : FirebaseMessagingService() {
companion object {
const val TAG = "PushListenerService"
const val CHANNEL_ID = "Default Channel"
const val NOTIFICATION_ID = 1
const val TITLE_KEY = "pinpoint.notification.title"
const val BODY_KEY = "pinpoint.notification.body"
}
// tokenが更新された場合、それをPinpointに通知する必要がある。
override fun onNewToken(token: String) {
super.onNewToken(token)
Log.d(TAG, "Registering push notifications token: $token")
AWSUtils.getPinpointManager(applicationContext)
.notificationClient.registerDeviceToken(token)
}
// Pinpointから送られてくるメッセージはnotificationではなくdata以下に格納されているため、
// アプリがバックグランドでもフォアグラウンドpush通知処理を自分で書かなければならない。
override fun onMessageReceived(remoteMessage: RemoteMessage) {
super.onMessageReceived(remoteMessage)
Log.d(TAG, "Message: ${remoteMessage.data}")
val notificationClient = AWSUtils.getPinpointManager(applicationContext).notificationClient
val notificationDetails = NotificationDetails.builder()
.from(remoteMessage.from)
.mapData(remoteMessage.data)
.intentAction(NotificationClient.FCM_INTENT_ACTION)
.build()
val pushResult =
notificationClient.handleCampaignPush(notificationDetails)
if (CampaignPushResult.NOT_HANDLED != pushResult) {
if (CampaignPushResult.APP_IN_FOREGROUND == pushResult) {
// アプリがforegroundで実行されていた場合は自分でnotification処理を書かなければならない
createNotification(remoteMessage.data)
}
return
}
}
private fun createNotification(data: Map<String, String>) {
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
val name = CHANNEL_ID
val descriptionText = "サーバーからの通知"
val importance = NotificationManager.IMPORTANCE_DEFAULT
val channel = NotificationChannel(CHANNEL_ID, name, importance).apply {
description = descriptionText
}
val notificationManager: NotificationManager =
getSystemService(Context.NOTIFICATION_SERVICE) as NotificationManager
notificationManager.createNotificationChannel(channel)
}
val notification = NotificationCompat.Builder(applicationContext, CHANNEL_ID)
.setContentTitle(data[TITLE_KEY])
.setStyle(NotificationCompat.BigTextStyle().bigText(data[BODY_KEY]))
.setSmallIcon(R.mipmap.ic_launcher)
.setPriority(NotificationCompat.PRIORITY_DEFAULT)
.build()
NotificationManagerCompat.from(this).notify(NOTIFICATION_ID, notification)
}
}
amplifyconfiguration.jsonを修正。
ここで一度アプリをビルドしてみてください。
ビルド出来れば問題ありませんが、当ブログ運営者の環境では以下のようなエラーを出力してクラッシュしました。
E/AWSUtils: initialize onResult exception: Attempt to invoke virtual method 'org.json.JSONObject org.json.JSONObject.getJSONObject(java.lang.String)' on a null object reference
E/AndroidRuntime: FATAL EXCEPTION: DefaultDispatcher-worker-2
Process: com.example.amplifytutorial, PID: 8440
java.lang.IllegalStateException: This category is not yet configured.Make sure you added it with Amplify.addPlugin and then called Amplify.config
at com.amplifyframework.core.category.Category.getSelectedPlugin(Category.java:137)
at com.amplifyframework.analytics.AnalyticsCategory.recordEvent(AnalyticsCategory.java:84)
at com.example.amplifytutorial.AWSUtils.configureAmplifyPlugin(AWSUtils.kt:73)
at com.example.amplifytutorial.SplashActivity$initializeAWS$1.invokeSuspend(SplashActivity.kt:34)
at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
at kotlinx.coroutines.DispatchedTask.run(Dispatched.kt:241)
at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:594)
at kotlinx.coroutines.scheduling.CoroutineScheduler.access$runSafely(CoroutineScheduler.kt:60)
at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:740)
いままで説明を省略していたのですが、amplifyはAWSのバックエンドにアクセスするための設定をres/rawディレクトリ以下に格納してます。
どうやら、ここで設定されているjsonオブジェクトに対して存在しないキーでアクセスしようとしているため、pluginの初期化が上手く出来ていないようです。
アプリがビルドできるようにamplifyconfigure.jsonを以下のように書き換えます。
- "awsPinpointAnalyticsPlugin": {
+ "amazonPinpointAnalyticsPlugin": {
amplify-android-sdkはまだプレビューですので、こういったバグは他の場所にもあるかもしれないですね。
Lamdba関数を作成
これでAndroid側の実装は全て終了です。
あとは、Pinpointにpush通知を依頼するlamdba関数を作成するだけです。
今回は簡略化のため、S3に任意のオブジェクトが作成された場合に、全てのエンドポイントに対してpush通知を送信するとさせていただきます。
またlamdba関数はnode.jsで作成します。
AWS Lamdbaのwebコンソールを開き、以下の設定でlamdba関数を作成しましょう。
| 項目 | 内容 |
|---|---|
| 関数名 | AmplifyTutorialPushNotification |
| ランタイム | Node.js 12.x |
S3のWebコンソール画面のプロパティでlamdba関数とeventを紐付けます。
| 項目 | 内容 |
|---|---|
| 名前 | ImageUploadEvent |
| イベント | すべてのオブジェクト作成イベント |
| 送信先 | Lamdba関数 |
| Lamdba | AmplifyTutorialPushNotification |
Lamdba関数がPinpointにアクセスできるようにiamロールにポリシーを付け加えます。
{
"Version": "2012-10-17",
"Statement": [
{
"Sid": "VisualEditor0",
"Effect": "Allow",
"Action": "mobiletargeting:CreateCampaign",
"Resource": "arn:aws:mobiletargeting:<region>:<account id>:apps/<app id>"
}
]
}
今回はPinpointのWebコンソールであらかじめSegmentを作成しておきます。
コンソール画面のSegmentsからCreate Segmentを選択し、NameにAllUsersを入力し、他は初期設定のままで作成します。
javascriptでpinpointにpush通知を依頼する処理を書き、アップロードします。
segment idは以下のコマンドで取得できます。
$ aws pinpoint get-segments --region <region> --application-id <app id>
javascriptコードは以下の通りです。
var AWS = require("aws-sdk");
var pinpoint = new AWS.Pinpoint({ region: "us-west-2" });
var params = {
ApplicationId: "<project id>",
WriteCampaignRequest: {
MessageConfiguration: {
ADMMessage: {
Action: "OPEN_APP",
Body: "",
Title: "message from lamdba"
},
APNSMessage: {
Action: "OPEN_APP",
Body: "",
Title: "message from lamdba"
},
BaiduMessage: {
Action: "OPEN_APP",
Body: "",
Title: "message from lamdba"
},
GCMMessage: {
Action: "OPEN_APP",
Body: "",
Title: "message from lamdba"
}
},
Name: "Campaign form lambda",
Schedule: {
IsLocalTime: false,
StartTime: "IMMEDIATE",
Timezone: "UTC"
},
SegmentId: "<segment id>",
SegmentVersion: 1
}
};
function formatString(date, format) {
format = format.replace(/YYYY/, date.getFullYear());
format = format.replace(/MM/, date.getMonth() + 1);
format = format.replace(/DD/, date.getDate());
format = format.replace(/hh/, date.getHours());
format = format.replace(/mm/, date.getMinutes());
format = format.replace(/ss/, date.getSeconds());
return format;
}
exports.handler = async event => {
let s3 = event["Records"][0]["s3"];
let bucketName = s3["bucket"]["name"];
let date = formatString(new Date(), "YYYY/MM/DD hh:mm:ss");
let body = `${date}\nバケット ${bucketName} 内に、ファイルが新しく作成されました。`;
params["WriteCampaignRequest"]["MessageConfiguration"]["GCMMessage"][
"Body"
] = body;
let request = pinpoint.createCampaign(params);
await request.promise();
const response = {
statusCode: 200
};
return response;
};
デモ
これで、画像をアップロードしたタイミングでpush通知が届くようになりました。
実際にアプリを起動して、写真を撮影し、S3へアップロードしてみてください。
バケット内にオブジェクトが作成されたというメッセージが届くかと思います。
まとめ
駆け足ではありましたが以上で、AmplifyとAndroidでログインとファイル保存とPush通知のtutorialシリーズは終了です。
amplify-android-sdk自体はまだ発表されて間もないので、これから様々な機能が追加されていくことに期待したいですね。
今後は、Pinpointの各機能をより深く掘り下げていけたらなと考えいています。
自分はまだandroidアプリもawsも知識不足なので、至るところにお見苦しい点があったかと思いますが、最後まで読んで頂き本当にありがとうございました。