Estoy tratando de crear una colección y un documento una vez que se crea un documento en Firebase.
Funciona bien en el emulador, pero cuando implemento mis funciones en el proyecto Firebase, no crean esa colección y documento.
Pero si creo campos en el documento existente (instantánea), funciona.
En la función obtengo datos de una API y los escribo en el nuevo documento (que no se está creando en este momento).
Función:
exports.quoteEndPoint = functions.firestore.document('users/{userID}/followedStocks/{stockID}') .onCreate((snap, context) => { const stock_id = context.params.stockID; const user_id = context.params.userID; var request = require('request'); var http = require('https'); const options = { "method": "GET", "hostname": "alpha-vantage.p.rapidapi.com", "port": null, "path": '/query?function=GLOBAL_QUOTE&symbol='+stock_id+'&datatype=json', "headers": { "x-rapidapi-host": "%API_HOST%", "x-rapidapi-key": "%API_KEY%", "useQueryString": true } }; const req = http.request(options, function(res){ const chunks = []; res.on('data', function(chunk){ chunks.push(chunk); }); res.on('end', function(){ const body = Buffer.concat(chunks); //console.log(body.toString()); const result = JSON.parse(body.toString()); console.log(result); //set values from json responso to Firebase return snap.ref.collection('quoteEndPoint').doc('data').set( { 'symbol': result['Global Quote']['01. symbol'], 'open': result['Global Quote']['02. open'], }, { merge: true }).then(()=>{ console.log('New quoteEndPoint fields for ' + stock_id + ' added to Firebase'); }) .catch(err => { console.log(err); }); }); }) .on('error',(err) => { console.log('Error: '+err.message); }); req.end(); return true; });Traté de hacer que la función: function() fuera asíncrona, pero no funcionó.
En el emulador, está creando y completando valores en la ruta correcta: /users/7nDGdHmZDuoDiJkxixgz/followedStocks/AMD/quoteEndPoint/data
¿Alguien puede ayudar?
Gracias
Lo más probable es que su problema provenga del hecho de que una llamada con request no devuelve una promesa, mientras que en Cloud Functions desencadenadas por eventos en segundo plano (como .onCreate() para Firestore) debe devolver una Promesa. Mire esta serie de videos oficiales para obtener más detalles: en particular, los 3 videos titulados "Learn JavaScript Promises".
Además, la request está en desuso.
Puede usar axios , que devuelve una Promesa, o node-fetch . Debe encadenar las promesas devueltas por las operaciones asíncronas, es decir, las llamadas asíncronas de axios y Firestore, como se ilustra en el siguiente código "esqueleto":
const functions = require('firebase-functions'); const admin = require('firebase-admin'); const axios = require('axios'); exports.quoteEndPoint = functions.firestore.document('users/{userID}/followedStocks/{stockID}') .onCreate((snap, context) => { const stock_id = context.params.stockID; const user_id = context.params.userID; return axios({ method: 'get', url: 'http://....' // ... See the doc }) .then(response => { // ... return snap.ref.collection('quoteEndPoint').doc('data').set(...); }); });