cleaning, prolly broke a lot but whatever
This commit is contained in:
Arjun Patel
@@ -1,5 +0,0 @@
|
||||
import { Firestore } from "firebase/firestore";
|
||||
|
||||
export default interface IService {
|
||||
db: Firestore;
|
||||
}
|
||||
@@ -1,94 +0,0 @@
|
||||
import AgoraRTC, {
|
||||
ClientConfig,
|
||||
IAgoraRTCRemoteUser,
|
||||
ICameraVideoTrack,
|
||||
IMicrophoneAudioTrack,
|
||||
} from "agora-rtc-sdk-ng";
|
||||
// import {
|
||||
// AgoraVideoPlayer,
|
||||
// createClient,
|
||||
// createMicrophoneAndCameraTracks,
|
||||
// createMicrophoneAudioTrack,
|
||||
// } from "agora-rtc-react";
|
||||
import { getFunctions, httpsCallable } from "firebase/functions";
|
||||
import toast from "react-hot-toast";
|
||||
|
||||
const config: ClientConfig = {
|
||||
mode: "rtc",
|
||||
codec: "vp8",
|
||||
};
|
||||
|
||||
// const useClient = createClient(config);
|
||||
// const useMicrophoneTracks = createMicrophoneAudioTrack();
|
||||
|
||||
// TODO: move this to env file
|
||||
const appId: string = "c8dfd65deb5c4741bd564085627139d0"; //ENTER APP ID HERE
|
||||
|
||||
export default class AgoraService {
|
||||
private functions = getFunctions();
|
||||
// private rtcClient = useClient();
|
||||
|
||||
async getAgoraToken(channelName: string): Promise<string> {
|
||||
const cfResult = httpsCallable(this.functions, "agoraToken");
|
||||
|
||||
return await cfResult({ channelName })
|
||||
.then((result: { data: { token: string } }) => {
|
||||
const data = result.data;
|
||||
|
||||
if (!data.token) {
|
||||
throw new Error("No token retrieved from agora");
|
||||
}
|
||||
|
||||
return data.token;
|
||||
})
|
||||
.catch((error) => {
|
||||
// Getting the Error details.
|
||||
const code = error.code;
|
||||
const message = error.message;
|
||||
const details = error.details;
|
||||
throw error;
|
||||
});
|
||||
}
|
||||
|
||||
// async handleJoinChannel(channelName: string, agoraToken: string) {
|
||||
// const localTrack: IMicrophoneAudioTrack =
|
||||
// await AgoraRTC.createMicrophoneAudioTrack();
|
||||
|
||||
// let init = async (name: string) => {
|
||||
// this.rtcClient.on("user-published", async (user, mediaType) => {
|
||||
// await this.rtcClient.subscribe(user, mediaType);
|
||||
// console.log("subscribe success");
|
||||
|
||||
// if (mediaType === "audio") {
|
||||
// user.audioTrack?.play();
|
||||
// }
|
||||
// });
|
||||
|
||||
// this.rtcClient.on("user-unpublished", async (user, type) => {
|
||||
// console.log("unpublished", user, type);
|
||||
// if (type === "audio") {
|
||||
// user.audioTrack?.stop();
|
||||
// }
|
||||
|
||||
// await this.rtcClient.unsubscribe(user);
|
||||
// });
|
||||
|
||||
// this.rtcClient.on("user-left", (user) => {
|
||||
// console.log("user left", user);
|
||||
// });
|
||||
|
||||
// await this.rtcClient.join(appId, name, agoraToken, null);
|
||||
// if (localTrack) await this.rtcClient.publish(localTrack);
|
||||
// };
|
||||
|
||||
// if (localTrack) {
|
||||
// console.log("init ready");
|
||||
// init(channelName);
|
||||
// } else {
|
||||
// toast.error("Not ready for joining call");
|
||||
// return;
|
||||
// }
|
||||
// }
|
||||
}
|
||||
|
||||
export { appId };
|
||||
@@ -1,27 +0,0 @@
|
||||
import {
|
||||
addDoc,
|
||||
collection,
|
||||
doc,
|
||||
Firestore,
|
||||
getFirestore,
|
||||
serverTimestamp,
|
||||
setDoc,
|
||||
} from "firebase/firestore";
|
||||
import { AnnouncementState } from "../models/announcement";
|
||||
import { Collections } from "./collections";
|
||||
|
||||
export class AnnouncementService {
|
||||
private db: Firestore = getFirestore();
|
||||
|
||||
async updateAnnouncementState(
|
||||
announcementId: string,
|
||||
newState: AnnouncementState
|
||||
) {
|
||||
const docRef = doc(this.db, Collections.announcements, announcementId);
|
||||
await setDoc(
|
||||
docRef,
|
||||
{ state: newState, lastUpdatedDate: serverTimestamp() },
|
||||
{ merge: true }
|
||||
);
|
||||
}
|
||||
}
|
||||
@@ -1,75 +0,0 @@
|
||||
import {
|
||||
getDownloadURL,
|
||||
getStorage,
|
||||
ref,
|
||||
uploadBytesResumable,
|
||||
} from "firebase/storage";
|
||||
|
||||
export default class CloudStorageService {
|
||||
private storage = getStorage();
|
||||
|
||||
/**
|
||||
* return the
|
||||
*/
|
||||
async uploadMessageAudioFile(audioFile: File): Promise<string> {
|
||||
// Create the file metadata
|
||||
/** @type {any} */
|
||||
const metadata = {
|
||||
contentType: "audio/mpeg",
|
||||
};
|
||||
|
||||
// Upload file and metadata to the object 'images/mountains.jpg'
|
||||
const storageRef = ref(this.storage, "messages/" + audioFile.name);
|
||||
const uploadTask = uploadBytesResumable(storageRef, audioFile, metadata);
|
||||
|
||||
// Listen for state changes, errors, and completion of the upload.
|
||||
return new Promise((resolve, reject) => {
|
||||
uploadTask.on(
|
||||
"state_changed",
|
||||
(snapshot) => {
|
||||
// Get task progress, including the number of bytes uploaded and the total number of bytes to be uploaded
|
||||
const progress =
|
||||
(snapshot.bytesTransferred / snapshot.totalBytes) * 100;
|
||||
console.log("Upload is " + progress + "% done");
|
||||
switch (snapshot.state) {
|
||||
case "paused":
|
||||
console.log("Upload is paused");
|
||||
break;
|
||||
case "running":
|
||||
console.log("Upload is running");
|
||||
break;
|
||||
}
|
||||
},
|
||||
(error) => {
|
||||
// A full list of error codes is available at
|
||||
// https://firebase.google.com/docs/storage/web/handle-errors
|
||||
|
||||
reject(new Error(error.message));
|
||||
|
||||
switch (error.code) {
|
||||
case "storage/unauthorized":
|
||||
// User doesn't have permission to access the object
|
||||
break;
|
||||
case "storage/canceled":
|
||||
// User canceled the upload
|
||||
break;
|
||||
|
||||
// ...
|
||||
|
||||
case "storage/unknown":
|
||||
// Unknown error occurred, inspect error.serverResponse
|
||||
break;
|
||||
}
|
||||
},
|
||||
() => {
|
||||
// Upload completed successfully, now we can get the download URL
|
||||
return getDownloadURL(uploadTask.snapshot.ref).then((downloadURL) => {
|
||||
console.log("File available at", downloadURL);
|
||||
|
||||
return resolve(downloadURL);
|
||||
});
|
||||
}
|
||||
);
|
||||
});
|
||||
}
|
||||
}
|
||||
@@ -1,13 +0,0 @@
|
||||
export enum Collections {
|
||||
users = "users",
|
||||
teams = "teams",
|
||||
teamMembers = "teamMembers",
|
||||
teamSubscriptions = "teamSubscriptions",
|
||||
audioMessages = "audioMessages",
|
||||
|
||||
rooms = "rooms",
|
||||
announcements = "announcements",
|
||||
links = "links",
|
||||
|
||||
officeRooms = "officeRooms",
|
||||
}
|
||||
@@ -1,15 +0,0 @@
|
||||
import firebaseAdmin from "firebase-admin/app";
|
||||
|
||||
import serviceAccount from "../nirvana-for-business-firebase-adminsdk";
|
||||
|
||||
const adminApp = firebaseAdmin.initializeApp({
|
||||
credential: credential.cert({
|
||||
privateKey: serviceAccount.private_key,
|
||||
clientEmail: serviceAccount.client_email,
|
||||
projectId: serviceAccount.project_id,
|
||||
}),
|
||||
});
|
||||
|
||||
console.log("initialized firebase admin");
|
||||
|
||||
export { adminApp };
|
||||
@@ -1,24 +0,0 @@
|
||||
import {
|
||||
addDoc,
|
||||
collection,
|
||||
doc,
|
||||
Firestore,
|
||||
getFirestore,
|
||||
serverTimestamp,
|
||||
setDoc,
|
||||
} from "firebase/firestore";
|
||||
import Link, { LinkState } from "../models/link";
|
||||
import { Collections } from "./collections";
|
||||
|
||||
export class LinkService {
|
||||
private db: Firestore = getFirestore();
|
||||
|
||||
async updateLinkState(linkId: string, newState: LinkState) {
|
||||
const docRef = doc(this.db, Collections.links, linkId);
|
||||
await setDoc(
|
||||
docRef,
|
||||
{ state: newState, lastUpdatedDate: serverTimestamp() },
|
||||
{ merge: true }
|
||||
);
|
||||
}
|
||||
}
|
||||
@@ -1,93 +0,0 @@
|
||||
import {
|
||||
addDoc,
|
||||
collection,
|
||||
doc,
|
||||
FieldValue,
|
||||
Firestore,
|
||||
getFirestore,
|
||||
serverTimestamp,
|
||||
setDoc,
|
||||
writeBatch,
|
||||
} from "firebase/firestore";
|
||||
import OfficeRoom, { OfficeRoomState } from "../models/officeRoom";
|
||||
// import AgoraService from "./agoraService";
|
||||
import { Collections } from "./collections";
|
||||
|
||||
export default class OfficeRoomService {
|
||||
private db: Firestore = getFirestore();
|
||||
private batch = writeBatch(this.db);
|
||||
|
||||
// private agoraService = new AgoraService();
|
||||
|
||||
async createInitialOfficeRooms(createdByUserId: string, teamId: string) {
|
||||
const entrance = new OfficeRoom("Entrance", teamId, createdByUserId);
|
||||
const kitchen = new OfficeRoom("Kitchen", teamId, createdByUserId);
|
||||
const hallway = new OfficeRoom("Hallway", teamId, createdByUserId);
|
||||
const corner = new OfficeRoom("Corner", teamId, createdByUserId);
|
||||
const main = new OfficeRoom("Team Hub", teamId, createdByUserId);
|
||||
const handsOnDeck = new OfficeRoom(
|
||||
"All Hands On Deck",
|
||||
teamId,
|
||||
createdByUserId
|
||||
);
|
||||
|
||||
const initialORs: OfficeRoom[] = [
|
||||
entrance,
|
||||
kitchen,
|
||||
hallway,
|
||||
corner,
|
||||
main,
|
||||
handsOnDeck,
|
||||
];
|
||||
|
||||
initialORs.forEach((oR) => {
|
||||
const oRRef = doc(this.db, Collections.officeRooms, oR.id);
|
||||
this.batch.set(oRRef, { ...oR, createdDate: serverTimestamp() });
|
||||
});
|
||||
|
||||
await this.batch.commit();
|
||||
}
|
||||
|
||||
async joinOfficeRoom(officeRoom: OfficeRoom, userId: string) {
|
||||
// get agoraToken
|
||||
// const agoraToken = await this.agoraService.getAgoraToken();
|
||||
|
||||
// join channel
|
||||
// await this.agoraService.handleJoinChannel(officeRoom.id, agoraToken);
|
||||
|
||||
// update members list in firestore
|
||||
const newMembers = [...officeRoom.members, userId];
|
||||
await this.updateMembersInOfficeRoom(officeRoom.id, newMembers);
|
||||
}
|
||||
|
||||
async updateMembersInOfficeRoom(
|
||||
officeRoomId: string,
|
||||
newMembersInRoom: string[]
|
||||
) {
|
||||
// if the room is going to be empty, then change status accordingly
|
||||
var state: OfficeRoomState = OfficeRoomState.active;
|
||||
if (newMembersInRoom.length == 0) {
|
||||
state = OfficeRoomState.idle;
|
||||
}
|
||||
|
||||
const docRef = doc(this.db, Collections.officeRooms, officeRoomId);
|
||||
await setDoc(
|
||||
docRef,
|
||||
{
|
||||
state,
|
||||
members: newMembersInRoom,
|
||||
lastUpdatedDate: serverTimestamp(),
|
||||
},
|
||||
{ merge: true }
|
||||
);
|
||||
}
|
||||
|
||||
// async updateRoom(room: Room) {
|
||||
// const docRef = doc(this.db, Collections.rooms, room.id);
|
||||
// await setDoc(
|
||||
// docRef,
|
||||
// { ...room, lastUpdatedDate: serverTimestamp() },
|
||||
// { merge: true }
|
||||
// );
|
||||
// }
|
||||
}
|
||||
@@ -1,56 +0,0 @@
|
||||
import {
|
||||
addDoc,
|
||||
collection,
|
||||
doc,
|
||||
Firestore,
|
||||
getFirestore,
|
||||
serverTimestamp,
|
||||
setDoc,
|
||||
} from "firebase/firestore";
|
||||
import Room, { RoomStatus } from "../models/room";
|
||||
import { Collections } from "./collections";
|
||||
|
||||
export default class RoomService {
|
||||
private db: Firestore = getFirestore();
|
||||
|
||||
async createOrUpdateRoom(room: Room) {
|
||||
if (room.id) {
|
||||
//update
|
||||
await this.updateRoom(room);
|
||||
} else {
|
||||
//create
|
||||
const roomDocRef = await addDoc(collection(this.db, Collections.rooms), {
|
||||
...room,
|
||||
createdDate: serverTimestamp(),
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
async updateMembersInRoom(roomId: string, newMembersInRoom: string[]) {
|
||||
// if the room is going to be empty, then change status accordingly
|
||||
var status: RoomStatus = RoomStatus.live;
|
||||
if (newMembersInRoom.length == 0) {
|
||||
status = RoomStatus.empty;
|
||||
}
|
||||
|
||||
const docRef = doc(this.db, Collections.rooms, roomId);
|
||||
await setDoc(
|
||||
docRef,
|
||||
{
|
||||
status,
|
||||
membersInRoom: newMembersInRoom,
|
||||
lastUpdatedDate: serverTimestamp(),
|
||||
},
|
||||
{ merge: true }
|
||||
);
|
||||
}
|
||||
|
||||
async updateRoom(room: Room) {
|
||||
const docRef = doc(this.db, Collections.rooms, room.id);
|
||||
await setDoc(
|
||||
docRef,
|
||||
{ ...room, lastUpdatedDate: serverTimestamp() },
|
||||
{ merge: true }
|
||||
);
|
||||
}
|
||||
}
|
||||
@@ -1,42 +0,0 @@
|
||||
import {
|
||||
addDoc,
|
||||
collection,
|
||||
Firestore,
|
||||
getFirestore,
|
||||
serverTimestamp,
|
||||
} from "firebase/firestore";
|
||||
import Announcement from "../models/announcement";
|
||||
import Link from "../models/link";
|
||||
import { Message } from "../models/message";
|
||||
import { Collections } from "./collections";
|
||||
|
||||
export class SendService {
|
||||
private db: Firestore = getFirestore();
|
||||
|
||||
async sendMessage(message: Message) {
|
||||
// do quick stuff to create the composite for easier future querying
|
||||
message.senderReceiver = [message.senderUserId, message.receiverUserId];
|
||||
|
||||
const teamDocRef = await addDoc(
|
||||
collection(this.db, Collections.audioMessages),
|
||||
{
|
||||
...message,
|
||||
createdDate: serverTimestamp(),
|
||||
}
|
||||
);
|
||||
}
|
||||
|
||||
async sendLink(link: Link) {
|
||||
await addDoc(collection(this.db, Collections.links), {
|
||||
...link,
|
||||
createdDate: serverTimestamp(),
|
||||
});
|
||||
}
|
||||
|
||||
async sendAnnouncement(announcement: Announcement) {
|
||||
await addDoc(collection(this.db, Collections.announcements), {
|
||||
...announcement,
|
||||
createdDate: serverTimestamp(),
|
||||
});
|
||||
}
|
||||
}
|
||||
@@ -1,297 +0,0 @@
|
||||
import {
|
||||
addDoc,
|
||||
collection,
|
||||
doc,
|
||||
DocumentReference,
|
||||
Firestore,
|
||||
getDoc,
|
||||
getDocs,
|
||||
getFirestore,
|
||||
orderBy,
|
||||
query,
|
||||
serverTimestamp,
|
||||
setDoc,
|
||||
where,
|
||||
} from "firebase/firestore";
|
||||
import { Team } from "../models/team";
|
||||
import {
|
||||
TeamMember,
|
||||
TeamMemberRole,
|
||||
TeamMemberStatus,
|
||||
} from "../models/teamMember";
|
||||
import { Collections } from "./collections";
|
||||
import IService from "./IService";
|
||||
|
||||
export default class TeamService implements IService {
|
||||
db: Firestore = getFirestore();
|
||||
|
||||
async createTeam(team: Team): Promise<string> {
|
||||
// create team
|
||||
const teamDocRef = await addDoc(collection(this.db, Collections.teams), {
|
||||
...team,
|
||||
createdDate: serverTimestamp(),
|
||||
});
|
||||
|
||||
const teamMember = new TeamMember();
|
||||
teamMember.role = TeamMemberRole.admin;
|
||||
teamMember.teamId = teamDocRef.id;
|
||||
teamMember.userId = team.createdByUserId;
|
||||
teamMember.status = TeamMemberStatus.activated;
|
||||
|
||||
// create team member as admin who created the team
|
||||
const teamMemberRef = await addDoc(
|
||||
collection(this.db, Collections.teamMembers),
|
||||
{
|
||||
...teamMember,
|
||||
createdDate: serverTimestamp(),
|
||||
}
|
||||
);
|
||||
|
||||
console.log("created team");
|
||||
|
||||
return teamDocRef.id;
|
||||
}
|
||||
|
||||
async updateTeam(team: Team) {
|
||||
const docRef = doc(this.db, Collections.teams, team.id);
|
||||
await setDoc(
|
||||
docRef,
|
||||
{ ...team, lastUpdatedDate: serverTimestamp() },
|
||||
{ merge: true }
|
||||
);
|
||||
}
|
||||
|
||||
async getTeam(teamId: string): Promise<Team | null> {
|
||||
const docRef = doc(this.db, Collections.teams, teamId);
|
||||
const docSnap = await getDoc(docRef);
|
||||
|
||||
if (docSnap.exists()) {
|
||||
console.log("got team data");
|
||||
let team: Team = docSnap.data() as Team;
|
||||
team.id = docSnap.id;
|
||||
return team;
|
||||
} else {
|
||||
// doc.data() will be undefined in this case
|
||||
console.log("team not found!");
|
||||
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
async getTeamMemberByUserId(
|
||||
teamId: string,
|
||||
userId: string
|
||||
): Promise<TeamMember | null> {
|
||||
const q = query(
|
||||
collection(this.db, Collections.teamMembers),
|
||||
where("teamId", "==", teamId),
|
||||
where("userId", "==", userId)
|
||||
);
|
||||
|
||||
const querySnapshot = await getDocs(q);
|
||||
|
||||
if (querySnapshot.size > 1) {
|
||||
console.log(
|
||||
"there are multiple teammembers for this user...error in teamservice"
|
||||
);
|
||||
}
|
||||
|
||||
var teamMember: TeamMember | null = null;
|
||||
querySnapshot.forEach((doc) => {
|
||||
// doc.data() is never undefined for query doc snapshots
|
||||
// get the first one and just return...shouldn't be more
|
||||
console.log("got teammember data");
|
||||
teamMember = doc.data() as TeamMember;
|
||||
|
||||
teamMember.id = doc.id;
|
||||
});
|
||||
|
||||
return teamMember;
|
||||
}
|
||||
|
||||
async getTeamMemberByEmailInvite(
|
||||
teamId: string,
|
||||
emailAddress: string
|
||||
): Promise<TeamMember | null> {
|
||||
const q = query(
|
||||
collection(this.db, Collections.teamMembers),
|
||||
where("teamId", "==", teamId),
|
||||
where("inviteEmailAddress", "==", emailAddress)
|
||||
);
|
||||
|
||||
const querySnapshot = await getDocs(q);
|
||||
|
||||
if (querySnapshot.size > 1) {
|
||||
console.log(
|
||||
"there are multiple teammembers for this user...error in teamservice"
|
||||
);
|
||||
}
|
||||
|
||||
var teamMember: TeamMember | null = null;
|
||||
querySnapshot.forEach((doc) => {
|
||||
// doc.data() is never undefined for query doc snapshots
|
||||
// get the first one and just return...shouldn't be more
|
||||
console.log("got teammember data");
|
||||
teamMember = doc.data() as TeamMember;
|
||||
|
||||
teamMember.id = doc.id;
|
||||
});
|
||||
|
||||
return teamMember;
|
||||
}
|
||||
|
||||
async getTeamMembersByEmailInvite(
|
||||
emailAddress: string
|
||||
): Promise<TeamMember[]> {
|
||||
const q = query(
|
||||
collection(this.db, Collections.teamMembers),
|
||||
where("inviteEmailAddress", "==", emailAddress)
|
||||
);
|
||||
|
||||
const querySnapshot = await getDocs(q);
|
||||
|
||||
var teamMembers: TeamMember[] = [];
|
||||
querySnapshot.forEach((doc) => {
|
||||
// doc.data() is never undefined for query doc snapshots
|
||||
// get the first one and just return...shouldn't be more
|
||||
console.log("got teammember data");
|
||||
let teamMember: TeamMember = doc.data() as TeamMember;
|
||||
|
||||
teamMember.id = doc.id;
|
||||
|
||||
teamMembers.push(teamMember);
|
||||
});
|
||||
|
||||
return teamMembers;
|
||||
}
|
||||
|
||||
async getTeamMembersByUserId(userId: string): Promise<TeamMember[]> {
|
||||
const q = query(
|
||||
collection(this.db, Collections.teamMembers),
|
||||
where("userId", "==", userId)
|
||||
);
|
||||
|
||||
const querySnapshot = await getDocs(q);
|
||||
|
||||
if (querySnapshot.size > 1) {
|
||||
console.log("this user is part of multiple teams");
|
||||
}
|
||||
|
||||
var teamMembers: TeamMember[] = [];
|
||||
|
||||
querySnapshot.forEach((doc) => {
|
||||
// doc.data() is never undefined for query doc snapshots
|
||||
// get the first one and just return...shouldn't be more
|
||||
console.log("got teammember data");
|
||||
let teamMember: TeamMember = doc.data() as TeamMember;
|
||||
teamMember.id = doc.id;
|
||||
|
||||
teamMembers.push(teamMember);
|
||||
});
|
||||
|
||||
return teamMembers;
|
||||
}
|
||||
|
||||
async getTeamMembersByTeamId(teamId: string): Promise<TeamMember[]> {
|
||||
const q = query(
|
||||
collection(this.db, Collections.teamMembers),
|
||||
where("teamId", "==", teamId)
|
||||
);
|
||||
|
||||
const querySnapshot = await getDocs(q);
|
||||
|
||||
var teamMembers: TeamMember[] = [];
|
||||
|
||||
querySnapshot.forEach((doc) => {
|
||||
// doc.data() is never undefined for query doc snapshots
|
||||
// get the first one and just return...shouldn't be more
|
||||
let teamMember: TeamMember = doc.data() as TeamMember;
|
||||
teamMember.id = doc.id;
|
||||
|
||||
teamMembers.push(teamMember);
|
||||
});
|
||||
|
||||
return teamMembers;
|
||||
}
|
||||
|
||||
async updateTeamMember(teamMember: TeamMember) {
|
||||
const docRef = doc(this.db, Collections.teamMembers, teamMember.id);
|
||||
await setDoc(
|
||||
docRef,
|
||||
{ ...teamMember, lastUpdatedDate: serverTimestamp() },
|
||||
{ merge: true }
|
||||
);
|
||||
}
|
||||
|
||||
async createTeamInvite(teamMember: TeamMember) {
|
||||
if (teamMember.status == TeamMemberStatus.activated) {
|
||||
console.log('cannot invite this user, already active.')
|
||||
return
|
||||
}
|
||||
|
||||
// if a person was already invited, then update that record, otherwise create a new one
|
||||
const existingTeamMember = await this.getTeamMemberByEmailInvite(
|
||||
teamMember.teamId,
|
||||
teamMember.inviteEmailAddress
|
||||
);
|
||||
|
||||
if (!existingTeamMember) {
|
||||
const teamMemberRef = await addDoc(
|
||||
collection(this.db, Collections.teamMembers),
|
||||
{
|
||||
...teamMember,
|
||||
createdDate: serverTimestamp(),
|
||||
}
|
||||
);
|
||||
|
||||
return;
|
||||
}
|
||||
|
||||
// just update the current user to active since we are activating again
|
||||
await this.updateTeamMemberStatus(
|
||||
existingTeamMember.id,
|
||||
TeamMemberStatus.invited
|
||||
);
|
||||
}
|
||||
|
||||
async updateTeamMemberStatus(teamMemberId: string, status: TeamMemberStatus) {
|
||||
const docRef = doc(this.db, Collections.teamMembers, teamMemberId);
|
||||
await setDoc(
|
||||
docRef,
|
||||
{ status, lastUpdatedDate: serverTimestamp() },
|
||||
{ merge: true }
|
||||
);
|
||||
}
|
||||
|
||||
async getActiveOrInvitedTeamsbyUser(
|
||||
userId: string,
|
||||
email: string
|
||||
): Promise<Team[]> {
|
||||
// get all of the teammember entries for the user
|
||||
const userTeamMembers = await this.getTeamMembersByUserId(userId);
|
||||
const userTeamMembersByEmail = await this.getTeamMembersByEmailInvite(
|
||||
email
|
||||
);
|
||||
|
||||
// traverse through and get the teams for each
|
||||
var teams: Promise<Team>[];
|
||||
if (userTeamMembers) {
|
||||
teams = userTeamMembers.map(async (tm) => {
|
||||
if (tm.status != TeamMemberStatus.deleted) {
|
||||
let team = await this.getTeam(tm.teamId);
|
||||
return team;
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
var invitedToTeams: Promise<Team>[] = [];
|
||||
invitedToTeams = userTeamMembersByEmail
|
||||
.filter((tm) => tm.status == TeamMemberStatus.invited)
|
||||
.map(async (tm) => {
|
||||
let team = await this.getTeam(tm.teamId);
|
||||
return team;
|
||||
});
|
||||
|
||||
return Promise.all([...teams, ...invitedToTeams]);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user