watchRecent method

Stream<List<DtoChat>> watchRecent({
  1. int? limit,
})

Returns the Stream of recent DtoChats being in a historical order.

Implementation

Stream<List<DtoChat>> watchRecent({int? limit}) {
  return stream((db) {
    final stmt = db.select(db.chats);

    stmt.where(
      (u) =>
          u.isHidden.equals(false) &
          u.id.like('local_%').not() &
          u.id.like('d_%').not() &
          u.favoritePosition.isNull(),
    );
    stmt.orderBy([(u) => OrderingTerm.desc(u.updatedAt)]);

    if (limit != null) {
      stmt.limit(limit);
    }

    return stmt.watch().map((rows) => rows.map(_ChatDb.fromDb).toList());
  });
}