85 lines
3.4 KiB
Java
85 lines
3.4 KiB
Java
package org.joinmastodon.android;
|
|
|
|
import android.content.Context;
|
|
import android.util.Log;
|
|
|
|
import org.jetbrains.annotations.NotNull;
|
|
import org.joinmastodon.android.api.MastodonAPIController;
|
|
import org.joinmastodon.android.api.session.AccountSession;
|
|
import org.joinmastodon.android.api.session.AccountSessionManager;
|
|
import org.joinmastodon.android.model.Notification;
|
|
import org.joinmastodon.android.model.PaginatedResponse;
|
|
import org.unifiedpush.android.connector.MessagingReceiver;
|
|
|
|
import java.util.List;
|
|
|
|
import me.grishka.appkit.api.Callback;
|
|
import me.grishka.appkit.api.ErrorResponse;
|
|
|
|
public class UnifiedPushNotificationReceiver extends MessagingReceiver{
|
|
private static final String TAG="UnifiedPushNotificationReceiver";
|
|
|
|
public UnifiedPushNotificationReceiver() {
|
|
super();
|
|
}
|
|
|
|
@Override
|
|
public void onNewEndpoint(@NotNull Context context, @NotNull String endpoint, @NotNull String instance) {
|
|
// Called when a new endpoint be used for sending push messages
|
|
Log.d(TAG, "onNewEndpoint: New Endpoint " + endpoint + " for "+ instance);
|
|
AccountSession account = AccountSessionManager.getInstance().tryGetAccount(instance);
|
|
if (account != null)
|
|
account.getPushSubscriptionManager().registerAccountForPush(null, endpoint);
|
|
}
|
|
|
|
@Override
|
|
public void onRegistrationFailed(@NotNull Context context, @NotNull String instance) {
|
|
// called when the registration is not possible, eg. no network
|
|
Log.d(TAG, "onRegistrationFailed: " + instance);
|
|
//re-register for gcm
|
|
AccountSession account = AccountSessionManager.getInstance().tryGetAccount(instance);
|
|
if (account != null)
|
|
account.getPushSubscriptionManager().registerAccountForPush(null);
|
|
}
|
|
|
|
@Override
|
|
public void onUnregistered(@NotNull Context context, @NotNull String instance) {
|
|
// called when this application is unregistered from receiving push messages
|
|
Log.d(TAG, "onUnregistered: " + instance);
|
|
//re-register for gcm
|
|
AccountSession account = AccountSessionManager.getInstance().tryGetAccount(instance);
|
|
if (account != null)
|
|
account.getPushSubscriptionManager().registerAccountForPush(null);
|
|
}
|
|
|
|
@Override
|
|
public void onMessage(@NotNull Context context, @NotNull byte[] message, @NotNull String instance) {
|
|
// Called when a new message is received. The message contains the full POST body of the push message
|
|
AccountSession account = AccountSessionManager.getInstance().tryGetAccount(instance);
|
|
|
|
if (account == null)
|
|
return;
|
|
|
|
//this is stupid
|
|
// Mastodon stores the info to decrypt the message in the HTTP headers, which are not accessible in UnifiedPush,
|
|
// thus it is not possible to decrypt them. SO we need to re-request them from the server and transform them later on
|
|
// The official uses fcm and moves the headers to extra data, see
|
|
// https://github.com/mastodon/webpush-fcm-relay/blob/cac95b28d5364b0204f629283141ac3fb749e0c5/webpush-fcm-relay.go#L116
|
|
// https://github.com/tuskyapp/Tusky/pull/2303#issue-1112080540
|
|
account.getCacheController().getNotifications(null, 1, false, false, true, new Callback<>(){
|
|
@Override
|
|
public void onSuccess(PaginatedResponse<List<Notification>> result){
|
|
result.items
|
|
.stream()
|
|
.findFirst()
|
|
.ifPresent(value->MastodonAPIController.runInBackground(()->new PushNotificationReceiver().notifyUnifiedPush(context, instance, value)));
|
|
}
|
|
|
|
@Override
|
|
public void onError(ErrorResponse error){
|
|
//professional error handling
|
|
}
|
|
});
|
|
}
|
|
}
|