blob: bb55834865e2e4e2bde87e08b226042541c6c794 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
|
import 'package:auto_gpt_flutter_client/models/task.dart';
import 'package:auto_gpt_flutter_client/models/task_request_body.dart';
import 'package:auto_gpt_flutter_client/models/task_response.dart';
import 'package:auto_gpt_flutter_client/services/shared_preferences_service.dart';
import 'package:auto_gpt_flutter_client/utils/rest_api_utility.dart';
/// Service class for performing task-related operations.
class TaskService {
final RestApiUtility api;
final SharedPreferencesService prefsService;
List<String> _deletedTaskIds = [];
TaskService(this.api, this.prefsService);
/// Creates a new task.
///
/// [taskRequestBody] is a Map representing the request body for creating a task.
Future<Map<String, dynamic>> createTask(
TaskRequestBody taskRequestBody) async {
try {
return await api.post('agent/tasks', taskRequestBody.toJson());
} catch (e) {
// TODO: We are bubbling up the full response. Revisit this.
rethrow;
}
}
/// Fetches a single page of tasks.
///
/// [currentPage] and [pageSize] are pagination parameters.
Future<TaskResponse> fetchTasksPage(
{int currentPage = 1, int pageSize = 10}) async {
try {
final response = await api
.get('agent/tasks?current_page=$currentPage&page_size=$pageSize');
return TaskResponse.fromJson(response);
} catch (e) {
throw Exception('Failed to fetch a page of tasks: $e');
}
}
/// Fetches all tasks across all pages.
// TODO: Temporaily make page size 10000 until pagination is fixed
Future<List<Task>> fetchAllTasks({int pageSize = 10000}) async {
int currentPage = 1;
List<Task> allTasks = [];
while (true) {
final response =
await fetchTasksPage(currentPage: currentPage, pageSize: pageSize);
allTasks.addAll(response.tasks);
if (response.tasks.length < pageSize) {
// No more tasks to fetch
break;
}
currentPage++;
}
return allTasks;
}
/// Gets details about a specific task.
///
/// [taskId] is the ID of the task.
Future<Map<String, dynamic>> getTaskDetails(String taskId) async {
try {
return await api.get('agent/tasks/$taskId');
} catch (e) {
throw Exception('Failed to get task details: $e');
}
}
/// Lists all artifacts for a specific task.
///
/// [taskId] is the ID of the task.
/// [currentPage] and [pageSize] are optional pagination parameters.
Future<Map<String, dynamic>> listTaskArtifacts(String taskId,
{int currentPage = 1, int pageSize = 10}) async {
try {
return await api.get(
'agent/tasks/$taskId/artifacts?current_page=$currentPage&page_size=$pageSize');
} catch (e) {
throw Exception('Failed to list task artifacts: $e');
}
}
Future<void> loadDeletedTasks() async {
_deletedTaskIds = await prefsService.getStringList('deletedTasks') ?? [];
print("Deleted tasks fetched successfully!");
}
void saveDeletedTask(String taskId) {
_deletedTaskIds.add(taskId);
prefsService.setStringList('deletedTasks', _deletedTaskIds);
print("Task $taskId deleted successfully!");
}
bool isTaskDeleted(String taskId) {
return _deletedTaskIds.contains(taskId);
}
}
|
