Assistant Endpoints

library/src/main/java/com/owncloud/android/lib/common/operations/RemoteOperation.java

@@ -33,6 +33,7 @@
 
 import androidx.annotation.NonNull;
 
+import com.google.gson.Gson;
 import com.nextcloud.common.NextcloudClient;
 import com.nextcloud.common.User;
 import com.owncloud.android.lib.common.OwnCloudAccount;
@@ -55,6 +56,7 @@
  */
 public abstract class RemoteOperation<T> implements Runnable {
 
+    public final Gson gson = new Gson();
     private static final String TAG = RemoteOperation.class.getSimpleName();
 
     /**

library/src/main/java/com/owncloud/android/lib/resources/OCSRemoteOperation.java

@@ -27,7 +27,6 @@
 
 package com.owncloud.android.lib.resources;
 
-import com.google.gson.Gson;
 import com.google.gson.JsonElement;
 import com.google.gson.JsonParser;
 import com.google.gson.reflect.TypeToken;
@@ -48,21 +47,13 @@ public abstract class OCSRemoteOperation<T> extends RemoteOperation<T> {
     @Deprecated
     public <T> T getServerResponse(HttpMethodBase method, TypeToken<T> type) throws IOException {
         String response = method.getResponseBodyAsString();
-        JsonParser parser = new JsonParser();
-        JsonElement element = parser.parse(response);
-
-        Gson gson = new Gson();
-
+        JsonElement element = JsonParser.parseString(response);
         return gson.fromJson(element, type.getType());
     }
 
     public <T> T getServerResponse(OkHttpMethodBase method, TypeToken<T> type) {
         String response = method.getResponseBodyAsString();
-        JsonParser parser = new JsonParser();
-        JsonElement element = parser.parse(response);
-
-        Gson gson = new Gson();
-
+        JsonElement element = JsonParser.parseString(response);
         return gson.fromJson(element, type.getType());
     }
 }

library/src/main/java/com/owncloud/android/lib/resources/assistant/CreateTaskRemoteOperation.kt

@@ -0,0 +1,60 @@
+/*
+ * Nextcloud Android client application
+ *
+ * @author Alper Ozturk
+ * Copyright (C) 2024 Alper Ozturk
+ * Copyright (C) 2024 Nextcloud GmbH
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program 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 Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <https://www.gnu.org/licenses/>.
+ */
+
+package com.owncloud.android.lib.resources.assistant
+
+import com.nextcloud.common.NextcloudClient
+import com.nextcloud.operations.PostMethod
+import com.owncloud.android.lib.common.operations.RemoteOperation
+import com.owncloud.android.lib.common.operations.RemoteOperationResult
+import okhttp3.MediaType.Companion.toMediaTypeOrNull
+import okhttp3.RequestBody.Companion.toRequestBody
+import org.apache.commons.httpclient.HttpStatus
+
+class CreateTaskRemoteOperation(private val input: String, private val type: String) :
+    RemoteOperation<Void>() {
+    override fun run(client: NextcloudClient): RemoteOperationResult<Void> {
+        val requestBody = hashMapOf(
+            "input" to input,
+            "type" to type,
+            "appId" to "assistant",
+            "identifier" to ""
+        )
+
+        val json = gson.toJson(requestBody)
+
+        val request = json.toRequestBody("application/json".toMediaTypeOrNull())
+
+        val postMethod = PostMethod(client.baseUri.toString() + TAG_URL, true, request)
+
+        val status = postMethod.execute(client)
+
+        return if (status == HttpStatus.SC_OK) {
+            RemoteOperationResult<Void>(true, postMethod)
+        } else {
+            RemoteOperationResult<Void>(false, postMethod)
+        }
+    }
+
+    companion object {
+        const val TAG_URL = "/ocs/v2.php/textprocessing/schedule"
+    }
+}

library/src/main/java/com/owncloud/android/lib/resources/assistant/GetTaskListRemoteOperation.kt

@@ -0,0 +1,72 @@
+/*
+ * Nextcloud Android client application
+ *
+ * @author Alper Ozturk
+ * Copyright (C) 2024 Alper Ozturk
+ * Copyright (C) 2024 Nextcloud GmbH
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program 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 Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <https://www.gnu.org/licenses/>.
+ */
+
+package com.owncloud.android.lib.resources.assistant
+
+import com.google.gson.reflect.TypeToken
+import com.nextcloud.common.NextcloudClient
+import com.nextcloud.operations.GetMethod
+import com.owncloud.android.lib.common.operations.RemoteOperationResult
+import com.owncloud.android.lib.common.utils.Log_OC
+import com.owncloud.android.lib.ocs.ServerResponse
+import com.owncloud.android.lib.resources.OCSRemoteOperation
+import com.owncloud.android.lib.resources.assistant.model.TaskList
+import org.apache.commons.httpclient.HttpStatus
+
+class GetTaskListRemoteOperation(private val appId: String) : OCSRemoteOperation<TaskList>() {
+    @Suppress("TooGenericExceptionCaught")
+    override fun run(client: NextcloudClient): RemoteOperationResult<TaskList> {
+        var result: RemoteOperationResult<TaskList>
+        var getMethod: GetMethod? = null
+        try {
+            getMethod =
+                GetMethod(client.baseUri.toString() + DIRECT_ENDPOINT + appId + JSON_FORMAT, true)
+            val status = client.execute(getMethod)
+            if (status == HttpStatus.SC_OK) {
+                val taskTypes: TaskList =
+                    getServerResponse(
+                        getMethod,
+                        object : TypeToken<ServerResponse<TaskList>>() {}
+                    )
+                        .ocs.data
+                result = RemoteOperationResult(true, getMethod)
+                result.setResultData(taskTypes)
+            } else {
+                result = RemoteOperationResult(false, getMethod)
+            }
+        } catch (e: Exception) {
+            result = RemoteOperationResult(e)
+            Log_OC.e(
+                TAG,
+                "Get task list for user " + " failed: " + result.logMessage,
+                result.exception
+            )
+        } finally {
+            getMethod?.releaseConnection()
+        }
+        return result
+    }
+
+    companion object {
+        private val TAG = GetTaskTypesRemoteOperation::class.java.simpleName
+        private const val DIRECT_ENDPOINT = "/ocs/v2.php/textprocessing/tasks/app/"
+    }
+}

library/src/main/java/com/owncloud/android/lib/resources/assistant/GetTaskTypesRemoteOperation.kt

@@ -0,0 +1,72 @@
+/*
+ * Nextcloud Android client application
+ *
+ * @author Alper Ozturk
+ * Copyright (C) 2024 Alper Ozturk
+ * Copyright (C) 2024 Nextcloud GmbH
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program 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 Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <https://www.gnu.org/licenses/>.
+ */
+
+package com.owncloud.android.lib.resources.assistant
+
+import com.google.gson.reflect.TypeToken
+import com.nextcloud.common.NextcloudClient
+import com.nextcloud.operations.GetMethod
+import com.owncloud.android.lib.common.operations.RemoteOperationResult
+import com.owncloud.android.lib.common.utils.Log_OC
+import com.owncloud.android.lib.ocs.ServerResponse
+import com.owncloud.android.lib.resources.OCSRemoteOperation
+import com.owncloud.android.lib.resources.assistant.model.TaskTypes
+import org.apache.commons.httpclient.HttpStatus
+
+class GetTaskTypesRemoteOperation : OCSRemoteOperation<TaskTypes>() {
+    @Suppress("TooGenericExceptionCaught")
+    override fun run(client: NextcloudClient): RemoteOperationResult<TaskTypes> {
+        var result: RemoteOperationResult<TaskTypes>
+        var getMethod: GetMethod? = null
+        try {
+            getMethod =
+                GetMethod(client.baseUri.toString() + DIRECT_ENDPOINT + JSON_FORMAT, true)
+            val status = client.execute(getMethod)
+            if (status == HttpStatus.SC_OK) {
+                val taskTypes: TaskTypes =
+                    getServerResponse(
+                        getMethod,
+                        object : TypeToken<ServerResponse<TaskTypes>>() {}
+                    )
+                        .ocs.data
+                result = RemoteOperationResult(true, getMethod)
+                result.setResultData(taskTypes)
+            } else {
+                result = RemoteOperationResult(false, getMethod)
+            }
+        } catch (e: Exception) {
+            result = RemoteOperationResult(e)
+            Log_OC.e(
+                TAG,
+                "Get task types for user " + " failed: " + result.logMessage,
+                result.exception
+            )
+        } finally {
+            getMethod?.releaseConnection()
+        }
+        return result
+    }
+
+    companion object {
+        private val TAG = GetTaskTypesRemoteOperation::class.java.simpleName
+        private const val DIRECT_ENDPOINT = "/ocs/v2.php/textprocessing/tasktypes"
+    }
+}

library/src/main/java/com/owncloud/android/lib/resources/assistant/model/TaskList.kt

@@ -0,0 +1,38 @@
+/*
+ * Nextcloud Android client application
+ *
+ * @author Alper Ozturk
+ * Copyright (C) 2024 Alper Ozturk
+ * Copyright (C) 2024 Nextcloud GmbH
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program 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 Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <https://www.gnu.org/licenses/>.
+ */
+
+package com.owncloud.android.lib.resources.assistant.model
+
+data class TaskList (
+    val tasks: List<Task>
+)
+
+data class Task (
+    val id: Long,
+    val type: String,
+    val status: Long,
+    val userId: String,
+    val appId: String,
+    val input: String,
+    val output: String,
+    val identifier: String,
+    val completionExpectedAt: String? = null
+)

library/src/main/java/com/owncloud/android/lib/resources/assistant/model/TaskTypes.kt

@@ -0,0 +1,32 @@
+/*
+ * Nextcloud Android client application
+ *
+ * @author Alper Ozturk
+ * Copyright (C) 2024 Alper Ozturk
+ * Copyright (C) 2024 Nextcloud GmbH
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program 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 Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <https://www.gnu.org/licenses/>.
+ */
+
+package com.owncloud.android.lib.resources.assistant.model
+
+data class TaskTypes (
+    val types: List<TaskType>
+)
+
+data class TaskType(
+    val id: String,
+    val name: String,
+    val description: String
+)