refactor feature fetch message structure

lib/core/data/model/query/query_parameter.dart

@@ -0,0 +1,22 @@
+abstract class QueryParameter<T> {
+  final String queryName;
+  final T queryValue;
+
+  QueryParameter(this.queryName, this.queryValue);
+}
+
+class BooleanQueryParameter extends QueryParameter<bool> {
+  BooleanQueryParameter(String queryName, bool queryValue) : super(queryName, queryValue);
+}
+
+class StringQueryParameter extends QueryParameter<String> {
+  StringQueryParameter(String queryName, String queryValue) : super(queryName, queryValue);
+}
+
+class IntQueryParameter extends QueryParameter<int> {
+  IntQueryParameter(String queryName, int queryValue) : super(queryName, queryValue);
+}
+
+extension ListQueryParameterExtension on List<QueryParameter?> {
+  Map<String, dynamic> toMap() => { for (var data in this) if (data != null) data.queryName : data.queryValue };
+}

lib/core/domain/repository/repository.dart

@@ -0,0 +1,17 @@
+import 'package:flutter/material.dart';
+import 'package:twake/models/globals/globals.dart';
+
+abstract class RepositoryHelper {
+  navigatorDatasource({
+    VoidCallback? onLocal,
+    VoidCallback? onRemote,
+  }) {
+    if (!Globals.instance.isNetworkConnected) {
+      onLocal?.call();
+      return;
+    }
+    onRemote?.call();
+  }
+}
+
+abstract class Repository with RepositoryHelper {}

lib/core/domain/state/app_state.dart

@@ -0,0 +1,16 @@
+import 'package:dartz/dartz.dart';
+import 'package:meta/meta.dart';
+import 'package:equatable/equatable.dart';
+import 'package:twake/core/domain/state/failure.dart';
+import 'package:twake/core/domain/state/success.dart';
+
+
+@immutable
+abstract class AppState with EquatableMixin {
+  final Either<Failure, Success> viewState;
+
+  AppState(this.viewState);
+
+  @override
+  List<Object?> get props => [viewState];
+}

lib/core/domain/state/failure.dart

@@ -0,0 +1,16 @@
+import 'package:equatable/equatable.dart';
+
+abstract class Failure extends Equatable {}
+
+abstract class FeatureFailure extends Failure {}
+
+class ExceptionFailure extends Failure {
+  final dynamic exception;
+
+  ExceptionFailure(this.exception);
+
+  @override
+  List<Object?> get props => [
+        exception,
+      ];
+}

lib/core/domain/state/success.dart

@@ -0,0 +1,48 @@
+import 'package:equatable/equatable.dart';
+
+abstract class Success with EquatableMixin {}
+
+abstract class ViewState extends Success {}
+
+abstract class ViewEvent extends Success {}
+
+class UIState extends ViewState {
+  static final idle = UIState();
+
+  UIState() : super();
+
+  @override
+  List<Object?> get props => [];
+}
+
+class SuccessUIState<T> extends ViewState {
+  final T result;
+
+  SuccessUIState(this.result) : super();
+
+  @override
+  List<Object?> get props => [
+        result,
+      ];
+}
+
+class LoadingState extends UIState {
+  LoadingState();
+
+  @override
+  List<Object?> get props => [];
+}
+
+class LoadingMoreState extends UIState {
+  LoadingMoreState();
+
+  @override
+  List<Object?> get props => [];
+}
+
+class RefreshingState extends UIState {
+  RefreshingState();
+
+  @override
+  List<Object?> get props => [];
+}

lib/core/domain/use_case/use_case.dart

@@ -0,0 +1,12 @@
+import 'package:dartz/dartz.dart';
+import 'package:twake/core/domain/state/failure.dart';
+
+abstract class UseCase<Input extends UseCaseInput, Success> {
+  Either<ExceptionFailure, Success> execute({required Input input});
+}
+
+abstract class NonInputUseCase<Success> {
+  Either<ExceptionFailure, Success> execute();
+}
+
+abstract class UseCaseInput {}

lib/features/message/data/datasource/message_datasource.dart

@@ -0,0 +1,16 @@
+import 'package:twake/features/message/data/model/message/response/message.dart';
+
+abstract class MessageDataSource {
+  Future<List<Message>> fetch({
+    String? companyId,
+    String? workspaceId,
+    required String channelId,
+    String? threadId,
+    String? afterMessageId,
+    bool? withExistedFiles = false,
+  });
+
+  Future<void> multiInsert({
+    required Iterable<Message> data,
+  });
+}

