164 lines
5.8 KiB
Dart
164 lines
5.8 KiB
Dart
import 'dart:async';
|
|
|
|
import 'package:contacts_plus_plus/clients/api_client.dart';
|
|
import 'package:contacts_plus_plus/apis/friend_api.dart';
|
|
import 'package:contacts_plus_plus/apis/message_api.dart';
|
|
import 'package:contacts_plus_plus/models/friend.dart';
|
|
import 'package:contacts_plus_plus/models/message.dart';
|
|
import 'package:contacts_plus_plus/widgets/default_error_widget.dart';
|
|
import 'package:contacts_plus_plus/widgets/expanding_input_fab.dart';
|
|
import 'package:contacts_plus_plus/widgets/friend_list_tile.dart';
|
|
import 'package:contacts_plus_plus/widgets/settings_page.dart';
|
|
import 'package:flutter/material.dart';
|
|
import 'package:flutter_local_notifications/flutter_local_notifications.dart' as fln;
|
|
|
|
class FriendsList extends StatefulWidget {
|
|
const FriendsList({super.key});
|
|
|
|
@override
|
|
State<FriendsList> createState() => _FriendsListState();
|
|
}
|
|
|
|
class _FriendsListState extends State<FriendsList> {
|
|
Future<List<Friend>>? _friendsFuture;
|
|
ClientHolder? _clientHolder;
|
|
Timer? _debouncer;
|
|
String _searchFilter = "";
|
|
final _unreads = <String, List<Message>>{};
|
|
|
|
@override
|
|
void dispose() {
|
|
_debouncer?.cancel();
|
|
super.dispose();
|
|
}
|
|
|
|
@override
|
|
void didChangeDependencies() async {
|
|
super.didChangeDependencies();
|
|
final clientHolder = ClientHolder.of(context);
|
|
if (_clientHolder != clientHolder) {
|
|
_clientHolder = clientHolder;
|
|
_refreshFriendsList();
|
|
}
|
|
}
|
|
|
|
void _refreshFriendsList() {
|
|
_friendsFuture = FriendApi.getFriendsList(_clientHolder!.apiClient).then((Iterable<Friend> value) async {
|
|
final unreadMessages = await MessageApi.getUserMessages(_clientHolder!.apiClient, unreadOnly: true);
|
|
_unreads.clear();
|
|
|
|
for (final msg in unreadMessages) {
|
|
if (msg.senderId != _clientHolder!.apiClient.userId) {
|
|
final value = _unreads[msg.senderId];
|
|
if (value == null) {
|
|
_unreads[msg.senderId] = [msg];
|
|
} else {
|
|
value.add(msg);
|
|
}
|
|
}
|
|
}
|
|
|
|
final friends = value.toList()
|
|
..sort((a, b) {
|
|
var aVal = _unreads.containsKey(a.id) ? -3 : 0;
|
|
var bVal = _unreads.containsKey(b.id) ? -3 : 0;
|
|
|
|
aVal -= a.userStatus.lastStatusChange.compareTo(b.userStatus.lastStatusChange);
|
|
aVal += a.userStatus.onlineStatus.compareTo(b.userStatus.onlineStatus) * 2;
|
|
return aVal.compareTo(bVal);
|
|
});
|
|
return friends;
|
|
});
|
|
}
|
|
|
|
@override
|
|
Widget build(BuildContext context) {
|
|
return Scaffold(
|
|
appBar: AppBar(
|
|
title: const Text("Contacts++"),
|
|
actions: [
|
|
IconButton(
|
|
onPressed: () {
|
|
Navigator.of(context).push(MaterialPageRoute(builder: (context) => const SettingsPage()));
|
|
},
|
|
icon: const Icon(Icons.settings),
|
|
)
|
|
],
|
|
),
|
|
body: Stack(
|
|
children: [
|
|
RefreshIndicator(
|
|
onRefresh: () async {
|
|
_refreshFriendsList();
|
|
await _friendsFuture; // Keep the indicator running until everything's loaded
|
|
},
|
|
child: FutureBuilder(
|
|
future: _friendsFuture,
|
|
builder: (context, snapshot) {
|
|
if (snapshot.hasData) {
|
|
var friends = (snapshot.data as List<Friend>);
|
|
if (_searchFilter.isNotEmpty) {
|
|
friends = friends.where((element) => element.username.contains(_searchFilter)).toList();
|
|
friends.sort((a, b) => a.username.length.compareTo(b.username.length));
|
|
}
|
|
return ListView.builder(
|
|
itemCount: friends.length,
|
|
itemBuilder: (context, index) {
|
|
final friend = friends[index];
|
|
final unread = _unreads[friend.id] ?? [];
|
|
return FriendListTile(
|
|
friend: friend,
|
|
unreads: unread.length,
|
|
onTap: () async {
|
|
if (unread.isNotEmpty) {
|
|
final readBatch = MarkReadBatch(
|
|
senderId: _clientHolder!.apiClient.userId,
|
|
ids: unread.map((e) => e.id).toList(),
|
|
readTime: DateTime.now(),
|
|
);
|
|
_clientHolder!.hub.markMessagesRead(readBatch);
|
|
}
|
|
setState(() {
|
|
unread.clear();
|
|
});
|
|
},
|
|
);
|
|
},
|
|
);
|
|
} else if (snapshot.hasError) {
|
|
FlutterError.reportError(FlutterErrorDetails(exception: snapshot.error!, stack: snapshot.stackTrace));
|
|
return DefaultErrorWidget(
|
|
message: "${snapshot.error}",
|
|
onRetry: () {
|
|
_refreshFriendsList();
|
|
},
|
|
);
|
|
} else {
|
|
return const LinearProgressIndicator();
|
|
}
|
|
}
|
|
),
|
|
),
|
|
Align(
|
|
alignment: Alignment.bottomCenter,
|
|
child: ExpandingInputFab(
|
|
onInputChanged: (String text) {
|
|
setState(() {
|
|
_searchFilter = text;
|
|
});
|
|
},
|
|
onExpansionChanged: (expanded) {
|
|
if (_debouncer?.isActive ?? false) _debouncer?.cancel();
|
|
if (!expanded) {
|
|
setState(() {
|
|
_searchFilter = "";
|
|
});
|
|
}
|
|
},
|
|
),
|
|
),
|
|
],
|
|
),
|
|
);
|
|
}
|
|
}
|