add user status repo

Signed-off-by: alperozturk <[email protected]>

Author: alperozturk96

app/src/main/java/it/niedermann/owncloud/notes/accountswitcher/SetStatusMessageBottomSheet.kt

@@ -22,6 +22,7 @@ import android.widget.AdapterView
 import android.widget.AdapterView.OnItemSelectedListener
 import android.widget.ArrayAdapter
 import androidx.annotation.VisibleForTesting
+import androidx.lifecycle.lifecycleScope
 import androidx.recyclerview.widget.LinearLayoutManager
 import com.nextcloud.common.User
 import com.owncloud.android.lib.resources.users.ClearAt
@@ -35,6 +36,7 @@ import com.vanniktech.emoji.installForceSingleEmoji
 import it.niedermann.owncloud.notes.R
 import it.niedermann.owncloud.notes.accountswitcher.adapter.PredefinedStatusClickListener
 import it.niedermann.owncloud.notes.accountswitcher.adapter.PredefinedStatusListAdapter
+import it.niedermann.owncloud.notes.accountswitcher.repository.UserStatusRepository
 import it.niedermann.owncloud.notes.accountswitcher.task.ClearStatusTask
 import it.niedermann.owncloud.notes.accountswitcher.task.SetPredefinedCustomStatusTask
 import it.niedermann.owncloud.notes.accountswitcher.task.SetUserDefinedCustomStatusTask
@@ -45,6 +47,8 @@ import it.niedermann.owncloud.notes.shared.util.DisplayUtils
 import it.niedermann.owncloud.notes.util.runner.AsyncRunner
 import it.niedermann.owncloud.notes.util.runner.ThreadPoolAsyncRunner
 import it.niedermann.owncloud.notes.util.storage.UserStorage
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.launch
 import java.util.Calendar
 import java.util.Locale
 
@@ -68,12 +72,11 @@ private const val CLEAR_AT_TYPE_END_OF = "end-of"
 
 class SetStatusMessageBottomSheet(val user: User, val currentStatus: Status?) :
     BrandedBottomSheetDialogFragment(R.layout.set_status_message_bottom_sheet),
