package fr.gouv.etalab.mastodon.services; /* Copyright 2017 Thomas Schneider * * This file is a part of Mastalab * * This program is free software; you can redistribute it and/or modify it under the terms of the * GNU General Public License as published by the Free Software Foundation; either version 3 of the * License, or (at your option) any later version. * * Mastalab is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even * the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General * Public License for more details. * * You should have received a copy of the GNU General Public License along with Mastalab; if not, * see . */ import android.app.Service; import android.content.Context; import android.content.Intent; import android.content.SharedPreferences; import android.database.sqlite.SQLiteDatabase; import android.graphics.Bitmap; import android.graphics.BitmapFactory; import android.os.Bundle; import android.os.Handler; import android.os.IBinder; import android.os.Looper; import android.os.SystemClock; import android.support.annotation.Nullable; import android.support.v4.content.LocalBroadcastManager; import com.bumptech.glide.Glide; import com.bumptech.glide.load.DataSource; import com.bumptech.glide.load.engine.GlideException; import com.bumptech.glide.request.RequestListener; import com.bumptech.glide.request.target.SimpleTarget; import com.bumptech.glide.request.target.Target; import com.bumptech.glide.request.transition.Transition; import org.json.JSONException; import org.json.JSONObject; import java.io.BufferedInputStream; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.Authenticator; import java.net.HttpURLConnection; import java.net.InetSocketAddress; import java.net.PasswordAuthentication; import java.net.Proxy; import java.net.URL; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import javax.net.ssl.HttpsURLConnection; import fr.gouv.etalab.mastodon.R; import fr.gouv.etalab.mastodon.activities.BaseMainActivity; import fr.gouv.etalab.mastodon.activities.MainActivity; import fr.gouv.etalab.mastodon.client.API; import fr.gouv.etalab.mastodon.client.Entities.Account; import fr.gouv.etalab.mastodon.client.Entities.Notification; import fr.gouv.etalab.mastodon.client.Entities.Status; import fr.gouv.etalab.mastodon.client.TLSSocketFactory; import fr.gouv.etalab.mastodon.helper.Helper; import fr.gouv.etalab.mastodon.sqlite.AccountDAO; import fr.gouv.etalab.mastodon.sqlite.Sqlite; import static fr.gouv.etalab.mastodon.helper.Helper.INTENT_ACTION; import static fr.gouv.etalab.mastodon.helper.Helper.INTENT_TARGETED_ACCOUNT; import static fr.gouv.etalab.mastodon.helper.Helper.NOTIFICATION_INTENT; import static fr.gouv.etalab.mastodon.helper.Helper.PREF_KEY_ID; import static fr.gouv.etalab.mastodon.helper.Helper.notify_user; /** * Created by Thomas on 29/11/2017. * Manage service for streaming api and new notifications */ public class LiveNotificationService extends Service { protected Account account; private boolean stop = false; private static HashMap isRunning = new HashMap<>(); private Proxy proxy; public void onCreate() { super.onCreate(); } static { Helper.installProvider(); } @Override public int onStartCommand(Intent intent, int flags, int startId) { SharedPreferences sharedpreferences = getSharedPreferences(Helper.APP_PREFS, Context.MODE_PRIVATE); boolean proxyEnabled = sharedpreferences.getBoolean(Helper.SET_PROXY_ENABLED, false); int type = sharedpreferences.getInt(Helper.SET_PROXY_TYPE, 0); proxy = null; if( proxyEnabled ){ try{ String host = sharedpreferences.getString(Helper.SET_PROXY_HOST, "127.0.0.1"); int port = sharedpreferences.getInt(Helper.SET_PROXY_PORT, 8118); if( type == 0 ) proxy = new Proxy(Proxy.Type.HTTP, new InetSocketAddress(host, port)); else proxy = new Proxy(Proxy.Type.SOCKS, new InetSocketAddress(host, port)); final String login = sharedpreferences.getString(Helper.SET_PROXY_LOGIN, null); final String pwd = sharedpreferences.getString(Helper.SET_PROXY_PASSWORD, null); if( login != null) { Authenticator authenticator = new Authenticator() { public PasswordAuthentication getPasswordAuthentication() { assert pwd != null; return (new PasswordAuthentication(login, pwd.toCharArray())); } }; Authenticator.setDefault(authenticator); } }catch (Exception e){ proxy = null; } } if( intent == null || intent.getBooleanExtra("stop", false) ) { stop = true; stopSelf(); } boolean liveNotifications = sharedpreferences.getBoolean(Helper.SET_LIVE_NOTIFICATIONS, true); String userId; SQLiteDatabase db = Sqlite.getInstance(getApplicationContext(), Sqlite.DB_NAME, null, Sqlite.DB_VERSION).open(); if( liveNotifications ){ if( intent == null || intent.getStringExtra("userId") == null) { List accountStreams = new AccountDAO(getApplicationContext(), db).getAllAccount(); if (accountStreams != null){ for (final Account accountStream : accountStreams) { Thread thread = new Thread() { @Override public void run() { if(Helper.isConnectedToInternet(LiveNotificationService.this, accountStream.getInstance())) taks(accountStream); } }; thread.start(); } } }else { userId = intent.getStringExtra("userId"); final Account accountStream = new AccountDAO(getApplicationContext(), db).getAccountByID(userId); if (accountStream != null) { Thread thread = new Thread() { @Override public void run() { if(Helper.isConnectedToInternet(LiveNotificationService.this, accountStream.getInstance())) taks(accountStream); } }; thread.start(); } } } return START_STICKY; } @Nullable @Override public IBinder onBind(Intent intent) { return null; } @Override public void onDestroy() { super.onDestroy(); if( !stop) sendBroadcast(new Intent("RestartLiveNotificationService")); } private void taks(Account account){ InputStream inputStream = null; HttpsURLConnection httpsURLConnection = null; HttpURLConnection httpURLConnection = null; BufferedReader reader = null; Helper.EventStreaming lastEvent = null; if( account != null){ isRunning.get(account.getAcct()+account.getInstance()); if(!isRunning.containsKey(account.getAcct()+account.getInstance()) || ! isRunning.get(account.getAcct()+account.getInstance())) { if (Helper.instanceWithProtocol(account.getInstance()).startsWith("https")) { try { URL url = new URL("https://" + account.getInstance() + "/api/v1/streaming/user"); if( proxy != null) httpsURLConnection = (HttpsURLConnection) url.openConnection(proxy); else httpsURLConnection = (HttpsURLConnection) url.openConnection(); httpsURLConnection.setRequestProperty("Content-Type", "application/json"); httpsURLConnection.setRequestProperty("Authorization", "Bearer " + account.getToken()); httpsURLConnection.setRequestProperty("Connection", "Keep-Alive"); httpsURLConnection.setRequestProperty("Keep-Alive", "header"); httpsURLConnection.setRequestProperty("Connection", "close"); httpsURLConnection.setSSLSocketFactory(new TLSSocketFactory()); httpsURLConnection.setRequestMethod("GET"); if (httpsURLConnection.getResponseCode() == HttpURLConnection.HTTP_OK) { inputStream = new BufferedInputStream(httpsURLConnection.getInputStream()); reader = new BufferedReader(new InputStreamReader(inputStream)); String event; Helper.EventStreaming eventStreaming; while ((event = reader.readLine()) != null) { isRunning.put(account.getAcct() + account.getInstance(), true); if ((lastEvent == Helper.EventStreaming.NONE || lastEvent == null) && !event.startsWith("data: ")) { switch (event.trim()) { case "event: update": lastEvent = Helper.EventStreaming.UPDATE; break; case "event: notification": lastEvent = Helper.EventStreaming.NOTIFICATION; break; case "event: delete": lastEvent = Helper.EventStreaming.DELETE; break; default: lastEvent = Helper.EventStreaming.NONE; } } else { if (!event.startsWith("data: ")) { lastEvent = Helper.EventStreaming.NONE; continue; } event = event.substring(6); if (lastEvent == Helper.EventStreaming.UPDATE) { eventStreaming = Helper.EventStreaming.UPDATE; } else if (lastEvent == Helper.EventStreaming.NOTIFICATION) { eventStreaming = Helper.EventStreaming.NOTIFICATION; } else if (lastEvent == Helper.EventStreaming.DELETE) { eventStreaming = Helper.EventStreaming.DELETE; event = "{id:" + event + "}"; } else { eventStreaming = Helper.EventStreaming.UPDATE; } lastEvent = Helper.EventStreaming.NONE; try { JSONObject eventJson = new JSONObject(event); onRetrieveStreaming(eventStreaming, account, eventJson); } catch (JSONException ignored) { ignored.printStackTrace(); } } } isRunning.put(account.getAcct() + account.getInstance(), false); } } catch (Exception ignored) { isRunning.put(account.getAcct() + account.getInstance(), false); ignored.printStackTrace(); } finally { if (reader != null) { try { reader.close(); } catch (IOException ignored) { } } if (inputStream != null) { try { inputStream.close(); } catch (IOException ignored) { } } SystemClock.sleep(5000); Intent streamingIntent = new Intent(this, LiveNotificationService.class); streamingIntent.putExtra("userId", account.getId()); try { startService(streamingIntent); } catch (Exception ignored) { } } }else { try { URL url = new URL("http://" + account.getInstance() + "/api/v1/streaming/user"); if( proxy != null) httpURLConnection = (HttpURLConnection) url.openConnection(proxy); else httpURLConnection = (HttpURLConnection) url.openConnection(); httpURLConnection.setRequestProperty("Content-Type", "application/json"); httpURLConnection.setRequestProperty("Authorization", "Bearer " + account.getToken()); httpURLConnection.setRequestProperty("Connection", "Keep-Alive"); httpURLConnection.setRequestProperty("Keep-Alive", "header"); httpURLConnection.setRequestProperty("Connection", "close"); httpURLConnection.setRequestMethod("GET"); if (httpURLConnection.getResponseCode() == HttpURLConnection.HTTP_OK) { inputStream = new BufferedInputStream(httpURLConnection.getInputStream()); reader = new BufferedReader(new InputStreamReader(inputStream)); String event; Helper.EventStreaming eventStreaming; while ((event = reader.readLine()) != null) { isRunning.put(account.getAcct() + account.getInstance(), true); if ((lastEvent == Helper.EventStreaming.NONE || lastEvent == null) && !event.startsWith("data: ")) { switch (event.trim()) { case "event: update": lastEvent = Helper.EventStreaming.UPDATE; break; case "event: notification": lastEvent = Helper.EventStreaming.NOTIFICATION; break; case "event: delete": lastEvent = Helper.EventStreaming.DELETE; break; default: lastEvent = Helper.EventStreaming.NONE; } } else { if (!event.startsWith("data: ")) { lastEvent = Helper.EventStreaming.NONE; continue; } event = event.substring(6); if (lastEvent == Helper.EventStreaming.UPDATE) { eventStreaming = Helper.EventStreaming.UPDATE; } else if (lastEvent == Helper.EventStreaming.NOTIFICATION) { eventStreaming = Helper.EventStreaming.NOTIFICATION; } else if (lastEvent == Helper.EventStreaming.DELETE) { eventStreaming = Helper.EventStreaming.DELETE; event = "{id:" + event + "}"; } else { eventStreaming = Helper.EventStreaming.UPDATE; } lastEvent = Helper.EventStreaming.NONE; try { JSONObject eventJson = new JSONObject(event); onRetrieveStreaming(eventStreaming, account, eventJson); } catch (JSONException ignored) { ignored.printStackTrace(); } } } isRunning.put(account.getAcct() + account.getInstance(), false); } } catch (Exception ignored) { isRunning.put(account.getAcct() + account.getInstance(), false); ignored.printStackTrace(); } finally { if (reader != null) { try { reader.close(); } catch (IOException ignored) { } } if (inputStream != null) { try { inputStream.close(); } catch (IOException ignored) { } } SystemClock.sleep(5000); Intent streamingIntent = new Intent(this, LiveNotificationService.class); streamingIntent.putExtra("userId", account.getId()); try { startService(streamingIntent); } catch (Exception ignored) { } } } } } } private void onRetrieveStreaming(Helper.EventStreaming event, final Account account, JSONObject response) { if( response == null ) return; //No previous notifications in cache, so no notification will be sent fr.gouv.etalab.mastodon.client.Entities.Status status ; final Notification notification; String dataId = null; Bundle b = new Bundle(); if( event == Helper.EventStreaming.NOTIFICATION){ notification = API.parseNotificationResponse(getApplicationContext(), response); b.putParcelable("data", notification); boolean activityPaused; try { activityPaused = BaseMainActivity.activityState(); }catch (Exception e){ activityPaused = true; } final SharedPreferences sharedpreferences = getSharedPreferences(Helper.APP_PREFS, Context.MODE_PRIVATE); boolean liveNotifications = sharedpreferences.getBoolean(Helper.SET_LIVE_NOTIFICATIONS, true); boolean canNotify = Helper.canNotify(getApplicationContext()); boolean notify = sharedpreferences.getBoolean(Helper.SET_NOTIFY, true); String userId = sharedpreferences.getString(Helper.PREF_KEY_ID, null); String targeted_account = null; Helper.NotifType notifType = Helper.NotifType.MENTION; if((userId == null || !userId.equals(account.getId()) || activityPaused) && liveNotifications && canNotify && notify) { boolean notif_follow = sharedpreferences.getBoolean(Helper.SET_NOTIF_FOLLOW, true); boolean notif_add = sharedpreferences.getBoolean(Helper.SET_NOTIF_ADD, true); boolean notif_mention = sharedpreferences.getBoolean(Helper.SET_NOTIF_MENTION, true); boolean notif_share = sharedpreferences.getBoolean(Helper.SET_NOTIF_SHARE, true); boolean somethingToPush = (notif_follow || notif_add || notif_mention || notif_share); String title = null; if( somethingToPush && notification != null){ switch (notification.getType()){ case "mention": notifType = Helper.NotifType.MENTION; if(notif_mention){ if( notification.getAccount().getDisplay_name() != null && notification.getAccount().getDisplay_name().length() > 0 ) title = String.format("%s %s", Helper.shortnameToUnicode(notification.getAccount().getDisplay_name(), true),getString(R.string.notif_mention)); else title = String.format("@%s %s", notification.getAccount().getAcct(),getString(R.string.notif_mention)); } break; case "reblog": notifType = Helper.NotifType.BOOST; if(notif_share){ if( notification.getAccount().getDisplay_name() != null && notification.getAccount().getDisplay_name().length() > 0 ) title = String.format("%s %s", Helper.shortnameToUnicode(notification.getAccount().getDisplay_name(), true),getString(R.string.notif_reblog)); else title = String.format("@%s %s", notification.getAccount().getAcct(),getString(R.string.notif_reblog)); } break; case "favourite": notifType = Helper.NotifType.FAV; if(notif_add){ if( notification.getAccount().getDisplay_name() != null && notification.getAccount().getDisplay_name().length() > 0 ) title = String.format("%s %s", Helper.shortnameToUnicode(notification.getAccount().getDisplay_name(), true),getString(R.string.notif_favourite)); else title = String.format("@%s %s", notification.getAccount().getAcct(),getString(R.string.notif_favourite)); } break; case "follow": notifType = Helper.NotifType.FOLLLOW; if(notif_follow){ if( notification.getAccount().getDisplay_name() != null && notification.getAccount().getDisplay_name().length() > 0 ) title = String.format("%s %s", Helper.shortnameToUnicode(notification.getAccount().getDisplay_name(), true),getString(R.string.notif_follow)); else title = String.format("@%s %s", notification.getAccount().getAcct(),getString(R.string.notif_follow)); targeted_account = notification.getAccount().getId(); } break; default: } //Some others notification final Intent intent = new Intent(getApplicationContext(), MainActivity.class); intent.addFlags(Intent.FLAG_ACTIVITY_SINGLE_TOP | Intent.FLAG_ACTIVITY_NEW_TASK ); intent.putExtra(INTENT_ACTION, NOTIFICATION_INTENT); intent.putExtra(PREF_KEY_ID, account.getId()); if( targeted_account != null ) intent.putExtra(INTENT_TARGETED_ACCOUNT, targeted_account); long notif_id = Long.parseLong(account.getId()); final int notificationId = ((notif_id + 1) > 2147483647) ? (int) (2147483647 - notif_id - 1) : (int) (notif_id + 1); if( notification.getAccount().getAvatar() != null ) { final String finalTitle = title; Handler mainHandler = new Handler(Looper.getMainLooper()); Helper.NotifType finalNotifType = notifType; Runnable myRunnable = new Runnable() { @Override public void run() { if( finalTitle != null) { Glide.with(getApplicationContext()) .asBitmap() .load(notification.getAccount().getAvatar()) .listener(new RequestListener() { @Override public boolean onResourceReady(Bitmap resource, Object model, Target target, DataSource dataSource, boolean isFirstResource) { return false; } @Override public boolean onLoadFailed(@Nullable GlideException e, Object model, Target target, boolean isFirstResource) { notify_user(getApplicationContext(), intent, notificationId, BitmapFactory.decodeResource(getResources(), R.drawable.mastodonlogo), finalNotifType, finalTitle, "@"+account.getAcct()+"@"+account.getInstance()); String lastNotif = sharedpreferences.getString(Helper.LAST_NOTIFICATION_MAX_ID + account.getId() + account.getInstance(), null); if (lastNotif == null || Long.parseLong(notification.getId()) > Long.parseLong(lastNotif)) { SharedPreferences.Editor editor = sharedpreferences.edit(); editor.putString(Helper.LAST_NOTIFICATION_MAX_ID + account.getId() + account.getInstance(), notification.getId()); editor.apply(); } return false; } }) .into(new SimpleTarget() { @Override public void onResourceReady(Bitmap resource, Transition transition) { notify_user(getApplicationContext(), intent, notificationId, resource, finalNotifType, finalTitle, "@"+account.getAcct()+"@"+account.getInstance()); String lastNotif = sharedpreferences.getString(Helper.LAST_NOTIFICATION_MAX_ID + account.getId() + account.getInstance(), null); if (lastNotif == null || Long.parseLong(notification.getId()) > Long.parseLong(lastNotif)) { SharedPreferences.Editor editor = sharedpreferences.edit(); editor.putString(Helper.LAST_NOTIFICATION_MAX_ID + account.getId() + account.getInstance(), notification.getId()); editor.apply(); } } }); } } }; mainHandler.post(myRunnable); } } } }else if ( event == Helper.EventStreaming.UPDATE){ status = API.parseStatuses(getApplicationContext(), response); status.setNew(true); b.putParcelable("data", status); }else if( event == Helper.EventStreaming.DELETE){ try { dataId = response.getString("id"); } catch (JSONException ignored) {} } if( account != null) b.putString("userIdService",account.getId()); Intent intentBC = new Intent(Helper.RECEIVE_DATA); intentBC.putExtra("eventStreaming", event); intentBC.putExtras(b); LocalBroadcastManager.getInstance(getApplicationContext()).sendBroadcast(intentBC); } }