feat(chatbot): integrate create task, answer question for chatbot

Author: tqha1011

src/lib/features/chatbot/services/chatbot_services.dart

@@ -1,6 +1,7 @@
 import 'package:flutter/foundation.dart';
 import 'package:flutter_dotenv/flutter_dotenv.dart';
 import 'package:google_generative_ai/google_generative_ai.dart';
+import 'package:supabase_flutter/supabase_flutter.dart';
 
 class ChatBotAssistantService {
   final String _apiKey = (dotenv.env['GEMINI_API_KEY'] ?? '').trim();
@@ -16,6 +17,37 @@ class ChatBotAssistantService {
     _model = GenerativeModel(
       apiKey: _apiKey,
       model: 'gemini-2.5-flash',
+      tools: [
+        Tool(
+          functionDeclarations: [
+            FunctionDeclaration(
+              'create_task_full',
+              'Tạo một công việc mới. Hãy tự động trích xuất tên công việc, suy luận độ ưu tiên (1-Thấp, 2-Trung bình, 3-Cao) và các thẻ (tags) dựa trên câu nói của người dùng.',
+              Schema(
+                SchemaType.object,
+                properties: {
+                  'title': Schema(
+                    SchemaType.string,
+                    description: 'Tên công việc cần làm',
+                  ),
+                  'priority': Schema(
+                    SchemaType.integer,
+                    description:
+                        'Độ ưu tiên: 1 (Thấp), 2 (Trung bình), 3 (Cao). Nếu người dùng không nói rõ, mặc định là 1.',
+                  ),
+                  'tags': Schema(
+                    SchemaType.array,
+                    items: Schema(SchemaType.string),
+                    description:
+                        'Danh sách các thẻ phân loại (ví dụ: ["Học tập", "Gấp", "Backend"]). Gửi mảng rỗng [] nếu không có.',
+                  ),
+                },
+                requiredProperties: ['title', 'priority', 'tags'],
+              ),
+            ),
+          ],
+        ),
+      ],
       systemInstruction: Content.system(
         'Bạn là một chuyên gia quản lý thời gian và trợ lý năng suất cho ứng dụng Task Management. '
         'Nhiệm vụ của bạn là đưa ra lời khuyên ngắn gọn (dưới 100 chữ), thực tế để giúp người dùng '
@@ -36,8 +68,48 @@ class ChatBotAssistantService {
       final response = await _chatSession!.sendMessage(
         Content.text(userMessage),
       );
+
+      if (response.functionCalls.isNotEmpty) {
+        final functionCall = response.functionCalls.first;
+        if (functionCall.name == 'create_task_full') {
+          final args = functionCall.args;
+          final title = args['title'] as String;
+          final priority = (args['priority'] as num?)?.toInt() ?? 1;
+          final rawTags = args['tags'] as List<dynamic>? ?? [];
+          final tags = rawTags.map((e) => e.toString()).toList();
+
+          final userId = Supabase.instance.client.auth.currentUser?.id;
+          if (userId == null) {
+            return 'Vui lòng đăng nhập để tạo công việc.';
+          }
+
+          final dbResponse = await Supabase.instance.client.rpc(
+            'create_task_full',
+            params: {
+              'p_title': title,
+              'p_priority': priority,
+              'p_profile_id': userId,
+              'p_tag_names': tags,
+            },
+          );
+
+          final isSuccess = dbResponse['success'] == true;
+          final functionResponse = await _chatSession!.sendMessage(
+            Content.functionResponse('create_task_full', {
+              'status': isSuccess ? 'Thành công' : 'Thất bại',
+            }),
+          );
+          return functionResponse.text ?? 'Đã xử lý xong yêu cầu của bạn!';
+        }
+      }
       return response.text ?? 'Xin lỗi, trợ lý đang bận xíu. Thử lại sau nhé!';
     } catch (e) {
+      final errorString = e.toString();
+      if (errorString.contains('503')) {
+        return 'Bạn đợi vài phút rồi chat lại nhé!';
+      } else if (errorString.contains('429')) {
+        return 'Bạn chat nhanh quá! Vui lòng chờ chút';
+      }
       return 'Lỗi kết nối AI: $e';
     }
   }

src/lib/features/chatbot/view/widgets/chat_header.dart

@@ -38,10 +38,6 @@ class ChatHeader extends StatelessWidget {
               ],
             ),
           ),
-          IconButton(
-            onPressed: () {},
-            icon: Icon(Icons.settings, color: scheme.onSurfaceVariant),
-          ),
         ],
       ),
     );

supabase/migrations/20260417060333_chatbot_add_task_rpc.sql

@@ -0,0 +1,52 @@
+CREATE OR REPLACE FUNCTION create_task_full(
+  p_title TEXT,
+  p_priority INT4,
+  p_profile_id UUID,
+  p_tag_names TEXT[]
+)
+RETURNS JSON
+LANGUAGE plpgsql
+AS $$
+DECLARE
+  v_task_id INT8;
+  v_tag_name TEXT;
+  v_tag_id INT8;
+BEGIN
+
+  INSERT INTO task (title, priority, profile_id, status)
+  VALUES (p_title, p_priority, p_profile_id, 0)
+  RETURNING id INTO v_task_id;
+
+  IF p_tag_names IS NOT NULL THEN
+    FOREACH v_tag_name IN ARRAY p_tag_names
+    LOOP
+      v_tag_name := trim(v_tag_name);
+      
+      IF v_tag_name != '' THEN
+        INSERT INTO tag (name, profile_id, color_code)
+        VALUES (v_tag_name, p_profile_id, '#6200EE')
+        ON CONFLICT (name, profile_id) 
+        DO UPDATE SET name = EXCLUDED.name
+        RETURNING id INTO v_tag_id;
+
+
+        INSERT INTO task_tags (task_id, tag_id)
+        VALUES (v_task_id, v_tag_id)
+        ON CONFLICT DO NOTHING;
+      END IF;
+    END LOOP;
+  END IF;
+
+  RETURN json_build_object(
+    'success', true,
+    'task_id', v_task_id,
+    'message', 'Đã tạo task với priority ' || p_priority
+  );
+
+EXCEPTION WHEN OTHERS THEN
+  RETURN json_build_object(
+    'success', false,
+    'error', SQLERRM
+  );
+END;
+$$;