Calling a query inside a mutation

[spidertwin2]

Hello,

getBlogs - query MongoDB by userId, return all documents linked to userId.
updateUsersBlogs - accept an array of userIds. Call getBlogs for each userId. Update users in Postgres with latest blogs.

I don't know how to call getBlogs inside updateUsersBlogs.

getBlogs.ts

export default resolver.pipe(resolver.authorize(), async (userId: string) => {
  const { db } = await mongodbConnect()

  try {
    const blogs = await db.collection("blog").find({ _id: userId }).toArray()
    return blogs
  } catch (error) {
    console.log("Error retrieving blogs: ", error)
  }
})

getUsersBlogs.ts

export default resolver.pipe(resolver.authorize(), async (userIds: string[], ctx) => {
  try {
   userIds.map((userId) => {

      // for each userId, how should I call getBlogs here?

    ... perform update in postgres
    })
  } catch (error) {
    console.log("Error updating users: ", error)
  }
})

Thanks 🌳

[zackshen]

hi @spidertwin2 , the code like below,

import getBlogs from './getBlogs'

export default resolver.pipe(resolver.authorize(), async (userIds: string[], ctx) => {
  try {
     const userBlogs = await Promise.all(userIds.map((userId) => getBlogs(userId).then(blogs => ({ userId, blogs}))))
     return userBlogs
  } catch (error) {
    console.log("Error updating users: ", error)
  }
})

[spidertwin2]

太好了! 谢谢
🪔