relatica/lib/services/direct_message_service.dart

import 'package:flutter/foundation.dart';
import 'package:logging/logging.dart';
import 'package:result_monad/result_monad.dart';

import '../friendica_client/paging_data.dart';
import '../globals.dart';
import '../models/direct_message.dart';
import '../models/direct_message_thread.dart';
import '../models/exec_error.dart';
import 'auth_service.dart';

class DirectMessageService extends ChangeNotifier {
  static final _logger = Logger('$DirectMessageService');
  final _threads = <String, DirectMessageThread>{};

  List<DirectMessageThread> get threads {
    if (_threads.isEmpty) {
      updateThreads();
    }

    return _threads.values.toList();
  }

  Result<DirectMessageThread, ExecError> getThreadByParentUri(String uri) {
    if (_threads.containsKey(uri)) {
      return Result.ok(_threads[uri]!);
    }

    return buildErrorResult(
        type: ErrorType.notFound, message: 'Thread ID not found: $uri');
  }

  Future<void> updateThreads() async {
    await getIt<AuthService>()
        .currentClient
        .andThenAsync((client) => client.getDirectMessages(PagingData()))
        .match(
      onSuccess: (update) {
        final newThreads = DirectMessageThread.createThreads(update);
        _threads.clear();
        for (final t in newThreads) {
          //TODO do merge operation
          _threads[t.parentUri] = t;
        }
        _logger.fine(
            'Updated ${update.length} direct messages, across ${newThreads.length} threads');
        notifyListeners();
      },
      onError: (error) {
        _logger.severe('Error getting direct messages: $error');
      },
    );

    notifyListeners();
  }

  Future<void> markMessageRead(String threadId, DirectMessage m) async {
    final thread = _threads[threadId];
    if (thread == null) {
      _logger.severe('Message is not for this thread: $threadId, $m');
      return;
    }
    final oldIndex = thread.messages.indexOf(m);
    if (oldIndex < 0) {
      _logger.severe('Message is not for this thread: $threadId, $m');
      return;
    }

    await getIt<AuthService>()
        .currentClient
        .andThenAsync((client) => client.markDirectMessageRead(m))
        .match(
      onSuccess: (update) {
        thread.messages.removeAt(oldIndex);
        thread.messages.insert(oldIndex, update);
        notifyListeners();
      },
      onError: (error) {
        _logger.severe('Error getting direct messages: $error');
      },
    );
    notifyListeners();
  }
}