moxxy/lib/repositories/database.dart

import "dart:collection";

import "package:moxxyv2/db/conversation.dart";
import "package:moxxyv2/db/message.dart";
import "package:moxxyv2/db/roster.dart";
import "package:moxxyv2/models/conversation.dart";
import "package:moxxyv2/models/message.dart";
import "package:moxxyv2/redux/state.dart";
import "package:moxxyv2/redux/conversation/actions.dart";

import "package:isar/isar.dart";
import "package:redux/redux.dart";

import "package:moxxyv2/isar.g.dart";

class DatabaseRepository {
  final Isar isar;
  final Store<MoxxyState> store;

  final HashMap<int, DBConversation> _cache = HashMap();
  final List<String> loadedConversations = List.empty(growable: true);
  
  DatabaseRepository({ required this.isar, required this.store });

  /// Loads all conversations from the database and adds them to the state and cache.
  Future<void> loadConversations() async {
    var conversations = await this.isar.dBConversations.where().findAll();

    store.dispatch(AddMultipleConversationsAction(
        conversations: conversations.map((c) {
            this._cache[c.id!] = c;
            return Conversation(
              id: c.id!,
              title: c.title,
              jid: c.jid,
              avatarUrl: c.avatarUrl,
              lastMessageBody: c.lastMessageBody,
              unreadCounter: c.unreadCounter,
              lastChangeTimestamp: c.lastChangeTimestamp,
              sharedMediaPaths: [],
              open: c.open
            );
          }
        ).toList()
      )
    );
  }

  /// Loads all messages for the conversation with jid [jid].
  Future<void> loadMessagesForJid(String jid) async {
    final messages = await this.isar.dBMessages.where().conversationJidEqualTo(jid).findAll();
    this.loadedConversations.add(jid);

    store.dispatch(AddMultipleMessagesAction(
        conversationJid: jid,
        messages: messages.map((m) => Message(
            from: m.from,
            conversationJid: m.conversationJid,
            body: m.body,
            timestamp: m.timestamp,
            sent: m.sent,
            id: m.id!
        )).toList()
    ));
  }

  /// Updates the conversation with id [id] inside the database.
  Future<void> updateConversation({ required int id, String? lastMessageBody, int? lastChangeTimestamp, bool? open, int? unreadCounter }) async {
    print("updateConversation");

    final c = this._cache[id]!;
    if (lastMessageBody != null) {
      c.lastMessageBody = lastMessageBody;
    }
    if (lastChangeTimestamp != null) {
      c.lastChangeTimestamp = lastChangeTimestamp;
    }
    if (open != null) {
      c.open = open;
    }
    if (unreadCounter != null) {
      c.unreadCounter = unreadCounter;
    }

    await this.isar.writeTxn((isar) async {
        await isar.dBConversations.put(c);
        print("DONE");
    });
  }

  /// Creates a [Conversation] inside the database given the data. This is so that the
  /// [Conversation] object can carry its database id.
  Future<Conversation> addConversationFromData(String title, String lastMessageBody, String avatarUrl, String jid, int unreadCounter, int lastChangeTimestamp, List<String> sharedMediaPaths, bool open) async {
    print("addConversationFromAction");
    final c = DBConversation()
      ..jid = jid
      ..title = title
      ..avatarUrl = avatarUrl
      ..lastChangeTimestamp = lastChangeTimestamp
      ..unreadCounter = unreadCounter
      ..lastMessageBody = lastMessageBody
      ..open = open;
    await this.isar.writeTxn((isar) async {
        await isar.dBConversations.put(c);
        print("DONE");
    });
    this._cache[c.id!] = c;

    return Conversation(
      title: title,
      lastMessageBody: lastMessageBody,
      avatarUrl: avatarUrl,
      jid: jid,
      id: c.id!,
      unreadCounter: unreadCounter,
      lastChangeTimestamp: lastChangeTimestamp,
      sharedMediaPaths: sharedMediaPaths,
      open: open
    );
  }

  /// Same as [this.addConversationFromData] but for a [Message].
  Future<Message> addMessageFromData(String body, int timestamp, String from, String conversationJid, bool sent) async {
    print("addMessageFromData");
    final m = DBMessage()
      ..from = from
      ..conversationJid = conversationJid
      ..timestamp = timestamp
      ..body = body
      ..sent = sent;
      
    await this.isar.writeTxn((isar) async {
        await isar.dBMessages.put(m);
        print("DONE");
    });

    return Message(
      body: body,
      from: from,
      conversationJid: conversationJid,
      timestamp: timestamp,
      sent: sent,
      id: m.id!
    );
  }
}