52 lines
1.6 KiB
Dart
52 lines
1.6 KiB
Dart
import 'package:cloud_firestore/cloud_firestore.dart';
|
|
import 'package:firebase_auth/firebase_auth.dart';
|
|
|
|
import '../../constants.dart';
|
|
import '../../utils/helper.dart';
|
|
import '../../models/message.dart';
|
|
|
|
class ChatService {
|
|
// get instance of firestore and auth
|
|
final FirebaseFirestore _firestore = FirebaseFirestore.instance;
|
|
final FirebaseAuth _auth = FirebaseAuth.instance;
|
|
|
|
// send message
|
|
Future<void> sendMessage(String receiverID, message) async {
|
|
// get current user info
|
|
final String currentUserID = _auth.currentUser!.uid;
|
|
final String currentUserEmail = _auth.currentUser!.email!;
|
|
final Timestamp timestamp = Timestamp.now();
|
|
|
|
// create new message
|
|
Message newMessage = Message(
|
|
senderID: currentUserID,
|
|
senderEmail: currentUserEmail,
|
|
receiverID: receiverID,
|
|
message: message,
|
|
timestamp: timestamp,
|
|
);
|
|
|
|
// construct chat room ID for the two users
|
|
String chatRoomID = getCompoundId([currentUserID, receiverID]);
|
|
|
|
// add new message to database
|
|
await _firestore
|
|
.collection(Constants.dbCollectionChatRooms)
|
|
.doc(chatRoomID)
|
|
.collection(Constants.dbCollectionMessages)
|
|
.add(newMessage.toMap());
|
|
}
|
|
|
|
// get messages
|
|
Stream<QuerySnapshot> getMessages(String userID, otherUserID) {
|
|
String chatRoomID = getCompoundId([userID, otherUserID]);
|
|
|
|
return _firestore
|
|
.collection(Constants.dbCollectionChatRooms)
|
|
.doc(chatRoomID)
|
|
.collection(Constants.dbCollectionMessages)
|
|
.orderBy('timestamp', descending: false)
|
|
.snapshots();
|
|
}
|
|
}
|