feat(dms): Connect DMs to backend (#114)

Author: ZiadMontaser

lam7a/lib/core/services/socket_service.dart

@@ -0,0 +1,153 @@
+import 'dart:io';
+
+import 'package:cookie_jar/cookie_jar.dart';
+import 'package:flutter_riverpod/flutter_riverpod.dart';
+import 'package:lam7a/core/constants/server_constant.dart';
+import 'package:lam7a/core/providers/authentication.dart';
+import 'package:lam7a/core/utils/logger.dart';
+import 'package:path_provider/path_provider.dart';
+import 'package:riverpod_annotation/riverpod_annotation.dart';
+import 'package:socket_io_client/socket_io_client.dart' as IO;
+import 'package:path/path.dart' as path;
+
+part 'socket_service.g.dart';
+
+
+final socketServiceProvider = Provider<SocketService>((ref) => SocketService());
+
+@Riverpod(keepAlive: true)
+void socketInitializer(Ref ref) {
+  final auth = ref.watch(authenticationProvider);
+  final socket = ref.read(socketServiceProvider);
+
+  if(auth.user != null){
+    socket.connect();
+  }else{
+    socket.disconnect();
+  }
+}
+
+class SocketService {
+  IO.Socket? _socket;
+
+  final Map<String, List<Function(dynamic)>> _listeners = {};
+
+
+  final _logger = getLogger(SocketService);
+
+  Future<void> connect() async {
+    if (_socket != null) {
+      _logger.i('Disposing existing socket');
+      try {
+        _socket!.disconnect();
+      } catch (_) {}
+      try {
+        _socket!.dispose();
+      } catch (_) {}
+      _socket = null;
+    }
+
+    _logger.i("Connecting to socket service");
+
+    var cookieHeader = await getCookie();
+
+    _socket = IO.io(
+      ServerConstant.serverURL,
+      IO.OptionBuilder()
+          .setTransports(['websocket'])
+          .enableReconnection()
+          .setExtraHeaders({'cookie': cookieHeader})
+          .build(),
+    );
+
+    _socket!.onError((err) => _logger.e(err.toString()));
+
+    _socket!.onConnect((_) => _logger.i('Connected to socket'));
+    _socket!.onDisconnect((_) => _logger.i('Disconnected'));
+
+    _attachStoredListeners();
+  }
+
+  Future<String> getCookie() async {
+    final directory = await getApplicationDocumentsDirectory();
+    final cookiePath = path.join(directory.path, '.cookies');
+    await Directory(cookiePath).create(recursive: true);
+
+    final cookieJar = PersistCookieJar(storage: FileStorage(cookiePath));
+
+    final uri = Uri.parse(ServerConstant.serverURL); // ← your API / socket domain
+    final cookies = await cookieJar.loadForRequest(uri);
+
+    if (cookies.isEmpty) {
+      _logger.w('⚠️ No cookies found in jar for $uri');
+      return "";
+    }
+
+    final cookieHeader = cookies.map((c) => '${c.name}=${c.value}').join('; ');
+
+    return cookieHeader;
+  }
+
+  void _attachStoredListeners() {
+    if (_socket == null) return;
+    _listeners.forEach((event, callbacks) {
+      for (final cb in callbacks) {
+        try {
+          _socket!.on(event, cb);
+        } catch (e, st) {
+          _logger.w('Failed to attach listener for "$event": $e\n$st');
+        }
+      }
+    });
+  }
+
+
+  void on(String event, Function(dynamic) callback) {
+    // store callback
+    _listeners.putIfAbsent(event, () => []).add(callback);
+
+    // attach to live socket if exists
+    try {
+      _socket?.on(event, callback);
+    } catch (e) {
+      _logger.w('Failed to attach on() for "$event": $e');
+    }
+  }
+
+
+  void emit(String event, dynamic data) {
+    if (_socket == null) {
+      _logger.w('Attempted to emit while socket is null. Event: $event');
+      return;
+    }
+    try {
+      _socket!.emit(event, data);
+    } catch (e) {
+      _logger.e('Failed to emit "$event": $e');
+    }
+  }
+
+
+  void off(String event, [Function(dynamic)? callback]) {
+    if (callback == null) {
+      _listeners.remove(event);
+      try {
+        _socket?.off(event);
+      } catch (e) {
+        _logger.w('Failed to off() for "$event": $e');
+      }
+    } else {
+      _listeners[event]?.remove(callback);
+      try {
+        _socket?.off(event, callback);
+      } catch (e) {
+        _logger.w('Failed to off(event, callback) for "$event": $e');
+      }
+    }
+  }
+
+  void disconnect() {
+    _logger.i("Disconnecting from socket");
+    _socket?.disconnect();
+  }
+}

lam7a/lib/core/utils/logger.dart

@@ -0,0 +1,36 @@
+import 'package:logger/logger.dart';
+
+import 'package:logger/logger.dart';
+
+class SimpleLogPrinter extends LogPrinter {
+  final String className;
+
+  SimpleLogPrinter(this.className);
+
+  @override
+  List<String> log(LogEvent event) {
+    final color = PrettyPrinter.defaultLevelColors[event.level]!;
+    final emoji = PrettyPrinter.defaultLevelEmojis[event.level];
+    final message = event.message;
+    final error = event.error;
+    final stackTrace = event.stackTrace;
+
+    final buffer = StringBuffer();
+
+    buffer.write('${color('$emoji $className - $message')}');
+
+    if (error != null) {
+      buffer.write('\n${color('Error: $error')}');
+    }
+
+    if (stackTrace != null) {
+      buffer.write('\n${color(stackTrace.toString())}');
+    }
+
+    return [buffer.toString()];
+  }
+}
+
+Logger getLogger(Type type) {
+  return Logger(printer: SimpleLogPrinter(type.toString()));
+}

lam7a/lib/features/common/dtos/api_response.dart

@@ -0,0 +1,48 @@
+import 'package:freezed_annotation/freezed_annotation.dart';
+import 'package:lam7a/features/messaging/dtos/conversation_dto.dart';
+
+part 'api_response.freezed.dart';
+part 'api_response.g.dart';
+
+@Freezed(genericArgumentFactories: true)
+abstract class ApiResponse<T> with _$ApiResponse<T> {
+  const factory ApiResponse({
+    required String status,
+    required T data,
+    required Metadata metadata,
+  }) = _ApiResponse<T>;
+
+  factory ApiResponse.fromJson(
+    Map<String, dynamic> json,
+    T Function(Object?) fromJsonT,
+  ) => _$ApiResponseFromJson(json, fromJsonT);
+}
+
+
+class Metadata {
+  final int totalItems;
+  final int page;
+  final int limit;
+  final int totalPages;
+
+  Metadata({
+    required this.totalItems,
+    required this.page,
+    required this.limit,
+    required this.totalPages,
+  });
+
+  factory Metadata.fromJson(Map<String, dynamic> json) => Metadata(
+        totalItems: json['totalItems'],
+        page: json['page'],
+        limit: json['limit'],
+        totalPages: json['totalPages'],
+      );
+
+  Map<String, dynamic> toJson() => {
+        'totalItems': totalItems,
+        'page': page,
+        'limit': limit,
+        'totalPages': totalPages,
+      };
+}

lam7a/lib/features/messaging/dtos/conversation_dto.dart

@@ -0,0 +1,33 @@
+import 'package:freezed_annotation/freezed_annotation.dart';
+import 'package:lam7a/features/messaging/dtos/message_socket_dtos.dart';
+
+part 'conversation_dto.freezed.dart';
+part 'conversation_dto.g.dart';
+
+@freezed
+abstract class ConversationDto with _$ConversationDto {
+  const factory ConversationDto({
+    required int id,
+    required String createdAt,
+    required DateTime updatedAt,
+    MessageDto? lastMessage,
+    required UserDto user,
+  }) = _ConversationDto;
+ 
+  factory ConversationDto.fromJson(Map<String, dynamic> json) =>
+      _$ConversationDtoFromJson(json);
+}
+
+
+@freezed
+abstract class UserDto with _$UserDto {
+  const factory UserDto({
+    required int id,
+    required String username,
+    @JsonKey(name: 'profile_image_url') String? profileImageUrl,
+    required String displayName,
+  }) = _UserDto;
+
+  factory UserDto.fromJson(Map<String, dynamic> json) =>
+      _$UserDtoFromJson(json);
+}