Feature/4 kt 21 implement chat get feature

lib/api/message.dart

@@ -2,18 +2,20 @@ import 'package:dio/dio.dart';
 
 import 'package:kuna_talk/api/config.dart';
 import 'package:kuna_talk/dto/create_message_dto.dart';
-import 'package:kuna_talk/dto/fetch_message_dto.dart';
+import 'package:kuna_talk/dto/fetch_all_messages.dto.dart';
+import 'package:kuna_talk/dto/fetch_messages_in_minute_dto.dart';
 import 'package:kuna_talk/models/message.dart';
 
 final Dio dio = DioClient().dio;
 
+// create
 Future<Message> createMessage(CreateMessageDto data) async {
   try {
     final response = await dio.post('/chat', data: data);
     final result = Message.fromJson(response.data);
 
     if (response.statusCode == 201) {
-      print('createMessage111: $result');
+      print('createMessage: $result');
 
       return result;
     } else {
@@ -26,11 +28,36 @@ Future<Message> createMessage(CreateMessageDto data) async {
   }
 }
 
-Future<List<Message>> fetchMessage(FetchMessageDto data) async {
+// read
+Future<List<Message>> fetchAllMessages(FetchAllMessagesDto data) async {
   try {
     final response = await dio.get('/chat', queryParameters: {
       'senderId': data.senderId,
       'receiverId': data.receiverId,
+    });
+
+    final result =
+        (response.data as List).map((json) => Message.fromJson(json)).toList();
+
+    if (response.statusCode == 200) {
+      print('fetchAllMessages: ${result[0].message}');
+      return result;
+    } else {
+      print('Failed to send message');
+      throw Exception(
+          'createMessage API error ${response.statusCode} ${response.statusMessage}');
+    }
+  } catch (e) {
+    throw Exception('createMessage API error: $e');
+  }
+}
+
+Future<List<Message>> fetchMessagesInMinute(
+    FetchMessageInMinuteDto data) async {
+  try {
+    final response = await dio.get('/chat/minute', queryParameters: {
+      'senderId': data.senderId,
+      'receiverId': data.receiverId,
       'createdAt': data.createdAt
     });
 

lib/chat.dart

@@ -2,7 +2,8 @@ import 'package:flutter/material.dart';
 
 import 'package:kuna_talk/api/message.dart';
 import 'package:kuna_talk/dto/create_message_dto.dart';
-import 'package:kuna_talk/dto/fetch_message_dto.dart';
+import 'package:kuna_talk/dto/fetch_all_messages.dto.dart';
+import 'package:kuna_talk/dto/fetch_messages_in_minute_dto.dart';
 import 'package:kuna_talk/models/message.dart';
 import 'package:kuna_talk/utils/util.dart';
 
@@ -17,26 +18,40 @@ class ChatState extends State<Chat> {
   final person1 = '4rwodzn1uuacfpq';
   final person2 = 'c4w28yb8dmgo4lz';
 
-  final TextEditingController controller = TextEditingController();
   List<Message> messages = [];
-  String? message;
+
+  final TextEditingController controller = TextEditingController();
 
   @override
   void initState() {
     super.initState();
-    loadMessages();
+    loadAllMessages();
+  }
+
+  Future<void> loadAllMessages() async {
+    final response = await fetchAllMessages(
+      FetchAllMessagesDto(senderId: person1, receiverId: person2),
+    );
+
+    setState(() {
+      messages = response;
+    });
   }
 
-  Future<void> loadMessages({DateTime? createdAt}) async {
+  Future<void> loadMessagesInMinute(DateTime createdAt) async {
     try {
-      final response = await fetchMessage(
-        FetchMessageDto(
+      final response = await fetchMessagesInMinute(
+        FetchMessageInMinuteDto(
           senderId: person1,
           receiverId: person2,
-          createdAt: createdAt!,
+          createdAt: createdAt,
         ),
       );
 
+      List<String> ids = messages.map((item) => item.messageId).toList();
+
+      response.removeWhere((item) => ids.contains(item.messageId));
+
       setState(() {
         messages.addAll(response);
       });
@@ -46,6 +61,8 @@ class ChatState extends State<Chat> {
   }
 
   Future<void> sendMessage(String message) async {
+    final messageId = generateRandomId(15);
+
     if (message.isEmpty) {
       print('Message required');
       return;
@@ -54,7 +71,7 @@ class ChatState extends State<Chat> {
     final data = CreateMessageDto(
       senderId: person1,
       receiverId: person2,
-      messageId: generateRandomId(15),
+      messageId: messageId,
       message: message,
       updatedAt: DateTime.now(),
       createdAt: DateTime.now(),
@@ -64,12 +81,10 @@ class ChatState extends State<Chat> {
       final response = await createMessage(data);
 
       setState(() {
-        messages.add(response);
-        message = response.message;
         controller.clear();
       });
 
-      loadMessages(createdAt: response.createdAt);
+      loadMessagesInMinute(response.createdAt);
     } catch (e) {
       throw Exception('sendMessage error: $e');
     }

lib/dto/fetch_all_messages.dto.dart

@@ -0,0 +1,27 @@
+import 'package:json_annotation/json_annotation.dart';
+
+part 'fetch_all_messages.dto.g.dart';
+
+@JsonSerializable()
+class FetchAllMessagesDto {
+  @JsonKey(required: true)
+  final String senderId;
+
+  @JsonKey(required: true)
+  final String receiverId;
+
+  FetchAllMessagesDto({
+    required this.senderId,
+    required this.receiverId,
+  });
+
+  /// Connect the generated [_$FetchAllMessagesDtoFromJson] function to the `fromJson`
+  /// factory.
+  factory FetchAllMessagesDto.fromJson(Map<String, dynamic> json) =>
+      _$FetchAllMessagesDtoFromJson(json);
+
+  /// Connect the generated [_$FetchAllMessagesDtoToJson] function to the `toJson` method.
+  Map<String, dynamic> toJson() => _$FetchAllMessagesDtoToJson(this);
+}
+
+// dart run build_runner build

lib/dto/fetch_messages_in_minute_dto.dart

@@ -0,0 +1,31 @@
+import 'package:json_annotation/json_annotation.dart';
+
+part 'fetch_messages_in_minute_dto.g.dart';
+
+@JsonSerializable()
+class FetchMessageInMinuteDto {
+  @JsonKey(required: true)
+  final String senderId;
+
+  @JsonKey(required: true)
+  final String receiverId;
+
+  @JsonKey(required: true)
+  final DateTime createdAt;
+
+  FetchMessageInMinuteDto({
+    required this.senderId,
+    required this.receiverId,
+    required this.createdAt,
+  });
+
+  /// Connect the generated [_$FetchMessageInMinuteDtoFromJson] function to the `fromJson`
+  /// factory.
+  factory FetchMessageInMinuteDto.fromJson(Map<String, dynamic> json) =>
+      _$FetchMessageInMinuteDtoFromJson(json);
+
+  /// Connect the generated [_$FetchMessageInMinuteDtoToJson] function to the `toJson` method.
+  Map<String, dynamic> toJson() => _$FetchMessageInMinuteDtoToJson(this);
+}
+
+// dart run build_runner build