fedilab-Android-App/app/src/fdroidcommon/java/app/fedilab/android/helper/PushHelper.java

package app.fedilab.android.helper;

import android.app.Activity;
import android.content.Context;
import android.database.sqlite.SQLiteDatabase;

import org.unifiedpush.android.connector.Registration;

import java.util.List;

import app.fedilab.android.client.Entities.Account;
import app.fedilab.android.jobs.ApplicationJob;
import app.fedilab.android.jobs.NotificationsSyncJob;
import app.fedilab.android.sqlite.AccountDAO;
import app.fedilab.android.sqlite.Sqlite;

import static app.fedilab.android.helper.BaseHelper.NOTIF_NONE;
import static app.fedilab.android.helper.BaseHelper.NOTIF_PUSH;
import static app.fedilab.android.helper.BaseHelper.liveNotifType;

public class PushHelper {

    public static void startStreaming(Context context) {
        int liveNotifications = liveNotifType(context);
        ApplicationJob.cancelAllJob(NotificationsSyncJob.NOTIFICATION_REFRESH);
        NotificationsSyncJob.schedule(false);
        switch (liveNotifications) {
            case NOTIF_PUSH:
                new Thread(() -> {
                    SQLiteDatabase db = Sqlite.getInstance(context.getApplicationContext(), Sqlite.DB_NAME, null, Sqlite.DB_VERSION).open();
                    List<Account> accounts = new AccountDAO(context, db).getPushNotificationAccounts();
                    ((Activity) context).runOnUiThread(() -> {
                        for (Account account : accounts) {
                            new Registration().registerAppWithDialog(context, account.getUsername() + "@" + account.getInstance());
                        }
                    });
                }).start();
                break;
            case NOTIF_NONE:
                new Registration().unregisterApp(context);
                break;
        }
    }
}