Comment utiliser Geofirex dans les fonctions Google Cloud

le problème a été résolu comme suit:

const query = geoFire.collection('places', queryRef).within(center, radius, field);
const nearbyPlaces = await get(query); // await query.pipe(operators.first()).toPromise();

Puis

exports.geofenceUserNotifications = functions.https.onRequest(async (req, res) => {

  //setPoint (id, field, lat, lng)
  geoFire.collection('users').setPoint(uid, field, latitude, longitude).then(result => {
    res.end('User geo point is updated!');
  }).catch( err => {
      res.end('error when update user geo point');
      return;
  });
});

Et geoFireX fonctionne bien.

mais maintenant je suis confronté à un autre problème avec la requête geoFireX. J'ai essayé d'obtenir des éléments à proximité, mais geoFireX renvoie Observable et cela ne fonctionne pas dans les fonctions du cloud.

J'ai essayé d'utiliser get () par geoFireX:

const functions = require('firebase-functions');
const admin = require('firebase-admin');
admin.initializeApp();
admin.firestore().settings({timestampsInSnapshots: true});

// Init GeoFireX
const geofirex = require('geofirex');// <-- Use require Instead of import geofirex
import { get } from 'geofirex';
const geoFire = geofirex.init(admin); // <-- admin not admin.app()

mais malheureusement cela ne fonctionne pas. et j'obtiens l'erreur suivante:

Erreur: l'argument "onNext" n'est pas une fonction valide. à Validator. (fonction anonyme) .values ​​[as isFunction] (/srv/node_modules/@google-cloud/firestore/build/src/validate.js:99:27) à Query.onSnapshot (/srv/node_modules/@google-cloud/firestore/build/src/reference.js:1524:25) à Observable._subscribe (/srv/node_modules/geofirex/dist/index.cjs.js:1597:33) à Observable._trySubscribe (/srv/node_modules/rxjs/internal/Observable.js:44:25) à Observable.subscribe (/srv/node_modules/rxjs/internal/Observable.js:30:22) à MapOperator.call (/srv/node_modules/rxjs/internal/operators/map.js:32:23) à Observable.subscribe (/srv/node_modules/rxjs/internal/Observable.js:25:31) à Object.subscribeToResult (/srv/node_modules/rxjs/internal/util/subscribeToResult.js:12:23) à CombineLatestSubscriber._complete (/srv/node_modules/rxjs/internal/observable/combineLatest.js:76:46) sur CombineLatestSubscriber.Subscriber.complete (/srv/node_modules/rxjs/internal/Subscriber.js:78:18)

- C'est peut-être la solution complète -

Deux étapes: -

1. Ajout de Geopoint et Geohashes dans Firestore
2. Requête avec des données de géopoint

Solution de l'étape 1: Pour cela, vous devez ajouter firebase-admin sdk et configurer le geofirex avec geofirex.init (admin). Ex:

router.get('/expert', (req, res, next) => {
    const radius = req.query.radius
    const lat = req.query.lat
    const lng = req.query.lng
    const field = 'position'

    geo.collection('ex-pending').within(geo.point(lat, lng), radius, field).subscribe(snap => {
        res.status(200).send(snap)
    })

})

maintenant vous pouvez stocker vos Geopoint et Geohashes comme ceci: -

import * as firebase from 'firebase';
var firebaseConfig = {
    apiKey: API_KEY_HERE,
    authDomain: DOMAIN_HERE,
    databaseURL: FIREBASE_REALTIME_DATABASE_URL,
    projectId: PROJECT_ID,
    storageBucket: STORAGE_BUCKET,
    messagingSenderId: MESSAGING_SENDER_ID,
    appId: FIREBASE_APP_ID,
    measurementId: MEASUREMENT_ID
  };
firebase.initializeApp(firebaseConfig);

import geofirex = require('geofirex');// <-- Now, use import Instead of require('geofirex')
const geo = geofirex.init(firebase.app()); // <-- firebase or, firebase.app()

Stockez ceci dans la base de données en utilisant Firestore.

Solution de l'étape 2: Pour cela, vous devez utiliser firebase web sdk pour configurer le geofirex. Sinon, vous ne pourrez pas interroger votre base de données Firestore! Ex:

const point = geo.point(40.1, -119.1);

Vous pouvez obtenir firebaseConfig à partir de la configuration du sdk Web de la console Firebase. Copiez et collez cela! ;) Vous pouvez maintenant interroger votre géopoint Firestore comme ceci: -

const geofirex = require('geofirex');// <-- Use require Instead of import geofirex
import { get } from 'geofirex';
const geo = geofirex.init(admin); // <-- admin not admin.app()

C'est tout! : D