feat: add function for pins after user updates

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) {
@@ -142,6 +144,8 @@ async function updatePostsCountry(userId: string, country: IUserDB['country']) {
   return false
 }
 
+// update _lastActive for any action --> content creation/editing
+
 async function deleteMapPin(_id: string) {
   const pin = await db.collection(DB_ENDPOINTS.mappins).doc(_id).get()
 

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`)
+}