package app.fedilab.android.fragments; /* Copyright 2017 Thomas Schneider * * This file is a part of Fedilab * * 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. * * Fedilab 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 Fedilab; if not, * see . */ import android.content.BroadcastReceiver; import android.content.Context; import android.content.Intent; import android.content.IntentFilter; import android.content.SharedPreferences; import android.os.AsyncTask; import android.os.Bundle; import android.os.Handler; import android.os.Looper; import androidx.annotation.NonNull; import androidx.fragment.app.Fragment; import androidx.core.content.ContextCompat; import androidx.localbroadcastmanager.content.LocalBroadcastManager; import androidx.swiperefreshlayout.widget.SwipeRefreshLayout; import androidx.recyclerview.widget.LinearLayoutManager; import androidx.recyclerview.widget.RecyclerView; import android.view.LayoutInflater; import android.view.View; import android.view.ViewGroup; import android.widget.RelativeLayout; import android.widget.Toast; import java.util.ArrayList; import java.util.List; import app.fedilab.android.client.APIResponse; import app.fedilab.android.client.Entities.Account; import app.fedilab.android.client.Entities.Notification; import app.fedilab.android.client.Entities.Status; import app.fedilab.android.drawers.NotificationsListAdapter; import app.fedilab.android.helper.Helper; import es.dmoral.toasty.Toasty; import app.fedilab.android.R; import app.fedilab.android.activities.MainActivity; import app.fedilab.android.asynctasks.RetrieveMissingNotificationsAsyncTask; import app.fedilab.android.asynctasks.RetrieveNotificationsAsyncTask; import app.fedilab.android.asynctasks.UpdateAccountInfoAsyncTask; import app.fedilab.android.interfaces.OnRetrieveMissingNotificationsInterface; import app.fedilab.android.interfaces.OnRetrieveNotificationsInterface; /** * Created by Thomas on 28/04/2017. * Fragment to display notifications related to accounts */ public class DisplayNotificationsFragment extends Fragment implements OnRetrieveNotificationsInterface, OnRetrieveMissingNotificationsInterface { private boolean flag_loading; private Context context; private AsyncTask asyncTask; private NotificationsListAdapter notificationsListAdapter; private String max_id; private List notifications; private RelativeLayout mainLoader, nextElementLoader, textviewNoAction; private boolean firstLoad; private SwipeRefreshLayout swipeRefreshLayout; private boolean swiped; private RecyclerView lv_notifications; private String userId, instance; private SharedPreferences sharedpreferences; LinearLayoutManager mLayoutManager; private BroadcastReceiver receive_action; private static BroadcastReceiver receive_data; public DisplayNotificationsFragment(){ } public enum Type{ ALL, MENTION, FAVORITE, BOOST, POLL, FOLLOW } Type type; @Override public View onCreateView(@NonNull LayoutInflater inflater, ViewGroup container, Bundle savedInstanceState) { View rootView = inflater.inflate(R.layout.fragment_notifications, container, false); max_id = null; context = getContext(); firstLoad = true; flag_loading = true; notifications = new ArrayList<>(); swiped = false; swipeRefreshLayout = rootView.findViewById(R.id.swipeContainer); sharedpreferences = context.getSharedPreferences(Helper.APP_PREFS, Context.MODE_PRIVATE); Bundle bundle = this.getArguments(); if (bundle != null) { type = (Type) bundle.get("type"); } lv_notifications = rootView.findViewById(R.id.lv_notifications); mainLoader = rootView.findViewById(R.id.loader); nextElementLoader = rootView.findViewById(R.id.loading_next_notifications); textviewNoAction = rootView.findViewById(R.id.no_action); mainLoader.setVisibility(View.VISIBLE); nextElementLoader.setVisibility(View.GONE); boolean isOnWifi = Helper.isOnWIFI(context); int behaviorWithAttachments = sharedpreferences.getInt(Helper.SET_ATTACHMENT_ACTION, Helper.ATTACHMENT_ALWAYS); userId = sharedpreferences.getString(Helper.PREF_KEY_ID, null); instance = sharedpreferences.getString(Helper.PREF_INSTANCE, context!=null?Helper.getLiveInstance(context):null); notificationsListAdapter = new NotificationsListAdapter(context,isOnWifi, behaviorWithAttachments,this.notifications); lv_notifications.setAdapter(notificationsListAdapter); mLayoutManager = new LinearLayoutManager(context); lv_notifications.setLayoutManager(mLayoutManager); lv_notifications.addOnScrollListener(new RecyclerView.OnScrollListener() { public void onScrolled(RecyclerView recyclerView, int dx, int dy) { if(dy > 0) { int visibleItemCount = mLayoutManager.getChildCount(); int totalItemCount = mLayoutManager.getItemCount(); int firstVisibleItem = mLayoutManager.findFirstVisibleItemPosition(); if (firstVisibleItem + visibleItemCount == totalItemCount && context != null) { if (!flag_loading) { flag_loading = true; asyncTask = new RetrieveNotificationsAsyncTask(context, type,true, null, max_id, DisplayNotificationsFragment.this).executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR); nextElementLoader.setVisibility(View.VISIBLE); } } else { nextElementLoader.setVisibility(View.GONE); } } } }); if (MainActivity.social == UpdateAccountInfoAsyncTask.SOCIAL.MASTODON || MainActivity.social == UpdateAccountInfoAsyncTask.SOCIAL.PLEROMA) { if (receive_action != null) LocalBroadcastManager.getInstance(context).unregisterReceiver(receive_action); receive_action = new BroadcastReceiver() { @Override public void onReceive(Context context, Intent intent) { Bundle b = intent.getExtras(); assert b != null; Status status = b.getParcelable("status"); if( notificationsListAdapter != null && status != null) notificationsListAdapter.notifyNotificationWithActionChanged(status); } }; LocalBroadcastManager.getInstance(context).registerReceiver(receive_action, new IntentFilter(Helper.RECEIVE_ACTION)); if( type == Type.ALL) { if (receive_data != null) LocalBroadcastManager.getInstance(context).unregisterReceiver(receive_data); receive_data = new BroadcastReceiver() { @Override public void onReceive(Context context, Intent intent) { Bundle b = intent.getExtras(); assert b != null; String userIdService = b.getString("userIdService", null); if (userIdService != null && userIdService.equals(userId)) { Notification notification = b.getParcelable("data"); refresh(notification); if (context instanceof MainActivity && type == Type.ALL ) ((MainActivity) context).updateNotifCounter(); } } }; LocalBroadcastManager.getInstance(context).registerReceiver(receive_data, new IntentFilter(Helper.RECEIVE_DATA)); } } swipeRefreshLayout.setOnRefreshListener(new SwipeRefreshLayout.OnRefreshListener() { @Override public void onRefresh() { flag_loading = true; swiped = true; if(type == Type.ALL) { MainActivity.countNewNotifications = 0; try { ((MainActivity) context).updateNotifCounter(); } catch (Exception ignored) { } } String sinceId = null; if( notifications != null && notifications.size() > 0 ) sinceId = notifications.get(0).getId(); if( context != null) asyncTask = new RetrieveMissingNotificationsAsyncTask(context, type, sinceId, DisplayNotificationsFragment.this).executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR); } }); SharedPreferences sharedpreferences = context.getSharedPreferences(Helper.APP_PREFS, Context.MODE_PRIVATE); int theme = sharedpreferences.getInt(Helper.SET_THEME, Helper.THEME_DARK); switch (theme){ case Helper.THEME_LIGHT: swipeRefreshLayout.setColorSchemeResources(R.color.mastodonC4, R.color.mastodonC2, R.color.mastodonC3); swipeRefreshLayout.setProgressBackgroundColorSchemeColor(ContextCompat.getColor(context, R.color.white)); break; case Helper.THEME_DARK: swipeRefreshLayout.setColorSchemeResources(R.color.mastodonC4__, R.color.mastodonC4, R.color.mastodonC4); swipeRefreshLayout.setProgressBackgroundColorSchemeColor(ContextCompat.getColor(context, R.color.mastodonC1_)); break; case Helper.THEME_BLACK: swipeRefreshLayout.setColorSchemeResources(R.color.dark_icon, R.color.mastodonC2, R.color.mastodonC3); swipeRefreshLayout.setProgressBackgroundColorSchemeColor(ContextCompat.getColor(context, R.color.black_3)); break; } if( context != null) asyncTask = new RetrieveNotificationsAsyncTask(context, type,true, null, max_id, DisplayNotificationsFragment.this).executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR); else new Handler(Looper.getMainLooper()).postDelayed(new Runnable() { @Override public void run() { if( context != null) asyncTask = new RetrieveNotificationsAsyncTask(context, type,true, null, max_id, DisplayNotificationsFragment.this).executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR); } }, 500); return rootView; } @Override public void onCreate(Bundle saveInstance) { super.onCreate(saveInstance); } @Override public void onAttach(Context context) { super.onAttach(context); this.context = context; } @Override public void onDestroy() { super.onDestroy(); if(asyncTask != null && asyncTask.getStatus() == AsyncTask.Status.RUNNING) asyncTask.cancel(true); if( receive_action != null) LocalBroadcastManager.getInstance(context).unregisterReceiver(receive_action); if( receive_data != null) LocalBroadcastManager.getInstance(context).unregisterReceiver(receive_data); } @Override public void onRetrieveNotifications(APIResponse apiResponse, Account account, boolean refreshData) { mainLoader.setVisibility(View.GONE); nextElementLoader.setVisibility(View.GONE); String lastReadNotifications = sharedpreferences.getString(Helper.LAST_NOTIFICATION_MAX_ID + userId + instance, null); if( apiResponse.getError() != null){ Toasty.error(context, apiResponse.getError().getError(),Toast.LENGTH_LONG).show(); flag_loading = false; swipeRefreshLayout.setRefreshing(false); swiped = false; return; } int previousPosition = notifications.size(); max_id = apiResponse.getMax_id(); List notifications = apiResponse.getNotifications(); if( !swiped && firstLoad && (notifications == null || notifications.size() == 0)) textviewNoAction.setVisibility(View.VISIBLE); else textviewNoAction.setVisibility(View.GONE); if( swiped ){ if (previousPosition > 0) { for (int i = 0; i < previousPosition; i++) { this.notifications.remove(0); } notificationsListAdapter.notifyItemRangeRemoved(0, previousPosition); } swiped = false; } if( notifications != null && notifications.size() > 0) { for(Notification tmpNotification: notifications){ if(type == Type.ALL) { if (lastReadNotifications != null && Long.parseLong(tmpNotification.getId()) > Long.parseLong(lastReadNotifications)) { MainActivity.countNewNotifications++; } try { ((MainActivity) context).updateNotifCounter(); } catch (Exception ignored) { } } this.notifications.add(tmpNotification); } if( firstLoad && type == Type.ALL) { //Update the id of the last notification retrieved if( MainActivity.lastNotificationId == null || Long.parseLong(notifications.get(0).getId()) > Long.parseLong(MainActivity.lastNotificationId)) MainActivity.lastNotificationId = notifications.get(0).getId(); updateNotificationLastId(notifications.get(0).getId()); } notificationsListAdapter.notifyItemRangeInserted(previousPosition, notifications.size()); }else { if( firstLoad) textviewNoAction.setVisibility(View.VISIBLE); } if( firstLoad && type == Type.ALL) ((MainActivity)context).updateNotifCounter(); swipeRefreshLayout.setRefreshing(false); firstLoad = false; //The initial call comes from a classic tab refresh flag_loading = (max_id == null ); } /** * Called from main activity in onResume to retrieve missing notifications * @param sinceId String */ public void retrieveMissingNotifications(String sinceId){ asyncTask = new RetrieveMissingNotificationsAsyncTask(context, type, sinceId, DisplayNotificationsFragment.this).executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR); } @Override public void setMenuVisibility(final boolean visible) { super.setMenuVisibility(visible); if( context == null) return; //Store last notification id to avoid to notify for those that have been already seen if (visible && notifications != null && notifications.size() > 0) { retrieveMissingNotifications(notifications.get(0).getId()); updateNotificationLastId(notifications.get(0).getId()); } } public void scrollToTop(){ if( lv_notifications != null) lv_notifications.setAdapter(notificationsListAdapter); //Store last toot id for home timeline to avoid to notify for those that have been already seen if (this.notifications != null && this.notifications.size() > 0) { updateNotificationLastId(this.notifications.get(0).getId()); } } public void refreshAll(){ if( context == null) return; max_id = null; firstLoad = true; flag_loading = true; swiped = true; if(type == Type.ALL) { MainActivity.countNewNotifications = 0; } asyncTask = new RetrieveNotificationsAsyncTask(context, type,true, null, null, DisplayNotificationsFragment.this).executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR); } public void refresh(Notification notification){ if( context == null) return; if( notification != null){ //Makes sure the notifications is not already displayed if( !this.notifications.contains(notification)) { //Update the id of the last notification retrieved MainActivity.lastNotificationId = notification.getId(); notifications.add(0, notification); if( type == Type.ALL) { MainActivity.countNewNotifications++; try { ((MainActivity) context).updateNotifCounter(); } catch (Exception ignored) { } } int firstVisibleItem = mLayoutManager.findFirstVisibleItemPosition(); if (firstVisibleItem > 0) notificationsListAdapter.notifyItemInserted(0); else notificationsListAdapter.notifyDataSetChanged(); if (textviewNoAction.getVisibility() == View.VISIBLE) textviewNoAction.setVisibility(View.GONE); } } } @Override public void onRetrieveMissingNotifications(List notifications) { flag_loading = false; swipeRefreshLayout.setRefreshing(false); if( this.notifications != null && this.notifications.size() > 0 && swiped){ swiped = false; notificationsListAdapter.notifyItemRangeChanged(0,this.notifications.size()); } if( notifications != null && notifications.size() > 0) { if( textviewNoAction.getVisibility() == View.VISIBLE){ textviewNoAction.setVisibility(View.GONE); lv_notifications.setVisibility(View.VISIBLE); } int inserted = 0; for (int i = notifications.size()-1 ; i >= 0 ; i--) { if (this.notifications != null && this.notifications.size() == 0 || Long.parseLong(notifications.get(i).getId()) > Long.parseLong(this.notifications.get(0).getId())) { MainActivity.countNewNotifications++; this.notifications.add(0, notifications.get(i)); inserted++; } } notificationsListAdapter.notifyItemRangeInserted(0,inserted); try { ((MainActivity) context).updateNotifCounter(); }catch (Exception ignored){} } } /** * Records the id of the notification only if its greater than the previous one. * @param notificationId String current notification id to check */ private void updateNotificationLastId(String notificationId){ if( type == Type.ALL) { String lastNotif = sharedpreferences.getString(Helper.LAST_NOTIFICATION_MAX_ID + userId + instance, null); if (lastNotif == null || Long.parseLong(notificationId) > Long.parseLong(lastNotif)) { MainActivity.countNewNotifications = 0; SharedPreferences.Editor editor = sharedpreferences.edit(); editor.putString(Helper.LAST_NOTIFICATION_MAX_ID + userId + instance, notificationId); editor.apply(); } } } }