talksik/stream-chat-flutter
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[MessageSendingStatus] lowercase enum values

Browse Source
This commit is contained in:
Sahil Kumar
2021-01-25 19:12:34 +05:30
parent 463dc96a26
commit 1021814a75
10 changed files with 69 additions and 69 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/dart_client/lib/src/api/channel.dart
+2 -2
View File
@@ -183,7 +183,7 @@ class Channel {
user: _client.state.user,
id: messageId,
quotedMessage: quotedMessage,
status: MessageSendingStatus.SENDING,
status: MessageSendingStatus.sending,
);
if (message.parentId != null && message.id == null) {
@@ -978,7 +978,7 @@ class ChannelClientState {
<Message>[...messages, ...threads.values.expand((v) => v)]
.where((message) =>
message.status != null &&
message.status != MessageSendingStatus.SENT &&
message.status != MessageSendingStatus.sent &&
message.createdAt.isBefore(DateTime.now().subtract(Duration(
seconds: 1,
))))
packages/dart_client/lib/src/api/retry_queue.dart
+21 -21
View File
@@ -113,30 +113,30 @@ class RetryQueue {
}
void _sendFailedEvent(Message message) {
final newStatus = message.status == MessageSendingStatus.SENDING
? MessageSendingStatus.FAILED
: (message.status == MessageSendingStatus.UPDATING
? MessageSendingStatus.FAILED_UPDATE
: MessageSendingStatus.FAILED_DELETE);
final newStatus = message.status == MessageSendingStatus.sending
? MessageSendingStatus.failed
: (message.status == MessageSendingStatus.updating
? MessageSendingStatus.failed_update
: MessageSendingStatus.failed_delete);
channel.state.addMessage(message.copyWith(
status: newStatus,
));
}
Future<void> _sendMessage(Message message) async {
if (message.status == MessageSendingStatus.FAILED_UPDATE ||
message.status == MessageSendingStatus.UPDATING) {
if (message.status == MessageSendingStatus.failed_update ||
message.status == MessageSendingStatus.updating) {
await channel.client.updateMessage(
message,
channel.cid,
);
} else if (message.status == MessageSendingStatus.FAILED ||
message.status == MessageSendingStatus.SENDING) {
} else if (message.status == MessageSendingStatus.failed ||
message.status == MessageSendingStatus.sending) {
await channel.sendMessage(
message,
);
} else if (message.status == MessageSendingStatus.FAILED_DELETE ||
message.status == MessageSendingStatus.DELETING) {
} else if (message.status == MessageSendingStatus.failed_delete ||
message.status == MessageSendingStatus.deleting) {
await channel.client.deleteMessage(
message,
channel.cid,
@@ -152,15 +152,15 @@ class RetryQueue {
messageList.indexWhere((m) => m.id == event.message.id);
if (messageIndex == -1 &&
[
MessageSendingStatus.FAILED_UPDATE,
MessageSendingStatus.FAILED,
MessageSendingStatus.FAILED_DELETE,
MessageSendingStatus.failed_update,
MessageSendingStatus.failed,
MessageSendingStatus.failed_delete,
].contains(event.message.status)) {
logger?.info('add message from events');
add([event.message]);
} else if (messageIndex != -1 &&
[
MessageSendingStatus.SENT,
MessageSendingStatus.sent,
null,
].contains(event.message.status)) {
_messageQueue.remove(messageList[messageIndex]);
@@ -184,16 +184,16 @@ class RetryQueue {
static DateTime _getMessageDate(Message m1) {
switch (m1.status) {
case MessageSendingStatus.FAILED_DELETE:
case MessageSendingStatus.DELETING:
case MessageSendingStatus.failed_delete:
case MessageSendingStatus.deleting:
return m1.deletedAt;
case MessageSendingStatus.FAILED:
case MessageSendingStatus.SENDING:
case MessageSendingStatus.failed:
case MessageSendingStatus.sending:
return m1.createdAt;
case MessageSendingStatus.FAILED_UPDATE:
case MessageSendingStatus.UPDATING:
case MessageSendingStatus.failed_update:
case MessageSendingStatus.updating:
return m1.updatedAt;
default:
return null;