497 lines
14 KiB
Dart
497 lines
14 KiB
Dart
import 'package:cwtch/main.dart';
|
|
import 'package:cwtch/models/message_draft.dart';
|
|
import 'package:cwtch/models/profile.dart';
|
|
import 'package:cwtch/models/redaction.dart';
|
|
import 'package:cwtch/themes/opaque.dart';
|
|
import 'package:cwtch/views/contactsview.dart';
|
|
import 'package:cwtch/widgets/messagerow.dart';
|
|
import 'package:flutter/material.dart';
|
|
import 'package:flutter/widgets.dart';
|
|
import 'package:flutter_gen/gen_l10n/app_localizations.dart';
|
|
import 'package:provider/provider.dart';
|
|
import 'package:scrollable_positioned_list/scrollable_positioned_list.dart';
|
|
|
|
import 'messagecache.dart';
|
|
|
|
enum ConversationNotificationPolicy {
|
|
Default,
|
|
OptIn,
|
|
Never,
|
|
}
|
|
|
|
extension Nameable on ConversationNotificationPolicy {
|
|
String toName(BuildContext context) {
|
|
switch (this) {
|
|
case ConversationNotificationPolicy.Default:
|
|
return AppLocalizations.of(context)!.conversationNotificationPolicyDefault;
|
|
case ConversationNotificationPolicy.OptIn:
|
|
return AppLocalizations.of(context)!.conversationNotificationPolicyOptIn;
|
|
case ConversationNotificationPolicy.Never:
|
|
return AppLocalizations.of(context)!.conversationNotificationPolicyNever;
|
|
}
|
|
}
|
|
}
|
|
|
|
class ContactInfoState extends ChangeNotifier {
|
|
final String profileOnion;
|
|
final int identifier;
|
|
final String onion;
|
|
late String _nickname;
|
|
late String _localNickname;
|
|
|
|
late ConversationNotificationPolicy _notificationPolicy;
|
|
|
|
late bool _accepted;
|
|
late bool _blocked;
|
|
late String _status;
|
|
late String _imagePath;
|
|
late String _defaultImagePath;
|
|
late String _savePeerHistory;
|
|
late int _unreadMessages = 0;
|
|
late int _totalMessages = 0;
|
|
late DateTime _lastMessageReceivedTime; // last time we received a message, for sorting
|
|
late DateTime _lastMessageSentTime; // last time a message reported being sent, for display
|
|
late Map<String, GlobalKey<MessageRowState>> keys;
|
|
int _newMarkerMsgIndex = -1;
|
|
late MessageCache messageCache;
|
|
ItemScrollController messageScrollController = new ItemScrollController();
|
|
|
|
// todo: a nicer way to model contacts, groups and other "entities"
|
|
late bool _isGroup;
|
|
String? _server;
|
|
late bool _archived;
|
|
late bool _pinned;
|
|
|
|
int _antispamTickets = 0;
|
|
String? _acnCircuit;
|
|
MessageDraft _messageDraft = MessageDraft.empty();
|
|
|
|
var _hoveredIndex = -1;
|
|
var _pendingScroll = -1;
|
|
|
|
DateTime _lastRetryTime = DateTime.now();
|
|
DateTime loaded = DateTime.now();
|
|
|
|
List<ContactEvent> contactEvents = List.empty(growable: true);
|
|
|
|
ContactInfoState(
|
|
this.profileOnion,
|
|
this.identifier,
|
|
this.onion, {
|
|
nickname = "",
|
|
localNickname = "",
|
|
isGroup = false,
|
|
accepted = false,
|
|
blocked = false,
|
|
status = "",
|
|
imagePath = "",
|
|
defaultImagePath = "",
|
|
savePeerHistory = "DeleteHistoryConfirmed",
|
|
numMessages = 0,
|
|
numUnread = 0,
|
|
lastMessageTime,
|
|
server,
|
|
archived = false,
|
|
notificationPolicy = "ConversationNotificationPolicy.Default",
|
|
pinned = false,
|
|
}) {
|
|
this._nickname = nickname;
|
|
this._localNickname = localNickname;
|
|
this._isGroup = isGroup;
|
|
this._accepted = accepted;
|
|
this._blocked = blocked;
|
|
this._status = status;
|
|
this._imagePath = imagePath;
|
|
this._defaultImagePath = defaultImagePath;
|
|
this._totalMessages = numMessages;
|
|
this._unreadMessages = numUnread;
|
|
this._savePeerHistory = savePeerHistory;
|
|
this._lastMessageReceivedTime = lastMessageTime == null ? DateTime.fromMillisecondsSinceEpoch(0) : lastMessageTime;
|
|
this._lastMessageSentTime = _lastMessageReceivedTime;
|
|
this._server = server;
|
|
this._archived = archived;
|
|
this._notificationPolicy = notificationPolicyFromString(notificationPolicy);
|
|
this.messageCache = new MessageCache(_totalMessages);
|
|
this._pinned = pinned;
|
|
keys = Map<String, GlobalKey<MessageRowState>>();
|
|
}
|
|
|
|
String get nickname {
|
|
if (this._localNickname != "") {
|
|
return this._localNickname;
|
|
}
|
|
return this._nickname;
|
|
}
|
|
|
|
String get savePeerHistory => this._savePeerHistory;
|
|
|
|
String? get acnCircuit => this._acnCircuit;
|
|
|
|
MessageDraft get messageDraft => this._messageDraft;
|
|
|
|
DateTime get lastRetryTime => this._lastRetryTime;
|
|
set lastRetryTime(DateTime lastRetryTime) {
|
|
this._lastRetryTime = lastRetryTime;
|
|
notifyListeners();
|
|
}
|
|
|
|
set antispamTickets(int antispamTickets) {
|
|
this._antispamTickets = antispamTickets;
|
|
notifyListeners();
|
|
}
|
|
|
|
int get antispamTickets => this._antispamTickets;
|
|
|
|
set acnCircuit(String? acnCircuit) {
|
|
this._acnCircuit = acnCircuit;
|
|
notifyListeners();
|
|
}
|
|
|
|
// Indicated whether the conversation is archived, in which case it will
|
|
// be moved to the very bottom of the active conversations list until
|
|
// new messages appear
|
|
set isArchived(bool archived) {
|
|
this._archived = archived;
|
|
notifyListeners();
|
|
}
|
|
|
|
bool get isArchived => this._archived;
|
|
|
|
set savePeerHistory(String newVal) {
|
|
this._savePeerHistory = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
set nickname(String newVal) {
|
|
this._nickname = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
set localNickname(String newVal) {
|
|
this._localNickname = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
bool get isGroup => this._isGroup;
|
|
|
|
set isGroup(bool newVal) {
|
|
this._isGroup = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
bool get isBlocked => this._blocked;
|
|
|
|
bool get isInvitation => !this._blocked && !this._accepted;
|
|
|
|
set accepted(bool newVal) {
|
|
this._accepted = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
set blocked(bool newVal) {
|
|
this._blocked = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
String get status => this._status;
|
|
|
|
set status(String newVal) {
|
|
this._status = newVal;
|
|
this.contactEvents.add(ContactEvent("Update Peer Status Received: $newVal"));
|
|
notifyListeners();
|
|
}
|
|
|
|
set messageDraft(MessageDraft newVal) {
|
|
this._messageDraft = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
void notifyMessageDraftUpdate() {
|
|
notifyListeners();
|
|
}
|
|
|
|
void selected() {
|
|
this._newMarkerMsgIndex = this._unreadMessages - 1;
|
|
this._unreadMessages = 0;
|
|
}
|
|
|
|
void unselected() {
|
|
this._newMarkerMsgIndex = -1;
|
|
}
|
|
|
|
int get unreadMessages => this._unreadMessages;
|
|
|
|
set unreadMessages(int newVal) {
|
|
this._unreadMessages = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
int get newMarkerMsgIndex {
|
|
return this._newMarkerMsgIndex;
|
|
}
|
|
|
|
int get totalMessages => this._totalMessages;
|
|
|
|
set totalMessages(int newVal) {
|
|
this._totalMessages = newVal;
|
|
this.messageCache.storageMessageCount = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
String get imagePath {
|
|
// don't show custom images for blocked contacts..
|
|
if (!this.isBlocked) {
|
|
return this._imagePath;
|
|
}
|
|
return this.defaultImagePath;
|
|
}
|
|
|
|
set imagePath(String newVal) {
|
|
this._imagePath = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
String get defaultImagePath => this._defaultImagePath;
|
|
|
|
set defaultImagePath(String newVal) {
|
|
this._defaultImagePath = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
// This is last message received time (local) and to be used for sorting only
|
|
// for instance, group sync, we want to pop to the top, so we set to time.Now() for new messages
|
|
// but it should not be used for display
|
|
DateTime get lastMessageReceivedTime => this._lastMessageReceivedTime;
|
|
|
|
set lastMessageReceivedTime(DateTime newVal) {
|
|
this._lastMessageReceivedTime = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
// This is last message sent time and is based on message reports of sent times
|
|
// this can be used to display in the contact list a last time a message was received
|
|
DateTime get lastMessageSentTime => this._lastMessageSentTime;
|
|
set lastMessageSentTime(DateTime newVal) {
|
|
this._lastMessageSentTime = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
// we only allow callers to fetch the server
|
|
String? get server => this._server;
|
|
|
|
bool isOnline() {
|
|
if (this.isGroup == true) {
|
|
// We now have an out of sync warning so we will mark these as online...
|
|
return this.status == "Authenticated" || this.status == "Synced";
|
|
} else {
|
|
return this.status == "Authenticated";
|
|
}
|
|
}
|
|
|
|
bool canSend() {
|
|
if (this.isGroup == true) {
|
|
// We now have an out of sync warning so we will mark these as online...
|
|
return this.status == "Synced" && this.antispamTickets > 0;
|
|
} else {
|
|
return this.isOnline();
|
|
}
|
|
}
|
|
|
|
ConversationNotificationPolicy get notificationsPolicy => _notificationPolicy;
|
|
|
|
set notificationsPolicy(ConversationNotificationPolicy newVal) {
|
|
_notificationPolicy = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
GlobalKey<MessageRowState> getMessageKey(int conversation, int message) {
|
|
String index = "c: " + conversation.toString() + " m:" + message.toString();
|
|
if (keys[index] == null) {
|
|
keys[index] = GlobalKey<MessageRowState>();
|
|
}
|
|
GlobalKey<MessageRowState> ret = keys[index]!;
|
|
return ret;
|
|
}
|
|
|
|
GlobalKey<MessageRowState>? getMessageKeyOrFail(int conversation, int message) {
|
|
String index = "c: " + conversation.toString() + " m:" + message.toString();
|
|
|
|
if (keys[index] == null) {
|
|
return null;
|
|
}
|
|
GlobalKey<MessageRowState> ret = keys[index]!;
|
|
return ret;
|
|
}
|
|
|
|
void newMessage(int identifier, int messageID, DateTime timestamp, String senderHandle, String senderImage, bool isAuto, String data, String contenthash, bool selectedConversation) {
|
|
if (!selectedConversation) {
|
|
unreadMessages++;
|
|
}
|
|
if (_newMarkerMsgIndex == -1) {
|
|
if (!selectedConversation) {
|
|
_newMarkerMsgIndex = 0;
|
|
}
|
|
} else {
|
|
_newMarkerMsgIndex++;
|
|
}
|
|
|
|
this._lastMessageReceivedTime = timestamp;
|
|
this._lastMessageSentTime = timestamp;
|
|
this.messageCache.addNew(profileOnion, identifier, messageID, timestamp, senderHandle, senderImage, isAuto, data, contenthash);
|
|
this.totalMessages += 1;
|
|
|
|
// We only ever see messages from authenticated peers.
|
|
// If the contact is marked as offline then override this - can happen when the contact is removed from the front
|
|
// end during syncing.
|
|
if (isOnline() == false) {
|
|
status = "Authenticated";
|
|
}
|
|
notifyListeners();
|
|
}
|
|
|
|
void ackCache(int messageID) {
|
|
this.messageCache.ackCache(messageID);
|
|
notifyListeners();
|
|
}
|
|
|
|
void errCache(int messageID) {
|
|
this.messageCache.errCache(messageID);
|
|
notifyListeners();
|
|
}
|
|
|
|
static ConversationNotificationPolicy notificationPolicyFromString(String val) {
|
|
switch (val) {
|
|
case "ConversationNotificationPolicy.Default":
|
|
return ConversationNotificationPolicy.Default;
|
|
case "ConversationNotificationPolicy.OptIn":
|
|
return ConversationNotificationPolicy.OptIn;
|
|
case "ConversationNotificationPolicy.Never":
|
|
return ConversationNotificationPolicy.Never;
|
|
}
|
|
return ConversationNotificationPolicy.Never;
|
|
}
|
|
|
|
bool get pinned {
|
|
return _pinned;
|
|
}
|
|
|
|
// Pin the conversation to the top of the conversation list
|
|
// Requires caller tree to contain a FlwtchState and ProfileInfoState provider.
|
|
void pin(context) {
|
|
_pinned = true;
|
|
var profileHandle = Provider.of<ProfileInfoState>(context, listen: false).onion;
|
|
Provider.of<FlwtchState>(context, listen: false).cwtch.SetConversationAttribute(profileHandle, identifier, "profile.pinned", "true");
|
|
notifyListeners();
|
|
}
|
|
|
|
// Unpin the conversation from the top of the conversation list
|
|
// Requires caller tree to contain a FlwtchState and ProfileInfoState provider.
|
|
void unpin(context) {
|
|
_pinned = false;
|
|
var profileHandle = Provider.of<ProfileInfoState>(context, listen: false).onion;
|
|
Provider.of<FlwtchState>(context, listen: false).cwtch.SetConversationAttribute(profileHandle, identifier, "profile.pinned", "false");
|
|
notifyListeners();
|
|
}
|
|
|
|
// returns true only if the conversation has been accepted, and has not been blocked
|
|
bool isAccepted() {
|
|
return _accepted && !_blocked;
|
|
}
|
|
|
|
String summary = "";
|
|
void updateSummaryEvent(String summary) {
|
|
this.summary += summary;
|
|
notifyListeners();
|
|
}
|
|
|
|
void updateTranslationEvent(int messageID, String translation) {
|
|
this.messageCache.updateTranslationEvent(messageID, translation);
|
|
notifyListeners();
|
|
}
|
|
|
|
// Contact Attributes. Can be set in Profile Edit View...
|
|
List<String?> attributes = [null, null, null];
|
|
void setAttribute(int i, String? value) {
|
|
this.attributes[i] = value;
|
|
notifyListeners();
|
|
}
|
|
|
|
ProfileStatusMenu availabilityStatus = ProfileStatusMenu.available;
|
|
void setAvailabilityStatus(String status) {
|
|
switch (status) {
|
|
case "available":
|
|
availabilityStatus = ProfileStatusMenu.available;
|
|
break;
|
|
case "busy":
|
|
availabilityStatus = ProfileStatusMenu.busy;
|
|
break;
|
|
case "away":
|
|
availabilityStatus = ProfileStatusMenu.away;
|
|
break;
|
|
default:
|
|
ProfileStatusMenu.available;
|
|
}
|
|
notifyListeners();
|
|
}
|
|
|
|
Color getBorderColor(OpaqueThemeType theme) {
|
|
if (this.isBlocked) {
|
|
return theme.portraitBlockedBorderColor;
|
|
}
|
|
if (this.isOnline()) {
|
|
switch (this.availabilityStatus) {
|
|
case ProfileStatusMenu.available:
|
|
return theme.portraitOnlineBorderColor;
|
|
case ProfileStatusMenu.away:
|
|
return theme.portraitOnlineAwayColor;
|
|
case ProfileStatusMenu.busy:
|
|
return theme.portraitOnlineBusyColor;
|
|
default:
|
|
// noop not a valid status...
|
|
break;
|
|
}
|
|
}
|
|
return theme.portraitOfflineBorderColor;
|
|
}
|
|
|
|
String augmentedNickname(BuildContext context) {
|
|
var nick = redactedNick(context, this.onion, this.nickname);
|
|
return nick + (this.availabilityStatus == ProfileStatusMenu.available ? "" : " (" + this.statusString(context) + ")");
|
|
}
|
|
|
|
// Never use this for message lookup - can be a non-indexed value
|
|
// e.g. -1
|
|
int get hoveredIndex => _hoveredIndex;
|
|
set hoveredIndex(int newVal) {
|
|
this._hoveredIndex = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
int get pendingScroll => _pendingScroll;
|
|
set pendingScroll(int newVal) {
|
|
this._pendingScroll = newVal;
|
|
notifyListeners();
|
|
}
|
|
|
|
String statusString(BuildContext context) {
|
|
switch (this.availabilityStatus) {
|
|
case ProfileStatusMenu.available:
|
|
return AppLocalizations.of(context)!.availabilityStatusAvailable;
|
|
case ProfileStatusMenu.away:
|
|
return AppLocalizations.of(context)!.availabilityStatusAway;
|
|
case ProfileStatusMenu.busy:
|
|
return AppLocalizations.of(context)!.availabilityStatusBusy;
|
|
default:
|
|
throw UnimplementedError("not a valid status");
|
|
}
|
|
}
|
|
}
|
|
|
|
class ContactEvent {
|
|
String summary;
|
|
late DateTime timestamp;
|
|
ContactEvent(this.summary) {
|
|
this.timestamp = DateTime.now();
|
|
}
|
|
}
|