agboola/MessagingApp_Functions
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Remove Conversation Link

Browse Source 
Remove conversation link from function
Chat ID standardized for individual chats so hence removal of conversation link
This commit is contained in:
onasanya.lanre
2025-04-06 15:12:43 +01:00
parent 671874851f
commit 1ebd5d6b00
1 changed files with 6 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files
functions/chatapp-functions/lib/main.dart
+6 -35
View File
@@ -39,8 +39,6 @@ Future<dynamic> main(final _context) async {
createdAt = DateTime.parse(_context.req.bodyJson['\$createdAt']); createdAt = DateTime.parse(_context.req.bodyJson['\$createdAt']);
updatedAt = DateTime.parse(_context.req.bodyJson['\$updatedAt']); updatedAt = DateTime.parse(_context.req.bodyJson['\$updatedAt']);
// _context.log(_messages);
Map allMessages = {}; Map allMessages = {};
for (var pp = 0; pp < _messages.length; pp++) { for (var pp = 0; pp < _messages.length; pp++) {
allMessages.addAll(json.decode(_messages[pp])); allMessages.addAll(json.decode(_messages[pp]));
@@ -49,15 +47,12 @@ Future<dynamic> main(final _context) async {
if (createdAt.isAtSameMomentAs(updatedAt)) { if (createdAt.isAtSameMomentAs(updatedAt)) {
// //
for (var _member in _members) { for (var _member in _members) {
var _linkId = await createConversation( // var _linkId =
await createConversation(
_context, _context,
_member, _member,
_members.where((_data) => _data != _member).toList(), _members.where((_data) => _data != _member).toList(),
); );
if (_linkId != null) {
await updateConversationLink(_context, _linkId, _documentId);
}
} }
} else { } else {
// //
@@ -115,7 +110,8 @@ dynamic createConversation(final _context, String _member, var _members) async {
} }
try { try {
var _data = '{"name": "$_name","image": "$_imageUrl","unseenCount": 0}'; var _data =
'{"name": "$_name","image": "$_imageUrl","unseenCount": 0,"timeStamp":"${DateTime.now().toUtc().toIso8601String()}"}';
_chatIdMap.add(_documentId); _chatIdMap.add(_documentId);
_detailMap.add(_data); _detailMap.add(_data);
@@ -133,7 +129,8 @@ dynamic createConversation(final _context, String _member, var _members) async {
documentId: _member, documentId: _member,
data: _conversationMap, data: _conversationMap,
); );
return '$_member${_members[0]}'; return '';
// return '$_member${_members[0]}';
} on AppwriteException catch (e) { } on AppwriteException catch (e) {
_context.log('amessage - $e.message'); _context.log('amessage - $e.message');
return ''; return '';
@@ -199,29 +196,3 @@ dynamic updateConversation(var _context, var _member, var _messages) async {
return ''; return '';
} }
dynamic updateConversationLink(
var _context, var _linkId, var _documentId) async {
//
dynamic _conversationLink;
try {
_conversationLink = await _database.getDocument(
databaseId: _databaseId,
collectionId: _conversationLinkDbId,
documentId: _linkId);
} on AppwriteException catch (e) {
e.message;
} on Exception catch (e) {
e.toString();
}
if (_conversationLink == null) {
await _database.createDocument(
databaseId: _databaseId,
collectionId: _conversationLinkDbId,
documentId: _linkId.substring(0, 36),
data: {"chatId": _documentId},
);
}
return '';
}