서버 연결 ã 코드 작성ì중

lib/services/chat_service.dart

@@ -0,0 +1,117 @@
+import 'dart:convert';
+import 'package:http/http.dart' as http;
+import '../models/chat_message.dart';
+
+class ChatService {
+  // 서버 URL
+  static const String serverUrl = 'http://49.238.167.71:8000/chat/';
+
+  // 타임아웃 설정 (초)
+  static const int timeoutSeconds = 30;
+
+  /// 사용자 메시지를 서버로 전송하고 응답을 받는 메서드
+  static Future<String> sendMessage(String userMessage) async {
+    try {
+      // 요청 생성
+      final requestBody = {
+        'device_id': 1,
+        'locale': 'ko-KR',
+        'message': userMessage,
+        'session_id': 'session-001',
+        'user_id': 'user-123',
+      };
+
+      // JSON 형식 확인
+      final jsonBody = jsonEncode(requestBody);
+      print('서버로 요청 전송 (Map): $requestBody');
+      print('서버로 요청 전송 (JSON): $jsonBody');
+
+      final uri = Uri.parse(serverUrl);
+      print('요청 URI: $uri');
+      print('요청 헤더: {Content-Type: application/json, accept: application/json}');
+      print('요청 바디: ${jsonEncode(requestBody)}');
+
+      // POST 요청 전송
+      final response = await http.post(
+        Uri.parse(serverUrl),
+        headers: {
+          'Content-Type': 'application/json',
+          'accept': 'application/json',
+        },
+        body: jsonEncode(requestBody),
+      ).timeout(
+        const Duration(seconds: timeoutSeconds),
+        onTimeout: () => throw TimeoutException('서버 응답 시간 초과'),
+      );
+
+      print('서버 응답 상태코드: ${response.statusCode}');
+      print('서버 응답 본문: ${response.body}');
+
+      // 상태 코드 확인
+      if (response.statusCode == 200) {
+        final jsonResponse = jsonDecode(response.body);
+
+        print('전체 응답: $jsonResponse');
+
+        // 'message' 필드 추출
+        final responseMessage = jsonResponse['message'] as String?;
+
+        if (responseMessage != null && responseMessage.isNotEmpty) {
+          print('응답 메시지: $responseMessage');
+          return responseMessage;
+        } else {
+          print('message 필드가 없습니다');
+          // 혹시 다른 필드에 응답이 있는지 확인
+          print('응답 전체: ${jsonResponse.toString()}');
+          return '응답을 받지 못했습니다';
+        }
+      } else {
+        // 실패
+        print('서버 오류: ${response.statusCode}');
+        return '서버 오류 (${response.statusCode})';
+      }
+    } on TimeoutException catch (e) {
+      print('타임아웃: $e');
+      return '서버 응답이 없습니다. 시간 초과';
+    } on FormatException catch (e) {
+      print('JSON 파싱 오류: $e');
+      return 'JSON 형식 오류';
+    } catch (e) {
+      print('오류 발생: $e');
+      return '오류가 발생했습니다: $e';
+    }
+  }
+
+  /// 서버 연결 테스트
+  static Future<bool> testConnection() async {
+    try {
+      print('서버 연결 테스트 중...');
+
+      final response = await http.get(
+        Uri.parse(serverUrl),
+      ).timeout(
+        const Duration(seconds: timeoutSeconds),
+      );
+
+      if (response.statusCode == 200 || response.statusCode == 405) {
+        print('서버 연결 성공');
+        return true;
+      } else {
+        print('서버 연결 실패: ${response.statusCode}');
+        return false;
+      }
+    } catch (e) {
+      print('서버 연결 오류: $e');
+      return false;
+    }
+  }
+}
+
+/// 타임아웃 예외
+class TimeoutException implements Exception {
+  final String message;
+  TimeoutException(this.message);
+
+  @override
+  String toString() => message;
+}