feat: add function for pins after user updates

functions/src/discussionUpdates/index.ts

@@ -1,10 +1,10 @@
-import { firestore } from 'firebase-admin'
 import * as functions from 'firebase-functions'
 
 import { db } from '../Firebase/firestoreDB'
 import { DB_ENDPOINTS } from '../models'
 
-import type { IUserDB, IDiscussion } from '../models'
+import type { firestore } from 'firebase-admin'
+import type { IDiscussion, IUserDB } from '../models'
 
 /*********************************************************************
  * Side-effects to be carried out on various question updates, namely:
@@ -21,7 +21,6 @@ export const handleDiscussionUpdate = functions
 async function updateDocument(
   change: functions.Change<firestore.QueryDocumentSnapshot>,
 ) {
-  // add new comments to user.stats.userCreatedComments
   const addedComments = getAddedComments(change)
   for (const addedComment of addedComments) {
     const commentId = addedComment._id
@@ -31,10 +30,12 @@ async function updateDocument(
       .get()
     const user = userSnapshot.docs[0].data() as IUserDB
 
-    let userCreatedComments = user.stats?.userCreatedComments ?? {}
+    const _lastActive = Date.now().toString(16)
+    const userCreatedComments = user.stats?.userCreatedComments ?? {}
     userCreatedComments[commentId] = addedComment.parentCommentId
 
     await userSnapshot.docs[0].ref.update({
+      _lastActive,
       'stats.userCreatedComments': userCreatedComments,
     })
   }
@@ -49,10 +50,12 @@ async function updateDocument(
       .get()
     const user = userSnapshot.docs[0].data() as IUserDB
 
-    let userCreatedComments = user.stats?.userCreatedComments ?? {}
+    const _lastActive = Date.now().toString(16)
+    const userCreatedComments = user.stats?.userCreatedComments ?? {}
     delete userCreatedComments[commentId]
 
     await userSnapshot.docs[0].ref.update({
+      _lastActive,
       'stats.userCreatedComments': userCreatedComments,
     })
   }

functions/src/emulator/seed/users-create.ts

@@ -1,8 +1,9 @@
 import { MOCK_AUTH_USERS } from 'oa-shared/mocks/auth'
-import type { IUserDB } from '../../models'
+
 import { firebaseAuth } from '../../Firebase/auth'
 import { setDoc } from '../../Firebase/firestoreDB'
-import { IModerationStatus } from 'oa-shared'
+
+import type { IUserDB } from '../../models'
 
 /**
  * Create auth users to allow sign-in on firebase emulators
@@ -43,11 +44,10 @@ export async function seedUsersCreate() {
       _deleted: false,
       displayName: user.label,
       userName: uid,
-      moderation: IModerationStatus.AWAITING_MODERATION,
       notifications: [],
       userRoles: roles,
       links: [],
-      ['profileType' as any]: 'member', // include pp profile field
+      profileType: 'member',
       coverImages: [],
       verified: true,
     }

functions/src/questionUpdates/index.ts

@@ -1,10 +1,10 @@
-import { firestore } from 'firebase-admin'
 import * as functions from 'firebase-functions'
 
 import { db } from '../Firebase/firestoreDB'
 import { DB_ENDPOINTS } from '../models'
 
-import type { IUserDB, IQuestionDB } from '../models'
+import type { firestore } from 'firebase-admin'
+import type { IQuestionDB, IUserDB } from '../models'
 
 /*********************************************************************
  * Side-effects to be carried out on various question updates, namely:
@@ -41,10 +41,12 @@ async function updateDocument(docSnapshot: firestore.QueryDocumentSnapshot) {
     .get()
   const user = userSnapshot.docs[0].data() as IUserDB
 
-  let userCreatedQuestions = user.stats?.userCreatedQuestions ?? {}
+  const _lastActive = Date.now().toString(16)
+  const userCreatedQuestions = user.stats?.userCreatedQuestions ?? {}
   userCreatedQuestions[question_id] = question.moderation
 
   await userSnapshot.docs[0].ref.update({
+    _lastActive,
     'stats.userCreatedQuestions': userCreatedQuestions,
   })
 }
@@ -59,10 +61,12 @@ async function deleteDocument(docSnapshot: firestore.QueryDocumentSnapshot) {
     .get()
   const user = userSnapshot.docs[0].data() as IUserDB
 
-  let userCreatedQuestions = user.stats?.userCreatedQuestions ?? {}
+  const _lastActive = Date.now().toString(16)
+  const userCreatedQuestions = user.stats?.userCreatedQuestions ?? {}
   delete userCreatedQuestions[question_id]
 
   await userSnapshot.docs[0].ref.update({
+    _lastActive,
     'stats.userCreatedQuestions': userCreatedQuestions,
   })
 }

functions/src/userUpdates/index.ts

@@ -4,6 +4,7 @@ import { db } from '../Firebase/firestoreDB'
 import { DB_ENDPOINTS } from '../models'
 import { backupUser } from './backupUser'
 import { updateDiscussionComments } from './updateDiscussionComments'
+import { updateMapPins } from './updateMapPins'
 
 import type { IDBDocChange, IUserDB } from '../models'
 
@@ -17,12 +18,12 @@ import type { IDBDocChange, IUserDB } from '../models'
 export const handleUserUpdates = functions
   .runWith({ memory: '512MB' })
   .firestore.document(`${DB_ENDPOINTS.users}/{id}`)
-  .onUpdate(async (change, context) => {
+  .onUpdate(async (change, _) => {
     await backupUser(change)
     await updateDocuments(change)
   })
 
-const isUserCountryDifferent = (prevInfo, info) => {
+const isUserCountryDifferent = (prevInfo: IUserDB, info: IUserDB) => {
   const prevCountryCode = prevInfo.location?.countryCode
   const newCountryCode = info.location?.countryCode
   const prevCountry = prevInfo.country
@@ -48,6 +49,7 @@ async function updateDocuments(change: IDBDocChange) {
   }
 
   await updateDiscussionComments(prevInfo, info)
+  await updateMapPins(prevInfo, info)
 
   const didDelete = prevDeleted !== deleted && deleted
   if (didDelete) {

functions/src/userUpdates/updateDiscussionComments.ts

@@ -1,27 +1,28 @@
 import { DB_ENDPOINTS } from 'oa-shared'
 
 import { db } from '../Firebase/firestoreDB'
-import { hasKeyDetailsChanged } from './hasKeyDetailsChanged'
+import { getCreatorImage, hasDetailsForCommentsChanged } from './utils'
 
 import type { IDiscussion, IUserDB } from '../models'
 
 export const updateDiscussionComments = async (
   prevUser: IUserDB,
   user: IUserDB,
 ) => {
-  if (!hasKeyDetailsChanged(prevUser, user)) return
+  if (!hasDetailsForCommentsChanged(prevUser, user)) return
 
   const snapshot = await db
     .collection(DB_ENDPOINTS.discussions)
     .where('contributorIds', 'array-contains', user._id)
     .get()
 
   if (!snapshot.empty) {
-    const { _id, badges, userImage, location } = user
+    const { _id, badges, country, userImage, location } = user
     const creatorImage = getCreatorImage(userImage)
+    const creatorCountry = location?.countryCode || country || ''
 
     const userDetails = {
-      creatorCountry: location?.countryCode || '',
+      creatorCountry,
       creatorImage,
       isUserVerified: !!badges?.verified,
       isUserSupporter: !!badges?.supporter,
@@ -47,10 +48,3 @@ export const updateDiscussionComments = async (
     return console.log(`Updated ${updatedCommentCount} discussion comments`)
   }
 }
-
-const getCreatorImage = (userImage: IUserDB['userImage']) => {
-  if (userImage && userImage.downloadUrl) {
-    return userImage.downloadUrl
-  }
-  return null
-}

functions/src/userUpdates/updateMapPins.ts

@@ -0,0 +1,62 @@
+import { DB_ENDPOINTS } from 'oa-shared'
+
+import { db } from '../Firebase/firestoreDB'
+import {
+  getCreatorImage,
+  getFirstCoverImage,
+  hasDetailsForMapPinChanged,
+} from './utils'
+
+import type { IUserDB } from '../models'
+
+export const updateMapPins = async (prevUser: IUserDB, user: IUserDB) => {
+  if (!hasDetailsForMapPinChanged(prevUser, user)) {
+    return
+  }
+
+  const snapshot = await db
+    .collection(DB_ENDPOINTS.mappins)
+    .where('_id', '==', user._id)
+    .get()
+
+  if (snapshot.empty) {
+    return
+  }
+
+  const {
+    _id,
+    _lastActive,
+    about,
+    badges,
+    country,
+    coverImages,
+    displayName,
+    isContactableByPublic,
+    profileType,
+    subType,
+    userImage,
+    location,
+  } = user
+  const creatorImage = getCreatorImage(userImage)
+  const coverImage = getFirstCoverImage(coverImages)
+  const countryCode = location?.countryCode || country || ''
+
+  const creator = {
+    _lastActive,
+    about,
+    badges,
+    countryCode,
+    coverImage,
+    displayName,
+    isContactableByPublic,
+    profileType,
+    subType,
+    userImage: creatorImage,
+  }
+
+  // Only one expected
+  for (const doc of snapshot.docs) {
+    await doc.ref.update({ creator })
+  }
+  return console.log(`Updated ${_id}'s mapPin`)
+}