From 786267d0ebb337ad5b4f1e528fdd4c23731e0606 Mon Sep 17 00:00:00 2001
From: Iván Ávalos <avalos@disroot.org>
Date: Mon, 22 May 2023 00:09:43 -0600
Subject: Se implementa funcionalidad básica de chat
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lib/firebase/auth.dart     | 16 ++++++++--
 lib/firebase/database.dart | 74 ++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 88 insertions(+), 2 deletions(-)
 create mode 100644 lib/firebase/database.dart

(limited to 'lib/firebase')

diff --git a/lib/firebase/auth.dart b/lib/firebase/auth.dart
index a876d5b..303412e 100644
--- a/lib/firebase/auth.dart
+++ b/lib/firebase/auth.dart
@@ -2,7 +2,9 @@ import 'dart:io';
 
 import 'package:firebase_auth/firebase_auth.dart';
 import 'package:flutter/foundation.dart';
+import 'package:linkchat/firebase/database.dart';
 
+import '../models/user.dart';
 import 'storage.dart';
 
 class Auth {
@@ -10,6 +12,8 @@ class Auth {
   final GithubAuthProvider _githubProvider = GithubAuthProvider();
   final GoogleAuthProvider _googleAuthProvider = GoogleAuthProvider();
 
+  final Database _db = Database();
+
   User? get currentUser => _auth.currentUser;
 
   Future<bool> createUserWithEmailAndPassword({
@@ -25,8 +29,16 @@ class Auth {
       );
       User? user = cred.user;
       if (user != null) {
-        user.updateDisplayName(displayName);
-        user.updatePhotoURL(await Storage().uploadAvatar(user.uid, avatar));
+        String photoUrl = await Storage().uploadAvatar(user.uid, avatar);
+        await user.updateDisplayName(displayName);
+        await user.updatePhotoURL(photoUrl);
+        // Store user in database
+        _db.saveUser(FsUser(
+          uid: user.uid,
+          displayName: displayName,
+          photoUrl: photoUrl,
+          email: user.email!,
+        ));
       }
       return true;
     } catch (e) {
diff --git a/lib/firebase/database.dart b/lib/firebase/database.dart
new file mode 100644
index 0000000..eb9ef05
--- /dev/null
+++ b/lib/firebase/database.dart
@@ -0,0 +1,74 @@
+import 'dart:async';
+
+import 'package:cloud_firestore/cloud_firestore.dart';
+import 'package:linkchat/models/group.dart';
+import 'package:linkchat/models/message.dart';
+
+import '../models/user.dart';
+
+class Database {
+  final FirebaseFirestore _firestore = FirebaseFirestore.instance;
+
+  Future<FsUser?> getUserById(String uid) async {
+    var snap = await _firestore.collection('users').doc(uid).get();
+    return snap.data() != null ? FsUser.fromMap(snap.data()!) : null;
+  }
+
+  Stream<List<FsUser>> getAllUsers() {
+    return _firestore.collection('users').snapshots().map<List<FsUser>>((e) {
+      return e.docs.map((e) {
+        return FsUser.fromMap(e.data());
+      }).toList();
+    });
+  }
+
+  Future<void> saveUser(FsUser user) async {
+    await _firestore.collection('users').doc(user.uid).set({
+      "uid": user.uid,
+      "displayName": user.displayName,
+      "photoUrl": user.photoUrl,
+      "email": user.email,
+    });
+  }
+
+  Stream<List<Group>> getGroupsByUserID(String uid) {
+    return _firestore
+        .collection('groups')
+        .where('members', arrayContains: uid)
+        .snapshots()
+        .map<List<Group>>((e) {
+      return e.docs.map((e) {
+        return Group.fromMap(e.data(), e.id);
+      }).toList();
+    });
+  }
+
+  Stream<List<Message>> getMessagesByGroupId(String id) {
+    return _firestore
+        .collection('messages')
+        .doc(id)
+        .collection('messages')
+        .orderBy('sentAt')
+        .snapshots()
+        .map<List<Message>>((e) {
+      return e.docs.map((e) {
+        return Message.fromMap(e.data());
+      }).toList();
+    });
+  }
+
+  Future<void> saveMessage(Message msg, String groupId) async {
+    await _firestore
+        .collection('messages')
+        .doc(groupId)
+        .collection('messages')
+        .add(msg.toMap());
+    await _firestore.collection('groups').doc(groupId).update({
+      "recentMessage": msg.toMap(),
+    });
+  }
+
+  Future<void> saveGroup(Group group) async {
+    await _firestore.collection('groups').add(group.toMap());
+  }
+}
-- 
cgit v1.2.3