javascript - 使用 firestore Cloud Function 请求不同的端点

Question

我正在尝试拥有一个在不同端点上执行的灵活的云功能。

我原来的云函数如下所示:

const functions = require('firebase-functions')
const admin = require('firebase-admin')
const _ = require('lodash')
const { getObjectValues } = require('./helper-functions.js')
admin.initializeApp()

const json2csv = require('json2csv').parse
exports.csvJsonReport = functions.https.onRequest((request, response) => {
  const db = admin.firestore()
  const userAnswers = db.collection('/surveys/CNA/submissions')
  return (
    userAnswers
      .get()
      // eslint-disable-next-line promise/always-return
      .then(querySnapshot => {
        let surveySubmissions = []
        querySnapshot.forEach(doc => {
          const userSubmission = doc.data()
          surveySubmissions.push({
            ..._.mapValues(userSubmission.answers, getObjectValues), // format answers
            ...userSubmission.anonUser,
          })
        })

        const csv = json2csv(surveySubmissions)
        response.setHeader('Content-disposition', 'attachment; filename=cna.csv')
        response.set('Content-Type', 'text/csv')
        response.status(200).send(csv)
      })
      .catch(error => {
        console.log(error)
      })
  )
})

我正在尝试扩展此功能以适用于多个集合。在上面的函数中，我的目标是 CNA收藏。所以而不是 db.collection('/surveys/CNA/submissions/')我希望它是 db.collection('/surveys/:surveyId/submissions/')

以下是我尝试扩展我的原始云功能的尝试:

const functions = require('firebase-functions')
const admin = require('firebase-admin')

const express = require('express')
const bodyParser = require('body-parser')

const _ = require('lodash')
const { getObjectValues } = require('./helper-functions.js')

admin.initializeApp(functions.config().firebase)
const db = admin.firestore()

const app = express()
const main = express()

main.use('/api/v1', app)
main.use(bodyParser.json())

exports.webApi = functions.https.onRequest(main)

app.get('surveys/:id', (request, response) => {
  const surveyId = request.query
  const userAnswers = db.collection(`/survey/${surveyId}/submissions`)
  return (
    userAnswers
      .get()
      // eslint-disable-next-line promise/always-return
      .then(querySnapshot => {
        let surveySubmissions = []
        querySnapshot.forEach(doc => {
          const userSubmission = doc.data()
          surveySubmissions.push({
            ..._.mapValues(userSubmission.answers, getObjectValues), // format answers
            ...userSubmission.anonUser,
          })
        })

        const csv = json2csv(surveySubmissions)
        response.setHeader('Content-disposition', 'attachment; filename=cna.csv')
        response.set('Content-Type', 'text/csv')
        response.status(200).send(csv)
      })
      .catch(error => {
        console.log(error)
      })
  )
})

当我请求我的端点时:myapp.firebaseapp.com/api/v1/surveys/CNA Cannot GET /api/v1/surveys/CNA显示在我的浏览器中。

有人能给我指出正确的方向吗？

Answer 1

要创建 GET/survey/:id 端点以便按 ID 获取提交，请在新的云函数中使用以下代码:

app.get('surveys/:id', (request, response) => {
  const surveyId = request.params.id
  const userAnswers = db.collection(`/survey/${surveyId}/submissions`)

请告诉我它是否适合您。