-    PredefinedStatusClickListener,
-    Injectable {
+    PredefinedStatusClickListener{
 
     private lateinit var binding: SetStatusMessageBottomSheetBinding
 
-    private lateinit var accountManager: UserAccountManager
+    private lateinit var repository: UserStatusRepository
     private lateinit var predefinedStatus: ArrayList<PredefinedStatus>
     private lateinit var adapter: PredefinedStatusListAdapter
     private var selectedPredefinedMessageId: String? = null
@@ -88,6 +91,11 @@ class SetStatusMessageBottomSheet(val user: User, val currentStatus: Status?) :
         val uiHandler = Handler(Looper.getMainLooper())
         asyncRunner = ThreadPoolAsyncRunner(uiHandler, 4, "io")
         predefinedStatus = UserStorage.readPredefinedStatus(requireContext())
+
+        lifecycleScope.launch(Dispatchers.IO) {
+
+        }
+        repository = UserStatusRepository(requireContext())
         EmojiManager.install(GoogleEmojiProvider())
     }
 

app/src/main/java/it/niedermann/owncloud/notes/accountswitcher/repository/UserStatusRepository.kt

@@ -0,0 +1,63 @@
+package it.niedermann.owncloud.notes.accountswitcher.repository
+
+import android.content.Context
+import android.util.Log
+import androidx.annotation.WorkerThread
+import com.nextcloud.android.sso.model.SingleSignOnAccount
+import it.niedermann.owncloud.notes.persistence.ApiProvider
+import it.niedermann.owncloud.notes.shared.model.OcsResponse
+import retrofit2.Response
+import kotlin.getValue
+
+class UserStatusRepository(
+    private val context: Context,
+    private val ssoAccount: SingleSignOnAccount
+) {
+    companion object {
+        private const val TAG = "UserStatusRepository"
+    }
+
+    private val ocsAPI by lazy { ApiProvider.getInstance().getOcsAPI(context, ssoAccount) }
+
+    @WorkerThread
+    fun clearStatus(): Boolean {
+        return try {
+            val response: Response<OcsResponse<Void>> = ocsAPI.clearStatusMessage().execute()
+            response.isSuccessful
+        } catch (t: Throwable) {
+            Log.e(TAG, "Clearing status failed", t)
+            false
+        }
+    }
+
+    @WorkerThread
+    fun setPredefinedStatus(messageId: String, clearAt: Long? = null): Boolean {
+        val body = mutableMapOf<String, String>("messageId" to messageId)
+        clearAt?.let { body["clearAt"] = it.toString() }
+
+        return try {
+            val response: Response<OcsResponse<Void>> = ocsAPI.setPredefinedStatusMessage(body).execute()
+            response.isSuccessful
+        } catch (t: Throwable) {
+            Log.e(TAG, "Setting predefined status failed", t)
+            false
+        }
+    }
+
+    @WorkerThread
+    fun setCustomStatus(message: String, statusIcon: String, clearAt: Long? = null): Boolean {
+        val body = mutableMapOf(
+            "message" to message,
+            "statusIcon" to statusIcon
+        )
+        clearAt?.let { body["clearAt"] = it.toString() }
+
+        return try {
+            val response: Response<OcsResponse<Void>> = ocsAPI.setUserDefinedStatusMessage(body).execute()
+            response.isSuccessful
+        } catch (t: Throwable) {
+            Log.e(TAG, "Setting custom status failed", t)
+            false
+        }
+    }
+}

app/src/main/java/it/niedermann/owncloud/notes/persistence/sync/OcsAPI.java

@@ -8,13 +8,19 @@
 
 import com.nextcloud.android.sso.api.ParsedResponse;
 
+import java.util.Map;
+
 import io.reactivex.Observable;
 import it.niedermann.owncloud.notes.shared.model.Capabilities;
 import it.niedermann.owncloud.notes.shared.model.OcsResponse;
 import it.niedermann.owncloud.notes.shared.model.OcsUser;
 import retrofit2.Call;
+import retrofit2.http.Body;
+import retrofit2.http.DELETE;
 import retrofit2.http.GET;
 import retrofit2.http.Header;
+import retrofit2.http.Headers;
+import retrofit2.http.PUT;
 import retrofit2.http.Path;
 
 /**
@@ -27,4 +33,15 @@ public interface OcsAPI {
 
     @GET("users/{userId}?format=json")
     Call<OcsResponse<OcsUser>> getUser(@Path("userId") String userId);
+
+    @DELETE("apps/user_status/api/v1/user_status/message?format=json")
+    Call<OcsResponse<Void>> clearStatusMessage();
+
+    @PUT("apps/user_status/api/v1/user_status/message/predefined?format=json")
+    @Headers("Content-Type: application/json")
+    Call<OcsResponse<Void>> setPredefinedStatusMessage(@Body Map<String, String> body);
+
+    @PUT("apps/user_status/api/v1/user_status/message/custom?format=json")
+    @Headers("Content-Type: application/json")
+    Call<OcsResponse<Void>> setUserDefinedStatusMessage(@Body Map<String, String> body);
 }

app/src/main/java/it/niedermann/owncloud/notes/util/storage/UserStorage.kt

@@ -2,16 +2,16 @@ package it.niedermann.owncloud.notes.util.storage
 
 import android.content.Context
 import android.content.SharedPreferences
+import androidx.preference.PreferenceManager
 import com.google.gson.Gson
 import com.google.gson.reflect.TypeToken
 import com.owncloud.android.lib.resources.users.PredefinedStatus
 
 object UserStorage {
-    private const val APP = "NextcloudNotes"
     private const val PREDEFINED_STATUS = "PREDEFINED_STATUS"
 
     private fun getSharedPreferences(context: Context): SharedPreferences {
-        return context.getSharedPreferences(APP, Context.MODE_PRIVATE)
+        return PreferenceManager.getDefaultSharedPreferences(context)
     }
 
     fun readPredefinedStatus(context: Context): ArrayList<PredefinedStatus> {