lib/features/message/data/datasource_impl/local_message_datasource_impl.dart

@@ -0,0 +1,47 @@
+import 'package:twake/features/message/data/datasource/message_datasource.dart';
+import 'package:twake/features/message/data/model/message/response/message.dart';
+import 'package:twake/services/storage_service.dart';
+
+class LocalMessageDataSourceImpl extends MessageDataSource {
+  final _storage = StorageService.instance;
+
+  @override
+  Future<List<Message>> fetch(
+      {String? companyId,
+      String? workspaceId,
+      required String channelId,
+      String? threadId,
+      String? afterMessageId,
+      bool? withExistedFiles = false}) async {
+    var where = 'channel_id = ?';
+    if (threadId == null) {
+      where += ' AND thread_id = id';
+    } else {
+      where += ' AND thread_id = ?';
+    }
+    if (withExistedFiles == true) {
+      where += ' AND files <> ?';
+    }
+
+    final localResult = await _storage.select(
+      table: Table.message,
+      where: where,
+      limit: threadId == null ? 25 : 9999,
+      orderBy: 'created_at DESC',
+      whereArgs: [
+        channelId,
+        if (threadId != null) threadId,
+        if (withExistedFiles == true) '[]'
+      ],
+    );
+    final messages =
+        localResult.map((entry) => Message.fromJson(entry)).toList();
+
+    return messages;
+  }
+
+  @override
+  Future<void> multiInsert({required Iterable<Message> data}) async {
+    await _storage.multiInsert(table: Table.message, data: data);
+  }
+}

lib/features/message/data/datasource_impl/remote_message_datasource_impl.dart

@@ -0,0 +1,87 @@
+import 'package:sprintf/sprintf.dart';
+import 'package:twake/core/data/model/query/query_parameter.dart';
+import 'package:twake/features/message/data/datasource/message_datasource.dart';
+import 'package:twake/features/message/data/model/message/response/message.dart';
+import 'package:twake/models/globals/globals.dart';
+import 'package:twake/services/api_service.dart';
+import 'package:twake/services/endpoints.dart';
+
+class RemoteMessageDataSourceImpl extends MessageDataSource {
+  final _api = ApiService.instance;
+
+  @override
+  Future<List<Message>> fetch(
+      {String? companyId,
+      String? workspaceId,
+      required String channelId,
+      String? threadId,
+      String? afterMessageId,
+      bool? withExistedFiles = false}) async {
+    List<dynamic> remoteResult;
+
+    final queryParameters = <QueryParameter?>[
+      IntQueryParameter('include_users', 1),
+      BooleanQueryParameter('emoji', false),
+      StringQueryParameter('direction', 'history'),
+      IntQueryParameter('limit', 25),
+    ];
+
+    if (afterMessageId != null) {
+      queryParameters.addAll([
+        StringQueryParameter('page_token', afterMessageId),
+        StringQueryParameter('direction', 'future'),
+      ]);
+    }
+    if (withExistedFiles == true) {
+      queryParameters.add(
+        StringQueryParameter('filter', 'files'),
+       );
+    }
+    if (threadId == null) {
+      remoteResult = await _api.get(
+        endpoint: sprintf(Endpoint.threadsChannel, [
+          companyId ?? Globals.instance.companyId,
+          workspaceId ?? Globals.instance.workspaceId,
+          channelId
+        ]),
+        queryParameters: queryParameters.toMap(),
+        key: 'resources',
+      );
+    } else {
+      final queryParameters = <QueryParameter?>[
+        IntQueryParameter('include_users', 1),
+        BooleanQueryParameter('emoji', false),
+        StringQueryParameter('direction', 'history'),
+      ];
+
+      remoteResult = await _api.get(
+        endpoint: sprintf(Endpoint.threadMessages, [
+          companyId ?? Globals.instance.companyId,
+          threadId,
+        ]),
+        queryParameters: queryParameters.toMap(),
+        key: 'resources',
+      );
+    }
+
+    return remoteResult
+        .where((rm) =>
+            rm['type'] == 'message' &&
+            rm['subtype'] != 'system' &&
+            rm['subtype'] !=
+                'application') // TODO remove the last condition once the support for applications has been implemented
+        .map((entry) => Message.fromJson(
+              entry,
+              channelId: channelId,
+              jsonify: true,
+              transform: true,
+            ))
+        .toList();
+  }
+
+  @override
+  Future<void> multiInsert({required Iterable<Message> data}) {
+    // TODO: implement multiInsert
+    throw UnimplementedError();
+  }
+}